提交 7566ceaf authored 作者: aiqingguo's avatar aiqingguo

Merge branch 'v6.4_transportation_20231110' into release

......@@ -96,7 +96,7 @@ public class OrderChildDtsListener {
Result<?> result = client.encryptPost(JSON.toJSONString(after),after.topic());
log.info("运单信息同步,运单编号:{},响应结果:{}",after.getChildNo(),JSON.toJSONString(result));
//当运单状态为到达目的地之后的状态时候,需要判断最后一车的逻辑
if(after.getStatus() >= OrderChildEnum.Status.ARRIVE_RECEIVE.getCode() && after.getStatus() >= OrderChildEnum.Status.COMPLETE.getCode()){
if(after.getStatus() >= OrderChildEnum.Status.ARRIVE_RECEIVE.getCode() && after.getStatus() <= OrderChildEnum.Status.COMPLETE.getCode()){
OrderChild child = lastTruckService.getLastTruckChild(after.getOrderNo());
if(Objects.nonNull(child)){
OrderChildMessage message = orderChildStruct.convertMessage(child);
......
......@@ -25,7 +25,7 @@ public class OrderChildDriverConfirmListener {
@Autowired
private OrderChildMqHandlerService orderChildMqHandlerService;
@RabbitListener(queues = RabbitKeyOrderChildConstants.ORDER_CHILD_ADD_QUEUE)
@RabbitListener(queues = RabbitKeyOrderChildConstants.ORDER_CHILD_DRIVER_CONFIRM_QUEUE)
public void process(Message message) {
try{
log.info("运单-司机确认收货, message:{}", new String(message.getBody()));
......
......@@ -417,8 +417,11 @@ public class OrderGoodsServiceImpl implements OrderGoodsService {
}
}
}
orderGoodsTruckBindDao.saveBatchEntity(param.getOrderNo(), orderGoodsNo, truckList, now);
goodsOrderTruckRecordComponent.saveTruckRecord(orderGoodsNo, truckList);
if (CollectionUtils.isNotEmpty(truckList)) {
orderGoodsTruckBindDao.saveBatchEntity(param.getOrderNo(), orderGoodsNo, truckList, now);
goodsOrderTruckRecordComponent.saveTruckRecord(orderGoodsNo, truckList);
}
}
orderGoodsStatusLazyComponent.deleteRedisRecordForLastOrderTime(orderGoodsNo);
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论