看板相关接口开发

fiveep-controller/src/main/java/com/bizmatics/controller/web/BulletinContentListController.java

@@ -0,0 +1,41 @@
+package com.bizmatics.controller.web;
+
+
+import com.bizmatics.common.core.bean.ApiResult;
+import com.bizmatics.model.BulletinContentList;
+import com.bizmatics.service.BulletinContentListService;
+import com.bizmatics.service.vo.DeviceCountVO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * 内容清单
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+@RestController
+@RequestMapping("/bulletinContentList")
+public class BulletinContentListController {
+
+    @Autowired
+    private BulletinContentListService bulletinContentListService;
+
+    /**
+     * 内容清单列表查询
+     * @return
+     */
+    @GetMapping("/getBulletinContentList")
+    public ApiResult<List<BulletinContentList>> getBulletinContentList() {
+        return ApiResult.success(bulletinContentListService.getBulletinContentList());
+    }
+
+}
+

fiveep-controller/src/main/java/com/bizmatics/controller/web/BulletinCruxConfigController.java

@@ -0,0 +1,63 @@
+package com.bizmatics.controller.web;
+
+
+import com.bizmatics.common.core.bean.ApiResult;
+import com.bizmatics.model.BulletinCruxConfig;
+import com.bizmatics.service.BulletinCruxConfigService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * 数据看板-数据配置1
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+@RestController
+@RequestMapping("/bulletinCruxConfig")
+public class BulletinCruxConfigController {
+    @Autowired
+    private BulletinCruxConfigService bulletinCruxConfigService;
+
+    /**
+     * 数据看板-数据配置查询1
+     *
+     * @param siteId 站点ID
+     * @param id     配置ID
+     * @return
+     */
+    @GetMapping("/getBulletinCruxConfigList")
+    public ApiResult<List<Object>> getBulletinCruxConfigList(@RequestParam(value = "siteId") Integer siteId,
+                                                             @RequestParam(value = "id", required = false, defaultValue = "0") Integer id) {
+        return ApiResult.success(bulletinCruxConfigService.getBulletinCruxConfigList(siteId, id));
+    }
+
+
+    /**
+     * 数据看板-数据配置1编辑
+     *
+     * @param bulletinCruxConfig
+     * @return
+     */
+    @PostMapping("editBulletinCruxConfig")
+    public ApiResult<Void> editBulletinCruxConfig(@RequestBody BulletinCruxConfig bulletinCruxConfig) {
+        bulletinCruxConfigService.editBulletinCruxConfig(bulletinCruxConfig);
+        return ApiResult.success();
+    }
+
+    /**
+     * 数据看板-数据配置1删除
+     *
+     * @param id 配置ID
+     * @return
+     */
+    @GetMapping("/delBulletinCruxConfig")
+    public ApiResult<Void> delBulletinCruxConfig(@RequestParam(value = "id") Integer id) {
+        bulletinCruxConfigService.delBulletinCruxConfig(id);
+        return ApiResult.success();
+    }
+
+}
+

fiveep-controller/src/main/java/com/bizmatics/controller/web/BulletinHistoricalConfigController.java

@@ -0,0 +1,21 @@
+package com.bizmatics.controller.web;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.stereotype.Controller;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-06
+ */
+@Controller
+@RequestMapping("/bulletinHistoricalConfig")
+public class BulletinHistoricalConfigController {
+
+}
+

fiveep-controller/src/main/java/com/bizmatics/controller/web/BulletinHistoricalRelationController.java

@@ -0,0 +1,21 @@
+package com.bizmatics.controller.web;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.stereotype.Controller;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-06
+ */
+@Controller
+@RequestMapping("/bulletinHistoricalRelation")
+public class BulletinHistoricalRelationController {
+
+}
+

fiveep-controller/src/main/java/com/bizmatics/controller/web/BulletinStatusConfigController.java

@@ -0,0 +1,21 @@
+package com.bizmatics.controller.web;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.stereotype.Controller;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+@Controller
+@RequestMapping("/bulletinStatusConfig")
+public class BulletinStatusConfigController {
+
+}
+

fiveep-controller/src/main/java/com/bizmatics/controller/web/MybatisGeneratorUtils.java

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

fiveep-model/src/main/java/com/bizmatics/model/BulletinContentList.java

@@ -0,0 +1,47 @@
+package com.bizmatics.model;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class BulletinContentList implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * 内容清单ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 清单图片路径
+     */
+    private String picturePath;
+
+    /**
+     * 清单标题
+     */
+    private String listTitle;
+
+    /**
+     * 清单内容
+     */
+    private String listContent;
+
+
+}

