feat: update policy created message model

Author: petrukhinandrew

DashboardService.Test/PolicyDocumentBuilder.cs

@@ -8,6 +8,7 @@ public class PolicyDocumentBuilder
     private readonly string policyHolder;
     private string agentLogin;
     private DateTime from;
+    private DateTime salesDate;
     private string number;
     private string productCode;
     private DateTime to;
@@ -18,6 +19,7 @@ public PolicyDocumentBuilder()
         number = Guid.NewGuid().ToString();
         from = new DateTime(2020, 1, 1);
         to = from.AddYears(1).AddDays(-1);
+        salesDate = from;
         policyHolder = "Jan Test";
         productCode = "TRI";
         totalPremium = 100M;
@@ -39,6 +41,13 @@ public PolicyDocumentBuilder WithDates(string start, string end)
     {
         from = DateTime.Parse(start);
         to = DateTime.Parse(end);
+        salesDate = from;
+        return this;
+    }
+
+    public PolicyDocumentBuilder WithSalesDate(string date)
+    {
+        salesDate = DateTime.Parse(date);
         return this;
     }
 
@@ -67,6 +76,7 @@ public PolicyDocument Build()
             number,
             from,
             to,
+            salesDate,
             policyHolder,
             productCode,
             totalPremium,

DashboardService/DataAccess/InMemory/LucenePolicyRepository.cs

@@ -38,6 +38,9 @@ public void Save(PolicyDocument policy)
                 new StringField("agentLogin", policy.AgentLogin ?? string.Empty, Field.Store.YES),
                 new StringField("productCode", policy.ProductCode ?? string.Empty, Field.Store.YES),
                 new StringField("from", policy.From.ToString("o", CultureInfo.InvariantCulture), Field.Store.YES),
+                new StringField("to", policy.To.ToString("o", CultureInfo.InvariantCulture), Field.Store.YES),
+                new StringField("salesDate", policy.SalesDate.ToString("o", CultureInfo.InvariantCulture), Field.Store.YES),
+                new StringField("policyHolder", policy.PolicyHolder ?? string.Empty, Field.Store.YES),
                 new DoubleField("totalPremium", Convert.ToDouble(policy.TotalPremium), Field.Store.YES)
             };
 
