新增亚马逊结算表的拉取

AutoTurnOver.Models/dc_base_amazon_settlement.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace AutoTurnOver.Models
+{
+    public class dc_base_amazon_settlement
+    {
+        public int id { get; set; }
+        public string settlement_id { get; set; }
+        public decimal amount { get; set; }
+        public DateTime? start_date { get; set; }
+        public DateTime? end_date { get; set; }
+        public DateTime? deposit_date { get; set; }
+        public DateTime _ts { get; set; }
+        public string account { get; set; }
+        public string data_id { get; set; }
+    }
+}

AutoTurnOver.Services/AmazonDataSynchroService.cs

@@ -623,6 +623,26 @@ namespace AutoTurnOver.Services
                         }
 
                     }
+
+                    dc_base_amazon_settlement settlementDbData = new dc_base_amazon_settlement {
+                        amount = settlementData.AmazonEnvelope.Message.SettlementReport.SettlementData.TotalAmount.Text??0,
+                        account = pamsAccount.Account,
+                        settlement_id = settlementData.AmazonEnvelope.Message.SettlementReport.SettlementData.AmazonSettlementID,
+                        deposit_date = settlementData.AmazonEnvelope.Message.SettlementReport.SettlementData.DepositDate,
+                        end_date = settlementData.AmazonEnvelope.Message.SettlementReport.SettlementData.EndDate,
+                        start_date = settlementData.AmazonEnvelope.Message.SettlementReport.SettlementData.StartDate,
+                        _ts = DateTime.Now
+                    };
+                    settlementDbData.data_id = $"{settlementDbData.account}-{settlementDbData.settlement_id}";
+                    settlementDbData.id = MyMySqlConnection._connection.QueryFirstOrDefault<int?>("select id from dc_base_amazon_settlement where data_id=@data_id", new { data_id = settlementDbData.data_id }) ?? 0;
+                    if (settlementDbData.id > 0)
+                    {
+                        MyMySqlConnection._connection.Update(settlementDbData);
+                    }
+                    else
+                    {
+                        MyMySqlConnection._connection.Insert(settlementDbData);
+                    }
                 }