楚江ERP:草稿要车单消息提醒业务员补充数据

@@ -4,10 +4,12 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageInfo;
+import com.lframework.starter.mq.core.service.MqProducerService;
 import com.lframework.starter.web.core.components.redis.RedisHandler;
 import com.lframework.starter.web.core.components.security.SecurityUtil;
 import com.lframework.starter.web.core.utils.*;
 import com.lframework.starter.web.inner.dto.dic.city.DicCityDto;
+import com.lframework.starter.web.inner.dto.message.SysSiteMessageDto;
 import com.lframework.starter.web.inner.entity.SysDept;
 import com.lframework.starter.web.inner.service.DicCityService;
 import com.lframework.starter.web.inner.service.system.SysDeptService;
@@ -80,6 +82,8 @@ public class ShipmentsOrderInfoServiceImpl extends BaseMpServiceImpl<ShipmentsOr
     private RedisHandler redisHandler;
     @Resource
     private MessageHandler messageHandler;
+    @Resource
+    private MqProducerService mqProducerService;
 
 
 
@@ -579,6 +583,17 @@ public class ShipmentsOrderInfoServiceImpl extends BaseMpServiceImpl<ShipmentsOr
                 String draftId = draftRequestCarTicketService.create(createVo);
                 // 草稿要车单ID和发货单ID映射
                 redisHandler.set("GET_SHIPMENTS_ORDER_ID_" + draftId, shipmentsOrderId);
+                //发送消息提醒业务员（发货单中合同创建人）补充草稿要车单相关数据
+                SysSiteMessageDto messageDto = new SysSiteMessageDto();
+                List<String> userIdList = new ArrayList<>();
+                userIdList.add(orderInfo.getContractCreateById());
+                messageDto.setUserIdList(userIdList);
+                messageDto.setTitle("草稿要车单补充通知");
+                messageDto.setContent("您有新的草稿要车单需要补充，请尽快完成！");
+                messageDto.setBizKey(IdUtil.getId());
+                //如果是空表示由系统自动发起
+                messageDto.setCreateUserId(null);
+                mqProducerService.createSysSiteMessage(messageDto);
                 break;
             }
             if ("PASS".equals(draftTicket.getStatus())) {