Commit 716c5b3c by lizefeng

优化采购建议推送

parent 33f8b907
......@@ -12,7 +12,7 @@ namespace AutoGeneratePurchaseAdvise
static async Task Main(string[] args)
{
Console.WriteLine("采购建议计算任务启动...");
//PurchaseAdviseServices.AutoPushBuySys(5);
//PurchaseAdviseServices.AutoPushBuySys(1);
var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
{
services.AddHostedService<GeneratePurchaseAdviseBackgroundService>();
......
......@@ -463,6 +463,9 @@ t7.bailun_order_ids
try
{
_connection.Execute(@"
set session transaction isolation level read uncommitted;
start transaction;
insert into dc_mid_transit(bailun_sku, warehouse_code, quantity_out_stock,gmt_out_stock_modified)
SELECT
t1.bailun_sku as bailunSku,
......@@ -495,7 +498,9 @@ ON DUPLICATE KEY UPDATE quantity_out_stock = values(quantity_out_stock) ,gmt_o
", commandTimeout: 0);
var time = _connection.QueryFirstOrDefault<DateTime>(" select max(gmt_out_stock_modified) from dc_mid_transit ");
_connection.Execute(" update dc_mid_transit set quantity_out_stock =0 where gmt_out_stock_modified < @time ",new {
_connection.Execute(@" set session transaction isolation level read uncommitted;
start transaction;
update dc_mid_transit set quantity_out_stock =0 where gmt_out_stock_modified < @time ", new {
time= time
});
}
......
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