package com.smartor.service.impl;
|
|
import java.lang.reflect.Field;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import com.ruoyi.common.core.domain.entity.SysDept;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.smartor.domain.*;
|
import com.smartor.mapper.*;
|
import com.smartor.service.IServiceExternalService;
|
import com.smartor.service.IServiceSubtaskRecordService;
|
import com.smartor.service.IServiceSubtaskService;
|
import io.swagger.annotations.ApiModelProperty;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.apache.poi.ss.formula.functions.T;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.security.auth.login.CredentialNotFoundException;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 主键Service业务层处理
|
*
|
* @author lihu
|
* @date 2024-11-04
|
*/
|
@Slf4j
|
@Service
|
public class ServiceExternalServiceImpl implements IServiceExternalService {
|
@Autowired
|
private SysDept2Mapper sysDeptMapper;
|
@Autowired
|
private SysUser2Mapper sysUserMapper;
|
@Autowired
|
private BaseOrganizationMapper baseOrganizationMapper;
|
@Autowired
|
private PatArchiveMapper patArchiveMapper;
|
@Autowired
|
private PatMedInhospMapper patMedInhospMapper;
|
@Autowired
|
private Icd10AssociationMapper icd10AssociationMapper;
|
|
@Autowired
|
private IServiceSubtaskService iServiceSubtaskService;
|
|
|
public Boolean generalInterface(Map dataMap) {
|
Map XiaoXiTou = (Map) dataMap.get("XiaoXiTou");
|
String xiaoXiLX = XiaoXiTou.get("XiaoXiLX").toString();
|
return getType(xiaoXiLX, dataMap);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public Boolean addDeptInfo(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---addDeptInfo的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
Map<String, Object> keShiXX = (Map<String, Object>) yeWuXX.get("KeShiXX");
|
ExternalDept externalDept = BeanUtil.mapToBean(keShiXX, ExternalDept.class, true);
|
SysDept sysDept = new SysDept();
|
sysDept.setOrgid(externalDept.getZuZhiJGID());
|
sysDept.setHisDeptId(externalDept.getKeShiID());
|
sysDept.setHisParentId(externalDept.getFuKeSID());
|
//通过his的父科室ID去找到科室ID,填充parentId
|
if (StringUtils.isNotEmpty(externalDept.getKeShiID())) {
|
SysDept sd = new SysDept();
|
sd.setHisDeptId(externalDept.getFuKeSID());
|
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(externalDept.getKeShiMC());
|
sysDept.setDeptType("1");
|
sysDept.setLeader("");
|
sysDept.setStatus("0");
|
sysDept.setType(externalDept.getKeShiLBDM());
|
sysDept.setDeptCode(externalDept.getKeShiID());
|
sysDept.setCreateBy(externalDept.getCreateBy());
|
sysDept.setCreateTime(externalDept.getCreateTime());
|
sysDept.setUpdateTime(externalDept.getUpdateTime());
|
sysDept.setUpdateBy(externalDept.getUpdateBy());
|
if (StringUtils.isNotEmpty(externalDept.getShiJianDM()) && externalDept.getShiJianDM().equals("3")) {
|
sysDept.setStatus("1");
|
}
|
if (StringUtils.isNotEmpty(externalDept.getShiJianDM()) && externalDept.getShiJianDM().equals("1")) {
|
int i = sysDeptMapper.insertDept(sysDept);
|
log.error("ServiceExternalServiceImpl---addDeptInfo是否新增成功：{}", i);
|
} else {
|
int i = sysDeptMapper.updateDept(sysDept);
|
log.error("ServiceExternalServiceImpl---addDeptInfo是否修改成功：{}", i);
|
}
|
return true;
|
}
|
|
@Override
|
public Boolean addUserInfo(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---addUserInfo的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
Map<String, Object> yongHuXX = (Map<String, Object>) yeWuXX.get("YongHuXX");
|
ExternalUserInfo externalUserInfo = BeanUtil.mapToBean(yongHuXX, ExternalUserInfo.class, true);
|
SysUser sysUser = new SysUser();
|
sysUser.setGuid(externalUserInfo.getZuZhiJGID());
|
sysUser.setUserName(externalUserInfo.getYongHuID());
|
sysUser.setNickName(externalUserInfo.getYongHuXM());
|
sysUser.setUserType("");
|
sysUser.setDeptId(null);
|
sysUser.setTitle(null);
|
sysUser.setHisUserId(externalUserInfo.getYongHuID());
|
sysUser.setPhonenumber(externalUserInfo.getLianXiDH());
|
sysUser.setJobPhone(externalUserInfo.getGongZuoDH());
|
sysUser.setSex(externalUserInfo.getXingBieDM());
|
sysUser.setCreateBy(externalUserInfo.getChuangJianRXM());
|
sysUser.setCreateTime(externalUserInfo.getChuangJianSJ());
|
sysUser.setUpdateTime(externalUserInfo.getXiuGaiSJ());
|
sysUser.setUpdateBy(externalUserInfo.getXiuGaiRXM());
|
sysUser.setOrgid(externalUserInfo.getZuZhiJGID());
|
if (StringUtils.isNotEmpty(externalUserInfo.getShiJianDM()) && externalUserInfo.getShiJianDM().equals("3")) {
|
sysUser.setStatus("1");
|
}
|
sysUser.setBirthday(externalUserInfo.getChuShengRQ());
|
if (StringUtils.isNotEmpty(externalUserInfo.getShiJianDM()) && externalUserInfo.getShiJianDM().equals("1")) {
|
int i = sysUserMapper.insertUser(sysUser);
|
log.error("ServiceExternalServiceImpl---addDeptInfo是否新增成功：{}", i);
|
} else {
|
int i = sysUserMapper.updateUser(sysUser);
|
log.error("ServiceExternalServiceImpl---addDeptInfo是否修改成功：{}", i);
|
}
|
return true;
|
}
|
|
|
@Override
|
public Boolean addOrganInfo(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---addOrganInfo的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
Map<String, Object> ZuZhiJGXX = (Map<String, Object>) yeWuXX.get("ZuZhiJGXX");
|
ExternalOrganInfo externalOrganInfo = BeanUtil.mapToBean(ZuZhiJGXX, ExternalOrganInfo.class, true);
|
BaseOrganization baseOrganization = new BaseOrganization();
|
baseOrganization.setOrganizationID(externalOrganInfo.getZuZhiJGID());
|
baseOrganization.setOrganizationName(externalOrganInfo.getZuZhiJGMC());
|
baseOrganization.setCreateBy(externalOrganInfo.getCreateBy());
|
baseOrganization.setCreateTime(externalOrganInfo.getCreateTime());
|
baseOrganization.setUpdateTime(externalOrganInfo.getUpdateTime());
|
baseOrganization.setUpdateBy(externalOrganInfo.getUpdateBy());
|
baseOrganization.setOrgid(externalOrganInfo.getZuZhiJGID());
|
if (StringUtils.isNotEmpty(externalOrganInfo.getShiJianDM()) && externalOrganInfo.getShiJianDM().equals("1")) {
|
int i = baseOrganizationMapper.insertBaseOrganization(baseOrganization);
|
log.error("ServiceExternalServiceImpl---addOrganInfo是否新增成功：{}", i);
|
} else {
|
int i = baseOrganizationMapper.updateBaseOrganization(baseOrganization);
|
log.error("ServiceExternalServiceImpl---addOrganInfo是否修改成功：{}", i);
|
}
|
return true;
|
}
|
|
@Override
|
public Boolean addCheckupReport(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---addCheckupReport的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
Map<String, Object> ZuZhiJGXX = (Map<String, Object>) yeWuXX.get("ZuZhiJGXX");
|
return false;
|
}
|
|
@Override
|
public Boolean addInHospInfo(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---addInHospInfo的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
List<HashMap<String, Object>> epai = (List<HashMap<String, Object>>) yeWuXX.get("DiZhiXXList");
|
List<HashMap<String, Object>> epli = (List<HashMap<String, Object>>) yeWuXX.get("LianXiRList");
|
List<HashMap<String, Object>> hospPatientDiagnoseInfos = (List<HashMap<String, Object>>) yeWuXX.get("ZhenDuanList");
|
Map<String, Object> BingRenXX = (Map<String, Object>) yeWuXX.get("BingRenXX");
|
ExternalInHospPatientInfo externalInHospPatientInfo = BeanUtil.mapToBean(BingRenXX, ExternalInHospPatientInfo.class, true);
|
ExternalInHospPatientAddrInfo externalInHospPatientAddrInfo = null;
|
ExternalInHospPatientLiaisonInfo externalInHospPatientLiaisonInfo = null;
|
ExternalInHospPatientDiagnoseInfo externalInHospPatientDiagnoseInfo = null;
|
List<ExternalInHospPatientAddrInfo> epai2 = epai.stream().map(map -> {
|
ExternalInHospPatientAddrInfo info = new ExternalInHospPatientAddrInfo();
|
info.setDiZhiLX((String) map.get("DiZhiLX")); // 假设字段类型是 Integer
|
info.setDiZhiXX((String) map.get("DiZhiXX"));
|
info.setShengFenDM((String) map.get("ShengFenDM"));
|
info.setShengFenMC((String) map.get("ShengFenMC"));
|
info.setShiDiQDM((String) map.get("ShiDiQDM"));
|
info.setShiDiQMC((String) map.get("ShiDiQMC"));
|
info.setXianQuDM((String) map.get("XianQuDM"));
|
info.setXianQuMC((String) map.get("XianQuMC"));
|
info.setXiangZhenDM((String) map.get("XiangZhenDM"));
|
info.setXiangZhenMC((String) map.get("XiangZhenMC"));
|
info.setCunJiDM((String) map.get("CunJiDM"));
|
info.setQiTaXX((String) map.get("QiTaXX"));
|
info.setYouBian((String) map.get("YouBian"));
|
return info;
|
}).collect(Collectors.toList());
|
|
List<ExternalInHospPatientLiaisonInfo> epli2 = epli.stream().map(map -> {
|
ExternalInHospPatientLiaisonInfo info = new ExternalInHospPatientLiaisonInfo();
|
info.setLianXiRXM((String) map.get("LianXiRXM"));
|
info.setLianXiRDH((String) map.get("LianXiRDH"));
|
info.setGuanXiDM((String) map.get("GuanXiDM"));
|
info.setGuanXiMC((String) map.get("GuanXiMC"));
|
return info;
|
}).collect(Collectors.toList());
|
|
List<ExternalInHospPatientDiagnoseInfo> hospPatientDiagnoseInfos2 = hospPatientDiagnoseInfos.stream().map(map -> {
|
ExternalInHospPatientDiagnoseInfo info = new ExternalInHospPatientDiagnoseInfo();
|
info.setZhenDuanID((String) map.get("ZhenDuanID"));
|
info.setZhenDuanMC((String) map.get("ZhenDuanMC"));
|
return info;
|
}).collect(Collectors.toList());
|
|
if (CollectionUtils.isNotEmpty(epai)) externalInHospPatientAddrInfo = epai2.get(0);
|
if (CollectionUtils.isNotEmpty(epli)) externalInHospPatientLiaisonInfo = epli2.get(0);
|
if (CollectionUtils.isNotEmpty(hospPatientDiagnoseInfos))
|
externalInHospPatientDiagnoseInfo = hospPatientDiagnoseInfos2.get(0);
|
//新增患者基本信息
|
PatArchive patArchive = addPatArchive(externalInHospPatientInfo, externalInHospPatientAddrInfo, externalInHospPatientLiaisonInfo);
|
//新增患者入院信息
|
Boolean aBoolean = addPadInhospInfo(externalInHospPatientInfo, patArchive, externalInHospPatientDiagnoseInfo);
|
return aBoolean;
|
}
|
|
@Override
|
public Boolean cancelInHospInfo(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---cancelInHospInfo的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
Map<String, Object> BingRenXX = (Map<String, Object>) yeWuXX.get("BingRenXX");
|
ExternalInHospPatientInfo externalInHospPatientInfo = BeanUtil.mapToBean(BingRenXX, ExternalInHospPatientInfo.class, true);
|
PatMedInhosp patMedInhosp = new PatMedInhosp();
|
patMedInhosp.setInhospno(externalInHospPatientInfo.getZhuYuanHao());
|
List<PatMedInhosp> patMedInhospList = patMedInhospMapper.selectPatMedInhospList(patMedInhosp);
|
if (CollectionUtils.isNotEmpty(patMedInhospList)) {
|
Map<String, Object> JiuZhenXX = (Map<String, Object>) yeWuXX.get("JiuZhenXX");
|
PatMedInhosp patMedInhosp1 = patMedInhospList.get(0);
|
patMedInhosp1.setSchemestatus(3L);
|
patMedInhosp1.setDelFlag("1");
|
patMedInhosp1.setOperator(JiuZhenXX.get("CaoZuoRXM").toString());
|
patMedInhosp1.setOperatorId(JiuZhenXX.get("CaoZuoRID").toString());
|
patMedInhosp1.setUpdateTime(new Date());
|
int i = patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
|
if (i != 1) return false;
|
}
|
return true;
|
}
|
|
@Override
|
public Boolean addOutHospInfo(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---addOutHospInfo的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
Map<String, Object> BingRenXX = (Map<String, Object>) yeWuXX.get("BingRenXX");
|
ExternalInHospPatientInfo externalInHospPatientInfo = BeanUtil.mapToBean(BingRenXX, ExternalInHospPatientInfo.class, true);
|
|
PatMedInhosp patMedInhosp = new PatMedInhosp();
|
patMedInhosp.setInhospno(externalInHospPatientInfo.getZhuYuanHao());
|
List<PatMedInhosp> patMedInhospList = patMedInhospMapper.selectPatMedInhospList(patMedInhosp);
|
if (CollectionUtils.isNotEmpty(patMedInhospList)) {
|
Map<String, Object> JiuZhenXX = (Map<String, Object>) yeWuXX.get("JiuZhenXX");
|
PatMedInhosp patMedInhosp1 = patMedInhospList.get(0);
|
patMedInhosp1.setSchemestatus(2L);
|
try {
|
patMedInhosp1.setEndtime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(JiuZhenXX.get("ChuYuanSJ").toString()));
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
patMedInhosp1.setOperator(JiuZhenXX.get("CaoZuoRXM").toString());
|
patMedInhosp1.setOperatorId(JiuZhenXX.get("CaoZuoRID").toString());
|
patMedInhosp1.setUpdateTime(new Date());
|
patMedInhosp1.setUpdateTime(new Date());
|
|
patMedInhosp1.setLeavehospitaldistrictcode(externalInHospPatientInfo.getDangQianBQID());
|
patMedInhosp1.setLeavehospitaldistrictname(externalInHospPatientInfo.getDangQianBQMC());
|
patMedInhosp1.setLeaveldeptname(externalInHospPatientInfo.getDangQianKSMC());
|
patMedInhosp1.setLeaveldeptcode(externalInHospPatientInfo.getDangQianKSID());
|
List<HashMap<String, Object>> zhenDuanList = (List<HashMap<String, Object>>) yeWuXX.get("ZhenDuanList");
|
List<ExternalInHospPatientDiagnoseInfo> hospPatientDiagnoseInfos2 = zhenDuanList.stream().map(map -> {
|
ExternalInHospPatientDiagnoseInfo info = new ExternalInHospPatientDiagnoseInfo();
|
info.setZhenDuanID((String) map.get("ZhenDuanID"));
|
info.setZhenDuanMC((String) map.get("ZhenDuanMC"));
|
return info;
|
}).collect(Collectors.toList());
|
patMedInhosp1.setLeaveicd10code(StringUtils.isNotEmpty(patMedInhosp1.getLeaveicd10code()) ? patMedInhosp1.getLeaveicd10code() + "," + hospPatientDiagnoseInfos2.get(0).getZhenDuanID() : hospPatientDiagnoseInfos2.get(0).getZhenDuanID());
|
patMedInhosp1.setLeavediagname(StringUtils.isNotEmpty(patMedInhosp1.getLeavediagname()) ? patMedInhosp1.getLeavediagname() + "," + hospPatientDiagnoseInfos2.get(0).getZhenDuanMC() : hospPatientDiagnoseInfos2.get(0).getZhenDuanMC());
|
|
int i = patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
|
if (i != 1) return false;
|
}
|
return true;
|
}
|
|
@Override
|
public Boolean cancelOutHospInfo(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---cancelOutHospInfo的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
Map<String, Object> BingRenXX = (Map<String, Object>) yeWuXX.get("BingRenXX");
|
ExternalInHospPatientInfo externalInHospPatientInfo = BeanUtil.mapToBean(BingRenXX, ExternalInHospPatientInfo.class, true);
|
PatMedInhosp patMedInhosp = new PatMedInhosp();
|
patMedInhosp.setInhospno(externalInHospPatientInfo.getZhuYuanHao());
|
List<PatMedInhosp> patMedInhospList = patMedInhospMapper.selectPatMedInhospList(patMedInhosp);
|
if (CollectionUtils.isNotEmpty(patMedInhospList)) {
|
Map<String, Object> JiuZhenXX = (Map<String, Object>) yeWuXX.get("JiuZhenXX");
|
PatMedInhosp patMedInhosp1 = patMedInhospList.get(0);
|
patMedInhosp1.setSchemestatus(4L);
|
patMedInhosp1.setOperator(JiuZhenXX.get("CaoZuoRXM").toString());
|
patMedInhosp1.setOperatorId(JiuZhenXX.get("CaoZuoRID").toString());
|
patMedInhosp1.setUpdateTime(new Date());
|
int i = patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
|
if (i != 1) return false;
|
}
|
return true;
|
}
|
|
@Override
|
public Boolean addFinshJZInfo(Map dataMap) {
|
//这个先等等
|
|
return null;
|
}
|
|
@Override
|
public Boolean addDiseaseInfo(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---addDiseaseInfo的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
Map<String, Object> JiBing = (Map<String, Object>) yeWuXX.get("JiBing");
|
ExternalDiseaseInfo externalDiseaseInfo = BeanUtil.mapToBean(JiBing, ExternalDiseaseInfo.class, true);
|
Icd10Association icd10Association = new Icd10Association();
|
icd10Association.setIcd10code(externalDiseaseInfo.getJiBingID());
|
icd10Association.setIcd10name(externalDiseaseInfo.getJiBingMC());
|
icd10Association.setGuid(externalDiseaseInfo.getZuZhiJGID());
|
icd10Association.setOrgid(externalDiseaseInfo.getZuZhiJGID());
|
icd10Association.setPid(externalDiseaseInfo.getFUJIBID());
|
icd10Association.setIcd10AssortCode(externalDiseaseInfo.getJiBingFLDM());
|
icd10Association.setIcd10AssortName(externalDiseaseInfo.getJiBingFLMC());
|
icd10Association.setChineseMedicineDiagnoseSign(externalDiseaseInfo.getZhongYiZDBZ());
|
icd10Association.setChineseMedicineDiagnoseAssortCode(externalDiseaseInfo.getZhongYiZDFLDM());
|
icd10Association.setChineseMedicineDiagnoseAssortName(externalDiseaseInfo.getZhongYiZDFLMC());
|
icd10Association.setOutpatientUseAssort(externalDiseaseInfo.getMenZhenSYBZ());
|
icd10Association.setInpatientUseAssort(externalDiseaseInfo.getZhuYuanSYBZ());
|
icd10AssociationMapper.insertIcd10Association(icd10Association);
|
return true;
|
}
|
|
@Override
|
public Boolean addWardAreaInfo(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---addWardAreaInfo的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
Map<String, Object> bqxx = (Map<String, Object>) yeWuXX.get("BingQuXX");
|
ExternalWardArea externalWardArea = BeanUtil.mapToBean(bqxx, ExternalWardArea.class, true);
|
SysDept sysDept = new SysDept();
|
sysDept.setGuid(externalWardArea.getZuZhiJGID());
|
sysDept.setHisDeptId(externalWardArea.getBingQuID());
|
|
sysDept.setDeptName(externalWardArea.getBingQuMC());
|
sysDept.setDeptType("2");
|
sysDept.setLeader("");
|
sysDept.setStatus("0");
|
sysDept.setDeptCode(externalWardArea.getBingQuID());
|
sysDept.setCreateBy(externalWardArea.getChuangJianRXM());
|
sysDept.setType(externalWardArea.getBingQuLXDM());
|
sysDept.setCreateTime(externalWardArea.getCreateTime());
|
sysDept.setUpdateTime(externalWardArea.getUpdateTime());
|
sysDept.setUpdateBy(externalWardArea.getUpdateBy());
|
if (StringUtils.isNotEmpty(externalWardArea.getShiJianDM()) && externalWardArea.getShiJianDM().equals("3")) {
|
sysDept.setStatus("1");
|
}
|
if (StringUtils.isNotEmpty(externalWardArea.getShiJianDM()) && externalWardArea.getShiJianDM().equals("1")) {
|
int i = sysDeptMapper.insertDept(sysDept);
|
log.error("ServiceExternalServiceImpl---addWardAreaInfo是否新增成功：{}", i);
|
} else {
|
int i = sysDeptMapper.updateDept(sysDept);
|
log.error("ServiceExternalServiceImpl---addWardAreaInfo是否修改成功：{}", i);
|
}
|
return true;
|
}
|
|
//新增患者基本信息
|
private PatArchive addPatArchive(ExternalInHospPatientInfo externalInHospPatientInfo, ExternalInHospPatientAddrInfo externalInHospPatientAddrInfo, ExternalInHospPatientLiaisonInfo externalInHospPatientLiaisonInfo) {
|
PatArchive patArchive = new PatArchive();
|
patArchive.setIdcardno(externalInHospPatientInfo.getZhengJianHM());
|
List<PatArchive> patArchives = patArchiveMapper.selectPatArchiveList(patArchive);
|
patArchive.setPatientno(externalInHospPatientInfo.getJiuZhenKH());
|
patArchive.setPatidHis(externalInHospPatientInfo.getBingRenID());
|
patArchive.setSourcefrom(1);
|
patArchive.setPattype("2");
|
patArchive.setName(externalInHospPatientInfo.getXingMing());
|
if (StringUtils.isNotEmpty(externalInHospPatientInfo.getXingBieDM()))
|
patArchive.setSex(Long.valueOf(externalInHospPatientInfo.getXingBieDM()));
|
patArchive.setNation(externalInHospPatientInfo.getMinZuMC());
|
patArchive.setNativePlace(externalInHospPatientInfo.getGuoJiMC());
|
if (ObjectUtils.isNotEmpty(externalInHospPatientAddrInfo)) {
|
patArchive.setPlaceOfResidence(externalInHospPatientAddrInfo.getShengFenMC() + externalInHospPatientAddrInfo.getShiDiQMC() + externalInHospPatientAddrInfo.getXianQuMC() + externalInHospPatientAddrInfo.getXiangZhenMC() + externalInHospPatientAddrInfo.getCunJiMC() + externalInHospPatientAddrInfo.getQiTaXX());
|
patArchive.setBirthplace(externalInHospPatientAddrInfo.getShengFenMC() + externalInHospPatientAddrInfo.getShiDiQMC() + externalInHospPatientAddrInfo.getXianQuMC() + externalInHospPatientAddrInfo.getXiangZhenMC() + externalInHospPatientAddrInfo.getCunJiMC() + externalInHospPatientAddrInfo.getQiTaXX());
|
}
|
patArchive.setBirthdate(externalInHospPatientInfo.getChuShengRQ());
|
patArchive.setAge(externalInHospPatientInfo.getNianLing());
|
patArchive.setAgeUnit(externalInHospPatientInfo.getNianLingDW());
|
patArchive.setTelcode(externalInHospPatientInfo.getLianXiDH());
|
patArchive.setGuid(externalInHospPatientInfo.getZuZhiJGID());
|
if (ObjectUtils.isNotEmpty(externalInHospPatientLiaisonInfo))
|
patArchive.setRelativetelcode(externalInHospPatientLiaisonInfo.getLianXiRDH());
|
patArchive.setInhospno(externalInHospPatientInfo.getZhuYuanHao());
|
patArchive.setCreateTime(new Date());
|
if (CollectionUtils.isNotEmpty(patArchives)) {
|
//如果不为空，直接将查询出来的对象返回
|
PatArchive patArchive1 = patArchives.get(0);
|
String orgid = patArchive1.getOrgid();
|
if (StringUtils.isNotEmpty(orgid)) {
|
orgid = orgid + "," + externalInHospPatientInfo.getZuZhiJGID();
|
patArchive.setOrgid(orgid);
|
patArchive.setId(patArchive1.getId());
|
patArchiveMapper.updatePatArchive(patArchive);
|
return patArchive;
|
}
|
}
|
patArchiveMapper.insertPatArchiveSingle(patArchive);
|
return patArchive;
|
}
|
|
//新增患者入院信息
|
private Boolean addPadInhospInfo(ExternalInHospPatientInfo externalInHospPatientInfo, PatArchive patArchive, ExternalInHospPatientDiagnoseInfo externalInHospPatientDiagnoseInfo) {
|
PatMedInhosp patMedInhosp = new PatMedInhosp();
|
if (ObjectUtils.isNotEmpty(externalInHospPatientInfo)) {
|
patMedInhosp.setInhospno(externalInHospPatientInfo.getZhuYuanHao());
|
patMedInhosp.setSerialnum(externalInHospPatientInfo.getZhuYuanHao());
|
patMedInhosp.setHospitalname(externalInHospPatientInfo.getZuZhiJGMC());
|
patMedInhosp.setHospitalcode(externalInHospPatientInfo.getZuZhiJGID());
|
patMedInhosp.setStarttime(externalInHospPatientInfo.getRuYuanSJ());
|
patMedInhosp.setDeptcode(externalInHospPatientInfo.getDangQianKSID());
|
patMedInhosp.setDeptname(externalInHospPatientInfo.getDangQianKSMC());
|
patMedInhosp.setBedNo(externalInHospPatientInfo.getDangQianCWID());
|
patMedInhosp.setOrgid(externalInHospPatientInfo.getZuZhiJGID());
|
patMedInhosp.setHospitaldistrictid(externalInHospPatientInfo.getDangQianBQID());
|
patMedInhosp.setGuid(externalInHospPatientInfo.getZuZhiJGID());
|
patMedInhosp.setInhospstate("0");
|
patMedInhosp.setOperator(externalInHospPatientInfo.getCaoZuoRXM());
|
patMedInhosp.setOperatorId(externalInHospPatientInfo.getCaoZuoRID());
|
patMedInhosp.setHospitaldistrictcode(externalInHospPatientInfo.getDangQianBQID());
|
patMedInhosp.setHospitaldistrictname(externalInHospPatientInfo.getDangQianBQMC());
|
}
|
if (ObjectUtils.isNotEmpty(externalInHospPatientDiagnoseInfo)) {
|
patMedInhosp.setIcd10code(StringUtils.isNotEmpty(patMedInhosp.getIcd10code()) ? patMedInhosp.getIcd10code() + "," + externalInHospPatientDiagnoseInfo.getZhenDuanID() : externalInHospPatientDiagnoseInfo.getZhenDuanID());
|
patMedInhosp.setDiagname(StringUtils.isNotEmpty(patMedInhosp.getDiagname()) ? patMedInhosp.getDiagname() + "," + externalInHospPatientDiagnoseInfo.getZhenDuanMC() : externalInHospPatientDiagnoseInfo.getZhenDuanMC());
|
}
|
|
if (ObjectUtils.isNotEmpty(patArchive)) {
|
patMedInhosp.setPatid(patArchive.getId());
|
patMedInhosp.setPatno(patArchive.getPatientno());
|
patMedInhosp.setPatname(patArchive.getName());
|
patMedInhosp.setDrname("");
|
patMedInhosp.setSchemestatus(1L);
|
patMedInhosp.setCreateTime(new Date());
|
}
|
int i = patMedInhospMapper.insertPatMedInhosp(patMedInhosp);
|
if (i == 1) return true;
|
return false;
|
}
|
|
//新增随访任务同步
|
@Override
|
public Boolean addTaskInfo(Map dataMap) {
|
log.error("ServiceExternalServiceImpl---addTaskInfo的新增的值为：{}", dataMap);
|
Map yeWuXX = (Map) dataMap.get("YeWuXX");
|
Map<String, Object> bqxx = (Map<String, Object>) yeWuXX.get("BingQuXX");
|
|
ExternalTaskInfo externalTaskInfo = BeanUtil.mapToBean(bqxx, ExternalTaskInfo.class, true);
|
ServiceSubtask serviceSubtask = new ServiceSubtask();
|
// serviceSubtask.setGuid(externalTaskInfo.getZuZhiJGID());
|
//
|
//
|
// if (StringUtils.isNotEmpty(externalTaskInfo.getShiJianDM()) && externalTaskInfo.getShiJianDM().equals("1")) {
|
// int i = iServiceSubtaskService.insertServiceSubtask(serviceSubtask);
|
// log.error("ServiceExternalServiceImpl---addWardAreaInfo是否新增成功：{}", i);
|
// } else {
|
// int i = iServiceSubtaskService.insertServiceSubtask(serviceSubtask);
|
// log.error("ServiceExternalServiceImpl---addWardAreaInfo是否修改成功：{}", i);
|
// }
|
return true;
|
}
|
|
private Boolean getType(String type, Map dataMap) {
|
switch (type) {
|
case "BR_DA_DangAnJL":
|
log.error("患者档案建立入参类型为：{}", type);
|
return true;
|
case "BR_DA_DangAnXG":
|
log.error("患者档案修改入参类型为：{}", type);
|
return true;
|
case "JZ_MZ_ZhenDuanXXLR":
|
log.error("患者诊断信息门诊录入入参类型为：{}", type);
|
return true;
|
case "JZ_ZY_ZhenDuanXXLR":
|
log.error("患者诊断信息住院录入入参类型为：{}", type);
|
return true;
|
case "YZ_MZ_YiZhuSQ":
|
log.error("门诊医嘱申请入参类型为：{}", type);
|
return true;
|
case "YZ_ZY_YiZhuZX":
|
log.error("住院医嘱执行入参类型为：{}", type);
|
return true;
|
case "YZ_MZ_YiZhuXG":
|
log.error("门诊医嘱修改入参类型为：{}", type);
|
return true;
|
case "YZ_MZ_YiZhuCX":
|
log.error("门诊医嘱撤销入参类型为：{}", type);
|
return true;
|
case "YZ_MZ_YiZhuCS":
|
log.error("门诊医嘱删除入参类型为：{}", type);
|
return true;
|
case "JC_SQ_ShenQing":
|
log.error("检查申请单入参类型为：{}", type);
|
return true;
|
case "JC_SQ_XiuGai":
|
log.error("检查申请信息更新入参类型为：{}", type);
|
return true;
|
case "JC_SQ_CheXiao":
|
log.error("检查撤销入参类型为：{}", type);
|
return true;
|
case "JY_SQ_ShenQing":
|
log.error("检验申请入参类型为：{}", type);
|
return true;
|
case "JY_SQ_CheXiao":
|
log.error("检验撤销入参类型为：{}", type);
|
return true;
|
case "JY_SQ_XiuGai":
|
log.error("检验修改入参类型为辅：{}", type);
|
return true;
|
case "JY_SQ_BiaoBenCJ":
|
log.error("检验标本采集入参类型为：{}", type);
|
return true;
|
case "JY_SQ_QuXiaoBBCJ":
|
log.error("取消检验标本采集入参类型为：{}", type);
|
return true;
|
case "SM_SQ_ShenQing":
|
log.error("手术申请入参类型为：{}", type);
|
return true;
|
case "TJ_YW_BaoGaoXX":
|
log.error("体检报告入参类型为：{}", type);
|
return true;
|
case "TJ_YW_QuXiaoBG":
|
log.error("取消体检报告入参类型为：{}", type);
|
return true;
|
case "JG_ZZ_JiGou":
|
log.error("组织机构入参类型为：{}", type);
|
return addOrganInfo(dataMap);
|
case "JG_ZZ_KeShi":
|
log.error("科室入参类型为：{}", type);
|
return addDeptInfo(dataMap);
|
case "JG_YH_JiBenXX":
|
log.error("用户信息入参类型为：{}", type);
|
return addUserInfo(dataMap);
|
case "fu_task":
|
log.error("fu_task服务入参类型为：{}", type);
|
return addTaskInfo(dataMap);
|
case "GY_ZD_JiBingML":
|
log.error("疾病入参类型为：{}", type);
|
return addDiseaseInfo(dataMap);
|
case "YP_ZD_YaoPinCDJG":
|
log.error("药品产地价格入参类型为：{}", type);
|
return true;
|
case "JZ_MZ_WanChengJZ":
|
log.error("完成接诊入参类型为：{}", type);
|
return addFinshJZInfo(dataMap);
|
case "JZ_ZY_RuYuanDJ":
|
log.error("入院登记入参类型为：{}", type);
|
return addInHospInfo(dataMap);
|
case "JZ_ZY_QuXiaoRY":
|
log.error("取消入院登记入参类型为：{}", type);
|
return cancelInHospInfo(dataMap);
|
case "JZ_ZY_ChuYuan":
|
log.error("患者出院入参类型为：{}", type);
|
return addOutHospInfo(dataMap);
|
case "JZ_ZY_QuXiaoCY":
|
log.error("取消出院入参类型为：{}", type);
|
return cancelOutHospInfo(dataMap);
|
case "JG_ZZ_BingQu":
|
log.error("病区信息入参类型为辅：{}", type);
|
return addWardAreaInfo(dataMap);
|
}
|
return true;
|
}
|
|
}
|
