fix

AutoTurnOver.DB/Base/DbHelper.cs

@@ -210,26 +210,15 @@ namespace AutoTurnOver.DB.Base
         /// <param name="connectionString">目标连接字符</param>
         /// <param name="TableName">目标表</param>
         /// <param name="dt">源数据</param>
-        public static int BatchInsert<T>(this MySqlConnection conn,IList<T> list, string tableName)
+        public static int BatchInsert<T>(this MySqlConnection _conn,IList<T> list, string tableName)
         {
             System.Diagnostics.Stopwatch watch = new System.Diagnostics.Stopwatch();
             watch.Start();//开始计时
-            var connectionString = conn.ConnectionString;
-            var sourceTable = DataTableExtensions.ToDataTable<T>(list);
+            var table = DataTableExtensions.ToDataTable<T>(list);
             int insertCount = 0;
-            int pageIndex = 1;
-            int pageSize = 500000;
-            while (true)
+            using (var conn = new MySqlConnection(connectionHelper.connStr))
             {
-                DataTable table = DtSelectTop((pageIndex - 1) * pageSize, pageIndex * pageSize, sourceTable);
-
-                if (table.Rows.Count <= 0)
-                    break;
-
-                pageIndex++;
-
-                if (table.Rows.Count == 0) return 0;
-                string tmpPath = Guid.NewGuid()+".csv";
+                string tmpPath = Guid.NewGuid() + ".csv";
                 Console.WriteLine(tmpPath);
                 string csv = DataTableToCsv(table);
                 File.WriteAllText(tmpPath, csv);

AutoTurnOver.DB/report_cash_flow_dao.cs

@@ -407,7 +407,6 @@ namespace AutoTurnOver.DB
 
         }
 
-
         public static void UpdateUsersTest(MySqlConnection conn, List<dc_report_cash_flow_log> datas)
         {
             var sql = @"UPDATE dc_report_cash_flow_log SET warehouse_code=@warehouse_code,platform_type=@platform_type,bailun_sku=@bailun_sku,data_type=@data_type,pay_type=@pay_type,val=@val,occur_time=@occur_time,pay_time=@pay_time,no=@no,item=@item,item_no=@item_no,remarks=@remarks,is_delete=@is_delete,update_time=@update_time,occur_time_year_month_no=@occur_time_year_month_no,pay_time_year_month_no=@pay_time_year_month_no WHERE id = @id ;";

ResetOutofstock/Program.cs

@@ -14,17 +14,17 @@ namespace ResetOutofstock
         {
             Console.WriteLine("刷新缺货数据任务启动...");
             //report_cash_flow_dao.CalculationOrderCostLogistics(now.AddMonths(-3), DateTime.Parse(now.AddDays(-1).ToString("yyyy-MM-dd 23:59:59")));
-            //try
-            //{
-            //    var now = DateTime.Now;
-            //    report_cash_flow_dao.CalculationOrder(now.AddMonths(-3), DateTime.Parse(now.ToString("yyyy-MM-dd 23:59:59")));
-            //}
-            //catch (Exception ex)
-            //{
+            try
+            {
+                var now = DateTime.Now;
+                report_cash_flow_dao.CalculationOrder(now.AddMonths(-3), DateTime.Parse(now.ToString("yyyy-MM-dd 23:59:59")));
+            }
+            catch (Exception ex)
+            {
+
+                throw;
+            }
 
-            //    throw;
-            //}
-           
             var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
             {
                 services.AddHostedService<ResetOutofstockBackgrounService>();