WTOAAM/dataContract/algorithmContract/confBusiness.py

import pandas as pd
from utils.jsonUtil import JsonUtil

# 全局变量
charset_unify = 'utf-8'
CSVSuffix = '.csv'

Field_NameOfTurbine = "turbine_name"
Field_GeneratorTorque = "generator_torque"
Field_GeneratorSpeed = "generator_speed"
Field_RotorSpeed = "rotor_speed"
Field_WindSpeed = "wind_speed"
Field_AngleIncluded = "angle_included"
Field_YearMonth = "year-month"
Field_YearMonthDay = "year-month-day"
Field_PowerFloor= "power_floor"
Field_Cp = "cp"
Field_CpMedian = "cp_median"
Field_TSR = "tsr"
Field_TSRMedian = "tsr_median"
Field_YawError="yaw_error"
Field_LableFlag="lab"


class GraphSet:
    def __init__(self):
        self.multipl = None
        self.step = None
        self.min = None
        self.max = None


class ConfBusiness:
    def __init__(self):
        self.farm_name = None
        self.rated_power = None
        self.rated_WindSpeed = None
        self.rotor_diameter = None
        self.density_air = None
        self.rotational_Speed_Ratio = None

        self.type_name = None

        self.time_period = None            # 时间间隔,单位是秒

        self.output_name = None
        self.output_prefix = None

        self.turbineInfoFilePathCSV = None  # 风电机组信息
        self.turbineGuaranteedPowerCurveFilePathCSV = None  # 合同担保功率曲线

        self.input_path = None
        self.skip_row_number = None  # 跳过的行数
        self.csvFileNameSplitStringForTurbine = None  # 自文件名中获取机组号的分隔符
        self.index_turbine = None  # 自文件名中获取机组号的索引
        self.filter = None

        self.output_path = None

        self.start_time_str = None
        self.end_time_str = None

        # 将字符串转换为 pd.Timestamp 类型
        self.start_time = None
        self.end_time = None
        self.excludingMonths = None  # 排除指定的月份数据 格式%Y-%m

        self.field_turbine_time = None    # 字段名 时间
        self.field_turbine_name = None    # 字段名 机组名

        self.field_wind_speed = None      # 字段名 风速
        self.field_power = None           # 字段名 有功功率
        self.field_pitch_angle1 = None    # 字段名 桨距角1
        self.field_pitch_angle2 = None    # 字段名 桨距角2
        self.field_pitch_angle3 = None    # 字段名 桨距角3
        self.field_turbine_state = None   # 字段名 风机状态
        self.field_gen_speed = None       # 字段名 发电机转速
        self.value_gen_speed_multiple = None  # 值 发电机转速放大倍数
        self.value_gen_speed_step = None            # 值 发电机转速轴系间隔
        self.value_gen_speed_min = None       # 值 发电机转速最小
        self.value_gen_speed_max = None       # 值 发电机转速最大
        self.field_rotor_speed = None     # 字段名 叶轮转速
        self.field_torque = None          # 字段名 转矩
        self.field_wind_dir = None        # 字段名 风向
        self.field_angle_included = None
        self.field_nacelle_pos = None     # 字段名 机舱温度
        self.field_env_temp = None        # 字段名 环境温度
        self.field_nacelle_temp = None    # 字段名 机舱温度
        self.field_temperature_large_components = None  # 字段名列表  大部件温度传感器
        self.temperature_Generator = None
        self.graphSets = None
        self.field_activePowerSet = None
        self.field_activePowerAvailable = None
        self.rated_cut_in_windspeed = None  #额定切入风速
        self.rated_cut_out_windspeed = None #额定切出风速

    def loadConfig(self, jsonFilePath, charset=charset_unify):
        """
        配置初始化
        """
        # # 使用global声明，表示我们要修改的是全局变量config_data
        # global farm_name

        # 将配置数据存储在变量中
        configData = JsonUtil.read_json(jsonFilePath)

        self.farm_name = configData['name_PowerFarm']
        self.rated_power = configData['rated_Power_Turbine_Unit_kW']
        self.rated_WindSpeed = configData["rated_WindSpeed"]
        self.rated_cut_in_windspeed = configData["rated_cut_in_windspeed"]  #额定切入风速
        self.rated_cut_out_windspeed = configData["rated_cut_out_windspeed"]#额定切出风速

        self.rotor_diameter = configData['rotor_diameter']
        self.rotational_Speed_Ratio = configData['rotational_Speed_Ratio']
        self.density_air = configData['density_air']

        self.type_name = configData['name_Type_For_Analysis']
        # 时间间隔,单位是秒
        self.time_period = configData['time_Period_Unit_Second']

        self.output_name = configData['name_Output']
        self.output_prefix = configData['outputFileDirectory']

        self.turbineInfoFilePathCSV = configData["turbineInfoFilePathCSV"]
        self.turbineGuaranteedPowerCurveFilePathCSV = configData[
            "turbineGuaranteedPowerCurveFilePathCSV"]
        self.input_path = configData['inputFileDirectoryByCSV']
        self.csvFileNameSplitStringForTurbine = configData["csvFileNameSplitStringForTurbine"]
        self.index_turbine = configData["index_turbine"]
        self.skip_row_number = configData['skip_row_number']
        self.filter = configData['filter']

        self.output_path = self.output_prefix + \
            r"/{}".format(self.farm_name)

        # start_time_str = '{} 00:00:00'.format(configData['date_Begin'])
        # end_time_str = '{} 23:59:59'.format(configData['date_End'])
        self.start_time_str = configData['date_Begin']
        self.end_time_str = configData['date_End']

        # 将字符串转换为 pd.Timestamp 类型
        self.start_time = pd.to_datetime(
            self.start_time_str, format='%Y-%m-%d %H:%M:%S')
        self.end_time = pd.to_datetime(
            self.end_time_str, format='%Y-%m-%d %H:%M:%S')
        self.excludingMonths = configData['excludingMonths']

        self.field_turbine_time = configData['turbine_Time']
        self.field_turbine_name = configData['turbine_Name']

        self.field_wind_speed = configData['speed_Wind']
        self.field_power = configData['power_Active']
        self.field_pitch_angle1 = configData['pitch_Angle1']
        self.field_pitch_angle2 = configData['pitch_Angle2']
        self.field_pitch_angle3 = configData['pitch_Angle3']
        self.field_turbine_state = configData['state_Turbine']
        self.field_gen_speed = configData['speed_Generator']
        # self.value_gen_speed_multiple = configData['speed_Generator_Multiple']
        # self.value_gen_speed_step = configData['speed_Generator_Step']
        # self.value_gen_speed_min = configData['speed_Generato_min']
        # self.value_gen_speed_max = configData['speed_Generato_max']
        self.field_rotor_speed = configData['speed_Rotor']
        self.field_torque = configData['torque']
        self.field_wind_dir = configData['direction_Wind']
        self.field_angle_included = configData['angle_included']
        self.field_nacelle_pos = configData['nacelle_Pos']
        self.field_env_temp = configData['temperature_Env']
        self.field_nacelle_temp = configData['temperature_Nacelle']
        self.field_temperature_large_components = configData['temperature_large_components']
        self.temperature_Generator = configData["temperature_Generator"]
        self.graphSets = configData["graphSets"]
        self.field_Cabin_Vibrate_X = configData["Cabin_Vibrate_X"]
        self.field_Cabin_Vibrate_Y = configData["Cabin_Vibrate_Y"]
        self.field_activePowerSet = configData["activePowerSet"]
        self.field_activePowerAvailable = configData["activePowerAvailable"]

        return self

    # def add_W_if_starts_with_digit(self,s):
    #     if s and s[0].isdigit():
    #         return 'W' + s
    #     return s

    # 定义一个函数，用于检查字符串首字母是否为数字，并在是的情况下添加'W'
    def add_W_if_starts_with_digit(self, s):
        if isinstance(s, str) and s[0].isdigit():
            return 'W' + s
        return s