diff --git a/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.MesAgent/Incoming/MesIncomingBackgroundWorker.cs b/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.MesAgent/Incoming/MesIncomingBackgroundWorker.cs
index 6b4bc05ae..3a919536a 100644
--- a/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.MesAgent/Incoming/MesIncomingBackgroundWorker.cs
+++ b/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.MesAgent/Incoming/MesIncomingBackgroundWorker.cs
@@ -60,58 +60,58 @@ public class MesIncomingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase
             await TransferNoteConverter.ConvertAsync(mesOutsFromExternalList_TransferNote).ConfigureAwait(false);
         }
 
-        //Logger.LogInformation($"Read Scrap");//报废
-        //var scrapReader = workerContext.ServiceProvider.GetRequiredService<ScrapReader>();
-        //var scrapConverter = workerContext.ServiceProvider.GetRequiredService<ScrapConverter>();
-        ////读取并保存Scrap
-        //var scrapsFromExternalList = await scrapReader.ReadAsync().ConfigureAwait(false);
-        ////转换Scrap
-        //await scrapConverter.ConvertAsync(scrapsFromExternalList).ConfigureAwait(false);
-
-
-        //Logger.LogInformation($"Read BackFlush");//耗用单
-        //var BackFlushReader = workerContext.ServiceProvider.GetRequiredService<BackFluReader>();
-        //var BackFlushConverter = workerContext.ServiceProvider.GetRequiredService<BackFluConverter>();
-        ////读取并保存BackFlush
-        //var backFlushsFromExternalList = await BackFlushReader.ReadAsync().ConfigureAwait(false);
-        ////转换BackFlush
-        //await BackFlushConverter.ConvertAsync(backFlushsFromExternalList).ConfigureAwait(false);
-
-
-        //Logger.LogInformation($"Read TransferNote");//储位调拨
-        //var TransferNoteReader = workerContext.ServiceProvider.GetRequiredService<QtyrfeReader>();
-        //// var TransferNoteConverter = workerContext.ServiceProvider.GetRequiredService<QtyrfeConverter>();
-        ////读取并保存TransferNote
-        //var transferNoteFromExternalList = await TransferNoteReader.ReadAsync().ConfigureAwait(false);
-        ////转换TransferNote
-        //await TransferNoteConverter.ConvertAsync(transferNoteFromExternalList).ConfigureAwait(false);
-
-        //Logger.LogInformation($"Read Frozen");//冻结解冻
-        //var FrozenReader = workerContext.ServiceProvider.GetRequiredService<FrozenReader>();
-        //var FrozenConverter = workerContext.ServiceProvider.GetRequiredService<FrozenConverter>();
-        ////读取并保存Frozen
-        //var mesNoteFromExternalList = await FrozenReader.ReadAsync().ConfigureAwait(false);
-        ////转换Frozen
-        //await FrozenConverter.ConvertAsync(mesNoteFromExternalList).ConfigureAwait(false);
-
-
-        //Logger.LogInformation($"Read Delivery");//成品发运
-        //var DeliveryReader = workerContext.ServiceProvider.GetRequiredService<DeliveryReader>();
-        //var DeliveryConverter = workerContext.ServiceProvider.GetRequiredService<DeliveryConverter>();
-        ////读取并保存Delivery
-        //var deliveryNoteFromExternalList = await DeliveryReader.ReadAsync().ConfigureAwait(false);
-        ////转换Delivery
-        //await DeliveryConverter.ConvertAsync(deliveryNoteFromExternalList).ConfigureAwait(false);
-
-
-
-        //Logger.LogInformation($"Read CallMtl");//自动叫料
-        //var CallMtlReader = workerContext.ServiceProvider.GetRequiredService<CallMtlReader>();
-        //var CallMtlConverter = workerContext.ServiceProvider.GetRequiredService<CallMtlConverter>();
-        ////读取并保存Delivery
-        //var callMtlFromExternalList = await CallMtlReader.ReadAsync().ConfigureAwait(false);
-        ////转换Delivery
-        //await CallMtlConverter.ConvertAsync(callMtlFromExternalList).ConfigureAwait(false);
+        Logger.LogInformation($"Read Scrap");//报废
+        var scrapReader = workerContext.ServiceProvider.GetRequiredService<ScrapReader>();
+        var scrapConverter = workerContext.ServiceProvider.GetRequiredService<ScrapConverter>();
+        //读取并保存Scrap
+        var scrapsFromExternalList = await scrapReader.ReadAsync().ConfigureAwait(false);
+        //转换Scrap
+        await scrapConverter.ConvertAsync(scrapsFromExternalList).ConfigureAwait(false);
+
+
+        Logger.LogInformation($"Read BackFlush");//耗用单
+        var BackFlushReader = workerContext.ServiceProvider.GetRequiredService<BackFluReader>();
+        var BackFlushConverter = workerContext.ServiceProvider.GetRequiredService<BackFluConverter>();
+        //读取并保存BackFlush
+        var backFlushsFromExternalList = await BackFlushReader.ReadAsync().ConfigureAwait(false);
+        //转换BackFlush
+        await BackFlushConverter.ConvertAsync(backFlushsFromExternalList).ConfigureAwait(false);
+
+
+        Logger.LogInformation($"Read TransferNote");//储位调拨
+        var TransferNoteReader = workerContext.ServiceProvider.GetRequiredService<QtyrfeReader>();
+        // var TransferNoteConverter = workerContext.ServiceProvider.GetRequiredService<QtyrfeConverter>();
+        //读取并保存TransferNote
+        var transferNoteFromExternalList = await TransferNoteReader.ReadAsync().ConfigureAwait(false);
+        //转换TransferNote
+        await TransferNoteConverter.ConvertAsync(transferNoteFromExternalList).ConfigureAwait(false);
+
+        Logger.LogInformation($"Read Frozen");//冻结解冻
+        var FrozenReader = workerContext.ServiceProvider.GetRequiredService<FrozenReader>();
+        var FrozenConverter = workerContext.ServiceProvider.GetRequiredService<FrozenConverter>();
+        //读取并保存Frozen
+        var mesNoteFromExternalList = await FrozenReader.ReadAsync().ConfigureAwait(false);
+        //转换Frozen
+        await FrozenConverter.ConvertAsync(mesNoteFromExternalList).ConfigureAwait(false);
+
+
+        Logger.LogInformation($"Read Delivery");//成品发运
+        var DeliveryReader = workerContext.ServiceProvider.GetRequiredService<DeliveryReader>();
+        var DeliveryConverter = workerContext.ServiceProvider.GetRequiredService<DeliveryConverter>();
+        //读取并保存Delivery
+        var deliveryNoteFromExternalList = await DeliveryReader.ReadAsync().ConfigureAwait(false);
+        //转换Delivery
+        await DeliveryConverter.ConvertAsync(deliveryNoteFromExternalList).ConfigureAwait(false);
+
+
+
+        Logger.LogInformation($"Read CallMtl");//自动叫料
+        var CallMtlReader = workerContext.ServiceProvider.GetRequiredService<CallMtlReader>();
+        var CallMtlConverter = workerContext.ServiceProvider.GetRequiredService<CallMtlConverter>();
+        //读取并保存Delivery
+        var callMtlFromExternalList = await CallMtlReader.ReadAsync().ConfigureAwait(false);
+        //转换Delivery
+        await CallMtlConverter.ConvertAsync(callMtlFromExternalList).ConfigureAwait(false);
 
         Logger.LogInformation($"Completed: Handling {Incoming}");
 
