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

zhanyd

发布于 2022-12-05 15:20:09

5880

发布于 2022-12-05 15:20:09

文章被收录于专栏：编程我也会编程我也会

采购订单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
 
 
}

编译后，执行AutoBuild.bat批处理程序，会自动拷贝对应的项目的dll文件到u9系统目录中。