fiveep-model/src/main/java/com/bizmatics/model/BulletinCruxConfig.java

@@ -0,0 +1,111 @@
+package com.bizmatics.model;
+
+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;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class BulletinCruxConfig implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * 关键数据配置表ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 数据名称
+     */
+    private String dataName;
+
+    /**
+     * 数据类型
+     */
+    private Integer dataType;
+
+    /**
+     * 数据取值
+     */
+    private Integer dataValue;
+
+    /**
+     * 背景颜色
+     */
+    private String backgroundColor;
+
+    /**
+     * 数据名称颜色
+     */
+    private String dataNameColor;
+
+    /**
+     * 数据值颜色
+     */
+    private String dataValueColor;
+
+    /**
+     * 数据名称字体大小
+     */
+    private String dataNameFont;
+
+    /**
+     * 数据值字体大小
+     */
+    private String dataValueFont;
+
+    /**
+     * 图标路径
+     */
+    private String iconPath;
+
+    /**
+     * 创建人
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+
+    /**
+     * 站点id
+     */
+    private Integer siteId;
+
+    /**
+     * 变量ID
+     */
+    private Integer variableId;
+
+    /**
+     * 计算周期：1本日 2本月 3本年 4实时值
+     */
+    private Integer cycle;
+
+    /**
+     * 计算方法：1平均 2最大 3最小
+     */
+    private Integer method;
+
+    /**
+     * 保留小数
+     */
+    private Integer digit;
+}

fiveep-model/src/main/java/com/bizmatics/model/BulletinHistoricalConfig.java

@@ -0,0 +1,108 @@
+package com.bizmatics.model;
+
+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;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-06
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class BulletinHistoricalConfig implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * 关键数据配置表ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 数据标题
+     */
+    private String dataTitle;
+
+    /**
+     * 图标路径
+     */
+    private String iconPath;
+
+    /**
+     * 查询周期
+     */
+    private Integer queryCycle;
+
+    /**
+     * 查询类型
+     */
+    private Integer queryType;
+
+    /**
+     * 最大值是否标注
+     */
+    private Integer maxDimension;
+
+    /**
+     * 最小值是否标注
+     */
+    private Integer minDimension;
+
+    /**
+     * 平均值是否标注
+     */
+    private Integer meanDimension;
+
+    /**
+     * 纵轴自适应
+     */
+    private Integer lonAdaptation;
+
+    /**
+     * 创建人
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+
+    /**
+     * 站点id
+     */
+    private Integer siteId;
+
+    /**
+     * X轴坐标
+     */
+    private Integer xAxis;
+
+    /**
+     * Y轴坐标
+     */
+    private Integer yAxis;
+
+    /**
+     * 宽
+     */
+    private Integer wide;
+
+    /**
+     * 高
+     */
+    private Integer high;
+
+
+}

fiveep-model/src/main/java/com/bizmatics/model/BulletinHistoricalRelation.java

@@ -0,0 +1,62 @@
+package com.bizmatics.model;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-06
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class BulletinHistoricalRelation implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * 历史数据关联表ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 历史数据模块id
+     */
+    private Integer historicalId;
+
+    /**
+     * 监控设备id
+     */
+    private Integer deviceId;
+
+    /**
+     * 变量id
+     */
+    private Integer variableId;
+
+    /**
+     * 统计图颜色
+     */
+    private String graphicColor;
+
+    /**
+     * 1折线图 2柱形图
+     */
+    private Integer graphicType;
+
+    /**
+     * 显示名称
+     */
+    private String displayName;
+
+
+}

fiveep-model/src/main/java/com/bizmatics/model/BulletinStatusConfig.java

@@ -0,0 +1,53 @@
+package com.bizmatics.model;
+
+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;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class BulletinStatusConfig implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * 关键数据配置表ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 数据标题
+     */
+    private String dataTitle;
+
+    /**
+     * 创建人
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+
+    /**
+     * 站点id
+     */
+    private Integer siteId;
+
+
+}

fiveep-model/src/main/java/com/bizmatics/model/vo/BulletinCruxConfigVo.java

