From c1138109f484ca940cfa4308593d99bfa9ddc548 Mon Sep 17 00:00:00 2001
From: huangfeng <huangfeng@xinyingpower.com>
Date: Tue, 27 Aug 2024 10:49:33 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0i2=E5=AF=BC=E5=87=BA?=
 =?UTF-8?q?=E7=B1=BB=E5=9E=8B=E6=97=B6=E8=87=AA=E5=8A=A8=E6=96=B0=E5=A2=9E?=
 =?UTF-8?q?=E5=AF=BC=E5=87=BA=E8=AE=B0=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../xydl/cac/service/impl/I2syncServiceImpl.java  | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/src/main/java/com/xydl/cac/service/impl/I2syncServiceImpl.java b/src/main/java/com/xydl/cac/service/impl/I2syncServiceImpl.java
index a32b568..4be0423 100644
--- a/src/main/java/com/xydl/cac/service/impl/I2syncServiceImpl.java
+++ b/src/main/java/com/xydl/cac/service/impl/I2syncServiceImpl.java
@@ -103,6 +103,21 @@ public class I2syncServiceImpl implements I2syncService {
         item.setId(null);
         item.setCreateTime(new Date());
         configRepository.save(item);
+
+        List<NSensor> list = sensorRepository.findByTypeId(item.getModevtypeId());
+        for (NSensor sensor : list) {
+            if (StringUtils.isNotBlank(sensor.getEquipmentId()) &&
+                    StringUtils.isNotBlank(sensor.getSensorCode()) &&
+                    StringUtils.isNotBlank(sensor.getPhase())) {
+                List<I2syncRecord> recordList = recordRepository.findByEqmid(sensor.getDevId());
+                if (CollectionUtils.isEmpty(recordList)) {
+                    I2syncRecord record = new I2syncRecord();
+                    record.setEqmid(sensor.getDevId());
+                    record.setModevtypeId(sensor.getTypeId());
+                    recordRepository.save(record);
+                }
+            }
+        }
     }
 
     @Override