天地伟业摄像头同步优化

Modules/Mine/Http/Controllers/MineController.php

@@ -157,7 +157,7 @@ class MineController extends BaseController
                     return $this->error(1, '请输入连接视频服务器必传参数');
                 }
             }
-            MineServices::insertMineListExt($request->input('id'), $request->all());
+            MineServices::editMineListExt($request->input('id'), $request->all());
         }
 
         return $this->redirect('admin/mine/list');

app/Console/Commands/UpdateHkList.php

@@ -6,6 +6,7 @@ use Illuminate\Console\Command;
 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\Services\MineServices;
@@ -110,96 +111,56 @@ class UpdateHkList extends Command
             }
         }
         //同步天地伟业摄像头
-        //登录
-        // $url = 'http://10.71.177.215:7000/pangu/sdkServer/user/loginUser';
-        // $format = 'post';
-        // $data = array('username'=>'admin1','password'=>'Td123..','sysId'=>'PG');
-        // $res =  $this->httpRequest($url,$format,$data);
-        //设备列表
-        //通过接口获取设备
-         $url = 'http://10.71.177.215:7000/pangu/sdkServer/device/queryDeviceList';
-         $format = 'post';
-         $data = array('sOrgId'=>'21dsec1d-4a27-48d1-we4c5-e44fcc23110','iDeviceTypes'=>'5','rootCodes'=>'BH-0001','isOrgTree'=>true,'needPage'=>true,'pageSize'=>50,'currentPage'=>1);
-         $device_list =  $this->httpRequest($url,$format,$data);
-         //获取金家渠mine_id
-         $mine_list0 = DB::table('mine_list')->where('title', 'like', '%金家渠煤矿%')->get();
-         if(sizeof($mine_list0)>0){
-             $mine_id0 = $mine_list0[0]->id;
-         }else{
-             $res0['parent_id'] = 0;
-             $res0['title'] = '金家渠煤矿';
-             $res0['slug'] = 'JinJiaQuMeiKuang';
-             $res0['created_at'] = date('y-m-d h:i:s',time());
-             $res0['updated_at'] = date('y-m-d h:i:s',time());
-             DB::table('mine_list')->insert($res0);
-             $mine_id0 = DB::getPdo()->lastInsertId();
-         }
-
-        $mine_list = DB::table('mine_list')->where('title', 'like', '%金家渠地面%')->get();
-        if(sizeof($mine_list)>0){
-            $mine_id = $mine_list[0]->id;
-        }else{
-            $res['parent_id'] = $mine_id0;
-            $res['title'] = '金家渠地面';
-            $res['slug'] = 'JinJiaQuDiMian';
-            $res['created_at'] = date('y-m-d h:i:s',time());
-            $res['updated_at'] = date('y-m-d h:i:s',time());
-            DB::table('mine_list')->insert($res);
-            $mine_id = DB::getPdo()->lastInsertId();
-        }
-
-         if(sizeof($device_list['content'])>0){
-             for($i=0;$i<sizeof($device_list['content']);$i++){
-                if(isset($device_list['content'][$i]['sId'])/* && $device_list['content'][$i]['onlineStatus']==1*/){
-//                    //rtsp视频流
-//                     $url = 'http://10.71.177.215:7000/pangu/sdkServer/videoStreaming/getRtspById';
-//                     $format = 'post';
-//                     $data = array('sId'=>$device_list['content'][$i]['sId'],'ip'=>'10.71.177.215','port'=>554,'type'=>0);
-//                     $camera_url =  $this->httpRequest($url,$format,$data);
-                    $params = [
-                        'mine_id'       => $mine_id,
-                        'ip'            => '10.71.177.215',
-                        'port'          => 1554,
-//                        'user_name'     => 'admin1',
-//                        'password'      => 'Td123..',
-//                        'camera_url'    => $camera_url['content'][0]['url'],
-                        'revert_id'     => CameraEnum::CAMERA_DEFAULT_REVERT_ID,
-                        'sort'          => sizeof($device_list['content']) - $i,
-                        'camera_name'   => $device_list['content'][$i]['sName'],
-                        'camera_source' => CameraEnum::CAMERA_SOURCE_2,
-                        'index_code'    => $device_list['content'][$i]['sId'],
-                        'video_recorder'=> CameraEnum::VIDEO_RECORDER_TD,
-                    ];
-                    CameraList::updateOrCreate(['index_code' => $device_list['content'][$i]['sId']], $params);
+        //需要同步的矿区
+        $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',2)
+            ->where('mine_list_ext.ip','!=','')
+            ->where('mine_list_ext.port','!=','')
+            ->where('mine_list_ext.key','!=','')
+            ->where('mine_list_ext.secret','!=','')->get();
+        if(sizeof($mine_list_ext)>0){
+            for($i=0;$i<sizeof($mine_list_ext);$i++){//循环同步所有天地伟业矿区
+                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'   => "21dsec1d-4a27-48d1-we4c5-e44fcc23110",
+                        'ip'       => $mine_list_ext[$i]->ip,
+                        'port'     => $mine_list_ext[$i]->port,
+                    ]
+                );
+                //获取设备列表
+                $tdwy = new TdwyController();
+                $device_list = $tdwy->queryDeviceList();
+                //获取需要同步到的区域
+                $mine_id = DB::table('mine_list')->where('parent_id',$mine_list_ext[$i]->mine_id)->where('deleted_at',null)->orderBy('sort','desc')->first()->id;
+                //先删除需要同步区域下的所有摄像头
+                DB::table('camera_list')->where('mine_id',$mine_id)->delete();
+                if(sizeof($device_list['content'])>0){
+                    for($j=0;$j<sizeof($device_list['content']);$j++){//循环添加所有摄像头
+                        if(isset($device_list['content'][$j]['sId'])){//筛选有sId的摄像头
+                            $params = [
+                                'mine_id'       => $mine_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,
+                            ];
+                            CameraList::updateOrCreate(['index_code' => $device_list['content'][$j]['sId']], $params);
+                        }
+                    }
                 }
-             }
-         }
-        //删除不存在的摄像头
-//        CameraList::where('mine_id', $mine_id)->where('onlineStatus',0)->delete();
-
-    }
-
-    public static function httpRequest($url, $format = 'get', $data = null){
-        //设置头信息
-        $headerArray =array("Content-type:application/json;","Accept:application/json","token:M3sWWDyqHsw3jmPP2VfIhd/z8KnV9gvJs2C4s/vbAfPAPuNUEmniC7OWtbFDSmWcm38LwUnZe2cuaClRsBegeQ==");
-        $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;
     }
 
     //转义摄像头名称中的特殊字符