调整平台订单利润率一天的时间长度；调整物流供应商往来统计服务

Bailun.DC.DailyItemNoProfitRate/Services.cs

@@ -37,7 +37,7 @@ namespace Bailun.DC.DailyItemNoProfitRate
                     Init(day.AddDays(-20),day);
 
                     Console.WriteLine("开始生成一天的itemno利润率" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-                    OneDayItemNoProfitRate(day.AddDays(-2), day);
+                    OneDayItemNoProfitRate(day.AddDays(-1), day);
 
                     Console.WriteLine("任务运行完成 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
 
@@ -53,7 +53,7 @@ namespace Bailun.DC.DailyItemNoProfitRate
                 Init(day.AddDays(-20), day);
 
                 Console.WriteLine("开始生成一天的itemno利润率" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-                OneDayItemNoProfitRate(day.AddDays(-2), day);
+                OneDayItemNoProfitRate(day.AddDays(-1), day);
 
             }
 

Bailun.DC.DailyLogisticSupplierTransaction/Program.cs

@@ -27,7 +27,10 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction
         {
             var _services = new Services();
 
-            var start = DateTime.Parse("2020-09-01");
+            var start = DateTime.Parse("2020-11-01");
+            _services.Init(start);
+
+            return;
             while (start.AddDays(1) < DateTime.Now)
             {
                 Console.WriteLine(start);

Bailun.DC.DailyLogisticSupplierTransaction/Services.cs

@@ -73,7 +73,7 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction
             var list = new List<dc_daily_logistics_supplier_transaction>();
 
             
-            using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
+            using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString_read))
             {
                 if (cn.State == System.Data.ConnectionState.Closed)
                 {
@@ -316,31 +316,34 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction
             foreach(var item in listMerge)
             {
                 var listObj = list.Where(a => a.suppliername == item.Key || item.Select(a => a.suppliername).Contains(a.suppliername));
-
-                var newObj = new dc_daily_logistics_supplier_transaction()
+                if(listObj.Count()>0)
                 {
-                    amount_happen = listObj.Count() > 0 ? listObj.Sum(a => a.amount_happen) : 0,
-                    amount_pay = listObj.Count() > 0 ? listObj.Sum(a => a.amount_pay) : 0,
-                    amount_receipt = listObj.Count() > 0 ? listObj.Sum(a => a.amount_receipt) : 0,
-                    amount_other = listObj.Count() > 0 ? listObj.Sum(a => a.amount_other) : 0,
-
-                    suppliername = item.Key,
-                    supplierid = 0,
-                    amount_end = 0,
-                    amount_start = 0,
-                    createtime = DateTime.Now,
-                    day = list.FirstOrDefault().day,
-                    lastupdatetime = DateTime.Now,
-                    lastupdateuserid = 0,
-                    lastupdateusername = "admin"
-                };
-
-                foreach(var o in listObj)
-                {
-                    list.Remove(o);
-                }
+                    var newObj = new dc_daily_logistics_supplier_transaction()
+                    {
+                        amount_happen = listObj.Count() > 0 ? listObj.Sum(a => a.amount_happen) : 0,
+                        amount_pay = listObj.Count() > 0 ? listObj.Sum(a => a.amount_pay) : 0,
+                        amount_receipt = listObj.Count() > 0 ? listObj.Sum(a => a.amount_receipt) : 0,
+                        amount_other = listObj.Count() > 0 ? listObj.Sum(a => a.amount_other) : 0,
+
+                        suppliername = item.Key,
+                        supplierid = 0,
+                        amount_end = 0,
+                        amount_start = 0,
+                        createtime = DateTime.Now,
+                        day = list.FirstOrDefault().day,
+                        lastupdatetime = DateTime.Now,
+                        lastupdateuserid = 0,
+                        lastupdateusername = "admin"
+                    };
 
-                list.Add(newObj);
+                    foreach (var o in listObj)
+                    {
+                        list.Remove(o);
+                    }
+
+                    list.Add(newObj);
+                }
+                
             }