xyzshop/test/TestMemberCard.php

<?php declare(strict_types=0);

use PHPUnit\Framework\TestCase;

/**
 * Created by PhpStorm.
 * User: stanley-king
 * Date: 16/6/27
 * Time: 下午10:27
 */
define('APP_ID', 'test');
define('BASE_ROOT_PATH', str_replace('/test', '', dirname(__FILE__)));

require_once(BASE_ROOT_PATH . '/global.php');
require_once(BASE_CORE_PATH . '/lrlz.php');
require_once(BASE_ROOT_PATH . '/fooder.php');

require_once(BASE_HELPER_PATH . '/mcard/mcard.php');
require_once(BASE_HELPER_PATH . '/mtopcard/mtopcard.php');
require_once(BASE_HELPER_PATH . '/util_helper.php');
require_once(BASE_HELPER_PATH . '/order_helper.php');
require_once(BASE_HELPER_PATH . '/bonus_helper.php');
require_once(BASE_HELPER_PATH . '/vrorder_helper.php');

class TestMemberCard extends TestCase
{
    private $member_id = 36490;

    public static function setUpBeforeClass(): void
    {
        Base::run_util();
    }

    public function testAddCardno()
    {
        $vr_order = Model();

        $count = 1000;
        $i = 0;
        while (true)
        {
            $start = $i * $count;
            $items = $vr_order->table('vr_order')->field('*')->order('order_id asc')->limit("{$start},{$count}")->select();
            if(empty($items)) {
                break;
            }
            $i++;

            foreach ($items as $item)
            {
                try {
                    if(empty($item['extra_info'])) {
                        continue;
                    }

                    $extra_info = json_decode($item['extra_info'],true);
                    if(empty($extra_info)) {
                        continue;
                    }
                    $card_no   = $extra_info['input']['card_no'];
                    $card_type = mtopcard\topcard_type($extra_info['input']['card_type']);

                    Log::record("{$card_no} {$card_type}",Log::DEBUG);
                    if(empty($card_no)) continue;

                    $vr_order->table('vr_order')->where(['order_id' => $item['order_id']])->update(['card_no' => $card_no]);
                }
                catch (Exception $ex) {
                    Log::record($ex->getMessage(),Log::DEBUG);
                }
            }
        }
    }

    public function testLoadTopcards()
    {
        global $config;
        $spec_card = $config['vgoods_spec_card'];

        $vr_order = Model();
        $topcard = Model('topcard');
        $member_topcard = Model('member_topcard');

        $count = 1000;
        $i = 0;

        $index = 0;
        while (true)
        {
            $start = $i * $count;
            $items = $vr_order->table('vr_order')->field('*')->order('order_id asc')->limit("{$start},{$count}")->select();
            if(empty($items)) {
                break;
            }
            $i++;

            foreach ($items as $item)
            {
                try {
                    $member_id = intval($item['buyer_id']);
                    $add_time  = intval($item['add_time']);
                    $payment_time  = intval($item['payment_time']);
                    $goods_id  = intval($item['goods_id']);
                    $amount = $spec_card[$goods_id];
                    $order_state = intval($item['order_state']);

                    if(empty($item['extra_info'])) {
                        $index++;
                        continue;
                    }

                    $extra_info = json_decode($item['extra_info'],true);
                    if(empty($extra_info)) {
                        $index++;
                        continue;
                    }
                    $card_no   = $extra_info['input']['card_no'];
                    $card_type = mtopcard\topcard_type($extra_info['input']['card_type']);

                    Log::record("{$index} {$card_no} {$card_type}",Log::DEBUG);
                    $index++;

                    if(empty($card_no)) continue;

                    if(empty($topcard->get_card($card_no))) {
                        $topcard->add($card_no,$card_type,$add_time);
                    }

                    if(in_array($order_state,[ORDER_STATE_PAY, ORDER_STATE_SEND, ORDER_STATE_SUCCESS]) && $amount > 0)
                    {
                        $ret = $topcard->add_money($card_no,$amount,$payment_time);
                        if(!$ret) {
                            Log::record("{$card_no} add money fail.",Log::DEBUG);
                        }
                    }
                }
                catch (Exception $ex) {
                    Log::record($ex->getMessage(),Log::DEBUG);
                }
            }
        }
    }

    public function testDate()
    {
        $now = time();
        $nine = strtotime(date('Y-m-d',$now)) + 9*3600;
        $twenty_first = strtotime(date('Y-m-d',$now)) + 21*3600;

        if($now > $nine || $now < $twenty_first) {
            $x = 0;
        }
    }

