Merge branch 'han' of usky-cloud-paas/data-agbox-java into master

agbox-topsail/pom.xml

@@ -0,0 +1,104 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>data-agbox-java</artifactId>
+        <groupId>com.usky</groupId>
+        <version>0.0.1</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <packaging>jar</packaging>
+    <artifactId>agbox-topsail</artifactId>
+
+    <dependencies>
+        <!--MQTT依赖-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-integration</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.integration</groupId>
+            <artifactId>spring-integration-mqtt</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis</groupId>
+            <artifactId>mybatis-spring</artifactId>
+            <version>2.0.7</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-openfeign-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.usky</groupId>
+            <artifactId>usky-common-core</artifactId>
+        </dependency>
+
+        <!-- SpringBoot Actuator -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-actuator</artifactId>
+        </dependency>
+
+        <!-- Mysql Connector -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-generator</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.velocity</groupId>
+            <artifactId>velocity-engine-core</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.hibernate</groupId>
+            <artifactId>hibernate-validator</artifactId>
+            <version>6.0.18.Final</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>4.5.7</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-text</artifactId>
+            <version>1.6</version>
+        </dependency>
+        <dependency>
+            <groupId>com.usky</groupId>
+            <artifactId>usky-common-mybatis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>4.5.13</version>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <finalName>${project.artifactId}</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>

agbox-topsail/src/main/java/com/usky/topsail/Application.java

@@ -0,0 +1,44 @@
+package com.usky.topsail;
+
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.core.env.Environment;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
+/**
+ * 系统模块
+ *
+ * @author ruoyi
+ */
+
+@EnableFeignClients(basePackages = "com.usky")
+@MapperScan(value = "com.usky.topsail.mapper")
+@ComponentScan("com.usky")
+@SpringBootApplication
+public class Application
+{
+    private static final Logger LOGGER = LoggerFactory.getLogger(Application.class);
+
+    public static void main(String[] args) throws UnknownHostException {
+        ConfigurableApplicationContext application = SpringApplication.run(Application.class, args);
+        Environment env = application.getEnvironment();
+        String ip = InetAddress.getLocalHost().getHostAddress();
+        String port = env.getProperty("server.port");
+        String path = env.getProperty("server.servlet.context-path");
+        LOGGER.info("\n----------------------------------------------------------\n\t" +
+                "Application is running! Access URLs:\n\t" +
+                "Local: \t\thttp://localhost:" + port + (null==path?"":path) + "/\n\t" +
+                "External: \thttp://" + ip + ":" + port + (null==path?"":path) + "/\n\t" +
+                "----------------------------------------------------------");
+    }
+}
+

agbox-topsail/src/main/java/com/usky/topsail/controller/MybatisGeneratorUtils.java

@@ -0,0 +1,108 @@
+package com.usky.topsail.controller;
+
+
+import com.baomidou.mybatisplus.core.toolkit.StringPool;
+import com.baomidou.mybatisplus.generator.AutoGenerator;
+import com.baomidou.mybatisplus.generator.InjectionConfig;
+import com.baomidou.mybatisplus.generator.config.*;
+import com.baomidou.mybatisplus.generator.config.po.TableInfo;
+import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author yq
+ * @date 2021/7/6 11:42
+ */
+public class MybatisGeneratorUtils {
+    public static void main(String[] args) {
+
+        shell("agbox-topsail");
+    }
+
+    private static void shell(String model) {
+
+        AutoGenerator mpg = new AutoGenerator();
+        //1、全局配置
+        GlobalConfig gc = new GlobalConfig();
+//        File file = new File(model);
+//        String path = file.getAbsolutePath();
+        String projectPath = System.getProperty("user.dir");
+        projectPath+="/"+model;
+        gc.setOutputDir(projectPath+ "/src/main/java");  //生成路径(一般都是生成在此项目的src/main/java下面)
+        //修改为自己的名字
+        gc.setAuthor("han"); //设置作者
+        gc.setOpen(false);
+        gc.setFileOverride(true); //第二次生成会把第一次生成的覆盖掉
+        gc.setServiceName("%sService"); //生成的service接口名字首字母是否为I，这样设置就没有
+        gc.setBaseResultMap(true); //生成resultMap
+        mpg.setGlobalConfig(gc);
+
+        //2、数据源配置
+        //修改数据源
+        DataSourceConfig dsc = new DataSourceConfig();
+        dsc.setUrl("jdbc:mysql://47.98.201.187:3306/jdxf?useUnicode=true&serverTimezone=GMT&useSSL=false&characterEncoding=utf8");
+        dsc.setDriverName("com.mysql.jdbc.Driver");
+        dsc.setUsername("root");
+        dsc.setPassword("Yt2018IoT");
+        mpg.setDataSource(dsc);
+
+        // 3、包配置
+        PackageConfig pc = new PackageConfig();
+        pc.setParent("com.usky.topsail");
+        pc.setController("controller.web");
+        pc.setEntity("domain");
+        pc.setMapper("mapper");
+        pc.setService("service");
+        pc.setServiceImpl("service.impl");
+//        pc.setXml("mapper.demo");
+        //pc.setModuleName("test");
+        mpg.setPackageInfo(pc);
+
+        // 4、策略配置
+        StrategyConfig strategy = new StrategyConfig();
+        strategy.setNaming(NamingStrategy.underline_to_camel);
+        strategy.setColumnNaming(NamingStrategy.underline_to_camel);
+        strategy.setSuperMapperClass("com.usky.common.mybatis.core.CrudMapper");
+        strategy.setSuperServiceClass("com.usky.common.mybatis.core.CrudService");
+        strategy.setSuperServiceImplClass("com.usky.common.mybatis.core.AbstractCrudService");
+        // strategy.setTablePrefix("t_"); // 表名前缀
+        strategy.setEntityLombokModel(true); //使用lombok
+        //修改自己想要生成的表
+        strategy.setInclude("aa");  // 逆向工程使用的表   如果要生成多个,这里可以传入String[]
+        mpg.setStrategy(strategy);
+
+        // 关闭默认 xml 生成，调整生成 至 根目录
+        //修改对应的模块名称
+        TemplateConfig tc = new TemplateConfig();
+        // 自定义配置
+        InjectionConfig cfg = new InjectionConfig() {
+            @Override
+            public void initMap() {
+                // to do nothing
+            }
+        };
+        //如果模板引擎是 velocity
+        String templatePath = "/templates/mapper.xml.vm";
+        // 自定义输出配置
+        List<FileOutConfig> focList = new ArrayList<>();
+        // 自定义配置会被优先输出
+        String finalProjectPath = projectPath;
+        focList.add(new FileOutConfig(templatePath) {
+            @Override
+            public String outputFile(TableInfo tableInfo) {
+                // 自定义输出文件名 ， 如果你 Entity 设置了前后缀、此处注意 xml 的名称会跟着发生变化！！
+                return finalProjectPath + "/src/main/resources/mapper/topsail" + "/"
+                        + tableInfo.getEntityName() + "Mapper" + StringPool.DOT_XML;
+            }
+        });
+        cfg.setFileOutConfigList(focList);
+        mpg.setCfg(cfg);
+        tc.setXml(null);
+        mpg.setTemplate(tc);
+        //5、执行
+        mpg.execute();
+    }
+}
+

