更新

FullCardClient/src/main/java/com/zhongshu/card/client/model/mqtt/SendMessageModel.java

@@ -13,6 +13,6 @@ public class SendMessageModel {
     @Schema(description = "接收信息的Topic，格式如：v1/device/001/on", required = true)
     private String topic;
 
-    @Schema(description = "消息内容", required = true)
+    @Schema(description = "消息内容, JSONObject 字符串 或其他", required = true)
     private String message;
 }

FullCardClient/src/main/java/com/zhongshu/card/client/service/MqttFeignService.java

@@ -0,0 +1,22 @@
+package com.zhongshu.card.client.service;
+
+import com.zhongshu.card.client.model.mqtt.SendMessageModel;
+import com.zhongshu.card.client.model.org.*;
+import com.zhongshu.card.client.ret.ResultContent;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+
+
+@FeignClient(name = "fullcardserver-trx/mqttFeign/manager")
+public interface MqttFeignService {
+
+    @Operation(summary = "发送mqtt信息", description = "发送mqtt信息")
+    @RequestMapping(value = "sendMessage", method = {RequestMethod.POST})
+    ResultContent sendMessage(@RequestBody SendMessageModel param);
+
+}

FullCardServer/src/main/java/com/zhongshu/card/server/core/controller/feign/MqttFeignController.java

@@ -0,0 +1,35 @@
+package com.zhongshu.card.server.core.controller.feign;
+
+import com.zhongshu.card.client.model.mqtt.SendMessageModel;
+import com.zhongshu.card.client.model.org.*;
+import com.zhongshu.card.client.ret.ResultContent;
+import com.zhongshu.card.client.service.org.OrganizationService;
+import com.zhongshu.card.client.service.org.UserAccountService;
+import com.zhongshu.card.server.core.service.mqtt.MqttServiceImpl;
+import io.swagger.v3.oas.annotations.Hidden;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @author TRX
+ * @date 2024/7/23
+ */
+@RestController
+@RequestMapping("mqttFeign")
+@Tag(name = "消息服务")
+@Hidden
+public class MqttFeignController {
+
+    @Autowired
+    MqttServiceImpl mqttService;
+
+    @Operation(summary = "发送mqtt信息", description = "发送mqtt信息")
+    @RequestMapping(value = "manager/sendMessage", method = {RequestMethod.POST})
+    public ResultContent<OrganizationUserModel> sendMessage(@RequestBody SendMessageModel param) {
+        return mqttService.sendMessage(param);
+    }
+
+}