延时客服复用时检测并赋值新的获客链接

src/main/java/com/yaoyaozw/customer/components/CustomerServiceCommonAsyncComponent.java

@@ -20,10 +20,7 @@ import com.yaoyaozw.customer.mapper.CustomerGraphicsDelayMapper;
 import com.yaoyaozw.customer.mapper.CustomerGraphicsMapper;
 import com.yaoyaozw.customer.mapper.KanbanCommonMapper;
 import com.yaoyaozw.customer.mapper.MaterialCommonMapper;
-import com.yaoyaozw.customer.service.CrowdPackageConditionMatchService;
-import com.yaoyaozw.customer.service.CustomerServiceCommonService;
-import com.yaoyaozw.customer.service.ReferralEntityService;
-import com.yaoyaozw.customer.service.RegisterUserEntityService;
+import com.yaoyaozw.customer.service.*;
 import com.yaoyaozw.customer.vo.AuthInfoVO;
 import com.yaoyaozw.customer.vo.kanban.CommonOptionResponseVO;
 import com.yaoyaozw.customer.vo.customer.CrowdPackageUserVO;
@@ -37,6 +34,7 @@ import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.concurrent.TimeUnit;
@@ -78,6 +76,8 @@ public class CustomerServiceCommonAsyncComponent {
     private CustomerGraphicsDelayMapper customerGraphicsDelayMapper;
     @Autowired
     private RabbitTemplate rabbitTemplate;
+    @Resource
+    private CompanyAcquisitionLinkService companyAcquisitionLinkService;
 
 
     @Async("myExecutor")
@@ -416,7 +416,7 @@ public class CustomerServiceCommonAsyncComponent {
             BeanUtil.copyProperties(sourceReferralEntity, targetReferralEntity, "referral");
             if (sourceReferralEntity.getNewsType().equals(-1)) {
                 // 自定义链接延用链接
-                targetReferralEntity.setReferral(sourceReferralEntity.getReferral());
+                targetReferralEntity.setReferral(companyAcquisitionLinkService.checkAndSearchTargetReferral(sourceReferralEntity.getReferral(), targetAuthInfo.getId()));
             }
             // 重新生成链接主键id
             targetReferralEntity.setId(snowflakeComponent.snowflakeId());