<?php

namespace Shopping;

use LibModels\Web\Home\OrderData;
use LibModels\Web\Product\PayData;
use Plugin\Helpers;
use WebPlugin\Pay\Banks;
use WebPlugin\Pay\PayFactory;
use WebPlugin\Pay\Reqparams;
use WebPlugin\Pay\Rspparams;
use WebPlugin\Pay\weixin\lib\WxPayApi;
use WebPlugin\Pay\weixin\lib\WxPayConfig;
use WebPlugin\Pay\weixin\lib\WxPayNativePay;
use WebPlugin\Pay\weixin\lib\WxPayOrderQuery;
use WebPlugin\Pay\weixin\lib\WxPayUnifiedOrder;
use WebPlugin\PhpLog;

/**
 * 支付有关方法
 *
 * @package Shopping
 * @author Gtskk
 * @copyright 2016/3/22 14:19 Gtskk<iamgtskk@gmail.com>
 * @version: 0.0.1
 */
class PayModel
{
    // 日志等级，2表示记录信息等级的日志
    const LOG_LEVEL = 2;
    // 支付方式有关接口调用日志
    const PAYMENT_LIST_LOG = '/Data/logs/pc_pay/payment_list';
    // 向ERP提交订单状态有关接口调用日志和更新订单状态有关接口调用日志
    const ORDER_STATUS_LOG = '/Data/logs/pc_pay/order_status';
    // 获取或者更新订单支付银行的接口调用日志
    const ORDER_BANK_LOG = '/Data/logs/pc_pay/order_bank';
    // 根据用户UID获取订单数有关接口调用日志
    const ORDER_COUNT_LOG = '/Data/logs/pc_pay/order_count';
    // 发送短信有关接口调用日志
    const SEND_MESSAGE_LOG = '/Data/logs/pc_pay/send_message';

    // 是否老用户订单数判断值
    const OLD_USER_LIMIT = 1;

