From 90b83e2ee39c9599d08a963ebf445911e5d6ff5c Mon Sep 17 00:00:00 2001
From: heheng <475597332@qq.com>
Date: 星期五, 20 六月 2025 13:49:35 +0800
Subject: [PATCH] 准东数据推送优化
---
src/main/java/com/ruoyi/doublePrevention/scheduls/SearchReportDateSchedule.java | 12 ++++++++++++
1 files changed, 12 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchReportDateSchedule.java b/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchReportDateSchedule.java
index 9df9c4f..0151c23 100644
--- a/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchReportDateSchedule.java
+++ b/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchReportDateSchedule.java
@@ -173,6 +173,8 @@
CJReportRiskAnaUnit.setDataSource((byte) 1);
CJReportRiskAnaUnit.setReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
CJReportRiskAnaUnit.setReportTime(null);
+ CJReportRiskAnaUnit.setZhunReportTime(null);
+ CJReportRiskAnaUnit.setZhunReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
CJReportRiskAnaUnit.setRiskUnitId(infoByRiskId.getRiskListId());//此处封装主表的id
//封装数据
CJUnitLists.add(CJReportRiskAnaUnit);
@@ -230,6 +232,8 @@
CJReportRiskEvent.setUpdateDate(riskEvent.getGmtModitify());
CJReportRiskEvent.setReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
CJReportRiskEvent.setReportTime(null);
+ CJReportRiskEvent.setZhunReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
+ CJReportRiskEvent.setZhunReportTime(null);
CJReportRiskEvent.setDataSource((byte) 1);
PreventRiskUnitUuid riskUnitUuidByUnitId = preventRiskUnitUuidService.getRiskUnitUuidByUnitId(riskEvent.getRiskUnitId());
CJReportRiskEvent.setRiskUnitId(riskUnitUuidByUnitId.getRiskUnitUuid());
@@ -297,6 +301,8 @@
CJReportMeasure.setUpdateDate(measure.getGmtModitify());
CJReportMeasure.setReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
CJReportMeasure.setReportTime(null);
+ CJReportMeasure.setZhunReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
+ CJReportMeasure.setZhunReportTime(null);
CJReportMeasure.setDataSource((byte) 1);
CJReportMeasure.setRiskEventId(measure.getRiskEventUuid());
CJReportMeasure.setRiskMeasureDesc(measure.getMeasureDesc());
@@ -406,6 +412,8 @@
}
CJTaskFromWork.setReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
CJTaskFromWork.setReportTime(null);
+ CJTaskFromWork.setZhunReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
+ CJTaskFromWork.setZhunReportTime(null);
CJTaskFromWork.setDataSource((byte) 1);
CJTaskFromWork.setRiskMeasureId(work.getMeasureUuid());
CJTaskFromWork.setWorkId(jobById.getJobId());
@@ -547,6 +555,8 @@
}
CJRecordFromTask.setReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
CJRecordFromTask.setReportTime(null);
+ CJRecordFromTask.setZhunReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
+ CJRecordFromTask.setZhunReportTime(null);
CJRecordFromTask.setDataSource((byte) 1);
List<PreventRiskDangerCheckAndMeasure> baseCheckPointAndMeasure = riskDangerCheckAndMeasureService.getByBaseCheckPointId(hiddenDangerCheckPoint.getCheckPointId());
//获取该条记录对应的管控措施id，
@@ -754,6 +764,8 @@
}
CJDangerInfo.setReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
CJDangerInfo.setReportTime(null);
+ CJDangerInfo.setZhunReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
+ CJDangerInfo.setZhunReportTime(null);
CJDangerInfo.setDataSource((byte) 1);
CJDangerInfo.setDangerName(hiddenDanger.getDangerName());
CJDangerInfo.setDangerLevel(hiddenDanger.getDangerLevel());
--
Gitblit v1.9.2