| | |
|---|
| | | @Transactional
|
|---|
| | | // @Scheduled(cron = "0 0/1 * * * ? ") // 分钟
|
|---|
| | | // @Scheduled(cron = "0/30 * * * * ?") // 30秒
|
|---|
| | | @Scheduled(cron = "0 0/30 * * * ? ") // 分钟
|
|---|
| | | // @Scheduled(cron = "0 0/30 * * * ? ") // 分钟
|
|---|
| | | public void searchReportDate(){
|
|---|
| | |
|
|---|
| | | logger.info("【双重预防】定时检索需要上报数据...");
|
|---|
| | |
|---|
| | | CJReportRiskAnaUnit.setUpdateBy(updateUser.getUserName());
|
|---|
| | | CJReportRiskAnaUnit.setUpdateDate(infoByRiskId.getCreateTime());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | CJReportRiskAnaUnit.setDataSource((byte) 1);
|
|---|
| | | CJReportRiskAnaUnit.setReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
|
|---|
| | | CJReportRiskAnaUnit.setReportTime(null);
|
|---|
| | |
|---|
| | | CJReportMeasure.setRiskMeasureId(measure.getId());
|
|---|
| | | CJReportMeasure.setTroubleshootContent(measure.getCheckContent());
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | //封装数据
|
|---|
| | | CJMeasureLists.add(CJReportMeasure);
|
|---|
| | | //设置原始数据上报状态
|
|---|
| | |
|---|
| | | CJTaskFromWork.setTaskStartTime(jobById.getStartTime());
|
|---|
| | |
|
|---|
| | | CJTaskFromWork.setWorkDayType("0");
|
|---|
| | | CJTaskFromWork.setWorkStartTime("00:00:01");
|
|---|
| | | CJTaskFromWork.setWorkEndTime("23:59:59");
|
|---|
| | | CJTaskFromWork.setWorkType(measureById.getWorkType());
|
|---|
| | | if (ObjectUtils.isNotEmpty(measureById.getTaskNum())){
|
|---|
| | | CJTaskFromWork.setTaskNum(measureById.getTaskNum());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | List<PreventTaskType> typeByJobId = taskTypeService.getInfoByJobId(work.getJobId());
|
|---|
| | | int typeTag = 0;
|
|---|
| | | for (PreventTaskType taskType : typeByJobId) {
|
|---|
