Merge branch 'master' of http://dev.ccwin-in.com:3000/BoXu.Zheng/BeiJinSettleAccount

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

@@ -20,6 +20,7 @@ using Win.Sfs.SettleAccount.Entities.BQ.Syncs;
 using Win.Sfs.SettleAccount.Entities.BQ.Vmi;
 using Win.Sfs.Shared.RepositoryBase;
 using Win.Sfs.SettleAccount.Entities.TaskJobs;
+using Volo.Abp.Uow;
 
 namespace Win.Sfs.SettleAccount.Entities.BQ
 {
@@ -43,24 +44,18 @@ namespace Win.Sfs.SettleAccount.Entities.BQ
         {
             _service = service;
         }
-
+     
         public override async Task<string> ApprovalPassed(List<string> p_list)
         {
             var detailist = _detailRepository.Where(p => p_list.Contains(p.BillNum)).ToList();
-
-
             List<CustomCondition> customConditionList = new List<CustomCondition>();
-
             customConditionList.Add(new CustomCondition() { Name = "BillNumList", Value =string.Join(",",p_list) });
             customConditionList.Add(new CustomCondition() { Name = "Type", Value = EnumBusinessType.JisBBAC.ToString() });
-          
+            customConditionList.Add(new CustomCondition() { Name = "IsOut", Value ="out"});
             var _taskid = await _service.ExportEnqueueAsync("BBAC待扣减任务", ExportExtentsion.Excel, DateTime.Now.ToString("yyyyMM"), string.Empty, CurrentUser, typeof(PendingDeductionService), customConditionList, (rs) =>
             {
             });
             return _taskid;
-
-
-
         }
     }
 }                                          

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

@@ -8,123 +8,62 @@ using System.Threading.Tasks;
 using EFCore.BulkExtensions;
 using Microsoft.CodeAnalysis.CSharp.Syntax;
 using Nito.AsyncEx;
+using NPOI.SS.Formula.Functions;
 using SettleAccount.Bases;
 using SettleAccount.Domain.BQ;
 using TaskJob.EventArgs;
 using TaskJob.Interfaces;
+using Volo.Abp.Application.Services;
 using Volo.Abp.DependencyInjection;
+using Volo.Abp.Uow;
 using Win.Sfs.SettleAccount.Constant;
 using Win.Sfs.SettleAccount.Entities.BQ.Vmi;
 using Win.Sfs.SettleAccount.Entities.CodeSettings;
 using Win.Sfs.Shared.RepositoryBase;
 
 namespace Win.Sfs.SettleAccount.Entities.BQ.Syncs;
