CameraApiController.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: qiuzijian
  5. * Date: 2021-04-25
  6. * Time: 09:53
  7. */
  8. namespace Modules\Camera\Http\Controllers\Api;
  9. use App\Enum\ApiEnum;
  10. use App\Http\Controllers\Api\BaseController;
  11. use Illuminate\Support\Facades\Input;
  12. use Illuminate\Support\Facades\Log;
  13. use Modules\Camera\Entities\CameraList;
  14. use Modules\Camera\Enum\CameraEnum;
  15. use Modules\Camera\Services\CameraServices;
  16. use Modules\Mine\Entities\MineList;
  17. use Modules\Mine\Entities\MineListExt;
  18. use DB;
  19. class CameraApiController extends BaseController
  20. {
  21. //通过摄像头类型获取摄像头
  22. public function getCameraByType(){
  23. $mine_code = Input::get('mine_code', '');
  24. $camera_type = Input::get('camera_type', '');
  25. if (!$mine_code || !$camera_type) {
  26. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  27. }
  28. $result['status'] = true;
  29. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  30. $mine = DB::table('mine_list')->where('slug','like','%'.$mine_code.'%')->where('parent_id',0)->where('deleted_at',null)->first();
  31. if (!$mine) {
  32. $result['status'] = false;
  33. $result['msg'] = '矿区名称不存在';
  34. return $result;
  35. }
  36. $mine_list = DB::table('mine_list')->where('degree', 'like', $mine->id . '|' . '%')->where('deleted_at',null)->get();
  37. $mine_array = [];
  38. foreach($mine_list as $k=>$v){
  39. $mine_array[] = $v->id;
  40. }
  41. $query = CameraList::where('is_show', CameraEnum::IS_SHOW_YES)->where('deleted_at',null)->whereIn('mine_id',$mine_array)->where('camera_type',$camera_type)->orderBy('sort', 'desc')->get();
  42. if (!$query) {
  43. $result['status'] = false;
  44. $result['msg'] = '矿区下没有摄像头';
  45. return $result;
  46. }
  47. $result = [];
  48. foreach($query as $k=>$v){
  49. $result[$k]['id'] = $v->id;
  50. $result[$k]['mine_id'] = $v->mine_id;
  51. $result[$k]['camera_name'] = $v->camera_name;
  52. $result[$k]['cover_picture'] = $v->cover_picture;
  53. $result[$k]['camera_status'] = $v->camera_status;
  54. $result[$k]['playback'] = $v->playback;
  55. }
  56. return self::successResponse($result);
  57. }
  58. //宁煤摄像头统计
  59. public function getTotalNingmei(){
  60. $result['status'] = true;
  61. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  62. //宁煤集团
  63. $ningmei = DB::table('mine_list')->where('title',config('mine_hls'))->get();
  64. $mine_all = DB::table('mine_list')->where('deleted_at',null)->get();//所有区域
  65. $mine_ningmei = [];//宁煤集团所有区域
  66. foreach($mine_all as $k=>$v){
  67. if(explode('|',$v->degree)[0] == $ningmei[0]->id){
  68. $mine_ningmei[] = $v->id;
  69. }
  70. }
  71. //宁煤在离线数量
  72. $data[0]['title'] = '宁煤公司';
  73. $data[0]['mine_code'] = $ningmei[0]->slug;
  74. $data[0]['total'] = DB::table('camera_list')->whereIn('mine_id',$mine_ningmei)->where('deleted_at',null)->count();
  75. $data[0]['total_online'] = DB::table('camera_list')->whereIn('mine_id',$mine_ningmei)->where('camera_status',1)->where('deleted_at',null)->count();
  76. $data[0]['total_offline'] = $data[0]['total'] - $data[0]['total_online'];
  77. $data[0]['rate'] = round($data[0]['total_online'] / $data[0]['total'] * 100,2)."%";
  78. //宁煤下各矿在离线数量
  79. $mine_list = DB::table('mine_list')->where('parent_id',$ningmei[0]->id)->where('deleted_at',null)->get();
  80. foreach($mine_list as $k => $v){
  81. $mine_use = [];//宁煤下每个矿所有区域
  82. foreach($mine_all as $key=>$value){
  83. if(count(explode('|',$value->degree)) > 1){
  84. if(explode('|',$value->degree)[0] == $ningmei[0]->id && explode('|',$value->degree)[1] == $v->id){
  85. $mine_use[] = $value->id;
  86. }
  87. }
  88. }
  89. $total = DB::table('camera_list')->whereIn('mine_id',$mine_use)->where('is_show',1)->where('deleted_at',null)->count();
  90. $total_online = DB::table('camera_list')->whereIn('mine_id',$mine_use)->where('is_show',1)->where('camera_status',1)->where('deleted_at',null)->count();
  91. if($total == 0){
  92. $rate = "0%";
  93. }else{
  94. $rate = round($total_online / $total * 100,2)."%";
  95. }
  96. if($v->slug == 'NingXiaMeiYeTeShuZuoYeJianKongShiPin'){
  97. $res['title'] = $v->title;
  98. $res['mine_code'] = $v->slug."_jituan";
  99. $res['total'] = $total;
  100. $res['total_online'] = $total_online;
  101. $res['total_offline'] = $total - $total_online;
  102. $res['rate'] = $rate;
  103. }else{
  104. array_push($data,[
  105. 'title'=>$v->title,
  106. 'mine_code'=>$v->slug."_jituan",
  107. 'total'=>$total,
  108. 'total_online'=>$total_online,
  109. 'total_offline'=>$total - $total_online,
  110. 'rate'=>$rate
  111. ]);
  112. }
  113. }
  114. if(isset($res)){
  115. array_push($data,[
  116. 'title'=>$res['title'],
  117. 'mine_code'=>$res['mine_code'],
  118. 'total'=>$res['total'],
  119. 'total_online'=>$res['total_online'],
  120. 'total_offline'=>$res['total_offline'],
  121. 'rate'=>$res['rate']
  122. ]);
  123. }
  124. return self::successResponse($data);
  125. }
  126. //宁煤不在线摄像头列表
  127. public function offlineList(){
  128. $mine_code = Input::get('mine_code', '');
  129. if (!$mine_code) {
  130. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  131. }
  132. $result['status'] = true;
  133. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  134. //宁煤集团
  135. $ningmei = DB::table('mine_list')->where('title',config('mine_hls'))->get();
  136. $mine_all = DB::table('mine_list')->where('deleted_at',null)->get();//所有区域
  137. $mine_ningmei = [];//宁煤集团所有区域
  138. foreach($mine_all as $k=>$v){
  139. if(explode('|',$v->degree)[0] == $ningmei[0]->id){
  140. $mine_ningmei[] = $v->id;
  141. }
  142. }
  143. if(count(explode('_',$mine_code)) > 1){
  144. $mine_code = explode('_',$mine_code)[0];
  145. }
  146. $mine_list = DB::table('mine_list')->where('parent_id',0)->where('slug','like','%'.$mine_code.'%')->where('deleted_at',null)->get();
  147. //如果传参是宁煤显示全部
  148. if(isset($mine_list[0]->title) && $mine_list[0]->title == config('mine_hls')[0]){
  149. //宁煤在离线数量
  150. $offline_list = DB::table('camera_list')->select('id','camera_name','cover_picture','camera_status')->whereIn('mine_id',$mine_ningmei)->where('camera_status','!=',1)->where('deleted_at',null)->get();
  151. return self::successResponse($offline_list);
  152. }
  153. //宁煤下各矿在离线数量
  154. $mine_list = DB::table('mine_list')->where('parent_id',$ningmei[0]->id)->where('slug','like','%'.$mine_code.'%')->where('deleted_at',null)->get();
  155. $total_offline = [];
  156. foreach($mine_list as $k => $v){
  157. $mine_use = [];//宁煤下每个矿所有区域
  158. foreach($mine_all as $key=>$value){
  159. if(count(explode('|',$value->degree)) > 1){
  160. if(explode('|',$value->degree)[0] == $ningmei[0]->id && explode('|',$value->degree)[1] == $v->id){
  161. $mine_use[] = $value->id;
  162. }
  163. }
  164. }
  165. $total_offline = DB::table('camera_list')->select('id','camera_name','cover_picture','camera_status')->whereIn('mine_id',$mine_use)->where('is_show',1)->where('camera_status','!=',1)->where('deleted_at',null)->get();
  166. }
  167. return self::successResponse($total_offline);
  168. }
  169. //宁煤高风险摄像头
  170. public function getRiskNingmei(){
  171. $mine_code = Input::get('mine_code', '');
  172. if (!$mine_code) {
  173. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  174. }
  175. $result['status'] = true;
  176. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  177. //宁煤集团
  178. $ningmei = DB::table('mine_list')->where('title',config('mine_hls'))->get();
  179. //宁煤集团下级单位
  180. $mine = DB::table('mine_list')
  181. ->where('parent_id',$ningmei[0]->id)
  182. ->where('slug','like','%'.$mine_code.'%')
  183. ->where('deleted_at',null)
  184. ->get();
  185. //子区域树形列表
  186. $child_list = DB::table('mine_list')->where('parent_id',$mine[0]->id)->where('deleted_at',null)->orderBy('sort','desc')->get();
  187. $risk_id = null;
  188. if(count($child_list)>0){
  189. $risk_id = $this->mineTree($child_list);
  190. }
  191. $mine_list = [];
  192. if($risk_id != null){
  193. $risk = DB::table('mine_list')->where('parent_id',$risk_id)->where('deleted_at',null)->get();
  194. if(count($risk) > 0){
  195. //有子区域
  196. $mine_list = $this->riskTree($risk,[]);
  197. }else{
  198. //没有子区域
  199. $mine_list[] = $risk_id;
  200. }
  201. }
  202. $camera_list = DB::table('camera_list')
  203. ->select('camera_list.*','mine_list.title')
  204. ->leftJoin('mine_list','camera_list.mine_id','=','mine_list.id')
  205. ->where('camera_list.deleted_at',null)
  206. ->whereIn('camera_list.mine_id',$mine_list)
  207. ->orderBy('sort', 'desc')->get();
  208. $result = [];
  209. foreach($camera_list as $k=>$v){
  210. $result[$k]['parent_id'] = $ningmei[0]->id;
  211. $result[$k]['camera_id'] = $v->id;
  212. $result[$k]['mine_name'] = $v->title;
  213. $result[$k]['camera_name'] = $v->camera_name;
  214. $result[$k]['cover_picture'] = $v->cover_picture;
  215. $result[$k]['camera_status'] = $v->camera_status;
  216. $result[$k]['base64'] = $v->base64;
  217. }
  218. return self::successResponse($result);
  219. }
  220. public function mineTree($regions)
  221. {
  222. $arr = null;
  223. foreach ($regions as $key => $value) {
  224. $risk = explode('高风险作业',$value->title);
  225. if (count($risk)>1){
  226. return $value->id;
  227. }
  228. $mine_child = DB::table('mine_list')->where('parent_id', $value->id)->where('deleted_at',null)->get();
  229. if (count($mine_child) > 0) {
  230. $arr = self::mineTree($mine_child, $value->id);
  231. if($arr != null){
  232. return $arr;
  233. }
  234. }
  235. }
  236. return $arr;
  237. }
  238. public function riskTree($regions,$risk_list)
  239. {
  240. foreach ($regions as $key => $value) {
  241. $risk_child = DB::table('mine_list')->where('parent_id', $value->id)->where('deleted_at',null)->get();
  242. if (count($risk_child) > 0) {
  243. $risk_list = array_merge($risk_list,self::riskTree($risk_child,[]));
  244. }else{
  245. $risk_list[] = $value->id;
  246. }
  247. }
  248. return $risk_list;
  249. }
  250. //高风险区域摄像头
  251. public function getCameraByMinecode(){
  252. $mine_code = Input::get('mine_code', '');
  253. if (!$mine_code) {
  254. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  255. }
  256. $result['status'] = true;
  257. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  258. $mine = DB::table('mine_list')->where('slug','like','%'.$mine_code.'%')->where('parent_id',0)->where('deleted_at',null)->first();
  259. if (!$mine) {
  260. $result['status'] = false;
  261. $result['msg'] = '矿区名称不存在';
  262. return $result;
  263. }
  264. $mine_list = DB::table('mine_list')->where('degree', 'like', $mine->id . '|' . '%')->where('title','like','%高风险%')->where('deleted_at',null)->get();
  265. $mine_array = [];
  266. foreach($mine_list as $k=>$v){
  267. $mine_child = DB::table('mine_list')->where('degree', 'like','%' . $v->id . '%')->where('deleted_at',null)->get();
  268. if(count($mine_child)>0){
  269. for($i=0;$i<count($mine_child);$i++){
  270. $mine_array[] = $mine_child[$i]->id;
  271. }
  272. }
  273. }
  274. $query = DB::table('camera_list')
  275. ->select('camera_list.*','mine_list.title')
  276. ->leftJoin('mine_list','camera_list.mine_id','=','mine_list.id')
  277. ->where('camera_list.deleted_at',null)
  278. ->whereIn('camera_list.mine_id',$mine_array)
  279. ->orderBy('sort', 'desc')->get();
  280. if (!$query) {
  281. $result['status'] = false;
  282. $result['msg'] = '矿区下没有摄像头';
  283. return $result;
  284. }
  285. $result = [];
  286. foreach($query as $k=>$v){
  287. $result[$k]['parent_id'] = $mine->id;
  288. $result[$k]['camera_id'] = $v->id;
  289. $result[$k]['mine_name'] = $v->title;
  290. $result[$k]['camera_name'] = $v->camera_name;
  291. $result[$k]['cover_picture'] = $v->cover_picture;
  292. $result[$k]['camera_status'] = $v->camera_status;
  293. }
  294. return self::successResponse($result);
  295. }
  296. /**
  297. * 作者: qiuzijian
  298. * 注释: 获取摄像头列表
  299. * @return \App\Http\Controllers\Api\JsonResponse
  300. */
  301. public function getCamerasList()
  302. {
  303. $parent_id = Input::get('parent_id', '');
  304. $mine_id = Input::get('mine_id', '');
  305. $camera_type = Input::get('camera_type', CameraEnum::CAMERA_TYPE_ALL);
  306. $surface_id = Input::get('surface_id', '');
  307. if (!$parent_id) {
  308. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  309. }
  310. if (!in_array($camera_type, [CameraEnum::CAMERA_TYPE_NORMAL, CameraEnum::CAMERA_TYPE_ALL]) && !$surface_id) {
  311. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  312. }
  313. //判断是否使用海康视频服务器
  314. // $is_hak = MineListExt::where('mine_id', $parent_id)->value('is_hak');
  315. // if ($is_hak) {
  316. // $result = CameraServices::getHaiKangCamera($parent_id, $mine_id, $camera_type);
  317. // } else {
  318. $result = CameraServices::getCameraListByMineId($mine_id, $camera_type, $parent_id, $surface_id);
  319. // }
  320. return self::successResponse($result);
  321. }
  322. /**
  323. * 作者: qiuzijian
  324. * 注释: 获取摄像头播放地址
  325. * @return \App\Http\Controllers\Api\JsonResponse
  326. */
  327. public function getCamerasUrl()
  328. {
  329. $parent_id = Input::get('parent_id', '');
  330. $camera_id = Input::get('camera_id', '');
  331. if (!$parent_id || !$camera_id) {
  332. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  333. }
  334. //判断摄像头来源是否为内网服务器
  335. $camera_source = CameraList::where('id', $camera_id)->value('camera_source');
  336. if ($camera_source == CameraEnum::CAMERA_SOURCE_3) {
  337. $result = CameraServices::getIntranetCameraUrl($camera_id);
  338. return self::successResponse($result);
  339. }
  340. //判断是否使用海康视频服务器
  341. $is_hak = MineListExt::where('mine_id', $parent_id)->value('is_hak');
  342. //判断是否生成摄像头请求链接
  343. $camera_url = CameraList::where('id', $camera_id)->value('camera_url');
  344. if ($is_hak && !$camera_url) {
  345. //判断是否是mine配置文件的矿区
  346. $mine_res = DB::table('mine_list')->where('id',$parent_id)->get();
  347. //天地伟业
  348. if(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('mine'))){
  349. $result = CameraServices::getRtspTianDi($camera_id,$parent_id);
  350. //宁煤集团
  351. }elseif(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('mine_hls'))){
  352. $result = CameraServices::getHkHls($camera_id,$parent_id);
  353. //信息技术中心测试ws协议
  354. }elseif($mine_res[0]-> slug == 'XinXiJiShuZhongXin'){
  355. $result = CameraServices::getHkWs($camera_id,$parent_id);
  356. //海康切片逻辑
  357. }else{
  358. $result = CameraServices::downloadCameraFiles($parent_id, $camera_id);
  359. }
  360. } else {
  361. //判断硬盘录像机的有没有封面图,有的走easydrawin,没有的走ffmpeg
  362. $cover_picture = CameraList::where('id', $camera_id)->value('cover_picture');
  363. // if(!$cover_picture){
  364. //ffmpeg拉流获取首帧图片
  365. // $result = CameraServices::getCameraUrlByFfmpeg($camera_id);
  366. // }else{
  367. // $result = CameraServices::getCameraUrlByCameraId($camera_id);
  368. $result = CameraServices::getRtspYingPan($camera_id);
  369. // }
  370. }
  371. return self::successResponse($result);
  372. }
  373. public function getCamerasLanUrl()
  374. {
  375. $parent_id = Input::get('parent_id', '');
  376. $camera_id = Input::get('camera_id', '');
  377. if (!$parent_id || !$camera_id) {
  378. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  379. }
  380. //判断摄像头来源是否为内网服务器
  381. $camera_source = CameraList::where('id', $camera_id)->value('camera_source');
  382. if ($camera_source == CameraEnum::CAMERA_SOURCE_3) {
  383. $result = CameraServices::getIntranetCameraUrl($camera_id);
  384. return self::successResponse($result);
  385. }
  386. //判断是否使用海康视频服务器
  387. $is_hak = MineListExt::where('mine_id', $parent_id)->value('is_hak');
  388. //判断是否生成摄像头请求链接
  389. $camera_url = CameraList::where('id', $camera_id)->value('camera_url');
  390. if ($is_hak && !$camera_url) {
  391. //判断是否是mine配置文件的矿区
  392. $mine_res = DB::table('mine_list')->where('id',$parent_id)->get();
  393. //天地伟业
  394. if(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('mine'))){
  395. $result = CameraServices::getRtspTianDi($camera_id,$parent_id);
  396. //宁煤集团
  397. }elseif(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('mine_hls'))){
  398. $result = CameraServices::getHkHls($camera_id,$parent_id);
  399. }else{
  400. $result = CameraServices::getLanCameraUrl($parent_id, $camera_id);
  401. }
  402. } else {
  403. //判断硬盘录像机的有没有封面图,有的走easydrawin,没有的走ffmpeg
  404. $cover_picture = CameraList::where('id', $camera_id)->value('cover_picture');
  405. // if(!$cover_picture){
  406. //ffmpeg拉流获取首帧图片
  407. // $result = CameraServices::getCameraUrlByFfmpeg($camera_id);
  408. // }else{
  409. $result = CameraServices::getCameraUrlByCameraId($camera_id);
  410. // }
  411. }
  412. return self::successResponse($result);
  413. }
  414. //获取海康rtsp流
  415. public function getHikRtsp(){
  416. $parent_id = Input::get('parent_id', '');
  417. $camera_id = Input::get('camera_id', '');
  418. if (!$parent_id || !$camera_id) {
  419. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  420. }
  421. //判断是否使用海康视频服务器
  422. $is_hak = MineListExt::where('mine_id', $parent_id)->value('is_hak');
  423. //判断是否生成摄像头请求链接
  424. $camera_url = CameraList::where('id', $camera_id)->value('camera_url');
  425. if ($is_hak == 1 && !$camera_url) {
  426. $result = CameraServices::getHkRtsp($camera_id,$parent_id);
  427. return self::successResponse($result);
  428. }else{
  429. return self::errorResponse(ApiEnum::HK_REQUEST_FAIL);
  430. }
  431. }
  432. //获取海康rtmp流
  433. public function getHikRtmp(){
  434. $parent_id = Input::get('parent_id', '');
  435. $camera_id = Input::get('camera_id', '');
  436. if (!$parent_id || !$camera_id) {
  437. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  438. }
  439. //判断是否使用海康视频服务器
  440. $is_hak = MineListExt::where('mine_id', $parent_id)->value('is_hak');
  441. //判断是否生成摄像头请求链接
  442. $camera_url = CameraList::where('id', $camera_id)->value('camera_url');
  443. if ($is_hak == 1 && !$camera_url) {
  444. $result = CameraServices::getHkRtmp($camera_id,$parent_id);
  445. return self::successResponse($result);
  446. }else{
  447. return self::errorResponse(ApiEnum::HK_REQUEST_FAIL);
  448. }
  449. }
  450. //海康摄像头easy_drawin方式获取url
  451. public function getCamerasRtsp()
  452. {
  453. $parent_id = Input::get('parent_id', '');
  454. $camera_id = Input::get('camera_id', '');
  455. if (!$parent_id || !$camera_id) {
  456. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  457. }
  458. //判断摄像头来源是否为内网服务器
  459. $camera_source = CameraList::where('id', $camera_id)->value('camera_source');
  460. if ($camera_source == CameraEnum::CAMERA_SOURCE_3) {
  461. $result = CameraServices::getIntranetCameraUrl($camera_id);
  462. return self::successResponse($result);
  463. }
  464. //判断是否使用海康视频服务器
  465. $is_hak = MineListExt::where('mine_id', $parent_id)->value('is_hak');
  466. //判断是否生成摄像头请求链接
  467. $camera_url = CameraList::where('id', $camera_id)->value('camera_url');
  468. if ($is_hak && !$camera_url) {
  469. //判断是否是mine配置文件的矿区
  470. $mine_res = DB::table('mine_list')->where('id',$parent_id)->get();
  471. if(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('mine'))){
  472. //天地伟业使用easy_drawin获取rtsp
  473. $result = CameraServices::getRtspTianDi($camera_id,$parent_id);
  474. }else{
  475. //海康使用easy_drawin获取rtsp
  476. $result = CameraServices::getRtspHaiKang($camera_id, $parent_id);
  477. }
  478. } else {
  479. //硬盘录像机使用easy_drawin获取rtsp
  480. $result = CameraServices::getRtspYingPan($camera_id);
  481. }
  482. return self::successResponse($result);
  483. }
  484. /**
  485. * 作者: qiuzijian
  486. * 注释: 停止摄像头推流
  487. * @return \App\Http\Controllers\Api\JsonResponse
  488. */
  489. public function stopCamerasStream()
  490. {
  491. $camera_id = Input::get('camera_id', '');
  492. $result = CameraServices::stopCameraStream();
  493. return self::successResponse($result);
  494. }
  495. //回放列表
  496. public function getPlaybackList(){
  497. $camera_id = Input::get('camera_id', '');
  498. $result['status'] = true;
  499. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  500. if (!$camera_id) {
  501. $result['status'] = false;
  502. $result['msg'] = ApiEnum::STATUS_CODE_EMPTY;
  503. return $result;
  504. }
  505. $query = CameraList::where('id', $camera_id)->first();
  506. if (!$query) {
  507. $result['status'] = false;
  508. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  509. return $result;
  510. }
  511. if($query->playback == 0){
  512. $result['status'] = false;
  513. $result['msg'] = ApiEnum::NO_SUPORT_PLAYBACK;
  514. return $result;
  515. }
  516. $playback = DB::table('playback')->where('camera_id',$query->id)->where('deleted_at',null)->get();
  517. if(count($playback)>0){
  518. for($i=0;$i<count($playback);$i++){
  519. $result['data'][$i]['title'] = $playback[$i]->title;
  520. $result['data'][$i]['start_time'] = $playback[$i]->start_time;
  521. $result['data'][$i]['end_time'] = $playback[$i]->end_time;
  522. $result['data'][$i]['camera_id'] = $playback[$i]->camera_id;
  523. }
  524. }else{
  525. $result['data'] = null;
  526. }
  527. return $result;
  528. }
  529. //回放URL
  530. public function getPlaybackUrl(){
  531. $time['start_time'] = explode(' ',Input::get('start_time', ''))[1];
  532. $time['end_time'] = explode(' ',Input::get('end_time', ''))[1];
  533. $camera_id = Input::get('camera_id', '');
  534. $start_time = Input::get('start_time', '');
  535. $end_time = Input::get('end_time', '');
  536. $result['status'] = true;
  537. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  538. if (!$camera_id || !$start_time || !$end_time) {
  539. $result['status'] = false;
  540. $result['msg'] = ApiEnum::STATUS_CODE_EMPTY;
  541. return $result;
  542. }
  543. $query = CameraList::where('id', $camera_id)->first();
  544. if (!$query) {
  545. $result['status'] = false;
  546. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  547. return $result;
  548. }
  549. if($query->playback == 0){
  550. $result['status'] = false;
  551. $result['msg'] = ApiEnum::NO_SUPORT_PLAYBACK;
  552. return $result;
  553. }
  554. $degree = MineList::where('id', $query->mine_id)->value('degree');
  555. $degree = explode('|', $degree)[0];
  556. $mine_res = DB::table('mine_list')->where('id',$degree)->get();
  557. //判断摄像头是否是洗选中心的时间+34分钟
  558. if($mine_res[0]->slug == 'XiXuanZhongXin'){
  559. $start_time = date('Y-m-d H:i:s',strtotime($start_time.'+34 minutes'));
  560. $end_time = date('Y-m-d H:i:s',strtotime($end_time.'+34 minutes'));
  561. }
  562. $str = '.000+';
  563. $start_time = date('c', strtotime($start_time));//2022-07-14T08:00:00.000+08:00
  564. $start_time = explode('+',$start_time);
  565. $start_time = $start_time[0].$str.$start_time[1];
  566. $end_time = date('c', strtotime($end_time));
  567. $end_time = explode('+',$end_time);
  568. $end_time = $end_time[0].$str.$end_time[1];
  569. //判断是否在配置文件里,在的不用走ffmpeg
  570. if(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('playback'))){
  571. $result = CameraServices::getPlaybackRtsp($camera_id,$start_time,$end_time);
  572. return self::successResponse($result);
  573. }else{
  574. $result = CameraServices::getPlaybackRtmp($camera_id,$start_time,$end_time,$time);
  575. return self::successResponse($result);
  576. }
  577. }
  578. //easydrawin回放URL
  579. public function getPlaybackUrlByEasy(){
  580. $time['start_time'] = explode(' ',Input::get('start_time', ''))[1];
  581. $time['end_time'] = explode(' ',Input::get('end_time', ''))[1];
  582. $camera_id = Input::get('camera_id', '');
  583. $start_time = Input::get('start_time', '');
  584. $end_time = Input::get('end_time', '');
  585. $result['status'] = true;
  586. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  587. if (!$camera_id || !$start_time || !$end_time) {
  588. $result['status'] = false;
  589. $result['msg'] = ApiEnum::STATUS_CODE_EMPTY;
  590. return $result;
  591. }
  592. $query = CameraList::where('id', $camera_id)->first();
  593. if (!$query) {
  594. $result['status'] = false;
  595. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  596. return $result;
  597. }
  598. if($query->playback == 0){
  599. $result['status'] = false;
  600. $result['msg'] = ApiEnum::NO_SUPORT_PLAYBACK;
  601. return $result;
  602. }
  603. $degree = MineList::where('id', $query->mine_id)->value('degree');
  604. $degree = explode('|', $degree)[0];
  605. $mine_res = DB::table('mine_list')->where('id',$degree)->get();
  606. //判断摄像头是否是洗选中心的时间+34分钟
  607. if($mine_res[0]->slug == 'XiXuanZhongXin'){
  608. $start_time = date('Y-m-d H:i:s',strtotime($start_time.'+34 minutes'));
  609. $end_time = date('Y-m-d H:i:s',strtotime($end_time.'+34 minutes'));
  610. }
  611. $str = '.000+';
  612. $start_time = date('c', strtotime($start_time));//2022-07-14T08:00:00.000+08:00
  613. $start_time = explode('+',$start_time);
  614. $start_time = $start_time[0].$str.$start_time[1];
  615. $end_time = date('c', strtotime($end_time));
  616. $end_time = explode('+',$end_time);
  617. $end_time = $end_time[0].$str.$end_time[1];
  618. //判断是否在配置文件里,在的不用走ffmpeg
  619. if(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('playback'))){
  620. $result = CameraServices::getPlaybackRtsp($camera_id,$start_time,$end_time);
  621. return self::successResponse($result);
  622. }else{
  623. $result = CameraServices::getPlaybackByEasy($camera_id,$start_time,$end_time,$time);
  624. return self::successResponse($result);
  625. }
  626. }
  627. /**
  628. * 作者: qiuzijian
  629. * 注释: 获取编码设备信息
  630. * @return \App\Http\Controllers\Api\JsonResponse
  631. */
  632. public function getTranscodeInfo()
  633. {
  634. $parent_id = Input::get('parent_id', '');
  635. if (!$parent_id) {
  636. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  637. }
  638. $result = CameraServices::getHaiKangTransCode($parent_id);
  639. return self::successResponse($result);
  640. }
  641. /**
  642. * 作者: qiuzijian
  643. * 注释: 获取大南湖摄像头列表
  644. * @return \App\Http\Controllers\Api\JsonResponse
  645. */
  646. public function getSouthLakeCamera()
  647. {
  648. $result = CameraServices::getLeChangeCamera();
  649. return self::successResponse($result);
  650. }
  651. public function pictureBase64(){
  652. $base64 = Input::get('base64', '');
  653. $camera_id = Input::get('camera_id', '');
  654. if (!$base64 || !$camera_id) {
  655. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  656. }
  657. $data['base64'] = $base64;
  658. DB::table('camera_list')->where('id',$camera_id)->update($data);
  659. return self::successResponse();
  660. }
  661. public function test(){
  662. // header("Access-Control-Allow-Origin: *");
  663. $data = DB::table('goods')->get();
  664. return $data;
  665. }
  666. }