project-zsy
/
gasWellWatch
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/develop' into develop

This commit is contained in:
qinjie 2024-11-25 15:48:10 +08:00
parent 24795e3b17 2281749c14
commit a93f20772b
15 changed files with 473 additions and 190 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pom.xml
View File

@ -166,6 +166,11 @@
<artifactId>sa-token-spring-boot3-starter</artifactId>
<version>1.38.0</version>
</dependency>
<dependency>
<groupId>org.bouncycastle</groupId>
<artifactId>bcprov-jdk15on</artifactId>
<version>1.70</version>
</dependency>
<dependency>
<groupId>com.infiniteautomation</groupId>
<artifactId>modbus4j</artifactId>

2
src/main/java/com/isu/gaswellwatch/GasWellWatchApplication.java
View File

@ -2,7 +2,9 @@ package com.isu.gaswellwatch;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
@EnableScheduling
@SpringBootApplication
public class GasWellWatchApplication {

2
src/main/java/com/isu/gaswellwatch/modbus/data/PersistenceHandler.java
View File

@ -10,7 +10,7 @@ public interface PersistenceHandler {
public static final String MODBUS_DEVICE_TYPE = "KNPCV1";
String DEVICE_DATA_CACHE = "data:device:";
void createTable(String tableName);
void createTable(String tableName, Long deviceId);
void insert(String tableName, String cacheKey);

6
src/main/java/com/isu/gaswellwatch/modbus/data/decode/DecodeHandler.java
View File

@ -4,6 +4,8 @@ import com.isu.gaswellwatch.modbus.data.ModbusMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Map;
/**
* Modbus 数据解析器
*
@ -14,6 +16,8 @@ public interface DecodeHandler {
Logger logger = LoggerFactory.getLogger("com.isu.gaswellwatch.decode");
void decode(ModbusMessage.MessagePoint point);
String decode(Map<String, Object> commandPointMap, String value);
void decode(Map<String, Object> commandPointMap, ModbusMessage.MessagePoint point);
}

51
src/main/java/com/isu/gaswellwatch/modbus/data/decode/impl/FactorDecodeHandler.java Normal file
View File

@ -0,0 +1,51 @@
package com.isu.gaswellwatch.modbus.data.decode.impl;
import cn.hutool.core.map.MapUtil;
import com.isu.gaswellwatch.modbus.data.ModbusMessage;
import com.isu.gaswellwatch.modbus.data.decode.DecodeHandler;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Component;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.Map;
/**
* 乘除系数解析器
* <ul>
* <ol>系数为正数时，采用除法</ol>
* <li>例如：输入值：2580，系数(factor)：100，精度(precision)：2，输出值：2580 / 100 = 25.8</li>
* <ol>系数为负数时，采用乘法</ol>
* <li>例如：输入值：2580，系数(factor)：100，精度(precision)：2，输出值：2580 * 100 = 258000</li>
* </ul>
*
* @author <a href="mailto:shilong.wang@alpha-ess.com">王仕龙</a>
* 2024/11/24 21:23
*/
@Slf4j
@SuppressWarnings("all")
@Component("factorDecodeHandler")
public class FactorDecodeHandler implements DecodeHandler {
@Override
public String decode(Map<String, Object> commandPointMap, String value) {
return value;
}
@Override
public void decode(Map<String, Object> commandPointMap, ModbusMessage.MessagePoint point) {
point.setValue(decode(commandPointMap, point.getParseValue()));
String factorStr = MapUtil.getStr(commandPointMap, "factor");
if (StringUtils.isNotBlank(factorStr) && StringUtils.isNotBlank(point.getParseValue())) {
BigDecimal factor = new BigDecimal(factorStr);
BigDecimal value = new BigDecimal(point.getParseValue());
int precision = MapUtil.getInt(commandPointMap, "precision", 0);
switch (factor.compareTo(BigDecimal.ZERO)) {
case -1 -> point.setValue(value.multiply(factor.abs()).toString());
case 1 -> point.setValue(value.divide(factor, precision, RoundingMode.HALF_UP).toString());
}
}
}
}

36
src/main/java/com/isu/gaswellwatch/modbus/data/decode/impl/Knpcv1DecodeHandler.java
View File

@ -1,36 +0,0 @@
package com.isu.gaswellwatch.modbus.data.decode.impl;
import com.isu.gaswellwatch.modbus.data.ModbusMessage;
import com.isu.gaswellwatch.modbus.data.decode.DecodeHandler;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
/**
* KNPCV1 柱塞器解析
*
* @author <a href="mailto:shilong.wang@alpha-ess.com">王仕龙</a>
* 2024/11/23 11:23
*/
@Slf4j
@SuppressWarnings("all")
@Component(Knpcv1DecodeHandler.MODBUS_DEVICE_TYPE + "_1")
public class Knpcv1DecodeHandler implements DecodeHandler {
public static final String MODBUS_DEVICE_TYPE = "KNPCV1";
private static final String COMMAND_POINT_SQL = "select * from command_points where command_id = ?";
@Resource
private JdbcTemplate jdbcTemplate;
@Resource(name = "redisTemplate")
private RedisTemplate redisTemplate;
@Override
public void decode(ModbusMessage.MessagePoint point) {
}
}

36
src/main/java/com/isu/gaswellwatch/modbus/data/decode/impl/LocalDateDecodeHandler.java Normal file
View File

@ -0,0 +1,36 @@
package com.isu.gaswellwatch.modbus.data.decode.impl;
import com.isu.gaswellwatch.modbus.data.ModbusMessage;
import com.isu.gaswellwatch.modbus.data.decode.DecodeHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.Map;
/**
* 本地日期类型解析器
*
* @author <a href="mailto:shilong.wang@alpha-ess.com">王仕龙</a>
* 2024/11/25 11:51
*/
@Slf4j
@SuppressWarnings("all")
@Component("localDateDecodeHandler")
public class LocalDateDecodeHandler implements DecodeHandler {
public static final DateTimeFormatter IN_FORMATTER = DateTimeFormatter.ofPattern("yyyy-M-d");
public static final DateTimeFormatter OUT_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd");
@Override
public String decode(Map<String, Object> commandPointMap, String value) {
return LocalDate.parse(value, IN_FORMATTER).format(OUT_FORMATTER);
}
@Override
public void decode(Map<String, Object> commandPointMap, ModbusMessage.MessagePoint point) {
point.setValue(decode(commandPointMap, point.getParseValue()));
}
}

36
src/main/java/com/isu/gaswellwatch/modbus/data/decode/impl/LocalDateTimeDecodeHandler.java Normal file
View File

@ -0,0 +1,36 @@
package com.isu.gaswellwatch.modbus.data.decode.impl;
import com.isu.gaswellwatch.modbus.data.ModbusMessage;
import com.isu.gaswellwatch.modbus.data.decode.DecodeHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.Map;
/**
* 本地日期时间类型解析器
*
* @author <a href="mailto:shilong.wang@alpha-ess.com">王仕龙</a>
* 2024/11/24 21:34
*/
@Slf4j
@SuppressWarnings("all")
@Component("localDateTimeDecodeHandler")
public class LocalDateTimeDecodeHandler implements DecodeHandler {
public static final DateTimeFormatter IN_FORMATTER = DateTimeFormatter.ofPattern("yyyy-M-d H:m:s");
public static final DateTimeFormatter OUT_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
@Override
public String decode(Map<String, Object> commandPointMap, String value) {
return LocalDateTime.parse(value, IN_FORMATTER).format(OUT_FORMATTER);
}
@Override
public void decode(Map<String, Object> commandPointMap, ModbusMessage.MessagePoint point) {
point.setValue(decode(commandPointMap, point.getParseValue()));
}
}

36
src/main/java/com/isu/gaswellwatch/modbus/data/decode/impl/LocalTimeDecodeHandler.java Normal file
View File

@ -0,0 +1,36 @@
package com.isu.gaswellwatch.modbus.data.decode.impl;
import com.isu.gaswellwatch.modbus.data.ModbusMessage;
import com.isu.gaswellwatch.modbus.data.decode.DecodeHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.time.LocalTime;
import java.time.format.DateTimeFormatter;
import java.util.Map;
/**
* 本地时间类型解析器
*
* @author <a href="mailto:shilong.wang@alpha-ess.com">王仕龙</a>
* 2024/11/25 11:58
*/
@Slf4j
@SuppressWarnings("all")
@Component("localTimeDecodeHandler")
public class LocalTimeDecodeHandler implements DecodeHandler {
public static final DateTimeFormatter IN_FORMATTER = DateTimeFormatter.ofPattern("H:m:s");
public static final DateTimeFormatter OUT_FORMATTER = DateTimeFormatter.ofPattern("HH:mm:ss");
@Override
public String decode(Map<String, Object> commandPointMap, String value) {
return LocalTime.parse(value, IN_FORMATTER).format(OUT_FORMATTER);
}
@Override
public void decode(Map<String, Object> commandPointMap, ModbusMessage.MessagePoint point) {
point.setValue(decode(commandPointMap, point.getParseValue()));
}
}

40
src/main/java/com/isu/gaswellwatch/modbus/data/decode/impl/StringTimeDecodeHandler.java Normal file
View File

@ -0,0 +1,40 @@
package com.isu.gaswellwatch.modbus.data.decode.impl;
import com.isu.gaswellwatch.modbus.data.ModbusMessage;
import com.isu.gaswellwatch.modbus.data.decode.DecodeHandler;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Component;
import java.util.Arrays;
import java.util.Map;
import java.util.stream.Collectors;
/**
* 时间类型解析器
* 支持解析：999:59:59, 实际使用中请不要转为LocalTime
*
* @author <a href="mailto:shilong.wang@alpha-ess.com">王仕龙</a>
* 2024/11/24 21:38
*/
@Slf4j
@SuppressWarnings("all")
@Component("stringTimeDecodeHandler")
public class StringTimeDecodeHandler implements DecodeHandler {
@Override
public String decode(Map<String, Object> commandPointMap, String value) {
if (StringUtils.isBlank(value)) {
return value;
}
return Arrays.stream(StringUtils.split(value, ":"))
.map(item -> StringUtils.leftPad(item, 2, '0'))
.collect(Collectors.joining(":"));
}
@Override
public void decode(Map<String, Object> commandPointMap, ModbusMessage.MessagePoint point) {
point.setValue(decode(commandPointMap, point.getParseValue()));
}
}

86
src/main/java/com/isu/gaswellwatch/modbus/data/decode/listener/ModbusMessagePersistListener.java
View File

@ -5,7 +5,9 @@ import cn.hutool.json.JSONUtil;
import com.isu.gaswellwatch.modbus.data.ModbusMessage;
import com.isu.gaswellwatch.modbus.data.PersistenceHandler;
import com.isu.gaswellwatch.modbus.data.decode.DecodeHandler;
import com.serotonin.modbus4j.msg.ReadInputRegistersResponse;
import com.isu.gaswellwatch.modbus.data.decode.impl.LocalDateTimeDecodeHandler;
import com.serotonin.modbus4j.code.FunctionCode;
import com.serotonin.modbus4j.msg.*;
import com.serotonin.modbus4j.serial.rtu.RtuMessageParser;
import com.serotonin.modbus4j.serial.rtu.RtuMessageResponse;
import com.serotonin.modbus4j.sero.util.queue.ByteQueue;
@ -22,7 +24,13 @@ import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.jdbc.core.JdbcTemplate;
import java.time.Duration;
import java.util.*;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
/**
* @author <a href="mailto:shilong.wang@alpha-ess.com">王仕龙</a>
@ -39,7 +47,7 @@ public class ModbusMessagePersistListener implements BatchMessageListener {
@Resource
private JdbcTemplate jdbcTemplate;
@Resource(name = "redisTemplate")
@Resource(name = "stringRedisTemplate")
private RedisTemplate redisTemplate;
@Resource
private Map<String, DecodeHandler> decodeHandlerMap;
@ -66,35 +74,50 @@ public class ModbusMessagePersistListener implements BatchMessageListener {
continue;
}
messagePointMap = new HashMap<>();
collectionMessage = messageSplit[5];
commandId = NumberUtils.createLong(messageSplit[2]);
commandString = Objects.toString(this.redisTemplate.opsForValue().get(COMMAND_CACHE + commandId), "");
commandMap = StringUtils.isNotEmpty(commandString) ? JSONUtil.parseObj(commandString) : null;
if (ObjectUtils.isEmpty(commandMap)) {
commandMap = this.jdbcTemplate.queryForMap(COMMAND_SQL, commandId);
if (ObjectUtils.isNotEmpty(commandMap)) {
if (ObjectUtils.isEmpty(commandMap)) {
log.error("指令[{}]不存在，数据: {}", commandId, messageString);
continue;
}
this.redisTemplate.opsForValue()
.setIfAbsent(COMMAND_CACHE + commandId, JSONUtil.toJsonStr(commandMap), Duration.ofDays(1));
}
DecodeHandler decodeHandler = Optional.ofNullable(MapUtil.getStr(commandMap, "decode_handler_name"))
.map(this.decodeHandlerMap::get)
.orElse(null);
if (Objects.isNull(decodeHandler)) {
log.error("指令[{}]未配置解析器，数据: {}", commandId, messageString);
continue;
}
messagePointMap = new HashMap<>();
try {
String address;
int index = MapUtil.getInt(commandMap, "start_address"), stepSize = 0;
ByteQueue byteQueue = new ByteQueue(collectionMessage);
RtuMessageParser masterParser = new RtuMessageParser(true);
RtuMessageResponse response = (RtuMessageResponse) masterParser.parseMessage(byteQueue);
ReadInputRegistersResponse readInputRegistersResponse = (ReadInputRegistersResponse) response.getModbusResponse();
for (short value : readInputRegistersResponse.getShortData()) {
ModbusResponse modbusResponse = response.getModbusResponse();
short[] values = null;
switch (modbusResponse.getFunctionCode()) {
case FunctionCode.READ_COILS -> {
values = ((ReadCoilsResponse) modbusResponse).getShortData();
}
case FunctionCode.READ_DISCRETE_INPUTS -> {
values = ((ReadDiscreteInputsResponse) modbusResponse).getShortData();
}
case FunctionCode.READ_INPUT_REGISTERS -> {
values = ((ReadInputRegistersResponse) modbusResponse).getShortData();
}
case FunctionCode.READ_HOLDING_REGISTERS -> {
values = ((ReadHoldingRegistersResponse) modbusResponse).getShortData();
}
// case FunctionCode.READ_EXCEPTION_STATUS -> {
// values = new short[]{((ReadExceptionStatusResponse) modbusResponse).getExceptionStatus()};
// }
default -> {
throw new RuntimeException("Funcetion code not supported: " + modbusResponse.getFunctionCode());
}
}
for (short value : values) {
stepSize = index * 4;
messagePointMap.put(StringUtils.leftPad(String.valueOf(index), 4, '0'),
ModbusMessage.MessagePoint.builder()
@ -131,7 +154,7 @@ public class ModbusMessagePersistListener implements BatchMessageListener {
List<Map<String, Object>> commandPointList = StringUtils.isNotEmpty(cachePoints) ? (List) JSONUtil.parseArray(cachePoints) : null;
if (ObjectUtils.isEmpty(commandPointList)) {
commandPointList = this.jdbcTemplate.queryForList(COMMAND_POINT_SQL, commandId);
if (ObjectUtils.isNotEmpty(commandPointList)) {
if (ObjectUtils.isEmpty(commandPointList)) {
log.error("指令[{}]点表配置为空", commandId, cachePoints);
throw new RuntimeException("指令[" + commandId + "]点表未配置");
}
@ -144,6 +167,13 @@ public class ModbusMessagePersistListener implements BatchMessageListener {
ModbusMessage.MessagePoint messagePoint;
String deviceDataCacheName = PersistenceHandler.DEVICE_DATA_CACHE + modbusMessage.getDeviceId();
HashOperations<String, Object, Object> hashOperations = this.redisTemplate.opsForHash();
hashOperations.put(deviceDataCacheName, "deviceId", String.valueOf(modbusMessage.getDeviceId()));
hashOperations.put(deviceDataCacheName, "receiveTime", LocalDateTime.ofInstant(Instant
.ofEpochMilli(modbusMessage.getReceiveTime()), ZoneOffset.systemDefault())
.format(LocalDateTimeDecodeHandler.OUT_FORMATTER));
hashOperations.put(deviceDataCacheName, "collectionTime", LocalDateTime.ofInstant(Instant
.ofEpochMilli(modbusMessage.getCollectionTime()), ZoneOffset.systemDefault())
.format(LocalDateTimeDecodeHandler.OUT_FORMATTER));
for (Map<String, Object> point : commandPointList) {
fieldName = MapUtil.getStr(point, "field");
stepSize = MapUtil.getInt(point, "step_size");
@ -153,35 +183,41 @@ public class ModbusMessagePersistListener implements BatchMessageListener {
if (stepSize <= 1) {
messagePoint = modbusMessage.getMessagePointMap()
.get(StringUtils.leftPad(String.valueOf(startAddress), 4, '0'));
decodeMessage(decodeName, messagePoint);
decodeMessage(decodeName, point, messagePoint);
value = messagePoint.getValue();
} else {
value = decodeCommandPoint(modbusMessage.getMessagePointMap(), decodeName,
MapUtil.getStr(point, "format"), startAddress, stepSize);
value = decodeCommandPoint(modbusMessage.getMessagePointMap(), decodeName, point, startAddress, stepSize);
}
hashOperations.put(deviceDataCacheName, fieldName, value);
}
}
private void decodeMessage(String decodeName, ModbusMessage.MessagePoint messagePoint) {
private void decodeMessage(String decodeName, Map<String, Object> commandPointMap, ModbusMessage.MessagePoint messagePoint) {
if (StringUtils.isNotBlank(decodeName)) {
DecodeHandler decodeHandler = this.decodeHandlerMap.get(decodeName);
DecodeHandler decodeHandler = this.decodeHandlerMap.get(decodeName + "DecodeHandler");
if (Objects.nonNull(decodeHandler)) {
decodeHandler.decode(messagePoint);
decodeHandler.decode(commandPointMap, messagePoint);
}
}
}
private String decodeCommandPoint(Map<String, ModbusMessage.MessagePoint> pointMap,
String decodeName, String format, int startAddress, int stepSize) {
private String decodeCommandPoint(Map<String, ModbusMessage.MessagePoint> pointMap, String decodeName,
Map<String, Object> commandPointMap, int startAddress, int stepSize) {
String[] values = new String[stepSize];
ModbusMessage.MessagePoint messagePoint;
for (int i = 0; i < stepSize; i++) {
messagePoint = pointMap.get(StringUtils.leftPad(String.valueOf(startAddress + i), 4, '0'));
decodeMessage(decodeName, messagePoint);
values[i] = messagePoint.getValue();
}
return String.format(format, values);
String format = MapUtil.getStr(commandPointMap, "format");
String result = StringUtils.isBlank(format) ? StringUtils.join(values) : String.format(format, values);
if (StringUtils.isNotBlank(decodeName)) {
DecodeHandler decodeHandler = this.decodeHandlerMap.get(decodeName + "DecodeHandler");
if (Objects.nonNull(decodeHandler)) {
return decodeHandler.decode(commandPointMap, result);
}
}
return result;
}
}

115
src/main/java/com/isu/gaswellwatch/modbus/data/impl/Knpcv1PersistenceHandler.java
View File

@ -6,7 +6,6 @@ import com.isu.gaswellwatch.modbus.data.PersistenceHandler;
import jakarta.annotation.Resource;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementCallback;
@ -34,13 +33,15 @@ public class Knpcv1PersistenceHandler implements PersistenceHandler {
private JdbcTemplate jdbcTemplate;
@Resource
private SnowflakeConfig snowflakeConfig;
@Resource(name = "redisTemplate")
@Resource(name = "stringRedisTemplate")
private RedisTemplate redisTemplate;
@Override
public void createTable(String tableName) {
public void createTable(String tableName, Long deviceId) {
String createTableSQL = getResource("sql/CREATE_KNPCV1.sql");
this.jdbcTemplate.execute(StringUtils.replace(createTableSQL, "$TableName$", tableName));
createTableSQL = StringUtils.replace(createTableSQL, "$TableName$", tableName);
createTableSQL = StringUtils.replace(createTableSQL, "$DeviceId$", String.valueOf(deviceId));
this.jdbcTemplate.execute(createTableSQL);
}
@Override
@ -52,62 +53,60 @@ public class Knpcv1PersistenceHandler implements PersistenceHandler {
this.jdbcTemplate.execute(insertTableSQL, new PreparedStatementCallback<Object>() {
@Override
public Object doInPreparedStatement(PreparedStatement ps) throws SQLException, DataAccessException {
public Object doInPreparedStatement(PreparedStatement ps) throws SQLException {
ps.setLong(1, Knpcv1PersistenceHandler.this.snowflakeConfig.snowflakeId());
Knpcv1PersistenceHandler.this.setValue(ps, row, 2, "deviceId", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 3, "collectionTime", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 4, "receiveTime", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 5, "status", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 6, "device_time", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 7, "runMode", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 8, "wellStatus", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 9, "plugStatus", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 10, "statusOpenTime", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 11, "statusCloseTime", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 12, "oilPressure", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 13, "casPressure", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 14, "prePressure", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 15, "pipePressure", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 16, "liquidLevel", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 17, "temperature", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 18, "humidity", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 19, "opmode", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 20, "well_ctl", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 21, "timer1", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 22, "timer2", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 23, "timer1Open", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 24, "timer1Close", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 25, "timer2Open", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 26, "timer2Close", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 27, "timingOpen", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 28, "timingClose", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 29, "timingCelay", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 30, "presource", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 31, "pressureOpen", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 32, "pressureClose", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 33, "triggerType", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 34, "stabilityTime", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 35, "maxOpenWell", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 36, "maxCloseWell", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 37, "minOpenWell", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 38, "minCloseWell", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 39, "presproTect", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 40, "presproSource", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 41, "openWellLimitMax", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 42, "openWellLimitMin", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 43, "plugInitStatus", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 44, "plugSustainTime", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 45, "plugCloseTime", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 46, "tpInitStatus", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 47, "tpOpenSource", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 48, "tpOpenTrigger", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 49, "tpOpenPressure", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 50, "tpOpenTime", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 51, "tpCloseSource", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 52, "tpCloseTrigger", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 53, "tpClosePressure", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 54, "tpCloseTime", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 55, "tpStabilityTime", Types.BIGINT);
Knpcv1PersistenceHandler.this.setValue(ps, row, 3, "collectionTime", Types.TIMESTAMP);
Knpcv1PersistenceHandler.this.setValue(ps, row, 4, "receiveTime", Types.TIMESTAMP);
Knpcv1PersistenceHandler.this.setValue(ps, row, 5, "deviceTime", Types.TIMESTAMP);
Knpcv1PersistenceHandler.this.setValue(ps, row, 6, "runMode", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 7, "wellStatus", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 8, "plugStatus", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 9, "statusOpenTime", Types.TIME);
Knpcv1PersistenceHandler.this.setValue(ps, row, 10, "statusCloseTime", Types.TIME);
Knpcv1PersistenceHandler.this.setValue(ps, row, 11, "oilPressure", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 12, "casPressure", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 13, "prePressure", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 14, "pipePressure", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 15, "liquidLevel", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 16, "temperature", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 17, "humidity", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 18, "opmode", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 19, "timer1", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 20, "timer2", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 21, "timer1Open", Types.TIME);
Knpcv1PersistenceHandler.this.setValue(ps, row, 22, "timer1Close", Types.TIME);
Knpcv1PersistenceHandler.this.setValue(ps, row, 23, "timer2Open", Types.TIME);
Knpcv1PersistenceHandler.this.setValue(ps, row, 24, "timer2Close", Types.TIME);
Knpcv1PersistenceHandler.this.setValue(ps, row, 25, "timingOpen", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 26, "timingClose", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 27, "timingCelay", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 28, "presource", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 29, "pressureOpen", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 30, "pressureClose", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 31, "triggerType", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 32, "stabilityTime", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 33, "maxOpenWell", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 34, "maxCloseWell", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 35, "minOpenWell", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 36, "minCloseWell", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 37, "presproTect", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 38, "presproSource", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 39, "openWellLimitMax", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 40, "openWellLimitMin", Types.DECIMAL);
Knpcv1PersistenceHandler.this.setValue(ps, row, 41, "plugInitStatus", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 42, "plugSustainTime", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 43, "plugCloseTime", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 44, "tpInitStatus", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 45, "tpOpenSource", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 46, "tpOpenTrigger", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 47, "tpOpenPressure", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 48, "tpOpenTime", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 49, "tpCloseSource", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 50, "tpCloseTrigger", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 51, "tpClosePressure", Types.INTEGER);
Knpcv1PersistenceHandler.this.setValue(ps, row, 52, "tpCloseTime", Types.VARCHAR);
Knpcv1PersistenceHandler.this.setValue(ps, row, 53, "tpStabilityTime", Types.INTEGER);
return ps.executeUpdate();
}
});

86
src/main/java/com/isu/gaswellwatch/modbus/data/impl/Redis2DBPersistenceService.java
View File

@ -1,16 +1,19 @@
package com.isu.gaswellwatch.modbus.data.impl;
import cn.hutool.core.map.MapUtil;
import com.isu.gaswellwatch.entity.Response;
import com.isu.gaswellwatch.modbus.data.PersistenceHandler;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.core.annotation.Order;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.data.redis.core.Cursor;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ScanOptions;
import org.springframework.http.RequestEntity;
import org.springframework.http.ResponseEntity;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@ -19,6 +22,8 @@ import org.springframework.web.client.RestTemplate;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;
/**
* @author <a href="mailto:shilong.wang@alpha-ess.com">王仕龙</a>
@ -29,59 +34,80 @@ import java.util.Map;
@SuppressWarnings("all")
public class Redis2DBPersistenceService {
private static final String EXISTS_TABLE_SQL = "SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA='gaswellwatch' AND TABLE_NAME=?";
private static final String EXISTS_TABLE_SQL = "SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA" +
" IN ('gaswellwatch', 'gas_well_watch') AND TABLE_NAME='$TableName$'";
@Resource
private JdbcTemplate jdbcTemplate;
@Resource(name = "redisTemplate")
@Resource(name = "stringRedisTemplate")
private RedisTemplate redisTemplate;
@Resource
private Map<String, PersistenceHandler> persistenceHandlerMap;
private RestTemplate restTemplate = new RestTemplate();
@Order(100)
@Scheduled(cron = "5/30 * * * * ? ")
@Scheduled(cron = "20/30 * * * * ? ")
public void write() {
Map<Long, String> idGatewayMappingMap = null;
try {
String onlineGateways = this.restTemplate.getForObject("http://127.0.0.1:9999/modbus-tcp/online", String.class);
if (StringUtils.isBlank(onlineGateways)) {
return;
}
List<Map<String, Object>> idGatewayMappingList = this.jdbcTemplate
.queryForList("select id, gateway_sn from devices where gateway_sn in (" + onlineGateways + ")");
if (ObjectUtils.isEmpty(idGatewayMappingList)) {
return;
}
idGatewayMappingMap = new HashMap<Long, String>();
for (Map<String, Object> map : idGatewayMappingList) {
idGatewayMappingMap.put(MapUtil.getLong(map, "id"), MapUtil.getStr(map, "gateway_sn"));
}
} catch (Exception e) {
log.error("Get online devices list fail", e);
}
Map<Long, String> idGatewayMappingMap = getOnlineGateway();
HashOperations operations = this.redisTemplate.opsForHash();
try (Cursor<String> cursor = this.redisTemplate.scan(ScanOptions.scanOptions()
.match(PersistenceHandler.DEVICE_DATA_CACHE + "*").build())) {
Long deviceId;
String cacheKey, tableName;
Map<String, Object> deviceMap, temp;
Map<String, Object> deviceMap;
PersistenceHandler persistenceHandler;
List<Map<String, Object>> existsTableList;
while (cursor.hasNext()) {
deviceMap = operations.entries(cacheKey = cursor.next());
if (ObjectUtils.isEmpty(deviceMap)) {
continue;
}
deviceId = MapUtil.getLong(deviceMap, "deviceId");
if (Objects.isNull(deviceId)) {
continue;
}
if (Objects.nonNull(idGatewayMappingMap)) {
operations.put(PersistenceHandler.DEVICE_DATA_CACHE + deviceId,
"online", idGatewayMappingMap.containsKey(deviceId));
"online", String.valueOf(idGatewayMappingMap.containsKey(deviceId)));
}
persistenceHandler = persistenceHandlerMap.get("KNPCV1");
tableName = "t_device_data_" + deviceId;
temp = this.jdbcTemplate.queryForMap(EXISTS_TABLE_SQL, tableName); //$TableName$
if (StringUtils.isBlank(MapUtil.getStr(temp, "TABLE_NAME"))) {
persistenceHandler.createTable(tableName);
existsTableList = this.jdbcTemplate.queryForList(StringUtils.replace(EXISTS_TABLE_SQL, "$TableName$", tableName));
if (ObjectUtils.isEmpty(existsTableList)
|| ObjectUtils.isEmpty(existsTableList.get(0))
|| StringUtils.isBlank(MapUtil.getStr(existsTableList.get(0), "TABLE_NAME"))) {
persistenceHandler.createTable(tableName, deviceId);
}
persistenceHandler.insert(tableName, cacheKey);
}
}
}
private Map<Long, String> getOnlineGateway() {
try {
RequestEntity request = RequestEntity.get("http://127.0.0.1:9999/modbus-tcp/online").build();
ResponseEntity<Response<List<String>>> response = this.restTemplate.exchange(request,
new ParameterizedTypeReference<Response<List<String>>>() {
});
if (Objects.isNull(response)
|| Objects.isNull(response.getBody())
|| ObjectUtils.isEmpty(response.getBody().getData())) {
return null;
}
List<Map<String, Object>> idGatewayMappingList = this.jdbcTemplate
.queryForList("select id, gateway_sn from devices where gateway_sn in (" +
response.getBody().getData().stream().map(value -> "'" + value + "'")
.collect(Collectors.joining(",")) + ")");
if (ObjectUtils.isEmpty(idGatewayMappingList)) {
return null;
}
Map<Long, String> idGatewayMappingMap = new HashMap<Long, String>();
for (Map<String, Object> map : idGatewayMappingList) {
idGatewayMappingMap.put(MapUtil.getLong(map, "id"), MapUtil.getStr(map, "gateway_sn"));
}
return idGatewayMappingMap;
} catch (Exception e) {
log.error("Get online devices list fail", e);
return null;
}
}
}

66
src/main/resources/sql/CREATE_KNPCV1.sql
View File

@ -5,11 +5,10 @@ CREATE TABLE `$TableName$`
`created_time` datetime NOT NULL COMMENT '数据落库时间',
`collection_time` datetime NOT NULL COMMENT '采集指令下发时间',
`receive_time` datetime NOT NULL COMMENT '接收到数据时间',
`status` tinyint NULL DEFAULT NULL COMMENT '开关井。寄存器地址：0:0001，允许值：0：关井 ，1：开井',
`device_time` datetime NULL DEFAULT NULL COMMENT '设备时间。\r\n寄存器地址：3:0000，3:0001，3:0002，3:0003，3:0004，3:0005\r\n',
`run_mode` tinyint NULL DEFAULT NULL COMMENT '运行模式：\r\n0：手动模式 \r\n1：定时器模式 \r\n2：计时器模式 \r\n3：压力模式\r\n4：柱塞模式\r\n5：时压模式',
`gas_status` tinyint NULL DEFAULT NULL COMMENT '气井状态：\r\n0：关闭 \r\n1：打开',
`plug_status` tinyint NULL DEFAULT NULL COMMENT '柱塞状态：\r\n0：离开\r\n1：上升中\r\n2：到达',
`run_mode` smallint NULL DEFAULT NULL COMMENT '运行模式：\r\n0：手动模式 \r\n1：定时器模式 \r\n2：计时器模式 \r\n3：压力模式\r\n4：柱塞模式\r\n5：时压模式',
`gas_status` smallint NULL DEFAULT NULL COMMENT '气井状态：\r\n0：关闭 \r\n1：打开',
`plug_status` smallint NULL DEFAULT NULL COMMENT '柱塞状态：\r\n0：离开\r\n1：上升中\r\n2：到达',
`status_start_time` time NULL DEFAULT NULL COMMENT '当前状态开始时间',
`status_end_time` time NULL DEFAULT NULL COMMENT '当前状态结束时间',
`oil_pressure` decimal(10, 2) NULL DEFAULT NULL COMMENT '油压：单位Mpa',
@ -19,43 +18,42 @@ CREATE TABLE `$TableName$`
`liquid_level` decimal(10, 2) NULL DEFAULT NULL COMMENT '流量：单位mm',
`temperature` decimal(10, 2) NULL DEFAULT NULL COMMENT '温度：单位℃，*100，最高位表示正负，0正1负，即零下的温度加32768',
`humidity` decimal(10, 2) NULL DEFAULT NULL COMMENT '湿度：单位%',
`op_mode` tinyint NULL DEFAULT NULL COMMENT '运行模式：\r\n0： 手动模式 hand_mode\r\n1：定时器模式 timer_mode\r\n2：计时器模式 t2mode\r\n3：压力模式 pressure_mode\r\n4：柱塞模式 piston_mode\r\n5：时压模式 tp_mode',
`well_ctl` tinyint NULL DEFAULT NULL COMMENT '开关井，保持现有的模式，同显示屏按钮：\r\n0：关井 close_well\r\n1：开井 open_well',
`timer_able1` tinyint NULL DEFAULT NULL COMMENT '定时模式定时器1使能：\r\n0：禁止 disable\r\n1：使能 enable',
`timer_able2` tinyint NULL DEFAULT NULL COMMENT '定时模式定时器2使能：\r\n0：禁止 disable\r\n1：使能 ',
`op_mode` smallint NULL DEFAULT NULL COMMENT '运行模式：\r\n0： 手动模式 hand_mode\r\n1：定时器模式 timer_mode\r\n2：计时器模式 t2mode\r\n3：压力模式 pressure_mode\r\n4：柱塞模式 piston_mode\r\n5：时压模式 tp_mode',
`timer_able1` smallint NULL DEFAULT NULL COMMENT '定时模式定时器1使能：\r\n0：禁止 disable\r\n1：使能 enable',
`timer_able2` smallint NULL DEFAULT NULL COMMENT '定时模式定时器2使能：\r\n0：禁止 disable\r\n1：使能 ',
`timer_open1` time NULL DEFAULT NULL COMMENT '时0~23：分0~59：秒0~59',
`timer_close1` time NULL DEFAULT NULL COMMENT '时0~23：分0~59：秒0~59',
`timer_open2` time NULL DEFAULT NULL COMMENT '时0~23：分0~59：秒0~59',
`timer_close2` time NULL DEFAULT NULL COMMENT '时0~23：分0~59：秒0~59',
`timing_open` time NULL DEFAULT NULL COMMENT '时0~23：分0~59：秒0~59',
`timing_close` time NULL DEFAULT NULL COMMENT '时0~23：分0~59：秒0~59',
`timing_delay` time NULL DEFAULT NULL COMMENT '时0~23：分0~59：秒0~59',
`presource` tinyint NULL DEFAULT NULL COMMENT '触发压力源：\r\n0：油压 oil_pressure\r\n1：套压 cas_pressure\r\n2：输压 pre_pressure\r\n3：差压 diff_pressure',
`timing_open` varchar(10) NULL DEFAULT NULL COMMENT '时0~23：分0~59：秒0~59',
`timing_close` varchar(10) NULL DEFAULT NULL COMMENT '时0~23：分0~59：秒0~59',
`timing_delay` varchar(10) NULL DEFAULT NULL COMMENT '时0~23：分0~59：秒0~59',
`presource` smallint NULL DEFAULT NULL COMMENT '触发压力源：\r\n0：油压 oil_pressure\r\n1：套压 cas_pressure\r\n2：输压 pre_pressure\r\n3：差压 diff_pressure',
`pressure_open` decimal(10, 2) NULL DEFAULT NULL COMMENT '开井压力：单位Mpa，*100',
`pressure_close` decimal(10, 2) NULL DEFAULT NULL COMMENT '关井压力： 单位Mpa，*100',
`trigger_type` tinyint NULL DEFAULT NULL COMMENT '压力触发类型：\n0：大于开井压力开井、小于关井压力关井 gre_less\n1：大于开井压力开井、大于关井压力关井 gre_gre\n2：小于开井压力开井、小于关井压力关井 less_less\n3：小于开井压力开井、大于关井压力关井 less_gre',
`stability_time` smallint NULL DEFAULT NULL COMMENT '传感器压力稳定时间：秒',
`max_open_well` time NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`max_close_well` time NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`min_open_well` time NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`min_close_well` time NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`prespro_tect` tinyint NULL DEFAULT NULL COMMENT '开井压力保护使能：\r\n0：禁止 disable\r\n1：使能 enable',
`prespro_source` tinyint NULL DEFAULT NULL COMMENT '开井压力保护源：\r\n0：油压 oil_pressure\r\n1：套压 cas_pressure\r\n2：输压 pre_pressure\r\n3：差压 diff_pressure',
`trigger_type` smallint NULL DEFAULT NULL COMMENT '压力触发类型：\n0：大于开井压力开井、小于关井压力关井 gre_less\n1：大于开井压力开井、大于关井压力关井 gre_gre\n2：小于开井压力开井、小于关井压力关井 less_less\n3：小于开井压力开井、大于关井压力关井 less_gre',
`stability_time` int NULL DEFAULT NULL COMMENT '传感器压力稳定时间：秒',
`max_open_well` varchar(10) NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`max_close_well` varchar(10) NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`min_open_well` varchar(10) NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`min_close_well` varchar(10) NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`prespro_tect` smallint NULL DEFAULT NULL COMMENT '开井压力保护使能：\r\n0：禁止 disable\r\n1：使能 enable',
`prespro_source` smallint NULL DEFAULT NULL COMMENT '开井压力保护源：\r\n0：油压 oil_pressure\r\n1：套压 cas_pressure\r\n2：输压 pre_pressure\r\n3：差压 diff_pressure',
`open_well_limit_max` decimal(10, 2) NULL DEFAULT NULL COMMENT '开井压力限制上限：单位MPa *100',
`open_well_limit_min` decimal(10, 2) NULL DEFAULT NULL COMMENT '开井压力限制下限：单位MPa *100',
`plug_init_status` tinyint NULL DEFAULT NULL COMMENT '柱塞模式初始气井状态：\r\n0：关井 close_well\r\n1：开井 open_well',
`plug_sustain_time` time NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`plug_close_time` time NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`tp_init_status` tinyint NULL DEFAULT NULL COMMENT '时压模式初始气井状态：\r\n0：关井 close_well\r\n1：开井 open_well',
`tp_open_source` tinyint NULL DEFAULT NULL COMMENT '时压模式开井源：\r\n0：油压 oil_pressure\r\n1：套压 cas_pressure\r\n2：输压 pre_pressure\r\n3：差压 diff_pressure\r\n4：时间 time_pressure',
`tp_open_trigger` tinyint NULL DEFAULT NULL COMMENT '时压模式开井压力触发模式：\r\n0：大于压力触发\r\n1：小于压力触发',
`tp_open_pressure` tinyint NULL DEFAULT NULL COMMENT '时压模式开井压力',
`tp_open_time` time NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`tp_close_source` tinyint NULL DEFAULT NULL COMMENT '时压模式关井源：\r\n0：油压 oil_pressure\r\n1：套压 cas_pressure\r\n2：输压 pre_pressure\r\n3：差压 diff_pressure\r\n4：时间 time_pressure',
`tp_close_trigger` tinyint NULL DEFAULT NULL COMMENT '时压模式关井压力触发模式：\r\n0：大于压力触发 max_pressure\r\n1：小于压力触发 min_pressure',
`plug_init_status` smallint NULL DEFAULT NULL COMMENT '柱塞模式初始气井状态：\r\n0：关井 close_well\r\n1：开井 open_well',
`plug_sustain_time` varchar(10) NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`plug_close_time` varchar(10) NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`tp_init_status` smallint NULL DEFAULT NULL COMMENT '时压模式初始气井状态：\r\n0：关井 close_well\r\n1：开井 open_well',
`tp_open_source` smallint NULL DEFAULT NULL COMMENT '时压模式开井源：\r\n0：油压 oil_pressure\r\n1：套压 cas_pressure\r\n2：输压 pre_pressure\r\n3：差压 diff_pressure\r\n4：时间 time_pressure',
`tp_open_trigger` smallint NULL DEFAULT NULL COMMENT '时压模式开井压力触发模式：\r\n0：大于压力触发\r\n1：小于压力触发',
`tp_open_pressure` smallint NULL DEFAULT NULL COMMENT '时压模式开井压力',
`tp_open_time` varchar(10) NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`tp_close_source` smallint NULL DEFAULT NULL COMMENT '时压模式关井源：\r\n0：油压 oil_pressure\r\n1：套压 cas_pressure\r\n2：输压 pre_pressure\r\n3：差压 diff_pressure\r\n4：时间 time_pressure',
`tp_close_trigger` smallint NULL DEFAULT NULL COMMENT '时压模式关井压力触发模式：\r\n0：大于压力触发 max_pressure\r\n1：小于压力触发 min_pressure',
`tp_close_pressure` smallint NULL DEFAULT NULL COMMENT '时压模式关井压力',
`tp_close_time` time NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`tp_stability_time` tinyint NULL DEFAULT NULL COMMENT '时压模式压力稳定时长：秒',
`tp_close_time` varchar(10) NULL DEFAULT NULL COMMENT '时0~999：分0~59：秒0~59',
`tp_stability_time` smallint NULL DEFAULT NULL COMMENT '时压模式压力稳定时长：秒',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE INDEX `udx_device_create_time` (`device_id` ASC, `created_time` ASC) USING BTREE COMMENT '设备采集数据唯一键'
) ENGINE = InnoDB COMMENT = '设备ID：1的采集数据';
UNIQUE INDEX `udx_device_create_time` (`device_id` ASC, `collection_time` ASC) USING BTREE COMMENT '设备采集数据唯一键'
) ENGINE = InnoDB COMMENT = '设备ID：$DeviceId$的采集数据'

58
src/main/resources/sql/INSERT_KNPCV1.sql
View File

@ -1,7 +1,7 @@
INSERT INTO `$TableName$` (`id`, `device_id`, `created_time`, `collection_time`, `receive_time`, `status`,
INSERT INTO `$TableName$` (`id`, `device_id`, `created_time`, `collection_time`, `receive_time`,
`device_time`, `run_mode`, `gas_status`, `plug_status`, `status_start_time`,
`status_end_time`, `oil_pressure`, `cas_pressure`, `pre_pressure`, `pipe_pressure`,
`liquid_level`, `temperature`, `humidity`, `op_mode`, `well_ctl`, `timer_able1`,
`liquid_level`, `temperature`, `humidity`, `op_mode`, `timer_able1`,
`timer_able2`, `timer_open1`, `timer_close1`, `timer_open2`, `timer_close2`,
`timing_open`, `timing_close`, `timing_delay`, `presource`, `pressure_open`,
`pressure_close`, `trigger_type`, `stability_time`, `max_open_well`, `max_close_well`,
@ -10,5 +10,55 @@ INSERT INTO `$TableName$` (`id`, `device_id`, `created_time`, `collection_time`,
`plug_close_time`, `tp_init_status`, `tp_open_source`, `tp_open_trigger`,
`tp_open_pressure`, `tp_open_time`, `tp_close_source`, `tp_close_trigger`,
`tp_close_pressure`, `tp_close_time`, `tp_stability_time`)
VALUES (?, ?, NOW(), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,
?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?);
VALUES (?, ?, NOW(), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,
?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON DUPLICATE KEY UPDATE receive_time=VALUES(receive_time),
device_time=VALUES(device_time),
run_mode=VALUES(run_mode),
gas_status=VALUES(gas_status),
plug_status=VALUES(plug_status),
status_start_time=VALUES(status_start_time),
status_end_time=VALUES(status_end_time),
oil_pressure=VALUES(oil_pressure),
cas_pressure=VALUES(cas_pressure),
pre_pressure=VALUES(pre_pressure),
pipe_pressure=VALUES(pipe_pressure),
liquid_level=VALUES(liquid_level),
temperature=VALUES(temperature),
humidity=VALUES(humidity),
op_mode=VALUES(op_mode),
timer_able1=VALUES(timer_able1),
timer_able2=VALUES(timer_able2),
timer_open1=VALUES(timer_open1),
timer_close1=VALUES(timer_close1),
timer_open2=VALUES(timer_open2),
timer_close2=VALUES(timer_close2),
timing_open=VALUES(timing_open),
timing_close=VALUES(timing_close),
timing_delay=VALUES(timing_delay),
presource=VALUES(presource),
pressure_open=VALUES(pressure_open),
pressure_close=VALUES(pressure_close),
trigger_type=VALUES(trigger_type),
stability_time=VALUES(stability_time),
max_open_well=VALUES(max_open_well),
max_close_well=VALUES(max_close_well),
min_open_well=VALUES(min_open_well),
min_close_well=VALUES(min_close_well),
prespro_tect=VALUES(prespro_tect),
prespro_source=VALUES(prespro_source),
open_well_limit_max=VALUES(open_well_limit_max),
open_well_limit_min=VALUES(open_well_limit_min),
plug_init_status=VALUES(plug_init_status),
plug_sustain_time=VALUES(plug_sustain_time),
plug_close_time=VALUES(plug_close_time),
tp_init_status=VALUES(tp_init_status),
tp_open_source=VALUES(tp_open_source),
tp_open_trigger=VALUES(tp_open_trigger),
tp_open_pressure=VALUES(tp_open_pressure),
tp_open_time=VALUES(tp_open_time),
tp_close_source=VALUES(tp_close_source),
tp_close_trigger=VALUES(tp_close_trigger),
tp_close_pressure=VALUES(tp_close_pressure),
tp_close_time=VALUES(tp_close_time),
tp_stability_time=VALUES(tp_stability_time)