获客链接异常替换的处理发布与监听器

src/main/java/com/yaoyaozw/customer/dto/AcquisitionExceptionHandleParam.java

+package com.yaoyaozw.customer.dto;
+
+import com.yaoyaozw.customer.entity.AuthorizerInfo;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class AcquisitionExceptionHandleParam implements Serializable {
+
+    /**
+     * 公众号信息
+     */
+    private AuthorizerInfo authorizerInfo;
+
+    /**
+     * 被替换的链接地址
+     */
+    private String fromPath;
+
+    /**
+     * 替换的链接地址
+     */
+    private String toPath;
+
+}

src/main/java/com/yaoyaozw/customer/event/AcquisitionExceptionEvent.java

+package com.yaoyaozw.customer.event;
+
+import cn.hutool.json.JSONUtil;
+import com.yaoyaozw.customer.dto.AcquisitionExceptionHandleParam;
+import org.springframework.context.ApplicationEvent;
+
+public class AcquisitionExceptionEvent extends ApplicationEvent {
+
+    public AcquisitionExceptionEvent(AcquisitionExceptionHandleParam source) {
+        super(source);
+    }
+
+    public AcquisitionExceptionHandleParam getSource() {
+        return JSONUtil.toBean(JSONUtil.toJsonStr(super.getSource()), AcquisitionExceptionHandleParam.class);
+    }
+
+}

src/main/java/com/yaoyaozw/customer/listener/DelayCustomerAcquisitionListener.java

+package com.yaoyaozw.customer.listener;
+
+import com.yaoyaozw.customer.dto.AcquisitionExceptionHandleParam;
+import com.yaoyaozw.customer.event.AcquisitionExceptionEvent;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class DelayCustomerAcquisitionListener implements ApplicationListener<AcquisitionExceptionEvent> {
+
+    @Override
+    public void onApplicationEvent(AcquisitionExceptionEvent acquisitionExceptionEvent) {
+        AcquisitionExceptionHandleParam source = acquisitionExceptionEvent.getSource();
+        if (source == null) {
+            return;
+        }
+
+    }
+}

src/main/java/com/yaoyaozw/customer/listener/FollowReplyAcquisitionListener.java

+package com.yaoyaozw.customer.listener;
+
+import com.yaoyaozw.customer.dto.AcquisitionExceptionHandleParam;
+import com.yaoyaozw.customer.event.AcquisitionExceptionEvent;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class FollowReplyAcquisitionListener implements ApplicationListener<AcquisitionExceptionEvent> {
+
+    @Override
+    public void onApplicationEvent(AcquisitionExceptionEvent acquisitionExceptionEvent) {
+        AcquisitionExceptionHandleParam source = acquisitionExceptionEvent.getSource();
+        if (source == null) {
+            return;
+        }
+
+    }
+}

src/main/java/com/yaoyaozw/customer/listener/KeywordAcquisitionListener.java

+package com.yaoyaozw.customer.listener;
+
+import com.yaoyaozw.customer.dto.AcquisitionExceptionHandleParam;
+import com.yaoyaozw.customer.event.AcquisitionExceptionEvent;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class KeywordAcquisitionListener implements ApplicationListener<AcquisitionExceptionEvent> {
+
+    @Override
+    public void onApplicationEvent(AcquisitionExceptionEvent acquisitionExceptionEvent) {
+        AcquisitionExceptionHandleParam source = acquisitionExceptionEvent.getSource();
+        if (source == null) {
+            return;
+        }
+
+    }
+}

src/main/java/com/yaoyaozw/customer/listener/MenuAcquisitionListener.java

+package com.yaoyaozw.customer.listener;
+
+import com.yaoyaozw.customer.dto.AcquisitionExceptionHandleParam;
+import com.yaoyaozw.customer.event.AcquisitionExceptionEvent;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class MenuAcquisitionListener implements ApplicationListener<AcquisitionExceptionEvent> {
+
+    @Override
+    public void onApplicationEvent(AcquisitionExceptionEvent acquisitionExceptionEvent) {
+        AcquisitionExceptionHandleParam source = acquisitionExceptionEvent.getSource();
+        if (source == null) {
+            return;
+        }
+
+    }
+}

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

+package com.yaoyaozw.customer.publisher;
+
+import com.yaoyaozw.customer.dto.AcquisitionExceptionHandleParam;
+import com.yaoyaozw.customer.event.AcquisitionExceptionEvent;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+/**
+ * @author eumenides
+ * @time 2024/12/13 17:44
+ */
+@Slf4j
+@Component
+public class AcquisitionExceptionEventPublisher {
+
+    @Resource
+    private ApplicationEventPublisher applicationEventPublisher;
+
+    public void publishAcquisitionExceptionEvent(AcquisitionExceptionHandleParam source) {
+        log.info("准备替换公众号：{} 获客链接：{} 为：{}", source.getAuthorizerInfo().getNickName(), source.getFromPath(), source.getToPath());
+        applicationEventPublisher.publishEvent(new AcquisitionExceptionEvent(source));
+    }
+
+
+
+}