Skip to content

D
data-center-auto
Commit 21cc4bd6 by 泽锋 李
Options

降低晚上服务的刷新压力

parent 7e8c6b02
Showing with 59 additions and 25 deletions
AutoTurnOver.DB/dc_auto_turnover.cs
...@@ -1418,6 +1418,19 @@ where t1.gmt_modified>=@btime and t1.gmt_modified<=@etime ...@@ -1418,6 +1418,19 @@ where t1.gmt_modified>=@btime and t1.gmt_modified<=@etime
modalData.order_count_3_radio = modalData.order_count<=0?0 : modalData.order_count_3 / modalData.order_count; modalData.order_count_3_radio = modalData.order_count<=0?0 : modalData.order_count_3 / modalData.order_count;
modalData.product_count_3_radio = modalData.product_count <= 0?0 : modalData.product_count_3 / modalData.product_count; modalData.product_count_3_radio = modalData.product_count <= 0?0 : modalData.product_count_3 / modalData.product_count;
datas.FirstOrDefault(s => s.name == "空运调拨票数占比").days.Add(new transfer_profit_dto.day_dto
{
date = this_time,
val = modalData.order_count_3_radio,
formula = $" 空运调拨票数占比 "
});
datas.FirstOrDefault(s => s.name == "空运调拨数量占比").days.Add(new transfer_profit_dto.day_dto
{
date = this_time,
val = modalData.product_count_3_radio,
formula = $" 空运调拨票数占比 "
});
var dc_base_transfer_freight_data = _connection.QueryFirstOrDefault<dc_base_transfer_freight>(" select * from dc_base_transfer_freight where warehouse_code=@warehouse_code and bailun_sku=@bailun_sku limit 1 ", new var dc_base_transfer_freight_data = _connection.QueryFirstOrDefault<dc_base_transfer_freight>(" select * from dc_base_transfer_freight where warehouse_code=@warehouse_code and bailun_sku=@bailun_sku limit 1 ", new
{ {
warehouse_code = result.warehouse_code, warehouse_code = result.warehouse_code,
...@@ -1725,17 +1738,30 @@ where t1.gmt_modified>=@btime and t1.gmt_modified<=@etime ...@@ -1725,17 +1738,30 @@ where t1.gmt_modified>=@btime and t1.gmt_modified<=@etime
} }
else // 过去 else // 过去
{ {
var average_warehouse_data = _connection.QueryFirstOrDefault<dc_average_warehouse>(" select * from dc_average_warehouse where warehouse_code=@warehouse_code and bailun_sku=@bailun_sku limit 1 ", new //var average_warehouse_data = _connection.QueryFirstOrDefault<dc_average_warehouse>(" select * from dc_average_warehouse where warehouse_code=@warehouse_code and bailun_sku=@bailun_sku limit 1 ", new
//{
// warehouse_code = result.warehouse_code,
// bailun_sku = result.bailun_sku
//}) ?? new dc_average_warehouse { };
//modalData.product_count = average_warehouse_data.product_count;
//modalData.product_count_3 = average_warehouse_data.product_count_3;
//modalData.order_count = average_warehouse_data.order_count;
//modalData.order_count_3 = average_warehouse_data.order_count_3;
//modalData.order_count_3_radio = modalData.order_count <= 0 ? 0 : modalData.order_count_3 / modalData.order_count;
//modalData.product_count_3_radio = modalData.product_count <= 0 ? 0 : modalData.product_count_3 / modalData.product_count;
datas.FirstOrDefault(s => s.name == "空运调拨票数占比").days.Add(new transfer_profit_dto.day_dto
{ {
warehouse_code = result.warehouse_code, date = this_time,
bailun_sku = result.bailun_sku val = null,
}) ?? new dc_average_warehouse { }; formula = $" 空运调拨票数占比 "
modalData.product_count = average_warehouse_data.product_count; });
modalData.product_count_3 = average_warehouse_data.product_count_3; datas.FirstOrDefault(s => s.name == "空运调拨数量占比").days.Add(new transfer_profit_dto.day_dto
modalData.order_count = average_warehouse_data.order_count; {
modalData.order_count_3 = average_warehouse_data.order_count_3; date = this_time,
modalData.order_count_3_radio = modalData.order_count <= 0 ? 0 : modalData.order_count_3 / modalData.order_count; val = null,
modalData.product_count_3_radio = modalData.product_count <= 0 ? 0 : modalData.product_count_3 / modalData.product_count; formula = $" 空运调拨票数占比 "
});
datas.FirstOrDefault(s => s.name == "30天预测销量实际-海运金额汇总").days.Add(new transfer_profit_dto.day_dto datas.FirstOrDefault(s => s.name == "30天预测销量实际-海运金额汇总").days.Add(new transfer_profit_dto.day_dto
{ {
...@@ -2122,6 +2148,10 @@ from dc_base_oms_sku where bailun_sku=@bailun_sku and warehouse_code=@warehouse_ ...@@ -2122,6 +2148,10 @@ from dc_base_oms_sku where bailun_sku=@bailun_sku and warehouse_code=@warehouse_
/// </summary> /// </summary>
public static void SynchroCalculationProfitAnalysis() public static void SynchroCalculationProfitAnalysis()
{ {
if (DateTime.Now.Hour < 8)
{
return;
}
var task_name = $"SynchroCalculationProfitAnalysis_v19"; var task_name = $"SynchroCalculationProfitAnalysis_v19";
var conn = MyMySqlConnection._connection; ; var conn = MyMySqlConnection._connection; ;
// 查询最后一次成功抓取的记录 // 查询最后一次成功抓取的记录
......
AutoTurnOver.DB/dc_base_full_link_wait_order_dao.cs
...@@ -19,6 +19,10 @@ namespace AutoTurnOver.DB ...@@ -19,6 +19,10 @@ namespace AutoTurnOver.DB
public static void ResetDatas() public static void ResetDatas()
{ {
if (DateTime.Now.Hour < 8)
{
return;
}
List<dc_base_full_link_wait_order_temp> datas = new List<dc_base_full_link_wait_order_temp>(); List<dc_base_full_link_wait_order_temp> datas = new List<dc_base_full_link_wait_order_temp>();
datas.AddRange(GetPurchaseOrder()); datas.AddRange(GetPurchaseOrder());
datas.AddRange(GetTransferOrder()); datas.AddRange(GetTransferOrder());
......
AutoTurnOver.DB/report.cs
...@@ -4316,7 +4316,7 @@ truncate table dc_report_goods_temp; ...@@ -4316,7 +4316,7 @@ truncate table dc_report_goods_temp;
/// </summary> /// </summary>
public static void SynchroReportGoodsStockData() public static void SynchroReportGoodsStockData()
{ {
if (DateTime.Now.Hour < 1) if (DateTime.Now.Hour < 8)
{ {
return; return;
} }
...@@ -4395,7 +4395,7 @@ truncate table dc_report_goods_temp; ...@@ -4395,7 +4395,7 @@ truncate table dc_report_goods_temp;
/// </summary> /// </summary>
public static void SynchroReportGoodsOnTheWayData() public static void SynchroReportGoodsOnTheWayData()
{ {
if (DateTime.Now.Hour < 1) if (DateTime.Now.Hour < 8)
{ {
return; return;
} }
......
AutoTurnOver.DB/report_cash_flow_dao.cs
...@@ -25,7 +25,7 @@ namespace AutoTurnOver.DB ...@@ -25,7 +25,7 @@ namespace AutoTurnOver.DB
{ {
try try
{ {
var conn = MyMySqlConnection._connection; var conn = _connection;
conn.Open(); conn.Open();
int page = 1; int page = 1;
int rows = 10000; int rows = 10000;
...@@ -464,7 +464,7 @@ namespace AutoTurnOver.DB ...@@ -464,7 +464,7 @@ namespace AutoTurnOver.DB
{ {
try try
{ {
var conn = MyMySqlConnection._connection; var conn = _connection;
conn.Open(); conn.Open();
int page = 1; int page = 1;
int rows = 5000; int rows = 5000;
......
ResetOutofstock/CaseFlowBackgrounService.cs
...@@ -58,7 +58,7 @@ namespace ResetOutofstock ...@@ -58,7 +58,7 @@ namespace ResetOutofstock
daily.ResetFbaExtendSales(now); daily.ResetFbaExtendSales(now);
Console.WriteLine($"结束 刷新fba历史销量，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 刷新fba历史销量，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
} }
if (now.Hour == 0 && now.Minute == 06) if (now.Hour == 0 && now.Minute == 07)
{ {
Console.WriteLine($"开始 刷新fba昨日review，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 刷新fba昨日review，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
daily.ResetFbaExtendReview(now); daily.ResetFbaExtendReview(now);
......
ResetOutofstock/ReportFinanceBackgrounService.cs
...@@ -25,49 +25,49 @@ namespace ResetOutofstock ...@@ -25,49 +25,49 @@ namespace ResetOutofstock
if (now.Hour == 0 && now.Minute == 01) if (now.Hour == 0 && now.Minute == 01)
{ {
Console.WriteLine($"开始 财报财务付现数据 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 财报财务付现数据 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_report_finance_dao.CalculationCashPayment(DateTime.Now.AddDays(-90)); //dc_report_finance_dao.CalculationCashPayment(DateTime.Now.AddDays(-90));
Console.WriteLine($"结束 财报财务付现数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 财报财务付现数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
} }
if (now.Hour == 0 && now.Minute == 02) if (now.Hour == 0 && now.Minute == 02)
{ {
Console.WriteLine($"开始 财报出库退税数据 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 财报出库退税数据 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_report_finance_dao.CalculationTax(DateTime.Now.AddDays(-90)); //dc_report_finance_dao.CalculationTax(DateTime.Now.AddDays(-90));
Console.WriteLine($"结束 财报出库退税数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 财报出库退税数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
} }
if (now.Hour == 0 && now.Minute == 03) if (now.Hour == 0 && now.Minute == 03)
{ {
Console.WriteLine($"开始 财报订单数据 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 财报订单数据 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_report_finance_dao.CalculationOrder(DateTime.Now.AddDays(-90)); //dc_report_finance_dao.CalculationOrder(DateTime.Now.AddDays(-90));
Console.WriteLine($"结束 财报订单数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 财报订单数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
} }
if (now.Hour == 0 && now.Minute == 04) if (now.Hour == 0 && now.Minute == 04)
{ {
Console.WriteLine($"开始 财报订单-平台数据 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 财报订单-平台数据 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_report_finance_dao.CalculationOrderPlatfrom(DateTime.Now.AddDays(-90)); //dc_report_finance_dao.CalculationOrderPlatfrom(DateTime.Now.AddDays(-90));
Console.WriteLine($"结束 财报订单-平台数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 财报订单-平台数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
} }
if (now.Hour == 0 && now.Minute == 05) if (now.Hour == 0 && now.Minute == 05)
{ {
Console.WriteLine($"开始 财报退款数据 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 财报退款数据 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_report_finance_dao.CalculationRefund(DateTime.Now.AddDays(-90)); //dc_report_finance_dao.CalculationRefund(DateTime.Now.AddDays(-90));
Console.WriteLine($"结束 财报退款数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 财报退款数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
} }
if (now.Hour == 0 && now.Minute == 06) if (now.Hour == 0 && now.Minute == 06)
{ {
Console.WriteLine($"开始 财报其他收入 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 财报其他收入 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_report_finance_dao.CalculationOtherIncome(DateTime.Now.AddDays(-90)); //dc_report_finance_dao.CalculationOtherIncome(DateTime.Now.AddDays(-90));
Console.WriteLine($"结束 财报其他收入，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 财报其他收入，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
} }
if (now.Hour == 0 && now.Minute == 06) if (now.Hour == 0 && now.Minute == 06)
{ {
Console.WriteLine($"开始 财报筹资流入出 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 财报筹资流入出 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_report_finance_dao.CalculationRaise(DateTime.Now.AddDays(-90)); //dc_report_finance_dao.CalculationRaise(DateTime.Now.AddDays(-90));
Console.WriteLine($"结束 财报筹资流入出，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 财报筹资流入出，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
} }
if (now.Hour == 0 && now.Minute == 06) if (now.Hour == 0 && now.Minute == 06)
{ {
Console.WriteLine($"开始 财报应首付账款 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 财报应首付账款 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_report_finance_dao.CalculationAccounts(DateTime.Now.AddDays(-90)); //dc_report_finance_dao.CalculationAccounts(DateTime.Now.AddDays(-90));
Console.WriteLine($"结束 财报应首付账款，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 财报应首付账款，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
} }
......
ResetOutofstock/ResetOutofstockBackgrounService.cs
...@@ -148,7 +148,7 @@ namespace ResetOutofstock ...@@ -148,7 +148,7 @@ namespace ResetOutofstock
try try
{ {
var now = DateTime.Now; var now = DateTime.Now;
if (now.Hour>2 && now.Hour<=8) if (now.Hour>0 && now.Hour<=8)
{ {
Console.WriteLine(" 刷新缺货明细数据 * (数据库忙时，暂停)"); Console.WriteLine(" 刷新缺货明细数据 * (数据库忙时，暂停)");
} }
......
ResetOutofstock/StockBackgrounService.cs
...@@ -24,7 +24,7 @@ namespace ResetOutofstock ...@@ -24,7 +24,7 @@ namespace ResetOutofstock
if (now.Minute == 0) if (now.Minute == 0)
{ {
if (now.Hour > 2 && now.Hour <= 8) if (now.Hour > 0 && now.Hour <= 8)
{ {
Console.WriteLine($"开始 刷新缺货明细 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 刷新缺货明细 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
Console.WriteLine(" 刷新缺货明细数据 * (数据库忙时，暂停)"); Console.WriteLine(" 刷新缺货明细数据 * (数据库忙时，暂停)");
......
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