-public class PendingDeductionService : ITransientDependency, IExportJob
+public class PendingDeductionService : ApplicationService, ITransientDependency, IExportJob
 {
-    protected readonly VmiAppService _vimservice;
-    protected readonly INormalEfCoreRepository<BBAC_SEC_DETAIL, Guid> _bbacSecRepository;
-    protected readonly INormalEfCoreRepository<HBPO_SEC_DETAIL, Guid> _hbpoSecRepository;
-    protected readonly INormalEfCoreRepository<PUB_SEC_DETAIL, Guid> _pubSecRepository;
-    protected readonly INormalEfCoreRepository<BBAC_PD_DETAIL, Guid> _bbacRepository;
-    protected readonly INormalEfCoreRepository<HBPO_PD_DETAIL, Guid> _hbpoRepository;
-    protected readonly INormalEfCoreRepository<PUB_PD_DETAIL, Guid> _pubRepository;
-    protected readonly INormalEfCoreRepository<CodeSetting, Guid> _codesetRepository;
-    protected readonly INormalEfCoreRepository<VmiLog, Guid> _vmiRepository;
+
+    protected readonly SettleAccountDbContext _dbcontext;
 
     public PendingDeductionService(
-    INormalEfCoreRepository<BBAC_SEC_DETAIL, Guid> bbacSecRepository,
-    INormalEfCoreRepository<HBPO_SEC_DETAIL, Guid> hbpoSecRepository,
-    INormalEfCoreRepository<PUB_SEC_DETAIL, Guid> pubSecRepository,
-    INormalEfCoreRepository<BBAC_PD_DETAIL, Guid> bbacRepository,
-    INormalEfCoreRepository<HBPO_PD_DETAIL, Guid> hbpoRepository,
-    INormalEfCoreRepository<PUB_PD_DETAIL, Guid> pubRepository,
-    INormalEfCoreRepository<CodeSetting, Guid> codesetRepository,
-    INormalEfCoreRepository<VmiLog, Guid> vmiRepository,
-    VmiAppService vimservice
+        SettleAccountDbContext dbcontext
+       
+
         )
     {
-        _hbpoRepository = hbpoRepository;
-        _bbacRepository= bbacRepository;
-        _pubRepository= pubRepository;
-        _bbacSecRepository = bbacSecRepository;
-        _hbpoSecRepository= hbpoSecRepository;
-        _pubSecRepository= pubSecRepository;
-        _vimservice =vimservice;
-        _codesetRepository = codesetRepository;
-        _vmiRepository = vmiRepository;
+        _dbcontext = dbcontext;
+       
     }
 
     public  string ExportFile(Guid id, List<string> exportName, List<CustomCondition> property)
     {
+
         var billList = property.Where(p => p.Name == "BillNumList").FirstOrDefault().Value;
         var type = property.Where(p => p.Name == "Type").FirstOrDefault().Value;
+        var isout = property.Where(p => p.Name == "IsOut").FirstOrDefault().Value;
         var list = billList.Split(",");
-        var projectList = _codesetRepository.Where(p => p.Project == "库位");
+        var projectList = _dbcontext.Set<CodeSetting>().Where(p => p.Project == "库位");
         if (type == "JisBBAC")
         {
-            var jisdetail = _bbacRepository.Where(p => list.Contains(p.BillNum) && p.BusinessType == EnumBusinessType.JisBBAC);//jis
-            Sync(jisdetail.ToList());            
-            var mdetail = _bbacRepository.Where(p => list.Contains(p.BillNum) && p.BusinessType == EnumBusinessType.MaiDanJianBBAC);//买单件
-            Sync(mdetail.ToList());
+                var jisdetail = _dbcontext.Set<BBAC_PD_DETAIL>().Where(p => list.Contains(p.BillNum) && p.BusinessType == EnumBusinessType.JisBBAC);//jis
+                Sync(jisdetail.ToList(),isout=="out"?true:false);
+                var mdetail = _dbcontext.Set<BBAC_PD_DETAIL>().Where(p => list.Contains(p.BillNum) && p.BusinessType == EnumBusinessType.MaiDanJianBBAC);//买单件
+                Sync(mdetail.ToList(), isout == "out" ? true : false);
         }
         else if (type == "JisHBPO")
         {
-            var detailist = _hbpoRepository.Where(p => list.Contains(p.BillNum) && p.BusinessType== EnumBusinessType.JisHBPO).ToList();
-            Sync(detailist);
-            var mdetail = _bbacRepository.Where(p => list.Contains(p.BillNum) && p.BusinessType == EnumBusinessType.MaiDanJianHBPO);//买单件
-            Sync(mdetail.ToList());
+            var detailist = _dbcontext.Set<HBPO_PD_DETAIL>().Where(p => list.Contains(p.BillNum) && p.BusinessType== EnumBusinessType.JisHBPO).ToList();
+            Sync(detailist, isout == "out" ? true : false);
+            var mdetail = _dbcontext.Set<HBPO_PD_DETAIL>().Where(p => list.Contains(p.BillNum) && p.BusinessType == EnumBusinessType.MaiDanJianHBPO);//买单件
+            Sync(mdetail.ToList(),isout == "out" ? true : false);
         }
         else
         {
-            var detailist = _hbpoRepository.Where(p => list.Contains(p.BillNum)).ToList();
-            Sync(detailist);
-
-            ////switch (type)
-            ////{
-            ////    case "ZhiGongJianBBAC":
-            ////        if (detailist != null && detailist.Count > 0)
-            ////        {
-
-            ////        }
-            ////        break;
-            ////    case "ZhiGongJianHBPO":
-            ////        if (detailist != null && detailist.Count > 0)
-            ////        {
-
-            ////        }
-            ////        break;
-            ////    case "MaiDanJianBBAC":
-            ////        if (detailist != null && detailist.Count > 0)
-            ////        {
-
-            ////        }
-            ////        break;
-            ////    case "MaiDanJianHBPO":
-            ////        if (detailist != null && detailist.Count > 0)
-            ////        {
-
-            ////        }
-            ////        break;
-            ////    case "BeiJian":
-            ////        if (detailist != null && detailist.Count > 0)
-            ////        {
-
-            ////        }
-            ////        break;
-            ////    case "YinDuJian":
-            ////        if (detailist != null && detailist.Count > 0)
-            ////        {
-
-            ////        }
-            ////        break;
-            ////}
-            //if (detailist != null && detailist.Count > 0)
-            //{
-            //    foreach (var itm in detailist)
-            //    {
-
-            //    }
-            //}
+            var detailist = _dbcontext.Set<PUB_PD_DETAIL>().Where(p => list.Contains(p.BillNum)).ToList();
+            Sync(detailist, isout == "out" ? true : false);
+
         }
         return id.ToString();
     }
@@ -144,42 +83,91 @@ public class PendingDeductionService : ITransientDependency, IExportJob
         return pageCount;
     }
 
