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