@@ -0,0 +1,117 @@
+package com.bizmatics.model.vo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class BulletinCruxConfigVo implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * 关键数据配置表ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 数据名称
+     */
+    private String dataName;
+
+    /**
+     * 数据类型
+     */
+    private Integer dataType;
+
+    /**
+     * 数据取值
+     */
+    private Integer dataValue;
+
+    /**
+     * 背景颜色
+     */
+    private String backgroundColor;
+
+    /**
+     * 数据名称颜色
+     */
+    private String dataNameColor;
+
+    /**
+     * 数据值颜色
+     */
+    private String dataValueColor;
+
+    /**
+     * 数据名称字体大小
+     */
+    private String dataNameFont;
+
+    /**
+     * 数据值字体大小
+     */
+    private String dataValueFont;
+
+    /**
+     * 图标路径
+     */
+    private String iconPath;
+
+    /**
+     * 创建人
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+
+    /**
+     * 站点id
+     */
+    private Integer siteId;
+
+    /**
+     * 变量ID
+     */
+    private Integer variableId;
+
+    /**
+     * 计算周期：1本日 2本月 3本年 4实时值
+     */
+    private Integer cycle;
+
+    /**
+     * 计算方法：1平均 2最大 3最小
+     */
+    private Integer method;
+
+    /**
+     * 保留小数
+     */
+    private Integer digit;
+
+
+    private String textValue;
+
+    private String idx;
+}

fiveep-persistence/src/main/java/com/bizmatics/persistence/mapper/BulletinContentListMapper.java

@@ -0,0 +1,16 @@
+package com.bizmatics.persistence.mapper;
+
+import com.bizmatics.model.BulletinContentList;
+import com.bizmatics.common.mvc.base.CrudMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+public interface BulletinContentListMapper extends CrudMapper<BulletinContentList> {
+
+}

fiveep-persistence/src/main/java/com/bizmatics/persistence/mapper/BulletinCruxConfigMapper.java

@@ -0,0 +1,27 @@
+package com.bizmatics.persistence.mapper;
+
+import com.bizmatics.model.BulletinCruxConfig;
+import com.bizmatics.common.mvc.base.CrudMapper;
+import com.bizmatics.model.vo.RtData;
+import com.bizmatics.model.vo.SiteData;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+public interface BulletinCruxConfigMapper extends CrudMapper<BulletinCruxConfig> {
+    int delBulletinCruxConfig(Integer id);
+
+    List<SiteData> getSiteData(Integer siteId);
+
+    List<RtData> getTextData(String table,String fieldData,String deviceCode, String startTime, String endTime);
+
+    Integer getAlarmCount(@Param("siteId") Integer siteId);
+}

fiveep-persistence/src/main/java/com/bizmatics/persistence/mapper/BulletinHistoricalConfigMapper.java

@@ -0,0 +1,16 @@
+package com.bizmatics.persistence.mapper;
+
+import com.bizmatics.model.BulletinHistoricalConfig;
+import com.bizmatics.common.mvc.base.CrudMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-06
+ */
+public interface BulletinHistoricalConfigMapper extends CrudMapper<BulletinHistoricalConfig> {
+
+}

fiveep-persistence/src/main/java/com/bizmatics/persistence/mapper/BulletinHistoricalRelationMapper.java

@@ -0,0 +1,16 @@
+package com.bizmatics.persistence.mapper;
+
+import com.bizmatics.model.BulletinHistoricalRelation;
+import com.bizmatics.common.mvc.base.CrudMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-06
+ */
+public interface BulletinHistoricalRelationMapper extends CrudMapper<BulletinHistoricalRelation> {
+
+}

fiveep-persistence/src/main/java/com/bizmatics/persistence/mapper/BulletinStatusConfigMapper.java

@@ -0,0 +1,16 @@
+package com.bizmatics.persistence.mapper;
+
+import com.bizmatics.model.BulletinStatusConfig;
+import com.bizmatics.common.mvc.base.CrudMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+public interface BulletinStatusConfigMapper extends CrudMapper<BulletinStatusConfig> {
+
+}

fiveep-persistence/src/main/resources/mapper/mysql/BulletinContentListMapper.xml

@@ -0,0 +1,13 @@
+<?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.bizmatics.persistence.mapper.BulletinContentListMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.bizmatics.model.BulletinContentList">
+        <id column="id" property="id" />
+        <result column="picture_path" property="picturePath" />
+        <result column="list_title" property="listTitle" />
+        <result column="list_content" property="listContent" />
+    </resultMap>
+
+</mapper>

fiveep-persistence/src/main/resources/mapper/mysql/BulletinCruxConfigMapper.xml

