Kaynağa Gözat

fix 绑定关系更新后聊天室随之更新

18339543638 3 yıl önce
ebeveyn
işleme
c00ef179e3

+ 1 - 0
nb-im/src/main/java/com/nb/im/service/LocalImRoomService.java

@@ -100,6 +100,7 @@ public class LocalImRoomService extends BaseService<ImRoomMapper, ImRoomEntity,S
                 .eq(ImRoomEntity::getDoctorId,doctorId)
                 .eq(ImRoomEntity::getPatientId,oldPatientId)
                 .in(ImRoomEntity::getStatus,ImStatusEnum.WAITING,ImStatusEnum.SUCCESS)
+                .set(StrUtil.isNotEmpty(param.getDoctorId()), ImRoomEntity::getDoctorId, param.getDoctorId())
                 .set(StrUtil.isNotEmpty(param.getPatientId()), ImRoomEntity::getPatientId, param.getPatientId())
                 .set(StrUtil.isNotEmpty(param.getPatientAge()), ImRoomEntity::getPatientAge, param.getPatientAge())
                 .set(StrUtil.isNotEmpty(param.getPatientCode()), ImRoomEntity::getPatientCode, param.getPatientCode())

+ 2 - 0
nb-service-api/app-assistant-api/src/main/java/com/nb/app/assistant/api/feign/result/UpdateBindPatientParam.java

@@ -25,6 +25,8 @@ public class UpdateBindPatientParam {
 
     private String patientAge;
 
+    private String doctorId;
+
     @ApiModelProperty("绑定关系id")
     @NotNull(message = "绑定关系id不能为空")
     private String bindId;

+ 2 - 7
nb-service/app-assistant/src/main/java/com/nb/app/assistant/service/LocalAssistantUserBindService.java

@@ -40,6 +40,7 @@ import com.nb.common.queue.delay.manager.DelayMessageManager;
 import com.nb.common.queue.delay.message.DelayMessage;
 import com.nb.common.queue.delay.message.DelayMessageProperties;
 import com.nb.core.Value;
+import com.nb.core.enums.SexEnum;
 import com.nb.core.enums.StatusEnum;
 import com.nb.core.exception.CustomException;
 import com.nb.core.sms.SmsHelper;
@@ -464,7 +465,6 @@ public class LocalAssistantUserBindService extends BaseService<AssistantUserBind
         AssistantUserResult assistantUser = userService.getById(userBind.getAssistId());
         if(BindEnum.WAITING.equals(userBind.getStatus())){
             AssistantUserBindEntity userBindEntity = BeanUtil.toBean(source, AssistantUserBindEntity.class);
-            String patientNameHis = userBindEntity.getPatientName();
             boolean result = this.updateById(userBindEntity);
             if(result){
                 SpringUtil.publishEvent(new SaveMsgEvent(
@@ -486,15 +486,10 @@ public class LocalAssistantUserBindService extends BaseService<AssistantUserBind
                                 .extend(userBind.getInviteCode())
                                 .sys(false)
                                 .build()));
-
                 //更新最新的聊天室信息
                 UpdateBindPatientParam patientParam = new UpdateBindPatientParam();
+                BeanUtil.copyProperties(userBindEntity,patientParam);
                 patientParam.setBindId(userBindEntity.getId());
-                patientParam.setPatientAge(String.valueOf(userBindEntity.getPatientAge()));
-                patientParam.setPatientCode(userBindEntity.getPatientCode());
-                patientParam.setPatientId(userBindEntity.getPatientId());
-                patientParam.setPatientSex(userBindEntity.getPatientSex());
-                patientParam.setPatientName(userBindEntity.getPatientName());
                 SpringUtil.publishEvent(new UpdateBindPatientEvent(this,patientParam,userBindEntity.getAssistId(),userBindEntity.getDoctorId(),userBindEntity.getPatientId()));
             }
             return result;