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