td engine增加场站表

neim-biz/src/main/java/com/jiayue/biz/domain/StationEnvironmentData.java

@@ -0,0 +1,124 @@
+package com.jiayue.biz.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.sql.Timestamp;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class StationEnvironmentData {
+
+    /**
+     * 时间戳
+     **/
+    private Timestamp ts;
+    /**
+     * 温度瞬时值（℃）
+     **/
+    private Float tInst;
+    /**
+     * 温度最大值（℃）
+     **/
+    private Float tMax;
+    /**
+     * 温度最小值（℃）
+     **/
+    private Float tMin;
+    /**
+     * 温度平均值（℃）
+     **/
+    private Float tAve;
+    /**
+     * 温度标准差（℃）
+     **/
+    private Float tSta;
+    /**
+     * 温度实时值（℃）
+     **/
+    private Float tNow;
+    /**
+     * 湿度瞬时值（%）
+     **/
+    private Float rhInst;
+    /**
+     * 湿度最大值（%）
+     **/
+    private Float rhMax;
+    /**
+     * 湿度最小值（%）
+     **/
+    private Float rhMin;
+    /**
+     * 湿度平均值（%）
+     **/
+    private Float rhAve;
+    /**
+     * 湿度标准差（%）
+     **/
+    private Float rhSta;
+    /**
+     * 湿度实时值（%）
+     **/
+    private Float rhNow;
+    /**
+     * 气压瞬时值（hPa）
+     **/
+    private Float paInst;
+    /**
+     * 气压最大值（hPa）
+     **/
+    private Float paMax;
+    /**
+     * 气压最小值（hPa）
+     **/
+    private Float paMin;
+    /**
+     * 气压平均值（hPa）
+     **/
+    private Float paAve;
+    /**
+     * 气压标准差（hPa）
+     **/
+    private Float paSta;
+    /**
+     * 电压实时值（hPa）
+     **/
+    private Float paNow;
+    /**
+     * 电压瞬时值（hPa）
+     **/
+    private Float vInst;
+    /**
+     * 电压最大值（hPa）
+     **/
+    private Float vMax;
+    /**
+     * 电压最小值（hPa）
+     **/
+    private Float vMin;
+    /**
+     * 电压平均值（hPa）
+     **/
+    private Float vAve;
+    /**
+     * 电压标准差（hPa）
+     **/
+    private Float vSta;
+    /**
+     * 电压实时值（hPa）
+     **/
+    private Float vNow;
+    /**
+     * 空气密度（Kg/m³）
+     **/
+    private Float airDensity;
+    /**
+     * 设备ID
+     **/
+    private String equipmentId;
+
+
+}

neim-biz/src/main/java/com/jiayue/biz/domain/StationWindData.java

@@ -0,0 +1,83 @@
+package com.jiayue.biz.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.sql.Timestamp;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class StationWindData {
+
+    /**
+     * 时间戳
+     **/
+    private Timestamp ts;
+    /**
+     * 风速瞬时值（m/s）
+     **/
+    private Float wsInst;
+    /**
+     * 风速最大值（m/s）
+     **/
+    private Float wsMax;
+    /**
+     * 风速最小值（m/s）
+     **/
+    private Float wsMin;
+    /**
+     * 风速平均值（m/s）
+     **/
+    private Float wsAve;
+    /**
+     * 风速极大值（m/s）
+     **/
+    private Float wsGreat;
+    /**
+     * 风速阵风（m/s）
+     **/
+    private Float wsGust;
+    /**
+     * 风速标准差（m/s）
+     **/
+    private Float wsSta;
+    /**
+     * 风向瞬时值（°）
+     **/
+    private Float wdInst;
+    /**
+     * 风向最大值（°）
+     **/
+    private Float wdMax;
+    /**
+     * 风向最小值（°）
+     **/
+    private Float wdMin;
+    /**
+     * 风向平均值（°）
+     **/
+    private Float wdAve;
+    /**
+     * 风向标准差（°）
+     **/
+    private Float wdSta;
+    /**
+     * 风向实时值（°）
+     **/
+    private Float wdNow;
+    /**
+     * 最大风速时风向（°）
+     **/
+    private Float wdOnWs;
+    /**
+     * 设备ID
+     **/
+    private String equipmentId;
+    /**
+     * 层高
+     **/
+    private String layerHeight;
+
+}

neim-biz/src/main/java/com/jiayue/biz/mapper/StationEnvironmentDataMapper.java