@@ -0,0 +1,64 @@
+<?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.bizmatics.persistence.mapper.BulletinCruxConfigMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.bizmatics.model.BulletinCruxConfig">
+        <id column="id" property="id" />
+        <result column="data_name" property="dataName" />
+        <result column="data_type" property="dataType" />
+        <result column="data_value" property="dataValue" />
+        <result column="background_color" property="backgroundColor" />
+        <result column="data_name_color" property="dataNameColor" />
+        <result column="data_value_color" property="dataValueColor" />
+        <result column="data_name_font" property="dataNameFont" />
+        <result column="data_value_font" property="dataValueFont" />
+        <result column="icon_path" property="iconPath" />
+        <result column="create_by" property="createBy" />
+        <result column="create_time" property="createTime" />
+        <result column="site_id" property="siteId" />
+        <result column="variable_id" property="variableId" />
+        <result column="cycle" property="cycle" />
+        <result column="method" property="method" />
+        <result column="digit" property="digit" />
+    </resultMap>
+
+    <delete id="delBulletinCruxConfig" parameterType="Long">
+        delete from bulletin_crux_config where id=#{id}
+    </delete>
+
+    <select id="getSiteData" resultType="com.bizmatics.model.vo.SiteData">
+        select s.id,s.site_name,s.site_address,s.phone,s.spare_phone,s.installed_capacity,sdp.power_supply_type,sdp.voltage_level,sdp.operation_time,s.create_time
+        from site as s
+        left join site_dynamic_properties as sdp
+        on s.id = sdp.site_id
+        <where>
+            and s.id=#{siteId}
+        </where>
+    </select>
+
+    <select id="getTextData" resultType="com.bizmatics.model.vo.RtData">
+        select ${fieldData}
+        from ${table}
+        <where>
+            and deviceName=#{deviceCode}
+            <if test="endTime != null and startTime != null and endTime != '' and startTime != ''">
+                and dataTime BETWEEN #{startTime} and #{endTime}
+            </if>
+        </where>
+    </select>
+
+
+    <select id="getAlarmCount" resultType="java.lang.Integer">
+        SELECT
+        count(1)
+        FROM
+        device AS a
+        JOIN alarm_power AS b ON a.device_code = b.device_code
+        <where>
+            a. ENABLE = 1
+            AND a.site_id = #{siteId}
+        </where>
+    </select>
+
+</mapper>

fiveep-persistence/src/main/resources/mapper/mysql/BulletinHistoricalConfigMapper.xml

@@ -0,0 +1,25 @@
+<?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.bizmatics.persistence.mapper.BulletinHistoricalConfigMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.bizmatics.model.BulletinHistoricalConfig">
+        <id column="id" property="id" />
+        <result column="data_title" property="dataTitle" />
+        <result column="icon_path" property="iconPath" />
+        <result column="query_cycle" property="queryCycle" />
+        <result column="query_type" property="queryType" />
+        <result column="max_dimension" property="maxDimension" />
+        <result column="min_dimension" property="minDimension" />
+        <result column="mean_dimension" property="meanDimension" />
+        <result column="lon_adaptation" property="lonAdaptation" />
+        <result column="create_by" property="createBy" />
+        <result column="create_time" property="createTime" />
+        <result column="site_id" property="siteId" />
+        <result column="x_axis" property="xAxis" />
+        <result column="y_axis" property="yAxis" />
+        <result column="wide" property="wide" />
+        <result column="high" property="high" />
+    </resultMap>
+
+</mapper>

fiveep-persistence/src/main/resources/mapper/mysql/BulletinHistoricalRelationMapper.xml

@@ -0,0 +1,16 @@
+<?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.bizmatics.persistence.mapper.BulletinHistoricalRelationMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.bizmatics.model.BulletinHistoricalRelation">
+        <id column="id" property="id" />
+        <result column="historical_id" property="historicalId" />
+        <result column="device_id" property="deviceId" />
+        <result column="variable_id" property="variableId" />
+        <result column="graphic_color" property="graphicColor" />
+        <result column="graphic_type" property="graphicType" />
+        <result column="display_name" property="displayName" />
+    </resultMap>
+
+</mapper>

fiveep-persistence/src/main/resources/mapper/mysql/BulletinStatusConfigMapper.xml

@@ -0,0 +1,14 @@
+<?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.bizmatics.persistence.mapper.BulletinStatusConfigMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.bizmatics.model.BulletinStatusConfig">
+        <id column="id" property="id" />
+        <result column="data_title" property="dataTitle" />
+        <result column="create_by" property="createBy" />
+        <result column="create_time" property="createTime" />
+        <result column="site_id" property="siteId" />
+    </resultMap>
+
+</mapper>

fiveep-service/src/main/java/com/bizmatics/service/BulletinContentListService.java

