【分享】在插件中调用工作流审批

在插件中可以调用ApprovalAssignmentServiceHelper.SubmitApprovalItems(）进行工作流审批。但SubmitApprovalItems(）需要一个AssignmentContext参数，而AssignmentContext属性非常多，构造起来很麻烦。
因此我写了两个方法，将SubmitApprovalItems(）再次封装，传入几个简单参数，就能完成审批。

1. using Kingdee.BOS.App.Data;
   

2. using Kingdee.BOS.Core.DynamicForm.PlugIn;
   

3. using Kingdee.BOS.Core.Metadata;
   

4. using Kingdee.BOS.Orm;
   

5. using Kingdee.BOS.Orm.DataEntity;
   

6. using Kingdee.BOS.ServiceHelper;
   

7. using Kingdee.BOS.Workflow.Assignment;
   

8. using Kingdee.BOS.Workflow.Interface;
   

9. using Kingdee.BOS.Workflow.Models.ApprovalAssignment;
   

10. using Kingdee.BOS.Workflow.Models.EnumStatus;
    

11. using Kingdee.BOS.Workflow.ServiceHelper;
    

12. using System;
    

13. using System.Collections.Generic;
    

14. using System.Data;
    

15. using System.Linq;

1. /// <summary>
   

2.         /// 审批单据，actionName为空时，自动寻找第一个同意审批项；
   

3.         /// 有多个类型为通过的审批项时，可用actionName指定审批项，如actionName="审批通过"
   

4.         /// </summary>
   

5.         /// <param name="formId">单据FormId</param>
   

6.         /// <param name="pKValue">单据主键</param>
   

7.         /// <param name="receiverName">处理人</param>
   

8.         /// <param name="disposition">审批意见</param>
   

9.         /// <param name="isApprovalFlow">是否为审批流</param>
   

10.         public void ApproveBill(Context ctx,string formId, string pKValue, string receiverName, string disposition, bool isApprovalFlow = false, string actionName = null)
    

11.         {
    

12.             List<AssignResult> assignResults = GetApproveActions(ctx, formId, pKValue, receiverName);
    

13.             AssignResult approvalAssignResults = assignResults.FirstOrDefault(r => r.ApprovalType == AssignResultApprovalType.Forward);
    

14.             if (approvalAssignResults == null) throw new Exception("未找到审批项。");
    

15.             SubmitWorkflow(ctx, formId, pKValue, receiverName, approvalAssignResults.Id, disposition, isApprovalFlow);
    

16.         }
    

17. 
    

18.         /// <summary>
    

19.         /// 驳回单据，actionName为空时，自动寻找一个驳回审批项；
    

20.         /// 有多个类型为驳回的审批项时（如驳回、打回发起人），可用actionName指定审批项，如actionName="打回发起人"
    

21.         /// </summary>
    

22.         public void RejectBill(Context ctx,string formId, string pKValue, string receiverName, string disposition, bool isApprovalFlow = false, string actionName = null)
    

23.         {
    

24.             List<AssignResult> assignResults = GetApproveActions(ctx, formId, pKValue, receiverName);
    

25.             if (!string.IsNullOrEmpty(actionName))
    

26.                 assignResults = assignResults.Where(r => r.Name.Any(p => p.Value == actionName)).ToList();
    

27.             else
    

28.                 assignResults = assignResults.OrderBy(r => r.Name.Any(p => p.Value == "打回发起人")).ToList();
    

29.             AssignResult rejectAssignResults = assignResults.FirstOrDefault(r => r.ApprovalType == AssignResultApprovalType.Reject);
    

30.             if (rejectAssignResults == null) throw new Exception("未找到驳回审批项。");
    

31.             SubmitWorkflow(ctx, formId, pKValue, receiverName, rejectAssignResults.Id, disposition, isApprovalFlow);
    

32.         }
    

33. 
    

34. private List<AssignResult> GetApproveActions(Context ctx,string formId, string pKValue, string receiverName)
    

35.         {
    

36.             DataSet ds = DBUtils.ExecuteDataSet(ctx, @"select b.FASSIGNID,b.FAPPROVALASSIGNID,a.FRECEIVERNAMES
    

37.                                 from t_wf_assign a 
    

38.                                 join T_WF_APPROVALASSIGN b on a.fassignid=b.fassignid 
    

39.                                 where b.Fobjecttypeid=@FormID 
    

40.                                 and b.Fkeyvalue=@pKValue and a.FSTATUS=0",
    

41.                         new List<SqlParam>
    

42.                         {
    

43.                             new SqlParam("@FormID", DbType.String, formId),
    

44.                             new SqlParam("@pKValue", DbType.String, pKValue)
    

45.                         });
    

46.             DataRow row = ds.Tables[0].Rows.Cast<DataRow>().FirstOrDefault(dr => dr["FRECEIVERNAMES"].ToString().Split(',').Any(r => r == receiverName));
    

47.             if (row == null) return new List<AssignResult> { };
    

48. 
    

49.             string assignId = row["FASSIGNID"].ToString();
    

50.             string approvalAssignId = row["FAPPROVALASSIGNID"].ToString();
    

51.             string _approvalItemId = AssignmentServiceHelper.OpenApprovalItem(ctx, ctx.UserId, assignId, false);
    

52.             var _approvalItem = AssignmentServiceHelper.GetApprovalItemById(ctx, _approvalItemId);
    

53.             return _approvalItem.Actions.ToList();
    

54.         }
    

55. 
    

56. 
    

57.         private void SubmitWorkflow(Context ctx,string formId, string pKValue, string receiverName, string actionResult, string disposition, bool isApprovalFlow)
    

58.         {
    

59.             DataSet ds = DBUtils.ExecuteDataSet(ctx, @"select b.FASSIGNID,b.FAPPROVALASSIGNID,a.FACTINSTID,a.FRECEIVERNAMES
    

60.                                 from t_wf_assign a 
    

61.                                 join T_WF_APPROVALASSIGN b on a.fassignid=b.fassignid 
    

62.                                 where b.Fobjecttypeid=@FormID 
    

63.                                 and b.Fkeyvalue=@pKValue and a.FSTATUS=0",
    

64.                         new List<SqlParam>
    

65.                         {
    

66.                             new SqlParam("@FormID", DbType.String, formId),
    

67.                             new SqlParam("@pKValue", DbType.String, pKValue)
    

68.                         });
    

69.             DataRow row = ds.Tables[0].Rows.Cast<DataRow>().FirstOrDefault(dr => dr["FRECEIVERNAMES"].ToString().Split(',').Any(r => r == receiverName));
    

70.             if (row == null) throw new Exception("未找到待办任务");
    

71. 
    

72. 
    

73.             string assignId = row["FASSIGNID"].ToString();
    

74.             string approvalAssignId = row["FAPPROVALASSIGNID"].ToString();
    

75.             string _approvalItemId = AssignmentServiceHelper.OpenApprovalItem(ctx, ctx.UserId, assignId, false);
    

76.             FormMetadata formMetadata = MetaDataServiceHelper.GetFormMetaData(ctx, formId);
    

77.             DynamicObject ObjData = BusinessDataServiceHelper.LoadSingle(ctx, pKValue, formMetadata.BusinessInfo.GetDynamicObjectType());
    

78.             BusinessInfo businessInfo = formMetadata.BusinessInfo;
    

79. 
    

80.             var _approvalItem = AssignmentServiceHelper.GetApprovalItemById(ctx, _approvalItemId);
    

81.             if (_approvalItem == null) throw new Exception("待办任务所在的流程实例不在运行中，不能进行处理！");
    

82.             _approvalItem.ObjData = ObjData;
    

83.             _approvalItem.ReceiverPostId = 0;
    

84.             _approvalItem.ActionResult = actionResult;
    

85.             _approvalItem.Disposition = disposition.ToString();
    

86.             AssignResult assignResult = _approvalItem.Actions != null ? _approvalItem.Actions.FirstOrDefault(i => i.Id == actionResult) : null;
    

87.             AssignResultApprovalType approvalType = assignResult != null ? assignResult.ApprovalType : AssignResultApprovalType.None;
    

88.             _approvalItem.ActionResultType = approvalType;
    

89.             _approvalItem.Status = ApprovalItemStatus.Completed;
    

90.             DateTime timeNow = TimeServiceHelper.GetSystemDateTime(ctx);
    

91.             _approvalItem.CompletedTime = timeNow;
    

92. 
    

93.             ObjectActivityInstance _activityInstance = AssignmentServiceHelper.ConvertActivityModel(
    

94.                     ctx, businessInfo, approvalAssignId, _approvalItem);
    

95. 
    

96.             var option = OperateOption.Create();
    

97. 
    

98.             if (isApprovalFlow)
    

99.             {
    

100.                 ApprovalAssignmentContext assignCtx = new ApprovalAssignmentContext()
     

101.                 {
     

102.                     ApprovalItems = new List<ApprovalItem>() { _approvalItem },
     

103.                     Info = businessInfo,
     

104.                     Option = option
     

105.                 };
     

106.                 assignCtx.NextActHandler = null;
     

107.                 assignCtx.RejectReturn = false;
     

108.                 assignCtx.ActivityInstance = _activityInstance;
     

109.                 if (actionResult == AssignResultApprovalType.Reject.ToString())
     

110.                 {
     

111.                     var _policy = AssignmentServiceHelper.GetApprovalAssignByAssignId(ctx, assignId);
     

112.                     var nextHandleWrapper = new Kingdee.BOS.ApprovalFlow.PlugIns.Mobile.MobNextHandleWrapper(assignId, ctx, _policy);
     

113.                     assignCtx.Target = nextHandleWrapper.RejectActivityModel.ActivityId;
     

114.                 }
     

115.                 ApprovalAssignmentServiceHelper.SubmitApprovalItem(Context, assignCtx);
     

116.             }
     

117.             else
     

118.             {
     

119.                 ApprovalAssignmentContext assignCtx = new ApprovalAssignmentContext()
     

120.                 {
     

121.                     ApprovalItems = new List<ApprovalItem>() { _approvalItem },
     

122.                     Info = businessInfo,
     

123.                     Option = option
     

124.                 };
     

125.                 assignCtx.NextActHandler = null;
     

126.                 assignCtx.RejectReturn = false;
     

127.                 assignCtx.ActivityInstance = _activityInstance;
     

128.                 AssignmentServiceHelper.SubmitApprovalItem(Context, assignCtx);
     

129.             }
     

130.         }