修改推送运单预计时间改为批量接口

performance-web/src/main/java/com/clx/performance/job/PushOrderChildExpectTimeJob.java

@@ -2,6 +2,7 @@ package com.clx.performance.job;
 
 import com.alibaba.fastjson.JSON;
 import com.clx.open.sdk.callback.OpenCallBackClient;
+import com.clx.open.sdk.callback.dto.OrderChildExpectTimeDTO;
 import com.clx.open.sdk.callback.message.OrderChildExpectTimeMessage;
 import com.clx.order.enums.SyncPlatformEnum;
 import com.clx.order.feign.OrderFeign;
@@ -27,9 +28,7 @@ import org.apache.commons.lang.exception.ExceptionUtils;
 import org.springframework.stereotype.Component;
 
 import java.time.LocalDateTime;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
+import java.util.*;
 import java.util.stream.Collectors;
 
 @Slf4j
@@ -72,6 +71,7 @@ public class PushOrderChildExpectTimeJob {
                 return;
             }
             Map<String, Integer> orderSourceMap = mapResult.getData();
+            List<OrderChildExpectTimeDTO> syncExpectList = new ArrayList<>();
             list.forEach(item->{
                 //交易平台数媒宝同步运单同步实时预计时间
                 if(Objects.equals(orderSourceMap.get(item.getOrderNo()),SyncPlatformEnum.Source.TRADE_PLATFORM.getCode())){
@@ -89,26 +89,29 @@ public class PushOrderChildExpectTimeJob {
                         return;
                     }
 
-                    OrderChildExpectTimeMessage message = new OrderChildExpectTimeMessage();
-                    message.setOrderNo(item.getOrderNo());
-                    message.setChildNo(item.getChildNo());
-                    message.setStatus(item.getStatus());
+                    OrderChildExpectTimeDTO dto = new OrderChildExpectTimeDTO();
+                    dto.setOrderNo(item.getOrderNo());
+                    dto.setChildNo(item.getChildNo());
+                    dto.setStatus(item.getStatus());
 
                     if(item.getStatus() < OrderChildEnum.Status.ARRIVE_SEND.getCode()){  //到达货源地之前
-                        message.setExpectArriveTime(orderChildExpect.getExpectArriveTime());
+                        dto.setExpectArriveTime(orderChildExpect.getExpectArriveTime());
                     }else{    //到达货源地之后 && 到达目的地之前
-                        message.setExpectArriveTime(orderChildExpect.getExpectReceiveTime());
+                        dto.setExpectArriveTime(orderChildExpect.getExpectReceiveTime());
                     }
-                    String data = JSON.toJSONString(message);
-
-                    OpenCallBackClient openCallBackClient = thirdAppConfig.getOpenCallBackClient(
-                            SyncPlatformEnum.Source.TRADE_PLATFORM.getCode().toString());
-                    log.info("运单预计时间信息同步开始，请求参数:{}",data);
-                    Result<?> result = openCallBackClient.encryptPost(data,message.topic());
-                    log.info("运单预计时间信息同步，响应结果:{}",JSON.toJSONString(result));
+                    syncExpectList.add(dto);
                 }
-
             });
+            if(CollectionUtils.isNotEmpty(syncExpectList)){
+                OrderChildExpectTimeMessage message = new OrderChildExpectTimeMessage();
+                message.setList(syncExpectList);
+                String data = JSON.toJSONString(message);
+                OpenCallBackClient openCallBackClient = thirdAppConfig.getOpenCallBackClient(
+                        SyncPlatformEnum.Source.TRADE_PLATFORM.getCode().toString());
+                log.info("运单预计时间信息同步开始，请求参数:{}",data);
+                Result<?> result = openCallBackClient.encryptPost(data,message.topic());
+                log.info("运单预计时间信息同步，响应结果:{}",JSON.toJSONString(result));
+            }
         }