From 2b9b126a1804715fbb6a30476c5c13a5209d2a35 Mon Sep 17 00:00:00 2001
From: zhangli <2235006734@qq.com>
Date: Fri, 20 Oct 2023 16:09:41 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=B1=BB=E5=9E=8B=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E7=B1=BB=E5=9E=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/win/module/infra/api/trends/dto/TrendsCreateReqDTO.java | 2 ++
 .../com/win/module/infra/mq/consumer/trends/TrendsConsumer.java | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/win-module-infra/win-module-infra-api/src/main/java/com/win/module/infra/api/trends/dto/TrendsCreateReqDTO.java b/win-module-infra/win-module-infra-api/src/main/java/com/win/module/infra/api/trends/dto/TrendsCreateReqDTO.java
index 8e4c2249..f8e4166d 100644
--- a/win-module-infra/win-module-infra-api/src/main/java/com/win/module/infra/api/trends/dto/TrendsCreateReqDTO.java
+++ b/win-module-infra/win-module-infra-api/src/main/java/com/win/module/infra/api/trends/dto/TrendsCreateReqDTO.java
@@ -19,4 +19,6 @@ public class TrendsCreateReqDTO {
     @NotNull(message = "内容不能为空")
     private String content;
 
+    private String creator;
+
 }
diff --git a/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/mq/consumer/trends/TrendsConsumer.java b/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/mq/consumer/trends/TrendsConsumer.java
index 2dd3d7dd..a9af48e1 100644
--- a/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/mq/consumer/trends/TrendsConsumer.java
+++ b/win-module-infra/win-module-infra-biz/src/main/java/com/win/module/infra/mq/consumer/trends/TrendsConsumer.java
@@ -1,6 +1,7 @@
 package com.win.module.infra.mq.consumer.trends;
 
 import com.win.framework.mq.core.stream.AbstractStreamMessageListener;
+import com.win.framework.security.core.util.SecurityFrameworkUtils;
 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;
@@ -26,6 +27,7 @@ public class TrendsConsumer extends AbstractStreamMessageListener<TrendsMessage>
     public void onMessage(TrendsMessage message) {
         log.info("[onMessage][消息内容({})]", message);
         TrendsCreateReqDTO trendsCreateReqDTO = TrendsConvert.INSTANCE.convert(message);
+        trendsCreateReqDTO.setCreator(String.valueOf(SecurityFrameworkUtils.getLoginUserId()));
         trendsService.createTrends(trendsCreateReqDTO);
     }