363 lines
14 KiB
PHP
363 lines
14 KiB
PHP
<?php
|
||
|
||
namespace App\Http\Controllers\Web;
|
||
|
||
use App\Models\Gateway;
|
||
use App\Models\GatewayWind;
|
||
use App\Models\Good;
|
||
use App\Models\Merchant;
|
||
use App\Models\MerchantCommission;
|
||
use App\Models\MerchantMoneyLog;
|
||
use App\Models\MerchantOrder;
|
||
use App\Models\MerchantRatio;
|
||
use App\Models\MerchantRegist;
|
||
use App\Models\MerchantWallet;
|
||
use App\ServicePay\ApiOrderServices;
|
||
use App\ServicePay\LocalOrderServices;
|
||
use App\ServicePay\MerchantOrderServices;
|
||
use Illuminate\Http\Request;
|
||
use Illuminate\Support\Facades\Log;
|
||
use DB;
|
||
use Yansongda\Pay\Pay;
|
||
|
||
class MerchantController extends BaseController
|
||
{
|
||
|
||
public $order;
|
||
public $pay_method;
|
||
public $gateway_id;
|
||
public $gateway, $pay_gateway, $pay_config, $pay_model;
|
||
public $log_name = 'merchant_order_';
|
||
|
||
public function index($type, $id)
|
||
{
|
||
//取得商户注册模型
|
||
$regist = MerchantRegist::find($id);
|
||
$data = [
|
||
'title' => '开通商户',
|
||
'model_type' => $type,
|
||
'model_id' => $id,
|
||
'regist' => $regist,
|
||
'order_sn' => order_sn(),
|
||
'money' => $regist->money
|
||
];
|
||
//dump($data);
|
||
|
||
if (is_mobile_client()) {
|
||
$this->setViewPath('', 'mindex');
|
||
}
|
||
return $this->display($data);
|
||
}
|
||
|
||
public function pay(Request $request)
|
||
{
|
||
//发起支付
|
||
$pay = new MerchantOrderServices();
|
||
return $pay->order($request);
|
||
}
|
||
|
||
public function notify($type, $method, Request $request)
|
||
{
|
||
switch ($method) {
|
||
case 'return':
|
||
//return abort(403, '请查看之前的页面');
|
||
return view('web.merchant.checkshow', ['order_sn' => $request->input('out_trade_no')]);
|
||
break;
|
||
case 'notify':
|
||
|
||
|
||
$order_sn = $request->input('out_trade_no');
|
||
$this->debugLog('商户推广订单号-------' . $order_sn . '----------开始回调');
|
||
$this->debugLog('回调数据'.json_encode($request->all()));
|
||
//异步回调
|
||
//取得这个订单号，然后验证签名
|
||
$this->order = MerchantOrder::where('order_sn', $order_sn)->first();
|
||
|
||
$this->pay_method = $this->order->gateway_method;//支付方法
|
||
$this->gateway_id = $this->order->gateway_id;//通道ID
|
||
//取得通道信息，数组形式
|
||
$this->gateway = $this->pay_gateway = config('gateway.config')[$this->gateway_id];
|
||
$config = [
|
||
'app_id' => $this->pay_gateway['app_id'],
|
||
'ali_public_key' => trim($this->pay_gateway['cert_pub']),
|
||
'private_key' => trim($this->pay_gateway['cert_key']),
|
||
];
|
||
$extend_config = [
|
||
'log' => [ // optional
|
||
'file' => to_linux_path(base_path()) . '/paylogs/' . $type . '_pay.log',
|
||
'level' => 'info', // 建议生产环境等级调整为 info，开发环境为 debug
|
||
'type' => 'daily', // optional, 可选 daily.
|
||
'max_file' => 30, // optional, 当 type 为 daily 时有效，默认 30 天
|
||
],
|
||
'return_url' => action('Pay\PayController@returnNotify', ['type' => $type]),
|
||
'notify_url' => action('Pay\PayController@notify', ['type' => $type]),
|
||
'http' => [ // optional
|
||
'timeout' => 5.0,
|
||
'connect_timeout' => 5.0,
|
||
// 更多配置项请参考 [Guzzle](https://guzzle-cn.readthedocs.io/zh_CN/latest/request-options.html)
|
||
],
|
||
|
||
];
|
||
if ($this->pay_gateway['is_dev'] == 1) {
|
||
$extend_config['mode'] = 'dev';//沙箱
|
||
}
|
||
$this->pay_config = $extend_config + $config;
|
||
$this->pay_model = Pay::alipay($this->pay_config);
|
||
$data = $this->pay_model->verify();
|
||
|
||
$this->debugLog('签名的数据',$data->toArray());
|
||
if (empty($data)) {
|
||
$this->debugLog('验证签名失败');
|
||
return false;
|
||
}
|
||
// dump($data->trade_status);
|
||
if (!in_array($data->trade_status, ['TRADE_SUCCESS', 'TRADE_FINISHED'])) {
|
||
|
||
$this->debugLog('支付宝订单关闭，未支付');
|
||
return false;
|
||
exit();//终止
|
||
}
|
||
$result = [
|
||
'order_sn' => $data->out_trade_no,
|
||
'pay_order_sn' => $data->trade_no,
|
||
'pay_money' => $data->total_amount,
|
||
'pay_type' => 'alipay',
|
||
'account' => $data->buyer_logon_id,
|
||
];
|
||
//更新订单
|
||
$order = $this->order;
|
||
//订单已经支付成功，直接success
|
||
|
||
if ($order->pay_status == 1) {
|
||
|
||
return $this->success();;
|
||
}
|
||
$this->debugLog('订单开始更新');
|
||
\Illuminate\Support\Facades\DB::beginTransaction();
|
||
//风控
|
||
$this->debugLog('写入风控');
|
||
$this->gategoryWind();
|
||
$this->debugLog('风控写入完成');
|
||
|
||
$order->pay_order_sn = $result['pay_order_sn'];//支付流水号
|
||
//开始更新订单数据
|
||
$order->pay_money = $result['pay_money'];//支付金额
|
||
$order->pay_status = 1;//支付成功
|
||
$order->status = 1;//订单交易成功
|
||
$order->notify_status = 1;//支付回调成功
|
||
$order_r = $order->save();
|
||
$this->debugLog('订单更新情况:' . $order_r);
|
||
|
||
//找到注册提交的数据
|
||
$regist = MerchantRegist::find($order->model_id);
|
||
|
||
//取得推广商户信息
|
||
$fid_model = Merchant::where('id', $regist->from_merchant_id)->where('is_checked', 1)->first();
|
||
|
||
//发起商户注册
|
||
$m_r = Merchant::create([
|
||
'from_regist' => 2,//推广注册
|
||
'email' => $regist->email,
|
||
'next_ratio' => $fid_model->ratio,
|
||
'origin_password' => $regist->password,
|
||
'password' => ($regist->password),
|
||
'name' => $regist->email,
|
||
'ip' => $request->getClientIp(),
|
||
'app_key' => date('YmdHis') . str_random(6),
|
||
'token' => str_random(32),
|
||
'draw_type' => 1,
|
||
'ratio' => $regist->ratio,
|
||
'from_id' => $regist->merchant_id,
|
||
'level' => $regist->level,
|
||
'qq' => $regist->qq,
|
||
'mobile' => $regist->mobile,
|
||
'skype' => $regist->skype
|
||
]);
|
||
//更新注册推广
|
||
$regist->pay_status = 1;
|
||
$regist->status = 1;
|
||
$regist->merchant_id = $m_r->id;//更新最后注册成功的商户id
|
||
$r_r = $regist->save();
|
||
|
||
$this->debugLog('写入商户关系线');
|
||
//商户新增的关联线
|
||
$rel_r = $this->updateMerchantRatio($m_r);
|
||
$this->debugLog('写入商户关系线完成');
|
||
|
||
$this->debugLog('写入资金变动');
|
||
|
||
$this->debugLog('模型'.$order->from_merchant_id);
|
||
//资金变动
|
||
try{
|
||
$mlog_r = MerchantMoneyLog::adRegistMerchantMoney($order, $order->merchant_money);
|
||
}catch (\Exception $exception)
|
||
{
|
||
$this->debugLog('资金问题'.$exception->getMessage().'---code'.$exception->getLine());
|
||
}
|
||
|
||
$this->debugLog('写入资金变动完成');
|
||
//商户钱包
|
||
//增加金额
|
||
$wallet_r = MerchantWallet::moneyIncr($order->from_merchant_id, $order->merchant_money, 'money');
|
||
$this->debugLog('写入资金钱包完成');
|
||
if ($r_r && $m_r && $rel_r && $wallet_r && $mlog_r) {
|
||
\Illuminate\Support\Facades\DB::commit();
|
||
$this->debugLog('--------END---------------' . $this->order->order_sn . '-订单交易更新完成------------------------');
|
||
} else {
|
||
$this->debugLog('各个情况如下', ['order_r' => $order_r, 'regist_r' => $r_r, 'rel_r' => $rel_r, 'merchant_r' => $m_r, 'wallter_r' => $wallet_r, 'mlog' => $mlog_r]);
|
||
$this->debugLog('--------END---------------' . $this->order->order_sn . '-订单交易更新失败------------------------');
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
public function debugLog($str = '', $arr = [])
|
||
{
|
||
|
||
$arr = is_array($arr) ? $arr : [$arr];
|
||
if ($this->log_name) {
|
||
Log::channel($this->log_name . 'notify_order')->info($str, $arr);
|
||
} else {
|
||
Log::channel('pay_order')->info($str, $arr);
|
||
}
|
||
|
||
}
|
||
|
||
protected function updateMerchantRatio($merchant)
|
||
{
|
||
//取得费率表信息
|
||
$ratio = MerchantRatio::where('merchant_id', $merchant->id)->where('is_self', 1)->first();
|
||
|
||
//判断上级是否有上级
|
||
$upObj = Merchant::find($merchant->from_id);
|
||
$hierarchy = 1;//默认1级，表示顶级
|
||
if ($upObj) {
|
||
|
||
if ($upObj->from_id != 0) {
|
||
$hierarchy = 3;
|
||
} else {
|
||
//没有上级，则只有2级别
|
||
$hierarchy = 2;
|
||
}
|
||
}
|
||
//层级不一样了，判断谁的层级高一点
|
||
//全部删除，重新添加
|
||
MerchantRatio::where('merchant_id', $merchant->id)->delete();
|
||
//重新添加
|
||
|
||
//判断层级
|
||
if ($hierarchy == 3) {
|
||
//3级关系级别
|
||
return MerchantRatio::addDefault($merchant->from_id, $merchant->id, $merchant->ratio);
|
||
} elseif ($hierarchy == 2) {
|
||
//代理级别
|
||
if ($merchant->level == 2) {
|
||
//代理级别
|
||
return MerchantRatio::addProxyLevel($merchant->from_id, $merchant->id, $merchant->ratio);
|
||
} else {
|
||
//商户级别
|
||
return MerchantRatio::add($merchant->from_id, $merchant->level, 2, $merchant->id, $merchant->ratio);
|
||
}
|
||
|
||
} elseif ($hierarchy == 1) {
|
||
//普通级别
|
||
return MerchantRatio::add(0, $merchant->level, 1, $merchant->id, $merchant->ratio);
|
||
}
|
||
|
||
}
|
||
|
||
//推广商户佣金写入
|
||
public function merchantCommission($data, $mid)
|
||
{
|
||
|
||
return MerchantCommission::getOrCreate($data, ['order_id' => $this->orderObj->id, 'merchant_id' => $mid]);
|
||
}
|
||
|
||
//成功完成异步回调返回给支付商
|
||
public function success()
|
||
{
|
||
$this->pay_model->success()->send();
|
||
}
|
||
|
||
//支付风控写入
|
||
public function gategoryWind()
|
||
{
|
||
$gateway_id = $this->gateway_id;// getOrder获得gateway_id
|
||
$money = $this->order['money'];
|
||
//风控
|
||
$obj = new GatewayWind();
|
||
$has = GatewayWind::where(['gateway_id' => $gateway_id, 'day' => date('Y-m-d')])->lockForUpdate()->first();
|
||
|
||
if ($has) {
|
||
|
||
$now_money = $money + $has->amount_total;
|
||
$has->increment('amount_total', $money);//增加金额
|
||
|
||
//判断金额是否大于最大的限额，如果是，则更新通道并且关闭
|
||
if ($now_money >= $has->max_total) {
|
||
//更新通道为关闭，并且时系统设置
|
||
Gateway::where('id', $gateway_id)->update(['is_checked' => 0, 'is_system_close' => 1]);
|
||
write_gateway();//写入文件
|
||
}
|
||
|
||
} else {
|
||
|
||
$obj->day = date('Y-m-d');
|
||
$obj->gateway_name = $this->pay_gateway['name'] . '(' . $this->pay_gateway['mch_id'] . ')';//通道
|
||
$obj->amount_total = $money;
|
||
$obj->gateway_id = $this->gateway_id;
|
||
$obj->save();
|
||
|
||
}
|
||
|
||
}
|
||
|
||
//检测订单是否完成
|
||
public function check(Request $request)
|
||
{
|
||
$order_sn = $request->input('order_sn');
|
||
$order = MerchantOrder::where('order_sn', $order_sn)->first();
|
||
|
||
if (empty($order)) {
|
||
$data = [
|
||
'error' => 1,
|
||
'msg' => '订单不存在'
|
||
];
|
||
return response()->json($data);
|
||
}
|
||
if ($order->pay_status == 1) {
|
||
//取得商户信息
|
||
$regist = MerchantRegist::find($order->model_id);
|
||
$admin_url = route('merchant.admin.login');
|
||
$mdata = [
|
||
'admin_url' => $admin_url,
|
||
'email' => $regist->email,
|
||
'password' => $regist->password,
|
||
'msg' => '<p>登录地址:' . $admin_url . '</p>' . '<p>账号:' . $regist->email . '</p>' . '<p>密码:' . $regist->password . '</p>请记住账号信息'
|
||
];
|
||
$data = [
|
||
'error' => 0,
|
||
'msg' => '订单支付完成',
|
||
'merchant' => $mdata
|
||
];
|
||
return response()->json($data);
|
||
} else {
|
||
$data = [
|
||
'error' => 1,
|
||
'msg' => '订单还没支付',
|
||
|
||
];
|
||
return response()->json($data);
|
||
}
|
||
}
|
||
|
||
public function checkShow(Request $request)
|
||
{
|
||
$order_sn = $request->input('order_sn');
|
||
return $this->display(['order_sn' => $order_sn]);
|
||
}
|
||
|
||
|
||
|
||
}
|