main
parent
09c1251b33
commit
d5a5886f57
@ -1,15 +0,0 @@
|
||||
package com.xydl.config;
|
||||
|
||||
import com.alibaba.druid.pool.DruidDataSource;
|
||||
import org.springframework.boot.context.properties.ConfigurationProperties;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
|
||||
@Configuration
|
||||
public class DruidConfig {
|
||||
@ConfigurationProperties(prefix = "spring.datasource")
|
||||
@Bean
|
||||
public DruidDataSource getDurid(){
|
||||
return new DruidDataSource();
|
||||
}
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.xydl.config;
|
||||
|
||||
|
||||
import com.baomidou.mybatisplus.autoconfigure.ConfigurationCustomizer;
|
||||
import com.baomidou.mybatisplus.core.MybatisConfiguration;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
|
||||
@Configuration
|
||||
public class MyBatisConfig {
|
||||
|
||||
public ConfigurationCustomizer configurationCustomizer(){
|
||||
return new ConfigurationCustomizer() {
|
||||
@Override
|
||||
public void customize(MybatisConfiguration configuration) {
|
||||
//下划线与驼峰命名进行自动映射
|
||||
configuration.setMapUnderscoreToCamelCase(true);
|
||||
}
|
||||
};
|
||||
}
|
||||
}
|
||||
@ -1,44 +0,0 @@
|
||||
package com.xydl.controller;
|
||||
|
||||
import com.xydl.util.DataSourceUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
import javax.sql.DataSource;
|
||||
import java.sql.*;
|
||||
|
||||
|
||||
@RestController
|
||||
public class JDBCController {
|
||||
private static final Logger logger = LoggerFactory.getLogger(DataSourceUtils.class);
|
||||
|
||||
|
||||
@RequestMapping("/data")
|
||||
public void getData() {
|
||||
Connection conn = null;
|
||||
PreparedStatement pstmt = null;
|
||||
try {
|
||||
conn = DataSourceUtils.getConnection();
|
||||
String sql = "insert into pop_id(node_id,id) values(?,?)";
|
||||
pstmt = conn.prepareStatement(sql);
|
||||
pstmt.setString(1, "");
|
||||
pstmt.setInt(2, 100);
|
||||
pstmt.executeUpdate();
|
||||
} catch (Exception e) {
|
||||
logger.error("execute sql exception:", e);
|
||||
} finally {
|
||||
DataSourceUtils.closeResource(pstmt, conn);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,26 +1,18 @@
|
||||
package com.xydl.controller;
|
||||
|
||||
|
||||
import com.xydl.model.Eia;
|
||||
import com.xydl.service.EiaService;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Controller;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.ResponseBody;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Controller
|
||||
public class TestController {
|
||||
|
||||
@Autowired
|
||||
private EiaService eiaService;
|
||||
|
||||
@RequestMapping("/eia")
|
||||
@ResponseBody
|
||||
public List<Eia> eia() {
|
||||
System.out.println("get eia");
|
||||
return eiaService.getEia();
|
||||
public String test() {
|
||||
System.out.println("===");
|
||||
return "测试成功";
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,21 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
|
||||
import com.xydl.model.Eaif;
|
||||
import com.xydl.model.Epa;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface EaifMapper {
|
||||
|
||||
|
||||
//红外测温
|
||||
List<Eaif> getEaif();
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,21 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
import com.xydl.model.Eia;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface EiaMapper {
|
||||
|
||||
|
||||
//铁芯、夹件、电容性设备
|
||||
List<Eia> getEia();
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,34 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
import com.xydl.model.Epa;
|
||||
import com.xydl.model.SuperModel;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface EpaMapper {
|
||||
|
||||
|
||||
//油色谱
|
||||
List<Epa> getEpa(int devid);
|
||||
|
||||
List<SuperModel> getData(String sql);
|
||||
|
||||
List<Integer> getEqmidsByTableName(String tableName);
|
||||
|
||||
List<String> getTableNamesBySyncTable(String syncTable);
|
||||
|
||||
String getSqlBySyncTable(String syncTable, String tableName);
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,21 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
import com.xydl.model.Etp;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface EtpMapper {
|
||||
|
||||
|
||||
//绕组测温
|
||||
List<Etp> getEtp();
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,24 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
|
||||
import com.xydl.model.Epa;
|
||||
import com.xydl.model.Microclimate;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface MicMapper {
|
||||
|
||||
|
||||
|
||||
//微气象
|
||||
List<Microclimate> getMicroclimate();
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,24 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
|
||||
import com.xydl.model.Epa;
|
||||
import com.xydl.model.Moa;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface MoaMapper {
|
||||
|
||||
|
||||
|
||||
//绝缘监测-金属氧化物
|
||||
List<Moa> getMoa();
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,12 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public interface OperationDB {
|
||||
|
||||
List<String> getAllDevId(String tableName);
|
||||
|
||||
String getLastTime(String tableName, String devId);
|
||||
|
||||
|
||||
}
|
||||
@ -1,25 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
|
||||
import com.xydl.model.Epa;
|
||||
import com.xydl.model.Pd;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface PdMapper {
|
||||
|
||||
|
||||
|
||||
//局放监测
|
||||
List<Pd> getPd();
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,24 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
import com.xydl.model.Eia;
|
||||
import com.xydl.model.Epa;
|
||||
import com.xydl.model.Etp;
|
||||
import com.xydl.model.RptTemper;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface RptTemperMapper {
|
||||
|
||||
|
||||
|
||||
//测温点
|
||||
List<RptTemper> getRptTemper();
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,25 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
|
||||
import com.xydl.model.Epa;
|
||||
import com.xydl.model.Scur;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface ScurMapper {
|
||||
|
||||
|
||||
|
||||
//电缆环流
|
||||
List<Scur> getScur();
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,22 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
import com.xydl.model.Epa;
|
||||
import com.xydl.model.Sf6;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface Sf6Mapper {
|
||||
|
||||
|
||||
//SF6监测
|
||||
List<Sf6> getSf6();
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,22 +0,0 @@
|
||||
package com.xydl.mapper;
|
||||
|
||||
|
||||
import com.xydl.model.Epa;
|
||||
import com.xydl.model.Sf6env;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
@Repository
|
||||
public interface Sf6envMapper {
|
||||
|
||||
|
||||
//SF6环境
|
||||
List<Sf6env> getSf6env();
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,30 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.sql.Timestamp;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Eaif {
|
||||
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String captureTime;
|
||||
|
||||
@JsonProperty("MaxTmp")
|
||||
private double maxTemp;
|
||||
|
||||
@JsonProperty("MinTmp")
|
||||
private double minTemp;
|
||||
|
||||
@JsonProperty("AvgTmp")
|
||||
private double avgTemp;
|
||||
|
||||
}
|
||||
@ -1,33 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Eia {
|
||||
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String captureTime;
|
||||
|
||||
@JsonProperty("MaxTmp")
|
||||
private String maxTemp;
|
||||
|
||||
@JsonProperty("MinTmp")
|
||||
private String minTemp;
|
||||
|
||||
@JsonProperty("AvgTmp")
|
||||
private String avgTemp;
|
||||
|
||||
@JsonProperty("Phase")
|
||||
private String phase;
|
||||
|
||||
|
||||
}
|
||||
@ -1,65 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
import net.sf.jsqlparser.expression.DateTimeLiteralExpression;
|
||||
|
||||
import java.sql.Timestamp;
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.Date;
|
||||
|
||||
/*
|
||||
油色谱
|
||||
*/
|
||||
@Data
|
||||
public class Epa {
|
||||
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String dTime ;
|
||||
|
||||
@JsonProperty("H2")
|
||||
private double h2ppm;
|
||||
|
||||
@JsonProperty("CH4")
|
||||
private double ch4ppm;
|
||||
|
||||
@JsonProperty("C2H6")
|
||||
private double c2h6ppm;
|
||||
|
||||
@JsonProperty("C2H4")
|
||||
private double c2h4ppm;
|
||||
|
||||
@JsonProperty("C2H2")
|
||||
private double c2h2ppm;
|
||||
|
||||
@JsonProperty("CO")
|
||||
private double coppm;
|
||||
|
||||
@JsonProperty("CO2")
|
||||
private double co2ppm;
|
||||
|
||||
@JsonProperty("O2")
|
||||
private double o2ppm;
|
||||
|
||||
@JsonProperty("N2")
|
||||
private double n2ppm;
|
||||
|
||||
@JsonProperty("TotalHydrocarbon")
|
||||
private double totalHydroCarbon;
|
||||
|
||||
@JsonProperty("GasPress")
|
||||
private double gaspress;
|
||||
|
||||
@JsonProperty("H2O")
|
||||
private double h2oppm;
|
||||
|
||||
@JsonProperty("Phase")
|
||||
private String phase;
|
||||
|
||||
}
|
||||
@ -1,33 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.TableField;
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.sql.Timestamp;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Etp {
|
||||
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String dTime;
|
||||
|
||||
@JsonProperty("MaxTmp")
|
||||
private double t1;
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,42 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.sql.Timestamp;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Microclimate {
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String dTime;
|
||||
|
||||
@JsonProperty("AirTemperature")
|
||||
private double envTmp;
|
||||
|
||||
@JsonProperty("AirPressure")
|
||||
private double envPres;
|
||||
|
||||
@JsonProperty("Humidity")
|
||||
private double envHum;
|
||||
|
||||
@JsonProperty("Precipitation")
|
||||
private double rnfll;
|
||||
|
||||
@JsonProperty("PrecipitationIntensity")
|
||||
private double PreciInten = 0;
|
||||
|
||||
@JsonProperty("RadiationIntensity")
|
||||
private double radiInten = 0;
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,36 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.sql.Timestamp;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Moa {
|
||||
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String captureTime;
|
||||
|
||||
@JsonProperty("SystemVoltage")
|
||||
private double pt1;
|
||||
|
||||
@JsonProperty("TotalCurrent")
|
||||
private double lc1;
|
||||
|
||||
@JsonProperty("ResistiveCurrent")
|
||||
private double rc1;
|
||||
|
||||
@JsonProperty("ActionCount")
|
||||
private double ligcnt1;
|
||||
|
||||
@JsonProperty("LastActionTime")
|
||||
private String lastligtm1;
|
||||
|
||||
}
|
||||
@ -1,30 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.sql.Timestamp;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Pd {
|
||||
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String dTime;
|
||||
|
||||
@JsonProperty("DischargeCapacity")
|
||||
private double waveForm;
|
||||
|
||||
@JsonProperty("DischargePosition")
|
||||
private double apppadsch;
|
||||
|
||||
@JsonProperty("PulseCount")
|
||||
private double plsNum;
|
||||
|
||||
}
|
||||
@ -1,42 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
import java.sql.Timestamp;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class RptTemper {
|
||||
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String createTime;
|
||||
|
||||
@JsonProperty("OlTmpA")
|
||||
private double aoTemper;
|
||||
|
||||
@JsonProperty("OlTmpB")
|
||||
private double boTemper;
|
||||
|
||||
@JsonProperty("OlTmpC")
|
||||
private double coTemper;
|
||||
|
||||
@JsonProperty("IlTmpA")
|
||||
private double aiTemper;
|
||||
|
||||
@JsonProperty("IlTmpB")
|
||||
private double biTemper;
|
||||
|
||||
@JsonProperty("IlTmpC")
|
||||
private double ciTemper;
|
||||
|
||||
@JsonProperty("OntologyTmp")
|
||||
private double boxTemper;
|
||||
|
||||
|
||||
}
|
||||
@ -1,22 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
import java.sql.Timestamp;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Scur {
|
||||
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String dTime;
|
||||
|
||||
@JsonProperty("CoreCurrent")
|
||||
private double currentVal;
|
||||
}
|
||||
@ -1,35 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
import java.sql.Timestamp;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Sf6 {
|
||||
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String dTime;
|
||||
|
||||
@JsonProperty("Temperature")
|
||||
private double temp1;
|
||||
|
||||
@JsonProperty("Pressure20C")
|
||||
private double pressure1;
|
||||
|
||||
@JsonProperty("AbsolutePressure")
|
||||
private double AbsolutePressure = pressure1 + 900;
|
||||
|
||||
@JsonProperty("Density")
|
||||
private double md1;
|
||||
|
||||
@JsonProperty("Moisture")
|
||||
private double pm1;
|
||||
|
||||
}
|
||||
@ -1,43 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
import java.sql.Timestamp;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Sf6env {
|
||||
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String dTime;
|
||||
|
||||
@JsonProperty("gas1")
|
||||
private double gas1;
|
||||
|
||||
@JsonProperty("yq1")
|
||||
private double yq1;
|
||||
|
||||
@JsonProperty("md1")
|
||||
private double md1;
|
||||
|
||||
@JsonProperty("pm1")
|
||||
private double pm1;
|
||||
|
||||
@JsonProperty("gascnt1")
|
||||
private double gascnt1;
|
||||
|
||||
@JsonProperty("hmcnt1")
|
||||
private double hmcnt1;
|
||||
|
||||
@JsonProperty("sf6warn1")
|
||||
private double sf6warn1;
|
||||
|
||||
@JsonProperty("o2warn1")
|
||||
private double o2warn1;
|
||||
}
|
||||
@ -1,231 +0,0 @@
|
||||
package com.xydl.model;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
|
||||
public class SuperModel {
|
||||
|
||||
/**
|
||||
* EPA
|
||||
*/
|
||||
@JsonProperty("SubDeviceID")
|
||||
private String subDeviceID;
|
||||
|
||||
@JsonProperty("SensorCode")
|
||||
private String sensorId;
|
||||
|
||||
@JsonProperty("AcquisitionTime")
|
||||
private String dTime ;
|
||||
|
||||
@JsonProperty("H2")
|
||||
private double h2ppm;
|
||||
|
||||
@JsonProperty("CH4")
|
||||
private double ch4ppm;
|
||||
|
||||
@JsonProperty("C2H6")
|
||||
private double c2h6ppm;
|
||||
|
||||
@JsonProperty("C2H4")
|
||||
private double c2h4ppm;
|
||||
|
||||
@JsonProperty("C2H2")
|
||||
private double c2h2ppm;
|
||||
|
||||
@JsonProperty("CO")
|
||||
private double coppm;
|
||||
|
||||
@JsonProperty("CO2")
|
||||
private double co2ppm;
|
||||
|
||||
@JsonProperty("O2")
|
||||
private double o2ppm;
|
||||
|
||||
@JsonProperty("N2")
|
||||
private double n2ppm;
|
||||
|
||||
@JsonProperty("TotalHydrocarbon")
|
||||
private double totalHydroCarbon;
|
||||
|
||||
@JsonProperty("GasPress")
|
||||
private double gaspress;
|
||||
|
||||
@JsonProperty("H2O")
|
||||
private double h2oppm;
|
||||
|
||||
@JsonProperty("Phase")
|
||||
private String phase;
|
||||
|
||||
/**
|
||||
* Eaif
|
||||
*/
|
||||
|
||||
// @JsonProperty("AcquisitionTime")
|
||||
// private String captureTime;
|
||||
|
||||
@JsonProperty("MaxTmp")
|
||||
private double maxTemp;
|
||||
|
||||
@JsonProperty("MinTmp")
|
||||
private double minTemp;
|
||||
|
||||
@JsonProperty("AvgTmp")
|
||||
private double avgTemp;
|
||||
|
||||
/**
|
||||
* Eia
|
||||
*/
|
||||
|
||||
/**
|
||||
* Etp
|
||||
*/
|
||||
|
||||
|
||||
// @JsonProperty("MaxTmp")
|
||||
// private double t1;
|
||||
|
||||
|
||||
/**
|
||||
* Microclimate
|
||||
*/
|
||||
|
||||
|
||||
@JsonProperty("AirTemperature")
|
||||
private double envTmp;
|
||||
|
||||
@JsonProperty("AirPressure")
|
||||
private double envPres;
|
||||
|
||||
@JsonProperty("Humidity")
|
||||
private double envHum;
|
||||
|
||||
@JsonProperty("Precipitation")
|
||||
private double rnfll;
|
||||
|
||||
@JsonProperty("PrecipitationIntensity")
|
||||
private double PreciInten = 0;
|
||||
|
||||
@JsonProperty("RadiationIntensity")
|
||||
private double radiInten = 0;
|
||||
|
||||
/**
|
||||
* Moa
|
||||
*/
|
||||
|
||||
|
||||
@JsonProperty("SystemVoltage")
|
||||
private double pt1;
|
||||
|
||||
@JsonProperty("TotalCurrent")
|
||||
private double lc1;
|
||||
|
||||
@JsonProperty("ResistiveCurrent")
|
||||
private double rc1;
|
||||
|
||||
@JsonProperty("ActionCount")
|
||||
private double ligcnt1;
|
||||
|
||||
@JsonProperty("LastActionTime")
|
||||
private String lastligtm1;
|
||||
|
||||
/**
|
||||
* Pd
|
||||
*/
|
||||
|
||||
|
||||
@JsonProperty("DischargeCapacity")
|
||||
private double waveForm;
|
||||
|
||||
@JsonProperty("DischargePosition")
|
||||
private double apppadsch;
|
||||
|
||||
@JsonProperty("PulseCount")
|
||||
private double plsNum;
|
||||
|
||||
/**
|
||||
* RptTemper
|
||||
*/
|
||||
|
||||
|
||||
// @JsonProperty("AcquisitionTime")
|
||||
// private String createTime;
|
||||
|
||||
@JsonProperty("OlTmpA")
|
||||
private double aoTemper;
|
||||
|
||||
@JsonProperty("OlTmpB")
|
||||
private double boTemper;
|
||||
|
||||
@JsonProperty("OlTmpC")
|
||||
private double coTemper;
|
||||
|
||||
@JsonProperty("IlTmpA")
|
||||
private double aiTemper;
|
||||
|
||||
@JsonProperty("IlTmpB")
|
||||
private double biTemper;
|
||||
|
||||
@JsonProperty("IlTmpC")
|
||||
private double ciTemper;
|
||||
|
||||
@JsonProperty("OntologyTmp")
|
||||
private double boxTemper;
|
||||
|
||||
/**
|
||||
* Scur
|
||||
*/
|
||||
|
||||
|
||||
@JsonProperty("CoreCurrent")
|
||||
private double currentVal;
|
||||
|
||||
/**
|
||||
* Sf6
|
||||
*/
|
||||
|
||||
|
||||
@JsonProperty("Temperature")
|
||||
private double temp1;
|
||||
|
||||
@JsonProperty("Pressure20C")
|
||||
private double pressure1;
|
||||
|
||||
@JsonProperty("AbsolutePressure")
|
||||
private double AbsolutePressure = pressure1 + 900;
|
||||
|
||||
@JsonProperty("Density")
|
||||
private double md1Sf6;
|
||||
|
||||
@JsonProperty("Moisture")
|
||||
private double pm1Sf6;
|
||||
|
||||
|
||||
/**
|
||||
* Sf6env
|
||||
*/
|
||||
|
||||
@JsonProperty("gas1")
|
||||
private double gas1;
|
||||
|
||||
@JsonProperty("yq1")
|
||||
private double yq1;
|
||||
|
||||
@JsonProperty("md1")
|
||||
private double md1;
|
||||
|
||||
@JsonProperty("pm1")
|
||||
private double pm1;
|
||||
|
||||
@JsonProperty("gascnt1")
|
||||
private double gascnt1;
|
||||
|
||||
@JsonProperty("hmcnt1")
|
||||
private double hmcnt1;
|
||||
|
||||
@JsonProperty("sf6warn1")
|
||||
private double sf6warn1;
|
||||
|
||||
@JsonProperty("o2warn1")
|
||||
private double o2warn1;
|
||||
|
||||
|
||||
}
|
||||
@ -1,33 +0,0 @@
|
||||
package com.xydl.service;
|
||||
|
||||
import com.xydl.model.*;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
public interface EiaService {
|
||||
|
||||
List<Eaif> getEaif();
|
||||
|
||||
List<Eia> getEia();
|
||||
|
||||
void getEpa();
|
||||
|
||||
List<Etp> getEtp();
|
||||
|
||||
List<Microclimate> getMic();
|
||||
|
||||
List<Moa> getMoa();
|
||||
|
||||
List<Pd> getPd();
|
||||
|
||||
List<RptTemper> getRptTemper();
|
||||
|
||||
List<Scur> getScur();
|
||||
|
||||
List<Sf6> getSf6();
|
||||
|
||||
List<Sf6env> getSf6env();
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,14 @@
|
||||
<?xml version="1.0" encoding="UTF-8" ?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
|
||||
<mapper namespace="com.xydl.mapper.OperationDB">
|
||||
|
||||
<select id="getAllDevId" parameterType="String" resultType="String">
|
||||
select distinct eqmid from ${tableName}
|
||||
</select>
|
||||
|
||||
<select id="getLastTime" parameterType="String" resultType="String">
|
||||
select d_time from ${tableName} where eqmid=#{devId} ORDER BY d_time asc limit 1
|
||||
</select>
|
||||
|
||||
|
||||
</mapper>
|
||||
@ -0,0 +1,59 @@
|
||||
/*
|
||||
Navicat Premium Data Transfer
|
||||
|
||||
Source Server : 本机
|
||||
Source Server Type : MySQL
|
||||
Source Server Version : 80100
|
||||
Source Host : localhost:3306
|
||||
Source Schema : cac
|
||||
|
||||
Target Server Type : MySQL
|
||||
Target Server Version : 80100
|
||||
File Encoding : 65001
|
||||
|
||||
Date: 05/12/2023 10:26:24
|
||||
*/
|
||||
|
||||
SET NAMES utf8mb4;
|
||||
SET FOREIGN_KEY_CHECKS = 0;
|
||||
|
||||
-- ----------------------------
|
||||
-- Table structure for sync_tables_info
|
||||
-- ----------------------------
|
||||
DROP TABLE IF EXISTS `sync_tables_info`;
|
||||
CREATE TABLE `sync_tables_info` (
|
||||
`client_id` int UNSIGNED NOT NULL,
|
||||
`table_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
|
||||
`sql` varchar(2048) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
|
||||
`devid_field_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
|
||||
`outer_devid_fname` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
|
||||
`field_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
|
||||
`field_type` tinyint NOT NULL DEFAULT 1 COMMENT '1: 整数 2: 字符串 3: 日期 4: 浮点数',
|
||||
`update_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0),
|
||||
PRIMARY KEY (`client_id`, `table_name`) USING BTREE
|
||||
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
|
||||
|
||||
DROP TABLE IF EXISTS `sync_records`;
|
||||
CREATE TABLE `sync_records` (
|
||||
`client_id` int UNSIGNED NOT NULL,
|
||||
`table_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
|
||||
`devid_val` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
|
||||
`field_val1` bigint UNSIGNED NULL DEFAULT 0,
|
||||
`field_val2` datetime(0) NULL DEFAULT '1999-01-01 01:00:00',
|
||||
`update_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0),
|
||||
PRIMARY KEY (`client_id`, `table_name`, `devid_val`) USING BTREE
|
||||
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
|
||||
|
||||
DROP TABLE IF EXISTS `sync_fields_info`;
|
||||
CREATE TABLE `sync_fields_info` (
|
||||
`id` int UNSIGNED NOT NULL AUTO_INCREMENT,
|
||||
`client_id` int UNSIGNED NOT NULL,
|
||||
`table_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
|
||||
`field_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
|
||||
`field_type` tinyint UNSIGNED NOT NULL DEFAULT 0,
|
||||
`dest_field_name` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
|
||||
PRIMARY KEY (`id`) USING BTREE,
|
||||
INDEX `fields`(`client_id`, `table_name`, `field_name`) USING BTREE
|
||||
) ENGINE = InnoDB AUTO_INCREMENT = 41 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
|
||||
|
||||
SET FOREIGN_KEY_CHECKS = 1;
|
||||
Loading…
Reference in New Issue