|
@@ -367,6 +367,8 @@ public abstract class AbstractDataPullTaskCallBack {
|
|
|
continue;
|
|
continue;
|
|
|
}
|
|
}
|
|
|
Long time = parsedContent.getUploadTime();
|
|
Long time = parsedContent.getUploadTime();
|
|
|
|
|
+ //取5分钟整数时间点插入数据库 2023/7/11
|
|
|
|
|
+ time = time - time % 500;
|
|
|
if (!isDate(time.toString())) {
|
|
if (!isDate(time.toString())) {
|
|
|
continue;
|
|
continue;
|
|
|
}
|
|
}
|
|
@@ -392,7 +394,7 @@ public abstract class AbstractDataPullTaskCallBack {
|
|
|
onlineData = new OnlineData()
|
|
onlineData = new OnlineData()
|
|
|
.setTerminal_id(termianlId)
|
|
.setTerminal_id(termianlId)
|
|
|
.setInsert_time(parsedContent.getInsertTime())
|
|
.setInsert_time(parsedContent.getInsertTime())
|
|
|
- .setUpload_date(parsedContent.getUploadTime())
|
|
|
|
|
|
|
+ .setUpload_date(time)
|
|
|
.setCollectDatas(new Object[singleTableColsOrderMap.size()]);
|
|
.setCollectDatas(new Object[singleTableColsOrderMap.size()]);
|
|
|
onlineDatas.put(termianlIdkey, onlineData);
|
|
onlineDatas.put(termianlIdkey, onlineData);
|
|
|
}
|
|
}
|