@@ -0,0 +1,23 @@
+package com.jiayue.biz.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.jiayue.biz.domain.ProphaseWeatherData;
+import com.jiayue.biz.domain.StationEnvironmentData;
+import org.apache.ibatis.annotations.Insert;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@DS("tdengine")
+public interface StationEnvironmentDataMapper extends BaseMapper<StationEnvironmentData> {
+
+    @Insert("<script>" +
+            "insert into environment_${equipmentId} USING station_environment_data TAGS(${equipmentId}) values " +
+            "<foreach collection='stationEnvironmentData' item='p' separator=','> " +
+            "(#{p.ts},#{p.tInst},#{p.tMax},#{p.tMin},#{p.tAve},#{p.tSta},#{p.tNow},#{p.rhInst},#{p.rhMax},#{p.rhMin},#{p.rhAve},#{p.rhSta},#{p.rhNow},#{p.paInst},#{p.paMax},#{p.paMin},#{p.paAve},#{p.paSta},#{p.paNow},#{p.vInst},#{p.vMax},#{p.vMin},#{p.vAve},#{p.vSta},#{p.vNow},#{p.airDensity}) " +
+            "</foreach> " +
+            "</script>")
+    int insertSplice(@Param("stationEnvironmentData") List<StationEnvironmentData> stationEnvironmentData, @Param("equipmentId") String equipmentId);
+
+}

neim-biz/src/main/java/com/jiayue/biz/mapper/StationWindDataMapper.java

@@ -0,0 +1,23 @@
+package com.jiayue.biz.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.jiayue.biz.domain.StationWindData;
+import org.apache.ibatis.annotations.Insert;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@DS("tdengine")
+public interface StationWindDataMapper extends BaseMapper<StationWindData> {
+
+    @Insert("<script>" +
+            "insert into wind_${equipmentId}_${layerHeight} USING station_wind_data TAGS(#{equipmentId}, #{layerHeight}) values " +
+            "<foreach collection='stationWindData' item='p' separator=','> " +
+            "(#{p.ts},#{p.wsInst},#{p.wsMax},#{p.wsMin},#{p.wsAve},#{p.wsGreat},#{p.wsGust},#{p.wsSta},#{p.wdInst},#{p.wdMax},#{p.wdMin},#{p.wdAve},#{p.wdSta},#{p.wdNow},#{p.wdOnWs}) " +
+            "</foreach> " +
+            "</script>")
+    int insertSplice(@Param("stationWindData") List<StationWindData> stationWindData, @Param("equipmentId") String equipmentId, @Param("layerHeight") String layerHeight);
+
+
+}

neim-biz/src/main/java/com/jiayue/biz/service/StationEnvironmentDataService.java

@@ -0,0 +1,13 @@
+package com.jiayue.biz.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.jiayue.biz.domain.StationEnvironmentData;
+
+import java.util.List;
+
+public interface StationEnvironmentDataService extends IService<StationEnvironmentData> {
+
+    //批量插入
+    int saveStationEnvironmentDataList(List<StationEnvironmentData> stationEnvironmentDataList, String equipmentId);
+
+}

neim-biz/src/main/java/com/jiayue/biz/service/StationWindDataService.java

@@ -0,0 +1,13 @@
+package com.jiayue.biz.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.jiayue.biz.domain.StationWindData;
+
+import java.util.List;
+
+public interface StationWindDataService extends IService<StationWindData> {
+
+    //批量插入
+    int saveStationWindDataList(List<StationWindData> stationWindDataList, String equipmentId, String height);
+
+}

neim-biz/src/main/java/com/jiayue/biz/service/impl/StationEnvironmentDataServiceImpl.java

@@ -0,0 +1,22 @@
+package com.jiayue.biz.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.jiayue.biz.domain.StationEnvironmentData;
+import com.jiayue.biz.mapper.StationEnvironmentDataMapper;
+import com.jiayue.biz.service.StationEnvironmentDataService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+
+@Service
+public class StationEnvironmentDataServiceImpl extends ServiceImpl<StationEnvironmentDataMapper, StationEnvironmentData> implements StationEnvironmentDataService {
+
+
+    //批量插入
+    public int saveStationEnvironmentDataList(List<StationEnvironmentData> stationEnvironmentDataList, String equipmentId) {
+        return baseMapper.insertSplice(stationEnvironmentDataList, equipmentId);
+    }
+
+
+}

neim-biz/src/main/java/com/jiayue/biz/service/impl/StationWindDataServiceImpl.java

@@ -0,0 +1,20 @@
+package com.jiayue.biz.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.jiayue.biz.domain.StationWindData;
+import com.jiayue.biz.mapper.StationWindDataMapper;
+import com.jiayue.biz.service.StationWindDataService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class StationWindDataServiceImpl extends ServiceImpl<StationWindDataMapper, StationWindData> implements StationWindDataService {
+
+    //批量插入
+    public int saveStationWindDataList(List<StationWindData> stationWindDataList, String equipmentId, String height) {
+        return baseMapper.insertSplice(stationWindDataList, equipmentId, height);
+    }
+
+}