WaterServer/waterHeight.py

import requests
import json
import codecs
import os
from datetime import datetime, timedelta

qxData = []
swData = []
swHeightData = []
wagaData = []
def GetStartEndTime(deltaHour = 6):
    # 获取当前时间
    current_time = datetime.now()

    # 取整到最近的小时，即当前时间的小时数不变，分钟和秒数归零
    rounded_time = datetime(current_time.year, current_time.month, current_time.day, current_time.hour, 0, 0)

    # 往前推6个小时
    previous_time = rounded_time - timedelta(hours=deltaHour)

    # 输出两个时间
    return rounded_time.strftime('%Y-%m-%d %H:%M:%S'), previous_time.strftime('%Y-%m-%d %H:%M:%S')
    #return "2024-07-13 16:00:00", "2024-07-10 16:00:00"


def GetSixHourQXData():
    global qxData

    requestData = {}
    requestHead = {}
    requestData["eqaddvcd"] = "421083"
    requestData["pageSize"] = "80"
    requestHead["token"] = "6C60F37D40B48DECF9A3F2CC1A5A50142C4BE52F26D15B171153F20DB63960696A439E435DDCA9AF925F13338470FFBDDC98CEE65AFBC92C2EB4E44C0A757DB5"
    responese = requests.post("http://111.4.141.191:18081/shareddata/api/v1/baseinfo/stbprp/qx",data=requestData,headers=requestHead)

    qxDataDic = {}
    jsonData = json.loads(responese.content)
    index = 0
    for jsData in jsonData["data"]["list"]:
        #if (114.115926000756 > jsData["LGTD"] and jsData["LGTD"] > 113.410714576698 and 30.2676753765206 > jsData["LTTD"] and jsData["LTTD"] > 29.8114499954776):
        qxData.append(jsData)
        qxDataDic[jsData["STCD"]] = index
        index += 1

    requestData = {}
    sts = ''
    index = 0
    for qx in qxData:
        if index == 0:
            sts += qx["STCD"]
        else:
            sts += "," + qx["STCD"]
        index += 1
    
    etm,stm = GetStartEndTime(6)
    requestData["sts"] = sts
    requestData["etm"] = etm
    requestData["stm"] = stm
    #print(sts)
    dropDic = {}
    responese = requests.post("http://111.4.141.191:18081/shareddata/api/v1/monitdata/pptn/qx",data=requestData,headers=requestHead)
    jsonData = json.loads(responese.content)
    for jd in jsonData['data']:
        if jd["STCD"] not in dropDic.keys():
            dropDic[jd["STCD"]] = jd["DRP"]
        else:
            dropDic[jd["STCD"]] += jd["DRP"]
    
    for key in dropDic.keys():
        if key in qxDataDic:
            qxData[qxDataDic[key]]["dropSum6"] = dropDic[key]

    for sw in qxData:
        print(sw["STNM"] + " 经度:" + str(sw["LGTD"]) + " 维度:" + str(sw["LTTD"]) + " 六小时内降雨量:" + str(sw["dropSum6"]))
    
    
def GetSixHourSWData():
    global swData

    requestData = {}
    requestHead = {}
    requestData["eqaddvcd"] = "421083"
    requestData["pageSize"] = "80"
    requestHead["token"] = "6C60F37D40B48DECF9A3F2CC1A5A50142C4BE52F26D15B171153F20DB63960696A439E435DDCA9AF925F13338470FFBDDC98CEE65AFBC92C2EB4E44C0A757DB5"
    responese = requests.post("http://111.4.141.191:18081/shareddata/api/v1/baseinfo/stbprp/sw",data=requestData,headers=requestHead)

    swDataDic = {}
    jsonData = json.loads(responese.content)
    index = 0
    for jsData in jsonData["data"]["list"]:
        #if (114.115926000756 > jsData["LGTD"] and jsData["LGTD"] > 113.410714576698 and 30.2676753765206 > jsData["LTTD"] and jsData["LTTD"] > 29.8114499954776):
        swData.append(jsData)
        swDataDic[jsData["STCD"]] = index
        index += 1

    
    
        
    requestData = {}
    sts = ''
    index = 0
    for sw in swData:
        if index == 0:
            sts += sw["STCD"]
        else:
            sts += "," + sw["STCD"]
        index += 1
    print(sts)
    etm,stm = GetStartEndTime(6)
    requestData["sts"] = sts
    requestData["etm"] = etm
    requestData["stm"] = stm
    dropDic = {}
    wthDic = {}
    responese = requests.post("http://111.4.141.191:18081/shareddata/api/v1/monitdata/pptn/sw",data=requestData,headers=requestHead)
    jsonData = json.loads(responese.content)
    for jd in jsonData['data']:
        if jd["STCD"] not in dropDic.keys():
            dropDic[jd["STCD"]] = jd["DRP"]
        else:
            dropDic[jd["STCD"]] += jd["DRP"]

        wthDic[jd["STCD"]] = jd["WTH"]
    
    for key in dropDic.keys():
        if key in swDataDic:
            swData[swDataDic[key]]["dropSum6"] = dropDic[key]
            swData[swDataDic[key]]["wth"] = wthDic[key]

    # 使用列表推导过滤出包含 'dropSum6' 字段的字典
    filtered_swData = [item for item in swData if 'dropSum6' in item]

    swData = filtered_swData
    for sw in swData:
        print(sw["STNM"] + " 经度:" + str(sw["LGTD"]) + " 维度:" + str(sw["LTTD"]) + " 六小时内降雨量:" + str(sw["dropSum6"]) + " 天气:" + str(sw["wth"]))
    

