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减员数据
