Merge branch 'master' of http://192.168.1.222:3000/zhengbingbing/ZLJ_API_V6.0

代码/TVShoppingCallCenter_ZLJ/Controllers/hangfire/HangfireController.cs

@@ -0,0 +1,122 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Logging;
+using Hangfire;
+using System.Text;
+using System.IO;
+using System.Net;
+using System.Linq.Expressions;
+using System.Common;
+
+namespace TVShoppingCallCenter_ZLJ.Controllers.hangfire
+{
+    /// <summary>
+    /// 任务调度Hangfire
+    /// </summary>
+    [Produces("application/json")]
+    [Route("api/[controller]")]
+    public class HangfireController : BaseController
+    {
+        private readonly ILogger<HangfireController> _logger;
+
+        public HangfireController(
+            ILogger<HangfireController> logger
+            )
+        {
+            _logger = logger;
+
+        }
+
+        
+
+        #region 四个定时基础方法
+        /// <summary>
+        /// 基于队列的任务处理(Fire-and-forget jobs)
+        /// </summary>
+        /// <param name="str"></param>
+        /// <returns></returns>
+        public IActionResult EnqueueAsync(string str)
+        {
+            var jobId = BackgroundJob.Enqueue(() => Console.WriteLine("Fire-and-forget!"));
+            return Success($"基于队列的任务处理  Enqueue :  jobId={jobId}");
+        }
+
+        /// <summary>
+        /// 延迟任务执行(Delayed jobs)
+        /// </summary>
+        /// <returns></returns>
+        public IActionResult Delayed()
+        {
+            var jobId = BackgroundJob.Schedule(() => Console.WriteLine("Delayed!"),
+                TimeSpan.FromSeconds(10));
+            return Success($"延迟任务执行  Delayed :  jobId={jobId}");
+        }
+
+        /// <summary>
+        /// 定时任务执行(Recurring jobs)
+        /// </summary>
+        /// <returns></returns>
+        public IActionResult Recurring()
+        {
+            RecurringJob.AddOrUpdate(() => Console.Write("定时任务执行  Recurring "), "1/1  * * * *");
+            return Success($"定时任务执行  Recurring ");
+        }
+
+        /// <summary>
+        /// 延续性任务执行
+        /// </summary>
+        /// <param name="jobId"></param>
+        /// <returns></returns>
+        [Obsolete]
+        public IActionResult Continuations(string jobId)
+        {
+            BackgroundJob.ContinueWith(jobId, () => Console.WriteLine("Continuation!"));
+            return Success($"延续性任务执行  Continuation ");
+        }
+        #endregion
+
+
+
+
+        /// <summary>
+        /// 定时任务执行导出
+        /// </summary>
+        /// <returns></returns>
+        public IActionResult RecurringToExport()
+        {
+            RecurringJob.AddOrUpdate(() => HttpGetExport(), Cron.Minutely);
+            return Success($"定时任务执行导出  api/Values/Export/ ");
+        }
+
+        /// <summary>
+        /// 执行导出
+        /// </summary>
+        private void HttpGetExport()
+        {
+            try
+            {
+                //_logger.LogInformation("定时任务执行【导出】【开始】  api/Values/Export/");
+                //HttpWebRequest request = (HttpWebRequest)WebRequest.Create("http://localhost:8082/api/Values/Export?start=2017-12-08&end=2017-12-09");
+                //request.Method = "GET";
+                //request.ContentType = "text/html;charset=UTF-8";
+
+                //HttpWebResponse response = (HttpWebResponse)request.GetResponse();
+                //Stream myResponseStream = response.GetResponseStream();
+                //StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.UTF8);
+                //var result = myStreamReader.ReadToEnd();
+                //myStreamReader.Close();
+                //myResponseStream.Close();
+                //if (result != "定时导出Excel文件，并保存Excel文件信息到数据库中")
+                //    throw new Exception("导出错误");
+                //_logger.LogInformation("定时任务执行【导出】【结束】  api/Values/Export/");
+            }
+            catch (Exception e)
+            {
+                //_logger.LogError(e, "定时任务执行【导出】【失败】  api/Values/Export/");
+            }
+        }
+    }
+}

代码/TVShoppingCallCenter_ZLJ/Filter/HangfireAuthorizationFilter.cs

