From d8c2a5ff7b6f02214083ab1203723d7fa5298450 Mon Sep 17 00:00:00 2001 From: huangfeng Date: Thu, 13 Jun 2024 10:35:03 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E7=AC=AC=E4=B8=80=E6=AC=A1=E5=90=8C?= =?UTF-8?q?=E6=AD=A5=E5=85=A8=E9=87=8F=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/xydl/cac/task/I2syncTask.java | 11 +++++++++++ 1 file changed, 11 insertions(+) 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); + } } }