diff --git a/fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/cust/CustomerChangeBizService.java b/fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/cust/CustomerChangeBizService.java
index d2c282c..586f96b 100644
--- a/fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/cust/CustomerChangeBizService.java
+++ b/fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/cust/CustomerChangeBizService.java
@@ -330,9 +330,9 @@ public class CustomerChangeBizService extends AbstractCustomerService {
         }
         if (Objects.isNull(customer.getAdviserId()) && Objects.isNull(customer.getShopId())) {
             publicPoolService.removeByCustomerId(customer.getId(), customer.getGroupId());
-            create(customer, adviserId, true);
+            create(customer, adviserId, true, shopId);
         } else {
-            create(customer, adviserId, false);
+            create(customer, adviserId, false, shopId);
         }
         return updated;
     }
@@ -514,12 +514,13 @@ public class CustomerChangeBizService extends AbstractCustomerService {
         followTaskService.updateBatchById(list);
     }
 
-    private void create(Customer customer, Long adviserId, boolean publicPool) {
+    private void create(Customer customer, Long adviserId, boolean publicPool, Long shopId) {
         StammkundePool stammkundePool = createSimpleInfo(customer, adviserId);
         stammkundePool.setSources(StammkundeSourcesEnum.SYSTEMATIC);
         if (publicPool) {
             stammkundePool.setSources(StammkundeSourcesEnum.PUBLIC_POOL);
         }
+        stammkundePool.setShopId(shopId);
         stammkundePool.setPoolStatus(StammkundeStatusEnum.KUNDE);
         stammkundePool.setAktiv(Boolean.TRUE);
         stammkundePool.setActivationTime(new Date());