agbox-topsail/src/main/java/com/usky/topsail/controller/web/AaController.java

@@ -0,0 +1,21 @@
+package com.usky.topsail.controller.web;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.stereotype.Controller;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-28
+ */
+@Controller
+@RequestMapping("/aa")
+public class AaController {
+
+}
+

agbox-topsail/src/main/java/com/usky/topsail/controller/web/SpOwnerController.java

@@ -0,0 +1,47 @@
+package com.usky.topsail.controller.web;
+
+
+import com.usky.common.core.bean.ApiResult;
+import com.usky.topsail.domain.SpOwner;
+import com.usky.topsail.service.SpOwnerService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-02
+ */
+@RestController
+@RequestMapping("/spOwner")
+public class SpOwnerController {
+    @Autowired
+    private SpOwnerService spOwnerService;
+
+    /**
+     * 查询设备
+     * @param deviceType  设备类型
+     * @return
+     */
+    @GetMapping("/deviceInfo")
+    public ApiResult<List<SpOwner>> deviceInfo(@RequestParam(value = "deviceType") Integer deviceType)
+    {
+        return ApiResult.success(spOwnerService.deviceInfo(deviceType));
+    }
+
+    /**
+     * 新增
+     * @return
+     */
+    @PostMapping("/alarmInfo")
+    ApiResult<Void> add(@RequestBody String requestBody){
+        spOwnerService.add(requestBody);
+        return ApiResult.success();
+    }
+}
+

agbox-topsail/src/main/java/com/usky/topsail/controller/web/SpSj2017Controller.java

@@ -0,0 +1,39 @@
+package com.usky.topsail.controller.web;
+
+
+import com.usky.common.core.bean.ApiResult;
+import com.usky.topsail.service.SpOwnerService;
+import com.usky.topsail.service.SpSj2017Service;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ * asf 前端控制器
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-02
+ */
+@RestController
+@RequestMapping("/spSj2017")
+public class SpSj2017Controller {
+    @Autowired
+    private SpSj2017Service spSj2017Service;
+
+    /**
+     * 新增
+     * @return
+     */
+    @PostMapping("/alarmInfo")
+    ApiResult<Void> add(@RequestBody String requestBody){
+        spSj2017Service.add(requestBody);
+        return ApiResult.success();
+    }
+}
+

agbox-topsail/src/main/java/com/usky/topsail/domain/Aa.java

@@ -0,0 +1,32 @@
+package com.usky.topsail.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-28
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class Aa implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    private String data;
+
+    private LocalDateTime time;
+
+
+}

agbox-topsail/src/main/java/com/usky/topsail/domain/SpOwner.java

@@ -0,0 +1,171 @@
+package com.usky.topsail.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import com.baomidou.mybatisplus.annotation.TableField;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-02
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class SpOwner implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 单位编号
+     */
+    private String ownerCode;
+
+    /**
+     * 单位名称
+     */
+    private String ownerName;
+
+    /**
+     * 单元地址
+     */
+    private String unitinfo;
+
+    /**
+     * 楼层
+     */
+    private String louyu;
+
+    /**
+     * sim卡
+     */
+    private String sim;
+
+    /**
+     * 维保时间
+     */
+    @TableField("maintainTime")
+    private String maintainTime;
+
+    /**
+     * 对应方法
+     */
+    private Integer destAddress;
+
+    /**
+     * 省
+     */
+    private String addr1;
+
+    /**
+     * 市
+     */
+    private String addr2;
+
+    /**
+     * 区、县
+     */
+    private String addr3;
+
+    /**
+     * 地址
+     */
+    private String address;
+
+    /**
+     * 位置
+     */
+    private String posistion;
+
+    /**
+     * 安装时间
+     */
+    private LocalDateTime installTime;
+
+    /**
+     * 安装人
+     */
+    private String installMan;
+
+    /**
+     * 1火系统  2水系统 3烟感系统 4消防栓，5液位 6rtu 7电气火灾 8防火门 9气体灭火 10人脸识别 16视频监控 128井盖 
+     */
+    private Integer dwtype;
+
+    /**
+     * 型号 id,方法
+     */
+    private String ownerXh;
+
+    /**
+     * 间隔时间
+     */
+    private Integer sInterval;
+
+    /**
+     * 社区
+     */
+    private String community;
+
+    /**
+     * 所属单位
+     */
+    private String company;
+
+    private String rtmp;
+
+    private String hls;
+
+    private String html5;
+
+    private String danwei;
+
+    /**
+     * 倍率
+     */
+    private String ownerBl;
+
+    /**
+     * 报告推送参数1
+     */
+    private Integer pushParam1;
+
+    /**
+     * 报告推送参数2
+     */
+    private Integer pushParam2;
+
+    /**
+     * 报告推送参数3
+     */
+    private Integer pushParam3;
+
+    /**
+     * 报告推送参数4
+     */
+    private Integer pushParam4;
+
+    /**
+     * 登录参数Json格式存储
+     */
+    private String loginParam;
+
+    /**
+     * 传输类型
+     */
+    private String transferType;
+
+
+}

agbox-topsail/src/main/java/com/usky/topsail/domain/SpSj2017.java

@@ -0,0 +1,119 @@
+package com.usky.topsail.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * asf
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-02
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class SpSj2017 implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    private String port;
+
+    /**
+     * 设备编号
+     */
+    private String deviceCode;
+
+    /**
+     * 时间
+     */
+    private LocalDateTime time;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+    /**
+     * 地址 ip
+     */
+    private String address;
+
+    /**
+     * 命令码
+     */
+    private String ncmd;
+
+    /**
+     * 报警类型0 正常 1 低压 2高压 3故障 4离线
+     */
+    private String data1;
+
+    /**
+     * 电池电量
+     */
+    private String data2;
+
+    /**
+     * 信号强度
+     */
+    private String data3;
+
+    /**
+     * 压力值 mpa
+     */
+    private String data4;
+
+    /**
+     * 物联网卡号
+     */
+    private String data5;
+
+    /**
+     * 联系人
+     */
+    private String cllxr;
+
+    /**
+     * 处理时间
+     */
+    private LocalDateTime clsj;
+
+    /**
+     * 处理人
+     */
+    private String clr;
+
+    /**
+     * 处理内容
+     */
+    private String clnr;
+
+    private String clwb;
+
+    /**
+     * 联系电话
+     */
+    private String cldh;
+
+    /**
+     * 处理状态
+     */
+    private Integer clzt;
+
+    private String cllx;
+
+    /**
+     * 视频地址
+     */
+    private String video;
+
+
+}

agbox-topsail/src/main/java/com/usky/topsail/mapper/AaMapper.java

@@ -0,0 +1,16 @@
+package com.usky.topsail.mapper;
+
+import com.usky.topsail.domain.Aa;
+import com.usky.common.mybatis.core.CrudMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-28
+ */
+public interface AaMapper extends CrudMapper<Aa> {
+
+}

agbox-topsail/src/main/java/com/usky/topsail/mapper/SpOwnerMapper.java

@@ -0,0 +1,16 @@
+package com.usky.topsail.mapper;
+
+import com.usky.topsail.domain.SpOwner;
+import com.usky.common.mybatis.core.CrudMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-02
+ */
+public interface SpOwnerMapper extends CrudMapper<SpOwner> {
+
+}

agbox-topsail/src/main/java/com/usky/topsail/mapper/SpSj2017Mapper.java

@@ -0,0 +1,16 @@
+package com.usky.topsail.mapper;
+
+import com.usky.topsail.domain.SpSj2017;
+import com.usky.common.mybatis.core.CrudMapper;
+
+/**
+ * <p>
+ * asf Mapper 接口
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-02
+ */
+public interface SpSj2017Mapper extends CrudMapper<SpSj2017> {
+
+}

agbox-topsail/src/main/java/com/usky/topsail/service/AaService.java

@@ -0,0 +1,16 @@
+package com.usky.topsail.service;
+
+import com.usky.topsail.domain.Aa;
+import com.usky.common.mybatis.core.CrudService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-28
+ */
+public interface AaService extends CrudService<Aa> {
+
+}

agbox-topsail/src/main/java/com/usky/topsail/service/SpOwnerService.java

@@ -0,0 +1,19 @@
+package com.usky.topsail.service;
+
+import com.usky.topsail.domain.SpOwner;
+import com.usky.common.mybatis.core.CrudService;
+
+import java.util.List;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-02
+ */
+public interface SpOwnerService extends CrudService<SpOwner> {
+    List<SpOwner> deviceInfo(Integer deviceType);
+    boolean add(String requestBody);
+}

agbox-topsail/src/main/java/com/usky/topsail/service/SpSj2017Service.java

@@ -0,0 +1,16 @@
+package com.usky.topsail.service;
+
+import com.usky.topsail.domain.SpSj2017;
+import com.usky.common.mybatis.core.CrudService;
+
+/**
+ * <p>
+ * asf 服务类
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-02
+ */
+public interface SpSj2017Service extends CrudService<SpSj2017> {
+    boolean add(String requestBody);
+}

agbox-topsail/src/main/java/com/usky/topsail/service/config/mqtt/MqttBaseConfig.java

@@ -0,0 +1,50 @@
+package com.usky.topsail.service.config.mqtt;
+
+import lombok.Data;
+import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory;
+import org.springframework.integration.mqtt.core.MqttPahoClientFactory;
+import org.springframework.stereotype.Component;
+
+@ConditionalOnProperty(prefix = "mqtt", value = {"enabled"}, havingValue = "true")
+@Data
+@Component
+@ConfigurationProperties(prefix = "mqtt")
+public class MqttBaseConfig {
+
+    @Value("${mqtt.username}")
+    private String username;
+
+    @Value("${mqtt.password}")
+    private String password;
+
+    @Value("${mqtt.url}")
+    private String hostUrl;
+
+    @Value("${mqtt.sub-topics}")
+    private String msgTopic;
+
+    @Value("${mqtt.keep-alive-interval}")
+    //心跳间隔
+    private int keepAliveInterval;
+    @Value("${mqtt.completionTimeout}")
+    //心跳间隔
+    private int completionTimeout;
+
+
+    @Bean
+    public MqttPahoClientFactory mqttClientFactory() {
+        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
+        MqttConnectOptions options = new MqttConnectOptions();
+        options.setServerURIs(new String[]{this.getHostUrl()});
+        options.setUserName(this.getUsername());
+        options.setPassword(this.getPassword().toCharArray());
+        factory.setConnectionOptions(options);
+        return factory;
+    }
+
+}

agbox-topsail/src/main/java/com/usky/topsail/service/config/mqtt/MqttInConfig.java

@@ -0,0 +1,48 @@
+package com.usky.topsail.service.config.mqtt;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.integration.channel.DirectChannel;
+import org.springframework.integration.core.MessageProducer;
+import org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter;
+import org.springframework.integration.mqtt.support.DefaultPahoMessageConverter;
+import org.springframework.messaging.MessageChannel;
+
+/**
+ * @author han
+ * @date 2025/03/20 14:30
+ */
+@ConditionalOnProperty(prefix = "mqtt", value = {"enabled"}, havingValue = "true")
+@Configuration
+public class MqttInConfig {
+    @Autowired
+    private MqttBaseConfig mqttBaseConfig;
+
+    public static final String CHANNEL_NAME_INPUT = "mqttInputChannel";
+
+    @Bean(name = CHANNEL_NAME_INPUT)
+    public MessageChannel mqttInputChannel() {
+        return new DirectChannel();
+    }
+
+
+    /**
+     * 消息订阅绑定-消费者
+     *
+     * @return
+     */
+    @Bean
+    public MessageProducer inbound() {
+        String[] tops = mqttBaseConfig.getMsgTopic().split(",");
+        String clientId = "h-agbox-mqtt-in-" + System.currentTimeMillis();
+        MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter(clientId,
+                mqttBaseConfig.mqttClientFactory(), tops);
+        adapter.setCompletionTimeout(mqttBaseConfig.getCompletionTimeout());
+        adapter.setConverter(new DefaultPahoMessageConverter());
+        adapter.setQos(2);
+        adapter.setOutputChannel(mqttInputChannel());
+        return adapter;
+    }
+}

agbox-topsail/src/main/java/com/usky/topsail/service/config/mqtt/MqttOutConfig.java

@@ -0,0 +1,86 @@
+package com.usky.topsail.service.config.mqtt;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.integration.annotation.MessagingGateway;
+import org.springframework.integration.annotation.ServiceActivator;
+import org.springframework.integration.channel.DirectChannel;
+import org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler;
+import org.springframework.integration.mqtt.support.MqttHeaders;
+import org.springframework.messaging.MessageChannel;
+import org.springframework.messaging.MessageHandler;
+import org.springframework.messaging.handler.annotation.Header;
+
+/**
+ * @author han
+ * @date 2025/03/20 14:31
+ */
+@ConditionalOnProperty(prefix = "mqtt", value = {"enabled"}, havingValue = "true")
+@Configuration
+public class MqttOutConfig {
+    @Autowired
+    public MqttBaseConfig mqttBaseConfig;
+
+    public static final String CHANNEL_NAME_OUT = "mqttOutboundChannel";
+
+    public static final String MESSAGE_NAME = "messageOut";
+
+    public static final String DEFAULT_TOPIC = "testTopic";
+
+    /**
+     * 连接通道
+     *
+     * @return
+     */
+    @Bean(name = CHANNEL_NAME_OUT)
+    public MessageChannel mqttOutboundChannel() {
+        return new DirectChannel();
+    }
+
+    /**
+     * 发送消息和消费消息Channel可以使用相同MqttPahoClientFactory
+     *
+     * @return
+     */
+    @Bean(name = MESSAGE_NAME)
+    @ServiceActivator(inputChannel = CHANNEL_NAME_OUT)
+    public MessageHandler outbound() {
+        // 在这里进行mqttOutboundChannel的相关设置
+        String clientId = "h-backend-mqtt-in-" + System.currentTimeMillis();
+        MqttPahoMessageHandler messageHandler =
+                new MqttPahoMessageHandler(clientId, mqttBaseConfig.mqttClientFactory());
+        //如果设置成true，发送消息时将不会阻塞。
+        messageHandler.setAsync(true);
+        messageHandler.setDefaultTopic(DEFAULT_TOPIC);
+        return messageHandler;
+    }
+
+    @MessagingGateway(defaultRequestChannel = CHANNEL_NAME_OUT)
+    public interface MqttGateway {
+        /**
+         * 发送消息
+         *
+         * @param payload
+         */
+        void sendToMqtt(String payload);
+
+        /**
+         * 指定top发送消息
+         *
+         * @param topic
+         * @param payload
+         */
+        void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, String payload);
+
+        /**
+         * 指定队列和qos
+         *
+         * @param topic
+         * @param qos
+         * @param payload
+         */
+        void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, @Header(MqttHeaders.QOS) int qos, String payload);
+    }
+}

agbox-topsail/src/main/java/com/usky/topsail/service/impl/AaServiceImpl.java

@@ -0,0 +1,20 @@
+package com.usky.topsail.service.impl;
+
+import com.usky.topsail.domain.Aa;
+import com.usky.topsail.mapper.AaMapper;
+import com.usky.topsail.service.AaService;
+import com.usky.common.mybatis.core.AbstractCrudService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-28
+ */
+@Service
+public class AaServiceImpl extends AbstractCrudService<AaMapper, Aa> implements AaService {
+
+}

agbox-topsail/src/main/java/com/usky/topsail/service/impl/SpOwnerServiceImpl.java

@@ -0,0 +1,88 @@
+package com.usky.topsail.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.toolkit.SqlRunner;
+import com.usky.topsail.domain.Aa;
+import com.usky.topsail.domain.SpOwner;
+import com.usky.topsail.mapper.SpOwnerMapper;
+import com.usky.topsail.service.AaService;
+import com.usky.topsail.service.SpOwnerService;
+import com.usky.common.mybatis.core.AbstractCrudService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.util.*;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-02
+ */
+@Service
+public class SpOwnerServiceImpl extends AbstractCrudService<SpOwnerMapper, SpOwner> implements SpOwnerService {
+    @Autowired
+    private AaService aaService;
+
+    public List<SpOwner> deviceInfo(Integer deviceType){
+        LambdaQueryWrapper<SpOwner> queryWrapper = Wrappers.lambdaQuery();
+        queryWrapper.select(SpOwner::getOwnerCode);
+        List<SpOwner> records = this.list(queryWrapper);
+        return records;
+    }
+
+    @Override
+    public boolean add(String requestBody){
+        JSONObject requestVO = JSONObject.parseObject(requestBody);
+        String serviceId = requestVO.get("serviceId").toString();
+        if (StringUtils.isNotBlank(serviceId) && serviceId.equals("sensor_dat_report")){
+            String payload = requestVO.get("payload").toString();
+            JSONObject payloadVO = JSONObject.parseObject(payload);
+            String device_code = payloadVO.get("IMEI").toString();
+            Integer bat_level = Integer.parseInt(payloadVO.get("bat_level").toString());
+            Integer CSQ = Integer.parseInt(payloadVO.get("CSQ").toString());
+            Integer dev_type = Integer.parseInt(payloadVO.get("dev_type").toString());
+            Integer alarm = Integer.parseInt(payloadVO.get("alarm").toString());
+            String samp_time = LocalDateTime.now().toString();
+            String sensor_dat = payloadVO.get("sensor_dat").toString();
+            String[] strArray = sensor_dat.split("\\|");
+            String sensor_dat_value = strArray[1];
+            String[] strArray1 = sensor_dat_value.split(",");
+            String device_value = "";
+            if (strArray1.length>=2){
+                device_value = strArray1[1];
+            }else {
+                device_value = strArray1[0];
+            }
+            String device_status = "";
+            if(dev_type.equals(1)){
+                if (alarm.equals(0)){
+                    device_status = "WP0";
+                }
+            }else if (dev_type.equals(2)){
+                if (alarm.equals(0)){
+                    device_status = "LL0";
+                }
+            }
+            // 构建SQL语句
+            String sql =
+                    "INSERT INTO " + "sp_d"+device_code + "(device_code,port,time,data1,data2," +
+                            "data3,data4,data5) " + "VALUES ("+ "\""+device_code+ "\""+","+"\""+"TSM-10P"+"\""+","+"\""+samp_time+"\""
+                            +","+"\""+device_status+"\""+","+"\""+bat_level+"\""+","+"\""+CSQ+"\""+","+"\""+device_value+"\""+","+"\""+"11111111111"+"\""+")";
+            // 调用JdbcTemplate进行数据库操作
+            SqlRunner.db().insert(sql);
+        }
+        Aa aa = new Aa();
+        aa.setData(requestBody);
+        aa.setTime(LocalDateTime.now());
+        aaService.save(aa);
+        return true;
+    }
+}

agbox-topsail/src/main/java/com/usky/topsail/service/impl/SpSj2017ServiceImpl.java

@@ -0,0 +1,235 @@
+package com.usky.topsail.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.toolkit.SqlRunner;
+import com.usky.topsail.domain.Aa;
+import com.usky.topsail.domain.SpOwner;
+import com.usky.topsail.domain.SpSj2017;
+import com.usky.topsail.mapper.SpSj2017Mapper;
+import com.usky.topsail.service.AaService;
+import com.usky.topsail.service.SpOwnerService;
+import com.usky.topsail.service.SpSj2017Service;
+import com.usky.common.mybatis.core.AbstractCrudService;
+import com.usky.topsail.service.config.mqtt.MqttOutConfig;
+import com.usky.topsail.service.util.HttpClientUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.time.Instant;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * <p>
+ * asf 服务实现类
+ * </p>
+ *
+ * @author han
+ * @since 2024-02-02
+ */
+@Service
+public class SpSj2017ServiceImpl extends AbstractCrudService<SpSj2017Mapper, SpSj2017> implements SpSj2017Service {
+    @Autowired
+    private AaService aaService;
+
+    @Autowired
+    private SpOwnerService spOwnerService;
+
+    @Resource
+    private MqttOutConfig.MqttGateway mqttGateway;
+
+    @Override
+    public boolean add(String requestBody){
+        JSONObject requestVO = JSONObject.parseObject(requestBody);
+        String serviceId = requestVO.get("serviceId").toString();
+        if (StringUtils.isNotBlank(serviceId) && serviceId.equals("sensor_dat_report")){
+            String payload = requestVO.get("payload").toString();
+            JSONObject payloadVO = JSONObject.parseObject(payload);
+            String device_code = payloadVO.get("IMEI").toString();
+            LambdaQueryWrapper<SpOwner> wrapper = Wrappers.lambdaQuery();
+            wrapper.select(SpOwner::getCompany,SpOwner::getOwnerName);
+            wrapper.eq(SpOwner::getOwnerCode, device_code);
+            List<SpOwner> deviceList = spOwnerService.list(wrapper);
+            if (deviceList.size()>0){
+                Integer bat_level = Integer.parseInt(payloadVO.get("bat_level").toString());
+                Integer CSQ = Integer.parseInt(payloadVO.get("CSQ").toString());
+                Integer dev_type = Integer.parseInt(payloadVO.get("dev_type").toString());
+                String alarm = payloadVO.get("alarm").toString();
+                DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+                String samp_time = LocalDateTime.now().format(formatter);
+                String sensor_dat = payloadVO.get("sensor_dat").toString();
+                String[] strArray = sensor_dat.split("\\|");
+                String sensor_dat_value = strArray[1];
+                String[] strArray1 = sensor_dat_value.split(",");
+                String device_value = "";
+                if (strArray1.length>=2){
+                    device_value = strArray1[1];
+                }else {
+                    device_value = strArray1[0];
+                }
+                String device_status = "";
+                JSONObject payloadVO1 = new JSONObject();
+                List<Map<String, Object>> payloadVO3 = new ArrayList<>();
+                JSONObject payloadVO2 = new JSONObject();
+                payloadVO1.put("devId",device_code);
+                payloadVO1.put("connType","G");
+                payloadVO1.put("deviceName",deviceList.get(0).getOwnerName());
+                payloadVO2.put("deviceName",deviceList.get(0).getOwnerName());
+                Instant instant = Instant.now();
+                long seconds = instant.getEpochSecond();
+                payloadVO2.put("timeStamp",seconds);
+                payloadVO1.put("timeStamp",seconds);
+                payloadVO2.put("deviceModel","");
+                payloadVO2.put("devId",device_code);
+                List<Map<String, Object>> db = new ArrayList<>();
+                Map<String, Object> dbMap = new HashMap<>();
+                dbMap.put("property","电量");
+                dbMap.put("serial","201");
+                dbMap.put("value",bat_level);
+                db.add(dbMap);
+                Map<String, Object> dbMap1 = new HashMap<>();
+                dbMap1.put("property","信号");
+                dbMap1.put("serial","202");
+                dbMap1.put("value","3");
+                db.add(dbMap1);
+                if(dev_type.equals(1)){
+                    payloadVO2.put("deviceType","2");
+                    Map<String, Object> dbMap2 = new HashMap<>();
+                    dbMap2.put("property","水压");
+                    dbMap2.put("serial","203");
+                    dbMap2.put("value",device_value);
+                    db.add(dbMap2);
+                    Map<String, Object> dbMap3 = new HashMap<>();
+                    dbMap3.put("property","状态");
+                    dbMap3.put("serial","204");
+                    if (alarm.equals("0")){
+                        device_status = "WP0";
+                        dbMap3.put("value","0");
+                        payloadVO1.put("type","INFO");
+                    }else if (alarm.equals("131072")){
+                        device_status = "WP1";
+                        dbMap3.put("value","1");
+                        payloadVO1.put("type","ALARM");
+                    }else if (alarm.equals("262144")){
+                        device_status = "WP2";
+                        dbMap3.put("value","2");
+                        payloadVO1.put("type","ALARM");
+                    }
+                    db.add(dbMap3);
+                }else if (dev_type.equals(2)){
+                    payloadVO2.put("deviceType","5");
+                    Map<String, Object> dbMap2 = new HashMap<>();
+                    dbMap2.put("property","水位");
+                    dbMap2.put("serial","203");
+                    dbMap2.put("value",device_value);
+                    db.add(dbMap2);
+                    Map<String, Object> dbMap3 = new HashMap<>();
+                    dbMap3.put("property","状态");
+                    dbMap3.put("serial","204");
+                    if (alarm.equals("0")){
+                        device_status = "LL0";
+                        dbMap3.put("value","0");
+                        payloadVO1.put("type","INFO");
+                    }else if (alarm.equals("131072")){
+                        payloadVO1.put("type","ALARM");
+                        dbMap3.put("value","1");
+                        device_status = "LL1";
+                        SpSj2017 spSj2017 = new SpSj2017();
+                        spSj2017.setPort("TSM-10P");
+                        spSj2017.setDeviceCode(device_code);
+                        spSj2017.setStatus("17");
+                        spSj2017.setAddress("127.0.0.1");
+                        spSj2017.setNcmd("");
+                        spSj2017.setTime(LocalDateTime.now());
+                        spSj2017.setData1(device_status);
+                        spSj2017.setData2(bat_level.toString());
+                        spSj2017.setData3(CSQ.toString());
+                        spSj2017.setData4(device_value);
+                        spSj2017.setData5("11111111111");
+                        spSj2017.setCllxr("");
+                        spSj2017.setClsj(LocalDateTime.now());
+                        spSj2017.setClr("");
+                        spSj2017.setClnr("");
+                        spSj2017.setClwb("");
+                        spSj2017.setCldh("");
+                        spSj2017.setClzt(0);
+                        spSj2017.setCllx("");
+                        spSj2017.setVideo("");
+                        this.save(spSj2017);
+                        Long insertid1 = spSj2017.getId();
+                        HashMap map = new HashMap();
+                        map.put("IMEI", device_code);
+                        map.put("insert_id", String.valueOf(insertid1));
+                        map.put("phone", "17630065224");
+                        map.put("time", samp_time);
+                        map.put("evt", device_status);
+                        String httpurl = "https://iot.usky.cn/jdxf/wxapp2.php/Home/Waterwarn/message_water";
+                        String httpOrgCreateTestRtn = HttpClientUtil.doPost(httpurl, map, "utf-8");
+                    }else if (alarm.equals("262144")){
+                        payloadVO1.put("type","ALARM");
+                        dbMap3.put("value","2");
+                        device_status = "LL2";
+                        SpSj2017 spSj2017 = new SpSj2017();
+                        spSj2017.setPort("TSM-10P");
+                        spSj2017.setDeviceCode(device_code);
+                        spSj2017.setStatus("17");
+                        spSj2017.setAddress("127.0.0.1");
+                        spSj2017.setNcmd("");
+                        spSj2017.setTime(LocalDateTime.now());
+                        spSj2017.setData1(device_status);
+                        spSj2017.setData2(bat_level.toString());
+                        spSj2017.setData3(CSQ.toString());
+                        spSj2017.setData4(device_value);
+                        spSj2017.setData5("11111111111");
+                        spSj2017.setCllxr("");
+                        spSj2017.setClsj(LocalDateTime.now());
+                        spSj2017.setClr("");
+                        spSj2017.setClnr("");
+                        spSj2017.setClwb("");
+                        spSj2017.setCldh("");
+                        spSj2017.setClzt(0);
+                        spSj2017.setCllx("");
+                        spSj2017.setVideo("");
+                        this.save(spSj2017);
+                        Long insertid1 = spSj2017.getId();
+                        HashMap map = new HashMap();
+                        map.put("IMEI", device_code);
+                        map.put("insert_id", String.valueOf(insertid1));
+                        map.put("phone", "17630065224");
+                        map.put("time", samp_time);
+                        map.put("evt", device_status);
+                        String httpurl = "https://iot.usky.cn/jdxf/wxapp2.php/Home/Waterwarn/message_water";
+                        String httpOrgCreateTestRtn = HttpClientUtil.doPost(httpurl, map, "utf-8");
+                    }
+                    db.add(dbMap3);
+                }
+                payloadVO2.put("dp",db);
+                payloadVO3.add(payloadVO2);
+                payloadVO1.put("devs",payloadVO3);
+                // 构建SQL语句
+                String sql =
+                        "INSERT INTO " + "sp_d"+device_code + "(device_code,port,time,data1,data2," +
+                                "data3,data4,data5) " + "VALUES ("+ "\""+device_code+ "\""+","+"\""+"TSM-10P"+"\""+","+"\""+samp_time+"\""
+                                +","+"\""+device_status+"\""+","+"\""+bat_level+"\""+","+"\""+CSQ+"\""+","+"\""+device_value+"\""+","+"\""+"11111111111"+"\""+")";
+                // 调用JdbcTemplate进行数据库操作
+                SqlRunner.db().insert(sql);
+                System.out.print(payloadVO1.toJSONString());
+                mqttGateway.sendToMqtt("/usky/ytDP0002/"+deviceList.get(0).getCompany()+"/"+device_code+"/info",
+                        payloadVO1.toJSONString());
+            }
+        }
+        Aa aa = new Aa();
+        aa.setData(requestBody);
+        aa.setTime(LocalDateTime.now());
+        aaService.save(aa);
+        return true;
+    }
+}

agbox-topsail/src/main/java/com/usky/topsail/service/listener/MqttListener.java

@@ -0,0 +1,55 @@
+//package com.usky.topsail.service.listener;
+//
+//import com.usky.topsail.service.config.mqtt.MqttInConfig;
+//import com.usky.topsail.service.mqtt.SimpleContext;
+//import com.usky.topsail.service.vo.MqttBaseVO;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.integration.annotation.ServiceActivator;
+//import org.springframework.messaging.MessageHandler;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * @author han
+// * @date 2025/03/20 14:41
+// */
+//@ConditionalOnProperty(prefix = "mqtt", value = {"enabled"}, havingValue = "true")
+//@Slf4j
+//@Component
+//public class MqttListener {
+//    public static final String MESSAGE_NAME = "messageInput";
+//
+//    @Autowired
+//    private SimpleContext simpleContext;
+//
+//    /**
+//     * 处理消息-消费者
+//     *
+//     * @return
+//     */
+//    @Bean(MESSAGE_NAME)
+//    @ServiceActivator(inputChannel = MqttInConfig.CHANNEL_NAME_INPUT)
+//    public MessageHandler handler() {
+//        return message -> {
+//            String payload = message.getPayload().toString();
+//            //进行接口推送
+//            Object mqttReceivedTopic = message.getHeaders().get("mqtt_receivedTopic");
+//            if (null != mqttReceivedTopic) {
+//                String topic = mqttReceivedTopic.toString();
+//                MqttBaseVO mqttBaseVO = new MqttBaseVO();
+//                mqttBaseVO.setTopic(topic);
+//                if (topic.indexOf("info") != -1 ) {
+//                    mqttBaseVO.setDescribe("info");
+//                    mqttBaseVO.setData(payload);
+//                }else if(topic.indexOf("event") != -1 ) {
+//                    mqttBaseVO.setDescribe("event");
+//                    mqttBaseVO.setData(payload);
+//                }
+//                //统一处理数据
+//                simpleContext.getResource(mqttBaseVO);
+//            }
+//        };
+//    }
+//}

agbox-topsail/src/main/java/com/usky/topsail/service/mqtt/MqttStrategy.java

@@ -0,0 +1,13 @@
+package com.usky.topsail.service.mqtt;
+
+import com.usky.topsail.service.vo.MqttBaseVO;
+
+public interface MqttStrategy {
+    /**
+     * 处理消息(策略模式由子类实现)
+     *
+     * @param mqttBaseVO
+     * @return
+     */
+    String disposeMessage(MqttBaseVO mqttBaseVO);
+}

agbox-topsail/src/main/java/com/usky/topsail/service/mqtt/SimpleContext.java

@@ -0,0 +1,25 @@
+package com.usky.topsail.service.mqtt;
+
+import com.usky.topsail.service.vo.MqttBaseVO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * 中间处理消息转发
+ */
+@Service
+public class SimpleContext {
+    @Autowired
+    private final Map<String, MqttStrategy> strategyMap = new ConcurrentHashMap<>();
+
+    public SimpleContext(Map<String, MqttStrategy> strategyMap) {
+        strategyMap.forEach(this.strategyMap::put);
+    }
+
+    public String getResource(MqttBaseVO mqttBaseVO) {
+        return strategyMap.get(mqttBaseVO.getDescribe()).disposeMessage(mqttBaseVO);
+    }
+}

agbox-topsail/src/main/java/com/usky/topsail/service/mqtt/info/Info.java

@@ -0,0 +1,27 @@
+package com.usky.topsail.service.mqtt.info;
+
+import com.alibaba.fastjson.JSONObject;
+import com.usky.topsail.service.mqtt.MqttStrategy;
+import com.usky.topsail.service.vo.MqttBaseVO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author han
+ * @date 2025/03/20 17:56
+ */
+@Service("info")
+public class Info implements MqttStrategy {
+
+    public String disposeMessage(MqttBaseVO mqttBaseVO) {
+
+        try {
+            JSONObject map_data = JSONObject.parseObject(mqttBaseVO.getData().toString());
+            System.out.println("FInfoReceiver消费者收到消息： " + mqttBaseVO.getData().toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return null;
+    }
+}

agbox-topsail/src/main/java/com/usky/topsail/service/util/DynamicTableDataInsertion.java

@@ -0,0 +1,21 @@
+package com.usky.topsail.service.util;
+
+import com.baomidou.mybatisplus.extension.toolkit.SqlRunner;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DynamicTableDataInsertion {
+
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
+    public void insertDynamicTableData(String tableName, String column1Value, String column2Value) {
+        // 构建SQL语句
+        String sql = "INSERT INTO " + tableName + "(data,time) VALUES ("+"\""+column1Value+"\""+","+"\""+column2Value+"\""+")";
+
+        // 调用JdbcTemplate进行数据库操作
+        SqlRunner.db().insert(sql);
+    }
+}

agbox-topsail/src/main/java/com/usky/topsail/service/util/HttpClientUtil.java

@@ -0,0 +1,51 @@
+package com.usky.topsail.service.util;
+
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.util.EntityUtils;
+import org.springframework.stereotype.Repository;
+
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+
+@Repository
+public class HttpClientUtil {
+    public static String doPost(String url, Map<String, String> map, String charset) {
+        HttpClient httpClient = null;
+        HttpPost httpPost = null;
+        String result = null;
+        try {
+            httpClient = new SSLClient();
+            httpPost = new HttpPost(url);
+            //设置参数
+            List<NameValuePair> list = new ArrayList<NameValuePair>();
+            Iterator iterator = map.entrySet().iterator();
+            while (iterator.hasNext()) {
+                Map.Entry<String, String> elem = (Map.Entry<String, String>) iterator.next();
+                list.add(new BasicNameValuePair(elem.getKey(), elem.getValue()));
+            }
+            if (list.size() > 0) {
+                UrlEncodedFormEntity entity = new UrlEncodedFormEntity(list, charset);
+                httpPost.setEntity(entity);
+            }
+            HttpResponse response = httpClient.execute(httpPost);
+            System.out.println("HttpPost +++++++++++++++ " + url);
+            if (response != null) {
+                HttpEntity resEntity = response.getEntity();
+                if (resEntity != null) {
+                    result = EntityUtils.toString(resEntity, charset);
+                }
+            }
+        } catch (Exception ex) {
+            ex.printStackTrace();
+        }
+        return result;
+    }
+}

agbox-topsail/src/main/java/com/usky/topsail/service/util/SSLClient.java

@@ -0,0 +1,42 @@
+package com.usky.topsail.service.util;
+
+import java.security.cert.CertificateException;
+import java.security.cert.X509Certificate;
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.X509TrustManager;
+
+import org.apache.http.conn.ClientConnectionManager;
+import org.apache.http.conn.scheme.Scheme;
+import org.apache.http.conn.scheme.SchemeRegistry;
+import org.apache.http.conn.ssl.SSLSocketFactory;
+import org.apache.http.impl.client.DefaultHttpClient;
+
+//用于进行Https请求的HttpClient
+public class SSLClient extends DefaultHttpClient {
+    public SSLClient() throws Exception {
+        super();
+        SSLContext ctx = SSLContext.getInstance("TLS");
+        X509TrustManager tm = new X509TrustManager() {
+            @Override
+            public void checkClientTrusted(X509Certificate[] chain,
+                                           String authType) throws CertificateException {
+            }
+
+            @Override
+            public void checkServerTrusted(X509Certificate[] chain,
+                                           String authType) throws CertificateException {
+            }
+
+            @Override
+            public X509Certificate[] getAcceptedIssuers() {
+                return null;
+            }
+        };
+        ctx.init(null, new TrustManager[]{tm}, null);
+        SSLSocketFactory ssf = new SSLSocketFactory(ctx, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
+        ClientConnectionManager ccm = this.getConnectionManager();
+        SchemeRegistry sr = ccm.getSchemeRegistry();
+        sr.register(new Scheme("https", 443, ssf));
+    }
+}

agbox-topsail/src/main/java/com/usky/topsail/service/vo/MqttBaseVO.java

@@ -0,0 +1,21 @@
+package com.usky.topsail.service.vo;
+
+import lombok.Data;
+
+/**
+ * @author han
+ * @date 2025/03/20 14:41
+ */
+@Data
+public class MqttBaseVO {
+    /**
+     * 接口描述
+     */
+    private String describe;
+
+    private String topic;
+    /**
+     * 数据内容
+     */
+    private Object data;
+}

agbox-topsail/src/main/resources/application.yml

@@ -0,0 +1,91 @@
+# Tomcat
+server:
+  port: 9892
+  servlet:
+    context-path: /agbox-topsail
+mqtt:
+  completionTimeout: 5000
+  enabled: true
+  keep-alive-interval: 60
+  password: usky
+  sub-topics: /usky/ytDP0009/10387/1/info
+  url: tcp://47.98.201.73:1883
+  username: usky
+mybatis:
+  refresh:
+    delay-seconds: 10
+    enabled: true
+    sleep-seconds: 20
+mybatis-plus:
+  configuration:
+    defaultStatementTimeout: 3
+    lazy-loading-enabled: true
+    map-underscore-to-camel-case: true
+  global-config:
+    db-config:
+      id-type: auto
+    mapperRegistryCache: true
+    enable-sql-runner: true
+  mapper-locations: classpath*:mapper/**/*.xml
+spring:
+  application:
+    # 应用名称
+    name: agbox-topsail
+  cache:
+    ehcache:
+      config: classpath:ehcache.xml
+      enabled: false
+    redis:
+      enabled: true
+  datasource:
+    druid:
+      stat-view-servlet:
+        enabled: true
+        login-password: '@dmin1234'
+        login-username: admin
+        reset-enable: true
+        url-pattern: /druid/*
+    dynamic:
+      datasource:
+        master:
+          password: Yt2018IoT
+          url: jdbc:mysql://47.98.201.187:3306/jdxf?useunicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai&characterEncoding=utf8&allowMultiQueries=true
+          username: root
+      druid:
+        initial-size: 5
+        min-idle: 5
+        maxActive: 20
+        maxWait: 60000
+        timeBetweenEvictionRunsMillis: 60000
+        minEvictableIdleTimeMillis: 300000
+        validationQuery: SELECT 1 FROM DUAL
+        testWhileIdle: true
+        testOnBorrow: false
+        testOnReturn: false
+        poolPreparedStatements: true
+        maxPoolPreparedStatementPerConnectionSize: 20
+        filters: stat,slf4j
+        connectionProperties: druid.stat.mergeSql\=true;druid.stat.slowSqlMillis\=5000
+      primary: master
+  jackson:
+    date-format: yyyy-MM-dd HH:mm:ss
+    default-property-inclusion: always
+    deserialization:
+      fail-on-unknown-properties: false
+    parser:
+      allow-single-quotes: true
+      allow-unquoted-control-chars: true
+    serialization:
+      fail-on-empty-beans: false
+    time-zone: GMT+8
+#  redis:
+#    host: 172.16.120.165
+#    password: 123456
+#    port: 6379
+#    timeout: 10000
+  tenant:
+    enable: false
+  servlet:
+    multipart:
+      max-file-size: 10MB
+      max-request-size: 15MB

agbox-topsail/src/main/resources/mapper/topsail/AaMapper.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.usky.topsail.mapper.AaMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.usky.topsail.domain.Aa">
+        <id column="id" property="id" />
+        <result column="data" property="data" />
+        <result column="time" property="time" />
+    </resultMap>
+
+</mapper>

agbox-topsail/src/main/resources/mapper/topsail/SpOwnerMapper.xml

@@ -0,0 +1,40 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.usky.topsail.mapper.SpOwnerMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.usky.topsail.domain.SpOwner">
+        <id column="id" property="id" />
+        <result column="owner_code" property="ownerCode" />
+        <result column="owner_name" property="ownerName" />
+        <result column="unitinfo" property="unitinfo" />
+        <result column="louyu" property="louyu" />
+        <result column="sim" property="sim" />
+        <result column="maintainTime" property="maintainTime" />
+        <result column="dest_address" property="destAddress" />
+        <result column="addr1" property="addr1" />
+        <result column="addr2" property="addr2" />
+        <result column="addr3" property="addr3" />
+        <result column="address" property="address" />
+        <result column="posistion" property="posistion" />
+        <result column="install_time" property="installTime" />
+        <result column="install_man" property="installMan" />
+        <result column="dwtype" property="dwtype" />
+        <result column="owner_xh" property="ownerXh" />
+        <result column="s_interval" property="sInterval" />
+        <result column="community" property="community" />
+        <result column="company" property="company" />
+        <result column="rtmp" property="rtmp" />
+        <result column="hls" property="hls" />
+        <result column="html5" property="html5" />
+        <result column="danwei" property="danwei" />
+        <result column="owner_bl" property="ownerBl" />
+        <result column="push_param1" property="pushParam1" />
+        <result column="push_param2" property="pushParam2" />
+        <result column="push_param3" property="pushParam3" />
+        <result column="push_param4" property="pushParam4" />
+        <result column="login_param" property="loginParam" />
+        <result column="transfer_type" property="transferType" />
+    </resultMap>
+
+</mapper>

agbox-topsail/src/main/resources/mapper/topsail/SpSj2017Mapper.xml

@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.usky.topsail.mapper.SpSj2017Mapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.usky.topsail.domain.SpSj2017">
+        <id column="id" property="id" />
+        <result column="port" property="port" />
+        <result column="device_code" property="deviceCode" />
+        <result column="time" property="time" />
+        <result column="status" property="status" />
+        <result column="address" property="address" />
+        <result column="ncmd" property="ncmd" />
+        <result column="data1" property="data1" />
+        <result column="data2" property="data2" />
+        <result column="data3" property="data3" />
+        <result column="data4" property="data4" />
+        <result column="data5" property="data5" />
+        <result column="cllxr" property="cllxr" />
+        <result column="clsj" property="clsj" />
+        <result column="clr" property="clr" />
+        <result column="clnr" property="clnr" />
+        <result column="clwb" property="clwb" />
+        <result column="cldh" property="cldh" />
+        <result column="clzt" property="clzt" />
+        <result column="cllx" property="cllx" />
+        <result column="video" property="video" />
+    </resultMap>
+
+</mapper>

pom.xml

@@ -33,6 +33,8 @@
 
     <module>agbox-energy</module>
 
+    <module>agbox-topsail</module>
+
   </modules>
 
   <dependencies>