修复添加目录SQL错误 #881

648540858

2023-06-05 b7d85a270e58daf8abd1bc165f79fee27747d688

 src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java

@@ -1,6 +1,5 @@
package com.genersoft.iot.vmp.vmanager.gb28181.play;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.genersoft.iot.vmp.common.InviteInfo;
@@ -25,6 +24,7 @@
import com.genersoft.iot.vmp.service.bean.InviteErrorCode;
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
import com.genersoft.iot.vmp.utils.DateUtil;
import com.genersoft.iot.vmp.vmanager.bean.ErrorCode;
import com.genersoft.iot.vmp.vmanager.bean.StreamContent;
import com.genersoft.iot.vmp.vmanager.bean.WVPResult;
@@ -116,9 +116,7 @@
      // 录像查询以channelId作为deviceId查询
      resultHolder.put(key, uuid, result);

      playService.play(newMediaServerItem, deviceId, channelId, ((code, msg, data) -> {
         System.out.println("controller收到回调");
         System.out.println(JSON.toJSONString(data));
      playService.play(newMediaServerItem, deviceId, channelId, (code, msg, data) -> {
         WVPResult<StreamContent> wvpResult = new WVPResult<>();
         if (code == InviteErrorCode.SUCCESS.getCode()) {
            wvpResult.setCode(ErrorCode.SUCCESS.getCode());
@@ -135,10 +133,9 @@
            wvpResult.setCode(code);
            wvpResult.setMsg(msg);
         }
         System.out.println(JSON.toJSONString(wvpResult));
         requestMessage.setData(wvpResult);
         resultHolder.invokeResult(requestMessage);
      }));
      });
      return result;
   }

@@ -341,5 +338,35 @@
      return jsonObject;
   }

   @Operation(summary = "获取截图")
   @Parameter(name = "deviceId", description = "设备国标编号", required = true)
   @Parameter(name = "channelId", description = "通道国标编号", required = true)
   @GetMapping("/snap")
   public DeferredResult<String> getSnap(String deviceId, String channelId) {
      if (logger.isDebugEnabled()) {
         logger.debug("获取截图: {}/{}", deviceId, channelId);
      }

      DeferredResult<String> result = new DeferredResult<>(3 * 1000L);
      String key  = DeferredResultHolder.CALLBACK_CMD_SNAP + deviceId;
      String uuid  = UUID.randomUUID().toString();
      resultHolder.put(key, uuid,  result);

      RequestMessage message = new RequestMessage();
      message.setKey(key);
      message.setId(uuid);

      String fileName = deviceId + "_" + channelId + "_" + DateUtil.getNowForUrl() + ".jpg";
      playService.getSnap(deviceId, channelId, fileName, (code, msg, data) -> {
         if (code == InviteErrorCode.SUCCESS.getCode()) {
            message.setData(data);
         }else {
            message.setData(WVPResult.fail(code, msg));
         }
         resultHolder.invokeResult(message);
      });
      return result;
   }

}