Merge remote-tracking branch 'origin/dev_group_act_notice' into dev_group_act_notice

epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/act/service/impl/GroupActInfoServiceImpl.java

@@ -193,8 +193,6 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
     }
 
     private void saveActReadRecord(GroupActInfoEntity groupActInfoEntity,List<ResiGroupMemberDTO> memberDTOList) {
-        /*String actReadKey= RedisKeys.getGroupMsgReadKey(GroupActConstant.ACT_STR,groupActInfoEntity.getGroupId(),groupActInfoEntity.getId());
-        String actShoudReadUserKey=RedisKeys.getGroupMsgShouldReadUser(GroupActConstant.ACT_STR,groupActInfoEntity.getGroupId(),groupActInfoEntity.getId());*/
         List<ActReadRecordEntity> readRecordEntityList=new ArrayList<>();
         memberDTOList.forEach(memberDTO->{
             ActReadRecordEntity actReadRecordEntity=new ActReadRecordEntity();
@@ -206,11 +204,8 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
             actReadRecordEntity.setGroupId(groupActInfoEntity.getGroupId());
             actReadRecordEntity.setGridId(groupActInfoEntity.getGridId());
             if(!groupActInfoEntity.getPublishUserId().equals(memberDTO.getCustomerUserId())){
+                //组长不记录 已读记录
                 readRecordEntityList.add(actReadRecordEntity);
-               /* //默认是未读
-                redisUtils.setBit(actReadKey,memberDTO.getTempNum(),false);
-                //当前所有成员默认应读
-                redisUtils.setBit(actShoudReadUserKey,memberDTO.getTempNum(),true);*/
             }
         });
         readRecordEntityList.forEach(readRecordEntity->{
@@ -505,27 +500,30 @@ public class GroupActInfoServiceImpl extends BaseServiceImpl<GroupActInfoDao, Gr
         resultDTO.setUserRole(resiGroupMemberDTO.getGroupLeaderFlag());
         // 有签到后不可以修改活动时间：true可以修改，false不可以，
         resultDTO.setStartTimeEditFlag(groupActInfoEntity.getSignedInNum() > NumConstant.ZERO ? false : true);
-        //返回详情，并且已读状态
+        if (!GroupActConstant.CLOSED.equals(groupActInfoEntity.getStatus())) {
-        ActReadRecordEntity actReadRecordEntity=actReadRecordDao.selectUserRec(formDTO.getGroupActId(),formDTO.getUserId());
+            //如果活动关闭，则不更新已读记录
-        if(null== actReadRecordEntity){
+            //非关闭状态下，返回详情，并且已读状态
-            if(!GroupActConstant.CLOSED.equals(groupActInfoEntity.getStatus())){
+            ActReadRecordEntity actReadRecordEntity = actReadRecordDao.selectUserRec(formDTO.getGroupActId(), formDTO.getUserId());
-                //插入已读记录，默认不属于应读人。
+            if (null == actReadRecordEntity) {
-                ActReadRecordEntity insertEntity=new ActReadRecordEntity();
+                if (!GroupActConstant.CLOSED.equals(groupActInfoEntity.getStatus())) {
-                insertEntity.setCustomerId(groupActInfoEntity.getCustomerId());
+                    //插入已读记录，默认不属于应读人。
-                insertEntity.setGroupActId(formDTO.getGroupActId());
+                    ActReadRecordEntity insertEntity = new ActReadRecordEntity();
-                insertEntity.setReadFlag(GroupActConstant.READ);
+                    insertEntity.setCustomerId(groupActInfoEntity.getCustomerId());
-                insertEntity.setShouldBeRead(Constant.NO);
+                    insertEntity.setGroupActId(formDTO.getGroupActId());
-                insertEntity.setUserId(formDTO.getUserId());
+                    insertEntity.setReadFlag(GroupActConstant.READ);
-                insertEntity.setGridId(groupActInfoEntity.getGridId());
+                    insertEntity.setShouldBeRead(Constant.NO);
-                insertEntity.setGroupId(groupActInfoEntity.getGroupId());
+                    insertEntity.setUserId(formDTO.getUserId());
-                actReadRecordDao.insert(insertEntity);
+                    insertEntity.setGridId(groupActInfoEntity.getGridId());
-            }
+                    insertEntity.setGroupId(groupActInfoEntity.getGroupId());
-        }else{
+                    actReadRecordDao.insert(insertEntity);
-            if(GroupActConstant.UN_READ.equals(actReadRecordEntity.getReadFlag())){
+                }
-                //未读->已读
+            } else {
-                actReadRecordEntity.setReadFlag(GroupActConstant.READ);
+                if (GroupActConstant.UN_READ.equals(actReadRecordEntity.getReadFlag())) {
-                actReadRecordEntity.setUpdatedTime(new Date());
+                    //未读->已读
-                actReadRecordDao.updateById(actReadRecordEntity);
+                    actReadRecordEntity.setReadFlag(GroupActConstant.READ);
+                    actReadRecordEntity.setUpdatedTime(new Date());
+                    actReadRecordDao.updateById(actReadRecordEntity);
+                }
             }
         }
         return resultDTO;