Commit 0481cecb by 泽锋 李

fix

parent 5e5cddb9
...@@ -1272,6 +1272,7 @@ where bailun_sku in @skus", new { skus = skus.Split(',').ToList() }); ...@@ -1272,6 +1272,7 @@ where bailun_sku in @skus", new { skus = skus.Split(',').ToList() });
/// </summary> /// </summary>
public static void ResetFbaExtendSales(DateTime date) public static void ResetFbaExtendSales(DateTime date)
{ {
var conn = _connection;
// 时间点 // 时间点
// 最近1天 // 最近1天
var btime1 = date.AddDays(-1).ToDayHome(); var btime1 = date.AddDays(-1).ToDayHome();
...@@ -1291,7 +1292,7 @@ where bailun_sku in @skus", new { skus = skus.Split(',').ToList() }); ...@@ -1291,7 +1292,7 @@ where bailun_sku in @skus", new { skus = skus.Split(',').ToList() });
while (true) while (true)
{ {
page++; page++;
var configs = _connection.Query<dc_config_fba_extend>($@" select * from dc_config_fba_extend limit {(page - 1) * rows},{rows} ").ToList(); var configs = conn.Query<dc_config_fba_extend>($@" select * from dc_config_fba_extend limit {(page - 1) * rows},{rows} ",commandTimeout:0).ToList();
if (configs == null || configs.Count <= 0) if (configs == null || configs.Count <= 0)
{ {
break; break;
...@@ -1299,7 +1300,7 @@ where bailun_sku in @skus", new { skus = skus.Split(',').ToList() }); ...@@ -1299,7 +1300,7 @@ where bailun_sku in @skus", new { skus = skus.Split(',').ToList() });
foreach (var item in configs) foreach (var item in configs)
{ {
var tempData = _connection.QueryFirstOrDefault<dc_config_fba_extend_temp_dto>($@" var tempData = conn.QueryFirstOrDefault<dc_config_fba_extend_temp_dto>($@"
select t1.bailun_sku,t1.warehouse_code, select t1.bailun_sku,t1.warehouse_code,
sum(case when t1.create_time>=@btime1 and t1.create_time<=@etime1 then t1.amount_sales * t1.order_to_usd_exchange_rate * t1.bailun_sku_quantity_ordered else 0 end) as 'amount_sales_usd_1', sum(case when t1.create_time>=@btime1 and t1.create_time<=@etime1 then t1.amount_sales * t1.order_to_usd_exchange_rate * t1.bailun_sku_quantity_ordered else 0 end) as 'amount_sales_usd_1',
sum(case when t1.create_time>=@btime1 and t1.create_time<=@etime1 then t1.bailun_sku_quantity_ordered else 0 end) as 'bailun_sku_quantity_ordered_1', sum(case when t1.create_time>=@btime1 and t1.create_time<=@etime1 then t1.bailun_sku_quantity_ordered else 0 end) as 'bailun_sku_quantity_ordered_1',
...@@ -1318,7 +1319,7 @@ and t1.bailun_sku=@bailun_sku and t1.warehouse_code=@warehouse_code ...@@ -1318,7 +1319,7 @@ and t1.bailun_sku=@bailun_sku and t1.warehouse_code=@warehouse_code
and bailun_order_status !='Canceled' and bailun_order_status !='Canceled'
and platform_order_type != '手工单' and platform_order_type != '手工单'
", new { btime1, etime1, btime7, etime7, btime30, etime30, item.bailun_sku, item.warehouse_code },commandTimeout:0) ?? new dc_config_fba_extend_temp_dto(); ", new { btime1, etime1, btime7, etime7, btime30, etime30, item.bailun_sku, item.warehouse_code },commandTimeout:0) ?? new dc_config_fba_extend_temp_dto();
_connection.Execute($@" update dc_config_fba_extend set conn.Execute($@" update dc_config_fba_extend set
amount_sales_usd_1=@amount_sales_usd_1, amount_sales_usd_1=@amount_sales_usd_1,
bailun_sku_quantity_ordered_1=@bailun_sku_quantity_ordered_1, bailun_sku_quantity_ordered_1=@bailun_sku_quantity_ordered_1,
amount_sales_usd_7=@amount_sales_usd_7, amount_sales_usd_7=@amount_sales_usd_7,
...@@ -1338,7 +1339,7 @@ where id=@id ...@@ -1338,7 +1339,7 @@ where id=@id
id = item.id id = item.id
}); });
var tempMonthData = _connection.QueryFirstOrDefault<dc_config_fba_extend_temp_dto>($@" var tempMonthData = conn.QueryFirstOrDefault<dc_config_fba_extend_temp_dto>($@"
select t1.bailun_sku,t1.warehouse_code, select t1.bailun_sku,t1.warehouse_code,
sum(case when t1.create_time>=@btime_month_1 and t1.create_time<=@etime_month_1 then t1.amount_sales * t1.order_to_usd_exchange_rate * t1.bailun_sku_quantity_ordered else 0 end) as 'amount_sales_usd_month_1', sum(case when t1.create_time>=@btime_month_1 and t1.create_time<=@etime_month_1 then t1.amount_sales * t1.order_to_usd_exchange_rate * t1.bailun_sku_quantity_ordered else 0 end) as 'amount_sales_usd_month_1',
sum(case when t1.create_time>=@btime_month_1 and t1.create_time<=@etime_month_1 then t1.bailun_sku_quantity_ordered else 0 end) as 'bailun_sku_quantity_ordered_month_1', sum(case when t1.create_time>=@btime_month_1 and t1.create_time<=@etime_month_1 then t1.bailun_sku_quantity_ordered else 0 end) as 'bailun_sku_quantity_ordered_month_1',
...@@ -1355,7 +1356,7 @@ and t1.bailun_sku=@bailun_sku and t1.warehouse_code=@warehouse_code ...@@ -1355,7 +1356,7 @@ and t1.bailun_sku=@bailun_sku and t1.warehouse_code=@warehouse_code
and bailun_order_status !='Canceled' and bailun_order_status !='Canceled'
and platform_order_type != '手工单' and platform_order_type != '手工单'
", new { btime_month_1, etime_month_1, btime_month_2, etime_month_2, item.bailun_sku, item.warehouse_code },commandTimeout:0) ?? new dc_config_fba_extend_temp_dto(); ", new { btime_month_1, etime_month_1, btime_month_2, etime_month_2, item.bailun_sku, item.warehouse_code },commandTimeout:0) ?? new dc_config_fba_extend_temp_dto();
_connection.Execute($@" update dc_config_fba_extend set conn.Execute($@" update dc_config_fba_extend set
amount_sales_usd_month_1=@amount_sales_usd_month_1, amount_sales_usd_month_1=@amount_sales_usd_month_1,
bailun_sku_quantity_ordered_month_1=@bailun_sku_quantity_ordered_month_1, bailun_sku_quantity_ordered_month_1=@bailun_sku_quantity_ordered_month_1,
amount_sales_usd_month_2=@amount_sales_usd_month_2, amount_sales_usd_month_2=@amount_sales_usd_month_2,
......
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