APP站内信--触发预警类型：装车超时、卸车超时

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

@@ -3,12 +3,14 @@ package com.clx.performance.service.impl.vehiclewarn;
 import com.clx.performance.dao.vehiclewarn.VehicleWarnConfigDao;
 import com.clx.performance.dao.vehiclewarn.VehicleWarnInfoDao;
 import com.clx.performance.dto.vehiclewarn.VehicleWarnCommonInfoDTO;
+import com.clx.performance.enums.InternalMessageTemplateEnum;
 import com.clx.performance.enums.vehiclewarn.VehicleWarnConfigEnum;
 import com.clx.performance.enums.vehiclewarn.VehicleWarnInfoEnum;
 import com.clx.performance.model.OrderChild;
 import com.clx.performance.model.vehiclewarn.VehicleWarnChild;
 import com.clx.performance.model.vehiclewarn.VehicleWarnConfig;
 import com.clx.performance.model.vehiclewarn.VehicleWarnInfo;
+import com.clx.performance.service.SendInternalMessageService;
 import com.clx.performance.service.vehiclewarn.VehicleWarnCommonService;
 import com.clx.performance.service.vehiclewarn.VehicleWarnSendAddressWarnService;
 import lombok.extern.slf4j.Slf4j;
@@ -32,6 +34,8 @@ public class VehicleWarnSendAddressWarnServiceImpl implements VehicleWarnSendAdd
     private VehicleWarnInfoDao vehicleWarnInfoDao;
     @Autowired
     private VehicleWarnCommonService vehicleWarnCommonService;
+    @Autowired
+    private SendInternalMessageService sendInternalMessageService;
 
     /**
      * 前往货源地超时
@@ -80,6 +84,19 @@ public class VehicleWarnSendAddressWarnServiceImpl implements VehicleWarnSendAdd
         // 更新
         vehicleWarnCommonService.vehicleWarnInfoUpdate(orderChild, vehicleWarnInfo, vehicleWarnConfig);
 
+        // 司机触发运单预警规则，系统通知给司机，APP站内信
+        sendInternalMessageService.sendInternalMessageMq(
+                // APP
+                InternalMessageTemplateEnum.PlatformType.DRIVER_APP.getCode(),
+                // 业务类型
+                InternalMessageTemplateEnum.BusinessType.APP_SECOND_CLASSIFICATION.getCode(),
+                // 司机触发运单预警规则-前往货源地超时
+                InternalMessageTemplateEnum.DRIVER_TRIGGER_GO_SOURCE_LOCAL_TIMEOUT,
+                // 运单编号、货源地超时时间
+                List.of(orderChild.getChildNo(), needTime),
+                null,
+                orderChild.getDriverUserNo());
+
     }
 
     /**
@@ -125,6 +142,19 @@ public class VehicleWarnSendAddressWarnServiceImpl implements VehicleWarnSendAdd
         // 更新
         vehicleWarnCommonService.vehicleWarnInfoUpdate(orderChild, vehicleWarnInfo, vehicleWarnConfig);
 
+        // 司机触发运单预警规则，系统通知给司机，到达货源地延误
+        sendInternalMessageService.sendInternalMessageMq(
+                // APP
+                InternalMessageTemplateEnum.PlatformType.DRIVER_APP.getCode(),
+                // 业务类型
+                InternalMessageTemplateEnum.BusinessType.APP_SECOND_CLASSIFICATION.getCode(),
+                // 司机触发运单预警规则-到达货源地超时
+                InternalMessageTemplateEnum.DRIVER_ARRIVE_SOURCE_LOCAL_DELAY_CODE,
+                // 运单编号
+                List.of(orderChild.getChildNo()),
+                null,
+                orderChild.getDriverUserNo());
+
     }
 
 }