From 459aa78c84cf552ebea6ef056d978c2531d71ac8 Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期五, 06 三月 2026 17:14:27 +0800
Subject: [PATCH] 代码提交
---
smartor/src/main/java/com/smartor/service/impl/PatMedInhospServiceImpl.java | 148 ++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 146 insertions(+), 2 deletions(-)
diff --git a/smartor/src/main/java/com/smartor/service/impl/PatMedInhospServiceImpl.java b/smartor/src/main/java/com/smartor/service/impl/PatMedInhospServiceImpl.java
index 33ceda8..a6bc74a 100644
--- a/smartor/src/main/java/com/smartor/service/impl/PatMedInhospServiceImpl.java
+++ b/smartor/src/main/java/com/smartor/service/impl/PatMedInhospServiceImpl.java
@@ -9,6 +9,7 @@
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.StringUtils;
import com.smartor.domain.*;
+import com.smartor.domain.entity.ServiceSubtaskEntity;
import com.smartor.mapper.*;
import com.smartor.service.IPatMedInhospService;
import lombok.extern.slf4j.Slf4j;
@@ -389,6 +390,149 @@
return 1;
}
+ /**
+ * 澶氱淮搴﹂殢璁�
+ * @param config
+ * @return
+ */
+ public int dealOutHospInfoByDimension(String config) {
+ // 涓�娆℃�ф煡鍑烘墍鏈夐渶瑕佸鐞嗙殑鍑洪櫌鎮ｈ�咃紙涓変釜缁村害浠绘剰涓�涓湭瀹屾垚锛�
+ List<PatMedInhosp> patList = patMedInhospMapper.selectNeedProcessList();
+ log.info("銆愮粺涓�鎵弿銆戝緟澶勭悊鎮ｈ�呮暟锛歿}", patList.size());
+
+ for (PatMedInhosp patMedInhosp1 : patList) {
+ PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(patMedInhosp1.getPatid());
+ if (Objects.isNull(patArchive)) {
+ // 涓変釜缁村害閮芥爣璁颁负澶辫触
+ markAllFlagsAsError(patMedInhosp1, "鎮ｈ�呭熀鏈俊鎭负绌�");
+ continue;
+ }
+
+ // 鈹�鈹� 缁村害1锛氱瀹� 鈹�鈹�
+ if ("0".equals(patMedInhosp1.getDeptcheckFlag())) {
+ processTasksByDimension(patMedInhosp1, patArchive, config, 1);
+ }
+
+ // 鈹�鈹� 缁村害2锛氱梾鍖� 鈹�鈹�锛堟柊鍗庡尰闄㈣烦杩囷級
+ if (!active.equals("xh") && "0".equals(patMedInhosp1.getWardcheckFlag())) {
+ processTasksByDimension(patMedInhosp1, patArchive, config, 2);
+ }
+
+ // 鈹�鈹� 缁村害3锛氱柧鐥� 鈹�鈹�锛堟柊鍗庡尰闄㈣烦杩囷級
+ if (!active.equals("xh") && "0".equals(patMedInhosp1.getDiagcheckFlag())) {
+ processTasksByDimension(patMedInhosp1, patArchive, config, 3);
+ }
+ }
+ return 1;
+ }
+
+ /**
+ * 鎸夌淮搴︽壘鍒版墍鏈夊尮閰嶉暱鏈熶换鍔★紝鎵归噺鐢熸垚 subtask
+ * type: 1=绉戝, 2=鐥呭尯, 3=鐤剧梾
+ */
+ private void processTasksByDimension(PatMedInhosp patMedInhosp1,
+ PatArchive patArchive,
+ String config, int type) {
+ List<Long> matchedTaskIds = findMatchingTaskIds(patMedInhosp1, type);
+
+ if (CollectionUtils.isEmpty(matchedTaskIds)) {
+ String reason = getDimensionReason(type);
+ markFlagAsNoConfig(patMedInhosp1, type, reason);
+ return;
+ }
+
+ // 涓�鏉� inhosp 璁板綍 鈫� 澶氫釜鍖归厤浠诲姟 鈫� 澶氭潯 subtask
+ for (Long taskId : matchedTaskIds) {
+ writeInSubTask(taskId, true, patMedInhosp1, patArchive, type, config);
+ }
+ }
+
+ private String getDimensionReason(int type){
+ switch (type) {
+ case 1: { // 绉戝
+ return "鏈壘鍒扮瀹ゅ尮閰嶇殑闀挎湡浠诲姟";
+ }
+ case 2: { // 鐥呭尯
+ return "鏈壘鍒扮梾鍖哄尮閰嶇殑闀挎湡浠诲姟";
+ }
+ case 3: { // 鐤剧梾
+ return "鏈壘鍒扮柧鐥呭尮閰嶇殑闀挎湡浠诲姟";
+ }
+ }
+ return "澶氱淮闀挎湡浠诲姟-鍖归厤绫诲瀷涓虹┖";
+ }
+
+ private void markFlagAsNoConfig(PatMedInhosp patMedInhosp,
+ int type,
+ String reason){
+ switch (type) {
+ case 1: { // 绉戝
+ patMedInhosp.setDeptcheckFlag("2");
+ patMedInhosp.setRemark(reason);
+ patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
+ break;
+ }
+ case 2: { // 鐥呭尯
+ patMedInhosp.setWardcheckFlag("2");
+ patMedInhosp.setRemark(reason);
+ patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
+ break;
+ }
+ case 3: { // 鐤剧梾
+ patMedInhosp.setDiagcheckFlag("2");
+ patMedInhosp.setRemark(reason);
+ patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
+ break;
+ }
+ }
+
+ }
+
+ private void markAllFlagsAsError(PatMedInhosp patMedInhosp,
+ String reason){
+ patMedInhosp.setDeptcheckFlag("2");
+ patMedInhosp.setWardcheckFlag("2");
+ patMedInhosp.setDiagcheckFlag("2");
+ patMedInhosp.setRemark(reason);
+ patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
+ }
+ /**
+ * 鏍规嵁缁村害绫诲瀷鏌ヨ鍖归厤鐨勯暱鏈熶换鍔� ID 鍒楄〃
+ */
+ private List<Long> findMatchingTaskIds(PatMedInhosp patMedInhosp1, int type) {
+ switch (type) {
+ case 1: { // 绉戝
+ ServiceTaskdept query = new ServiceTaskdept();
+ query.setLongtask(1L);
+ query.setDeptCode(patMedInhosp1.getLeaveldeptcode());
+ query.setDeptType("1");
+ query.setOrgid(patMedInhosp1.getOrgid());
+ return serviceTaskdeptMapper.selectServiceTaskdeptList(query)
+ .stream().map(ServiceTaskdept::getTaskId).collect(Collectors.toList());
+ }
+ case 2: { // 鐥呭尯
+ ServiceTaskdept query = new ServiceTaskdept();
+ query.setLongtask(1L);
+ query.setDeptCode(patMedInhosp1.getLeavehospitaldistrictcode());
+ query.setDeptType("2");
+ query.setOrgid(patMedInhosp1.getOrgid());
+ return serviceTaskdeptMapper.selectServiceTaskdeptList(query)
+ .stream().map(ServiceTaskdept::getTaskId).collect(Collectors.toList());
+ }
+ case 3: { // 鐤剧梾
+ if (StringUtils.isEmpty(patMedInhosp1.getLeaveicd10code())) return Collections.emptyList();
+ ServiceTaskdiag query = new ServiceTaskdiag();
+ query.setLongtask(1L);
+ query.setIcd10code(patMedInhosp1.getLeaveicd10code());
+ query.setOrgid(patMedInhosp1.getOrgid());
+ return serviceTaskdiagMapper.selectServiceTaskdiagList(query)
+ .stream().map(ServiceTaskdiag::getTaskId).collect(Collectors.toList());
+ }
+ }
+ return Collections.emptyList();
+ }
+
+
//
// @Override
// public int dealOutHospInfo() {
@@ -609,7 +753,7 @@
//鍏堝垽鏂竴涓嬶紝鏄惁闇�瑕佹牎楠�
if (check && (Objects.isNull(serviceSubtask.getTaskSituation()) || serviceSubtask.getTaskSituation() != 6)) {
//鍦ㄦ柊澧炰箣鍓嶏紝鍏堥�氳繃鎮ｈ�匢D锛宻endstate=2鏌ヨ涓�涓嬶紝鍦ㄦ墍鏈夐暱鏈熶换鍔′腑锛屾槸涓嶆槸杩樻湁璇ユ偅鑰呭緟鎵ц鐨勪换鍔★紝鏈夌殑璇�,姣旇緝涔嬪墠鐨別ndtime鏄惁灏忎簬褰撳墠鐨別ndtaime,濡傛灉涔嬪墠鐨勫皬浜庣幇鍦ㄧ殑锛屽垯鐩存帴灏嗕箣鍓嶇殑鍋滄帀锛堝師鍥犲啀鍏ラ櫌锛�
- ServiceSubtaskVO subtask = new ServiceSubtaskVO();
+ ServiceSubtaskEntity subtask = new ServiceSubtaskEntity();
subtask.setPatid(patArchive.getId());
subtask.setSendstate(2L);
subtask.setTaskid(taskid);
@@ -906,7 +1050,7 @@
for (PatMedInhosp patMedInhosp1 : patMedInhospList) {
try {
//鑾峰彇褰撳墠鍏ラ櫌鎮ｈ�呯殑寰呮墽琛岀殑鍑洪櫌瀛愪换鍔￠殢璁夸俊鎭�
- ServiceSubtaskVO subtask = new ServiceSubtaskVO();
+ ServiceSubtaskEntity subtask = new ServiceSubtaskEntity();
subtask.setPatid(patMedInhosp1.getPatid());
subtask.setSendstate(2L);
List<ServiceSubtask> selectServiceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(subtask);
--
Gitblit v1.9.3