diff --git a/pom.xml b/pom.xml
index 74d7bd1..4db133b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
com.casic.sensor
sensor-transfer
1.0-SNAPSHOT
- war
+ jar
UTF-8
@@ -61,10 +61,6 @@
3.4.3
-
- org.postgresql
- postgresql
-
org.projectlombok
@@ -85,6 +81,12 @@
1.2.73
+
+ xyz.downgoon
+ snowflake
+ 1.0.0
+
+
@@ -120,4 +122,154 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index 74d7bd1..4db133b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
com.casic.sensor
sensor-transfer
1.0-SNAPSHOT
- war
+ jar
UTF-8
@@ -61,10 +61,6 @@
3.4.3
-
- org.postgresql
- postgresql
-
org.projectlombok
@@ -85,6 +81,12 @@
1.2.73
+
+ xyz.downgoon
+ snowflake
+ 1.0.0
+
+
@@ -120,4 +122,154 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/main/build/bin/start.bat b/src/main/build/bin/start.bat
new file mode 100644
index 0000000..d858fb2
--- /dev/null
+++ b/src/main/build/bin/start.bat
@@ -0,0 +1,4 @@
+@echo off
+title ${project.build.finalName}
+java -jar ./lib/${project.build.finalName}.jar
+@pause
diff --git a/pom.xml b/pom.xml
index 74d7bd1..4db133b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
com.casic.sensor
sensor-transfer
1.0-SNAPSHOT
- war
+ jar
UTF-8
@@ -61,10 +61,6 @@
3.4.3
-
- org.postgresql
- postgresql
-
org.projectlombok
@@ -85,6 +81,12 @@
1.2.73
+
+ xyz.downgoon
+ snowflake
+ 1.0.0
+
+
@@ -120,4 +122,154 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/main/build/bin/start.bat b/src/main/build/bin/start.bat
new file mode 100644
index 0000000..d858fb2
--- /dev/null
+++ b/src/main/build/bin/start.bat
@@ -0,0 +1,4 @@
+@echo off
+title ${project.build.finalName}
+java -jar ./lib/${project.build.finalName}.jar
+@pause
diff --git a/src/main/build/bin/start.sh b/src/main/build/bin/start.sh
new file mode 100644
index 0000000..e14c4c7
--- /dev/null
+++ b/src/main/build/bin/start.sh
@@ -0,0 +1,2 @@
+java -jar ./lib/${project.build.finalName}.jar
+
diff --git a/pom.xml b/pom.xml
index 74d7bd1..4db133b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
com.casic.sensor
sensor-transfer
1.0-SNAPSHOT
- war
+ jar
UTF-8
@@ -61,10 +61,6 @@
3.4.3
-
- org.postgresql
- postgresql
-
org.projectlombok
@@ -85,6 +81,12 @@
1.2.73
+
+ xyz.downgoon
+ snowflake
+ 1.0.0
+
+
@@ -120,4 +122,154 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/main/build/bin/start.bat b/src/main/build/bin/start.bat
new file mode 100644
index 0000000..d858fb2
--- /dev/null
+++ b/src/main/build/bin/start.bat
@@ -0,0 +1,4 @@
+@echo off
+title ${project.build.finalName}
+java -jar ./lib/${project.build.finalName}.jar
+@pause
diff --git a/src/main/build/bin/start.sh b/src/main/build/bin/start.sh
new file mode 100644
index 0000000..e14c4c7
--- /dev/null
+++ b/src/main/build/bin/start.sh
@@ -0,0 +1,2 @@
+java -jar ./lib/${project.build.finalName}.jar
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index c55e37d..0887f1f 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -3,8 +3,6 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.web.servlet.ServletComponentScan;
-import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.ComponentScan;
/**
diff --git a/pom.xml b/pom.xml
index 74d7bd1..4db133b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
com.casic.sensor
sensor-transfer
1.0-SNAPSHOT
- war
+ jar
UTF-8
@@ -61,10 +61,6 @@
3.4.3
-
- org.postgresql
- postgresql
-
org.projectlombok
@@ -85,6 +81,12 @@
1.2.73
+
+ xyz.downgoon
+ snowflake
+ 1.0.0
+
+
@@ -120,4 +122,154 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/main/build/bin/start.bat b/src/main/build/bin/start.bat
new file mode 100644
index 0000000..d858fb2
--- /dev/null
+++ b/src/main/build/bin/start.bat
@@ -0,0 +1,4 @@
+@echo off
+title ${project.build.finalName}
+java -jar ./lib/${project.build.finalName}.jar
+@pause
diff --git a/src/main/build/bin/start.sh b/src/main/build/bin/start.sh
new file mode 100644
index 0000000..e14c4c7
--- /dev/null
+++ b/src/main/build/bin/start.sh
@@ -0,0 +1,2 @@
+java -jar ./lib/${project.build.finalName}.jar
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index c55e37d..0887f1f 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -3,8 +3,6 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.web.servlet.ServletComponentScan;
-import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.ComponentScan;
/**
diff --git a/src/main/java/com/casic/controller/DeviceController.java b/src/main/java/com/casic/controller/DeviceController.java
index 653db64..6152cb6 100644
--- a/src/main/java/com/casic/controller/DeviceController.java
+++ b/src/main/java/com/casic/controller/DeviceController.java
@@ -1,15 +1,21 @@
package com.casic.controller;
-import com.casic.model.*;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.casic.model.ReceiveDataParam;
+import com.casic.model.ResponseData;
import com.casic.service.DeviceService;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+import java.util.Map;
+@Slf4j
@RestController
-@RequestMapping("/device")
+@RequestMapping("/casic")
public class DeviceController {
@@ -24,9 +30,11 @@
return deviceService.testMysql();
}
- @PostMapping("/online")
- public ResponseData DeviceOnline(@RequestBody DeviceOnlineParam onlineParam) {
- return deviceService.onlineStatusByImei(onlineParam.getEventType(),onlineParam.getImei());
+ @PostMapping("/data/gas")
+ public ResponseData saveDataGas(@RequestBody Map receiveData) {
+ log.error("----------------------第三方燃气数据上报为{}",JSONObject.toJSONString(receiveData));
+ return deviceService.saveDataGas(receiveData);
}
+
}
diff --git a/pom.xml b/pom.xml
index 74d7bd1..4db133b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
com.casic.sensor
sensor-transfer
1.0-SNAPSHOT
- war
+ jar
UTF-8
@@ -61,10 +61,6 @@
3.4.3
-
- org.postgresql
- postgresql
-
org.projectlombok
@@ -85,6 +81,12 @@
1.2.73
+
+ xyz.downgoon
+ snowflake
+ 1.0.0
+
+
@@ -120,4 +122,154 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/main/build/bin/start.bat b/src/main/build/bin/start.bat
new file mode 100644
index 0000000..d858fb2
--- /dev/null
+++ b/src/main/build/bin/start.bat
@@ -0,0 +1,4 @@
+@echo off
+title ${project.build.finalName}
+java -jar ./lib/${project.build.finalName}.jar
+@pause
diff --git a/src/main/build/bin/start.sh b/src/main/build/bin/start.sh
new file mode 100644
index 0000000..e14c4c7
--- /dev/null
+++ b/src/main/build/bin/start.sh
@@ -0,0 +1,2 @@
+java -jar ./lib/${project.build.finalName}.jar
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index c55e37d..0887f1f 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -3,8 +3,6 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.web.servlet.ServletComponentScan;
-import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.ComponentScan;
/**
diff --git a/src/main/java/com/casic/controller/DeviceController.java b/src/main/java/com/casic/controller/DeviceController.java
index 653db64..6152cb6 100644
--- a/src/main/java/com/casic/controller/DeviceController.java
+++ b/src/main/java/com/casic/controller/DeviceController.java
@@ -1,15 +1,21 @@
package com.casic.controller;
-import com.casic.model.*;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.casic.model.ReceiveDataParam;
+import com.casic.model.ResponseData;
import com.casic.service.DeviceService;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+import java.util.Map;
+@Slf4j
@RestController
-@RequestMapping("/device")
+@RequestMapping("/casic")
public class DeviceController {
@@ -24,9 +30,11 @@
return deviceService.testMysql();
}
- @PostMapping("/online")
- public ResponseData DeviceOnline(@RequestBody DeviceOnlineParam onlineParam) {
- return deviceService.onlineStatusByImei(onlineParam.getEventType(),onlineParam.getImei());
+ @PostMapping("/data/gas")
+ public ResponseData saveDataGas(@RequestBody Map receiveData) {
+ log.error("----------------------第三方燃气数据上报为{}",JSONObject.toJSONString(receiveData));
+ return deviceService.saveDataGas(receiveData);
}
+
}
diff --git a/src/main/java/com/casic/controller/DeviceDataController.java b/src/main/java/com/casic/controller/DeviceDataController.java
deleted file mode 100644
index e5351c9..0000000
--- a/src/main/java/com/casic/controller/DeviceDataController.java
+++ /dev/null
@@ -1,37 +0,0 @@
-package com.casic.controller;
-
-import com.casic.model.DataReportParam;
-import com.casic.model.HeartbeatParam;
-import com.casic.model.ResponseData;
-import com.casic.service.DeviceDataService;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-@RequestMapping("/data")
-@RestController
-public class DeviceDataController {
-
- private final DeviceDataService dataService;
-
- public DeviceDataController(DeviceDataService dataService) {
- this.dataService = dataService;
- }
-
- @PostMapping("/commit")
- public ResponseData DeviceDataCommit(@RequestBody DataReportParam dataReportParam) {
- return dataService.DeviceDataCommit(dataReportParam);
- }
-
- @PostMapping("/heartbeat")
- public ResponseData heartBeat(@RequestBody HeartbeatParam heartbeatParam) {
- return dataService.heartBeatSave(heartbeatParam);
- }
-
- @PostMapping("/gas/receiver")
- public ResponseData gasReceiver(@RequestBody HeartbeatParam heartbeatParam) {
- return dataService.heartBeatSave(heartbeatParam);
- }
-
-}
diff --git a/pom.xml b/pom.xml
index 74d7bd1..4db133b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
com.casic.sensor
sensor-transfer
1.0-SNAPSHOT
- war
+ jar
UTF-8
@@ -61,10 +61,6 @@
3.4.3
-
- org.postgresql
- postgresql
-
org.projectlombok
@@ -85,6 +81,12 @@
1.2.73
+
+ xyz.downgoon
+ snowflake
+ 1.0.0
+
+
@@ -120,4 +122,154 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/main/build/bin/start.bat b/src/main/build/bin/start.bat
new file mode 100644
index 0000000..d858fb2
--- /dev/null
+++ b/src/main/build/bin/start.bat
@@ -0,0 +1,4 @@
+@echo off
+title ${project.build.finalName}
+java -jar ./lib/${project.build.finalName}.jar
+@pause
diff --git a/src/main/build/bin/start.sh b/src/main/build/bin/start.sh
new file mode 100644
index 0000000..e14c4c7
--- /dev/null
+++ b/src/main/build/bin/start.sh
@@ -0,0 +1,2 @@
+java -jar ./lib/${project.build.finalName}.jar
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index c55e37d..0887f1f 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -3,8 +3,6 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.web.servlet.ServletComponentScan;
-import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.ComponentScan;
/**
diff --git a/src/main/java/com/casic/controller/DeviceController.java b/src/main/java/com/casic/controller/DeviceController.java
index 653db64..6152cb6 100644
--- a/src/main/java/com/casic/controller/DeviceController.java
+++ b/src/main/java/com/casic/controller/DeviceController.java
@@ -1,15 +1,21 @@
package com.casic.controller;
-import com.casic.model.*;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.casic.model.ReceiveDataParam;
+import com.casic.model.ResponseData;
import com.casic.service.DeviceService;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+import java.util.Map;
+@Slf4j
@RestController
-@RequestMapping("/device")
+@RequestMapping("/casic")
public class DeviceController {
@@ -24,9 +30,11 @@
return deviceService.testMysql();
}
- @PostMapping("/online")
- public ResponseData DeviceOnline(@RequestBody DeviceOnlineParam onlineParam) {
- return deviceService.onlineStatusByImei(onlineParam.getEventType(),onlineParam.getImei());
+ @PostMapping("/data/gas")
+ public ResponseData saveDataGas(@RequestBody Map receiveData) {
+ log.error("----------------------第三方燃气数据上报为{}",JSONObject.toJSONString(receiveData));
+ return deviceService.saveDataGas(receiveData);
}
+
}
diff --git a/src/main/java/com/casic/controller/DeviceDataController.java b/src/main/java/com/casic/controller/DeviceDataController.java
deleted file mode 100644
index e5351c9..0000000
--- a/src/main/java/com/casic/controller/DeviceDataController.java
+++ /dev/null
@@ -1,37 +0,0 @@
-package com.casic.controller;
-
-import com.casic.model.DataReportParam;
-import com.casic.model.HeartbeatParam;
-import com.casic.model.ResponseData;
-import com.casic.service.DeviceDataService;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-@RequestMapping("/data")
-@RestController
-public class DeviceDataController {
-
- private final DeviceDataService dataService;
-
- public DeviceDataController(DeviceDataService dataService) {
- this.dataService = dataService;
- }
-
- @PostMapping("/commit")
- public ResponseData DeviceDataCommit(@RequestBody DataReportParam dataReportParam) {
- return dataService.DeviceDataCommit(dataReportParam);
- }
-
- @PostMapping("/heartbeat")
- public ResponseData heartBeat(@RequestBody HeartbeatParam heartbeatParam) {
- return dataService.heartBeatSave(heartbeatParam);
- }
-
- @PostMapping("/gas/receiver")
- public ResponseData gasReceiver(@RequestBody HeartbeatParam heartbeatParam) {
- return dataService.heartBeatSave(heartbeatParam);
- }
-
-}
diff --git a/src/main/java/com/casic/dao/AlarmJobMapper.java b/src/main/java/com/casic/dao/AlarmJobMapper.java
new file mode 100644
index 0000000..e5e9c8d
--- /dev/null
+++ b/src/main/java/com/casic/dao/AlarmJobMapper.java
@@ -0,0 +1,17 @@
+package com.casic.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.entity.AlarmJob;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+@Mapper
+public interface AlarmJobMapper extends BaseMapper {
+
+ @Select("SELECT MAX(jobcode) " +
+ "FROM alarm_job " +
+ "WHERE JOBCODE like '${jobcode}%'")
+ String getJobCodeMaxSerial(@Param("jobcode") String jobcode);
+
+}
diff --git a/pom.xml b/pom.xml
index 74d7bd1..4db133b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
com.casic.sensor
sensor-transfer
1.0-SNAPSHOT
- war
+ jar
UTF-8
@@ -61,10 +61,6 @@
3.4.3
-
- org.postgresql
- postgresql
-
org.projectlombok
@@ -85,6 +81,12 @@
1.2.73
+
+ xyz.downgoon
+ snowflake
+ 1.0.0
+
+
@@ -120,4 +122,154 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/main/build/bin/start.bat b/src/main/build/bin/start.bat
new file mode 100644
index 0000000..d858fb2
--- /dev/null
+++ b/src/main/build/bin/start.bat
@@ -0,0 +1,4 @@
+@echo off
+title ${project.build.finalName}
+java -jar ./lib/${project.build.finalName}.jar
+@pause
diff --git a/src/main/build/bin/start.sh b/src/main/build/bin/start.sh
new file mode 100644
index 0000000..e14c4c7
--- /dev/null
+++ b/src/main/build/bin/start.sh
@@ -0,0 +1,2 @@
+java -jar ./lib/${project.build.finalName}.jar
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index c55e37d..0887f1f 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -3,8 +3,6 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.web.servlet.ServletComponentScan;
-import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.ComponentScan;
/**
diff --git a/src/main/java/com/casic/controller/DeviceController.java b/src/main/java/com/casic/controller/DeviceController.java
index 653db64..6152cb6 100644
--- a/src/main/java/com/casic/controller/DeviceController.java
+++ b/src/main/java/com/casic/controller/DeviceController.java
@@ -1,15 +1,21 @@
package com.casic.controller;
-import com.casic.model.*;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.casic.model.ReceiveDataParam;
+import com.casic.model.ResponseData;
import com.casic.service.DeviceService;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+import java.util.Map;
+@Slf4j
@RestController
-@RequestMapping("/device")
+@RequestMapping("/casic")
public class DeviceController {
@@ -24,9 +30,11 @@
return deviceService.testMysql();
}
- @PostMapping("/online")
- public ResponseData DeviceOnline(@RequestBody DeviceOnlineParam onlineParam) {
- return deviceService.onlineStatusByImei(onlineParam.getEventType(),onlineParam.getImei());
+ @PostMapping("/data/gas")
+ public ResponseData saveDataGas(@RequestBody Map receiveData) {
+ log.error("----------------------第三方燃气数据上报为{}",JSONObject.toJSONString(receiveData));
+ return deviceService.saveDataGas(receiveData);
}
+
}
diff --git a/src/main/java/com/casic/controller/DeviceDataController.java b/src/main/java/com/casic/controller/DeviceDataController.java
deleted file mode 100644
index e5351c9..0000000
--- a/src/main/java/com/casic/controller/DeviceDataController.java
+++ /dev/null
@@ -1,37 +0,0 @@
-package com.casic.controller;
-
-import com.casic.model.DataReportParam;
-import com.casic.model.HeartbeatParam;
-import com.casic.model.ResponseData;
-import com.casic.service.DeviceDataService;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-@RequestMapping("/data")
-@RestController
-public class DeviceDataController {
-
- private final DeviceDataService dataService;
-
- public DeviceDataController(DeviceDataService dataService) {
- this.dataService = dataService;
- }
-
- @PostMapping("/commit")
- public ResponseData DeviceDataCommit(@RequestBody DataReportParam dataReportParam) {
- return dataService.DeviceDataCommit(dataReportParam);
- }
-
- @PostMapping("/heartbeat")
- public ResponseData heartBeat(@RequestBody HeartbeatParam heartbeatParam) {
- return dataService.heartBeatSave(heartbeatParam);
- }
-
- @PostMapping("/gas/receiver")
- public ResponseData gasReceiver(@RequestBody HeartbeatParam heartbeatParam) {
- return dataService.heartBeatSave(heartbeatParam);
- }
-
-}
diff --git a/src/main/java/com/casic/dao/AlarmJobMapper.java b/src/main/java/com/casic/dao/AlarmJobMapper.java
new file mode 100644
index 0000000..e5e9c8d
--- /dev/null
+++ b/src/main/java/com/casic/dao/AlarmJobMapper.java
@@ -0,0 +1,17 @@
+package com.casic.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.entity.AlarmJob;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+@Mapper
+public interface AlarmJobMapper extends BaseMapper {
+
+ @Select("SELECT MAX(jobcode) " +
+ "FROM alarm_job " +
+ "WHERE JOBCODE like '${jobcode}%'")
+ String getJobCodeMaxSerial(@Param("jobcode") String jobcode);
+
+}
diff --git a/src/main/java/com/casic/dao/AlarmRecordsMapper.java b/src/main/java/com/casic/dao/AlarmRecordsMapper.java
new file mode 100644
index 0000000..fde1818
--- /dev/null
+++ b/src/main/java/com/casic/dao/AlarmRecordsMapper.java
@@ -0,0 +1,36 @@
+package com.casic.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.entity.AlarmRecords;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+@Mapper
+public interface AlarmRecordsMapper extends BaseMapper {
+
+
+ @Select("SELECT JOB_ID AS \"jobId\"\n " +
+ "FROM alarm_records\n " +
+ "WHERE DEVCODE = #{devcode}\n " +
+ "AND ALARM_CONTENT = #{MsgContent}\n " +
+ "AND STATUS='1'\n " +
+ "AND JOB_ID>0 ")
+ String isOldAlarmRecord(@Param("devcode") String devcode, @Param("MsgContent") String MsgContent);
+
+ @Update(" UPDATE alarm_records\n" +
+ " SET STATUS='0'\n" +
+ " WHERE DEVCODE = #{devcode}\n" +
+ " AND ALARM_CONTENT = #{MsgContent}\n" +
+ " AND STATUS='1'")
+ Integer updateOldAlarmRecord(@Param("devcode") String devcode, @Param("MsgContent") String MsgContent);
+
+
+ @Update(" UPDATE alarm_records\n" +
+ " SET STATUS='3'\n" +
+ " WHERE DEVCODE = #{devcode}\n" +
+ " AND STATUS='1'")
+ Integer clearAlarm(@Param("devcode") String devcode);
+
+}
diff --git a/pom.xml b/pom.xml
index 74d7bd1..4db133b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
com.casic.sensor
sensor-transfer
1.0-SNAPSHOT
- war
+ jar
UTF-8
@@ -61,10 +61,6 @@
3.4.3
-
- org.postgresql
- postgresql
-
org.projectlombok
@@ -85,6 +81,12 @@
1.2.73
+
+ xyz.downgoon
+ snowflake
+ 1.0.0
+
+
@@ -120,4 +122,154 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/main/build/bin/start.bat b/src/main/build/bin/start.bat
new file mode 100644
index 0000000..d858fb2
--- /dev/null
+++ b/src/main/build/bin/start.bat
@@ -0,0 +1,4 @@
+@echo off
+title ${project.build.finalName}
+java -jar ./lib/${project.build.finalName}.jar
+@pause
diff --git a/src/main/build/bin/start.sh b/src/main/build/bin/start.sh
new file mode 100644
index 0000000..e14c4c7
--- /dev/null
+++ b/src/main/build/bin/start.sh
@@ -0,0 +1,2 @@
+java -jar ./lib/${project.build.finalName}.jar
+
diff --git a/src/main/java/com/casic/CasicApplication.java b/src/main/java/com/casic/CasicApplication.java
index c55e37d..0887f1f 100644
--- a/src/main/java/com/casic/CasicApplication.java
+++ b/src/main/java/com/casic/CasicApplication.java
@@ -3,8 +3,6 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.web.servlet.ServletComponentScan;
-import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.ComponentScan;
/**
diff --git a/src/main/java/com/casic/controller/DeviceController.java b/src/main/java/com/casic/controller/DeviceController.java
index 653db64..6152cb6 100644
--- a/src/main/java/com/casic/controller/DeviceController.java
+++ b/src/main/java/com/casic/controller/DeviceController.java
@@ -1,15 +1,21 @@
package com.casic.controller;
-import com.casic.model.*;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.casic.model.ReceiveDataParam;
+import com.casic.model.ResponseData;
import com.casic.service.DeviceService;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+import java.util.Map;
+@Slf4j
@RestController
-@RequestMapping("/device")
+@RequestMapping("/casic")
public class DeviceController {
@@ -24,9 +30,11 @@
return deviceService.testMysql();
}
- @PostMapping("/online")
- public ResponseData DeviceOnline(@RequestBody DeviceOnlineParam onlineParam) {
- return deviceService.onlineStatusByImei(onlineParam.getEventType(),onlineParam.getImei());
+ @PostMapping("/data/gas")
+ public ResponseData saveDataGas(@RequestBody Map receiveData) {
+ log.error("----------------------第三方燃气数据上报为{}",JSONObject.toJSONString(receiveData));
+ return deviceService.saveDataGas(receiveData);
}
+
}
diff --git a/src/main/java/com/casic/controller/DeviceDataController.java b/src/main/java/com/casic/controller/DeviceDataController.java
deleted file mode 100644
index e5351c9..0000000
--- a/src/main/java/com/casic/controller/DeviceDataController.java
+++ /dev/null
@@ -1,37 +0,0 @@
-package com.casic.controller;
-
-import com.casic.model.DataReportParam;
-import com.casic.model.HeartbeatParam;
-import com.casic.model.ResponseData;
-import com.casic.service.DeviceDataService;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-@RequestMapping("/data")
-@RestController
-public class DeviceDataController {
-
- private final DeviceDataService dataService;
-
- public DeviceDataController(DeviceDataService dataService) {
- this.dataService = dataService;
- }
-
- @PostMapping("/commit")
- public ResponseData DeviceDataCommit(@RequestBody DataReportParam dataReportParam) {
- return dataService.DeviceDataCommit(dataReportParam);
- }
-
- @PostMapping("/heartbeat")
- public ResponseData heartBeat(@RequestBody HeartbeatParam heartbeatParam) {
- return dataService.heartBeatSave(heartbeatParam);
- }
-
- @PostMapping("/gas/receiver")
- public ResponseData gasReceiver(@RequestBody HeartbeatParam heartbeatParam) {
- return dataService.heartBeatSave(heartbeatParam);
- }
-
-}
diff --git a/src/main/java/com/casic/dao/AlarmJobMapper.java b/src/main/java/com/casic/dao/AlarmJobMapper.java
new file mode 100644
index 0000000..e5e9c8d
--- /dev/null
+++ b/src/main/java/com/casic/dao/AlarmJobMapper.java
@@ -0,0 +1,17 @@
+package com.casic.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.entity.AlarmJob;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+@Mapper
+public interface AlarmJobMapper extends BaseMapper {
+
+ @Select("SELECT MAX(jobcode) " +
+ "FROM alarm_job " +
+ "WHERE JOBCODE like '${jobcode}%'")
+ String getJobCodeMaxSerial(@Param("jobcode") String jobcode);
+
+}
diff --git a/src/main/java/com/casic/dao/AlarmRecordsMapper.java b/src/main/java/com/casic/dao/AlarmRecordsMapper.java
new file mode 100644
index 0000000..fde1818
--- /dev/null
+++ b/src/main/java/com/casic/dao/AlarmRecordsMapper.java
@@ -0,0 +1,36 @@
+package com.casic.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.casic.entity.AlarmRecords;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+@Mapper
+public interface AlarmRecordsMapper extends BaseMapper {
+
+
+ @Select("SELECT JOB_ID AS \"jobId\"\n " +
+ "FROM alarm_records\n " +
+ "WHERE DEVCODE = #{devcode}\n " +
+ "AND ALARM_CONTENT = #{MsgContent}\n " +
+ "AND STATUS='1'\n " +
+ "AND JOB_ID>0 ")
+ String isOldAlarmRecord(@Param("devcode") String devcode, @Param("MsgContent") String MsgContent);
+
+ @Update(" UPDATE alarm_records\n" +
+ " SET STATUS='0'\n" +
+ " WHERE DEVCODE = #{devcode}\n" +
+ " AND ALARM_CONTENT = #{MsgContent}\n" +
+ " AND STATUS='1'")
+ Integer updateOldAlarmRecord(@Param("devcode") String devcode, @Param("MsgContent") String MsgContent);
+
+
+ @Update(" UPDATE alarm_records\n" +
+ " SET STATUS='3'\n" +
+ " WHERE DEVCODE = #{devcode}\n" +
+ " AND STATUS='1'")
+ Integer clearAlarm(@Param("devcode") String devcode);
+
+}
diff --git a/src/main/java/com/casic/dao/DataGasMapper.java b/src/main/java/com/casic/dao/DataGasMapper.java
index 47e7cce..8a064f2 100644
--- a/src/main/java/com/casic/dao/DataGasMapper.java
+++ b/src/main/java/com/casic/dao/DataGasMapper.java
@@ -1,9 +1,36 @@
package com.casic.dao;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.casic.entity.DataGasReport;
+import com.casic.entity.DataGasDector;
import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+import java.util.List;
+import java.util.Map;
@Mapper
-public interface DataGasMapper extends BaseMapper {
+public interface DataGasMapper extends BaseMapper {
+
+ @Select("SELECT level,high_value " +
+ "FROM alarm_level " +
+ "WHERE device_type=#{deviceType} ")
+ List