diff --git a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/AssembleIssueRequests/AssembleIssueRequestManager.cs b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/AssembleIssueRequests/AssembleIssueRequestManager.cs
index a9adfe5ee..8ac47efbc 100644
--- a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/AssembleIssueRequests/AssembleIssueRequestManager.cs
+++ b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/AssembleIssueRequests/AssembleIssueRequestManager.cs
@@ -36,9 +36,10 @@ public class AssembleIssueRequestManager
         entity.Submit();
         entity.Agree();
         entity.RequestStatus = EnumRequestStatus.Partial;
+        await _repository.InsertAsync(entity).ConfigureAwait(false);
         await LocalEventBus.PublishAsync(new SfsHandledEntityEventData<AssembleIssueRequest>(entity), false)
             .ConfigureAwait(false);
-        await _repository.InsertAsync(entity).ConfigureAwait(false);
+        
         return entity;
     }
 
@@ -58,6 +59,9 @@ public class AssembleIssueRequestManager
 
     public virtual async Task<AssembleIssueRequest> UpdateByEntityAsync(AssembleIssueRequest request)
     {
-        return await _repository.UpdateAsync(request).ConfigureAwait(false);
+        await Task.CompletedTask.ConfigureAwait(false);
+        var entity = await _repository.GetAsync(request.Id).ConfigureAwait(false);
+        entity.Details = request.Details;
+        return await _repository.UpdateAsync(entity, true).ConfigureAwait(false);
     }
 }
