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 e0e3831..d468bfe 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
@@ -389,6 +389,7 @@ public class CustomerChangeBizService extends AbstractCustomerService {
         if (Objects.isNull(userDTO)) {
             return null;
         }
+        AffiliationRecord entity = createEntity(customer, userDTO.getUserId(), customer.getShopId());
         customer.setAdviserId(userDTO.getUserId());
         customerService.updateById(customer);
         DefeatReasonEnum reasonEnum = DefeatReasonEnum.OT;
@@ -398,7 +399,6 @@ public class CustomerChangeBizService extends AbstractCustomerService {
         if (FollowTypeEnum.RM.equals(task.getType())) {
             reasonEnum = DefeatReasonEnum.RM;
         }
-        AffiliationRecord entity = createEntity(customer, userDTO.getUserId(), customer.getShopId());
         entity.setReason(reasonEnum.getName());
         affiliationRecordService.save(entity);
         StammkundeDto stammkundeDto = new StammkundeDto();