package com.smartor.service.impl;
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.google.gson.Gson;
|
import com.google.gson.reflect.TypeToken;
|
import com.ruoyi.common.core.domain.entity.SysDept;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import com.ruoyi.common.core.domain.entity.SysUserDept;
|
import com.ruoyi.common.core.domain.entity.SysUserRole;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.common.utils.http.HttpUtils;
|
import com.smartor.domain.*;
|
import com.smartor.mapper.*;
|
import com.smartor.service.IPatArchiveService;
|
import com.smartor.service.IPatMedInhospService;
|
import com.smartor.service.IServiceSLTDHealthcareRecordService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
|
import org.springframework.stereotype.Service;
|
|
import java.lang.reflect.Type;
|
import java.math.BigDecimal;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
|
@Slf4j
|
@Service
|
public class ServiceSLTDHealthcareRecordServiceImpl implements IServiceSLTDHealthcareRecordService {
|
|
private static final String DATE_FORMAT = "yyyy-MM-dd HH:mm:ss";
|
public static final String APP_KEY = "ak-zUMiOWhqXiJQWPB1pCbz0pjr";
|
|
@Autowired
|
private IPatArchiveService patArchiveService;
|
|
@Autowired
|
private IPatMedInhospService patMedInhospService;
|
|
@Autowired
|
private PatMedOuthospMapper patMedOuthospMapper;
|
|
@Autowired
|
private SysUser2Mapper sysUser2Mapper;
|
|
@Autowired
|
private SysDept2Mapper sysDeptMapper;
|
|
@Autowired
|
private SysUserDeptMapper sysUserDeptMapper;
|
|
@Autowired
|
private SysUserRole2Mapper sysUserRoleMapper;
|
|
@Autowired
|
private RedisTemplate<String, String> redisTemplate;
|
|
@Value("${sltd_pub_path}")
|
private String sltdPubPath;
|
|
@Value("${userPwd}")
|
private String userPwd;
|
|
@Override
|
public List<ServiceSLTDInhospResDTO> queryHealthcareRecordList(ServiceSLTDInhospReqVO reqVO) {
|
try {
|
Map<String, Object> requestParams = buildRequestParams(reqVO);
|
Map<String, String> headers = buildRequestHeaders();
|
String result = HttpUtils.sendPostByHeader(sltdPubPath + "osj/hbos-thirdparty-integration/standard/common/healthcareRecord/dtcQueryHealthcareRecordList", new Gson().toJson(requestParams), headers);
|
|
String cry = determineCry(reqVO);
|
log.info("cry的值为：{}", cry);
|
List<ServiceSLTDInhospResDTO> serviceSLTDInhospResDTOS = parseResponseData(result, CollectionUtils.isNotEmpty(reqVO.getStatusList()) ? reqVO.getStatusList() : reqVO.getHealthcareRecordTypeList(), cry, reqVO.getCampusId() != null ? reqVO.getCampusId().toString() : null);
|
log.info("serviceSLTDInhospResDTOS是否返回的有值：{}", CollectionUtils.isNotEmpty(serviceSLTDInhospResDTOS) ? "有" : "没有");
|
return serviceSLTDInhospResDTOS;
|
} catch (Exception e) {
|
log.error("【queryHealthcareRecordList】调用省立同德健康记录查询接口异常，请求参数：{}", reqVO, e);
|
throw new RuntimeException("调用省立同德健康记录查询接口失败", e);
|
}
|
}
|
|
|
/**
|
* 采集科室病区信息
|
*
|
* @param serviceSLTDDeptReqVO
|
* @return 参考
|
* {
|
* "orgId": 20001001,
|
* "campusIds": 30001002,
|
* "unitIds": null,
|
* "relationType": null,
|
* "searchText": null,
|
* "status": 1
|
* }
|
*/
|
@Override
|
public Boolean queryDeptWardAreaInfoList(ServiceSLTDDeptReqVO serviceSLTDDeptReqVO) {
|
log.info("【queryDeptWardAreaInfoList】开始调用省立同德科室病区查询接口，请求参数：{}", serviceSLTDDeptReqVO);
|
try {
|
Map<String, Object> params = new HashMap<>();
|
if (serviceSLTDDeptReqVO.getOrgId() != null) {
|
params.put("orgId", Long.parseLong(serviceSLTDDeptReqVO.getOrgId()));
|
}
|
if (serviceSLTDDeptReqVO.getCampusIds() != null) {
|
params.put("campusIds", serviceSLTDDeptReqVO.getCampusIds());
|
}
|
params.put("subjectCode", serviceSLTDDeptReqVO.getSubjectCode());
|
params.put("orgSubjectCode", serviceSLTDDeptReqVO.getOrgSubjectCode());
|
|
params.put("deptDimensions", serviceSLTDDeptReqVO.getDeptDimensions());
|
|
params.put("serviceScopes", serviceSLTDDeptReqVO.getServiceScopes());
|
params.put("inpatientArea", serviceSLTDDeptReqVO.getInpatientArea());
|
params.put("status", serviceSLTDDeptReqVO.getStatus());
|
|
|
Map<String, String> headers = buildRequestHeaders();
|
String result = HttpUtils.sendPostByHeader(sltdPubPath + "/osj/hbos-thirdparty-integration/standard/common/dept/queryDeptList", new Gson().toJson(params), headers);
|
log.info("【queryDeptWardAreaInfoList】接口响应结果：{}", StringUtils.isEmpty(result) ? "空的" : "不空");
|
List<Map<String, Object>> dataList = getDataList(result);
|
log.info("-----------dataList接口响应结果：{}", dataList.size());
|
for (Map<String, Object> dataItem : dataList) {
|
SysDept sysDept = new SysDept();
|
sysDept.setOrgid("" + getLongValue(dataItem, "orgId"));
|
sysDept.setCampusid("" + getLongValue(dataItem, "campusId"));
|
sysDept.setHisDeptId("" + getLongValue(dataItem, "deptId"));
|
sysDept.setHisParentId(getStringValue(dataItem, "parentDeptId"));
|
//通过his的父科室ID去找到科室ID,填充parentId
|
if (StringUtils.isNotEmpty(getStringValue(dataItem, "parentDeptId"))) {
|
SysDept sd = new SysDept();
|
sd.setHisDeptId(getStringValue(dataItem, "parentDeptId"));
|
sd.setOrgid(getStringValue(dataItem, "orgId"));
|
List<SysDept> sysDepts = sysDeptMapper.selectDeptList(sd);
|
if (CollectionUtils.isNotEmpty(sysDepts)) {
|
SysDept sysDept1 = sysDepts.get(0);
|
sysDept.setParentId(sysDept1.getDeptId());
|
sysDept.setParentName(sysDept1.getDeptName());
|
}
|
}
|
sysDept.setDeptName(getStringValue(dataItem, "deptName"));
|
Integer inpatientArea = getIntegerValue(dataItem, "inpatientArea");
|
if (inpatientArea != null && inpatientArea == 0) sysDept.setDeptType("1");
|
else if (inpatientArea != null && inpatientArea == 1) sysDept.setDeptType("2");
|
sysDept.setLeader("");
|
Integer status = getIntegerValue(dataItem, "status");
|
if (status != null & status == 0) sysDept.setStatus("1");
|
if (status != null & status == 1) sysDept.setStatus("0");
|
sysDept.setType("");
|
sysDept.setDeptCode("" + getLongValue(dataItem, "deptId"));
|
sysDept.setCreateBy(null);
|
sysDept.setCreateTime(new Date());
|
sysDept.setUpdateTime(new Date());
|
sysDept.setUpdateBy(null);
|
|
SysDept sysDept1 = sysDeptMapper.selectDeptByCode(sysDept.getDeptCode(), sysDept.getOrgid());
|
if (Objects.isNull(sysDept1)) {
|
int i = sysDeptMapper.insertDept(sysDept);
|
log.info("ServiceExternalServiceImpl---addDeptInfo是否新增成功：{}", i);
|
} else {
|
sysDept.setDeptId(sysDept1.getDeptId());
|
int i = sysDeptMapper.updateDept(sysDept);
|
log.info("ServiceExternalServiceImpl---addDeptInfo是否修改成功04：{}", i);
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return true;
|
}
|
|
@Override
|
public void aa(Map<String, Object> map) {
|
List<String> types = new ArrayList<>();
|
types.add("FH0109.27");
|
ObjectMapper objectMapper = new ObjectMapper();
|
try {
|
String jsonString = objectMapper.writeValueAsString(map);
|
parseResponseData(jsonString, types, "1", "20001001");
|
} catch (JsonProcessingException e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
|
/**
|
* 采集医院用户信息
|
*
|
* @param reqVO
|
* @return
|
*/
|
@Override
|
public Boolean queryHospUserInfoList(ServiceSLTDInhospReqVO reqVO) {
|
Map<String, Object> requestParams = buildRequestParams(reqVO);
|
Map<String, String> headers = buildRequestHeaders();
|
String result = HttpUtils.sendPostByHeader(sltdPubPath + "/osj/hbos-thirdparty-integration/standard/common/staff/queryStaffList", new Gson().toJson(requestParams), headers);
|
log.info("【queryHealthcareRecordList】接口响应结果是否有值：{}", StringUtils.isEmpty(result) ? "没值" : "有值");
|
List<Map<String, Object>> dataList = getDataList(result);
|
for (Map<String, Object> dataItem : dataList) {
|
SysUser sysUser = new SysUser();
|
if (StringUtils.isEmpty(getStringValue(dataItem, "accountNo"))) {
|
continue;
|
}
|
sysUser.setUserName(getStringValue(dataItem, "accountNo"));
|
sysUser.setNickName(getStringValue(dataItem, "name"));
|
List diagnosisObjList = (List<?>) dataItem.get("qualifications");
|
if (CollectionUtils.isNotEmpty(diagnosisObjList)) {
|
for (Object diagnosis : diagnosisObjList) {
|
if (diagnosis instanceof Map) {
|
Map<String, Object> diagnosisMap = (Map<String, Object>) diagnosis;
|
String professionalTitleName = getStringValue(diagnosisMap, "professionalTitleName");
|
if (professionalTitleName.contains("医师")) {
|
sysUser.setUserType("医生");
|
sysUser.setSearchscope("1");
|
}
|
if (professionalTitleName.contains("护")) {
|
sysUser.setUserType("护士");
|
sysUser.setSearchscope("2");
|
}
|
sysUser.setTitle(getStringValue(diagnosisMap, "professionalTitleName"));
|
}
|
}
|
}
|
|
sysUser.setPhonenumber(getStringValue(dataItem, "telephone"));
|
sysUser.setUserCode(getStringValue(dataItem, "jobNumber"));
|
//设置性别
|
String genderName = getStringValue(dataItem, "genderName");
|
if ("男".equals(genderName)) sysUser.setSex("0");
|
else if ("女".equals(genderName)) sysUser.setSex("1");
|
else sysUser.setSex("2");
|
|
sysUser.setCreateTime(new Date());
|
sysUser.setUpdateTime(new Date());
|
sysUser.setUpdateBy("admin");
|
sysUser.setCreateBy("admin");
|
sysUser.setCreateBy("admin");
|
sysUser.setOrgid("" + getLongValue(dataItem, "orgId"));
|
// sysUser.setCampusid("" + getLongValue(dataItem, "cmpusId"));
|
BCryptPasswordEncoder passwordEncoder = new BCryptPasswordEncoder();
|
sysUser.setPassword(passwordEncoder.encode(userPwd));
|
|
SysUser sysUser1 = sysUser2Mapper.selectUserByUserName(sysUser.getUserName());
|
if (ObjectUtils.isNotEmpty(sysUser1)) {
|
sysUser.setUserId(sysUser1.getUserId());
|
sysUser2Mapper.updateUser(sysUser);
|
} else {
|
sysUser2Mapper.insertUser(sysUser);
|
}
|
|
// 处理用户与部门的关系
|
List businessDepts = (List<?>) dataItem.get("businessDepts");
|
if (CollectionUtils.isEmpty(businessDepts)) {
|
continue;
|
}
|
|
List<List<String>> deptInfoList = new ArrayList<>();
|
List<List<String>> hospInfoList = new ArrayList<>();
|
log.info("------businessDepts是否有值：{}", businessDepts.size());
|
for (Object businessDept : businessDepts) {
|
if (businessDept instanceof Map) {
|
Map<String, Object> businessDeptMap = (Map<String, Object>) businessDept;
|
log.info("------businessDeptMap是否有值：{}", businessDeptMap);
|
// Long hisDeptId = (Long) personnelDeptMap.get("deptId");
|
String hisDeptId = getStringValue(businessDeptMap, "deptId");
|
log.info("------hisDeptId是否有值：{}, reqVO.getOrgId()的值为:{}", hisDeptId, reqVO.getCampusId());
|
//在这里，hisDeptId就是deptCode
|
SysDept sysDept = sysDeptMapper.selectDeptByCode(hisDeptId, reqVO.getOrgId());
|
log.info("------hisDeptId是否有值：{}, reqVO.getCampusId()的值为:{}", hisDeptId, reqVO.getCampusId());
|
if (Objects.isNull(sysDept)) continue;
|
SysUserDept sysUserDept = new SysUserDept();
|
sysUserDept.setUserId(sysUser.getUserId());
|
sysUserDept.setDeptType(sysDept.getDeptType());
|
sysUserDept.setDeptId(sysDept.getDeptId());
|
sysUserDept.setDeptCode(sysDept.getDeptCode());
|
sysUserDept.setDeptName(sysDept.getDeptName());
|
sysUserDept.setOrgid(sysDept.getOrgid());
|
sysUserDept.setCreateTime(new Date());
|
sysUserDept.setDelFlag(0L);
|
|
//判断一下是不是已经存在了
|
if (ObjectUtils.isNotEmpty(sysUser1) && ObjectUtils.isNotEmpty(sysDept)) {
|
SysUserDept sud = new SysUserDept();
|
sud.setUserId(sysUser1.getUserId());
|
sud.setDeptId(sysDept.getDeptId());
|
List<SysUserDept> sysUserDepts = sysUserDeptMapper.selectSysUserDeptList(sud);
|
if (CollectionUtils.isNotEmpty(sysUserDepts)) {
|
sysUserDept.setId(sysUserDepts.get(0).getId());
|
sysUserDeptMapper.updateSysUserDept(sysUserDept);
|
}
|
} else {
|
//不存在，则新增
|
sysUserDeptMapper.insertSysUserDept(sysUserDept);
|
}
|
if (StringUtils.isNotEmpty(sysDept.getDeptType()) && sysDept.getDeptType().equals("1")) {
|
hospInfoList.add(Arrays.asList(sysDept.getDeptCode()));
|
} else if (StringUtils.isNotEmpty(sysDept.getDeptType()) && sysDept.getDeptType().equals("2")) {
|
deptInfoList.add(Arrays.asList(sysDept.getDeptCode()));
|
}
|
}
|
}
|
//将部门我病区放到指定字段中
|
Gson gson = new Gson();
|
sysUser.setHospInfo(gson.toJson(hospInfoList));
|
sysUser.setDeptInfo(gson.toJson(deptInfoList));
|
sysUser2Mapper.updateUser(sysUser);
|
|
//设置一个默认角色（医生角色）
|
List<SysUserRole> userRoleList = new ArrayList();
|
SysUserRole sur = new SysUserRole();
|
sur.setUserId(sysUser.getUserId());
|
sur.setRoleId(3L);
|
sur.setOrgid(sysUser.getOrgid());
|
|
//先查询一下，是否存在
|
SysUserRole sysUserRole = sysUserRoleMapper.selectUserRoleByRoleIdAndUserId(sysUser.getUserId(), 3L);
|
if (ObjectUtils.isNotEmpty(sysUserRole)) continue;
|
|
userRoleList.add(sur);
|
sysUserRoleMapper.batchUserRole(userRoleList);
|
}
|
|
return true;
|
}
|
|
private String determineCry(ServiceSLTDInhospReqVO reqVO) {
|
if (CollectionUtils.isEmpty(reqVO.getStatusList())) return null;
|
|
if (reqVO.getStatusList().contains("FH0109.26")) {
|
//入院
|
return "0";
|
} else if (reqVO.getStatusList().contains("FH0109.27")) {
|
//出院
|
return "1";
|
} else if (reqVO.getStatusList().contains("FH0109.22") || reqVO.getStatusList().contains("FH0109.23") || reqVO.getStatusList().contains("FH0109.53")) {
|
//预入院
|
return "3";
|
}
|
return null;
|
}
|
|
private Map<String, Object> buildRequestParams(ServiceSLTDInhospReqVO reqVO) {
|
Map<String, Object> params = new HashMap<>();
|
if (reqVO.getOrgId() != null) {
|
params.put("orgId", Long.parseLong(reqVO.getOrgId()));
|
}
|
if (reqVO.getCampusId() != null) {
|
params.put("campusId", reqVO.getCampusId());
|
}
|
if (reqVO.getStartHeadTime() != null) {
|
params.put("startHeadTime", reqVO.getStartHeadTime());
|
}
|
if (reqVO.getStartTailTime() != null) {
|
params.put("startTailTime", reqVO.getStartTailTime());
|
}
|
if (reqVO.getEncounterTimeStart() != null) {
|
params.put("encounterTimeStart", reqVO.getEncounterTimeStart());
|
}
|
if (reqVO.getEncounterTimeEnd() != null) {
|
params.put("encounterTimeEnd", reqVO.getEncounterTimeEnd());
|
}
|
if (reqVO.getPreOutHospitalHeadDate() != null) {
|
params.put("preOutHospitalHeadDate", reqVO.getPreOutHospitalHeadDate());
|
}
|
if (reqVO.getPreOutHospitalTailDate() != null) {
|
params.put("preOutHospitalTailDate", reqVO.getPreOutHospitalTailDate());
|
}
|
if (reqVO.getHealthcareRecordTypeList() != null && !reqVO.getHealthcareRecordTypeList().isEmpty()) {
|
params.put("healthcareRecordTypeList", reqVO.getHealthcareRecordTypeList());
|
}
|
if (reqVO.getStatusList() != null && !reqVO.getStatusList().isEmpty()) {
|
params.put("statusList", reqVO.getStatusList());
|
}
|
params.put("subjectCode", reqVO.getPatientName());
|
params.put("healthcareRecordNo", reqVO.getHealthcareRecordNo());
|
params.put("orgSubjectCode", reqVO.getIdCardNo());
|
if (reqVO.getDeptIdList() != null && !reqVO.getDeptIdList().isEmpty()) {
|
params.put("deptDimensions", reqVO.getDeptIdList());
|
}
|
params.put("serviceScopes", null);
|
params.put("inpatientArea", null);
|
// params.put("status", reqVO.getStatusList() != null && !reqVO.getStatusList().isEmpty() ? reqVO.getStatusList().get(0) : null);
|
params.put("status", null);
|
return params;
|
}
|
|
private Map<String, String> buildRequestHeaders() {
|
Map<String, String> headers = new HashMap<>();
|
headers.put("Content-Type", "application/json");
|
headers.put("app-key", APP_KEY);
|
return headers;
|
}
|
|
private List<ServiceSLTDInhospResDTO> parseResponseData(String result, List<String> types, String cry, String campusId) {
|
try {
|
List<Map<String, Object>> dataList = getDataList(result);
|
List<ServiceSLTDInhospResDTO> resultList = new ArrayList<>();
|
for (Map<String, Object> dataItem : dataList) {
|
resultList.add(convertToDTO(dataItem));
|
}
|
log.info("【parseResponseData】成功解析{}条健康记录数据", resultList.size());
|
|
processResultList(resultList, types, cry, campusId);
|
return resultList;
|
} catch (Exception e) {
|
log.error("【parseResponseData】解析响应数据异常，响应内容：{}", result, e);
|
throw new RuntimeException("解析响应数据失败", e);
|
}
|
}
|
|
public List<Map<String, Object>> getDataList(String result) {
|
Gson gson = new Gson();
|
Type mapType = new TypeToken<Map<String, Object>>() {
|
}.getType();
|
Map<String, Object> responseMap = gson.fromJson(result, mapType);
|
Number codeNum = (Number) responseMap.get("code");
|
String code = BigDecimal.valueOf(codeNum.longValue()).toPlainString();
|
if (StringUtils.isEmpty(code) || !code.equals("200")) {
|
log.error("【parseResponseData】接口返回失败，响应码：{}，响应内容：{}", code, result);
|
throw new RuntimeException("接口调用失败，响应码：" + code);
|
}
|
|
Object dataObj = responseMap.get("data");
|
if (dataObj == null) {
|
log.info("【parseResponseData】接口返回数据为空");
|
return new ArrayList<>();
|
}
|
|
String dataJson = gson.toJson(dataObj);
|
Type listType = new TypeToken<List<Map<String, Object>>>() {
|
}.getType();
|
List<Map<String, Object>> dataList = gson.fromJson(dataJson, listType);
|
|
// 使用 Set 去重，确保没有重复的数据
|
Set<Map<String, Object>> uniqueDataSet = new HashSet<>(dataList);
|
dataList = new ArrayList<>(uniqueDataSet);
|
return dataList;
|
}
|
|
private void processResultList(List<ServiceSLTDInhospResDTO> resultList, List<String> types, String cry, String campusId) {
|
for (String type : types)
|
switch (type) {
|
case "FH0108.01":
|
log.info("【parseResponseData】解析门诊数据");
|
outHospitalDate(resultList);
|
break;
|
case "FH0109.26":
|
log.info("【parseResponseData】解析住院数据");
|
inHospitalDate(resultList, cry);
|
break;
|
case "FH0109.22":
|
log.info("【parseResponseData】解析预住院数据");
|
inHospitalDate(resultList, cry);
|
break;
|
case "FH0109.23":
|
log.info("【parseResponseData】解析预住院（待安床）数据");
|
inHospitalDate(resultList, cry);
|
break;
|
case "FH0109.27":
|
log.info("【parseResponseData】解析出院数据");
|
inHospitalDate(resultList, cry);
|
break;
|
case "FH0109.53":
|
log.info("【parseResponseData】解析预住院（其他）数据");
|
inHospitalDate(resultList, cry);
|
break;
|
// case "FH0108.03":
|
// log.info("【parseResponseData】解析急诊数据");
|
// outHospitalDate(resultList);
|
// break;
|
default:
|
log.warn("【parseResponseData】未知的数据类型：{}", type);
|
break;
|
}
|
}
|
|
private Boolean outHospitalDate(List<ServiceSLTDInhospResDTO> resultList) {
|
List<PatMedOuthosp> batchList = new ArrayList<>();
|
|
for (ServiceSLTDInhospResDTO dto : resultList) {
|
if (Objects.isNull(dto)) {
|
continue;
|
}
|
PatArchive patArchive = processPatientArchive(dto);
|
PatMedOuthosp patMedOuthosp = buildPatMedOuthosp(dto, patArchive);
|
batchList.add(patMedOuthosp);
|
}
|
|
// 批量插入，自动忽略重复
|
if (CollectionUtils.isNotEmpty(batchList)) {
|
try {
|
int insertCount = patMedOuthospMapper.batchInsertIgnore(batchList);
|
log.info("批量插入门急诊记录，总数：{}, 实际插入：{}", batchList.size(), insertCount);
|
} catch (Exception e) {
|
log.error("批量插入门急诊记录失败", e);
|
// 降级为逐条插入
|
for (PatMedOuthosp patMedOuthosp : batchList) {
|
try {
|
patMedOuthospMapper.insertPatMedOuthosp(patMedOuthosp);
|
} catch (Exception ex) {
|
log.warn("单条插入失败：serialnum={}", patMedOuthosp.getSerialnum());
|
}
|
}
|
}
|
}
|
return true;
|
}
|
|
private PatMedOuthosp buildPatMedOuthosp(ServiceSLTDInhospResDTO dto, PatArchive patArchive) {
|
PatMedOuthosp patMedOuthosp = new PatMedOuthosp();
|
patMedOuthosp.setOuthospno(dto.getHealthcareRecordNo());
|
patMedOuthosp.setSerialnum(dto.getHealthcareRecordNo());
|
patMedOuthosp.setPatid(patArchive.getId());
|
patMedOuthosp.setPatname(patArchive.getName());
|
patMedOuthosp.setPatno(patArchive.getPatientno());
|
patMedOuthosp.setDeptcode("" + dto.getDeptId());
|
patMedOuthosp.setDeptname(dto.getDeptName());
|
patMedOuthosp.setDiagname(dto.getDiagnosisName());
|
patMedOuthosp.setIcd10code(dto.getDiagnosisCode());
|
patMedOuthosp.setDrcode("" + dto.getDoctorId());
|
patMedOuthosp.setDrname(dto.getDoctorName());
|
patMedOuthosp.setAdmitdate(parseDate(dto.getLastEncounterTime()));
|
patMedOuthosp.setSchemestatus(1L);
|
patMedOuthosp.setMainsuit(dto.getDiagnosisName());
|
patMedOuthosp.setHpi(null);
|
patMedOuthosp.setCreateTime(new Date());
|
patMedOuthosp.setOrgid(dto.getOrgId());
|
patMedOuthosp.setCampusid(dto.getCampusId());
|
return patMedOuthosp;
|
}
|
|
private Date parseDate(String dateStr) {
|
if (StringUtils.isEmpty(dateStr)) {
|
return null;
|
}
|
try {
|
return new SimpleDateFormat(DATE_FORMAT).parse(dateStr);
|
} catch (ParseException e) {
|
log.warn("【parseDate】解析日期失败：{}", dateStr, e);
|
return null;
|
}
|
}
|
|
private Boolean inHospitalDate(List<ServiceSLTDInhospResDTO> resultList, String cry) {
|
for (ServiceSLTDInhospResDTO dto : resultList) {
|
if (Objects.isNull(dto)) continue;
|
PatArchive patArchive = processPatientArchive(dto);
|
processPatientInhospInfo(dto, patArchive, cry);
|
}
|
return true;
|
}
|
|
private void processPatientInhospInfo(ServiceSLTDInhospResDTO dto, PatArchive patArchive, String cry) {
|
PatMedInhosp patMedInhosp = buildPatientInhospInfo(dto, patArchive, cry);
|
PatMedInhosp queryInhosp = new PatMedInhosp();
|
queryInhosp.setPatno(StringUtils.trim(patArchive.getPatientno()));
|
queryInhosp.setSerialnum(StringUtils.trim(patMedInhosp.getSerialnum()));
|
queryInhosp.setOrgid(StringUtils.trim(dto.getOrgId()));
|
queryInhosp.setInhospstate(cry);
|
log.info("----------------这里的入参为：{},{}", queryInhosp.getPatno(), queryInhosp.getSerialnum());
|
List<PatMedInhosp> existingInhosps = patMedInhospService.selectPatMedInhosp(queryInhosp);
|
|
if (cry.equals("0")) {
|
//入院数据处理
|
if (CollectionUtils.isEmpty(existingInhosps)) {
|
//如果为空，要先判断，预入院是否有值，有值的话则更新
|
queryInhosp.setInhospstate("3");
|
List<PatMedInhosp> patMedInhospList = patMedInhospService.selectPatMedInhosp(queryInhosp);
|
if (CollectionUtils.isNotEmpty(patMedInhospList)) {
|
//如果预入院不为空，则进行修改
|
patMedInhospService.updatePatMedInhosp(patMedInhosp);
|
} else {
|
//如果出院不为空，则不进行处理
|
queryInhosp.setInhospstate("1");
|
patMedInhospList = patMedInhospService.selectPatMedInhosp(queryInhosp);
|
if (CollectionUtils.isNotEmpty(patMedInhospList)) {
|
return;
|
}
|
}
|
|
//如果都为空，则进行新增
|
if (CollectionUtils.isEmpty(patMedInhospList)) {
|
try {
|
patMedInhospService.insertPatMedInhosp(patMedInhosp);
|
} catch (org.springframework.dao.DuplicateKeyException e) {
|
log.warn("入院记录已存在，跳过：serialnum={}, orgid={}, state={}", patMedInhosp.getSerialnum(), patMedInhosp.getOrgid(), patMedInhosp.getInhospstate());
|
}
|
}
|
}
|
|
} else if (cry.equals("1")) {
|
// 出院数据处理
|
if (CollectionUtils.isEmpty(existingInhosps)) {
|
//如果为空，要先判断，预入院是否有值，有值的话则更新
|
queryInhosp.setInhospstate("3");
|
log.info("-----patMedInhospList进来了不？入参为：{}", queryInhosp);
|
List<PatMedInhosp> patMedInhospList = patMedInhospService.selectPatMedInhosp(queryInhosp);
|
log.info("----patMedInhospList进来了不？返参为：{}", CollectionUtils.isEmpty(patMedInhospList) ? null : patMedInhospList.get(0).getSerialnum());
|
if (CollectionUtils.isNotEmpty(patMedInhospList)) {
|
//如果预入院不为空，则进行修改
|
patMedInhospService.updatePatMedInhosp(patMedInhosp);
|
} else {
|
//如果入院不为空，则进行修改
|
queryInhosp.setInhospstate("0");
|
patMedInhospList = patMedInhospService.selectPatMedInhosp(queryInhosp);
|
if (CollectionUtils.isNotEmpty(patMedInhospList)) {
|
patMedInhospService.updatePatMedInhosp(patMedInhosp);
|
}
|
}
|
|
//如果都为空，则进行新增
|
if (CollectionUtils.isEmpty(patMedInhospList)) {
|
//如果入院不为空，则进行修改
|
queryInhosp.setInhospstate("0");
|
log.debug("出院queryInhosp入参为：{}", queryInhosp);
|
List<PatMedInhosp> patMedInhosps = patMedInhospService.selectPatMedInhosp(queryInhosp);
|
log.debug("出院patMedInhospList返参为：{}", CollectionUtils.isEmpty(patMedInhosps) ? null : patMedInhosps.size());
|
if (CollectionUtils.isNotEmpty(patMedInhosps)) {
|
patMedInhospService.updatePatMedInhosp(patMedInhosp);
|
} else {
|
try {
|
patMedInhospService.insertPatMedInhosp(patMedInhosp);
|
} catch (org.springframework.dao.DuplicateKeyException e) {
|
log.warn("出院记录已存在，跳过：serialnum={}, orgid={}, state={}", patMedInhosp.getSerialnum(), patMedInhosp.getOrgid(), patMedInhosp.getInhospstate());
|
}
|
}
|
}
|
}
|
} else if ("3".equals(cry)) {
|
//预入院数据处理：任一状态存在则不新增；都不存在才新增
|
String serialnum = patMedInhosp.getSerialnum() == null ? "" : patMedInhosp.getSerialnum().trim();
|
String orgid = patMedInhosp.getOrgid() == null ? "" : patMedInhosp.getOrgid().trim();
|
String state = patMedInhosp.getInhospstate() == null ? "" : patMedInhosp.getInhospstate();
|
String lockKey = "inhosp:lock:" + serialnum + ":" + orgid + ":" + state;
|
|
Boolean locked = false;
|
try {
|
locked = redisTemplate.opsForValue().setIfAbsent(lockKey, "1", 10, TimeUnit.SECONDS);
|
} catch (Exception e) {
|
log.warn("Redis锁获取失败，降级为直接插入：{}", e.getMessage());
|
locked = null; // 标记Redis不可用
|
}
|
|
if (locked == null || Boolean.TRUE.equals(locked)) {
|
try {
|
queryInhosp.setInhospstate(null);
|
List<PatMedInhosp> patMedInhospList3 = patMedInhospService.selectPatMedInhosp(queryInhosp);
|
if (CollectionUtils.isEmpty(patMedInhospList3)) {
|
try {
|
patMedInhospService.insertPatMedInhosp(patMedInhosp);
|
log.debug("成功插入预入院记录：serialnum={}", patMedInhosp.getSerialnum());
|
} catch (Exception e) {
|
log.warn("预入院记录插入失败（可能已存在）：serialnum={}, orgid={}, state={}, 错误：{}", patMedInhosp.getSerialnum(), patMedInhosp.getOrgid(), patMedInhosp.getInhospstate(), e.getMessage());
|
}
|
}
|
} finally {
|
if (Boolean.TRUE.equals(locked)) {
|
try {
|
redisTemplate.delete(lockKey);
|
} catch (Exception e) {
|
log.warn("Redis锁释放失败：{}", e.getMessage());
|
}
|
}
|
}
|
} else {
|
log.debug("预入院记录正在被其他线程处理，跳过：serialnum={}", patMedInhosp.getSerialnum());
|
}
|
}
|
}
|
|
private PatMedInhosp buildPatientInhospInfo(ServiceSLTDInhospResDTO dto, PatArchive patArchive, String cry) {
|
log.info("----------------buildPatientInhospInfo这里进来了吗？{}", cry);
|
PatMedInhosp patMedInhosp = new PatMedInhosp();
|
patMedInhosp.setPatid(patArchive.getId());
|
patMedInhosp.setPatno(patArchive.getPatientno());
|
patMedInhosp.setPatname(patArchive.getName());
|
patMedInhosp.setNurseId(dto.getChiefNurseId() == null ? "" : dto.getChiefNurseId().toString());
|
patMedInhosp.setNurseName(dto.getChiefNurseName());
|
patMedInhosp.setSerialnum(dto.getHealthcareRecordNo());
|
patMedInhosp.setFuflag("1");
|
if ("0".equals(cry)) patMedInhosp.setInhospstate("0");
|
if ("1".equals(cry)) patMedInhosp.setInhospstate("1");
|
if ("3".equals(cry)) patMedInhosp.setInhospstate("3");
|
patMedInhosp.setHospitalcode(dto.getOrgId());
|
patMedInhosp.setBedNo(dto.getBedNumber());
|
patMedInhosp.setStarttime(parseDate(dto.getStartTime()));
|
patMedInhosp.setEndtime(parseDate(dto.getPreOutHospitalDate()));
|
|
if ("1".equals(cry)) {
|
setDischargeInfo(patMedInhosp, dto);
|
} else {
|
setAdmissionInfo(patMedInhosp, dto);
|
}
|
|
patMedInhosp.setDrname(dto.getDoctorName());
|
patMedInhosp.setDrcode("" + dto.getDoctorId());
|
patMedInhosp.setSchemestatus("0".equals(cry) ? 1L : 2L);
|
patMedInhosp.setDelFlag("0");
|
patMedInhosp.setOrgid(dto.getOrgId());
|
patMedInhosp.setCampusid(dto.getCampusId());
|
return patMedInhosp;
|
}
|
|
private void setDischargeInfo(PatMedInhosp patMedInhosp, ServiceSLTDInhospResDTO dto) {
|
patMedInhosp.setLeaveldeptcode("" + dto.getDeptId());
|
patMedInhosp.setLeaveldeptname(dto.getDeptName());
|
patMedInhosp.setLeavediagname(dto.getMainDischargeDiagnosis() == null ? null : dto.getMainDischargeDiagnosis().getDiagnosisDictName());
|
patMedInhosp.setLeaveicd10code(dto.getMainDischargeDiagnosis() == null ? null : dto.getMainDischargeDiagnosis().getDiagnosisDictCode());
|
patMedInhosp.setOutWayId(null);
|
patMedInhosp.setOutWayName(null);
|
patMedInhosp.setLeavehospitaldistrictid("" + dto.getAreaId());
|
patMedInhosp.setLeavehospitaldistrictcode("" + dto.getAreaId());
|
patMedInhosp.setLeavehospitaldistrictname(dto.getAreaName());
|
patMedInhosp.setLeaveldeptid("" + dto.getDeptId());
|
}
|
|
private void setAdmissionInfo(PatMedInhosp patMedInhosp, ServiceSLTDInhospResDTO dto) {
|
patMedInhosp.setDeptcode("" + dto.getDeptId());
|
patMedInhosp.setDeptname(dto.getDeptName());
|
patMedInhosp.setDiagname(dto.getAdmissionDiagnosisName());
|
patMedInhosp.setIcd10code(dto.getAdmissionDiagnosisCode());
|
patMedInhosp.setHospitaldistrictid("" + dto.getAreaId());
|
patMedInhosp.setHospitaldistrictcode("" + dto.getAreaId());
|
patMedInhosp.setHospitaldistrictname(dto.getAreaName());
|
}
|
|
private PatArchive processPatientArchive(ServiceSLTDInhospResDTO dto) {
|
PatArchive queryArchive = new PatArchive();
|
queryArchive.setIdcardno(StringUtils.isEmpty(dto.getIdCardNo()) ? "" + dto.getMedicalCardId() : dto.getIdCardNo().trim());
|
List<PatArchive> existingArchives = patArchiveService.selectPatArchiveList(queryArchive);
|
|
PatArchive patArchive = buildPatientArchive(dto);
|
|
if (CollectionUtils.isEmpty(existingArchives)) {
|
patArchiveService.insertPatArchive(patArchive);
|
log.debug("【processPatientArchive】新增患者档案，患者编号：{}", patArchive.getPatientno());
|
} else {
|
patArchive.setId(existingArchives.get(0).getId());
|
patArchiveService.updateArchive(patArchive);
|
log.debug("【processPatientArchive】更新患者档案，患者编号：{}", patArchive.getPatientno());
|
}
|
|
return patArchive;
|
}
|
|
private PatArchive buildPatientArchive(ServiceSLTDInhospResDTO dto) {
|
PatArchive patArchive = new PatArchive();
|
patArchive.setPatientno("" + dto.getPatientId());
|
patArchive.setIdcardno(StringUtils.isEmpty(dto.getIdCardNo()) ? "" + dto.getMedicalCardId() : dto.getIdCardNo().trim());
|
patArchive.setName(dto.getPatientName());
|
patArchive.setSourcefrom(2);
|
patArchive.setPattype("2");
|
patArchive.setSex("男".equals(dto.getGender()) ? 1L : 2L);
|
patArchive.setNation(dto.getNation());
|
patArchive.setNativePlace(dto.getNativePlace());
|
patArchive.setPlaceOfResidence(dto.getAddress());
|
patArchive.setBirthdate(parseDate(dto.getBirthday()));
|
patArchive.setTelcode(dto.getPhone());
|
if (CollectionUtils.isNotEmpty(dto.getResidentContactInfos())) {
|
patArchive.setRelativetelcode(dto.getResidentContactInfos().get(0).getTelecom());
|
}
|
patArchive.setDelFlag("0");
|
patArchive.setCreateTime(new Date());
|
patArchive.setUpdateTime(new Date());
|
patArchive.setOrgid("" + dto.getOrgId());
|
patArchive.setCampusid(dto.getCampusId());
|
return patArchive;
|
}
|
|
private ServiceSLTDInhospResDTO convertToDTO(Map<String, Object> dataItem) {
|
ServiceSLTDInhospResDTO dto = new ServiceSLTDInhospResDTO();
|
dto.setOrgId(getStringValue(dataItem, "orgId"));
|
dto.setCampusId(getStringValue(dataItem, "campusId"));
|
dto.setHealthcareRecordId(getLongValue(dataItem, "healthcareRecordId"));
|
dto.setHealthcareRecordNo(getStringValue(dataItem, "healthcareRecordNo"));
|
dto.setPatientId(getLongValue(dataItem, "patientId"));
|
dto.setPatientName(getStringValue(dataItem, "patientName"));
|
dto.setPinyin(getStringValue(dataItem, "pinyin"));
|
dto.setNation(getStringValue(dataItem, "nation"));
|
dto.setIdCardNo(getStringValue(dataItem, "idCardNo"));
|
dto.setHealthcareRecordTimes(getIntegerValue(dataItem, "healthcareRecordTimes"));
|
dto.setHospitalizationNumber(getIntegerValue(dataItem, "hospitalizationNumber"));
|
dto.setMedicalCardId(getLongValue(dataItem, "medicalCardId"));
|
dto.setMedicalCardType(getStringValue(dataItem, "medicalCardType"));
|
dto.setMedicalCardTypeName(getStringValue(dataItem, "medicalCardTypeName"));
|
dto.setMedicalCardNo(getStringValue(dataItem, "medicalCardNo"));
|
dto.setMedicalRecordNo(getStringValue(dataItem, "medicalRecordNo"));
|
dto.setGender(getStringValue(dataItem, "gender"));
|
dto.setGenderCode(getStringValue(dataItem, "genderCode"));
|
dto.setAge(getStringValue(dataItem, "age"));
|
dto.setBirthday(getStringValue(dataItem, "birthday"));
|
dto.setPhone(getStringValue(dataItem, "phone"));
|
dto.setEducation(getStringValue(dataItem, "education"));
|
dto.setEducationCode(getStringValue(dataItem, "educationCode"));
|
dto.setNeonatal(getBooleanValue(dataItem, "neonatal"));
|
dto.setMarriage(getStringValue(dataItem, "marriage"));
|
dto.setMarriageCode(getStringValue(dataItem, "marriageCode"));
|
dto.setOccupationType(getStringValue(dataItem, "occupationType"));
|
dto.setOccupationTypeCode(getStringValue(dataItem, "occupationTypeCode"));
|
dto.setNativePlace(getStringValue(dataItem, "nativePlace"));
|
dto.setAreaId(getLongValue(dataItem, "areaId"));
|
dto.setAreaName(getStringValue(dataItem, "areaName"));
|
dto.setRoomId(getLongValue(dataItem, "roomId"));
|
dto.setRoomNumber(getStringValue(dataItem, "roomNumber"));
|
dto.setBedId(getLongValue(dataItem, "bedId"));
|
dto.setBedNumber(getStringValue(dataItem, "bedNumber"));
|
dto.setEncounterTime(getStringValue(dataItem, "encounterTime"));
|
dto.setStartTime(getStringValue(dataItem, "startTime"));
|
dto.setPreOutHospitalDate(getStringValue(dataItem, "preOutHospitalDate"));
|
dto.setLastEncounterTime(getStringValue(dataItem, "lastEncounterTime"));
|
dto.setDiagnosisCode(getStringValue(dataItem, "diagnosisCode"));
|
dto.setDiagnosisName(getStringValue(dataItem, "diagnosisName"));
|
dto.setHealthcareRecordStatus(getStringValue(dataItem, "healthcareRecordStatus"));
|
dto.setHealthcareType(getStringValue(dataItem, "healthcareType"));
|
dto.setDeptId(getLongValue(dataItem, "deptId"));
|
dto.setDeptName(getStringValue(dataItem, "deptName"));
|
dto.setDoctorId(getLongValue(dataItem, "doctorId"));
|
dto.setDoctorName(getStringValue(dataItem, "doctorName"));
|
dto.setHealthcarePeriodId(getLongValue(dataItem, "healthcarePeriodId"));
|
dto.setChiefNurseId(getLongValue(dataItem, "chiefNurseId"));
|
dto.setChiefNurseName(getStringValue(dataItem, "chiefNurseName"));
|
dto.setCostCategoryName(getStringValue(dataItem, "costCategoryName"));
|
dto.setCostCategoryCode(getStringValue(dataItem, "costCategoryCode"));
|
dto.setCostNatureName(getStringValue(dataItem, "costNatureName"));
|
dto.setCostNatureCode(getStringValue(dataItem, "costNatureCode"));
|
dto.setFurtherConsultationStatus(getIntegerValue(dataItem, "furtherConsultationStatus"));
|
|
Object contactsObj = dataItem.get("residentContactInfos");
|
if (contactsObj instanceof List) {
|
dto.setResidentContactInfos(parseContacts((List<?>) contactsObj));
|
}
|
|
Object diagnosisObj = dataItem.get("diagnosisList");
|
if (diagnosisObj instanceof List) {
|
dto.setDiagnosisList(parseDiagnosis((List<?>) diagnosisObj));
|
}
|
|
return dto;
|
}
|
|
private List<ServiceSLTDContactsResDTO> parseContacts(List<?> contactsList) {
|
List<ServiceSLTDContactsResDTO> contacts = new ArrayList<>();
|
for (Object contactObj : contactsList) {
|
if (contactObj instanceof Map) {
|
Map<String, Object> contactMap = (Map<String, Object>) contactObj;
|
ServiceSLTDContactsResDTO contact = new ServiceSLTDContactsResDTO();
|
contact.setName(getStringValue(contactMap, "name"));
|
contact.setRelationshipCode(getStringValue(contactMap, "relationshipCode"));
|
contact.setRelationship(getStringValue(contactMap, "relationship"));
|
contact.setTelecom(getStringValue(contactMap, "telecom"));
|
contact.setCurrentAddress(getStringValue(contactMap, "currentAddress"));
|
contacts.add(contact);
|
}
|
}
|
return contacts;
|
}
|
|
private List<ServiceSLTDDiagnosisResDTO> parseDiagnosis(List<?> diagnosisList) {
|
List<ServiceSLTDDiagnosisResDTO> diagnosis = new ArrayList<>();
|
for (Object diagnosisObj : diagnosisList) {
|
if (diagnosisObj instanceof Map) {
|
Map<String, Object> diagnosisMap = (Map<String, Object>) diagnosisObj;
|
ServiceSLTDDiagnosisResDTO diag = new ServiceSLTDDiagnosisResDTO();
|
diag.setDiagnosisDictCode(getStringValue(diagnosisMap, "diagnosisDictCode"));
|
diag.setDiagnosisDictName(getStringValue(diagnosisMap, "diagnosisDictName"));
|
diag.setDiagnosisCategory(getStringValue(diagnosisMap, "diagnosisCategory"));
|
diag.setRecordType(getIntegerValue(diagnosisMap, "recordType"));
|
diag.setIsMainDiagnosis(getIntegerValue(diagnosisMap, "isMainDiagnosis"));
|
diagnosis.add(diag);
|
}
|
}
|
return diagnosis;
|
}
|
|
private String getStringValue(Map<String, Object> map, String key) {
|
Object value = map.get(key);
|
if (value == null) {
|
return null;
|
}
|
|
// 只处理数字类型，避免科学计数法
|
return value instanceof Number ? new BigDecimal(value.toString()).toPlainString() : value.toString();
|
}
|
|
private Long getLongValue(Map<String, Object> map, String key) {
|
Object value = map.get(key);
|
if (value == null) return null;
|
if (value instanceof Number) {
|
return ((Number) value).longValue();
|
}
|
try {
|
return Long.parseLong(value.toString());
|
} catch (NumberFormatException e) {
|
return null;
|
}
|
}
|
|
private Integer getIntegerValue(Map<String, Object> map, String key) {
|
Object value = map.get(key);
|
if (value == null) return null;
|
if (value instanceof Number) {
|
return ((Number) value).intValue();
|
}
|
try {
|
return Integer.parseInt(value.toString());
|
} catch (NumberFormatException e) {
|
return null;
|
}
|
}
|
|
private Boolean getBooleanValue(Map<String, Object> map, String key) {
|
Object value = map.get(key);
|
if (value == null) return null;
|
if (value instanceof Boolean) {
|
return (Boolean) value;
|
}
|
return Boolean.parseBoolean(value.toString());
|
}
|
}
|
