摄像头同步修改

Modules/Camera/Http/Controllers/Api/CameraApiController.php

@@ -1354,7 +1354,7 @@ class CameraApiController extends BaseController
     public function readme(Request $request){
         $params = $request->all();
 
-        $result['coal_washery'] = DB::connection('task_xixuan')->table('xx_coal_washery')->get();
+        $result['coal_washery'] = DB::connection('task_xixuan')->table('xx_coal_washery')->orderBy('id')->get();
 
         $mine_list = DB::table('mine_list')->where('parent_id',6356)->where('deleted_at',null)->get();
 
@@ -1933,4 +1933,44 @@ class CameraApiController extends BaseController
 
         return self::successResponse($result);
     }
+
+    //获取大华视频服务器摄像头列表
+    public function getDahuaList(Request $request){
+        $ip = '222.75.25.198:8443';
+        $url = $ip.'/evo-apigw/evo-brm/1.2.0/device/channel/subsystem/page';
+        $params = [
+            'pageNum' => 1,
+            'pageSize' => 10,
+            'sortType' => 'ASC',
+            'sort' => 'channelSn',
+//            'ownerCode' =>
+        ];
+        $aa = $this->httpRequest($url,'post',$params);
+        var_dump($aa);
+        return 111;
+    }
+
+    //接口第三方调用
+    public function httpRequest($url, $format = 'get', $data = null){
+        //设置头信息
+        $headerArray =array("Content-type:application/json;","Accept:application/json");
+        $curl=curl_init();
+        curl_setopt($curl, CURLOPT_URL, $url);
+        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
+        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);
+        if ($format == 'post') {
+            //post传值设置post传参
+            curl_setopt($curl, CURLOPT_POST, 1);
+            if ($data) {
+                $data = json_encode($data);
+                curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
+            }
+        }
+        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
+        curl_setopt($curl,CURLOPT_HTTPHEADER,$headerArray);
+        $data=json_decode(curl_exec($curl), true);
+        curl_close($curl);
+        //返回接口返回数据
+        return $data;
+    }
 }

Modules/Camera/Routes/api.php

@@ -72,4 +72,6 @@ Route::namespace('Api')->group(function () {
     Route::post('task_xixuan/home', 'CameraApiController@taskHome');//首頁接口
     Route::post('task_xixuan/work_search', 'CameraApiController@workSearch');//首頁作业查询
     Route::post('task_xixuan/area_work_search', 'CameraApiController@areaWorkSearch');//首頁片区作业查询
+
+    Route::post('task_xixuan/get_dahua_list', 'CameraApiController@getDahuaList');//获取大华视频服务器播放列表
 });

app/Console/Commands/UpdateAreaList.php

