China代码结构

FSG 天津表模块

CIIC 模块功能:整合CIIC

函数返回值1.处理结果的提示信息

process_reduction_sheet[FSG减员函数]

FSG 增员|减员|统计 类

参数[输入]:1.input_file_path  原始数据文件路径2.sheet_names 指定增员表

参数[输入]:1. input_file  原始数据文件路径2.vendor_file_path 供应商表文件     3.  sheet_names=['增员'] 工作表名称参数[输出]1. output_file 输出文件路径2. log_path日志文件存储路径前缀3. b ket_nameS3桶名称

FSG 模块功能:整合FSG

函数返回值1.result_df  FSG增员数据

函数返回值1.DataFrame对象 筛选后的数据

CIIC 增员表模块

参数[输入]:1.self. input_file  原始数据文件路径

主函数传入路径按照日期命名

FSG 珠海表模块

参数[输入]:1. input_file  原始数据文件路径2.vendor_file_path 供应商表文件     3.  sheet_names=['减员'] 工作表名称参数[输出]1. output_file 输出文件路径

初始化类参数[输入]:1. input_file  原始数据文件路径2.vendor_file_path 供应商表文件初始化类参数[输出]1. output_file 输出文件路径

参数[输入]:1.input_file_s3  原始数据文件路径2.vendor_file_s3 供应商表文件    参数[输出]      1. output_file_s3: 整合结果文件输出路径

# ======== 公共参数 ========    bucket_name = \"payroll-china-bucket\"  # 桶名，方便后期修改    today_str = datetime.now().strftime(\"%Y%m%d\")  # 当前日期，格式：YYYYMMDD    # ======== FSG 参数 ========    fsg_input_file_s3 = event.get(\"fsg_input_file_s3\")  # 由事件指定    fsg_output_file_s3 = f\"s3://{bucket_name}/10.China Retail/2.output/prod_data_{today_str}/FSG.xlsx\"    fsg_vendor_file_s3 = f\"s3://{bucket_name}/10.China Retail/1.input/Vendor/供应商表.xlsx\"    # ======== CIIC 参数 ========    ciic_input_file_s3 = event.get(\"ciic_input_file_s3\")  # 由事件指定    ciic_vendor_file_s3 = f\"s3://{bucket_name}/10.China Retail/1.input/Vendor/供应商表.xlsx\"    ciic_output_file_s3 = f\"s3://{bucket_name}/10.China Retail/2.output/prod_data_{today_str}/CIIC.xlsx\"    ciic_log_path = f\"10.China+Retail/3.log/log_{today_str}\"  # 注意这里是 key，不带 s3://

参数[输入]:1.self. input_file  原始数据文件路径

process_addition_sheet[FSG增员函数]

参数[输入]:1.input_file_s3  原始数据文件路径2.vendor_file_s3 供应商表文件    参数[输出]      1. output_file_s3: 整合结果文件输出路径2. log_path日志文件存储路径前缀3. b ket_nameS3桶名称

主函数 模块功能:整合|调用

CIIC 减员表模块

函数返回值1.result_df  FSG减员数据

函数返回值1.df_final CIIC 增员数据

FSG 北京表模块

函数返回值1.result_df  CIIC减员数据