-    public void Sync<T>(List<T> p_ls) where T : PD_BASE,new()
+    public void Sync<T>(List<T> p_ls,bool flag=true) where T : PD_BASE,new()
     {
-
         var query = from itm in p_ls
-                    select new
+                    select  new VmiLog()
                     {
+                        
                         BillTime = DateTime.Now,
                         ChangedTime = DateTime.Now,
                         Qty = itm.Qty,
-                        DeliverTime = itm.CreationTime,
+                        RealPartCode=itm.RELU,
+
+                        RealCode=itm.RELU,
+
                         LogType = Entities.BQ.Vmi.VmiLogType.Type200,
-                        ChangedQty = itm.Qty,
+                        ChangedQty =(flag==true)? -itm.Qty:itm.Qty,
                         ChangedType = VmiType.Out,
                         //SubBillType = EnumDeliverSubBillType.小件BBAC,
                         //BillType = EnumDeliverBjBmpBillType.JIS件,
-                        PartCode = itm.LU,
+                        CustPartCode = itm.LU,
                         SettlementVinCode = itm.PN,
-                        PartCode2 = itm.LU,
-                        CustomerPartCode = string.IsNullOrEmpty(itm.Extend4) ? string.Empty : itm.Extend4,
+                        
                         VinCode = itm.PN,
                         OrderNum = itm.GroupNum,
-                        ErpToLoc = itm.Extend2,
+                        ErpToLoc = string.IsNullOrEmpty(itm.Extend2)?string.Empty:itm.Extend2,
  
                     };
         var ls = query.ToList();
-        if (ls != null && ls.Count > 0)
+
+
+
+
+        var _first= p_ls.FirstOrDefault();
+
+        
+
+
+
+        using (var transaction =_dbcontext.Database.BeginTransaction())
         {
-            var count = CalculatePageCount(ls.Count, 2000);
-            for (int pagenumber = 0; pagenumber < count; pagenumber++)
+         
+            try
+            {
+                // 执行批量数据操作
+                if (ls != null && ls.Count > 0)
+                {
+                    var count = CalculatePageCount(ls.Count, 2000);
+                    for (int pagenumber = 0; pagenumber < count; pagenumber++)
+                    {
+                        ls = GetPagedData(ls, pagenumber, 2000);
+                        foreach (var item in ls)
+                        {
+                            item.SetId(GuidGenerator.Create());
+                        }
+
+                        _dbcontext.BulkInsert(ls);
+                        Task.Delay(500);
+                    }
+                }
+
+                // 提交事务
+                 transaction.Commit();
+            }
+            catch (Exception)
             {
-                ls = GetPagedData(ls, pagenumber, 2000);
-                _vmiRepository.DbContext.BulkInsert(ls);
-               
-                Task.Delay(500);
+                // 回滚事务
+                transaction.Rollback();
+                throw;
             }
         }
+
+
+
+
+
+
+
+
+
+
+
+
+
+        ;
+
+      
     }
 
 

code/src/Modules/SettleAccount/src/SettleAccount.Application/SettleAccountApplicationModule.cs

@@ -102,22 +102,6 @@ namespace Win.Sfs.SettleAccount
                 }; return accesor;
             });
 
-            //context.Services.AddTransient(implementationFactory =>
-            //{
-            //    Func<string, IExportJob> accesor = key =>
-            //    {
-            //        if (key.Equals(typeof(PendingDeductionService).FullName))
-            //        {
-            //            return implementationFactory.GetService<PendingDeductionService>();
-            //        }
-            //         else
-            //        {
-            //            throw new ArgumentException($"Not Support key:{key}");
-            //        }
-
-            //    };
-            //    return accesor;
-            //});
         }
 
         private static void ConfigureJson(ServiceConfigurationContext context)

