diff --git a/yudao-module-iot/pom.xml b/yudao-module-iot/pom.xml
index d9002abea5..0422c5d6c8 100644
--- a/yudao-module-iot/pom.xml
+++ b/yudao-module-iot/pom.xml
@@ -10,7 +10,7 @@
yudao-module-iot-api
yudao-module-iot-biz
- yudao-module-iot-plugin
+ yudao-module-iot-plugins
4.0.0
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/dependency-reduced-pom.xml b/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/dependency-reduced-pom.xml
deleted file mode 100644
index 260ef9c8d9..0000000000
--- a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/dependency-reduced-pom.xml
+++ /dev/null
@@ -1,43 +0,0 @@
-
-
-
- yudao-module-iot-plugin
- cn.iocoder.boot
- 2.2.0-snapshot
-
- 4.0.0
- yudao-module-iot-plugin-http
- ${project.artifactId}
- 1.0.0
- 物联网 插件模块 - http 插件
-
-
-
- maven-shade-plugin
- 3.2.4
-
-
- package
-
- shade
-
-
-
-
- com.example.HttpPluginSpringbootApplication
-
-
-
-
-
-
-
-
-
- ${project.artifactId}
- ${project.artifactId}-${project.version}
- cn.iocoder.yudao.module.iot.config.HttpVertxPlugin
- ${project.version}
- yudao
-
-
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/plugin.properties b/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/plugin.properties
deleted file mode 100644
index 49aef5b187..0000000000
--- a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/plugin.properties
+++ /dev/null
@@ -1,6 +0,0 @@
-plugin.id=yudao-module-iot-plugin-http
-plugin.class=cn.iocoder.yudao.module.iot.config.HttpVertxPlugin
-plugin.version=1.0.0
-plugin.provider=yudao
-plugin.dependencies=
-plugin.description=yudao-module-iot-plugin-http-1.0.0
\ No newline at end of file
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/HttpPluginSpringbootApplication.java b/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/HttpPluginSpringbootApplication.java
deleted file mode 100644
index 7b29367d21..0000000000
--- a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/HttpPluginSpringbootApplication.java
+++ /dev/null
@@ -1,26 +0,0 @@
-package cn.iocoder.yudao.module.iot;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.WebApplicationType;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-
-// TODO @haohao:建议包名:cn.iocoder.yudao.module.iot.plugin.${pluginName},例如说 http。然后子包如下:
-// config:方配置类,以及 HttpVertxPlugin 初始化
-// service:放 HttpVertxHandler 逻辑;
-@SpringBootApplication
-public class HttpPluginSpringbootApplication {
-
- public static void main(String[] args) {
-// SpringApplication.run(HttpPluginSpringbootApplication.class, args);
- SpringApplication application = new SpringApplication(HttpPluginSpringbootApplication.class);
- application.setWebApplicationType(WebApplicationType.NONE);
- application.run(args);
- }
-
-}
-
-// TODO @haohao:如下是 sdk 的包:cn.iocoder.yudao.module.iot.plugin.sdk
-// 1. api 包:实现 DeviceDataApi 接口,通过 resttemplate 调用
-// 2. config 包:初始化 DeviceDataApi 等等
-
-// 3. 其中 resttemplate 调用的后端地址,通过每个服务的 application.yaml 进行注入。
\ No newline at end of file
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/config/TestConfiguration.java b/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/config/TestConfiguration.java
deleted file mode 100644
index 18f6b285ef..0000000000
--- a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/config/TestConfiguration.java
+++ /dev/null
@@ -1,69 +0,0 @@
-package cn.iocoder.yudao.module.iot.config;
-
-import cn.iocoder.yudao.framework.common.pojo.CommonResult;
-import cn.iocoder.yudao.module.iot.api.device.DeviceDataApi;
-import cn.iocoder.yudao.module.iot.api.device.dto.IotDeviceEventReportReqDTO;
-import cn.iocoder.yudao.module.iot.api.device.dto.IotDevicePropertyReportReqDTO;
-import cn.iocoder.yudao.module.iot.api.device.dto.IotDeviceStatusUpdateReqDTO;
-import org.pf4j.DefaultPluginManager;
-import org.pf4j.PluginWrapper;
-import org.springframework.boot.web.client.RestTemplateBuilder;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.client.RestTemplate;
-
-import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
-
-// TODO 芋艿:临时实现;
-@Configuration
-public class TestConfiguration {
-
-// @Resource
-// private RestTemplate restTemplate;
-
- // TODO 芋艿:这里,后续看看怎么创建好点
- @Bean
- public RestTemplate restTemplate() {
- return new RestTemplateBuilder().build();
- }
-
- @Bean
- public DeviceDataApi deviceDataApi(RestTemplate restTemplate) {
- return new DeviceDataApi() {
-
- @Override
- public CommonResult updateDeviceStatus(IotDeviceStatusUpdateReqDTO updateReqDTO) {
- // TODO haohao:待实现
- return null;
- }
-
- @Override
- public CommonResult reportDeviceEventData(IotDeviceEventReportReqDTO reportReqDTO) {
- // TODO haohao:待实现
- return null;
- }
-
- @Override
- public CommonResult reportDevicePropertyData(IotDevicePropertyReportReqDTO reportReqDTO) {
- // TODO haohao:待完整实现
- String url = "http://127.0.0.1:48080/rpc-api/iot/device-data/report-property";
- try {
- restTemplate.postForObject(url, reportReqDTO, CommonResult.class);
- return success(true);
- } catch (Exception e) {
- e.printStackTrace();
- return CommonResult.error(400, "error");
- }
- }
-
- };
- }
-
- // TODO @haohao:可能要看下,有没更好的方式
- @Bean(initMethod = "start")
- public HttpVertxPlugin HttpVertxPlugin() {
- PluginWrapper pluginWrapper = new PluginWrapper(new DefaultPluginManager(), null, null, null);
- return new HttpVertxPlugin(pluginWrapper);
- }
-
-}
diff --git a/yudao-module-iot/yudao-module-iot-plugin/pom.xml b/yudao-module-iot/yudao-module-iot-plugins/pom.xml
similarity index 86%
rename from yudao-module-iot/yudao-module-iot-plugin/pom.xml
rename to yudao-module-iot/yudao-module-iot-plugins/pom.xml
index 949ff13e6f..d33292527b 100644
--- a/yudao-module-iot/yudao-module-iot-plugin/pom.xml
+++ b/yudao-module-iot/yudao-module-iot-plugins/pom.xml
@@ -8,6 +8,7 @@
${revision}
+ yudao-module-iot-plugin-common
yudao-module-iot-plugin-http
yudao-module-iot-plugin-mqtt
yudao-module-iot-plugin-emqx
@@ -15,7 +16,7 @@
4.0.0
- yudao-module-iot-plugin
+ yudao-module-iot-plugins
pom
${project.artifactId}
diff --git a/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/pom.xml b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/pom.xml
new file mode 100644
index 0000000000..568f862004
--- /dev/null
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/pom.xml
@@ -0,0 +1,55 @@
+
+
+
+ yudao-module-iot-plugins
+ cn.iocoder.boot
+ ${revision}
+
+ 4.0.0
+ yudao-module-iot-plugin-common
+ jar
+
+ ${project.artifactId}
+
+ 物联网 插件 模块 - 通用功能
+
+
+
+
+ cn.iocoder.boot
+ yudao-common
+
+
+
+ cn.iocoder.boot
+ yudao-module-iot-api
+ ${revision}
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+
+ org.pf4j
+ pf4j-spring
+
+
+ org.slf4j
+ slf4j-log4j12
+
+
+
+
+
+ org.projectlombok
+ lombok
+
+
+
+
diff --git a/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/src/main/java/cn/iocoder/yudao/module/iot/plugin/common/api/DeviceDataApiClient.java b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/src/main/java/cn/iocoder/yudao/module/iot/plugin/common/api/DeviceDataApiClient.java
new file mode 100644
index 0000000000..183c76e58d
--- /dev/null
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/src/main/java/cn/iocoder/yudao/module/iot/plugin/common/api/DeviceDataApiClient.java
@@ -0,0 +1,60 @@
+package cn.iocoder.yudao.module.iot.plugin.common.api;
+
+import cn.iocoder.yudao.framework.common.pojo.CommonResult;
+import cn.iocoder.yudao.module.iot.api.device.DeviceDataApi;
+import cn.iocoder.yudao.module.iot.api.device.dto.IotDeviceEventReportReqDTO;
+import cn.iocoder.yudao.module.iot.api.device.dto.IotDevicePropertyReportReqDTO;
+import cn.iocoder.yudao.module.iot.api.device.dto.IotDeviceStatusUpdateReqDTO;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.client.RestTemplate;
+
+import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
+
+@Slf4j
+public class DeviceDataApiClient implements DeviceDataApi {
+
+ private final RestTemplate restTemplate;
+ private final String deviceDataUrl;
+
+ // 可以通过构造器把 RestTemplate 和 baseUrl 注入进来
+ public DeviceDataApiClient(RestTemplate restTemplate, String deviceDataUrl) {
+ this.restTemplate = restTemplate;
+ this.deviceDataUrl = deviceDataUrl;
+ }
+
+ @Override
+ public CommonResult updateDeviceStatus(IotDeviceStatusUpdateReqDTO updateReqDTO) {
+ // 示例:如果对应的远程地址是 /rpc-api/iot/device-data/update-status
+ String url = deviceDataUrl + "/rpc-api/iot/device-data/update-status";
+ return doPost(url, updateReqDTO, "updateDeviceStatus");
+ }
+
+ @Override
+ public CommonResult reportDeviceEventData(IotDeviceEventReportReqDTO reportReqDTO) {
+ // 示例:如果对应的远程地址是 /rpc-api/iot/device-data/report-event
+ String url = deviceDataUrl + "/rpc-api/iot/device-data/report-event";
+ return doPost(url, reportReqDTO, "reportDeviceEventData");
+ }
+
+ @Override
+ public CommonResult reportDevicePropertyData(IotDevicePropertyReportReqDTO reportReqDTO) {
+ // 示例:如果对应的远程地址是 /rpc-api/iot/device-data/report-property
+ String url = deviceDataUrl + "/rpc-api/iot/device-data/report-property";
+ return doPost(url, reportReqDTO, "reportDevicePropertyData");
+ }
+
+ /**
+ * 将与远程服务交互的通用逻辑抽取成一个私有方法
+ */
+ private CommonResult doPost(String url, T requestBody, String actionName) {
+ log.info("[{}] Sending request to URL: {}", actionName, url);
+ try {
+ // 这里指定返回类型为 CommonResult>,根据后台服务返回的实际结构做调整
+ restTemplate.postForObject(url, requestBody, CommonResult.class);
+ return success(true);
+ } catch (Exception e) {
+ log.error("[{}] Error sending request to URL: {}", actionName, url, e);
+ return CommonResult.error(400, "Request error: " + e.getMessage());
+ }
+ }
+}
diff --git a/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/src/main/java/cn/iocoder/yudao/module/iot/plugin/common/config/DeviceDataApiInitializer.java b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/src/main/java/cn/iocoder/yudao/module/iot/plugin/common/config/DeviceDataApiInitializer.java
new file mode 100644
index 0000000000..9473033c20
--- /dev/null
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/src/main/java/cn/iocoder/yudao/module/iot/plugin/common/config/DeviceDataApiInitializer.java
@@ -0,0 +1,29 @@
+package cn.iocoder.yudao.module.iot.plugin.common.config;
+
+import cn.iocoder.yudao.module.iot.api.device.DeviceDataApi;
+import cn.iocoder.yudao.module.iot.plugin.common.api.DeviceDataApiClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.web.client.RestTemplateBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.client.RestTemplate;
+
+@Configuration
+public class DeviceDataApiInitializer {
+
+ @Value("${iot.device-data.url}")
+ private String deviceDataUrl;
+
+ @Bean
+ public RestTemplate restTemplate() {
+ // 如果你有更多的自定义需求,比如连接池、超时时间等,可以在这里设置
+ return new RestTemplateBuilder().build();
+ }
+
+ @Bean
+ public DeviceDataApi deviceDataApi(RestTemplate restTemplate) {
+ // 返回我们自定义的 Client 实例
+ return new DeviceDataApiClient(restTemplate, deviceDataUrl);
+ }
+
+}
diff --git a/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/src/main/java/cn/iocoder/yudao/module/iot/plugin/common/package-info.java b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/src/main/java/cn/iocoder/yudao/module/iot/plugin/common/package-info.java
new file mode 100644
index 0000000000..f9eae496d4
--- /dev/null
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-common/src/main/java/cn/iocoder/yudao/module/iot/plugin/common/package-info.java
@@ -0,0 +1 @@
+package cn.iocoder.yudao.module.iot.plugin.common;
\ No newline at end of file
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-emqx/plugin.properties b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-emqx/plugin.properties
similarity index 100%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-emqx/plugin.properties
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-emqx/plugin.properties
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-emqx/pom.xml b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-emqx/pom.xml
similarity index 98%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-emqx/pom.xml
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-emqx/pom.xml
index 266e45fd34..cd89743214 100644
--- a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-emqx/pom.xml
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-emqx/pom.xml
@@ -4,7 +4,7 @@
http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd">
- yudao-module-iot-plugin
+ yudao-module-iot-plugins
cn.iocoder.boot
${revision}
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-emqx/src/main/assembly/assembly.xml b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-emqx/src/main/assembly/assembly.xml
similarity index 100%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-emqx/src/main/assembly/assembly.xml
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-emqx/src/main/assembly/assembly.xml
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-emqx/src/main/java/cn/iocoder/yudao/module/iot/plugin/EmqxPlugin.java b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-emqx/src/main/java/cn/iocoder/yudao/module/iot/plugin/EmqxPlugin.java
similarity index 100%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-emqx/src/main/java/cn/iocoder/yudao/module/iot/plugin/EmqxPlugin.java
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-emqx/src/main/java/cn/iocoder/yudao/module/iot/plugin/EmqxPlugin.java
diff --git a/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/plugin.properties b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/plugin.properties
new file mode 100644
index 0000000000..bcdce07c97
--- /dev/null
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/plugin.properties
@@ -0,0 +1,6 @@
+plugin.id=yudao-module-iot-plugin-http
+plugin.class=cn.iocoder.yudao.module.iot.plugin.http.config.HttpVertxPlugin
+plugin.version=1.0.0
+plugin.provider=yudao
+plugin.dependencies=
+plugin.description=yudao-module-iot-plugin-http-1.0.0
\ No newline at end of file
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/pom.xml b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/pom.xml
similarity index 87%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/pom.xml
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/pom.xml
index cfea78964c..15adef3e1d 100644
--- a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/pom.xml
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/pom.xml
@@ -4,7 +4,7 @@
http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd">
- yudao-module-iot-plugin
+ yudao-module-iot-plugins
cn.iocoder.boot
${revision}
@@ -22,7 +22,7 @@
${project.artifactId}
- cn.iocoder.yudao.module.iot.config.HttpVertxPlugin
+ cn.iocoder.yudao.module.iot.plugin.http.config.HttpVertxPlugin
${project.version}
yudao
${project.artifactId}-${project.version}
@@ -121,26 +121,12 @@
-
-
- org.springframework.boot
- spring-boot-starter-web
-
-
-
- org.pf4j
- pf4j-spring
-
cn.iocoder.boot
- yudao-module-iot-api
+ yudao-module-iot-plugin-common
${revision}
-
- org.projectlombok
- lombok
-
io.vertx
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/assembly/assembly.xml b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/assembly/assembly.xml
similarity index 100%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/assembly/assembly.xml
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/assembly/assembly.xml
diff --git a/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/HttpPluginSpringbootApplication.java b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/HttpPluginSpringbootApplication.java
new file mode 100644
index 0000000000..74c5651017
--- /dev/null
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/HttpPluginSpringbootApplication.java
@@ -0,0 +1,16 @@
+package cn.iocoder.yudao.module.iot.plugin.http;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.WebApplicationType;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication(scanBasePackages = "cn.iocoder.yudao.module.iot.plugin")
+public class HttpPluginSpringbootApplication {
+
+ public static void main(String[] args) {
+ SpringApplication application = new SpringApplication(HttpPluginSpringbootApplication.class);
+ application.setWebApplicationType(WebApplicationType.NONE);
+ application.run(args);
+ }
+
+}
\ No newline at end of file
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/config/HttpVertxPlugin.java b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/config/HttpVertxPlugin.java
similarity index 95%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/config/HttpVertxPlugin.java
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/config/HttpVertxPlugin.java
index d77f990c20..e6145b93d5 100644
--- a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/config/HttpVertxPlugin.java
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/config/HttpVertxPlugin.java
@@ -1,8 +1,8 @@
-package cn.iocoder.yudao.module.iot.config;
+package cn.iocoder.yudao.module.iot.plugin.http.config;
import cn.hutool.extra.spring.SpringUtil;
import cn.iocoder.yudao.module.iot.api.device.DeviceDataApi;
-import cn.iocoder.yudao.module.iot.service.HttpVertxHandler;
+import cn.iocoder.yudao.module.iot.plugin.http.service.HttpVertxHandler;
import io.vertx.core.Vertx;
import io.vertx.ext.web.Router;
import io.vertx.ext.web.handler.BodyHandler;
diff --git a/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/config/HttpVertxPluginConfiguration.java b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/config/HttpVertxPluginConfiguration.java
new file mode 100644
index 0000000000..b5e977efbb
--- /dev/null
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/config/HttpVertxPluginConfiguration.java
@@ -0,0 +1,16 @@
+package cn.iocoder.yudao.module.iot.plugin.http.config;
+
+import org.pf4j.DefaultPluginManager;
+import org.pf4j.PluginWrapper;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class HttpVertxPluginConfiguration {
+
+ @Bean(initMethod = "start")
+ public HttpVertxPlugin httpVertxPlugin() {
+ PluginWrapper pluginWrapper = new PluginWrapper(new DefaultPluginManager(), null, null, null);
+ return new HttpVertxPlugin(pluginWrapper);
+ }
+}
\ No newline at end of file
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/service/HttpVertxHandler.java b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/service/HttpVertxHandler.java
similarity index 98%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/service/HttpVertxHandler.java
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/service/HttpVertxHandler.java
index b92b0869b5..becba2a082 100644
--- a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/service/HttpVertxHandler.java
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/java/cn/iocoder/yudao/module/iot/plugin/http/service/HttpVertxHandler.java
@@ -1,4 +1,4 @@
-package cn.iocoder.yudao.module.iot.service;
+package cn.iocoder.yudao.module.iot.plugin.http.service;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/resources/application.yml b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/resources/application.yml
similarity index 53%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/resources/application.yml
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/resources/application.yml
index c5a1ee84cf..e98d46eebe 100644
--- a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-http/src/main/resources/application.yml
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-http/src/main/resources/application.yml
@@ -1,3 +1,7 @@
spring:
application:
name: yudao-module-iot-plugin-http
+
+iot:
+ device-data:
+ url: http://127.0.0.1:48080
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/plugin.properties b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/plugin.properties
similarity index 100%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/plugin.properties
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/plugin.properties
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/pom.xml b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/pom.xml
similarity index 98%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/pom.xml
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/pom.xml
index 7e4689b4ae..e007596dc0 100644
--- a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/pom.xml
+++ b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/pom.xml
@@ -4,7 +4,7 @@
http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd">
- yudao-module-iot-plugin
+ yudao-module-iot-plugins
cn.iocoder.boot
${revision}
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/src/main/assembly/assembly.xml b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/src/main/assembly/assembly.xml
similarity index 100%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/src/main/assembly/assembly.xml
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/src/main/assembly/assembly.xml
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/src/main/java/cn/iocoder/yudao/module/iot/plugin/MqttPlugin.java b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/src/main/java/cn/iocoder/yudao/module/iot/plugin/MqttPlugin.java
similarity index 100%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/src/main/java/cn/iocoder/yudao/module/iot/plugin/MqttPlugin.java
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/src/main/java/cn/iocoder/yudao/module/iot/plugin/MqttPlugin.java
diff --git a/yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/src/main/java/cn/iocoder/yudao/module/iot/plugin/MqttServerExtension.java b/yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/src/main/java/cn/iocoder/yudao/module/iot/plugin/MqttServerExtension.java
similarity index 100%
rename from yudao-module-iot/yudao-module-iot-plugin/yudao-module-iot-plugin-mqtt/src/main/java/cn/iocoder/yudao/module/iot/plugin/MqttServerExtension.java
rename to yudao-module-iot/yudao-module-iot-plugins/yudao-module-iot-plugin-mqtt/src/main/java/cn/iocoder/yudao/module/iot/plugin/MqttServerExtension.java