| | |
| | | dockingTask.setClassifyName(classifyname);//数据所在分类名称 |
| | | dockingTask.setSendType(sendtype);//数据推送类型 |
| | | dockingTask.setDataOid(dataoid); |
| | | |
| | | dockingTask.setCreateTime(new Date()); |
| | | dockingTask.setLastModifyTime(new Date()); |
| | | dockingTask.setCreator("sysAdmin"); |
| | | dockingTask.setLastModifier("sysAdmin"); |
| | | //intinfo |
| | | dockingTask.setSysInfoOid(sysIntInfoVOi.getOid());//intinfo的oid |
| | | dockingTask.setSystemOid(sysIntInfoVOi.getSysBaseOid());//系统oid |
| | |
| | | sendString = "<?xml version=\"1.0\" encoding=\"UTF-8\" ?>\n" + xStream.toXML(nodeDataDTO); |
| | | } |
| | | //调用接口 |
| | | callInterface(sendString,dockingSystemConfig,dockingTask); |
| | | callInterface(sendString,dockingSystemConfig,dockingTask,"pushClassifyData"); |
| | | }catch (Throwable e){ |
| | | e.printStackTrace(); |
| | | }finally { |
| | |
| | | sendString = "<?xml version=\"1.0\" encoding=\"UTF-8\" ?>\n" + xStream.toXML(nodeDataDTO); |
| | | } |
| | | //调用接口 |
| | | callInterface(sendString,dockingSystemConfig, dockingTask); |
| | | callInterface(sendString,dockingSystemConfig, dockingTask,"pushData"); |
| | | }catch (Throwable e){ |
| | | e.printStackTrace(); |
| | | }finally { |
| | |
| | | * @param dockingTask |
| | | * @throws Throwable |
| | | */ |
| | | private void callInterface(String sendString , DockingSystemConfig dockingSystemConfig,DockingTask dockingTask) throws Throwable{ |
| | | private void callInterface(String sendString , DockingSystemConfig dockingSystemConfig,DockingTask dockingTask,String operation) throws Throwable{ |
| | | String paramString = ""; |
| | | |
| | | String backString = ""; |
| | |
| | | dockingLogeDO.setParamString(paramString); |
| | | dockingLogeDO.setReturnString(backString); |
| | | dockingLogeDO.setInterfaceStatus(isSend?"true":"false"); |
| | | dockingLogeDO.setType(DATA_LOGE_OUT); |
| | | dockingLogeDO.setType(operation); |
| | | dockingLogeDO.setMsg(msg); |
| | | log.error("集成推送数据,systemcode:"+dockingTask.getSystemCode()+",systemname:"+dockingTask.getSystemName()+",url:"+url+",param:"+paramString+",e:"+msg); |
| | | dockingLogeService.save(dockingLogeDO); |
| | |
| | | //全都接收成功的情况下,修改dockingtask sendflag为已发送 |
| | | if(isSend) { |
| | | dockingTask.setSendFlag(MdmDuckingConstant.SEND_FLAG_TRUE); |
| | | dockingTask.setLastModifyTime(new Date()); |
| | | dockingTaskService.updateById(dockingTask); |
| | | } |
| | | } |