测试获客链接替换的测试类接口

src/main/java/com/yaoyaozw/customer/controller/TestController.java

@@ -9,6 +9,7 @@ import com.yaoyaozw.customer.dto.integration.IntegrationRequestDTO;
 import com.yaoyaozw.customer.entity.CustomerFollowReply;
 import com.yaoyaozw.customer.entity.CustomerGraphics;
 import com.yaoyaozw.customer.mapper.KanbanCommonMapper;
+import com.yaoyaozw.customer.publisher.AcquisitionExceptionEventPublisher;
 import com.yaoyaozw.customer.service.*;
 import com.yaoyaozw.customer.service.wechat.service.WeChatService;
 import com.yaoyaozw.customer.vo.AuthInfoVO;
@@ -162,4 +163,13 @@ public class TestController {
         asyncComponent.addMatchUserIntoPackage(id, true);
     }
 
+
+    @Resource
+    private AcquisitionExceptionEventPublisher acquisitionExceptionEventPublisher;
+
+    @GetMapping("/testAcquisitionReplace")
+    public void testAcquisitionReplace(@RequestParam String linkId) {
+        acquisitionExceptionEventPublisher.inspectAndExecute(linkId);
+    }
+
 }

src/main/java/com/yaoyaozw/customer/publisher/AcquisitionExceptionEventPublisher.java

@@ -45,7 +45,7 @@ public class AcquisitionExceptionEventPublisher {
 
 
 
-    public void publishAcquisitionExceptionEvent(AcquisitionExceptionHandleParam source) {
+    private void publishAcquisitionExceptionEvent(AcquisitionExceptionHandleParam source) {
         if (source == null || source.getAuthorizerInfo() == null || StringUtils.isAnyBlank(source.getFromPath(), source.getToPath())) {
             log.error("publishAcquisitionExceptionEvent 链接异常处理异常，异常参数：{}", (source == null ? "NULL SOURCE" : JSONUtil.toJsonStr(source)));
             return;