    /**
     * 获取支付方式选择页面有关信息
     *
     * @param int $uid 用户ID
     * @param string $orderCode 订单号
     * @return array
     */
    public static function getPayTypeData($uid, $orderCode)
    {
        $result = array();

        do {
            // 订单详情
            $orderDetail = OrderData::getOrderDetail($uid, $orderCode);
            if (!$orderDetail || empty($orderDetail['data'])) {
                $result['noOrder'] = true;
                break;
            }

            $order = $orderDetail['data'];
            $result['orderNum'] = $orderCode;
            $result['count'] = $order['payment_amount'];
            $result['paymentType'] = ($order['payment_type'] == 1 ? '在线支付' : '货到付款');
            // 订单商品（用于订单统计）
            $result['orderGoods'] = $order['order_goods'];

            //统计成交的skn
            $sknList = array();
            $skuList = array();
            $goodsData = array();
            $pinyouGoodsArr = array();
            foreach ($order['order_goods'] as $val) {
                $sknList[] = $val['product_skn'];
                $skuList[] = $val['product_sku'];
                $goodsData[] = array(
                    'goods_name' => $val['product_name'],
                    'product_sku' => $val['product_sku'],
                    'price' => $val['goods_price'],
                    'number' => $val['buy_number']
                );
                $pinyouGoodsArr[] = $val['product_skn'] . ',' . $val['buy_number'];//pinyou统计改为skn
            }
            $result['goodsData'] = $goodsData;
            // skn列表
            $result['sknList'] = implode(',', $sknList);
            // sku列表
            $result['skuList'] = implode(',', $skuList);
            // 品友统计需要的商品数据
            $result['pinyouGoods'] = implode(';', $pinyouGoodsArr);

            // 货到付款的情况
            if ($order['payment_type'] == 2) {
                $result['finish'] = true;
                // 有货币
                $result['yohoCoin'] = $order['yoho_give_coin'];
                // 订单详情链接地址
                $result['checkOrderUrl'] = Helpers::url('/home/orders/detail', array('orderCode' => $orderCode));
                // 有货币地址
                $result['yohoCoinUrl'] = Helpers::url('/help', array('category_id' => 87));
                // vip地址
                $result['vipUrl'] = Helpers::url('/help', array('category_id' => 91));
                // 订单中心地址
                $result['ordersUrl'] = Helpers::url('/home/orders');
                // 退换货地址
                $result['backGoodsUrl'] = Helpers::url('/help', array('category_id' => 121));
                // 返回首页地址
                $result['returnHomeUrl'] = Helpers::url('/');
                break;
            }

            $result['deliveryType'] =isset($order['delivery_time']) ? $order['delivery_time'] : '';

            // 用户ID
            $result['uid'] = $uid;

            // 初始化日志
            $log = new PhpLog(self::PAYMENT_LIST_LOG, 'PRC', self::LOG_LEVEL);
            // 获取支付途径列表
            $log->LogInfo('===开始调用支付方式列表接口,接口方法为web.SpaceOrders.getPaymentList===');
            $payTypes = PayData::getPaymentList();
            $log->LogInfo('===结束调用支付方式列表接口,返回结果为===');
            $log->LogInfo(var_export($payTypes, true));

            $defaultPayType = 0;
            $types = array();
            if (isset($payTypes['data']) && !empty($payTypes['data'])) {
                $oneType = array();

                foreach ($payTypes['data'] as $key => $payType) {
                    if (empty($payType['payIcon'])) { // 排除图标不存在的支付方式
                        continue;
                    }

                    // 获取第一个支付方式
                    if ($key === 0) {
                        $defaultPayType = $payType['id'];
                    }

                    $oneType = array();
                    $oneType['name'] = $payType['payName'];
                    $oneType['ico'] = $payType['payIcon'];

                    $types[$payType['id']] = $oneType;
                }
                $result['list'] = self::procPayType($types);
            }

            // 获取银行列表
            $result['entry'] = self::procPayType(Banks::getList(), true);

            // 无需付款
            if (isset($order["payment_amount"]) && $order["payment_amount"] == 0) {
                // 初始化日志
                $log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
                $log->LogInfo('===[' . $orderCode . ']===');

                // ERP提交订单状态
                $log->LogInfo('===开始调用ERP提交订单状态接口,接口方法为web.SpaceOrders.submitOrderStatus===');
                $log->LogInfo('===请求参数为orderCode=' . $orderCode . '===');
                $erpReturn = PayData::submitOrderStatus($orderCode, 0, '', '', 0, '', '', '');
                $log->LogInfo('===结束调用ERP提交订单状态接口,返回结果为===');
                $log->LogInfo(var_export($erpReturn, true));

                // 更新订单的状态
                $log->LogInfo('===开始调用更新订单状态接口,接口方法为web.SpaceOrders.updatePaymentStatus===');
                $log->LogInfo('===请求参数为orderId=' . $order['order_id'] . 'uid=' . $uid . '===');
                $updateOrderStatus = PayData::updateOrderStatus($order['order_id'], $uid, 0, 'Y', '');
                $log->LogInfo('===结束调用更新订单状态接口,返回结果为===');
                $log->LogInfo(var_export($updateOrderStatus, true));

                $result['notNeedPay'] = true;
                break;
            }

            // 记录支付方式
            // 初始化日志
            $log = new PhpLog(self::ORDER_BANK_LOG, 'PRC', self::LOG_LEVEL);
            $log->LogInfo('===开始调用记录支付方式接口,接口方法为web.SpaceOrders.getOrderPayBank===');
            $log->LogInfo('===请求参数为orderCode=' . $orderCode . '===');
            $bankRecord = PayData::getBankByOrder($orderCode);
            $log->LogInfo('===结束调用记录支付方式接口,返回结果为===');
            $log->LogInfo(var_export($bankRecord, true));

            if (isset($bankRecord['data']['bankCode']) && !empty($bankRecord['data']['bankCode'])) {
                $payRecord = $bankRecord['data']['bankCode'];
            } else {
                $payCode = $order['payment'] ?: $defaultPayType;
                //记录app上的支付方式
                $changeCodes = array(
                    19 => 21,// app上微信支付
                    22 => 21,// h5微信支付
                    18 => $defaultPayType// h5支付宝支付
                );
                $platformCode = isset($changeCodes[$payCode]) && $changeCodes[$payCode] ? $changeCodes[$payCode] : $payCode;
                $platformCodeList = array_keys($types);
                $payRecord = in_array($platformCode, $platformCodeList) ? $platformCode : $defaultPayType;
            }
            $result['payRecord'] = $payRecord;

            // 已完成付款的链接地址
            $result['ordersUrl'] = Helpers::url('/home/orders');
            // 支付地址
            $result['payUrl'] = Helpers::url('/pay/index/index');

            // 是否是老用户（用于订单统计）
            $orderCount = 0;
            // 初始化日志
            $log = new PhpLog(self::ORDER_COUNT_LOG, 'PRC', self::LOG_LEVEL);
            $log->LogInfo('===开始调用查询用户订单数接口,接口方法为web.SpaceOrders.getOrderCountByUid===');
            $orders = PayData::getOrderCountByUid($uid);
            $log->LogInfo('===结束调用查询用户订单数接口,返回结果为===');
            $log->LogInfo(var_export($orders, true));

            if (isset($orders['data']) && !empty($orders['data'])) {
                $orderCount = $orders['data']['total'];
            }
            $result['isOldUser'] = (intval($orderCount) > self::OLD_USER_LIMIT) ? true : false;
            // 订单数（用于订单统计）
            $result['orderCount'] = $orderCount;
            $result['is_advance'] = $order['attribute'] == 5 ? 'Y' : 'N';
            // 订单商品数（用于订单统计）
            $result['ordersGoodsNums'] = count($order['order_goods']);
        } while (false);

        return $result;
    }

