diff --git a/src/main/java/com/xydl/cac/task/I2syncTask.java b/src/main/java/com/xydl/cac/task/I2syncTask.java index 91e6769..1176a5a 100644 --- a/src/main/java/com/xydl/cac/task/I2syncTask.java +++ b/src/main/java/com/xydl/cac/task/I2syncTask.java @@ -75,8 +75,12 @@ public class I2syncTask { } List list = sensorRepository.findByTypeId(config.getModevtypeId()); for (NSensor sensor : list) { - sensor.setTableName(config.getTableName()); - this.syncOneSensor(sensor, config, fieldList, points); + if (StringUtils.isNotBlank(sensor.getEquipmentId()) && + StringUtils.isNotBlank(sensor.getSensorCode()) && + StringUtils.isNotBlank(sensor.getPhase())) { + sensor.setTableName(config.getTableName()); + this.syncOneSensor(sensor, config, fieldList, points); + } } }