recurrentjob

gistfile1.txt

		public void UpdateProduct()
		{
			var productToUpdate = _context.FollowProducts
				.FirstOrDefault(fp => fp.LastUpdate < DateTime.SpecifyKind(DateTime.Now, DateTimeKind.Unspecified));
			if (productToUpdate == null)
				return;

			var updatedProduct = _shops.GetProduct(productToUpdate.ShopType, productToUpdate.URL);

			if (updatedProduct.Price < productToUpdate.Money)
			{
				productToUpdate.Money = updatedProduct.Price;
			}

			productToUpdate.LastUpdate = DateTime.Now;

			_context.SaveChanges();
		}
        
        // Startup.cs
        	public class Startup
	{
		public Startup(IConfiguration configuration)
		{
			Configuration = configuration;
		}

		public IConfiguration Configuration { get; }

		// This method gets called by the runtime. Use this method to add services to the container.
		public void ConfigureServices(IServiceCollection services)
		{
			services.AddSingleton<IChannel>(new Channel(Configuration));

			services.AddSingleton<IShopContainer>(new ShopContainer());

			services.AddHangfire(o => o.UsePostgreSqlStorage("User ID=postgres;Password=rootpass;Server=localhost;Database=promo;Enlist=false;Pooling=false"));

			services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);

			//services.AddEntityFrameworkNpgsql().AddDbContext<PromoContext>(o => o.UseNpgsql("Server=localhost;Database=promo"));
			services.AddDbContext<PromoContext>(o => o.UseNpgsql("User ID=postgres;Password=rootpass;Server=localhost;Database=promo"));

			services.AddScoped<IChecker, Checker>();
		}

		// This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
		public void Configure(IApplicationBuilder app, IHostingEnvironment env)
		{
			var options = new BackgroundJobServerOptions { WorkerCount = 3 };
			app.UseHangfireServer(options);
			app.UseHangfireDashboard();

			if (env.IsDevelopment())
			{
				app.UseDeveloperExceptionPage();
			}
			else
			{
				app.UseHsts();
			}

			//app.UseHttpsRedirection();
			app.UseMvc();

			RecurringJob.AddOrUpdate((IChecker ch) => ch.UpdateProduct(), "0/1 * * * *");
		}