数据库提交

cuikaidong

2025-06-12 066063ed92fdd40da4dfe21770557f3adba3e1af

数据库提交

 db/dbo.sql

¶Ô±ÈÐÂÎļþ
ÎļþÌ«´ó

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/entity/Equipment.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,188 @@
package org.jeecg.modules.iot.mdc.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import org.jeecgframework.poi.excel.annotation.Excel;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;

/**
 * @Description: é‡‡é›†è®¾å¤‡è¡¨
 * @Author: liuS
 * @Date: 2023-03-23
 * @Version: V1.0
 */
@Data
@TableName("Equipment")
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@ApiModel(value = "Equipment对象", description = "采集设备表")
public class Equipment {

    /**
     * ç³»ç»Ÿid
     */
    @Excel(name = "系统id", width = 15)
    @ApiModelProperty(value = "系统id")
    private String beltlineid;
    /**
     * è®¾å¤‡ç¼–码
     */
    @Excel(name = "设备编码", width = 15)
    @ApiModelProperty(value = "设备编码")
    @TableId(type = IdType.AUTO)
    private String equipmentid;
    /**
     * å·¥åŽ‚id
     */
    @Excel(name = "工厂id", width = 15)
    @ApiModelProperty(value = "工厂id")
    private String factoryid;
    /**
     * ç³»ç»Ÿåç§°
     */
    @Excel(name = "系统名称", width = 15)
    @ApiModelProperty(value = "系统名称")
    private String beltlinename;
    /**
     * è®¾å¤‡ç±»åž‹
     */
    @Excel(name = "设备类型", width = 15)
    @ApiModelProperty(value = "设备类型")
    private String equipmentmodel;
    /**
     * è®¾å¤‡åç§°
     */
    @Excel(name = "设备名称", width = 15)
    @ApiModelProperty(value = "设备名称")
    private String equipmentname;
    /**
     * è®¾å¤‡åˆ†ç±»
     */
    @Excel(name = "设备分类", width = 15)
    @ApiModelProperty(value = "设备分类")
    private String equipmentclassify;
    /**
     * è®¾å¤‡ä½ç½®
     */
    @Excel(name = "设备位置", width = 15)
    @ApiModelProperty(value = "设备位置")
    private String equipmentlocation;
    /**
     * æŠ¥è­¦å·
     */
    @Excel(name = "报警号", width = 15)
    @ApiModelProperty(value = "报警号")
    private String alarm;
    /**
     * é‡‡é›†æ—¶é—´
     */
    @Excel(name = "采集时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
    @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @ApiModelProperty(value = "采集时间")
    private Date collecttime;
    /**
     * è®¾å¤‡ç±»åž‹
     */
    @Excel(name = "设备类型", width = 15)
    @ApiModelProperty(value = "设备类型")
    private String equipmenttype;
    /**
     * å›ºå®šä½ç½®
     */
    @Excel(name = "固定位置", width = 15)
    @ApiModelProperty(value = "固定位置")
    private String fixlocation;
    /**
     * å®žæ—¶çŠ¶æ€
     */
    @Excel(name = "实时状态", width = 15)
    @ApiModelProperty(value = "实时状态")
    private Integer oporation;
    /**
     * è®¾å¤‡æ•°æ®
     */
    @Excel(name = "设备数据", width = 15)
    @ApiModelProperty(value = "设备数据")
    private Object equipmentdata;
    /**
     * è®¾å¤‡ip
     */
    @Excel(name = "设备ip", width = 15)
    @ApiModelProperty(value = "设备ip")
    private String equipmentip;
    /**
     * å¤‡æ³¨
     */
    @Excel(name = "备注", width = 15)
    @ApiModelProperty(value = "备注")
    private String remark;
    /**
     * æŠ¥è­¦å·
     */
    @Excel(name = "报警号", width = 15)
    @ApiModelProperty(value = "报警号")
    private String alarmno;
    /**
     * æŠ¥è­¦å†…容
     */
    @Excel(name = "报警内容", width = 15)
    @ApiModelProperty(value = "报警内容")
    private String alarmcontent;
    /**
     * äº§å“æ•°é‡
     */
    @Excel(name = "产品数量", width = 15)
    @ApiModelProperty(value = "产品数量")
    private String productcount;
    /**
     * é©±åŠ¨ç±»åž‹
     */
    @Excel(name = "驱动类型", width = 15)
    @ApiModelProperty(value = "驱动类型")
    private String drivetype;
    /**
     * æ•°æ®ç«¯å£
     */
    @Excel(name = "数据端口", width = 15)
    @ApiModelProperty(value = "数据端口")
    private String dataport;
    /**
     * æŽ§åˆ¶ç³»ç»Ÿ
     */
    @Excel(name = "控制系统", width = 15)
    @ApiModelProperty(value = "控制系统")
    private String controlsystem;
    /**
     * è¡¨å
     */
    @Excel(name = "表名", width = 15)
    @ApiModelProperty(value = "表名")
    private String savetablename;
    /**
     * é‡è¦æ€§
     */
    @Excel(name = "重要性", width = 15)
    @ApiModelProperty(value = "重要性")
    private Integer isimportant;
    /**
     * ç»´æŠ¤çŠ¶æ€
     */
    @Excel(name = "维护状态", width = 15)
    @ApiModelProperty(value = "维护状态")
    private Integer maintaintype;
    /**
     * é«˜ä½ŽæŽ§åˆ¶
     */
    @Excel(name = "高低控制", width = 15)
    @ApiModelProperty(value = "高低控制")
    private String highlowcontrol;
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/entity/EquipmentAlarm.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,37 @@
package org.jeecg.modules.iot.mdc.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

import java.io.Serializable;
import java.util.Date;

@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("EquipmentAlarm")
public class EquipmentAlarm implements Serializable {

    private static final long serialVersionUID = -4762333096168370779L;

    @TableId(type = IdType.AUTO)
    private String equipmentid;
    private Date collecttime;

    @TableField(value = "alarmNo")
    private String alarmNo;

    @TableField(value = "alarmContent")
    private String alarmContent;
    private String isexamine;
    private String iseffective;
    private Date examinetime;
    private String examineperson;
    private String remark;

}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/entity/EquipmentLog.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,43 @@
package org.jeecg.modules.iot.mdc.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

import java.io.Serializable;
import java.util.Date;

@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("EquipmentLog")
@ApiModel(value = "设备历史表")
public class EquipmentLog implements Serializable {

    private static final long serialVersionUID = 6978749606363390023L;

    @ApiModelProperty(value = "设备ID")
    @TableId(value = "EquipmentID")
    private String equipmentId;

    @TableField(value = "EquipmentName")
    private String equipmentName;

    @TableField(value = "CollectTime")
    private Date collectTime;
    @TableField(value = "Oporation")
    private Integer oporation;
    @TableField(value = "Alarm")
    private String alarm;

    @TableField(exist = false)
    private String createBy = "admin";
    @TableField(exist = false)
    private String oporationName;
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/entity/MdcDriveTypeParamConfig.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,66 @@
package org.jeecg.modules.iot.mdc.entity;

import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import org.jeecg.common.system.base.entity.JeecgEntity;
import org.jeecgframework.poi.excel.annotation.Excel;

/**
 * @Description: é©±åŠ¨å‚数配置
 * @Author: jeecg-boot
 * @Date: 2023-04-20
 * @Version: V1.0
 */
@Data
@TableName("mdc_drive_type_param_config")
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@ApiModel(value = "mdc_drive_type_param_config对象", description = "驱动参数配置")
public class MdcDriveTypeParamConfig extends JeecgEntity {

    /**
     * æŽ§åˆ¶ç³»ç»Ÿç±»åž‹
     */
    @Excel(name = "控制系统类型", width = 15)
    @ApiModelProperty(value = "控制系统类型")
    private String controlSystemType;
    /**
     * ä¸­æ–‡åç§°
     */
    @Excel(name = "中文名称", width = 15)
    @ApiModelProperty(value = "中文名称")
    private String chineseName;
    /**
     * è‹±æ–‡åç§°
     */
    @Excel(name = "英文名称", width = 15)
    @ApiModelProperty(value = "英文名称")
    private String englishName;
    /**
     * åºå·
     */
    @Excel(name = "序号", width = 15)
    @ApiModelProperty(value = "序号")
    private Integer sortNo;
    /**
     * å±•ç¤ºæ ‡å¿—
     */
    @Excel(name = "展示标志", width = 15, replace = {"是_Y", "否_N"})
    @ApiModelProperty(value = "展示标志")
    private String showFlag;
    /**
     * å·¥ä½œæ›²çº¿ç”Ÿæˆæ ‡è®°
     */
    @Excel(name = "工作曲线生成标记", width = 15, replace = {"是_Y", "否_N"})
    @ApiModelProperty(value = "工作曲线生成标记")
    private String curveGenerationFlags;

    @TableField(exist = false)
    @ApiModelProperty(value = "采集值")
    private String value;
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/mapper/EquipmentAlarmMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,11 @@
package org.jeecg.modules.iot.mdc.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.jeecg.modules.iot.mdc.entity.EquipmentAlarm;

/**
 * @author: LiuS
 * @create: 2023-04-12 16:39
 */
public interface EquipmentAlarmMapper extends BaseMapper<EquipmentAlarm> {
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/mapper/EquipmentLogMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,22 @@
package org.jeecg.modules.iot.mdc.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
import org.jeecg.modules.iot.mdc.entity.EquipmentLog;

import java.util.Date;
import java.util.List;

/**
 * @author: LiuS
 * @create: 2023-04-12 14:44
 */
public interface EquipmentLogMapper extends BaseMapper<EquipmentLog> {


    EquipmentLog getRow(@Param("equipmentid") String equipmentid, @Param("startTime") Date startTime);

    EquipmentLog selectEquipmentOporation(@Param("equipmentId") String equipmentId);

    List<EquipmentLog> getEquipmentStatusList(@Param("equipmentIdList") List<String> equipmentIdList);
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/mapper/EquipmentMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,32 @@
package org.jeecg.modules.iot.mdc.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.*;
import org.jeecg.modules.iot.mdc.entity.Equipment;
import org.springframework.stereotype.Component;

/**
 * @Description: é‡‡é›†è®¾å¤‡è¡¨
 * @Author: liuS
 * @Date: 2023-03-23
 * @Version: V1.0
 */
@Component("mdcEquipmentMapper")
@Mapper
public interface EquipmentMapper extends BaseMapper<Equipment> {

    @Select(" SELECT name FROM SysObjects Where XType='U' AND name = '${saveTableName}' ")
    String checkTableExists(@Param("saveTableName") String saveTableName);

    @Select(" SELECT COUNT(CollectTime) num FROM ${saveTableName} WHERE CollectTime < '${day}' ")
    Integer checkTableDataNum(@Param("saveTableName") String saveTableName, @Param("day") String day);

    @Insert(" INSERT INTO ${tableName} SELECT * FROM ${lastTableName}  WHERE CollectTime < '${date}' ")
    void insertTableData(@Param("tableName") String tableName, @Param("lastTableName") String lastTableName, @Param("date") String date);

    @Delete(" delete from ${tableName} where CollectTime < '${day}' ")
    void deleteTableData(@Param("tableName") String saveTableName, @Param("day") String day);

    @Insert(" SELECT * INTO ${tableName} FROM ${lastTableName} WHERE CollectTime < '${date}' ")
    void insertNoTableData(@Param("tableName") String tableName, @Param("lastTableName") String lastTableName, @Param("date") String date);
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/mapper/MdcDriveTypeParamConfigMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package org.jeecg.modules.iot.mdc.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
import org.jeecg.modules.iot.mdc.entity.MdcDriveTypeParamConfig;

import java.util.List;

/**
 * @Description: é©±åŠ¨å‚数配置
 * @Author: jeecg-boot
 * @Date: 2023-04-20
 * @Version: V1.0
 */
public interface MdcDriveTypeParamConfigMapper extends BaseMapper<MdcDriveTypeParamConfig> {

    /**
     * æ ¹æ®è®¾å¤‡ç¼–码获取工作曲线参数
     */
    List<MdcDriveTypeParamConfig> findWorkCurveParamList(@Param("equipmentId") String equipmentId);

    /**
     * èŽ·å–控制系统类型下拉框选项
     */
    List<String> getDriveParamOptions();

}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/mapper/xml/EquipmentLogMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
<?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="org.jeecg.modules.iot.mdc.mapper.EquipmentLogMapper">

    <select id="getRow" resultType="org.jeecg.modules.iot.mdc.entity.EquipmentLog">
        SELECT top 1 * FROM EquipmentLog WHERE EquipmentID = #{ equipmentid } AND CollectTime &lt;= #{ startTime } AND Oporation in ('0','1','2','3') ORDER BY CollectTime ASC
    </select>

    <select id="selectEquipmentOporation" resultType="org.jeecg.modules.iot.mdc.entity.EquipmentLog">
        SELECT TOP 1 * FROM EquipmentLog WHERE EquipmentID = #{ equipmentId } ORDER BY CollectTime DESC
    </select>

    <!--查询设备最新一条数据-->
    <select id="getEquipmentStatusList" resultType="org.jeecg.modules.iot.mdc.entity.EquipmentLog">
        SELECT
            t1.*
        FROM
            EquipmentLog t1
        INNER JOIN ( SELECT MAX ( CollectTime ) AS CollectTime, EquipmentID FROM EquipmentLog GROUP BY EquipmentID ) t2 ON t1.CollectTime= t2.CollectTime
        AND t1.EquipmentID= t2.EquipmentID
        <if test="equipmentIdList != null and equipmentIdList.size() > 0">
            AND t1.EquipmentID IN
            <foreach collection="equipmentIdList" index="index" item="id" open="(" separator="," close=")">
                #{id}
            </foreach>
        </if>
    </select>
</mapper>

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/mapper/xml/EquipmentMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,5 @@
<?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="org.jeecg.modules.iot.mdc.mapper.EquipmentMapper">

</mapper>

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/mapper/xml/MdcDriveTypeParamConfigMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,23 @@
<?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="org.jeecg.modules.iot.mdc.mapper.MdcDriveTypeParamConfigMapper">

    <!--根据设备编码获取工作曲线参数-->
    <select id="findWorkCurveParamList" resultType="org.jeecg.modules.iot.mdc.entity.MdcDriveTypeParamConfig">
        SELECT
            mdtpc.*
        FROM
            mdc_drive_type_param_config mdtpc
            LEFT JOIN mdc_equipment me ON mdtpc.control_system_type = me.drive_type
        WHERE
            mdtpc.curve_generation_flags = 'Y'
            AND me.equipment_id = #{equipmentId}
    </select>

    <select id="getDriveParamOptions" resultType="java.lang.String">
        SELECT DISTINCT
            control_system_type
        FROM
            mdc_drive_type_param_config
    </select>
</mapper>

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/service/IEquipmentAlarmService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,15 @@
package org.jeecg.modules.iot.mdc.service;

import com.baomidou.mybatisplus.extension.service.IService;
import org.jeecg.modules.iot.mdc.entity.EquipmentAlarm;

import java.util.Date;
import java.util.List;

/**
 * @author: LiuS
 * @create: 2023-04-12 16:38
 */
public interface IEquipmentAlarmService extends IService<EquipmentAlarm> {
    List<EquipmentAlarm> findEquipmentAlarmByDate(String equipmentId, Date startTime, Date endTime);
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/service/IEquipmentLogService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,33 @@
package org.jeecg.modules.iot.mdc.service;

import com.baomidou.mybatisplus.extension.service.IService;
import org.jeecg.modules.iot.mdc.entity.EquipmentLog;

import java.util.Date;
import java.util.List;

/**
 * @author: LiuS
 * @create: 2023-04-12 14:40
 */
public interface IEquipmentLogService extends IService<EquipmentLog> {

    /**
     * æŸ¥è¯¢æŸä¸ªè®¾å¤‡æŸä¸ªæ—¶é—´ç‚¹ä¹‹åŽçš„数据
     */
    List<EquipmentLog> findEquipmentLogByEndTime(String equipmentId, Date maxDate);

    /**
     * æŸ¥è¯¢æŸä¸ªè®¾å¤‡æŸä¸ªæ—¶é—´ç‚¹ä¹‹åŽçš„数据(报警数据)
     */
    List<EquipmentLog> findEquipmentLogByErrorEndTime(String equipmentId, Date endTime);

    /**
     * èŽ·å–设备某个时间点之后的最新一条数据
     */
    EquipmentLog getRow(String equipmentid, Date startTime);

    EquipmentLog selectEquipmentOporation(String equipmentId);

    List<EquipmentLog> getEquipmentStatusList(List<String> equipmentIdList);
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/service/IEquipmentService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,51 @@
package org.jeecg.modules.iot.mdc.service;

import com.baomidou.mybatisplus.extension.service.IService;
import org.jeecg.modules.iot.mdc.entity.Equipment;

/**
 * @Description: é‡‡é›†è®¾å¤‡è¡¨
 * @Author: liuS
 * @Date: 2023-03-23
 * @Version: V1.0
 */
public interface IEquipmentService extends IService<Equipment> {

    /**
     * æ ¹æ®æ•°æ®è¡¨åç§°æŸ¥è¯¢æ•°æ®è¡¨æ˜¯å¦å­˜åœ¨
     * @param saveTableName
     * @return
     */
    String checkTableExists(String saveTableName);

    /**
     * æŸ¥è¯¢éœ€å¤‡ä»½æ•°æ®é‡
     * @param saveTableName
     * @param day
     * @return
     */
    Integer checkTableDataNum(String saveTableName, String day);

    /**
     * æ•°æ®è¿ç§»
     * @param backupTableName
     * @param tableName
     * @param day
     */
    void insertTableData(String backupTableName, String tableName, String day);

    /**
     * åˆ é™¤åŽŸæ•°æ®è¡¨æ•°æ®
     * @param tableName
     * @param day
     */
    void deleteTableData(String tableName, String day);

    /**
     * åˆ›å»ºå¤‡ä»½è¡¨
     * @param backupTableName
     * @param tableName
     * @param day
     */
    void insertNoTableData(String backupTableName, String tableName, String day);
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/service/IMdcDriveTypeParamConfigService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,16 @@
package org.jeecg.modules.iot.mdc.service;

import com.baomidou.mybatisplus.extension.service.IService;
import org.jeecg.modules.iot.mdc.entity.MdcDriveTypeParamConfig;

import java.util.List;

/**
 * @Description: é©±åŠ¨å‚数配置
 * @Author: jeecg-boot
 * @Date: 2023-04-20
 * @Version: V1.0
 */
public interface IMdcDriveTypeParamConfigService extends IService<MdcDriveTypeParamConfig> {

}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/service/impl/EquipmentAlarmServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,25 @@
package org.jeecg.modules.iot.mdc.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.jeecg.modules.iot.mdc.entity.EquipmentAlarm;
import org.jeecg.modules.iot.mdc.mapper.EquipmentAlarmMapper;
import org.jeecg.modules.iot.mdc.service.IEquipmentAlarmService;
import org.springframework.stereotype.Service;

import java.util.Date;
import java.util.List;

/**
 * @author: LiuS
 * @create: 2023-04-12 16:39
 */
@Service
public class EquipmentAlarmServiceImpl extends ServiceImpl<EquipmentAlarmMapper, EquipmentAlarm> implements IEquipmentAlarmService {
    @Override
    public List<EquipmentAlarm> findEquipmentAlarmByDate(String equipmentId, Date startTime, Date endTime) {
        return this.list(new LambdaQueryWrapper<EquipmentAlarm>()
                .ge(EquipmentAlarm::getCollecttime, startTime).le(EquipmentAlarm::getCollecttime, endTime)
                .eq(EquipmentAlarm::getEquipmentid, equipmentId).orderByDesc(EquipmentAlarm::getCollecttime));
    }
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/service/impl/EquipmentLogServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,61 @@
package org.jeecg.modules.iot.mdc.service.impl;

import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.jeecg.modules.iot.mdc.entity.EquipmentLog;
import org.jeecg.modules.iot.mdc.mapper.EquipmentLogMapper;
import org.jeecg.modules.iot.mdc.service.IEquipmentLogService;
import org.springframework.stereotype.Service;

import java.util.Arrays;
import java.util.Date;
import java.util.List;

/**
 * @author: LiuS
 * @create: 2023-04-12 14:41
 */
@Service
public class EquipmentLogServiceImpl extends ServiceImpl<EquipmentLogMapper, EquipmentLog> implements IEquipmentLogService {


    @Override
    public List<EquipmentLog> findEquipmentLogByEndTime(String equipmentId, Date maxDate) {
        LambdaQueryChainWrapper<EquipmentLog> lambdaQuery = this.lambdaQuery();
        lambdaQuery.eq(EquipmentLog::getEquipmentId, equipmentId);
        if (maxDate != null) {
            lambdaQuery.ge(EquipmentLog::getCollectTime, maxDate);
        }
        lambdaQuery.ne(EquipmentLog::getOporation, 22);
        lambdaQuery.ne(EquipmentLog::getOporation, 23);
        lambdaQuery.orderByAsc(EquipmentLog::getCollectTime);
        return lambdaQuery.list();
    }

    @Override
    public List<EquipmentLog> findEquipmentLogByErrorEndTime(String equipmentId, Date endTime) {
        LambdaQueryChainWrapper<EquipmentLog> lambdaQuery = this.lambdaQuery();
        lambdaQuery.eq(EquipmentLog::getEquipmentId, equipmentId);
        if (endTime != null) {
            lambdaQuery.ge(EquipmentLog::getCollectTime, endTime);
        }
        lambdaQuery.in(EquipmentLog::getOporation, Arrays.asList(0, 22, 23));
        lambdaQuery.orderByAsc(EquipmentLog::getCollectTime);
        return lambdaQuery.list();
    }

    @Override
    public EquipmentLog getRow(String equipmentid, Date startTime) {
        return this.baseMapper.getRow(equipmentid, startTime);
    }

    @Override
    public EquipmentLog selectEquipmentOporation(String equipmentId) {
        return this.baseMapper.selectEquipmentOporation(equipmentId);
    }

    @Override
    public List<EquipmentLog> getEquipmentStatusList(List<String> equipmentIdList) {
        return this.baseMapper.getEquipmentStatusList(equipmentIdList);
    }
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/service/impl/EquipmentServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,42 @@
package org.jeecg.modules.iot.mdc.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.jeecg.modules.iot.mdc.entity.Equipment;
import org.jeecg.modules.iot.mdc.mapper.EquipmentMapper;
import org.jeecg.modules.iot.mdc.service.IEquipmentService;
import org.springframework.stereotype.Service;

/**
 * @Description: é‡‡é›†è®¾å¤‡è¡¨
 * @Author: liuS
 * @Date: 2023-03-23
 * @Version: V1.0
 */
@Service("mdcEquipmentServiceImpl")
public class EquipmentServiceImpl extends ServiceImpl<EquipmentMapper, Equipment> implements IEquipmentService {

    @Override
    public String checkTableExists(String saveTableName) {
        return this.baseMapper.checkTableExists(saveTableName);
    }

    @Override
    public Integer checkTableDataNum(String saveTableName, String day) {
        return this.baseMapper.checkTableDataNum(saveTableName, day);
    }

    @Override
    public void insertTableData(String backupTableName, String tableName, String day) {
        this.baseMapper.insertTableData(backupTableName, tableName, day);
    }

    @Override
    public void deleteTableData(String tableName, String day) {
        this.baseMapper.deleteTableData(tableName, day);
    }

    @Override
    public void insertNoTableData(String backupTableName, String tableName, String day) {
        this.baseMapper.insertNoTableData(backupTableName, tableName, day);
    }
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/iot/mdc/service/impl/MdcDriveTypeParamConfigServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,21 @@
package org.jeecg.modules.iot.mdc.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.jeecg.common.constant.CommonConstant;
import org.jeecg.modules.iot.mdc.entity.MdcDriveTypeParamConfig;
import org.jeecg.modules.iot.mdc.mapper.MdcDriveTypeParamConfigMapper;
import org.jeecg.modules.iot.mdc.service.IMdcDriveTypeParamConfigService;
import org.springframework.stereotype.Service;

import java.util.Arrays;
import java.util.List;

/**
 * @Description: é©±åŠ¨å‚数配置
 * @Author: jeecg-boot
 * @Date: 2023-04-20
 * @Version: V1.0
 */
@Service
public class MdcDriveTypeParamConfigServiceImpl extends ServiceImpl<MdcDriveTypeParamConfigMapper, MdcDriveTypeParamConfig> implements IMdcDriveTypeParamConfigService {
}

 jeecg-boot-module-system/src/main/java/org/jeecg/modules/quartz/job/SampleParamJob.java

@@ -7,9 +7,10 @@
import lombok.extern.slf4j.Slf4j;
import org.jeecg.modules.iot.depository.Influxdb;
import org.jeecg.modules.iot.depository.InfluxdbTest;
import org.jeecg.modules.iot.depository.MysqlDataWriter;
import org.jeecg.modules.iot.entity.Equipment;
import org.jeecg.modules.iot.entity.InfluxdbDeploy;
import org.jeecg.modules.iot.mdc.entity.EquipmentLog;
import org.jeecg.modules.iot.mdc.service.IEquipmentLogService;
import org.jeecg.modules.iot.service.IEquipmentService;
import org.jeecg.modules.iot.service.IInfluxdbDeployService;
import org.quartz.Job;
@@ -24,6 +25,7 @@
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.concurrent.atomic.AtomicReference;
import java.util.stream.Collectors;

/**
@@ -39,6 +41,8 @@
    private DataSource dataSource;
    @Autowired
    private IEquipmentService equipmentService;
    @Autowired
    private IEquipmentLogService equipmentLogService;

    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
@@ -89,14 +93,21 @@
                        // æ ¹æ®æ—¶é—´è¿›è¡Œåˆ†ç»„
                        Map<String, List<Influxdb>> timeListMap = timeList.stream()
                                .collect(Collectors.groupingBy(Influxdb::getAcquisitionTime));
                        timeListMap.forEach((measurement, influxdbList) -> {
                            int lastIndex = table.lastIndexOf('.');
                            String code = table.substring(lastIndex + 1);
                        // å¤„理设备状态
                        int lastIndex = table.lastIndexOf('.');
                        String code = table.substring(lastIndex + 1);
                        EquipmentLog equipmentLog = equipmentLogService.selectEquipmentOporation(code);
                        // è®¾å¤‡çŠ¶æ€
                        Integer equipmentState = null;
                        for (Map.Entry<String, List<Influxdb>> entry : timeListMap.entrySet()) {
                            String measurement = entry.getKey();
                            List<Influxdb> influxdbList = entry.getValue();
                            Equipment equipment = equipmentService.findEquipmentByCode(code);
                            String tableName = equipment.getControlSystem() + '_' + equipment.getEqptCode();
                            // èŽ·å–表名
                            String[] columns = new String[influxdbList.size() + 2];
                            Object[] values = new Object[influxdbList.size() + 2];
                            String state = "";
                            // éåŽ†å½“前设备下的所有参数
                            for (int i = 0; i < influxdbList.size(); i++) {
                                String parameter = influxdbList.get(i).getParameter();
@@ -104,7 +115,12 @@
                                values[i] = influxdbList.get(i).getValue();
                                if (values[i] == null || values[i] == "") {
                                    values[i] = "";
                                } else {
                                    if (columns[i].equals("Oporation")) {
                                        state = values[i].toString();
                                    }
                                }

                            }
                            // éªŒè¯æ•°æ®æ˜¯å¦éƒ½ä¸ºç©º
                            if (!allEmptyStrings(values)) {
@@ -119,8 +135,23 @@
                                values[influxdbList.size()] = tableName;
                                // æ’入数据
                                equipmentService.insertMysqlData(tableName, columns, values);
                                if (!state.equals("")) {
                                    EquipmentLog log = new EquipmentLog();
                                    log.setOporation(Integer.parseInt(state));
                                    log.setEquipmentId(equipment.getEqptCode());
                                    log.setEquipmentName(equipment.getEqptName());
                                    log.setCollectTime(Date.from(dateTime.atZone(java.time.ZoneId.systemDefault()).toInstant()));
                                    // éªŒè¯è®¾å¤‡çŠ¶æ€æ˜¯å¦éœ€è¦å­˜å‚¨
                                    if (equipmentLog == null) {
                                        equipmentLogService.save(log);
                                        equipmentState = Integer.parseInt(state);
                                    } else if (equipmentState == null && equipmentLog.getOporation() != Integer.parseInt(state)) {
                                        equipmentState = Integer.parseInt(state);
                                        equipmentLogService.save(log);
                                    }
                                }
                            }
                        });
                        };
                    });
                } catch (Exception e) {
                    log.error(String.valueOf(e));

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/entity/Equipment.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/entity/EquipmentAlarm.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/entity/EquipmentLog.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/entity/MdcDriveTypeParamConfig.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/mapper/EquipmentAlarmMapper.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/mapper/EquipmentLogMapper.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/mapper/EquipmentMapper.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/mapper/MdcDriveTypeParamConfigMapper.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/mapper/xml/EquipmentLogMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
<?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="org.jeecg.modules.iot.mdc.mapper.EquipmentLogMapper">

    <select id="getRow" resultType="org.jeecg.modules.iot.mdc.entity.EquipmentLog">
        SELECT top 1 * FROM EquipmentLog WHERE EquipmentID = #{ equipmentid } AND CollectTime &lt;= #{ startTime } AND Oporation in ('0','1','2','3') ORDER BY CollectTime ASC
    </select>

    <select id="selectEquipmentOporation" resultType="org.jeecg.modules.iot.mdc.entity.EquipmentLog">
        SELECT TOP 1 * FROM EquipmentLog WHERE EquipmentID = #{ equipmentId } ORDER BY CollectTime DESC
    </select>

    <!--查询设备最新一条数据-->
    <select id="getEquipmentStatusList" resultType="org.jeecg.modules.iot.mdc.entity.EquipmentLog">
        SELECT
            t1.*
        FROM
            EquipmentLog t1
        INNER JOIN ( SELECT MAX ( CollectTime ) AS CollectTime, EquipmentID FROM EquipmentLog GROUP BY EquipmentID ) t2 ON t1.CollectTime= t2.CollectTime
        AND t1.EquipmentID= t2.EquipmentID
        <if test="equipmentIdList != null and equipmentIdList.size() > 0">
            AND t1.EquipmentID IN
            <foreach collection="equipmentIdList" index="index" item="id" open="(" separator="," close=")">
                #{id}
            </foreach>
        </if>
    </select>
</mapper>

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/mapper/xml/EquipmentMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,5 @@
<?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="org.jeecg.modules.iot.mdc.mapper.EquipmentMapper">

</mapper>

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/mapper/xml/MdcDriveTypeParamConfigMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,23 @@
<?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="org.jeecg.modules.iot.mdc.mapper.MdcDriveTypeParamConfigMapper">

    <!--根据设备编码获取工作曲线参数-->
    <select id="findWorkCurveParamList" resultType="org.jeecg.modules.iot.mdc.entity.MdcDriveTypeParamConfig">
        SELECT
            mdtpc.*
        FROM
            mdc_drive_type_param_config mdtpc
            LEFT JOIN mdc_equipment me ON mdtpc.control_system_type = me.drive_type
        WHERE
            mdtpc.curve_generation_flags = 'Y'
            AND me.equipment_id = #{equipmentId}
    </select>

    <select id="getDriveParamOptions" resultType="java.lang.String">
        SELECT DISTINCT
            control_system_type
        FROM
            mdc_drive_type_param_config
    </select>
</mapper>

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/service/IEquipmentAlarmService.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/service/IEquipmentLogService.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/service/IEquipmentService.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/service/IMdcDriveTypeParamConfigService.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/service/impl/EquipmentAlarmServiceImpl.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/service/impl/EquipmentLogServiceImpl.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/service/impl/EquipmentServiceImpl.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/iot/mdc/service/impl/MdcDriveTypeParamConfigServiceImpl.class

Binary files differ

 jeecg-boot-module-system/target/classes/org/jeecg/modules/quartz/job/SampleParamJob.class

Binary files differ