新增fba实时库存下载服务

AutoTurnOver.Models/dc_fba_inventory_realtime.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace AutoTurnOver.Models
+{
+    /// <summary>
+    /// fba 实时库存
+    /// </summary>
+    public class dc_fba_inventory_realtime
+    {
+        public int id { get; set; }
+        public string seller_sku { get; set; }
+        public string fulfillment_channel_sku { get; set; }
+        public string asin { get; set; }
+        public string condition_type { get; set; }
+        public string warehouse_condition_code { get; set; }
+        public decimal quantity_available { get; set; }
+        public string unique_id { get; set; }
+        public DateTime last_update_date { get; set; }
+        public string account { get; set; }
+        public string site { get; set; }
+        public string marketplaceId { get; set; }
+    }
+}

AutoTurnOver.RabbitMqService/AnaFbaInventoryRabbitBackgroundService.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
+{
+    /// <summary>
+    /// 读取fba实时库存
+    /// </summary>
+    class AnaFbaInventoryRabbitBackgroundService : RabbitWorkerBase<t_task_queue>
+    {
+
+        public AnaFbaInventoryRabbitBackgroundService() : base("fba实时库存", "aims:AnaFbaInventory:input", 1)
+        {
+
+        }
+
+        protected override async Task DoWork(t_task_queue taskDto)
+        {
+
+
+            try
+            {
+                var pars = taskDto.id.Split("_");
+                new AmazonDataSynchroService().AnaFbaInventoryReport(int.Parse(pars[0]), pars[1]);
+                Console.WriteLine($"fba实时库存 完成  ");
+            }
+            catch (Exception e)
+            {
+                RabbitMQHelper.EnqueneMsg("aims:AnaFbaInventory:input", taskDto);
+                Console.WriteLine($"fba实时库存 数据异常，异常原因为：{e.Message}，异常堆栈为：{e.StackTrace}");
+            }
+
+        }
+    }
+}

AutoTurnOver.RabbitMqService/Program.cs

@@ -39,6 +39,7 @@ namespace AutoTurnOver.RabbitMqService
                     services.AddHostedService<AnaFbaInventoryStorageFeeRabbitBackgroundService>();
                     services.AddHostedService<AnaFbaOverageStorageFeeRabbitBackgroundService>();
                     services.AddHostedService<SynchroFinancialEventGroupsRabbitBackgroundService>();
+                    services.AddHostedService<AnaFbaInventoryRabbitBackgroundService>();
                 }
               
 

FikaAmazonAPI/AmazonSpApiSDK/Models/Finances/AdjustmentEventList.cs

@@ -100,4 +100,87 @@ namespace FikaAmazonAPI.AmazonSpApiSDK.Models.Finances
         }
     }
 
+    /// <summary>
+    /// A list of adjustment event information for the seller&#39;s account.
+    /// </summary>
+    [DataContract]
+    public partial class CapacityReservationBillingEventList : List<CapacityReservationBillingEvent>, IEquatable<CapacityReservationBillingEventList>, IValidatableObject
+    {
+        /// <summary>
+        /// Initializes a new instance of the <see cref="AdjustmentEventList" /> class.
+        /// </summary>
+        [JsonConstructorAttribute]
+        public CapacityReservationBillingEventList() : base()
+        {
+        }
+
+        /// <summary>
+        /// Returns the string presentation of the object
+        /// </summary>
+        /// <returns>String presentation of the object</returns>
+        public override string ToString()
+        {
+            var sb = new StringBuilder();
+            sb.Append("class CapacityReservationBillingEventList {\n");
+            sb.Append("  ").Append(base.ToString().Replace("\n", "\n  ")).Append("\n");
+            sb.Append("}\n");
+            return sb.ToString();
+        }
+
+        /// <summary>
+        /// Returns the JSON string presentation of the object
+        /// </summary>
+        /// <returns>JSON string presentation of the object</returns>
+        public string ToJson()
+        {
+            return JsonConvert.SerializeObject(this, Formatting.Indented);
+        }
+
+        /// <summary>
+        /// Returns true if objects are equal
+        /// </summary>
+        /// <param name="input">Object to be compared</param>
+        /// <returns>Boolean</returns>
+        public override bool Equals(object input)
+        {
+            return this.Equals(input as CapacityReservationBillingEventList);
+        }
+
+        /// <summary>
+        /// Returns true if AdjustmentEventList instances are equal
+        /// </summary>
+        /// <param name="input">Instance of AdjustmentEventList to be compared</param>
+        /// <returns>Boolean</returns>
+        public bool Equals(CapacityReservationBillingEventList input)
+        {
+            if (input == null)
+                return false;
+
+            return base.Equals(input);
+        }
+
+        /// <summary>
+        /// Gets the hash code
+        /// </summary>
+        /// <returns>Hash code</returns>
+        public override int GetHashCode()
+        {
+            unchecked // Overflow is fine, just wrap
+            {
+                int hashCode = base.GetHashCode();
+                return hashCode;
+            }
+        }
+
+        /// <summary>
+        /// To validate all properties of the instance
+        /// </summary>
+        /// <param name="validationContext">Validation context</param>
+        /// <returns>Validation Result</returns>
+        IEnumerable<System.ComponentModel.DataAnnotations.ValidationResult> IValidatableObject.Validate(ValidationContext validationContext)
+        {
+            yield break;
+        }
+    }
+
 }

