调整成品仓每日进销存服务

Bailun.DC.DailyPurchaseSellStock/Program.cs

@@ -7,31 +7,31 @@ namespace Bailun.DC.DailyPurchaseSellStock
 {
     class Program
     {
-        //static async Task Main(string[] args)
-        //{
-        //    Console.WriteLine("启动服务 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
-        //    var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
-        //    {
-        //        services.AddHostedService<Services>();
-        //    });
+        static async Task Main(string[] args)
+        {
+            Console.WriteLine("启动服务 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
+            var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
+            {
+                services.AddHostedService<Services>();
+            });
 
-        //    await builder.RunConsoleAsync();
-        //}
+            await builder.RunConsoleAsync();
+        }
 
-        static void Main(string[] args)
-        {
-            var _services = new Services();
+        //static void Main(string[] args)
+        //{
+        //    var _services = new Services();
 
-            var start = DateTime.Parse("2020-07-31");
-            _services.Init(start);
+        //    var start = DateTime.Parse("2020-08-03");
+        //    //_services.Init(start);
 
-            //while (start.AddDays(1) < DateTime.Now)
-            //{
-            //    Console.WriteLine(start);
-            //    _services.Init(start);
-            //    start = start.AddDays(1);
-            //}
-        }
+        //    while (start.AddDays(1) < DateTime.Now)
+        //    {
+        //        Console.WriteLine(start);
+        //        _services.Init(start);
+        //        start = start.AddDays(1);
+        //    }
+        //}
     }
     
 }

Bailun.DC.DailyPurchaseSellStock/Services.cs

@@ -67,13 +67,13 @@ namespace Bailun.DC.DailyPurchaseSellStock
                     }
 
                     var page = 1;
-                    var pagesize = 3000;
+                    var pagesize = 5000;
 
 
                     //昨日库存
-                    sql = $@"select t1.bailun_sku,t1.warehouse_code,t2.warehouse_name,sum(t1.usable_stock+t1.occupy_stock) count,sum((t1.usable_stock+t1.occupy_stock)*t1.unit_price) as amount from dc_daily_stock t1 
+                    sql = $@"select t1.bailun_sku,t1.warehouse_code,t2.warehouse_name,(t1.usable_stock+t1.occupy_stock) count,((t1.usable_stock+t1.occupy_stock)*t1.unit_price) as amount from dc_daily_stock t1 
                         left join dc_base_warehouse t2 on t1.warehouse_code=t2.warehouse_code
-                        where t1.record_time='{day.AddDays(-1).ToString("yyyy-MM-dd")}' group by t1.bailun_sku,t1.warehouse_code";
+                        where t1.record_time='{day.AddDays(-1).ToString("yyyy-MM-dd")}'";
                     var temp = cn.Query<mStock>(sql + " limit " + (page - 1) * pagesize + "," + pagesize, null, null, true, 2 * 60);
                     while (temp.Count() > 0)
                     {
@@ -85,11 +85,11 @@ namespace Bailun.DC.DailyPurchaseSellStock
 
                     //在库库存
                     page = 1;
-                    pagesize = 3000;
+                    pagesize = 5000;
                     
-                    sql = $@"select t1.bailun_sku,t1.warehouse_code,t2.warehouse_name,sum(t1.usable_stock+t1.occupy_stock) count,sum((t1.usable_stock+t1.occupy_stock)*t1.unit_price) as amount from dc_daily_stock t1 
+                    sql = $@"select t1.bailun_sku,t1.warehouse_code,t2.warehouse_name,(t1.usable_stock+t1.occupy_stock) count,((t1.usable_stock+t1.occupy_stock)*t1.unit_price) as amount from dc_daily_stock t1 
                         left join dc_base_warehouse t2 on t1.warehouse_code=t2.warehouse_code
-                        where t1.record_time='{day.ToString("yyyy-MM-dd")}' group by t1.bailun_sku,t1.warehouse_code";
+                        where t1.record_time='{day.ToString("yyyy-MM-dd")}'";
                     temp = cn.Query<mStock>(sql + " limit " + (page - 1) * pagesize + "," + pagesize, null, null, true, 2 * 60);
                     while (temp.Count() > 0)
                     {