    /**
     * 处理支付类型数据
     *
     * @param array $pays 支付方式数据
     * @param bool $isBank 是否是银行数据
     * @return array
     */
    private static function procPayType($pays, $isBank = false)
    {
        $result = array();

        $onePay = array();
        foreach ($pays as $code => $pay) {
            $onePay = array();
            $onePay['dataId'] = $code;
            $onePay['dataVal'] = $isBank ? '12_' . $code : $code . '_platform';
            $onePay['idNum'] = $code;
            $onePay['ico'] = $pay['ico'];
            $onePay['name'] = $pay['name'];
            $onePay['imgId'] = $onePay['dataVal'];

            $result[] = $onePay;
        }

        return $result;
    }


    /**
     * 获取支付有关信息
     *
     * @param int $uid 用户ID
     * @param string $orderCode 订单号
     * @param string $paymentType 支付方式
     * @param string $userName 用户名
     * @param string $alipayToken 支付宝用户token
     * @return array
     */
    public static function getPayData($uid, $orderCode, $paymentType, $userName, $alipayToken)
    {
        $result = array();

        do {
            /* 判断是否有订单号参数 */
            if (empty($orderCode)) {
                $result['error'] = true;
                $result['message'] = '订单号不能为空';
                break;
            }

            /* 判断支付方式是否选择 */
            $paymentPars = explode('_', $paymentType);
            if (count($paymentPars) != 2) {
                $result['error'] = true;
                $result['message'] = '请选择一个支付方式';
                break;
            }

            /* 判断订单信息是否存在 */
            $orderDetail = OrderData::getOrderDetail($uid, $orderCode);
            if (empty($orderDetail['data'])) {
                $result['error'] = true;
                $result['message'] = '没有找到该订单';
                break;
            }

            /* 判断订单是否已取消 */
            if (isset($orderDetail['data']['is_cancel']) && $orderDetail['data']['is_cancel'] === 'Y') {
                $result['error'] = true;
                $result['message'] = '订单已经取消';
                $result['location'] = 'window.location="' . Helpers::url('/home/orders/detail', array('order_code' => $orderCode)) . '";';
                break;
            }

            // 获取支付有关参数
            $payId = $paymentPars[0];
            $paymentParams = self::getPaymentById($payId);
            if (empty($paymentParams)) {
                $result['error'] = true;
                $result['message'] = '支付系统繁忙，请稍后再试';
                break;
            }

            $payService = PayFactory::factory($paymentParams);
            if ($payService == false) { // 没找到支付方式时
                $result['error'] = true;
                $result['message'] = '请选择一个支付方式';
                break;
            }

            $totalFee = $orderDetail['data']['payment_amount'] * 100;
            $isTest = (APPLICATION_ENV === 'developer' || APPLICATION_ENV === 'testing');
            $paymentParameter = $paymentPars[1];
            // 判断是否传入支付宝token
            if ($paymentType == 2 && !empty($alipayToken)) {

                $paymentParameter = $alipayToken;
            }

            $reqParams = new Reqparams($orderCode, $totalFee, '有货订单号:' . $orderCode, '', $orderDetail['data']['create_time'], $paymentParameter, $isTest, $uid, $userName);
            $reqPars = $payService->getPayRequestPars($reqParams);
            if (empty($reqPars)) {
                $result['error'] = true;
                $result['message'] = '支付系统繁忙，请稍后再试';
                break;
            }

            // 记录并更新订单支付方式
            $paymentRecod = OrderData::updateOrderPayment($orderCode, $payId, $uid);
            if (empty($paymentRecod) || $paymentRecod['code'] != 200) {
                $result['error'] = true;
                $result['message'] = '系统繁忙，请稍后再试';
                break;
            }
            $bankRecord = PayData::getBankByOrder($orderCode);
            $bankCode = ($paymentParameter != 'platform' ? $paymentParameter : '');
            if (isset($bankRecord['data']['bankCode']) && !empty($bankRecord['data']['bankCode'])) {
                $bankPayRecord = PayData::updateOrderPayBank($orderCode, $payId, $bankCode);
            } else {
                $bankPayRecord = PayData::setOrderPayBank($orderCode, $payId, $bankCode);
            }
            if (!isset($bankPayRecord['code']) || $bankPayRecord['code'] != 200) {
                $result['error'] = true;
                $result['message'] = '支付方式记录失败';
                break;
            }

            if ($reqPars['reqType'] == 'get') {
                //直接跳转到支付界面
                $result['go'] = true;
                $result['payUrl'] = $reqPars['pay_url'] . '?' . $reqPars['pars'];
            } else {
                //如果是post，去form提交
                $result = array('reqPars' => $reqPars);
            }
        } while (false);

        return $result;
    }

