最后一车 同步新货主客户端

performance-web/src/main/java/com/clx/performance/listener/OrderChildDtsListener.java

 package com.clx.performance.listener;
 
+import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
 import com.clx.open.sdk.callback.OpenCallBackClient;
+import com.clx.open.sdk.callback.message.OrderChildLastOneMessage;
 import com.clx.open.sdk.callback.message.OrderChildMessage;
 import com.clx.open.sdk.callback.message.OrderChildSyncMessage;
 import com.clx.open.sdk.enums.ResultStatusEnum;
@@ -113,7 +115,32 @@ public class OrderChildDtsListener  {
             Result<?> result = openCallBackClient.encryptPost(data,after.topic());
             log.info("运单信息同步，运单编号:{},响应结果:{}",after.getChildNo(),JSON.toJSONString(result));
             syncLastTruck(orderInfoFeign,after);
+            return;
+        }
 
+        if (Objects.equals(orderInfoFeign.getOrderSource(), SyncPlatformEnum.Source.NEW_OWNER_CLIENT.getCode())) {
+            if(Objects.equals(com.clx.open.sdk.enums.OrderChildEnum.Status.COMMON_CANCEL.getCode(),after.getStatus()) ||
+                    (after.getStatus() >= OrderChildEnum.Status.ARRIVE_RECEIVE.getCode()  && after.getStatus() <= OrderChildEnum.Status.COMPLETE.getCode())){
+                OrderChild child;
+                if(Objects.equals(orderInfoFeign.getOrderStatus(), OrderEnum.Status.COMPLETED.getCode()) ||
+                        Objects.equals(orderInfoFeign.getOrderStatus(), OrderEnum.Status.SUCCESS.getCode())) { //订单变成已完成 || 已完结
+                    OrderEnum.Status byCode = OrderEnum.Status.getByCode(orderInfoFeign.getOrderStatus());
+                    log.info("订单号:{},运单号：{},订单状态：{},开始查询最后一车运单===========" ,orderInfoFeign.getOrderNo(),after.getChildNo(),
+                            Objects.nonNull(byCode)?byCode.getName():"未知状态");
+                    child = lastTruckService.getOrderCompleteLastTruck(after.getOrderNo());
+                }else{  // 订单除  已完成 || 已完结  外的其他状态
+                    child = lastTruckService.getLastTruckChild(after.getOrderNo());
+                }
+                if (Objects.nonNull(child)) {
+                    log.info("开始同步新货主客户端最后一车的运单，运单编号:{}", child.getChildNo());
+                    OpenCallBackClient openCallBackClient = thirdAppConfig.getOpenCallBackClient(SyncPlatformEnum.Source.NEW_OWNER_CLIENT.getCode().toString());
+                    OrderChildLastOneMessage message = new OrderChildLastOneMessage();
+                    message.setChildNo(child.getChildNo());
+                    Result<?> result = openCallBackClient.encryptPost(JSONUtil.parse(message).toString(), message.topic());
+                    log.info("结束同步新货主客户端最后一车的运单，运单编号:{}，响应结果:{}", child.getChildNo(), JSONUtil.parse(result));
+                }
+
+            }
         }
     }
 
@@ -134,6 +161,7 @@ public class OrderChildDtsListener  {
             if(Objects.nonNull(child)){
                 lastTruckService.syncLastTruckChild(child);
             }
+
         }
     }