diff --git a/src/main/java/com/xydl/cac/task/I2syncTask.java b/src/main/java/com/xydl/cac/task/I2syncTask.java index ef1cade..3d3d3ca 100644 --- a/src/main/java/com/xydl/cac/task/I2syncTask.java +++ b/src/main/java/com/xydl/cac/task/I2syncTask.java @@ -59,6 +59,7 @@ public class I2syncTask { for (I2syncField field : fieldList) { ModevTypePoint point = new ModevTypePoint(); point.setField(field.getFieldName()); + points.add(point); } List list = sensorRepository.findByTypeId(config.getModevtypeId()); for (NSensor sensor : list) { @@ -84,6 +85,7 @@ public class I2syncTask { return; } + int count = dataList.size(); // 格式转换 Request request = dataTransformer.transform(sensor, record, fieldList, dataList); @@ -91,6 +93,15 @@ public class I2syncTask { String xml = JSONUtil.object2Xml(request); recordRepository.save(record); + log.info("I2syncTask.syncOneSensor 同步导出" + sensor.getEquipmentId() + count + + "条数据,最后数据时间" + DateUtil.format(record.getLastDTime())); + + if (count >= 1000) { + dataList.clear(); + request = null; + xml = null; + this.syncOneSensor(sensor, fieldList, points); + } } }