Merge branch 'refs/heads/v16.3_line_warn_20240528' into test

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

@@ -27,6 +27,7 @@ import com.clx.performance.param.mq.trace.TruckTraceSyncMqParam;
 import com.clx.performance.param.mq.vehiclewarn.VehicleWarnChildAddMqParam;
 import com.clx.performance.param.mq.vehiclewarn.VehicleWarnTruckWarnMqParam;
 import com.clx.performance.param.mq.vehiclewarn.VehicleWarnTruckWarnNoticeMqParam;
+import com.clx.performance.service.linewarn.LineWarnMqService;
 import com.clx.performance.service.trace.TruckTraceMqHandlerService;
 import com.clx.performance.service.vehiclewarn.*;
 import com.clx.performance.utils.LocalDateTimeUtils;
@@ -79,6 +80,8 @@ public class VehicleWarnMqHandlerServiceImpl implements VehicleWarnMqHandlerServ
     private VehicleWarnDelayWarnService vehicleWarnDelayWarnService;
     @Autowired
     private TruckTraceMqHandlerService truckTraceMqHandlerService;
+    @Autowired
+    private LineWarnMqService lineWarnMqService;
 
     @Override
     public void orderChildAdd(VehicleWarnChildAddMqParam mq) {
@@ -332,6 +335,9 @@ public class VehicleWarnMqHandlerServiceImpl implements VehicleWarnMqHandlerServ
         VehicleWarnInfo vehicleWarnInfo = vehicleWarnInfoDao
                 .findById(mq.getInfoId()).orElseThrow(ResultEnum.DATA_NOT_FIND);
 
+        // 发送mq（运单异常）
+        lineWarnMqService.orderChildWarn(vehicleWarnInfo.getOrderGoodsNo(), vehicleWarnInfo.getChildNo());
+
         List<String> mobileList = new ArrayList<>();
 
         // 过滤需要通知的人员