| | |
|---|
| | | */ |
|---|
| | | private void initPushDataTaks(int type){ |
|---|
| | | initSysadmin(); |
|---|
| | | |
|---|
| | | List<DockingSystemConfig> dockingSystemConfigList = dockingSystemConfigService.list( |
|---|
| | | Wrappers.<DockingSystemConfig>query().lambda().eq(DockingSystemConfig::getUsedFlag,"true") |
|---|
| | | .eq(DockingSystemConfig::getPushType,type==2?"2":"1").eq(DockingSystemConfig::getDataFlowType, SysIntegrationDataFlowTypeEnum.PUSH.getValue()));//2是代表分类推送，1是代表数据推送 |
|---|
| | |
|---|
| | | * 发送编码主数据 |
|---|
| | | */ |
|---|
| | | private void sendpushDataForService (List<DockingTask> dockingTaskS){ |
|---|
| | | |
|---|
| | | //每个task依次执行推送 |
|---|
| | | for (DockingTask dockingTask:dockingTaskS){ |
|---|
| | | //每个task一个事务，开启 |
|---|
| | |
|---|
| | | } |
|---|
| | | if(isGroupCodeFlage){ |
|---|
| | | code=data.getOrDefault("groupcode",""); |
|---|
| | | if(StringUtils.isBlank(code)) {//如果是集团码，没有领取到集团码则任务不结束等待集团码申请后再通过定时器调用集团码段 |
|---|
| | | dockingTask.setDescription("等待集团申请集团码"); |
|---|
| | | dockingTask.setSendFlag(MdmDuckingConstant.SEND_FLAG_FALSE); |
|---|
| | | dockingTask.setLastModifyTime(new Date()); |
|---|
| | | dockingTaskService.updateById(dockingTask); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | String[] classCodeLeves = dockingTask.getClassifyId().split(","); |
|---|
| | | NodeJosnDTO nodeJosnDTO = new NodeJosnDTO(); |
|---|