@@ -0,0 +1,20 @@
+package com.bizmatics.service;
+
+import com.bizmatics.common.mvc.base.CrudService;
+import com.bizmatics.model.BulletinContentList;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 服务类
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+public interface BulletinContentListService extends CrudService<BulletinContentList> {
+
+    List<BulletinContentList> getBulletinContentList();
+
+}

fiveep-service/src/main/java/com/bizmatics/service/BulletinCruxConfigService.java

@@ -0,0 +1,24 @@
+package com.bizmatics.service;
+
+import com.bizmatics.model.BulletinCruxConfig;
+import com.bizmatics.common.mvc.base.CrudService;
+import com.bizmatics.model.vo.BulletinCruxConfigVo;
+
+import java.util.List;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+public interface BulletinCruxConfigService extends CrudService<BulletinCruxConfig> {
+
+    List<Object> getBulletinCruxConfigList(Integer siteId, Integer id);
+
+    void editBulletinCruxConfig(BulletinCruxConfig bulletinCruxConfig);
+
+    void delBulletinCruxConfig(Integer id);
+}

fiveep-service/src/main/java/com/bizmatics/service/BulletinHistoricalConfigService.java

@@ -0,0 +1,16 @@
+package com.bizmatics.service;
+
+import com.bizmatics.model.BulletinHistoricalConfig;
+import com.bizmatics.common.mvc.base.CrudService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-06
+ */
+public interface BulletinHistoricalConfigService extends CrudService<BulletinHistoricalConfig> {
+
+}

fiveep-service/src/main/java/com/bizmatics/service/BulletinHistoricalRelationService.java

@@ -0,0 +1,16 @@
+package com.bizmatics.service;
+
+import com.bizmatics.model.BulletinHistoricalRelation;
+import com.bizmatics.common.mvc.base.CrudService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-06
+ */
+public interface BulletinHistoricalRelationService extends CrudService<BulletinHistoricalRelation> {
+
+}

fiveep-service/src/main/java/com/bizmatics/service/BulletinStatusConfigService.java

@@ -0,0 +1,16 @@
+package com.bizmatics.service;
+
+import com.bizmatics.model.BulletinStatusConfig;
+import com.bizmatics.common.mvc.base.CrudService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+public interface BulletinStatusConfigService extends CrudService<BulletinStatusConfig> {
+
+}

fiveep-service/src/main/java/com/bizmatics/service/impl/BulletinContentListServiceImpl.java

@@ -0,0 +1,36 @@
+package com.bizmatics.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.bizmatics.model.BulletinContentList;
+import com.bizmatics.model.DeviceAnalogVariableList;
+import com.bizmatics.model.DeviceAttribute;
+import com.bizmatics.model.vo.DeviceOneVo;
+import com.bizmatics.persistence.mapper.BulletinContentListMapper;
+import com.bizmatics.service.BulletinContentListService;
+import com.bizmatics.common.mvc.base.AbstractCrudService;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+@Service
+public class BulletinContentListServiceImpl extends AbstractCrudService<BulletinContentListMapper, BulletinContentList> implements BulletinContentListService {
+    /**
+     * 内容清单列表查询
+     * @return
+     */
+    public List<BulletinContentList> getBulletinContentList() {
+        LambdaQueryWrapper<BulletinContentList> queryWrapper = Wrappers.lambdaQuery();
+        List<BulletinContentList> bulletinContentList = this.list(queryWrapper);
+        return bulletinContentList;
+    }
+}

fiveep-service/src/main/java/com/bizmatics/service/impl/BulletinCruxConfigServiceImpl.java

