CameraApiController.php 31 KB

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