|
@@ -54,15 +54,15 @@ public class ThreadHistoryTask implements Runnable{
|
|
|
List<JSONObject> deviceRealtimeDataList = new ArrayList<>();
|
|
|
int pageSize = 1000;
|
|
|
for (Map<String, Object> map : deviceList) {
|
|
|
- int pageNo = 1;
|
|
|
- while (true) {
|
|
|
+// int pageNo = 1;
|
|
|
+// while (true) {
|
|
|
JSONObject devicerealtimeDataTotal = null;
|
|
|
try {
|
|
|
Map<String, String> paramRealtime = new HashMap<>();
|
|
|
paramRealtime.put("deviceType", deviceType);
|
|
|
paramRealtime.put("deviceCode", String.valueOf(map.get("deviceCode")));
|
|
|
- paramRealtime.put("pageNo", String.valueOf(pageNo));
|
|
|
- paramRealtime.put("pageSize", String.valueOf(pageSize));
|
|
|
+// paramRealtime.put("pageNo", String.valueOf(pageNo));
|
|
|
+// paramRealtime.put("pageSize", String.valueOf(pageSize));
|
|
|
paramRealtime.put("startTime", oneMonthStr);
|
|
|
paramRealtime.put("endTime", nowTimeStr);
|
|
|
Map<String, String> headers = new HashMap<>();
|
|
@@ -90,8 +90,8 @@ public class ThreadHistoryTask implements Runnable{
|
|
|
} catch (Exception ex) {
|
|
|
log.error("历史任务线程" + taskId + " " + String.valueOf(map.get("deviceCode")) + "查询异常:" + ex.getLocalizedMessage() + ";resJson:" + devicerealtimeDataTotal.toJSONString());
|
|
|
}
|
|
|
- pageNo++;
|
|
|
- }
|
|
|
+// pageNo++;
|
|
|
+// }
|
|
|
}
|
|
|
//TODO 开始插入数据库
|
|
|
//第三方对应的字段集
|