@@ -0,0 +1,242 @@
+package com.bizmatics.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.bizmatics.common.core.exception.BusinessException;
+import com.bizmatics.common.mvc.base.AbstractCrudService;
+import com.bizmatics.model.BulletinCruxConfig;
+import com.bizmatics.model.Device;
+import com.bizmatics.model.DeviceAnalogVariableList;
+import com.bizmatics.model.DeviceStatus;
+import com.bizmatics.model.system.SysUser;
+import com.bizmatics.model.vo.BulletinCruxConfigVo;
+import com.bizmatics.model.vo.RtData;
+import com.bizmatics.model.vo.SiteData;
+import com.bizmatics.persistence.mapper.BulletinCruxConfigMapper;
+import com.bizmatics.service.BulletinCruxConfigService;
+import com.bizmatics.service.DeviceAnalogVariableListService;
+import com.bizmatics.service.DeviceService;
+import com.bizmatics.service.DeviceStatusService;
+import com.bizmatics.service.util.SecurityUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.util.*;
+
+/**
+ * 数据看板
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+@Service
+public class BulletinCruxConfigServiceImpl extends AbstractCrudService<BulletinCruxConfigMapper, BulletinCruxConfig> implements BulletinCruxConfigService {
+
+    @Autowired
+    private DeviceAnalogVariableListService deviceAnalogVariableListService;
+
+    @Autowired
+    private DeviceService deviceService;
+    @Autowired
+    private DeviceStatusService deviceStatusService;
+
+    /**
+     * 数据看板-数据配置查询1
+     *
+     * @param siteId 站点ID
+     * @param id     配置ID
+     * @return
+     */
+    public List<Object> getBulletinCruxConfigList(Integer siteId, Integer id) {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        SimpleDateFormat sdfa = new SimpleDateFormat("yyyy");
+        //配置数据查询1
+        LambdaQueryWrapper<BulletinCruxConfig> queryWrapper = Wrappers.lambdaQuery();
+        queryWrapper.eq(BulletinCruxConfig::getSiteId, siteId);
+        if (id != 0) {
+            queryWrapper.eq(BulletinCruxConfig::getId, id);
+        }
+        List<BulletinCruxConfig> list = this.list(queryWrapper);
+//        List<BulletinCruxConfigVo> list1 = new ArrayList<>();
+        List<Object> list2 = new ArrayList<>();
+        if (list.size() > 0) {
+            for (int i = 0; i < list.size(); i++) {
+                BulletinCruxConfigVo bulletinCruxConfigVo = new BulletinCruxConfigVo();
+                bulletinCruxConfigVo.setId(list.get(i).getId());
+                bulletinCruxConfigVo.setDataName(list.get(i).getDataName());
+                bulletinCruxConfigVo.setDataType(list.get(i).getDataType());
+                bulletinCruxConfigVo.setDataValue(list.get(i).getDataValue());
+                bulletinCruxConfigVo.setBackgroundColor(list.get(i).getBackgroundColor());
+                bulletinCruxConfigVo.setDataNameColor(list.get(i).getDataNameColor());
+                bulletinCruxConfigVo.setDataValueColor(list.get(i).getDataValueColor());
+                bulletinCruxConfigVo.setDataNameFont(list.get(i).getDataNameFont());
+                bulletinCruxConfigVo.setDataValueFont(list.get(i).getDataValueFont());
+                bulletinCruxConfigVo.setIconPath(list.get(i).getIconPath());
+                bulletinCruxConfigVo.setCreateBy(list.get(i).getCreateBy());
+                bulletinCruxConfigVo.setCreateTime(list.get(i).getCreateTime());
+                bulletinCruxConfigVo.setSiteId(list.get(i).getSiteId());
+                bulletinCruxConfigVo.setIdx(""+(list2.size()+1));
+                if (list.get(i).getDataType() == 1) {//普通文本
+
+                } else if (list.get(i).getDataType() == 2) {//站点管理信息
+                    List<SiteData> site = baseMapper.getSiteData(list.get(i).getSiteId());
+                    //1名称 2地址 3联系电话 4额定容量 5供电类型 6电压等级 7投运时间 8运行天数
+                    if (list.get(i).getDataValue() == 1) {
+                        bulletinCruxConfigVo.setTextValue(site.get(0).getSiteName());
+                    } else if (list.get(i).getDataValue() == 2) {
+                        bulletinCruxConfigVo.setTextValue(site.get(0).getSiteAddress());
+                    } else if (list.get(i).getDataValue() == 3) {
+                        bulletinCruxConfigVo.setTextValue(site.get(0).getPhone());
+                    } else if (list.get(i).getDataValue() == 4) {
+                        bulletinCruxConfigVo.setTextValue(site.get(0).getInstalledCapacity());
+                    } else if (list.get(i).getDataValue() == 5) {
+                        if (site.get(0).getPowerSupplyType() == 1) {
+                            bulletinCruxConfigVo.setTextValue("单路");
+                        } else if (site.get(0).getPowerSupplyType() == 2) {
+                            bulletinCruxConfigVo.setTextValue("双路");
+                        }
+                    } else if (list.get(i).getDataValue() == 6) {
+                        bulletinCruxConfigVo.setTextValue(site.get(0).getVoltageLevel());
+                    } else if (list.get(i).getDataValue() == 7) {
+                        bulletinCruxConfigVo.setTextValue("" + site.get(0).getOperationTime());
+                    } else if (list.get(i).getDataValue() == 8) {
+                        int time = daysBetween(site.get(0).getCreateTime(), new Date());
+                        bulletinCruxConfigVo.setTextValue("" + time);
+                    }
+                } else if (list.get(i).getDataType() == 3) {//智能设备数据
+                    LambdaQueryWrapper<DeviceAnalogVariableList> queryWrapper1 = Wrappers.lambdaQuery();
+                    queryWrapper1.eq(DeviceAnalogVariableList::getId, list.get(i).getVariableId());
+                    List<DeviceAnalogVariableList> deviceAttributelist = deviceAnalogVariableListService.list(queryWrapper1);
+                    String[] deviceAttribute = deviceAttributelist.get(0).getVariableCoding().split("_");
+                    String deviceCode = deviceAttribute[0];
+                    String field = deviceAttribute[1];
+                    String fieldData = null;
+                    if (list.get(i).getMethod() == 1) {//平均
+                        fieldData = " avg(" + field + ") as textValue ";
+                    } else if (list.get(i).getMethod() == 2) {//最大
+                        fieldData = " max(" + field + ") as textValue ";
+                    } else if (list.get(i).getMethod() == 3) {//最小
+                        fieldData = " min(" + field + ") as textValue ";
+                    }
+                    LambdaQueryWrapper<Device> queryWrapper2 = Wrappers.lambdaQuery();
+                    queryWrapper2.eq(Device::getDeviceCode, deviceCode);
+                    List<Device> Devicelist = deviceService.list(queryWrapper2);
+                    String table = "ht_analog_data";
+                    String table1 = "rt_analog_data";
+                    if (Devicelist.get(0).getDeviceType().equals("1")) {
+                        table = "ht_analog_data";
+                        table1 = "rt_analog_data";
+                    } else if (Devicelist.get(0).getDeviceType().equals("3")) {
+                        table = "ht_analog_171_data";
+                        table1 = "rt_analog_171_data";
+                    } else if (Devicelist.get(0).getDeviceType().equals("4")) {
+                        table = "ht_analog_173_data";
+                        table1 = "rt_analog_173_data";
+                    }
+                    String startHms = "00:00:00";
+                    String endHms = "23:59:59";
+                    if (list.get(i).getCycle() == 1) {//本日
+                        String time = sdf.format(new Date());
+                        String startTime = time + " " + startHms;
+                        String endTime = time + " " + endHms;
+                        List<RtData> rtData = baseMapper.getTextData(table, fieldData, deviceCode, startTime, endTime);
+                        bulletinCruxConfigVo.setTextValue(rtData.get(0).getTextValue());
+                    } else if (list.get(i).getCycle() == 2) {//本月
+                        Calendar calendar = new GregorianCalendar();
+                        calendar.setTime(new Date());
+                        //获得本月第一天
+                        calendar.add(Calendar.MONTH, 0);
+                        calendar.set(Calendar.DAY_OF_MONTH, 1);
+                        String startTime = sdf.format(calendar.getTime()) + " " + startHms;
+                        //获得本月最后一天
+                        calendar.set(Calendar.DAY_OF_MONTH, calendar.getActualMaximum(Calendar.DAY_OF_MONTH));
+                        String endTime = sdf.format(calendar.getTime()) + " " + endHms;
+                        List<RtData> rtData = baseMapper.getTextData(table, fieldData, deviceCode, startTime, endTime);
+                        bulletinCruxConfigVo.setTextValue(rtData.get(0).getTextValue());
+                    } else if (list.get(i).getCycle() == 3) {//本年
+                        String time = sdfa.format(new Date());
+                        String startTime = time + "-01-01 00:00:00";
+                        String endTime = time + "-12-31 23:59:59";
+                        List<RtData> rtData = baseMapper.getTextData(table, fieldData, deviceCode, startTime, endTime);
+                        bulletinCruxConfigVo.setTextValue(rtData.get(0).getTextValue());
+                    } else if (list.get(i).getCycle() == 3) {//实时值
+                        List<RtData> rtData = baseMapper.getTextData(table1, field + " as textValue ", deviceCode, null, null);
+                        bulletinCruxConfigVo.setTextValue(rtData.get(0).getTextValue());
+                    }
+                } else if (list.get(i).getDataType() == 4) {//站点告警状态
+                    Integer alarCount = baseMapper.getAlarmCount(siteId);
+                    bulletinCruxConfigVo.setTextValue("无告警");
+                    if (alarCount>0){
+                        bulletinCruxConfigVo.setTextValue("告警");
+                    }
+                } else if (list.get(i).getDataType() == 5) {//站点通信状态
+                    LambdaQueryWrapper<DeviceStatus> queryWrapper1 = Wrappers.lambdaQuery();
+                    queryWrapper1.eq(DeviceStatus::getSiteId, siteId);
+                    List<DeviceStatus> deviceStatusList = deviceStatusService.list(queryWrapper1);
+                    if (deviceStatusList.size()>0){
+                        for (int j = 0; j < deviceStatusList.size(); j++) {
+                            bulletinCruxConfigVo.setTextValue("在线");
+                            if (deviceStatusList.get(j).getDeviceStatus()==1){
+                                bulletinCruxConfigVo.setTextValue("离线");
+                            }
+                        }
+                    }else {
+                        bulletinCruxConfigVo.setTextValue("离线");
+                    }
+                }
+                list2.add(bulletinCruxConfigVo);
+            }
+        }
+
+        //配置数据查询1
+
+
+
+        return list2;
+    }
+
+
+    public int daysBetween(Date smdate, Date bdate) {
+        try {
+            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+            smdate = sdf.parse(sdf.format(smdate));
+            bdate = sdf.parse(sdf.format(bdate));
+            Calendar cal = Calendar.getInstance();
+            cal.setTime(smdate);
+            long time1 = cal.getTimeInMillis();
+            cal.setTime(bdate);
+            long time2 = cal.getTimeInMillis();
+            long between_days = (time2 - time1) / (1000 * 3600 * 24);
+            return Integer.parseInt(String.valueOf(between_days));
+        } catch (Exception e) {
+            throw new BusinessException("时间计算错误");
+        }
+    }
+
+    /**
+     * 数据看板-数据配置1编辑
+     *
+     * @param bulletinCruxConfig
+     */
+    public void editBulletinCruxConfig(BulletinCruxConfig bulletinCruxConfig) {
+        if (bulletinCruxConfig.getId() == 0) {
+            this.updateById(bulletinCruxConfig);
+        } else {
+            SysUser user = SecurityUtils.getLoginUser().getUser();
+            bulletinCruxConfig.setCreateTime(LocalDateTime.now());
+            bulletinCruxConfig.setCreateBy(user.getUserName());
+            this.save(bulletinCruxConfig);
+        }
+    }
+
+    /**
+     * 数据看板-数据配置1删除
+     *
+     * @param id
+     */
+    public void delBulletinCruxConfig(Integer id) {
+        baseMapper.delBulletinCruxConfig(id);
+    }
+}

