Add project files.

Author: rineshaccion

QuartzWithCore.sln

@@ -0,0 +1,31 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 16
+VisualStudioVersion = 16.0.28729.10
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "QuartzWithCore", "QuartzWithCore\QuartzWithCore.csproj", "{362C27F1-8955-43C1-8EF1-0AAF9798E658}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WorkflowSteps", "WorkflowSteps\WorkflowSteps.csproj", "{0FA72B33-E377-4604-8A0A-CF7D01384B7F}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{362C27F1-8955-43C1-8EF1-0AAF9798E658}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{362C27F1-8955-43C1-8EF1-0AAF9798E658}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{362C27F1-8955-43C1-8EF1-0AAF9798E658}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{362C27F1-8955-43C1-8EF1-0AAF9798E658}.Release|Any CPU.Build.0 = Release|Any CPU
+		{0FA72B33-E377-4604-8A0A-CF7D01384B7F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{0FA72B33-E377-4604-8A0A-CF7D01384B7F}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{0FA72B33-E377-4604-8A0A-CF7D01384B7F}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{0FA72B33-E377-4604-8A0A-CF7D01384B7F}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {75DC2088-EC0C-437C-B8A9-875D28FDBE9A}
+	EndGlobalSection
+EndGlobal

QuartzWithCore/Controllers/HomeController.cs

@@ -0,0 +1,108 @@
+using Microsoft.AspNetCore.Mvc;
+using Quartz;
+using QuartzWithCore.Models;
+using QuartzWithCore.Tasks;
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Threading.Tasks;
+using WorkflowSteps.Tasks;
+
+namespace QuartzWithCore.Controllers
+{
+    public class HomeController : Controller
+    {
+        private readonly IScheduler _scheduler;
+
+        public HomeController(IScheduler factory)
+        {
+            _scheduler = factory;
+        }
+
+        public IActionResult Index()
+        {
+            return View();
+        }
+
+        public async Task<IActionResult> CheckAvailability(int intervalinSec = 5)
+        {
+            ITrigger trigger = TriggerBuilder.Create()
+             .WithIdentity($"Check Availability-{DateTime.Now}")
+             .StartNow()
+             .WithSimpleSchedule(scheduleBuilder =>
+                scheduleBuilder
+                    .WithIntervalInSeconds(intervalinSec)
+                    .RepeatForever())
+             .Build();
+           
+            IDictionary<string, object> map = new Dictionary<string, object>()
+            {
+                {"Current Date Time", $"{DateTime.Now}" },
+                {"Tickets needed", $"5" },
+                {"Concert Name", $"Rock" }
+            };
+
+            IJobDetail job = JobBuilder.Create<SchedueleJob>()
+                        .WithIdentity($"Check Availability#{intervalinSec}-{DateTime.Now}")
+                        .SetJobData(new JobDataMap(map))
+                        .Build();
+
+            //Finally schedule the job
+            await _scheduler.ScheduleJob(job, trigger);
+            return RedirectToAction("Index");
+        }
+
+        public async Task<IActionResult> CheckAvailabilityV1()
+        {
+            ITrigger trigger = TriggerBuilder.Create()
+             .WithIdentity($"Check Availability 1-{DateTime.Now}")
+             .StartAt(new DateTimeOffset(DateTime.Now.AddSeconds(15)))
+             .WithPriority(1)
+             .Build();
+
+            IDictionary<string, object> map = new Dictionary<string, object>()
+            {
+                {"Current Date Time", $"{DateTime.Now}" },
+                {"Tickets needed", $"5" },
+                {"Concert Name", $"Rock" }
+            };
+
+            IJobDetail job = JobBuilder.Create<CheckAvailabilityTask>()
+             //.WithIdentity("Check Availability")
+             .WithIdentity($"Check Availability 1-{DateTime.Now}")
+                        .SetJobData(new JobDataMap(map))
+                        .Build();
+
+
+            await _scheduler.ScheduleJob(job, trigger);
+            return RedirectToAction("Index");
+        }
+
+        public async Task<IActionResult> ReserveTickets()
+        {
+            ITrigger trigger = TriggerBuilder.Create()
+             .WithIdentity($"Reserve Tickets-{DateTime.Now}")
+             .StartNow()
+             .WithPriority(1)
+             .Build();
+
+            IDictionary<string, object> map = new Dictionary<string, object>()
+            {
+            };
+
+            IJobDetail job = JobBuilder.Create<ReserveTicketsTask>()
+                        .WithIdentity($"Reserve Tickets:{DateTime.Now.Ticks}")
+                        .SetJobData(new JobDataMap(map))
+                        .Build();
+
+            await _scheduler.ScheduleJob(job, trigger);
+            return RedirectToAction("Index");
+        }
+
+        [ResponseCache(Duration = 0, Location = ResponseCacheLocation.None, NoStore = true)]
+        public IActionResult Error()
+        {
+            return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
+        }
+    }
+}

QuartzWithCore/Models/ErrorViewModel.cs

@@ -0,0 +1,11 @@
+using System;
+
+namespace QuartzWithCore.Models
+{
+    public class ErrorViewModel
+    {
+        public string RequestId { get; set; }
+
+        public bool ShowRequestId => !string.IsNullOrEmpty(RequestId);
+    }
+}

QuartzWithCore/Program.cs

@@ -0,0 +1,24 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+
+namespace QuartzWithCore
+{
+    public class Program
+    {
+        public static void Main(string[] args)
+        {
+            CreateWebHostBuilder(args).Build().Run();
+        }
+
+        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
+            WebHost.CreateDefaultBuilder(args)
+                .UseStartup<Startup>();
+    }
+}

QuartzWithCore/Properties/launchSettings.json

@@ -0,0 +1,27 @@
+{
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:52552/",
+      "sslPort": 44351
+    }
+  },
+  "profiles": {
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "QuartzWithCore": {
+      "commandName": "Project",
+      "launchBrowser": true,
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      },
+      "applicationUrl": "https://localhost:5001;http://localhost:5000"
+    }
+  }
+}

