HaiKangController.php 50 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: qiuzijian
  5. * Date: 2021-04-28
  6. * Time: 20:59
  7. */
  8. namespace Modules\Camera\Http\Controllers\Api;
  9. use App\Enum\ApiEnum;
  10. use App\Http\Controllers\Api\BaseController;
  11. use Illuminate\Http\Request;
  12. use Illuminate\Support\Facades\Input;
  13. use Illuminate\Support\Facades\Log;
  14. use Modules\Camera\Entities\CameraList;
  15. use Modules\Camera\Enum\CameraEnum;
  16. use Modules\Mine\Entities\MineList;
  17. use Modules\Mine\Services\MineServices;
  18. use Modules\Camera\Services\CameraServices;
  19. use DB;
  20. class HaiKangController extends BaseController
  21. {
  22. protected $pre_url; // 海康接口地址
  23. protected $app_key; // 海康app_key
  24. protected $app_secret; // 海康app_secret
  25. protected $sign;// 签名
  26. protected $time;// 时间戳
  27. protected $artemis;// OpenAPI接口的上下文
  28. public function __construct()
  29. {
  30. // if ($request->has('mine')) {
  31. // $this->pre_url = config('haikang.' . $request->input('mine') . '.pre_url'); // https://120.253.79.51:4433
  32. // $this->app_key = config('haikang.' . $request->input('mine') . '.app_key'); // 25720460
  33. // $this->app_secret = config('haikang.' . $request->input('mine') . '.app_secret'); // qqP7NLcIDwO9MgtYmp8L
  34. // $this->artemis = config('haikang.' . $request->input('mine') . '.artemis'); // /artemis
  35. // } else {
  36. // $this->pre_url = env('HAI_KANG_URL'); // https://120.253.79.51:4433
  37. // $this->app_key = env('HAI_KANG_APP_KEY'); // 25720460
  38. // $this->app_secret = env('HAI_KANG_APP_SECRET'); // qqP7NLcIDwO9MgtYmp8L
  39. // $this->artemis = env('HAI_KANG_ARTEMIS_PATH'); // /artemis
  40. // }
  41. // $this->pre_url = 'https://10.71.252.64:4433'; // https://120.253.79.51:4433
  42. // $this->app_key = '25720460'; // 25720460
  43. // $this->app_secret = 'qqP7NLcIDwO9MgtYmp8L'; // qqP7NLcIDwO9MgtYmp8L
  44. // $this->artemis = '/artemis'; // /artemis
  45. $this->pre_url = Input::get('url'); // https://120.253.79.51:4433
  46. $this->app_key = Input::get('key'); // 25720460
  47. $this->app_secret = Input::get('secret'); // qqP7NLcIDwO9MgtYmp8L
  48. $this->artemis = '/artemis'; // /artemis
  49. list($msec, $sec) = explode(' ', microtime());
  50. $this->time = (float)sprintf('%.0f', (floatval($msec) + floatval($sec)) * 1000);
  51. }
  52. //视频质量诊断
  53. public function videoQuality(){
  54. $indexCode = Input::get('indexCode');
  55. $url = $this->artemis . '/api/nms/v1/vqd/list';
  56. //请求参数
  57. $params = [];
  58. $params['pageNo'] = 1;
  59. $params['pageSize'] = 20;
  60. $params['indexCodes'] = [$indexCode];
  61. $this->sign = $this->get_sign($url);
  62. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  63. $result = json_decode($result, true);
  64. return $result;
  65. }
  66. //根据区域编号获取下一级区域列表
  67. public function getChildMineList(){
  68. $url = $this->artemis . '/api/resource/v2/regions/subRegions';
  69. //请求参数
  70. $params = [];
  71. $params['parentIndexCode'] = Input::get('index_code');
  72. $params['resourceType'] = 'camera';
  73. $params['pageNo'] = 1;
  74. $params['pageSize'] = 1000;
  75. $params['cascadeFlag'] = 0;
  76. $this->sign = $this->get_sign($url);
  77. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  78. $result = json_decode($result, true);
  79. dd($result);
  80. }
  81. /**
  82. * 获取区域列表
  83. * @return bool|mixed|string
  84. */
  85. public function getRegionsList()
  86. {
  87. $url = $this->artemis . '/api/resource/v1/regions';
  88. //请求参数
  89. $params = [];
  90. // $params['pageNo'] = $request->has('pageNo') ? intval($request->input('pageNo')) : 1;
  91. // $params['pageSize'] = $request->has('pageSize') ? intval($request->input('pageSize')) : 1000;
  92. $params['pageNo'] = 1;
  93. $params['pageSize'] = 1000;
  94. $this->sign = $this->get_sign($url);
  95. $type = Input::get('type');
  96. $mine_id = Input::get('mine_id');
  97. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  98. $result = json_decode($result, true);
  99. //超出1000条数据
  100. if(isset($result['data']['list']) && count((array)$result['data']['list']) == 1000){
  101. $params['pageNo'] = 2;
  102. $result2 = $this->curlPost($this->pre_url . $url, json_encode($params));
  103. $result2 = json_decode($result2, true);
  104. }
  105. $area_list = [];
  106. if (isset($result['code']) && $result['code'] == 0 && isset($result['data']['list'])) {
  107. if(isset($result2)){
  108. $list = array_merge($result['data']['list'],$result2['data']['list']);
  109. }else{
  110. $list = $result['data']['list'];
  111. }
  112. foreach ($list as $key => $item) {
  113. $area_list[] = $item['indexCode'];
  114. if ($item['parentIndexCode'] == '-1') {
  115. unset($list[$key]);
  116. }
  117. }
  118. $result['data']['list'] = array_values($list);
  119. }else{
  120. $result['data']['list'] = [];
  121. }
  122. if ($type == CameraEnum::REQUEST_TYPE_API) {
  123. $result['data']['list'] = $this->regionsTree($result['data']['list']);
  124. } else {
  125. //先删除不存在的区域
  126. if ($area_list) {
  127. MineList::where('degree', 'like', $mine_id . '|%')->whereNotIn('index_code', $area_list)->delete();
  128. }
  129. //更新区域
  130. $result['data']['list'] = $this->saveTree($result['data']['list'], $mine_id);
  131. }
  132. return $result;
  133. }
  134. protected function regionsTree($regions, $pid = 'root000000')
  135. {
  136. $arr = [];
  137. if (empty($regions)) {
  138. return [];
  139. }
  140. foreach ($regions as $key => $value) {
  141. if (isset($value['parentIndexCode']) && $value['parentIndexCode'] == $pid) {
  142. $arr[$key]['indexCode'] = $value['indexCode'];
  143. $arr[$key]['mine_id'] = $value['indexCode'];
  144. $arr[$key]['name'] = $value['name'];
  145. $arr[$key]['parentIndexCode'] = $value['parentIndexCode'];
  146. $arr[$key]['treeCode'] = $value['treeCode'];
  147. $arr[$key]['children'] = array_values(self::regionsTree($regions, $value['indexCode']));
  148. unset($arr[$key]['indexCode']);
  149. unset($arr[$key]['parentIndexCode']);
  150. unset($arr[$key]['treeCode']);
  151. if (count($arr[$key]['children']) == 0) {
  152. unset($arr[$key]['children']);
  153. }
  154. }
  155. }
  156. return array_values($arr);
  157. }
  158. protected function saveTree($regions, $parent_id, $pid = 'root000000')
  159. {
  160. $arr = [];
  161. if (empty($regions)) {
  162. return [];
  163. }
  164. $mineService = new MineServices();
  165. $mineService->initMineList();
  166. $arr_count = count($regions);
  167. foreach ($regions as $key => $value) {
  168. if (isset($value['parentIndexCode']) && $value['parentIndexCode'] == $pid) {
  169. $arr[$key]['indexCode'] = $value['indexCode'];
  170. $arr[$key]['mine_id'] = $value['indexCode'];
  171. $arr[$key]['name'] = str_replace('#', '号', $value['name']);
  172. $arr[$key]['parentIndexCode'] = $value['parentIndexCode'];
  173. $arr[$key]['treeCode'] = $value['treeCode'];
  174. $id = MineList::where('index_code', $value['indexCode'])->value('id');
  175. $params = [
  176. 'id' => $id,
  177. 'parent_id' => $parent_id,
  178. 'title' => $value['name'],
  179. 'sort' => $arr_count - $key,
  180. 'index_code' => $value['indexCode'],
  181. ];
  182. $result = $mineService->add($params);
  183. $mine_id = $result->id;
  184. $arr[$key]['children'] = array_values(self::saveTree($regions, $mine_id, $value['indexCode']));
  185. if (count($arr[$key]['children']) == 0) {
  186. unset($arr[$key]['children']);
  187. }
  188. }
  189. }
  190. return array_values($arr);
  191. }
  192. /**
  193. * 获取区域监控列表
  194. * @return bool|mixed|string
  195. */
  196. public function getCamerasList()
  197. {
  198. if (!Input::has('indexCode')) {
  199. return $this->error(1, '缺少必要参数');
  200. }
  201. $url = $this->artemis . '/api/resource/v1/regions/regionIndexCode/cameras';
  202. //请求参数
  203. $params = [];
  204. $params['regionIndexCode'] = Input::get('indexCode');
  205. // $params['pageNo'] = $request->has('pageNo') ? intval($request->input('pageNo')) : 1;
  206. // $params['pageSize'] = $request->has('pageSize') ? intval($request->input('pageSize')) : 1000;
  207. $params['pageNo'] = 1;
  208. $params['pageSize'] = 1000;
  209. $this->sign = $this->get_sign($url);
  210. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  211. $result = json_decode($result, true);
  212. return $result;
  213. }
  214. //查询区域列表v2
  215. public function getMineInfo($mine_name)
  216. {
  217. if (!Input::has('indexCode')) {
  218. return $this->error(1, '缺少必要参数');
  219. }
  220. $url = $this->artemis . '/api/irds/v2/region/nodesByParams';
  221. //请求参数
  222. $params = [];
  223. $params['resourceType'] = 'region';
  224. $params['pageNo'] = 1;
  225. $params['pageSize'] = 1000;
  226. $params['regionName'] = $mine_name;
  227. $this->sign = $this->get_sign($url);
  228. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  229. $result = json_decode($result, true);
  230. if(isset($result['data']['list'][0]['updateTime'])){
  231. $mine_update_time = strtotime($result['data']['list'][0]['updateTime']);
  232. $mine_update_time = number_format((time() - $mine_update_time)/(60*60*24),2);
  233. if($mine_update_time < 1){
  234. return true;
  235. }else{
  236. return false;
  237. }
  238. }else{
  239. return false;
  240. }
  241. }
  242. public function getCameraStatus($indexCode){
  243. $url = $this->artemis . '/api/nms/v1/online/camera/get';
  244. $params = [];
  245. $params['regionId'] = 'root000000';
  246. $params['includeSubNode'] = '1';
  247. $params['indexCodes'] = [$indexCode];
  248. // $params['status'] = '1';
  249. $params['pageNo'] = 1;
  250. $params['pageSize'] = 20;
  251. $this->sign = $this->get_sign($url);
  252. $result_status = $this->curlPost($this->pre_url . $url, json_encode($params));
  253. $result_status = json_decode($result_status, true);
  254. if(isset($result_status['data']['list'][0]['online']) && $result_status['data']['list'][0]['online'] == 0){
  255. return 2;//离线
  256. }else{
  257. return 1;//在线
  258. }
  259. }
  260. //洗选执法记录仪
  261. public function getWssCameraUrl(){
  262. if (!Input::has('cameraIndexCode')) {
  263. return $this->error(1, '缺少必要参数');
  264. }
  265. $parent_id = Input::get('parent_id');
  266. $protocol = Input::get('protocol', 'hls');
  267. $streamType = Input::get('streamType', 1);
  268. $url = $this->artemis . '/api/video/v2/cameras/previewURLs';
  269. // $cameras_info = json_decode($this->getCamerasInfo(Input::all()), true);
  270. //请求参数
  271. $params = [];
  272. // $params['regionIndexCode'] = $request->input('regionIndexCode');
  273. $params['cameraIndexCode'] = Input::get('cameraIndexCode');
  274. $params['streamType'] = $streamType; //0主码流 1子码流 2第三码流
  275. $params['protocol'] = 'wss';
  276. $params['transmode'] = 1; //0:UDP 1:TCP
  277. $params['expand'] = 'streamform=rtp';
  278. $this->sign = $this->get_sign($url);
  279. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  280. $result = json_decode($result, true);
  281. if (isset($result['code']) && $result['code'] == 0 && $parent_id != 353) { // 将内网地址替换为外网地址,除了羊二
  282. $video_url = $result['data']['url'];
  283. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $video_url, $res); // 提取内网ip
  284. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $this->pre_url, $res_n); // 提取外网ip
  285. $result['data']['url'] = str_replace($res, $res_n, $video_url);
  286. }
  287. return $result;
  288. }
  289. //鹰骏一矿ws
  290. public function getWsCameraUrl(){
  291. if (!Input::has('cameraIndexCode')) {
  292. return $this->error(1, '缺少必要参数');
  293. }
  294. $parent_id = Input::get('parent_id');
  295. $protocol = Input::get('protocol', 'hls');
  296. $streamType = Input::get('streamType', 1);
  297. $url = $this->artemis . '/api/video/v2/cameras/previewURLs';
  298. // $cameras_info = json_decode($this->getCamerasInfo(Input::all()), true);
  299. //请求参数
  300. $params = [];
  301. // $params['regionIndexCode'] = $request->input('regionIndexCode');
  302. $params['cameraIndexCode'] = Input::get('cameraIndexCode');
  303. $params['streamType'] = $streamType; //0主码流 1子码流 2第三码流
  304. $params['protocol'] = 'ws';
  305. $params['transmode'] = 1; //0:UDP 1:TCP
  306. $params['expand'] = 'streamform=rtp';
  307. $this->sign = $this->get_sign($url);
  308. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  309. $result = json_decode($result, true);
  310. if (isset($result['code']) && $result['code'] == 0 && $parent_id != 353) { // 将内网地址替换为外网地址,除了羊二
  311. $video_url = $result['data']['url'];
  312. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $video_url, $res); // 提取内网ip
  313. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $this->pre_url, $res_n); // 提取外网ip
  314. $result['data']['url'] = str_replace($res, $res_n, $video_url);
  315. }
  316. return $result;
  317. }
  318. //洗选执法记录仪对讲
  319. public function getHikTalkUrl(){
  320. if (!Input::has('cameraIndexCode')) {
  321. return $this->error(1, '缺少必要参数');
  322. }
  323. $parent_id = Input::get('parent_id');
  324. $protocol = Input::get('protocol', 'hls');
  325. $streamType = Input::get('streamType', 1);
  326. $url = $this->artemis . '/api/video/v1/cameras/talkURLs';
  327. // $cameras_info = json_decode($this->getCamerasInfo(Input::all()), true);
  328. //请求参数
  329. $params = [];
  330. // $params['regionIndexCode'] = $request->input('regionIndexCode');
  331. $params['cameraIndexCode'] = Input::get('cameraIndexCode');
  332. $params['transmode'] = 1; //0:UDP 1:TCP
  333. $params['expand'] = 'streamform=ps';
  334. $params['protocol'] = 'wss';
  335. $this->sign = $this->get_sign($url);
  336. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  337. $result = json_decode($result, true);
  338. if (isset($result['code']) && $result['code'] == 0 && $parent_id != 353) { // 将内网地址替换为外网地址,除了羊二
  339. $video_url = $result['data']['url'];
  340. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $video_url, $res); // 提取内网ip
  341. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $this->pre_url, $res_n); // 提取外网ip
  342. $result['data']['url'] = str_replace($res, $res_n, $video_url);
  343. }
  344. return $result;
  345. }
  346. /**
  347. * 获取摄像头码流url
  348. * @return array|mixed
  349. */
  350. public function getCamerasUrl()
  351. {
  352. if (!Input::has('cameraIndexCode')) {
  353. return $this->error(1, '缺少必要参数');
  354. }
  355. $parent_id = Input::get('parent_id');
  356. $protocol = Input::get('protocol', 'hls');
  357. $streamType = Input::get('streamType', 1);
  358. $url = $this->artemis . '/api/video/v1/cameras/previewURLs';
  359. // $cameras_info = json_decode($this->getCamerasInfo(Input::all()), true);
  360. //请求参数
  361. $params = [];
  362. // $params['regionIndexCode'] = $request->input('regionIndexCode');
  363. $params['cameraIndexCode'] = Input::get('cameraIndexCode');
  364. $params['streamType'] = $streamType; //0主码流 1子码流 2第三码流
  365. $params['protocol'] = $protocol;
  366. $params['transmode'] = 1; //0:UDP 1:TCP
  367. $params['expand'] = 'transcode=1&systemformat=ps&videotype=h264';
  368. $this->sign = $this->get_sign($url);
  369. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  370. $result = json_decode($result, true);
  371. if (isset($result['code']) && $result['code'] == 0 && $parent_id != 353) { // 将内网地址替换为外网地址,除了羊二
  372. $video_url = $result['data']['url'];
  373. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $video_url, $res); // 提取内网ip
  374. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $this->pre_url, $res_n); // 提取外网ip
  375. $result['data']['url'] = str_replace($res, $res_n, $video_url);
  376. }
  377. return $result;
  378. }
  379. /**
  380. * 获取摄像头详情
  381. * @param array $data
  382. * @return array|bool|string
  383. */
  384. public function getCamerasInfo($data)
  385. {
  386. $url = $this->artemis . '/api/resource/v1/cameras/indexCode';
  387. //请求参数
  388. $params = [];
  389. $params['cameraIndexCode'] = $data['cameraIndexCode'];
  390. $this->sign = $this->get_sign($url);
  391. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  392. return $result;
  393. }
  394. //获取编码设备信息
  395. public function getTranscodeInfo()
  396. {
  397. $url = $this->artemis . '/api/resource/v1/encodeDevice/get';
  398. //请求参数
  399. $params = [];
  400. $params['pageNo'] = 1;
  401. $params['pageSize'] = 1;
  402. $this->sign = $this->get_sign($url);
  403. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  404. return $result;
  405. }
  406. //根据区域获取下级编码设备列表
  407. public function getTest()
  408. {
  409. $url = $this->artemis . '/api/resource/v1/encodeDevice/subResources';
  410. //请求参数
  411. $params = [];
  412. $params['pageNo'] = 1;
  413. $params['pageSize'] = 1000;
  414. $params['regionIndexCode'] = Input::get('indexCode');
  415. $this->sign = $this->get_sign($url);
  416. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  417. $result = json_decode($result, true);
  418. return $result;
  419. }
  420. //获取编码设备列表
  421. public function getTranscodeList()
  422. {
  423. $url = $this->artemis . '/api/resource/v1/encodeDevice/subResources';
  424. //请求参数
  425. $params['regionIndexCode'] = 'root000000';
  426. $params['pageNo'] = 1;
  427. $params['pageSize'] = 100;
  428. $this->sign = $this->get_sign($url);
  429. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  430. $result = json_decode($result, true);
  431. return $result;
  432. }
  433. public function getRegionsInfo()
  434. {
  435. $url = $this->artemis . '/api/resource/v1/region/regionCatalog/regionInfo';
  436. //请求参数
  437. $params = [];
  438. $indexCodes = Input::get('indexCodes');
  439. $params['indexCodes'] = $indexCodes;
  440. $this->sign = $this->get_sign($url);
  441. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  442. $result = json_decode($result, true);
  443. // if (isset($result['code']) && $result['code'] == 0) {
  444. // }
  445. return $result;
  446. }
  447. public function getPlaybackRtsp(){
  448. $result['status'] = true;
  449. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  450. $camera_id = Input::get('camera_id');
  451. $start_time = Input::get('start_time');
  452. $end_time = Input::get('end_time');
  453. $query = CameraList::where('id', $camera_id)->first();
  454. // $url = $this->artemis.'/api/video/v2/cameras/playbackURLs';
  455. // $params['cameraIndexCode'] = $query->index_code;
  456. // $params['recordLocation'] = 0;
  457. // $params['protocol'] = 'rtsp';//rtsp
  458. // $params['transmode'] = 0;
  459. // $params['beginTime'] = $start_time;
  460. // $params['endTime'] = $end_time;
  461. // $params['uuid'] = '';
  462. // $params['expand'] = 'transcode=0';
  463. // $params['streamform'] = 'ps';
  464. // $params['lockType'] = 0;
  465. $url = $this->artemis.'/api/video/v1/cameras/playbackURLs';
  466. $params['cameraIndexCode'] = $query->index_code;
  467. $params['recordLocation'] = 0;
  468. $params['protocol'] = 'rtsp';//rtsp
  469. // $params['transmode'] = 0;
  470. $params['beginTime'] = $start_time;
  471. $params['endTime'] = $end_time;
  472. // $params['uuid'] = '';
  473. // $params['expand'] = 'streamform=ps';
  474. $params['streamType'] = 1; //0主码流 1子码流 2第三码流
  475. $params['transmode'] = 1; //0:UDP 1:TCP
  476. $params['expand'] = 'transcode=1&systemformat=ps&videotype=h264';
  477. $this->sign = $this->get_sign($url);
  478. $data = $this->curlPost($this->pre_url . $url, json_encode($params));
  479. $data = json_decode($data, true);
  480. if (isset($data['code']) && $data['code'] == 0) { // 将内网地址替换为外网地址
  481. $video_url = $data['data']['url'];
  482. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $video_url, $res); // 提取内网ip
  483. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $this->pre_url, $res_n); // 提取外网ip
  484. $data['data']['url'] = str_replace($res, $res_n, $video_url);
  485. }
  486. if ($data['data']['url']) {
  487. $result['camera_id'] = $camera_id;
  488. $result['url'] = $data['data']['url'];
  489. } else {
  490. $result['status'] = false;
  491. $result['msg'] = ApiEnum::HK_REQUEST_FAIL;
  492. }
  493. return $result;
  494. }
  495. public function getPlaybackByEasy(){
  496. $result['status'] = true;
  497. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  498. $camera_id = Input::get('camera_id');
  499. $start_time = Input::get('start_time');
  500. $end_time = Input::get('end_time');
  501. $old_time = Input::get('time');
  502. $query = CameraList::where('id', $camera_id)->first();
  503. $degree = MineList::where('id', $query->mine_id)->value('degree');
  504. $degree = explode('|', $degree);
  505. $mine_list = MineList::whereIn('id', $degree)->select(['title'])->get()->toArray();
  506. $time = explode('T',$start_time);
  507. $time = substr($time[1],0,5);
  508. $time = str_replace(":","",$time);
  509. $path = '';
  510. $path = '/'.$mine_list[0]['title'];
  511. $new_camera_name = str_replace('-','',$query->camera_name);
  512. $new_camera_name = str_replace('#','号',$new_camera_name);
  513. $path .= '/' . $new_camera_name.'回放'.$time;
  514. $playback = DB::table('playback')
  515. ->where('camera_id',$camera_id)
  516. ->where('start_time',$old_time['start_time'])
  517. ->where('end_time',$old_time['end_time'])
  518. ->where('deleted_at',null)->get();
  519. //已有拉流id,直接返回拉流链接
  520. if(count($playback)>0){
  521. if($playback[0]->revert_back_id != 'NullId'){
  522. $result['data'] = [
  523. 'camera_id' => $camera_id,
  524. 'url' => env('EASY_DARWIN_JF_RTSP') . $path
  525. ];
  526. return $result;
  527. }
  528. }
  529. $url = $this->artemis.'/api/video/v1/cameras/playbackURLs';
  530. $params['cameraIndexCode'] = $query->index_code;
  531. $params['recordLocation'] = 0;
  532. $params['protocol'] = 'rtsp';//rtsp
  533. $params['beginTime'] = $start_time;
  534. $params['endTime'] = $end_time;
  535. $params['streamType'] = 1; //0主码流 1子码流 2第三码流
  536. $params['transmode'] = 1; //0:UDP 1:TCP
  537. $params['expand'] = 'streamform=rtp';
  538. $this->sign = $this->get_sign($url);
  539. $data = $this->curlPost($this->pre_url . $url, json_encode($params));
  540. $data = json_decode($data, true);
  541. if(!$data['data']['url']){//切换码流
  542. $params['streamType'] = 0;
  543. $this->sign = $this->get_sign($url);
  544. $data = $this->curlPost($this->pre_url . $url, json_encode($params));
  545. $data = json_decode($data, true);
  546. }
  547. if(!$data['data']['url']){
  548. $result['status'] = false;
  549. $result['msg'] = ApiEnum::HK_REQUEST_FAIL;
  550. return $result;
  551. }
  552. $data = [
  553. 'url' => $data['data']['url'].'?beginTime='.$start_time.'&endTime='.$end_time.'&playBackMode=1',
  554. 'customPath' => $path,
  555. ];
  556. //请求流媒体服务器拉流
  557. $curl = env('EASY_DARWIN_JF_URL') . CameraEnum::API_STREAM_START . '?' . http_build_query($data);
  558. $curl_res = curl_request($curl);
  559. if(strpos($curl_res,' ')){
  560. $result['status'] = false;
  561. $result['msg'] = ApiEnum::EASY_DAWIN_REQUEST_FAIL;
  562. return $result;
  563. }
  564. //更新拉流id
  565. // CameraList::where('id', $camera_id)->update(
  566. // [
  567. // 'revert_back_id' => trim($curl_res, '"'),
  568. // ]
  569. // );
  570. if(count($playback)>0){
  571. $back_data['revert_back_id'] = trim($curl_res, '"');
  572. DB::table('playback')->where('id',$playback[0]->id)->update($back_data);
  573. }
  574. $result['data'] = [
  575. 'camera_id' => Input::get('camera_id'),
  576. 'url' => env('EASY_DARWIN_JF_RTSP') . $path
  577. ];
  578. return $result;
  579. }
  580. public function getPlaybackRtmp(){
  581. $camera_id = Input::get('camera_id');
  582. $start_time = Input::get('start_time');
  583. $end_time = Input::get('end_time');
  584. $stream_type = Input::get('stream_type');
  585. $query = CameraList::where('id', $camera_id)->first();
  586. // $url = $this->artemis.'/api/video/v2/cameras/playbackURLs';
  587. // $params['cameraIndexCode'] = $query->index_code;
  588. // $params['recordLocation'] = 0;
  589. // $params['protocol'] = 'rtsp';//rtsp
  590. // $params['transmode'] = 0;
  591. // $params['beginTime'] = $start_time;
  592. // $params['endTime'] = $end_time;
  593. // $params['uuid'] = '';
  594. // $params['expand'] = 'transcode=0';
  595. // $params['streamform'] = 'ps';
  596. // $params['lockType'] = 0;
  597. $url = $this->artemis.'/api/video/v1/cameras/playbackURLs';
  598. $params['cameraIndexCode'] = $query->index_code;
  599. $params['recordLocation'] = 0;
  600. $params['protocol'] = 'rtmp';//rtsp
  601. // $params['transmode'] = 0;
  602. $params['beginTime'] = $start_time;
  603. $params['endTime'] = $end_time;
  604. $params['streamType'] = $stream_type; //0主码流 1子码流 2第三码流
  605. $params['transmode'] = 1; //0:UDP 1:TCP
  606. $params['expand'] = 'transcode=1&systemformat=ps&videotype=h264';
  607. // $params['uuid'] = '';
  608. // $params['expand'] = 'streamform=ps';
  609. $this->sign = $this->get_sign($url);
  610. $data = $this->curlPost($this->pre_url . $url, json_encode($params));
  611. $data = json_decode($data, true);
  612. if (isset($data['code']) && $data['code'] == 0) { // 将内网地址替换为外网地址
  613. $video_url = $data['data']['url'].'?beginTime='.$start_time.'&endTime='.$end_time.'&playBackMode=1';
  614. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $video_url, $res); // 提取内网ip
  615. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $this->pre_url, $res_n); // 提取外网ip
  616. $data['data']['url'] = str_replace($res, $res_n, $video_url);
  617. }
  618. return $data;
  619. }
  620. //海康获取rtsp
  621. public function getHikRtsp(){
  622. $result['status'] = true;
  623. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  624. $query = CameraList::where('id',Input::get('camera_id'))->first();
  625. if (!$query) {
  626. $result['status'] = false;
  627. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  628. return $result;
  629. }
  630. $degree = MineList::where('id', $query->mine_id)->value('degree');
  631. $mine_list = MineList::whereIn('id', explode('|', $degree))->select(['title'])->get()->toArray();
  632. $path = '';
  633. foreach ($mine_list as $key => $val) {
  634. $path .= '/' . $val['title'];
  635. }
  636. $new_camera_name = str_replace('-','',$query->camera_name);
  637. $new_camera_name = str_replace('#','号',$new_camera_name);
  638. $path .= '/' . $new_camera_name;
  639. if($query->code_stream == 2){
  640. $code_stream = 0;
  641. }else{
  642. $code_stream = 1;
  643. }
  644. $url = $this->artemis.'/api/video/v1/cameras/previewURLs';
  645. $params['cameraIndexCode'] = $query->index_code;
  646. $params['streamType'] = $code_stream; //0主码流 1子码流 2第三码流
  647. $params['protocol'] = 'rtsp';//rtsp
  648. $params['transmode'] = 1; //0:UDP 1:TCP
  649. $params['expand'] = 'streamform=rtp';
  650. $this->sign = $this->get_sign($url);
  651. $rtsp = $this->curlPost($this->pre_url . $url, json_encode($params));
  652. $rtsp = json_decode($rtsp, true);
  653. if($rtsp['data']['url']){
  654. //访问记录
  655. $log['mine_id'] = $query->mine_id;
  656. $log['camera_id'] = Input::get('camera_id');
  657. $log['log'] = '海康接口返回rtsp成功';
  658. $log['status'] = 0;//正常
  659. $log['created_at'] = date('Y-m-d H:i:s');
  660. $log['updated_at'] = date('Y-m-d H:i:s');
  661. DB::table('log')->insert($log);
  662. }else{
  663. //访问记录
  664. $log['mine_id'] = $query->mine_id;
  665. $log['camera_id'] = Input::get('camera_id');
  666. $log['log'] = '海康接口返回rtsp失败';
  667. $log['status'] = 1;//异常
  668. $log['created_at'] = date('Y-m-d H:i:s');
  669. $log['updated_at'] = date('Y-m-d H:i:s');
  670. DB::table('log')->insert($log);
  671. }
  672. $ffmpeg_rtsp = $rtsp['data']['url'];
  673. $rtsp['data']['url'] = substr_replace($rtsp['data']['url'],env('NMJT_IP'),7,12);
  674. $result['data'] = [
  675. 'camera_id' => Input::get('camera_id'),
  676. 'url' => $rtsp['data']['url']
  677. ];
  678. //查询是否存在封面图
  679. $cover_picture = CameraList::where('id', Input::get('camera_id'))->value('cover_picture');
  680. if (!$cover_picture) {
  681. register_shutdown_function(array($this, "getFirstPicture"),$path,$ffmpeg_rtsp);
  682. }
  683. return $result;
  684. }
  685. //获取摄像头质量
  686. public function checkCameraQuality(){
  687. if (!Input::has('indexCode')) {
  688. return $this->error(1, '缺少必要参数');
  689. }
  690. $url = $this->artemis . '/api/nms/v1/vqd/list';
  691. //请求参数
  692. $params = [];
  693. $params['indexCodes'] = [Input::get('indexCode')];
  694. $params['pageNo'] = 1;
  695. $params['pageSize'] = 20;
  696. $this->sign = $this->get_sign($url);
  697. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  698. $result = json_decode($result, true);
  699. return $result;
  700. }
  701. //海康获取rtmp
  702. public function getHikHls(){
  703. $result['status'] = true;
  704. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  705. $query = CameraList::where('id',Input::get('camera_id'))->first();
  706. if (!$query) {
  707. $result['status'] = false;
  708. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  709. return $result;
  710. }
  711. $degree = MineList::where('id', $query->mine_id)->value('degree');
  712. $mine_list = MineList::whereIn('id', explode('|', $degree))->select(['title'])->get()->toArray();
  713. $path = '';
  714. foreach ($mine_list as $key => $val) {
  715. $path .= '/' . $val['title'];
  716. }
  717. $new_camera_name = str_replace('-','',$query->camera_name);
  718. $new_camera_name = str_replace('#','号',$new_camera_name);
  719. $path .= '/' . $new_camera_name;
  720. if($query->code_stream == 2){
  721. $code_stream = 0;
  722. }else{
  723. $code_stream = 1;
  724. }
  725. $url = $this->artemis.'/api/video/v1/cameras/previewURLs';
  726. $params['cameraIndexCode'] = $query->index_code;
  727. $params['streamType'] = 0; //0主码流 1子码流 2第三码流
  728. $params['protocol'] = 'ws';//rtmp
  729. $params['transmode'] = 1; //0:UDP 1:TCP
  730. $params['expand'] = 'streamform=rtp';
  731. $this->sign = $this->get_sign($url);
  732. $rtmp = $this->curlPost($this->pre_url . $url, json_encode($params));
  733. $rtmp = json_decode($rtmp, true);
  734. if($rtmp['data']['url']){
  735. //访问记录
  736. $log['mine_id'] = $query->mine_id;
  737. $log['camera_id'] = Input::get('camera_id');
  738. $log['log'] = '海康接口返回rtsp成功';
  739. $log['status'] = 0;//正常
  740. $log['created_at'] = date('Y-m-d H:i:s');
  741. $log['updated_at'] = date('Y-m-d H:i:s');
  742. DB::table('log')->insert($log);
  743. }else{
  744. //访问记录
  745. $log['mine_id'] = $query->mine_id;
  746. $log['camera_id'] = Input::get('camera_id');
  747. $log['log'] = '海康接口返回rtsp失败';
  748. $log['status'] = 1;//异常
  749. $log['created_at'] = date('Y-m-d H:i:s');
  750. $log['updated_at'] = date('Y-m-d H:i:s');
  751. DB::table('log')->insert($log);
  752. }
  753. $ffmpeg_rtmp = $rtmp['data']['url'];
  754. $pattern = '/^(ws:\/\/[^\/]+)/';
  755. if (preg_match($pattern, $ffmpeg_rtmp, $matches)) {
  756. $protocolHost = $matches[1];
  757. $rtmp['data']['url'] = str_replace($protocolHost, env('HK_HLS_JF'), $ffmpeg_rtmp);
  758. } else {
  759. $rtmp['data']['url'] = substr_replace($rtmp['data']['url'],env('HK_HLS_JF'),0,21);
  760. }
  761. $result['data'] = [
  762. 'camera_id' => Input::get('camera_id'),
  763. 'url' => $rtmp['data']['url']
  764. ];
  765. //查询是否存在封面图
  766. $cover_picture = CameraList::where('id', Input::get('camera_id'))->value('cover_picture');
  767. if (!$cover_picture) {
  768. // register_shutdown_function(array($this, "getFirstPicture"),$path,$ffmpeg_rtmp);
  769. $this->getPictureByHk($query);
  770. }
  771. return $result;
  772. }
  773. //海康ws协议获取url
  774. public function getHikWs(){
  775. $result['status'] = true;
  776. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  777. $query = CameraList::where('id',Input::get('camera_id'))->first();
  778. if (!$query) {
  779. $result['status'] = false;
  780. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  781. return $result;
  782. }
  783. $degree = MineList::where('id', $query->mine_id)->value('degree');
  784. $mine_list = MineList::whereIn('id', explode('|', $degree))->select(['title'])->get()->toArray();
  785. $path = '';
  786. foreach ($mine_list as $key => $val) {
  787. $path .= '/' . $val['title'];
  788. }
  789. $new_camera_name = str_replace('-','',$query->camera_name);
  790. $new_camera_name = str_replace('#','号',$new_camera_name);
  791. $path .= '/' . $new_camera_name;
  792. if($query->code_stream == 2){
  793. $code_stream = 0;
  794. }else{
  795. $code_stream = 1;
  796. }
  797. $url = $this->artemis.'/api/video/v1/cameras/previewURLs';
  798. $params['cameraIndexCode'] = $query->index_code;
  799. $params['streamType'] = 0; //0主码流 1子码流 2第三码流
  800. $params['protocol'] = 'ws';//rtmp
  801. $params['transmode'] = 1; //0:UDP 1:TCP
  802. $params['expand'] = 'streamform=rtp';
  803. $this->sign = $this->get_sign($url);
  804. $rtmp = $this->curlPost($this->pre_url . $url, json_encode($params));
  805. $rtmp = json_decode($rtmp, true);
  806. if($rtmp['data']['url']){
  807. //访问记录
  808. $log['mine_id'] = $query->mine_id;
  809. $log['camera_id'] = Input::get('camera_id');
  810. $log['log'] = '海康接口返回rtsp成功';
  811. $log['status'] = 0;//正常
  812. $log['created_at'] = date('Y-m-d H:i:s');
  813. $log['updated_at'] = date('Y-m-d H:i:s');
  814. DB::table('log')->insert($log);
  815. }else{
  816. //访问记录
  817. $log['mine_id'] = $query->mine_id;
  818. $log['camera_id'] = Input::get('camera_id');
  819. $log['log'] = '海康接口返回rtsp失败';
  820. $log['status'] = 1;//异常
  821. $log['created_at'] = date('Y-m-d H:i:s');
  822. $log['updated_at'] = date('Y-m-d H:i:s');
  823. DB::table('log')->insert($log);
  824. }
  825. $ffmpeg_rtmp = $rtmp['data']['url'];
  826. $rtmp['data']['url'] = substr_replace($rtmp['data']['url'],env('HK_HLS_JF'),0,20);
  827. $result['data'] = [
  828. 'camera_id' => Input::get('camera_id'),
  829. 'url' => $rtmp['data']['url']
  830. ];
  831. //查询是否存在封面图
  832. $cover_picture = CameraList::where('id', Input::get('camera_id'))->value('cover_picture');
  833. if (!$cover_picture) {
  834. // register_shutdown_function(array($this, "getFirstPicture"),$path,$ffmpeg_rtmp);
  835. $this->getPictureByHk($query);
  836. }
  837. return $result;
  838. }
  839. //宁煤通过海康接口获取首桢图片
  840. public function getPictureByHk($query){
  841. $url = $this->artemis.'/api/video/v1/manualCapture';
  842. $params['cameraIndexCode'] = $query->index_code;
  843. $this->sign = $this->get_sign($url);
  844. $picture = $this->curlPost($this->pre_url . $url, json_encode($params));
  845. $picture = json_decode($picture, true);
  846. if(isset($picture['data']['picUrl'])){
  847. if (!is_dir('/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH.'/img/' )) {
  848. mkdir('/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH.'/img/', 0777, true);
  849. }
  850. $path = '/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH.'/img/';
  851. $cms = new CameraServices();
  852. $file_name = $cms->downloadFile($picture['data']['picUrl'],$path);
  853. //判断图片是否存在
  854. $picture_exists = file_exists($path . '/' . $file_name);
  855. if ($picture_exists) {
  856. //上传图片到oss并更新数据库
  857. $picture_path = $cms->uploadOssFile($file_name, $path);
  858. CameraList::where('id',$query->id)->update(['cover_picture' => $picture_path]);
  859. }
  860. }
  861. }
  862. //宁煤集团获取rtsp流后获取首帧图片
  863. public function getFirstPicture($path,$ffmpeg_rtsp){
  864. if (!is_dir('/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH . '/' . $path)) {
  865. mkdir('/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH . '/' . $path, 0777, true);
  866. }
  867. // dd($result_td['content'][0]['url']);
  868. $exec = 'nohup /usr/bin/ffmpeg -i "' . $ffmpeg_rtsp . '" -vcodec copy -acodec copy -vbsf h264_mp4toannexb -f hls -hls_flags delete_segments -segment_list_size 10 -hls_list_size 2 /www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::M3U8_FILE_NAME . ' >/dev/null &';
  869. shell_exec($exec);
  870. //sleep10秒生成文件
  871. $i = 1;
  872. while ($i <= 10) {
  873. //判断m3u8文件是否存在
  874. $file_exists = file_exists(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::M3U8_FILE_NAME);
  875. //判断ts文件是否存在
  876. $ts_exists = glob(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::TS_FILE_SUFFIX);
  877. if ($file_exists && $ts_exists) {
  878. //获取第一帧作为封面图
  879. $file_name = time() . CameraEnum::COVER_PICTURE_NAME;
  880. $cover_exec = 'ffmpeg -i ' . public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::M3U8_FILE_NAME . ' -vf "select=between(mod(n\, 25)\, 0\, 0), setpts=N/24/TB" ' . public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . $file_name;
  881. exec($cover_exec);
  882. //判断图片是否存在
  883. $picture_exists = file_exists(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . $file_name);
  884. if ($picture_exists) {
  885. $cms = new CameraServices();
  886. //上传图片到oss并更新数据库
  887. $picture_path = $cms->uploadOssFile($file_name, public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/');
  888. CameraList::where('id', Input::get('camera_id'))->update(['cover_picture' => $picture_path]);
  889. }
  890. } else {
  891. sleep(1);
  892. }
  893. $i++;
  894. }
  895. }
  896. //海康easy_drawin获取rtsp并推流
  897. public function getRtspByCameraId(){
  898. $result['status'] = true;
  899. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  900. $query = CameraList::where('id',Input::get('camera_id'))->first();
  901. if (!$query) {
  902. $result['status'] = false;
  903. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  904. return $result;
  905. }
  906. $degree = MineList::where('id', $query->mine_id)->value('degree');
  907. $mine_list = MineList::whereIn('id', explode('|', $degree))->select(['title'])->get()->toArray();
  908. $path = '';
  909. // foreach ($mine_list as $key => $val) {
  910. // $path .= '/' . $val['title'];
  911. // }
  912. $path = '/'.$mine_list[0]['title'];
  913. $new_camera_name = str_replace('-','',$query->camera_name);
  914. $new_camera_name = str_replace('#','号',$new_camera_name);
  915. $path .= '/' . $new_camera_name;
  916. //标记摄像头为在线状态
  917. CameraList::where('id', Input::get('camera_id'))->update(['camera_status' => CameraEnum::CAMERA_STATUS_ONLINE]);
  918. //已有拉流id,直接返回拉流链接
  919. if($query->revert_id != 'NullId'){
  920. $result['data'] = [
  921. 'camera_id' => Input::get('camera_id'),
  922. 'url' => env('EASY_DARWIN_JF_RTSP') . $path
  923. ];
  924. return $result;
  925. }
  926. if($query->code_stream == 2){
  927. $code_stream = 0;
  928. }else{
  929. $code_stream = 1;
  930. }
  931. $url = $this->artemis.'/api/video/v1/cameras/previewURLs';
  932. $params['cameraIndexCode'] = $query->index_code;
  933. $params['streamType'] = $code_stream; //0主码流 1子码流 2第三码流
  934. $params['protocol'] = 'rtsp';
  935. $params['transmode'] = 1; //0:UDP 1:TCP
  936. $params['expand'] = 'streamform=rtp';
  937. $this->sign = $this->get_sign($url);
  938. $rtsp = $this->curlPost($this->pre_url . $url, json_encode($params));
  939. $rtsp = json_decode($rtsp, true);
  940. $data = [
  941. 'url' => $rtsp['data']['url'],
  942. 'customPath' => $path,
  943. ];
  944. // dd($data);
  945. Log::info('请求流媒体服务器参数------------');
  946. Log::info($data);
  947. $curl = env('EASY_DARWIN_JF_URL') . CameraEnum::API_STREAM_START . '?' . http_build_query($data);
  948. //请求流媒体服务器拉流
  949. $curl_res = curl_request($curl);
  950. // DB::table('camera_list')->where('id',$camera_id)->update($res);
  951. // dd($res);
  952. Log::info('请求流媒体服务器result------------');
  953. Log::info($curl_res);
  954. if (strpos($curl_res,' ')) {
  955. //切换码流重新获取rtsp
  956. if($code_stream == 1){
  957. $code_stream = 0;
  958. }else{
  959. $code_stream = 1;
  960. }
  961. $params['streamType'] = $code_stream; //0主码流 1子码流 2第三码流
  962. $rtsp = $this->curlPost($this->pre_url . $url, json_encode($params));
  963. $rtsp = json_decode($rtsp, true);
  964. $data = [
  965. 'url' => $rtsp['data']['url'],
  966. 'customPath' => $path,
  967. ];
  968. // dd($data);
  969. Log::info('请求流媒体服务器参数------------');
  970. Log::info($data);
  971. $curl = env('EASY_DARWIN_JF_URL') . CameraEnum::API_STREAM_START . '?' . http_build_query($data);
  972. //请求流媒体服务器拉流
  973. $curl_res = curl_request($curl);
  974. if(strpos($curl_res,' ')){
  975. //标记摄像头为异常状态
  976. CameraList::where('id', Input::get('camera_id'))->update(['camera_status' => CameraEnum::CAMERA_STATUS_ERROR]);
  977. $result['status'] = false;
  978. $result['msg'] = ApiEnum::EASY_DAWIN_REQUEST_FAIL;
  979. return $result;
  980. }
  981. }
  982. //更新拉流id
  983. CameraList::where('id', Input::get('camera_id'))->update(
  984. [
  985. 'revert_id' => trim($curl_res, '"'),
  986. 'updated_at' => date('Y-m-d H:i:s'),
  987. ]
  988. );
  989. $result['data'] = [
  990. 'camera_id' => Input::get('camera_id'),
  991. 'url' => env('EASY_DARWIN_JF_RTSP') . $path
  992. ];
  993. //查询是否存在封面图
  994. $cover_picture = CameraList::where('id', Input::get('camera_id'))->value('cover_picture');
  995. if (!$cover_picture) {
  996. if (!is_dir('/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH . '/' . $path)) {
  997. mkdir('/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH . '/' . $path, 0777, true);
  998. }
  999. // dd($result_td['content'][0]['url']);
  1000. $exec = 'nohup /usr/bin/ffmpeg -i "' . $rtsp['data']['url'] . '" -vcodec copy -acodec copy -vbsf h264_mp4toannexb -f hls -hls_flags delete_segments -segment_list_size 10 -hls_list_size 2 /www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH . '/' . $path . '/' . CameraEnum::M3U8_FILE_NAME . ' >/dev/null &';
  1001. shell_exec($exec);
  1002. //sleep10秒生成文件
  1003. $i = 1;
  1004. while ($i <= 10) {
  1005. //判断m3u8文件是否存在
  1006. $file_exists = file_exists(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::M3U8_FILE_NAME);
  1007. //判断ts文件是否存在
  1008. $ts_exists = glob(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::TS_FILE_SUFFIX);
  1009. if ($file_exists && $ts_exists) {
  1010. //获取第一帧作为封面图
  1011. $file_name = time() . CameraEnum::COVER_PICTURE_NAME;
  1012. $cover_exec = 'ffmpeg -i ' . public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::M3U8_FILE_NAME . ' -vf "select=between(mod(n\, 25)\, 0\, 0), setpts=N/24/TB" ' . public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . $file_name;
  1013. exec($cover_exec);
  1014. //判断图片是否存在
  1015. $picture_exists = file_exists(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . $file_name);
  1016. if ($picture_exists) {
  1017. $cms = new CameraServices();
  1018. //上传图片到oss并更新数据库
  1019. $picture_path = $cms->uploadOssFile($file_name, public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/');
  1020. CameraList::where('id', Input::get('camera_id'))->update(['cover_picture' => $picture_path]);
  1021. }
  1022. return $result;
  1023. } else {
  1024. sleep(1);
  1025. }
  1026. $i++;
  1027. }
  1028. }else{
  1029. return $result;
  1030. }
  1031. //标记摄像头为异常状态
  1032. CameraList::where('id', Input::get('camera_id'))->update(['camera_status' => CameraEnum::CAMERA_STATUS_ERROR]);
  1033. $result['status'] = false;
  1034. $result['msg'] = ApiEnum::EASY_DAWIN_REQUEST_FAIL;
  1035. return $result;
  1036. }
  1037. /**
  1038. * 以appSecret为密钥,使用HmacSHA256算法对签名字符串生成消息摘要,对消息摘要使用BASE64算法生成签名(签名过程中的编码方式全为UTF-8)
  1039. */
  1040. protected function get_sign($url)
  1041. {
  1042. $sign_str = $this->get_sign_str($url); //签名字符串
  1043. $priKey = $this->app_secret;
  1044. $sign = hash_hmac('sha256', $sign_str, $priKey, true); //生成消息摘要
  1045. $result = base64_encode($sign);
  1046. return $result;
  1047. }
  1048. /**
  1049. * 生成签名
  1050. * @param $url
  1051. * @return string
  1052. */
  1053. protected function get_sign_str($url)
  1054. {
  1055. // $next = "\n";
  1056. $next = "\n";
  1057. $str = "POST" . $next . '*/*' . $next . 'application/json' . $next;
  1058. $str .= "x-ca-key:" . $this->app_key . $next;
  1059. $str .= "x-ca-timestamp:" . $this->time . $next;
  1060. $str .= $url;
  1061. return $str;
  1062. }
  1063. /**
  1064. * 发送请求
  1065. * @param string $url
  1066. * @param string $postData
  1067. * @param array $options
  1068. * @return bool|string
  1069. */
  1070. public function curlPost($url = '', $postData = '', $options = array())
  1071. {
  1072. if (is_array($postData)) {
  1073. $postData = http_build_query($postData);
  1074. }
  1075. $ch = curl_init();
  1076. curl_setopt($ch, CURLOPT_URL, $url);
  1077. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  1078. curl_setopt($ch, CURLOPT_POST, 1);
  1079. curl_setopt($ch, CURLOPT_POSTFIELDS, $postData);
  1080. curl_setopt($ch, CURLOPT_TIMEOUT, 30); //设置cURL允许执行的最长秒数
  1081. curl_setopt_array($ch, array(
  1082. CURLOPT_HTTPHEADER => array(
  1083. "Accept:" . '*/*',
  1084. "Content-Type:" . 'application/json',
  1085. "x-Ca-Key:" . $this->app_key,
  1086. "X-Ca-Signature:" . $this->sign,
  1087. "X-Ca-Timestamp:" . $this->time,
  1088. "X-Ca-Signature-Headers:" . "x-ca-key,x-ca-timestamp",
  1089. )
  1090. ));
  1091. //https请求 不验证证书和host
  1092. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  1093. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  1094. $data = curl_exec($ch);
  1095. curl_close($ch);
  1096. return $data;
  1097. }
  1098. }