<?php
/**
 * sqc @小T科技 2018.06.07
 *
 *
 */
namespace App\Logic;

use App\Models\ShopGoods;
use App\Models\ShopOrder;
use Illuminate\Support\Facades\DB;
use EasyWeChat\Factory;
use Carbon\Carbon;
use function EasyWeChat\Kernel\Support\generate_sign;

class Buy
{

    /**
     * 会员信息id
     * @var string
     */
    private $_user_id = '';

    /**
     * 下单数据
     * @var array
     */
    private $_order_data = array();

    /**
     * 下单地区数据
     * @var array
     */
    private $_address_data = array();

    /**
     * 表单数据
     * @var array
     */
    private $_post_data = array();

    public function __construct()
    {
    }


    /**
     * 执行购买
     * @param int $user_id // 购买者
     * @param array $buydata // 购买的商品
     * @param array $address //收货地址
     * @param object $request // 表单数据
     * @return array
     */
    public function buyStep($request, $buy_info, $address, $user_id)
    {
        $this->_user_id = $user_id;
        $this->_order_data = $buy_info;
        $this->_post_data = $request;
        $this->_address_data = $address;
        try {
            DB::beginTransaction();
            //第1步 执行下单
            $order_info = $this->_createOrderStep1();
            return $order_info;
        } catch (\Exception $e) {
            DB::rollBack();
            return ['error' => $e->getMessage()];
        }

    }


    /**
     * 生成订单
     * @param array $input
     * @throws Exception
     * @return array array(支付单sn,订单列表)
     */
    private function _createOrderStep1()
    {
        $paycode = $this->makePaySn($this->_user_id);
        //订单数据
        $order_insert = array();
        $order_insert['order_sn'] = $this->makeOrderSn($paycode); // 订单编号
        $order_insert['uid'] = $this->_user_id;
        $order_insert['pay_name'] = '微信支付';// 目前只有微信支付
        $order_insert['pay_id'] = 1;// 目前只有微信支付
        $order_insert['order_status'] = ShopOrder::STATUS_WAIT_PAY;// 待支付
        $order_insert['shipping_status'] = ShopOrder::SHIPING_STATUS_WAIT_SEND;// 待发货
        $order_insert['pay_status'] = ShopOrder::PAY_WAIT;// 待支付下单
        $order_insert['actual_price'] = $this->_order_data['actualPrice'];// 订单实际要支付的金额
        $order_insert['order_price'] = $this->_order_data['orderTotalPrice'];// 订单总价
        $order_insert['goods_price'] = $this->_order_data['goodsTotalPrice'];// 商品总价
        $order_insert['freight_price'] = $this->_order_data['freightPrice'];// 配送费用
        $order_insert['coupon_id'] = $this->_order_data['checkedCouponId'];// 使用的优惠券id
        $order_insert['coupon_price'] = $this->_order_data['couponPrice'];// 优惠金额
        $order_insert['add_time'] = Carbon::now();// 订单生成时间

        // 收货地址
        $order_insert['country'] = $this->_address_data['country_id'];// 国家id 1 中国
        $order_insert['province'] = $this->_address_data['province_id'];// 省市id
        $order_insert['city'] = $this->_address_data['city_id'];// 城市id
        $order_insert['district'] = $this->_address_data['district_id'];// 区县、街道id
        $order_insert['address'] = $this->_address_data['address'];// 详细地址
        $order_insert['consignee'] = $this->_address_data['user_name'];// 收件人
        $order_insert['mobile'] = $this->_address_data['mobile'];// 收件人手机号

        //用户留言
        $order_insert['postscript'] = empty($this->_post_data->remark) ? '用户无留言' : $this->_post_data->remark;

        $order_goods_insert = array(); // 订单附表的数据

        // 执行插入
        $order_model = ShopOrder::create($order_insert);
        if (!$order_model->id) {
            throw new \Exception('订单保存失败[未生成支付单]');
        }
        foreach ($this->_order_data['checkedGoodsList'] as $k => $va) {
            if ($va['number']) {
                $order_goods_insert[] = [
                    'order_id' => $order_model->id,
                    'goods_id' => $va['goods_id'],
                    'goods_name' => $va['goods_name'],
                    'retail_price' => $va['retail_price'],
                    'market_price' => $va['market_price'],
                    'list_pic_url' => $va['list_pic_url'] ? $va['list_pic_url'] : '',
                    'number' => $va['number'],
                ];
                $re1 = $this->addSaleNum($va['goods_id'], $va['number']);
                if (!$re1) {
                    throw new \Exception('订单保存失败[商品库存不足]');
                }
            }
        }
        $order_goods_model = DB::table('shop_order_goods')->insert($order_goods_insert);
        // 清除购物车商品
        $cartRe = CartLogic::clearCart($this->_user_id);
        if ($order_goods_model) {
            DB::commit();
            return $order_model->toArray();
        } else {
            $this->pay_log('order_goods_insert.error' . var_export($order_goods_insert, true));
            throw new \Exception('订单商品保存失败');
        }
    }

    public function addSaleNum($id, $num = 1)
    {
        $goods = ShopGoods::lockForUpdate()->find($id);
        if (empty($goods) || $goods->goods_number < $num) {
            return false;
        }
        $goods->sell_volume = $goods->sell_volume + $num;
        $goods->goods_number = $goods->goods_number - $num;
        return $goods->save();
    }

    /**
     * 生成支付单编号(两位随机 + 从2000-01-01 00:00:00 到现在的秒数+微秒+会员ID%1000)，该值会传给第三方支付接口
     * 长度 =2位 + 10位 + 3位 + 3位  = 18位
     * 1000个会员同一微秒提订单，重复机率为1/100
     * @return string
     */
    public function makePaySn($member_id)
    {
        return mt_rand(10, 99)
        . sprintf('%010d', time() - 946656000)
        . sprintf('%03d', (float)microtime() * 1000)
        . sprintf('%03d', (int)$member_id % 1000);
    }

    /**
     * 订单编号生成规则
     * 生成订单编号(年取1位 + $pay_id取13位 + 第N个子订单取2位)
     * 1000个会员同一微秒提订单，重复机率为1/100
     * @param $pay_sn
     * @return string
     */
    public function makeOrderSn($pay_sn)
    {
        //记录生成子订单的个数，如果生成多个子订单，该值会累加
        static $num;
        if (empty($num)) {
            $num = 1;
        } else {
            $num++;
        }
        return (date('y', time()) % 9 + 1) . sprintf('%013d', $pay_sn) . sprintf('%02d', $num);
    }


    // 支付第一步
    public function pay_step1($attributes, $openid)
    {
        $time = time();
        $app = Factory::payment(config('wechat.payment.default'));
        $result = $app->order->unify([
            'body' => '小T商城',
            'detail' => '小T商城的订单',
            'out_trade_no' => $attributes['order_sn'],
            'total_fee' => $attributes['actual_price'] * 100,
            'trade_type' => 'JSAPI',
            'openid' => $openid,
        ]);
        $this->pay_log('order:' . var_export($attributes, true) . '  result:' . var_export($result, true));
        if ($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS') {
            // 如果成功生成统一下单的订单，那么进行二次签名 二次签名的参数必须与下面相同
            $params = [
                'appId' => config('wechat.payment.default.app_id'),
                'timeStamp' => time(),
                'nonceStr' => $result['nonce_str'],
                'package' => 'prepay_id=' . $result['prepay_id'],
                'signType' => 'MD5',
            ];
            $params['paySign'] = generate_sign($params, config('wechat.payment.default.key'));
            return $params;
        } else {
            // 返回错误信息
            $this->pay_log('json_prepare' . var_export($result, true));
            return false;
        }
    }

    /**
     * 记录日志
     */
    private function pay_log($msg)
    {
        $msg = date('H:i:s') . "|" . $msg . "\r\n";
        $msg .= '| GET:' . var_export($_GET, true) . "\r\n";
        file_put_contents('./log/pay' . date('Y-m-d') . ".log", $msg, FILE_APPEND);
    }


}