def GetSWHegihtData():
    global swHeightData
    swDataDic = {}
    requestData = {}
    requestHead = {}
    requestHead["token"] = "6C60F37D40B48DECF9A3F2CC1A5A50142C4BE52F26D15B171153F20DB63960696A439E435DDCA9AF925F13338470FFBDDC98CEE65AFBC92C2EB4E44C0A757DB5"
    if not os.path.exists("importZa.json"):
        requestData["pageSize"] = "10000"
        responese = requests.post("http://111.4.141.191:18081/shareddata/api/v1/baseinfo/stbprp/sw",data=requestData,headers=requestHead)

        importZ = ["福田寺","黄丝南","下新河","子贝渊","沙螺"]
        
        jsonData = json.loads(responese.content)
        index = 0
        for jsData in jsonData["data"]["list"]:
            esixt = False
            for im in importZ:
                if im in jsData["STNM"]:
                    esixt = True
            if esixt:
                swHeightData.append(jsData)
                swDataDic[jsData["STCD"]] = index
                index += 1
        newJ = json.dumps(swHeightData, ensure_ascii=False)
        with codecs.open("importZa.json", "w+", encoding="utf-8") as nj:
            nj.write(newJ)
    else:
        index = 0
        with codecs.open("importZa.json","r", encoding="utf-8") as iz:
            izContent = json.loads(iz.read())
        for izc in izContent:
            swHeightData.append(izc)
            swDataDic[izc["STCD"]] = index
            index+=1
        # requestData["eqaddvcd"] = "421083"
        # requestData["pageSize"] = "80"
        # responese = requests.post("http://111.4.141.191:18081/shareddata/api/v1/baseinfo/stbprp/sw",data=requestData,headers=requestHead)
        # jsonData = json.loads(responese.content)
        # for jsData in jsonData["data"]["list"]:
        #     if jsData not in swHeightData:
        #         swHeightData.append(jsData)
        #         swDataDic[jsData["STCD"]] = index
        #         index += 1
    
    requestData = {}
    etm,stm = GetStartEndTime(0)
    requestData["pageSize"] = 300
    requestData["etm"] = etm
    requestData["stm"] = stm
    dwzDic = {}
    upzDic = {}
    tgtqDic = {}
    responese = requests.post("http://111.4.141.191:18081/shareddata/api/v1/monitdata/rw/st_was_r",data=requestData,headers=requestHead)
    jsonData = json.loads(responese.content)
    for jd in jsonData['data']["list"]:
        dwzDic[jd["STCD"]] = jd["DWZ"]
        upzDic[jd["STCD"]] = jd["UPZ"]
        tgtqDic[jd["STCD"]] = jd["TGTQ"]
    

    for key in dwzDic.keys():
        if key in swDataDic.keys():
            swHeightData[swDataDic[key]]["dwz"] = dwzDic[key]
            swHeightData[swDataDic[key]]["upz"] = upzDic[key]
            swHeightData[swDataDic[key]]["tgtq"] = tgtqDic[key]

    # 使用列表推导过滤出包含 'dropSum6' 字段的字典
    filtered_swData = [item for item in swHeightData if 'dwz' in item]
    

    sub_swData = [item for item in swHeightData if 'dwz' not in item]
    for ssw in sub_swData:
        ssw["dwz"] = None
        ssw["upz"] = None
        ssw["tgtq"] = None
        filtered_swData.append(ssw)

    swHeightData = filtered_swData

    for sw in swHeightData:
        #print(sw)
        print(sw["STNM"] + " 编码:" + str(sw["STCD"]) + " 经度:" + str(sw["LGTD"]) + " 维度:" + str(sw["LTTD"]) + " 下水位:" + str(sw["dwz"]) + " 下水位:" + str(sw["dwz"]) + " 上水位:" + str(sw["upz"]) + " 流量:" + str(sw["tgtq"]))



def GetWaGaData():
    global wagaData

    requestData = {}
    requestHead = {}
    requestData["pageSize"] = "320"
    requestHead["token"] = "6C60F37D40B48DECF9A3F2CC1A5A50142C4BE52F26D15B171153F20DB63960696A439E435DDCA9AF925F13338470FFBDDC98CEE65AFBC92C2EB4E44C0A757DB5"
    responese = requests.post("http://111.4.141.191:18081/shareddata/api/v1/baseinfo/bfx/fx_att_waga",data=requestData,headers=requestHead)

    wagaDataDic = {}
    jsonData = json.loads(responese.content)
    index = 0
    for jsData in jsonData["data"]["list"]:
        #if (114.115926000756 > jsData["LGTD"] and jsData["LGTD"] > 113.410714576698 and 30.2676753765206 > jsData["LTTD"] and jsData["LTTD"] > 29.8114499954776):
        wagaData.append(jsData)
        wagaDataDic[jsData["WAGA_CODE"]] = index
        index += 1
        
    
    requestData = {}
    etm,stm = GetStartEndTime(0)
    #requestData["etm"] = etm
    #requestData["stm"] = stm
    dwzDic = {}
    upzDic = {}
    tgtqDic = {}

    for waga in wagaData:
        #requestData["waga_code"] = waga["WAGA_CODE"]
        requestData["waga_name"] = waga["WAGA_NAME"]
        
        responese = requests.post("http://111.4.141.191:18081/shareddata/api/v1/monitdata/rw/waga_st_info",data=requestData,headers=requestHead)
        jsonData = json.loads(responese.content)
        if(len(jsonData["data"]["list"]) > 0):
            print(waga["WAGA_NAME"])
            print(waga["WAGA_CODE"])
            print(len(jsonData["data"]["list"]))
    


#GetSixHourQXData()
#GetSixHourSWData()
GetSWHegihtData()
#GetWaGaData()