commit

clx-performance-web/src/main/java/com/clx/performance/service/impl/breakcontract/BreakContractDriverRecordServiceImpl.java

@@ -7,6 +7,7 @@ import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.dao.breakcontract.BreakContractDriverRecordDao;
 import com.clx.performance.dao.breakcontract.BreakContractDriverRuleDao;
 import com.clx.performance.enums.BreakContractRecordEnum;
+import com.clx.performance.enums.InternalMessageTemplateEnum;
 import com.clx.performance.enums.PerformanceResultEnum;
 import com.clx.performance.enums.TruckDemandEnum;
 import com.clx.performance.model.OrderChild;
@@ -17,6 +18,7 @@ import com.clx.performance.param.app.breakcontract.DriverPageBreakContractDriver
 import com.clx.performance.param.pc.breakcontract.carrier.BreakContractDriverRecordAddParam;
 import com.clx.performance.param.pc.breakcontract.carrier.PageBreakContractDriverRecordParam;
 import com.clx.performance.service.IntegralRecordService;
+import com.clx.performance.service.SendInternalMessageService;
 import com.clx.performance.service.breakcontract.BreakContractDriverRecordService;
 import com.clx.performance.service.breakcontract.BreakContractMqService;
 import com.clx.performance.service.impl.UniqueOrderNumService;
@@ -34,6 +36,7 @@ import org.springframework.transaction.annotation.Transactional;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.time.LocalDateTime;
+import java.util.Collections;
 import java.util.Objects;
 
 /**
@@ -61,6 +64,8 @@ public class BreakContractDriverRecordServiceImpl  implements BreakContractDrive
     private UniqueOrderNumService uniqueOrderNumService;
     @Autowired
     private IntegralRecordService integralRecordService;
+    @Autowired
+    SendInternalMessageService sendInternalMessageService;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -110,6 +115,12 @@ public class BreakContractDriverRecordServiceImpl  implements BreakContractDrive
             integralRecordService.addPlatformCompensationRecord(record.getTruckNo());
         }
 
+        //司机违约通知 站内信
+        sendInternalMessageService.sendInternalMessageMq(InternalMessageTemplateEnum.PlatformType.CARRIER.getCode(),
+                InternalMessageTemplateEnum.BusinessType.WAIT_APPROVED_ITEM.getCode(),
+                InternalMessageTemplateEnum.CUSTOM_DRIVER_TRIGGER_BREAK_CONTRACT_CODE, Collections.singletonList(breakNo),null);
+
+
     }
 
     @Override
@@ -170,6 +181,11 @@ public class BreakContractDriverRecordServiceImpl  implements BreakContractDrive
 
         // 发送mq (违约记录新增)
         breakContractMqService.driverRecordAdd(record.getId());
+
+        //司机违约通知 站内信
+        sendInternalMessageService.sendInternalMessageMq(InternalMessageTemplateEnum.PlatformType.CARRIER.getCode(),
+                InternalMessageTemplateEnum.BusinessType.WAIT_APPROVED_ITEM.getCode(),
+                InternalMessageTemplateEnum.CUSTOM_DRIVER_TRIGGER_BREAK_CONTRACT_CODE, Collections.singletonList(record.getBreakNo()),null);
     }
 
     @Override
@@ -211,6 +227,12 @@ public class BreakContractDriverRecordServiceImpl  implements BreakContractDrive
 
         // 发送mq (违约记录新增)
         breakContractMqService.driverRecordAdd(record.getId());
+
+        //司机违约通知 站内信
+        sendInternalMessageService.sendInternalMessageMq(InternalMessageTemplateEnum.PlatformType.CARRIER.getCode(),
+                InternalMessageTemplateEnum.BusinessType.WAIT_APPROVED_ITEM.getCode(),
+                InternalMessageTemplateEnum.CUSTOM_DRIVER_TRIGGER_BREAK_CONTRACT_CODE, Collections.singletonList(record.getBreakNo()),null);
+
     }
 
     @Override
@@ -249,6 +271,11 @@ public class BreakContractDriverRecordServiceImpl  implements BreakContractDrive
 
         // 发送mq (违约记录新增)
         breakContractMqService.driverRecordAdd(record.getId());
+
+        //司机违约通知 站内信
+        sendInternalMessageService.sendInternalMessageMq(InternalMessageTemplateEnum.PlatformType.CARRIER.getCode(),
+                InternalMessageTemplateEnum.BusinessType.WAIT_APPROVED_ITEM.getCode(),
+                InternalMessageTemplateEnum.CUSTOM_DRIVER_TRIGGER_BREAK_CONTRACT_CODE, Collections.singletonList(record.getBreakNo()),null);
     }
 
     @Override