tanzherong
/
docus-webservice
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1，配置文件修改

Browse Source 
2，添加日志保存
docus_webservice_1.1
mill 4 years ago
parent 0c472ffd6a
commit 01da536920
3 changed files with 132 additions and 56 deletions
Show Stats Download Patch File Download Diff File

106
docus-webservice/dataConfig/homeQualitySet.json
Unescape Escape View File

@ -2,156 +2,164 @@
"selectColumns":[ "selectColumns":[
{ {
"serialNumber": "1", "serialNumber": "1",
"tableName": "t_basic_sub", "tableName": "t_basic",
"columnName": "healthy_card", "columnName": "ward_palce",
"qualityColumn": "VUID", "qualityColumn": "SUBOR_HOSPITAL_DISTRICT",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "2", "serialNumber": "2",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "admiss_id", "columnName": "emp_id",
"qualityColumn": "INHOSP_INDEX_NO", "qualityColumn": "ACCOUNT_NUM",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "3", "serialNumber": "3",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "inpatient_no", "columnName": "admiss_id",
"qualityColumn": "INHOSP_NO", "qualityColumn": "INHOSP_INDEX_NO",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "4", "serialNumber": "4",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "jzh", "columnName": "name",
"qualityColumn": "EMPI_ID", "qualityColumn": "PAT_NAME",
"byNull":1 "byNull":0
}, },
{ {
"serialNumber": "5", "serialNumber": "5",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "dis_date", "columnName": "admiss_times",
"qualityColumn": "DISCHARGE_DATETIME", "qualityColumn": "VISIT_NO",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "6", "serialNumber": "6",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "name", "columnName": "dis_dept",
"qualityColumn": "PAT_NAME", "qualityColumn": "DEPT_CODE",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "7", "serialNumber": "7",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "admiss_times", "columnName": "dis_dept_name",
"qualityColumn": "VISIT_NO", "qualityColumn": "DEPT_NAME",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "8", "serialNumber": "8",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "visit_type_code", "columnName": "attending",
"qualityColumn": "VISIT_TYPE_CODE", "qualityColumn": "CHAR_DOC_CODE",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "9", "serialNumber": "9",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "visit_type_name", "columnName": "dis_date",
"qualityColumn": "VISIT_TYPE_NAME", "qualityColumn": "DISCHARGE_DATETIME",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "10", "serialNumber": "10",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "admiss_days", "columnName": "is_dead",
"qualityColumn": "INHOSP_DAYS", "qualityColumn": "DEATH_FLAG",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "11", "serialNumber": "11",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "id_card", "columnName": "inpatient_no",
"qualityColumn": "ID_NUMBER", "qualityColumn": "INHOSP_NO",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "12", "serialNumber": "12",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "main_diag_code", "columnName": "jzh",
"qualityColumn": "WM_DIAG_CODE", "qualityColumn": "EMPI_ID",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "13", "serialNumber": "13",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "main_diag_name", "columnName": "visit_type_code",
"qualityColumn": "WM_DIAG_NAME", "qualityColumn": "VISIT_TYPE_CODE",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "14", "serialNumber": "14",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "attending", "columnName": "visit_type_name",
"qualityColumn": "WM_DIAG_DR_CODE", "qualityColumn": "VISIT_TYPE_NAME",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "15", "serialNumber": "15",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "attending_name", "columnName": "admiss_days",
"qualityColumn": "WM_DIAG_DR_NAME", "qualityColumn": "INHOSP_DAYS",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "16", "serialNumber": "16",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "tcm_diag_code", "columnName": "id_card",
"qualityColumn": "TCM_DIAG_CODE", "qualityColumn": "ID_NUMBER",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "17", "serialNumber": "17",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "tcm_diag_name", "columnName": "main_diag_code",
"qualityColumn": "TCM_DIAG_NAME", "qualityColumn": "WM_DIAG_CODE",
"byNull":0 "byNull":0
}, },
{ {
"serialNumber": "18", "serialNumber": "18",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "dis_dept", "columnName": "main_diag_name",
"qualityColumn": "DEPT_CODE", "qualityColumn": "WM_DIAG_NAME",
"byNull":1 "byNull":0
}, },
{ {
"serialNumber": "19", "serialNumber": "19",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "dis_dept_name", "columnName": "tcm_diag_code",
"qualityColumn": "DEPT_NAME", "qualityColumn": "TCM_DIAG_CODE",
"byNull":1 "byNull":0
}, },
{ {
"serialNumber": "20", "serialNumber": "20",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "emp_id", "columnName": "tcm_diag_name",
"qualityColumn": "ACCOUNT_NUM", "qualityColumn": "TCM_DIAG_NAME",
"byNull":1 "byNull":0
}, },
{ {
"serialNumber": "21", "serialNumber": "21",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "ward_palce", "columnName": "admiss_dept",
"qualityColumn": "SUBOR_HOSPITAL_DISTRICT", "qualityColumn": "ADMIT_DEPT_CODE",
"byNull":1 "byNull":1
}, },
{ {
"serialNumber": "22", "serialNumber": "22",
"tableName": "t_basic", "tableName": "t_basic",
"columnName": "admiss_dept", "columnName": "admiss_dept_name",
"qualityColumn": "ADMIT_DEPT_COD", "qualityColumn": "ADMIT_DEPT_NAME",
"byNull":1
}
,
{
"serialNumber": "23",
"tableName": "t_basic",
"columnName": "admiss_date",
"qualityColumn": "ADMIT_DATE",
"byNull":1 "byNull":1
} }
] ]

