APP站内信--触发预警类型：前往目的地超宇、到达目的地超时

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

@@ -3,6 +3,7 @@ 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.OrderChildEnum;
 import com.clx.performance.enums.vehiclewarn.VehicleWarnConfigEnum;
 import com.clx.performance.enums.vehiclewarn.VehicleWarnInfoEnum;
@@ -10,6 +11,7 @@ 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.VehicleWarnReceiveAddressWarnService;
 import lombok.extern.slf4j.Slf4j;
@@ -34,6 +36,8 @@ public class VehicleWarnReceiveAddressWarnServiceImpl implements VehicleWarnRece
     private VehicleWarnInfoDao vehicleWarnInfoDao;
     @Autowired
     private VehicleWarnCommonService vehicleWarnCommonService;
+    @Autowired
+    private SendInternalMessageService sendInternalMessageService;
 
     /**
      * 前往目的地超时
@@ -89,6 +93,19 @@ public class VehicleWarnReceiveAddressWarnServiceImpl implements VehicleWarnRece
 
         // 更新
         vehicleWarnCommonService.vehicleWarnInfoUpdate(orderChild, vehicleWarnInfo, vehicleWarnConfig);
+
+        // 司机触发运单预警规则，系统通知给司机，APP站内信
+        sendInternalMessageService.sendInternalMessageMq(
+                // APP
+                InternalMessageTemplateEnum.PlatformType.DRIVER_APP.getCode(),
+                // 业务类型
+                InternalMessageTemplateEnum.BusinessType.APP_SECOND_CLASSIFICATION.getCode(),
+                // 司机触发运单预警规则-前往目的地超时
+                InternalMessageTemplateEnum.DRIVER_TRIGGER_GO_DESTINATION_TIMEOUT,
+                // 运单编号、前往目的地超时时间
+                List.of(orderChild.getChildNo(), needTime),
+                null,
+                orderChild.getDriverUserNo());
     }
 
     /**
@@ -137,6 +154,19 @@ public class VehicleWarnReceiveAddressWarnServiceImpl implements VehicleWarnRece
 
         // 更新
         vehicleWarnCommonService.vehicleWarnInfoUpdate(orderChild, vehicleWarnInfo, vehicleWarnConfig);
+
+        // 司机触发运单预警规则，系统通知给司机，APP站内信
+        sendInternalMessageService.sendInternalMessageMq(
+                // APP
+                InternalMessageTemplateEnum.PlatformType.DRIVER_APP.getCode(),
+                // 业务类型
+                InternalMessageTemplateEnum.BusinessType.APP_SECOND_CLASSIFICATION.getCode(),
+                // 司机触发运单预警规则-到达目的地超时
+                InternalMessageTemplateEnum.DRIVER_TRIGGER_ARRIVE_DESTINATION_DELAY,
+                // 运单编号、前往目的地超时时间
+                List.of(orderChild.getChildNo()),
+                null,
+                orderChild.getDriverUserNo());
     }
 
 }