|
|
|
|
@ -2,15 +2,12 @@ package com.docus.webservice.handler;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
|
|
import com.docus.webservice.dto.CollectList;
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
|
|
import com.docus.webservice.dto.SelectColumn;
|
|
|
|
|
import com.docus.webservice.entity.AfInterfaceCollect;
|
|
|
|
|
import com.docus.webservice.entity.AfInterfaceCollectSub;
|
|
|
|
|
import com.docus.webservice.entity.MrReportError;
|
|
|
|
|
import com.docus.webservice.entity.*;
|
|
|
|
|
|
|
|
|
|
import com.docus.webservice.entity.TBasic;
|
|
|
|
|
import com.docus.webservice.enums.Codes;
|
|
|
|
|
import com.docus.webservice.mapper.AfInterfaceCollectMapper;
|
|
|
|
|
import com.docus.webservice.mapper.*;
|
|
|
|
|
import com.docus.webservice.service.IMrReportErrorService;
|
|
|
|
|
import com.docus.webservice.service.IPcmachineService;
|
|
|
|
|
import com.docus.webservice.service.ITBasicService;
|
|
|
|
|
@ -19,14 +16,13 @@ import org.apache.commons.lang3.StringUtils;
|
|
|
|
|
import org.apache.logging.log4j.LogManager;
|
|
|
|
|
import org.apache.logging.log4j.Logger;
|
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
import org.springframework.scheduling.annotation.Async;
|
|
|
|
|
|
|
|
|
|
import javax.jws.WebService;
|
|
|
|
|
import java.io.ByteArrayInputStream;
|
|
|
|
|
import java.io.File;
|
|
|
|
|
import java.io.IOException;
|
|
|
|
|
import java.io.UnsupportedEncodingException;
|
|
|
|
|
import java.net.URISyntaxException;
|
|
|
|
|
import java.text.SimpleDateFormat;
|
|
|
|
|
import java.util.*;
|
|
|
|
|
|
|
|
|
|
@WebService
|
|
|
|
|
@ -44,6 +40,18 @@ public class TBasicWebService implements ITBasicWebService {
|
|
|
|
|
@Autowired
|
|
|
|
|
private AfInterfaceCollectMapper afInterfaceCollectMapper;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private TBasicMapper tBasicMapper;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private TScanAssortMapper tScanAssortMapper;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private TBasicExtendMapper tBasicExtendMapper;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private TSealMapper tSealMapper;
|
|
|
|
|
|
|
|
|
|
private Logger log = LogManager.getLogger(TBasicWebService.class);
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
@ -73,6 +81,12 @@ public class TBasicWebService implements ITBasicWebService {
|
|
|
|
|
mrReportErrorService.save(mrReportError);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 住院成员信息新增
|
|
|
|
|
*
|
|
|
|
|
* @param tbasic
|
|
|
|
|
* @return
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public String OUT_HOS_REG(String tbasic) {
|
|
|
|
|
log.info("住院成员信息新增xml" + tbasic);
|
|
|
|
|
@ -80,7 +94,9 @@ public class TBasicWebService implements ITBasicWebService {
|
|
|
|
|
//解析xml
|
|
|
|
|
HashMap<String, Object> tBasicMap = new HashMap<>();
|
|
|
|
|
HashMap<String, Object> tBasicSubMap = new HashMap<>();
|
|
|
|
|
parseXml(tbasic, tBasicMap, tBasicSubMap);
|
|
|
|
|
HashMap dateMap = new HashMap<>();
|
|
|
|
|
// Date disDate=null;
|
|
|
|
|
parseXml(tbasic, tBasicMap, tBasicSubMap, dateMap);
|
|
|
|
|
//处理业务
|
|
|
|
|
TBasic tBasic;
|
|
|
|
|
if (tBasicMap != null && tBasicMap.size() > 0) {
|
|
|
|
|
@ -91,12 +107,22 @@ public class TBasicWebService implements ITBasicWebService {
|
|
|
|
|
// }
|
|
|
|
|
//特殊处理出院时间 没有就取当前时间
|
|
|
|
|
Date currentDate = new Date();
|
|
|
|
|
if(tBasic.getDisDate()==null){
|
|
|
|
|
tBasic.setDisDate(currentDate);
|
|
|
|
|
}
|
|
|
|
|
// if(tBasic.getDisDate()==null){
|
|
|
|
|
// tBasic.setDisDate(currentDate);
|
|
|
|
|
// }
|
|
|
|
|
//tBasic.setCreateTime(currentDate);
|
|
|
|
|
tBasic.setCreateTime(currentDate);
|
|
|
|
|
itBasicService.savaAndSub(tBasic, tBasicSubMap);
|
|
|
|
|
// this.saveAndCall(tBasic);
|
|
|
|
|
itBasicService.savaAndSub(tBasic, tBasicSubMap,String.valueOf(dateMap.get("preJzh")));
|
|
|
|
|
// this.saveAndCall(tBasic);
|
|
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
|
|
SimpleDateFormat sdf1 = new SimpleDateFormat("EEE MMM dd HH:mm:ss zzz yyyy",Locale.US);
|
|
|
|
|
if (dateMap.size() > 1) {
|
|
|
|
|
Date admissDate = sdf1.parse(String.valueOf(dateMap.get("admissDate")));
|
|
|
|
|
Date disDate = sdf1.parse(String.valueOf(dateMap.get("disDate")));
|
|
|
|
|
tBasic.setAdmissDate(sdf.parse(sdf.format(admissDate)));
|
|
|
|
|
tBasic.setDisDate(sdf.parse(sdf.format(disDate)));
|
|
|
|
|
tBasic.setInpatientNo(dateMap.get("inpatientNo").toString());
|
|
|
|
|
}
|
|
|
|
|
pcmachineService.saveAndCall(tBasic);
|
|
|
|
|
} else {
|
|
|
|
|
insertLog(tbasic);
|
|
|
|
|
@ -110,20 +136,21 @@ public class TBasicWebService implements ITBasicWebService {
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
log.error("OUT_HOS_REG方法中错误信息:" + e.getMessage());
|
|
|
|
|
return ResultUtils.fail();
|
|
|
|
|
return ResultUtils.fail(e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
log.info("返回结果:" + ResultUtils.success().asXML());
|
|
|
|
|
log.info("OUT_HOS_REG返回结果:" + ResultUtils.success().asXML());
|
|
|
|
|
return ResultUtils.success().asXML();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 解析xml
|
|
|
|
|
* 住院解析xml
|
|
|
|
|
*
|
|
|
|
|
* @param tbasic
|
|
|
|
|
* @param tBasicMap
|
|
|
|
|
* @param tBasicSubMap
|
|
|
|
|
*/
|
|
|
|
|
private void parseXml(String tbasic, HashMap<String, Object> tBasicMap, HashMap<String, Object> tBasicSubMap) {
|
|
|
|
|
private void parseXml(String tbasic, HashMap<String, Object> tBasicMap, HashMap<String, Object> tBasicSubMap, HashMap dateMap) {
|
|
|
|
|
XmlUtils xmlUtils = null;
|
|
|
|
|
log.info("开始解析xml");
|
|
|
|
|
try {
|
|
|
|
|
@ -162,55 +189,396 @@ public class TBasicWebService implements ITBasicWebService {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
String preJzh = xmlUtils.getElementText("PRE_INHOSP_NO");
|
|
|
|
|
System.err.println(preJzh);
|
|
|
|
|
if (null != preJzh && !"".equals(preJzh)) {
|
|
|
|
|
//预住院患者记录
|
|
|
|
|
TBasic tBasic = tBasicMapper.selectOne(new QueryWrapper<TBasic>().eq("jzh", preJzh));
|
|
|
|
|
//正式住院患者记录
|
|
|
|
|
TBasic tBasic1 = tBasicMapper.selectOne(new QueryWrapper<TBasic>().eq("jzh", tBasicMap.get("jzh")));
|
|
|
|
|
if (null != tBasic && null != tBasic1) {
|
|
|
|
|
dateMap.put("admissDate", tBasic.getAdmissDate().toString());
|
|
|
|
|
dateMap.put("disDate", tBasic1.getAdmissDate().toString());
|
|
|
|
|
dateMap.put("inpatientNo", tBasic.getInpatientNo());
|
|
|
|
|
//将预住院患者病历文件patient_id改为正式住院的patient_id，合并病历
|
|
|
|
|
int i = tScanAssortMapper.updateByPatientId(tBasic1.getPatientId(), tBasic.getPatientId());
|
|
|
|
|
if (i <= 0) {
|
|
|
|
|
log.info("当前预住院没有文件！");
|
|
|
|
|
}else {
|
|
|
|
|
log.info("本次预住院合并"+i+"份报告");
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
log.error("");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
dateMap.put("preJzh",preJzh);
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("预住院错误信息{}", e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 住院成员信息修改
|
|
|
|
|
*
|
|
|
|
|
* @param tbasic
|
|
|
|
|
* @return
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public String OUT_HOS_CAN(String tbasic) {
|
|
|
|
|
log.info("住院成员信息修改xml" + tbasic);
|
|
|
|
|
try {
|
|
|
|
|
long l = System.currentTimeMillis();
|
|
|
|
|
HashMap<String, Object> tBasicMap = new HashMap<>();
|
|
|
|
|
HashMap<String, Object> tBasicSubMap = new HashMap<>();
|
|
|
|
|
parseXml(tbasic, tBasicMap, tBasicSubMap);
|
|
|
|
|
HashMap<String, Date> dateMap = new HashMap<>();
|
|
|
|
|
//parseXml(tbasic, tBasicMap, tBasicSubMap);
|
|
|
|
|
parseXml(tbasic, tBasicMap, tBasicSubMap, dateMap);
|
|
|
|
|
TBasic tBasic;
|
|
|
|
|
XmlUtils xmlUtils = new XmlUtils(new ByteArrayInputStream(tbasic.getBytes("UTF-8")));
|
|
|
|
|
String elementText = xmlUtils.getElementText("IS_ADM_CANCEL");
|
|
|
|
|
if (elementText.equals("1")) {
|
|
|
|
|
tBasic = JSON.parseObject(JSON.toJSONString(tBasicMap), TBasic.class);
|
|
|
|
|
tBasic.setIsCancel("1");
|
|
|
|
|
int update = tBasicMapper.update(tBasic, new QueryWrapper<TBasic>().eq("jzh", tBasic.getJzh()));
|
|
|
|
|
if (update > 0) {
|
|
|
|
|
log.info(tBasic.getJzh() + "取消入院成功！");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
long l1 = System.currentTimeMillis();
|
|
|
|
|
log.info("解析xml时间------" + (l1 - l));
|
|
|
|
|
//处理业务
|
|
|
|
|
long l2 = System.currentTimeMillis();
|
|
|
|
|
|
|
|
|
|
if (tBasicMap != null && tBasicMap.size() > 0) {
|
|
|
|
|
long l3 = System.currentTimeMillis();
|
|
|
|
|
tBasic = JSON.parseObject(JSON.toJSONString(tBasicMap), TBasic.class);
|
|
|
|
|
// if(StringUtils.isNotBlank(String.valueOf(tBasicMap.get("isDead")))||StringUtils.isNotBlank(String.valueOf("is_dead"))){
|
|
|
|
|
// String isDead=StringUtils.isNotBlank(String.valueOf(tBasicMap.get("isDead")))?String.valueOf(tBasicMap.get("isDead")):String.valueOf(tBasicMap.get("is_dead"));
|
|
|
|
|
// tBasic.setIsDead(isDead);
|
|
|
|
|
// }
|
|
|
|
|
long l4 = System.currentTimeMillis();
|
|
|
|
|
log.info("获取tBasic对象时间----------" + (l4 - l3));
|
|
|
|
|
if (StringUtils.isBlank(tBasic.getEmpId())) {
|
|
|
|
|
insertLog(tbasic);
|
|
|
|
|
log.info("emp_id字段不能为空值");
|
|
|
|
|
return ResultUtils.fail("emp_id字段不能为空值");
|
|
|
|
|
}
|
|
|
|
|
long l5 = System.currentTimeMillis();
|
|
|
|
|
tBasic.setUpdateTime(new Date());
|
|
|
|
|
try {
|
|
|
|
|
itBasicService.updateAndSub(tBasic, tBasicSubMap,String.valueOf(dateMap.get("preJzh")));
|
|
|
|
|
// this.saveAndCall(tBasic);
|
|
|
|
|
long l6 = System.currentTimeMillis();
|
|
|
|
|
log.info("update耗时----------" + (l6 - l5));
|
|
|
|
|
long l7 = System.currentTimeMillis();
|
|
|
|
|
tBasic.setAdmissDate(dateMap.get("admissDate"));
|
|
|
|
|
tBasic.setDisDate(dateMap.get("disDate"));
|
|
|
|
|
pcmachineService.saveAndCall(tBasic);
|
|
|
|
|
long l8 = System.currentTimeMillis();
|
|
|
|
|
log.info("saveAndCall耗时-------" + (l8 - l7));
|
|
|
|
|
} catch (RuntimeException e) {
|
|
|
|
|
insertLog(tbasic);
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
log.error("OUT_HOS_CAN方法中错误信息:" + e.getMessage());
|
|
|
|
|
return ResultUtils.fail(e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
insertLog(tbasic);
|
|
|
|
|
return ResultUtils.fail("请提供完整的xml");
|
|
|
|
|
}
|
|
|
|
|
long l3 = System.currentTimeMillis();
|
|
|
|
|
log.info("业务处理时间------------" + (l3 - l2));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
log.error("OUT_HOS_CAN方法中错误信息:" + e.getMessage());
|
|
|
|
|
return ResultUtils.fail(e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
log.info("OUT_HOS_CAN方法运行结果:" + ResultUtils.success().asXML());
|
|
|
|
|
return ResultUtils.success().asXML();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 出院成员信息新增
|
|
|
|
|
*
|
|
|
|
|
* @param tbasic
|
|
|
|
|
* @return
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public String DISCHARGE_REG(String tbasic) {
|
|
|
|
|
log.info("出院成员信息新增xml" + tbasic);
|
|
|
|
|
try {
|
|
|
|
|
//解析xml
|
|
|
|
|
HashMap<String, Object> tBasicMap = new HashMap<>();
|
|
|
|
|
HashMap<String, Object> tBasicSubMap = new HashMap<>();
|
|
|
|
|
HashMap<String, Object> tBasicExtendMap = new HashMap<>();
|
|
|
|
|
OutParseXml(tbasic, tBasicMap, tBasicSubMap, tBasicExtendMap);
|
|
|
|
|
//处理业务
|
|
|
|
|
TBasic tBasic;
|
|
|
|
|
XmlUtils xmlUtils = new XmlUtils(new ByteArrayInputStream(tbasic.getBytes("UTF-8")));
|
|
|
|
|
String elementText = xmlUtils.getElementText("IS_ADM_CANCEL");
|
|
|
|
|
if (elementText.equals("1")) {
|
|
|
|
|
tBasic = JSON.parseObject(JSON.toJSONString(tBasicMap), TBasic.class);
|
|
|
|
|
tBasic.setIsCancel("1");
|
|
|
|
|
int update = tBasicMapper.update(tBasic, new QueryWrapper<TBasic>().eq("jzh", tBasic.getJzh()));
|
|
|
|
|
if (update > 0) {
|
|
|
|
|
log.info(tBasic.getJzh() + "取消入院成功！");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}else {
|
|
|
|
|
TBasicExtend tBasicExtend;
|
|
|
|
|
if (tBasicMap != null && tBasicMap.size() > 0) {
|
|
|
|
|
tBasic = JSON.parseObject(JSON.toJSONString(tBasicMap), TBasic.class);
|
|
|
|
|
tBasicExtend = JSON.parseObject(JSON.toJSONString(tBasicExtendMap), TBasicExtend.class);
|
|
|
|
|
tBasicExtend.setPatientId(tBasic.getPatientId());
|
|
|
|
|
// if(StringUtils.isNotBlank(String.valueOf(tBasicMap.get("isDead")))||StringUtils.isNotBlank(String.valueOf("is_dead"))){
|
|
|
|
|
// String isDead=StringUtils.isNotBlank(String.valueOf(tBasicMap.get("isDead")))?String.valueOf(tBasicMap.get("isDead")):String.valueOf(tBasicMap.get("is_dead"));
|
|
|
|
|
// tBasic.setIsDead(isDead);
|
|
|
|
|
// }
|
|
|
|
|
//特殊处理出院时间 没有就取当前时间
|
|
|
|
|
|
|
|
|
|
// if(tBasic.getDisDate()==null){
|
|
|
|
|
// tBasic.setDisDate(currentDate);
|
|
|
|
|
// }
|
|
|
|
|
//tBasic.setCreateTime(currentDate);
|
|
|
|
|
|
|
|
|
|
itBasicService.OutSavaAndSub(tBasic, tBasicSubMap, tBasicExtend);
|
|
|
|
|
// this.saveAndCall(tBasic);
|
|
|
|
|
pcmachineService.saveAndCallOut(tBasic);
|
|
|
|
|
} else {
|
|
|
|
|
insertLog(tbasic);
|
|
|
|
|
log.info("请提供完整的xml");
|
|
|
|
|
return ResultUtils.fail("请提供完整的xml");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
} catch (RuntimeException e) {
|
|
|
|
|
insertLog(tbasic);
|
|
|
|
|
log.error("DISCHARGE_REG方法中错误信息:" + e.getMessage());
|
|
|
|
|
return ResultUtils.fail(e.getMessage());
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
log.error("DISCHARGE_REG方法中错误信息:" + e.getMessage());
|
|
|
|
|
return ResultUtils.fail(e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
log.info("DISCHARGE_REG返回结果:" + ResultUtils.success().asXML());
|
|
|
|
|
return ResultUtils.success().asXML();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 出院成员信息修改
|
|
|
|
|
*
|
|
|
|
|
* @param tbasic
|
|
|
|
|
* @return
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public String DISCHARGE_CAN(String tbasic) {
|
|
|
|
|
log.info("出院成员信息修改xml" + tbasic);
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
|
|
long l = System.currentTimeMillis();
|
|
|
|
|
HashMap<String, Object> tBasicMap = new HashMap<>();
|
|
|
|
|
HashMap<String, Object> tBasicSubMap = new HashMap<>();
|
|
|
|
|
HashMap<String, Object> tBasicExtendMap = new HashMap<>();
|
|
|
|
|
TBasic tBasic;
|
|
|
|
|
TBasicExtend tBasicExtend;
|
|
|
|
|
OutParseXml(tbasic, tBasicMap, tBasicSubMap, tBasicExtendMap);
|
|
|
|
|
long l1 = System.currentTimeMillis();
|
|
|
|
|
log.info("解析xml时间------" + (l1 - l));
|
|
|
|
|
//处理业务
|
|
|
|
|
long l2 = System.currentTimeMillis();
|
|
|
|
|
|
|
|
|
|
if (tBasicMap != null && tBasicMap.size() > 0) {
|
|
|
|
|
long l3 = System.currentTimeMillis();
|
|
|
|
|
tBasic = JSON.parseObject(JSON.toJSONString(tBasicMap), TBasic.class);
|
|
|
|
|
tBasicExtend = JSON.parseObject(JSON.toJSONString(tBasicExtendMap), TBasicExtend.class);
|
|
|
|
|
tBasicExtend.setPatientId(tBasic.getPatientId());
|
|
|
|
|
// if(StringUtils.isNotBlank(String.valueOf(tBasicMap.get("isDead")))||StringUtils.isNotBlank(String.valueOf("is_dead"))){
|
|
|
|
|
// String isDead=StringUtils.isNotBlank(String.valueOf(tBasicMap.get("isDead")))?String.valueOf(tBasicMap.get("isDead")):String.valueOf(tBasicMap.get("is_dead"));
|
|
|
|
|
// tBasic.setIsDead(isDead);
|
|
|
|
|
// }
|
|
|
|
|
if (StringUtils.isBlank(tBasic.getEmpId())) {
|
|
|
|
|
long l4 = System.currentTimeMillis();
|
|
|
|
|
log.info("获取tBasic对象时间----------" + (l4 - l3));
|
|
|
|
|
if (StringUtils.isBlank(tBasic.getJzh())) {
|
|
|
|
|
insertLog(tbasic);
|
|
|
|
|
log.info("emp_id字段不能为空值");
|
|
|
|
|
return ResultUtils.fail("emp_id字段不能为空值");
|
|
|
|
|
log.info("INHOSP_NO字段不能为空值");
|
|
|
|
|
return ResultUtils.fail("INHOSP_NO字段不能为空值");
|
|
|
|
|
}
|
|
|
|
|
long l5 = System.currentTimeMillis();
|
|
|
|
|
tBasic.setUpdateTime(new Date());
|
|
|
|
|
try {
|
|
|
|
|
itBasicService.updateAndSub(tBasic, tBasicSubMap);
|
|
|
|
|
itBasicService.OutUpdateAndSub(tBasic, tBasicSubMap, tBasicExtend);
|
|
|
|
|
// this.saveAndCall(tBasic);
|
|
|
|
|
pcmachineService.saveAndCall(tBasic);
|
|
|
|
|
long l6 = System.currentTimeMillis();
|
|
|
|
|
log.info("update耗时----------" + (l6 - l5));
|
|
|
|
|
long l7 = System.currentTimeMillis();
|
|
|
|
|
pcmachineService.saveAndCallOut(tBasic);
|
|
|
|
|
long l8 = System.currentTimeMillis();
|
|
|
|
|
log.info("saveAndCall耗时-------" + (l8 - l7));
|
|
|
|
|
} catch (RuntimeException e) {
|
|
|
|
|
insertLog(tbasic);
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
log.error("OUT_HOS_CAN方法中错误信息:" + e.getMessage());
|
|
|
|
|
log.error("DISCHARGE_CAN方法中错误信息:" + e.getMessage());
|
|
|
|
|
return ResultUtils.fail(e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
insertLog(tbasic);
|
|
|
|
|
return ResultUtils.fail("请提供完整的xml");
|
|
|
|
|
}
|
|
|
|
|
long l3 = System.currentTimeMillis();
|
|
|
|
|
log.info("业务处理时间------------" + (l3 - l2));
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
log.error("OUT_HOS_CAN方法中错误信息:" + e.getMessage());
|
|
|
|
|
return ResultUtils.fail();
|
|
|
|
|
log.error("DISCHARGE_CAN方法中错误信息:" + e.getMessage());
|
|
|
|
|
return ResultUtils.fail(e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
log.info("OUT_HOS_CAN方法运行结果:" + ResultUtils.success().asXML());
|
|
|
|
|
log.info("DISCHARGE_CAN方法运行结果:" + ResultUtils.success().asXML());
|
|
|
|
|
return ResultUtils.success().asXML();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 病案封存
|
|
|
|
|
*
|
|
|
|
|
* @param tseal
|
|
|
|
|
* @return
|
|
|
|
|
*/
|
|
|
|
|
// @Override
|
|
|
|
|
// public String MEDICAL_RECORD_SEAL(String tseal) {
|
|
|
|
|
// log.info("病案封存" + tseal);
|
|
|
|
|
// try {
|
|
|
|
|
// //解析xml
|
|
|
|
|
// HashMap<String, Object> tSealMap = new HashMap<>();
|
|
|
|
|
// SealParseXml(tseal, tSealMap);
|
|
|
|
|
// //处理业务
|
|
|
|
|
// TSeal tSeal;
|
|
|
|
|
// if (tSealMap != null && tSealMap.size() > 0) {
|
|
|
|
|
// tSeal = JSON.parseObject(JSON.toJSONString(tSealMap), TSeal.class);
|
|
|
|
|
// int insert = tSealMapper.insert(tSeal);
|
|
|
|
|
// if (insert > 0){
|
|
|
|
|
// log.info(tSeal.getJzh()+"----封存信息插入成功!");
|
|
|
|
|
// }else {
|
|
|
|
|
// log.info(tSeal.getJzh()+"----封存信息插入失败!");
|
|
|
|
|
// }
|
|
|
|
|
// } else {
|
|
|
|
|
// insertLog(tseal);
|
|
|
|
|
// log.info("请提供完整的xml");
|
|
|
|
|
// return ResultUtils.fail("请提供完整的xml");
|
|
|
|
|
// }
|
|
|
|
|
// } catch (RuntimeException e) {
|
|
|
|
|
// insertLog(tseal);
|
|
|
|
|
// log.error("MEDICAL_RECORD_SEAL方法中错误信息:" + e.getMessage());
|
|
|
|
|
// return ResultUtils.fail(e.getMessage());
|
|
|
|
|
// } catch (Exception e) {
|
|
|
|
|
// e.printStackTrace();
|
|
|
|
|
// log.error("MEDICAL_RECORD_SEAL中错误信息:" + e.getMessage());
|
|
|
|
|
// return ResultUtils.fail(e.getMessage());
|
|
|
|
|
// }
|
|
|
|
|
// log.info("MEDICAL_RECORD_SEAL返回结果:" + ResultUtils.success().asXML());
|
|
|
|
|
// return ResultUtils.success().asXML();
|
|
|
|
|
// }
|
|
|
|
|
// /**
|
|
|
|
|
// * 封存解析xml
|
|
|
|
|
// *
|
|
|
|
|
// * @param tSeal
|
|
|
|
|
// * @param tSealMap
|
|
|
|
|
// */
|
|
|
|
|
// private void SealParseXml(String tSeal, HashMap<String, Object> tSealMap) {
|
|
|
|
|
// XmlUtils xmlUtils = null;
|
|
|
|
|
// log.info("开始解析xml");
|
|
|
|
|
// try {
|
|
|
|
|
// xmlUtils = new XmlUtils(new ByteArrayInputStream(tSeal.getBytes("UTF-8")));
|
|
|
|
|
// } catch (UnsupportedEncodingException e) {
|
|
|
|
|
// e.printStackTrace();
|
|
|
|
|
// }
|
|
|
|
|
//
|
|
|
|
|
// if (StringUtils.isBlank(xmlUtils.getElementText("SEAL_ID"))){
|
|
|
|
|
// log.error("SEAL_ID 字段不能为空值");
|
|
|
|
|
// throw new RuntimeException("SEAL_ID 字段不能为空值");
|
|
|
|
|
// }
|
|
|
|
|
// //解析json映射文件
|
|
|
|
|
// String json = JsonUtils.readJsonFile(CurrentPath() + Codes.JSON_SEAL_ADDRESS.getMessage());
|
|
|
|
|
// Map jsonMap = JSON.parseObject(json, Map.class);
|
|
|
|
|
//
|
|
|
|
|
// List<SelectColumn> selectColumns = JSON.parseArray(String.valueOf(jsonMap.get(Codes.SELECT_COLUMNS.getMessage())), SelectColumn.class);
|
|
|
|
|
// String value;
|
|
|
|
|
// for (SelectColumn selectColumn : selectColumns) {
|
|
|
|
|
// try {
|
|
|
|
|
// value = xmlUtils.getElementText(selectColumn.getQualityColumn()) == null ? null : String.valueOf(xmlUtils.getElementText(selectColumn.getQualityColumn()));
|
|
|
|
|
// } catch (RuntimeException e) {
|
|
|
|
|
// String message = e.getMessage();
|
|
|
|
|
// log.error("解析xml出现:" + message);
|
|
|
|
|
// throw new RuntimeException(message);
|
|
|
|
|
// }
|
|
|
|
|
// if (StringUtils.isBlank(value)) {
|
|
|
|
|
// if (selectColumn.getByNull() == 0) {
|
|
|
|
|
// insertLog(tSeal);
|
|
|
|
|
// log.error(selectColumn.getQualityColumn() + " 字段不能为空值");
|
|
|
|
|
// throw new RuntimeException(selectColumn.getQualityColumn() + " 字段不能为空值");
|
|
|
|
|
// } else {
|
|
|
|
|
// continue;
|
|
|
|
|
// }
|
|
|
|
|
// } else {
|
|
|
|
|
// if (selectColumn.getTableName().equals("t_seal")) {
|
|
|
|
|
// tSealMap.put(selectColumn.getColumnName(), value);
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
//
|
|
|
|
|
/**
|
|
|
|
|
* 出院解析xml
|
|
|
|
|
*
|
|
|
|
|
* @param tbasic
|
|
|
|
|
* @param tBasicMap
|
|
|
|
|
* @param tBasicSubMap
|
|
|
|
|
*/
|
|
|
|
|
private void OutParseXml(String tbasic, HashMap<String, Object> tBasicMap, HashMap<String, Object> tBasicSubMap, HashMap<String, Object> tBasicExtendMap) {
|
|
|
|
|
XmlUtils xmlUtils = null;
|
|
|
|
|
log.info("开始解析xml");
|
|
|
|
|
try {
|
|
|
|
|
xmlUtils = new XmlUtils(new ByteArrayInputStream(tbasic.getBytes("UTF-8")));
|
|
|
|
|
} catch (UnsupportedEncodingException e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
//解析json映射文件
|
|
|
|
|
String json = JsonUtils.readJsonFile(CurrentPath() + Codes.JSON_OUT_ADDRESS.getMessage());
|
|
|
|
|
Map jsonMap = JSON.parseObject(json, Map.class);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
List<SelectColumn> selectColumns = JSON.parseArray(String.valueOf(jsonMap.get(Codes.SELECT_COLUMNS.getMessage())), SelectColumn.class);
|
|
|
|
|
String value;
|
|
|
|
|
for (SelectColumn selectColumn : selectColumns) {
|
|
|
|
|
try {
|
|
|
|
|
value = xmlUtils.getElementText(selectColumn.getQualityColumn()) == null ? null : String.valueOf(xmlUtils.getElementText(selectColumn.getQualityColumn()));
|
|
|
|
|
} catch (RuntimeException e) {
|
|
|
|
|
String message = e.getMessage();
|
|
|
|
|
log.error("解析xml出现:" + message);
|
|
|
|
|
throw new RuntimeException(message);
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.isBlank(value)) {
|
|
|
|
|
if (selectColumn.getByNull() == 0) {
|
|
|
|
|
insertLog(tbasic);
|
|
|
|
|
log.error(selectColumn.getQualityColumn() + " 字段不能为空值");
|
|
|
|
|
throw new RuntimeException(selectColumn.getQualityColumn() + " 字段不能为空值");
|
|
|
|
|
} else {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
if (selectColumn.getTableName().equals("t_basic")) {
|
|
|
|
|
tBasicMap.put(selectColumn.getColumnName(), value);
|
|
|
|
|
}
|
|
|
|
|
if (selectColumn.getTableName().equals("t_basic_extend")) {
|
|
|
|
|
tBasicExtendMap.put(selectColumn.getColumnName(), value);
|
|
|
|
|
}
|
|
|
|
|
if (selectColumn.getTableName().equals("t_basic_sub")) {
|
|
|
|
|
tBasicSubMap.put(selectColumn.getColumnName(), value);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
tan
2 years ago