当前位置: 首页 > article >正文

Quartz实现定时调用接口(.net core2.0)

1.nuget安装Quartz.AspNetCore

2.startup的ConfigureServices方法中增加注入

services.AddQuartz(q =>
            {
                q.UseMicrosoftDependencyInjectionJobFactory();
                //是否开启定时补传打卡记录
                if (Common.Const.IsOpenPostRecordInfosSyn=="1")
                {
                    var jobKey = new JobKey("PostRecordInfosJob");
                    q.AddJob<App_Code.QuartzJob.PostRecordInfosJob>(opts => opts.WithIdentity(jobKey));

                    q.AddTrigger(opts => opts
                        .ForJob(jobKey)
                        .WithIdentity("PostRecordInfosJob-trigger")
                        //每分钟
                        .WithCronSchedule("0 * * * * ?")
                    );
                }
                //是否开启定时同步部门、员工信息
                if (Common.Const.IsOpenBaseInfoSyn == "1")
                {
                    var jobKey = new JobKey("BaseInfoSynJob");
                    q.AddJob<App_Code.QuartzJob.BaseInfoSynJob>(opts => opts.WithIdentity(jobKey));

                    q.AddTrigger(opts => opts
                        .ForJob(jobKey)
                        .WithIdentity("BaseInfoSyn-trigger")
                        //每小时
                        .WithCronSchedule("0 0 * * * ?")
                    );
                }
                //是否开启定时同步设备状态
                if (Common.Const.IsOpenDeviceStateSyn == "1")
                {
                    var jobKey = new JobKey("DeviceStateSynJob");
                    q.AddJob<App_Code.QuartzJob.DeviceStateSynJob>(opts => opts.WithIdentity(jobKey));

                    q.AddTrigger(opts => opts
                        .ForJob(jobKey)
                        .WithIdentity("DeviceStateSynJob-trigger")
                        //每分钟
                        .WithCronSchedule("0 * * * * ?")
                    );
                }
            });

            // ASP.NET Core hosting
            services.AddQuartzServer(options =>
            {
                // when shutting down we want jobs to complete gracefully
                options.WaitForJobsToComplete = true;                
            });

 3.实现job接口

 [DisallowConcurrentExecution]
    public class PostRecordInfosJob : IJob
    {
        private readonly IConfiguration _config;
        private readonly IHttpClientFactory _factory;
        private readonly IFreeSql _freeSql; 
        public PostRecordInfosJob(IConfiguration config,
            IHttpClientFactory factory, IFreeSql freeSql)
        {
            _config = config;
            _factory = factory;
            _freeSql = freeSql;
        }
        /// <summary>
        /// 补传打卡记录(补传记录每天12点进行一次)
        /// </summary>
        //对于耗时任务,需要上一次执行完成后,才执行下次任务,覆盖之前设置的执行周期 
        public async Task Execute(IJobExecutionContext context)
        {
            try
            {
                postRecordInfos();
            }
            catch (Exception ex)
            {
                Common.LogHelper.Error(Common.LogHelper.GetMethodInfo(), ex.ToString(), XHEnum.LogType.异常Error, ex);
            }
        }
    }

 部署到服务器是需要注意引入这四个dll

System.Configuration.ConfigurationManager.dll 


http://www.kler.cn/a/379804.html

相关文章:

  • 算法专题:栈
  • 你知道Mac也能拥有丰富的右键菜单栏吗?
  • selinux和防火墙
  • github - ssh 配置 key、下载repo
  • Java 实现接口幂等的九种方法:确保系统稳定性与数据一致性
  • 智能网联汽车:人工智能与汽车行业的深度融合
  • 华为HarmonyOS打造开放、合规的广告生态 - 激励广告
  • SpringSession源码分析
  • 水仙花求和
  • 使用 pytorch 运行预训练模型的框架
  • D58【python 接口自动化学习】- python基础之异常
  • 不需要复制粘贴,重复内容如何使用Mac快速完成输入
  • 初始JavaEE篇——多线程(5):生产者-消费者模型、阻塞队列
  • 【Mac】Screen Recorder by Omi Mac:Omi录屏专家
  • 从最小作用量原理推导牛顿三大定律
  • 相机硬触发
  • 小红书笔记详情API接口系列(概述到示例案例)
  • Mac上的免费压缩软件-FastZip使用体验实测
  • Vue3的router和Vuex的学习笔记整理
  • WPF使用Prism框架首页界面
  • 语言模型的采样方法
  • 企业培训考试系统源码
  • 深入理解Spring、SpringMVC、SpringBoot和Spring Cloud的区别与用法
  • 服务器数据恢复—RAID5阵列硬盘坏道掉线导致存储不可用的数据恢复案例
  • 【前端开发入门】JavaScript快速入门--数据操作
  • [vulnhub] DC:9