Commit 7492be7a by 泽锋 李

fix

parent da4fe96d
...@@ -704,7 +704,7 @@ left join dc_base_warehouse as dbw on dacp.warehouse_code = dbw.warehouse_code w ...@@ -704,7 +704,7 @@ left join dc_base_warehouse as dbw on dacp.warehouse_code = dbw.warehouse_code w
public static string BatchTortStatus(string ids, int tort_status, UserData user) public static string BatchTortStatus(string ids, int tort_status, UserData user)
{ {
var conn = _connection; var conn = MyMySqlConnection._connection;
conn.Open(); conn.Open();
if (tort_status != 1 && tort_status != 0) if (tort_status != 1 && tort_status != 0)
{ {
...@@ -1565,7 +1565,7 @@ and start_date<=@end_date and end_date>=@start_date ...@@ -1565,7 +1565,7 @@ and start_date<=@end_date and end_date>=@start_date
public static void SaveSalesForecastConfig(Models.dc_auto_sales_forecast_config_dto input_data, string username) public static void SaveSalesForecastConfig(Models.dc_auto_sales_forecast_config_dto input_data, string username)
{ {
var m = input_data.ToJson().ToObject<dc_auto_sales_forecast_config>(); var m = input_data.ToJson().ToObject<dc_auto_sales_forecast_config>();
using (var conn = _connection) using (var conn = MyMySqlConnection._connection)
{ {
conn.Open(); conn.Open();
using (var t = conn.BeginTransaction()) using (var t = conn.BeginTransaction())
......
...@@ -69,7 +69,7 @@ namespace AutoTurnOver.DB ...@@ -69,7 +69,7 @@ namespace AutoTurnOver.DB
public static void GeneratePurchaseAdvise() public static void GeneratePurchaseAdvise()
{ {
using (var conn = _connection) using (var conn = MyMySqlConnection._connection)
{ {
conn.Open(); conn.Open();
using (var t = conn.BeginTransaction()) using (var t = conn.BeginTransaction())
......
...@@ -451,7 +451,7 @@ from dc_auto_turnover as dat ...@@ -451,7 +451,7 @@ from dc_auto_turnover as dat
/// <param name="datas"></param> /// <param name="datas"></param>
public static void AddsSaleSetting(List<dc_auto_config_promotion_input> datas) public static void AddsSaleSetting(List<dc_auto_config_promotion_input> datas)
{ {
var _con = _connection; var _con = MyMySqlConnection._connection;
_con.Open(); _con.Open();
IDbTransaction transaction = _con.BeginTransaction(); IDbTransaction transaction = _con.BeginTransaction();
try try
......
...@@ -193,7 +193,7 @@ where 1=1 ...@@ -193,7 +193,7 @@ where 1=1
{ {
throw new Exception("请选择商品"); throw new Exception("请选择商品");
} }
MyMySqlConnection conn = _connection; MySqlConnection conn = MyMySqlConnection._connection;
conn.Open(); conn.Open();
IDbTransaction transaction = conn.BeginTransaction(); IDbTransaction transaction = conn.BeginTransaction();
try try
...@@ -239,7 +239,7 @@ where t1.sku = t2.bailun_sku and t2.product_inner_code in @product_inner_codes a ...@@ -239,7 +239,7 @@ where t1.sku = t2.bailun_sku and t2.product_inner_code in @product_inner_codes a
{ {
throw new Exception("请选择商品"); throw new Exception("请选择商品");
} }
MyMySqlConnection conn = _connection; MySqlConnection conn = MyMySqlConnection._connection;
conn.Open(); conn.Open();
IDbTransaction transaction = conn.BeginTransaction(); IDbTransaction transaction = conn.BeginTransaction();
try try
......
...@@ -25,7 +25,7 @@ namespace AutoTurnOver.DB ...@@ -25,7 +25,7 @@ namespace AutoTurnOver.DB
{ {
try try
{ {
var conn = _connection; var conn = MyMySqlConnection._connection;
conn.Open(); conn.Open();
int page = 1; int page = 1;
int rows = 10000; int rows = 10000;
...@@ -431,7 +431,7 @@ namespace AutoTurnOver.DB ...@@ -431,7 +431,7 @@ namespace AutoTurnOver.DB
} }
public static void UpdateUsersTest(MyMySqlConnection conn, List<dc_report_cash_flow_log> datas) public static void UpdateUsersTest(MySqlConnection conn, List<dc_report_cash_flow_log> datas)
{ {
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 ;"; 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(); System.Diagnostics.Stopwatch watch = new System.Diagnostics.Stopwatch();
...@@ -440,7 +440,7 @@ namespace AutoTurnOver.DB ...@@ -440,7 +440,7 @@ namespace AutoTurnOver.DB
Console.WriteLine($" 更新 {datas.Count} 条数据,耗时 {watch.ElapsedMilliseconds} 毫秒 "); Console.WriteLine($" 更新 {datas.Count} 条数据,耗时 {watch.ElapsedMilliseconds} 毫秒 ");
} }
public static void BatchInsertDatas(MyMySqlConnection conn, List<dc_report_cash_flow_log> datas) public static void BatchInsertDatas(MySqlConnection conn, List<dc_report_cash_flow_log> datas)
{ {
System.Diagnostics.Stopwatch watch = new System.Diagnostics.Stopwatch(); System.Diagnostics.Stopwatch watch = new System.Diagnostics.Stopwatch();
watch.Start();//开始计时 watch.Start();//开始计时
...@@ -464,7 +464,7 @@ namespace AutoTurnOver.DB ...@@ -464,7 +464,7 @@ namespace AutoTurnOver.DB
{ {
try try
{ {
var conn = _connection; var conn = MyMySqlConnection._connection;
conn.Open(); conn.Open();
int page = 1; int page = 1;
int rows = 5000; int rows = 5000;
......
...@@ -609,7 +609,7 @@ namespace AutoTurnOver.DB ...@@ -609,7 +609,7 @@ namespace AutoTurnOver.DB
public static void Save(dc_report_cash_flow_forecast_task_input_dto input_data) public static void Save(dc_report_cash_flow_forecast_task_input_dto input_data)
{ {
var m = input_data.ToJson().ToObj<dc_report_cash_flow_forecast_task>(); var m = input_data.ToJson().ToObj<dc_report_cash_flow_forecast_task>();
using (var conn = _connection) using (var conn = MyMySqlConnection._connection)
{ {
conn.Open(); conn.Open();
using (var t = conn.BeginTransaction()) using (var t = conn.BeginTransaction())
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment