HelloController.java 9.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223
  1. package com.persagy.cameractl.controller;
  2. import com.alibaba.fastjson.JSONObject;
  3. import com.persagy.cameractl.cache.SceneConfigCache;
  4. import com.persagy.cameractl.model.NvrSceneRelation;
  5. import com.persagy.cameractl.model.SceneConfig;
  6. import com.persagy.cameractl.service.PtzMain;
  7. import com.persagy.cameractl.service.windows.Nvr9CameraExecuteApi;
  8. import com.persagy.cameractl.utils.*;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.apache.commons.lang.StringUtils;
  11. import org.springframework.beans.factory.annotation.Autowired;
  12. import org.springframework.web.bind.annotation.*;
  13. import javax.servlet.http.HttpServletRequest;
  14. import javax.servlet.http.HttpServletResponse;
  15. import java.io.File;
  16. import java.io.OutputStream;
  17. import java.nio.file.Files;
  18. import java.util.*;
  19. import java.util.Map.Entry;
  20. @Slf4j
  21. @CrossOrigin
  22. @RestController
  23. public class HelloController {
  24. @Autowired
  25. private PtzMain ptzMain;
  26. @RequestMapping(value = "/hello/{name}", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
  27. public @ResponseBody String helloName(@PathVariable("name") String name) {
  28. return ResultTools.errorResult(name);
  29. }
  30. /**
  31. * 摄像头操作接口(底层调用SDK),包括:摄像头控制、回放、查询SDK日志。客户端回放流程为:客户端先调用该接口,成功后再调用vplayf接口播放MP4
  32. * opertype为control时,参数:command、cameraIp、cameraPort、userName、password、channel、
  33. * speed
  34. *
  35. * opertype为playback时,参数:cameraIp、cameraPort、userName、password、channel、
  36. * startDateStr、endDateStr
  37. *
  38. * opertype为searchlog时,参数:cameraIp、cameraPort、userName、password、channel、
  39. * startDateStr、endDateStr
  40. */
  41. @RequestMapping(value = "/sdk/{opertype}", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
  42. public String ptzOperation(@PathVariable("opertype") String operType, @RequestBody Camera _camera) {
  43. // 拆分rtsp://(Admin:123@)0.0.0.0(:0)(/xxx/xxxxxx)(?xxx=xxxx) 中的ip地址
  44. if (StringUtils.isNotEmpty(_camera.ipcIp) && _camera.ipcIp.startsWith("rtsp://")) {
  45. String val = _camera.ipcIp.substring(7);
  46. int idx = val.indexOf('@');
  47. if (idx > -1) {
  48. val = val.substring(idx + 1);
  49. }
  50. idx = val.indexOf('/');
  51. if (idx > -1) {
  52. val = val.substring(0, idx);
  53. }
  54. idx = val.indexOf(':');
  55. if (idx > -1) {
  56. val = val.substring(0, idx);
  57. }
  58. idx = val.indexOf('?');
  59. if (idx > -1) {
  60. val = val.substring(0, idx);
  61. }
  62. _camera.ipcIp = val;
  63. }
  64. // 2022-07-04 视频必须转码
  65. _camera.transcoding = true;
  66. ResultClass result = ptzMain.ptzOper(_camera, operType);
  67. switch (String.valueOf(result.name)) {
  68. // 调用成功
  69. case "true":
  70. return ResultTools.dataResult(result.resultData);
  71. // 调用失败
  72. default:
  73. return ResultTools.errorResult(result.reason);
  74. }
  75. }
  76. /**
  77. * 请求视频文件接口
  78. */
  79. @RequestMapping(value = "/vplayf/{file}", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
  80. public void vplay(@PathVariable("file") String file, HttpServletResponse response,
  81. HttpServletRequest request) {
  82. String filePath = OtherTools.getLocalVideoFilePath(file);
  83. if (filePath.equals(""))
  84. return;
  85. try {
  86. File videoFile = new File(filePath);
  87. if (!videoFile.exists())
  88. return;
  89. response.setContentType(String.format("video/%s", OtherTools.getFileSuffix(file)));
  90. response.setHeader("Content-Disposition", "attachment; filename=\"" + file + "\"");
  91. response.setContentLength((int) videoFile.length());
  92. // 不支持分段请求
  93. response.setHeader("Accept-Ranges", "none");
  94. response.setHeader("Etag", "W/\"" + StringTools.getUUID() + "\"");
  95. OutputStream os = response.getOutputStream();
  96. Files.copy(videoFile.toPath(), os);
  97. // 先声明的流后关掉!
  98. os.flush();
  99. os.close();
  100. } catch (Exception e) {
  101. log.error("播放" + file + "异常:", e);
  102. }
  103. }
  104. /**
  105. * 获取场景
  106. *
  107. * @param oper
  108. * @return
  109. * @date 2021年11月4日 下午12:11:52
  110. */
  111. @GetMapping(value = "/config/{oper}")
  112. public Map<String, Object> scene(@PathVariable("oper") String oper) {
  113. Map<String, Object> result = new HashMap<String, Object>();
  114. result.put(ResultTools.key_result, ResultTools.result_success);
  115. List<Object> dataList = new ArrayList<Object>();
  116. Map<String, NvrSceneRelation> sceneConfig = SceneConfigCache.SCENE_CONFIG;
  117. Set<Entry<String,NvrSceneRelation>> entrySet = sceneConfig.entrySet();
  118. Iterator<Entry<String, NvrSceneRelation>> iterator = entrySet.iterator();
  119. switch (oper) {
  120. case "scene":
  121. Set<String> temp = new HashSet<String>();
  122. while (iterator.hasNext()) {
  123. Entry<String, NvrSceneRelation> next = iterator.next();
  124. NvrSceneRelation sceneRelation = next.getValue();
  125. String key = sceneRelation.getGroup() + "_" + sceneRelation.getScene();
  126. if (!temp.contains(key)) {
  127. JSONObject jsonObject = new JSONObject();
  128. jsonObject.put("group", sceneRelation.getGroup());
  129. jsonObject.put("scene", sceneRelation.getScene());
  130. dataList.add(jsonObject);
  131. temp.add(key);
  132. }
  133. }
  134. break;
  135. case "json":
  136. while (iterator.hasNext()) {
  137. Entry<String, NvrSceneRelation> next = iterator.next();
  138. dataList.add(next.getValue());
  139. }
  140. break;
  141. default:
  142. break;
  143. }
  144. result.put(ResultTools.key_data, dataList);
  145. return result;
  146. }
  147. /**
  148. * 调用软件平台接口,根据摄像头监控点位获取预览流url、回放流url、云台控制
  149. * operType: preview 预览 playback 回放 control 云台控制 other 支持传入接口名称和参数,方便调试 tvwall 获取视频墙列表
  150. * tvwalllayout 获取某个视频墙的布局 toup 投屏,即上墙操作 exittoup 退出投屏
  151. * kaichuang 在电视墙屏幕上进行开窗 setwinsource 设置窗口视频源
  152. * 预览参数:
  153. * cameraIndexCode(视频通道编码,例1000000$1$0$0)、streamType(码流类型,可不传,不传时默认1; 0:主码流 1:子码流 2:第三码流)、levelNo(级联号,没有时不传)
  154. * 回放参数:
  155. * cameraIndexCode(视频通道编码,例1000000$1$0$0)、streamType(码流类型,可不传,不传时默认1; 0:主码流 1:子码流 2:第三码流)、levelNo(级联号,没有时不传)
  156. * startDateStr(开始时间,2021-04-01 11:12:13)、endDateStr(结束时间,2021-04-01 11:12:13)
  157. * 云台控制参数:
  158. * cameraIndexCode(视频通道编码,例1000000$1$0$0)、command(控制命令)、speed(速度,值范围1~8,默认8)
  159. *
  160. * other 根据传入接口名称来调用对应的大华软件平台接口,参数:
  161. * url 调用的大华软件平台接口名称,例:admin/rest/api
  162. * paramStr 自定义参数,格式:{_type:"get | post",interfaceId:"可为空",isToken:"1 url上需要拼接token | 0 url上不需要拼接token"}
  163. * jsonParam 传给大华软件平台的接口参数;例:"{\"param\":{\"category\":1}}"
  164. *
  165. * 获取视频墙列表参数
  166. * 无
  167. * 获取某个视频墙的布局参数
  168. * tvWallId 视频墙ID
  169. * 投屏参数
  170. * layoutCode one(只有一个窗口)、left-up-one(六个窗口,左上角是大窗口)、right-down-one(六个窗口,右下角是大窗口)、right-up-one(六个窗口,右上角是大窗口)、left-down-one(六个窗口,左下角是大窗口)、multi-one(九宫格窗口)
  171. * cameraIndexArr 视频墙数据源数组,每一项均为cameraIndexCode,数组的顺序和窗口顺序保持一致
  172. */
  173. @RequestMapping(value = "/vision/{opertype}", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
  174. public String hikvisionOper(@PathVariable("opertype") String operType, @RequestBody SceneConfig sceneConfig) {
  175. log.info("调用NVR9平台接口开始,操作类型:{},场景配置:{}", operType, sceneConfig);
  176. long start = System.currentTimeMillis();
  177. Nvr9CameraExecuteApi dahCameraExecuteApi = new Nvr9CameraExecuteApi();
  178. ResultClass executeResult = operType.equals("currentVideo") ? dahCameraExecuteApi.currentVideo(sceneConfig.getNvrSceneRelation())
  179. : operType.equals("currentlunx") ? dahCameraExecuteApi.currentlunx(sceneConfig.getNvrSceneRelation())
  180. : operType.equals("transitionScene") ? dahCameraExecuteApi.transitionScene(sceneConfig)
  181. : operType.equals("toup") ? dahCameraExecuteApi.toup(sceneConfig)
  182. : operType.equals("lunx") ? dahCameraExecuteApi.lunx(sceneConfig)
  183. : new ResultClass(false, "非法请求");
  184. switch (String.valueOf(executeResult.name)) {
  185. case "true":
  186. log.info("调用NVR9平台接口success,返回值:{},耗时:{} ms", ResultTools.dataResult(executeResult.resultData), (System.currentTimeMillis() - start));
  187. return ResultTools.dataResult(executeResult.resultData);
  188. default:
  189. log.warn("调用NVR9平台接口success,返回值:{},耗时:{} ms", ResultTools.dataResult(executeResult.reason), (System.currentTimeMillis() - start));
  190. return ResultTools.errorResult(executeResult.reason);
  191. }
  192. }
  193. }