    public function testTime()
    {
        $this->month_range(time());
        $x = strtotime(date('Y-m-d',time()));
        $y = strtotime('+1 day',$x);

        $x1 = date('Y-m-01',strtotime(date('Y-m-d')));
        $x2 = date('Y-m-t',strtotime(date('Y-m-d')));
        $x3 = date('Y-m-01',strtotime('-1 month'));
        $x4 = date('Y-m-t',strtotime('-1 month'));

    }

    private function month_range($time)
    {
        $x = strtotime(date('Y-m-d',$time));
        $x = strtotime(date('Y-m-01',$x));
        $y = strtotime('+1 month',$x);

        return [$x,$y];
    }

    public function testGetOils()
    {
        $ret = mcard\getTopcardInfo('oil',36490);
    }

    public function testAddMemberYearCard()
    {
        $finder = function () {
            $mid_amounts = [];
            $path = BASE_DATA_PATH . "/cards/memcard.txt";
            $file = fopen($path,'r');
            if(!is_resource($file)) {
                Log::record(__METHOD__ . " {$path} file is not exist",Log::ERR);
                return $mid_amounts;
            }

            while(!feof($file)) {
                $line = fgets($file);
                $kv = preg_split('/,/',$line);
                if(count($kv) != 2) continue;
                $mid_amounts[] = ['mid' => intval($kv[0]),'amount' => intval($kv[1])];
            }
            fclose($file);

            return $mid_amounts;
        };

        $mids = $finder();
        foreach ($mids as $val)
        {
            $usercards = new mcard\user_mcards($val['mid']);
            $params = mcard\getConfig('year',$val['amount']);
            $ret = $usercards->addCard($params);
            if($ret) {
                Log::record("{$val['mid']} : {$val['amount']} success.",Log::DEBUG);
            } else {
                Log::record("{$val['mid']} : {$val['amount']} fail.",Log::ERR);
            }
        }
    }

    public function testAddMemberCard4Hg()
    {
        $mids = [62704,52836];
        foreach ($mids as $mid) {
            $usercards = new mcard\user_mcards($mid);
            $usercards->addCard(['card_type' => mcard\BothType, 'total_amount' => 100000, 'discount' => 0.05, 'package_type' => 'year']);
        }
    }
    public function testAddMemberCardForinvite()
    {
        $mids = [59820];
        foreach ($mids as $mid) {
            $usercards = new mcard\user_mcards($mid);
            $usercards->addCard(['card_type' => mcard\BothType, 'total_amount' => 10000, 'discount' => 0.05, 'package_type' => 'year']);
        }
    }

    //docker-compose run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestMemberCard::testAddMemberCard)( .*)?$/" --test-suffix TestMemberCard.php /var/www/html/test


    public function testDeduct()
    {
        $usercards = new mcard\user_mcards(36490);

        $amounts = [3000, 5000, 200, 100, 200, 2000, 1000];
        foreach ($amounts as $amount) {
            if ($usercards->enough($amount)) {
                $usercards->deduct($amount);
                Log::record("Consume {$amount}.");

            } else {
                Log::record("Not enough money {$amount}.");
            }
        }
    }

    public function testAddTopCard()
    {
        $cards = new mtopcard\user_topcards($this->member_id);
        $cards->addCard('1000111100020445281', mtopcard\PetroChinaCard);

        $cards->addMoney(0, 1000);
        $cards->addMoney(0, 1000);
        $cards->addMoney(0, 1000);
        $ret = $cards->cards_format();
    }

    public function testAddCardKeys()
    {
        $params = [
            ['card_type' => mtopcard\OilCardPaper, 'amount' => 100],
            ['card_type' => mtopcard\OilCardPaper, 'amount' => 200],
            ['card_type' => mtopcard\OilCardPaper, 'amount' => 500],
            ['card_type' => mtopcard\OilCardPaper, 'amount' => 1000],
            ['card_type' => mtopcard\PhoneCardPaper, 'amount' => 100],
        ];

        $car_no = '1900000000000000';
        $count = 10;
        $mod_card = Model('card_key');
        foreach ($params as $item)
        {
            for($i= 0; $i < $count; $i++) {
                $mod_card->addCard(['card_no' => $car_no,'card_key' => 'm8i094k4t8n8','card_type' => $item['card_type'],'amount' => $item['amount']]);
                $car_no += 1;
            }
        }
    }

