升级缺货改零算法

AutoTurnOver.Services/ReportServices.cs

@@ -453,11 +453,20 @@ namespace AutoTurnOver.Services
             List<string> platform1s = new List<string> {"ebay","amazon", "aliexpress", "shopee", "wish", "lazada" };
             foreach (var item in platform1s.Where(s=> string.IsNullOrWhiteSpace(platform) || platform==s))
             {
-                List<dc_auto_shortage_push> datas = new List<dc_auto_shortage_push>();
-                datas.AddRange(report.ChinaShortagePush(item, is_all));
-                var err_datas = ApiServices.ShortagePush(datas, item);
-                // 记录推送状态
-                report.AddShortagePush(datas.Where(s => !err_datas.Any(e => e.warehouseCode == s.warehouse_code && s.bailun_sku == e.sku)));
+                try
+                {
+                    List<dc_auto_shortage_push> datas = new List<dc_auto_shortage_push>();
+                    datas.AddRange(report.ChinaShortagePush(item, is_all));
+                    var err_datas = ApiServices.ShortagePush(datas, item);
+                    // 记录推送状态
+                    report.AddShortagePush(datas.Where(s => !err_datas.Any(e => e.warehouseCode == s.warehouse_code && s.bailun_sku == e.sku)));
+                }
+                catch (Exception ex)
+                {
+                    Console.WriteLine(ex.Message);
+                    Console.WriteLine(ex.StackTrace);
+                }
+                
             }
 
             //国外仓1
@@ -465,11 +474,20 @@ namespace AutoTurnOver.Services
             List<string> rule1 = new List<string> { "GBYKD", "JZHYBLGC", "MDBLWYT", "MXBLWYT", "BLUSGDC", "GBBMHBL", "GB4PXBL", "DEBLDG", "USGCBL", "USHWBL", "US4PXBL", "AUWYTBL", "AU4PXBL", "GBWYTUK", "BLGBPX" };
             foreach (var item in platform2s.Where(s => string.IsNullOrWhiteSpace(platform) || platform == s))
             {
-                List<dc_auto_shortage_push> datas = new List<dc_auto_shortage_push>();
-                datas.AddRange(report.NotChinaShortagePush(rule1, item, is_all));
-                var err_datas = ApiServices.ShortagePush(datas, item);
-                // 记录推送状态
-                report.AddShortagePush(datas.Where(s => !err_datas.Any(e => e.warehouseCode == s.warehouse_code && s.bailun_sku == e.sku)));
+                try
+                {
+                    List<dc_auto_shortage_push> datas = new List<dc_auto_shortage_push>();
+                    datas.AddRange(report.NotChinaShortagePush(rule1, item, is_all));
+                    var err_datas = ApiServices.ShortagePush(datas, item);
+                    // 记录推送状态
+                    report.AddShortagePush(datas.Where(s => !err_datas.Any(e => e.warehouseCode == s.warehouse_code && s.bailun_sku == e.sku)));
+                }
+                catch (Exception ex)
+                {
+                    Console.WriteLine(ex.Message);
+                    Console.WriteLine(ex.StackTrace);
+                }
+                
             }
 
             // 国外仓2
@@ -477,11 +495,20 @@ namespace AutoTurnOver.Services
             List<string> rule2 = new List<string> {"MDBLWYT", "MXBLWYT", "BLUSGDC", "USGCBL", "USHWBL", "US4PXBL" };
             foreach (var item in platform3s.Where(s => string.IsNullOrWhiteSpace(platform) || platform == s))
             {
-                List<dc_auto_shortage_push> datas = new List<dc_auto_shortage_push>();
-                datas.AddRange(report.NotChinaShortagePush(rule2, item, is_all));
-                var err_datas = ApiServices.ShortagePush(datas, item);
-                // 记录推送状态
-                report.AddShortagePush(datas.Where(s => !err_datas.Any(e => e.warehouseCode == s.warehouse_code && s.bailun_sku == e.sku)));
+                try
+                {
+                    List<dc_auto_shortage_push> datas = new List<dc_auto_shortage_push>();
+                    datas.AddRange(report.NotChinaShortagePush(rule2, item, is_all));
+                    var err_datas = ApiServices.ShortagePush(datas, item);
+                    // 记录推送状态
+                    report.AddShortagePush(datas.Where(s => !err_datas.Any(e => e.warehouseCode == s.warehouse_code && s.bailun_sku == e.sku)));
+                }
+                catch (Exception ex)
+                {
+                    Console.WriteLine(ex.Message);
+                    Console.WriteLine(ex.StackTrace);
+                }
+                
             }
 
         }

ShortagePush/Program.cs

@@ -13,6 +13,7 @@ namespace ShortagePush
         {
             Console.WriteLine("推送缺货数据服务");
             new ReportServices().ShortagePush();
+            //new ReportServices().ShortagePush(platform: "ebay");
             var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
             {
                 services.AddHostedService<ShortagePushBackgroundService>();