fix

AutoTurnOver.RabbitMqService/AnaFbaInventoryStorageFeeRabbitBackgroundService.cs

+using AutoTurnOver.DB;
+using AutoTurnOver.Models;
+using AutoTurnOver.Services;
+using AutoTurnOver.Utility;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ResetOutofstock
+{
+    class AnaFbaInventoryStorageFeeRabbitBackgroundService : RabbitWorkerBase<t_task_queue>
+    {
+
+        public AnaFbaInventoryStorageFeeRabbitBackgroundService() : base("解析亚马逊服务费", "aims:AnaFbaInventoryStorageFee:input", 1)
+        {
+
+        }
+
+        protected override async Task DoWork(t_task_queue taskDto)
+        {
+
+
+            try
+            {
+                var pars = taskDto.id.Split("_");
+                new AmazonDataSynchroService().AnaFbaLongTermStorageFeeReport(int.Parse(pars[0]), pars[1]);
+                Console.WriteLine($"解析亚马逊服务费 完成  ");
+            }
+            catch (Exception e)
+            {
+                RabbitMQHelper.EnqueneMsg("aims:AnaFbaInventoryStorageFee:input", taskDto);
+                Console.WriteLine($"解析亚马逊服务费 数据异常，异常原因为：{e.Message}，异常堆栈为：{e.StackTrace}");
+            }
+
+        }
+    }
+}

AutoTurnOver.RabbitMqService/AnaFbaOverageStorageFeeRabbitBackgroundService.cs

+using AutoTurnOver.DB;
+using AutoTurnOver.Models;
+using AutoTurnOver.Services;
+using AutoTurnOver.Utility;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ResetOutofstock
+{
+    class AnaFbaOverageStorageFeeRabbitBackgroundService : RabbitWorkerBase<t_task_queue>
+    {
+
+        public AnaFbaOverageStorageFeeRabbitBackgroundService() : base("解析亚马逊服务费", "aims:AnaFbaOverageStorageFee:input", 1)
+        {
+
+        }
+
+        protected override async Task DoWork(t_task_queue taskDto)
+        {
+
+
+            try
+            {
+                var pars = taskDto.id.Split("_");
+                new AmazonDataSynchroService().AnaFbaOverageStorageFeeReport(int.Parse(pars[0]), pars[1]);
+                Console.WriteLine($"解析亚马逊服务费 完成  ");
+            }
+            catch (Exception e)
+            {
+                RabbitMQHelper.EnqueneMsg("aims:AnaFbaStorageFee:input", taskDto);
+                Console.WriteLine($"解析亚马逊服务费 数据异常，异常原因为：{e.Message}，异常堆栈为：{e.StackTrace}");
+            }
+
+        }
+    }
+}

AutoTurnOver.RabbitMqService/Program.cs

@@ -31,6 +31,8 @@ namespace AutoTurnOver.RabbitMqService
                 if ("amazon_storage_fee".Equals(environmentName))
                 {
                     services.AddHostedService<AnaFbaStorageFeeRabbitBackgroundService>();
+                    services.AddHostedService<AnaFbaInventoryStorageFeeRabbitBackgroundService>();
+                    services.AddHostedService<AnaFbaOverageStorageFeeRabbitBackgroundService>();
                 }
               
 

ResetOutofstock/ResetOutofstockBackgrounService.cs

@@ -794,6 +794,8 @@ namespace ResetOutofstock
                 {
                     Console.WriteLine($"开始  提交解析月度仓储费任务，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                     new AmazonDataSynchroService().AnaFbaStorageFeeReportSubmit("GET_FBA_STORAGE_FEE_CHARGES_DATA", "aims:AnaFbaStorageFee:input");
+                    new AmazonDataSynchroService().AnaFbaStorageFeeReportSubmit("GET_FBA_INVENTORY_PLANNING_DATA", "aims:AnaFbaInventoryStorageFee:input");
+                    new AmazonDataSynchroService().AnaFbaStorageFeeReportSubmit("GET_FBA_OVERAGE_FEE_CHARGES_DATA", "aims:AnaFbaOverageStorageFee:input");
                     //new AmazonDataSynchroService().AnaFbaStorageFeeReport(-1);
                     Console.WriteLine($"结束 提交解析月度仓储费任务，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                     Thread.Sleep(500);
@@ -807,52 +809,8 @@ namespace ResetOutofstock
 
             }
         });
-            Task.Factory.StartNew(() =>
-        {
-            while (true)
-            {
-
-                try
-                {
-                    Console.WriteLine($"开始  解析亚马逊长期仓储费，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
-                    new AmazonDataSynchroService().AnaFbaLongTermStorageFeeReport();
-                    new AmazonDataSynchroService().AnaFbaLongTermStorageFeeReport(-1);
-                    Console.WriteLine($"结束 解析亚马逊长期仓储费，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
-                    Thread.Sleep(1000 * 3);
-                }
-                catch (Exception ex)
-                {
-                    Console.WriteLine(" 解析解析亚马逊长期仓储费:" + ex.Message);
-                    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")}");
-                    new AmazonDataSynchroService().AnaFbaOverageStorageFeeReport();
-                    new AmazonDataSynchroService().AnaFbaOverageStorageFeeReport(-1);
-                    Console.WriteLine($"结束 解析亚马逊超量仓储费，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
-                    Thread.Sleep(1000 * 3);
-                }
-                catch (Exception ex)
-                {
-                    Console.WriteLine(" 解析解析亚马逊长期仓储费:" + ex.Message);
-                    Console.WriteLine(" 解析解析亚马逊长期仓储费 :" + ex.StackTrace);
-                }
-
-
-            }
-        });
-
 
             Task.Factory.StartNew(() =>
         {