<?php

namespace app\api\controller;

use app\admin\model\PayMember;
use app\admin\model\ToBalance;
use app\common\controller\Api;
use EasyWeChat\Factory;
use function GuzzleHttp\Promise\inspect;
use think\Db;
use app\admin\model\User;
use think\Log;
use fast\Http;
use think\Validate;
use Exception;
use function EasyWeChat\Kernel\Support\generate_sign;
/**
 * 支付接口
 */
class Pay extends Api
{
    protected  $noNeedLogin = ['payMemberNotify','paySecurityNotify','payOrderNotify'];
    protected $noNeedRight = ['*'];
    protected $uid = '';//token存贮uid
    protected $order_status = [];//订单状态
    public function _initialize()
    {
        parent::_initialize();
        $this->uid = $this->auth->getUserId();
    }

    /**
     * @ApiTitle    (充值/支付订单)
     * @ApiSummary  (充值支付)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/pay/pay)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="openid", type="string", required=true, description="小程序openid")
     * @ApiParams   (name="num", type="inter", required=false, description="支付订单号")
     *
     */
    public function pay(){
        if($this->request->isPost()){
            $openid = $this->request->post('openid');
            $order_sn = $this->request->post('num');

            if(empty($openid)){
                $this->error(['code'=>2,'msg'=>'openid不能为空']);
            }
            if($order_sn){
                //支付订单
                $res = Db::name('order')->where(['num'=>$order_sn,'uid'=>$this->uid])->find();
                if($res){
                    if($res['status'] == 2){
                        $this->error('该订单已支付过了');
                    }else{
                        //创建支付对象
                        $config = config('verify.wx_pay');
                        $app = Factory::payment($config);
                        $result = $app->order->unify([
                            'body' => '山东航拍',
                            'out_trade_no' => $order_sn,//支付订单号
                            'total_fee' => $money*100,//单位分
                            'notify_url' => $notify_url, // 支付结果通知网址，如果不设置则会使用配置里的默认地址
                            'trade_type' => 'JSAPI', // 请对应换成你的支付方式对应的值类型
                            'openid' => $openid,
                        ]);
                        if($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS'){
                            $params = [
                                'appId'     => $config['app_id'],
                                'timeStamp' => time(),
                                'nonceStr'  => $result['nonce_str'], // 统一下单返回的随机字符串
                                'package'   => 'prepay_id='.$result['prepay_id'], // 统一下单Id
                                'signType'  => 'MD5', // 签名方法
                            ];
                            // 注意这里用的是商户平台的Key进行二次签名
                            $params['paySign'] = generate_sign($params, $config['key']);
                            $this->success('成功',$params);
                        }
                        $this->error($result['err_code_des']);
                    }
                }else{
                    $this->error('无效的订单');
                }
            }
        }else{
            $this->error('请求方式错误');
        }
    }

    //购买会员回调通知（无需调用）
    public function payMemberNotify(){
        $config = config('verify.wx_pay');
        $app = Factory::payment($config);
        Log::info('会员');
        $response = $app->handlePaidNotify(function($message, $fail){
            //return_code 表示通信状态
            Log::info($message);
            if ($message['return_code'] === 'SUCCESS') {

                if ($message['result_code'] === 'SUCCESS') {
                    //支付成功
                    //更新成为会员
                    $userModel = new User();
                    $userModel->where('openid',$message['openid'])->update(['member'=>1]);
                    //增加记录
                    $payMemberModel = new PayMember();
                    $payMemberModel->create(['openid'=>$message['openid'],'pay_order'=>$message['out_trade_no']]);
                }elseif($message['result_code'] === 'FAIL') {
                    //支付失败
                }
            } else {
                return $fail('通信失败，请稍后再通知我');
            }
            return true; // 返回处理完成
        });
        $response->send();
    }

