From ff3688742cfeb6b9d0eb5fce923d253d39b83642 Mon Sep 17 00:00:00 2001
From: liuchen864 <23082234@qq.com>
Date: Tue, 24 Oct 2023 12:29:12 +0800
Subject: [PATCH] =?UTF-8?q?=E5=85=B3=E9=97=ADmq?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../win/module/infra/api/logger/ApiAccessLogApiImpl.java  | 8 +++-----
 .../win/module/infra/api/logger/ApiErrorLogApiImpl.java   | 8 +++-----
 .../com/win/module/infra/api/trends/TrendsApiImpl.java    | 8 +++-----
 win-server/src/main/resources/application.yaml            | 2 +-
 4 files changed, 10 insertions(+), 16 deletions(-)

diff --git a/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/logger/ApiAccessLogApiImpl.java b/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/logger/ApiAccessLogApiImpl.java
index b191b88d..a37ea3e2 100644
--- a/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/logger/ApiAccessLogApiImpl.java
+++ b/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/logger/ApiAccessLogApiImpl.java
@@ -1,8 +1,6 @@
 package com.win.module.infra.api.logger;
 
 import com.win.module.infra.api.logger.dto.ApiAccessLogCreateReqDTO;
-import com.win.module.infra.convert.logger.ApiAccessLogConvert;
-import com.win.module.infra.mq.message.logger.ApiAccessLogMessage;
 import com.win.module.infra.mq.producer.logger.ApiAccessLogProducer;
 import com.win.module.infra.service.logger.ApiAccessLogService;
 import org.springframework.stereotype.Service;
@@ -27,9 +25,9 @@ public class ApiAccessLogApiImpl implements ApiAccessLogApi {
 
     @Override
     public void createApiAccessLog(ApiAccessLogCreateReqDTO createDTO) {
-        //apiAccessLogService.createApiAccessLog(createDTO);
-        ApiAccessLogMessage accessLogMessage = ApiAccessLogConvert.INSTANCE.convertMessage(createDTO);
-        apiAccessLogProducer.sendMessage(accessLogMessage);
+        apiAccessLogService.createApiAccessLog(createDTO);
+        //ApiAccessLogMessage accessLogMessage = ApiAccessLogConvert.INSTANCE.convertMessage(createDTO);
+        //apiAccessLogProducer.sendMessage(accessLogMessage);
     }
 
 }
diff --git a/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/logger/ApiErrorLogApiImpl.java b/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/logger/ApiErrorLogApiImpl.java
index 73c5eebc..f78cf538 100644
--- a/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/logger/ApiErrorLogApiImpl.java
+++ b/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/logger/ApiErrorLogApiImpl.java
@@ -1,8 +1,6 @@
 package com.win.module.infra.api.logger;
 
 import com.win.module.infra.api.logger.dto.ApiErrorLogCreateReqDTO;
-import com.win.module.infra.convert.logger.ApiErrorLogConvert;
-import com.win.module.infra.mq.message.logger.ApiErrorLogMessage;
 import com.win.module.infra.mq.producer.logger.ApiErrorLogProducer;
 import com.win.module.infra.service.logger.ApiErrorLogService;
 import org.springframework.stereotype.Service;
@@ -27,9 +25,9 @@ public class ApiErrorLogApiImpl implements ApiErrorLogApi {
 
     @Override
     public void createApiErrorLog(ApiErrorLogCreateReqDTO createDTO) {
-        //apiErrorLogService.createApiErrorLog(createDTO);
-        ApiErrorLogMessage errorLogMessage = ApiErrorLogConvert.INSTANCE.convertMessage(createDTO);
-        apiErrorLogProducer.sendMessage(errorLogMessage);
+        apiErrorLogService.createApiErrorLog(createDTO);
+        //ApiErrorLogMessage errorLogMessage = ApiErrorLogConvert.INSTANCE.convertMessage(createDTO);
+        //apiErrorLogProducer.sendMessage(errorLogMessage);
     }
 
 }
diff --git a/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/trends/TrendsApiImpl.java b/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/trends/TrendsApiImpl.java
index 90a748ce..d681f933 100644
--- a/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/trends/TrendsApiImpl.java
+++ b/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/api/trends/TrendsApiImpl.java
@@ -1,8 +1,6 @@
 package com.win.module.infra.api.trends;
 
 import com.win.module.infra.api.trends.dto.TrendsCreateReqDTO;
-import com.win.module.infra.convert.trends.TrendsConvert;
-import com.win.module.infra.mq.message.trends.TrendsMessage;
 import com.win.module.infra.mq.producer.trends.TrendsProducer;
 import com.win.module.infra.service.trends.TrendsService;
 import org.springframework.stereotype.Service;
@@ -27,9 +25,9 @@ public class TrendsApiImpl implements TrendsApi {
 
     @Override
     public void createTrends(TrendsCreateReqDTO createDTO) {
-        //trendsService.createTrends(createDTO);
-        TrendsMessage trendsMessage = TrendsConvert.INSTANCE.convertMessage(createDTO);
-        trendsProducer.sendMessage(trendsMessage);
+        trendsService.createTrends(createDTO);
+        //TrendsMessage trendsMessage = TrendsConvert.INSTANCE.convertMessage(createDTO);
+        //trendsProducer.sendMessage(trendsMessage);
     }
 
 }
diff --git a/win-server/src/main/resources/application.yaml b/win-server/src/main/resources/application.yaml
index fb8fb185..d89f0b25 100644
--- a/win-server/src/main/resources/application.yaml
+++ b/win-server/src/main/resources/application.yaml
@@ -139,7 +139,7 @@ win:
       pubsub:
         enable: false # 是否开启 Redis pubsub 广播消费，默认为 true。这里设置成 false，可以按需开启
       stream:
-        enable: true  # 是否开启 Redis stream 集群消费，默认为 true。这里设置成 false，可以按需开启
+        enable: false  # 是否开启 Redis stream 集群消费，默认为 true。这里设置成 false，可以按需开启
   tenant: # 多租户相关配置项
     enable: true
     ignore-urls: