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 list = sensorRepository.findByTypeId(item.getModevtypeId()); + for (NSensor sensor : list) { + if (StringUtils.isNotBlank(sensor.getEquipmentId()) && + StringUtils.isNotBlank(sensor.getSensorCode()) && + StringUtils.isNotBlank(sensor.getPhase())) { + List 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