import os

import pandas as pd


def add_minute_table(df):
    del df['历史采样表名']
    del df['历史采样域名']

    min_table_path = r'C:\Users\wzl\Desktop\中广核104测点\分钟级表-字段.csv'
    min_df = pd.read_csv(min_table_path, encoding='gbk', usecols=['遥测ID', '历史采样表名', '历史采样域名'])

    min_df['遥测ID'] = min_df['遥测ID'].apply(lambda x: x.replace('遥测定义表 ', '').replace('遥测值', '').strip())
    min_df.rename(columns={'遥测ID': '遥测名称'}, inplace=True)

    df = df.merge(min_df, on='遥测名称', how='left')
    return df


if __name__ == '__main__':
    read_file = r'C:\Users\wzl\Desktop\中广核104测点\0416部署需要\最终测点配置.xlsx'
    df = pd.read_excel(read_file)
    # df = add_minute_table(df)
    # df.to_excel('最终测点配置.xlsx', index=False)

    wind_names = df['场站'].unique()

    for wind_name in wind_names:
        now_df = df[df['场站'] == wind_name]
        port = now_df['端口'].unique()[0]
        os.makedirs(str(port), exist_ok=True)
        now_df.sort_values(by=['风机号', '测点'], inplace=True)
        now_df.to_csv(os.path.join(str(port), wind_name + '.csv'))