改低现金流服务的刷新频率

AutoTurnOver.DB/report_cash_flow_dao.cs

@@ -413,11 +413,11 @@ namespace AutoTurnOver.DB
                     Console.WriteLine($" 开始写入第 {page} 页数据 ， 预计 写入 {addList.Count} 条 ， 更新 {updateList.Count} 条, 最大id {updateList.Max(s => s.item_no)}, 最小id {updateList.Min(s => s.item_no)} ");
                     if (addList != null && addList.Count >= 1)
                     {
-                        BatchInsertDatas(conn, addList);
+                        BatchInsertDatas( addList);
                     }
                     if (updateList != null && updateList.Count >= 1)
                     {
-                        UpdateUsersTest(conn, updateList);
+                        UpdateUsersTest( updateList);
                     }
 
                 }
@@ -431,8 +431,9 @@ namespace AutoTurnOver.DB
 
         }
 
-        public static void UpdateUsersTest(MySqlConnection conn, List<dc_report_cash_flow_log> datas)
+        public static void UpdateUsersTest(List<dc_report_cash_flow_log> datas)
         {
+            var conn = MyMySqlConnection._connection;
             var sql = @"UPDATE dc_report_cash_flow_log SET web_site=@web_site,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 ;";
             System.Diagnostics.Stopwatch watch = new System.Diagnostics.Stopwatch();
             watch.Start();//开始计时
@@ -440,8 +441,9 @@ namespace AutoTurnOver.DB
             Console.WriteLine($" 更新 {datas.Count} 条数据，耗时 {watch.ElapsedMilliseconds} 毫秒 ");
         }
 
-        public static void BatchInsertDatas(MySqlConnection conn, List<dc_report_cash_flow_log> datas)
+        public static void BatchInsertDatas( List<dc_report_cash_flow_log> datas)
         {
+           var conn = MyMySqlConnection._connection;
             System.Diagnostics.Stopwatch watch = new System.Diagnostics.Stopwatch();
             watch.Start();//开始计时
             StringBuilder sqlSb = new StringBuilder(@" insert into dc_report_cash_flow_log(`web_site`,`warehouse_code`,`platform_type`,`bailun_sku`,`data_type`,`pay_type`,`val`,`occur_time`,`pay_time`,`no`,`item`,`item_no`,`remarks`,`is_delete`,`update_time`,`occur_time_year_month_no`,`pay_time_year_month_no`)  value ");
@@ -574,11 +576,11 @@ namespace AutoTurnOver.DB
 
                     if (addList != null && addList.Count >= 1)
                     {
-                        BatchInsertDatas(conn, addList);
+                        BatchInsertDatas( addList);
                     }
                     if (updateList != null && updateList.Count >= 1)
                     {
-                        UpdateUsersTest(conn, updateList);
+                        UpdateUsersTest( updateList);
                     }
                 }
             }