提交 32aa1ee2 authored 作者: 艾庆国's avatar 艾庆国

运单预警

上级 9ea4ca7b
......@@ -42,21 +42,6 @@ public class TruckTraceMqHandlerServiceImpl implements TruckTraceMqHandlerServic
@Override
public void truckTracSync(TruckTraceSyncMqParam mq) {
if (StringUtils.isNotBlank(mq.getChildNo())) {
VehicleWarnChild vehicleWarnChild = vehicleWarnChildDao.findByChildNo(mq.getChildNo()).orElseThrow(ResultEnum.DATA_NOT_FIND);
OrderChild orderChild = orderChildDao.getByChildNo(mq.getChildNo()).orElseThrow(ResultEnum.DATA_NOT_FIND);
if (orderChild.getFinishTime() != null) {
vehicleWarnChild.setTraceStatus(VehicleWarnChildEnum.TraceStatus.DISABLE.getCode());
}
vehicleWarnChild.setTraceTime(LocalDateTimeUtils.parseTime(mq.getEndTime()));
// 更新同步时间
if (StringUtils.isNotBlank(mq.getChildNo())) {
vehicleWarnChildDao.updateTraceTime(vehicleWarnChild);
}
}
List<TruckTraceDTO> list = zjxlGpsService.getTruckTrace(mq.getTruckNo(), mq.getBeginTime(), mq.getEndTime());
if (list.isEmpty()) {return;}
......
......@@ -87,7 +87,11 @@ public class VehicleWarnMqHandlerServiceImpl implements VehicleWarnMqHandlerServ
truckTraceSyncMqParam.setTruckNo(orderChild.getTruckNo());
truckTraceSyncMqParam.setBeginTime(LocalDateTimeUtils.formatTime(LocalDateTime.now().minusMinutes(5)));
truckTraceSyncMqParam.setEndTime(LocalDateTimeUtils.formatTime());
truckTraceMqHandlerService.truckTracSync(truckTraceSyncMqParam);
try {
truckTraceMqHandlerService.truckTracSync(truckTraceSyncMqParam);
}catch (Exception e){
log.info("同步车辆轨迹失败, msg:{}", e.getMessage());
}
// 计算预计时间
BigDecimal[] currentPosition = vehicleWarnCommonService.getCurrentPosition(orderChild.getTruckNo(),
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论