123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390 |
- <?php
- namespace App\Http\Controllers\Api;
- use App\Components\Helpers;
- use App\Http\Controllers\Controller;
- use App\Http\Models\Goods;
- use App\Http\Models\GoodsLabel;
- use App\Http\Models\Order;
- use App\Http\Models\Payment;
- use App\Http\Models\PaymentCallback;
- use App\Http\Models\SsNode;
- use App\Http\Models\SsNodeLabel;
- use App\Http\Models\User;
- use App\Http\Models\UserLabel;
- use App\Mail\sendUserInfo;
- use DB;
- use Exception;
- use Hash;
- use Illuminate\Http\Request;
- use Log;
- use Mail;
- /**
- * 有赞云支付消息推送接收
- *
- * Class YzyController
- *
- * @package App\Http\Controllers
- */
- class YzyController extends Controller
- {
- protected static $systemConfig;
- function __construct()
- {
- self::$systemConfig = Helpers::systemConfig();
- }
- // 接收GET请求
- public function index(Request $request)
- {
- Log::info("【有赞云】回调接口[GET]:".var_export($request->all(), TRUE).'['.getClientIp().']');
- exit("【有赞云】接口正常");
- }
- // 接收POST请求
- public function store(Request $request)
- {
- Log::info("【有赞云】回调接口[POST]:".var_export($request->all(), TRUE));
- $json = file_get_contents('php://input');
- $data = json_decode($json, TRUE);
- if(!$data){
- Log::info('YZY-POST:回调数据无法解析,可能是非法请求['.getClientIp().']');
- exit();
- }
- // 判断消息是否合法
- $msg = $data['msg'];
- $sign_string = self::$systemConfig['youzan_client_id']."".$msg."".self::$systemConfig['youzan_client_secret'];
- $sign = md5($sign_string);
- if($sign != $data['sign']){
- Log::info('本地签名:'.$sign_string.' | 远程签名:'.$data['sign']);
- Log::info('YZY-POST:回调数据签名错误,可能是非法请求['.getClientIp().']');
- exit();
- }else{
- // 返回请求成功标识给有赞
- var_dump(["code" => 0, "msg" => "success"]);
- }
- // 容错
- if(!isset($data['kdt_name'])){
- Log::info("【有赞云】回调数据解析错误,请检查有赞支付设置是否与有赞控制台中的信息保持一致。如果还出现此提示,请执行一遍php artisan cache:clear命令");
- exit();
- }
- // 先写入回调日志
- $this->callbackLog($data['client_id'], $data['id'], $data['kdt_id'], $data['kdt_name'], $data['mode'], $data['msg'], $data['sendCount'], $data['sign'], $data['status'], $data['test'], $data['type'], $data['version']);
- // msg内容经过 urlencode 编码,进行解码
- $msg = json_decode(urldecode($msg), TRUE);
- switch($data['type']){
- case 'trade_TradePaid':
- $this->tradePaid($msg);
- break;
- case 'trade_TradeCreate':
- $this->tradeCreate($msg);
- break;
- case 'trade_TradeClose':
- $this->tradeClose($msg);
- break;
- case 'trade_TradeSuccess':
- $this->tradeSuccess($msg);
- break;
- case 'trade_TradePartlySellerShip':
- $this->tradePartlySellerShip($msg);
- break;
- case 'trade_TradeSellerShip':
- $this->tradeSellerShip($msg);
- break;
- case 'trade_TradeBuyerPay':
- $this->tradeBuyerPay($msg);
- break;
- case 'trade_TradeMemoModified':
- $this->tradeMemoModified($msg);
- break;
- default:
- Log::info('【有赞云】回调无法识别,可能是没有启用[交易消息V3]接口,请到有赞云控制台启用消息推送服务');
- exit();
- }
- exit();
- }
- // 交易支付
- private function tradePaid($msg)
- {
- Log::info('【有赞云】回调交易支付');
- $payment = Payment::query()->with(['order', 'order.goods'])->where('qr_id', $msg['qr_info']['qr_id'])->first();
- if(!$payment){
- Log::info('【有赞云】回调订单不存在');
- exit();
- }
- if($payment->status != '0'){
- Log::info('【有赞云】回调订单状态不正确');
- exit();
- }
- // 处理订单
- DB::beginTransaction();
- try{
- // 如果支付单中没有用户信息则创建一个用户
- if(!$payment->user_id){
- // 生成一个可用端口
- $port = self::$systemConfig['is_rand_port']? Helpers::getRandPort() : Helpers::getOnlyPort();
- $user = new User();
- $user->username = '自动生成-'.$payment->order->email;
- $user->password = Hash::make(makeRandStr());
- $user->port = $port;
- $user->passwd = makeRandStr();
- $user->vmess_id = createGuid();
- $user->enable = 1;
- $user->method = Helpers::getDefaultMethod();
- $user->protocol = Helpers::getDefaultProtocol();
- $user->obfs = Helpers::getDefaultObfs();
- $user->usage = 1;
- $user->transfer_enable = 1; // 新创建的账号给1,防止定时任务执行时发现u + d >= transfer_enable被判为流量超限而封禁
- $user->enable_time = date('Y-m-d');
- $user->expire_time = date('Y-m-d', strtotime("+".$payment->order->goods->days." days"));
- $user->reg_ip = getClientIp();
- $user->referral_uid = 0;
- $user->traffic_reset_day = 0;
- $user->status = 1;
- $user->save();
- if($user->id){
- Order::query()->where('oid', $payment->oid)->update(['user_id' => $user->id]);
- }
- }
- // 更新支付单
- $payment->pay_way = $msg['full_order_info']['order_info']['pay_type_str'] == 'WEIXIN_DAIXIAO'? 1 : 2; // 1-微信、2-支付宝
- $payment->status = 1;
- $payment->save();
- // 更新订单
- $order = Order::query()->with(['user'])->where('oid', $payment->oid)->first();
- $order->status = 2;
- $order->save();
- $goods = Goods::query()->where('id', $order->goods_id)->first();
- // 商品为流量或者套餐
- if($goods->type <= 2){
- // 如果买的是套餐,则先将之前购买的所有套餐置都无效,并扣掉之前所有套餐的流量,重置用户已用流量为0
- if($goods->type == 2){
- $existOrderList = Order::query()
- ->with(['goods'])
- ->whereHas('goods', function($q){
- $q->where('type', 2);
- })
- ->where('user_id', $order->user_id)
- ->where('oid', '<>', $order->oid)
- ->where('is_expire', 0)
- ->where('status', 2)
- ->get();
- foreach($existOrderList as $vo){
- Order::query()->where('oid', $vo->oid)->update(['is_expire' => 1]);
- // 先判断,防止手动扣减过流量的用户流量被扣成负数
- if($order->user->transfer_enable-$vo->goods->traffic*1048576 <= 0){
- // 写入用户流量变动记录
- Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, 0, 0, '[在线支付]用户购买套餐,先扣减之前套餐的流量(扣完)');
- User::query()->where('id', $order->user_id)->update(['u' => 0, 'd' => 0, 'transfer_enable' => 0]);
- }else{
- // 写入用户流量变动记录
- $user = User::query()->where('id', $order->user_id)->first(); // 重新取出user信息
- Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, ($user->transfer_enable-$vo->goods->traffic*1048576), '[在线支付]用户购买套餐,先扣减之前套餐的流量(未扣完)');
- User::query()->where('id', $order->user_id)->update(['u' => 0, 'd' => 0]);
- User::query()->where('id', $order->user_id)->decrement('transfer_enable', $vo->goods->traffic*1048576);
- }
- }
- }
- // 写入用户流量变动记录
- $user = User::query()->where('id', $order->user_id)->first(); // 重新取出user信息
- Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, ($user->transfer_enable+$goods->traffic*1048576), '[在线支付]用户购买商品,加上流量');
- // 计算账号过期时间
- if($order->user->expire_time < date('Y-m-d', strtotime("+".$goods->days." days"))){
- $expireTime = date('Y-m-d', strtotime("+".$goods->days." days"));
- }else{
- $expireTime = $order->user->expire_time;
- }
- // 把商品的流量加到账号上
- User::query()->where('id', $order->user_id)->increment('transfer_enable', $goods->traffic*1048576);
- // 套餐就改流量重置日,流量包不改
- if($goods->type == 2){
- User::query()->where('id', $order->user_id)->update(['traffic_reset_day' => date('d'), 'expire_time' => $expireTime, 'enable' => 1]);
- }else{
- User::query()->where('id', $order->user_id)->update(['expire_time' => $expireTime, 'enable' => 1]);
- }
- // 写入用户标签
- if($goods->label){
- // 用户默认标签
- $defaultLabels = [];
- if(self::$systemConfig['initial_labels_for_user']){
- $defaultLabels = explode(',', self::$systemConfig['initial_labels_for_user']);
- }
- // 取出现有的标签
- $userLabels = UserLabel::query()->where('user_id', $order->user_id)->pluck('label_id')->toArray();
- $goodsLabels = GoodsLabel::query()->where('goods_id', $order->goods_id)->pluck('label_id')->toArray();
- // 标签去重
- $newUserLabels = array_values(array_unique(array_merge($userLabels, $goodsLabels, $defaultLabels)));
- // 删除用户所有标签
- UserLabel::query()->where('user_id', $order->user_id)->delete();
- // 生成标签
- foreach($newUserLabels as $vo){
- $obj = new UserLabel();
- $obj->user_id = $order->user_id;
- $obj->label_id = $vo;
- $obj->save();
- }
- }
- // 写入返利日志
- if($order->user->referral_uid){
- $this->addReferralLog($order->user_id, $order->user->referral_uid, $order->oid, $order->amount, $order->amount*self::$systemConfig['referral_percent']);
- }
- // 取消重复返利
- User::query()->where('id', $order->user_id)->update(['referral_uid' => 0]);
- }elseif($goods->type == 3){ // 商品为在线充值
- User::query()->where('id', $order->user_id)->increment('balance', $goods->price*100);
- // 余额变动记录日志
- $this->addUserBalanceLog($order->user_id, $order->oid, $order->user->balance, $order->user->balance+$goods->price, $goods->price, '用户在线充值');
- }
- // 自动提号机:如果order的email值不为空
- if($order->email){
- $title = '自动发送账号信息';
- $content = [
- 'order_sn' => $order->order_sn,
- 'goods_name' => $order->goods->name,
- 'goods_traffic' => flowAutoShow($order->goods->traffic*1048576),
- 'port' => $order->user->port,
- 'passwd' => $order->user->passwd,
- 'method' => $order->user->method,
- //'protocol' => $order->user->protocol,
- //'protocol_param' => $order->user->protocol_param,
- //'obfs' => $order->user->obfs,
- //'obfs_param' => $order->user->obfs_param,
- 'created_at' => $order->created_at->toDateTimeString(),
- 'expire_at' => $order->expire_at
- ];
- // 获取可用节点列表
- $labels = UserLabel::query()->where('user_id', $order->user_id)->get()->pluck('label_id');
- $nodeIds = SsNodeLabel::query()->whereIn('label_id', $labels)->get()->pluck('node_id');
- $nodeList = SsNode::query()->whereIn('id', $nodeIds)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get()->toArray();
- $content['serverList'] = $nodeList;
- $logId = Helpers::addEmailLog($order->email, $title, json_encode($content));
- Mail::to($order->email)->send(new sendUserInfo($logId, $content));
- }
- DB::commit();
- } catch(Exception $e){
- DB::rollBack();
- Log::info('【有赞云】回调更新支付单和订单异常:'.$e->getMessage());
- }
- exit();
- }
- // 创建交易
- private function tradeCreate($msg)
- {
- Log::info('【有赞云】回调创建交易');
- exit();
- }
- // 关闭交易(无视,系统自带15分钟自动关闭未支付订单的定时任务)
- private function tradeClose($msg)
- {
- Log::info('【有赞云】回调关闭交易');
- exit();
- }
- // 交易成功
- private function tradeSuccess($msg)
- {
- Log::info('【有赞云】回调交易成功');
- exit();
- }
- // 卖家部分发货
- private function tradePartlySellerShip($msg)
- {
- Log::info('【有赞云】回调卖家部分发货');
- exit();
- }
- // 卖家发货
- private function tradeSellerShip($msg)
- {
- Log::info('【有赞云】回调卖家发货');
- exit();
- }
- // 买家付款
- private function tradeBuyerPay($msg)
- {
- Log::info('【有赞云】回调买家付款');
- exit();
- }
- // 卖家修改交易备注
- private function tradeMemoModified($msg)
- {
- Log::info('【有赞云】回调卖家修改交易备注');
- exit();
- }
- public function show(Request $request)
- {
- exit('show');
- }
- // 写入回调请求日志
- private function callbackLog($client_id, $yz_id, $kdt_id, $kdt_name, $mode, $msg, $sendCount, $sign, $status, $test, $type, $version)
- {
- $obj = new PaymentCallback();
- $obj->client_id = $client_id;
- $obj->yz_id = $yz_id;
- $obj->kdt_id = $kdt_id;
- $obj->kdt_name = $kdt_name;
- $obj->mode = $mode;
- $obj->msg = urldecode($msg);
- $obj->sendCount = $sendCount;
- $obj->sign = $sign;
- $obj->status = $status;
- $obj->test = $test;
- $obj->type = $type;
- $obj->version = $version;
- $obj->save();
- return $obj->id;
- }
- }
|