Skip to content

D
data-center-auto
Commit 8fe4f20b by 泽锋 李
Options

fix

parent 0bdddfbb
Showing with 224 additions and 224 deletions
ResetOutofstock/ResetOutofstockBackgrounService.cs
...@@ -26,10 +26,10 @@ namespace ResetOutofstock ...@@ -26,10 +26,10 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine(" fba 1/2 月销量 异常 :"+ex.Message); Console.WriteLine(" fba 1/2 月销量 异常 :" + ex.Message);
Console.WriteLine(" fba 1/2 月销量 异常: " +ex.StackTrace); Console.WriteLine(" fba 1/2 月销量 异常: " + ex.StackTrace);
} }
}); });
...@@ -49,17 +49,17 @@ namespace ResetOutofstock ...@@ -49,17 +49,17 @@ namespace ResetOutofstock
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("同步调拨 采购临时数据:" + ex.Message); Console.WriteLine("同步调拨 采购临时数据:" + ex.Message);
Console.WriteLine("同步调拨 采购临时数据:"+ex.StackTrace); Console.WriteLine("同步调拨 采购临时数据:" + ex.StackTrace);
} }
Thread.Sleep(10 * 60 * 1000); Thread.Sleep(10 * 60 * 1000);
} }
}); });
Task.Factory.StartNew(() => Task.Factory.StartNew(() =>
{ {
while (true) while (true)
{ {
Thread.Sleep(10 * 60 * 1000); Thread.Sleep(10 * 60 * 1000);
...@@ -71,33 +71,33 @@ namespace ResetOutofstock ...@@ -71,33 +71,33 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("同步生产订单数据:"+ex.Message); Console.WriteLine("同步生产订单数据:" + ex.Message);
Console.WriteLine("同步生产订单数据:"+ex.StackTrace); Console.WriteLine("同步生产订单数据:" + ex.StackTrace);
}
}
});
Task.Factory.StartNew(() =>
{
while (true)
{
Thread.Sleep(10 * 60 * 1000);
try
{
Console.WriteLine($"开始 同步调拨单当前节点 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_base_transfer_extend_dao.SynchroLmsTransferOrder();
Console.WriteLine($"结束 同步调拨单当前节点 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
catch (Exception ex)
{
Console.WriteLine("同步调拨单当前节点:"+ex.Message);
Console.WriteLine("同步调拨单当前节点:"+ex.StackTrace);
} }
} }
}); });
Task.Factory.StartNew(() =>
{
while (true)
{
Thread.Sleep(10 * 60 * 1000);
try
{
Console.WriteLine($"开始 同步调拨单当前节点 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
dc_base_transfer_extend_dao.SynchroLmsTransferOrder();
Console.WriteLine($"结束 同步调拨单当前节点 ，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
catch (Exception ex)
{
Console.WriteLine("同步调拨单当前节点:" + ex.Message);
Console.WriteLine("同步调拨单当前节点:" + ex.StackTrace);
}
}
});
Task.Factory.StartNew(() => Task.Factory.StartNew(() =>
...@@ -112,15 +112,15 @@ namespace ResetOutofstock ...@@ -112,15 +112,15 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("同步供应商数据:"+ex.Message); Console.WriteLine("同步供应商数据:" + ex.Message);
Console.WriteLine("同步供应商数据:"+ex.StackTrace); Console.WriteLine("同步供应商数据:" + ex.StackTrace);
} }
Thread.Sleep(60 * 60 * 1000); Thread.Sleep(60 * 60 * 1000);
} }
}); });
Task.Factory.StartNew(() => Task.Factory.StartNew(() =>
{ {
while (true) while (true)
...@@ -133,8 +133,8 @@ namespace ResetOutofstock ...@@ -133,8 +133,8 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("同步半成品库存数据:"+ex.Message); Console.WriteLine("同步半成品库存数据:" + ex.Message);
Console.WriteLine("同步半成品库存数据:"+ex.StackTrace); Console.WriteLine("同步半成品库存数据:" + ex.StackTrace);
} }
...@@ -149,7 +149,7 @@ namespace ResetOutofstock ...@@ -149,7 +149,7 @@ namespace ResetOutofstock
try try
{ {
var now = DateTime.Now; var now = DateTime.Now;
if (now.Hour>0 && now.Hour<=8) if (now.Hour > 0 && now.Hour <= 8)
{ {
Console.WriteLine(" 刷新缺货明细数据 * (数据库忙时，暂停)"); Console.WriteLine(" 刷新缺货明细数据 * (数据库忙时，暂停)");
} }
...@@ -159,19 +159,19 @@ namespace ResetOutofstock ...@@ -159,19 +159,19 @@ namespace ResetOutofstock
report.ResetOutofstock(); report.ResetOutofstock();
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")}");
} }
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("开始刷新数据:"+ex.Message); Console.WriteLine("开始刷新数据:" + ex.Message);
Console.WriteLine("开始刷新数据:"+ex.StackTrace); Console.WriteLine("开始刷新数据:" + ex.StackTrace);
} }
Thread.Sleep(4 * 60 * 60 * 1000); Thread.Sleep(4 * 60 * 60 * 1000);
} }
}); });
Task.Factory.StartNew(() => Task.Factory.StartNew(() =>
{ {
...@@ -189,14 +189,14 @@ namespace ResetOutofstock ...@@ -189,14 +189,14 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("开始刷新库存监控数据:"+ex.Message); Console.WriteLine("开始刷新库存监控数据:" + ex.Message);
Console.WriteLine("开始刷新库存监控数据:"+ex.StackTrace); Console.WriteLine("开始刷新库存监控数据:" + ex.StackTrace);
} }
Thread.Sleep(4 * 60 * 60 * 1000); Thread.Sleep(4 * 60 * 60 * 1000);
} }
}); });
Task.Factory.StartNew(() => Task.Factory.StartNew(() =>
{ {
while (true) while (true)
...@@ -209,8 +209,8 @@ namespace ResetOutofstock ...@@ -209,8 +209,8 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("开始同步真实调拨费:"+ex.Message); Console.WriteLine("开始同步真实调拨费:" + ex.Message);
Console.WriteLine("开始同步真实调拨费:"+ex.StackTrace); Console.WriteLine("开始同步真实调拨费:" + ex.StackTrace);
} }
Thread.Sleep(60 * 60 * 1000); Thread.Sleep(60 * 60 * 1000);
...@@ -228,8 +228,8 @@ namespace ResetOutofstock ...@@ -228,8 +228,8 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("开始刷新最快到货的调拨单数据:"+ex.Message); Console.WriteLine("开始刷新最快到货的调拨单数据:" + ex.Message);
Console.WriteLine("开始刷新最快到货的调拨单数据:"+ex.StackTrace); Console.WriteLine("开始刷新最快到货的调拨单数据:" + ex.StackTrace);
} }
Thread.Sleep(10 * 60 * 1000); Thread.Sleep(10 * 60 * 1000);
...@@ -248,8 +248,8 @@ namespace ResetOutofstock ...@@ -248,8 +248,8 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("已经停止监控的周转数据:"+ex.Message); Console.WriteLine("已经停止监控的周转数据:" + ex.Message);
Console.WriteLine("已经停止监控的周转数据:"+ex.StackTrace); Console.WriteLine("已经停止监控的周转数据:" + ex.StackTrace);
} }
Thread.Sleep(10 * 60 * 1000); Thread.Sleep(10 * 60 * 1000);
...@@ -269,8 +269,8 @@ namespace ResetOutofstock ...@@ -269,8 +269,8 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("商品报表库存字段增量刷新:"+ex.Message); Console.WriteLine("商品报表库存字段增量刷新:" + ex.Message);
Console.WriteLine("商品报表库存字段增量刷新"+ex.StackTrace); Console.WriteLine("商品报表库存字段增量刷新" + ex.StackTrace);
} }
Thread.Sleep(60 * 1000); Thread.Sleep(60 * 1000);
...@@ -289,8 +289,8 @@ namespace ResetOutofstock ...@@ -289,8 +289,8 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("增量刷新周转利润分析:"+ex.Message); Console.WriteLine("增量刷新周转利润分析:" + ex.Message);
Console.WriteLine("增量刷新周转利润分析:"+ex.StackTrace); Console.WriteLine("增量刷新周转利润分析:" + ex.StackTrace);
} }
Thread.Sleep(10 * 60 * 1000); Thread.Sleep(10 * 60 * 1000);
...@@ -309,8 +309,8 @@ namespace ResetOutofstock ...@@ -309,8 +309,8 @@ namespace ResetOutofstock
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("增量刷新周转利润分析:"+ex.Message); Console.WriteLine("增量刷新周转利润分析:" + ex.Message);
Console.WriteLine("增量刷新周转利润分析:"+ex.StackTrace); Console.WriteLine("增量刷新周转利润分析:" + ex.StackTrace);
} }
Thread.Sleep(10 * 60 * 1000); Thread.Sleep(10 * 60 * 1000);
...@@ -334,191 +334,191 @@ namespace ResetOutofstock ...@@ -334,191 +334,191 @@ namespace ResetOutofstock
Console.WriteLine("全链路在途:" + ex.StackTrace); Console.WriteLine("全链路在途:" + ex.StackTrace);
} }
} }
}); });
Task.Factory.StartNew(() =>
{
while (true)
{
try
{
Console.WriteLine($"开始刷新 采购单理论交期，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
daily.ResetPurchaseQuantityNotInbound();
Console.WriteLine($"结束刷新 采购单理论交期，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
Thread.Sleep(60 * 1000);
}
catch (Exception ex)
{
Console.WriteLine("采购单理论交期:" + ex.Message);
Console.WriteLine("采购单理论交期:" + ex.StackTrace);
}
Task.Factory.StartNew(() =>
} {
}); while (true)
{
Task.Factory.StartNew(() =>
{ try
while (true) {
{ Console.WriteLine($"开始刷新 采购单理论交期，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
daily.ResetPurchaseQuantityNotInbound();
try Console.WriteLine($"结束刷新 采购单理论交期，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
{ Thread.Sleep(60 * 1000);
Console.WriteLine($"开始 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); }
catch (Exception ex)
{
Console.WriteLine("采购单理论交期:" + ex.Message);
Console.WriteLine("采购单理论交期:" + ex.StackTrace);
}
}
});
Task.Factory.StartNew(() =>
{
while (true)
{
try
{
Console.WriteLine($"开始 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
base_sku_dao.SynchroCharacter(); base_sku_dao.SynchroCharacter();
Console.WriteLine($"结束 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
Thread.Sleep(60 * 60 * 1000); Thread.Sleep(60 * 60 * 1000);
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("拉取sku特性:" + ex.Message); Console.WriteLine("拉取sku特性:" + ex.Message);
Console.WriteLine("拉取sku特性:" + ex.StackTrace); Console.WriteLine("拉取sku特性:" + ex.StackTrace);
} }
} }
}); });
Task.Factory.StartNew(() => Task.Factory.StartNew(() =>
{ {
while (true) while (true)
{ {
try try
{ {
Console.WriteLine($"开始 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
base_sku_dao.SynchroSkuCharacter(); base_sku_dao.SynchroSkuCharacter();
Console.WriteLine($"结束 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
Thread.Sleep(10 * 60 * 1000); Thread.Sleep(10 * 60 * 1000);
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine("拉取sku特性:" + ex.Message); Console.WriteLine("拉取sku特性:" + ex.Message);
Console.WriteLine("拉取sku特性:" + ex.StackTrace); Console.WriteLine("拉取sku特性:" + ex.StackTrace);
} }
}
});
Task.Factory.StartNew(() => }
{ });
while (true)
{
try
{
Console.WriteLine($"开始 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
base_sku_dao.SynchroSkuCharacterSupplement();
Console.WriteLine($"结束 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
Thread.Sleep(24 *60 * 60 * 1000);
}
catch (Exception ex)
{
Console.WriteLine("拉取sku特性:" + ex.Message);
Console.WriteLine("拉取sku特性:" + ex.StackTrace);
}
Task.Factory.StartNew(() =>
} {
}); while (true)
{
Task.Factory.StartNew(() => try
{ {
while (true) Console.WriteLine($"开始 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
{ base_sku_dao.SynchroSkuCharacterSupplement();
Console.WriteLine($"结束 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
try Thread.Sleep(24 * 60 * 60 * 1000);
{ }
Console.WriteLine($"开始 计算Shopify的备货数量，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); catch (Exception ex)
report.ClearShopifyJitInventory(); {
report.ShopifyJitInventory(); Console.WriteLine("拉取sku特性:" + ex.Message);
Console.WriteLine($"结束 计算Shopify的备货数量，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine("拉取sku特性:" + ex.StackTrace);
Thread.Sleep(60 * 60 * 1000); }
}
catch (Exception ex)
{
Console.WriteLine("计算Shopify的备货数量:" + ex.Message);
Console.WriteLine("计算Shopify的备货数量:" + ex.StackTrace);
}
}
});
Task.Factory.StartNew(() => }
{ });
while (true)
{
try
{
Console.WriteLine($"开始 计算最近7天的订单数量，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
daily.ResetOrders7();
Console.WriteLine($"结束 计算最近7天的订单数量，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
Thread.Sleep(4 * 60 * 60 * 1000);
}
catch (Exception ex)
{
Console.WriteLine("计算最近7天的订单数量:" + ex.Message);
Console.WriteLine("计算最近7天的订单数量:" + ex.StackTrace);
}
}
});
Task.Factory.StartNew(() => Task.Factory.StartNew(() =>
{ {
while (true) while (true)
{ {
try try
{ {
Console.WriteLine($"开始 lm 产品换仓备货，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"开始 计算Shopify的备货数量，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
report.ClearShopifyJitInventory();
report.ShopifyJitInventory();
Console.WriteLine($"结束 计算Shopify的备货数量，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
Thread.Sleep(60 * 60 * 1000);
}
catch (Exception ex)
{
Console.WriteLine("计算Shopify的备货数量:" + ex.Message);
Console.WriteLine("计算Shopify的备货数量:" + ex.StackTrace);
}
}
});
Task.Factory.StartNew(() =>
{
while (true)
{
try
{
Console.WriteLine($"开始 计算最近7天的订单数量，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
daily.ResetOrders7();
Console.WriteLine($"结束 计算最近7天的订单数量，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
Thread.Sleep(4 * 60 * 60 * 1000);
}
catch (Exception ex)
{
Console.WriteLine("计算最近7天的订单数量:" + ex.Message);
Console.WriteLine("计算最近7天的订单数量:" + ex.StackTrace);
}
}
});
Task.Factory.StartNew(() =>
{
while (true)
{
try
{
Console.WriteLine($"开始 lm 产品换仓备货，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
lm_dao.ChangeWarehouseStockUp(); lm_dao.ChangeWarehouseStockUp();
Console.WriteLine($"结束 lm 产品换仓备货，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 lm 产品换仓备货，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
Thread.Sleep(60 * 1000); Thread.Sleep(60 * 1000);
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine(" lm 产品换仓备货:" + ex.Message); Console.WriteLine(" lm 产品换仓备货:" + ex.Message);
Console.WriteLine(" lm 产品换仓备货:" + ex.StackTrace); Console.WriteLine(" lm 产品换仓备货:" + ex.StackTrace);
} }
}
});
Task.Factory.StartNew(() => }
{ });
while (true)
{ Task.Factory.StartNew(() =>
{
try while (true)
{ {
Console.WriteLine($"开始 推送lm的调拨计划，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
try
{
Console.WriteLine($"开始 推送lm的调拨计划，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
lm_dao.PustTransferPlan(); lm_dao.PustTransferPlan();
Console.WriteLine($"结束 推送lm的调拨计划，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); Console.WriteLine($"结束 推送lm的调拨计划，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
Thread.Sleep(60 * 1000); Thread.Sleep(60 * 1000);
} }
catch (Exception ex) catch (Exception ex)
{ {
Console.WriteLine(" 推送lm的调拨计划:" + ex.Message); Console.WriteLine(" 推送lm的调拨计划:" + ex.Message);
Console.WriteLine(" 推送lm的调拨计划:" + ex.StackTrace); Console.WriteLine(" 推送lm的调拨计划:" + ex.StackTrace);
} }
}
});
}
});
return Task.CompletedTask; return Task.CompletedTask;
......
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