| | |
| | | */ |
| | | @Autowired(required = false) |
| | | private DockingSystemMapper dockingSystemMapper; |
| | | /*** |
| | | * 任务生成服务 |
| | | */ |
| | | @Autowired( required = false) |
| | | private IDockingTaskService dockingTaskService; |
| | | // /*** |
| | | // * 任务生成服务 |
| | | // */ |
| | | // @Resource |
| | | // private IDockingTaskService dockingTaskService; |
| | | |
| | | |
| | | /** |
| | |
| | | log.info(" 增加系统集成的接口管理信息:"+dockingSystemConfigDTO.toString()); |
| | | VciBaseUtil.alertNotNull(dockingSystemConfigDTO, "需要添加的数据对象"); |
| | | checkColumnNotNull(dockingSystemConfigDTO); |
| | | String sourcesystemoid = dockingSystemConfigDTO.getSourceSystemOid(); |
| | | DockingSystem dockingSystem = dockingSystemMapper.selectById(sourcesystemoid); |
| | | dockingSystemConfigDTO.setSysBaseOid(sourcesystemoid); |
| | | String systemOid =""; |
| | | if(dockingSystemConfigDTO.getDataFlowType().equals(SysIntegrationDataFlowTypeEnum.ACCEPT.getValue())) { |
| | | systemOid = dockingSystemConfigDTO.getTargetSystemOid(); |
| | | }else{ |
| | | systemOid = dockingSystemConfigDTO.getSourceSystemOid(); |
| | | } |
| | | DockingSystem dockingSystem = dockingSystemMapper.selectById(systemOid); |
| | | dockingSystemConfigDTO.setSysBaseOid(systemOid); |
| | | dockingSystemConfigDTO.setSysBaseId(dockingSystem.getId()); |
| | | dockingSystemConfigDTO.setSysBaseName(dockingSystem.getName()); |
| | | dockingSystemConfigDTO.setUsedFlag("true");//设置默认启用状态 |
| | |
| | | dockingTaskDO_insert.add(dockingTaskDO); |
| | | }); |
| | | } |
| | | dockingTaskService.saveBatch(dockingTaskDO_insert); |
| | | // dockingTaskService.saveBatch(dockingTaskDO_insert); |
| | | }catch (Throwable e){ |
| | | msg="数据推送到定时任务失败!"; |
| | | log.error("数据推送到定时任务失败!"+e); |