提交 a8f84556 authored 作者: liuhaiquan's avatar liuhaiquan

增加订单取消、到达最晚拉运时间 的最后一车同步逻辑

上级 29c97b74
...@@ -121,4 +121,7 @@ public class OrderChildDtsListener { ...@@ -121,4 +121,7 @@ public class OrderChildDtsListener {
} }
} }
} }
package com.clx.performance.service; package com.clx.performance.service;
import com.clx.performance.model.OrderChild; import com.clx.performance.model.OrderChild;
import com.msl.common.result.Result;
public interface LastTruckService { public interface LastTruckService {
OrderChild getLastTruckChild(String orderNo); OrderChild getLastTruckChild(String orderNo);
void syncLastTruckChild(OrderChild child); Result<?> syncLastTruckChild(OrderChild child);
OrderChild getOrderCompleteLastTruck(String orderNo); OrderChild getOrderCompleteLastTruck(String orderNo);
Result<?> syncLastTruckChild4OrderTrigger(String orderNo);
} }
...@@ -67,13 +67,14 @@ public class LastTruckServiceImpl implements LastTruckService { ...@@ -67,13 +67,14 @@ public class LastTruckServiceImpl implements LastTruckService {
* @return * @return
**/ **/
@Override @Override
public void syncLastTruckChild(OrderChild child) { public Result<?> syncLastTruckChild(OrderChild child) {
OrderChildMessage message = orderChildStruct.convertMessage(child); OrderChildMessage message = orderChildStruct.convertMessage(child);
message.setLastFlag(ResultStatusEnum.YES.getCode()); message.setLastFlag(ResultStatusEnum.YES.getCode());
log.info("开始同步最后一车的运单,运单编号:{},运单信息:{}",child.getChildNo(), JSON.toJSONString(message)); log.info("开始同步最后一车的运单,运单编号:{},运单信息:{}",child.getChildNo(), JSON.toJSONString(message));
OpenCallBackClient client2 = new OpenCallBackClient(mslAppConfig.getUrl(),mslAppConfig.getAppId(),mslAppConfig.getSecret()); OpenCallBackClient client2 = new OpenCallBackClient(mslAppConfig.getUrl(),mslAppConfig.getAppId(),mslAppConfig.getSecret());
Result<?> result2 = client2.encryptPost(JSON.toJSONString(message),message.topic()); Result<?> result2 = client2.encryptPost(JSON.toJSONString(message),message.topic());
log.info("结束同步最后一车的运单,运单编号:{},响应结果:{}",child.getChildNo(),JSON.toJSONString(result2)); log.info("结束同步最后一车的运单,运单编号:{},响应结果:{}",child.getChildNo(),JSON.toJSONString(result2));
return result2;
} }
@Override @Override
...@@ -87,4 +88,20 @@ public class LastTruckServiceImpl implements LastTruckService { ...@@ -87,4 +88,20 @@ public class LastTruckServiceImpl implements LastTruckService {
} }
return null; return null;
} }
/**
* @Author kavin
* @Description 订单取消、到达最晚拉运时间 同步最后一车
* @Param [orderNo]
* @return
**/
public Result<?> syncLastTruckChild4OrderTrigger(String orderNo) {
OrderChild child = getOrderCompleteLastTruck(orderNo);
if(Objects.nonNull(child)){
return syncLastTruckChild(child);
}
return Result.ok("订单完成/完结状态下未查询最后一车,订单编号:" + orderNo);
}
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论