[CI SKIP]补充注释

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/BeiSeSyncAppService.cs

@@ -31,6 +31,9 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
             };
         }
 
+        /// <summary>
+        /// 执行备件发运同步
+        /// </summary>
         [UnitOfWork(IsDisabled = true)]
         public virtual async Task Invoke(IServiceProvider serviceProvider)
         {

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/HandSeSyncAppService.cs

@@ -28,11 +28,15 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 同步
         /// </summary>
+        /// <remarks>
+        /// 发运数据手动同步
+        /// JisBBAC、JisHBPO、买单件BBAC、买单件HBPO、直供件BBAC、直供件HBPO、备件、印度件
+        /// </remarks>
         [HttpPost]
         [UnitOfWork(IsDisabled = true)]
         public virtual async Task<IActionResult> SyncAsync([FromBody] EnumBusinessType businessType)
         {
-            using var scope = this._applicationServices.CreateScope();
+            using var scope = _applicationServices.CreateScope();
             IInvocable seSyncAppService = businessType switch
             {
                 EnumBusinessType.JisBBAC => scope.ServiceProvider.GetRequiredService<JisBBACSeSyncAppService>(),

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/JisBBACSeEdiCompareAppService.cs

@@ -29,6 +29,14 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 执行
         /// </summary>
+        /// <remarks>
+        /// 根据PN、无空格的客户零件号分组查询出状态为无Edi数据的发运数据
+        /// 根据PN、无空格的客户零件号分组查询出状态为无发运数据的Edi数据
+        /// 关联发运数据和Edi数据PN相同、无空格的客户零件号系统的前5_000条数据，获取匹配上的PN、CustomerPartCodeNoSpace
+        /// 根据PN、CustomerPartCodeNoSpace查询发运、Eid
+        /// 修改发运数据状态为有Eid数据
+        /// 修改Eid数据状态为有发运数据
+        /// </remarks>
         public async Task Invoke()
         {
             using var serviceScope = _serviceProvider.CreateScope();
@@ -88,14 +96,14 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 处理删除的EDI数据
         /// </summary>
+        /// <remarks>
+        /// 处理10次、每次处理1000条已删除、有发运的Edi数据（JisBBAC）
+        /// 获取对应的发运数据和Edi数据
+        /// 设置发运数据状态为无EDI数据
+        /// 设置EDI数据状态为无发运数据
+        /// </remarks>
         private async Task HandDelEdiDataAsync()
         {
-            /*
-             * 处理有发运数据状态是删除的数据
-             * 获取对应的发运数据
-             * 设置发运数据状态为无EDI数据
-             * 设置EDI数据状态为无发运数据
-             */
             using var serviceScope = _serviceProvider.CreateScope();
             var db = serviceScope.ServiceProvider.GetRequiredService<SettleAccountDbContext>();
             var seed = 0;

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/JisBBACSeSyncAppService.cs

@@ -38,6 +38,9 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
             };
         }
 
+        /// <summary>
+        /// 执行JisBBAC发运同步
+        /// </summary>
         [UnitOfWork(IsDisabled = true)]
         public async Task Invoke(IServiceProvider serviceProvider)
         {

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/JisBBACSeSyncBaseAppService.cs

@@ -51,6 +51,13 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// </summary>
         public SeSyncConfig SeSyncConfigInfo { get; set; }
 
+        /// <summary>
+        /// 执行发运同步
+        /// </summary>
+        /// <remarks>
+        /// 执行JisBBAC、买单件BBAC发运同步
+        /// 从WMS系统中 TM_BJBMPT_JIT_RECORD、TM_BJBMPT_JIS_RECORD 表中获取发运数据
+        /// </remarks>
         [HttpPost]
         public async Task Invoke()
         {
@@ -65,6 +72,10 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 同步JitRecord
         /// </summary>
+        /// <remarks>
+        /// 同步TM_BJBMPT_JIT_RECORD表发运数据
+        /// 同步十次、每次同步100_000条发运数据
+        /// </remarks>
         private async Task SyncJitRecordAsync()
         {
             //同步表名称
@@ -91,7 +102,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
                 var jisSeDetails = ObjectMapper.Map<List<TM_BJBMPT_JIT_RECORD>, List<BBAC_SE_DETAIL>>(wmsSeRecords);
                 if (jisSeDetails.Any())
                 {
-                    await SeDataPutInStorageAsync(jisSeDetails, false).ConfigureAwait(false);
+                    await SeDataPutInStorageAsync(jisSeDetails, syncTableName).ConfigureAwait(false);
                 }
                 else
                 {
@@ -103,6 +114,10 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 同步JisRecord
         /// </summary>
+        /// <remarks>
+        /// 同步TM_BJBMPT_JIS_RECORD表发运数据
+        /// 同步十次、每次同步100_000条发运数据
+        /// </remarks>
         private async Task SyncJisRecordAsync()
         {
             //同步表名称
@@ -129,7 +144,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
                 var jisSeDetails = ObjectMapper.Map<List<TM_BJBMPT_JIS_RECORD>, List<BBAC_SE_DETAIL>>(wmsSeRecords);
                 if (jisSeDetails.Any())
                 {
-                    await SeDataPutInStorageAsync(jisSeDetails, true).ConfigureAwait(false);
+                    await SeDataPutInStorageAsync(jisSeDetails, syncTableName).ConfigureAwait(false);
                 }
                 else
                 {
@@ -141,11 +156,12 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 发运数据入库
         /// </summary>
-        private async Task SeDataPutInStorageAsync(List<BBAC_SE_DETAIL> seDetails, bool isJisTable)
+        /// <remarks>
+        /// 添加客户与厂内零件号关系
+        /// 记录同步位置、发运数据入库、入库寄售库数据
+        /// </remarks>
+        private async Task SeDataPutInStorageAsync(List<BBAC_SE_DETAIL> seDetails, string syncTableName)
         {
-            //同步表名称
-            var syncTableName = isJisTable ? SeSyncConfigInfo.SyncTableName +
-        "_Jis" : SeSyncConfigInfo.SyncTableName + "_Jit";
             //业务类别
             var businessType = SeSyncConfigInfo.BusinessType;
 
@@ -189,6 +205,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
                     _settleAccountDbContext.Add<SyncPositionFlag>(syncPositionFlag);
                 }
                 await _settleAccountDbContext.BulkInsertAsync(seDetails).ConfigureAwait(false);
+                var isJisTable = syncTableName.EndsWith("_Jis");
                 await _syncExtendManager.JisSeDetailsSaveConsignAsync<BBAC_SE_DETAIL>(seDetails, isJisTable).ConfigureAwait(false);
                 await _settleAccountDbContext.SaveChangesAsync().ConfigureAwait(false);
                 await transaction.CommitAsync().ConfigureAwait(false);

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/JisHBPOSeEdiCompareAppService.cs

@@ -30,6 +30,14 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 执行
         /// </summary>
+        /// <remarks>
+        /// 根据PN、无空格的客户零件号分组查询出状态为无Edi数据的发运数据
+        /// 根据PN、无空格的客户零件号分组查询出状态为无发运数据的Edi数据
+        /// 关联发运数据和Edi数据PN相同、无空格的客户零件号系统的前5_000条数据，获取匹配上的PN、CustomerPartCodeNoSpace
+        /// 根据PN、CustomerPartCodeNoSpace查询发运、Eid
+        /// 修改发运数据状态为有Eid数据
+        /// 修改Eid数据状态为有发运数据
+        /// </remarks>
         public async Task Invoke()
         {
             using var serviceScope = _serviceProvider.CreateScope();
@@ -89,6 +97,12 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 处理删除的EDI数据
         /// </summary>
+        /// <remarks>
+        /// 处理10次、每次处理1000条已删除、有发运的Edi数据（JisHBPO）
+        /// 获取对应的发运数据和Edi数据
+        /// 设置发运数据状态为无EDI数据
+        /// 设置EDI数据状态为无发运数据
+        /// </remarks>
         private async Task HandDelEdiDataAsync()
         {
             using var serviceScope = _serviceProvider.CreateScope();

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/JisHBPOSeSyncAppService.cs

@@ -36,6 +36,9 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
             };
         }
 
+        /// <summary>
+        /// 执行JisHBPO发运同步
+        /// </summary>
         [UnitOfWork(IsDisabled = true)]
         public virtual async Task Invoke(IServiceProvider serviceProvider)
         {

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/JisHBPOSeSyncBaseAppService.cs

@@ -52,6 +52,13 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// </summary>
         public SeSyncConfig SeSyncConfigInfo { get; set; }
 
+        /// <summary>
+        /// 执行发运同步
+        /// </summary>
+        /// <remarks>
+        /// 执行JisBBAC、买单件BBAC发运同步
+        /// 从WMS系统中 TM_BJBMPT_JIT_RECORD、TM_BJBMPT_JIS_RECORD 表中获取发运数据
+        /// </remarks>
         [HttpPost]
         public virtual async Task Invoke()
         {
@@ -66,6 +73,10 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 同步JitRecord
         /// </summary>
+        /// <remarks>
+        /// 同步TM_BJBMPT_JIT_RECORD表发运数据
+        /// 同步十次、每次同步100_000条发运数据
+        /// </remarks>
         private async Task SyncJitRecordAsync()
         {
             //同步表名称
@@ -92,7 +103,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
                 var jisSeDetails = ObjectMapper.Map<List<TM_BJBMPT_JIT_RECORD>, List<HBPO_SE_DETAIL>>(wmsSeRecords);
                 if (jisSeDetails.Any())
                 {
-                    await SeDataPutInStorageAsync(jisSeDetails, false).ConfigureAwait(false);
+                    await SeDataPutInStorageAsync(jisSeDetails, syncTableName).ConfigureAwait(false);
                 }
                 else
                 {
@@ -104,6 +115,10 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 同步JisRecord
         /// </summary>
+        /// <remarks>
+        /// 同步TM_BJBMPT_JIS_RECORD表发运数据
+        /// 同步十次、每次同步100_000条发运数据
+        /// </remarks>
         private async Task SyncJisRecordAsync()
         {
             //同步表名称
@@ -130,7 +145,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
                 var jisSeDetails = ObjectMapper.Map<List<TM_BJBMPT_JIS_RECORD>, List<HBPO_SE_DETAIL>>(wmsRecords);
                 if (jisSeDetails.Any())
                 {
-                    await SeDataPutInStorageAsync(jisSeDetails, true).ConfigureAwait(false);
+                    await SeDataPutInStorageAsync(jisSeDetails, syncTableName).ConfigureAwait(false);
                 }
                 else
                 {
@@ -142,11 +157,12 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 发运数据入库
         /// </summary>
-        private async Task SeDataPutInStorageAsync(List<HBPO_SE_DETAIL> seDetails, bool isJisTable)
+        /// <remarks>
+        /// 添加客户与厂内零件号关系
+        /// 记录同步位置、发运数据入库、入库寄售库数据
+        /// </remarks>
+        private async Task SeDataPutInStorageAsync(List<HBPO_SE_DETAIL> seDetails, string syncTableName)
         {
-            //同步表名称
-            var syncTableName = isJisTable ? SeSyncConfigInfo.SyncTableName +
-        "_Jis" : SeSyncConfigInfo.SyncTableName + "_Jit";
             //业务类别
             var businessType = SeSyncConfigInfo.BusinessType;
 
@@ -190,6 +206,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
                     _settleAccountDbContext.Add<SyncPositionFlag>(syncPositionFlag);
                 }
                 await _settleAccountDbContext.BulkInsertAsync(seDetails).ConfigureAwait(false);
+                var isJisTable = syncTableName.EndsWith("_Jis");
                 await _syncExtendManager.JisSeDetailsSaveConsignAsync<HBPO_SE_DETAIL>(seDetails, isJisTable).ConfigureAwait(false);
                 await _settleAccountDbContext.SaveChangesAsync().ConfigureAwait(false);
                 await transaction.CommitAsync().ConfigureAwait(false);

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/JitSeSyncAppService.cs

@@ -50,6 +50,15 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// </summary>
         public SeSyncConfig SeSyncConfigInfo { get; set; }
 
+        /// <summary>
+        /// 执行发运同步
+        /// </summary>
+        /// <remarks>
+        /// 直供件BBAC、直供件HBPO、备件、印度件发运同步
+        /// 数据同步规则
+        /// * 同步十次、每次同步100_000条发运数据
+        /// * 每次同步需要记录同步WMS数据的最大Id（递增Id）、下次同步从最大Id向后查询数据
+        /// </remarks>
         [HttpPost]
         public async Task Invoke()
         {
@@ -91,6 +100,10 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 发运数据入库
         /// </summary>
+        /// <remarks>
+        /// 除了备件业务外，直供件BBAC、直供件HBPO、印度件业务需要添加客户与厂内零件号关系
+        /// 记录同步位置、发运数据入库、入库寄售库数据
+        /// </remarks>
         private async Task SeDataPutInStorageAsync(List<PUB_SE_DETAIL> seDetails)
         {
             var syncTableName = SeSyncConfigInfo.SyncTableName;

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/MaiDanBBACSeSyncAppService.cs

@@ -38,6 +38,9 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
             };
         }
 
+        /// <summary>
+        /// 执行买单件BBAC发运同步
+        /// </summary>
         [UnitOfWork(IsDisabled = true)]
         public async Task Invoke(IServiceProvider serviceProvider)
         {

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/MaiDanHBPOSeSyncAppService.cs

@@ -36,6 +36,9 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
             };
         }
 
+        /// <summary>
+        /// 执行买单件HBPO发运同步
+        /// </summary>
         [UnitOfWork(IsDisabled = true)]
         public async Task Invoke(IServiceProvider serviceProvider)
         {

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/SeSyncExtendManager.cs

@@ -32,6 +32,10 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// 添加零件关系
         /// </summary>
+        /// <remarks>
+        /// 过滤客户零件号、厂内零件号、业务类型已存在的数据
+        /// 其他数据入库
+        /// </remarks>
         public async Task AddNewMaterialRelationshipsAsync(IEnumerable<MaterialRelationship> materialRelationships)
         {
             //新客户零件号和厂内零件号
@@ -52,6 +56,11 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// Jis发运数据保存寄售库
         /// </summary>
+        /// <remarks>
+        /// JisBBAC、JisHBPO、买单件BBAC、买单件HBPO发运同步保存寄售库
+        /// isJisTable 用于区分数据来源表 TM_BJBMPT_JIS_RECORD、TM_BJBMPT_JIT_RECORD
+        /// 不同表获取的字段有差别
+        /// </remarks>
         public async Task JisSeDetailsSaveConsignAsync<T>(List<T> seDetails, bool isJisTable) where T : JisSeBase
         {
             var deliverSeDetails = seDetails.FindAll(t => t.TransType == EnumDelTransType.发货);
@@ -121,6 +130,10 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
         /// <summary>
         /// Pub发运数据保存寄售库
         /// </summary>
+        /// <remarks>
+        /// 直供件BBAC、直供件HBPO、备件、印度件
+        /// 发运同步保存寄售库
+        /// </remarks>
         public async Task PubSeDetailsSaveConsignAsync(List<PUB_SE_DETAIL> seDetails)
         {
             var deliverSeDetails = seDetails.FindAll(t => t.TransType == EnumDelTransType.发货);

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/YinDuSeSyncAppService.cs

@@ -31,6 +31,9 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
             };
         }
 
+        /// <summary>
+        /// 执行印度件发运同步
+        /// </summary>
         [UnitOfWork(IsDisabled = true)]
         public virtual async Task Invoke(IServiceProvider serviceProvider)
         {

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/ZhiGongBBACSeSyncAppService.cs

@@ -31,6 +31,9 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
             };
         }
 
+        /// <summary>
+        /// 执行直供件BBAC发运同步
+        /// </summary>
         [UnitOfWork(IsDisabled = true)]
         public virtual async Task Invoke(IServiceProvider serviceProvider)
         {

code/src/Modules/SettleAccount/src/SettleAccount.Application/Entities/BQ/Syncs/ZhiGongHBPOSeSyncAppService.cs

@@ -31,6 +31,9 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs
             };
         }
 
+        /// <summary>
+        /// 执行直供件HBPO发运同步
+        /// </summary>
         [UnitOfWork(IsDisabled = true)]
         public virtual async Task Invoke(IServiceProvider serviceProvider)
         {