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

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

@@ -2,12 +2,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.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.VehicleWarnLoadAndUnloadWarnService;
 import lombok.extern.slf4j.Slf4j;
@@ -31,6 +33,8 @@ public class VehicleWarnLoadAndUnloadWarnServiceImpl implements VehicleWarnLoadA
     private VehicleWarnInfoDao vehicleWarnInfoDao;
     @Autowired
     private VehicleWarnCommonService vehicleWarnCommonService;
+    @Autowired
+    private SendInternalMessageService sendInternalMessageService;
 
     /**
      * 装车超时
@@ -69,6 +73,19 @@ public class VehicleWarnLoadAndUnloadWarnServiceImpl implements VehicleWarnLoadA
         // 更新
         vehicleWarnCommonService.vehicleWarnInfoUpdate(orderChild, vehicleWarnInfo, vehicleWarnConfig);
 
+        // 司机触发运单预警规则，系统通知给司机，APP站内信
+        sendInternalMessageService.sendInternalMessageMq(
+                // APP
+                InternalMessageTemplateEnum.PlatformType.DRIVER_APP.getCode(),
+                // 业务类型
+                InternalMessageTemplateEnum.BusinessType.APP_SECOND_CLASSIFICATION.getCode(),
+                // 司机触发运单预警规则-装车超时
+                InternalMessageTemplateEnum.DRIVER_TRIGGER_UPLOAD_TIMEOUT,
+                // 运单编号、前往目的地超时时间
+                List.of(orderChild.getChildNo(), time),
+                null,
+                orderChild.getDriverUserNo());
+
     }
 
     /**
@@ -107,6 +124,20 @@ public class VehicleWarnLoadAndUnloadWarnServiceImpl implements VehicleWarnLoadA
 
         // 更新
         vehicleWarnCommonService.vehicleWarnInfoUpdate(orderChild, vehicleWarnInfo, vehicleWarnConfig);
+
+        // 司机触发运单预警规则，系统通知给司机，APP站内信
+        sendInternalMessageService.sendInternalMessageMq(
+                // APP
+                InternalMessageTemplateEnum.PlatformType.DRIVER_APP.getCode(),
+                // 业务类型
+                InternalMessageTemplateEnum.BusinessType.APP_SECOND_CLASSIFICATION.getCode(),
+                // 司机触发运单预警规则-卸车超时
+                InternalMessageTemplateEnum.DRIVER_TRIGGER_DOWNLOAD_TIMEOUT,
+                // 运单编号、前往目的地超时时间
+                List.of(orderChild.getChildNo(), time),
+                null,
+                orderChild.getDriverUserNo());
+
     }
 
 }