From 29069b790469cb7136cadba7ddcd63a83bc4ac70 Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期一, 23 三月 2026 15:20:20 +0800
Subject: [PATCH] 门急诊分表代码（增、改、查）提交
---
smartor/src/main/java/com/smartor/service/impl/PatMedOuthospServiceImpl.java | 180 +++++++++++++++++++++++++++++++++++++++++++++---------------
1 files changed, 135 insertions(+), 45 deletions(-)
diff --git a/smartor/src/main/java/com/smartor/service/impl/PatMedOuthospServiceImpl.java b/smartor/src/main/java/com/smartor/service/impl/PatMedOuthospServiceImpl.java
index 473c457..6d833d5 100644
--- a/smartor/src/main/java/com/smartor/service/impl/PatMedOuthospServiceImpl.java
+++ b/smartor/src/main/java/com/smartor/service/impl/PatMedOuthospServiceImpl.java
@@ -1,26 +1,26 @@
package com.smartor.service.impl;
+import com.ruoyi.common.utils.DateUtils;
+import com.ruoyi.common.utils.DtoConversionUtils;
+import com.ruoyi.common.utils.StringUtils;
+import com.smartor.domain.*;
+import com.smartor.domain.entity.ServiceSubtaskEntity;
+import com.smartor.mapper.*;
+import com.smartor.service.IPatMedOuthospService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import javax.sql.DataSource;
+import java.sql.Connection;
+import java.sql.Statement;
import java.time.LocalDate;
import java.time.Period;
import java.time.ZoneId;
import java.time.temporal.ChronoUnit;
import java.util.*;
-
-import com.ruoyi.common.core.domain.entity.SysDept;
-import com.ruoyi.common.core.domain.entity.SysUserDept;
-import com.ruoyi.common.utils.DateUtils;
-import com.ruoyi.common.utils.DtoConversionUtils;
-import com.ruoyi.common.utils.SecurityUtils;
-import com.ruoyi.common.utils.StringUtils;
-import com.smartor.domain.*;
-import com.smartor.mapper.*;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.ObjectUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.cache.annotation.Cacheable;
-import org.springframework.stereotype.Service;
-import com.smartor.service.IPatMedOuthospService;
-import org.springframework.util.CollectionUtils;
/**
* 鎮ｈ�呴棬璇婅褰昐ervice涓氬姟灞傚鐞�
@@ -35,7 +35,7 @@
private PatMedOuthospMapper patMedOuthospMapper;
@Autowired
- private SysUserDeptMapper sysUserDeptMapper;
+ private DataSource dataSource;
@Autowired
private ServiceSubtaskMapper serviceSubtaskMapper;
@@ -61,7 +61,8 @@
*/
@Override
public PatMedOuthosp selectPatMedOuthospById(Long id) {
- return patMedOuthospMapper.selectPatMedOuthospById(id);
+// return patMedOuthospMapper.selectPatMedOuthospById(id);
+ return null;
}
/**
@@ -72,9 +73,10 @@
*/
@Override
public List<PatMedOuthosp> selectPatMedOuthospList(PatMedOuthosp patMedOuthosp) {
- List<PatMedOuthosp> patMedOuthosps = patMedOuthospMapper.selectPatMedOuthospList(patMedOuthosp);
+ PatMedOuthospQueryReq patMedOuthospQueryReq = DtoConversionUtils.sourceToTarget(patMedOuthosp, PatMedOuthospQueryReq.class);
+ List<PatMedOuthosp> patMedOuthospQueryResps = patMedOuthospMapper.callSpQueryOuthosp(patMedOuthospQueryReq);
if (patMedOuthosp.getPageNum() != null) {
- for (PatMedOuthosp patMedOuthosp1 : patMedOuthosps) {
+ for (PatMedOuthosp patMedOuthosp1 : patMedOuthospQueryResps) {
PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(patMedOuthosp1.getPatid());
if (patArchive.getBirthdate() != null) {
Map<String, String> map = calculateAge(patArchive.getBirthdate().toInstant().atZone(ZoneId.systemDefault()).toLocalDate(), LocalDate.now());
@@ -88,7 +90,7 @@
patMedOuthosp1.setTelcode(patArchive.getTelcode());
patMedOuthosp1.setIdcardno(patArchive.getIdcardno());
}
- ServiceSubtaskVO serviceSubtaskVO = new ServiceSubtaskVO();
+ ServiceSubtaskEntity serviceSubtaskVO = new ServiceSubtaskEntity();
serviceSubtaskVO.setPatid(patMedOuthosp1.getPatid());
List<Long> sendstates = new ArrayList<>();
sendstates.add(1L);
@@ -100,7 +102,7 @@
if (!CollectionUtils.isEmpty(serviceSubtaskList)) patMedOuthosp1.setServerState("1");
}
}
- return patMedOuthosps;
+ return patMedOuthospQueryResps;
}
public Map<String, String> calculateAge(LocalDate birthdate, LocalDate today) {
@@ -157,27 +159,109 @@
/**
* 鏂板鎮ｈ�呴棬璇婅褰�
+ * 鏍规嵁 admitdate 璺敱鍒板搴斿垎琛紱鑻ュ垎琛ㄤ笉瀛樺湪鍒欏啓鍏ヤ富琛�
*
* @param patMedOuthosp 鎮ｈ�呴棬璇婅褰�
* @return 缁撴灉
*/
@Override
public int insertPatMedOuthosp(PatMedOuthosp patMedOuthosp) {
+ if (patMedOuthosp.getAdmitdate() != null) {
+ log.error("闂ㄦ�ュ氨璇婃椂闂翠笉鑳戒负绌�");
+ return 0;
+ }
patMedOuthosp.setCreateTime(DateUtils.getNowDate());
patMedOuthosp.setUpdateTime(DateUtils.getNowDate());
- return patMedOuthospMapper.insertPatMedOuthosp(patMedOuthosp);
+ patMedOuthosp.setGuid(UUID.randomUUID().toString());
+ //闇�瑕佹彃鍏ュ埌鍝釜琛紝鏍规嵁灏辫瘖鏃堕棿鐨勬棩鏈熸潵瀹氾紝濡傛灉鏍规嵁灏辫瘖鏃堕棿鏉ョ‘瀹氱殑琛ㄤ笉瀛樺湪锛屽垯瀛樺湪pat_med_outhosp琛ㄤ腑
+ String targetTable = resolveTargetTable(patMedOuthosp.getAdmitdate());
+ if (targetTable != null) {
+ log.info("[insert] 璺敱鍒板垎琛�: {}", targetTable);
+ return patMedOuthospMapper.insertIntoTable(targetTable, patMedOuthosp);
+ }
+ return 0;
}
/**
* 淇敼鎮ｈ�呴棬璇婅褰�
+ * 鏍规嵁 admitdate 璺敱鍒板搴斿垎琛紱鑻ュ垎琛ㄤ笉瀛樺湪鍒欐敼涓昏〃
*
* @param patMedOuthosp 鎮ｈ�呴棬璇婅褰�
* @return 缁撴灉
*/
@Override
public int updatePatMedOuthosp(PatMedOuthosp patMedOuthosp) {
- patMedOuthosp.setUpdateTime(DateUtils.getNowDate());
- return patMedOuthospMapper.updatePatMedOuthosp(patMedOuthosp);
+ if (patMedOuthosp.getSerialnum() == null) {
+ log.error("娴佹按鍙蜂笉鑳戒负绌�");
+ return 0;
+ }
+ PatMedOuthospQueryReq patMedOuthospQueryReq = new PatMedOuthospQueryReq();
+ patMedOuthospQueryReq.setSerialnum(patMedOuthosp.getSerialnum());
+ patMedOuthospQueryReq.setGuid(patMedOuthosp.getGuid());
+ patMedOuthospQueryReq.setOuthospno(patMedOuthosp.getOuthospno());
+ List<PatMedOuthosp> patMedOuthosps = patMedOuthospMapper.callSpQueryOuthosp(patMedOuthospQueryReq);
+
+ if (patMedOuthosps == null || patMedOuthosps.size() == 0) {
+ insertPatMedOuthosp(patMedOuthosp);
+ } else {
+ patMedOuthosp.setUpdateTime(DateUtils.getNowDate());
+ String targetTable = resolveTargetTable(patMedOuthosp.getAdmitdate());
+ if (targetTable != null) {
+ log.info("[update] 璺敱鍒板垎琛�: {}", targetTable);
+ return patMedOuthospMapper.updateInTable(targetTable, patMedOuthosp);
+ }
+ }
+ return 0;
+ }
+
+ /**
+ * 鏍规嵁 create_time 鎺ㄧ畻鐩爣鍒嗚〃鍚嶏紝涓庡缓琛ㄧ瓥鐣ヤ繚鎸佷竴鑷�
+ * <ul>
+ * <li>6浣嶅悗缂�锛圷YYYMM锛夆啋 鎸夋湀鍒嗚〃</li>
+ * <li>8浣嶅悗缂�锛圷YYYMMdd锛夆啋 鎸夊搴﹀垎琛紝瀛ｅ害鍚庣紑鍥哄畾涓� 0103/0406/0709/1012</li>
+ * <li>4浣嶅悗缂�锛圷YYY锛� 鈫� 鎸夊勾鍒嗚〃</li>
+ * </ul>
+ * 鎺ㄧ畻鍑鸿〃鍚嶅悗鏍￠獙琛ㄦ槸鍚﹀瓨鍦紝涓嶅瓨鍦ㄨ繑鍥� null锛堝洖钀戒富琛級
+ *
+ * @param createTime 鍒涘缓鏃堕棿锛屼负 null 鏃惰繑鍥� null
+ * @return 鐩爣鍒嗚〃鍚嶏紝鎴� null
+ */
+ private String resolveTargetTable(java.util.Date createTime) {
+ if (createTime == null) return null;
+ List<String> allTables = patMedOuthospMapper.getAllOuthospTableNames();
+ if (allTables == null || allTables.isEmpty()) return null;
+
+ // 鍒ゆ柇褰撳墠鍒嗚〃鍚庣紑闀垮害锛堜互绗竴寮犺〃涓哄噯锛�
+ String sample = allTables.get(0);
+ String suffix = sample.replaceFirst("pat_med_outhosp_", "");
+ int suffixLen = suffix.length();
+
+ java.util.Calendar cal = java.util.Calendar.getInstance();
+ cal.setTime(createTime);
+ int year = cal.get(java.util.Calendar.YEAR);
+ int month = cal.get(java.util.Calendar.MONTH) + 1; // 1-based
+
+ String targetTable;
+ if (suffixLen == 4) {
+ // 鎸夊勾
+ targetTable = "pat_med_outhosp_" + year;
+ } else if (suffixLen == 6) {
+ // 鎸夋湀
+ targetTable = String.format("pat_med_outhosp_%d%02d", year, month);
+ } else {
+ // 鎸夊搴︼紙8浣嶅悗缂�锛屽 20260103锛�
+ String quarterSuffix;
+ if (month <= 3) quarterSuffix = "0103";
+ else if (month <= 6) quarterSuffix = "0406";
+ else if (month <= 9) quarterSuffix = "0709";
+ else quarterSuffix = "1012";
+ targetTable = "pat_med_outhosp_" + year + quarterSuffix;
+ }
+
+ boolean exists = allTables.contains(targetTable);
+
+ log.info("[璺敱] createTime={} 鈫� 鐩爣琛�={} exists={}", createTime, targetTable, exists);
+ return exists ? targetTable : "pat_med_outhosp";
}
/**
@@ -188,7 +272,8 @@
*/
@Override
public int deletePatMedOuthospByIds(Long[] ids) {
- return patMedOuthospMapper.deletePatMedOuthospByIds(ids);
+// return patMedOuthospMapper.deletePatMedOuthospByIds(ids);
+ return 0;
}
/**
@@ -199,22 +284,26 @@
*/
@Override
public int deletePatMedOuthospById(Long id) {
- return patMedOuthospMapper.deletePatMedOuthospById(id);
+// return patMedOuthospMapper.deletePatMedOuthospById(id);
+ return 0;
}
@Override
public PatMedRes selectPatMedOuthospCount(PatMedReq patMedReq) {
-// // 鑾峰彇褰撳墠鐧婚檰浜虹殑閮ㄩ棬鏉冮檺
-// if (CollectionUtils.isEmpty(patMedReq.getDeptcodeList())) {
-// Long userId = SecurityUtils.getUserId();
-// List<SysDept> sysDepts = sysUserDeptMapper.selectDeptListByUserId(userId);
-// List<String> deptCode = new ArrayList<>();
-// for (SysDept sysDept : sysDepts) {
-// deptCode.add(sysDept.getDeptId().toString());
-// }
-// patMedReq.setDeptcodeList(deptCode);
-// }
- return patMedOuthospMapper.selectPatMedOuthospCount(patMedReq);
+ //鑾峰彇闂ㄨ瘖鐥呬汉淇℃伅锛屽苟缁熻浜烘暟鍜屼汉娆�
+ PatMedOuthospQueryReq req = new PatMedOuthospQueryReq();
+ String deptcodes = CollectionUtils.isEmpty(patMedReq.getDeptcodeList()) ? null : String.join(",", patMedReq.getDeptcodeList());
+ req.setBeginAdmitdate(patMedReq.getStartDate());
+ req.setEndAdmitdate(patMedReq.getEndDate());
+ req.setDeptcode(deptcodes);
+ req.setOrgid(patMedReq.getOrgid());
+// req.setCampusid(patMedReq.getCampusid());
+ Long count = patMedOuthospMapper.callSpQueryOuthospCount(req);
+
+ //鏌ヨ闅忚浜烘鍜屼汉鏁�
+ PatMedRes patMedRes = serviceSubtaskMapper.selectVisitCount(patMedReq);
+ patMedRes.setRc(count == null ? 0 : count.intValue());
+ return patMedRes;
}
@Override
@@ -248,7 +337,7 @@
if (org.apache.commons.collections4.CollectionUtils.isEmpty(serviceTaskdeptList) || serviceTaskdeptList.size() == 0) {
patMedOuthosp1.setDeptcheckFlag("2");
patMedOuthosp1.setRemark("閫氳繃閮ㄩ棬,娌℃湁鎵惧埌闂ㄨ瘖闅忚浠诲姟ID");
- patMedOuthospMapper.updatePatMedOuthosp(patMedOuthosp1);
+ updatePatMedOuthosp(patMedOuthosp1);
} else {
for (ServiceTaskdept serviceTaskdept1 : serviceTaskdeptList) {
writeInSubTask(serviceTaskdept1.getTaskId(), true, patMedOuthosp1, patArchive, 1);
@@ -264,7 +353,7 @@
if (org.apache.commons.collections4.CollectionUtils.isEmpty(serviceTaskdiags) || serviceTaskdiags.size() == 0) {
patMedOuthosp1.setDiagcheckFlag("2");
patMedOuthosp1.setRemark("閫氳繃icd10,娌℃湁鎵惧埌闂ㄨ瘖闅忚浠诲姟ID");
- patMedOuthospMapper.updatePatMedOuthosp(patMedOuthosp1);
+ updatePatMedOuthosp(patMedOuthosp1);
} else {
for (ServiceTaskdiag serviceTaskdept1 : serviceTaskdiags) {
writeInSubTask(serviceTaskdept1.getTaskId(), true, patMedOuthosp1, patArchive, 2);
@@ -293,7 +382,7 @@
if (type == 1) patMedOuthosp.setDiagcheckFlag("2");
if (type == 2) patMedOuthosp.setDeptcheckFlag("2");
patMedOuthosp.setRemark("璇ユ偅鑰呴棬璇婇殢璁块暱鏈熶换鍔′笉瀛樺湪,浠诲姟ID涓�:" + taskid);
- patMedOuthospMapper.updatePatMedOuthosp(patMedOuthosp);
+ updatePatMedOuthosp(patMedOuthosp);
return;
}
ServiceTask serviceTask = serviceTasks.get(0);
@@ -303,7 +392,7 @@
//鍏堝垽鏂竴涓嬶紝鏄惁闇�瑕佹牎楠�
if (check) {
//鍦ㄦ柊澧炰箣鍓嶏紝鍏堥�氳繃鎮ｈ�匢D锛宻endstate=2鏌ヨ涓�涓嬶紝鍦ㄦ墍鏈夐暱鏈熶换鍔′腑锛屾槸涓嶆槸杩樻湁璇ユ偅鑰呭緟鎵ц鐨勪换鍔★紝鏈夌殑璇�,姣旇緝涔嬪墠鐨別ndtime鏄惁灏忎簬褰撳墠鐨別ndtaime,濡傛灉涔嬪墠鐨勫皬浜庣幇鍦ㄧ殑锛屽垯鐩存帴灏嗕箣鍓嶇殑鍋滄帀锛堝師鍥犲啀鍏ラ櫌锛�
- ServiceSubtaskVO subtask = new ServiceSubtaskVO();
+ ServiceSubtaskEntity subtask = new ServiceSubtaskEntity();
subtask.setPatid(patArchive.getId());
subtask.setSendstate(2L);
subtask.setTaskid(taskid);
@@ -355,16 +444,17 @@
patMedOuthosp1.setId(patMedOuthosp.getId());
if (type == 1) patMedOuthosp1.setDiagcheckFlag("2");
if (type == 2) patMedOuthosp1.setDeptcheckFlag("2");
- patMedOuthospMapper.updatePatMedOuthosp(patMedOuthosp1);
+ updatePatMedOuthosp(patMedOuthosp1);
} else {
//鐢熸垚瀛愪换鍔″け璐ワ紝
log.info("鐢熸垚瀛愪换鍔″け璐erviceSubtask鐨則askid涓猴細{},patid涓猴細{}", serviceSubtask.getTaskid(), serviceSubtask.getPatid());
PatMedOuthosp pmo = new PatMedOuthosp();
- pmo.setId(patMedOuthosp.getId());
+ pmo.setGuid(patMedOuthosp.getGuid());
+ pmo.setSerialnum(patMedOuthosp.getSerialnum());
if (type == 1) pmo.setDiagcheckFlag("2");
if (type == 2) pmo.setDeptcheckFlag("2");
pmo.setRemark("鐢熸垚瀛愪换鍔″け璐�");
- patMedOuthospMapper.updatePatMedOuthosp(pmo);
+ updatePatMedOuthosp(pmo);
}
}
--
Gitblit v1.9.3