add

未读消息去除医生进入进出

tr-modules/tr-module-mobile/src/main/java/cn/tr/module/mobile/dto/ImMsgUnreadTotalCountQueryDTO.java

@@ -10,4 +10,7 @@ public class ImMsgUnreadTotalCountQueryDTO {
     @ApiModelProperty(value = "用户id",required = true)
     @NotBlank(message = "用户id不能为空")
     private String userId;
+
+    @ApiModelProperty("手术id")
+    private String clinicId;
 }

tr-modules/tr-module-mobile/src/main/java/cn/tr/module/mobile/service/impl/ImMsgReceivedServiceImpl.java

@@ -147,7 +147,8 @@ public class ImMsgReceivedServiceImpl implements IImMsgReceivedService {
                 }
             };
             LocalSendHelper.sendData(p, resultObserver);
-        }else if(Boolean.TRUE.equals(offlineSave)) {
+        }else if(Boolean.TRUE.equals(offlineSave)
+                &&(!StrUtil.equalsAny(msg.getType(),MsgContentType.DOCTOR_IN,MsgContentType.DOCTOR_OUT))) {
             //不在线的时候更新未读
             ImGroupUserPO groupUserPO = groupUserRepository.selectOne(new LambdaQueryWrapper<ImGroupUserPO>()
                     .eq(ImGroupUserPO::getUserId, msg.getToUserId())
@@ -186,6 +187,7 @@ public class ImMsgReceivedServiceImpl implements IImMsgReceivedService {
     @Override
     public Long selectUndReadTotalCount(ImMsgUnreadTotalCountQueryDTO query){
         List<ImGroupUserPO> imGroupUserList = groupUserRepository.selectList(new LambdaQueryWrapper<ImGroupUserPO>()
+                .eq(StrUtil.isNotBlank(query.getClinicId()),ImGroupUserPO::getGroupId,query.getClinicId())
                 .eq(ImGroupUserPO::getUserId, query.getUserId()));
         if(CollectionUtil.isEmpty(imGroupUserList)){
             return 0L;