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

日志修改

Browse Source
docus_webservice_1.1
lzy 4 years ago
parent 01da536920
commit e7121c5bf6
1 changed files with 36 additions and 33 deletions
Show Stats Download Patch File Download Diff File

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

@ -39,7 +39,8 @@ public class TBasicWebService implements ITBasicWebService {
@Autowired @Autowired
private AfInterfaceCollectMapper afInterfaceCollectMapper; private AfInterfaceCollectMapper afInterfaceCollectMapper;
private Logger log= LogManager.getLogger(TBasicWebService.class); private Logger log = LogManager.getLogger(TBasicWebService.class);
/** /**
* 获取jar包所在位置 * 获取jar包所在位置
* *
@ -69,41 +70,40 @@ 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); log.info("住院成员信息新增xml" + tbasic);
try { try {
//解析xml //解析xml
HashMap<String, Object> tBasicMap = new HashMap<>(); HashMap<String, Object> tBasicMap = new HashMap<>();
HashMap<String, Object> tBasicSubMap = new HashMap<>(); HashMap<String, Object> tBasicSubMap = new HashMap<>();
parseXml(tbasic,tBasicMap,tBasicSubMap); parseXml(tbasic, tBasicMap, tBasicSubMap);
//处理业务 //处理业务
TBasic tBasic; TBasic tBasic;
if (tBasicMap != null && tBasicMap.size() > 0) { if (tBasicMap != null && tBasicMap.size() > 0) {
tBasic = JSON.parseObject(JSON.toJSONString(tBasicMap), TBasic.class); tBasic = JSON.parseObject(JSON.toJSONString(tBasicMap), TBasic.class);
tBasic.setCreateTime(new Date()); tBasic.setCreateTime(new Date());
try {
itBasicService.savaAndSub(tBasic, tBasicSubMap); itBasicService.savaAndSub(tBasic, tBasicSubMap);
this.saveAndCall(tBasic); this.saveAndCall(tBasic);
} catch (RuntimeException e) {
insertLog(tbasic);
log.error("OUT_HOS_REG方法中错误信息:"+e.getMessage());
return ResultUtils.fail(e.getMessage());
}
} else { } else {
insertLog(tbasic); insertLog(tbasic);
log.info("请提供完整的xml"); log.info("请提供完整的xml");
return ResultUtils.fail("请提供完整的xml"); return ResultUtils.fail("请提供完整的xml");
} }
} catch (RuntimeException e) {
insertLog(tbasic);
log.error("OUT_HOS_REG方法中错误信息:" + e.getMessage());
return ResultUtils.fail(e.getMessage());
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
log.error("OUT_HOS_REG方法中错误信息:"+e.getMessage()); log.error("OUT_HOS_REG方法中错误信息:" + e.getMessage());
return ResultUtils.fail(); return ResultUtils.fail();
} }
log.info("返回结果:"+ResultUtils.success().asXML()); log.info("返回结果:" + ResultUtils.success().asXML());
return ResultUtils.success().asXML(); return ResultUtils.success().asXML();
} }
/** /**
* 解析xml * 解析xml
*
* @param tbasic * @param tbasic
* @param tBasicMap * @param tBasicMap
* @param tBasicSubMap * @param tBasicSubMap
@ -127,7 +127,7 @@ 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); log.error("解析xml出现:" + message);
throw new RuntimeException(message); throw new RuntimeException(message);
} }
if (StringUtils.isBlank(value)) { if (StringUtils.isBlank(value)) {
@ -148,13 +148,14 @@ 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); 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<>();
parseXml(tbasic,tBasicMap,tBasicSubMap); parseXml(tbasic, tBasicMap, tBasicSubMap);
//处理业务 //处理业务
TBasic tBasic; TBasic tBasic;
if (tBasicMap != null && tBasicMap.size() > 0) { if (tBasicMap != null && tBasicMap.size() > 0) {
@ -171,7 +172,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()); log.error("OUT_HOS_CAN方法中错误信息:" + e.getMessage());
return ResultUtils.fail(e.getMessage()); return ResultUtils.fail(e.getMessage());
} }
} else { } else {
@ -180,40 +181,42 @@ public class TBasicWebService implements ITBasicWebService {
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
log.error("OUT_HOS_CAN方法中错误信息:"+e.getMessage()); log.error("OUT_HOS_CAN方法中错误信息:" + e.getMessage());
return ResultUtils.fail(); return ResultUtils.fail();
} }
log.info("OUT_HOS_CAN方法运行结果:"+ResultUtils.success().asXML()); 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()); 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)) {
Map jsonMap = JSON.parseObject(json, Map.class); Map jsonMap = JSON.parseObject(json, Map.class);
//任务数 //任务数
Integer task_count= JSON.parseObject(String.valueOf(jsonMap.get(Codes.JSON_TASK_COUNT.getMessage())), Integer.class); Integer task_count = JSON.parseObject(String.valueOf(jsonMap.get(Codes.JSON_TASK_COUNT.getMessage())), Integer.class);
List<CollectList> collectLists = JSON.parseArray(String.valueOf(jsonMap.get(Codes.JSON_COLLECTLIST_ROOT.getMessage())), CollectList.class); List<CollectList> collectLists = JSON.parseArray(String.valueOf(jsonMap.get(Codes.JSON_COLLECTLIST_ROOT.getMessage())), CollectList.class);
//添加省中医病案采集 //添加省中医病案采集
SnowflakeIdWorker idWorker = new SnowflakeIdWorker(0, 0); SnowflakeIdWorker idWorker = new SnowflakeIdWorker(0, 0);
AfInterfaceCollect afc=new AfInterfaceCollect(); AfInterfaceCollect afc = new AfInterfaceCollect();
Long afcId=idWorker.nextId(); Long afcId = idWorker.nextId();
afc.setId(afcId); afc.setId(afcId);
afc.setJzh(tBasic.getJzh()); afc.setJzh(tBasic.getJzh());
afc.setTaskCount(task_count); afc.setTaskCount(task_count);
afc.setCreateTime(new Date()); afc.setCreateTime(new Date());
int i = afInterfaceCollectMapper.addAfInterfaceCollect(afc); int i = afInterfaceCollectMapper.addAfInterfaceCollect(afc);
if (i<0) { if (i < 0) {
log.info("省中医病案采集表添加信息失败！"); log.info("省中医病案采集表添加信息失败！");
} }
//添加省中医病案采集-子任务 //添加省中医病案采集-子任务
List<AfInterfaceCollectSub> list=new ArrayList<>(); List<AfInterfaceCollectSub> list = new ArrayList<>();
for (CollectList collectList : collectLists) { for (CollectList collectList : collectLists) {
AfInterfaceCollectSub afInterfaceCollectSub = new AfInterfaceCollectSub(); AfInterfaceCollectSub afInterfaceCollectSub = new AfInterfaceCollectSub();
Long afcsId= idWorker.nextId(); Long afcsId = idWorker.nextId();
afInterfaceCollectSub.setId(afcsId); afInterfaceCollectSub.setId(afcsId);
afInterfaceCollectSub.setAfInterfaceCollectId(afcId); afInterfaceCollectSub.setAfInterfaceCollectId(afcId);
afInterfaceCollectSub.setCollectsysCode(collectList.getCollectsys_code()); afInterfaceCollectSub.setCollectsysCode(collectList.getCollectsys_code());
@ -222,21 +225,21 @@ public class TBasicWebService implements ITBasicWebService {
list.add(afInterfaceCollectSub); list.add(afInterfaceCollectSub);
} }
int i1 = afInterfaceCollectMapper.addAfInterfaceCollectSub(list); int i1 = afInterfaceCollectMapper.addAfInterfaceCollectSub(list);
if (i1<0) { if (i1 < 0) {
log.info("省中医病案采集-子任务失败！"); log.info("省中医病案采集-子任务失败！");
} }
for (CollectList collectList : collectLists) { for (CollectList collectList : collectLists) {
//调用http发送请求 //调用http发送请求
this.sendHttp(collectList,tBasic.getJzh()); this.sendHttp(collectList, tBasic.getJzh());
} }
} }
} }
private String sendHttp(CollectList collectList,String jzh) throws URISyntaxException { private String sendHttp(CollectList collectList, String jzh) throws URISyntaxException {
Map<String, String > params= new HashMap<>(); Map<String, String> params = new HashMap<>();
params.put("empId",jzh); params.put("empId", jzh);
params.put("collectSubId",String.valueOf(collectList.getId())); params.put("collectSubId", String.valueOf(collectList.getId()));
return HttpUtils.get(collectList.getRequestUrl(),params); return HttpUtils.get(collectList.getRequestUrl(), params);
} }

Write Preview
Loading…
Cancel
Save