1.报检信息推送时增加字段traceId 便于排查问题

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-api/src/main/java/com/yeejoin/amos/boot/module/jyjc/api/model/InspectionApplicationPushData.java

@@ -57,5 +57,7 @@ public class InspectionApplicationPushData implements Serializable {
 
     private List<InspectionEquipData> inspectionEquips;
 
+    private String traceId;
+
 }
 

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-biz/src/main/java/com/yeejoin/amos/boot/module/jyjc/biz/event/listener/InspectionApplicationPushEventListener.java

@@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Sequence;
 import com.yeejoin.amos.boot.biz.common.entity.TzsBaseEntity;
 import com.yeejoin.amos.boot.module.jyjc.api.entity.JyjcInspectionApplicationEquip;
 import com.yeejoin.amos.boot.module.jyjc.api.entity.JyjcInspectionApplicationPushLog;
@@ -90,6 +91,9 @@ public class InspectionApplicationPushEventListener implements ApplicationListen
     @Autowired
     KafkaProducer kafkaProducer;
 
+    @Autowired
+    Sequence sequence;
+
     /**
      * 报检推送主题， 第一位为接收单位标识
      */
@@ -131,24 +135,27 @@ public class InspectionApplicationPushEventListener implements ApplicationListen
     }
 
     private JyjcInspectionApplicationPushLog createPushData(JyjcInspectionApplicationModel applicationModel) {
+        long id = sequence.nextId();
         JyjcInspectionApplicationPushLog pushLog = new JyjcInspectionApplicationPushLog();
         pushLog.setInspectionUnitCode(applicationModel.getInspectionUnitCode());
         pushLog.setApplicationSeq(applicationModel.getSequenceNbr());
         // 初始状态
+        pushLog.setSequenceNbr(id);
         pushLog.setPushStatus("1");
-        pushLog.setPushData(this.buildData(applicationModel));
+        pushLog.setPushData(this.buildData(id, applicationModel));
         pushLog.setRecDate(new Date());
         pushLogService.save(pushLog);
         return pushLog;
     }
 
-    private String buildData(JyjcInspectionApplicationModel applicationModel) {
+    private String buildData(long traceId, JyjcInspectionApplicationModel applicationModel) {
         InspectionApplicationPushData pushData = new InspectionApplicationPushData();
         BeanUtil.copyProperties(applicationModel, pushData);
         // 监管机构
         pushData.setSuperviseOrgName(this.getSuperviseNameByCode(applicationModel.getApplicationUnitCode()));
         // 报检的设备信息
         pushData.setInspectionEquips(this.buildInspectionEquipInfo(applicationModel.getSequenceNbr()));
+        pushData.setTraceId(traceId + "");
         return JSONObject.toJSONString(pushData);
     }