<?php

namespace app\controller;

use think\Request;
use think\facade\View;
use app\model\User;
use app\model\Order;
use app\model\PayAccount;
use app\model\PayChannel;

class PayController
{
    // 提交订单
    public function submit(Request $request)
    {
        $req_method = $request->method();
        $req_data = match ($req_method) {
            'GET' => $request->get(),
            'POST' => $request->post(),
            default => []
        };
        if (!$req_data) return '参数错误';
        // 验证签名
        $key = User::where('pid', $req_data['pid'])->where('state', 1)->value('secret_key');
        if (!$key) return '用户禁用或不存在';
        $sign_str = self::getSign($req_data, $key);
        if ($req_data['sign'] !== $sign_str) return '签名错误';
        // 检查商户订单
        $out_trade_no = Order::where('out_trade_no', $req_data['out_trade_no'])->value('out_trade_no');
        if ($out_trade_no) return '订单提交重复';
        // 创建新订单
        $order_info = Order::createOrder($req_data);
        if ($order_info['code'] !== 0) return $order_info['msg'];
        return redirect("/Pay/console/{$order_info['data']['order_id']}");
    }
    // api提交订单
    public function mapi(Request $request)
    {
        if (!$request->isPost()) return json(backMsg(0, '请求方式错误'));
        $req_data = $request->post();
        if (!$req_data) $req_data = $request->get();
        if (!$req_data) return json(backMsg(0, '参数错误'));
        // 验证签名
        $key = User::where('pid', $req_data['pid'])->where('state', 1)->value('secret_key');
        if (!$key) return json(backMsg(0, '用户禁用或不存在'));
        $sign_str = self::getSign($req_data, $key);
        if ($req_data['sign'] !== $sign_str) return json(backMsg(0, '签名错误'));
        // 检查商户订单
        $out_trade_no = Order::where('out_trade_no', $req_data['out_trade_no'])->value('out_trade_no');
        if ($out_trade_no) return json(backMsg(0, '订单提交重复'));
        // 创建新订单
        $order_info = Order::createOrder($req_data);
        if ($order_info['code'] !== 0) return json(backMsg(0, $order_info['msg']));
        $payurl = $request->domain() . "/Pay/console/{$order_info['data']['order_id']}";
        $info = ['code' => 1, 'msg' => '订单创建成功', 'trade_no' => $order_info['data']['order_id'], 'payurl' => $payurl];
        return json($info);
    }
    // 收银台
    public function console($order_id = '')
    {
        if ($order_id) {
            $act_order = Order::where('order_id', $order_id)->find();
            if ($act_order) {
                $channel = PayChannel::where('id', $act_order->cid)->find();
                View::assign($act_order->toArray());
                $passtime = strtotime($act_order->close_time) - time();
                View::assign('passtime', $passtime > 0 ? $passtime : 0);
                // Alipay免输
                if (preg_match('/^alipay4#\d+$/', $channel->channel)) {
                    $payurl = \payclient\AliPayf::getPayUrl($act_order->order_id, $act_order->money, $channel->qrcode);
                    View::assign('payUrl', $payurl['data'] ?? $payurl['msg']);
                } else {
                    View::assign('payUrl', $channel->qrcode);
                }
                View::assign('code_type', $channel->type);
                return View::fetch();
            } else {
                return '订单不存在';
            }
        } else {
            return '订单号参数错误';
        }
    }
    // 查询订单状态
    public function getOrderState($order_id = '')
    {
        if ($order_id) {
            $act_order = Order::where('order_id', $order_id)->find();
            if ($act_order) {
                $passtime = strtotime($act_order->close_time) - time();
                $data = [];
                if ($act_order->state === 0) {
                    $data['order_id'] = $act_order->order_id;
                    $data['passtime'] = $passtime > 0 ? $passtime : 0;
                    $data['state'] = $act_order->state;
                    return json($data);
                } elseif ($act_order->state === 1) {
                    // 通知参数
                    $notify = self::crateNotify($act_order);
                    // 字符串签名
                    $user_key = User::where('pid', $act_order->pid)->value('secret_key');
                    $sign = self::getSign($notify, $user_key);
                    $notify['sign'] = $sign;
                    // 跳转通知URL
                    $res_return_url = $act_order->return_url . '?' . http_build_query($notify);
                    if (strpos($act_order->return_url, '?')) $res_return_url = $act_order->return_url . '&' . http_build_query($notify);
                    // 响应消息
                    $data['order_id'] = $act_order->order_id;
                    $data['passtime'] = $passtime > 0 ? $passtime : 0;
                    $data['state'] = $act_order->state;
                    $data['return_url'] = $res_return_url;
                    return json($data);
                }
            } else {
                return '订单不存在';
            }
        } else {
            return '订单号参数错误';
        }
    }
    // 验证支付结果
    public function validatePayResult(Request $request)
    {
        $data = $request->post();
        $order = Order::find($data['id']);
        if (\strtotime($order->close_time) < \time()) {
            return \json(\backMsg(1, '订单已关闭'));
        }
        $up_data = ['id' => $data['id'], 'patt' => $data['patt']];
        $up_res = Order::update($up_data);
        if ($up_res) {
            return \json(\backMsg(0, '更新成功'));
        } else {
            return \json(\backMsg(1, '更新失败'));
        }
    }
    // 处理收款通知
    private function payHeart(array $records, array $config)
    {
        $pid = $config['pid'];
        $aid = $config['aid'];
        // 检测收款通知
        if (!$records) {
            return json(['code' => 0, 'msg' => '空收款通知']);
        }
        // 当前用户账号
        $query = ['pid' => $pid, 'aid' => $aid];
        // 排除已支付订单
        $doneOrders = Order::scope('dealOrder')->where($query)->column('platform_order');
        $new_orders = [];
        foreach ($records as $order) {
            if (!in_array($order['order_no'], $doneOrders)) $new_orders[] = $order;
        }
        if (!count($new_orders)) return json(['code' => 0, 'msg' => '收款通知无新消息']);
        // 有效订单列表
        $activeOrders = Order::scope('activeOrder')->where($query)->select();
        if (!count($activeOrders)) return json(['code' => 0, 'msg' => '数据库无有效期订单']);
        // 查找所有支付渠道
        $channels = $activeOrders->column('cid');
        $cids = PayChannel::whereIn('id', $channels)->column('channel', 'id');
        // 订单处理
        $notify = [];
        foreach ($new_orders as $new_order) {
            foreach ($activeOrders as $order) {
                // 支付方式核对
                $is_payway = $order->type == $new_order['payway'];
                if ($new_order['payway'] == '') $is_payway = true;
                // 支付渠道核对
                $is_channel = $cids[$order->cid] == $new_order['channel'];
                // 金额核对
                $is_money = $order->really_price == $new_order['price'];
                // 订单核对
                if ($is_payway && $is_channel && $is_money) {
                    // 是否免输
                    if (isset($new_order['remark'])) {
                        if ($new_order['remark'] == $order->order_id) {
                            $res = $this->updateOrderState($order, $new_order['order_no']);
                            $notify[] = $res;
                        }
                    } else {
                        $res = $this->updateOrderState($order, $new_order['order_no']);
                        $notify[] = $res;
                    }
                }
            }
        }
        if (!$notify) $notify = ['code' => 0, 'msg' => '收款通知无匹配订单'];
        return json($notify);
    }
    // 修改订单状态并通知
    private function updateOrderState(Order $order, string $order_no = ''): array
    {
        // 支付成功
        $set_order_state = $order->save(['state' => 1, 'pay_time' => date('Y-m-d H:i:s', time()), 'platform_order' => $order_no]);
        if (!$set_order_state) {
            return ['order' => $order->order_id, 'code' => 0, 'msg' => '修改订单状态失败'];
        }
        // 订单成交通知
        $notify = self::crateNotify($order);
        // 字符串签名
        $user_key = User::where('pid', $order->pid)->value('secret_key');
        $sign = self::getSign($notify, $user_key);
        $notify['sign'] = $sign;
        // 异步通知
        $notify_url = $order->notify_url . '?' . http_build_query($notify);
        if (strpos($order->notify_url, '?')) $notify_url = $order->notify_url . '&' . http_build_query($notify);
        $res_notify = self::getHttpResponse($notify_url);
        if ($res_notify === 'success') {
            return ['order' => $order->order_id, 'code' => 1, 'msg' => 'notify success'];
        } else {
            return ['order' => $order->order_id, 'code' => 0, 'msg' => 'notify fail'];
        }
    }
    // [定时任务]获取收款明细，提交收款通知
    public function checkPayResult(Request $request)
    {
        $req_info = $request->get();
        $req_pid = $req_info['pid'];
        $req_aid = $req_info['aid'];
        // 获取订单
        $new_order = cache('order');
        if (!$new_order) return json(['code' => 3, 'msg' => '没有找到新订单缓存']);
        // 检测新订单
        if ($new_order['code'] !== 1) return json($new_order);
        // 订单列表
        $order_list = $new_order['orders'];
        // 检测本账号订单
        $orders = [];
        foreach ($order_list as $key => $val) {
            if ($req_pid == $val['pid'] && $req_aid == $val['aid'] && $val['patt'] == 1) {
                $orders[] = $order_list[$key];
            }
        }
        if (!$orders) return json(['code' => 0, 'msg' => '非本账号订单或监听模式不对']);
        // 加载配置文件
        $config = PayAccount::getAccountConfig($req_aid);
        if ($config === false) return json(['code' => 4, 'msg' => '监听收款配置错误']);
        // 登陆账号
        $pay_config = ['username' => $config['account'], 'password' => $config['password']];
        // 配置参数
        $params = $config['params'];
        // 实例监听客户端
        $payclient_name = $config['payclass'];
        // 插件类文件是否存在
        $payclient_path = root_path() . '/extend/payclient/' . $payclient_name . '.php';
        if (!file_exists($payclient_path)) return json(['code' => 5, 'msg' => '监听客户端文件不存在']);
        $payclient_path = "\\payclient\\{$payclient_name}";
        $Payclient = new $payclient_path($pay_config);
        // 获取支付明细
        $records = $Payclient->getOrderInfo($params);
        if ($records['code'] === 0) {
            // 提交收款记录
            $upres = $this->payHeart($records['data'], $config);
            return $upres;
        } else {
            return json(['code' => 0, 'msg' => $records['msg']], 320);
        }
    }
    // [定时任务]监听新订单,生成缓存
    public function checkOrder($pid = '', $sign = '')
    {
        if (!($pid && $sign)) return '参数错误';
        $is_user = User::checkUser($pid, $sign);
        if ($is_user) {
            $orders = Order::scope('activeOrder')->field('id,pid,aid,cid,patt')->select();
            $old_info = cache('order');
            $num = count($orders);
            if ($num > 0) {
                $info = ['code' => 1, 'msg' => "有{$num}个新订单"];
                $order_list = ['code' => 1, 'msg' => "有{$num}个新订单", 'orders' => $orders];
                if ($old_info !== $order_list) {
                    cache('order', $order_list);
                }
                return json($info);
            } else {
                $info = ['code' => 0, 'msg' => '没有新订单'];
                if ($old_info !== $info) {
                    cache('order', $info);
                }
                return json($info);
            }
        } else {
            $info = ['code' => 2, 'msg' => '签名错误'];
            return json($info);
        }
    }
    // 处理微信/支付宝收款通知
    public function mpayNotify(Request $request)
    {
        $info = $request->post();
        $action = isset($info['action']) ? $info['action'] : '';
        if ($action !== 'mpay' && $action !== 'mpaypc') return '非mpay的访问请求';
        $data = json_decode($info['data'], true);
        if (!is_array($data)) return '通知数据为空';
        if (!isset($data['aid']) || !isset($data['pid'])) return 'aid和pid参数错误';
        $config = PayAccount::getAccountConfig($data['aid'], $data['pid']);
        $payclient_path = "\\payclient\\{$config['payclass']}";
        $Payclient = new $payclient_path($info, $config);
        if ($action == 'mpay') $res = $Payclient->notify();
        if ($action == 'mpaypc') $res = $Payclient->pcNotify();
        if ($res['code'] !== 0) return $res['msg'];
        $this->payHeart($res['data'], $config);
        return 200;
    }
    // 签名
    private static function getSign(array $param = [], string $key = ''): string
    {
        ksort($param);
        reset($param);
        $signstr = '';
        foreach ($param as $k => $v) {
            if ($k != "sign" && $k != "sign_type" && $v != '') {
                $signstr .= $k . '=' . $v . '&';
            }
        }
        $signstr = substr($signstr, 0, -1);
        $signstr .= $key;
        $sign = md5($signstr);
        return $sign;
    }
    // 构建通知
    private static function crateNotify($param): array
    {
        $notify = [
            'pid' => $param->pid,
            'trade_no' => $param->order_id,
            'out_trade_no' => $param->out_trade_no,
            'type' => $param->type,
            'name' => $param->name,
            'money' => $param->money,
            'trade_status' => 'TRADE_SUCCESS',
            'sign_type' => 'MD5',
        ];
        // 添加扩展参数
        // $notify = array_merge($notify, unserialize($param->param));
        $notify['param'] = unserialize($param->param);
        // 删除空值
        foreach ($notify as $key => $val) {
            if ($val === '') unset($notify[$key]);
        }
        return $notify;
    }
    // 请求外部资源
    private static function getHttpResponse($url, $header = [], $post = null, $timeout = 10)
    {
        $ch = curl_init($url);
        curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        if ($header) {
            curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        } else {
            $httpheader[] = "Accept: */*";
            $httpheader[] = "Accept-Language: zh-CN,zh;q=0.8";
            $httpheader[] = "Connection: close";
            curl_setopt($ch, CURLOPT_HTTPHEADER, $httpheader);
        }
        curl_setopt($ch, CURLOPT_HEADER, false);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        if ($post) {
            curl_setopt($ch, CURLOPT_POST, true);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $post);
        }
        $response = curl_exec($ch);
        curl_close($ch);
        return $response;
    }
}