auth->id; if(!$rc_id){ throw new Exception('请选择会员套餐'); } //赋值money $recharge_config = Db::name('payvip_config')->where('id',$rc_id)->find(); $money = $recharge_config['money']; if($money <= 0) { throw new Exception('支付金额必须大于0'); } if($money > 10000){ throw new Exception('支付金额太大'); } //会员等级冲突 //当前是会员,但是却要向下级续费,直接提示报错 //修改等级,向上立刻改,向下不允许 $wallet_info = model('wallet')->getWallet($this->auth->id); if($wallet_info['vip_endtime'] > time() && $recharge_config['vip_level'] < $wallet_info['vip_level']){ throw new Exception('当前会员没有过期,不能续费'); } //创建订单 $data = []; $data['status'] = 0; $pay_no = createUniqueNo('V',$uid); $data['pay_no'] = $pay_no; $data['money'] = $money; $data['payment_class'] = $pay_type; $data['user_id'] = $uid; $data['ext_info'] = json_encode(['subject'=>'充值vip支付']); $data['memo'] = '充值会员支付'; $data['createtime'] = time(); //$data['payment'] = 'miniapp'; $data['payment'] = 'app'; $orderid = Db::name('pay_order')->insertGetId($data); //创建回调 $even_data = []; $even_data['event'] = 'success'; $even_data['class'] = 'app\common\model\Recharge'; $even_data['method'] = 'vippaysucc'; $even_data['args'] = json_encode(['user_id'=>$uid,'days'=>$recharge_config['days'],'vip_level'=>$recharge_config['vip_level'],'gold_num'=>$recharge_config['gold_num'],'money'=>$money]); $even_data['pay_no'] = $pay_no; Db::name('pay_event')->insertGetId($even_data); $res[] = ''; if ($pay_type == 'wechat') { //$money = 0.01; $sandpay = new \app\common\library\SuningPay(); $sandpayParams = [ 'order_no' => $pay_no, 'goods_name' => '充值vip支付', 'money' => $money, 'type' => 'vip', ]; $sandRes = $sandpay->wechath5($sandpayParams); if ($sandRes['status'] != 1) { throw new Exception('失败'); } $res = json_decode($sandRes['data']['params'],true); $url = 'https://h5-min-pay-1gczed24bbbe3db8-1317709175.tcloudbaseapp.com/suning-pay.html'; $ress['url'] = $url.'?orderId='.$res['tradeOrderId']; } else { //下单 $params = [ 'type' => $pay_type, 'orderid' => $pay_no, 'title' => $data['memo'], 'amount' => $data['money'], //'amount' => 0.01, 'method' => 'app', 'notifyurl' => 'http://app.zhiyinvip001.com/notify.php/paytype/'.$pay_type, 'returnurl' => '', ]; $res = Service::submitOrder($params); } Db::commit(); $this->success('success',$ress); } catch (Exception $e) { Db::rollback(); $this->error($e->getMessage()); } } //金币充值 public function gold_config(){ $list = Db::name('paygold_config')->where('is_show',1)->order('weight asc,id asc')->select(); $data['goldconfig'] = $list; $data['gold'] = model('wallet')->getWallet($this->auth->id,'gold'); $data['money_to_gold'] = config('site.money_to_gold'); $data['is_first'] = Db::name('user_paygold_log')->where(['uid' => $this->auth->id])->count('id'); if ($list) { $arr = [ 'id' => -1, 'money' => 0, 'gold' => 0, 'title' => '自定义', 'is_show' => 1, 'weight' => 1, 'first_gold' => 0, 'first_vipdays' => 0 ]; array_push($data['goldconfig'], $arr); foreach ($data['goldconfig'] as &$v) { $v['is_first'] = $data['is_first']; } } $this->success('success',$data); } //充值金币 创建订单 public function gold_recharge() { exit; Db::startTrans(); try { $rc_id = input_post('rc_id',0); $pay_type = 'wechat'; $freemoney = input_post('freemoney', 0, 'intval'); $uid = $this->auth->id; if(!$rc_id && !$freemoney){ throw new Exception('请选择或填写充值金额'); } if (!in_array($pay_type,['wechat','alipay'])) { throw new Exception('错误的支付类型'); } //赋值money if($rc_id){ $recharge_config = Db::name('paygold_config')->where('id',$rc_id)->find(); $money = $recharge_config ? $recharge_config['money']: 0; $gold = $recharge_config ? $recharge_config['gold'] : 0; $first_gold = $recharge_config ? $recharge_config['first_gold'] : 0; $first_vipdays = $recharge_config ? $recharge_config['first_vipdays'] : 0; $vip_gold = $recharge_config ? $recharge_config['vip_gold'] : 0; } //自由输入覆盖 if(!empty($freemoney)){ $rc_id = 0; $money = floatval($freemoney); $bili = config('site.rmb_to_gold') ?: 10; $gold = bcmul($money,$bili,0); $first_gold = 0; $first_vipdays = 0; $vip_gold = 0; } if($money <= 0) { throw new Exception('支付金额必须大于0'); } if($money > 10000){ throw new Exception('支付金额太大'); } //查询是不是会员,若不是则不赠送金币 $vip_endtime = Db::name('user_wallet')->where('user_id',$this->auth->id)->value('vip_endtime'); if ($vip_endtime < time()) { $vip_gold = 0; } //创建订单 $data = []; $data['status'] = 0; $pay_no = createUniqueNo('P',$uid); $data['pay_no'] = $pay_no; $data['money'] = $money; $data['payment_class'] = $pay_type; $data['user_id'] = $uid; $data['ext_info'] = json_encode(['subject'=>'充值金币支付']); $data['memo'] = '充值金币支付'; $data['createtime'] = time(); $data['payment'] = 'app'; $orderid = Db::name('pay_order')->insertGetId($data); //创建回调 $even_data = []; $even_data['event'] = 'success'; $even_data['class'] = 'app\common\model\Recharge'; $even_data['method'] = 'goldpaysucc'; $even_data['args'] = json_encode(['user_id'=>$uid,'gold'=>$gold,'money'=>$money,'pg_id'=>$rc_id,'first_gold'=>$first_gold,'first_vipdays'=>$first_vipdays, 'intro_uid' => $this->auth->intro_uid, 'vip_gold' => $vip_gold]); $even_data['pay_no'] = $pay_no; Db::name('pay_event')->insertGetId($even_data); //$money = 0.01; $suningpay = new \app\common\library\SuningPay(); $suningpayParams = [ 'order_no' => $pay_no, 'goods_name' => '充值金币支付', 'money' => $money, 'type' => 'gold', ]; $suningRes = $suningpay->wechath5($suningpayParams); if ($suningRes['status'] != 1) { throw new Exception('失败'); } $res = json_decode($suningRes['data']['params'],true); $url = 'https://h5-min-pay-1gczed24bbbe3db8-1317709175.tcloudbaseapp.com/suning-pay.html'; $ress['url'] = $url.'?orderId='.$res['tradeOrderId']; Db::commit(); $this->success('成功', $ress); } catch (Exception $e) { Db::rollback(); $this->error($e->getMessage()); } } /** * 支付成功 */ public function notify() { //$input_post_data = json_encode($_POST); //filePut('[wallet][paySucc]充值参数 recharge money post'.$input_post_data); //$postData = isset($_POST['data']) ? $_POST['data'] : []; //$sign = isset($_POST['sign']) ? $_POST['sign'] : ''; $postData=file_get_contents('php://input'); $postData = urldecode($postData); $arr = explode('&', $postData); $nowArr = array(); foreach($arr as $v) { $kv = explode('=', $v); $nowArr[$kv[0]] = $kv[1]; } if($nowArr['responseCode'] == 'SJ0000' && $nowArr['transactStatus'] == '00') { $data = $this->verification($postData); if($data == 1) { //验签名通过 //查询订单信息 $PayResult = Db::name('pay_order'); $where['pay_no'] = $nowArr['orderId']; $order_info = $PayResult->where($where)->find(); if(!$order_info) { filePut('[wallet][paySucc]充值入账更新余额失败 recharge money fail 订单数据库检索不到'.$nowArr['orderId'],'suningno.txt'); exit; } if ($order_info['status'] == 1 || $order_info['status'] == 2) { filePut('[wallet][paySucc]充值入账更新余额失败 recharge money fail status已更新过'.$order_info['status'].'___'.$nowArr['orderId'],'suningno.txt'); echo 'true';exit; } $orderCode = $nowArr['orderId']; $extendType = ''; //区分vip 还是 冲金币 $is_g = stripos($orderCode,'P'); if($is_g !== false) { $extendType = 'gold'; }else{ $is_v = stripos($orderCode,'V'); if($is_v !== false) { $extendType = 'vip'; } } //status已更新过 $_data['status'] = 2; $result = $PayResult->where($where)->setField($_data); if ($result || 1) { //你可以在此编写订单逻辑 $payEventWhere['pay_no'] = $orderCode; $payEvent = Db::name('pay_event')->where($payEventWhere)->find(); $args = isset($payEvent['args']) ? $payEvent['args'] : ''; $args = json_decode($args,true); $rechargeM = new \app\common\model\Recharge(); if ($extendType == 'gold') { $payRes = $rechargeM->goldpaysucc($orderCode,$args); $payTypeStr = '充值'; } elseif($extendType == 'vip') { $payRes = $rechargeM->vippaysucc($orderCode,$args); $payTypeStr = 'vip'; } else { $payRes = false; $payTypeStr = '未知支付类型'; } if(!$payRes) { filePut('[wallet][paySucc]'.$payTypeStr.'更新失败请查看问题'.$orderCode,'suningno.txt'); exit; } filePut('[wallet][paySucc]回调成功'.$orderCode,'suningno.txt'); echo "true";exit; } filePut('[wallet][paySucc]充值入账更新余额失败 更新状态2不成功'.$orderCode."\n".' data:'.$postData."\n",'suningno.txt'); exit; } } else { filePut(' recharge gold fail 用户交易操作失败'.$postData,'suningno.txt'); echo '支付异常';exit; } filePut('[wallet][paySucc]充值入账更新余额失败 验证签名不通过'.$orderCode."\n".' data:'.$postData."\n",'suningno.txt'); echo 'Fail';exit; } protected function verification($str) { if($str != '') { $arr = explode('&', $str); $nowArr = array(); foreach($arr as $v) { $kv = explode('=', $v); $nowArr[$kv[0]] = $kv[1]; } ksort($nowArr); $newstr = ''; foreach($nowArr as $key => $value) { if($value == '' || $key == 'signature' || $key== 'signAlgorithm') { continue; } if($key == 'version') { $newstr .= $key.'='.$value; } else { $newstr .= $key.'='.$value.'&'; } } // print_r($nowArr); //var_dump($newstr); $sign = base64_decode($nowArr['signature']); // exit; $newstr = strtoupper(md5($newstr)); // var_dump($newstr); $pubfile = file_get_contents(APP_PATH.'common/library/suning/publicnew.pem'); $ret = openssl_verify($newstr,$sign,$pubfile); return $ret; } } }