from data_initialize_standard.data_standardization import DataStandardization from water_temp_cal.water_temp_setpoint_new import SetPointStrategyOff, SetPointStrategyOnChillerOff,\ SetPointStrategyOnChillerOnAsynchronous, SetPointStrategyOnChillerOnSynchronous,\ JudgeSynchronizeAsynchronous, JudgeTempControlMode from data_initialize_standard.results import * from water_temp_cal.water_temp_set_switch import WaterTempSetVerify from temp_humid_cal.temp_humi_calculation import * from optimized_and_individal.control_period_step_adjust import ControlPeriodStepAdjust from optimized_and_individal.frequently_start_stop import JudgeFrequentlyStartStop # from logs_conf.logger import * from logs.logger import * import pandas as pd import time class PublicMethodClass(ControlPeriodStepAdjust): def __init__(self, dict_input): super(PublicMethodClass, self).__init__(dict_input) self.dict_chiller_outer = {} # self.modify_data = {} self.dict_results = {} self.data_temp_humi = pd.DataFrame() self.isAdjustWaterTemp = 0 self.isControl = False self.water_temp_set_new = None self.results_depict = None self.judge_syn_asy = '' # 同步算法或异步算法 self.excess_result = {} self.terminal_cal = False # def is_null_judge(self): # self.ds = DataStandardization(self.dict_input) # dict_back_useless = self.ds.dict_useless() # Num = self.ds.null_judge() # return dict_back_useless, Num def output_abnormal_situation(self, missing_fields, empty_paths, is_control=1): """ 异常情况的输出 :param missing_fields: 缺失字段列表 :param empty_paths: 空值对应字段列表 :param is_control: :return: """ # if Num > 0: # self.results_depict = '输入参数存在空值，无计算结果' # elif self.dict_code['controlMode'] == 0: # self.results_depict = '智控开关状态关闭，无计算结果' # elif is_control == 0: # self.results_depict = '距上次下发指令周期太短，无计算结果' # else: # self.results_depict = '输入参数错误，无计算结果' # logger.critical("============%s============" % self.results_depict) # self.dict_results = DictResultsNull(self.dict_chiller_outer, self.dict_chiller_inner, self.dict_code, # self.results_depict) if self.dict_input['controlConfigInfo']['controlMode'] == 0: self.results_depict = '智控开关状态关闭，无计算结果' elif missing_fields: self.results_depict = '输入数据存在缺失字段，无计算结果，缺失的字段：%s' % missing_fields elif empty_paths: self.results_depict = '输入数据存在空值，无计算结果，空值的字段：' + str(empty_paths) elif is_control == 0: self.results_depict = '距上次下发指令周期太短，无计算结果' else: self.results_depict = '智控开关输入参数错误，无计算结果' logger.critical("============%s============" % self.results_depict) self.dict_results = DictResultsAbnormal(self.dict_input, self.results_depict) return None def output_normal_situation(self, is_safety_issue): """ 正常计算下的输出 :param is_safety_issue: 是否存在安全运行问题 :return: """ # if self.isAdjustWaterTemp == 1: # if self.dict_code['isHardwareControl'] == 1: # if self.isAdjustWaterTemp == 1: # self.isControl = True # else: # self.results_depict = '计算正常,但不向硬件层发送指令' # self.is_hardware_control() # 控制模块 parameter = (is_safety_issue, self.isControl, self.results_depict, self.water_temp_set_new, self.dict_chiller_inner, self.dict_chiller_outer, self.dict_code, self.data_temp_humi, self.excess_result, self.terminal_cal) self.dict_results = DictResultsNormal(*parameter) def water_temp_set_verify(self, cal_mode): """ 水温验证与转换，验证是否超限，转换单位等 cal_mode: False表示停机状态下的水温计算；True表示运行状态下的水温计算 :return: """ wtst = WaterTempSetVerify(self.water_temp_set_new, self.dict_chiller_inner) if cal_mode: self.water_temp_set_new = wtst.modify_verify() else: self.water_temp_set_new = wtst.limit_verify() logger.critical('============经水温设定值校核后，最新水温设定值为 %s ℃============' % self.water_temp_set_new) return self.water_temp_set_new def is_adjust_judge(self): control_time_diff = self.control_time_diff_cal() # -----校验一下数据·········· if self.dict_chiller_inner['runMode'] == 0: if self.dict_chiller_inner['waterTempControlMode'] == 0: delta_temp = self.water_temp_set_new - self.dict_chiller_inner['chillerWaterTempSet'] else: delta_temp = self.water_temp_set_new - self.dict_chiller_inner['chillerWaterTempInSet'] if (abs(delta_temp) < self.dict_code['minControlStep'] and self.dict_code['controlMode'] == 1 and self.judge_syn_asy == 0 and self.dict_chiller_inner['runStatus'][-1] == 1) or delta_temp == 0: self.results_depict = '制冷工况：计算正常,水温调整幅度太小，不进行调整' else: if (delta_temp > 0 and control_time_diff['upControlTimeDiff'] > control_time_diff['upTempControlPeriod']) \ or (delta_temp < 0 and control_time_diff['downControlTimeDiff'] > control_time_diff['downTempControlPeriod']): self.isAdjustWaterTemp = 1 self.results_depict = '制冷工况：计算正常,水温满足调整条件' else: self.results_depict = '制冷工况：计算正常,不满足控制周期，不进行调整' elif self.dict_chiller_inner['runMode'] == 1: if self.dict_chiller_inner['waterTempControlMode'] == 0: delta_temp = self.water_temp_set_new - self.dict_chiller_inner['heatingWaterTempSet'] else: delta_temp = self.water_temp_set_new - self.dict_chiller_inner['heatingWaterTempInSet'] if (abs(delta_temp) < self.dict_code['minControlStep'] and self.dict_code['controlMode'] == 1 and self.judge_syn_asy == 0 and self.dict_chiller_inner['runStatus'][-1] == 1) or delta_temp == 0: self.results_depict = '制热工况：计算正常,水温调整幅度太小，不进行调整' else: if (delta_temp > 0 and control_time_diff['upControlTimeDiff'] > control_time_diff['upControlPeriod']) \ or (delta_temp < 0 and control_time_diff['downControlTimeDiff'] > control_time_diff['downControlPeriod']): self.isAdjustWaterTemp = 1 self.results_depict = '制热工况：计算正常,水温满足调整条件' else: self.results_depict = '制热工况：计算正常,不满足控制周期，不进行调整' else: self.results_depict = '冷机运行模式输入错误' if self.isAdjustWaterTemp == 1: if self.dict_code['isHardwareControl'] == 1: self.isControl = True else: self.results_depict += ',但不向硬件层发送指令' logger.critical('============ %s ============' % self.results_depict) # ---------------------------------------- # -----------------重构重构----------------- def water_temp_set_cal(self): # 运行冷机的水温计算主要步骤 # 监测点数据处理 # 监测点计算 # 监测点超标判断 # 同步或异步判断 # 进入同步或异步算法 # 设定值校验 # 监测点计算 logger.critical('============监测点计算开始============') thf = TempHumiFunction(self.data_temp_humi, self.dict_code, self.dict_chiller_outer) # 监测点实时数据 self.data_temp_humi = thf.temp_humi_cal() if self.data_temp_humi.shape[0]: # 监测点超标判断 judge = JudgeOutRange(self.data_temp_humi, self.dict_code) self.excess_result = judge.is_out_of_range() # # 判断控制模式是否唯一（供水控制还是回水控制） jtcm = JudgeTempControlMode(self.dict_chiller_inner) judge_sin_mul = jtcm.is_single_control_strategy() if judge_sin_mul == 0 and not self.excess_result['isOutRange'] == '': parameter = (self.dict_chiller_inner, self.data_temp_humi) # 判断同步算法还是异步算法 jsa = JudgeSynchronizeAsynchronous(self.dict_chiller_inner) self.judge_syn_asy = jsa.judge_synchronize_asynchronous() # 判断同步算法还是异步算法 if self.judge_syn_asy == 1: logger.critical('============冷站设备异步，当前冷机水温设定值为 %s ℃，冷站内所有开机冷机设定值为 %s ============' % (self.dict_chiller_inner['chillerWaterTempSet'], self.dict_chiller_inner['allChillerWaterTempSetOn'])) spsocoa = SetPointStrategyOnChillerOnAsynchronous(*parameter, self.excess_result) # 异步算法 water_temp_set_new = spsocoa.set_point_asynchronous() # 异步算法 logger.critical('============经过异步算法计算后，最新水温设定值为 %s ℃============' % water_temp_set_new) else: logger.critical('============冷站设备同步，当前冷机水温设定值为 %s ℃，冷站内所有开机冷机设定值为 %s ============' % (self.dict_chiller_inner['chillerWaterTempSet'], self.dict_chiller_inner['allChillerWaterTempSetOn'])) spsocos = SetPointStrategyOnChillerOnSynchronous(*parameter, self.excess_result) # 同步算法 water_temp_set_new, excess_result = spsocos.set_point_synchronous(self.dict_code['controlBasis']) # 同步算法 logger.critical('============经过同步算法计算后，最新水温设定值为 %s ℃============' % water_temp_set_new) # 水温设定值限值校验 water_temp_set_new = WaterTempSetVerify(water_temp_set_new, self.dict_chiller_inner).limit_verify() logger.critical('============当前水温设定值为 %s ℃，经限值校验后，最新水温设定值为 %s ℃============' % (self.dict_chiller_inner['chillerWaterTempSet'], water_temp_set_new)) else: water_temp_set_new = None if judge_sin_mul != 0: # 供水和回水共存的场景暂不考虑 logger.critical('============所有冷机水温控制方式不唯一，暂不适配此场景============') self.results_depict = '所有冷机水温控制方式不唯一，暂不适配此场景' else: logger.critical('============监测点超标判断出现异常，不进行水温调控============') self.results_depict = '监测点超标判断出现异常，不进行水温调控' else: water_temp_set_new = None self.results_depict = '所有末端开启时间太短，不进行水温调控' logger.critical('============所有末端开启时间太短，不进行水温调控============') return water_temp_set_new def water_temp_main_process(self): """ 水温计算的主函数 :return: """ parameter = (self.dict_chiller_inner, self.data_temp_humi) if self.dict_code['controlMode'] == 0: # 智控关闭 # 实际上不用做任何计算或动作，这里只是需要考虑 如果在节能评估期的初始工况日，确保冷机水温保持在设定值或以下即可(后续随产品迭代) # spso = SetPointStrategyOff(*parameter) # 智控关闭场景下，恢复模式下的水温 # self.water_temp_set_new = spso.self_control_strategy_off() # 智控关闭下的水温设定,这里是恢复模式下的设定值 logger.critical('============智控开关为关闭，不进行水温计算============') elif self.dict_code['controlMode'] == 1: # 智控开启 logger.critical('============智控开关为开启，开始进行水温计算============') if self.dict_chiller_inner['runStatus'][-1] == 0: # 当前冷机状态为关机 jfss = JudgeFrequentlyStartStop(self.dict_code, self.dict_chiller_inner) judge_freq_start_stop = jfss.is_freq_start_stop() # 判断是正常停机还是频繁启停 if judge_freq_start_stop == 0: # 非频繁启停，则是停机下水温设定 logger.critical('============设备处于停机状态，水温正常调控============') spsoco = SetPointStrategyOnChillerOff(*parameter) # 停机下水温设定值 self.water_temp_set_new = spsoco.water_temp_set_confirm() # 判断停机时长是否超过16小时 else: logger.critical('============设备处于频繁启停状态，水温正常调控============') self.water_temp_set_new = self.water_temp_set_cal() # 运行冷机的水温计算 self.terminal_cal = True elif self.dict_chiller_inner['runStatus'][-1] == 1: # 当前冷机状态为运行 logger.critical('============设备处于运行状态，水温正常调控============') self.water_temp_set_new = self.water_temp_set_cal() # 运行冷机的水温计算 self.terminal_cal = True else: self.water_temp_set_new = None self.results_depict = '冷机运行状态输入错误' logger.critical('============冷机运行状态输入错误============') else: self.water_temp_set_new = None self.results_depict = '算法智控状态输入错误' logger.critical('============算法智控状态输入错误============') return self.water_temp_set_new