<?php

namespace app\api\controller;

use app\common\controller\Api;
use fast\Random;
use think\Config;
use WeChat\Exceptions\InvalidResponseException;
use WeChat\Exceptions\LocalCacheException;
use WeMini\Newtmpl;


/**
 * 订单接口
 */
class Order extends Api
{
    protected $noNeedLogin = ['notify','order_over'];
    protected $noNeedRight = '*';
    protected $config;

    public function _initialize()
    {
        parent::_initialize();
        $this->config = Config::get('weChat');
    }


    /**
     * 获得产品
     *
     * @ApiTitle    (获得产品)
     * @ApiSummary  (创建订单并支付)
     * @ApiMethod   (POST)
     * * @ApiParams   (name="course_id", type="string", required=false, description="课程id")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturnParams   (name="data", type="object", sample="{'prepay_id':'123','options':{},'order':{}}", description="扩展数据返回")
     * @ApiReturn   ({'code':'1','msg':'返回成功'})
     */
    public function get_product(){

        $where = [];
        $course_id = $this->request->request('course_id');
        if(!empty($course_id)){
            $product = new \app\admin\model\Product();
            $product = $product->where($where)->order('weigh','desc')->select();
            $productCourse = new \app\admin\model\ProductCoures();
            $return = [];
            foreach ($product as $K){
                $course = $productCourse->where(['product_id'=>$K['id']])->select();
                if(empty($course)){
                    $return[] = $K;
                }
                $course = $productCourse->where(['product_id'=>$K['id'],'course_id'=>$course_id])->select();
                if(!empty($course)){
                    $return[] = $K;
                }
            }
        }else{
            $product = new \app\admin\model\Product();
            $return = $product->where($where)->order('weigh','desc')->select();
        }


        $this->success('请求成功',$return);
    }


    /**
     * 创建订单并支付
     *
     * @ApiTitle    (创建订单并支付)
     * @ApiSummary  (创建订单并支付)
     * @ApiMethod   (POST)
     * @ApiParams   (name="user_id", type="string", required=true, description="会员ID")
     * @ApiParams   (name="product_id", type="string", required=true, description="产品ID")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturnParams   (name="data", type="object", sample="{'prepay_id':'123','options':{},'order':{}}", description="扩展数据返回")
     * @ApiReturn   ({'code':'1','msg':'返回成功'})
     */
    public function createOrder()
    {
        $user_id = $this->request->request('user_id');
        $product_id = $this->request->request('product_id');

        if (!$user_id) {
            $this->error(__('Invalid parameters'));
        }
        if (!$product_id) {
            $this->error(__('Invalid parameters'));
        }

        $product = new \app\admin\model\Product();
        $product = $product->where(['id'=>$product_id])->find();
        if(empty($product)){
            $this->error(__('Invalid product'));
        }
        $product = $product->toArray();

        $productCourse = new \app\admin\model\ProductCoures();
        $productCourse = $productCourse->where(['product_id'=>$product_id])->select();
        $product['product_course'] = $productCourse;

        $user = new \app\admin\model\User();
        $user = $user->where(['id'=>$user_id])->find();
        if(empty($user)){
            $this->error(__('Invalid user'));
        }
        $user = $user->toArray();

        $order_id = Random::uuid();
        $order_id = str_replace("-","",$order_id);

        //发起支付
        $weChat = \WeChat\Pay::instance($this->config);
        $options = [
            'body'             => '维克猩球-'.$product['name'],
            'out_trade_no'     => $order_id,
            'total_fee'        => $product['price']*100,
            'openid'           => $user['openid'],
            'trade_type'       => 'JSAPI',
            'notify_url'       => $this->config['notify_url'],
            'spbill_create_ip' => $_SERVER['SERVER_ADDR'],
        ];
        // 生成预支付码
        $result = $weChat->createOrder($options);
        if($result['result_code'] != 'SUCCESS'){
            $this->error(__('failed to create weChat order'));
        }
        // 创建JSAPI参数签名
        $options = $weChat->createParamsForJsApi($result['prepay_id']);


        $now = date('Y-m-d H:i:s');
        $data['product_id'] = $product_id;
        $data['user_id'] = $user_id;
        $data['order_id'] = $order_id;
        $data['status'] = 'create';
        $data['product_doc'] = json_encode($product);
        $data['total'] = $product['price'];
        $data['create_time'] = $now;
        $data['third_order_id'] = '';
        $data['count'] = $product['count'];
        $data['remain'] = ($product['count'] == -1)?999999:$product['count'];
        $data['start'] = $now;
        $data['end'] = date('Y-m-d H:i:s',strtotime('+'.$product['dateCount'].' day',strtotime($now)));
        $data['success_time'] = '';
        $data['notify'] = false;

        $order = new \app\admin\model\Order();
        $order = $order->insertGetId($data);

        $return['order'] = $order;
        $return['options'] = $options;
        $return['prepay_id'] = $result['prepay_id'];

        $this->success('ok',$return);
    }

    /**
     * 支付回调
     */
    public function notify(){

        $wechat = \WeChat\Pay::instance($this->config);

        $data = $wechat->getNotify();

        if ($data['return_code'] === 'SUCCESS' && $data['result_code'] === 'SUCCESS') {

            $order_no = $data['out_trade_no'];
            $order = new \app\admin\model\Order();
            $order = $order->where(['order_id'=>$order_no])->find();
            if(empty($order)){
               exit;
            }
            $order = $order->toArray();
            if((int)($order['total']*100) != $data['total_fee']){
                exit;
            }


            $user = new \app\admin\model\User();
            $user->save(['status' => 'normal'], ['id' => $order['user_id']]);

            $order1 = new \app\admin\model\Order();
            $order1->save([
                'status'         => 'success',
                'success_time'   => date('Y-m-d H:i:s'),
                'third_order_id' => $data['transaction_id']
            ], ['id' => $order['id']]);

            // 返回接收成功的回复
            ob_clean();
            echo $wechat->getNotifySuccessReply();
        }

    }


    /**
     * 订单结束推送
     *
     * @ApiTitle    (订单结束推送)
     * @ApiSummary  (订单结束推送)
     * @ApiMethod   (GET)
     *
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturnParams   (name="data", type="object", sample="{'prepay_id':'123','options':{},'order':{}}", description="扩展数据返回")
     * @ApiReturn   ({'code':'1','msg':'返回成功'})
     */
    public function order_over(){

        $template = new Newtmpl(Config::get('weChat'));
        $order = new \app\admin\model\Order();
        $order = $order->where(['status'=>'success','end'=>['<',date('Y-m-d H:i:s'), 'notify'=> false]])->with('user')->select();
        $notice = new \app\admin\model\UserNotice();
        foreach ($order as $k){

            $order = new \app\admin\model\Order();
            $order->save(['status'=>'over','notify'=>true],['id'=>$k['id']]);

            $insert = [
                'user_id'    => $k['id'],
                'type'       => 'order_over',
                'content_id' => $k['id'],
                'time'       => date('Y-m-d H:i:s'),
            ];
            $notice->insert($insert);

            //小程序通知
            $data = [
                'touser' => $k['user']['openid'],
                'template_id' => config('weChat.order_over_tmp'),
                'form_id'=> $k['id'],
                'page'=>'pages/classReserve/classReserve',
                'data'=>[
                    "thing1" => ["value" => "维克猩球"],
                    "number2" => ["value" => "0"],
                    "name3" => ["value" => $k['user']['nickname']],
                ],
            ];
            try {
                $template->send($data);
            } catch (InvalidResponseException $e) {
            } catch (LocalCacheException $e) {

            }

        }

        $this->success();
    }

}