emoticon_api/ARW.Tasks/TaskScheduler/Business/SubscribeTask_Job.cs

using ARW.Common;
using ARW.Model.Models.Business.SubscribeTasks;
using ARW.Model.System;
using ARW.Service.Business.IBusinessService.SubscribeTasks;
using ARW.Service.System.IService;
using Infrastructure;
using Infrastructure.Attribute;
using Infrastructure.WeChat.SubScribe;
using Quartz;
using Senparc.CO2NET.Extensions;
using Senparc.Weixin.Entities.TemplateMessage;
using Senparc.Weixin.WxOpen.AdvancedAPIs.WxApp.WxAppJson;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using SystemTime = System.SystemTime;

namespace ARW.Tasks.TaskScheduler.Business
{
    /// <summary>
    /// 订阅推送任务
    /// </summary>
    [AppService(ServiceType = typeof(SubscribeTask_Job), ServiceLifetime = LifeTime.Scoped)]
    public class SubscribeTask_Job : JobBase, IJob
    {
        private readonly NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
        private readonly ISysTasksLogService SysTasksLogService;
        private readonly ISysTasksQzService SysTasksQzService;

        private readonly ISubscribeTaskService _SubscribeTaskService;


        public SubscribeTask_Job(ISysTasksLogService sysTasksLogService, ISysTasksQzService sysTasksQzService, ISubscribeTaskService subscribeTaskService)
        {
            SysTasksLogService = sysTasksLogService;
            SysTasksQzService = sysTasksQzService;
            _SubscribeTaskService = subscribeTaskService;
        }

        public async Task Execute(IJobExecutionContext context)
        {
            var message = await Run();
            var logModel = await ExecuteJob(context, async () => await Run(), message);
            await RecordTaskLog(context, logModel);
        }

        
        public async Task<string> Run()
        {
            await Task.Delay(1);
            //TODO 业务逻辑

            var waitPushList = _SubscribeTaskService.GetSubscribeTaskList();
            if (waitPushList.Count > 0)
            {
                var pagePath = "pages/myMessage/myMessage";
                var templateMessageData = new TemplateMessageData();
                templateMessageData["thing1"] = new TemplateMessageDataValue("测试门店");
                templateMessageData["thing2"] = new TemplateMessageDataValue("佛山市顺德区xxx健身");
                templateMessageData["time3"] = new TemplateMessageDataValue(SystemTime.Now.ToString("yyyy年MM月dd日 HH:mm"));
                templateMessageData["short_thing4"] = new TemplateMessageDataValue("1小时");
                templateMessageData["thing5"] = new TemplateMessageDataValue("还有1个小时开始健身，请熟知！");

                var taskList = new List<string>();
                foreach (var item in waitPushList)
                {
                    try
                    {
                        if (item.EndTime < DateTime.Now)
                        {
                            logger.Info("执行到了这里" + item.OpenId);
                            logger.Info("一共有" + waitPushList.Count + "个");
                            var res = await Infrastructure.WeChat.SubScribe.Subscribe.SubscribeMessage(item.TemplateId, item.OpenId, templateMessageData);
                            logger.Info("推送结果：" + res);

                            if (res == "消息已发送，请注意查收")
                            {

                                // 修改推送状态
                                await _SubscribeTaskService.UpdateAsync(f => new SubscribeTask
                                {
                                    SubscribeTaskStatus = 1
                                }, s => s.SubscribeTaskGuid == item.SubscribeTaskGuid);
                                taskList.Add(item.OpenId + "用户的订阅已推送");
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        return ex.ToString();
                    }
                }
                return taskList.ToJson().ToString();
            }
            else
            {
                logger.Info("空的");
                return "没有需要执行的任务";
            }
            //return "执行成功！";

            #region 公众号模板消息信息       -- DPBMARK MP

            //可选参数（需要和公众号模板消息匹配）：
            //var templateData = new
            //{
            //    first = new Senparc.Weixin.MP.AdvancedAPIs.TemplateMessage.TemplateDataItem("预约健身开始提醒"),
            //    keyword1 = new Senparc.Weixin.MP.AdvancedAPIs.TemplateMessage.TemplateDataItem("测试门店"),
            //    keyword2 = new Senparc.Weixin.MP.AdvancedAPIs.TemplateMessage.TemplateDataItem("佛山市顺德区xxx健身"),
            //    keyword3 = new Senparc.Weixin.MP.AdvancedAPIs.TemplateMessage.TemplateDataItem(SystemTime.Now.ToString("yyyy年MM月dd日 HH:mm")),
            //    keyword4 = new Senparc.Weixin.MP.AdvancedAPIs.TemplateMessage.TemplateDataItem("1小时"),
            //    keyword5 = new Senparc.Weixin.MP.AdvancedAPIs.TemplateMessage.TemplateDataItem("还有1个小时开始健身，请熟知！"),
            //    remark = new Senparc.Weixin.MP.AdvancedAPIs.TemplateMessage.TemplateDataItem("您的 OpenId：" + openId),
            //};
            #endregion                      DPBMARK_END
            //System.Console.WriteLine("job test");
        }


        /// <summary>
        /// 记录到日志
        /// </summary>
        /// <param name="context"></param>
        /// <param name="logModel"></param>
        public async Task RecordTaskLog(IJobExecutionContext context, SysTasksLog logModel)
        {

            //可以直接获取 JobDetail 的值
            IJobDetail job = context.JobDetail;

            logModel.InvokeTarget = job.JobType.FullName;
            logModel = await SysTasksLogService.AddTaskLog(job.Key.Name, logModel);
            //成功后执行次数+1
            if (logModel.Status == "0")
            {
                await SysTasksQzService.UpdateAsync(f => new SysTasksQz()
                {
                    RunTimes = f.RunTimes + 1,
                    LastRunTime = DateTime.Now
                }, f => f.ID.ToString() == job.Key.Name);
            }
            logger.Info($"执行任务【{job.Key.Name}|{logModel.JobName}】结果={logModel.JobMessage}");
        }
    }
}