    /**
     * 根据支付ID获取支付相关参数
     *
     * @param int $payId 支付ID
     * @return array
     */
    public static function getPaymentById($payId)
    {
        $result = array();

        $paymentParams = PayData::getPaymentById($payId);
        if (isset($paymentParams['data']) && !empty($paymentParams['data'])) {
            $result = array(
                'id' => $payId,
                'pay_code' => $paymentParams['data']['payCode'],
                'pay_params' => isset($paymentParams['data']['payParams']) ? $paymentParams['data']['payParams'] : ''
            );
        }

        return $result;
    }


    /**
     * 处理微信支付
     *
     * @param int $uid 用户ID
     * @param string $orderCode 订单号
     * @return array
     */
    public static function weixinQrcode($uid, $orderCode)
    {
        $result = array();

        do {
            // 初始化日志
            $log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
            $log->LogInfo('=====[' . $orderCode . ']===开始生成微信支付二维码========');

            if (empty($orderCode)) {
                $log->LogInfo('=====[' . $orderCode . ']===微信支付时，订单号为空========');
                $result['error'] = true;
                $result['message'] = '订单号不能为空';
                break;
            }

            /* 判断订单信息是否存在 */
            $orderDetail = OrderData::getOrderDetail($uid, $orderCode);
            if (!isset($orderDetail['data']) || empty($orderDetail['data'])) {
                $log->LogInfo('=====[' . $orderCode . ']===微信支付时，订单信息未查到========');
                $result['error'] = true;
                $result['message'] = '没有找到该订单';
                break;
            }

            /*$wechatqrcode = new Service(array('id' => $paymentCode));
            $reqPars = $wechatqrcode->pay(array('order_code'=>$orderCode));
            if (empty($reqPars)) {
                $result['error'] = true;
                $result['message'] = '支付系统繁忙，请稍后再试';
                break;
            }*/

            //统一下单
            $totalFee = strval($orderDetail['data']['payment_amount'] * 100);
            $input = new WxPayUnifiedOrder();
            $input->SetBody('有货订单号:' . $orderCode);
            $input->SetOut_trade_no('YOHOBuy_' . $orderCode); // 商户订单号
            $input->SetTotal_fee($totalFee);
            $input->SetTime_start(date("YmdHis"));
            $input->SetTime_expire(date("YmdHis", time() + 600));
            $input->SetNotify_url(WxPayConfig::NOTIFY_URL);
            $input->SetTrade_type("NATIVE");
            $input->SetProduct_id($orderCode);
            $notify = new WxPayNativePay();
            $payResult = $notify->GetPayUrl($input);
            $log->LogInfo('=====[' . $orderCode . ']===微信支付时，微信统一下单的返回结果为：========');
            $log->LogInfo(var_export($payResult, true));

            $orderData = $orderDetail['data'];
            $firstGoods = current($orderData['order_goods']);
            $result = array(
                'orderNum' => $orderData['order_code'],
                'amount' => $orderData['payment_amount'],
                'address' => $orderData['address'],
                'name' => $orderData['user_name'],
                'tellphoneNum' => $orderData['mobile'],
                'tradeName' => $firstGoods['product_name'],
                'choosePayUrl' => Helpers::url('/shopping/pay', array('order_code' => $orderData['order_code'])),
                'qrcodeUrl' => $payResult['code_url'] // 'http://paysdk.weixin.qq.com/example/qrcode.php?data=' . $result['code_url']
            );

        } while (false);
        $log->LogInfo('=====[' . $orderCode . ']===微信支付时，处理微信支付的结果为：========');
        $log->LogInfo(var_export($result, true));

        return $result;
    }

