消息新增发送体

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/service/CommonService.java

@@ -270,8 +270,8 @@ public class CommonService {
                     .setUserInfos(userInfos)
                     .setCreateBy(LoginUserHolder.getUserId());
             log.info("发起物流托运-[贸易订单物流托运确认/承运订单分包托运确认]-创建人：{}", JSON.toJSONString(msg));
-
-            sendMessageLogistics(checkUnit, carriageUnit, map);
+            streamBridge.send("sckw-message", JSON.toJSONString(msg));
+//            sendMessageLogistics(checkUnit, carriageUnit, map);
         }
 
     }
@@ -298,6 +298,7 @@ public class CommonService {
                 .setUserInfos(userInfoList)
                 .setCreateBy(LoginUserHolder.getUserId());
         log.info("发起物流托运-[贸易订单物流托运确认/承运订单分包托运确认]-[承运方]-业务联系人：{}", JSON.toJSONString(sckwMessage));
+        streamBridge.send("sckw-message", JSON.toJSONString(sckwMessage));
 
         //给业务联系人发消息[托运方]
         List<UserInfo> list = new ArrayList<>();
@@ -363,7 +364,7 @@ public class CommonService {
                     .setUserInfos(userInfos)
                     .setCreateBy(LoginUserHolder.getUserId());
             log.info("托运订单/承运订单自建物流订单-创建人：{}", JSON.toJSONString(msg));
-
+            streamBridge.send("sckw-message", JSON.toJSONString(msg));
             sendMessageNewLogisticsOrder(checkUnit, map,MessageEnum.NEW_LOGISTICS_ORDER,consignLogisticsOrderUrl);
             sendMessageNewLogisticsOrder(carriageUnit, map,MessageEnum.NEW_CARRIAGE_ORDER,carriageLogisticsOrderUrl);
         }
@@ -393,6 +394,7 @@ public class CommonService {
                 .setUserInfos(userInfoList)
                 .setCreateBy(LoginUserHolder.getUserId());
         log.info("托运订单/承运订单自建物流订单-业务联系人：{}", JSON.toJSONString(sckwMessage));
+        streamBridge.send("sckw-message", JSON.toJSONString(sckwMessage));
 
     }
 
@@ -478,8 +480,8 @@ public class CommonService {
                     .setUserInfos(userInfos)
                     .setCreateBy(LoginUserHolder.getUserId());
             log.info(MessageEnum.getDesc(consignMessageEnum)+"-创建人：{}", JSON.toJSONString(msg));
-
-            sendMessagePublicLogistics(consignUnit, carriageUnit, map,consignMessageEnum);
+            streamBridge.send("sckw-message", JSON.toJSONString(msg));
+//            sendMessagePublicLogistics(consignUnit, carriageUnit, map,consignMessageEnum);
         }
     }
 
@@ -499,6 +501,8 @@ public class CommonService {
                 .setUserInfos(userInfoList)
                 .setCreateBy(LoginUserHolder.getUserId());
         log.info(MessageEnum.getDesc(consignMessageEnum)+"-[承运方]-业务联系人：{}", JSON.toJSONString(sckwMessage));
+        streamBridge.send("sckw-message", JSON.toJSONString(sckwMessage));
+
 
         //给业务联系人发消息[托运方]
         List<UserInfo> list = new ArrayList<>();