HaiKangController.php 50 KB

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