HaiKangController.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717
  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. class HaiKangController extends BaseController
  20. {
  21. protected $pre_url; // 海康接口地址
  22. protected $app_key; // 海康app_key
  23. protected $app_secret; // 海康app_secret
  24. protected $sign;// 签名
  25. protected $time;// 时间戳
  26. protected $artemis;// OpenAPI接口的上下文
  27. public function __construct()
  28. {
  29. // if ($request->has('mine')) {
  30. // $this->pre_url = config('haikang.' . $request->input('mine') . '.pre_url'); // https://120.253.79.51:4433
  31. // $this->app_key = config('haikang.' . $request->input('mine') . '.app_key'); // 25720460
  32. // $this->app_secret = config('haikang.' . $request->input('mine') . '.app_secret'); // qqP7NLcIDwO9MgtYmp8L
  33. // $this->artemis = config('haikang.' . $request->input('mine') . '.artemis'); // /artemis
  34. // } else {
  35. // $this->pre_url = env('HAI_KANG_URL'); // https://120.253.79.51:4433
  36. // $this->app_key = env('HAI_KANG_APP_KEY'); // 25720460
  37. // $this->app_secret = env('HAI_KANG_APP_SECRET'); // qqP7NLcIDwO9MgtYmp8L
  38. // $this->artemis = env('HAI_KANG_ARTEMIS_PATH'); // /artemis
  39. // }
  40. // $this->pre_url = 'https://10.71.252.64:4433'; // https://120.253.79.51:4433
  41. // $this->app_key = '25720460'; // 25720460
  42. // $this->app_secret = 'qqP7NLcIDwO9MgtYmp8L'; // qqP7NLcIDwO9MgtYmp8L
  43. // $this->artemis = '/artemis'; // /artemis
  44. $this->pre_url = Input::get('url'); // https://120.253.79.51:4433
  45. $this->app_key = Input::get('key'); // 25720460
  46. $this->app_secret = Input::get('secret'); // qqP7NLcIDwO9MgtYmp8L
  47. $this->artemis = '/artemis'; // /artemis
  48. list($msec, $sec) = explode(' ', microtime());
  49. $this->time = (float)sprintf('%.0f', (floatval($msec) + floatval($sec)) * 1000);
  50. }
  51. /**
  52. * 获取区域列表
  53. * @return bool|mixed|string
  54. */
  55. public function getRegionsList()
  56. {
  57. $url = $this->artemis . '/api/resource/v1/regions';
  58. //请求参数
  59. $params = [];
  60. // $params['pageNo'] = $request->has('pageNo') ? intval($request->input('pageNo')) : 1;
  61. // $params['pageSize'] = $request->has('pageSize') ? intval($request->input('pageSize')) : 1000;
  62. $params['pageNo'] = 1;
  63. $params['pageSize'] = 1000;
  64. $this->sign = $this->get_sign($url);
  65. $type = Input::get('type');
  66. $mine_id = Input::get('mine_id');
  67. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  68. $result = json_decode($result, true);
  69. $area_list = [];
  70. if (isset($result['code']) && $result['code'] == 0) {
  71. $list = $result['data']['list'];
  72. foreach ($list as $key => $item) {
  73. $area_list[] = $item['indexCode'];
  74. if ($item['parentIndexCode'] == '-1') {
  75. unset($list[$key]);
  76. }
  77. }
  78. $result['data']['list'] = array_values($list);
  79. }
  80. if ($type == CameraEnum::REQUEST_TYPE_API) {
  81. $result['data']['list'] = $this->regionsTree($result['data']['list']);
  82. } else {
  83. //先删除不存在的区域
  84. if ($area_list) {
  85. MineList::where('degree', 'like', $mine_id . '|%')->whereNotIn('index_code', $area_list)->delete();
  86. }
  87. //更新区域
  88. $result['data']['list'] = $this->saveTree($result['data']['list'], $mine_id);
  89. }
  90. return $result;
  91. }
  92. protected function regionsTree($regions, $pid = 'root000000')
  93. {
  94. $arr = [];
  95. if (empty($regions)) {
  96. return [];
  97. }
  98. foreach ($regions as $key => $value) {
  99. if (isset($value['parentIndexCode']) && $value['parentIndexCode'] == $pid) {
  100. $arr[$key]['indexCode'] = $value['indexCode'];
  101. $arr[$key]['mine_id'] = $value['indexCode'];
  102. $arr[$key]['name'] = $value['name'];
  103. $arr[$key]['parentIndexCode'] = $value['parentIndexCode'];
  104. $arr[$key]['treeCode'] = $value['treeCode'];
  105. $arr[$key]['children'] = array_values(self::regionsTree($regions, $value['indexCode']));
  106. unset($arr[$key]['indexCode']);
  107. unset($arr[$key]['parentIndexCode']);
  108. unset($arr[$key]['treeCode']);
  109. if (count($arr[$key]['children']) == 0) {
  110. unset($arr[$key]['children']);
  111. }
  112. }
  113. }
  114. return array_values($arr);
  115. }
  116. protected function saveTree($regions, $parent_id, $pid = 'root000000')
  117. {
  118. $arr = [];
  119. if (empty($regions)) {
  120. return [];
  121. }
  122. $mineService = new MineServices();
  123. $mineService->initMineList();
  124. $arr_count = count($regions);
  125. foreach ($regions as $key => $value) {
  126. if (isset($value['parentIndexCode']) && $value['parentIndexCode'] == $pid) {
  127. $arr[$key]['indexCode'] = $value['indexCode'];
  128. $arr[$key]['mine_id'] = $value['indexCode'];
  129. $arr[$key]['name'] = str_replace('#', '号', $value['name']);
  130. $arr[$key]['parentIndexCode'] = $value['parentIndexCode'];
  131. $arr[$key]['treeCode'] = $value['treeCode'];
  132. $id = MineList::where('index_code', $value['indexCode'])->value('id');
  133. $params = [
  134. 'id' => $id,
  135. 'parent_id' => $parent_id,
  136. 'title' => $value['name'],
  137. 'sort' => $arr_count - $key,
  138. 'index_code' => $value['indexCode'],
  139. ];
  140. $result = $mineService->add($params);
  141. $mine_id = $result->id;
  142. $arr[$key]['children'] = array_values(self::saveTree($regions, $mine_id, $value['indexCode']));
  143. if (count($arr[$key]['children']) == 0) {
  144. unset($arr[$key]['children']);
  145. }
  146. }
  147. }
  148. return array_values($arr);
  149. }
  150. /**
  151. * 获取区域监控列表
  152. * @return bool|mixed|string
  153. */
  154. public function getCamerasList()
  155. {
  156. if (!Input::has('indexCode')) {
  157. return $this->error(1, '缺少必要参数');
  158. }
  159. $url = $this->artemis . '/api/resource/v1/regions/regionIndexCode/cameras';
  160. //请求参数
  161. $params = [];
  162. $params['regionIndexCode'] = Input::get('indexCode');
  163. // $params['pageNo'] = $request->has('pageNo') ? intval($request->input('pageNo')) : 1;
  164. // $params['pageSize'] = $request->has('pageSize') ? intval($request->input('pageSize')) : 1000;
  165. $params['pageNo'] = 1;
  166. $params['pageSize'] = 1000;
  167. $this->sign = $this->get_sign($url);
  168. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  169. $result = json_decode($result, true);
  170. return $result;
  171. }
  172. public function getCameraStatus($indexCode){
  173. $url = $this->artemis . '/api/nms/v1/online/camera/get';
  174. $params = [];
  175. $params['regionId'] = 'root000000';
  176. $params['includeSubNode'] = '1';
  177. $params['indexCodes'] = [$indexCode];
  178. $params['status'] = '1';
  179. $params['pageNo'] = 1;
  180. $params['pageSize'] = 20;
  181. $this->sign = $this->get_sign($url);
  182. $result_status = $this->curlPost($this->pre_url . $url, json_encode($params));
  183. $result_status = json_decode($result_status, true);
  184. if(isset($result_status['data']['list'][0]['online']) && $result_status['data']['list'][0]['online'] == 1){
  185. return 0;//在线
  186. }else{
  187. return 1;//离线
  188. }
  189. }
  190. /**
  191. * 获取摄像头码流url
  192. * @return array|mixed
  193. */
  194. public function getCamerasUrl()
  195. {
  196. if (!Input::has('cameraIndexCode')) {
  197. return $this->error(1, '缺少必要参数');
  198. }
  199. $protocol = Input::get('protocol', 'hls');
  200. $streamType = Input::get('streamType', 1);
  201. $url = $this->artemis . '/api/video/v1/cameras/previewURLs';
  202. // $cameras_info = json_decode($this->getCamerasInfo(Input::all()), true);
  203. //请求参数
  204. $params = [];
  205. // $params['regionIndexCode'] = $request->input('regionIndexCode');
  206. $params['cameraIndexCode'] = Input::get('cameraIndexCode');
  207. $params['streamType'] = $streamType; //0主码流 1子码流 2第三码流
  208. $params['protocol'] = $protocol;
  209. $params['transmode'] = 1; //0:UDP 1:TCP
  210. $params['expand'] = 'transcode=1&systemformat=ps&videotype=h264';
  211. $this->sign = $this->get_sign($url);
  212. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  213. $result = json_decode($result, true);
  214. if (isset($result['code']) && $result['code'] == 0) { // 将内网地址替换为外网地址
  215. $video_url = $result['data']['url'];
  216. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $video_url, $res); // 提取内网ip
  217. preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/i', $this->pre_url, $res_n); // 提取外网ip
  218. $result['data']['url'] = str_replace($res, $res_n, $video_url);
  219. }
  220. return $result;
  221. }
  222. /**
  223. * 获取摄像头详情
  224. * @param array $data
  225. * @return array|bool|string
  226. */
  227. public function getCamerasInfo($data)
  228. {
  229. $url = $this->artemis . '/api/resource/v1/cameras/indexCode';
  230. //请求参数
  231. $params = [];
  232. $params['cameraIndexCode'] = $data['cameraIndexCode'];
  233. $this->sign = $this->get_sign($url);
  234. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  235. return $result;
  236. }
  237. //获取编码设备信息
  238. public function getTranscodeInfo()
  239. {
  240. $url = $this->artemis . '/api/resource/v1/encodeDevice/get';
  241. //请求参数
  242. $params = [];
  243. $params['pageNo'] = 1;
  244. $params['pageSize'] = 1;
  245. $this->sign = $this->get_sign($url);
  246. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  247. return $result;
  248. }
  249. //根据区域获取下级编码设备列表
  250. public function getTest()
  251. {
  252. $url = $this->artemis . '/api/resource/v1/encodeDevice/subResources';
  253. //请求参数
  254. $params = [];
  255. $params['pageNo'] = 1;
  256. $params['pageSize'] = 1000;
  257. $params['regionIndexCode'] = Input::get('indexCode');
  258. $this->sign = $this->get_sign($url);
  259. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  260. $result = json_decode($result, true);
  261. return $result;
  262. }
  263. //获取编码设备列表
  264. public function getTranscodeList()
  265. {
  266. $url = $this->artemis . '/api/resource/v1/encodeDevice/subResources';
  267. //请求参数
  268. $params['regionIndexCode'] = 'root000000';
  269. $params['pageNo'] = 1;
  270. $params['pageSize'] = 100;
  271. $this->sign = $this->get_sign($url);
  272. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  273. $result = json_decode($result, true);
  274. return $result;
  275. }
  276. public function getRegionsInfo()
  277. {
  278. $url = $this->artemis . '/api/resource/v1/region/regionCatalog/regionInfo';
  279. //请求参数
  280. $params = [];
  281. $indexCodes = Input::get('indexCodes');
  282. $params['indexCodes'] = $indexCodes;
  283. $this->sign = $this->get_sign($url);
  284. $result = $this->curlPost($this->pre_url . $url, json_encode($params));
  285. $result = json_decode($result, true);
  286. // if (isset($result['code']) && $result['code'] == 0) {
  287. // }
  288. return $result;
  289. }
  290. public function getHikRtsp(){
  291. $result['status'] = true;
  292. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  293. $query = CameraList::where('id',Input::get('camera_id'))->first();
  294. if (!$query) {
  295. $result['status'] = false;
  296. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  297. return $result;
  298. }
  299. $degree = MineList::where('id', $query->mine_id)->value('degree');
  300. $mine_list = MineList::whereIn('id', explode('|', $degree))->select(['title'])->get()->toArray();
  301. $path = '';
  302. foreach ($mine_list as $key => $val) {
  303. $path .= '/' . $val['title'];
  304. }
  305. $new_camera_name = str_replace('-','',$query->camera_name);
  306. $new_camera_name = str_replace('#','号',$new_camera_name);
  307. $path .= '/' . $new_camera_name;
  308. if($query->code_stream == 2){
  309. $code_stream = 0;
  310. }else{
  311. $code_stream = 1;
  312. }
  313. $url = $this->artemis.'/api/video/v1/cameras/previewURLs';
  314. $params['cameraIndexCode'] = $query->index_code;
  315. $params['streamType'] = $code_stream; //0主码流 1子码流 2第三码流
  316. $params['protocol'] = 'rtsp';//rtsp
  317. $params['transmode'] = 1; //0:UDP 1:TCP
  318. $params['expand'] = 'streamform=rtp';
  319. $this->sign = $this->get_sign($url);
  320. $rtsp = $this->curlPost($this->pre_url . $url, json_encode($params));
  321. $rtsp = json_decode($rtsp, true);
  322. if($rtsp['data']['url']){
  323. //访问记录
  324. $log['mine_id'] = $query->mine_id;
  325. $log['camera_id'] = Input::get('camera_id');
  326. $log['log'] = '海康接口返回rtsp成功';
  327. $log['status'] = 0;//正常
  328. $log['created_at'] = date('Y-m-d H:i:s');
  329. $log['updated_at'] = date('Y-m-d H:i:s');
  330. DB::table('log')->insert($log);
  331. }else{
  332. //访问记录
  333. $log['mine_id'] = $query->mine_id;
  334. $log['camera_id'] = Input::get('camera_id');
  335. $log['log'] = '海康接口返回rtsp失败';
  336. $log['status'] = 1;//异常
  337. $log['created_at'] = date('Y-m-d H:i:s');
  338. $log['updated_at'] = date('Y-m-d H:i:s');
  339. DB::table('log')->insert($log);
  340. }
  341. $ffmpeg_rtsp = $rtsp['data']['url'];
  342. $rtsp['data']['url'] = substr_replace($rtsp['data']['url'],env('NMJT_IP'),7,12);
  343. $result['data'] = [
  344. 'camera_id' => Input::get('camera_id'),
  345. 'url' => $rtsp['data']['url']
  346. ];
  347. //查询是否存在封面图
  348. $cover_picture = CameraList::where('id', Input::get('camera_id'))->value('cover_picture');
  349. if (!$cover_picture) {
  350. register_shutdown_function(array($this, "getFirstPicture"),$path,$ffmpeg_rtsp);
  351. }
  352. return $result;
  353. }
  354. //宁煤集团获取rtsp流后获取首帧图片
  355. public function getFirstPicture($path,$ffmpeg_rtsp){
  356. if (!is_dir('/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH . '/' . $path)) {
  357. mkdir('/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH . '/' . $path, 0777, true);
  358. }
  359. // dd($result_td['content'][0]['url']);
  360. $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 &';
  361. shell_exec($exec);
  362. //sleep10秒生成文件
  363. $i = 1;
  364. while ($i <= 10) {
  365. //判断m3u8文件是否存在
  366. $file_exists = file_exists(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::M3U8_FILE_NAME);
  367. //判断ts文件是否存在
  368. $ts_exists = glob(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::TS_FILE_SUFFIX);
  369. if ($file_exists && $ts_exists) {
  370. //获取第一帧作为封面图
  371. $file_name = time() . CameraEnum::COVER_PICTURE_NAME;
  372. $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;
  373. exec($cover_exec);
  374. //判断图片是否存在
  375. $picture_exists = file_exists(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . $file_name);
  376. if ($picture_exists) {
  377. $cms = new CameraServices();
  378. //上传图片到oss并更新数据库
  379. $picture_path = $cms->uploadOssFile($file_name, public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/');
  380. CameraList::where('id', Input::get('camera_id'))->update(['cover_picture' => $picture_path]);
  381. }
  382. } else {
  383. sleep(1);
  384. }
  385. $i++;
  386. }
  387. }
  388. //海康easy_drawin获取rtsp并推流
  389. public function getRtspByCameraId(){
  390. $result['status'] = true;
  391. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  392. $query = CameraList::where('id',Input::get('camera_id'))->first();
  393. if (!$query) {
  394. $result['status'] = false;
  395. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  396. return $result;
  397. }
  398. $degree = MineList::where('id', $query->mine_id)->value('degree');
  399. $mine_list = MineList::whereIn('id', explode('|', $degree))->select(['title'])->get()->toArray();
  400. $path = '';
  401. // foreach ($mine_list as $key => $val) {
  402. // $path .= '/' . $val['title'];
  403. // }
  404. $path = '/'.$mine_list[0]['title'];
  405. $new_camera_name = str_replace('-','',$query->camera_name);
  406. $new_camera_name = str_replace('#','号',$new_camera_name);
  407. $path .= '/' . $new_camera_name;
  408. //标记摄像头为在线状态
  409. CameraList::where('id', Input::get('camera_id'))->update(['camera_status' => CameraEnum::CAMERA_STATUS_ONLINE]);
  410. //已有拉流id,直接返回拉流链接
  411. if($query->revert_id != 'NullId'){
  412. $result['data'] = [
  413. 'camera_id' => Input::get('camera_id'),
  414. 'url' => env('EASY_DARWIN_JF_RTSP') . $path
  415. ];
  416. return $result;
  417. }
  418. if($query->code_stream == 2){
  419. $code_stream = 0;
  420. }else{
  421. $code_stream = 1;
  422. }
  423. $url = $this->artemis.'/api/video/v1/cameras/previewURLs';
  424. $params['cameraIndexCode'] = $query->index_code;
  425. $params['streamType'] = $code_stream; //0主码流 1子码流 2第三码流
  426. $params['protocol'] = 'rtsp';
  427. $params['transmode'] = 1; //0:UDP 1:TCP
  428. $params['expand'] = 'streamform=rtp';
  429. $this->sign = $this->get_sign($url);
  430. $rtsp = $this->curlPost($this->pre_url . $url, json_encode($params));
  431. $rtsp = json_decode($rtsp, true);
  432. $data = [
  433. 'url' => $rtsp['data']['url'],
  434. 'customPath' => $path,
  435. ];
  436. // dd($data);
  437. Log::info('请求流媒体服务器参数------------');
  438. Log::info($data);
  439. $curl = env('EASY_DARWIN_JF_URL') . CameraEnum::API_STREAM_START . '?' . http_build_query($data);
  440. //请求流媒体服务器拉流
  441. $curl_res = curl_request($curl);
  442. // DB::table('camera_list')->where('id',$camera_id)->update($res);
  443. // dd($res);
  444. Log::info('请求流媒体服务器result------------');
  445. Log::info($curl_res);
  446. if (strpos($curl_res,' ')) {
  447. //切换码流重新获取rtsp
  448. if($code_stream == 1){
  449. $code_stream = 0;
  450. }else{
  451. $code_stream = 1;
  452. }
  453. $params['streamType'] = $code_stream; //0主码流 1子码流 2第三码流
  454. $rtsp = $this->curlPost($this->pre_url . $url, json_encode($params));
  455. $rtsp = json_decode($rtsp, true);
  456. $data = [
  457. 'url' => $rtsp['data']['url'],
  458. 'customPath' => $path,
  459. ];
  460. // dd($data);
  461. Log::info('请求流媒体服务器参数------------');
  462. Log::info($data);
  463. $curl = env('EASY_DARWIN_JF_URL') . CameraEnum::API_STREAM_START . '?' . http_build_query($data);
  464. //请求流媒体服务器拉流
  465. $curl_res = curl_request($curl);
  466. if(strpos($curl_res,' ')){
  467. //标记摄像头为异常状态
  468. CameraList::where('id', Input::get('camera_id'))->update(['camera_status' => CameraEnum::CAMERA_STATUS_ERROR]);
  469. $result['status'] = false;
  470. $result['msg'] = ApiEnum::EASY_DAWIN_REQUEST_FAIL;
  471. return $result;
  472. }
  473. }
  474. //更新拉流id
  475. CameraList::where('id', Input::get('camera_id'))->update(
  476. [
  477. 'revert_id' => trim($curl_res, '"'),
  478. 'updated_at' => date('Y-m-d H:i:s'),
  479. ]
  480. );
  481. $result['data'] = [
  482. 'camera_id' => Input::get('camera_id'),
  483. 'url' => env('EASY_DARWIN_JF_RTSP') . $path
  484. ];
  485. //查询是否存在封面图
  486. $cover_picture = CameraList::where('id', Input::get('camera_id'))->value('cover_picture');
  487. if (!$cover_picture) {
  488. if (!is_dir('/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH . '/' . $path)) {
  489. mkdir('/www/wwwroot/video.nxjiewei.com/public/' . CameraEnum::M3U8_FILE_PATH . '/' . $path, 0777, true);
  490. }
  491. // dd($result_td['content'][0]['url']);
  492. $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 &';
  493. shell_exec($exec);
  494. //sleep10秒生成文件
  495. $i = 1;
  496. while ($i <= 10) {
  497. //判断m3u8文件是否存在
  498. $file_exists = file_exists(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::M3U8_FILE_NAME);
  499. //判断ts文件是否存在
  500. $ts_exists = glob(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . CameraEnum::TS_FILE_SUFFIX);
  501. if ($file_exists && $ts_exists) {
  502. //获取第一帧作为封面图
  503. $file_name = time() . CameraEnum::COVER_PICTURE_NAME;
  504. $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;
  505. exec($cover_exec);
  506. //判断图片是否存在
  507. $picture_exists = file_exists(public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/' . $file_name);
  508. if ($picture_exists) {
  509. $cms = new CameraServices();
  510. //上传图片到oss并更新数据库
  511. $picture_path = $cms->uploadOssFile($file_name, public_path() . '/' . CameraEnum::M3U8_FILE_PATH . $path . '/');
  512. CameraList::where('id', Input::get('camera_id'))->update(['cover_picture' => $picture_path]);
  513. }
  514. return $result;
  515. } else {
  516. sleep(1);
  517. }
  518. $i++;
  519. }
  520. }else{
  521. return $result;
  522. }
  523. //标记摄像头为异常状态
  524. CameraList::where('id', Input::get('camera_id'))->update(['camera_status' => CameraEnum::CAMERA_STATUS_ERROR]);
  525. $result['status'] = false;
  526. $result['msg'] = ApiEnum::EASY_DAWIN_REQUEST_FAIL;
  527. return $result;
  528. }
  529. /**
  530. * 以appSecret为密钥,使用HmacSHA256算法对签名字符串生成消息摘要,对消息摘要使用BASE64算法生成签名(签名过程中的编码方式全为UTF-8)
  531. */
  532. protected function get_sign($url)
  533. {
  534. $sign_str = $this->get_sign_str($url); //签名字符串
  535. $priKey = $this->app_secret;
  536. $sign = hash_hmac('sha256', $sign_str, $priKey, true); //生成消息摘要
  537. $result = base64_encode($sign);
  538. return $result;
  539. }
  540. /**
  541. * 生成签名
  542. * @param $url
  543. * @return string
  544. */
  545. protected function get_sign_str($url)
  546. {
  547. // $next = "\n";
  548. $next = "\n";
  549. $str = "POST" . $next . '*/*' . $next . 'application/json' . $next;
  550. $str .= "x-ca-key:" . $this->app_key . $next;
  551. $str .= "x-ca-timestamp:" . $this->time . $next;
  552. $str .= $url;
  553. return $str;
  554. }
  555. /**
  556. * 发送请求
  557. * @param string $url
  558. * @param string $postData
  559. * @param array $options
  560. * @return bool|string
  561. */
  562. public function curlPost($url = '', $postData = '', $options = array())
  563. {
  564. if (is_array($postData)) {
  565. $postData = http_build_query($postData);
  566. }
  567. $ch = curl_init();
  568. curl_setopt($ch, CURLOPT_URL, $url);
  569. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  570. curl_setopt($ch, CURLOPT_POST, 1);
  571. curl_setopt($ch, CURLOPT_POSTFIELDS, $postData);
  572. curl_setopt($ch, CURLOPT_TIMEOUT, 30); //设置cURL允许执行的最长秒数
  573. curl_setopt_array($ch, array(
  574. CURLOPT_HTTPHEADER => array(
  575. "Accept:" . '*/*',
  576. "Content-Type:" . 'application/json',
  577. "x-Ca-Key:" . $this->app_key,
  578. "X-Ca-Signature:" . $this->sign,
  579. "X-Ca-Timestamp:" . $this->time,
  580. "X-Ca-Signature-Headers:" . "x-ca-key,x-ca-timestamp",
  581. )
  582. ));
  583. //https请求 不验证证书和host
  584. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  585. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  586. $data = curl_exec($ch);
  587. curl_close($ch);
  588. return $data;
  589. }
  590. }