修复灯杆服务

environment-data-service/src/main/java/com/zksy/environment/config/NtServer.java

@@ -42,7 +42,6 @@ public class NtServer {
             boss = new NioEventLoopGroup(1);
             //事件处理group
             worker = new NioEventLoopGroup();
-
             ServerBootstrap bootstrap = new ServerBootstrap();
             // 绑定处理group
             bootstrap.group(boss, worker).channel(NioServerSocketChannel.class)

pole-service/src/main/java/com/zksy/pole/MQTTServer/callBack/BootNettyMqttMsgBack.java

@@ -79,6 +79,10 @@ public class BootNettyMqttMsgBack {
 	public  void puback (Channel channel, MqttMessage mqttMessage) throws InterruptedException {
 		MqttPublishMessage mqttPublishMessage = (MqttPublishMessage) mqttMessage;
 		MqttFixedHeader mqttFixedHeaderInfo = mqttPublishMessage.fixedHeader();
+		Object obj= mqttMessage.variableHeader();
+		MqttPublishVariableHeader variableHeader=(MqttPublishVariableHeader)obj;
+		String topicName=variableHeader.topicName();
+		System.err.println("topicName========"+topicName);
 		MqttQoS qos =  mqttFixedHeaderInfo.qosLevel();
 		//注意：	readableBytes会改变写指针位置，使后续推送数据时，读取数据为空，需要重置	读指针
         byte[] headBytes = new byte[mqttPublishMessage.payload().readableBytes()];

pole-service/src/main/java/com/zksy/pole/PoleApplication.java

@@ -1,5 +1,6 @@
 package com.zksy.pole;
 
+import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
@@ -10,6 +11,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
  * @description 灯杆服务
  * @date 2024/8/28 09:54:31
  */
+@MapperScan("com.zksy.pole.mapper")
 @SpringBootApplication
 public class PoleApplication {
     public static void main(String[] args) {

pole-service/src/main/java/com/zksy/pole/domain/po/DgEquipmentAlarm.java

@@ -0,0 +1,141 @@
+package com.zksy.pole.domain.po;
+
+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 java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 设备上下线报警
+ * @TableName dg_equipment_alarm
+ */
+@TableName(value ="dg_equipment_alarm")
+@Data
+public class DgEquipmentAlarm implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * cmd
+     */
+    private Long cmd;
+
+    /**
+     * 时间
+     */
+    private Date dateTime;
+
+    /**
+     * 网络设备为ip地址，非网络设备没有此字段
+     */
+    private String ip;
+
+    /**
+     * 网络设备为ip主机名称，串口设备为因子名
+     */
+    private String deviceName;
+
+    /**
+     * 1:摄像头 2:信息发布屏 3:网络广播 4:一键求助 5无线AP 6充电桩 7其它网络1 8其它网络2  9 串口设备
+     */
+    private String type;
+
+    /**
+     * 1:设备上线  0:设备离线
+     */
+    private String status;
+
+    /**
+     * 创建者
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DgEquipmentAlarm other = (DgEquipmentAlarm) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCmd() == null ? other.getCmd() == null : this.getCmd().equals(other.getCmd()))
+            && (this.getDateTime() == null ? other.getDateTime() == null : this.getDateTime().equals(other.getDateTime()))
+            && (this.getIp() == null ? other.getIp() == null : this.getIp().equals(other.getIp()))
+            && (this.getDeviceName() == null ? other.getDeviceName() == null : this.getDeviceName().equals(other.getDeviceName()))
+            && (this.getType() == null ? other.getType() == null : this.getType().equals(other.getType()))
+            && (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus()))
+            && (this.getCreateBy() == null ? other.getCreateBy() == null : this.getCreateBy().equals(other.getCreateBy()))
+            && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
+            && (this.getUpdateBy() == null ? other.getUpdateBy() == null : this.getUpdateBy().equals(other.getUpdateBy()))
+            && (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCmd() == null) ? 0 : getCmd().hashCode());
+        result = prime * result + ((getDateTime() == null) ? 0 : getDateTime().hashCode());
+        result = prime * result + ((getIp() == null) ? 0 : getIp().hashCode());
+        result = prime * result + ((getDeviceName() == null) ? 0 : getDeviceName().hashCode());
+        result = prime * result + ((getType() == null) ? 0 : getType().hashCode());
+        result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode());
+        result = prime * result + ((getCreateBy() == null) ? 0 : getCreateBy().hashCode());
+        result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
+        result = prime * result + ((getUpdateBy() == null) ? 0 : getUpdateBy().hashCode());
+        result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", cmd=").append(cmd);
+        sb.append(", dateTime=").append(dateTime);
+        sb.append(", ip=").append(ip);
+        sb.append(", deviceName=").append(deviceName);
+        sb.append(", type=").append(type);
+        sb.append(", status=").append(status);
+        sb.append(", createBy=").append(createBy);
+        sb.append(", createTime=").append(createTime);
+        sb.append(", updateBy=").append(updateBy);
+        sb.append(", updateTime=").append(updateTime);
+        sb.append(", serialVersionUID=").append(serialVersionUID);
+        sb.append("]");
+        return sb.toString();
+    }
+}

pole-service/src/main/java/com/zksy/pole/domain/po/DgEquipmentStatus.java

@@ -0,0 +1,117 @@
+package com.zksy.pole.domain.po;
+
+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 java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 灯控设备状态查询
+ * @TableName dg_equipment_status
+ */
+@TableName(value ="dg_equipment_status")
+@Data
+public class DgEquipmentStatus implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * cmd
+     */
+    private Long cmd;
+
+    /**
+     * 包id
+     */
+    private String packageId;
+
+    /**
+     * json数据格式包
+     */
+    private Object params;
+
+    /**
+     * 创建者
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DgEquipmentStatus other = (DgEquipmentStatus) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCmd() == null ? other.getCmd() == null : this.getCmd().equals(other.getCmd()))
+            && (this.getPackageId() == null ? other.getPackageId() == null : this.getPackageId().equals(other.getPackageId()))
+            && (this.getParams() == null ? other.getParams() == null : this.getParams().equals(other.getParams()))
+            && (this.getCreateBy() == null ? other.getCreateBy() == null : this.getCreateBy().equals(other.getCreateBy()))
+            && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
+            && (this.getUpdateBy() == null ? other.getUpdateBy() == null : this.getUpdateBy().equals(other.getUpdateBy()))
+            && (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCmd() == null) ? 0 : getCmd().hashCode());
+        result = prime * result + ((getPackageId() == null) ? 0 : getPackageId().hashCode());
+        result = prime * result + ((getParams() == null) ? 0 : getParams().hashCode());
+        result = prime * result + ((getCreateBy() == null) ? 0 : getCreateBy().hashCode());
+        result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
+        result = prime * result + ((getUpdateBy() == null) ? 0 : getUpdateBy().hashCode());
+        result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", cmd=").append(cmd);
+        sb.append(", packageId=").append(packageId);
+        sb.append(", params=").append(params);
+        sb.append(", createBy=").append(createBy);
+        sb.append(", createTime=").append(createTime);
+        sb.append(", updateBy=").append(updateBy);
+        sb.append(", updateTime=").append(updateTime);
+        sb.append(", serialVersionUID=").append(serialVersionUID);
+        sb.append("]");
+        return sb.toString();
+    }
+}

pole-service/src/main/java/com/zksy/pole/domain/po/DgGatewayRegistration.java

@@ -0,0 +1,141 @@
+package com.zksy.pole.domain.po;
+
+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 java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 网关注册
+ * @TableName dg_gateway_registration
+ */
+@TableName(value ="dg_gateway_registration")
+@Data
+public class DgGatewayRegistration implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * cmd
+     */
+    private Long cmd;
+
+    /**
+     * 时间
+     */
+    private Date dateTime;
+
+    /**
+     * 经度
+     */
+    private Double longitude;
+
+    /**
+     * 纬度
+     */
+    private Double latitude;
+
+    /**
+     * 设备类型
+     */
+    private String deviceType;
+
+    /**
+     * mac地址
+     */
+    private String mac;
+
+    /**
+     * 创建者
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DgGatewayRegistration other = (DgGatewayRegistration) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCmd() == null ? other.getCmd() == null : this.getCmd().equals(other.getCmd()))
+            && (this.getDateTime() == null ? other.getDateTime() == null : this.getDateTime().equals(other.getDateTime()))
+            && (this.getLongitude() == null ? other.getLongitude() == null : this.getLongitude().equals(other.getLongitude()))
+            && (this.getLatitude() == null ? other.getLatitude() == null : this.getLatitude().equals(other.getLatitude()))
+            && (this.getDeviceType() == null ? other.getDeviceType() == null : this.getDeviceType().equals(other.getDeviceType()))
+            && (this.getMac() == null ? other.getMac() == null : this.getMac().equals(other.getMac()))
+            && (this.getCreateBy() == null ? other.getCreateBy() == null : this.getCreateBy().equals(other.getCreateBy()))
+            && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
+            && (this.getUpdateBy() == null ? other.getUpdateBy() == null : this.getUpdateBy().equals(other.getUpdateBy()))
+            && (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCmd() == null) ? 0 : getCmd().hashCode());
+        result = prime * result + ((getDateTime() == null) ? 0 : getDateTime().hashCode());
+        result = prime * result + ((getLongitude() == null) ? 0 : getLongitude().hashCode());
+        result = prime * result + ((getLatitude() == null) ? 0 : getLatitude().hashCode());
+        result = prime * result + ((getDeviceType() == null) ? 0 : getDeviceType().hashCode());
+        result = prime * result + ((getMac() == null) ? 0 : getMac().hashCode());
+        result = prime * result + ((getCreateBy() == null) ? 0 : getCreateBy().hashCode());
+        result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
+        result = prime * result + ((getUpdateBy() == null) ? 0 : getUpdateBy().hashCode());
+        result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", cmd=").append(cmd);
+        sb.append(", dateTime=").append(dateTime);
+        sb.append(", longitude=").append(longitude);
+        sb.append(", latitude=").append(latitude);
+        sb.append(", deviceType=").append(deviceType);
+        sb.append(", mac=").append(mac);
+        sb.append(", createBy=").append(createBy);
+        sb.append(", createTime=").append(createTime);
+        sb.append(", updateBy=").append(updateBy);
+        sb.append(", updateTime=").append(updateTime);
+        sb.append(", serialVersionUID=").append(serialVersionUID);
+        sb.append("]");
+        return sb.toString();
+    }
+}

pole-service/src/main/java/com/zksy/pole/domain/po/DgGatewayStrategy.java

@@ -0,0 +1,125 @@
+package com.zksy.pole.domain.po;
+
+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 java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 抄读网关场景策略\接收主动上报网关场景策略
+ * @TableName dg_gateway_strategy
+ */
+@TableName(value ="dg_gateway_strategy")
+@Data
+public class DgGatewayStrategy implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * cmd
+     */
+    private Long cmd;
+
+    /**
+     * 包id
+     */
+    private String packageId;
+
+    /**
+     * 灯编号
+     */
+    private String lightNum;
+
+    /**
+     * json数据包
+     */
+    private Object params;
+
+    /**
+     * 创建者
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DgGatewayStrategy other = (DgGatewayStrategy) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCmd() == null ? other.getCmd() == null : this.getCmd().equals(other.getCmd()))
+            && (this.getPackageId() == null ? other.getPackageId() == null : this.getPackageId().equals(other.getPackageId()))
+            && (this.getLightNum() == null ? other.getLightNum() == null : this.getLightNum().equals(other.getLightNum()))
+            && (this.getParams() == null ? other.getParams() == null : this.getParams().equals(other.getParams()))
+            && (this.getCreateBy() == null ? other.getCreateBy() == null : this.getCreateBy().equals(other.getCreateBy()))
+            && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
+            && (this.getUpdateBy() == null ? other.getUpdateBy() == null : this.getUpdateBy().equals(other.getUpdateBy()))
+            && (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCmd() == null) ? 0 : getCmd().hashCode());
+        result = prime * result + ((getPackageId() == null) ? 0 : getPackageId().hashCode());
+        result = prime * result + ((getLightNum() == null) ? 0 : getLightNum().hashCode());
+        result = prime * result + ((getParams() == null) ? 0 : getParams().hashCode());
+        result = prime * result + ((getCreateBy() == null) ? 0 : getCreateBy().hashCode());
+        result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
+        result = prime * result + ((getUpdateBy() == null) ? 0 : getUpdateBy().hashCode());
+        result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", cmd=").append(cmd);
+        sb.append(", packageId=").append(packageId);
+        sb.append(", lightNum=").append(lightNum);
+        sb.append(", params=").append(params);
+        sb.append(", createBy=").append(createBy);
+        sb.append(", createTime=").append(createTime);
+        sb.append(", updateBy=").append(updateBy);
+        sb.append(", updateTime=").append(updateTime);
+        sb.append(", serialVersionUID=").append(serialVersionUID);
+        sb.append("]");
+        return sb.toString();
+    }
+}

pole-service/src/main/java/com/zksy/pole/domain/po/DgLampControlledHeartbeat.java

@@ -0,0 +1,125 @@
+package com.zksy.pole.domain.po;
+
+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 java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 灯控设备心跳
+ * @TableName dg_lamp_controlled_heartbeat
+ */
+@TableName(value ="dg_lamp_controlled_heartbeat")
+@Data
+public class DgLampControlledHeartbeat implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * cmd
+     */
+    private Long cmd;
+
+    /**
+     * 时间
+     */
+    private Date dateTime;
+
+    /**
+     * 包编号
+     */
+    private Long heardId;
+
+    /**
+     * 灯控设备信息JSON
+     */
+    private Object params;
+
+    /**
+     * 创建者
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DgLampControlledHeartbeat other = (DgLampControlledHeartbeat) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCmd() == null ? other.getCmd() == null : this.getCmd().equals(other.getCmd()))
+            && (this.getDateTime() == null ? other.getDateTime() == null : this.getDateTime().equals(other.getDateTime()))
+            && (this.getHeardId() == null ? other.getHeardId() == null : this.getHeardId().equals(other.getHeardId()))
+            && (this.getParams() == null ? other.getParams() == null : this.getParams().equals(other.getParams()))
+            && (this.getCreateBy() == null ? other.getCreateBy() == null : this.getCreateBy().equals(other.getCreateBy()))
+            && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
+            && (this.getUpdateBy() == null ? other.getUpdateBy() == null : this.getUpdateBy().equals(other.getUpdateBy()))
+            && (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCmd() == null) ? 0 : getCmd().hashCode());
+        result = prime * result + ((getDateTime() == null) ? 0 : getDateTime().hashCode());
+        result = prime * result + ((getHeardId() == null) ? 0 : getHeardId().hashCode());
+        result = prime * result + ((getParams() == null) ? 0 : getParams().hashCode());
+        result = prime * result + ((getCreateBy() == null) ? 0 : getCreateBy().hashCode());
+        result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
+        result = prime * result + ((getUpdateBy() == null) ? 0 : getUpdateBy().hashCode());
+        result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", cmd=").append(cmd);
+        sb.append(", dateTime=").append(dateTime);
+        sb.append(", heardId=").append(heardId);
+        sb.append(", params=").append(params);
+        sb.append(", createBy=").append(createBy);
+        sb.append(", createTime=").append(createTime);
+        sb.append(", updateBy=").append(updateBy);
+        sb.append(", updateTime=").append(updateTime);
+        sb.append(", serialVersionUID=").append(serialVersionUID);
+        sb.append("]");
+        return sb.toString();
+    }
+}

pole-service/src/main/java/com/zksy/pole/domain/po/DgRelayControl.java

@@ -0,0 +1,117 @@
+package com.zksy.pole.domain.po;
+
+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 java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 继电器控制
+ * @TableName dg_relay_control
+ */
+@TableName(value ="dg_relay_control")
+@Data
+public class DgRelayControl implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * cmd
+     */
+    private Long cmd;
+
+    /**
+     * 包id
+     */
+    private String packageId;
+
+    /**
+     * json格式数据包
+     */
+    private Object params;
+
+    /**
+     * 创建者
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DgRelayControl other = (DgRelayControl) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCmd() == null ? other.getCmd() == null : this.getCmd().equals(other.getCmd()))
+            && (this.getPackageId() == null ? other.getPackageId() == null : this.getPackageId().equals(other.getPackageId()))
+            && (this.getParams() == null ? other.getParams() == null : this.getParams().equals(other.getParams()))
+            && (this.getCreateBy() == null ? other.getCreateBy() == null : this.getCreateBy().equals(other.getCreateBy()))
+            && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
+            && (this.getUpdateBy() == null ? other.getUpdateBy() == null : this.getUpdateBy().equals(other.getUpdateBy()))
+            && (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCmd() == null) ? 0 : getCmd().hashCode());
+        result = prime * result + ((getPackageId() == null) ? 0 : getPackageId().hashCode());
+        result = prime * result + ((getParams() == null) ? 0 : getParams().hashCode());
+        result = prime * result + ((getCreateBy() == null) ? 0 : getCreateBy().hashCode());
+        result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
+        result = prime * result + ((getUpdateBy() == null) ? 0 : getUpdateBy().hashCode());
+        result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", cmd=").append(cmd);
+        sb.append(", packageId=").append(packageId);
+        sb.append(", params=").append(params);
+        sb.append(", createBy=").append(createBy);
+        sb.append(", createTime=").append(createTime);
+        sb.append(", updateBy=").append(updateBy);
+        sb.append(", updateTime=").append(updateTime);
+        sb.append(", serialVersionUID=").append(serialVersionUID);
+        sb.append("]");
+        return sb.toString();
+    }
+}

pole-service/src/main/java/com/zksy/pole/domain/po/DgRelayTimingStrategy.java

@@ -0,0 +1,125 @@
+package com.zksy.pole.domain.po;
+
+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 java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 继电器定时策略
+ * @TableName dg_relay_timing_strategy
+ */
+@TableName(value ="dg_relay_timing_strategy")
+@Data
+public class DgRelayTimingStrategy implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * cmd
+     */
+    private Long cmd;
+
+    /**
+     * 包id
+     */
+    private String packageId;
+
+    /**
+     * 继电器编号
+     */
+    private String index;
+
+    /**
+     * json格式数据包
+     */
+    private Object params;
+
+    /**
+     * 创建者
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DgRelayTimingStrategy other = (DgRelayTimingStrategy) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCmd() == null ? other.getCmd() == null : this.getCmd().equals(other.getCmd()))
+            && (this.getPackageId() == null ? other.getPackageId() == null : this.getPackageId().equals(other.getPackageId()))
+            && (this.getIndex() == null ? other.getIndex() == null : this.getIndex().equals(other.getIndex()))
+            && (this.getParams() == null ? other.getParams() == null : this.getParams().equals(other.getParams()))
+            && (this.getCreateBy() == null ? other.getCreateBy() == null : this.getCreateBy().equals(other.getCreateBy()))
+            && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
+            && (this.getUpdateBy() == null ? other.getUpdateBy() == null : this.getUpdateBy().equals(other.getUpdateBy()))
+            && (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCmd() == null) ? 0 : getCmd().hashCode());
+        result = prime * result + ((getPackageId() == null) ? 0 : getPackageId().hashCode());
+        result = prime * result + ((getIndex() == null) ? 0 : getIndex().hashCode());
+        result = prime * result + ((getParams() == null) ? 0 : getParams().hashCode());
+        result = prime * result + ((getCreateBy() == null) ? 0 : getCreateBy().hashCode());
+        result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
+        result = prime * result + ((getUpdateBy() == null) ? 0 : getUpdateBy().hashCode());
+        result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", cmd=").append(cmd);
+        sb.append(", packageId=").append(packageId);
+        sb.append(", index=").append(index);
+        sb.append(", params=").append(params);
+        sb.append(", createBy=").append(createBy);
+        sb.append(", createTime=").append(createTime);
+        sb.append(", updateBy=").append(updateBy);
+        sb.append(", updateTime=").append(updateTime);
+        sb.append(", serialVersionUID=").append(serialVersionUID);
+        sb.append("]");
+        return sb.toString();
+    }
+}

pole-service/src/main/java/com/zksy/pole/domain/po/DgReportEnvironmentalData.java

@@ -0,0 +1,117 @@
+package com.zksy.pole.domain.po;
+
+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 java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 网关以固定频率上报环境数据
+ * @TableName dg_report_environmental_data
+ */
+@TableName(value ="dg_report_environmental_data")
+@Data
+public class DgReportEnvironmentalData implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * cmd
+     */
+    private Long cmd;
+
+    /**
+     * 时间
+     */
+    private Date dateTime;
+
+    /**
+     * 0正常上报,1补传
+     */
+    private String flag;
+
+    /**
+     * 
+     */
+    private String sersorId;
+
+    /**
+     * 监测因子json
+     */
+    private Object params;
+
+    /**
+     * 继电器json
+     */
+    private Object params2;
+
+    /**
+     * 状态json
+     */
+    private Object params3;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DgReportEnvironmentalData other = (DgReportEnvironmentalData) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCmd() == null ? other.getCmd() == null : this.getCmd().equals(other.getCmd()))
+            && (this.getDateTime() == null ? other.getDateTime() == null : this.getDateTime().equals(other.getDateTime()))
+            && (this.getFlag() == null ? other.getFlag() == null : this.getFlag().equals(other.getFlag()))
+            && (this.getSersorId() == null ? other.getSersorId() == null : this.getSersorId().equals(other.getSersorId()))
+            && (this.getParams() == null ? other.getParams() == null : this.getParams().equals(other.getParams()))
+            && (this.getParams2() == null ? other.getParams2() == null : this.getParams2().equals(other.getParams2()))
+            && (this.getParams3() == null ? other.getParams3() == null : this.getParams3().equals(other.getParams3()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCmd() == null) ? 0 : getCmd().hashCode());
+        result = prime * result + ((getDateTime() == null) ? 0 : getDateTime().hashCode());
+        result = prime * result + ((getFlag() == null) ? 0 : getFlag().hashCode());
+        result = prime * result + ((getSersorId() == null) ? 0 : getSersorId().hashCode());
+        result = prime * result + ((getParams() == null) ? 0 : getParams().hashCode());
+        result = prime * result + ((getParams2() == null) ? 0 : getParams2().hashCode());
+        result = prime * result + ((getParams3() == null) ? 0 : getParams3().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", cmd=").append(cmd);
+        sb.append(", dateTime=").append(dateTime);
+        sb.append(", flag=").append(flag);
+        sb.append(", sersorId=").append(sersorId);
+        sb.append(", params=").append(params);
+        sb.append(", params2=").append(params2);
+        sb.append(", params3=").append(params3);
+        sb.append(", serialVersionUID=").append(serialVersionUID);
+        sb.append("]");
+        return sb.toString();
+    }
+}

pole-service/src/main/java/com/zksy/pole/domain/po/DgTimelyControl.java

@@ -0,0 +1,125 @@
+package com.zksy.pole.domain.po;
+
+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 java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 灯具及时控制
+ * @TableName dg_timely_control
+ */
+@TableName(value ="dg_timely_control")
+@Data
+public class DgTimelyControl implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * cmd
+     */
+    private Long cmd;
+
+    /**
+     * 状态码
+     */
+    private Integer code;
+
+    /**
+     * 包ID
+     */
+    private String packageId;
+
+    /**
+     * jsone数据格式
+     */
+    private Object params;
+
+    /**
+     * 创建者
+     */
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新者
+     */
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DgTimelyControl other = (DgTimelyControl) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getCmd() == null ? other.getCmd() == null : this.getCmd().equals(other.getCmd()))
+            && (this.getCode() == null ? other.getCode() == null : this.getCode().equals(other.getCode()))
+            && (this.getPackageId() == null ? other.getPackageId() == null : this.getPackageId().equals(other.getPackageId()))
+            && (this.getParams() == null ? other.getParams() == null : this.getParams().equals(other.getParams()))
+            && (this.getCreateBy() == null ? other.getCreateBy() == null : this.getCreateBy().equals(other.getCreateBy()))
+            && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
+            && (this.getUpdateBy() == null ? other.getUpdateBy() == null : this.getUpdateBy().equals(other.getUpdateBy()))
+            && (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()));
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getCmd() == null) ? 0 : getCmd().hashCode());
+        result = prime * result + ((getCode() == null) ? 0 : getCode().hashCode());
+        result = prime * result + ((getPackageId() == null) ? 0 : getPackageId().hashCode());
+        result = prime * result + ((getParams() == null) ? 0 : getParams().hashCode());
+        result = prime * result + ((getCreateBy() == null) ? 0 : getCreateBy().hashCode());
+        result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
+        result = prime * result + ((getUpdateBy() == null) ? 0 : getUpdateBy().hashCode());
+        result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", cmd=").append(cmd);
+        sb.append(", code=").append(code);
+        sb.append(", packageId=").append(packageId);
+        sb.append(", params=").append(params);
+        sb.append(", createBy=").append(createBy);
+        sb.append(", createTime=").append(createTime);
+        sb.append(", updateBy=").append(updateBy);
+        sb.append(", updateTime=").append(updateTime);
+        sb.append(", serialVersionUID=").append(serialVersionUID);
+        sb.append("]");
+        return sb.toString();
+    }
+}

