二开案例.计算任务.从零开发计算任务

栏目:云星空知识作者:金蝶来源:金蝶云社区发布:2024-09-23浏览:1

二开案例.计算任务.从零开发计算任务

【应用场景】一次性的,不需要周期性执行的,不需要界面交互的,高资源消耗型的后台任务。计算任务通过计算站点运行,能有效降低对应用站点的性能影响。

计算任务和执行计划都是运行在计算站点上,两者的主要区别在于,计算任务是即时启动任务,且仅执行一次;而执行计划是根据其定义的执行策略,周期性的执行。

【案例演示】实现一个计算任务,任务中实现写上机日志和发送邮件的功能,并在采购订单列表上启动该计算任务。

【实现步骤】

<1>编写计算任务服务类,代码如下。

using Kingdee.BOS.App.Core;

using Kingdee.BOS.Computing;

using Kingdee.BOS.Core.Log;

using Kingdee.BOS.Log;

using Kingdee.BOS.Util;

using System;

using System.Collections.Generic;


namespace Jac.XkDemo.BOS.App.PlugIn

{

    /// <summary>

    /// 【计算任务】从零开发计算任务

    /// </summary>

    public class SendMailComputeTaskService : IComputeTaskExecutor

    {

        /// <summary>

        /// 计算任务入口函数

        /// </summary>

        /// <param name="ctx"></param>

        public void Execute(ComputeContext ctx)

        {

            try

            {

                #region 计算任务主体逻辑


                // TODO

                // TODO

                // TODO


                #endregion


                #region 写个上机操作日志,证明我执行过啦


                var logs = new List<LogObject>();

                var log = new LogObject();

                log.pkValue = "0";

                log.Description = "我是一条来自计算任务的测试日志数据:)";

                log.OperateName = "执行计算任务";

                log.ObjectTypeId = "BOS_COMPUTETASK";

                log.SubSystemId = "BOS";

                log.Environment = OperatingEnvironment.BizOperate;

                logs.Add(log);

                new Kingdee.BOS.App.LogService.Log().BatchWriteLog(ctx.Task.BOSContext, logs);


                #endregion


                #region 执行完了,发个邮件通知下用户


                // 给当前用户发个邮件

                var userId = ctx.Task.BOSContext.UserId;

                var email = new SendMailService().GetEmailMessageInfoByUserId(ctx.Task.BOSContext, userId);

                if (email != null)

                {

                    email.To = new List<string>(new[] {"abc@qq.com"});

                    email.Subject = "计算任务测试邮件";

                    email.Body = "我是一封来自计算任务的测试邮件,计算任务已成功执行!";

                    MailUtils.Sendmail(email);

                }


                #endregion

            }

            catch (Exception ex)

            {

                var errMsg = string.Format("计算任务运行异常:{0}", ex.Message);

                Logger.Error("Jac", errMsg, ex);

            }

        }

    }

}


<2>编写列表插件,代码如下。

using Kingdee.BOS.App;

using Kingdee.BOS.Computing;

using Kingdee.BOS.Contracts.Computing;

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

using Kingdee.BOS.Core.List.PlugIn;

using Kingdee.BOS.Util;

using System;

using System.Collections.Generic;

using System.ComponentModel;


namespace Jac.XkDemo.BOS.Business.PlugIn

{

    /// <summary>

    /// 【列表插件】启动计算任务

    /// </summary>

    [Description("【列表插件】启动计算任务"), HotUpdate]

    public class SubmitComputeTaskListPlugIn : AbstractListPlugIn

    {

        public override void BarItemClick(BarItemClickEventArgs e)

        {

            base.BarItemClick(e);

            if (e.BarItemKey.EndsWith("tbSubmitComputeTask", StringComparison.OrdinalIgnoreCase))

            {

                // 启动一个已经定义好的计算任务

                var backAppService = ServiceHelper.GetService<IBackAppService>();

                var backAppTask = new BackAppTask();

                backAppTask.BOSContext = this.Context;

                backAppTask.OriginatorId = this.Context.UserId;

                backAppTask.ExecutorType = Type.GetType("Jac.XkDemo.BOS.App.PlugIn.SendMailComputeTaskService,Jac.XkDemo.BOS.App.PlugIn");

                backAppTask.Title = "计算任务运行演示";

                var properties = new Dictionary<string, object>();

                properties.Add("自定义参数1", "a");

                properties.Add("自定义参数2", "b");

                backAppTask.Properties = properties;

                backAppTask.Status = ComputeStatus.Ready;

                backAppTask.Priority = ComputePriority.Immediately;

                backAppTask.SerializeProperties();

                backAppService.SubmitTask(this.Context, backAppTask);

                this.View.ShowMessage("计算任务已启动!");

            }

        }

    }

}


<3>拷贝插件组件到应用站点的WebSite\Bin目录下,重启IIS。


<4>BOSIDE扩展采购订单,列表菜单新增菜单项,注册列表插件,保存元数据,开发完毕。



现在可以登录业务站点,打开采购订单列表,启动计算任务啦。

启动计算任务:

查看计算任务执行情况:

计算任务执行成功后,写入了上机操作日志:





【知识点】

<1>计算任务执行信息保存在表T_BOS_BACKAPPTASK(或者是T_BOS_COMPUTETASK)

<2>计算任务运行在计算站点(通常是K3CloudApp)

<3>计算站点Url在应用站点的App_Data\Common.config里的appSettings下的ComputeSiteUrl设置。















【金蝶云星空BOS二次开发案例演示】https://vip.kingdee.com/article/94751030918525696

二开案例.计算任务.从零开发计算任务

【应用场景】一次性的,不需要周期性执行的,不需要界面交互的,高资源消耗型的后台任务。计算任务通过计算站点运行,能有效降低对应用站点...
点击下载文档
确认删除?
回到顶部
客服QQ
  • 客服QQ点击这里给我发消息