添加rabbitmq日志类

src/main/java/com/usky/dxtop/MysqlGenerator.java

@@ -43,7 +43,7 @@
 //        strategy.setColumnNaming(NamingStrategy.underline_to_camel);
 //        // strategy.setTablePrefix("t_"); // 表名前缀
 //        strategy.setEntityLombokModel(true); //使用lombok
-//        strategy.setInclude("sys_file");  // 逆向工程使用的表   如果要生成多个,这里可以传入String[]
+//        strategy.setInclude("msg_log");  // 逆向工程使用的表   如果要生成多个,这里可以传入String[]
 //        mpg.setStrategy(strategy);
 //
 //        //5、执行

src/main/java/com/usky/dxtop/mapper/MsgLogMapper.java

@@ -0,0 +1,16 @@
+package com.usky.dxtop.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.usky.dxtop.model.MsgLog;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author yq
+ * @since 2021-10-13
+ */
+public interface MsgLogMapper extends BaseMapper<MsgLog> {
+
+}

src/main/java/com/usky/dxtop/model/MsgLog.java

@@ -0,0 +1,81 @@
+package com.usky.dxtop.model;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author yq
+ * @since 2021-10-13
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class MsgLog implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     *  
+     */
+    private Long id;
+
+    /**
+     * 消息体
+     */
+    private String msg;
+
+    /**
+     * 交换机
+     */
+    private String exchange;
+
+    /**
+     * 路由键
+     */
+    private String routingKey;
+
+    /**
+     * 重试次数
+     */
+    private Integer tryCount;
+
+    /**
+     * 下一次重试时间
+     */
+    private LocalDateTime nextTryTime;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updateTime;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 0未删除1已删除
+     */
+    private Integer delFlag;
+
+
+}

src/main/java/com/usky/dxtop/service/MsgLogService.java

@@ -0,0 +1,16 @@
+package com.usky.dxtop.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.usky.dxtop.model.MsgLog;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author yq
+ * @since 2021-10-13
+ */
+public interface MsgLogService extends IService<MsgLog> {
+
+}

src/main/java/com/usky/dxtop/service/impl/MsgLogServiceImpl.java

@@ -0,0 +1,20 @@
+package com.usky.dxtop.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.usky.dxtop.mapper.MsgLogMapper;
+import com.usky.dxtop.model.MsgLog;
+import com.usky.dxtop.service.MsgLogService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author yq
+ * @since 2021-10-13
+ */
+@Service
+public class MsgLogServiceImpl extends ServiceImpl<MsgLogMapper, MsgLog> implements MsgLogService {
+
+}

src/main/java/com/usky/dxtop/service/job/CardJob.java

@@ -2,7 +2,9 @@ package com.usky.dxtop.service.job;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.usky.dxtop.model.Charge;
 import com.usky.dxtop.model.Order;
+import com.usky.dxtop.service.ChargeService;
 import com.usky.dxtop.service.OrderService;
 import com.usky.dxtop.service.emun.OrderStatus;
 import lombok.extern.slf4j.Slf4j;
@@ -26,6 +28,9 @@ public class CardJob {
     @Autowired
     private OrderService orderService;
 
+    @Autowired
+    private ChargeService chargeService;
+
     @Scheduled(cron = "0 */1 * * * ?")
     public void execute(){
         LambdaQueryWrapper<Order> queryWrapper = Wrappers.lambdaQuery();
@@ -34,9 +39,13 @@ public class CardJob {
         List<Order> list = orderService.list(queryWrapper);
         for (Order order:list) {
             try {
-                //TODO 卡充值记录查询api
-                order.setOrderFlag(OrderStatus.COMPLETE.getCode());
-                orderService.updateById(order);
+                Charge one = chargeService.one(order.getId());
+                if (null == one){
+                    cartError(order);
+                }else {
+                    order.setOrderFlag(OrderStatus.COMPLETE.getCode());
+                    orderService.updateById(order);
+                }
             }catch (Exception e){
                 log.error("---orderJob---异常"+e.getMessage());
             }

src/main/resources/mapper/MsgLogMapper.xml

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.usky.dxtop.mapper.MsgLogMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.usky.dxtop.model.MsgLog">
+        <id column="id" property="id" />
+        <result column="msg" property="msg" />
+        <result column="exchange" property="exchange" />
+        <result column="routing_key" property="routingKey" />
+        <result column="try_count" property="tryCount" />
+        <result column="next_try_time" property="nextTryTime" />
+        <result column="create_time" property="createTime" />
+        <result column="update_by" property="updateBy" />
+        <result column="update_time" property="updateTime" />
+        <result column="remark" property="remark" />
+        <result column="del_flag" property="delFlag" />
+    </resultMap>
+
+</mapper>