Browse Source

fix 自动回复

18339543638 3 years ago
parent
commit
babaf71a7a

+ 19 - 0
nb-admin/src/test/java/com/nb/admin/NotifyTest.java

@@ -1,6 +1,11 @@
 package com.nb.admin;
 
 import cn.hutool.json.JSONUtil;
+import com.nb.app.doctor.service.LocalAppDoctorUserService;
+import com.nb.im.entity.ImMsgEntity;
+import com.nb.im.enums.SponsorEnum;
+import com.nb.im.event.ImMsgEvent;
+import com.nb.im.service.LocalImMsgService;
 import com.nb.web.service.bus.job.DeviceFlowStatsJob;
 import com.nb.common.config.notice.msg.DiskMsg;
 import com.nb.common.config.notice.wechat.EnterpriseWeChatNotify;
@@ -33,6 +38,20 @@ public class NotifyTest {
     DiskSpaceHealthIndicator spaceHealthIndicator;
 
     @Autowired
+    LocalAppDoctorUserService appDoctorUserService;
+
+    @Autowired
+    LocalImMsgService imMsgService;
+    @Test
+    public void autoApply(){
+        ImMsgEntity byId = imMsgService.getById("1580015983344975874");
+        byId.setSponsor(SponsorEnum.assist);
+        ImMsgEvent imMsgEvent = new ImMsgEvent(this, byId);
+        appDoctorUserService.assistListener(imMsgEvent);
+        while (true){}
+
+    }
+
     @Test
     public void test(){
         flowStatsJob.flowStats();

+ 1 - 1
nb-common/config-common/src/main/java/com/nb/common/config/web/handler/CheckRequestHandler.java

@@ -29,7 +29,7 @@ import java.util.concurrent.TimeUnit;
  * @Description
  * @createTime 2022年06月09日 14:11:00
  */
-@Configuration
+//@Configuration
 @ConditionalOnProperty(value = "request.check.enable",havingValue = "true",matchIfMissing = false)
 @Order(10)
 @Slf4j

+ 1 - 1
nb-core/src/main/java/com/nb/core/doc/SwaggerConfig.java

@@ -26,7 +26,7 @@ import java.util.*;
 @Configuration
 @EnableKnife4j
 @EnableSwagger2WebMvc
-@Profile("dev")
+//@Profile("dev")
 public class SwaggerConfig implements WebMvcConfigurer {
 
     public static final String VERSION = "1.0.0";

+ 1 - 1
nb-service/app-doctor/src/main/java/com/nb/app/doctor/service/LocalAppDoctorUserService.java

@@ -229,7 +229,7 @@ public class LocalAppDoctorUserService extends BaseService<AppDoctorUserMapper,
         //判断是否处于勿扰模式
         String imRoomId = entity.getRoomId();
         ImRoomEntity room = roomService.getById(imRoomId);
-        if(!ImStatusEnum.SUCCESS.equals(room.getStatus())){
+        if(!ImStatusEnum.SUCCESS.equals(room.getStatus())&&!ImStatusEnum.WAITING.equals(room.getStatus())){
             return;
         }
         AppUserConsultConfigEntity consultConfig = consultConfigService.getOne(new QueryWrapper<AppUserConsultConfigEntity>().lambda()