@@ -0,0 +1,10 @@
+using Hangfire.Dashboard;
+
+public class HangfireAuthorizationFilter : IDashboardAuthorizationFilter
+{
+    //这里需要配置权限规则
+    public bool Authorize(DashboardContext context)
+    {
+        return true;
+    }
+}

代码/TVShoppingCallCenter_ZLJ/Startup.cs

@@ -26,6 +26,7 @@ using Microsoft.Extensions.FileProviders;
 using System.IO;
 using Microsoft.AspNetCore.Http;
 using TVShoppingCallCenter_ZLJ.Controllers.Order;
+using Hangfire;
 
 namespace TVShoppingCallCenter_ZLJ
 {
@@ -125,7 +126,7 @@ namespace TVShoppingCallCenter_ZLJ
             services.AddTransient<ISys_CallDutyNumberRepository, Sys_CallDutyNumberRepository>();
             services.AddTransient<ISys_CallBlacklistRepository, Sys_CallBlacklistRepository>();
             services.AddTransient<ISys_PositionRepository, Sys_PositionRepository>();
-            services.AddTransient<ISys_DeptTeamRepository, Sys_DeptTeamRepository>(); 
+            services.AddTransient<ISys_DeptTeamRepository, Sys_DeptTeamRepository>();
 
             services.AddTransient<IBus_ProductClassRepository, Bus_ProductClassRepository>();
             services.AddTransient<IBus_ProductRepository, Bus_ProductRepository>();
@@ -135,6 +136,7 @@ namespace TVShoppingCallCenter_ZLJ
             services.AddTransient<IBus_StockLogRepository, Bus_StockLogRepository>();
             services.AddTransient<IBus_OrderMergeRepository, Bus_OrderMergeRepository>();
             services.AddTransient<IBus_AfterSaleRepository, Bus_AfterSaleRepository>();
+            services.AddHangfire(x => x.UseSqlServerStorage(BaseContext.DB_ConnectionString));
 
             services.AddTransient<ICus_VipInfoRepository, Cus_VipInfoRepository>();
             services.AddTransient<ICus_VipLabelInfoRepository, Cus_VipLabelInfoRepository>();
@@ -143,9 +145,9 @@ namespace TVShoppingCallCenter_ZLJ
 
             services.AddTransient<ISys_MarketingRepository, Sys_MarketingRepository>();
 
-            services.AddTransient<ISys_MediaCenteRepository , Sys_MediaCente >();
-            services.AddTransient<ISys_MediaManagementRepository , Sys_MediaManagement >();
-            services.AddTransient<ISys_PlanManagemenRepository , Sys_PlanManagemen >();
+            services.AddTransient<ISys_MediaCenteRepository, Sys_MediaCente>();
+            services.AddTransient<ISys_MediaManagementRepository, Sys_MediaManagement>();
+            services.AddTransient<ISys_PlanManagemenRepository, Sys_PlanManagemen>();
 
             services.AddTransient<ISys_TaskManagementRepository, Sys_TaskManagementRepository>();
 
@@ -183,6 +185,18 @@ namespace TVShoppingCallCenter_ZLJ
 
             app.UseMvc();
 
+            app.UseHangfireServer(new BackgroundJobServerOptions
+            {
+                Queues = new[] { "birthday" },//队列名称，只能为小写
+                WorkerCount = Environment.ProcessorCount * 3, //并发任务数
+                ServerName = "hangfire1",//服务器名称
+            });//启动Hangfire服务  有可选参数
+            app.UseHangfireDashboard("/hangfire", 
+                new DashboardOptions
+            {
+                Authorization = new[] { new HangfireAuthorizationFilter() }
+            });//启动hangfire面板 有可选参数
+
             #region steeltoe
             //app.UseDiscoveryClient();
             #endregion

代码/TVShoppingCallCenter_ZLJ/TVShoppingCallCenter_ZLJ.csproj

@@ -6,6 +6,8 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Hangfire.AspNetCore" Version="1.7.11" />
+    <PackageReference Include="HangFire.SqlServer" Version="1.7.11" />
     <PackageReference Include="Microsoft.AspNetCore.All" Version="2.2.8" />
     <PackageReference Include="Microsoft.AspNetCore.App" />
     <PackageReference Include="Microsoft.AspNetCore.Razor.Design" Version="2.2.0" PrivateAssets="All" />