修改类型数据类型

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;
+
 }

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);
     }