使用Hangfire MVC 做排程

public class ApplicationPreload : System.Web.Hosting.IProcessHostPreloadClient
{
  public void Preload(string[] parameters)
  {
    Startup.Instance.Start();
  }
}

public class Global : HttpApplication
{
  protected void Application_Start(object sender, EventArgs e)
  {
    Startup.Instance.Start();
  }
  protected void Application_End(object sender, EventArgs e)
  {
    Startup.Instance.Stop();
  }
}

[assembly: OwinStartup(typeof(AgentService.Startup))]
namespace AgentService
{
  public class Startup : IRegisteredObject
  {
    public static readonly Startup Instance = new Startup();
    private readonly object _lockObject = new object();
    private bool _started;
    private BackgroundJobServer _backgroundJobServer;
    /// <summary>
    /// 一開始所要執行的 初始化 Hangfire
    /// 會先尋找資料庫是否有被初始化再來則是這邊 如果一開始不先初始化資料庫直接 啟動 UseHangfireServer會產生
    ///	錯誤
    /// </summary>
    /// <param name="app"></param>
    public void Configuration(IAppBuilder app)
    {
      //啟用Hangfire的Dashboard
      //預設 Dashboard 路徑為http://localhost:xxxx/hangfire
      //使用 Dashboard，可以設定顯示 dashboard 的 path http://localhost:xxxx/HangfireDashboard
      //在這設定能進入Dashboard 得權限
      app.UseHangfireDashboard("/HangfireDashboard", new DashboardOptions
      {
        Authorization = new[] { new HangfireDashBoardAuthorizationFilter() },
      });
      //執行所需的 排程
      StartMyTask();
    }
}

/// <summary>
/// 執行的 Method 參數最好是字串，如果是物件的話，不要是 nested 物件，這樣會Parse不出來，然後報錯哦!
/// 使用 Hangfire 去執行的話， nested obj 會 parse 不出來，所以用字串傳遞
/// </summary>
private void StartMyTask()
{
  //設定每天的幾十幾分運作
  //Cron.Daily(07,30)
  //同上
  //分鐘 小時 日期 月份 週
  //30   07    *    *   *
  //代表這個域上包含所有合法的值
  //以下方做為表示是說每天07:30 AM執行此排程
  string cronExp = "30 07 * * *";
  //設定注意 這就是所謂的固定時間去做排程定時
  //第一參數為 RecurringJobId
  //第二為 你要所使用的call method
  //第三 就是你要這排程何時運作
  //第四 很重要!! 他會依你的排程時間下去實作但你需要將此時間設定為Local否則預設是 UTC你會不知道何時運作
  RecurringJob.AddOrUpdate("test", () =>  AgentService.SetDEMOamount(), cronExp,Ti	meZoneInfo.	Local);
  //這是需要在長時間 背景執行的工作就可以設定這個
  BackgroundJob.大专栏  使用Hangfire MVC 做排程>Enqueue(() => AgentService.SetDEMOamount());
  //BackgroundJob.Schedule()將目前的任務延後執行，在送入背景等待時就已經執行完畢，而不是3秒後才被執行。
  BackgroundJob.Schedule(() => AgentService.SetDEMOamount()),TimeSpan.FromSeconds(3));
  //使用下列方法 他會馬上執行此排程但不會紀錄這次的使用
  RecurringJob.Trigger("test");
}

/// <summary>
/// 一開始從 Global.aspx會啟動這邊 直接開啟 Hangfire 與 JobStorage資料庫連接
/// </summary>
public void Start()
{
  lock (_lockObject)
  {
    if (_started) return;
    _started = true;
    HostingEnvironment.RegisterObject(this);
    JobStorage.Current = new SqlServerStorage(ConnectionString);
    GlobalConfiguration.Configuration.UseSqlServerStorage(ConnectionString);
    // 建立Background JobSserver 來處理 Job
    // 啟用HanfireServer
    // reduce the heartbeat of the Hangfire dashboard. It is taking too much of our CPU usag	e.It is in our production also
    _backgroundJobServer = new BackgroundJobServer(new BackgroundJobServerOptions
    {
      //要處理的陣列列表
      Queues = new[] { "test" },
      //巡迴訪問時間越長 將會很耗CPU的效能
      //預設30秒 6分鐘為 使用 TransactionScope 限制時間
      HeartbeatInterval = new TimeSpan(0, 6, 0),
      ServerCheckInterval = new TimeSpan(0, 6, 0),
      //預設詢問Job是 15 秒，也可以依狀況來調整，如下我使用6分鐘
      SchedulePollingInterval = new TimeSpan(0, 6, 0),
      //服務名稱
      ServerName = "FundaySaleshangfireahent",
      //設定 Hangfire 同一時間，可以處理多少的 Job 現在是20
      //預設是 處理器數目 * 5
      WorkerCount = Environment.ProcessorCount * 5,
    });
  }
}

/// <summary>
/// 程序停止
/// </summary>
public void Stop()
{
  lock (_lockObject)
  {
    if (_backgroundJobServer != null)
    {
      _backgroundJobServer.Dispose();
    }
      HostingEnvironment.UnregisterObject(this);
    }
}
  void IRegisteredObject.Stop(bool immediate)
  {
    Stop();
  }
}

/// <summary>
/// 取得能進入 Hangfire Dashboard的人員 只有管理者權限才能進入
/// </summary>
public class HangfireDashBoardAuthorizationFilter : IDashboardAuthorizationFilter
{
  public bool Authorize([NotNull]DashboardContext context)
  {
    if (context == null) throw new ArgumentNullException(nameof(context));
    var owinContext = new Microsoft.Owin.OwinContext(context.GetOwinEnvironment());
    if (owinContext.Authentication.User.Identity.IsAuthenticated)
    {
      return true;
    }
    return false;
  }
}