    /**
     * 检查微信扫码支付结果
     *
     * @param int $uid 用户ID
     * @param int $orderCode 订单号
     * @return array 订单支付结果
     */
    public static function checkWechatPayStatus($uid, $orderCode)
    {
        $result = array(
            'code' => '400',
            'message' => 'fail'
        );

        do {
            if (empty($uid) || empty($orderCode)) {
                break;
            }

            // 初始化日志
            $log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
            $log->LogInfo('=====[' . $orderCode . ']===开始查询微信扫码支付状态========');

            // 组装微信支付的订单号
            $tradeNo = 'YOHOBuy_' . $orderCode;
            $input = new WxPayOrderQuery();
            $input->SetOut_trade_no($tradeNo);
            $payResult = WxPayApi::orderQuery($input);
            $log->LogInfo(var_export($payResult, true));

            if (isset($payResult['trade_state']) && $payResult['trade_state'] === 'SUCCESS') {
                $log->LogInfo('====[' . $orderCode . ']====微信扫码支付成功========');
                $result = array(
                    'code' => '200',
                    'message' => 'success'
                );
            }

            $log->LogInfo('====[' . $orderCode . ']====微信扫码支付失败========');
        } while (false);

        return $result;
    }

    /**
     * 订单支付后处理后续数据
     *
     * @param int $uid 用户ID
     * @param Rspparams $payResult 支付之后返回的结果
     * @param int $payment 支付方式ID
     * @return array
     */
    public static function procOrderData($uid, $payResult, $payment)
    {
        $result = array(
            'code' => 500,
            'message' => '支付失败'
        );

        do {
            // 初始化日志
            $log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
            $log->LogInfo('========[' . $payResult->orderCode . ']========');
            $log->LogInfo(var_export($payResult, true));

            $log->LogInfo('==[' . $payResult->orderCode . ']=开始调用获取订单详情方式接口,接口方法为app.SpaceOrders.detail===');
            $orderInfo = OrderData::getOrderDetail($uid, $payResult->orderCode);
            $log->LogInfo('==[' . $payResult->orderCode . ']=结束调用获取订单详情方式接口,返回结果为===');
            $log->LogInfo(var_export($orderInfo, true));

            if (!isset($orderInfo['data']) || empty($orderInfo['data'])) {
                $log->LogInfo('==[' . $payResult->orderCode . ']=订单支付失败，未获取到订单详情信息===');
                break;
            }

            $orderData = $orderInfo['data'];
            $orderCode = $orderData['order_code'];
            $paymentStatus = $orderData['payment_status'];
            $amount = $orderData['payment_amount'];

            // 订单已取消
            if ($orderData['is_cancel'] === 'Y' && $paymentStatus === 'N') {
                // 给用户发送短信
                // 初始化日志
                $log = new PhpLog(self::SEND_MESSAGE_LOG, 'PRC', self::LOG_LEVEL);
                $log->LogInfo('===[' . $orderCode . ']===');
                $log->LogInfo('==[' . $orderCode . ']=开始调用订单取消时给用户发短信接口,接口方法为app.message.sendMsg===');
                $messageReturn = PayData::sendMessage($orderData['mobile'], 'error_sms', '支付成功,但订单已取消，订单号为' . $orderCode);
                $log->LogInfo('==[' . $orderCode . ']=结束调用给用户发短信接口,返回结果为===');
                $log->LogInfo(var_export($messageReturn, true));

                $result['code'] = 417;
                $result['message'] = '支付成功，但订单已取消，需联系客服';
                break;
            }

            // 支付金额与订单金额不一致
            if (round($amount, 2) != round($payResult->totalFee, 2)) {
                $log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
                $log->LogInfo('==[' . $orderCode . ']=订单支付失败，支付金额与订单金额不一致===');
                $result['code'] = 415;
                $result['message'] = '支付金额与订单金额不一致';
                break;
            }

            //记录交易号和支付订单号（如果有银行流水号会记录银行流水号）
            $payOrderCode = $payResult->payOrderCode ? $payResult->payOrderCode : "";
            $tradeNo = $payResult->tradeNo ? $payResult->tradeNo : "";
            $bankBillNo = $payResult->bankBillNo ? $payResult->bankBillNo : "";
            $bankName = $payResult->bankName;
            $bankCode = $payResult->bankCode;

            // 初始化日志
            $log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
            $log->LogInfo('===[' . $orderCode . ']===');

            $log->LogInfo('==[' . $orderCode . ']=开始调用ERP提交订单状态接口,接口方法为web.SpaceOrders.submitOrderStatus===');
            $log->LogInfo('==[' . $orderCode . ']=请求参数为orderCode=' . $orderCode . '===');
            // ERP提交订单状态
            $erpReturn = PayData::submitOrderStatus($orderCode, $payment, $bankName, $bankCode, $amount, $payOrderCode, $tradeNo, $bankBillNo);
            $log->LogInfo('==[' . $orderCode . ']=结束调用ERP提交订单状态接口,返回结果为===');
            $log->LogInfo(var_export($erpReturn, true));

            $log->LogInfo('==[' . $orderCode . ']=开始调用更新订单状态接口,接口方法为web.SpaceOrders.updatePaymentStatus===');
            $log->LogInfo('==[' . $orderCode . ']=请求参数为orderId=' . $orderData['order_id'] . 'uid=' . $uid . '===');
            // 更新订单的状态
            $updateOrderStatus = PayData::updateOrderStatus($orderData['order_id'], $uid, $payment, 'Y', $bankCode);
            $log->LogInfo('==[' . $orderCode . ']=结束调用更新订单状态接口,返回结果为===');
            $log->LogInfo(var_export($updateOrderStatus, true));
            $log->LogInfo('==[' . $orderCode . ']=订单支付成功，请等待发货===');

            $result['code'] = 200;
            $result['message'] = '支付成功，请等待发货';
            $result['data'] = array(
                'pay' => $amount,
                'orderNum' => $orderData['order_code'],
                'items' => $orderData['order_goods'], // 订单商品
                'checkOrderUrl' => Helpers::url('/home/orders/detail', array('orderCode' => $orderData['order_code'])),
                'payMode' => ($orderData['payment_type'] == 1 ? '在线支付' : '货到付款'),
                'currency' => $orderData['yoho_give_coin'],
                'yohoCoinUrl' => Helpers::url('/help', array('category_id' => 87)),
                'ordersUrl' => Helpers::url('/home/orders'),
                'returnGoodsUrl' => Helpers::url('/help', array('category_id' => 121)),
                'vipSum' => $amount,
                'vipUrl' => Helpers::url('/help', array('category_id' => 91)),
                'returnHomeUrl' => Helpers::url('/')
            );
        } while (false);

        return $result;
    }
}