From 7085ba24d8decee4b13c86a55b93a3bcc4ea0d03 Mon Sep 17 00:00:00 2001 From: luodangjia <luodangjia> Date: 星期五, 23 八月 2024 09:27:38 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java | 25 ++++++++++++++++++++++--- 1 files changed, 22 insertions(+), 3 deletions(-) diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java index 9b0d3b1..22bb005 100644 --- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java +++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java @@ -1,13 +1,32 @@ package com.ruoyi.integration.iotda.utils.listener; +import com.alibaba.fastjson.JSONObject; +import com.ruoyi.common.core.web.domain.AjaxResult; import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RestController; + +import java.io.IOException; /** * iotda消息监听 */ @Slf4j -@Component +@RestController public class IotMessageListener { - + + + /** + * 设备消息监听 + * @param jsonObject + * @return + * @throws IOException + */ + @PostMapping(value = "/message") + public AjaxResult<Integer> add(@RequestBody JSONObject jsonObject) throws IOException { + System.err.println(jsonObject); + return AjaxResult.success(); + } + } \ No newline at end of file -- Gitblit v1.7.1