    public function testAddCardKeysLocal()
    {
        $params = [
            ['card_type' => mtopcard\OilCardPaper, 'amount' => 100],
            ['card_type' => mtopcard\OilCardPaper, 'amount' => 200],
            ['card_type' => mtopcard\PhoneCardPaper, 'amount' => 100],
            ['card_type' => mtopcard\PhoneCardPaper, 'amount' => 200]
        ];

        $car_no = '1900000000000000';
        $count = 10;
        $mod_card = Model('card_key');
        foreach ($params as $item)
        {
            for($i= 0; $i < $count; $i++) {
                $mod_card->addCard(['card_no' => $car_no,'card_key' => 'm8i094k4t8n8','card_type' => $item['card_type'],'amount' => $item['amount']]);
                $car_no += 1;
            }
        }
    }

    public function testReserve()
    {
        $amount = 1000;
        [$ret,$info] = mtopcard\cards_helper::reserve(mtopcard\OilCardPaper,1000,35268,'xxxyyyzzzkkkdj',mtopcard\PetroChinaCard);
        mtopcard\cards_helper::assign(1,'xiongmao');
        [$ret,$info] = mtopcard\cards_helper::reserve(mtopcard\OilCardPaper,1000,35268,'xxxyyyzzzkkkdj',mtopcard\PetroChinaCard);
        mtopcard\cards_helper::reuse(4);
    }

    public function testOnVrOrderSuccess()
    {
        $logic = Logic('queue');
        $logic->OnVrOrderSuccess(['order_sn' => '920648515867397620']);
    }
    public function testOnVrOrderCancel()
    {
        $logic = Logic('queue');
        $logic->OnVrOrderCancel(['order_sn' => '510649439049587625']);
    }

    public function testVOrderPaidSuccess()
    {
        $logic = Logic('queue');
        $logic->OnVrOrderPaidSuccess(['order_sn' => '530649437595131625']);
    }

    //测试购买会员,成功支付,改变用户会员属性,修改状态.
    public function testPaidVOrderSuccess()
    {
        $order_sn = '530649437595131625';
        $trade_no = '730510765598547599';

        $payer = new pay_helper($order_sn);
        $payer->update_order($trade_no,'wxpay');
    }

    public function testOnVrOrderComplete()
    {
        $order_sn = '260649436354923625';
        $logic = Logic('queue');
        $logic->OnVrOrderComplete(['order_sn' => $order_sn]);
    }
    //测试购买会员
    public function testMcardOrderSucess()
    {
        $logic = Logic('queue');
        $logic->OnMCardPaidSuccess(['order_sn' => '580648112029501620']);
    }

    public function testExtraInfo()
    {
        $order_sn = '920648515867397620';
        $model_order = Model('vr_order');
        $order = $model_order->getOrderInfo(['order_sn' => $order_sn]);
        vrorder_helper::extend_order_info($order);
    }

    public function testAnalyseBuyer()
    {
        $inputer = function () {
            $path = BASE_DATA_PATH . "/cards/userids.txt";
            $file = fopen($path,'r');
            if(!is_resource($file)) {
                Log::record(__METHOD__ . " {$path} file is not exist",Log::ERR);
                return [];
            }

            $mids = [];
            while(!feof($file)) {
                $line = fgets($file);
                $line = str_replace("\r\n", '',$line);
                $kv = preg_split('/,/',$line);

                if(count($kv) != 3) continue;
                $mids[] = ['mid' => intval($kv[0]),'start_time' => strtotime($kv[1]),'end_time' => strtotime($kv[2])];
            }
            fclose($file);

            return $mids;
        };

        $mids = $inputer();

        $result = [];
        foreach ($mids as $val) {
            $uid = intval($val['mid']);
            if (!array_key_exists($uid, $result)) {
                $result[$uid] = [1 => 0.0, 2 => 0.0, 3 => 0.0, 4 => 0.0, 5 => 0.0];
            }

            $condition['buyer_id'] = $val['mid'];
            $condition['add_time'] = ['between', [$val['start_time'], $val['end_time']]];
            $condition['order_state'] = ORDER_STATE_SUCCESS;

            $vr_order = Model('vr_order');
            $orders = $vr_order->getOrderList($condition);

            foreach ($orders as $order) {
                [$card_type, $amount] = $this->calc_order($order);
                if ($card_type > 0) {
                    $result[$uid][$card_type] += $amount;
                }
            }
        }
        $str = $this->format($result);
        file_put_contents(BASE_DATA_PATH .'/cards/useramounts.txt',$str);
    }

