病案审核后给医生发送socket消息

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

@@ -1,5 +1,6 @@
 package thyyxxk.webserver.service.inpatient.casefrontsheet;
 
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
@@ -30,6 +31,7 @@ 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.ApiMessageBody;
 import thyyxxk.webserver.entity.socketmessage.SendUserList;
 import thyyxxk.webserver.service.externalhttp.PowersiSrvc;
 import thyyxxk.webserver.service.externalhttp.WebSocketService;
@@ -1171,10 +1173,19 @@ public class CaseFrontSheetMainService {
         request.setAuditStaffName(redis.getEmployeeName(userCode));
         request.setAuditTime(new Date());
         int result = qualityVerificationDao.updateById(request);
-        if (request.getAuditState() == AuditState.APPROVED && result == 1) {
-            insertSheetAfterPrint(request.getSheet());
+        if (result == 1) {
+            String message;
+            if (request.getAuditState() == AuditState.APPROVED) {
+                insertSheetAfterPrint(request.getSheet());
+                message = StrUtil.format("【患者：{}-{}】病案首页质控审核已通过。");
+            } else {
+                message = StrUtil.format("【患者：{}-{}】病案首页质控审核已驳回，请前往【审核记录】查看。");
+            }
+            ApiMessageBody apiMessageBody = new ApiMessageBody(request.getDoctorCode(), message);
+            socketService.sendMessageByUserCode(apiMessageBody);
+            return "OK";
         }
-        return result == 1 ? "OK" : "数据库错误，请联系管理员。";
+        return "数据库错误，请联系管理员。";
     }
 
     public List<FrontsheetQualityVerification> fetchAuditHistories(FrontsheetQualityVerification request) {