fiveep-service/src/main/java/com/bizmatics/service/impl/BulletinHistoricalConfigServiceImpl.java

@@ -0,0 +1,20 @@
+package com.bizmatics.service.impl;
+
+import com.bizmatics.model.BulletinHistoricalConfig;
+import com.bizmatics.persistence.mapper.BulletinHistoricalConfigMapper;
+import com.bizmatics.service.BulletinHistoricalConfigService;
+import com.bizmatics.common.mvc.base.AbstractCrudService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-06
+ */
+@Service
+public class BulletinHistoricalConfigServiceImpl extends AbstractCrudService<BulletinHistoricalConfigMapper, BulletinHistoricalConfig> implements BulletinHistoricalConfigService {
+
+}

fiveep-service/src/main/java/com/bizmatics/service/impl/BulletinHistoricalRelationServiceImpl.java

@@ -0,0 +1,20 @@
+package com.bizmatics.service.impl;
+
+import com.bizmatics.model.BulletinHistoricalRelation;
+import com.bizmatics.persistence.mapper.BulletinHistoricalRelationMapper;
+import com.bizmatics.service.BulletinHistoricalRelationService;
+import com.bizmatics.common.mvc.base.AbstractCrudService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-06
+ */
+@Service
+public class BulletinHistoricalRelationServiceImpl extends AbstractCrudService<BulletinHistoricalRelationMapper, BulletinHistoricalRelation> implements BulletinHistoricalRelationService {
+
+}

fiveep-service/src/main/java/com/bizmatics/service/impl/BulletinStatusConfigServiceImpl.java

@@ -0,0 +1,20 @@
+package com.bizmatics.service.impl;
+
+import com.bizmatics.model.BulletinStatusConfig;
+import com.bizmatics.persistence.mapper.BulletinStatusConfigMapper;
+import com.bizmatics.service.BulletinStatusConfigService;
+import com.bizmatics.common.mvc.base.AbstractCrudService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author ya
+ * @since 2022-06-01
+ */
+@Service
+public class BulletinStatusConfigServiceImpl extends AbstractCrudService<BulletinStatusConfigMapper, BulletinStatusConfig> implements BulletinStatusConfigService {
+
+}