增加插入运单预计时间临时接口

performance-web/src/main/java/com/clx/performance/controller/temp/TempController.java

 package com.clx.performance.controller.temp;
 
 import com.clx.open.sdk.callback.message.OrderChildSyncMessage;
+import com.clx.performance.dto.OrderChildExpectDTO;
 import com.clx.performance.extranal.transport.TransportService;
 import com.clx.performance.feign.TransportFeignService;
 import com.clx.performance.listener.OrderChildDtsListener;
+import com.clx.performance.service.OrderChildService;
 import com.clx.performance.service.TempService;
 import com.clx.performance.service.child.FeignOrderChildService;
-import com.clx.performance.service.trace.TruckTraceMqHandlerService;
 import com.msl.common.result.Result;
+import com.msl.common.utils.DateUtils;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -17,7 +19,7 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.validation.constraints.NotBlank;
-
+import java.time.LocalDateTime;
 
 /**
  * @Author: aiqingguo
@@ -42,6 +44,9 @@ public class TempController {
     @Autowired
     private OrderChildDtsListener orderChildDtsListener;
 
+    @Autowired
+    private OrderChildService orderChildService;
+
 
     @ApiOperation(value = "test", notes = "<br>By:艾庆国")
     @RequestMapping(value = "/test", method = RequestMethod.GET)
@@ -66,6 +71,26 @@ public class TempController {
         return Result.ok();
     }
 
+
+
+
+
+    @ApiOperation(value = "插入缓存运单预计时间", notes = "<br>By:刘海泉")
+    @RequestMapping(value = "/saveOrderChildExpectTime", method = RequestMethod.GET)
+    public Result<Void> saveOrderChildExpectTime(@RequestParam("childNo") @NotBlank(message = "运单号不能为空") String childNo,
+            @RequestParam("expectArriveTime") @NotBlank(message = "预计到达货源地时间") String expectArriveTime,
+            @RequestParam("expectReceiveTime") @NotBlank(message = "预计到达目的地时间") String expectReceiveTime) {
+        OrderChildExpectDTO expect = new OrderChildExpectDTO();
+        expect.setChildNo(childNo);
+        expect.setExpectArriveTime(expectArriveTime);
+        expect.setExpectReceiveTime(expectReceiveTime);
+        expect.setCreateTime(DateUtils.formatDateTime(LocalDateTime.now()).get());
+        orderChildService.cacheOrderChildExpectData(childNo,expect);
+
+
+        return Result.ok();
+    }
+
 //    @ApiOperation(value = "更新网运标识", notes = "<br>By:艾庆国")
 //    @RequestMapping(value = "/updateInvoiceType", method = RequestMethod.POST)
 //    public Result<Void> updateInvoiceType(String childNo, Integer invoiceType) {

performance-web/src/main/java/com/clx/performance/service/OrderChildService.java

@@ -102,4 +102,6 @@ public interface OrderChildService {
     void cancelOrderChilds(CancelOrderGoodsParam param);
 
     List<OrderChildExpectDTO> getOrderChildExpect(String orderChildNo);
+
+    void cacheOrderChildExpectData(String childNo, OrderChildExpectDTO expect);
 }

performance-web/src/main/java/com/clx/performance/service/impl/OrderChildServiceImpl.java

@@ -2522,6 +2522,7 @@ public class OrderChildServiceImpl implements OrderChildService {
      * @Description 缓存实时计算的运单预计时间
      * @Param [orderChildNo, expect]
      **/
+    @Override
     public void cacheOrderChildExpectData(String orderChildNo, OrderChildExpectDTO expect) {
         String orderChildExpectDataKey = getOrderChildExpectDataKey(orderChildNo);
         //计算结果20分钟过期。定时每5分钟执行一次。所以在此记录过期前，该运单会生成四条记录。保留最新的两条记录即可，剩下两条不再结果集中记录。