updateAreaList(); $this->updateCameraList(); } //同步区域列表 public function updateAreaList() { //查询使用海康服务器的矿区id $mine_id_list = MineListExt::where('is_hak', 1)->pluck('mine_id')->all(); foreach ($mine_id_list as $key => $val) { MineServices::getHaiKangArea($val, CameraEnum::REQUEST_TYPE_LOCAL); } } public function updateCameraList() { //查询存在index_code列表 $index_code_list = MineList::where('index_code', '!=', null)->get(); foreach ($index_code_list as $key => $val) { $degree = explode('|', $val->degree); $trans_result = CameraServices::getHaiKangTransList($degree[0]); $result = CameraServices::getHaiKangCamera($degree[0], $val->index_code, CameraEnum::CAMERA_TYPE_ALL); if ($result['status'] && $trans_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']; $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, ]; 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(); } } } //转义摄像头名称中的特殊字符 public function transformCameraName($camera_name) { $camera_name = trim($camera_name); $camera_name = str_replace('#', '号', $camera_name); $camera_name = str_replace(' ', '-', $camera_name); return $camera_name; } }