Commit c3d4577f by 泽锋 李

新增周转任务状态的检查

parent c55e191d
......@@ -67,6 +67,13 @@ namespace AutoGeneratePurchaseAdvise
}
// 判断是不是指定的时间
if (now.Hour == 07 && now.Minute == 1)
{
Console.WriteLine($"开始 检查周转任务状态 任务,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
PurchaseAdviseServices.CheckTurnoveCount(DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd")));
Console.WriteLine($"结束 检查周转任务状态 任务,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
if (now.Hour == 09 && now.Minute == 1)
{
Console.WriteLine($"开始 推送采购建议 任务,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
......@@ -111,6 +118,12 @@ namespace AutoGeneratePurchaseAdvise
}
if (now.Hour == 14 && now.Minute == 30)
{
Console.WriteLine($"开始 检查周转任务状态 任务,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
PurchaseAdviseServices.CheckTurnoveCount(DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd")));
Console.WriteLine($"结束 检查周转任务状态 任务,线程Id:{Thread.CurrentThread.ManagedThreadId}{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
// 判断是不是指定的时间
if (now.Hour == 15 && now.Minute == 2)
{
......
......@@ -24,7 +24,7 @@ namespace AutoGeneratePurchaseAdvise
//PurchaseAdviseServices.AutoPushBuySys(6);
//PurchaseAdviseServices.AutoPushBuySys(7);
//PurchaseAdviseServices.Generate(DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd 00:00:00")));
PurchaseAdviseServices.Generate(DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd 12:00:00")));
//PurchaseAdviseServices.Generate(DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd 12:00:00")));
}
catch (Exception ex)
{
......
......@@ -1623,5 +1623,7 @@ where t1.warehouse_code=@warehousecode and t1.bailun_sku=@sku and t2.create_time
{
_connection.Delete<dc_auto_purchase_advise_detailed>(id);
}
}
}
......@@ -469,5 +469,12 @@ namespace AutoTurnOver.Services
}
}
}
public static void CheckTurnoveCount(DateTime time)
{
var count = MyMySqlConnection._connection_read_only.QuerySingleOrDefault<int>("select count(1) from dc_auto_turnover where gmt_modified>=@time ",new { time = time });
ApiServices.QiYeJiQiRenMsPush(new QiYeJiQiRenMsDto { msgtype = "text", text = new QiYeJiQiRenMsDto.text_dto { content = $" 骆宾, 当前已更新的周转数 {count}" } });
}
}
}
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