发送消息

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcScheduleServiceImpl.java

@@ -3,6 +3,7 @@ package com.epmet.modules.partyOrg.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
+import com.epmet.commons.rocketmq.messages.PartyMeetingMessageMQMsg;
 import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult;
 import com.epmet.commons.tools.exception.EpmetException;
@@ -11,11 +12,15 @@ import com.epmet.commons.tools.redis.common.CustomerOrgRedis;
 import com.epmet.commons.tools.redis.common.CustomerStaffRedis;
 import com.epmet.commons.tools.redis.common.bean.AgencyInfoCache;
 import com.epmet.commons.tools.utils.ConvertUtils;
+import com.epmet.commons.tools.utils.SpringContextUtils;
+import com.epmet.constant.SystemMessageType;
+import com.epmet.feign.EpmetMessageOpenFeignClient;
 import com.epmet.modules.partyOrg.dao.IcScheduleDao;
 import com.epmet.modules.partyOrg.entity.IcScheduleEntity;
 import com.epmet.modules.partyOrg.service.IcScheduleService;
 import com.epmet.resi.partymember.dto.IcScheduleDTO;
 import com.epmet.resi.partymember.dto.partyOrg.form.AddOrEditScheduleFormDTO;
+import com.epmet.send.SendMqMsgUtil;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
@@ -112,6 +117,13 @@ public class IcScheduleServiceImpl extends BaseServiceImpl<IcScheduleDao, IcSche
         e.setPid(agencyInfo.getPid());
         e.setOrgIdPath("".equals(agencyInfo.getPids()) ? "" : agencyInfo.getPids().concat(":").concat(agencyInfo.getId()));
         baseDao.insert(e);
+        PartyMeetingMessageMQMsg msg = new PartyMeetingMessageMQMsg();
+        msg.setCustomerId(formDTO.getCustomerId());
+        msg.setIcPartyActId(e.getId());
+        msg.setType("notify");
+        SendMqMsgUtil.build()
+                .openFeignClient(SpringContextUtils.getBean(EpmetMessageOpenFeignClient.class))
+                .sendRocketMqMsg(SystemMessageType.PARTY_MEETING_MESSAGE, msg);
     }
 
     /**