diff --git a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/CoatingIssuelRequests/CoatingIssueRequestManager.cs b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/CoatingIssuelRequests/CoatingIssueRequestManager.cs
index f9cb23eeb..9c4c47cc6 100644
--- a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/CoatingIssuelRequests/CoatingIssueRequestManager.cs
+++ b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/CoatingIssuelRequests/CoatingIssueRequestManager.cs
@@ -33,9 +33,10 @@ public class CoatingIssueRequestManager
         entity.Submit();
         entity.Agree();
         entity.RequestStatus = EnumRequestStatus.Partial;
+        await _repository.InsertAsync(entity).ConfigureAwait(false);
         await LocalEventBus.PublishAsync(new SfsHandledEntityEventData<CoatingIssueRequest>(entity), false)
             .ConfigureAwait(false);
-        await _repository.InsertAsync(entity).ConfigureAwait(false);
+        
         return entity;
     }
 
@@ -55,6 +56,9 @@ public class CoatingIssueRequestManager
 
     public virtual async Task<CoatingIssueRequest> UpdateByEntityAsync(CoatingIssueRequest request)
     {
-        return await _repository.UpdateAsync(request).ConfigureAwait(false);
+        await Task.CompletedTask.ConfigureAwait(false);
+        var entity = await _repository.GetAsync(request.Id).ConfigureAwait(false);
+        entity.Details = request.Details;
+        return await _repository.UpdateAsync(entity, true).ConfigureAwait(false);
     }
 }
diff --git a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/InjectionIssueRequests/InjectionIssueRequestManager.cs b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/InjectionIssueRequests/InjectionIssueRequestManager.cs
index 8e36276d3..1028f74b3 100644
--- a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/InjectionIssueRequests/InjectionIssueRequestManager.cs
+++ b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/InjectionIssueRequests/InjectionIssueRequestManager.cs
@@ -33,9 +33,10 @@ public class InjectionIssueRequestManager
         entity.Submit();
         entity.Agree();
         entity.RequestStatus = EnumRequestStatus.Partial;
+        await _repository.InsertAsync(entity).ConfigureAwait(false);
         await LocalEventBus.PublishAsync(new SfsHandledEntityEventData<InjectionIssueRequest>(entity), false)
             .ConfigureAwait(false);
-        await _repository.InsertAsync(entity).ConfigureAwait(false);
+        
         return entity;
     }
 
