[#32] Documents: Add PaymentVariantSummary

2024-05-07 12:32:53 +02:00
parent 384f7c9ec0
commit 30536819e7
7 changed files with 196 additions and 4 deletions
--- a/Elwig/Models/Dtos/PaymentVariantSummaryData.cs
+++ b/Elwig/Models/Dtos/PaymentVariantSummaryData.cs
@ -0,0 +1,83 @@
+using Elwig.Helpers;
+using Elwig.Models.Entities;
+using Microsoft.EntityFrameworkCore;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.Data.Entity.Core.Common.CommandTrees.ExpressionBuilder;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace Elwig.Models.Dtos {
+    public class PaymentVariantSummaryData {
+
+        public record struct PaymentRow(string Type, string Variety, string? Attribute, string? Cultivation, string QualityLevel, double Oe, int WeightUngeb, decimal? PriceUngeb, int WeightGeb, decimal? PriceGeb, decimal Amount);
+
+        public PaymentRow[] Rows;
+
+        public PaymentVariantSummaryData(PaymentRow[] rows) {
+            Rows = rows;
+        }
+
+        public static async Task<PaymentVariantSummaryData> ForPaymentVariant(PaymentVar v, DbSet<PaymentVariantSummaryRow> table) {
+            return new((await FromDbSet(table, v.Year, v.AvNr))
+                .Select(r => new PaymentRow(r.Type, r.Variety, r.Attribute, r.Cultivation, r.QualityLevel, r.Oe,
+                    r.WeightUngeb, r.PriceUngeb != null ? Utils.DecFromDb(r.PriceUngeb.Value, v.Season.Precision) : null,
+                    r.WeightGeb, r.PriceGeb != null ? Utils.DecFromDb(r.PriceGeb.Value, v.Season.Precision) : null,
+                    Utils.DecFromDb(r.Amount, v.Season.Precision)))
+                .ToArray());
+        }
+
+        private static async Task<IEnumerable<PaymentVariantSummaryRow>> FromDbSet(DbSet<PaymentVariantSummaryRow> table, int year, int avnr) {
+            return await table.FromSqlRaw($"""
+                SELECT v.type AS type,
+                       v.name AS variety,
+                       a.name AS attribute,
+                       c.name AS cultivation,
+                       q.name AS quality_level,
+                       ROUND(kmw * (4.54 + 0.022 * kmw)) AS oe,
+                       SUM(IIF(w.discr = '_', w.value, 0)) AS weight_ungeb,
+                       MAX(IIF(w.discr = '_', b.price, NULL)) AS price_ungeb,
+                       SUM(IIF(w.discr != '_', w.value, 0)) AS weight_geb,
+                       MAX(IIF(w.discr != '_', b.price, NULL)) AS price_geb,
+                       SUM(b.amount) AS amount
+                FROM payment_delivery_part_bucket b
+                    LEFT JOIN delivery_part_bucket w ON (w.year, w.did, w.dpnr, w.bktnr) = (b.year, b.did, b.dpnr, b.bktnr)
+                    LEFT JOIN delivery_part p ON (p.year, p.did, p.dpnr) = (b.year, b.did, b.dpnr)
+                    LEFT JOIN delivery d ON (d.year, d.did) = (p.year, p.did)
+                    LEFT JOIN wine_variety v ON v.sortid = p.sortid
+                    LEFT JOIN wine_attribute a ON a.attrid = p.attrid
+                    LEFT JOIN wine_cultivation c ON c.cultid = p.cultid
+                    LEFT JOIN wine_quality_level q ON q.qualid = p.qualid
+                WHERE d.year = {year} AND b.avnr = {avnr}
+                GROUP BY variety, attribute, cultivation, q.min_kmw, oe
+                ORDER BY variety, attribute, cultivation, q.min_kmw, oe
+                """).ToListAsync();
+        }
+    }
+
+    [Keyless]
+    public class PaymentVariantSummaryRow {
+        [Column("type")]
+        public required string Type { get; set; }
+        [Column("variety")]
+        public required string Variety { get; set; }
+        [Column("attribute")]
+        public string? Attribute { get; set; }
+        [Column("cultivation")]
+        public string? Cultivation { get; set; }
+        [Column("quality_level")]
+        public required string QualityLevel { get; set; }
+        [Column("oe")]
+        public double Oe { get; set; }
+        [Column("weight_ungeb")]
+        public int WeightUngeb { get; set; }
+        [Column("price_ungeb")]
+        public long? PriceUngeb { get; set; }
+        [Column("weight_geb")]
+        public int WeightGeb { get; set; }
+        [Column("price_geb")]
+        public long? PriceGeb { get; set; }
+        [Column("amount")]
+        public long Amount { get; set; }
+    }
+}