xyzshop/helper/mtopcard/card_query.php

<?php

namespace mtopcard;

use Log;

class card_query
{
    private function validate_checker($status)
    {
        // "status": 1 //状态 0:空号；1:实号；2:停机；3:库无；4:沉默号；5:风险号 6: 未知 7: 流量卡
        Log::record("status={$status}",Log::DEBUG);
        if (in_array($status, [0, 5, 7])) {
            return false;
        } else {
            return true;
        }
    }

    //[success,$card_type,$region_no,$isTransfer,$status]
    private function tencent_query($card_no)
    {
        $type_checker = function ($channel)
        {
            if($channel == 'CMCC') {
                return ChinaMobileCard;
            }
            elseif($channel == 'CTCC') {
                return ChinaTelecomCard;
            }
            elseif($channel == 'CUCC') {
                return ChinaUnicomCard;
            }
            else {
                return UnknownCard;
            }
        };

        // "status": 1 //状态 0:空号；1:实号；2:停机；3:库无；4:沉默号；5:风险号
        $status_converter = function ($code)
        {
            if($code === 1) {
                return 1;
            } elseif($code === 2) {
                return 0;
            } elseif ($code === 3) {
                return 2;
            } elseif ($code === 4) {
                return 7;
            } elseif($code === 5) {
                return 4;
            } else {
                return 6;
            }
        };

        $regin_checker = function ($province)
        {
            if(empty($province)) return -1;
            $endtxts= ["省","市","自治区","特别行政区"];

            foreach ($endtxts as $endtxt)
            {
                if(strpos($province, $endtxt) === false) {
                    continue;
                } else {
                    $province = mb_strcut($province, 0, strrpos($province, $endtxt));
                }
            }

            if(array_key_exists($province,Prov2Noes)) {
                return Prov2Noes[$province];
            } else {
                return -1;
            }
        };

        $query_fun = function ($card_no, &$card_type, &$region_no, &$status) use ($type_checker, $regin_checker, $status_converter)
        {
            $secretId = 'AKIDkd6sT6C4765LtYN1W2fN2WC2Ynr42acemjQW';
            $secretKey = 'dupQeU838dhuQ8uDP2bi81nQNb5wt9KW1qLP7eWu';
            $source = 'market';

            // 签名
            $datetime = gmdate('D, d M Y H:i:s T');
            $signStr = sprintf("x-date: %s\nx-source: %s", $datetime, $source);
            $sign = base64_encode(hash_hmac('sha1', $signStr, $secretKey, true));
            $auth = sprintf('hmac id="%s", algorithm="hmac-sha1", headers="x-date x-source", signature="%s"', $secretId, $sign);
            $header = [
                "X-Source: {$source}",
                "X-Date: {$datetime}",
                "Authorization: {$auth}",
            ];
            $data['number'] = $card_no;
            $url = 'https://service-empgc6lp-1256724964.sh.apigw.tencentcs.com/release/query';
            $net_err = 0;
            $resp = http_request($url, $data, 'GET',false, $header,$net_err);

            if ($resp == false) return false;

            $resp = json_decode($resp, true);
            if ($resp == false) return false;

            if ($resp['ret'] == 200)
            {
                $data = $resp['data'];
                $code = intval($data['code']);
                $extend = $data['extend'];

                $status = $status_converter($code);
                $card_type = $type_checker($extend['isp']);
                $region_no = $regin_checker($extend['prov']);
                return true;
            } else {
                Log::record("tencent_valid phone:{$card_no}", Log::DEBUG);
                return false;
            }
        };

        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////
        $org_type = card_type($card_no,$region_no);
        $region_no = -1;
        $status = 6;

        //[succ,$card_type,$region_no,$isTransfer,$status]
        $ret = $query_fun($card_no, $card_type, $region_no, $status);
        if ($ret) {
            $isTransfer = $org_type != $card_type;
            return [true, $card_type, $region_no, $isTransfer, $status];
        }
        else {
            return [false, $card_type, -1, false, $status];
        }
    }

