| | |
| | | package com.ruoyi.doublePrevention.scheduls; |
| | | |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.ruoyi.common.utils.StringUtils; |
| | | import com.ruoyi.doublePrevention.entity.*; |
| | | import com.ruoyi.doublePrevention.entity.CJReport.*; |
| | |
| | | if (recordReportConfig.getReportState().equals(SyncEnum.REPORT_ON.getCode())){ |
| | | |
| | | //logger.info("【##】5.检索排查任务记录数据..."); |
| | | System.out.println("【##】5.检索排查任务记录数据..."); |
| | | log.info("【##】5.检索排查任务记录数据..."); |
| | | |
| | | //查询所有 选择上报的数据 && (reportTime == null 或者 reportTime < updateReportDataTime) |
| | | List<PreventRiskDangerCheckLog> tasks = preventRiskDangerCheckLogService.listReportTask(); |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | //封装上报昌吉州的任务数据 |
| | |
| | | taskIds.add(task.getId()); |
| | | tag ++; |
| | | } |
| | | System.out.println("【##】5.数据封装完成..."); |
| | | log.info("【##】5.数据封装完成..."); |
| | | |
| | | } |
| | | }else { |
| | |
| | | |
| | | if (CJRecordFromTaskLists.size() > 0){ |
| | | log.info("【双重预防】排查任务记录CJ:数据处理..."); |
| | | log.info("【双重预防】排查任务记录CJ:数据处理开始taskIds..." + JSONObject.toJSONString(taskIds)); |
| | | |
| | | |
| | | //设置原始数据状态 |
| | | int taskUpdateResult = preventRiskDangerCheckLogService.updateTaskReportStatusByList(taskIds); |
| | | if (taskUpdateResult < taskIds.size()){ |
| | | log.error("【双重预防】排查任务记录CJ:数据处理开始taskIds...排查任务记录原始数据更新失败, 取消操作"); |
| | | throw new AusinessException(E.ADD_FAIL.getCode(), "排查任务记录原始数据更新失败, 取消操作"); |
| | | } |
| | | |
| | | log.info("【双重预防】排查任务记录CJ:数据处理开始CJRecordFromTaskLists..." + JSONObject.toJSONString(CJRecordFromTaskLists)); |
| | | int result = CJTaskRecordService.insertRecordList(CJRecordFromTaskLists); |
| | | if (result < CJRecordFromTaskLists.size()){ |
| | | log.error("【双重预防】排查任务记录CJ:数据处理开始taskIds...排查任务记录插入失败, 取消操作"); |
| | | throw new AusinessException(E.ADD_FAIL.getCode(), "排查任务记录插入失败, 取消操作"); |
| | | } |
| | | |
| | | |
| | | } |
| | | step = 6; |
| | | }else { |
| | |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | // /** |
| | | // * 7、检索检修记录数据 |
| | | // * */ |
| | |
| | | // logger.info("检修记录数据上报已关闭"); |
| | | // } |
| | | // |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | // TODO 目前应急厅没有风险点概念,此处暂时不写。目前看,风险点概念,类似管控措施,对用某个具体的风险位置 |