feat: Agent应用点击事件

src/main/java/cn/com/poc/expose/rest/impl/AgentApplicationRestImpl.java

@@ -20,6 +20,8 @@ import cn.com.poc.common.utils.UUIDTool;
 import cn.com.poc.expose.aggregate.AgentApplicationService;
 import cn.com.poc.expose.dto.*;
 import cn.com.poc.expose.rest.AgentApplicationRest;
+import cn.com.poc.message.entity.AgentApplicationClickEventMessage;
+import cn.com.poc.message.service.AgentApplicationProducerService;
 import cn.com.poc.support.security.oauth.entity.UserBaseEntity;
 import cn.com.yict.framemax.core.i18n.I18nMessageException;
 import cn.com.yict.framemax.data.model.PagingInfo;
@@ -55,7 +57,7 @@ public class AgentApplicationRestImpl implements AgentApplicationRest {
     private BizAgentApplicationDialoguesRecordService bizAgentApplicationDialoguesRecordService;
 
     @Resource
-    private AgentApplicationMallService agentApplicationMallService;
+    private AgentApplicationProducerService agentApplicationProducerService;
 
     @Override
     public List<String> getRecommendQuestions(HttpServletRequest httpServletRequest) throws Exception {
@@ -87,15 +89,9 @@ public class AgentApplicationRestImpl implements AgentApplicationRest {
     @Override
     public String createDialogues(String agentId) {
         if (StringUtils.isNotBlank(agentId)) {
-            try {
-                BizAgentApplicationPublishEntity agentApplicationPublishEntity = bizAgentApplicationPublishService.getByAgentId(agentId);
-                if (agentApplicationPublishEntity != null) {
-                    Integer publishId = agentApplicationPublishEntity.getId();
-                    agentApplicationMallService.addClickNumber(publishId);
-                }
-            } catch (Exception e) {
-                logger.error(e.getMessage());
-            }
+            AgentApplicationClickEventMessage agentApplicationClickEventMessage = new AgentApplicationClickEventMessage();
+            agentApplicationClickEventMessage.setAgentId(agentId);
+            agentApplicationProducerService.clickEvent(agentApplicationClickEventMessage);
         }
         return "DIA_" + UUIDTool.getUUID();
     }

src/main/java/cn/com/poc/message/entity/AgentApplicationClickEventMessage.java

+package cn.com.poc.message.entity;
+
+import java.io.Serializable;
+
+public class AgentApplicationClickEventMessage implements Serializable {
+
+    private String agentId;
+
+    public String getAgentId() {
+        return agentId;
+    }
+
+    public void setAgentId(String agentId) {
+        this.agentId = agentId;
+    }
+}

src/main/java/cn/com/poc/message/service/AgentApplicationConsumerService.java

+package cn.com.poc.message.service;
+
+import cn.com.poc.message.entity.AgentApplicationClickEventMessage;
+import cn.com.yict.framemax.core.service.BaseService;
+
+public interface AgentApplicationConsumerService extends BaseService {
+
+    void clickEvent(AgentApplicationClickEventMessage message) throws Exception;
+}

src/main/java/cn/com/poc/message/service/AgentApplicationProducerService.java

+package cn.com.poc.message.service;
+
+import cn.com.poc.message.entity.AgentApplicationClickEventMessage;
+import cn.com.yict.framemax.core.service.BaseService;
+
+public interface AgentApplicationProducerService extends BaseService {
+
+    AgentApplicationClickEventMessage clickEvent(AgentApplicationClickEventMessage message);
+
+}

src/main/java/cn/com/poc/message/service/impl/AgentApplicationConsumerServiceImpl.java

+package cn.com.poc.message.service.impl;
+
+import cn.com.poc.agent_application.aggregate.AgentApplicationMallService;
+import cn.com.poc.agent_application.entity.BizAgentApplicationPublishEntity;
+import cn.com.poc.agent_application.service.BizAgentApplicationDialoguesRecordService;
+import cn.com.poc.agent_application.service.BizAgentApplicationPublishService;
+import cn.com.poc.message.entity.AgentApplicationClickEventMessage;
+import cn.com.poc.message.service.AgentApplicationConsumerService;
+import cn.com.poc.message.topic.AgentApplicationTopic;
+import cn.com.yict.framemax.core.service.BaseService;
+import cn.com.yict.framemax.tumbleweed.client.annotation.Consumer;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+@Service
+public class AgentApplicationConsumerServiceImpl implements AgentApplicationConsumerService {
+
+
+    @Resource
+    private BizAgentApplicationPublishService bizAgentApplicationPublishService;
+
+    @Resource
+    private AgentApplicationMallService agentApplicationMallService;
+
+
+    @Override
+    @Consumer(topic = AgentApplicationTopic.AGENT_APPLICATION_CLICK_EVENT, retry = true)
+    public void clickEvent(AgentApplicationClickEventMessage message) throws Exception {
+        BizAgentApplicationPublishEntity agentApplicationPublishEntity = bizAgentApplicationPublishService.getByAgentId(message.getAgentId());
+        if (agentApplicationPublishEntity != null) {
+            Integer publishId = agentApplicationPublishEntity.getId();
+            agentApplicationMallService.addClickNumber(publishId);
+        }
+    }
+}

src/main/java/cn/com/poc/message/service/impl/AgentApplicationProducerServiceImpl.java

+package cn.com.poc.message.service.impl;
+
+import cn.com.poc.message.entity.AgentApplicationClickEventMessage;
+import cn.com.poc.message.service.AgentApplicationProducerService;
+import cn.com.poc.message.topic.AgentApplicationTopic;
+import cn.com.yict.framemax.core.service.BaseService;
+import cn.com.yict.framemax.tumbleweed.client.annotation.Producer;
+import org.springframework.stereotype.Service;
+
+@Service
+public class AgentApplicationProducerServiceImpl implements AgentApplicationProducerService {
+
+    @Override
+    @Producer(topic = AgentApplicationTopic.AGENT_APPLICATION_CLICK_EVENT)
+    public AgentApplicationClickEventMessage clickEvent(AgentApplicationClickEventMessage message) {
+        return message;
+    }
+}

src/main/java/cn/com/poc/message/topic/AgentApplicationTopic.java

+package cn.com.poc.message.topic;
+
+public interface AgentApplicationTopic {
+
+
+    /**
+     * Agent application click event.
+     */
+    String AGENT_APPLICATION_CLICK_EVENT = "agent_application_click_event";
+
+}