code/src/Modules/SettleAccount/src/SettleAccount.Domain/Bases/EntityBase.cs

@@ -407,10 +407,6 @@ namespace SettleAccount.Bases
         protected SA_CAN_BASE() { }
         public SA_CAN_BASE(Guid id) : base(id) { Id = id; }
 
-
-
-
-
         /// <summary>
         /// 期间
         /// </summary>

code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/BBAC_SE_EDI.cs

@@ -38,10 +38,12 @@ public class BBAC_SE_EDI:FullAuditedAggregateRoot<Guid>
 
     [Display(Name = "工厂")]
     public string Site { get; set; }
-
+    [Display(Name = "生产码类型")]
     public string Extend1 { set; get; }
     public string Extend2 { set; get; }
+    [Display(Name = "生产码序列号")]
     public string Extend3 { set; get; }
+    [Display(Name ="车型")]
     public string Extend4 { set; get; }
 
     /// <summary>
@@ -50,6 +52,11 @@ public class BBAC_SE_EDI:FullAuditedAggregateRoot<Guid>
     [Display(Name = "是否有发运数据")]
     public bool IsHaveSeData { get; set; }
 
+    [Display(Name ="生产线")]
+    public string LineStationCode { set; get; }
+
+    
+
     public BBAC_SE_EDI()
     { }
     public BBAC_SE_EDI(Guid guid,  string keyCode, string version, string lU, string pN, string seqNumber, string assemblyCode, string injectionCode, decimal qty, DateTime beginDate

code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Managers/BBAC_NOT_SA_MNG.cs

@@ -94,6 +94,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Managers
                     invbillnum: string.Empty,
                     partcode:itm.PartCode
                     );
+                _detailEntity.RealPartCode = itm.RealPartCode;
                 _entityList.Add(_detailEntity);
             }
             await _repository.DbContext.BulkDeleteAsync(p_list);

code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Managers/HBPO_NOT_SA_MNG.cs

@@ -98,6 +98,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Managers
                    invbillnum: string.Empty,
                    partcode:itm.PartCode
                     );
+                _detailEntity.RealPartCode = itm.RealPartCode;
                 _entityList.Add(_detailEntity);
             }
             await _notRepository.DbContext.BulkDeleteAsync(p_list);

code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Managers/INV_MNG.cs

@@ -551,7 +551,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Managers
                      
                       );//厂内实际零件号
 
-                    detail.RELU = itm.RealPartCode;//厂内替换零件号
+                    detail.RELU = string.IsNullOrEmpty(itm.RealPartCode) ? itm.PartCode : itm.RealPartCode;//厂内替换零件号
                     detail.Extend2 = itm.ErpLoc;//ERP库位
                     bbacDetail.Add(detail);
                 }
@@ -700,7 +700,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Managers
                       
 
                        );
-                    entity.RELU = itm.RealPartCode;//厂内替换零件号
+                    entity.RELU = string.IsNullOrEmpty(itm.RealPartCode) ? itm.PartCode : itm.RealPartCode;//厂内替换零件号
                     entity.Extend2 = itm.ErpLoc;//ERP库位
 
                     bbacDetail.Add(entity
@@ -852,7 +852,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Managers
               
                      
                       );
-                    entity.RELU = itm.RealPartCode;//厂内替换零件号
+                    entity.RELU =string.IsNullOrEmpty(itm.RealPartCode)?itm.PartCode:itm.RealPartCode;//厂内替换零件号
                     entity.Extend2 = itm.ErpLoc;//ERP库位
                     bbacDetail.Add(entity
                   );
@@ -1449,16 +1449,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Managers
 
                 if (salist.Count > 0)
                 {
-                    //foreach (var itm in invoiceMap)//分组影响和
-                    //{
-                    //    var key = itm.Key;//发票票号
-                    //    var ls = itm.Value;//结算分组号列表
-
-                        
-
-                    //    string str = $" EXEC [p_Invoice_generation_change]  @invbillnum = {"'" + key + "'"},@groupNum = {"'" + string.Join(",", ls) + "'"},@businessType = NULL";
-                    //    await _repository.DbContext.Database.ExecuteSqlRawAsync(str);
-                    //}
+                 
                     await _repository.DbContext.BulkUpdateAsync(salist,new BulkConfig() { BatchSize=10000 });
                 }
 

