From fd314eebecbce1927b264e0d0a479bb2eb90984a Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Thu, 22 Apr 2021 11:17:08 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E5=B8=83=E3=80=81=E7=BC=96=E8=BE=91?=
 =?UTF-8?q?=E3=80=81=E5=8F=96=E6=B6=88=E3=80=81=E5=85=B3=E9=97=AD=E6=B4=BB?=
 =?UTF-8?q?=E5=8A=A8=E8=AE=B0=E5=BD=95group=5Fmessage?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/GroupActInfoServiceImpl.java | 43 ++++++++++++++++++-
 1 file changed, 42 insertions(+), 1 deletion(-)

diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/act/service/impl/GroupActInfoServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/act/service/impl/GroupActInfoServiceImpl.java
index 54a184983c..bbd593b609 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/act/service/impl/GroupActInfoServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/act/service/impl/GroupActInfoServiceImpl.java
@@ -41,7 +41,10 @@ import com.epmet.dto.result.UserBaseInfoResultDTO;
 import com.epmet.feign.EpmetMessageOpenFeignClient;
 import com.epmet.feign.EpmetUserOpenFeignClient;
 import com.epmet.feign.GovOrgOpenFeignClient;
-import com.epmet.modules.act.dao.*;
+import com.epmet.modules.act.dao.ActOperationRecordDao;
+import com.epmet.modules.act.dao.ActReadRecordDao;
+import com.epmet.modules.act.dao.GroupActContentDao;
+import com.epmet.modules.act.dao.GroupActInfoDao;
 import com.epmet.modules.act.entity.*;
 import com.epmet.modules.act.service.ActCategoryDictService;
 import com.epmet.modules.act.service.ActSignInRecordService;
@@ -49,6 +52,7 @@ import com.epmet.modules.act.service.ActSummaryService;
 import com.epmet.modules.act.service.GroupActInfoService;
 import com.epmet.modules.constant.GroupActConstant;
 import com.epmet.modules.constant.UserMessageConstant;
+import com.epmet.modules.group.service.GroupMessageService;
 import com.epmet.modules.group.service.ResiGroupService;
 import com.epmet.modules.invitation.service.InvitationRecordService;
 import com.epmet.modules.member.service.ResiGroupMemberService;
@@ -57,6 +61,7 @@ import com.epmet.resi.group.dto.act.GroupActInfoDTO;
 import com.epmet.resi.group.dto.act.form.*;
 import com.epmet.resi.group.dto.act.result.ActDetailByLinkResultDTO;
 import com.epmet.resi.group.dto.act.result.ActDetailResultDTO;
+import com.epmet.resi.group.dto.group.GroupMessageDTO;
 import com.epmet.resi.group.dto.group.ResiGroupDTO;
 import com.epmet.resi.group.dto.invitation.InvitationRecordDTO;
 import com.epmet.resi.group.dto.member.ResiGroupMemberDTO;
@@ -115,6 +120,9 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
     private InvitationRecordService invitationRecordService;
     @Autowired
     private ActSummaryService actSummaryService;
+    @Autowired
+    private GroupMessageService groupMessageService;
+
     /**
      * 003、发布（编辑）组织活动
      *
@@ -175,10 +183,38 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
         //5、发送站内信
         sendMessage(memberDTOList,formDTO,groupActInfoEntity,groupDTO);
 
+        //6、插入或更新历史关系表
+        saveGroupMessage(groupActInfoEntity);
+
         result.setGroupActId(groupActInfoEntity.getId());
         return result;
     }
 
+    private void saveGroupMessage(GroupActInfoEntity groupActInfoEntity) {
+        GroupMessageDTO groupMessageDTO=groupMessageService.getByMessageId(groupActInfoEntity.getId());
+        if(null==groupMessageDTO){
+            GroupMessageDTO insert=new GroupMessageDTO();
+            insert.setCustomerId(groupActInfoEntity.getCustomerId());
+            insert.setGridId(groupActInfoEntity.getGridId());
+            if(GroupActConstant.CANCELED.equals(groupActInfoEntity.getStatus())){
+                insert.setOperateTime(groupActInfoEntity.getCanceledTime());
+            }else if(GroupActConstant.CLOSED.equals(groupActInfoEntity.getStatus())){
+                insert.setOperateTime(groupActInfoEntity.getClosedTime());
+            }else{
+                insert.setOperateTime(groupActInfoEntity.getUpdatedTime());
+            }
+            insert.setStatus(groupActInfoEntity.getStatus());
+            insert.setMessageId(insert.getId());
+            insert.setType("act");
+            insert.setPublishUserId(groupActInfoEntity.getPublishUserId());
+            groupMessageService.save(insert);
+            return;
+        }
+        groupMessageDTO.setOperateTime(groupActInfoEntity.getUpdatedTime());
+        groupMessageDTO.setStatus(groupActInfoEntity.getStatus());
+        groupMessageService.update(groupMessageDTO);
+    }
+
     private void sendMessage(List<ResiGroupMemberDTO> memberDTOList, PublishGroupActFormDTO formDTO, GroupActInfoEntity groupActInfoEntity,ResiGroupDTO resiGroupDTO) {
 
         List<UserMessageFormDTO> list = new ArrayList<>();
@@ -637,6 +673,8 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
         //6、发送站内信
         sendUserMessageForCancelAct(actInfoEntity,formDTO.getUserId());
 
+        //7、插入或更新消息表
+        saveGroupMessage(actInfoEntity);
         GroupActIdDTO resultDTO=new GroupActIdDTO();
         resultDTO.setGroupActId(formDTO.getGroupActId());
         return resultDTO;
@@ -743,5 +781,8 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
         actInfoEntity.setStatus(GroupActConstant.CLOSED);
         actInfoEntity.setClosedTime(actOperationRecordEntity.getCreatedTime());
         baseDao.updateById(actInfoEntity);
+
+        //6、插入或更新
+        saveGroupMessage(actInfoEntity);
     }
 }
\ No newline at end of file