zhongrj
2024-05-08 380c2d0e157bc3276604d204d075e4041ebd64aa
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/hk/controller/HkEventController.java
@@ -109,6 +109,7 @@
    */
   @GetMapping(value = "/eventSubscriptionByEventTypes")
   public R eventSubscriptionByEventTypes(EventVO eventVO) {
      eventVO.setType(3);
      String result = addEventSubscriptionByEventTypes(eventVO, HkConstant.eventSubscriptionByEventTypesURLs);
      log.info("事件订阅返回信息:" + result);
      JSONObject jsonObject1 = JSONObject.parseObject(result);
@@ -123,6 +124,7 @@
    */
   @GetMapping(value = "/eventUnSubscriptionByEventTypes")
   public R eventUnSubscriptionByEventTypes(EventVO eventVO) {
      eventVO.setType(3);
      String result = removeEventSubscriptionByEventTypes(eventVO, HkConstant.eventUnSubscriptionByEventTypesURLs);
      JSONObject jsonObject1 = JSONObject.parseObject(result);
      // 查询海康设备列表并返回
@@ -136,6 +138,7 @@
    */
   @GetMapping(value = "/eventSubscriptionView")
   public R eventSubscriptionView(EventVO eventVO) {
      eventVO.setType(3);
      String result = getEventSubscriptionView(eventVO, HkConstant.eventSubscriptionViewURLs);
      JSONObject jsonObject1 = JSONObject.parseObject(result);
      // 查询海康设备列表并返回
@@ -153,6 +156,7 @@
      JSONObject jsonObject = JSON.parseObject(data);
      String prettyData = JSON.toJSONString(jsonObject, SerializerFeature.PrettyFormat,
         SerializerFeature.WriteMapNullValue);
      log.info("收到事件:" + jsonObject);
      // 异步保存数据
      asyncHkEventService.saveHkEventInfo(prettyData);
      // 立即返回