[172]直供HBPO结算导入变更，需要按目标库位字段区分CN1与CN5，CC004=亦庄=CN1;CC172=顺义=CN5

code/src/Modules/SettleAccount/src/SettleAccount.Application.Contracts/Entities/BQ/Dtos/PUB_SA_DTO.cs

@@ -162,9 +162,11 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Dtos
         /// <summary>
         /// 地点
         /// </summary>
-        [Display(Name = "地点")]
-        [ImporterHeader(Name = "地点")]
+        [Display(Name = "目标库位")]
+        [ImporterHeader(Name = "目标库位")]
         [Required(ErrorMessage = "{0}不能为空")]
+        [ValueMapping("CC004", "CN1")]
+        [ValueMapping("CC172", "CN5")]
         public string Place { get; set; }
     }
 

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/INVOICE_SERVICE.cs

@@ -48,6 +48,7 @@ using Win.Sfs.Shared.RepositoryBase;
 using static Dm.parser.LVal;
 using static LinqToDB.Sql;
 using Win.Sfs.Shared.Filter;
+using Polly;
 
 namespace Win.Sfs.SettleAccount.Entities.BQ
 {
@@ -208,7 +209,17 @@ namespace Win.Sfs.SettleAccount.Entities.BQ
                 invoiceGrps.ForEach(t => t.State = SettleBillState.已提交QAD);
 
                 await _exChangeCenterDbContext.SaveChangesAsync().ConfigureAwait(false);
-                await _settleAccountDbContext.SaveChangesAsync().ConfigureAwait(false);
+
+                var retryPolicyAsync = Policy.Handle<Exception>().WaitAndRetryAsync(new[] {
+                    TimeSpan.FromSeconds(1),
+                    TimeSpan.FromSeconds(5),
+                    TimeSpan.FromSeconds(5),
+                    TimeSpan.FromSeconds(5)
+                }, (exception, timeSpan, retryCount, context) =>
+                {
+                    Console.WriteLine($"执行失败，第 {retryCount} 次重试");
+                });
+                await retryPolicyAsync.ExecuteAsync(async () => await _settleAccountDbContext.SaveChangesAsync().ConfigureAwait(false)).ConfigureAwait(false);
             }
 
             await Task.CompletedTask.ConfigureAwait(false);

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/PUB_SA_SERVICE.cs

@@ -135,7 +135,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ
             version = pubSaImportRequestDto.Version;
             businessType = pubSaImportRequestDto.BusinessType;
             site = pubSaImportRequestDto.Site;
-            switch (pubSaImportRequestDto.BusinessType)
+            switch (businessType)
             {
                 case EnumBusinessType.ZhiGongJianBBAC:
                     result = await ImportZhiGongJianBBACAsync(pubSaImportRequestDto.Files).ConfigureAwait(false);
@@ -301,7 +301,29 @@ namespace Win.Sfs.SettleAccount.Entities.BQ
             importPubSaDetails = HandleSaDetails(importPubSaDetails);
 
             #region 数据校验
-            var checkList = await CheckAsync(importPubSaDetails).ConfigureAwait(false);
+            var place = importPubSaDetails.FirstOrDefault().Place;
+            if (place != "CN1" && place != "CN5")
+            {
+                return new JsonResult(new { Code = 400, Message = $"目标库位值【{place}】无效" });
+            }
+            //数据校验
+            var checkList = new List<ErrorExportDto>();
+            //结算分组号
+            var pubSaGroupNums = importPubSaDetails.Select(t => t.GroupNum).Distinct();
+            //已存在的结算分组号
+            var havPubSaGroupNums = (await _pubSaDetailRepository.GetListAsync(t => t.Place == place && pubSaGroupNums.Contains(t.GroupNum)).ConfigureAwait(false)).Select(t => t.GroupNum).Distinct();
+            if (havPubSaGroupNums.Any() == true)
+            {
+                foreach (var item in havPubSaGroupNums)
+                {
+                    checkList.Add(new ErrorExportDto(string.Empty, string.Empty, string.Empty, string.Empty, string.Empty, string.Empty, $"结算分组号{item}已存在", string.Empty));
+                }
+            }
+
+            if (!checkList.Any())
+            {
+                checkList.AddRange(await CheckMaterialRelationshipAsync(importPubSaDetails).ConfigureAwait(false));
+            }
             if (checkList.Count > 0)
             {
                 string fileName = await ExportErrorReportAsync(checkList).ConfigureAwait(false);
@@ -403,6 +425,25 @@ namespace Win.Sfs.SettleAccount.Entities.BQ
 
             if (!checkList.Any())
             {
+                //验证客户对应厂内零件号是否存在
+                checkList.AddRange(await CheckMaterialRelationshipAsync(pubSaDetails).ConfigureAwait(false));
+            }
+
+            return checkList;
+            #endregion
+        }
+
+        /// <summary>
+        /// 数据校验
+        /// </summary>
+        /// <remarks>
+        /// 验证客户-厂内零件号关系是否已存在
+        /// </remarks>
+        private async Task<List<ErrorExportDto>> CheckMaterialRelationshipAsync(List<PUB_SA_DETAIL> pubSaDetails)
+        {
+            #region 数据校验
+            //数据校验
+            var checkList = new List<ErrorExportDto>();
             //验证客户对应厂内零件号是否存在
             //导入的零件号集合
             var importPubSaLUs = pubSaDetails.Select(t => t.LU).Distinct();
@@ -415,8 +456,6 @@ namespace Win.Sfs.SettleAccount.Entities.BQ
             {
                 checkList.Add(new ErrorExportDto(string.Empty, string.Empty, string.Empty, string.Empty, string.Empty, string.Empty, $"客户零件号【{t}】对应厂内零件号系统中不存在", string.Empty));
             });
-            }
-
             return checkList;
             #endregion
         }