Changeset f554983 for Farmatiko

Timestamp:

02/14/21 17:54:35 (4 years ago)

Author:

Dimitar Slezenkovski <dslezenkovski@…>

Branches:

master

Children:

472dd7e

Parents:

6e6f04b

Message:

Add cron job for updating data, with Quartz.NET

Location:

Farmatiko

Files:

• Controllers/FarmatikoController.cs (modified) (1 diff)
• Program.cs (modified) (2 diffs)
• Startup.cs (modified) (5 diffs)
• appsettings.json (modified) (1 diff)

Farmatiko/Controllers/FarmatikoController.cs

@@ -26 +26 @@
             //_JSONservice.DownloadPharmaciesExcel();
             //_JSONservice.GetProcessedHealthcareWorkersFromJSON();
-            //_JSONservice.GetProcessedHealthFacilitiesFromJSON();
-            //_JSONservice.GetProcessedMedicinesFromJSON();
-            //_JSONservice.GetProcessedPandemicsFromJSONApi();
+            //await _JSONservice.GetProcessedHealthFacilitiesFromJSON();
+            //await _JSONservice.GetProcessedMedicinesFromJSON();
         }
         [HttpGet]

Farmatiko/Program.cs

@@ -3 +3 @@
 using System.Linq;
 using System.Threading.Tasks;
+using FarmatikoServices.Services;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
@@ -22 +24 @@
                 {
                     webBuilder.UseStartup<Startup>();
+                    
                 });
     }

Farmatiko/Startup.cs

@@ -18 +18 @@
 using FarmatikoServices.Infrastructure;
 using System;
+using Quartz;
+using Quartz.Impl;
+using Quartz.Spi;
+using FarmatikoServices.Services.JobDTO;
+
 namespace Farmatiko
 {
@@ -23 +28 @@
     {
         readonly string MyAllowSpecificOrigins = "_myAllowSpecificOrigins";
-
         public Startup(IConfiguration configuration)
         {
@@ -53 +57 @@
             services.AddEntityFrameworkNpgsql().AddDbContext<FarmatikoDataContext>(opt => opt.UseNpgsql(connectionString));
 
+
+
             services.AddScoped<IPHRepo, PHRepo>();
             services.AddScoped<IRepository, Repository>();
             services.AddScoped<IAdminRepo, AdminRepo>();
+            services.AddTransient<IUpdateDataRepo, UpdateDataRepo>();
 
-            services.AddScoped<IPHService, PHService>();
+            services.AddTransient<IPHService, PHService>();
             services.AddTransient<IAdminService, AdminService>();
             services.AddTransient<IService, Service>();
@@ -64 +71 @@
 
             services.AddTransient<ILogger, Logger<ProcessJSONService>>();
-
-            // services.AddTransient<ISystemService, SystemService>();
 
 
@@ -116 +121 @@
                 o.MemoryBufferThreshold = int.MaxValue;
             });*/
+
+            services.AddSingleton<IJobFactory, SingletonUpdateDataJobFactory>();
+            services.AddSingleton<ISchedulerFactory, StdSchedulerFactory>();
+
+            services.AddTransient<UpdateDataJob>();
+            services.AddSingleton(new JobSchedule(
+            jobType: typeof(UpdateDataJob),
+            cronExpression: "0/30 * * * * ?"));
+
+
+            // "0 0 12 */7 * ?"
+
+
+            services.AddHostedService<UpdateDataHostedService>();
 
         }

Farmatiko/appsettings.json

@@ -24 +24 @@
   },
   "SecretKey": "PEJcK2bD4E2BKdNmAlUl",
-  "TokenIssuer": "FARMATIKOISSUER"
+  "TokenIssuer": "FARMATIKOISSUER",
+  "ifStartup": "true"
 }