start real time simulation api

demo.py

@@ -1,4 +1,7 @@
 from tjnetwork import *
-read_inp("testDMA","testWDA.inp")
+read_inp("beibeizone","beibeizone.inp")
+#open_project('beibeizone')
+#generate_service_area("beibeizone",0.00001)
+
 print(list_project())
 

get_current_status.py

@@ -0,0 +1,54 @@
+from tjnetwork import *
+from get_realValue import *
+import datetime
+
+
+ids=['3489','3854','3853','2510','2514','4780','4854']
+cur_data=None
+
+def get_latest_cal_time()->datetime:
+    current_time=datetime.datetime.now()
+    return current_time
+
+
+def get_current_data()->bool:
+    global cur_data
+    cur_data=get_realValue(ids)
+    if cur_data ==None:
+        return False    
+    return True
+
+def get_current_total_Q(str_dt:str='')->float:
+    q_ids=['3489','3854','3853']
+    q_dn900=cur_data[q_ids[0]]
+    q_dn500=cur_data[q_ids[1]]
+    q_dn1000=cur_data[q_ids[2]]
+    total_q=q_dn1000+q_dn500+q_dn900
+    return total_q
+
+def get_h_pressure()->float:
+    head_id='2510'
+    h_pressure=cur_data[head_id]
+    return h_pressure
+
+def get_l_pressure()->float:
+    head_id='2514'
+    l_pressure=cur_data[head_id]
+    return l_pressure
+
+def get_h_tank_leve()->float:
+    h_tank_id='4780'
+    h_tank_level=cur_data[h_tank_id]
+    return h_tank_level
+
+def get_l_tank_leve()->float:
+    l_tank_id='4854'
+    l_tank_level=cur_data[l_tank_id]
+    return l_tank_level
+
+
+# test interface
+if __name__ == '__main__':
+    if get_current_data()==True:
+        tQ=get_current_total_Q()
+        print(f"the current tQ is {tQ}\n")

get_hist_data.py

@@ -0,0 +1,69 @@
+import requests
+from datetime import datetime
+import pytz
+
+
+def convert_timestamp_to_beijing_time(timestamp):
+    # 将毫秒级时间戳转换为秒级时间戳
+    timestamp_seconds = timestamp / 1000
+
+    # 将时间戳转换为datetime对象
+    utc_time = datetime.utcfromtimestamp(timestamp_seconds)
+
+    # 设定UTC时区
+    utc_timezone = pytz.timezone('UTC')
+
+    # 转换为北京时间
+    beijing_timezone = pytz.timezone('Asia/Shanghai')
+    beijing_time = utc_time.replace(tzinfo=utc_timezone).astimezone(beijing_timezone)
+
+    return beijing_time
+
+
+def get_hist_data(ids, begin_date, end_date):
+    # 数据接口的地址
+    url = 'http://183.64.62.100:9057/loong/api/curves/data'
+
+    # 设置 GET 请求的参数
+    params = {
+        'ids': ids,
+        'beginDate': begin_date,
+        'endDate': end_date
+    }
+
+    try:
+        # 发送 GET 请求获取数据
+        response = requests.get(url, params=params)
+
+        # 检查响应状态码，200 表示请求成功
+        if response.status_code == 200:
+            # 解析响应的 JSON 数据
+            data = response.json()
+            # 这里可以对获取到的数据进行进一步处理
+
+            # 打印 'mpointId' 和 'mpointName'
+            for item in data['items']:
+                print("mpointId:", item['mpointId'])
+                print("mpointName:", item['mpointName'])
+
+                # 打印 'dataDate' 和 'dataValue'
+                for item_data in item['data']:
+                    # print("dataDate:", item_data['dataDate'])
+                    # 将时间戳转换为北京时间
+                    beijing_time = convert_timestamp_to_beijing_time(item_data['dataDate'])
+                    print("dataDate (Beijing Time):", beijing_time.strftime('%Y-%m-%d %H:%M:%S'))
+                    print("dataValue:", item_data['dataValue'])
+                    print()  # 打印空行分隔不同条目
+        else:
+            # 如果请求不成功，打印错误信息
+            print("请求失败，状态码:", response.status_code)
+
+    except Exception as e:
+        # 捕获异常
+        print("发生异常:", e)
+
+
+# 使用示例
+get_hist_data(ids='2498,2500',
+         begin_date='2024-03-31T16:00:00Z',
+         end_date='2024-04-01T16:00:00Z')

get_realValue.py

@@ -17,7 +17,7 @@ def convert_to_beijing_time(utc_time_str):
     return beijing_time
 
 
-def get_realValue(ids):
+def get_realValue(ids)->dict[str,float]:
     # 数据接口的地址
     url = 'http://183.64.62.100:9057/loong/api/mpoints/realValue'
 
@@ -25,7 +25,7 @@ def get_realValue(ids):
     params = {
         'ids': ids
     }
-
+    lst_data={}
     try:
         # 发送GET请求获取数据
         response = requests.get(url, params=params)
@@ -34,25 +34,27 @@ def get_realValue(ids):
         if response.status_code == 200:
             # 解析响应的JSON数据
             data = response.json()
-
+           
             # 只打印'id'、'datadt'和'realValue'数据
             for realValue in data:
-                print("id:", realValue['id'])
-                print("mpointName:",realValue['mpointName'])
+                #print("id:", realValue['id'])
+                #print("mpointName:",realValue['mpointName'])
                 # print("datadt:", realValue['datadt'])
                 # 转换datadt字段为北京时间
-                beijing_time = convert_to_beijing_time(realValue['datadt'])
-                print("datadt (Beijing Time):", beijing_time.strftime('%Y-%m-%d %H:%M:%S'))
-                print("realValue:", realValue['realValue'])
-                print()  # 打印空行分隔不同条目
+                #beijing_time = convert_to_beijing_time(realValue['datadt'])
+                #print("datadt (Beijing Time):", beijing_time.strftime('%Y-%m-%d %H:%M:%S'))
+                #print("realValue:", realValue['realValue'])
+                #print()  # 打印空行分隔不同条目
+                r=float(realValue['value'])
+                lst_data[str(realValue['id'])]=r
         else:
             # 如果请求不成功，打印错误信息
             print("请求失败，状态码:", response.status_code)
-
+        return lst_data
     except Exception as e:
         # 捕获异常
         print("发生异常:", e)
 
 
 # 使用示例
-get_realValue(ids='2498,2500')
+#get_realValue(ids='2498,2500')