fix: 修正i2同步500条没继续传问题

haikang
huangfeng 3 months ago
parent 79c31167ea
commit 073321327b

@ -22,4 +22,6 @@ public class Constants {
public static String DateTime = "datetime"; public static String DateTime = "datetime";
public static String Miss = "miss"; public static String Miss = "miss";
public static final Integer I2BatchSize = 500;
} }

@ -26,6 +26,8 @@ import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import static com.xydl.cac.entity.constants.Constants.I2BatchSize;
@Service @Service
@Slf4j @Slf4j
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
@ -263,7 +265,7 @@ public class DataServiceImpl implements DataService {
@Override @Override
public List<Map<String, Object>> getLatestData(String tableName, Integer devId, List<ModevTypePoint> points, Date start) throws Exception { public List<Map<String, Object>> getLatestData(String tableName, Integer devId, List<ModevTypePoint> points, Date start) throws Exception {
ConditionModel model = new ConditionModel(); ConditionModel model = new ConditionModel();
model.setPageSize(500); model.setPageSize(I2BatchSize);
model.setPageNum(1); model.setPageNum(1);
model.setStartTime(start); model.setStartTime(start);
model.setExcludeStartTime(true); model.setExcludeStartTime(true);

@ -22,6 +22,8 @@ import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import static com.xydl.cac.entity.constants.Constants.I2BatchSize;
@Service @Service
@Slf4j @Slf4j
public class I2syncTask { public class I2syncTask {
@ -135,7 +137,7 @@ public class I2syncTask {
log.info("I2syncTask.syncOneSensor 同步导出" + sensor.getName() + "(" + sensor.getSensorCode() + ") " log.info("I2syncTask.syncOneSensor 同步导出" + sensor.getName() + "(" + sensor.getSensorCode() + ") "
+ count + "条数据,最后数据时间" + DateUtil.format(record.getLastDTime())); + count + "条数据,最后数据时间" + DateUtil.format(record.getLastDTime()));
if (count >= 1000) { if (count >= I2BatchSize) {
dataList.clear(); dataList.clear();
this.syncOneSensor(sensor, config, fieldList, points); this.syncOneSensor(sensor, config, fieldList, points);
} }

Loading…
Cancel
Save