32
docus-webservice/src/main/java/com/docus/webservice/handler/TBasicWebService.java
Unescape Escape View File

@ -15,6 +15,8 @@ import com.docus.webservice.service.IMrReportErrorService;
import com.docus.webservice.service.ITBasicService; import com.docus.webservice.service.ITBasicService;
import com.docus.webservice.utils.*; import com.docus.webservice.utils.*;
import org.apache.commons.lang3.StringUtils; 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.beans.factory.annotation.Autowired;
import javax.jws.WebService; import javax.jws.WebService;
@ -37,6 +39,7 @@ public class TBasicWebService implements ITBasicWebService {
@Autowired @Autowired
private AfInterfaceCollectMapper afInterfaceCollectMapper; private AfInterfaceCollectMapper afInterfaceCollectMapper;
private Logger log= LogManager.getLogger(TBasicWebService.class);
/** /**
* 获取jar包所在位置 * 获取jar包所在位置
* *
@ -66,6 +69,7 @@ public class TBasicWebService implements ITBasicWebService {
@Override @Override
public String OUT_HOS_REG(String tbasic) { public String OUT_HOS_REG(String tbasic) {
log.info("打印底层xml"+tbasic);
try { try {
//解析xml //解析xml
HashMap<String, Object> tBasicMap = new HashMap<>(); HashMap<String, Object> tBasicMap = new HashMap<>();
@ -81,16 +85,20 @@ public class TBasicWebService implements ITBasicWebService {
this.saveAndCall(tBasic); this.saveAndCall(tBasic);
} catch (RuntimeException e) { } catch (RuntimeException e) {
insertLog(tbasic); insertLog(tbasic);
log.error("OUT_HOS_REG方法中错误信息:"+e.getMessage());
return ResultUtils.fail(e.getMessage()); return ResultUtils.fail(e.getMessage());
} }
} else { } else {
insertLog(tbasic); insertLog(tbasic);
log.info("请提供完整的xml");
return ResultUtils.fail("请提供完整的xml"); return ResultUtils.fail("请提供完整的xml");
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
log.error("OUT_HOS_REG方法中错误信息:"+e.getMessage());
return ResultUtils.fail(); return ResultUtils.fail();
} }
log.info("返回结果:"+ResultUtils.success().asXML());
return ResultUtils.success().asXML(); return ResultUtils.success().asXML();
} }
@ -102,7 +110,7 @@ public class TBasicWebService implements ITBasicWebService {
*/ */
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) {
XmlUtils xmlUtils = null; XmlUtils xmlUtils = null;
log.info("开始解析xml");
try { try {
xmlUtils = new XmlUtils(new ByteArrayInputStream(tbasic.getBytes("UTF-8"))); xmlUtils = new XmlUtils(new ByteArrayInputStream(tbasic.getBytes("UTF-8")));
} catch (UnsupportedEncodingException e) { } catch (UnsupportedEncodingException e) {
@ -119,11 +127,13 @@ public class TBasicWebService implements ITBasicWebService {
value = xmlUtils.getElementText(selectColumn.getQualityColumn()) == null ? null : String.valueOf(xmlUtils.getElementText(selectColumn.getQualityColumn())); value = xmlUtils.getElementText(selectColumn.getQualityColumn()) == null ? null : String.valueOf(xmlUtils.getElementText(selectColumn.getQualityColumn()));
} catch (RuntimeException e) { } catch (RuntimeException e) {
String message = e.getMessage(); String message = e.getMessage();
log.error("解析xml出现:"+message);
throw new RuntimeException(message); throw new RuntimeException(message);
} }
if (StringUtils.isBlank(value)) { if (StringUtils.isBlank(value)) {
if (selectColumn.getByNull() == 0) { if (selectColumn.getByNull() == 0) {
insertLog(tbasic); insertLog(tbasic);
log.error(selectColumn.getQualityColumn() + " 字段不能为空值");
throw new RuntimeException(selectColumn.getQualityColumn() + " 字段不能为空值"); throw new RuntimeException(selectColumn.getQualityColumn() + " 字段不能为空值");
} else { } else {
continue; continue;
@ -138,9 +148,9 @@ public class TBasicWebService implements ITBasicWebService {
} }
} }
} }
@Override @Override
public String OUT_HOS_CAN(String tbasic) { public String OUT_HOS_CAN(String tbasic) {
log.info("打印底层xml"+tbasic);
try { try {
HashMap<String, Object> tBasicMap = new HashMap<>(); HashMap<String, Object> tBasicMap = new HashMap<>();
HashMap<String, Object> tBasicSubMap = new HashMap<>(); HashMap<String, Object> tBasicSubMap = new HashMap<>();
@ -151,6 +161,7 @@ public class TBasicWebService implements ITBasicWebService {
tBasic = JSON.parseObject(JSON.toJSONString(tBasicMap), TBasic.class); tBasic = JSON.parseObject(JSON.toJSONString(tBasicMap), TBasic.class);
if (StringUtils.isBlank(tBasic.getEmpId())) { if (StringUtils.isBlank(tBasic.getEmpId())) {
insertLog(tbasic); insertLog(tbasic);
log.info("emp_id字段不能为空值");
return ResultUtils.fail("emp_id字段不能为空值"); return ResultUtils.fail("emp_id字段不能为空值");
} }
tBasic.setUpdateTime(new Date()); tBasic.setUpdateTime(new Date());
@ -160,6 +171,7 @@ public class TBasicWebService implements ITBasicWebService {
} catch (RuntimeException e) { } catch (RuntimeException e) {
insertLog(tbasic); insertLog(tbasic);
e.printStackTrace(); e.printStackTrace();
log.error("OUT_HOS_CAN方法中错误信息:"+e.getMessage());
return ResultUtils.fail(e.getMessage()); return ResultUtils.fail(e.getMessage());
} }
} else { } else {
@ -168,12 +180,14 @@ public class TBasicWebService implements ITBasicWebService {
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
log.error("OUT_HOS_CAN方法中错误信息:"+e.getMessage());
return ResultUtils.fail(); return ResultUtils.fail();
} }
log.info("OUT_HOS_CAN方法运行结果:"+ResultUtils.success().asXML());
return ResultUtils.success().asXML(); return ResultUtils.success().asXML();
} }
public void saveAndCall(TBasic tBasic) throws URISyntaxException { public void saveAndCall(TBasic tBasic) throws URISyntaxException {
log.info("病案对象"+tBasic.toString());
//解析json映射文件 //解析json映射文件
String json = JsonUtils.readJsonFile(CurrentPath() + Codes.JSON_COLLECTLIST.getMessage()); String json = JsonUtils.readJsonFile(CurrentPath() + Codes.JSON_COLLECTLIST.getMessage());
if (StringUtils.isNotBlank(json)) { if (StringUtils.isNotBlank(json)) {
@ -191,8 +205,10 @@ public class TBasicWebService implements ITBasicWebService {
afc.setJzh(tBasic.getJzh()); afc.setJzh(tBasic.getJzh());
afc.setTaskCount(task_count); afc.setTaskCount(task_count);
afc.setCreateTime(new Date()); afc.setCreateTime(new Date());
afInterfaceCollectMapper.addAfInterfaceCollect(afc); int i = afInterfaceCollectMapper.addAfInterfaceCollect(afc);
if (i<0) {
log.info("省中医病案采集表添加信息失败！");
}
//添加省中医病案采集-子任务 //添加省中医病案采集-子任务
List<AfInterfaceCollectSub> list=new ArrayList<>(); List<AfInterfaceCollectSub> list=new ArrayList<>();
for (CollectList collectList : collectLists) { for (CollectList collectList : collectLists) {
@ -205,8 +221,10 @@ public class TBasicWebService implements ITBasicWebService {
collectList.setId(afcsId); collectList.setId(afcsId);
list.add(afInterfaceCollectSub); list.add(afInterfaceCollectSub);
} }
afInterfaceCollectMapper.addAfInterfaceCollectSub(list); int i1 = afInterfaceCollectMapper.addAfInterfaceCollectSub(list);
if (i1<0) {
log.info("省中医病案采集-子任务失败！");
}
for (CollectList collectList : collectLists) { for (CollectList collectList : collectLists) {
//调用http发送请求 //调用http发送请求
this.sendHttp(collectList,tBasic.getJzh()); this.sendHttp(collectList,tBasic.getJzh());

50
docus-webservice/src/main/resources/logback-spring.xml
Unescape Escape View File

@ -0,0 +1,50 @@
<?xml version="1.0" encoding="UTF-8" ?>
<configuration>
<!-- %m输出的信息,%p日志级别,%t线程名,%d日期,%c类的全名,%i索引【从数字0开始递增】,,, -->
<!-- appender是configuration的子节点，是负责写日志的组件。 -->
<!-- ConsoleAppender：把日志输出到控制台 -->
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d %p (%file:%line\)- %m%n</pattern>
<!-- 控制台也要使用UTF-8，不要使用GBK，否则会中文乱码 -->
<charset>UTF-8</charset>
</encoder>
</appender>
<!-- RollingFileAppender：滚动记录文件，先将日志记录到指定文件，当符合某个条件时，将日志记录到其他文件 -->
<!-- 以下的大概意思是：1.先按日期存日志，日期变了，将前一天的日志文件名重命名为XXX%日期%索引，新的日志仍然是demo.log -->
<!-- 2.如果日期没有发生变化，但是当前日志的文件大小超过1KB时，对当前日志进行分割 重命名-->
<appender name="demolog" class="ch.qos.logback.core.rolling.RollingFileAppender">
<File>configLog/log.log</File>
<!-- rollingPolicy:当发生滚动时，决定 RollingFileAppender 的行为，涉及文件移动和重命名。 -->
<!-- TimeBasedRollingPolicy： 最常用的滚动策略，它根据时间来制定滚动策略，既负责滚动也负责出发滚动 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 活动文件的名字会根据fileNamePattern的值，每隔一段时间改变一次 -->
<!-- 文件名：log/demo.2017-12-05.0.log -->
<fileNamePattern>log/demo.%d.%i.log</fileNamePattern>
<!-- 每产生一个日志文件，该日志文件的保存期限为15天 -->
<maxHistory>15</maxHistory>
<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
<!-- maxFileSize:这是活动文件的大小，默认值是10MB，测试时可改成1KB看效果 -->
<maxFileSize>10MB</maxFileSize>
</timeBasedFileNamingAndTriggeringPolicy>
</rollingPolicy>
<encoder>
<!-- pattern节点，用来设置日志的输入格式 -->
<pattern>
%d %p (%file:%line\)- %m%n
</pattern>
<!-- 记录日志的编码:此处设置字符集 - -->
<charset>UTF-8</charset>
</encoder>
</appender>
<!-- 控制台输出日志级别 -->
<root level="info">
<appender-ref ref="STDOUT" />
</root>
<!-- 指定项目中某个包，当有日志操作行为时的日志记录级别 -->
<!-- com.liyan为根包，也就是只要是发生在这个根包下面的所有日志操作行为的权限都是DEBUG -->
<!-- 级别依次为【从高到低】：FATAL > ERROR > WARN > INFO > DEBUG > TRACE -->
<logger name="com.docus.webservice" level="INFO">
<appender-ref ref="demolog" />
</logger>
</configuration>
Write Preview
Loading…
Cancel
Save