|
|
@ -59,6 +59,7 @@ public class I2syncTask {
|
|
|
|
for (I2syncField field : fieldList) {
|
|
|
|
for (I2syncField field : fieldList) {
|
|
|
|
ModevTypePoint point = new ModevTypePoint();
|
|
|
|
ModevTypePoint point = new ModevTypePoint();
|
|
|
|
point.setField(field.getFieldName());
|
|
|
|
point.setField(field.getFieldName());
|
|
|
|
|
|
|
|
points.add(point);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<NSensor> list = sensorRepository.findByTypeId(config.getModevtypeId());
|
|
|
|
List<NSensor> list = sensorRepository.findByTypeId(config.getModevtypeId());
|
|
|
|
for (NSensor sensor : list) {
|
|
|
|
for (NSensor sensor : list) {
|
|
|
@ -84,6 +85,7 @@ public class I2syncTask {
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
int count = dataList.size();
|
|
|
|
// 格式转换
|
|
|
|
// 格式转换
|
|
|
|
Request request = dataTransformer.transform(sensor, record, fieldList, dataList);
|
|
|
|
Request request = dataTransformer.transform(sensor, record, fieldList, dataList);
|
|
|
|
|
|
|
|
|
|
|
@ -91,6 +93,15 @@ public class I2syncTask {
|
|
|
|
String xml = JSONUtil.object2Xml(request);
|
|
|
|
String xml = JSONUtil.object2Xml(request);
|
|
|
|
|
|
|
|
|
|
|
|
recordRepository.save(record);
|
|
|
|
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);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|