from api import API
import pandas as pd
from tqdm import tqdm

class Main:  
    """_summary_
    新签节点自动化同意，需要修改输入，输入应包含实例ID
    """
    # 获取token
    api_instance = API()
    TOKEN = api_instance.generateToken()
    
    # 表单id
    FORMID = "FORM-L89662816B04LXH893M4K50Q7MIZ1SVQI08ALU2"  # 读取新签节点化服务待办
    FORMID_two = "FORM-EA866E715PF9YA7ECCAGSABX91Q72PVA3WRFL6"  # 宜搭员工-ID对应表  
    FORMID2= "FORM-PE866MD1MJMU0WGLYRFLYEN5YN9L1I55Z7ZUK22"# [流程]续约服务流程
    # 查看宜搭-ID对应表有多少页
    form_data_two = api_instance.read_processes(token=TOKEN, formUuid=FORMID_two, page=1, n=100)
    PAGES_two = form_data_two.get('totalCount')//100 + 1

    # 遍历宜搭-ID对应表获取所有员工与员工ID
    ALL_DATA_staff = []
    for i in range(1, PAGES_two+1):
        # form_data = read_processes_instances(token=TOKEN, formUuid=FORMID, createFromTimeGMT=CREATE_FROM, createToTimeGMT=CREATE_TO, page=i, n=100, searchField={'textField_l7if5ff9': '否'})
        form_data_two = api_instance.read_processes(token=TOKEN, formUuid=FORMID_two, page=i, n=100)
        for data in form_data_two.get('data'):
            ALL_DATA_staff.append(data)
            
    
    # 读取excel表格获取数据
    ceshi_data = pd.read_excel(r"C:\Users\hp_z66\OneDrive\Desktop\钉钉文件\2026-4回访已（客服）.xlsx",sheet_name='7天节点且联系上（自动同意）')
    print("已读取表格")
    
    # 执行自动化脚本
    for i in tqdm(range(1, len(ceshi_data))):
        try:
            # 获取流程单审批记录
            res_new = api_instance.get_approval_records(token=TOKEN, processInstanceId=ceshi_data.loc[i,'实例ID'])  # 实例ID手动导出添加

            records_new = res_new.get('result')

            # 获取审批节点的 taskId
            records_new = [item for item in records_new if item.get('type') == "TODO"]

            taskId_new = records_new[0].get('taskId')
            # print(records_new[0]['operatorName'])


            data_new = {}
            # 自动同意审批节点
            res = api_instance.aggree_approval(token=TOKEN, taskId=taskId_new, processInstanceId=ceshi_data.loc[i,'实例ID'], formData=data_new,res_new =api_instance.get_staffID(TOKEN,ALL_DATA_staff,records_new[0]['operatorName'])[0] ) # get_staffID(TOKEN,ALL_DATA_staff,records_new[0]['operatorName'])[0]
            print(ceshi_data.loc[i,'实例ID'],res.json())
            
        except IndexError as e:
            print(f"索引错误: {e}")
            pass
        except ValueError as e:
            print(f"值错误: {e}")
            pass
        except Exception as e:
            print(f"未知错误: {e}")
            pass