不合理服务增加是否合理字段

Bailun.DC.Models/dc_mid_month_sale_putin_report.cs

@@ -124,6 +124,10 @@ namespace Bailun.DC.Models
         /// </summary>
         public int? is_aimsorder { get; set; }
 
+        /// <summary>
+        /// 是否合理 ，1：合理，0：不合理
+        /// </summary>
+        public int? is_reasonable { get; set; }
 
         /// <summary>
         /// 出库金额

Bailun.DC.MonthSalePutin/Services.cs

@@ -160,7 +160,7 @@ namespace Bailun.DC.MonthSalePutin
         {
             var sql = "";
 
-            var sql_head = "insert dc_mid_month_sale_putin_report (sale_putin_id,count_usable_stock,avg_sevenday_sales,avg_fourteenday_sales,avg_thirtyday_sales,avg_sales,type,createtime,avg_weighting_day_sales) values ";
+            var sql_head = "insert dc_mid_month_sale_putin_report (sale_putin_id,count_usable_stock,avg_sevenday_sales,avg_fourteenday_sales,avg_thirtyday_sales,avg_sales,type,createtime,avg_weighting_day_sales,is_reasonable) values ";
             var str = "";
             var total = 0;
 
@@ -189,7 +189,7 @@ namespace Bailun.DC.MonthSalePutin
 
                 foreach (var item in list)
                 {
-                    str += $" ({item.sale_putin_id},{item.count_usable_stock},{item.avg_sevenday_sales},{item.avg_fourteenday_sales},{item.avg_thirtyday_sales},{item.avg_sales},1,'{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}',{item.avg_weighting_day_sales}),";
+                    str += $" ({item.sale_putin_id},{item.count_usable_stock},{item.avg_sevenday_sales},{item.avg_fourteenday_sales},{item.avg_thirtyday_sales},{item.avg_sales},1,'{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}',{item.avg_weighting_day_sales},0),";
 
                     if ((total != 0 && total % 5000 == 0) || (total + 1) == list.Count)
                     {
@@ -241,7 +241,7 @@ namespace Bailun.DC.MonthSalePutin
 
                 foreach (var item in list)
                 {
-                    str += $" ({item.sale_putin_id},{item.count_usable_stock},{item.avg_sevenday_sales},{item.avg_fourteenday_sales},{item.avg_thirtyday_sales},{item.avg_sales},1,'{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}',{item.avg_weighting_day_sales}),";
+                    str += $" ({item.sale_putin_id},{item.count_usable_stock},{item.avg_sevenday_sales},{item.avg_fourteenday_sales},{item.avg_thirtyday_sales},{item.avg_sales},1,'{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}',{item.avg_weighting_day_sales},0),";
 
                     if ((total != 0 && total % 5000 == 0) || (total + 1) == list.Count)
                     {
@@ -294,7 +294,7 @@ namespace Bailun.DC.MonthSalePutin
 
                 foreach (var item in list)
                 {
-                    str += $" ({item.sale_putin_id},{item.count_usable_stock},{item.avg_sevenday_sales},{item.avg_fourteenday_sales},{item.avg_thirtyday_sales},{item.avg_sales},1,'{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}',{item.avg_weighting_day_sales}),";
+                    str += $" ({item.sale_putin_id},{item.count_usable_stock},{item.avg_sevenday_sales},{item.avg_fourteenday_sales},{item.avg_thirtyday_sales},{item.avg_sales},1,'{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}',{item.avg_weighting_day_sales},0),";
 
                     if ((total != 0 && total % 5000 == 0) || (total + 1) == list.Count)
                     {
@@ -318,6 +318,60 @@ namespace Bailun.DC.MonthSalePutin
 
             }
 
+            //Add by Allan at 20200225,For 添加合理sku的数据
+            total = 0;
+            str = "";
+            sql = $@"select tb.*,(tb.count_usable_stock/((tb.avg_sevenday_sales+tb.avg_fourteenday_sales+tb.avg_thirtyday_sales)/3)) avg_sales,((tb.avg_sevenday_sales+tb.avg_fourteenday_sales+tb.avg_thirtyday_sales)/3) avg_weighting_day_sales from (
+                    select t1.id as sale_putin_id,if(t3.usable_stock is null,0,t3.usable_stock) count_usable_stock,if(t4.sevenday_average_sales is null,0,t4.sevenday_average_sales) avg_sevenday_sales,if(t4.fourteenday_average_sales is null,0,t4.fourteenday_average_sales) avg_fourteenday_sales,if(t4.thirtyday_average_sales is null,0,thirtyday_average_sales) avg_thirtyday_sales from (select t1.* from dc_mid_month_sale_putin t1
+                    left join dc_mid_month_sale_putin_report t2 on t1.id=t2.sale_putin_id
+                    where t1.month='{month}' and t2.id is null) t1
+                    left join dc_daily_stock t3 on t1.warehouse_code=t3.warehouse_code and t1.bailun_sku=t3.bailun_sku and t3.record_time='{DateTime.Parse(month + "-1").AddMonths(1).AddDays(-1).ToString("yyyy-MM-dd")}'
+                    left join dc_daily_sales t4 on t1.warehouse_code=t4.warehouse_code and t1.bailun_sku=t4.bailun_sku and t4.record_date='{DateTime.Parse(month + "-1").AddMonths(1).AddDays(-1).ToString("yyyy-MM-dd")}'
+                    ) tb";
+
+
+            using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString + "Allow User Variables=True;"))
+            {
+                if (cn.State == System.Data.ConnectionState.Closed)
+                {
+                    cn.Open();
+                }
+
+                var list = cn.Query<dc_mid_month_sale_putin_report>(sql, null, null, true, 10 * 60).AsList();
+
+                cn.Execute($@"delete t1 from dc_mid_month_sale_putin_report t1
+                              join dc_mid_month_sale_putin t2 on t1.sale_putin_id=t2.id and t2.`month`='{month}'
+                              where t1.is_reasonable=1
+                              ");
+
+
+                foreach (var item in list)
+                {
+                    str += $" ({item.sale_putin_id},{item.count_usable_stock},{item.avg_sevenday_sales},{item.avg_fourteenday_sales},{item.avg_thirtyday_sales},{item.avg_sales},1,'{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}',{item.avg_weighting_day_sales},1),";
+
+                    if ((total != 0 && total % 5000 == 0) || (total + 1) == list.Count)
+                    {
+                        if (str.Length > 0)
+                        {
+                            str = str.Substring(0, str.Length - 1);
+
+                            if (cn.State == System.Data.ConnectionState.Closed)
+                            {
+                                cn.Open();
+                            }
+
+                            cn.Execute(sql_head + str);
+
+                            str = "";
+                        }
+                    }
+
+                    total++;
+                }
+
+            }
+
+
         }
 
         /// <summary>