    //支付订单（无需调用）
    public function payOrderNotify(){
        $config = config('verify.wx_pay');
        $app = Factory::payment($config);
        $response = $app->handlePaidNotify(function($message, $fail){
            //return_code 表示通信状态
            if ($message['return_code'] === 'SUCCESS') {

                if ($message['result_code'] === 'SUCCESS') {
                    //支付成功，更新订单状态
                    $orderModel = new \app\admin\model\Order();
                    $orderModel->where(['order_sn'=>$message['out_trade_no']])->update(['status'=>1]);

                    //创建订房记录
                    $this->auth->createHouseRecord($message['out_trade_no']);

                }elseif($message['result_code'] === 'FAIL') {
                    //支付失败
                }
            } else {
                return $fail('通信失败，请稍后再通知我');
            }
            return true; // 返回处理完成
        });
        $response->send();
    }


    /**
     * @ApiTitle    (更新订单号（支付订单失败后调用）)
     * @ApiSummary  (更新订单号（支付订单失败后调用）)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/pay/updateOrder)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="order_sn", type="inter", required=false, description="支付订单号")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "成功",
        "time": "1571812329",
        "data": null
    })
     */
    public function updateOrder(){
        if($this->request->isPost()){
            $order_sn = $this->request->post('order_sn');

            $rule = config('verify.order_sn');
            $validate = new Validate($rule['rule'],$rule['msg']);
            if (!$validate->check(['order_sn'=>$order_sn])) {
                $this->error($validate->getError());
            }

            $orderModel = new \app\admin\model\Order();
            $pay_order = $this->auth->genPayOrderSn('pay');//支付订单号
            $res = $orderModel->where(['order_sn'=>$order_sn,'uid'=>$this->uid])->update(['order_sn'=>$pay_order]);
            if($res){
                $this->success('成功');
            }else{
                $this->error('失败');
            }
        }else{
            $this->error('请求方式错误');
        }
    }

    /**
     * @ApiTitle    (提现到微信零钱)
     * @ApiSummary  (提现到微信零钱)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/pay/payBalance)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="openid", type="string", required=true, description="小程序openid")
     * @ApiParams   (name="price", type="inter", required=true, description="提现金额")
     */
    public function payBalance(){
        if($this->request->isPost()){
            $price = $this->request->post('price');
            $openid = $this->request->post('openid');

            $rule = config('verify.to_balance');
            $validate = new Validate($rule['rule'],$rule['msg']);
            if (!$validate->check(['price'=>$price,'openid'=>$openid])) {
                $this->error($validate->getError());
            }

            if($price < 0.3){
                $this->error('提现金额不能低于0.3元');
            }

            //每天提现次数不超过三次
            $count = Db::name('to_balance')->where('uid',$this->uid)->whereTime('createtime','today')->count();
            if($count >= 3){
                $this->error('每天提现次数不能超过3次');
            }
            //查询该用户钱包金额
            $userModel = new User();
            $user = $userModel->where(['id'=>$this->uid])->field('id,money,nickname')->find();
            if($price > $user['money']){
                $this->error('钱包金额不足');
            }

            //创建支付对象
            $config = config('verify.wx_pay');
            $app = Factory::payment($config);
            $balance_order = $this->auth->genPayOrderSn('balance');//提现单号
            $result = $app->transfer->toBalance([
                'partner_trade_no' => $balance_order, // 商户订单号，需保持唯一性(只能是字母或者数字，不能包含有符号)
                'openid' => $openid,
                'check_name' => 'NO_CHECK', // NO_CHECK：不校验真实姓名, FORCE_CHECK：强校验真实姓名
                're_user_name' => '', // 如果 check_name 设置为FORCE_CHECK，则必填用户真实姓名
                'amount' => $price*100, // 企业付款金额，单位为分
                'desc' => '提现到零钱', // 企业付款操作说明信息。必填
            ]);
            if($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS'){
                //创建提现记录
                $balanceRecordModel = new ToBalance();
                $data['uid'] = $this->uid;
                $data['openid'] = $openid;
                $data['price'] = $price;
                $data['to_order'] = $result['partner_trade_no'];
                $balanceRecordModel->create($data);
                //更新余额表
                $userModel = new User();
                $userModel->where(['id'=>$this->uid])->setDec('money',$price);
                $this->success('成功');
            }
            $this->error($result['err_code_des']);
        }else{
            $this->error('请求方式错误');
        }
    }
}