@@ -94,7 +97,7 @@ public SalesTrendsResult GetSalesTrend(SalesTrendsQuery query)
         var docs = SearchByFilters(null, query.FilterByProductCode, query.FilterBySalesDateStart, query.FilterBySalesDateEnd);
             var periods = docs.GroupBy(d =>
         {
-            var dt = DateTime.Parse(d.Get("from"), null, DateTimeStyles.RoundtripKind);
+            var dt = DateTime.Parse(d.Get("salesDate"), null, DateTimeStyles.RoundtripKind);
             return query.AggregationUnit switch
             {
                 TimeAggregationUnit.Month => new DateTime(dt.Year, dt.Month, 1),
@@ -145,7 +148,7 @@ private IEnumerable<Document> SearchByFilters(string agentLogin, string productC
         {
             docs = docs.Where(d =>
             {
-                var dt = DateTime.Parse(d.Get("from"), null, DateTimeStyles.RoundtripKind);
+                var dt = DateTime.Parse(d.Get("salesDate"), null, DateTimeStyles.RoundtripKind);
                 if (fromDate != default && dt < fromDate) return false;
                 if (toDate != default && dt > toDate) return false;
                 return true;
@@ -159,13 +162,14 @@ private static PolicyDocument DocToPolicy(Document doc)
     {
         var number = doc.Get("number");
         var from = DateTime.Parse(doc.Get("from"), null, DateTimeStyles.RoundtripKind);
-        var to = from.AddYears(1).AddDays(-1);
-        var insured = doc.Get("insuredName");
+        var to = DateTime.Parse(doc.Get("to"), null, DateTimeStyles.RoundtripKind);
+        var salesDate = DateTime.Parse(doc.Get("salesDate"), null, DateTimeStyles.RoundtripKind);
+        var insured = doc.Get("policyHolder");
         var product = doc.Get("productCode");
         var premium = Convert.ToDecimal(doc.Get("totalPremium"));
         var agent = doc.Get("agentLogin");
 
-        return new PolicyDocument(number, from, to, insured, product, premium, agent);
+        return new PolicyDocument(number, from, to, salesDate, insured, product, premium, agent);
     }
 
     public void Dispose()

DashboardService/Domain/PolicyDocument.cs

@@ -4,12 +4,13 @@ namespace DashboardService.Domain;
 
 public class PolicyDocument
 {
-    public PolicyDocument(string number, DateTime from, DateTime to, string policyHolder, string productCode,
-        decimal totalPremium, string agentLogin)
+    public PolicyDocument(string number, DateTime from, DateTime to, DateTime salesDate, string policyHolder, 
+        string productCode, decimal totalPremium, string agentLogin)
     {
         Number = number;
         From = from;
         To = to;
+        SalesDate = salesDate;
         PolicyHolder = policyHolder;
         ProductCode = productCode;
         TotalPremium = totalPremium;
@@ -19,6 +20,7 @@ public PolicyDocument(string number, DateTime from, DateTime to, string policyHo
     public string Number { get; }
     public DateTime From { get; }
     public DateTime To { get; }
+    public DateTime SalesDate { get; }
     public string PolicyHolder { get; }
     public string ProductCode { get; }
     public decimal TotalPremium { get; }

DashboardService/Init/SalesData.cs

@@ -34,11 +34,13 @@ public async Task SeedData()
 
             for (var index = 0; index < policies; index++)
             {
+                var salesDate = new DateTime(startMonth.Year, startMonth.Month, 1);
                 var policy = new PolicyDocument
                 (
                     Guid.NewGuid().ToString(),
-                    new DateTime(startMonth.Year, startMonth.Month, 1),
-                    new DateTime(startMonth.Year, startMonth.Month, 1).AddYears(1).AddDays(-1),
+                    salesDate,
+                    salesDate.AddYears(1).AddDays(-1),
+                    salesDate,
                     "Anonymous Mike",
                     product,
                     100M,

DashboardService/Listeners/PolicyCreatedHandler.cs

@@ -22,6 +22,7 @@ public Task Handle(PolicyCreated notification, CancellationToken cancellationTok
             notification.PolicyNumber,
             notification.PolicyFrom,
             notification.PolicyTo,
+            notification.SalesDate,
             $"{notification.PolicyHolder.FirstName} {notification.PolicyHolder.LastName}",
             notification.ProductCode,
             notification.TotalPremium,

PolicyService.Api/Events/PolicyCreated.cs

@@ -10,6 +10,7 @@ public class PolicyCreated : INotification
     public string ProductCode { get; set; }
     public DateTime PolicyFrom { get; set; }
     public DateTime PolicyTo { get; set; }
+    public DateTime SalesDate { get; set; }
     public PersonDto PolicyHolder { get; set; }
     public decimal TotalPremium { get; set; }
     public string AgentLogin { get; set; }

PolicyService/Commands/CreatePolicyHandler.cs

@@ -1,7 +1,6 @@
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
-using FluentValidation;
 using MediatR;
 using PolicyService.Api.Commands;
 using PolicyService.Api.Commands.Dtos;
@@ -64,6 +63,7 @@ private static PolicyCreated PolicyCreated(Policy policy)
             PolicyNumber = policy.Number,
             PolicyFrom = version.CoverPeriod.ValidFrom,
             PolicyTo = version.CoverPeriod.ValidTo,
+            SalesDate = policy.CreationDate,
             ProductCode = policy.ProductCode,
             TotalPremium = version.TotalPremiumAmount,
             PolicyHolder = new PersonDto