code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Managers/PUB_NOT_SA_MNG.cs

@@ -124,7 +124,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Managers
                        partcode: itm.PartCode,
                        pobillnum:string.Empty
                        );
-
+                    _detailEntity.RealPartCode = itm.RealPartCode;
                     _entityList.Add(_detailEntity);
                 }
                 await _repository.DbContext.BulkDeleteAsync(p_list);
@@ -164,7 +164,7 @@ namespace Win.Sfs.SettleAccount.Entities.BQ.Managers
                        partcode: itm.PartCode,
                        pobillnum: string.Empty
                        );
-
+                    _detailEntity.RealPartCode =string.IsNullOrEmpty(itm.RealPartCode)?itm.PartCode:itm.RealPartCode;
                     _entityList.Add(_detailEntity);
                 }
                // _repository.DbContext.Database.BeginTransaction();

code/src/Modules/SettleAccount/src/SettleAccount.Domain/Entities/BQ/Vmi/VmiLog.cs

@@ -12,7 +12,7 @@ public class VmiLog : VmiBalanceBase
     {
         ConcurrencyStamp = Guid.NewGuid().ToString("N");
     }
-
+    
     public VmiLog(Guid id) : base(id)
     {
         ConcurrencyStamp = Guid.NewGuid().ToString("N");

code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/Migrations/20230828060854_20230828.cs

@@ -0,0 +1,178 @@
+using System;
+using Microsoft.EntityFrameworkCore.Migrations;
+
+namespace Win.Sfs.SettleAccount.Migrations
+{
+    public partial class _20230828 : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AddColumn<string>(
+                name: "LineStationCode",
+                table: "Set_BBAC_SE_EDI",
+                type: "nvarchar(max)",
+                nullable: true);
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("185c5968-e02b-267e-db2f-225fccfc9716"),
+                column: "ConcurrencyStamp",
+                value: "b6452a12f9814a2ba8097b0a34934cf1");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("1bb02f67-ed05-6cc1-1507-502e8f6c7a31"),
+                column: "ConcurrencyStamp",
+                value: "e84ff12fed794e3d8eb0d8b6945873ce");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("49b1da12-418c-544d-fe8b-be7e5b572452"),
+                column: "ConcurrencyStamp",
+                value: "f4063fd5bc9a4321941edf1663633d73");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("6f68fc8f-b058-c3f4-e07d-722c61f3f7fa"),
+                column: "ConcurrencyStamp",
+                value: "565a6be9ca2a450aae2dc98b972a32bc");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("7a0dc087-a859-5863-eb6e-56f588bd779e"),
+                column: "ConcurrencyStamp",
+                value: "f21a6c7a50a5405aaced44507dbdd01b");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("8f7dc23d-e2e9-3691-cfe9-545bb958e3f2"),
+                column: "ConcurrencyStamp",
+                value: "df201f57bc0448d3909942c81a553597");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("b9b9c79f-4894-474b-4f67-b1ec121c41e5"),
+                column: "ConcurrencyStamp",
+                value: "673b92ac1f384632b35953a8601e92f2");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("c09c23ea-815f-1b43-4476-2365a8d9a60b"),
+                column: "ConcurrencyStamp",
+                value: "0f62e911f48d4c97a534eab3a6b2ddbd");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("c1f71240-1b81-0107-8b23-ddc9811a3efe"),
+                column: "ConcurrencyStamp",
+                value: "6a1b56ecc53e4c56b036daab195d3a86");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("ef3d8e8a-a88e-ca1f-e615-714c6bc48824"),
+                column: "ConcurrencyStamp",
+                value: "6e7a483ccf0e41e888beffb1e492f57e");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("f306b380-47e5-5c01-b902-67ca4113a8f4"),
+                column: "ConcurrencyStamp",
+                value: "b493f376395d40c7ad727a14ec909ee0");
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropColumn(
+                name: "LineStationCode",
+                table: "Set_BBAC_SE_EDI");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("185c5968-e02b-267e-db2f-225fccfc9716"),
+                column: "ConcurrencyStamp",
+                value: "89413f316dbf4647954b6669de927488");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("1bb02f67-ed05-6cc1-1507-502e8f6c7a31"),
+                column: "ConcurrencyStamp",
+                value: "ebb73d81d23c4ed9a6ae59730d163f4b");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("49b1da12-418c-544d-fe8b-be7e5b572452"),
+                column: "ConcurrencyStamp",
+                value: "e581ee4de97a46b1a1c0ba75a101c064");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("6f68fc8f-b058-c3f4-e07d-722c61f3f7fa"),
+                column: "ConcurrencyStamp",
+                value: "a7be915b8a5541c58081c668219edfb7");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("7a0dc087-a859-5863-eb6e-56f588bd779e"),
+                column: "ConcurrencyStamp",
+                value: "1fb801f3cbff422082d888ee8b5dab64");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("8f7dc23d-e2e9-3691-cfe9-545bb958e3f2"),
+                column: "ConcurrencyStamp",
+                value: "df723d768280494e88d49734cc6e55e5");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("b9b9c79f-4894-474b-4f67-b1ec121c41e5"),
+                column: "ConcurrencyStamp",
+                value: "93962cebd40f490b9df08b215b2c7bd2");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("c09c23ea-815f-1b43-4476-2365a8d9a60b"),
+                column: "ConcurrencyStamp",
+                value: "1c542463eb8746db949bcda48eabdbd8");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("c1f71240-1b81-0107-8b23-ddc9811a3efe"),
+                column: "ConcurrencyStamp",
+                value: "c5b29d7fa18e4b9cb8bc1e354d10c3ac");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("ef3d8e8a-a88e-ca1f-e615-714c6bc48824"),
+                column: "ConcurrencyStamp",
+                value: "25ec0d7c647f42d88882c4187af74201");
+
+            migrationBuilder.UpdateData(
+                table: "Set_JobItem",
+                keyColumn: "Id",
+                keyValue: new Guid("f306b380-47e5-5c01-b902-67ca4113a8f4"),
+                column: "ConcurrencyStamp",
+                value: "7bbeaa02b39947c089eda7f4b05babb9");
+        }
+    }
+}