    //[succ,$card_type,$region_no,$isTransfer,$status]
    public function tianyan_query($card_no)
    {
        $type_checker = function ($channel)
        {
            if($channel == '联通') {
                return ChinaUnicomCard;
            }
            elseif($channel == '电信') {
                return ChinaTelecomCard;
            }
            elseif($channel == '移动') {
                return ChinaMobileCard;
            }
            else {
                return UnknownCard;
            }
        };

        $regin_checker = function ($area)
        {
            if(empty($area)) return -1;
            $areas = explode('-',$area);
            if(count($areas) > 0)
            {
                $province = $areas[0];
                $endtxts= ["省","市","自治区","特别行政区"];

                foreach ($endtxts as $endtxt)
                {
                    if(strpos($province, $endtxt) === false) {
                        continue;
                    } else {
                        $province = mb_strcut($province, 0, strrpos($province, $endtxt));
                    }
                }

                if(array_key_exists($province,Prov2Noes)) {
                    return Prov2Noes[$province];
                }
            }

            return -1;
        };

        $ali = function ($card_no, &$region_no, &$status) use ($regin_checker): bool
        {
            $url = 'https://mobileempty.shumaidata.com/mobileempty';
            $params['mobile'] = $card_no;
            $headers = ["Authorization:APPCODE " . '8f92d951293f4d2ea48ff86d5a70c537'];

            $net_err = 0;
            $resp = http_request($url, $params, 'GET', false, $headers,$net_err);
            if ($resp == false) return false;

            $resp = json_decode($resp, true);
            if ($resp == false) return false;

            if ($resp['code'] == 200)
            {
                $data = $resp['data'];
                $status = intval($data['status']);
                $region_no = $regin_checker($data['area']);
                return true;
            } else {
                Log::record("ali_valid phone:{$card_no} return msg:{$resp['msg']}", Log::DEBUG);
                return false;
            }
        };

        $tianyan = function ($card_no, &$region_no, &$status) use ($regin_checker): bool
        {
            $url = 'https://api.shumaidata.com/v4/mobile_empty/check';
            $appid = '2Xfa6IFIPv0sVUjy';
            $appSecurity = '2Xfa6IFIPv0sVUjynOddsfh6KXfbyJ84';
            $cur = microtime (true);

            $data['appid'] = $appid;
            $data['timestamp'] = intval($cur * 1000);
            $content = "{$appid}&{$data['timestamp']}&{$appSecurity}";
            $data['sign'] = md5($content);
            $data['mobile'] = $card_no;

            $net_err = 0;
            $resp = http_request($url, $data, 'GET',false, [],$net_err);
            if ($resp == false) return false;

            $resp = json_decode($resp, true);
            if ($resp == false) return false;

            if ($resp['code'] == 200)
            {
                $data = $resp['data'];
                $status = intval($data['status']);
                $region_no = $regin_checker($data['area']);
                return true;
            } else {
                Log::record("tianyan_valid phone:{$card_no} return msg:{$resp['msg']}", Log::DEBUG);
                return false;
            }
        };

        $tianyan_cardtyper = function ($card_no) use ($type_checker)
        {
            $url = 'https://api.shumaidata.com/v4/mobile-transfer/query';
            $appid = '2Xfa6IFIPv0sVUjy';
            $appSecurity = '2Xfa6IFIPv0sVUjynOddsfh6KXfbyJ84';
            $cur = microtime (true);

            $data['appid'] = $appid;
            $data['timestamp'] = intval($cur * 1000);
            $content = "{$appid}&{$data['timestamp']}&{$appSecurity}";
            $data['sign'] = md5($content);
            $data['mobile'] = $card_no;

            $net_err = 0;
            $resp = http_request($url, $data, 'GET',false, [],$net_err);
            if ($resp == false) return [false,UnknownCard,UnknownCard,false];

            $resp = json_decode($resp, true);
            if ($resp == false) return [false,UnknownCard,UnknownCard,false];

            if ($resp['code'] == 200)
            {
                $data = $resp['data'];
                $ispType = $data['ispType'];
                $newIspType = $data['newIspType'];
                Log::record("tianyan_transfer phone:{$card_no} ispType:{$ispType} newIspType:{$newIspType}", Log::DEBUG);

                $card_type = $type_checker($newIspType);
                $org_type = $type_checker($ispType);
                $isTransfer = $org_type != $card_type;

                return [true,$card_type,$org_type,$isTransfer];
            } else {
                Log::record("tianyan_transfer phone:{$card_no} return msg:{$resp['msg']}", Log::DEBUG);
                return [false,UnknownCard,UnknownCard,false];
            }
        };

        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////
        [$succ,$_card_type,$_org_type,$_isTransfer] = $tianyan_cardtyper($card_no);
        if($succ) {
            $card_type = $_card_type;
            $org_type = $_org_type;
            $isTransfer = $_isTransfer;
        }
        else {
            $isTransfer = false;
        }

        $status = 6;
        $ret = $tianyan($card_no, $region_no, $status);
        if ($ret) {
            return [true, $card_type, $region_no, $isTransfer, $status];
        }

        $ret = $ali($card_no, $region_no, $status);
        if ($ret) {
            return [true, $card_type, $region_no, $isTransfer, $status];
        }

        return [false, $card_type, -1, false, $status];
    }


