From 9e64429aea8b5fae6fd2678994f3f5f371b6ce44 Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Fri, 19 Aug 2022 18:03:32 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B7=B2=E7=BB=8F=E5=8F=91=E5=B8=83=E7=9A=84?=
 =?UTF-8?q?=E7=BC=96=E8=BE=91=E9=9C=80=E8=A6=81=E5=8F=91=E9=80=81=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/IcPartyActServiceImpl.java   | 22 +++++++++++++++++++
 1 file changed, 22 insertions(+)

diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyActServiceImpl.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyActServiceImpl.java
index dc3a22fe5f..3a7254f146 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyActServiceImpl.java
+++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyActServiceImpl.java
@@ -17,6 +17,7 @@ import com.epmet.commons.tools.utils.DateUtils;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.utils.SpringContextUtils;
 import com.epmet.constant.ReadFlagConstant;
+import com.epmet.constant.SystemMessageType;
 import com.epmet.dto.form.UserMessageFormDTO;
 import com.epmet.feign.EpmetMessageOpenFeignClient;
 import com.epmet.modules.partyOrg.dao.*;
@@ -37,6 +38,7 @@ import com.epmet.resi.partymember.dto.partyOrg.form.ActAndScheduleListFormDTO;
 import com.epmet.resi.partymember.dto.partyOrg.form.HomeMonthTotalFormDTO;
 import com.epmet.resi.partymember.dto.partyOrg.result.ActAndScheduleListResultDTO;
 import com.epmet.resi.partymember.dto.partyOrg.result.HomeMonthTotalResultDTO;
+import com.epmet.send.SendMqMsgUtil;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import lombok.extern.slf4j.Slf4j;
@@ -157,13 +159,23 @@ public class IcPartyActServiceImpl extends BaseServiceImpl<IcPartyActDao, IcPart
         icPartyActEntity.setOrgId(staffInfo.getAgencyId());
         icPartyActEntity.setPid(staffInfo.getParentAgency().getId());
         icPartyActEntity.setOrgIdPath(staffInfo.getAgencyPIds());
+        Boolean sendMsg=false;
         if(StringUtils.isNotBlank(formDTO.getIcPartyActId())){
             icPartyActEntity.setId(formDTO.getIcPartyActId());
             //删除附件、删除参加组织
             SpringContextUtils.getBean(ResiPartymemberAttachmentService.class).deleteByBusinessId(formDTO.getCustomerId(), Arrays.asList(formDTO.getIcPartyActId()));
             SpringContextUtils.getBean(IcPartyActOrgService.class).deleteByPartyActId(formDTO.getCustomerId(), Arrays.asList(formDTO.getIcPartyActId()));
+            //保留原来的发布状态
+            IcPartyActEntity origin=baseDao.selectById(formDTO.getIcPartyActId());
+            icPartyActEntity.setIsPublish(origin.getIsPublish());
             baseDao.updateById(icPartyActEntity);
+            //已发布，在编辑的时候，需要发送消息
+            if(NumConstant.ONE_STR.equals(icPartyActEntity.getIsPublish())){
+                sendMsg=true;
+            }
         }else{
+            //默认是未发布
+            icPartyActEntity.setIsPublish(NumConstant.ZERO_STR);
             baseDao.insert(icPartyActEntity);
         }
         //新增参加参加活动党组织
@@ -186,6 +198,16 @@ public class IcPartyActServiceImpl extends BaseServiceImpl<IcPartyActDao, IcPart
         }
         Map<String, String> map=new HashMap<>();
         map.put("icPartyActId",icPartyActEntity.getId());
+        //已经发布的，编辑需要发消息
+        if(sendMsg){
+            PartyMeetingMessageMQMsg msg = new PartyMeetingMessageMQMsg();
+            msg.setCustomerId(formDTO.getCustomerId());
+            msg.setIcPartyActId(icPartyActEntity.getId());
+            msg.setType("publish");
+            SendMqMsgUtil.build()
+                    .openFeignClient(SpringContextUtils.getBean(EpmetMessageOpenFeignClient.class))
+                    .sendRocketMqMsg(SystemMessageType.PARTY_MEETING_MESSAGE, msg);
+        }
         return map;
     }