game-sdk/simplewind/extend/huoIdentify/identifyDriver/driver/Juefeng.php

<?php
/**
 * Juefeng.php UTF-8
 *   绝峰实名认证pi上报
 *
 * @date    : 2021/4/30 17:33
 *
 * @license 这不是一个自由软件，未经授权不许任何使用和传播。
 * @author  : chenbingling <cbl@huosdk.com>
 * @version : HUOSDK-9.0
 */

namespace huoIdentify\identifyDriver\driver;

use GuzzleHttp\Client;
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 huolib\tool\Http;

class JUEFENG extends Driver {
    const STATUS_SUCCESS     = 1;//认证成功
    const STATUS_IN_PROGRESS = 2;//认证中
    const STATUS_FAIL        = 3;//认证失败
    /**
     * @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;
        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', '');
    }

    /**
     * 实名认证
     * https://wlc.nppa.gov.cn/fcm_company/index.html#/login
     */
    public function identify() {
        if (!empty($this->pi)) {
            return $this->reportPi();
        }
        $_results = $this->check();
        $_results_arr = json_decode($_results, true);
        if (empty($_results_arr) || !isset($_results_arr['code'])
            || ('1' != $_results_arr['code']
                && '1001' != $_results_arr['code'])) {
            $_result = [$_results, $_results_arr, $this->real_name, $this->id_card];
            $_step = 0;
            $_other = '绝峰防沉迷实名认证API，认证异常realName';
            \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']);
        }
        /* 1001是用户不存在，默认为认证中 */
        if ('1001' == $_results_arr['code']) {
            $_results_arr['data'] = ['status' => self::STATUS_IN_PROGRESS, 'pi' => ''];
        }
        /* 认证失败 */
        if ($_results_arr['data']['status'] == self::STATUS_FAIL) {
            $_result = $_results_arr;
            $_step = 0;
            $_other = '绝峰防沉迷实名认证API，认证失败realName';
            \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_JUEFENG);
        $_log_data = [
            'mem_id'        => $this->mem_id,
            'mg_mem_id'     => $this->mg_mem_id,
            'app_id'        => $this->app_id,
            'identify_from' => IdentifyConst::DRIVER_KEY_JUEFENG,
            'real_name'     => $this->real_name,
            'id_card'       => $this->id_card,
            'identify_pi'   => $_results_arr['data']['pi'],
            'status'        => $_results_arr['data']['status'],
        ];
        if (empty($_ipl_info)) {
            $_ipl_model->addData($_log_data);
        } else {
            $_ipl_model->updateData($_log_data, $_ipl_info['id']);
        }
        /* 认证中 */
        if ($_results_arr['data']['status'] == 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']);
    }

    /**
     * PI值上报
     *
     * @return array
     */
    public function reportPi() {
        $_uri = str_replace("realName", "reprotPi", $this->require_url);
        $_uri = $_uri.'/'.$this->channel_code;
        $_headers = ['Content-Type' => 'application/x-www-form-urlencoded'];
        if (!empty($this->headers)) {
            $_headers = array_merge($_headers, $this->headers);
        }
        $_params = array(
            'pi'        => $this->pi,
            'uid'       => $this->mg_mem_id,
            'gameId'    => $this->app_id,
            'timestamp' => date('Y-m-d H:i:s'),
        );
        $_str = $this->channel_code.$this->app_id.$this->mg_mem_id.$this->pi.$_params['timestamp'];
        $_params['sign'] = md5($_str);
        $_results = $this->doRequest($_params, $_uri, $_headers);
        $_results_arr = json_decode($_results, true);
        if (empty($_results_arr) || !isset($_results_arr['code']) || ('1' != $_results_arr['code']
                                                                      && '1001' != $_results_arr['code'])) {
            $_result = [$_results, $_results_arr, $this->real_name, $this->id_card];
            $_step = 0;
            $_other = '绝峰防沉迷实名认证API，认证异常reprotPi';
            \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']);
        }
        /* 1001是用户不存在，默认为认证中 */
        if ('1001' == $_results_arr['code']) {
            $_code = CommonStatus::MEM_IDENTIFY_IN_PROGRESS;

            return $this->huoSuccess($_code, CommonStatus::getMsg($_code));
        }
        /**
         * 认证成功需要添加记录
         */
        $_ipl_model = new IdentifyPlatformLogModel();
        $_ipl_info = $_ipl_model->getInfoByMgFrom($this->mg_mem_id, IdentifyConst::DRIVER_KEY_JUEFENG);
        $_log_data = [
            'mem_id'        => $this->mem_id,
            'mg_mem_id'     => $this->mg_mem_id,
            'app_id'        => $this->app_id,
            'identify_from' => IdentifyConst::DRIVER_KEY_JUEFENG,
            'real_name'     => $this->real_name,
            'id_card'       => $this->id_card,
            'identify_pi'   => $this->pi,
            'status'        => self::STATUS_SUCCESS,
        ];
        if (empty($_ipl_info)) {
            $_ipl_model->addData($_log_data);
        } else {
            $_ipl_model->updateData($_log_data, $_ipl_info['id']);
        }
        $_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_JUEFENG);

        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']) {
            $_code = CommonStatus::NO_ERROR;

            return $this->huoSuccess($_code, CommonStatus::getMsg($_code));
        }
        $_identify_pi = isset($_identify_rs['data']['pi']) ? $_identify_rs['data']['pi'] : '';
        $_im_model = new IdentifyMemModel();
        $_old_id_data = $_im_model->getInfoByMemId($this->mem_id);
        if (empty($_old_id_data)) {
            $_data = [
                'identify_from' => IdentifyConst::DRIVER_KEY_JUEFENG,
                '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
     *
     * @return string
     */
    public function check() {
        $_uri = str_replace("reprotPi", "realName", $this->require_url);
        $_uri = $_uri.'/'.$this->channel_code;
        $_headers = ['Content-Type' => 'application/x-www-form-urlencoded'];
        if (!empty($this->headers)) {
            $_headers = array_merge($_headers, $this->headers);
        }
        $_params = array(
            'cardId'    => $this->id_card,
            'realName'  => base64_encode($this->real_name),
            'uid'       => $this->mg_mem_id,
            'gameId'    => $this->app_id,
            'timestamp' => date('Y-m-d H:i:s'),
        );
        $_str = $this->channel_code.$this->app_id.$this->mg_mem_id.$this->real_name.$this->id_card
                .$_params['timestamp'];
        $_params['sign'] = md5($_str);

        return $this->doRequest($_params, $_uri, $_headers);
    }

    /**
     * do request
     *
     * @param        $params
     * @param string $url
     * @param array  $headers
     *
     * @return mixed
     */
    private function doRequest($params, $url, $headers = []) {
        $_rs = Http::post($url, $params, ['header' => $headers, 'timeout' => $this->timeout]);

        return $_rs;
    }
}