소스 검색

第三方报警推送开启websocket推送

gao.qiang 1 주 전
부모
커밋
8d158daf40
1개의 변경된 파일14개의 추가작업 그리고 0개의 파일을 삭제
  1. 14 0
      hazard-sdk/src/main/java/com/ozs/controller/upload/GeoHazardMonitorTokenController.java

+ 14 - 0
hazard-sdk/src/main/java/com/ozs/controller/upload/GeoHazardMonitorTokenController.java

@@ -260,6 +260,20 @@ public class GeoHazardMonitorTokenController {
                     }
                     respMsgAlarmVo.setCancelTime(null);
                 }
+                try {
+                    MsgAlarm alarms = msgAlarmService.getOne(lw);
+                    log.info("sdkUrl:{}", sdkUrl);
+                    log.info("alarmJSON :{}", JSON.toJSONString(alarms));
+                    String result = HttpClientUtil.postJson(sdkUrl, JSON.toJSONString(alarms));
+                    log.info("result:{}", result);
+                } catch (Exception e) {
+                    log.info(e.getMessage());
+                    e.printStackTrace();
+                    jsonObject.put("resultCode", 0);
+                    jsonObject.put("message", "失败");
+                    jsonObject.put("data", "消息推送失败");
+                    return SM4Utils.encryptData_ECB(JSONObject.toJSONString(jsonObject), "4370780c9a8c43e5");
+                }
                 jsonObject.put("resultCode", 1);
                 jsonObject.put("message", "成功");
                 jsonObject.put("data", respMsgAlarmVo);