834 lines
34 KiB
PHP
834 lines
34 KiB
PHP
<?php
|
||
|
||
namespace app\api\model;
|
||
|
||
use think\Model;
|
||
use think\Db;
|
||
use think\facade\Env;
|
||
|
||
class UserRecharge extends Model
|
||
{
|
||
|
||
//用户充值
|
||
public function create_pay_order($uid, $crid, $pay_type, $custom_amount)
|
||
{
|
||
$user_info = db::name('user')->find($uid);
|
||
if($user_info['is_teenager'] == 1){
|
||
return ['code' => 201, 'msg' => '已开启青少年模式', 'data' => null];
|
||
}
|
||
if($user_info['is_real'] != 1){
|
||
return ['code' => 201, 'msg' => '请先实名认证', 'data' => null];
|
||
}
|
||
$pay_money = 0;
|
||
$give_integral = 0;
|
||
|
||
if (!in_array($pay_type, [1, 2, 21])) {
|
||
return ['code' => 201, 'msg' => '充值方式参数非法', 'data' => null];
|
||
}
|
||
|
||
|
||
//2:原生微信支付
|
||
if($pay_type==2){
|
||
$app_ys_wx_recharge = get_system_config('app_ys_wx_recharge');
|
||
if($app_ys_wx_recharge != 1){
|
||
return ['code' => 201, 'msg' => '系统维护中,马上回来!', 'data' => null];
|
||
}
|
||
}
|
||
|
||
//20:支付宝原生支付开关
|
||
|
||
if($pay_type==1){
|
||
$app_ys_zfb_recharge = get_system_config('app_ys_zfb_recharge');
|
||
if($app_ys_zfb_recharge != 1){
|
||
return ['code' => 201, 'msg' => '系统维护中,马上回来!', 'data' => null];
|
||
}
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
if ($pay_type == 21) {
|
||
$zfbh5_huifu_recharge = get_system_config('zfbh5_huifu_recharge');
|
||
if($zfbh5_huifu_recharge != 1){
|
||
return ['code' => 201, 'msg' => '系统维护中,马上回来!', 'data' => null];
|
||
}
|
||
}
|
||
|
||
|
||
|
||
if (!empty($crid)) {
|
||
$map = [];
|
||
$map[] = ['crid', '=', $crid];
|
||
$map[] = ['is_delete', '=', 1];
|
||
$can_recharge_info = Db::name('can_recharge')->where($map)->find();
|
||
if (empty($can_recharge_info)) {
|
||
return ['code' => 201, 'msg' => '充值金额不存在', 'data' => null];
|
||
}
|
||
if ($can_recharge_info['money'] <= 0) {
|
||
return ['code' => 201, 'msg' => '充值金额参数非法', 'data' => null];
|
||
}
|
||
$pay_money = $can_recharge_info['money'];
|
||
$give_integral = $can_recharge_info['integral'];
|
||
} else {
|
||
if (intval($custom_amount) != $custom_amount) {
|
||
return ['code' => 201, 'msg' => '充值金额必须为整数', 'data' => null];
|
||
}
|
||
if ($custom_amount < 1) {
|
||
return ['code' => 201, 'msg' => '充值金额最少1元', 'data' => null];
|
||
}
|
||
$exchange_rate = get_system_config('exchange_rate');
|
||
$pay_money = $custom_amount;
|
||
$give_integral = $custom_amount * $exchange_rate;
|
||
}
|
||
|
||
|
||
$order_sn = $this->create_recharge_order_sn(1);
|
||
// $pay_money = 0.01;
|
||
$data = [];
|
||
$data['order_sn'] = $order_sn;
|
||
$data['order_type'] = 1;
|
||
$data['money'] = $pay_money;
|
||
$data['integral'] = $give_integral;
|
||
$data['pay_type'] = $pay_type;
|
||
$data['uid'] = $uid;
|
||
$data['pay_status'] = 1;
|
||
$data['pay_time'] = 0;
|
||
$data['remarke'] = '';
|
||
$data['add_time'] = time();
|
||
$data['update_time'] = time();
|
||
$data['carry_money'] = $pay_money;
|
||
$data['is_carray_finish'] = 2;
|
||
$status = Db::name('user_recharge')->insert($data);
|
||
$data = [];
|
||
if ($status) {
|
||
|
||
if ($pay_type == 1) {
|
||
// $data = $this->threePayFromPost($order_sn, $pay_money, 922);
|
||
$data = $this->alipayHand($order_sn, $pay_money);
|
||
} elseif($pay_type == 21){
|
||
// $data = model('api/AdaPay')->create_order($order_sn, $pay_money, $uid);
|
||
// if($data['code'] != 200){
|
||
// return ['code' => 201, 'msg' => '支付失败', 'data' => null];
|
||
// }
|
||
// $result = $data['result'];
|
||
// if(isset($result['status']) && ($result['status'] == "succeeded")){
|
||
// $payment_id = $result['id'];
|
||
// $map = [];
|
||
// $map[] = ['order_sn', '=', $order_sn];
|
||
// $order_info = Db::name('user_recharge')->where($map)->update(['payment_id'=>$payment_id]);
|
||
// }
|
||
|
||
$data = model('HuiFu1')->ali_h5($order_sn, $pay_money);
|
||
if(!empty($data['data']['qr_code'])){
|
||
return ['code' => 200, 'msg' => '请求成功', 'data' => ['pay_info'=>'alipays://platformapi/startapp?saId=10000007&qrcode='.$data['data']['qr_code']]];
|
||
// return ['code' => 200, 'msg' => '请求成功', 'data' => $data['data']];
|
||
}else{
|
||
return ['code' => 201, 'msg' => '支付失败', 'data' => null];
|
||
}
|
||
} else {
|
||
// $data = $this->threePayFromPost($order_sn, $pay_money, 921);
|
||
$data = $this->wxpayHand($order_sn, $pay_money);
|
||
}
|
||
}
|
||
return ['code' => 200, 'msg' => '请求成功', 'data' => $data['data']];
|
||
}
|
||
|
||
|
||
//购买会员
|
||
public function pay_vip_order($uid, $vid, $pay_type)
|
||
{
|
||
$user_info = db::name('user')->find($uid);
|
||
if($user_info['is_teenager'] == 1){
|
||
return ['code' => 201, 'msg' => '已开启青少年模式', 'data' => null];
|
||
}
|
||
$pay_money = 0;
|
||
$give_integral = 0;
|
||
|
||
if (!in_array($pay_type, [1, 2])) {
|
||
return ['code' => 201, 'msg' => '充值方式参数非法', 'data' => null];
|
||
}
|
||
|
||
if(!empty($vid)){
|
||
$map = [];
|
||
$map[] = ['vid', '=', $vid];
|
||
$vip_info = db::name('vip')->where($map)->find();
|
||
if(empty($vip_info)){
|
||
return ['code' => 201, 'msg' => '会员卡类型不存在', 'data' => null];
|
||
}
|
||
if ($vip_info['price'] <= 0) {
|
||
return ['code' => 201, 'msg' => '会员卡购买金额参数非法', 'data' => null];
|
||
}
|
||
$pay_money = $vip_info['price'];
|
||
}else{
|
||
return ['code' => 201, 'msg' => '会员卡类型不存在', 'data' => null];
|
||
}
|
||
|
||
|
||
|
||
$order_sn = $this->create_recharge_order_sn(2);
|
||
// $pay_money = 0.01;
|
||
$data = [];
|
||
$data['order_sn'] = $order_sn;
|
||
$data['order_type'] = 2;
|
||
$data['vid'] = $vid;
|
||
$data['money'] = $pay_money;
|
||
$data['integral'] = $give_integral;
|
||
$data['pay_type'] = $pay_type;
|
||
$data['uid'] = $uid;
|
||
$data['pay_status'] = 1;
|
||
$data['pay_time'] = 0;
|
||
$data['remarke'] = '';
|
||
$data['add_time'] = time();
|
||
$data['update_time'] = time();
|
||
$status = Db::name('user_recharge')->insert($data);
|
||
$data = [];
|
||
if ($status) {
|
||
|
||
if ($pay_type == 1) {
|
||
// $data = $this->threePayFromPost($order_sn, $pay_money, 922);
|
||
$data = $this->alipayHand($order_sn, $pay_money);
|
||
} else {
|
||
// $data = $this->threePayFromPost($order_sn, $pay_money, 921);
|
||
$data = $this->wxpayHand($order_sn, $pay_money);
|
||
}
|
||
}
|
||
return ['code' => 200, 'msg' => '请求成功', 'data' => $data['data']];
|
||
}
|
||
|
||
//更换邀请人
|
||
public function update_user_inviter($uid, $user_id, $sms_code, $pay_type)
|
||
{
|
||
$config = get_uncache_system_config();
|
||
|
||
$user_info = db::name('user')->where('uid', $uid)->find();
|
||
if(!$user_info){
|
||
return ['code' => 201, 'msg' => '参数错误', 'data' => null];
|
||
}
|
||
if($user_info['is_teenager'] == 1){
|
||
return ['code' => 201, 'msg' => '已开启青少年模式', 'data' => null];
|
||
}
|
||
|
||
if($user_info['user_name'] == $uid){
|
||
return ['code' => 201, 'msg' => '该用户尚未绑定手机号', 'data' => null];
|
||
}
|
||
|
||
$reslut = model('sms')->verification_code($user_info['user_name'], $sms_code);
|
||
if ($reslut['code'] == 201) {
|
||
return ajaxReturn($reslut['code'], $reslut['msg'], $reslut['data']);
|
||
}
|
||
|
||
$pay_money = 0;
|
||
$give_integral = 0;
|
||
|
||
$inviter_info = db::name('user')->where('uid', $user_id)->find();
|
||
if(!$inviter_info){
|
||
return ['code' => 201, 'msg' => '更换邀请人不存在', 'data' => null];
|
||
}
|
||
|
||
if(empty($inviter_info['vid'])){
|
||
return ['code' => 201, 'msg' => '更换邀请人不是会员', 'data' => null];
|
||
}
|
||
|
||
if($inviter_info['vip_end_time'] - time() < (60*60*24*30)){
|
||
return ['code' => 201, 'msg' => '更换邀请人会员少于30天', 'data' => null];
|
||
}
|
||
|
||
if (!in_array($pay_type, [1, 2])) {
|
||
return ['code' => 201, 'msg' => '充值方式参数非法', 'data' => null];
|
||
}
|
||
|
||
if(empty($config['update_inviter_price']) && $config['update_inviter_price'] < 0){
|
||
return ['code' => 201, 'msg' => '换绑支付金额不能为空且不能小于0', 'data' => null];
|
||
}
|
||
|
||
$pay_money = $config['update_inviter_price'];
|
||
|
||
|
||
$order_sn = $this->create_recharge_order_sn(3);
|
||
// $pay_money = 0.01;
|
||
$data = [];
|
||
$data['order_sn'] = $order_sn;
|
||
$data['order_type'] = 3;
|
||
$data['invite_uid'] = $user_id;
|
||
$data['money'] = $pay_money;
|
||
$data['integral'] = $give_integral;
|
||
$data['pay_type'] = $pay_type;
|
||
$data['uid'] = $uid;
|
||
$data['pay_status'] = 1;
|
||
$data['pay_time'] = 0;
|
||
$data['remarke'] = '';
|
||
$data['add_time'] = time();
|
||
$data['update_time'] = time();
|
||
$status = Db::name('user_recharge')->insert($data);
|
||
$data = [];
|
||
if ($status) {
|
||
|
||
if ($pay_type == 1) {
|
||
// $data = $this->threePayFromPost($order_sn, $pay_money, 922);
|
||
$data = $this->alipayHand($order_sn, $pay_money);
|
||
} else {
|
||
// $data = $this->threePayFromPost($order_sn, $pay_money, 921);
|
||
$data = $this->wxpayHand($order_sn, $pay_money);
|
||
}
|
||
}
|
||
return ['code' => 200, 'msg' => '请求成功', 'data' => $data['data']];
|
||
}
|
||
|
||
public function threePayFromPost( $pay_orderid='', $pay_amount=0, $pay_bankcode='921'){
|
||
$pay_memberid = "210879796"; //商户后台API管理获取
|
||
//$pay_orderid = 'E'.date("YmdHis").rand(100000,999999); //订单号
|
||
//$pay_amount = 10; //交易金额
|
||
$pay_applydate = date("Y-m-d H:i:s"); //订单时间
|
||
$pay_notifyurl = "http://" . $_SERVER['HTTP_HOST'] . "/api/pay_notify/three_pay_notify"; //服务端返回地址
|
||
$pay_callbackurl = "http://" . $_SERVER['HTTP_HOST']; //页面跳转返回地址
|
||
$Md5key = "lsn75mdcbhuy0h913blni0wxycpcq2dk"; //商户后台API管理获取
|
||
$tjurl = "https://guohongpay.com//Pay_Index.html"; //提交地址
|
||
//$pay_bankcode = "921"; //922 支付宝 921 微信 //商户后台通道费率页 获取银行编码
|
||
$native = array(
|
||
"pay_memberid" => $pay_memberid,
|
||
"pay_orderid" => $pay_orderid,
|
||
"pay_amount" => $pay_amount,
|
||
"pay_applydate" => $pay_applydate,
|
||
"pay_bankcode" => $pay_bankcode,
|
||
"pay_notifyurl" => $pay_notifyurl,
|
||
"pay_callbackurl" => $pay_callbackurl,
|
||
);
|
||
ksort($native);
|
||
$md5str = "";
|
||
foreach ($native as $key => $val) {
|
||
$md5str = $md5str . $key . "=" . $val . "&";
|
||
}
|
||
|
||
//echo($md5str . "key=" . $Md5key);
|
||
$sign = strtoupper(md5($md5str . "key=" . $Md5key));
|
||
$native["pay_md5sign"] = $sign;
|
||
$native['pay_attach'] = "1234|456";
|
||
$native['pay_productname'] ='团购商品';
|
||
|
||
$html='<html lang="zh-CN">
|
||
<head>
|
||
<meta charset="utf-8">
|
||
<meta http-equiv="X-UA-Compatible" content="IE=edge">
|
||
<meta name="viewport" content="width=device-width, initial-scale=1">
|
||
</head>
|
||
<body><form class="form-inline" method="post" id="myForm" action="'.$tjurl.'" style="display:none">';
|
||
|
||
foreach ($native as $key => $val) {
|
||
$html.='<input type="hidden" name="'.$key.'" value="'.$val.'">';
|
||
}
|
||
|
||
$html.='</form><script>window.onload = function(){document.getElementById("myForm").submit();}</script></body>
|
||
</html>';
|
||
//<script>window.onload = function(){document.getElementById("myForm").submit();}</script>
|
||
echo $html;
|
||
|
||
}
|
||
|
||
//支付宝异步回调
|
||
public function three_pay_notify($data)
|
||
{
|
||
$returnArray = array( // 返回字段
|
||
"memberid" => $data["memberid"], // 商户ID
|
||
"orderid" => $data["orderid"], // 订单号
|
||
"amount" => $data["amount"], // 交易金额
|
||
"datetime" => $data["datetime"], // 交易时间
|
||
"transaction_id" => $data["transaction_id"], // 支付流水号
|
||
"returncode" => $data["returncode"],
|
||
);
|
||
$md5key = "lsn75mdcbhuy0h913blni0wxycpcq2dk";
|
||
ksort($returnArray);
|
||
reset($returnArray);
|
||
$md5str = "";
|
||
foreach ($returnArray as $key => $val) {
|
||
$md5str = $md5str . $key . "=" . $val . "&";
|
||
}
|
||
$sign = strtoupper(md5($md5str . "key=" . $md5key));
|
||
if ($sign == $data["sign"]) {
|
||
if ($data["returncode"] == "00") {
|
||
$order_sn = $data['orderid'];
|
||
$pay_amount = $data['amount'];
|
||
$data = $this->pay_notify_success($order_sn, $pay_amount);
|
||
if ($data['code'] == 200) {
|
||
exit('OK');
|
||
} else {
|
||
exit('FAIL');
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
public function payh5alipay($order_sn='', $money='', $title='订单支付'){
|
||
require_once Env::get('root_path') . 'extend/alipay-sdk-PHP-4.9.2/aop/AopClient.php';
|
||
require_once Env::get('root_path') . 'extend/alipay-sdk-PHP-4.9.2/aop/request/AlipayTradeWapPayRequest.php';
|
||
$config = model('admin/Config')->get_system_config();
|
||
$prv=$config['merchant_private_key'];
|
||
$pov=$config['alipay_public_key'];
|
||
//vendor('alipay.aop.AopSdk.AopClient');
|
||
//include_once ROOT_PATH . '/extend/alipay/aop/AopClient.php';
|
||
$aop = new \AopClient();
|
||
$aop->gatewayUrl = "https://openapi.alipay.com/gateway.do";
|
||
$aop->appId = $config['ali_appid'];
|
||
$aop->rsaPrivateKey = $prv;
|
||
$aop->format = "json";
|
||
$aop->charset = "UTF-8";
|
||
$aop->signType = "RSA2";
|
||
$aop->alipayrsaPublicKey = $pov;
|
||
$aop->apiVersion = '1.0';
|
||
|
||
|
||
//实例化具体API对应的request类,类名称和接口名称对应,当前调用接口名称：alipay.trade.app.pay
|
||
$request = new \AlipayTradeWapPayRequest();
|
||
|
||
// 异步通知地址
|
||
$notify_url = $_SERVER['REQUEST_SCHEME'].'://'.$_SERVER['HTTP_HOST'].'/api/pay_notify/ali_pay_notify';
|
||
//error_log(json_encode($notify_url), 3, 'pn.log');
|
||
$quit_url= $_SERVER['REQUEST_SCHEME'].'://'.$_SERVER['HTTP_HOST'].'/';
|
||
// 订单标题
|
||
$subject = $title;
|
||
// 订单详情
|
||
$body = $title;
|
||
// 订单号，示例代码使用时间值作为唯一的订单ID号
|
||
$out_trade_no = $order_sn;
|
||
|
||
$total = floatval($money);
|
||
|
||
//SDK已经封装掉了公共参数，这里只需要传入业务参数
|
||
$bizcontent = "{\"body\":\"".$body."\","
|
||
. "\"subject\": \"".$subject."\","
|
||
. "\"quit_url\": \"".$quit_url."\","
|
||
. "\"out_trade_no\": \"".$out_trade_no."\","
|
||
. "\"timeout_express\": \"600m\","
|
||
. "\"total_amount\": \"".$total."\","
|
||
. "\"product_code\":\"QUICK_WAP_WAY\""
|
||
. "}";
|
||
$request->setNotifyUrl($notify_url);
|
||
$request->setBizContent($bizcontent);
|
||
|
||
//这里和普通的接口调用不同，使用的是sdkExecute
|
||
$response = $aop->pageExecute($request);
|
||
// $data = '<div style=display:none>'.$response.'</div>';
|
||
// return ['code' => 200, 'msg' => '成功', 'data' => $data];
|
||
// 注意：这里不需要使用htmlspecialchars进行转义，直接返回即可
|
||
echo '<div style=display:none>'.$response.'</div>';
|
||
|
||
exit;
|
||
}
|
||
|
||
//支付宝支付
|
||
private function alipayHand($order_sn, $pay_amount)
|
||
{
|
||
require_once Env::get('root_path') . 'extend/alipay-sdk-PHP-4.9.2/aop/AopClient.php';
|
||
$config = model('admin/Config')->get_system_config();
|
||
$aop = new \AopClient();
|
||
$aop->gatewayUrl = "https://openapi.alipay.com/gateway.do";
|
||
$aop->appId = $config['ali_appid'];
|
||
$aop->alipayrsaPublicKey = $config['alipay_public_key'];
|
||
$aop->rsaPrivateKey = $config['merchant_private_key'];
|
||
$aop->format = "json";
|
||
$aop->charset = "UTF-8";
|
||
$aop->signType = "RSA2";
|
||
//实例化具体API对应的request类,类名称和接口名称对应,当前调用接口名称：alipay.trade.app.pay
|
||
require_once Env::get('root_path') . 'extend/alipay-sdk-PHP-4.9.2/aop/request/AlipayTradeAppPayRequest.php';
|
||
///app/Packages/alipay/aop/request
|
||
$request = new \AlipayTradeAppPayRequest();
|
||
//SDK已经封装掉了公共参数，这里只需要传入业务参数
|
||
$arr['body'] = "购买商品";
|
||
$arr['subject'] = "购买商品";
|
||
$arr['out_trade_no'] = $order_sn;
|
||
$arr['timeout_express'] = "30m";
|
||
$arr['total_amount'] = $pay_amount;
|
||
$arr['product_code'] = "QUICK_MSECURITY_PAY";
|
||
|
||
$bizcontent = json_encode($arr, JSON_UNESCAPED_UNICODE);
|
||
// $request->setNotifyUrl("http://" . $_SERVER['HTTP_HOST'] . "/api/pay_notify/ali_pay_notify");
|
||
$request->setNotifyUrl("http://119.45.115.72:621/api/pay_notify/ali_pay_notify");
|
||
$request->setBizContent($bizcontent);
|
||
//这里和普通的接口调用不同，使用的是sdkExecute
|
||
$response = $aop->sdkExecute($request);
|
||
return ['code' => 201, 'msg' => '', 'data' => $response];
|
||
}
|
||
|
||
|
||
//微信支付
|
||
private function wxpayHand($order_sn, $pay_amount)
|
||
{
|
||
$config = model('admin/Config')->get_system_config();
|
||
require_once Env::get('root_path') . 'extend/wxPay/WxPay.php';
|
||
$WxPay = new \WxPay($config['wx_appid'], $config['wx_mch_id'], $config['wx_key']);
|
||
$params['body'] = '购买商品'; //商品描述
|
||
$params['out_trade_no'] = $order_sn; //自定义的订单号
|
||
$params['total_fee'] = $pay_amount * 100; //订单金额 只能为整数 单位为分
|
||
$params['trade_type'] = 'APP'; //交易类型 JSAPI | NATIVE | APP | WAP
|
||
$params['attach'] = '123'; //附加参数
|
||
// $params['notify_url'] = "http://" . $_SERVER['HTTP_HOST'] . "/api/pay_notify/wx_pay_notify";
|
||
$params['notify_url'] = "http://119.45.115.72:621/api/pay_notify/wx_pay_notify";
|
||
$result = $WxPay->unifiedOrder($params);
|
||
// dump($result);die;
|
||
if ($result['prepay_id']) {
|
||
$data = $WxPay->getOrder($result['prepay_id']);
|
||
return ['code' => 200, 'msg' => '请求成功', 'data' => $data];
|
||
} else {
|
||
return ['code' => 201, 'msg' => '请求失败', 'data' => null];
|
||
}
|
||
}
|
||
//支付宝回调
|
||
public function wxPayNotify($xmlData)
|
||
{
|
||
require_once Env::get('root_path') . 'extend/wxPay/WxPay.php';
|
||
$config = model('admin/Config')->get_system_config();
|
||
$WxPay = new \WxPay($config['wx_appid'], $config['wx_mch_id'], $config['wx_key']);
|
||
//接收微信返回的数据数据,返回的xml格式
|
||
// $xmlData = file_get_contents('php://input');
|
||
$data = $WxPay->xml_to_data($xmlData);
|
||
$sign = $data['sign'];
|
||
unset($data['sign']);
|
||
if ($sign == $WxPay->MakeSign($data)) {
|
||
//签名验证成功后，判断返回微信返回的
|
||
if ($data['result_code'] == 'SUCCESS') {
|
||
//处理交易完成或者支付成功的通知
|
||
$order_sn = $data['out_trade_no'];
|
||
$pay_amount = $data['total_fee'] * 0.01;
|
||
$data = $this->pay_notify_success($order_sn, $pay_amount);
|
||
if ($data['code'] == 200) {
|
||
exit('SUCCESS');
|
||
} else {
|
||
exit('FAIL');
|
||
}
|
||
} else {
|
||
exit('FAIL');
|
||
}
|
||
} else {
|
||
|
||
exit('FAIL');
|
||
}
|
||
}
|
||
|
||
|
||
//支付宝异步回调
|
||
public function ali_pay_notify($data)
|
||
{
|
||
require_once Env::get('root_path') . 'extend/alipay-sdk-PHP-4.9.2/aop/AopClient.php';
|
||
$aop = new \AopClient();
|
||
$config = model('admin/Config')->get_system_config();
|
||
$aop->alipayrsaPublicKey = $config['alipay_public_key'];
|
||
if ($data['app_id'] == $config['ali_appid'] && $data['sign_type'] == 'RSA2') {
|
||
//处理业务，并从$_POST中提取需要的参数内容
|
||
if ($data['trade_status'] == 'TRADE_SUCCESS') {
|
||
//处理交易完成或者支付成功的通知
|
||
$order_sn = $data['out_trade_no'];
|
||
$pay_amount = $data['total_amount'];
|
||
$data = $this->pay_notify_success($order_sn, $pay_amount);
|
||
if ($data['code'] == 200) {
|
||
exit('SUCCESS');
|
||
} else {
|
||
exit('FAIL');
|
||
}
|
||
} else {
|
||
exit('FAIL');
|
||
}
|
||
} else {
|
||
exit('FAIL');
|
||
}
|
||
}
|
||
|
||
|
||
//支付回调验证成功
|
||
public function pay_notify_success($order_sn, $pay_amount)
|
||
{
|
||
$redis = connectionRedis();
|
||
$key_name = "api:user_recharge:pay_notify_success:order_sn".$order_sn;
|
||
$redis_order_sn = redis_lock_exits($key_name,1,5);
|
||
if($redis_order_sn){
|
||
$map = [];
|
||
$map[] = ['order_sn', '=', $order_sn];
|
||
$order_info = Db::name('user_recharge')->where($map)->find();
|
||
if (empty($order_info)) {
|
||
return ['code' => 201, 'msg' => '订单不存在', 'data' => null];
|
||
}
|
||
if ($order_info['pay_status'] != 1) {
|
||
return ['code' => 201, 'msg' => '订单已支付', 'data' => null];
|
||
}
|
||
if (bcmul($order_info['money'], 100, 2) != bcmul($pay_amount, 100, 2)) {
|
||
return ['code' => 201, 'msg' => '充值金额异常', 'data' => null];
|
||
}
|
||
Db::startTrans();
|
||
try {
|
||
//更改订单状态
|
||
$data = [];
|
||
$data['pay_status'] = 2;
|
||
$data['pay_time'] = time();
|
||
Db::name('user_recharge')->where('rid', $order_info['rid'])->update($data);
|
||
if($order_info['order_type'] == 1){
|
||
//增加用户余额及充值记录
|
||
$result = model('admin/User')->change_user_money_by_uid($order_info['uid'], $order_info['integral'], 2, 9, "用户充值:" . $order_info['order_sn'], $order_info['uid'], $order_info['rid']);
|
||
if($result['code'] != 200) {
|
||
Db::rollback();
|
||
return ['code' => 201, 'msg' => '充值金额异常', 'data' => null];
|
||
}
|
||
//会员邀请收益
|
||
model('api/Vip')->vip_invite_earnings($order_info['uid'], $order_info['money'], $order_info['integral']);
|
||
}elseif($order_info['order_type'] == 4) {
|
||
$result = model('admin/User')->change_user_money_by_uid($order_info['uid'], $order_info['integral'], 2, 44, "用户购买爵位:" . $order_info['order_sn'], $order_info['uid'], $order_info['rid']);
|
||
if($result['code'] != 200) {
|
||
Db::rollback();
|
||
return ['code' => 201, 'msg' => '充值金额异常', 'data' => null];
|
||
}
|
||
$type_params = json_decode($order_info['type_params'], true);
|
||
$result = model('api/Nobility')->user_pay_nobility_value($order_info['uid'], $type_params);
|
||
if($result['code'] != 200) {
|
||
Db::rollback();
|
||
return ['code' => 201, 'msg' => '充值金额异常', 'data' => null];
|
||
}
|
||
}
|
||
// 提交事务
|
||
Db::commit();
|
||
return ['code' => 200, 'msg' => "成功", 'data' => null];
|
||
} catch (\Exception $e) {
|
||
dump($e);
|
||
// 回滚事务
|
||
Db::rollback();
|
||
return ['code' => 201, 'msg' => "失败5", 'data' => null];
|
||
}
|
||
}
|
||
|
||
return ['code' => 200, 'msg' => 'success', 'data' => null];
|
||
}
|
||
|
||
//生成充值唯一单号
|
||
// private function create_recharge_order_sn()
|
||
// {
|
||
// $order_sn = 'CZ' . date('YmdHis') . mt_rand(10000, 99999);
|
||
// $map = [];
|
||
// $map[] = ['order_sn', '=', $order_sn];
|
||
// $reslut = db::name('user_recharge')->where($map)->find();
|
||
// if (empty($reslut)) {
|
||
// return $order_sn;
|
||
// } else {
|
||
// $this->create_recharge_order_sn();
|
||
// }
|
||
// }
|
||
private function create_recharge_order_sn($type)
|
||
{
|
||
if($type == 1){
|
||
$order_type = 'CZ';
|
||
}else if($type == 2){
|
||
$order_type = 'HY';
|
||
}elseif($type == 4){
|
||
$order_type = 'JW';
|
||
}else {
|
||
$order_type = 'JC';
|
||
}
|
||
$order_sn = $order_type . date('YmdHis') . mt_rand(10000, 99999);
|
||
$map = [];
|
||
$map[] = ['order_sn', '=', $order_sn];
|
||
$reslut = db::name('user_recharge')->where($map)->find();
|
||
if (empty($reslut)) {
|
||
return $order_sn;
|
||
} else {
|
||
return $this->create_recharge_order_sn($type);
|
||
}
|
||
}
|
||
|
||
//购买会员
|
||
public function pay_nobility_order($uid, $lid, $pay_type)
|
||
{
|
||
$user_info = db::name('user')->find($uid);
|
||
if($user_info['is_teenager'] == 1){
|
||
return ['code' => 201, 'msg' => '已开启青少年模式', 'data' => null];
|
||
}
|
||
$pay_money = 0;
|
||
$give_integral = 0;
|
||
|
||
if (!in_array($pay_type, [1, 2, 21])) {
|
||
return ['code' => 201, 'msg' => '充值方式参数非法', 'data' => null];
|
||
}
|
||
|
||
// if ($pay_type == 21) {
|
||
// return ['code' => 201, 'msg' => '系统维护中', 'data' => null];
|
||
// }
|
||
|
||
|
||
|
||
if($pay_type==2){
|
||
$app_ys_wx_recharge = get_system_config('app_ys_wx_recharge');
|
||
if($app_ys_wx_recharge != 1){
|
||
return ['code' => 201, 'msg' => '系统维护中,马上回来!', 'data' => null];
|
||
}
|
||
}
|
||
|
||
|
||
if($pay_type==1){
|
||
$app_ys_zfb_recharge = get_system_config('app_ys_zfb_recharge');
|
||
if($app_ys_zfb_recharge != 1){
|
||
return ['code' => 201, 'msg' => '系统维护中,马上回来!', 'data' => null];
|
||
}
|
||
}
|
||
|
||
|
||
if ($pay_type == 21) {
|
||
$zfbh5_huifu_recharge = get_system_config('zfbh5_huifu_recharge');
|
||
if($zfbh5_huifu_recharge != 1){
|
||
return ['code' => 201, 'msg' => '系统维护中,马上回来!', 'data' => null];
|
||
}
|
||
}
|
||
|
||
|
||
|
||
$type_params = [];
|
||
if(!empty($lid)){
|
||
if($user_info['nobility_id'] > $lid) {
|
||
return ['code' => 201, 'msg' => '不能购买低等级会员', 'data' => null];
|
||
}
|
||
$map = [];
|
||
$map[] = ['lid', '=', $lid];
|
||
$nobility_info = db::name('nobility')->where($map)->find();
|
||
if(empty($nobility_info)){
|
||
return ['code' => 201, 'msg' => '购买爵位等级不存在', 'data' => null];
|
||
}
|
||
if($user_info['nobility_id'] == $lid) {
|
||
$pay_money = $nobility_info['renew_price'];
|
||
$give_integral = $nobility_info['renew_coin'];
|
||
$is_renew = 1;
|
||
} else {
|
||
$pay_money = $nobility_info['pay_price'];
|
||
$give_integral = $nobility_info['pay_coin'];
|
||
$is_renew = 2;
|
||
}
|
||
$type_params['pay_money'] = $pay_money;
|
||
$type_params['pay_coin'] = $give_integral;
|
||
$type_params['day_num'] = $nobility_info['day_num'];
|
||
$type_params['is_renew'] = $is_renew;
|
||
$type_params['lid'] = $lid;
|
||
}else{
|
||
return ['code' => 201, 'msg' => '会员卡类型不存在', 'data' => null];
|
||
}
|
||
|
||
|
||
|
||
$order_sn = $this->create_recharge_order_sn(4);
|
||
// $pay_money = 0.01;
|
||
$data = [];
|
||
$data['order_sn'] = $order_sn;
|
||
$data['order_type'] = 4;
|
||
$data['money'] = $pay_money;
|
||
$data['integral'] = $give_integral;
|
||
$data['pay_type'] = $pay_type;
|
||
$data['uid'] = $uid;
|
||
$data['pay_status'] = 1;
|
||
$data['pay_time'] = 0;
|
||
$data['remarke'] = '';
|
||
$data['add_time'] = time();
|
||
$data['update_time'] = time();
|
||
$data['type_params'] = json_encode($type_params);
|
||
$data['type_id'] = $lid;
|
||
$data['carry_money'] = $pay_money;
|
||
$data['is_carray_finish'] = 2;
|
||
|
||
$status = Db::name('user_recharge')->insert($data);
|
||
$data = [];
|
||
if ($status) {
|
||
// return $this->pay_notify_success($order_sn, $pay_money);
|
||
if ($pay_type == 1) {
|
||
// $data = $this->threePayFromPost($order_sn, $pay_money, 922);
|
||
$data = $this->alipayHand($order_sn, $pay_money);
|
||
} elseif($pay_type == 21){
|
||
// $data = model('api/AdaPay')->create_order($order_sn, $pay_money, $uid);
|
||
// if($data['code'] != 200){
|
||
// return ['code' => 201, 'msg' => '支付失败', 'data' => null];
|
||
// }
|
||
|
||
// $result = $data['result'];
|
||
// if(isset($result['status']) && ($result['status'] == "succeeded")){
|
||
// $payment_id = $result['id'];
|
||
// $map = [];
|
||
// $map[] = ['order_sn', '=', $order_sn];
|
||
// $order_info = Db::name('user_recharge')->where($map)->update(['payment_id'=>$payment_id]);
|
||
// }
|
||
|
||
$data = model('HuiFu1')->ali_h5($order_sn, $pay_money);
|
||
if(!empty($data['data']['qr_code'])){
|
||
return ['code' => 200, 'msg' => '请求成功', 'data' => ['pay_info'=>'alipays://platformapi/startapp?saId=10000007&qrcode='.$data['data']['qr_code']]];
|
||
// return ['code' => 200, 'msg' => '请求成功', 'data' => $data['data']];
|
||
}else{
|
||
return ['code' => 201, 'msg' => '支付失败', 'data' => null];
|
||
}
|
||
|
||
|
||
} else {
|
||
// $data = $this->threePayFromPost($order_sn, $pay_money, 921);
|
||
$data = $this->wxpayHand($order_sn, $pay_money);
|
||
}
|
||
}
|
||
return ['code' => 200, 'msg' => '请求成功', 'data' => $data['data']];
|
||
}
|
||
|
||
public function ada_ali_pay_notify($data, $sign)
|
||
{
|
||
// $data_str = json_encode($data,JSON_UNESCAPED_UNICODE);
|
||
// $data = array (
|
||
// 'created_time' => '1721980908',
|
||
// 'data' => '{"app_id":"app_260e8610-8ee2-498a-8fec-66fa866bb072","business_mode":"00","created_time":"20240726160148","description":"description","end_time":"20240726160351","expend":{"buyer_logon_id":"187****3623","cashPayAmt":"0.10","sub_open_id":"2088812171930646"},"fee_amt":"0.00","id":"002212024072616014810662820123835744256","order_no":"1721980920","out_trans_id":"2024072622001430641404087500","party_order_id":"02212407265770824408339","pay_amt":"0.10","pay_channel":"alipay","real_amt":"0.10","share_eq":"Y","status":"succeeded","trans_response_add_info":"{\\"fund_bill_list\\":[{\\"amount\\":\\"0.10\\",\\"fund_channel\\":\\"ALIPAYACCOUNT\\"}]}"}',
|
||
// 'prod_mode' => 'true',
|
||
// 'sign' => 'rvOfQUFTJf72dhYqQjplF9p7+jMvGYFfThJ/miFwOT2ATYc9h8Mexr8wh2ED2eetVTAeo7NLgpa+z3j0wgL8uLvC3DCUYTegZ5039nag58DVIXVEtpPrke16vlfDk7psA9xbau4BbXRVrTl9POrnhQqd+cq87hnsvj3wxd+c7o8=',
|
||
// 'id' => '002210662820643004702720',
|
||
// 'type' => 'payment.succeeded',
|
||
// 'app_id' => 'app_260e8610-8ee2-498a-8fec-66fa866bb072',
|
||
// 'object' => 'payment',
|
||
// );
|
||
|
||
$post_data = $data;
|
||
$data_str = json_encode($data,JSON_UNESCAPED_UNICODE);
|
||
$result = model('api/AdaPay')->verify_sign($data_str, $sign);
|
||
if($result['code'] != 200) {
|
||
exit('FAIL');
|
||
}
|
||
if($post_data['status'] == 'succeeded') {
|
||
$order_sn = $post_data['order_no'];
|
||
$pay_amount = $post_data['pay_amt'];
|
||
$data = $this->pay_notify_success($order_sn, $pay_amount);
|
||
if ($data['code'] == 200) {
|
||
exit('SUCCESS');
|
||
} else {
|
||
exit('FAIL');
|
||
}
|
||
}
|
||
exit('FAIL');
|
||
}
|
||
|
||
|
||
|
||
public function hui_fu_pay_notify($data)
|
||
{
|
||
|
||
if($data['resp_code'] == '00000000') {
|
||
$resp_data = $data['resp_data'];
|
||
$resp_data_arr = json_decode($resp_data, true);
|
||
$huifu_id = $resp_data_arr['huifu_id'];
|
||
$sign = $data['sign'];
|
||
$verify_sign = model('HuiFu1')->wx_verify_sign($resp_data, $sign, $huifu_id);
|
||
if(!$verify_sign) {
|
||
return '';
|
||
}
|
||
if($resp_data_arr['resp_code'] == '00000000' && $resp_data_arr['trans_stat'] == 'S') {
|
||
$pay_amount = bcmul($resp_data_arr['trans_amt'], 1, 2);
|
||
$order_sn = $resp_data_arr['mer_ord_id'];
|
||
$result = $this->pay_notify_success($order_sn, $pay_amount);
|
||
if($result['code'] == 200) {
|
||
exit("RECV_ORD_ID_" . $resp_data_arr['out_trans_id']) ;
|
||
}
|
||
}
|
||
|
||
|
||
}
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
}
|