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