U9二次开发之BP定时任务插件开发

zhanyd

已于 2023-12-07 09:21:50 修改

阅读量1.5k

点赞数 3

分类专栏：计算机基础文章标签： U9 BP 插件定时任务

于 2022-09-08 14:07:11 首次发布

本文链接： https://blog.csdn.net/zhanyd/article/details/126635853

版权

计算机基础专栏收录该内容

64 篇文章 14 订阅

订阅专栏

采购订单BP定时任务插件开发

最近我们公司要做采购订单审批和OA的集成，也就是把u9的审批流程搬到OA里去做。当业务员点击标准采购提交按钮的时候，把采购订单的信息触发到OA流程，在OA里做审核，OA审核完成之后，再把审核结果回写到U9。

要实现这个功能需要用到BE插件和BP插件。

BE插件负责在业务员提交审核的时候，把采购订单的信息写到中间表里，然后再触发OA流程。

（请看这篇文章： U9二次开发之BE插件开发）

BP插件负责定时查询中间表，把审核结果写回到u9系统。

这里我讲解下BP插件的开发流程。

生成项目代码

1.打开ubfdev工具新建解决方案

打开ubfdev工具，点击文件-新建解决方案，勾选操作项目，输入解决方案的名称，点击确定按钮。

2.修改项目名称

修改项目名称，并删除自动生成的.ubfbp文件。

先点击“模型视图”，然后点击“属性”，修改名称：

修改后：

3.新建业务组件

右键项目–新建，选择业务操作组件，填写组件名称，点确定按钮。

选择模型视图，双击项目，就可以打开操作页面。

拖动操作按钮到窗体：

点击操作实体，点击属性按钮，修改名称：

修改事务类型为required：

4.构造代码

右键项目点击构造

在消息列表中可以看到生成代码的路径

编写代码

打开生成的项目，右键引用，添加引用：

注意：BP需要引入*PMISV.Agent.dll，要引入代理。

编写代码：

namespace UpdatePurchaseOrderAuditStatus
{
	using System;
	using System.Collections.Generic;
    using System.Data;
    using System.Text;
    using UFIDA.U9.CBO.Pub.Controller;
    using UFIDA.U9.PM.PO;
    using UFSoft.UBF.AopFrame;	
	using UFSoft.UBF.Util.Context;
    using UFSoft.UBF.Util.DataAccess;
    using UFIDA.U9.Base.DTOs;
    using UFIDA.U9.PM.DTOs;

    /// <summary>
    /// UpdateStatus partial 
    /// </summary>	
    public partial class UpdateStatus 
	{	
		internal BaseStrategy Select()
		{
			return new UpdateStatusImpementStrategy();	
		}		
	}
	
	#region  implement strategy	
	/// <summary>
	/// Impement Implement
	/// 
	/// </summary>	
	internal partial class UpdateStatusImpementStrategy : BaseStrategy
	{
		public UpdateStatusImpementStrategy() { }

		public override object Do(object obj)
		{						
			UpdateStatus bpObj = (UpdateStatus)obj;

            //get business operation context is as follows
            //IContext context = ContextManager.Context	

            //auto generating code end,underside is user custom code
            //and if you Implement replace this Exception Code...
            //throw new NotImplementedException();

            DataSet ds = new DataSet();
            DataParamList paras = new DataParamList();
            StringBuilder sql = new StringBuilder();
           
            //查找OA审核通过并未同步的数据，OA审核不通过的不处理
            sql.Append("select * from PurchaseOrder_Middle where audit_status = 1 and state = 0");
            DataAccessor.RunSQL(UFSoft.UBF.Util.DataAccess.DataAccessor.GetConn(), sql.ToString(), paras, out ds);
            if (ds != null)
            {
                if (ds.Tables.Count > 0)
                {
                    // 生成审核状态BP对象
                    UFIDA.U9.ISV.PO.Proxy.ApprovePOISVProxy approveProxy = new UFIDA.U9.ISV.PO.Proxy.ApprovePOISVProxy();

                    foreach (DataRow dataRow in ds.Tables[0].Rows)
                    {
                        try
                        {
                            string auditPerson = Convert.ToString(dataRow["audit_person"]);

                            if (auditPerson != null)
                            {
                                //设置审核人
                                setApprovedBy(auditPerson);
                            }
                  
                            List<IDCodeNameDTOData> dtoDatas = new List<IDCodeNameDTOData>();
                            IDCodeNameDTOData dtoData = new IDCodeNameDTOData();
                            dtoData.ID = Convert.ToInt64(dataRow["PRID"]);
                            dtoDatas.Add(dtoData);

                            //审核通过
                            approveProxy.ActionType = 8; // 审核：8
                            approveProxy.POList = dtoDatas;
                            approveProxy.TargetOrgCode = UFIDA.U9.Base.Context.LoginOrg.Code;
                            approveProxy.Do();

                            //修改中间表状态
                            sql.Clear();
                            sql.Append("update PurchaseOrder_Middle set state = 1,memo = '审核状态同步成功',update_by = 'sys',update_time = GETDATE() where id = " + dataRow["id"]);
                            DataAccessor.RunSQL(UFSoft.UBF.Util.DataAccess.DataAccessor.GetConn(), sql.ToString(), paras, out ds);
                        }
                        catch (Exception ex)
                        {
                            //记录异常信息
                            sql.Clear();
                            sql.Append("update PurchaseOrder_Middle set state = -1, memo = '" + ex.Message + "',update_by = 'sys',update_time = GETDATE() where id = " + dataRow["id"]);
                            DataAccessor.RunSQL(UFSoft.UBF.Util.DataAccess.DataAccessor.GetConn(), sql.ToString(), paras, out ds);
                            //throw ex;  //throw 异常会导致sql回滚
                        }
                    }
                }
            }
            return null;
        }


        //设置审核人
        private void setApprovedBy(String UserCode)
        {
            PlatformContext context = PlatformContext.Current;
            if (!((context == null) || string.IsNullOrEmpty(context.OrgCode)))
            {
                ContextDTO tdto = new ContextDTO();
                //传入审核人工号
                tdto.UserCode = UserCode;
                tdto.EntCode = context.EnterpriseID;
                tdto.CultureName = context.Culture;
                tdto.OrgCode = context.OrgCode;
                tdto.WriteToContext();
            }
        }

    }

	#endregion
	
	
}