Skip to content

D
data-center-auto
Commit fb550145 by 泽锋 李
Options

调整任务刷新的频率

parent c153ada1
Showing with 120 additions and 102 deletions
AutoTurnOver.DB/report.cs
......@@ -1591,7 +1591,6 @@ t1.bailun_sku,
from dc_base_sku as t1
);", commandTimeout: 0);
_connection.Execute(@"
set session transaction isolation level read uncommitted;
start transaction;
......@@ -1674,36 +1673,103 @@ alter table dc_view_stock_monitor_sku_temp rename dc_view_stock_monitor_sku;
alter table dc_view_stock_monitor_skuTemp rename dc_view_stock_monitor_sku_temp;
truncate table dc_view_stock_monitor_sku_temp; ", commandTimeout: 0);
_connection.Execute(@" -- 刷新 全量库存表
// _connection.Execute(@" -- 刷新sku汇总
//set session transaction isolation level read uncommitted;
//start transaction;
//-- 清空视图表的数据
//Truncate table dc_base_sku_sum_temp;
//insert into dc_base_sku_sum_temp(`bailun_sku`,
// `usable_stock`,
// `on_the_way`,
// `stock_amount`,
// `on_the_way_amount` ,
// `history_sevenday_sales`,
// `history_fourteenday_sales`,
// `history_thirtyday_sales`)
// (
// select t1.bailun_sku,sum(t1.usable_stock) as 'usable_stock',sum(ifnull(t5.quantity_transfer,0)+ifnull(t5.quantity_purchase,0)) as 'on_the_way',
//sum(ifnull(t1.usable_stock,0) * ifnull(t2.unit_price,0)) as 'stock_amount',(ifnull(t5.quantity_transfer,0)+ifnull(t5.quantity_purchase,0)) as 'on_the_way_amount',
//AVG(ifnull(t8.history_sevenday_sales,0)) as 'history_sevenday_sales',AVG(ifnull(t8.history_fourteenday_sales,0)) as 'history_fourteenday_sales',AVG(ifnull(t8.history_thirtyday_sales,0)) as 'history_thirtyday_sales'
//from
//dc_base_stock as t1
//left join dc_base_sku as t2 on t1.bailun_sku=t2.bailun_sku
//left join dc_mid_transit as t5 on t1.bailun_sku = t5.bailun_sku and t1.warehouse_code = t5.warehouse_code
//left join dc_auto_config_sku_warehouse as t7 on t1.bailun_sku = t7.bailun_sku and t1.warehouse_code = t7.warehouse_code
//left join dc_auto_turnover as t8 on t1.bailun_sku = t8.bailun_sku and t1.warehouse_code = t8.warehouse_code
//group by t1.bailun_sku
// );
//alter table dc_base_sku_sum rename dc_base_sku_sumTemp;
//alter table dc_base_sku_sum_temp rename dc_base_sku_sum;
//alter table dc_base_sku_sumTemp rename dc_base_sku_sum_temp;
//truncate table dc_base_sku_sum_temp;
//", commandTimeout: 0);
_connection.Execute(@" -- 刷新sku汇总
set session transaction isolation level read uncommitted;
start transaction;
-- 清空视图表的数据
Truncate table dc_base_full_stock_temp;
Truncate table dc_base_data_character_temp;
INSERT into dc_base_full_stock_temp(`warehouse_type`,`warehouse_code`,`bailun_sku`,`usable_stock`,`quantity_safe_inventory`,`sku_name`,`unit_price`)
(
select * from (
select
t3.hq_type as 'warehouse_type',t2.warehouse_code,t2.bailun_sku,t2.usable_stock,ifnull(t1.quantity_safe_inventory,0) as 'quantity_safe_inventory',
ifnull(t4.sku_title_cn,'') as 'sku_name',ifnull(t4.unit_price,0) as 'unit_price'
from dc_base_stock as t2
left join dc_auto_turnover as t1 on t1.bailun_sku = t2.bailun_sku and t1.warehouse_code = t2.warehouse_code
left join dc_base_warehouse as t3 on t2.warehouse_code = t3.warehouse_code
left join dc_base_sku as t4 on t2.bailun_sku = t4.bailun_sku
insert into dc_base_data_character_temp(`character`, `bailun_sku`, `warehouse_code`,`bailun_sku_warehouse_code`)
select '无库' as 'character',bailun_sku,warehouse_code,CONCAT(bailun_sku,warehouse_code) as 'bailun_sku_warehouse_code' from dc_base_stock where warehouse_code in ('BLGZ03','YWWH01');
union
insert into dc_base_data_character_temp(`character`, `bailun_sku`, `warehouse_code`,`bailun_sku_warehouse_code`)
select '自产' as 'character',t1.bailun_sku,t1.warehouse_code,CONCAT(t1.bailun_sku,t1.warehouse_code) as 'bailun_sku_warehouse_code' from dc_base_stock as t1 left join dc_base_sku as t2 on t1.bailun_sku =t2.bailun_sku where t2.buyer_name in ('张莹霞','张莹霞1');
insert into dc_base_data_character_temp(`character`, `bailun_sku`, `warehouse_code`,`bailun_sku_warehouse_code`)
select '海外仓' as 'character',t1.bailun_sku,t1.warehouse_code,CONCAT(t1.bailun_sku,t1.warehouse_code) as 'bailun_sku_warehouse_code' from dc_base_stock as t1 left join dc_base_warehouse as t2 on t1.warehouse_code = t2.warehouse_code where t2.hq_type not in ('国内仓');
select '半成品仓' as 'warehouse_type',t1.warehouse_code,t1.bailun_sku,t1.usable_stock,t1.quantity_safe_inventory,t1.sku_name,t1.unit_price from dc_base_wip_stock as t1
) as t1
);
alter table dc_base_data_character rename dc_base_data_characterTemp;
alter table dc_base_data_character_temp rename dc_base_data_character;
alter table dc_base_data_characterTemp rename dc_base_data_character_temp;
truncate table dc_base_data_character_temp;
update dc_base_stock as t1,
(
select bailun_sku,warehouse_code,GROUP_CONCAT(`character`) as 'character' from dc_base_data_character GROUP BY bailun_sku,warehouse_code
) as t2
set t1.`character` = t2.`character`
where t1.bailun_sku = t2.bailun_sku and t1.warehouse_code = t2.warehouse_code;
alter table dc_base_full_stock rename dc_base_full_stockTemp;
alter table dc_base_full_stock_temp rename dc_base_full_stock;
alter table dc_base_full_stockTemp rename dc_base_full_stock_temp;
truncate table dc_base_full_stock_temp; ", commandTimeout: 0);
_connection.Execute(@" -- 刷新 全量有效入库记录
", commandTimeout: 0);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
_connection.Insert<dc_task_error_log>(new dc_task_error_log
{
date = DateTime.Now,
message = ex.Message,
stack_trace = ex.StackTrace,
task_name = "ResetOutofstock"
});
}
}
/// <summary>
/// 全量刷新入库记录
/// </summary>
public static void ResetStockRecord()
{
_connection.Execute(@" -- 刷新 全量有效入库记录
set session transaction isolation level read uncommitted;
start transaction;
......@@ -1732,7 +1798,7 @@ alter table dc_base_stock_record_effective_temp rename dc_base_stock_record_effe
alter table dc_base_stock_record_effectiveTemp rename dc_base_stock_record_effective_temp;
truncate table dc_base_stock_record_effective_temp; ", commandTimeout: 0);
_connection.Execute(@" -- 刷新 库存表的索引字段
_connection.Execute(@" -- 刷新 库存表的索引字段
update dc_base_stock as t1,dc_base_warehouse as t2
set bailun_sku_warehouse_code=concat(t1.bailun_sku,t1.warehouse_code),bailun_sku_warehouse_area=concat(t1.bailun_sku,t2.hq_type,IFNULL(t2.area_id,0)) where t1.warehouse_code = t2.warehouse_code;
update dc_base_stock_record set bailun_sku_warehouse_code=concat(bailun_sku,warehouse_code);
......@@ -1743,7 +1809,7 @@ GROUP BY t1.bailun_sku_warehouse_area) as t2
set t1.first_inbound_date = t2.min_time
where t1.bailun_sku_warehouse_area=t2.bailun_sku_warehouse_area;", commandTimeout: 0);
_connection.Execute(@" -- 刷新库存日志
_connection.Execute(@" -- 刷新库存日志
set session transaction isolation level read uncommitted;
start transaction;
......@@ -1803,92 +1869,41 @@ truncate table dc_base_stock_record_temp;
", commandTimeout: 0);
}
_connection.Execute(@" -- 刷新sku汇总
set session transaction isolation level read uncommitted;
start transaction;
-- 清空视图表的数据
Truncate table dc_base_sku_sum_temp;
insert into dc_base_sku_sum_temp(`bailun_sku`,
`usable_stock`,
`on_the_way`,
`stock_amount`,
`on_the_way_amount` ,
`history_sevenday_sales`,
`history_fourteenday_sales`,
`history_thirtyday_sales`)
(
select t1.bailun_sku,sum(t1.usable_stock) as 'usable_stock',sum(ifnull(t5.quantity_transfer,0)+ifnull(t5.quantity_purchase,0)) as 'on_the_way',
sum(ifnull(t1.usable_stock,0) * ifnull(t2.unit_price,0)) as 'stock_amount',(ifnull(t5.quantity_transfer,0)+ifnull(t5.quantity_purchase,0)) as 'on_the_way_amount',
AVG(ifnull(t8.history_sevenday_sales,0)) as 'history_sevenday_sales',AVG(ifnull(t8.history_fourteenday_sales,0)) as 'history_fourteenday_sales',AVG(ifnull(t8.history_thirtyday_sales,0)) as 'history_thirtyday_sales'
from
dc_base_stock as t1
left join dc_base_sku as t2 on t1.bailun_sku=t2.bailun_sku
left join dc_mid_transit as t5 on t1.bailun_sku = t5.bailun_sku and t1.warehouse_code = t5.warehouse_code
left join dc_auto_config_sku_warehouse as t7 on t1.bailun_sku = t7.bailun_sku and t1.warehouse_code = t7.warehouse_code
left join dc_auto_turnover as t8 on t1.bailun_sku = t8.bailun_sku and t1.warehouse_code = t8.warehouse_code
group by t1.bailun_sku
);
alter table dc_base_sku_sum rename dc_base_sku_sumTemp;
alter table dc_base_sku_sum_temp rename dc_base_sku_sum;
alter table dc_base_sku_sumTemp rename dc_base_sku_sum_temp;
truncate table dc_base_sku_sum_temp;
", commandTimeout: 0);
_connection.Execute(@" -- 刷新sku汇总
/// <summary>
/// 刷新全量库存表
/// </summary>
public static void ResetFullStock()
{
_connection.Execute(@" -- 刷新 全量库存表
set session transaction isolation level read uncommitted;
start transaction;
-- 清空视图表的数据
Truncate table dc_base_data_character_temp;
insert into dc_base_data_character_temp(`character`, `bailun_sku`, `warehouse_code`,`bailun_sku_warehouse_code`)
select '无库' as 'character',bailun_sku,warehouse_code,CONCAT(bailun_sku,warehouse_code) as 'bailun_sku_warehouse_code' from dc_base_stock where warehouse_code in ('BLGZ03','YWWH01');
insert into dc_base_data_character_temp(`character`, `bailun_sku`, `warehouse_code`,`bailun_sku_warehouse_code`)
select '自产' as 'character',t1.bailun_sku,t1.warehouse_code,CONCAT(t1.bailun_sku,t1.warehouse_code) as 'bailun_sku_warehouse_code' from dc_base_stock as t1 left join dc_base_sku as t2 on t1.bailun_sku =t2.bailun_sku where t2.buyer_name in ('张莹霞','张莹霞1');
insert into dc_base_data_character_temp(`character`, `bailun_sku`, `warehouse_code`,`bailun_sku_warehouse_code`)
select '海外仓' as 'character',t1.bailun_sku,t1.warehouse_code,CONCAT(t1.bailun_sku,t1.warehouse_code) as 'bailun_sku_warehouse_code' from dc_base_stock as t1 left join dc_base_warehouse as t2 on t1.warehouse_code = t2.warehouse_code where t2.hq_type not in ('国内仓');
alter table dc_base_data_character rename dc_base_data_characterTemp;
alter table dc_base_data_character_temp rename dc_base_data_character;
alter table dc_base_data_characterTemp rename dc_base_data_character_temp;
truncate table dc_base_data_character_temp;
update dc_base_stock as t1,
(
select bailun_sku,warehouse_code,GROUP_CONCAT(`character`) as 'character' from dc_base_data_character GROUP BY bailun_sku,warehouse_code
) as t2
set t1.`character` = t2.`character`
where t1.bailun_sku = t2.bailun_sku and t1.warehouse_code = t2.warehouse_code;
Truncate table dc_base_full_stock_temp;
", commandTimeout: 0);
INSERT into dc_base_full_stock_temp(`warehouse_type`,`warehouse_code`,`bailun_sku`,`usable_stock`,`quantity_safe_inventory`,`sku_name`,`unit_price`)
(
select * from (
select
t3.hq_type as 'warehouse_type',t2.warehouse_code,t2.bailun_sku,t2.usable_stock,ifnull(t1.quantity_safe_inventory,0) as 'quantity_safe_inventory',
ifnull(t4.sku_title_cn,'') as 'sku_name',ifnull(t4.unit_price,0) as 'unit_price'
from dc_base_stock as t2
left join dc_auto_turnover as t1 on t1.bailun_sku = t2.bailun_sku and t1.warehouse_code = t2.warehouse_code
left join dc_base_warehouse as t3 on t2.warehouse_code = t3.warehouse_code
left join dc_base_sku as t4 on t2.bailun_sku = t4.bailun_sku
union
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
_connection.Insert<dc_task_error_log>(new dc_task_error_log
{
date = DateTime.Now,
message = ex.Message,
stack_trace = ex.StackTrace,
task_name = "ResetOutofstock"
});
}
select '半成品仓' as 'warehouse_type',t1.warehouse_code,t1.bailun_sku,t1.usable_stock,t1.quantity_safe_inventory,t1.sku_name,t1.unit_price from dc_base_wip_stock as t1
) as t1
);
alter table dc_base_full_stock rename dc_base_full_stockTemp;
alter table dc_base_full_stock_temp rename dc_base_full_stock;
alter table dc_base_full_stockTemp rename dc_base_full_stock_temp;
truncate table dc_base_full_stock_temp; ", commandTimeout: 0);
}
/// <summary>
......
ResetOutofstock/StockBackgrounService.cs
......@@ -58,9 +58,11 @@ namespace ResetOutofstock
dc_auto_pick_up_goods_order_dao.GenerateOrder(DateTime.Now.AddDays(-1), DateTime.Now);
Console.WriteLine($"结束 刷新jit安全库存，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
if (now.Hour==8 && now.Minute == 1)
if (now.Hour==8 && now.Minute == 10)
{
Console.WriteLine($"开始 刷新jit安全库存，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
report.ResetFullStock();
report.ResetStockRecord();
report.ResetInventory();
Console.WriteLine($"结束 刷新jit安全库存，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
......@@ -70,6 +72,7 @@ namespace ResetOutofstock
report.ResetOms7();
Console.WriteLine($"结束 刷新最近7天的oms数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
}
......
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