Browse Source

feat(all): 修改志邦节点回传逻辑

dist.1.3.0
zhaoqiaobo 8 months ago
parent
commit
da6e56af8b
  1. 23
      blade-service/logpm-factory-data/logpm-factory-data-zbom/src/main/java/com/logpm/factorydata/zbom/mq/ZbomNodeDataPushListener.java

23
blade-service/logpm-factory-data/logpm-factory-data-zbom/src/main/java/com/logpm/factorydata/zbom/mq/ZbomNodeDataPushListener.java

@ -131,7 +131,7 @@ public class ZbomNodeDataPushListener {
.eq(ZbFactoryNodePushEntity::getDepartCode, value.getDepartCode()) .eq(ZbFactoryNodePushEntity::getDepartCode, value.getDepartCode())
); );
// 已经推送过了就不再推了 // 已经推送过了就不再推了
if(CollUtil.isNotEmpty(list)){ if (CollUtil.isNotEmpty(list)) {
return; return;
} }
} }
@ -156,10 +156,11 @@ public class ZbomNodeDataPushListener {
Map<String, SendMsg> sendMsgMap = new HashMap<>(); Map<String, SendMsg> sendMsgMap = new HashMap<>();
// 构建提交参数 // 构建提交参数
buildParam(entries, node, workNodeEnums, orders, noSignNumberMap, nodeOrderMap, nodeConfirmLsit, sendMsgMap); buildParam(entries, node, workNodeEnums, orders, noSignNumberMap, nodeOrderMap, nodeConfirmLsit, sendMsgMap);
try { if (CollUtil.isNotEmpty(nodeConfirmLsit)) {
// 推送给志邦 for (NodeConfirmParamDTO nodeConfirmParam : nodeConfirmLsit) {
if (CollUtil.isNotEmpty(nodeConfirmLsit)) { log.info("zb节点数据推送NodeConfirmParamDTO:{}", JSONUtil.toJsonStr(nodeConfirmParam));
for (NodeConfirmParamDTO nodeConfirmParam : nodeConfirmLsit) { try {
// 推送给志邦
String key = nodeConfirmParam.getDepartCode() + nodeConfirmParam.getPlatformOrderCode(); String key = nodeConfirmParam.getDepartCode() + nodeConfirmParam.getPlatformOrderCode();
String body = JSONUtil.toJsonStr(nodeConfirmParam); String body = JSONUtil.toJsonStr(nodeConfirmParam);
String result = null; String result = null;
@ -224,14 +225,14 @@ public class ZbomNodeDataPushListener {
} }
} }
} }
} catch (Exception e) {
// 处理推送不成功的异常情况
log.error("zb节点推送数据异常:{}", e);
// 保存日志
e.printStackTrace();
} }
} }
} catch (Exception e) {
// 处理推送不成功的异常情况
log.error("zb节点推送数据异常:{}", e);
// 保存日志
e.printStackTrace();
} }
} }
} }

Loading…
Cancel
Save