|
@@ -1,379 +0,0 @@
|
|
|
-<?php
|
|
|
-
|
|
|
-class lzrefillControl extends lzbaseControl
|
|
|
-{
|
|
|
- public function __construct()
|
|
|
- {
|
|
|
- parent::__construct();
|
|
|
- }
|
|
|
-
|
|
|
- public function goodsOp()
|
|
|
- {
|
|
|
- $result = refill\RefillFactory::instance()->goods();
|
|
|
- $sorter = function (array $items) {
|
|
|
- $ret = [];
|
|
|
- foreach ($items as $key => $val) {
|
|
|
- sort($val);
|
|
|
- $ret[$key] = $val;
|
|
|
- }
|
|
|
- return $ret;
|
|
|
- };
|
|
|
-
|
|
|
- $result = $sorter($result);
|
|
|
- return self::outsuccess($result);
|
|
|
- }
|
|
|
-
|
|
|
- private function check_params($params)
|
|
|
- {
|
|
|
- if(empty($params['mob'])) {
|
|
|
- return -9;
|
|
|
- }
|
|
|
- if(empty($params['amt'])) {
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- $card_no = $params['mob'];
|
|
|
- if(empty($card_no)) {
|
|
|
- return -11;
|
|
|
- }
|
|
|
-
|
|
|
- if(empty($params['notifyurl'])) {
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- if(empty($params['ord'])) {
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- if(empty($params['tim'])) {
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- $tim = strtotime($params['tim']);
|
|
|
- if($tim === false) {
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- $cur = time();
|
|
|
- $start = strtotime(date('Y-m-d',$cur - 1800));
|
|
|
- if($tim < $start || $tim > $cur + 1800) {
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- return true;
|
|
|
- }
|
|
|
-
|
|
|
- public function add_mobOp()
|
|
|
- {
|
|
|
- $code = $this->check_params($_GET);
|
|
|
- if($code !== true) {
|
|
|
- return self::outerr($code,$this->merchant_available);
|
|
|
- }
|
|
|
-
|
|
|
- $amount = intval($_GET['amt']);
|
|
|
- $card_no = $_GET['mob'];
|
|
|
- $notify_url = $_GET['notifyurl'];
|
|
|
- $mch_order = $_GET['ord']; //对方的order编号
|
|
|
- $quality = $_GET['quality'] ?? 0;
|
|
|
-
|
|
|
- //此处判断是对的
|
|
|
- if($amount > $this->member_available) {
|
|
|
- return self::outerr(4,$this->merchant_available);
|
|
|
- }
|
|
|
-
|
|
|
- if(!$this->check_mchorder($this->mchid(),$mch_order)) {
|
|
|
- return self::outerr(11,$this->merchant_available);
|
|
|
- }
|
|
|
-
|
|
|
-// if(!$this->can_refill($card_no)) {
|
|
|
-// return self::outerr(10,$this->merchant_available);
|
|
|
-// }
|
|
|
-
|
|
|
- $params = [ 'mchid' => $this->mchid(),
|
|
|
- 'buyer_id' => $this->adminid(),
|
|
|
- 'amount' => $amount,
|
|
|
- 'card_no' => $card_no,
|
|
|
- 'mch_order' => $mch_order,
|
|
|
- 'notify_url' => $notify_url,
|
|
|
- 'org_quality' => $quality
|
|
|
- ];
|
|
|
- refill\util::push_queue_order($this->mchid(), $mch_order, ORDER_STATE_QUEUE);
|
|
|
- Model('refill_order')->add_detail($this->mchid(),$mch_order,$params,ORDER_STATE_QUEUE);
|
|
|
-
|
|
|
- $ret = refill\util::push_add($params);
|
|
|
- if ($ret) {
|
|
|
- return self::outsuccess($this->merchant_available);
|
|
|
- } else {
|
|
|
- refill\util::del_queue_order($this->mchid(),$mch_order);
|
|
|
- Model('refill_order')->del_detail($this->mchid(),$mch_order);
|
|
|
-
|
|
|
- return self::outerr(-6, $this->merchant_available);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private function check_third($params)
|
|
|
- {
|
|
|
- if(empty($params['product_code'])) {
|
|
|
- Log::record("check_third product_code",Log::ERR);
|
|
|
- return -9;
|
|
|
- }
|
|
|
- $pcode = $params['product_code'];
|
|
|
- if($this->check_pcode($pcode) == false) {
|
|
|
- Log::record("check_third check_pcode",Log::ERR);
|
|
|
- return -10;
|
|
|
- }
|
|
|
-
|
|
|
- if(empty($params['quantity']) || intval($params['quantity']) < 1) {
|
|
|
- Log::record("check_third quantity",Log::ERR);
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- $card_no = $params['mob'];
|
|
|
- if(empty($card_no)) {
|
|
|
- Log::record("check_third mob",Log::ERR);
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- $third_card_type = $params['card_type'];
|
|
|
- if(empty($third_card_type)) {
|
|
|
- Log::record("check_third card_type",Log::ERR);
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- if(empty($params['notifyurl'])) {
|
|
|
- Log::record("check_third notifyurl",Log::ERR);
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- if(empty($params['ord'])) {
|
|
|
- Log::record("check_third ord",Log::ERR);
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- if(empty($params['tim'])) {
|
|
|
- Log::record("check_third tim",Log::ERR);
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- $tim = strtotime($params['tim']);
|
|
|
- if($tim === false) {
|
|
|
- Log::record("check_third strtotime tim",Log::ERR);
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- $cur = time();
|
|
|
- $start = strtotime(date('Y-m-d',$cur - 1800));
|
|
|
- if($tim < $start || $tim > $cur + 1800) {
|
|
|
- Log::record("check_third check tim",Log::ERR);
|
|
|
- return -9;
|
|
|
- }
|
|
|
-
|
|
|
- return true;
|
|
|
- }
|
|
|
-
|
|
|
- private function check_pcode($pcode)
|
|
|
- {
|
|
|
- $mod_third = Model('thrid_refill');
|
|
|
- $product = $mod_third->getProduct(['system_code' => $pcode]);
|
|
|
- return !empty($product);
|
|
|
- }
|
|
|
-
|
|
|
- public function add_thirdOp()
|
|
|
- {
|
|
|
- $code = $this->check_third($_GET);
|
|
|
- if($code !== true) {
|
|
|
- return self::outerr($code,$this->merchant_available);
|
|
|
- }
|
|
|
-
|
|
|
- $amount = refill\util::ThirdRefillAmount;
|
|
|
- $mch_order = $_GET['ord'];
|
|
|
- $notify_url = $_GET['notifyurl'];
|
|
|
-
|
|
|
- //三方充值没有质量
|
|
|
- $quality = 1;
|
|
|
- $card_type = mtopcard\ThirdRefillCard;
|
|
|
-
|
|
|
- $product_code = $_GET['product_code'];
|
|
|
- $card_no = $_GET['mob'];
|
|
|
- $quantity = $_GET['quantity'];
|
|
|
- $third_card_type = $_GET['card_type'];
|
|
|
-
|
|
|
- //此处判断是对的
|
|
|
- if($this->member_available <= 0) {
|
|
|
- return self::outerr(4,$this->merchant_available);
|
|
|
- }
|
|
|
-
|
|
|
- if(!$this->check_mchorder($this->mchid(),$mch_order)) {
|
|
|
- return self::outerr(11,$this->merchant_available);
|
|
|
- }
|
|
|
-
|
|
|
- $params = [ 'mchid' => $this->mchid(),
|
|
|
- 'buyer_id' => $this->adminid(),
|
|
|
- 'amount' => $amount,
|
|
|
- 'mch_order' => $mch_order,
|
|
|
- 'notify_url' => $notify_url,
|
|
|
- 'org_quality' => $quality,
|
|
|
- 'card_type' => $card_type,
|
|
|
- 'card_no' => $card_no,
|
|
|
- 'product_code' => $product_code,
|
|
|
- 'quantity' => $quantity,
|
|
|
- 'third_card_type' => $third_card_type
|
|
|
- ];
|
|
|
-
|
|
|
- refill\util::push_queue_order($this->mchid(), $mch_order, ORDER_STATE_QUEUE);
|
|
|
- Model('refill_order')->add_detail($this->mchid(),$mch_order,$params,ORDER_STATE_QUEUE);
|
|
|
- $ret = refill\util::push_addthird($params);
|
|
|
- if($ret) {
|
|
|
- return self::outsuccess($this->merchant_available);
|
|
|
- }
|
|
|
- else {
|
|
|
- refill\util::del_queue_order($this->mchid(),$mch_order);
|
|
|
- Model('refill_order')->del_detail($this->mchid(),$mch_order);
|
|
|
-
|
|
|
- return self::outerr(-6,$this->merchant_available);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private function can_refill($cardno)
|
|
|
- {
|
|
|
- $card_info = refill\util::read_card($cardno);
|
|
|
- if(empty($card_info)) return false;
|
|
|
-
|
|
|
- return intval($card_info['black_card']) === 0;
|
|
|
- }
|
|
|
-
|
|
|
- private function check_mchorder($mchid,$mch_order)
|
|
|
- {
|
|
|
- if (empty($mch_order)) {
|
|
|
- return false;
|
|
|
- } else {
|
|
|
- $refill_order = Model('refill_order');
|
|
|
- $ret = $refill_order->exist($mchid, $mch_order);
|
|
|
- return ($ret == false);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public function balanceOp()
|
|
|
- {
|
|
|
- $uid = $this->adminid();
|
|
|
- $minfo = new member_info($uid);
|
|
|
- $available = $minfo->available_predeposit();
|
|
|
-
|
|
|
- $content = "0|".ncPriceFormat($available)."|0.00";
|
|
|
- echo $content;
|
|
|
- return true;
|
|
|
- }
|
|
|
-
|
|
|
- public function queryOp()
|
|
|
- {
|
|
|
- $mchid = $this->mchid();
|
|
|
- $order_sn = $_GET['ord']; //用户方的订单号,对应数据库中的mch_order
|
|
|
-
|
|
|
- if(empty($order_sn)) {
|
|
|
- return self::outerr(-9,$this->merchant_available);
|
|
|
- }
|
|
|
-
|
|
|
- $order_state = refill\util::query_queue_order($mchid,$order_sn);
|
|
|
- if ($order_state == ORDER_STATE_QUEUE || $order_state == ORDER_STATE_SEND) {
|
|
|
- Log::record("query_state in queue mchid={$mchid} mch_order={$order_sn} order_state={$order_state}" ,Log::DEBUG);
|
|
|
-
|
|
|
- $state = 0;
|
|
|
- $msg = "{$order_sn}-充值中";
|
|
|
- $remark = "";
|
|
|
- $content = "|{$state}|{$msg}|{$remark}";
|
|
|
- echo $content;
|
|
|
- $this->query_request($mchid,$order_sn);
|
|
|
-
|
|
|
- return true;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- $mod_refill = Model('refill_order');
|
|
|
- $refill_info = $mod_refill->getOrderInfo(['mch_order' => $order_sn,'mchid' => $mchid,'inner_status' => 0]);
|
|
|
-
|
|
|
- if(empty($refill_info))
|
|
|
- {
|
|
|
- Log::record("query_state in db no order mchid={$mchid} mch_order={$order_sn}" ,Log::DEBUG);
|
|
|
-
|
|
|
- $state = 3;
|
|
|
- $msg = "{$order_sn}-无此订单";
|
|
|
- $remark = "";
|
|
|
- $content = "|{$state}|{$msg}|{$remark}";
|
|
|
- echo $content;
|
|
|
- return true;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- $vr_order = Model('vr_order');
|
|
|
- $order_info = $vr_order->getOrderInfo(['order_sn' => $refill_info['order_sn']]);
|
|
|
- $order_state = $order_info['order_state'];
|
|
|
-
|
|
|
- Log::record("query_state in db mchid={$mchid} mch_order={$order_sn} order_state={$order_state}" ,Log::DEBUG);
|
|
|
-
|
|
|
- if ($order_state == ORDER_STATE_CANCEL) {
|
|
|
- $state = 2;
|
|
|
- $msg = "{$order_sn}-充值失败";
|
|
|
- $remark = "";
|
|
|
- }
|
|
|
- elseif($order_state == ORDER_STATE_SUCCESS) {
|
|
|
- $state = 1;
|
|
|
- $msg = "{$order_sn}-充值成功";
|
|
|
- $remark = "{$refill_info['official_sn']}";
|
|
|
- }
|
|
|
- else {
|
|
|
- $state = 0;
|
|
|
- $msg = "{$order_sn}-充值中";
|
|
|
- $remark = "";
|
|
|
- }
|
|
|
-
|
|
|
- if($refill_info['card_type'] == mtopcard\ThirdRefillCard) {
|
|
|
- $remark = $this->third_remark($refill_info);
|
|
|
- }
|
|
|
-
|
|
|
- $content = "|{$state}|{$msg}|{$remark}";
|
|
|
- echo $content;
|
|
|
-
|
|
|
- return true;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private function query_request($mchid,$order_sn)
|
|
|
- {
|
|
|
- $mod_refill = Model('refill_order');
|
|
|
- $refill_info = $mod_refill->getOrderInfo(['mch_order' => $order_sn,'mchid' => $mchid,'inner_status' => 0]);
|
|
|
-
|
|
|
- if(!empty($refill_info))
|
|
|
- {
|
|
|
- $vr_order = Model('vr_order');
|
|
|
- $order_info = $vr_order->getOrderInfo(['order_sn' => $refill_info['order_sn']]);
|
|
|
-
|
|
|
- if(!empty($order_info) && $order_info['order_state'] == ORDER_STATE_SEND) {
|
|
|
- QueueClient::push("QueryRefillState",['order_id' => $refill_info['order_id']]);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- private function third_remark($refill_info)
|
|
|
- {
|
|
|
- $mchinfo = Model('merchant')->getMerchantInfo(['mchid' => $this->mchid()]);
|
|
|
- $mod_third = Model('thrid_refill');
|
|
|
- $thrid_info = $mod_third->getThird($refill_info['order_id']);
|
|
|
- $secure_key = $mchinfo['secure_key'];
|
|
|
-
|
|
|
- $remark = '';
|
|
|
- if (!empty($thrid_info))
|
|
|
- {
|
|
|
- $card_info = $thrid_info['card_info'];
|
|
|
- if (!empty($card_info)) {
|
|
|
- $encrypt = openssl_encrypt($card_info,'AES-128-CBC',$secure_key);
|
|
|
- if($encrypt != false) {
|
|
|
- $remark = $encrypt;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return $remark;
|
|
|
- }
|
|
|
-}
|