1.推测工况修改

2.测点数据接口修改

app/utils/scheduler.py

@@ -241,6 +241,7 @@ def scheduled_get_max_nyid_by_point_id(start: int = 0,end: int = 0):
         # 2. 计算到期数据
         monitor = ConstructionMonitorUtils()
         daily_data = monitor.get_due_data(result,start=start,end=end)
+        print(daily_data)
         # time.sleep(10000)
         data = daily_data['data']
         error_data = daily_data['error_data']
@@ -256,7 +257,6 @@ def scheduled_get_max_nyid_by_point_id(start: int = 0,end: int = 0):
             print(max_num)
             # 提取冬休数据的point_id列表
             new_list = [int(w['point_id']) for w in winters]
-            print(new_list)
             # 获取更多历史记录
             nyid_list = daily_service.get_nyid_by_point_id(db, new_list, max_num)
             w_list = monitor.get_due_data(nyid_list,start=start,end=end)
@@ -298,7 +298,7 @@ def scheduled_get_max_nyid_by_point_id(start: int = 0,end: int = 0):
                 d['account_data'] = account_response.__dict__ if account_response else None
             else:
                 d['account_data'] = None
-        print(f"一共有{len(data)}条数据{data}")
+        print(f"一共有{len(data)}条数据")
         # 6. 构造DailyData数据并批量创建
         # daily_create_data1 = set()
         daily_create_data = []
@@ -320,6 +320,8 @@ def scheduled_get_max_nyid_by_point_id(start: int = 0,end: int = 0):
                 daily_create_data.append(tem)
         # 批量创建记录
         if daily_create_data:
+            # with open('data.json', 'w', encoding='utf-8') as f:
+                # json.dump(daily_create_data, f, ensure_ascii=False, indent=4)
             created_records = daily_service.batch_create_by_account_nyid(db, daily_create_data)
             logger.info(f"定时任务完成：成功创建{len(created_records)}条DailyData记录，共处理{len(data)}个point_id数据")
         else: