物联网实时数据查询相关接口开发

service-fire/service-fire-biz/src/main/java/com/usky/fire/controller/MybatisGeneratorUtils.java

@@ -71,7 +71,7 @@ public class MybatisGeneratorUtils {
         // strategy.setTablePrefix("t_"); // 表名前缀
         strategy.setEntityLombokModel(true); //使用lombok
         //修改自己想要生成的表
-        strategy.setInclude("base_device_attribute");  // 逆向工程使用的表   如果要生成多个,这里可以传入String[]
+        strategy.setInclude("data_rt");  // 逆向工程使用的表   如果要生成多个,这里可以传入String[]
         mpg.setStrategy(strategy);
 
         // 关闭默认 xml 生成，调整生成 至 根目录

service-fire/service-fire-biz/src/main/java/com/usky/fire/controller/web/DataRtController.java

@@ -0,0 +1,68 @@
+package com.usky.fire.controller.web;
+
+
+import com.ruoyi.common.core.utils.poi.ExcelUtil;
+import com.usky.common.core.bean.ApiResult;
+import com.usky.common.core.bean.CommonPage;
+import com.usky.fire.domain.DataRt;
+import com.usky.fire.service.DataRtService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.util.List;
+
+/**
+ * <p>
+ * 实时数据表 前端控制器
+ * </p>
+ *
+ * @author JCB
+ * @since 2022-08-24
+ */
+@RestController
+@RequestMapping("/dataRt")
+public class DataRtController {
+
+    @Autowired
+    private DataRtService dataRtService;
+
+    /**
+     * 物联网实时数据-列表查询
+     *
+     * @param deviceCode 设备编号
+     * @param systemType 系统类型(1.火灾自动报警系统 2.自动喷水灭火系统 3.消防给水及消火栓系统 4.防排烟系统 5.电气火灾系统 6.消防视频监控系统)
+     * @param pageNum    当前页
+     * @param pageSize   每页条数
+     * @return
+     */
+    @GetMapping("dataRtList")
+    public ApiResult<CommonPage<DataRt>> dataRtList(@RequestParam(value = "deviceCode", required = false) String deviceCode,
+                                                    @RequestParam(value = "systemType") Integer systemType,
+                                                    @RequestParam(value = "pageNum", required = false, defaultValue = "1") Integer pageNum,
+                                                    @RequestParam(value = "pageSize", required = false, defaultValue = "10") Integer pageSize) {
+        return ApiResult.success(dataRtService.dataRtList(deviceCode, systemType, pageNum, pageSize));
+    }
+
+    /**
+     * 物联网实时数据-导出
+     *
+     * @param response
+     * @param deviceCode  设备编号
+     * @param systemType  系统类型(1.火灾自动报警系统 2.自动喷水灭火系统 3.消防给水及消火栓系统 4.防排烟系统 5.电气火灾系统 6.消防视频监控系统)
+     * @param exportTitle 标题
+     * @throws IOException
+     */
+    @PostMapping("dataRtListExport")
+    public void export(HttpServletResponse response,
+                       @RequestParam(value = "deviceCode", required = false) String deviceCode,
+                       @RequestParam(value = "systemType") Integer systemType,
+                       @RequestParam(value = "exportTitle") String exportTitle) throws IOException {
+        List<DataRt> list = dataRtService.dataRtListOne(deviceCode, systemType);
+        ExcelUtil<DataRt> util = new ExcelUtil<DataRt>(DataRt.class);
+        util.exportExcel(response, list, exportTitle, exportTitle);
+    }
+
+}
+

service-fire/service-fire-biz/src/main/java/com/usky/fire/domain/DataRt.java

@@ -0,0 +1,91 @@
+package com.usky.fire.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 JCB
+ * @since 2022-08-24
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class DataRt implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 单位名称
+     */
+    private String companyName;
+
+    /**
+     * 单位ID
+     */
+    private String companyId;
+
+    /**
+     * 系统类型(1.火灾自动报警系统 2.自动喷水灭火系统 3.消防给水及消火栓系统 4.防排烟系统 5.电气火灾系统 6.消防视频监控系统)
+     */
+    private Integer systemType;
+
+    /**
+     * 设备名称
+     */
+    private String deviceName;
+
+    /**
+     * 设备编号
+     */
+    private String deviceCode;
+
+    /**
+     * 设备类型
+     */
+    private Integer deviceType;
+
+    /**
+     * 端口
+     */
+    private Integer ports;
+
+    /**
+     * 端口编码
+     */
+    private String portCode;
+
+    /**
+     * 端口名称
+     */
+    private String portName;
+
+    /**
+     * 采集值
+     */
+    private String portData;
+
+    /**
+     * 采集时间
+     */
+    private LocalDateTime dataTime;
+
+    /**
+     * 说明
+     */
+    private String content;
+
+
+}

service-fire/service-fire-biz/src/main/java/com/usky/fire/mapper/DataRtMapper.java

@@ -0,0 +1,16 @@
+package com.usky.fire.mapper;
+
+import com.usky.fire.domain.DataRt;
+import com.usky.common.mybatis.core.CrudMapper;
+
+/**
+ * <p>
+ * 实时数据表 Mapper 接口
+ * </p>
+ *
+ * @author JCB
+ * @since 2022-08-24
+ */
+public interface DataRtMapper extends CrudMapper<DataRt> {
+
+}

service-fire/service-fire-biz/src/main/java/com/usky/fire/service/DataRtService.java

@@ -0,0 +1,38 @@
+package com.usky.fire.service;
+
+import com.usky.common.core.bean.CommonPage;
+import com.usky.common.mybatis.core.CrudService;
+import com.usky.fire.domain.DataRt;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 实时数据表 服务类
+ * </p>
+ *
+ * @author JCB
+ * @since 2022-08-24
+ */
+public interface DataRtService extends CrudService<DataRt> {
+
+    /**
+     * 物联网实时数据-列表查询
+     *
+     * @param deviceCode 设备编号
+     * @param systemType 系统类型(1.火灾自动报警系统 2.自动喷水灭火系统 3.消防给水及消火栓系统 4.防排烟系统 5.电气火灾系统 6.消防视频监控系统)
+     * @param pageNum    当前页
+     * @param pageSize   每页条数
+     * @return
+     */
+    CommonPage<DataRt> dataRtList(String deviceCode, Integer systemType, Integer pageNum, Integer pageSize);
+
+    /**
+     * 物联网实时数据-导出数据查询
+     *
+     * @param deviceCode
+     * @param systemType
+     * @return
+     */
+    List<DataRt> dataRtListOne(String deviceCode, Integer systemType);
+}

service-fire/service-fire-biz/src/main/java/com/usky/fire/service/impl/DataRtServiceImpl.java

@@ -0,0 +1,63 @@
+package com.usky.fire.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.usky.common.core.bean.CommonPage;
+import com.usky.common.core.util.StringUtils;
+import com.usky.common.mybatis.core.AbstractCrudService;
+import com.usky.fire.domain.DataRt;
+import com.usky.fire.mapper.DataRtMapper;
+import com.usky.fire.service.BaseUserCompanyService;
+import com.usky.fire.service.DataRtService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * <p>
+ * 实时数据表 服务实现类
+ * </p>
+ *
+ * @author JCB
+ * @since 2022-08-24
+ */
+@Service
+public class DataRtServiceImpl extends AbstractCrudService<DataRtMapper, DataRt> implements DataRtService {
+
+    @Autowired
+    private BaseUserCompanyService baseUserCompanyService;
+
+    @Override
+    public CommonPage<DataRt> dataRtList(String deviceCode, Integer systemType, Integer pageNum, Integer pageSize) {
+        List<String> companyIdList = baseUserCompanyService.companyIdList();
+        IPage<DataRt> page = new Page<>(pageNum, pageSize);
+        if (CollectionUtils.isNotEmpty(companyIdList)) {
+            LambdaQueryWrapper<DataRt> queryWrapper = Wrappers.lambdaQuery();
+            queryWrapper.like(StringUtils.isNotBlank(deviceCode), DataRt::getDeviceCode, deviceCode)
+                    .eq(DataRt::getSystemType, systemType)
+                    .in(DataRt::getCompanyId, companyIdList);
+            page = this.page(page, queryWrapper);
+        }
+        return new CommonPage<>(page.getRecords(), page.getTotal(), pageSize, pageNum);
+    }
+
+    @Override
+    public List<DataRt> dataRtListOne(String deviceCode, Integer systemType) {
+        List<String> companyIdList = baseUserCompanyService.companyIdList();
+        List<DataRt> list = new ArrayList<>();
+        if (CollectionUtils.isNotEmpty(companyIdList)) {
+            LambdaQueryWrapper<DataRt> queryWrapper = Wrappers.lambdaQuery();
+            queryWrapper.like(StringUtils.isNotBlank(deviceCode), DataRt::getDeviceCode, deviceCode)
+                    .eq(DataRt::getSystemType, systemType)
+                    .in(DataRt::getCompanyId, companyIdList);
+            list = this.list(queryWrapper);
+        }
+        return list;
+    }
+
+}

service-fire/service-fire-biz/src/main/resources/mapper/fire/DataRtMapper.xml

@@ -0,0 +1,22 @@
+<?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.fire.mapper.DataRtMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.usky.fire.domain.DataRt">
+        <id column="id" property="id" />
+        <result column="company_name" property="companyName" />
+        <result column="company_id" property="companyId" />
+        <result column="system_type" property="systemType" />
+        <result column="device_name" property="deviceName" />
+        <result column="device_code" property="deviceCode" />
+        <result column="device_type" property="deviceType" />
+        <result column="ports" property="ports" />
+        <result column="port_code" property="portCode" />
+        <result column="port_name" property="portName" />
+        <result column="port_data" property="portData" />
+        <result column="data_time" property="dataTime" />
+        <result column="content" property="content" />
+    </resultMap>
+
+</mapper>