|
@@ -15,6 +15,8 @@ import com.ozs.entity.MsgAlarmExt;
|
|
|
import com.ozs.entity.MsgAlarmFrequency;
|
|
|
import com.ozs.entity.SvcAddress;
|
|
|
import com.ozs.entity.vo.Files;
|
|
|
+import com.ozs.entity.vo.HeartbeatVo;
|
|
|
+import com.ozs.entity.vo.ReleaseAlarmVo;
|
|
|
import com.ozs.entity.vo.ReqMsgAlarmVo;
|
|
|
import com.ozs.entity.vo.RespGeoHazardMonitorVo;
|
|
|
import com.ozs.entity.vo.RespMsgAlarmVo;
|
|
@@ -41,7 +43,9 @@ import javax.servlet.http.HttpServletRequest;
|
|
|
import java.text.ParseException;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.Date;
|
|
|
+import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
|
|
|
/**
|
|
|
* 1. 获取身份认证控制层
|
|
@@ -245,25 +249,93 @@ public class GeoHazardMonitorTokenController {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 报警解除接口
|
|
|
+ *
|
|
|
+ * @param parameter
|
|
|
+ * @param request
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @PostMapping("/api/releaseAlarm")
|
|
|
+ public String releaseAlarm(@RequestParam("parameter") String parameter, HttpServletRequest request) {
|
|
|
+ String token = apiTokenUtils.getGeoHazardMonitorToken(request);
|
|
|
+ log.info("token:{}", token);
|
|
|
+ log.info("parameter:{}", parameter);
|
|
|
+ JSONObject jsonObject = new JSONObject();
|
|
|
+ if (StringUtils.isNotEmpty(token)) {
|
|
|
+ String s = SM4Utils.decryptData_ECB(parameter, "4370780c9a8c43e5");
|
|
|
+ ReleaseAlarmVo releaseAlarmVo = JSON.parseObject(s, ReleaseAlarmVo.class);
|
|
|
+ LambdaQueryWrapper<MsgAlarm> wrapper = new LambdaQueryWrapper<>();
|
|
|
+ wrapper.eq(MsgAlarm::getAlarmId, releaseAlarmVo.getAlarmId());
|
|
|
+ MsgAlarm msgAlarm = msgAlarmService.getOne(wrapper);
|
|
|
+ if (ObjectUtils.isEmpty(msgAlarm)) {
|
|
|
+ jsonObject.put("resultCode", 0);
|
|
|
+ jsonObject.put("message", "失败");
|
|
|
+ jsonObject.put("data", "不存在该报警的唯一标识的数据");
|
|
|
+ return SM4Utils.encryptData_ECB(JSONObject.toJSONString(jsonObject), "4370780c9a8c43e5");
|
|
|
+ }
|
|
|
+ if (releaseAlarmVo.getReleaseTime().toString().length() == 10) {
|
|
|
+ releaseAlarmVo.setReleaseTime(releaseAlarmVo.getReleaseTime() * 1000);
|
|
|
+ }
|
|
|
+ msgAlarm.setReleasedTime(new Date(releaseAlarmVo.getReleaseTime()));
|
|
|
+ msgAlarm.setReleaseContent(releaseAlarmVo.getReleaseContent());
|
|
|
+ msgAlarm.setReleasedBy(releaseAlarmVo.getOperator());
|
|
|
+ msgAlarm.setUpdateBy(releaseAlarmVo.getOperator());
|
|
|
+ boolean count = msgAlarmService.updateById(msgAlarm);
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
+ map.put("alarmId", msgAlarm.getAlarmId());
|
|
|
+ if (count) {
|
|
|
+ map.put("releaseState", 1);
|
|
|
+ jsonObject.put("resultCode", 1);
|
|
|
+ jsonObject.put("message", "成功");
|
|
|
+ jsonObject.put("data", map);
|
|
|
+ } else {
|
|
|
+ map.put("releaseState", 2);
|
|
|
+ jsonObject.put("resultCode", 0);
|
|
|
+ jsonObject.put("message", "失败");
|
|
|
+ jsonObject.put("data", map);
|
|
|
+ }
|
|
|
+ return SM4Utils.encryptData_ECB(JSONObject.toJSONString(jsonObject), "4370780c9a8c43e5");
|
|
|
+ } else {
|
|
|
+ jsonObject.put("resultCode", 2);
|
|
|
+ jsonObject.put("message", "失败");
|
|
|
+ jsonObject.put("data", "token验证失败");
|
|
|
+ return SM4Utils.encryptData_ECB(JSONObject.toJSONString(jsonObject), "4370780c9a8c43e5");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ @PostMapping("/api/terminal/heartbeat")
|
|
|
+ public String heartbeat(@RequestParam("parameter") String parameter, HttpServletRequest request) {
|
|
|
+ String token = apiTokenUtils.getGeoHazardMonitorToken(request);
|
|
|
+ log.info("token:{}", token);
|
|
|
+ log.info("parameter:{}", parameter);
|
|
|
+ JSONObject jsonObject = new JSONObject();
|
|
|
+ if (StringUtils.isNotEmpty(token)) {
|
|
|
+ String s = SM4Utils.decryptData_ECB(parameter, "4370780c9a8c43e5");
|
|
|
+ HeartbeatVo heartbeatVo = JSON.parseObject(s, HeartbeatVo.class);
|
|
|
+// BeanUtils.copyProperties(heartbeatVo, msgAlarm);
|
|
|
+
|
|
|
+ jsonObject.put("resultCode", 1);
|
|
|
+ jsonObject.put("message", "成功");
|
|
|
+ jsonObject.put("data", null);
|
|
|
+ return SM4Utils.encryptData_ECB(JSONObject.toJSONString(jsonObject), "4370780c9a8c43e5");
|
|
|
+ } else {
|
|
|
+ jsonObject.put("resultCode", 2);
|
|
|
+ jsonObject.put("message", "失败");
|
|
|
+ jsonObject.put("data", "token验证失败");
|
|
|
+ return SM4Utils.encryptData_ECB(JSONObject.toJSONString(jsonObject), "4370780c9a8c43e5");
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
public static void main(String[] args) {
|
|
|
JSONObject res = new JSONObject();
|
|
|
- Files[] files = new Files[1];
|
|
|
- files[0] = new Files();
|
|
|
- files[0].fileUrl = "/1244/1/25/2023-03-03/63a1fe3084f24928915dafcf8a47a925.png";
|
|
|
- files[0].fileType = 1;
|
|
|
- res.put("alarmMile", 14000);
|
|
|
- res.put("lineDir", 1);
|
|
|
- res.put("alarmRailway", "G502");
|
|
|
res.put("alarmId", "42010001541320001115");
|
|
|
- res.put("alarmTime", 1681183564L);
|
|
|
- res.put("content", "报警内容");
|
|
|
- res.put("alarmType", 1);
|
|
|
- res.put("alarmLevel", 2);
|
|
|
- res.put("alarmConfidence", 1);
|
|
|
- res.put("alarmAttr", "1280,1280,80,0,738,660");
|
|
|
- res.put("files", files);
|
|
|
+ res.put("releaseTime", 1681200512L);
|
|
|
+ res.put("releaseContent", "已处理");
|
|
|
+ res.put("operator", 1);
|
|
|
String s = SM4Utils.encryptData_ECB(JSONObject.toJSONString(res), "4370780c9a8c43e5");
|
|
|
System.out.println(s);
|
|
|
-
|
|
|
}
|
|
|
}
|