实现第三方系统对接工作流

/**
 * 
 * 可通过 $page 获取或修改当前页面的 变量 状态 handler lifecycle 等信息
 * 可通过 app 获取或修改全局应用的 变量 状态 等信息
 * 具体可以console.info 在编辑器Console面板查看更多信息
 * 注意：该方法仅在所属的页面有效
 * 如果需要 async-await，请修改成 export default async function() {}
 **/

/**
 * @param {Object} event - 事件对象.
 * @param {string} event.name - 事件名.
 * @param {string} event.target - 事件的目标节点(触发该事件的节点).
 * @param {string} event.currentTarget - 当前处理该事件的节点。包括冒泡和捕获事件。.
 *
 * @param {Object} data
 * @param {any} data.target - 获取事件传参的数据
 **/
export default async function ({ event, data }) {

    const userInfo = await $app.auth.getUserInfo();
    console.log('$app.auth.getUserInfo:', userInfo);
    let zwname = userInfo.nickName;
    let currentDate = $app.utils.formatDate(Date.now(), "yyyy年mm月dd日 HH时MM分ss秒");

    let comment = '';
    if ($page.dataset.state.isBMLD) {
        if (!$page.dataset.state.bmld) {
            app.showToast({
                title: '审核意见不能为空!',
                icon: 'none',
                duration: 2000,      // 2秒
                mask: false,
            });
            return
        }
        comment = $page.dataset.state.bmld + '   ' + zwname + '  ' + currentDate;
    }
    if ($page.dataset.state.isFGLD) {
        if (!$page.dataset.state.ldyj) {
            app.showToast({
                title: '审核意见不能为空!',
                icon: 'none',
                duration: 2000,      // 2秒
                mask: false,
            });
            return
        }
        comment = $page.dataset.state.ldyj + '   ' + zwname + '  ' + currentDate;
    }

    $page.dataset.state.saveloading = true;
    $app.showLoading({
        title: "数据提交中"
    });
    let Approver = {
        "Type": 4,
        "UserId": $page.dataset.state.userid
    }
    // 调用连接器 调用流程OpenAPI CompleteTask
    let postparams = { "TaskId": $page.dataset.state.taskid, "ButtonAction": 2, "Comment": comment, "Approver": Approver };
    console.log(postparams, '查询入参');
    const result = await app.cloud.callConnector(
        {
            name: 'cxmxhgzlztsj_XXXXX',  //连接器标识
            methodName: 'method_XXXXX',  // 连接器方法标识
            params: postparams, // 方法入参
        }
    )

    setTimeout(function () {
        app.showToast({
            title: '提交成功',
            icon: 'success',
            duration: 1000,      // 2秒
        });
        $app.hideLoading();
        $page.dataset.state.saveloading = false;
        app.redirectTo({
            pageId: 'frzs_93k87uf_list',    // 页面 Id 
        });
    }, 5000);//5秒后返回列表
}



/*
* 可通过 $page 获取或修改当前页面的 变量 状态 handler lifecycle 等信息
* 可通过 app 获取或修改全局应用的 变量 状态 等信息
* 具体可以 console.info 在编辑器Console面板查看更多信息
* 如果需要 async-await，请在方法前 async
*/