code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/Migrations/SettleAccountDbContextModelSnapshot.cs

@@ -932,6 +932,9 @@ namespace Win.Sfs.SettleAccount.Migrations
                         .HasColumnType("uniqueidentifier")
                         .HasColumnName("LastModifierId");
 
+                    b.Property<string>("LineStationCode")
+                        .HasColumnType("nvarchar(max)");
+
                     b.Property<string>("PN")
                         .HasMaxLength(50)
                         .HasColumnType("nvarchar(50)");
@@ -4445,7 +4448,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("ef3d8e8a-a88e-ca1f-e615-714c6bc48824"),
-                            ConcurrencyStamp = "25ec0d7c647f42d88882c4187af74201",
+                            ConcurrencyStamp = "6e7a483ccf0e41e888beffb1e492f57e",
                             Cron = "0 0 8 26 *",
                             IsDisabled = false,
                             IsRunning = false,
@@ -4455,7 +4458,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("185c5968-e02b-267e-db2f-225fccfc9716"),
-                            ConcurrencyStamp = "89413f316dbf4647954b6669de927488",
+                            ConcurrencyStamp = "b6452a12f9814a2ba8097b0a34934cf1",
                             Cron = "0 0/1 * * * ?",
                             IsDisabled = false,
                             IsRunning = false,
@@ -4465,7 +4468,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("1bb02f67-ed05-6cc1-1507-502e8f6c7a31"),
-                            ConcurrencyStamp = "ebb73d81d23c4ed9a6ae59730d163f4b",
+                            ConcurrencyStamp = "e84ff12fed794e3d8eb0d8b6945873ce",
                             Cron = "0 0/1 * * * ?",
                             IsDisabled = false,
                             IsRunning = false,
@@ -4475,7 +4478,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("b9b9c79f-4894-474b-4f67-b1ec121c41e5"),
-                            ConcurrencyStamp = "93962cebd40f490b9df08b215b2c7bd2",
+                            ConcurrencyStamp = "673b92ac1f384632b35953a8601e92f2",
                             Cron = "0 0/30 * * * ? ",
                             IsDisabled = false,
                             IsRunning = false,
@@ -4485,7 +4488,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("49b1da12-418c-544d-fe8b-be7e5b572452"),
-                            ConcurrencyStamp = "e581ee4de97a46b1a1c0ba75a101c064",
+                            ConcurrencyStamp = "f4063fd5bc9a4321941edf1663633d73",
                             Cron = "0 0/30 * * * ? ",
                             IsDisabled = false,
                             IsRunning = false,
