goods(); return self::outsuccess($result); } private function check_params($params) { if(empty($params['cardno'])) { return [false,'参数没有包含cardno']; } if(empty($params['amount'])) { return [false,'参数没有包含充值金额:amount']; } $card_no = $_GET['cardno']; $card_type = mtopcard\card_type($card_no); if($card_type == mtopcard\UnknownCard) { return [false,"充值卡不是电话和中石油中石化类型."]; } if($card_type === mtopcard\PetroChinaCard) { if(empty($params['idcard'])) { return [false,'中石油需要参数没有包含身份证号码:idcard']; } if(empty($params['card_name'])) { return [false,'参数没有包含身份证姓名:card_name']; } } if(empty($params['notifyurl'])) { return [false,'参数没有包含notifyurl']; } if(empty($params['order_sn'])) { return [false,'参数没有包含贵方唯一订单号:order_sn']; } $card_type = mtopcard\card_type($card_no); if($card_type === mtopcard\UnknownCard) { return [false,'卡类型无法识别']; } return [true,""]; } public function addOp() { [$success,$error] = $this->check_params($_GET); if($success === false) { return self::outerr(201,$error); } $amount = intval($_GET['amount']); $card_no = $_GET['cardno']; $notify_url = $_GET['notifyurl']; $mch_order = $_GET['order_sn']; //对方的order $card_type = mtopcard\card_type($card_no); $providers = refill\RefillFactory::instance()->find_providers($amount,$card_type); if(empty($providers)) { return self::outerr(202,"找不到合适的充值通道"); } $buyer_id = $this->adminid(); $minfo = new member_info($buyer_id); $calc = new refill\CalcMerchantPrice($this->mchid(),$amount,$card_type); $mch_amount = $calc->calc_vgoods_price([]); if($mch_amount > $minfo->available_predeposit()) { return self::outerr(203,"余额不足"); } $refill_state = false; foreach ($providers as $provider) { $channel_name = $provider->name(); [$goods_id, $price] = $provider->goods($amount); $input['goods_id'] = $goods_id; $input['quantity'] = 1; $input['price'] = $price; $input['buyer_phone'] = $minfo->mobile(); $input['buyer_name'] = $minfo->truename(); $input['buyer_msg'] = $_POST['buyer_msg'] ?? ''; $input['order_from'] = 1; $input['pd_pay'] = true; $logic_buy_virtual = Logic('buy_virtual'); $result = $logic_buy_virtual->buyStep3($input, $buyer_id,[$calc,'calc_vorder_amount'],true); $mod_refill = Model('refill_order'); if($result['state'] === true) { $order_sn = $result['data']['order_sn']; $order_id = $result['data']['order_id']; //虚拟订单表信息扩展 $orderext = ['order_id' => $order_id,'order_sn' => $order_sn,'mchid' => $this->mchid(), 'refill_amount' => $amount,'mch_order' => $mch_order, 'notify_url' => $notify_url,'channel_name' => $channel_name, 'mch_amount' => $mch_amount,'channel_amount' => $price,'order_time' => time(), 'card_type' => $card_type,'card_no' => $card_no]; $mod_refill->add_refill($orderext); } else { continue; } $params = ['order_sn' => $order_sn]; [$state,$err] = $provider->add($card_no,$card_type,$amount,$params); if($state) { $trade_no = $err; $logic_vr_order = Logic("vr_order"); $logic_vr_order->changeOrderStateSend($order_id); $data = ['commit_time' => time(),'ch_trade_no' => $trade_no]; $mod_refill->edit($order_id,$data); $refill_state = true; break; } else { Log::record("channel:{$channel_name} err:{$err}"); $logic_vr_order = Logic("vr_order"); $order_info = Model('vr_order')->getOrderInfo(['order_id' => $order_id]); $logic_vr_order->changeOrderStateCancel($order_info,'',"调用{$channel_name}接口失败"); } } if($refill_state) { return self::outsuccess(['state' => true,'trade_no' => $order_sn]); } else { return self::outerr(204,"充值失败."); } } public function query_tradeOp() { $mchid = $this->mchid(); $trade_no = $_GET['trade_no']; if(empty($trade_no)) { return self::outerr(201,"交易号trade_no错误"); } $mod_refill = Model('refill_order'); $refill_info = $mod_refill->getOrderInfo(['order_sn' => $trade_no,'mchid' => $mchid]); $vr_order = Model('vr_order'); $order_info = $vr_order->getOrderInfo(['order_sn' => $trade_no]); if(empty($refill_info) || empty($order_info)) { return self::outerr(201,"无此交易号"); } $result = $this->format($order_info,$refill_info); return self::outsuccess($result); } private function format($order_info,$refill_info) { $result = []; $result['mchid'] = $refill_info['mchid']; $result['trade_no'] = $refill_info['order_sn']; $result['order_sn'] = $refill_info['mch_order']; $result['card_no'] = $refill_info['card_no']; $result['card_type'] = $refill_info['card_type']; $result['refill_amount'] = $refill_info['refill_amount']; $result['order_amount'] = $refill_info['mch_amount']; $result['order_time'] = $refill_info['order_time']; $result['success_time'] = $refill_info['notify_time']; $result['order_state'] = $order_info['order_state']; return $result; } public function queryOp() { $mchid = $this->mchid(); $order_sn = $_GET['order_sn']; //用户方的订单号,对应数据库中的mch_order if(empty($order_sn)) { return self::outerr(201,"交易号trade_no错误"); } $mod_refill = Model('refill_order'); $refill_info = $mod_refill->getOrderInfo(['mch_order' => $order_sn,'mchid' => $mchid]); if(empty($refill_info)) { return self::outerr(201,"无此订单"); } $vr_order = Model('vr_order'); $order_info = $vr_order->getOrderInfo(['order_sn' => $refill_info['order_sn']]); if(empty($order_info)) { return self::outerr(201,"无此交易号"); } if($order_info['order_state'] == ORDER_STATE_SEND) { //发起订单查询请求 } $result = $this->format($order_info,$refill_info); return self::outsuccess($result); } }