司南聚合-创意/SKU推广维度增加产品维度聚合

SiNan.Business/AggregationBusiness.cs

@@ -798,6 +798,7 @@ namespace SiNan.Business
 
             List<AggregationJDPopularizeAdSkuDaily> insertAggregationAdSkuDailyList = new List<AggregationJDPopularizeAdSkuDaily>();
             var aggregationDate_PopularizeLevelList = goiBusiness.CalculationAdSkuLevelGOI(adSkuIdList, startDate_aggregationDate, endDate_aggregationDate);
+            var aggregationDate_ProductLevelList = goiBusiness.CalculationAdSkuProductLevelGOI(adSkuIdList, startDate_aggregationDate, endDate_aggregationDate);
 
             var adSkuIndex = 0;
             foreach (var adSku in adSkuList)
@@ -805,10 +806,11 @@ namespace SiNan.Business
                 adSkuIndex++;
                 Console.WriteLine($"{DateTime.Now} {shopName} SKU聚合 {adSkuIndex}/{adSkuIdList.Count()}");
 
-                #region 处理计划每日聚合
+                #region 处理SKU每日聚合
                 var adSkuGoi_AggregationDate_PopularizeLevel = aggregationDate_PopularizeLevelList.FirstOrDefault(x => x.Sku == adSku.Sku && x.BusinessType == adSku.BusinessType);
+                var adSkuGoi_AggregationDate_ProductLevel = aggregationDate_ProductLevelList.FirstOrDefault(x => x.Sku == adSku.Sku && x.BusinessType == adSku.BusinessType);
 
-                if (adSkuGoi_AggregationDate_PopularizeLevel != null)
+                if (adSkuGoi_AggregationDate_PopularizeLevel != null || adSkuGoi_AggregationDate_ProductLevel != null)
                 {
                     var adSkuDailyAggregation = new AggregationJDPopularizeAdSkuDaily()
                     {
@@ -819,6 +821,8 @@ namespace SiNan.Business
                         Cost = adSkuGoi_AggregationDate_PopularizeLevel?.Cost ?? 0M,
                         PopularizeLevelProfit = adSkuGoi_AggregationDate_PopularizeLevel?.Profit ?? 0M,
                         PopularizeLevelGOI = adSkuGoi_AggregationDate_PopularizeLevel?.GOI ?? 0M,
+                        ProductLevelProfit = adSkuGoi_AggregationDate_ProductLevel?.Profit ?? 0M,
+                        ProductLevelGOI = adSkuGoi_AggregationDate_ProductLevel?.GOI ?? 0M,
                         AdGroupId = adSku.AdGroupId,
                         CampaignId = adSku.CampaignId,
                         BusinessType = adSku.BusinessType,
@@ -834,7 +838,6 @@ namespace SiNan.Business
             {
                 fsql.Delete<AggregationJDPopularizeAdSkuDaily>().Where(s => s.Date == aggregationDate && adSkuIdList.Contains(s.SkuId)).ExecuteAffrows();
                 fsql.Insert(insertAggregationAdSkuDailyList).ExecuteAffrows();
-
             });
         }
         #endregion

SiNan.Business/GOIBusiness.cs

@@ -253,6 +253,62 @@ namespace SiNan.Business
             return list;
         }
 
+        public IList<GOIByAdSku> CalculationAdSkuProductLevelGOI(IList<string> skuIdList, DateTime startDate, DateTime endDate)
+        {
+            var costs = fsql.Select<JDPopularizeAdSku>()
+                                   .Where(jas => skuIdList.Contains(jas.Sku) && jas.Date >= startDate && jas.Date <= endDate)
+                                   .GroupBy(jas => new { jas.Sku, jas.BusinessType })
+                                   .ToList(g => new
+                                   {
+                                       Cost = g.Sum(g.Value.Cost),
+                                       Sku = g.Key.Sku,
+                                       BusinessType = g.Key.BusinessType
+                                   });
+
+            var profits = fsql.Select<OrderCostDetail, Order>()
+                              .InnerJoin((ocd, o) => ocd.OrderId == o.Id)
+                              .Where((ocd, o) => skuIdList.Contains(ocd.SkuId) &&
+                                            ocd.IsEnabled &&
+                                            o.StartTime >= startDate &&
+                                            o.StartTime <= endDate &&
+                                            o.OrderState != Enums.OrderState.已取消 &&
+                                            o.IsGift == false)
+                              .GroupBy((ocd, o) => ocd.SkuId)
+                              .ToList(g => new
+                              {
+                                  Profit = g.Sum(g.Value.Item1.SkuGrossProfit),
+                                  Sku = g.Key
+                              });
+
+            IList<GOIByAdSku> list = new List<GOIByAdSku>();
+            foreach (var skuId in skuIdList)
+            {
+                {
+                    var cost = costs.FirstOrDefault(x => x.Sku == skuId && x.BusinessType == 2)?.Cost ?? 0M;
+                    var profit = profits.FirstOrDefault(x => x.Sku == skuId)?.Profit ?? 0M;
+
+                    if (cost != 0 || profit != 0)
+                    {
+                        var adskuGoi = new GOIByAdSku() { Sku = skuId, Cost = cost, Profit = profit, BusinessType = 2 };
+                        list.Add(adskuGoi);
+                    }
+
+                }
+
+                {
+                    var cost = costs.FirstOrDefault(x => x.Sku == skuId && x.BusinessType == 134217728)?.Cost ?? 0M;
+                    var profit = profits.FirstOrDefault(x => x.Sku == skuId)?.Profit ?? 0M;
+                    if (cost != 0 || profit != 0)
+                    {
+                        var adskuGoi = new GOIByAdSku() { Sku = skuId, Cost = cost, Profit = profit, BusinessType = 134217728 };
+                        list.Add(adskuGoi);
+                    }
+                }
+
+            }
+            return list;
+        }
+
         //public ListResponse<ProductGOIResponse> QueryProductGOI(QueryProductGOIRequest request)
         //{
         //    if (request.ShopId == 0)

SiNan.Model/Db/Aggregation/AggregationJDPopularizeAdSkuDaily.cs

@@ -61,6 +61,18 @@ namespace SiNan.Model.Db
         [Column(DbType = "decimal(18,2)")]
         public decimal? PopularizeLevelProfit { get; set; }
 
+        /// <summary>
+        /// 产品维度GOI
+        /// </summary>
+        [Column(DbType = "decimal(18,2)")]
+        public decimal? ProductLevelGOI { get; set; }
+
+        /// <summary>
+        /// 产品维度毛利
+        /// </summary>
+        [Column(DbType = "decimal(18,2)")]
+        public decimal? ProductLevelProfit { get; set; }
+
         [Column(DbType = "bigint")]
         public long? ShopId { get; set; }