export default {
    async onPageLoad(query) {
        console.log('---------> LifeCycle onPageLoad', query)
        //  forDateMethod()
        $app.showLoading({
            title: "加载中",
        });
        $page.dataset.state.isShow = false;
        // async function forDateMethod() {
        //console.log('---------> LifeCycle onPageLoad', query)

        // 获取当前用户信息
        const userInfo = await $app.auth.getUserInfo();
        //console.log('---------> LifeCycle onPageLoad', query)

        // 根据业务需要查询数据源记录列表 如 任务处理人（包含当前登录用户）、流程状态
        const wherelist = [{ key: "lcrwclr", rel: "search", val: userInfo.userId }, { key: "lczt", rel: "neq", val: "3" }];
        let res = await app.cloud.callDataSource({
            dataSourceName: 'frzs_XXXXX',
            methodName: 'wedaGetRecords',
            params: { "pageSize": 10000, "where": wherelist, "orderBy": "createdAt", "orderType": "desc" }, // 方法入参
        })

        let modeldata = res.records;
        // modeldata.map(async (jitem) => {
        // if(jitem.lcslid) {
        await Promise.all(
            modeldata.map(async (item) => {
                if (item.lcslid) {
                    // 调用连接器 GetFlowInstanceTasks 流程OpenAPI 根据流程实例Id查询审批任务列表
                    let postparams = { "InstanceId": item.lcslid };
                    let result = await app.cloud.callConnector(
                        {
                            name: 'cxlcslxq_XXXXX', //连接器标识
                            methodName: 'method_XXXX', // 连接器方法标识
                            params: postparams, // 方法入参
                        }
                    )

                    if (JSON.stringify(result.Response.Data) == "{}") {
                        return {}
                    } else {
                        if (result.Response.Data.Result.length == 0) {
                            return {}
                        } else {
                            let currentdata = result.Response.Data.Result;
                            //得到所有流程审批人 + 发起人
                            let cluserlist = currentdata.map(item => item.TaskAssignee).map(item => item.UserId).join(',');
                            let createuser = currentdata.map(item => item.FlowStartUser).map(item => item.UserId)[0];
                            let newuserlist = cluserlist + ',' + createuser;

                            // 获取当前登录用户的审批任务
                            let currentapprover = result.Response.Data.Result.filter(item => { if (item.TaskAssignee.UserId == userInfo.userId) { return item } });
                            console.log(currentapprover, 'currentapprover');
                            if (currentapprover.length > 0) {
                                if (currentapprover.length > 1) {
                                    // 当前登录用户下有多个审批任务，找到最新的任务
                                    let backdata = currentapprover;
                                    var sorted = backdata.slice().sort(function (a, b) {
                                        return new Date(a.StartTime) - new Date(b.StartTime);
                                    });
                                    let newtaskid = sorted.pop();
                                    await updataModel(newuserlist, item._id, newtaskid)
                                    return newtaskid
                                } else {
                                    // 当前登录用户下只有一个审批任务 直接返回
                                    await updataModel(newuserlist, item._id, currentapprover[0])
                                    return currentapprover[0]
                                }
                            } else {
                                // 当前登录用户下没有审批任务，但数据源记录处理人（发起人+审批人）中包含，即为发起
                                // 通用选项集中业务自定义流程状态 1:待办 2:已办 3:已完结 4:发起
                                let backdata = result.Response.Data.Result;
                                var sorted = backdata.slice().sort(function (a, b) {
                                    return new Date(a.StartTime) - new Date(b.StartTime);
                                });
                                let newtaskid = sorted.pop();
                                await updataModel(newuserlist, item._id, newtaskid, '4')
                                return newtaskid
                            }
                        }
                    }
                }
            })
        )
        $page.dataset.state.isShow = true;
        $app.hideLoading();
        //更新模型方法 将流程审批任务状态、跳转链接、处理人列表更新到数据源中
        async function updataModel(newuserlist, id, newtaskid, fq) {
            var updateparams = {
                _id: id,
                //基本信息---
                lczt: fq ? fq : (newtaskid.TaskStatus == 3 ? 2 : newtaskid.TaskStatus) + '',
                lcrwclr: newuserlist,
                lcurl: newtaskid.PageTransitionUrl
            }
            const resultupdate = await app.cloud.callDataSource(
                {
                    dataSourceName: 'frzs_XXXXX', //连接器标识
                    methodName: 'wedaUpdate', // 连接器方法标识
                    params: updateparams, // 方法入参
                }
            )
            console.log(resultupdate, '更新成功后的值')
        }
    },
    onPageShow() {
        console.log('---------> LifeCycle onPageShow')
    },
    onPageReady() {
        console.log('---------> LifeCycle onPageReady')
    },
    onPageHide() {
        console.log('---------> LifeCycle onPageHide')
    },
    onPageUnload() {
        console.log('---------> LifeCycle onPageUnload')
    },
}