@@ -55,6 +56,9 @@ public class InjectionIssueRequestManager
 
     public virtual async Task<InjectionIssueRequest> UpdateByEntityAsync(InjectionIssueRequest request)
     {
-        return await _repository.UpdateAsync(request).ConfigureAwait(false);
+        await Task.CompletedTask.ConfigureAwait(false);
+        var entity = await _repository.GetAsync(request.Id).ConfigureAwait(false);
+        entity.Details = request.Details;
+        return await _repository.UpdateAsync(entity, true).ConfigureAwait(false);
     }
 }
diff --git a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/KittingIssueRequests/KittingIssueRequestManager.cs b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/KittingIssueRequests/KittingIssueRequestManager.cs
index dd7aaea26..d497a3af0 100644
--- a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/KittingIssueRequests/KittingIssueRequestManager.cs
+++ b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/KittingIssueRequests/KittingIssueRequestManager.cs
@@ -6,6 +6,8 @@ using Win_in.Sfs.Shared.Event;
 
 namespace Win_in.Sfs.Wms.Store.Domain;
 
+using Volo.Abp.Uow;
+
 public class KittingIssueRequestManager
     : SfsStoreRequestManagerBase<KittingIssueRequest, KittingIssueRequestDetail>
         , IKittingIssueRequestManager
@@ -33,9 +35,10 @@ public class KittingIssueRequestManager
         entity.Submit();
         entity.Agree();
         entity.RequestStatus = EnumRequestStatus.Partial;
+        await _repository.InsertAsync(entity,true).ConfigureAwait(false);
         await LocalEventBus.PublishAsync(new SfsHandledEntityEventData<KittingIssueRequest>(entity),false)
             .ConfigureAwait(false);
-        await _repository.InsertAsync(entity).ConfigureAwait(false);
+        
         return entity;
     }
  
@@ -55,6 +58,9 @@ public class KittingIssueRequestManager
 
     public virtual async Task<KittingIssueRequest> UpdateByEntityAsync(KittingIssueRequest request)
     {
-        return await _repository.UpdateAsync(request).ConfigureAwait(false);
+        await Task.CompletedTask.ConfigureAwait(false);
+        var entity=await _repository.GetAsync(request.Id).ConfigureAwait(false);
+        entity.Details = request.Details;
+        return await _repository.UpdateAsync(entity,true).ConfigureAwait(false);
     }
 }
diff --git a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/SparePartIssueRequests/SparePartIssueRequestManager.cs b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/SparePartIssueRequests/SparePartIssueRequestManager.cs
index f9620dc71..c835fe79b 100644
--- a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/SparePartIssueRequests/SparePartIssueRequestManager.cs
+++ b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Domain/Requests/IssueRequests/SparePartIssueRequests/SparePartIssueRequestManager.cs
@@ -33,9 +33,9 @@ public class SparePartIssueRequestManager
         entity.Submit();
         entity.Agree();
         entity.RequestStatus = EnumRequestStatus.Partial;
+        await _repository.InsertAsync(entity).ConfigureAwait(false);
         await LocalEventBus.PublishAsync(new SfsHandledEntityEventData<SparePartIssueRequest>(entity),false)
             .ConfigureAwait(false);
-        await _repository.InsertAsync(entity).ConfigureAwait(false);
         return entity;
     }
  
@@ -55,6 +55,9 @@ public class SparePartIssueRequestManager
 
     public virtual async Task<SparePartIssueRequest> UpdateByEntityAsync(SparePartIssueRequest request)
     {
-        return await _repository.UpdateAsync(request).ConfigureAwait(false);
+        await Task.CompletedTask.ConfigureAwait(false);
+        var entity = await _repository.GetAsync(request.Id).ConfigureAwait(false);
+        entity.Details = request.Details;
+        return await _repository.UpdateAsync(entity, true).ConfigureAwait(false);
     }
 }