QuartzWithCore/QuartzWithCore.csproj

@@ -0,0 +1,18 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>netcoreapp2.1</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.AspNetCore.App" />
+    <PackageReference Include="Microsoft.AspNetCore.Razor.Design" Version="2.1.2" PrivateAssets="All" />
+    <PackageReference Include="Quartz" Version="3.0.7" />
+    <PackageReference Include="Quartz.Serialization.Json" Version="3.0.6" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\WorkflowSteps\WorkflowSteps.csproj" />
+  </ItemGroup>
+
+</Project>

QuartzWithCore/Startup.cs

@@ -0,0 +1,91 @@
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Quartz;
+using Quartz.Impl;
+using System.Collections.Specialized;
+using System.Threading.Tasks;
+using WorkflowSteps;
+
+namespace QuartzWithCore
+{
+    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.Configure<CookiePolicyOptions>(options =>
+            {
+                // This lambda determines whether user consent for non-essential cookies is needed for a given request.
+                options.CheckConsentNeeded = context => true;
+                options.MinimumSameSitePolicy = SameSiteMode.None;
+            });
+
+            services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);
+            services.AddSingleton(provider => GetScheduler().Result);
+            services.AddSingleton<GetPriceStep>();
+            services.AddSingleton<ReserveTickets>();
+            services.AddSingleton<PrintReceiptStep>();
+        }
+
+        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
+        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
+        {
+            if (env.IsDevelopment())
+            {
+                app.UseDeveloperExceptionPage();
+            }
+            else
+            {
+                app.UseExceptionHandler("/Home/Error");
+                app.UseHsts();
+            }
+
+            app.UseHttpsRedirection();
+            app.UseStaticFiles();
+            app.UseCookiePolicy();
+
+            app.UseMvc(routes =>
+            {
+                routes.MapRoute(
+                    name: "default",
+                    template: "{controller=Home}/{action=Index}/{id?}");
+            });
+        }
+
+        private async Task<IScheduler> GetScheduler()
+        {
+            var properties = new NameValueCollection
+            {
+                { "quartz.scheduler.instanceName", "QuartzWithCore" },
+                { "quartz.scheduler.instanceId", "QuartzWithCore" },
+                { "quartz.jobStore.type", "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz" },
+                { "quartz.jobStore.useProperties", "true" },
+                { "quartz.jobStore.dataSource", "default" },
+                { "quartz.jobStore.tablePrefix", "QRTZ_" },
+                {
+                    "quartz.dataSource.default.connectionString",
+                    "Server=(localdb)\\MSSQLLocalDB;Initial Catalog=quartz;integrated security=True;Trusted_Connection=True;"
+                },
+                { "quartz.dataSource.default.provider", "SqlServer" },
+                { "quartz.threadPool.threadCount", "1" },
+                { "quartz.serializer.type", "json" },
+            };
+            var schedulerFactory = new StdSchedulerFactory(properties);
+            var scheduler = await schedulerFactory.GetScheduler();
+            //await scheduler.Start();                                                                                  
+            return scheduler;
+        }
+    }
+}

QuartzWithCore/Tasks/CheckAvailabilityTask.cs

@@ -0,0 +1,30 @@
+using Quartz;
+using System;
+using System.Diagnostics;
+using System.Threading.Tasks;
+
+namespace QuartzWithCore.Tasks
+{
+    public class CheckAvailabilityTask : IJob
+    {
+        public Task Execute(IJobExecutionContext context)
+
+        {
+            var jobKey = context.JobDetail.Key;
+            Debug.WriteLine($"Hello - executed at {DateTime.Now} | jobKey- {jobKey}");
+            try
+            {
+                var dataMap = context.JobDetail.JobDataMap;
+                var timeRequested = dataMap.GetDateTime("Current Date Time");
+                var ticketsNeeded = dataMap.GetInt("Tickets needed");
+                var concertName = dataMap.GetString("Concert Name");
+                Debug.WriteLine($"{ticketsNeeded} Tickets to the {concertName} concert on {timeRequested.ToString("MM-dd-yyyy")} are available");
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine(ex);
+            }
+            return Task.FromResult(0);
+        }
+    }
+}

QuartzWithCore/Tasks/SheduleJob.cs

@@ -0,0 +1,19 @@
+using Quartz;
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace QuartzWithCore.Tasks
+{
+    public class SchedueleJob : IJob
+    {
+        public Task Execute(IJobExecutionContext context)
+        {
+            var jobKey = context.JobDetail.Key;
+            Debug.WriteLine($"Hello - executed at {DateTime.Now} | jobKey- {jobKey}");
+            return Task.FromResult(0);
+        }
+    }
+}

QuartzWithCore/Views/Home/About.cshtml

@@ -0,0 +1,7 @@
+@{
+    ViewData["Title"] = "About";
+}
+<h2>@ViewData["Title"]</h2>
+<h3>@ViewData["Message"]</h3>
+
+<p>Use this area to provide additional information.</p>