新增振动数据转换

energy-manage-common/src/main/java/com/energy/manage/common/mapper/MyMapper.java

@@ -11,5 +11,5 @@ import tk.mybatis.mapper.common.MySqlMapper;
  */
 public interface MyMapper<T> extends Mapper<T>, MySqlMapper<T> {
     //TODO
-    //FIXME 特别注意，该接口不能被扫描到，否则会出错
-}
+    //FIXME 特别注意，必须继承该接口，否则mapper无法被扫描到
+}

energy-manage-common/src/main/java/com/energy/manage/common/po/wavedatatransfer/WaveDataTransfer.java

@@ -0,0 +1,84 @@
+package com.energy.manage.common.po.wavedatatransfer;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import javax.persistence.Table;
+import java.util.Date;
+
+@Table(name = "wave_data_transfer")
+@Data
+@Accessors(chain = true)
+public class WaveDataTransfer {
+
+    /**
+     * 主键id
+     */
+    private Long id;
+
+    /**
+     * 风场编号
+     */
+    private String fieldCode;
+
+    /**
+     * 转换地址
+     */
+    private String transferAddr;
+
+    /**
+     * 转换状态 -1：未转换（默认状态）0：转换中 1转换完成 2：转换异常
+     */
+    private Byte trasferStatus;
+
+    /**
+     * 错误编码
+     */
+    private String errCode;
+
+    /**
+     * 错误信息
+     */
+    private String errInfo;
+
+    /**
+     * 转换开始时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8")
+    private Date transferStartTime;
+
+    /**
+     * 转换结束时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8")
+    private Date transferFinishTime;
+
+    /**
+     * 转换进度
+     */
+    private Integer transferProgress;
+
+    /**
+     * 创建人
+     */
+    private Integer createBy;
+
+    /**
+     * 创建时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8")
+    private Date createTime;
+
+    /**
+     * 更新人
+     */
+    private Integer updateBy;
+
+    /**
+     * 更新时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8")
+    private Date updateTime;
+
+}

energy-manage-service/src/main/java/com/energy/manage/common/po/wavedatatransfer/WaveDataTransfer.java

@@ -0,0 +1,138 @@
+package com.energy.manage.common.po.wavedatatransfer;
+
+import java.io.Serializable;
+import java.util.Date;
+
+public class WaveDataTransfer implements Serializable {
+    private Long id;
+
+    private String fieldCode;
+
+    private String transferAddr;
+
+    private Byte trasferStatus;
+
+    private String errCode;
+
+    private String errInfo;
+
+    private Date transferStartTime;
+
+    private Date transferFinishTime;
+
+    private Integer transferProgress;
+
+    private Integer createBy;
+
+    private Date createTime;
+
+    private Integer updateBy;
+
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getFieldCode() {
+        return fieldCode;
+    }
+
+    public void setFieldCode(String fieldCode) {
+        this.fieldCode = fieldCode == null ? null : fieldCode.trim();
+    }
+
+    public String getTransferAddr() {
+        return transferAddr;
+    }
+
+    public void setTransferAddr(String transferAddr) {
+        this.transferAddr = transferAddr == null ? null : transferAddr.trim();
+    }
+
+    public Byte getTrasferStatus() {
+        return trasferStatus;
+    }
+
+    public void setTrasferStatus(Byte trasferStatus) {
+        this.trasferStatus = trasferStatus;
+    }
+
+    public String getErrCode() {
+        return errCode;
+    }
+
+    public void setErrCode(String errCode) {
+        this.errCode = errCode == null ? null : errCode.trim();
+    }
+
+    public String getErrInfo() {
+        return errInfo;
+    }
+
+    public void setErrInfo(String errInfo) {
+        this.errInfo = errInfo == null ? null : errInfo.trim();
+    }
+
+    public Date getTransferStartTime() {
+        return transferStartTime;
+    }
+
+    public void setTransferStartTime(Date transferStartTime) {
+        this.transferStartTime = transferStartTime;
+    }
+
+    public Date getTransferFinishTime() {
+        return transferFinishTime;
+    }
+
+    public void setTransferFinishTime(Date transferFinishTime) {
+        this.transferFinishTime = transferFinishTime;
+    }
+
+    public Integer getTransferProgress() {
+        return transferProgress;
+    }
+
+    public void setTransferProgress(Integer transferProgress) {
+        this.transferProgress = transferProgress;
+    }
+
+    public Integer getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(Integer createBy) {
+        this.createBy = createBy;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public Integer getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(Integer updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getUpdateTime() {
+        return updateTime;
+    }
+
+    public void setUpdateTime(Date updateTime) {
+        this.updateTime = updateTime;
+    }
+}

energy-manage-service/src/main/java/com/energy/manage/service/controller/wavedatatransfer/WaveDatatransferController.java

@@ -0,0 +1,29 @@
+package com.energy.manage.service.controller.wavedatatransfer;
+
+import com.energy.manage.common.base.Page;
+import com.energy.manage.common.reponse.ResultResp;
+import com.energy.manage.service.controller.base.BaseServiceController;
+import com.energy.manage.service.domain.dto.wavedatatransfer.WaveDatatransferDto;
+import com.energy.manage.service.domain.vo.wavedatatransfer.WaveDatatransferVo;
+import com.energy.manage.service.service.wavedatatransfer.WaveDatatransferServce;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @author chy
+ * @date 2024/11/7 16:08
+ * @desc
+ */
+@RestController
+@RequestMapping("//waveDataTransfer")
+public class WaveDatatransferController extends BaseServiceController {
+
+    @Autowired
+    private WaveDatatransferServce waveDatatransferServce;
+
+
+    @GetMapping("/queryDataTransfer")
+    public ResultResp<Page<WaveDatatransferVo>> queryDataTransfer(@ModelAttribute WaveDatatransferDto waveDatatransferDto) {
+        return pageResult(waveDatatransferServce.queryDataTransfer(waveDatatransferDto), waveDatatransferDto);
+    }
+}

energy-manage-service/src/main/java/com/energy/manage/service/domain/dto/wavedatatransfer/WaveDatatransferDto.java

@@ -0,0 +1,46 @@
+package com.energy.manage.service.domain.dto.wavedatatransfer;
+
+import com.energy.manage.service.domain.dto.BaseDto;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.util.Date;
+
+/**
+ * @author chy
+ * @date 2024/11/7 16:12
+ * @desc
+ */
+@Data
+@Accessors(chain = true)
+public class WaveDatatransferDto extends BaseDto {
+
+    /**
+     * 风场编号
+     */
+    private String fieldCode;
+
+    /**
+     * 转换地址
+     */
+    private String transferAddr;
+
+    /**
+     * 转换状态 -1：未转换（默认状态）0：转换中 1转换完成 2：转换异常
+     */
+    private Byte trasferStatus;
+
+    /**
+     * 转换开始时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8")
+    private Date transferStartTime;
+
+    /**
+     * 转换结束时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8")
+    private Date transferFinishTime;
+
+}

energy-manage-service/src/main/java/com/energy/manage/service/domain/vo/wavedatatransfer/WaveDatatransferVo.java

@@ -0,0 +1,81 @@
+package com.energy.manage.service.domain.vo.wavedatatransfer;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.util.Date;
+
+/**
+ * @author chy
+ * @date 2024/11/7 16:16
+ * @desc
+ */
+@Data
+@Accessors(chain = true)
+public class WaveDatatransferVo {
+
+    /**
+     * 风场编号
+     */
+    private String fieldCode;
+
+    /**
+     * 转换地址
+     */
+    private String transferAddr;
+
+    /**
+     * 转换状态 -1：未转换（默认状态）0：转换中 1转换完成 2：转换异常
+     */
+    private Byte trasferStatus;
+
+    /**
+     * 错误编码
+     */
+    private String errCode;
+
+    /**
+     * 错误信息
+     */
+    private String errInfo;
+
+    /**
+     * 转换开始时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8")
+    private Date transferStartTime;
+
+    /**
+     * 转换结束时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8")
+    private Date transferFinishTime;
+
+    /**
+     * 转换进度
+     */
+    private Integer transferProgress;
+
+    /**
+     * 创建人
+     */
+    private Integer createBy;
+
+    /**
+     * 创建时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8")
+    private Date createTime;
+
+    /**
+     * 更新人
+     */
+    private Integer updateBy;
+
+    /**
+     * 更新时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8")
+    private Date updateTime;
+}

energy-manage-service/src/main/java/com/energy/manage/service/mappers/wavedatatransfer/WaveDataTransferMapper.java

@@ -0,0 +1,25 @@
+package com.energy.manage.service.mappers.wavedatatransfer;
+
+import com.energy.manage.common.mapper.MyMapper;
+import com.energy.manage.common.po.wavedatatransfer.WaveDataTransfer;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface WaveDataTransferMapper extends MyMapper<WaveDataTransfer> {
+
+    int deleteByPrimaryKey(Long id);
+
+    @Override
+    int insert(WaveDataTransfer record);
+
+    @Override
+    int insertSelective(WaveDataTransfer record);
+
+    WaveDataTransfer selectByPrimaryKey(Long id);
+
+    @Override
+    int updateByPrimaryKeySelective(WaveDataTransfer record);
+
+    @Override
+    int updateByPrimaryKey(WaveDataTransfer record);
+}

energy-manage-service/src/main/java/com/energy/manage/service/service/wavedatatransfer/WaveDatatransferServce.java

@@ -0,0 +1,18 @@
+package com.energy.manage.service.service.wavedatatransfer;
+
+import com.energy.manage.service.domain.dto.wavedatatransfer.WaveDatatransferDto;
+import com.energy.manage.service.domain.vo.wavedatatransfer.WaveDatatransferVo;
+
+import java.util.List;
+
+/**
+ * @author chy
+ * @date 2024/11/7 16:23
+ * @desc
+ */
+public interface WaveDatatransferServce {
+
+
+    List<WaveDatatransferVo> queryDataTransfer(WaveDatatransferDto waveDatatransferDto);
+
+}

energy-manage-service/src/main/java/com/energy/manage/service/service/wavedatatransfer/impl/WaveDatatransferServceImpl.java

@@ -0,0 +1,31 @@
+package com.energy.manage.service.service.wavedatatransfer.impl;
+
+import com.energy.manage.service.domain.dto.wavedatatransfer.WaveDatatransferDto;
+import com.energy.manage.service.domain.vo.wavedatatransfer.WaveDatatransferVo;
+import com.energy.manage.service.mappers.wavedatatransfer.WaveDataTransferMapper;
+import com.energy.manage.service.service.wavedatatransfer.WaveDatatransferServce;
+import com.github.pagehelper.PageHelper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @author chy
+ * @date 2024/11/7 16:23
+ * @desc
+ */
+@Service
+public class WaveDatatransferServceImpl implements WaveDatatransferServce {
+
+    @Autowired
+    private WaveDataTransferMapper waveDataTransferMapper;
+
+    @Override
+    public List<WaveDatatransferVo> queryDataTransfer( WaveDatatransferDto waveDatatransferDto) {
+        PageHelper.startPage(waveDatatransferDto.getPageNum(), waveDatatransferDto.getPageSize());
+//        return waveDataTransferMapper.selectByCondition(waveDatatransferDto);
+        return null;
+    }
+
+}

energy-manage-service/src/main/resources/mybatis/wavedatatransfer/WaveDataTransferMapper.xml

@@ -0,0 +1,195 @@
+<?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.energy.manage.service.mappers.wavedatatransfer.WaveDataTransferMapper">
+  <resultMap id="BaseResultMap" type="com.energy.manage.common.po.wavedatatransfer.WaveDataTransfer">
+    <id column="id" jdbcType="BIGINT" property="id" />
+    <result column="field_code" jdbcType="VARCHAR" property="fieldCode" />
+    <result column="transfer_addr" jdbcType="VARCHAR" property="transferAddr" />
+    <result column="trasfer_status" jdbcType="TINYINT" property="trasferStatus" />
+    <result column="err_code" jdbcType="VARCHAR" property="errCode" />
+    <result column="err_info" jdbcType="VARCHAR" property="errInfo" />
+    <result column="transfer_start_time" jdbcType="TIMESTAMP" property="transferStartTime" />
+    <result column="transfer_finish_time" jdbcType="TIMESTAMP" property="transferFinishTime" />
+    <result column="transfer_progress" jdbcType="INTEGER" property="transferProgress" />
+    <result column="create_by" jdbcType="INTEGER" property="createBy" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="update_by" jdbcType="INTEGER" property="updateBy" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, field_code, transfer_addr, trasfer_status, err_code, err_info, transfer_start_time,
+    transfer_finish_time, transfer_progress, create_by, create_time, update_by, update_time
+  </sql>
+
+  <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
+    select
+    <include refid="Base_Column_List" />
+    from wave_data_transfer
+    where id = #{id,jdbcType=BIGINT}
+  </select>
+
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
+    delete from wave_data_transfer
+    where id = #{id,jdbcType=BIGINT}
+  </delete>
+
+  <insert id="insert" parameterType="com.energy.manage.common.po.wavedatatransfer.WaveDataTransfer">
+    insert into wave_data_transfer (id, field_code, transfer_addr,
+      trasfer_status, err_code, err_info,
+      transfer_start_time, transfer_finish_time,
+      transfer_progress, create_by, create_time,
+      update_by, update_time)
+    values (#{id,jdbcType=BIGINT}, #{fieldCode,jdbcType=VARCHAR}, #{transferAddr,jdbcType=VARCHAR},
+      #{trasferStatus,jdbcType=TINYINT}, #{errCode,jdbcType=VARCHAR}, #{errInfo,jdbcType=VARCHAR},
+      #{transferStartTime,jdbcType=TIMESTAMP}, #{transferFinishTime,jdbcType=TIMESTAMP},
+      #{transferProgress,jdbcType=INTEGER}, #{createBy,jdbcType=INTEGER}, #{createTime,jdbcType=TIMESTAMP},
+      #{updateBy,jdbcType=INTEGER}, #{updateTime,jdbcType=TIMESTAMP})
+  </insert>
+
+  <insert id="insertSelective" parameterType="com.energy.manage.common.po.wavedatatransfer.WaveDataTransfer">
+    insert into wave_data_transfer
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="fieldCode != null">
+        field_code,
+      </if>
+      <if test="transferAddr != null">
+        transfer_addr,
+      </if>
+      <if test="trasferStatus != null">
+        trasfer_status,
+      </if>
+      <if test="errCode != null">
+        err_code,
+      </if>
+      <if test="errInfo != null">
+        err_info,
+      </if>
+      <if test="transferStartTime != null">
+        transfer_start_time,
+      </if>
+      <if test="transferFinishTime != null">
+        transfer_finish_time,
+      </if>
+      <if test="transferProgress != null">
+        transfer_progress,
+      </if>
+      <if test="createBy != null">
+        create_by,
+      </if>
+      <if test="createTime != null">
+        create_time,
+      </if>
+      <if test="updateBy != null">
+        update_by,
+      </if>
+      <if test="updateTime != null">
+        update_time,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=BIGINT},
+      </if>
+      <if test="fieldCode != null">
+        #{fieldCode,jdbcType=VARCHAR},
+      </if>
+      <if test="transferAddr != null">
+        #{transferAddr,jdbcType=VARCHAR},
+      </if>
+      <if test="trasferStatus != null">
+        #{trasferStatus,jdbcType=TINYINT},
+      </if>
+      <if test="errCode != null">
+        #{errCode,jdbcType=VARCHAR},
+      </if>
+      <if test="errInfo != null">
+        #{errInfo,jdbcType=VARCHAR},
+      </if>
+      <if test="transferStartTime != null">
+        #{transferStartTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="transferFinishTime != null">
+        #{transferFinishTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="transferProgress != null">
+        #{transferProgress,jdbcType=INTEGER},
+      </if>
+      <if test="createBy != null">
+        #{createBy,jdbcType=INTEGER},
+      </if>
+      <if test="createTime != null">
+        #{createTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="updateBy != null">
+        #{updateBy,jdbcType=INTEGER},
+      </if>
+      <if test="updateTime != null">
+        #{updateTime,jdbcType=TIMESTAMP},
+      </if>
+    </trim>
+  </insert>
+
+  <update id="updateByPrimaryKeySelective" parameterType="com.energy.manage.common.po.wavedatatransfer.WaveDataTransfer">
+    update wave_data_transfer
+    <set>
+      <if test="fieldCode != null">
+        field_code = #{fieldCode,jdbcType=VARCHAR},
+      </if>
+      <if test="transferAddr != null">
+        transfer_addr = #{transferAddr,jdbcType=VARCHAR},
+      </if>
+      <if test="trasferStatus != null">
+        trasfer_status = #{trasferStatus,jdbcType=TINYINT},
+      </if>
+      <if test="errCode != null">
+        err_code = #{errCode,jdbcType=VARCHAR},
+      </if>
+      <if test="errInfo != null">
+        err_info = #{errInfo,jdbcType=VARCHAR},
+      </if>
+      <if test="transferStartTime != null">
+        transfer_start_time = #{transferStartTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="transferFinishTime != null">
+        transfer_finish_time = #{transferFinishTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="transferProgress != null">
+        transfer_progress = #{transferProgress,jdbcType=INTEGER},
+      </if>
+      <if test="createBy != null">
+        create_by = #{createBy,jdbcType=INTEGER},
+      </if>
+      <if test="createTime != null">
+        create_time = #{createTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="updateBy != null">
+        update_by = #{updateBy,jdbcType=INTEGER},
+      </if>
+      <if test="updateTime != null">
+        update_time = #{updateTime,jdbcType=TIMESTAMP},
+      </if>
+    </set>
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+
+  <update id="updateByPrimaryKey" parameterType="com.energy.manage.common.po.wavedatatransfer.WaveDataTransfer">
+    update wave_data_transfer
+    set field_code = #{fieldCode,jdbcType=VARCHAR},
+      transfer_addr = #{transferAddr,jdbcType=VARCHAR},
+      trasfer_status = #{trasferStatus,jdbcType=TINYINT},
+      err_code = #{errCode,jdbcType=VARCHAR},
+      err_info = #{errInfo,jdbcType=VARCHAR},
+      transfer_start_time = #{transferStartTime,jdbcType=TIMESTAMP},
+      transfer_finish_time = #{transferFinishTime,jdbcType=TIMESTAMP},
+      transfer_progress = #{transferProgress,jdbcType=INTEGER},
+      create_by = #{createBy,jdbcType=INTEGER},
+      create_time = #{createTime,jdbcType=TIMESTAMP},
+      update_by = #{updateBy,jdbcType=INTEGER},
+      update_time = #{updateTime,jdbcType=TIMESTAMP}
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+
+</mapper>