CameraApiController.php 27 KB

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