获客链接异常事件处理发布者调整【未完成】

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

 package com.yaoyaozw.customer.publisher;
 
 import com.yaoyaozw.customer.dto.AcquisitionExceptionHandleParam;
+import com.yaoyaozw.customer.entity.AuthorizerInfo;
 import com.yaoyaozw.customer.event.AcquisitionExceptionEvent;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Component;
 
@@ -19,7 +21,29 @@ public class AcquisitionExceptionEventPublisher {
     @Resource
     private ApplicationEventPublisher applicationEventPublisher;
 
+    public void inspectAndExecute(String linkId) {
+        if (StringUtils.isBlank(linkId)) {
+            return;
+        }
+        try {
+            // TODO 查链接Id对应的链接数据
+            AuthorizerInfo authorizerInfo = null;
+            String fromPath = null;
+            // 查询可用于替换的链接
+            String toPath = null;
+
+            this.publishAcquisitionExceptionEvent(new AcquisitionExceptionHandleParam(authorizerInfo, fromPath, toPath));
+        } catch (Exception e) {
+            log.error("链接异常处理异常，链接Id：{}", linkId, e);
+        }
+    }
+
+
+
     public void publishAcquisitionExceptionEvent(AcquisitionExceptionHandleParam source) {
+        if (source == null || source.getAuthorizerInfo() == null || StringUtils.isAnyBlank(source.getFromPath(), source.getToPath())) {
+            return;
+        }
         log.info("准备替换公众号：{} 获客链接：{} 为：{}", source.getAuthorizerInfo().getNickName(), source.getFromPath(), source.getToPath());
         applicationEventPublisher.publishEvent(new AcquisitionExceptionEvent(source));
     }