Explorar el Código

add 持久化消息进行保存

18339543638 hace 3 años
padre
commit
58b71577f0
Se han modificado 1 ficheros con 3 adiciones y 4 borrados
  1. 3 4
      nb-im/src/main/java/com/nb/im/utils/ImUtils.java

+ 3 - 4
nb-im/src/main/java/com/nb/im/utils/ImUtils.java

@@ -87,10 +87,9 @@ public class ImUtils {
         if(ObjectUtil.equal(assitId,roomMsg.getSenderId())){
             roomMsg.setSponsor(SponsorEnum.assist);
         }
-        imRoomMsgService.save(roomMsg);
 
-
-        if(pubMsgInfo.isTmp()){
+        if(!pubMsgInfo.isTmp()){
+            imRoomMsgService.save(roomMsg);
             //更新聊天室信息
             roomService.update(new UpdateWrapper<ImRoomEntity>()
                     .lambda()
@@ -128,7 +127,7 @@ public class ImUtils {
                     }
                 });
 
-        if(pubMsgInfo.isTmp()){
+        if(!pubMsgInfo.isTmp()){
             String senderId = pubMsgInfo.getSenderId();
             roomOperator.addUnreadMsg(senderId.equals(roomOperator.getAssitId())?roomOperator.getDoctorId():roomOperator.getAssitId(),Arrays.asList(pubMsgInfo.getKey()));
         }