    private function format($data){
        $typeArr = ['中石油','中石化','中国联通','中国电信','中国移动'];
        $str = '';
        foreach ($data as $key => $val){
            $str .= "用户ID ： {$key},充值统计：";
            foreach ($val as $k => $v){
                if($v == 0){
                    continue;
                }else{
                    $str .= "{$typeArr[$k-1]} : {$v}元,";
                }
            }
            $str = rtrim($str , ',');
            $str .= "\r\n";
        }
        return $str;
    }

    private function carrier_type($phone)
    {
        $checker = function ($phone) {
            if (empty($phone)) return false;  //手机号不能为空
            $url = "https://tcc.taobao.com/cc/json/mobile_tel_segment.htm?tel={$phone}";
            $resp = file_get_contents($url);  //获取API返回 的数据
            $resp = mb_convert_encoding($resp, 'UTF-8', 'UTF-8,GBK,GB2312,BIG5'); //解决中文乱码

            $datas = explode('=', $resp);
            if(count($datas) == 2)
            {
                $body = trim($datas[1]);
                if(preg_match_all("/(\w+):'([^']+)/", $body, $m)) {
                    $res = array_combine($m[1], $m[2]);
                    return $res;
                }
            }

            return false;
        };


        $ret = $checker($phone);
        if(empty($ret)) {
            return mtopcard\UnknownCard;
        }
        elseif($ret['catName'] == '中国联通') {
            return mtopcard\ChinaUnicomCard;
        }
        elseif($ret['catName'] == '中国电信') {
            return mtopcard\ChinaTelecomCard;
        }
        elseif($ret['catName'] == '中国移动') {
            return mtopcard\ChinaMobileCard;
        }
        else {
            return mtopcard\UnknownCard;
        }
    }

    public function testPhoneZone()
    {
        $x = $this->carrier_type('13911129867');
        $x = $this->carrier_type('13886396292');
    }
    public function testCheckMobileChannel(){
        $mobile = 17801048874;
        return $this->check_mobile_channel($mobile);
    }


    private function check_mobile_channel($mobile){
        if(strlen($mobile) !== 11){
            return false;
        }
        $isChinaMobile  = "/^134[0-8]\d{7}$|^(?:13[5-9]|147|15[0-27-9]|17[28]|18[2-478]19[578])\d{8}$/";
        $isChinaUnicom  = "/^(?:13[0-2]|145|15[56]|166|17[156]|18[56]|196)\d{8}$/";
        $isChinaTelecom = "/^(?:133|149|153|177|173|18[019]|19[0139])\d{8}$/";
        if(preg_match($isChinaMobile, $mobile)){
            return 3;
        }elseif(preg_match($isChinaUnicom, $mobile)){
            return 1;
        }elseif(preg_match($isChinaTelecom, $mobile)){
            return 2;
        }else{
            return 0;
        }
    }

    /**
     * @param $order
     * @param $spec_card
     * @param $result
     */
    private function calc_order($order)
    {
        global $config;
        $spec_card = $config['vgoods_spec_card'];


        $goods_id = intval($order['goods_id']);
        $spec_amount = $spec_card[$goods_id];
        $extra_info = json_decode($order['extra_info'], true);

        $card_no = $extra_info['input']['card_no'];
        $card_type = mtopcard\topcard_type($extra_info['input']['card_type']);

        if ($card_type == 1 || $card_type == 2) {
            return [$card_type,$spec_card[$goods_id] * $order['goods_num']];
        }
        elseif ($card_type == 3)
        {
            $carrier_type = $this->carrier_type($card_no);
            if ($carrier_type > 0) {
                $card_type = $card_type + $carrier_type - 1;
                return [$card_type,$spec_amount * $order['goods_num']];

            } else {
                Log::record("order {$order} 无法检查手机号码：{$card_no} 类型", Log::ERR);
            }
        } else {
            Log::record("order {$order} 卡类型无效.", Log::ERR);
        }

        return [0,0];
    }
}

//docker-compose -f ./docker-compose-dev.yum run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestMemberCard::testAddMemberYearCard)( .*)?$/" --test-suffix TestMemberCard.php /var/www/html/test
//docker-compose run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestMemberCard::testAddMemberYearCard)( .*)?$/" --test-suffix TestMemberCard.php /var/www/html/test