调用报警推送信息

vehicle-admin/src/main/java/com/ozs/web/controller/sdk/GeoHazardMonitorTokenController.java

@@ -54,6 +54,7 @@ import com.ozs.service.VehiclePositionService;
 import com.ozs.system.mapper.SysUserMapper;
 import com.ozs.web.common.Constant;
 import com.ozs.web.controller.monitor.SysUserOnlineController;
+import com.ozs.web.controller.websocket.WebSocketCommon;
 import com.ozs.web.controller.websocket.WebSocketServer;
 import com.ozs.web.core.util.CameraUtil;
 import lombok.extern.slf4j.Slf4j;
@@ -126,6 +127,8 @@ public class GeoHazardMonitorTokenController {
     private BaseTerminalService baseTerminalService;
     @Resource
     private SysUserMapper sysUserMapper;
+    @Autowired
+    WebSocketCommon webSocketCommon;
 
     /**
      * 获取web访问令牌
@@ -326,6 +329,7 @@ public class GeoHazardMonitorTokenController {
                 msgAlarmVice.setRailwayCode(reqMsgAlarmVo.getAlarmRailway());
                 msgAlarmVice.setAlarmTime(new Date(reqMsgAlarmVo.getAlarmTime()));
                 msgAlarmFrequencyService.save(msgAlarmVice);
+                webSocketCommon.publish(msgAlarm);
                 for (BaseCameraManagement baseCameraManagement : baseCameraManagementList) {
                     String invite = CameraUtil.invite(baseCameraManagement.getCameraCode(), baseCameraManagement.getChannel());
                     if ("304".equals(invite) || "200".equals(invite)) {