医生提交病案质控审核后，给审核员发送socket消息

src/main/java/thyyxxk/webserver/dao/his/inpatient/casefrontsheet/QualityVerificationDao.java

@@ -1,9 +1,15 @@
 package thyyxxk.webserver.dao.his.inpatient.casefrontsheet;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Select;
 import org.mapstruct.Mapper;
 import thyyxxk.webserver.entity.casefrontsheet.FrontsheetQualityVerification;
 
+import java.util.List;
+
 @Mapper
 public interface QualityVerificationDao extends BaseMapper<FrontsheetQualityVerification> {
+
+    @Select("select user_code from dj_user_role where role_id=66")
+    List<String> selectAuditors();
 }

src/main/java/thyyxxk/webserver/service/inpatient/casefrontsheet/CaseFrontSheetMainService.java

@@ -30,7 +30,9 @@ import thyyxxk.webserver.entity.casefrontsheet.state.State;
 import thyyxxk.webserver.entity.covid.Region;
 import thyyxxk.webserver.entity.dictionary.CodeName;
 import thyyxxk.webserver.entity.dictionary.HisWjwMatchEntity;
+import thyyxxk.webserver.entity.socketmessage.SendUserList;
 import thyyxxk.webserver.service.externalhttp.PowersiSrvc;
+import thyyxxk.webserver.service.externalhttp.WebSocketService;
 import thyyxxk.webserver.service.redislike.RedisLikeService;
 import thyyxxk.webserver.service.zhuyuanyisheng.emr.EmrServer;
 import thyyxxk.webserver.utils.*;
@@ -52,9 +54,10 @@ public class CaseFrontSheetMainService {
     private final PowersiSrvc srvc;
     private final EmrServer emrService;
     private final RedisLikeService redis;
+    private final WebSocketService socketService;
 
     public CaseFrontSheetMainService(SheetCreatedDao createdDao, CaseFrontSheetDao dao, BasSelectOverviewDao basDao,
-                                     LoginDao userDao, QualityVerificationDao qualityVerificationDao, PowersiSrvc srvc, EmrServer emrService, RedisLikeService redis) {
+                                     LoginDao userDao, QualityVerificationDao qualityVerificationDao, PowersiSrvc srvc, EmrServer emrService, RedisLikeService redis, WebSocketService socketService) {
         this.dao = dao;
         this.createdDao = createdDao;
         this.basDao = basDao;
@@ -63,6 +66,7 @@ public class CaseFrontSheetMainService {
         this.srvc = srvc;
         this.emrService = emrService;
         this.redis = redis;
+        this.socketService = socketService;
         if (allDictionary == null) {
             allDictionary = new ConcurrentHashMap<>();
         }
@@ -1142,6 +1146,9 @@ public class CaseFrontSheetMainService {
         request.setApplicationTime(new Date());
         int result = qualityVerificationDao.insert(request);
         if (result == 1) {
+            List<String> auditors = qualityVerificationDao.selectAuditors();
+            String message = "有新的病案质控申请。";
+            socketService.sendUserListMessage(new SendUserList(auditors, message));
             return "OK";
         }
         return "提交审核失败，请稍后再试。";