diff --git a/src/main/java/com/casic/common/CasicFrame.java b/src/main/java/com/casic/common/CasicFrame.java index 3f3424d..2175800 100644 --- a/src/main/java/com/casic/common/CasicFrame.java +++ b/src/main/java/com/casic/common/CasicFrame.java @@ -19,6 +19,10 @@ String uptime; JSONObject messageBody; + public String getDevTypeName() { + return ""; + } + public void parseMessageBody() { } diff --git a/src/main/java/com/casic/common/CasicFrame.java b/src/main/java/com/casic/common/CasicFrame.java index 3f3424d..2175800 100644 --- a/src/main/java/com/casic/common/CasicFrame.java +++ b/src/main/java/com/casic/common/CasicFrame.java @@ -19,6 +19,10 @@ String uptime; JSONObject messageBody; + public String getDevTypeName() { + return ""; + } + public void parseMessageBody() { } diff --git a/src/main/java/com/casic/common/CasicFrameBuildFactory.java b/src/main/java/com/casic/common/CasicFrameBuildFactory.java index a2a5e8e..328c635 100644 --- a/src/main/java/com/casic/common/CasicFrameBuildFactory.java +++ b/src/main/java/com/casic/common/CasicFrameBuildFactory.java @@ -2,6 +2,9 @@ import com.casic.common.general.ConfigResponseFrame; import com.casic.common.general.HeartFrame; +import com.casic.methane.frame.brs.MethaneDataFrameBRS; +import com.casic.methane.frame.brs.MethaneEventFrameBRS; +import com.casic.methane.frame.brs.MethaneInfoFrameBRS; import com.casic.senitnel.frame.ncx.DataFrameNCX; import com.casic.senitnel.frame.ncx.EventFrameNCX; import com.casic.senitnel.frame.ncx.InfoFrameNCX; @@ -52,6 +55,9 @@ case "21": return buildSentinelDataFrame(manufacturerCode); + case "32": + return buildMethaneDataFrame(manufacturerCode); + default: return null; } @@ -65,6 +71,9 @@ case "21": return buildSentinelEventFrame(manufacturerCode); + case "32": + return buildTubeMethaneFrame(manufacturerCode); + default: return null; } @@ -78,6 +87,9 @@ case "21": return buildSentinelInfoFrame(manufacturerCode); + case "32": + return buildMethaneInfoFrame(manufacturerCode); + default: return null; } @@ -99,6 +111,22 @@ } } + private static CasicFrame buildMethaneDataFrame(String manufacturerCode) { + switch (manufacturerCode) { + case "15": // 百瑞生 + return new MethaneDataFrameBRS(); + + case "16": // 麦哈克 + return new DataFrameMHK(); + + case "17": // 航天拓扑 + return new DataFrameHTTP(); + + default: + return null; + } + } + private static CasicFrame buildSentinelDataFrame(String manufacturerCode) { switch (manufacturerCode) { case "14": // 诺成新 @@ -122,6 +150,19 @@ } } + private static CasicFrame buildTubeMethaneFrame(String manufacturerCode) { + switch (manufacturerCode) { + case "15": + return new MethaneEventFrameBRS(); + + case "16": + return new EventFrameMHK(); + + default: + return null; + } + } + private static CasicFrame buildSentinelEventFrame(String manufacturerCode) { switch (manufacturerCode) { case "14": // 诺成新 @@ -145,6 +186,19 @@ } } + private static CasicFrame buildMethaneInfoFrame(String manufacturerCode) { + switch (manufacturerCode) { + case "15": + return new MethaneInfoFrameBRS(); + + case "16": + return new InfoFrameMHK(); + + default: + return null; + } + } + private static CasicFrame buildSentinelInfoFrame(String manufacturerCode) { switch (manufacturerCode) { case "14": diff --git a/src/main/java/com/casic/common/CasicFrame.java b/src/main/java/com/casic/common/CasicFrame.java index 3f3424d..2175800 100644 --- a/src/main/java/com/casic/common/CasicFrame.java +++ b/src/main/java/com/casic/common/CasicFrame.java @@ -19,6 +19,10 @@ String uptime; JSONObject messageBody; + public String getDevTypeName() { + return ""; + } + public void parseMessageBody() { } diff --git a/src/main/java/com/casic/common/CasicFrameBuildFactory.java b/src/main/java/com/casic/common/CasicFrameBuildFactory.java index a2a5e8e..328c635 100644 --- a/src/main/java/com/casic/common/CasicFrameBuildFactory.java +++ b/src/main/java/com/casic/common/CasicFrameBuildFactory.java @@ -2,6 +2,9 @@ import com.casic.common.general.ConfigResponseFrame; import com.casic.common.general.HeartFrame; +import com.casic.methane.frame.brs.MethaneDataFrameBRS; +import com.casic.methane.frame.brs.MethaneEventFrameBRS; +import com.casic.methane.frame.brs.MethaneInfoFrameBRS; import com.casic.senitnel.frame.ncx.DataFrameNCX; import com.casic.senitnel.frame.ncx.EventFrameNCX; import com.casic.senitnel.frame.ncx.InfoFrameNCX; @@ -52,6 +55,9 @@ case "21": return buildSentinelDataFrame(manufacturerCode); + case "32": + return buildMethaneDataFrame(manufacturerCode); + default: return null; } @@ -65,6 +71,9 @@ case "21": return buildSentinelEventFrame(manufacturerCode); + case "32": + return buildTubeMethaneFrame(manufacturerCode); + default: return null; } @@ -78,6 +87,9 @@ case "21": return buildSentinelInfoFrame(manufacturerCode); + case "32": + return buildMethaneInfoFrame(manufacturerCode); + default: return null; } @@ -99,6 +111,22 @@ } } + private static CasicFrame buildMethaneDataFrame(String manufacturerCode) { + switch (manufacturerCode) { + case "15": // 百瑞生 + return new MethaneDataFrameBRS(); + + case "16": // 麦哈克 + return new DataFrameMHK(); + + case "17": // 航天拓扑 + return new DataFrameHTTP(); + + default: + return null; + } + } + private static CasicFrame buildSentinelDataFrame(String manufacturerCode) { switch (manufacturerCode) { case "14": // 诺成新 @@ -122,6 +150,19 @@ } } + private static CasicFrame buildTubeMethaneFrame(String manufacturerCode) { + switch (manufacturerCode) { + case "15": + return new MethaneEventFrameBRS(); + + case "16": + return new EventFrameMHK(); + + default: + return null; + } + } + private static CasicFrame buildSentinelEventFrame(String manufacturerCode) { switch (manufacturerCode) { case "14": // 诺成新 @@ -145,6 +186,19 @@ } } + private static CasicFrame buildMethaneInfoFrame(String manufacturerCode) { + switch (manufacturerCode) { + case "15": + return new MethaneInfoFrameBRS(); + + case "16": + return new InfoFrameMHK(); + + default: + return null; + } + } + private static CasicFrame buildSentinelInfoFrame(String manufacturerCode) { switch (manufacturerCode) { case "14": diff --git a/src/main/java/com/casic/dao/mapper/DataGasMapper.java b/src/main/java/com/casic/dao/mapper/DataGasMapper.java new file mode 100644 index 0000000..a5c0c3b --- /dev/null +++ b/src/main/java/com/casic/dao/mapper/DataGasMapper.java @@ -0,0 +1,18 @@ +package com.casic.dao.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.casic.dao.model.DataGas; +import org.apache.ibatis.annotations.Mapper; + +/** + *
+ * 报警数据 Mapper 接口 + *
+ * + * @author cz + * @since 2023-11-20 + */ +@Mapper +public interface DataGasMapper extends BaseMapper+ * 报警数据 Mapper 接口 + *
+ * + * @author cz + * @since 2023-11-20 + */ +@Mapper +public interface DataGasMapper extends BaseMapper+ * 报警数据 Mapper 接口 + *
+ * + * @author cz + * @since 2023-11-20 + */ +@Mapper +public interface DataGasliquidGasMapper extends BaseMapper+ * 报警数据 Mapper 接口 + *
+ * + * @author cz + * @since 2023-11-20 + */ +@Mapper +public interface DataGasMapper extends BaseMapper+ * 报警数据 Mapper 接口 + *
+ * + * @author cz + * @since 2023-11-20 + */ +@Mapper +public interface DataGasliquidGasMapper extends BaseMapper
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *
+ * 报警数据 Mapper 接口
+ *
+ * 报警数据 Mapper 接口
+ *
* 报警数据 Mapper 接口
@@ -17,4 +19,5 @@
public interface DeviceWellViewMapper extends BaseMapper
+ * 第三方厂家管盯数据
+ *
+ * 第三方厂家管盯数据
+ *