@@ -0,0 +1,380 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Input;
+use Modules\Camera\Entities\CameraList;
+use Modules\Camera\Enum\CameraEnum;
+use Modules\Camera\Services\CameraServices;
+use Modules\Camera\Http\Controllers\Api\TdwyController;
+use Modules\Mine\Entities\MineList;
+use Modules\Mine\Entities\MineListExt;
+use Modules\Mine\Enum\MineEnum;
+use Modules\Mine\Services\MineServices;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+
+class UpdateAreaList extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'arealist:update';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '同步海康区域';
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return mixed
+     */
+    public function handle()
+    {
+        $start_time = time();
+        echo '开始时间:'.date('Y-m-d H:i:s');
+        $this->updateAreaList();
+//        $this->updateCameraList();
+        echo '时长:'.number_format(((time()-$start_time)/60),2).'分钟';
+    }
+
+    //同步区域列表
+    public function updateAreaList()
+    {
+        //查询使用海康服务器的矿区id
+        $mine_id_list = MineListExt::where('is_hak', 1)->pluck('mine_id')->all();
+
+        //海康区域同步开始时间
+//        $syn['hk_area_start_time'] = date('Y-m-d H:i:s');
+
+        foreach ($mine_id_list as $key => $val) {
+//            if($val == 968){
+//                //宁煤区域同步开始时间
+//                $syn['nm_area_start_time'] = date('Y-m-d H:i:s');
+//
+//                MineServices::getHaiKangArea($val, CameraEnum::REQUEST_TYPE_LOCAL);
+//
+//                //宁煤区域同步结束时间
+//                $syn['nm_area_end_time'] = date('Y-m-d H:i:s');
+//            }else{
+            MineServices::getHaiKangArea($val, CameraEnum::REQUEST_TYPE_LOCAL);
+//            }
+        }
+
+        //海康区域同步结束时间
+//        $syn['hk_area_end_time'] = date('Y-m-d H:i:s');
+        //天地区域同步开始时间
+//        $syn['td_area_start_time'] = date('Y-m-d H:i:s');
+
+        //同步天地伟业矿区区域
+        $mine_list_ext = DB::table('mine_list_ext')
+            ->select('mine_list_ext.*','mine_list.parent_id')
+            ->leftJoin('mine_list','mine_list.id','=','mine_list_ext.mine_id')
+            ->where('mine_list.parent_id',0)
+            ->where('mine_list_ext.is_hak',MineEnum::IS_HAK_TD)
+            ->where('mine_list_ext.ip','!=','')
+            ->where('mine_list_ext.port','!=','')
+            ->where('mine_list_ext.key','!=','')
+            ->where('mine_list_ext.secret','!=','')
+            ->where('mine_list_ext.deleted_at',null)->get();
+
+        if(sizeof($mine_list_ext)>0){
+            for($i=0;$i<sizeof($mine_list_ext);$i++){//循环同步所有天地伟业矿区
+
+                Input::replace(
+                    [
+                        'parentOrgIds'   => $mine_list_ext[$i]->sOrgId,
+                        'url'      => $mine_list_ext[$i]->ip.":".$mine_list_ext[$i]->port,
+                        'username' => $mine_list_ext[$i]->key,
+                        'password' => $mine_list_ext[$i]->secret,
+                        'sysId'     => 'PG',
+                    ]
+                );
+                $tdwy = new TdwyController();
+                $region = $tdwy->getRegionByOrgId();
+                $mine_id = $mine_list_ext[$i]->mine_id;
+                //更新区域
+                $result['data']['list'] = $tdwy->saveTrees($region, $mine_id);
+            }
+        }
+
+        //天地区域同步结束时间
+//        $syn['td_area_end_time'] = date('Y-m-d H:i:s');
+//        DB::table('syn')->insert($syn);
+    }
+
+    public function updateCameraList()
+    {
+        //海康
+        //查询存在index_code列表
+        $index_code_list = MineList::where('index_code', '!=', null)->get();
+
+        //不在线矿区
+        $mine_list_ext = DB::table('mine_list_ext')->where('deleted_at',null)->where('ip','!=',null)->get();
+        for($i=0;$i<count($mine_list_ext);$i++){
+            $ip = explode('://',$mine_list_ext[$i]->ip)[1];
+            $port = $mine_list_ext[$i]->port;
+            if($fp = @fsockopen($ip,$port,$errno,$errstr,1)){
+                fclose($fp);
+            }else{
+                $arr[] = $mine_list_ext[$i]->mine_id;
+            }
+        }
+
+        //去掉不在线矿区
+        foreach($index_code_list as $k=>$v){
+            $degree = explode('|',$v->degree);
+            if(isset($arr)){
+                for($i=0;$i<count($arr);$i++){
+                    if($degree[0] == $arr[$i]){
+                        unset($index_code_list[$k]);
+                    }
+                }
+            }
+        }
+
+        //去掉洗选
+//        foreach($index_code_list as $k=>$v){
+//            $degree = explode('|',$v->degree);
+//            if($degree[0] == 66){
+//                unset($index_code_list[$k]);
+//            }
+//        }
+
+        //天地伟业矿区
+        $mine_ext = DB::table('mine_list_ext')
+            ->select('mine_list_ext.*','mine_list.parent_id')
+            ->leftJoin('mine_list','mine_list.id','=','mine_list_ext.mine_id')
+            ->where('mine_list.parent_id',0)
+            ->where('mine_list_ext.is_hak',MineEnum::IS_HAK_TD)
+            ->where('mine_list_ext.ip','!=','')
+            ->where('mine_list_ext.port','!=','')
+            ->where('mine_list_ext.key','!=','')
+            ->where('mine_list_ext.secret','!=','')
+            ->where('mine_list_ext.deleted_at',null)->get();
+
+        $mine_id_list = [];
+        foreach($mine_ext as $k=>$v){
+            $mine_id_list[$k] = $v->mine_id;
+        }
+        //清除天地伟业的区域
+        if(count($mine_id_list) > 0){
+            foreach($index_code_list as $k=>$v){
+                if(in_array(explode('|',$v->degree)[0],$mine_id_list)){
+                    unset($index_code_list[$k]);
+                }
+            }
+        }
+
+        //海康摄像头同步开始时间
+//        $syn_id = DB::table('syn')->orderBy('id','desc')->pluck('id')->first();
+//        $syn1['hk_camera_start_time'] = date('Y-m-d H:i:s');
+//        DB::table('syn')->where('id',$syn_id)->update($syn1);
+
+//        $nm_camera_time = 0;
+        foreach ($index_code_list as $key => $val) {
+
+            //宁煤同步摄像头开始时间
+//            $nm_start_time = time();
+//            $timetotal['mine_id'] = $val->id;
+//            $timetotal['interface_start_time'] = date('Y-m-d H:i:s');
+
+            $degree       = explode('|', $val->degree);
+//            $trans_result = CameraServices::getHaiKangTransList($degree[0]);
+            $result       = CameraServices::getHaiKangCamera($degree[0], $val->index_code, CameraEnum::CAMERA_TYPE_ALL);
+
+//            $info = DB::table('syn')->select('interface','handle')->orderBy('id','desc')->first();
+//            $syn2['interface'] = $info->interface . $val->id . ':' . (time() - $nm_start_time) . ';';
+//            $timetotal['interface_end_time'] = date('Y-m-d H:i:s');
+//            $timetotal['handle_start_time'] = date('Y-m-d H:i:s');
+//            DB::table('syn')->where('id',$syn_id)->update($syn2);
+
+//            $handle_start = time();
+
+            if ($result['status']) {
+                $trans_arr = [];
+//                foreach ($trans_result['data'] as $tk => $tv) {
+//                    $trans_arr[$tv['indexCode']]['ip'] = $tv['ip'];
+//                }
+
+                $index_code_arr = [];
+//                $arr_count = count($result['data']);
+                foreach ($result['data'] as $k => $v) {
+                    $ip         = '';
+                    $port       = '';
+                    $com_number = '';
+//                    if (isset($trans_arr[$v['trans_code']])) {
+//                        $ip         = $trans_arr[$v['trans_code']]['ip'];
+//                        $port       = CameraEnum::HAK_DEFAULT_PORT;
+//                        $com_number = $v['com_number'];
+//                    }
+
+                    //当前摄像头index_code数组
+                    $index_code_arr[$k] = $v['camera_id'];
+
+                    //更新时间距当前时间天数
+//                    $update_time = strtotime($v['updateTime']);
+//                    $update_time = number_format((time() - $update_time)/(60*60*24),2);
+
+                    $params = [
+                        'mine_id'       => $val->id,
+                        'camera_name'   => $this->transformCameraName($v['camera_name']),
+                        'index_code'    => $v['camera_id'],
+                        'revert_id'     => CameraEnum::CAMERA_DEFAULT_REVERT_ID,
+                        'camera_source' => CameraEnum::CAMERA_SOURCE_2,
+                        'ip'            => $ip,
+                        'port'          => $port,
+                        'com_number'    => $com_number,
+                        //'sort'          => $arr_count - $k,
+//                        'camera_status'        => $v['camera_status'],
+                    ];
+
+//                    if($result['is_update'] == true){
+                    CameraList::updateOrCreate(['index_code' => $v['camera_id']], $params);
+//                    }elseif($update_time < 10){
+//                        CameraList::updateOrCreate(['index_code' => $v['camera_id']], $params);
+//                    }
+
+                }
+
+                //删除不存在的摄像头
+                CameraList::where('mine_id', $val->id)->where('index_code', '!=', NULL)->whereNotIn('index_code', $index_code_arr)->delete();
+            }
+
+//            $syn2['handle'] = $info->handle . $val->id . ':' . (time() - $handle_start) . ';';
+//            $timetotal['handle_end_time'] = date('Y-m-d H:i:s');
+//            DB::table('syn')->where('id',$syn_id)->update($syn2);
+//            DB::table('timetotal')->insert($timetotal);
+
+//            if($val->parent_id == 968){
+//                //宁煤同步摄像头时间
+//                $nm_camera_time += time() - $nm_start_time;
+//            }
+
+        }
+
+//        $syn['nm_camera_time'] = $nm_camera_time;//宁煤单个区域同步时间
+//        DB::table('syn')->where('id',$syn_id)->update($syn);
+
+        //海康摄像头同步结束时间
+//        $syn['hk_camera_end_time'] = date('Y-m-d H:i:s');
+//        DB::table('syn')->where('id',$syn_id)->update($syn);
+
+        //天地伟业需要同步的矿区
+        $mine_list_ext = DB::table('mine_list_ext')
+            ->select('mine_list_ext.*','mine_list.parent_id')
+            ->leftJoin('mine_list','mine_list.id','=','mine_list_ext.mine_id')
+            ->where('mine_list.parent_id',1)//0,先不同步天地伟业摄像头
+            ->where('mine_list_ext.is_hak',MineEnum::IS_HAK_TD)
+            ->where('mine_list_ext.ip','!=','')
+            ->where('mine_list_ext.port','!=','')
+            ->where('mine_list_ext.key','!=','')
+            ->where('mine_list_ext.secret','!=','')
+            ->where('mine_list_ext.deleted_at',null)->get();
+
+        //天地摄像头同步开始时间
+//        $syn['td_camera_start_time'] = date('Y-m-d H:i:s');
+//        DB::table('syn')->where('id',$syn_id)->update($syn);
+
+        if(sizeof($mine_list_ext)>0){
+            for($i=0;$i<sizeof($mine_list_ext);$i++){//循环同步所有天地伟业矿区
+                //矿区下所有区域
+                $mine_list = DB::table('mine_list')
+                    ->where('degree','like',$mine_list_ext[$i]->mine_id.'|%')
+                    ->where('index_code','!=',null)->get();
+                foreach($mine_list as $k=>$v){
+                    $mine_id = $v->id;
+                    Input::replace(
+                        [
+                            'parentOrgIds'   => $v->index_code,
+                            'url'      => $mine_list_ext[$i]->ip.":".$mine_list_ext[$i]->port,
+                            'username' => $mine_list_ext[$i]->key,
+                            'password' => $mine_list_ext[$i]->secret,
+                            'sysId'     => 'PG',
+                        ]
+                    );
+                    //获取区域下的子区域
+                    $tdwy = new TdwyController();
+                    $region = $tdwy->getRegionByOrgId();
+
+                    //获取最底层区域摄像头列表
+                    if (empty($region['content'])) {
+                        Input::replace(
+                            [
+                                'url'      => $mine_list_ext[$i]->ip.":".$mine_list_ext[$i]->port,
+                                'username' => $mine_list_ext[$i]->key,
+                                'password' => $mine_list_ext[$i]->secret,
+                                'sysId'     => 'PG',
+                                'sOrgId'   => $v->index_code,
+                                'ip'       => $mine_list_ext[$i]->ip,
+                                'port'     => $mine_list_ext[$i]->port,
+                            ]
+                        );
+                        //获取设备列表
+                        $tdwy = new TdwyController();
+                        $device_list = $tdwy->queryDeviceList();
+                        $device_index_code = [];
+                        //删除区域下所有摄像头
+//                        DB::table('camera_list')->where('mine_id',$v->id)->delete();
+                        if(isset($device_list['content']) && sizeof($device_list['content'])>0){
+                            for($j=0;$j<sizeof($device_list['content']);$j++){//循环添加区域下所有摄像头
+                                if(isset($device_list['content'][$j]['sId'])){//筛选有sId的摄像头
+                                    if($device_list['content'][$j]['onlineStatus'] == 0){
+                                        $device_list['content'][$j]['onlineStatus'] = 2;
+                                    }
+                                    $params = [
+                                        'mine_id'       => $v->id,
+                                        'ip'            => $mine_list_ext[$i]->ip,
+                                        'port'          => 1554,
+                                        'revert_id'     => CameraEnum::CAMERA_DEFAULT_REVERT_ID,
+                                        'sort'          => sizeof($device_list['content']) - $j,
+                                        'camera_name'   => $device_list['content'][$j]['sName'],
+                                        'camera_source' => CameraEnum::CAMERA_SOURCE_2,
+                                        'index_code'    => $device_list['content'][$j]['sId'],
+                                        'video_recorder'=> CameraEnum::VIDEO_RECORDER_TD,
+                                        'camera_status' => $device_list['content'][$j]['onlineStatus'],
+                                    ];
+                                    CameraList::updateOrCreate(['index_code' => $device_list['content'][$j]['sId']], $params);
+                                }
+                                $device_index_code[$j] = $device_list['content'][$j]['sId'];
+                            }
+                        }
+                        //删除不存在的摄像头
+                        CameraList::where('mine_id', $mine_id)->where('index_code', '!=', NULL)->whereNotIn('index_code', $device_index_code)->delete();
+                    }
+                }
+            }
+        }
+
+        //天地摄像头同步结束时间
+//        $syn['td_camera_end_time'] = date('Y-m-d H:i:s');
+//        DB::table('syn')->where('id',$syn_id)->update($syn);
+    }
+
+    //转义摄像头名称中的特殊字符
+    public function transformCameraName($camera_name)
+    {
+        $camera_name = trim($camera_name);
+        $camera_name = str_replace('#', '号', $camera_name);
+        $camera_name = str_replace(' ', '-', $camera_name);
+        $camera_name = str_replace('+', '', $camera_name);
+        return $camera_name;
+    }
+}

app/Console/Commands/UpdateHkList.php

@@ -50,7 +50,7 @@ class UpdateHkList extends Command
     {
         $start_time = time();
         echo '开始时间:'.date('Y-m-d H:i:s');
-        $this->updateAreaList();
+//        $this->updateAreaList();
         $this->updateCameraList();
         echo '时长:'.number_format(((time()-$start_time)/60),2).'分钟';
     }