    //[$validate,$card_type,$region_no,$isTransfer,$status,$black]
    public function validate($card_no)
    {
        $time_checker = function ($update_time)
        {
            //90 天以内数据有效
            $delta = time() - intval($update_time);
            return $delta < 360 * 86400 && $delta >= 0;
        };

        $pinfo_getter = function ($card_no) use ($time_checker)
        {
            $mod_card = Model('card_info');
            $info = $mod_card->getCardInfo($card_no);

            if(empty($info)) {
                return [false,[]];
            }
            elseif($time_checker($info['update_time'])) {
                $mod_card->where(['card_no' => $card_no])->update(['using_times' => $info['using_times'] + 1]);

                $card_type = intval($info['card_type']);
                $region_no = intval($info['regin']);
                $isTransfer = !(intval($info['transfer']) == 0);
                $status = intval($info['card_state']);
                $black = intval($info['black']);
                $validate = $this->validate_checker($status);
                $result = [$validate,$card_type,$region_no,$isTransfer,$status,$black];
                return [true,$result];
            }
            else {
                return [false,[]];
            }
        };

        $pinfo_updator = function ($card_no,$card_type,$org_type,$region_no,$isTransfer,$status)
        {
            $mod_card = Model('card_info');
            $transfer = $isTransfer == true ? 1 : 0;
            $mod_card->replace_card($card_no,$card_type,$org_type,$region_no,$transfer,$status);
        };

        $validate = true;
        $black = 0;

        $org_type = card_type($card_no,$region_no);
        $region_no = -1;

        if($org_type === UnknownCard) {
            return [false, $org_type, $region_no, false, 1, $black];
        }

        if($org_type == PetroChinaCard || $org_type == SinopecCard) {
            return [$validate, $org_type, $region_no, false, 1, $black];
        }

        [$succ,$result] = $pinfo_getter($card_no);
        if($succ) return $result;

        [$succ,$card_type,$region_no,$isTransfer,$status] = $this->tencent_query($card_no);
        if($succ === false)
        {
            [$succ,$card_type,$region_no,$isTransfer,$status] = $this->tianyan_query($card_no);
            if($succ === false) {
                return [];
            }
        }

        $validate = $this->validate_checker($status);
        $pinfo_updator($card_no,$card_type,$org_type,$region_no,$isTransfer,$status);

        return [$validate,$card_type,$region_no,$isTransfer,$status,$black];
    }
}