Added Generate Statement job

TransactionProcessing.SchedulerService/TransactionProcessing.SchedulerService.Jobs/Bootstrapper.cs

@@ -0,0 +1,84 @@
+namespace TransactionProcessing.SchedulerService.Jobs;
+
+using System;
+using System.Net.Http;
+using System.Threading.Tasks;
+using System.Threading;
+using DataGeneration;
+using EstateManagement.Client;
+using EstateManagement.DataTransferObjects.Responses;
+using Microsoft.Extensions.DependencyInjection;
+using Quartz;
+using SecurityService.Client;
+using SecurityService.DataTransferObjects.Responses;
+using TransactionProcessor.Client;
+
+public static class Bootstrapper{
+
+    internal  static IJobExecutionContext JobExecutionContext;
+
+    internal static ServiceProvider ServiceProvider;
+
+    internal static IServiceCollection Services;
+
+    public static void ConfigureServices(IJobExecutionContext jobExecutionContext){
+        Bootstrapper.Services = new ServiceCollection();
+        Bootstrapper.JobExecutionContext = jobExecutionContext;
+
+        HttpClientHandler httpClientHandler = new HttpClientHandler{
+                                                                       ServerCertificateCustomValidationCallback = (message,
+                                                                                                                    cert,
+                                                                                                                    chain,
+                                                                                                                    errors) => {
+                                                                                                                       return true;
+                                                                                                                   }
+                                                                   };
+        HttpClient httpClient = new HttpClient(httpClientHandler);
+
+        Bootstrapper.Services.AddSingleton(httpClient);
+        Bootstrapper.Services.AddSingleton<ISecurityServiceClient, SecurityServiceClient>();
+        Bootstrapper.Services.AddSingleton<IEstateClient, EstateClient>();
+        Bootstrapper.Services.AddSingleton<ITransactionProcessorClient, TransactionProcessorClient>();
+        Bootstrapper.Services.AddSingleton<Func<String, String>>(container => serviceName => { return jobExecutionContext.MergedJobDataMap.GetString(serviceName); });
+
+        Bootstrapper.ServiceProvider = Bootstrapper.Services.BuildServiceProvider();
+    }
+
+    public static T GetService<T>()
+    {
+        return Bootstrapper.ServiceProvider.GetService<T>();
+    }
+}
+
+public class BaseJob{
+    protected ITransactionDataGenerator CreateTransactionDataGenerator(String clientId, String clientSecret, RunningMode runningMode){
+        ISecurityServiceClient securityServiceClient = Bootstrapper.GetService<ISecurityServiceClient>();
+        IEstateClient estateClient = Bootstrapper.GetService<IEstateClient>();
+        TransactionProcessorClient transactionProcessorClient = Bootstrapper.GetService<TransactionProcessorClient>();
+        Func<String, String> baseAddressFunc = Bootstrapper.GetService<Func<String, String>>();
+
+        ITransactionDataGenerator g = new TransactionDataGenerator(securityServiceClient,
+                                                                   estateClient,
+                                                                   transactionProcessorClient,
+                                                                   baseAddressFunc("EstateManagementApi"),
+                                                                   baseAddressFunc("FileProcessorApi"),
+                                                                   baseAddressFunc("TestHostApi"),
+                                                                   clientId,
+                                                                   clientSecret,
+                                                                   runningMode);
+        return g;
+    }
+
+    protected async Task<String> GetToken(String clientId, String clientSecret, CancellationToken cancellationToken)
+    {
+        ISecurityServiceClient securityServiceClient = Bootstrapper.GetService<ISecurityServiceClient>();
+        TokenResponse token = await securityServiceClient.GetToken(clientId, clientSecret, cancellationToken);
+
+        return token.AccessToken;
+    }
+
+    protected async Task<MerchantResponse> GetMerchant(String accessToken, Guid estateId, Guid merchantId, CancellationToken cancellationToken){
+        IEstateClient estateClient = Bootstrapper.GetService<IEstateClient>();
+        return await estateClient.GetMerchant(accessToken, estateId, merchantId, cancellationToken);
+    }
+}

TransactionProcessing.SchedulerService/TransactionProcessing.SchedulerService.Jobs/GenerateFileUploadsJob.cs

@@ -0,0 +1,43 @@
+namespace TransactionProcessing.SchedulerService.Jobs
+{
+    using System;
+    using System.Collections.Generic;
+    using System.Threading.Tasks;
+    using DataGeneration;
+    using EstateManagement.DataTransferObjects.Responses;
+    using Quartz;
+
+    [DisallowConcurrentExecution]
+    public class GenerateFileUploadsJob : BaseJob, IJob
+    {
+        #region Methods
+        public async Task Execute(IJobExecutionContext context)
+        {
+            Bootstrapper.ConfigureServices(context);
+
+            String clientId = context.MergedJobDataMap.GetString("ClientId");
+            String clientSecret = context.MergedJobDataMap.GetString("ClientSecret");
+            Guid estateId = context.MergedJobDataMap.GetGuidValueFromString("EstateId");
+            Guid merchantId = context.MergedJobDataMap.GetGuidValueFromString("MerchantId");
+
+            String accessToken = await this.GetToken(clientId,
+                                                     clientSecret,
+                                                     context.CancellationToken);
+
+            ITransactionDataGenerator t = CreateTransactionDataGenerator(clientId, clientSecret, RunningMode.Live);
+
+            MerchantResponse merchant = await this.GetMerchant(accessToken, estateId, merchantId, context.CancellationToken);
+
+            List<ContractResponse> contracts = await t.GetMerchantContracts(merchant, context.CancellationToken);
+            DateTime fileDate = DateTime.Now;
+            foreach (ContractResponse contract in contracts){
+                // Generate a file and upload
+                await t.SendUploadFile(fileDate, contract, merchant, context.CancellationToken);
+            }
+        }
+
+
+
+        #endregion
+    }
+}

TransactionProcessing.SchedulerService/TransactionProcessing.SchedulerService.Jobs/GenerateMerchantStatementJob.cs

@@ -0,0 +1,26 @@
+namespace TransactionProcessing.SchedulerService.Jobs;
+
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using DataGeneration;
+using EstateManagement.DataTransferObjects.Responses;
+using Quartz;
+
+public class GenerateMerchantStatementJob : BaseJob, IJob
+{
+    public async Task Execute(IJobExecutionContext context)
+    {
+        Bootstrapper.ConfigureServices(context);
+        String clientId = context.MergedJobDataMap.GetString("ClientId");
+        String clientSecret = context.MergedJobDataMap.GetString("ClientSecret");
+        Guid estateId = context.MergedJobDataMap.GetGuidValueFromString("EstateId");
+
+        ITransactionDataGenerator t = this.CreateTransactionDataGenerator(clientId, clientSecret, RunningMode.Live);
+
+        List<MerchantResponse> merchants = await t.GetMerchants(estateId, context.CancellationToken);
+        foreach (MerchantResponse merchantResponse in merchants){
+            await t.GenerateMerchantStatement(merchantResponse.EstateId, merchantResponse.MerchantId, DateTime.Now, context.CancellationToken);
+        }
+    }
+}