调控接口

获取预测类型(目前代码中为热力站)的当前负荷预测数据、一小时后的负荷预测数据，并对以上的数据进行排序【Substation_Forecast_Realtime】

获取两个热源heatplant、heatboiler的负荷值，并相加。以管网pid为索引单位，获取同一管网下两个热源之和的负荷量，写入heatsource_info中【Heatplant_C_History、Heatboilerroom_C_History】

将getcurrentsubstationload（当前负载数值）、getprimcurrent（一次侧温压流）、current_second_*（二次侧温压流）结果拼接起来，并对部分字段进行重名命，然后将这个dataframe的这些结果转成json的格式

pipenet_heatplant_info

结束

根据从substation_partition获得到的自控分区码，在substation_c_history中查找二次侧的温压流【manage.substation_partition(这张表在类初始化的时候使用过了)、substation_c_history】

在热网heat_network中获取pipenet和substation的关系，得到附属pid，同时还需要去除掉公建站。而在去除公建站时，先在热组对象中获取substation列表，然后和manage.substation中的非公建站取交集【manage.heat_network、manage.heat_group_obj、manage.substation】

getcurrentheatplantload

pipenet_heatboilerroom_info

在热网heat_network中获取pipenet和heatboilerroom的关系，得到附属pid，同时这些heatboilerroom的pid还需要对应的是投运状态的pipenet【manage.heat_network、manage.heat_group_obj、manage.heatboilerroom】

从pipenet_forecast_realtime表中获取“修正后的负荷值”字段 (f_009qc)的列表，写入heatsource_info的“require_heatplantload”字段中【pipenet_forecast_realtime（耗负荷预测的结果写入表）】

从配置项中获取手动配置进去的管网pid，用于判断这个管网pid是不是在heatplant和heatboilerroom里面【sys.sys_config】

将heatsource_info按照一行一行的记录形式，以json的格式进行输出

run()

getcurrentsubstationload

判断是不是公建站，判断开关时间，只有pid不是公建站且datetime在开关时间内的记录才可以被写入【Substation_Forecast_Realtime、manage.substation、sys.sys_config】

getseccurrent

开始

getsubstationpart()

从Substation_C_History表中获取一次侧的温压流 【Substation_C_History】

判断配置的pid是否在heatplant、heatboilerroom

在热网heat_network中获取pipenet和heatplant的关系，得到附属pid，同时这些heatplant的pid还需要对应的是投运状态的pipenet【manage.heat_network、manage.heat_group_obj、manage.heatplant】

substation_pidlist

run().mainquery()

主站点写入

run().querysubstationforeload()

substation_data

run().save_db()

分区站点写入

从substation_forecast_realtime表中获取负荷预测数值列表 (f_009qc：修正后的负荷预测值)【substation_forecast_realtime】

满足条件的二次侧数据，按照当前和一个小时后的两个dataframe完整数据及修整值的写入【substation_forecast_minute、】

getforedata_substation

interface()两个json传入这个算法内核进行计算

init_affiliated_pid()

满足条件的一次侧数据，按照当前和一个小时后的两个dataframe完整数据及修整值的写入【substation_forecast_minute、】

getprimcurrent

getsourceload_fore

获取自控系统分区码，part_info，用于在二次侧获取温压流时【manage.substation_partition】

ifwritein_result()