diff --git a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/AssembleIssueRequestEventHandler.cs b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/AssembleIssueRequestEventHandler.cs
index 278560a4b..34e4b3120 100644
--- a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/AssembleIssueRequestEventHandler.cs
+++ b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/AssembleIssueRequestEventHandler.cs
@@ -200,10 +200,11 @@ public class AssembleIssueRequestEventHandler
     private async Task<AssembleIssueJobEditInput> BuildAssembleIssueJobCreateInputWithQtyTypeAsync(
         AssembleIssueRequest assembleIssueRequest, AssembleIssueRequestDetail requestDetailInput)
     {
+        var location = await _locationAppService.GetByCodeAsync(requestDetailInput.ToLocationCode).ConfigureAwait(false);
         var job = ObjectMapper.Map<AssembleIssueRequest, AssembleIssueJobEditInput>(assembleIssueRequest);
         job.JobType = EnumJobType.IssueJob;
         job.JobStatus = EnumJobStatus.Open;
-        job.WorkGroupCode = requestDetailInput.ToLocationGroup;
+        job.WorkGroupCode = location?.WorkGroupCode;
         job.WarehouseCode = requestDetailInput.ToWarehouseCode;
         job.Worker = assembleIssueRequest.Worker;
         job.AssembleRequestNumber = assembleIssueRequest.Number;
@@ -406,10 +407,11 @@ public class AssembleIssueRequestEventHandler
         AssembleIssueRequest assembleIssueRequest,
         AssembleIssueRequestDetail assembleIssueRequestDetail, BalanceDTO balanceDtos)
     {
+        var location = await _locationAppService.GetByCodeAsync(assembleIssueRequestDetail.ToLocationCode).ConfigureAwait(false);
         var job = ObjectMapper.Map<AssembleIssueRequest, AssembleIssueJobEditInput>(assembleIssueRequest);
         job.JobType = EnumJobType.IssueJob;
         job.JobStatus = EnumJobStatus.Open;
-        job.WorkGroupCode = assembleIssueRequestDetail.ToLocationGroup;
+        job.WorkGroupCode = location?.WorkGroupCode;
         job.WarehouseCode = assembleIssueRequestDetail.ToWarehouseCode;
         job.Worker = assembleIssueRequest.Worker;
         job.AssembleRequestNumber = assembleIssueRequest.Number;
diff --git a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/CoatingIssueRequestEventHandler.cs b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/CoatingIssueRequestEventHandler.cs
index bdb6584f2..4a62caf3f 100644
--- a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/CoatingIssueRequestEventHandler.cs
+++ b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/CoatingIssueRequestEventHandler.cs
@@ -200,10 +200,11 @@ public class CoatingIssueRequestEventHandler
     private async Task<CoatingIssueJobEditInput> BuildCoatingIssueJobCreateInputWithQtyTypeAsync(
         CoatingIssueRequest CoatingIssueRequest, CoatingIssueRequestDetail requestDetailInput)
     {
+        var location = await _locationAppService.GetByCodeAsync(requestDetailInput.ToLocationCode).ConfigureAwait(false);
         var job = ObjectMapper.Map<CoatingIssueRequest, CoatingIssueJobEditInput>(CoatingIssueRequest);
         job.JobType = EnumJobType.IssueJob;
         job.JobStatus = EnumJobStatus.Open;
-        job.WorkGroupCode = requestDetailInput.ToLocationGroup;
+        job.WorkGroupCode = location?.WorkGroupCode;
         job.WarehouseCode = requestDetailInput.ToWarehouseCode;
         job.Worker = CoatingIssueRequest.Worker;
         job.CoatingRequestNumber = CoatingIssueRequest.Number;
@@ -406,10 +407,11 @@ public class CoatingIssueRequestEventHandler
         CoatingIssueRequest CoatingIssueRequest,
         CoatingIssueRequestDetail CoatingIssueRequestDetail, BalanceDTO balanceDtos)
     {
+        var location = await _locationAppService.GetByCodeAsync(CoatingIssueRequestDetail.ToLocationCode).ConfigureAwait(false);
         var job = ObjectMapper.Map<CoatingIssueRequest, CoatingIssueJobEditInput>(CoatingIssueRequest);
         job.JobType = EnumJobType.IssueJob;
         job.JobStatus = EnumJobStatus.Open;
-        job.WorkGroupCode = CoatingIssueRequestDetail.ToLocationGroup;
+        job.WorkGroupCode = location?.WorkGroupCode;
         job.WarehouseCode = CoatingIssueRequestDetail.ToWarehouseCode;
         job.Worker = CoatingIssueRequest.Worker;
         job.CoatingRequestNumber = CoatingIssueRequest.Number;
diff --git a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/InjectionIssueRequestEventHandler.cs b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/InjectionIssueRequestEventHandler.cs
index 7008e859b..0b886f202 100644
--- a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/InjectionIssueRequestEventHandler.cs
+++ b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/InjectionIssueRequestEventHandler.cs
@@ -200,10 +200,11 @@ public class InjectionIssueRequestEventHandler
     private async Task<InjectionIssueJobEditInput> BuildInjectionIssueJobCreateInputWithQtyTypeAsync(
         InjectionIssueRequest InjectionIssueRequest, InjectionIssueRequestDetail requestDetailInput)
     {
+       var location=  await _locationAppService.GetByCodeAsync(requestDetailInput.ToLocationCode).ConfigureAwait(false);
         var job = ObjectMapper.Map<InjectionIssueRequest, InjectionIssueJobEditInput>(InjectionIssueRequest);
         job.JobType = EnumJobType.IssueJob;
         job.JobStatus = EnumJobStatus.Open;
-        job.WorkGroupCode = requestDetailInput.ToLocationGroup;
+        job.WorkGroupCode = location?.WorkGroupCode;
         job.WarehouseCode = requestDetailInput.ToWarehouseCode;
         job.Worker = InjectionIssueRequest.Worker;
         job.InjectionRequestNumber = InjectionIssueRequest.Number;
@@ -406,10 +407,11 @@ public class InjectionIssueRequestEventHandler
         InjectionIssueRequest InjectionIssueRequest,
         InjectionIssueRequestDetail InjectionIssueRequestDetail, BalanceDTO balanceDtos)
     {
+        var location = await _locationAppService.GetByCodeAsync(InjectionIssueRequestDetail.ToLocationCode).ConfigureAwait(false);
         var job = ObjectMapper.Map<InjectionIssueRequest, InjectionIssueJobEditInput>(InjectionIssueRequest);
         job.JobType = EnumJobType.IssueJob;
         job.JobStatus = EnumJobStatus.Open;
-        job.WorkGroupCode = InjectionIssueRequestDetail.ToLocationGroup;
+        job.WorkGroupCode = location?.WorkGroupCode;
         job.WarehouseCode = InjectionIssueRequestDetail.ToWarehouseCode;
         job.Worker = InjectionIssueRequest.Worker;
         job.InjectionRequestNumber = InjectionIssueRequest.Number;
diff --git a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/KittingIssueRequestEventHandler.cs b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/KittingIssueRequestEventHandler.cs
index ecc36f17d..8f22bf842 100644
--- a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/KittingIssueRequestEventHandler.cs
+++ b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/KittingIssueRequestEventHandler.cs
@@ -200,10 +200,11 @@ public class KittingIssueRequestEventHandler
     private async Task<KittingIssueJobEditInput> BuildKittingIssueJobCreateInputWithQtyTypeAsync(
         KittingIssueRequest KittingIssueRequest, KittingIssueRequestDetail requestDetailInput)
     {
+        var location = await _locationAppService.GetByCodeAsync(requestDetailInput.ToLocationCode).ConfigureAwait(false);
         var job = ObjectMapper.Map<KittingIssueRequest, KittingIssueJobEditInput>(KittingIssueRequest);
         job.JobType = EnumJobType.IssueJob;
         job.JobStatus = EnumJobStatus.Open;
-        job.WorkGroupCode = requestDetailInput.ToLocationGroup;
+        job.WorkGroupCode = location?.WorkGroupCode;
         job.WarehouseCode = requestDetailInput.ToWarehouseCode;
         job.Worker = KittingIssueRequest.Worker;
         job.KittingRequestNumber = KittingIssueRequest.Number;
@@ -406,10 +407,11 @@ public class KittingIssueRequestEventHandler
         KittingIssueRequest KittingIssueRequest,
         KittingIssueRequestDetail KittingIssueRequestDetail, BalanceDTO balanceDtos)
     {
+        var location = await _locationAppService.GetByCodeAsync(KittingIssueRequestDetail.ToLocationCode).ConfigureAwait(false);
         var job = ObjectMapper.Map<KittingIssueRequest, KittingIssueJobEditInput>(KittingIssueRequest);
         job.JobType = EnumJobType.IssueJob;
         job.JobStatus = EnumJobStatus.Open;
-        job.WorkGroupCode = KittingIssueRequestDetail.ToLocationGroup;
+        job.WorkGroupCode = location?.WorkGroupCode;
         job.WarehouseCode = KittingIssueRequestDetail.ToWarehouseCode;
         job.Worker = KittingIssueRequest.Worker;
         job.KittingRequestNumber = KittingIssueRequest.Number;
diff --git a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/SparePartIssueRequestEventHandler.cs b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/SparePartIssueRequestEventHandler.cs
index 30c996fe6..f4e3152e4 100644
--- a/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/SparePartIssueRequestEventHandler.cs
+++ b/be/Modules/Store/src/Win_in.Sfs.Wms.Store.Event/Requests/IssueRequest/SparePartIssueRequestEventHandler.cs
@@ -200,10 +200,11 @@ public class SparePartIssueRequestEventHandler
     private async Task<SparePartIssueJobEditInput> BuildSparePartIssueJobCreateInputWithQtyTypeAsync(
         SparePartIssueRequest SparePartIssueRequest, SparePartIssueRequestDetail requestDetailInput)
     {
+        var location = await _locationAppService.GetByCodeAsync(requestDetailInput.ToLocationCode).ConfigureAwait(false);
         var job = ObjectMapper.Map<SparePartIssueRequest, SparePartIssueJobEditInput>(SparePartIssueRequest);
         job.JobType = EnumJobType.IssueJob;
         job.JobStatus = EnumJobStatus.Open;
-        job.WorkGroupCode = requestDetailInput.ToLocationGroup;
+        job.WorkGroupCode = location?.WorkGroupCode;
         job.WarehouseCode = requestDetailInput.ToWarehouseCode;
         job.Worker = SparePartIssueRequest.Worker;
         job.SparePartRequestNumber = SparePartIssueRequest.Number;
@@ -406,10 +407,11 @@ public class SparePartIssueRequestEventHandler
         SparePartIssueRequest SparePartIssueRequest,
         SparePartIssueRequestDetail SparePartIssueRequestDetail, BalanceDTO balanceDtos)
     {
+        var location = await _locationAppService.GetByCodeAsync(SparePartIssueRequestDetail.ToLocationCode).ConfigureAwait(false);
         var job = ObjectMapper.Map<SparePartIssueRequest, SparePartIssueJobEditInput>(SparePartIssueRequest);
         job.JobType = EnumJobType.IssueJob;
         job.JobStatus = EnumJobStatus.Open;
-        job.WorkGroupCode = SparePartIssueRequestDetail.ToLocationGroup;
+        job.WorkGroupCode = location?.WorkGroupCode;
         job.WarehouseCode = SparePartIssueRequestDetail.ToWarehouseCode;
         job.Worker = SparePartIssueRequest.Worker;
         job.SparePartRequestNumber = SparePartIssueRequest.Number;