@@ -4495,7 +4498,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("7a0dc087-a859-5863-eb6e-56f588bd779e"),
-                            ConcurrencyStamp = "1fb801f3cbff422082d888ee8b5dab64",
+                            ConcurrencyStamp = "f21a6c7a50a5405aaced44507dbdd01b",
                             Cron = "0 0/30 * * * ? ",
                             IsDisabled = false,
                             IsRunning = false,
@@ -4505,7 +4508,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("6f68fc8f-b058-c3f4-e07d-722c61f3f7fa"),
-                            ConcurrencyStamp = "a7be915b8a5541c58081c668219edfb7",
+                            ConcurrencyStamp = "565a6be9ca2a450aae2dc98b972a32bc",
                             Cron = "0 0/30 * * * ? ",
                             IsDisabled = false,
                             IsRunning = false,
@@ -4515,7 +4518,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("f306b380-47e5-5c01-b902-67ca4113a8f4"),
-                            ConcurrencyStamp = "7bbeaa02b39947c089eda7f4b05babb9",
+                            ConcurrencyStamp = "b493f376395d40c7ad727a14ec909ee0",
                             Cron = "0 0/30 * * * ? ",
                             IsDisabled = false,
                             IsRunning = false,
@@ -4525,7 +4528,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("8f7dc23d-e2e9-3691-cfe9-545bb958e3f2"),
-                            ConcurrencyStamp = "df723d768280494e88d49734cc6e55e5",
+                            ConcurrencyStamp = "df201f57bc0448d3909942c81a553597",
                             Cron = "0 0/30 * * * ? ",
                             IsDisabled = false,
                             IsRunning = false,
@@ -4535,7 +4538,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("c1f71240-1b81-0107-8b23-ddc9811a3efe"),
-                            ConcurrencyStamp = "c5b29d7fa18e4b9cb8bc1e354d10c3ac",
+                            ConcurrencyStamp = "6a1b56ecc53e4c56b036daab195d3a86",
                             Cron = "0 0/30 * * * ? ",
                             IsDisabled = false,
                             IsRunning = false,
@@ -4545,7 +4548,7 @@ namespace Win.Sfs.SettleAccount.Migrations
                         new
                         {
                             Id = new Guid("c09c23ea-815f-1b43-4476-2365a8d9a60b"),
-                            ConcurrencyStamp = "1c542463eb8746db949bcda48eabdbd8",
+                            ConcurrencyStamp = "0f62e911f48d4c97a534eab3a6b2ddbd",
                             Cron = "0 0/30 * * * ? ",
                             IsDisabled = false,
                             IsRunning = false,

code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/Repository/SettleAccountJob/Code/CodeSettingRepository.cs

@@ -1,4 +1,4 @@
-using EFCore.BulkExtensions;
+using EFCore.BulkExtensions;
 using Microsoft.EntityFrameworkCore;
 using System;
 using System.Collections.Generic;
@@ -13,7 +13,7 @@ using Win.Sfs.SettleAccount.Entities.Invoices;
 
 namespace Win.Sfs.SettleAccount.Repository.Code
 {
-    public class CodeSettingRepository: EfCoreRepository<SettleAccountDbContext, CodeSetting>, ITransientDependency
+    public class CodeSettingRepository:EfCoreRepository<SettleAccountDbContext, CodeSetting>, ITransientDependency
     {
         public CodeSettingRepository(IDbContextProvider<SettleAccountDbContext> dbContextProvider) : base(dbContextProvider)
         {
@@ -35,6 +35,14 @@ namespace Win.Sfs.SettleAccount.Repository.Code
             }
             return _list;
         }
+
+
+
+
     }
+
+
+
+
 }
 

code/src/Modules/SettleAccount/src/SettleAccount.EntityFrameworkCore/Repository/SettleAccountJob/PendingDeduction/PendingDeductionDapperRepository.cs

@@ -439,6 +439,7 @@ namespace Win.Sfs.SettleAccount.Repository.SettleAccountJob.Report
         /// <returns></returns>
         public virtual INVOICE_GRP GetInvoice(string inv_bill)
         {
+            
             return DbConnection.QueryFirst<INVOICE_GRP>(string.Format("select * from set_INVOICE_GRP where InvbillNum='{0}'",inv_bill));
         }