FikaAmazonAPI/AmazonSpApiSDK/Models/Finances/FinancialEvents.cs

@@ -162,6 +162,11 @@ namespace FikaAmazonAPI.AmazonSpApiSDK.Models.Finances
         /// </summary>
         [DataMember(Name = "AdjustmentEventList", EmitDefaultValue = false)]
         public AdjustmentEventList AdjustmentEventList { get; set; }
+        /// <summary>
+        /// Gets or Sets AdjustmentEventList
+        /// </summary>
+        [DataMember(Name = "CapacityReservationBillingEventList", EmitDefaultValue = false)]
+        public AdjustmentEventList CapacityReservationBillingEventList { get; set; }
 
         /// <summary>
         /// Gets or Sets SAFETReimbursementEventList

ResetOutofstock/Program.cs

@@ -49,16 +49,16 @@ namespace ResetOutofstock
                 //report_invest_return_dao.SynchBtmOrderRefund();
                 //report_invest_return_dao.CalculationStockScore("962073701");
                 //dc_ana_deviation_dao.PushAnaTask();
-                new AmazonDataSynchroService().SynchroFinancialEventGroups("Natural Daisy Encens", "ES");
+                //new AmazonDataSynchroService().SynchroFinancialEventGroups("Natural Daisy Encens", "ES");
                 //new AmazonDataSynchroService().SetMarketplaceName(DateTime.Now);
                 //new AmazonDataSynchroService().SetSettlementByDate();
                 //new AmazonDataSynchroService().SetMarketplaceNameByDate();
                 //new AmazonDataSynchroService().SynchroReportIds();
 
-                //new AmazonDataSynchroService().SynchroReportIdByCreate(FikaAmazonAPI.Utils.Constants.ReportTypes.GET_FBA_REIMBURSEMENTS_DATA, 17, "Siqidzi", "ES",DateTime.Parse("2023-03-01"),DateTime.Parse("2023-03-31 23:59:59"));
+                //new AmazonDataSynchroService().SynchroReportIdByCreate(FikaAmazonAPI.Utils.Constants.ReportTypes.GET_AFN_INVENTORY_DATA, 17, "Siqidzi", "ES");
                 //new AmazonDataSynchroService().SynchroReportIdByCreate(FikaAmazonAPI.Utils.Constants.ReportTypes.GET_FBA_INVENTORY_PLANNING_DATA, version: 22, account: "Elite99 Nail Art", site: "US",
                 //   btime: DateTime.Parse("2023-04-01"), DateTime.Parse("2023-04-24 23:59:59"));
-                //new AmazonDataSynchroService().SynchroReportIds(FikaAmazonAPI.Utils.Constants.ReportTypes.GET_AMAZON_FULFILLED_SHIPMENTS_DATA_GENERAL, 13);
+                //new AmazonDataSynchroService().SynchroReportIds(FikaAmazonAPI.Utils.Constants.ReportTypes.GET_AFN_INVENTORY_DATA, 13, "Natural Daisy Encens", "ES");
                 //new AmazonDataSynchroService().AnaFbaShipmentReport();
                 //new AmazonDataSynchroService().AnaFbaStorageFeeReport(status:-1);
                 //new AmazonDataSynchroService().AnaFbaLongTermStorageFeeReport(3);
@@ -66,6 +66,7 @@ namespace ResetOutofstock
                 //new AmazonDataSynchroService().AnaFbaOverageStorageFeeReport(report_id: "937084019471");
 
                 //new AmazonDataSynchroService().AnaFbaStorageFeeReport(data_id: "323250019473");
+                //new AmazonDataSynchroService().AnaFbaInventoryReport();
 
                 //new AmazonDataSynchroService().SynchroReportIdByCreate(
                 //      FikaAmazonAPI.Utils.Constants.ReportTypes.GET_FBA_STORAGE_FEE_CHARGES_DATA,