CameraApiController.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819
  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. }
  354. //信息技术中心测试ws协议
  355. // elseif($mine_res[0]-> slug == 'XinXiJiShuZhongXin'){
  356. // $result = CameraServices::getHkWs($camera_id,$parent_id);
  357. //
  358. // }
  359. //海康切片逻辑
  360. else{
  361. $result = CameraServices::downloadCameraFiles($parent_id, $camera_id);
  362. }
  363. } else {
  364. //判断硬盘录像机的有没有封面图,有的走easydrawin,没有的走ffmpeg
  365. $cover_picture = CameraList::where('id', $camera_id)->value('cover_picture');
  366. // if(!$cover_picture){
  367. //ffmpeg拉流获取首帧图片
  368. // $result = CameraServices::getCameraUrlByFfmpeg($camera_id);
  369. // }else{
  370. // $result = CameraServices::getCameraUrlByCameraId($camera_id);
  371. $result = CameraServices::getRtspYingPan($camera_id);
  372. // }
  373. }
  374. return self::successResponse($result);
  375. }
  376. public function getCamerasLanUrl()
  377. {
  378. $parent_id = Input::get('parent_id', '');
  379. $camera_id = Input::get('camera_id', '');
  380. if (!$parent_id || !$camera_id) {
  381. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  382. }
  383. //判断摄像头来源是否为内网服务器
  384. $camera_source = CameraList::where('id', $camera_id)->value('camera_source');
  385. if ($camera_source == CameraEnum::CAMERA_SOURCE_3) {
  386. $result = CameraServices::getIntranetCameraUrl($camera_id);
  387. return self::successResponse($result);
  388. }
  389. //判断是否使用海康视频服务器
  390. $is_hak = MineListExt::where('mine_id', $parent_id)->value('is_hak');
  391. //判断是否生成摄像头请求链接
  392. $camera_url = CameraList::where('id', $camera_id)->value('camera_url');
  393. if ($is_hak && !$camera_url) {
  394. //判断是否是mine配置文件的矿区
  395. $mine_res = DB::table('mine_list')->where('id',$parent_id)->get();
  396. //天地伟业
  397. if(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('mine'))){
  398. $result = CameraServices::getRtspTianDi($camera_id,$parent_id);
  399. //宁煤集团
  400. }elseif(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('mine_hls'))){
  401. $result = CameraServices::getHkHls($camera_id,$parent_id);
  402. }else{
  403. $result = CameraServices::getLanCameraUrl($parent_id, $camera_id);
  404. }
  405. } else {
  406. //判断硬盘录像机的有没有封面图,有的走easydrawin,没有的走ffmpeg
  407. $cover_picture = CameraList::where('id', $camera_id)->value('cover_picture');
  408. // if(!$cover_picture){
  409. //ffmpeg拉流获取首帧图片
  410. // $result = CameraServices::getCameraUrlByFfmpeg($camera_id);
  411. // }else{
  412. $result = CameraServices::getCameraUrlByCameraId($camera_id);
  413. // }
  414. }
  415. return self::successResponse($result);
  416. }
  417. //获取海康rtsp流
  418. public function getHikRtsp(){
  419. $parent_id = Input::get('parent_id', '');
  420. $camera_id = Input::get('camera_id', '');
  421. if (!$parent_id || !$camera_id) {
  422. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  423. }
  424. //判断是否使用海康视频服务器
  425. $is_hak = MineListExt::where('mine_id', $parent_id)->value('is_hak');
  426. //判断是否生成摄像头请求链接
  427. $camera_url = CameraList::where('id', $camera_id)->value('camera_url');
  428. if ($is_hak == 1 && !$camera_url) {
  429. $result = CameraServices::getHkRtsp($camera_id,$parent_id);
  430. return self::successResponse($result);
  431. }else{
  432. return self::errorResponse(ApiEnum::HK_REQUEST_FAIL);
  433. }
  434. }
  435. //获取海康rtmp流
  436. public function getHikRtmp(){
  437. $parent_id = Input::get('parent_id', '');
  438. $camera_id = Input::get('camera_id', '');
  439. if (!$parent_id || !$camera_id) {
  440. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  441. }
  442. //判断是否使用海康视频服务器
  443. $is_hak = MineListExt::where('mine_id', $parent_id)->value('is_hak');
  444. //判断是否生成摄像头请求链接
  445. $camera_url = CameraList::where('id', $camera_id)->value('camera_url');
  446. if ($is_hak == 1 && !$camera_url) {
  447. $result = CameraServices::getHkRtmp($camera_id,$parent_id);
  448. return self::successResponse($result);
  449. }else{
  450. return self::errorResponse(ApiEnum::HK_REQUEST_FAIL);
  451. }
  452. }
  453. //海康摄像头easy_drawin方式获取url
  454. public function getCamerasRtsp()
  455. {
  456. $parent_id = Input::get('parent_id', '');
  457. $camera_id = Input::get('camera_id', '');
  458. if (!$parent_id || !$camera_id) {
  459. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  460. }
  461. //判断摄像头来源是否为内网服务器
  462. $camera_source = CameraList::where('id', $camera_id)->value('camera_source');
  463. if ($camera_source == CameraEnum::CAMERA_SOURCE_3) {
  464. $result = CameraServices::getIntranetCameraUrl($camera_id);
  465. return self::successResponse($result);
  466. }
  467. //判断是否使用海康视频服务器
  468. $is_hak = MineListExt::where('mine_id', $parent_id)->value('is_hak');
  469. //判断是否生成摄像头请求链接
  470. $camera_url = CameraList::where('id', $camera_id)->value('camera_url');
  471. if ($is_hak && !$camera_url) {
  472. //判断是否是mine配置文件的矿区
  473. $mine_res = DB::table('mine_list')->where('id',$parent_id)->get();
  474. if(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('mine'))){
  475. //天地伟业使用easy_drawin获取rtsp
  476. $result = CameraServices::getRtspTianDi($camera_id,$parent_id);
  477. }else{
  478. //海康使用easy_drawin获取rtsp
  479. $result = CameraServices::getRtspHaiKang($camera_id, $parent_id);
  480. }
  481. } else {
  482. //硬盘录像机使用easy_drawin获取rtsp
  483. $result = CameraServices::getRtspYingPan($camera_id);
  484. }
  485. return self::successResponse($result);
  486. }
  487. /**
  488. * 作者: qiuzijian
  489. * 注释: 停止摄像头推流
  490. * @return \App\Http\Controllers\Api\JsonResponse
  491. */
  492. public function stopCamerasStream()
  493. {
  494. $camera_id = Input::get('camera_id', '');
  495. $result = CameraServices::stopCameraStream();
  496. return self::successResponse($result);
  497. }
  498. //回放列表
  499. public function getPlaybackList(){
  500. $camera_id = Input::get('camera_id', '');
  501. $result['status'] = true;
  502. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  503. if (!$camera_id) {
  504. $result['status'] = false;
  505. $result['msg'] = ApiEnum::STATUS_CODE_EMPTY;
  506. return $result;
  507. }
  508. $query = CameraList::where('id', $camera_id)->first();
  509. if (!$query) {
  510. $result['status'] = false;
  511. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  512. return $result;
  513. }
  514. if($query->playback == 0){
  515. $result['status'] = false;
  516. $result['msg'] = ApiEnum::NO_SUPORT_PLAYBACK;
  517. return $result;
  518. }
  519. $playback = DB::table('playback')->where('camera_id',$query->id)->where('deleted_at',null)->get();
  520. if(count($playback)>0){
  521. for($i=0;$i<count($playback);$i++){
  522. $result['data'][$i]['title'] = $playback[$i]->title;
  523. $result['data'][$i]['start_time'] = $playback[$i]->start_time;
  524. $result['data'][$i]['end_time'] = $playback[$i]->end_time;
  525. $result['data'][$i]['camera_id'] = $playback[$i]->camera_id;
  526. }
  527. }else{
  528. $result['data'] = null;
  529. }
  530. return $result;
  531. }
  532. //回放URL
  533. public function getPlaybackUrl(){
  534. $time['start_time'] = explode(' ',Input::get('start_time', ''))[1];
  535. $time['end_time'] = explode(' ',Input::get('end_time', ''))[1];
  536. $camera_id = Input::get('camera_id', '');
  537. $start_time = Input::get('start_time', '');
  538. $end_time = Input::get('end_time', '');
  539. $result['status'] = true;
  540. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  541. if (!$camera_id || !$start_time || !$end_time) {
  542. $result['status'] = false;
  543. $result['msg'] = ApiEnum::STATUS_CODE_EMPTY;
  544. return $result;
  545. }
  546. $query = CameraList::where('id', $camera_id)->first();
  547. if (!$query) {
  548. $result['status'] = false;
  549. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  550. return $result;
  551. }
  552. if($query->playback == 0){
  553. $result['status'] = false;
  554. $result['msg'] = ApiEnum::NO_SUPORT_PLAYBACK;
  555. return $result;
  556. }
  557. $degree = MineList::where('id', $query->mine_id)->value('degree');
  558. $degree = explode('|', $degree)[0];
  559. $mine_res = DB::table('mine_list')->where('id',$degree)->get();
  560. //判断摄像头是否是洗选中心的时间+34分钟
  561. if($mine_res[0]->slug == 'XiXuanZhongXin'){
  562. $start_time = date('Y-m-d H:i:s',strtotime($start_time.'+34 minutes'));
  563. $end_time = date('Y-m-d H:i:s',strtotime($end_time.'+34 minutes'));
  564. }
  565. $str = '.000+';
  566. $start_time = date('c', strtotime($start_time));//2022-07-14T08:00:00.000+08:00
  567. $start_time = explode('+',$start_time);
  568. $start_time = $start_time[0].$str.$start_time[1];
  569. $end_time = date('c', strtotime($end_time));
  570. $end_time = explode('+',$end_time);
  571. $end_time = $end_time[0].$str.$end_time[1];
  572. //判断是否在配置文件里,在的不用走ffmpeg
  573. if(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('playback'))){
  574. $result = CameraServices::getPlaybackRtsp($camera_id,$start_time,$end_time);
  575. return self::successResponse($result);
  576. }else{
  577. $result = CameraServices::getPlaybackRtmp($camera_id,$start_time,$end_time,$time);
  578. return self::successResponse($result);
  579. }
  580. }
  581. //easydrawin回放URL
  582. public function getPlaybackUrlByEasy(){
  583. $time['start_time'] = explode(' ',Input::get('start_time', ''))[1];
  584. $time['end_time'] = explode(' ',Input::get('end_time', ''))[1];
  585. $camera_id = Input::get('camera_id', '');
  586. $start_time = Input::get('start_time', '');
  587. $end_time = Input::get('end_time', '');
  588. $result['status'] = true;
  589. $result['msg'] = ApiEnum::RETURN_SUCCESS;
  590. if (!$camera_id || !$start_time || !$end_time) {
  591. $result['status'] = false;
  592. $result['msg'] = ApiEnum::STATUS_CODE_EMPTY;
  593. return $result;
  594. }
  595. $query = CameraList::where('id', $camera_id)->first();
  596. if (!$query) {
  597. $result['status'] = false;
  598. $result['msg'] = ApiEnum::NO_CAMERA_URL;
  599. return $result;
  600. }
  601. if($query->playback == 0){
  602. $result['status'] = false;
  603. $result['msg'] = ApiEnum::NO_SUPORT_PLAYBACK;
  604. return $result;
  605. }
  606. $degree = MineList::where('id', $query->mine_id)->value('degree');
  607. $degree = explode('|', $degree)[0];
  608. $mine_res = DB::table('mine_list')->where('id',$degree)->get();
  609. //判断摄像头是否是洗选中心的时间+34分钟
  610. if($mine_res[0]->slug == 'XiXuanZhongXin'){
  611. $start_time = date('Y-m-d H:i:s',strtotime($start_time.'+34 minutes'));
  612. $end_time = date('Y-m-d H:i:s',strtotime($end_time.'+34 minutes'));
  613. }
  614. $str = '.000+';
  615. $start_time = date('c', strtotime($start_time));//2022-07-14T08:00:00.000+08:00
  616. $start_time = explode('+',$start_time);
  617. $start_time = $start_time[0].$str.$start_time[1];
  618. $end_time = date('c', strtotime($end_time));
  619. $end_time = explode('+',$end_time);
  620. $end_time = $end_time[0].$str.$end_time[1];
  621. //判断是否在配置文件里,在的不用走ffmpeg
  622. if(isset($mine_res[0]->title) && in_array($mine_res[0]->title,config('playback'))){
  623. $result = CameraServices::getPlaybackRtsp($camera_id,$start_time,$end_time);
  624. return self::successResponse($result);
  625. }else{
  626. $result = CameraServices::getPlaybackByEasy($camera_id,$start_time,$end_time,$time);
  627. return self::successResponse($result);
  628. }
  629. }
  630. /**
  631. * 作者: qiuzijian
  632. * 注释: 获取编码设备信息
  633. * @return \App\Http\Controllers\Api\JsonResponse
  634. */
  635. public function getTranscodeInfo()
  636. {
  637. $parent_id = Input::get('parent_id', '');
  638. if (!$parent_id) {
  639. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  640. }
  641. $result = CameraServices::getHaiKangTransCode($parent_id);
  642. return self::successResponse($result);
  643. }
  644. /**
  645. * 作者: qiuzijian
  646. * 注释: 获取大南湖摄像头列表
  647. * @return \App\Http\Controllers\Api\JsonResponse
  648. */
  649. public function getSouthLakeCamera()
  650. {
  651. $result = CameraServices::getLeChangeCamera();
  652. return self::successResponse($result);
  653. }
  654. public function pictureBase64(){
  655. $base64 = Input::get('base64', '');
  656. $camera_id = Input::get('camera_id', '');
  657. if (!$base64 || !$camera_id) {
  658. return self::errorResponse(ApiEnum::STATUS_CODE_EMPTY);
  659. }
  660. $data['base64'] = $base64;
  661. DB::table('camera_list')->where('id',$camera_id)->update($data);
  662. return self::successResponse();
  663. }
  664. public function test(){
  665. // header("Access-Control-Allow-Origin: *");
  666. $data = DB::table('goods')->get();
  667. return $data;
  668. }
  669. }