From effacacffa1316d339bbd0d3d58e184ec8d044ed Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Tue, 20 Apr 2021 17:12:17 +0800
Subject: [PATCH] =?UTF-8?q?act=5Fread=5Frecord=E6=96=B0=E5=A2=9Egrid=5Fid?=
 =?UTF-8?q?=E3=80=81group=5Fid?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../epmet/resi/group/dto/act/ActReadRecordDTO.java  | 13 ++++++++++++-
 .../modules/act/entity/ActReadRecordEntity.java     | 10 ++++++++++
 .../act/service/impl/GroupActInfoServiceImpl.java   |  9 +++++++--
 3 files changed, 29 insertions(+), 3 deletions(-)

diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/act/ActReadRecordDTO.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/act/ActReadRecordDTO.java
index 78bbec055c..b1040693b0 100644
--- a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/act/ActReadRecordDTO.java
+++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/act/ActReadRecordDTO.java
@@ -17,9 +17,10 @@
 
 package com.epmet.resi.group.dto.act;
 
+import lombok.Data;
+
 import java.io.Serializable;
 import java.util.Date;
-import lombok.Data;
 
 
 /**
@@ -43,6 +44,16 @@ public class ActReadRecordDTO implements Serializable {
      */
 	private String customerId;
 
+    /**
+     * 小组所属网格id
+     */
+    private String gridId;
+
+    /**
+     * 小组id
+     */
+    private String groupId;
+
     /**
      * group_act_info.id
      */
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/act/entity/ActReadRecordEntity.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/act/entity/ActReadRecordEntity.java
index ad7809400d..561a3d760a 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/act/entity/ActReadRecordEntity.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/act/entity/ActReadRecordEntity.java
@@ -40,6 +40,16 @@ public class ActReadRecordEntity extends BaseEpmetEntity {
      */
 	private String customerId;
 
+	/**
+	 * 小组所属网格id
+	 */
+	private String gridId;
+
+	/**
+	 * 小组id
+	 */
+	private String groupId;
+
     /**
      * group_act_info.id
      */
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 ecf6f045df..a62da74ca6 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
@@ -148,7 +148,8 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
         List<ActReadRecordEntity> readRecordEntityList=constructReadRec(groupActInfoEntity.getId(),
                         formDTO.getCustomerId(),
                         formDTO.getGroupId(),
-                        formDTO.getPublishUserId());
+                        formDTO.getPublishUserId(),
+                        groupDTO.getGridId());
         //2、插入活动内容
         contentList.forEach(textContentEntity->{
             groupActContentDao.insert(textContentEntity);
@@ -167,7 +168,7 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
         return result;
     }
 
-    private List<ActReadRecordEntity> constructReadRec(String groupActId, String customerId, String groupId,String publishUserId) {
+    private List<ActReadRecordEntity> constructReadRec(String groupActId, String customerId, String groupId,String publishUserId,String gridId) {
         List<ActReadRecordEntity> list=new ArrayList<>();
         List<ResiGroupMemberDTO> memberDTOList=resiGroupMemberService.getMemberList(groupId);
         memberDTOList.forEach(memberDTO->{
@@ -177,6 +178,8 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
             actReadRecordEntity.setRead(GroupActConstant.UN_READ);
             actReadRecordEntity.setUserId(memberDTO.getCustomerUserId());
             actReadRecordEntity.setShouldBeRead(Constant.YES);
+            actReadRecordEntity.setGroupId(groupId);
+            actReadRecordEntity.setGridId(gridId);
             if(!publishUserId.equals(memberDTO.getCustomerUserId())){
                 list.add(actReadRecordEntity);
             }
@@ -393,6 +396,8 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
             insertEntity.setRead(GroupActConstant.READ);
             insertEntity.setShouldBeRead(Constant.NO);
             insertEntity.setUserId(formDTO.getUserId());
+            insertEntity.setGridId(groupActInfoEntity.getGridId());
+            insertEntity.setGroupId(groupActInfoEntity.getGroupId());
             actReadRecordDao.insert(insertEntity);
         }else{
             if(GroupActConstant.UN_READ.equals(actReadRecordEntity.getRead())){