【轉】【金蝶K3Cloud】 在插件中調用工作流

在插件中可以調用ApprovalAssignmentServiceHelper.SubmitApprovalItems(）進行工作流審批。但SubmitApprovalItems(）需要一個AssignmentContext參數，而AssignmentContext屬性非常多，構造起來很麻煩。
因此我寫了兩個方法，將SubmitApprovalItems(）再次封裝，傳入幾個簡單參數，就能完成審批。

 

  /// <summary>
        /// 審批單據，actionName為空時，自動尋找第一個同意審批項；
        /// 有多個類型為通過的審批項時，可用actionName指定審批項，如actionName="審批通過"
        /// </summary>
        /// <param name="formId">單據FormId</param>
        /// <param name="pKValue">單據主鍵</param>
        /// <param name="receiverName">處理人</param>
        /// <param name="disposition">審批意見</param>
        /// <param name="isApprovalFlow">是否為審批流</param>
        public void ApproveBill(string formId, string pKValue, string receiverName, string disposition, bool isApprovalFlow = false, string actionName = null)
        {
            List<AssignResult> assignResults = GetApproveActions(formId, pKValue, receiverName);
            AssignResult approvalAssignResults = assignResults.FirstOrDefault(r => r.ApprovalType == AssignResultApprovalType.Forward);
            if (approvalAssignResults == null) throw new Exception("未找到審批項。");
            SubmitWorkflow(formId, pKValue, receiverName, approvalAssignResults.Id, disposition, isApprovalFlow);
        }

        /// <summary>
        /// 駁回單據，actionName為空時，自動尋找一個駁回審批項；
        /// 有多個類型為駁回的審批項時（如駁回、打回發起人），可用actionName指定審批項，如actionName="打回發起人"
        /// </summary>
        public void RejectBill(string formId, string pKValue, string receiverName, string disposition, bool isApprovalFlow = false, string actionName = null)
        {
            List<AssignResult> assignResults = GetApproveActions(formId, pKValue, receiverName);
            if (!string.IsNullOrEmpty(actionName))
                assignResults = assignResults.Where(r => r.Name.Any(p => p.Value == actionName)).ToList();
            else
                assignResults = assignResults.OrderBy(r => r.Name.Any(p => p.Value == "打回發起人")).ToList();
            AssignResult rejectAssignResults = assignResults.FirstOrDefault(r => r.ApprovalType == AssignResultApprovalType.Reject);
            if (rejectAssignResults == null) throw new Exception("未找到駁回審批項。");
            SubmitWorkflow(formId, pKValue, receiverName, rejectAssignResults.Id, disposition, isApprovalFlow);
        }

        private List<AssignResult> GetApproveActions(string formId, string pKValue, string receiverName)
        {
            DataSet ds = DBUtils.ExecuteDataSet(this.Context, @"select b.FASSIGNID,b.FAPPROVALASSIGNID
                                from t_wf_assign a 
                                join T_WF_APPROVALASSIGN b on a.fassignid=b.fassignid 
                                where b.Fobjecttypeid=@FormID 
                                and b.Fkeyvalue=@pKValue and a.FSTATUS=0 and a.FRECEIVERNAMES=@FRECEIVERNAMES",
                        new List<SqlParam>
                        {
                            new SqlParam("@FormID", DbType.String, formId),
                            new SqlParam("@pKValue", DbType.String, pKValue),
                            new SqlParam("@FRECEIVERNAMES", DbType.String, receiverName)
                        });
            DataRow row = ds.Tables[0].Rows.Cast<DataRow>().FirstOrDefault();
            if (row == null) return new List<AssignResult> { };

            string assignId = row["FASSIGNID"].ToString();
            string approvalAssignId = row["FAPPROVALASSIGNID"].ToString();
            string _approvalItemId = AssignmentServiceHelper.OpenApprovalItem(this.Context, this.Context.UserId, assignId, false);
            var _approvalItem = AssignmentServiceHelper.GetApprovalItemById(this.View.Context, _approvalItemId);
            return _approvalItem.Actions.ToList();
        }


        private void SubmitWorkflow(string formId, string pKValue, string receiverName, string actionResult, string disposition, bool isApprovalFlow)
        {
            DataSet ds = DBUtils.ExecuteDataSet(this.Context, @"select b.FASSIGNID,b.FAPPROVALASSIGNID,a.FACTINSTID
                                from t_wf_assign a 
                                join T_WF_APPROVALASSIGN b on a.fassignid=b.fassignid 
                                where b.Fobjecttypeid=@FormID 
                                and b.Fkeyvalue=@pKValue and a.FSTATUS=0 and a.FRECEIVERNAMES=@FRECEIVERNAMES",
                        new List<SqlParam>
                        {
                            new SqlParam("@FormID", DbType.String, formId),
                            new SqlParam("@pKValue", DbType.String, pKValue),
                            new SqlParam("@FRECEIVERNAMES", DbType.String, receiverName)
                        });
            DataRow row = ds.Tables[0].Rows.Cast<DataRow>().FirstOrDefault();
            if (row == null) throw new Exception("未找到待辦任務");

            string assignId = row["FASSIGNID"].ToString();
            string approvalAssignId = row["FAPPROVALASSIGNID"].ToString();
            string _approvalItemId = AssignmentServiceHelper.OpenApprovalItem(this.Context, this.Context.UserId, assignId, false);
            FormMetadata formMetadata = MetaDataServiceHelper.GetFormMetaData(this.Context, formId);
            DynamicObject ObjData = BusinessDataServiceHelper.LoadSingle(this.Context, pKValue, formMetadata.BusinessInfo.GetDynamicObjectType());
            BusinessInfo businessInfo = formMetadata.BusinessInfo;

            var _approvalItem = AssignmentServiceHelper.GetApprovalItemById(this.View.Context, _approvalItemId);
            if (_approvalItem == null) throw new Exception("待辦任務所在的流程實例不在運行中，不能進行處理！");
            _approvalItem.ObjData = ObjData;
            _approvalItem.ReceiverPostId = 0;
            _approvalItem.ActionResult = actionResult;
            _approvalItem.Disposition = disposition.ToString();
            AssignResult assignResult = _approvalItem.Actions != null ? _approvalItem.Actions.FirstOrDefault(i => i.Id == actionResult) : null;
            AssignResultApprovalType approvalType = assignResult != null ? assignResult.ApprovalType : AssignResultApprovalType.None;
            _approvalItem.ActionResultType = approvalType;
            _approvalItem.Status = ApprovalItemStatus.Completed;
            DateTime timeNow = TimeServiceHelper.GetSystemDateTime(this.Context);
            _approvalItem.CompletedTime = timeNow;

            ObjectActivityInstance _activityInstance = AssignmentServiceHelper.ConvertActivityModel(
                    this.Context, businessInfo, approvalAssignId, _approvalItem);

            var option = OperateOption.Create();

            if (isApprovalFlow)
            {
                ApprovalAssignmentContext assignCtx = new ApprovalAssignmentContext()
                {
                    ApprovalItems = new List<ApprovalItem>() { _approvalItem },
                    Info = businessInfo,
                    Option = option
                };
                assignCtx.NextActHandler = null;
                assignCtx.RejectReturn = false;
                assignCtx.ActivityInstance = _activityInstance;
                if (actionResult == AssignResultApprovalType.Reject.ToString())
                {
                    string actInstId = row["FACTINSTID"].ToString();
                    Kingdee.BOS.Workflow.App.Core.ProcInstService procInstService = new Kingdee.BOS.Workflow.App.Core.ProcInstService();
                    var rejectActivityIds = procInstService.GetBackActInstList(this.Context, actInstId, true).Select(r => r.ActivityId);
                    if (!rejectActivityIds.Any()) throw new Exception("無駁回節點");
                    assignCtx.Target = rejectActivityIds.FirstOrDefault();
                }
                ApprovalAssignmentServiceHelper.SubmitApprovalItem(Context, assignCtx);
            }
            else
            {
                ApprovalAssignmentContext assignCtx = new ApprovalAssignmentContext()
                {
                    ApprovalItems = new List<ApprovalItem>() { _approvalItem },
                    Info = businessInfo,
                    Option = option
                };
                assignCtx.NextActHandler = null;
                assignCtx.RejectReturn = false;
                assignCtx.ActivityInstance = _activityInstance;
                AssignmentServiceHelper.SubmitApprovalItem(Context, assignCtx);
            }
        }