feature(*): 修复bug

- 修复bug

feature(*): 修复bug
- 修复bug
张志伟
1 parent 57a10bc7
Showing 2 changed files with 5 additions and 2 deletions
fw-valhalla-sdk/src/main/java/cn/fw/valhalla/sdk/result/RenewalSwitchMQ.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/component/producer/RenewalSwitchProducer.kt
@@ -33,5 +33,8 @@ public class RenewalSwitchMQ {
      * 续保跟进最后截止时间
      */
     private Date deadline;
-
+    /**
+     * 集团id
+     */
+    private Long groupId;
 }
@@ -50,7 +50,7 @@ class RenewalSwitchProducer(
         }
         log.info("发送续保跟进切换mq消息。vin:{}", vin)
         try {
-            val mq = RenewalSwitchMQ(FollowTypeEnum.IR.value, vin, DateUtil.localDate2Date(deadline))
+            val mq = RenewalSwitchMQ(FollowTypeEnum.IR.value, vin, DateUtil.localDate2Date(deadline), groupId)
             rocketMQTemplate.syncSend(CustomerDistributedMQ.TOPIC + ":*", mq)
         } catch (e: Exception) {
             log.info("发送保有客分配结束mq消息失败！", e)