* @version : HUOSDK 9.0 */ namespace huoIdentify\identifyDriver\driver; use GuzzleHttp\Client; use GuzzleHttp\Exception\ConnectException; use huoIdentify\controller\AesEcb; use huoIdentify\identifyDriver\Driver; use huoIdentify\model\IdentifyMemModel; use huoIdentify\model\IdentifyPlatformLogModel; use huolib\constant\IdentifyConst; use huolib\status\CommonStatus; use huolib\status\IdentifyStatus; use think\Config; class Yiwan extends Driver { const STATUS_SUCCESS = 1;//认证成功 const STATUS_IN_PROGRESS = 2;//认证中 const STATUS_FAIL = 3;//认证失败 /** * @var string */ protected $cipher = "aes-128-ecb"; /** * @var AesEcb */ protected $aes; /** * @var array */ protected $headers; /** * @var string */ protected $key; /** * @var int $timeout */ protected $timeout = 3; /** * @var Client */ protected $http; protected $app_id; /* 当前游戏id */ protected $channel_code; /* 渠道code 益玩提供 */ protected $require_url; /* 认证URL 益玩提供 */ /** * @param array $config */ public function __construct($config = []) { $_config = $config; if (empty($_config)) { $_config = (array)Config::get('identify_conf.yiwan'); } parent::__construct($_config); // 设置属性 $this->app_id = get_val($_config, 'app_id', 0); $this->channel_code = get_val($_config, 'channel_code', ''); $this->require_url = get_val($_config, 'require_url', ''); $this->aes = new AesEcb($this->channel_code, $this->cipher); if (!class_exists('\\GuzzleHttp\\Client')) { // 使用已有的GuzzleHttp require_once 'wxpay/TCloudAutoLoader.php'; } $this->http = new Client(); } /** * 实名认证 * https://wlc.nppa.gov.cn/fcm_company/index.html#/login */ public function identify() { $_results = $this->check($this->real_name, $this->id_card); $_results_arr = json_decode($_results, true); if (empty($_results_arr) || !isset($_results_arr['code']) || '0' != $_results_arr['code']) { $_result = [$_results, $_results_arr]; $_step = 0; $_other = '益玩防沉迷实名认证API,认证异常'; \huolib\tool\Log::outErrorLog(debug_backtrace(false, 1)[0], $_result, $_step, $_other); $_code = CommonStatus::INNER_ERROR; $_results_arr['msg'] = empty($_results_arr['msg']) ? $_other : $_results_arr['msg']; return $this->huoError($_code, $_results_arr['msg']); } /* 认证失败 */ if ($_results_arr['data']['auth_state'] == self::STATUS_FAIL) { $_result = $_results_arr; $_step = 0; $_other = '益玩防沉迷实名认证API,认证失败'; \huolib\tool\Log::outErrorLog(debug_backtrace(false, 1)[0], $_result, $_step, $_other); $_code = IdentifyStatus::IDENTITY_FAIL; return $this->huoError($_code, $_other); } /** * 认证成功需要添加记录 */ $_ipl_model = new IdentifyPlatformLogModel(); $_ipl_info = $_ipl_model->getInfoByMgFrom($this->mg_mem_id, IdentifyConst::DRIVER_KEY_YIWAN); $_log_data = [ 'mem_id' => $this->mem_id, 'mg_mem_id' => $this->mg_mem_id, 'app_id' => $this->app_id, 'identify_from' => IdentifyConst::DRIVER_KEY_YIWAN, 'real_name' => $this->real_name, 'id_card' => $this->id_card, 'identify_pi' => $_results_arr['data']['pi'], 'status' => $_results_arr['data']['auth_state'], ]; if (empty($_ipl_info)) { $_ipl_model->addData($_log_data); } else { $_ipl_model->updateData($_log_data, $_ipl_info['id']); } /* 认证中 */ if ($_results_arr['data']['auth_state'] == self::STATUS_IN_PROGRESS) { $_code = CommonStatus::MEM_IDENTIFY_IN_PROGRESS; return $this->huoSuccess($_code, CommonStatus::getMsg($_code)); } $_code = CommonStatus::NO_ERROR; return $this->huoSuccess($_code, CommonStatus::getMsg($_code), $_results_arr['data']); } /** * 查询是否已认证 * * @return bool */ private function checkIsVerified() { $_pi = (new IdentifyPlatformLogModel())->getPiByMgFrom($this->mg_mem_id, IdentifyConst::DRIVER_KEY_YIWAN); return empty($_pi) ? false : true; } public function loginBehavior($identify_pi) { $_check_rs = $this->checkIsVerified(); if (true === $_check_rs) { /* 已认证无需处理 */ $_code = CommonStatus::NO_ERROR; return $this->huoSuccess($_code, CommonStatus::getMsg($_code)); } $_identify_rs = $this->identify(); if (CommonStatus::NO_ERROR == $_identify_rs['code']) { $_im_model = new IdentifyMemModel(); $_old_id_data = $_im_model->getInfoByMemId($this->mem_id); $_identify_pi = isset($_identify_rs['data']['pi']) ? $_identify_rs['data']['pi'] : ''; if (empty($_old_id_data)) { $_data = [ 'identify_from' => IdentifyConst::DRIVER_KEY_YIWAN, 'identify_pi' => $_identify_pi, 'mem_id' => $this->mem_id, 'real_name' => $this->real_name, 'id_card' => $this->id_card ]; $_im_model->addData($_data); } elseif (empty($_old_id_data['identify_pi'])) { $_update_data = [ 'identify_pi' => $_identify_pi ]; $_im_model->updateData($_update_data, $_old_id_data['id']); } } $_code = CommonStatus::NO_ERROR; return $this->huoSuccess($_code, CommonStatus::getMsg($_code)); } /** * check the name and idNum * * @param string $name * @param string $idNum * * @return string */ public function check($name, $idNum) { $_uri = $this->require_url; $_headers = ['Content-Type' => 'text/plain', 'pf' => $this->getPf()]; if (!empty($this->headers)) { $_headers = array_merge($_headers, $this->headers); } $_uid = $this->mg_mem_id; $_body = ['id_no' => $idNum, 'id_name' => $name, 'uid' => $_uid, 'app_id' => $this->app_id]; return $this->doRequest('POST', $_uri, $_headers, $_body); } /** * do request * * @param string $method * @param string $uri * @param array $headers * @param array $body * @param array $options * * @return string */ private function doRequest($method, $uri, array $headers = [], array $body = [], array $options = []) { $raw = json_encode($body, JSON_UNESCAPED_UNICODE); $body = $this->aes->encrypt($raw); $options = array_merge(['headers' => $headers, 'body' => $body, 'timeout' => $this->timeout], $options); try { $response = $this->http->request($method, $uri, $options); return $response->getBody()->getContents(); } catch (ConnectException $e) { $_result = $e->getMessage(); $_step = 0; $_other = 0; \huolib\tool\Log::outErrorLog(debug_backtrace(false, 1)[0], $_result, $_step, $_other); throw new \think\Exception('实名认证系统异常'); } } }