pole-service/src/main/java/com/zksy/pole/mapper/DgEquipmentAlarmMapper.java

@@ -0,0 +1,18 @@
+package com.zksy.pole.mapper;
+
+import com.zksy.pole.domain.po.DgEquipmentAlarm;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author hxb
+* @description 针对表【dg_equipment_alarm(设备上下线报警)】的数据库操作Mapper
+* @createDate 2024-08-28 17:35:16
+* @Entity com.zksy.pole.domain.po.DgEquipmentAlarm
+*/
+public interface DgEquipmentAlarmMapper extends BaseMapper<DgEquipmentAlarm> {
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/mapper/DgEquipmentStatusMapper.java

@@ -0,0 +1,18 @@
+package com.zksy.pole.mapper;
+
+import com.zksy.pole.domain.po.DgEquipmentStatus;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author hxb
+* @description 针对表【dg_equipment_status(灯控设备状态查询)】的数据库操作Mapper
+* @createDate 2024-08-28 17:36:37
+* @Entity com.zksy.pole.domain.po.DgEquipmentStatus
+*/
+public interface DgEquipmentStatusMapper extends BaseMapper<DgEquipmentStatus> {
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/mapper/DgGatewayRegistrationMapper.java

@@ -0,0 +1,19 @@
+package com.zksy.pole.mapper;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.zksy.pole.domain.po.DgGatewayRegistration;
+
+/**
+* @author hxb
+* @description 针对表【dg_gateway_registration(网关注册)】的数据库操作Mapper
+* @createDate 2024-08-28 17:24:07
+* @Entity pole.domain.po.DgGatewayRegistration
+*/
+public interface DgGatewayRegistrationMapper extends BaseMapper<DgGatewayRegistration> {
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/mapper/DgGatewayStrategyMapper.java

@@ -0,0 +1,18 @@
+package com.zksy.pole.mapper;
+
+import com.zksy.pole.domain.po.DgGatewayStrategy;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author hxb
+* @description 针对表【dg_gateway_strategy(抄读网关场景策略\接收主动上报网关场景策略)】的数据库操作Mapper
+* @createDate 2024-08-28 17:36:42
+* @Entity com.zksy.pole.domain.po.DgGatewayStrategy
+*/
+public interface DgGatewayStrategyMapper extends BaseMapper<DgGatewayStrategy> {
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/mapper/DgLampControlledHeartbeatMapper.java

@@ -0,0 +1,18 @@
+package com.zksy.pole.mapper;
+
+import com.zksy.pole.domain.po.DgLampControlledHeartbeat;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author hxb
+* @description 针对表【dg_lamp_controlled_heartbeat(灯控设备心跳)】的数据库操作Mapper
+* @createDate 2024-08-28 17:36:46
+* @Entity com.zksy.pole.domain.po.DgLampControlledHeartbeat
+*/
+public interface DgLampControlledHeartbeatMapper extends BaseMapper<DgLampControlledHeartbeat> {
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/mapper/DgRelayControlMapper.java

@@ -0,0 +1,18 @@
+package com.zksy.pole.mapper;
+
+import com.zksy.pole.domain.po.DgRelayControl;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author hxb
+* @description 针对表【dg_relay_control(继电器控制)】的数据库操作Mapper
+* @createDate 2024-08-28 17:36:49
+* @Entity com.zksy.pole.domain.po.DgRelayControl
+*/
+public interface DgRelayControlMapper extends BaseMapper<DgRelayControl> {
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/mapper/DgRelayTimingStrategyMapper.java

@@ -0,0 +1,18 @@
+package com.zksy.pole.mapper;
+
+import com.zksy.pole.domain.po.DgRelayTimingStrategy;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author hxb
+* @description 针对表【dg_relay_timing_strategy(继电器定时策略)】的数据库操作Mapper
+* @createDate 2024-08-28 17:36:52
+* @Entity com.zksy.pole.domain.po.DgRelayTimingStrategy
+*/
+public interface DgRelayTimingStrategyMapper extends BaseMapper<DgRelayTimingStrategy> {
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/mapper/DgReportEnvironmentalDataMapper.java

@@ -0,0 +1,18 @@
+package com.zksy.pole.mapper;
+
+import com.zksy.pole.domain.po.DgReportEnvironmentalData;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author hxb
+* @description 针对表【dg_report_environmental_data(网关以固定频率上报环境数据)】的数据库操作Mapper
+* @createDate 2024-08-28 17:36:54
+* @Entity com.zksy.pole.domain.po.DgReportEnvironmentalData
+*/
+public interface DgReportEnvironmentalDataMapper extends BaseMapper<DgReportEnvironmentalData> {
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/mapper/DgTimelyControlMapper.java

@@ -0,0 +1,18 @@
+package com.zksy.pole.mapper;
+
+import com.zksy.pole.domain.po.DgTimelyControl;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author hxb
+* @description 针对表【dg_timely_control(灯具及时控制)】的数据库操作Mapper
+* @createDate 2024-08-28 17:36:57
+* @Entity com.zksy.pole.domain.po.DgTimelyControl
+*/
+public interface DgTimelyControlMapper extends BaseMapper<DgTimelyControl> {
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/service/DgEquipmentAlarmService.java

@@ -0,0 +1,13 @@
+package com.zksy.pole.service;
+
+import com.zksy.pole.domain.po.DgEquipmentAlarm;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author hxb
+* @description 针对表【dg_equipment_alarm(设备上下线报警)】的数据库操作Service
+* @createDate 2024-08-28 17:35:16
+*/
+public interface DgEquipmentAlarmService extends IService<DgEquipmentAlarm> {
+
+}

pole-service/src/main/java/com/zksy/pole/service/DgEquipmentStatusService.java

@@ -0,0 +1,13 @@
+package com.zksy.pole.service;
+
+import com.zksy.pole.domain.po.DgEquipmentStatus;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author hxb
+* @description 针对表【dg_equipment_status(灯控设备状态查询)】的数据库操作Service
+* @createDate 2024-08-28 17:36:37
+*/
+public interface DgEquipmentStatusService extends IService<DgEquipmentStatus> {
+
+}

pole-service/src/main/java/com/zksy/pole/service/DgGatewayRegistrationService.java

@@ -0,0 +1,14 @@
+package com.zksy.pole.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.zksy.pole.domain.po.DgGatewayRegistration;
+
+/**
+* @author hxb
+* @description 针对表【dg_gateway_registration(网关注册)】的数据库操作Service
+* @createDate 2024-08-28 17:24:07
+*/
+public interface DgGatewayRegistrationService extends IService<DgGatewayRegistration> {
+
+}

pole-service/src/main/java/com/zksy/pole/service/DgGatewayStrategyService.java

@@ -0,0 +1,13 @@
+package com.zksy.pole.service;
+
+import com.zksy.pole.domain.po.DgGatewayStrategy;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author hxb
+* @description 针对表【dg_gateway_strategy(抄读网关场景策略\接收主动上报网关场景策略)】的数据库操作Service
+* @createDate 2024-08-28 17:36:42
+*/
+public interface DgGatewayStrategyService extends IService<DgGatewayStrategy> {
+
+}

pole-service/src/main/java/com/zksy/pole/service/DgLampControlledHeartbeatService.java

@@ -0,0 +1,13 @@
+package com.zksy.pole.service;
+
+import com.zksy.pole.domain.po.DgLampControlledHeartbeat;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author hxb
+* @description 针对表【dg_lamp_controlled_heartbeat(灯控设备心跳)】的数据库操作Service
+* @createDate 2024-08-28 17:36:46
+*/
+public interface DgLampControlledHeartbeatService extends IService<DgLampControlledHeartbeat> {
+
+}

pole-service/src/main/java/com/zksy/pole/service/DgRelayControlService.java

@@ -0,0 +1,13 @@
+package com.zksy.pole.service;
+
+import com.zksy.pole.domain.po.DgRelayControl;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author hxb
+* @description 针对表【dg_relay_control(继电器控制)】的数据库操作Service
+* @createDate 2024-08-28 17:36:49
+*/
+public interface DgRelayControlService extends IService<DgRelayControl> {
+
+}

pole-service/src/main/java/com/zksy/pole/service/DgRelayTimingStrategyService.java

@@ -0,0 +1,13 @@
+package com.zksy.pole.service;
+
+import com.zksy.pole.domain.po.DgRelayTimingStrategy;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author hxb
+* @description 针对表【dg_relay_timing_strategy(继电器定时策略)】的数据库操作Service
+* @createDate 2024-08-28 17:36:52
+*/
+public interface DgRelayTimingStrategyService extends IService<DgRelayTimingStrategy> {
+
+}

pole-service/src/main/java/com/zksy/pole/service/DgReportEnvironmentalDataService.java

@@ -0,0 +1,13 @@
+package com.zksy.pole.service;
+
+import com.zksy.pole.domain.po.DgReportEnvironmentalData;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author hxb
+* @description 针对表【dg_report_environmental_data(网关以固定频率上报环境数据)】的数据库操作Service
+* @createDate 2024-08-28 17:36:54
+*/
+public interface DgReportEnvironmentalDataService extends IService<DgReportEnvironmentalData> {
+
+}

pole-service/src/main/java/com/zksy/pole/service/DgTimelyControlService.java

@@ -0,0 +1,13 @@
+package com.zksy.pole.service;
+
+import com.zksy.pole.domain.po.DgTimelyControl;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author hxb
+* @description 针对表【dg_timely_control(灯具及时控制)】的数据库操作Service
+* @createDate 2024-08-28 17:36:57
+*/
+public interface DgTimelyControlService extends IService<DgTimelyControl> {
+
+}

pole-service/src/main/java/com/zksy/pole/service/impl/DgEquipmentAlarmServiceImpl.java

@@ -0,0 +1,22 @@
+package com.zksy.pole.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.pole.domain.po.DgEquipmentAlarm;
+import com.zksy.pole.service.DgEquipmentAlarmService;
+import com.zksy.pole.mapper.DgEquipmentAlarmMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author hxb
+* @description 针对表【dg_equipment_alarm(设备上下线报警)】的数据库操作Service实现
+* @createDate 2024-08-28 17:35:16
+*/
+@Service
+public class DgEquipmentAlarmServiceImpl extends ServiceImpl<DgEquipmentAlarmMapper, DgEquipmentAlarm>
+    implements DgEquipmentAlarmService{
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/service/impl/DgEquipmentStatusServiceImpl.java

@@ -0,0 +1,22 @@
+package com.zksy.pole.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.pole.domain.po.DgEquipmentStatus;
+import com.zksy.pole.service.DgEquipmentStatusService;
+import com.zksy.pole.mapper.DgEquipmentStatusMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author hxb
+* @description 针对表【dg_equipment_status(灯控设备状态查询)】的数据库操作Service实现
+* @createDate 2024-08-28 17:36:37
+*/
+@Service
+public class DgEquipmentStatusServiceImpl extends ServiceImpl<DgEquipmentStatusMapper, DgEquipmentStatus>
+    implements DgEquipmentStatusService{
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/service/impl/DgGatewayRegistrationServiceImpl.java

@@ -0,0 +1,22 @@
+package com.zksy.pole.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.pole.domain.po.DgGatewayRegistration;
+import com.zksy.pole.mapper.DgGatewayRegistrationMapper;
+import com.zksy.pole.service.DgGatewayRegistrationService;
+import org.springframework.stereotype.Service;
+
+/**
+* @author hxb
+* @description 针对表【dg_gateway_registration(网关注册)】的数据库操作Service实现
+* @createDate 2024-08-28 17:24:07
+*/
+@Service
+public class DgGatewayRegistrationServiceImpl extends ServiceImpl<DgGatewayRegistrationMapper, DgGatewayRegistration>
+    implements DgGatewayRegistrationService {
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/service/impl/DgGatewayStrategyServiceImpl.java

@@ -0,0 +1,22 @@
+package com.zksy.pole.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.pole.domain.po.DgGatewayStrategy;
+import com.zksy.pole.service.DgGatewayStrategyService;
+import com.zksy.pole.mapper.DgGatewayStrategyMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author hxb
+* @description 针对表【dg_gateway_strategy(抄读网关场景策略\接收主动上报网关场景策略)】的数据库操作Service实现
+* @createDate 2024-08-28 17:36:42
+*/
+@Service
+public class DgGatewayStrategyServiceImpl extends ServiceImpl<DgGatewayStrategyMapper, DgGatewayStrategy>
+    implements DgGatewayStrategyService{
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/service/impl/DgLampControlledHeartbeatServiceImpl.java

@@ -0,0 +1,22 @@
+package com.zksy.pole.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.pole.domain.po.DgLampControlledHeartbeat;
+import com.zksy.pole.service.DgLampControlledHeartbeatService;
+import com.zksy.pole.mapper.DgLampControlledHeartbeatMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author hxb
+* @description 针对表【dg_lamp_controlled_heartbeat(灯控设备心跳)】的数据库操作Service实现
+* @createDate 2024-08-28 17:36:46
+*/
+@Service
+public class DgLampControlledHeartbeatServiceImpl extends ServiceImpl<DgLampControlledHeartbeatMapper, DgLampControlledHeartbeat>
+    implements DgLampControlledHeartbeatService{
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/service/impl/DgRelayControlServiceImpl.java

@@ -0,0 +1,22 @@
+package com.zksy.pole.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.pole.domain.po.DgRelayControl;
+import com.zksy.pole.service.DgRelayControlService;
+import com.zksy.pole.mapper.DgRelayControlMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author hxb
+* @description 针对表【dg_relay_control(继电器控制)】的数据库操作Service实现
+* @createDate 2024-08-28 17:36:49
+*/
+@Service
+public class DgRelayControlServiceImpl extends ServiceImpl<DgRelayControlMapper, DgRelayControl>
+    implements DgRelayControlService{
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/service/impl/DgRelayTimingStrategyServiceImpl.java

@@ -0,0 +1,22 @@
+package com.zksy.pole.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.pole.domain.po.DgRelayTimingStrategy;
+import com.zksy.pole.service.DgRelayTimingStrategyService;
+import com.zksy.pole.mapper.DgRelayTimingStrategyMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author hxb
+* @description 针对表【dg_relay_timing_strategy(继电器定时策略)】的数据库操作Service实现
+* @createDate 2024-08-28 17:36:52
+*/
+@Service
+public class DgRelayTimingStrategyServiceImpl extends ServiceImpl<DgRelayTimingStrategyMapper, DgRelayTimingStrategy>
+    implements DgRelayTimingStrategyService{
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/service/impl/DgReportEnvironmentalDataServiceImpl.java

@@ -0,0 +1,22 @@
+package com.zksy.pole.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.pole.domain.po.DgReportEnvironmentalData;
+import com.zksy.pole.service.DgReportEnvironmentalDataService;
+import com.zksy.pole.mapper.DgReportEnvironmentalDataMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author hxb
+* @description 针对表【dg_report_environmental_data(网关以固定频率上报环境数据)】的数据库操作Service实现
+* @createDate 2024-08-28 17:36:54
+*/
+@Service
+public class DgReportEnvironmentalDataServiceImpl extends ServiceImpl<DgReportEnvironmentalDataMapper, DgReportEnvironmentalData>
+    implements DgReportEnvironmentalDataService{
+
+}
+
+
+
+

pole-service/src/main/java/com/zksy/pole/service/impl/DgTimelyControlServiceImpl.java

@@ -0,0 +1,22 @@
+package com.zksy.pole.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.pole.domain.po.DgTimelyControl;
+import com.zksy.pole.service.DgTimelyControlService;
+import com.zksy.pole.mapper.DgTimelyControlMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author hxb
+* @description 针对表【dg_timely_control(灯具及时控制)】的数据库操作Service实现
+* @createDate 2024-08-28 17:36:57
+*/
+@Service
+public class DgTimelyControlServiceImpl extends ServiceImpl<DgTimelyControlMapper, DgTimelyControl>
+    implements DgTimelyControlService{
+
+}
+
+
+
+

pole-service/src/main/resources/mapper/DgEquipmentAlarmMapper.xml

@@ -0,0 +1,27 @@
+<?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.zksy.pole.mapper.DgEquipmentAlarmMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.pole.domain.po.DgEquipmentAlarm">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="cmd" column="cmd" jdbcType="BIGINT"/>
+            <result property="dateTime" column="date_time" jdbcType="TIMESTAMP"/>
+            <result property="ip" column="ip" jdbcType="VARCHAR"/>
+            <result property="deviceName" column="device_name" jdbcType="VARCHAR"/>
+            <result property="type" column="type" jdbcType="VARCHAR"/>
+            <result property="status" column="status" jdbcType="VARCHAR"/>
+            <result property="createBy" column="create_by" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,cmd,date_time,
+        ip,device_name,type,
+        status,create_by,create_time,
+        update_by,update_time
+    </sql>
+</mapper>

pole-service/src/main/resources/mapper/DgEquipmentStatusMapper.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="com.zksy.pole.mapper.DgEquipmentStatusMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.pole.domain.po.DgEquipmentStatus">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="cmd" column="cmd" jdbcType="BIGINT"/>
+            <result property="packageId" column="package_id" jdbcType="VARCHAR"/>
+            <result property="params" column="params" jdbcType="OTHER"/>
+            <result property="createBy" column="create_by" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,cmd,package_id,
+        params,create_by,create_time,
+        update_by,update_time
+    </sql>
+</mapper>

pole-service/src/main/resources/mapper/DgGatewayRegistrationMapper.xml

@@ -0,0 +1,27 @@
+<?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.zksy.pole.mapper.DgGatewayRegistrationMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.pole.domain.po.DgGatewayRegistration">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="cmd" column="cmd" jdbcType="BIGINT"/>
+            <result property="dateTime" column="date_time" jdbcType="TIMESTAMP"/>
+            <result property="longitude" column="longitude" jdbcType="DOUBLE"/>
+            <result property="latitude" column="latitude" jdbcType="DOUBLE"/>
+            <result property="deviceType" column="device_type" jdbcType="VARCHAR"/>
+            <result property="mac" column="mac" jdbcType="VARCHAR"/>
+            <result property="createBy" column="create_by" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,cmd,date_time,
+        longitude,latitude,device_type,
+        mac,create_by,create_time,
+        update_by,update_time
+    </sql>
+</mapper>

pole-service/src/main/resources/mapper/DgGatewayStrategyMapper.xml

@@ -0,0 +1,24 @@
+<?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.zksy.pole.mapper.DgGatewayStrategyMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.pole.domain.po.DgGatewayStrategy">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="cmd" column="cmd" jdbcType="BIGINT"/>
+            <result property="packageId" column="package_id" jdbcType="VARCHAR"/>
+            <result property="lightNum" column="light_num" jdbcType="VARCHAR"/>
+            <result property="params" column="params" jdbcType="OTHER"/>
+            <result property="createBy" column="create_by" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,cmd,package_id,
+        light_num,params,create_by,
+        create_time,update_by,update_time
+    </sql>
+</mapper>

pole-service/src/main/resources/mapper/DgLampControlledHeartbeatMapper.xml

@@ -0,0 +1,24 @@
+<?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.zksy.pole.mapper.DgLampControlledHeartbeatMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.pole.domain.po.DgLampControlledHeartbeat">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="cmd" column="cmd" jdbcType="BIGINT"/>
+            <result property="dateTime" column="date_time" jdbcType="TIMESTAMP"/>
+            <result property="heardId" column="heard_id" jdbcType="BIGINT"/>
+            <result property="params" column="params" jdbcType="OTHER"/>
+            <result property="createBy" column="create_by" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,cmd,date_time,
+        heard_id,params,create_by,
+        create_time,update_by,update_time
+    </sql>
+</mapper>

pole-service/src/main/resources/mapper/DgRelayControlMapper.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="com.zksy.pole.mapper.DgRelayControlMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.pole.domain.po.DgRelayControl">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="cmd" column="cmd" jdbcType="BIGINT"/>
+            <result property="packageId" column="package_id" jdbcType="VARCHAR"/>
+            <result property="params" column="params" jdbcType="OTHER"/>
+            <result property="createBy" column="create_by" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,cmd,package_id,
+        params,create_by,create_time,
+        update_by,update_time
+    </sql>
+</mapper>

pole-service/src/main/resources/mapper/DgRelayTimingStrategyMapper.xml

@@ -0,0 +1,24 @@
+<?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.zksy.pole.mapper.DgRelayTimingStrategyMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.pole.domain.po.DgRelayTimingStrategy">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="cmd" column="cmd" jdbcType="BIGINT"/>
+            <result property="packageId" column="package_id" jdbcType="VARCHAR"/>
+            <result property="index" column="index" jdbcType="VARCHAR"/>
+            <result property="params" column="params" jdbcType="OTHER"/>
+            <result property="createBy" column="create_by" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,cmd,package_id,
+        index,params,create_by,
+        create_time,update_by,update_time
+    </sql>
+</mapper>

pole-service/src/main/resources/mapper/DgReportEnvironmentalDataMapper.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="com.zksy.pole.mapper.DgReportEnvironmentalDataMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.pole.domain.po.DgReportEnvironmentalData">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="cmd" column="cmd" jdbcType="BIGINT"/>
+            <result property="dateTime" column="date_time" jdbcType="TIMESTAMP"/>
+            <result property="flag" column="flag" jdbcType="CHAR"/>
+            <result property="sersorId" column="sersor_id" jdbcType="CHAR"/>
+            <result property="params" column="params" jdbcType="OTHER"/>
+            <result property="params2" column="params2" jdbcType="OTHER"/>
+            <result property="params3" column="params3" jdbcType="OTHER"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,cmd,date_time,
+        flag,sersor_id,params,
+        params2,params3
+    </sql>
+</mapper>

pole-service/src/main/resources/mapper/DgTimelyControlMapper.xml

@@ -0,0 +1,24 @@
+<?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.zksy.pole.mapper.DgTimelyControlMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.pole.domain.po.DgTimelyControl">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="cmd" column="cmd" jdbcType="BIGINT"/>
+            <result property="code" column="code" jdbcType="INTEGER"/>
+            <result property="packageId" column="package_id" jdbcType="VARCHAR"/>
+            <result property="params" column="params" jdbcType="OTHER"/>
+            <result property="createBy" column="create_by" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,cmd,code,
+        package_id,params,create_by,
+        create_time,update_by,update_time
+    </sql>
+</mapper>