// 步骤1：调用数据源 OpenAPI 查询记录
Map<String, String> processKey2RecordId // 构造记录流程标识和数据模型记录id的映射关系
//步骤2：获取到已经部署的流程列表 - 调用接口2 ListDeployedFlows 出参 list<DeployedProcessInfo>
for(DeployedProcessInfo processInfo  : list<DeployedProcessInfo>) {
    // 步骤3：获取该流程的实例列表 - 调用接口6 GetFlowInstances, 入参processInfo.ProcessKey
    list<FlowInstanceData> = query GetFlowInstances(processInfo.ProcessKey) 
    3. //发起数 
    int fqs = list<FlowInstanceData>.size();
    // 总办结时长
    long sumtime=0；
    4. //处理中数
    int clz =0 ;
    5. //已办结数
    int ybj=0;
    for(FlowInstanceData flowInstanceData:list<FlowInstanceData>){
        if (flowInstanceData.endtime == null) {
            clz ++ ;
        }
        if (flowInstanceData.endtime != null) {
            ybj ++ ;
            sumtime + = flowInstanceData.endtime -flowInstanceData.starttime
        }
    }
    6.// 办结率
    办结率 = 已办结数/发起数
    7. // 平均办理时长
    平均办理时长 = sumtime / 已办结数 

    8. processKey2RecordId 查询数据源记录id
    // 调用数据源OpenAPI 更新记录
}



// 步骤1：调用数据源 OpenAPI 查询记录
Map<String, String> userId2RecordId // 构造记录用户Id和数据源记录id的映射关系
//步骤2：分页查询用户列表，调用用户权限接口
    list<User> = describeUserByOrgId() 
for (User user : list<User>) {
    //步骤3：查询流程任务信息，调用接口7 GetFlowInstanceTasks 入参TaskAssignee UserId=user.id Type=4
    list<FlowInstanceTaskData> = GetFlowInstanceTasks(TaskAssignee)
    4.// 已处理数
    for(FlowInstanceTaskData : list<FlowInstanceTaskData>){
        if(FlowInstanceTaskData.taskStatus==2){
            已处理数 ++ 
            sumtime += FlowInstanceTaskData.endtime - FlowInstanceTaskData.starttime
        }
        if(FlowInstanceTaskData.taskStatus==1){
            待办数 ++ 
        }

    }
    5.// 参与审批次数 = 已处理数 + 待办数
    6.// 处理完成率
    处理完成率 = 已处理数/参与审批次数
    7.// 平均等待时长
    平均等待时长 = sumtime/已处理数

    8. userId2RecordId 查询数据源记录id
    // 调用数据源OpenAPI 更新记录
}




// 步骤1：调用数据源 OpenAPI 查询记录
Map<String, String> instanceId2RecordId // 构造记录流程实例 ID 和数据源记录 ID 的映射关系
//步骤2：查询流程实例列表，调用接口6 GetFlowInstances
list<FlowInstanceData> = GetFlowInstances(ProcessKey)
for(FlowInstanceData : list<FlowInstanceData>){
    // 2. 标题 ，基于实例 ID 查数据源 FlowInstanceData.instanceId
    // 3. 发起人 = FlowInstanceData.StartUsername
    // 4. 当前节点
    // 5. 当前节点审批人

    if (FlowInstanceData.endtime!=null) {
        当前节点 = 已办结
    } else {
        //步骤3：查询流程任务信息 - 接口7 GetFlowInstanceTasks
        list<FlowInstanceTaskData> = GetFlowInstanceTasks(FlowInstanceData.instanceId)
        for (FlowInstanceTaskData : list<FlowInstanceTaskData>) {
            if (FlowInstanceTaskData.TaskStatus=1) {
                当前节点  = FlowInstanceTaskData.elementName
                等待时间 = now - FlowInstanceTaskData.starttime
                当前节点id curElementId = FlowInstanceTaskData.elementId
                break;
            }
        }
        for (FlowInstanceTaskData : list<FlowInstanceTaskData>) {
            if (FlowInstanceTaskData.ElementId == curElementId) {
                当前节点审批人 curApproverIds.add(FlowInstanceTaskData.TaskAssignee.UserId)
                当前节点审批人状态 = FlowInstanceTaskData.EndTime == null ? "待审批" : "同意"
            }
        }
    }

    //步骤4：调用户权限接口查当前审批人部门和名称，接口2 describeWedaUser，参数 UserId
    for (UserId : curApproverIds) {
        User user = query describeWedaUser(UserId)
        6. 当前节点审批人.add(user.name)
        7. 所在部门.add(user.mainOrg)
    }

    8. instanceId2RecordId 查询数据源记录 ID
    // 调用数据源OpenAPI 更新记录
}