youxiangjie/application/api/model/OrderModel.php

<?php

namespace app\api\model;

use app\common\lib\WxPay;
use think\Cache;
use think\Db;
use think\Model;

class OrderModel extends Model
{
    protected $name = 'order';
    protected $resultSetType = 'collection';

    /*
     * 用户余额支付
     */
    public function userMoneyPay($params)
    {
        $userInfo = UsersModel::where('user_id', $params['user_id'])->find();
        if ($userInfo['is_setpaypwd'] == 0) {
            return json(['code' => 90, 'msg' => '还未设置支付密码', 'data' => []]);
        }
        if ($userInfo['user_paypwd'] != $params['user_paypwd']) {
            return json(['code' => 100, 'msg' => '支付密码不正确', 'data' => '']);
        }
        if (!$userInfo) {
            return json(['code' => 100, 'msg' => '网络错误', 'data' => '']);
        }
        //对照金额书否正确的
//        $isMoney = Db::name('order_pre')->where('pre_id', $params['pre_id'])->where('money', $params['money'])->find();
//        if (!$isMoney) {
//            return json(['code' => 100, 'msg' => '金额不对', 'data' => '']);
//        }
        if ($userInfo['user_money'] < $params['money']) {
            return json(['code' => 100, 'msg' => '您的余额不足', 'data' => '']);
        }
        if ($userInfo['user_paypwd'] == '') {
            return json(['code' => 60, 'msg' => '还未设置支付密码，请去设置', 'data' => '']);
        }
        Db::startTrans();
        try {
            //扣除用户余额
            $updUserMoney = UsersModel::where('user_id', $params['user_id'])->setDec('user_money', $params['money']);
            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
        }
        if (!$updUserMoney) {
            return json(['code' => 100, 'msg' => '扣款失败', 'data' => '']);
        }
        $list = $params['list'];
        //循环加入奖励的白豆
        $whitebean = 0;  // 白豆初始化
        foreach ($list as &$v) {
            $commodity = CommodityModel::where('c_id', $v['c_id'])->find()->toArray(); // 查出商品详情
            $whitebean = $commodity['c_whitebean'] + $whitebean;
        }
        //创建订单信息
        $orderdata = array(
            'user_id'     => $params['user_id'],
            'money'       => $params['money'],
            'freight'     => $params['freight'],
            'number'      => $params['number'],
            'create_time' => $params['create_time'],
            'whitebeon'   => $whitebean,
            'pay_time'    => date("Y-m-d H:i:s", time()),
            'state'       => 2,
            'type'        => $params['type'],
        );
        //生成已支付订单
        $addOrderId = Db::name('order')->insertGetId($orderdata);
        if (!$addOrderId) {
            return json(['code' => 100, 'msg' => '订单生成失败', 'data' => '']);
        }
        $list = $params['list'];
        //循环加入奖励的白豆
        $whitebean = 0;  // 白豆初始化
        foreach ($list as &$v) {
            $commodity = CommodityModel::where('c_id', $v['c_id'])->find()->toArray(); // 查出商品详情
            $whitebean = $commodity['c_whitebean'] + $whitebean;
        }
        //创建订单商品信息
        foreach ($list as &$v) {
            $commoditycolor = Commoditycolor::where('colorid', $v['colorid'])->find()->toArray();                     //查 出商品颜色表参数
            $parameter = Parameter::where('p_id', $v['p_id'])->find()->toArray();                                     // 查出商品规格表参数
            $commodity = CommodityModel::where('c_id', $v['c_id'])->field('c_vipprice,c_freight')->find()->toArray(); // 查出商品价格和运费
            $v = array_merge($commoditycolor, $parameter, $commodity, $v);
            $order_commodity_data = array(
                'c_id'       => $v['c_id'],
                'p_id'       => $v['p_id'],
                'colorid'    => $v['colorid'],
                'name'       => $v['name'],
                'p_name'     => $v['p_name'],
                'color'      => $v['color'],
                'buy_number' => $v['buy_number'],
                'c_vipprice' => $v['money'],
                'c_freight'  => $v['c_freight'],
                'o_id'       => $addOrderId,
            );
            //循环插入订单商品信息
            $add_order_commodity = Db::name('order_commodity')->insert($order_commodity_data);
        }
        if (!$add_order_commodity) {
            return json(['code' => 100, 'msg' => '网络错误', 'data' => '']);
        }
        //创建地址信息
        $address = Address::where('a_id', $params['a_id'])->find();
        $order_address = array(
            'a_id'   => $params['a_id'],
            'a_name' => $address['a_name'],
            'a_tel'  => $address['a_tel'],
            'a_city' => $address['city'],
            'a_area' => $address['area'],
            'o_id'   => $addOrderId
        );
        //订单地址添加
        $add_order_address = Db::name('order_address')->insert($order_address);
        if ($add_order_address) {
            //用户白豆增加
            Db::name('users')->where('user_id', $params['user_id'])->setInc('user_whitebean', $whitebean);
            return json(['code' => 200, 'msg' => '下单成功', 'data' => $addOrderId]);
        } else {
            Db::name('order')->where('o_id', $addOrderId)->delete();
            return json(['code' => 200, 'msg' => '下单失败', 'data' => $addOrderId]);
        }
    }

    /*
     * 订单微信支付
     */
    public function wechatOrder($params)
    {
        $userInfo = UsersModel::where('user_id', $params['user_id'])->find();
        if (!$userInfo) {
            return json(['code' => 100, 'msg' => '网络错误11', 'data' => '']);
        }
        //对照金额书否正确的
//        $isMoney = Db::name('order_pre')->where('pre_id', $params['pre_id'])->where('money', $params['money'])->find();
//        if (!$isMoney) {
//            return json(['code' => 100, 'msg' => '金额不对', 'data' => '']);
//        }
        //创建订单信息
        $orderdata = array(
            'user_id'     => $params['user_id'],
            'money'       => $params['money'],
            'freight'     => $params['freight'],
            'number'      => $params['number'],
            'create_time' => $params['create_time'],
            'whitebeon'   => $params['whitebean'],
            'pay_time'    => date("Y-m-d H:i:s", time()),
            'state'       => 1,
            'type'        => $params['type'],
        );
        //生成已支付订单
        $addOrderId = Db::name('order')->insertGetId($orderdata);
        if (!$addOrderId) {
            return json(['code' => 100, 'msg' => '订单生成失败', 'data' => '']);
        }
        $list = $params['list'];
        //创建订单商品信息
        foreach ($list as &$v) {
            $commoditycolor = Commoditycolor::where('colorid', $v['colorid'])->find()->toArray();                     //查 出商品颜色表参数
            $parameter = Parameter::where('p_id', $v['p_id'])->find()->toArray();                                     // 查出商品规格表参数
            $commodity = CommodityModel::where('c_id', $v['c_id'])->field('c_vipprice,c_freight')->find()->toArray(); // 查出商品价格和运费
            $v = array_merge($commoditycolor, $parameter, $commodity, $v);
            $order_commodity_data = array(
                'c_id'       => $v['c_id'],
                'p_id'       => $v['p_id'],
                'colorid'    => $v['colorid'],
                'name'       => $v['name'],
                'p_name'     => $v['p_name'],
                'color'      => $v['color'],
                'buy_number' => $v['buy_number'],
                'c_vipprice' => $v['money'],  // 颜色商品的价格
                'c_freight'  => $v['c_freight'],
                'o_id'       => $addOrderId,
            );
            //循环插入订单商品信息
            $add_order_commodity = Db::name('order_commodity')->insert($order_commodity_data);
        }
//        if (!$add_order_commodity) {
//            return json(['code' => 100, 'msg' => '网络错误22', 'data' => '']);
//        }
        //创建地址信息
        $address = Address::where('a_id', $params['a_id'])->find();
        $order_address = array(
            'a_id'   => $params['a_id'],
            'a_name' => $address['a_name'],
            'a_tel'  => $address['a_tel'],
            'a_city' => $address['city'],
            'a_area' => $address['area'],
            'o_id'   => $addOrderId
        );
        //订单地址添加
        $add_order_address = Db::name('order_address')->insert($order_address);
        if (!$add_order_address) {
            return json(['code' => 200, 'msg' => '下单失败', 'data' => $addOrderId]);
        }
        //获取微信pre_id
        $wxpay = new WxPay();
        $body = "商品支付";
        //$total_fee = $params['money'] * 100;
        $total_fee = 1;
        $out_trade_no = $params['number'];
        $notify_url = config('site.httpurl') . '/api/order/order_notify';
        $res = $wxpay->getPrePayOrder($body, $out_trade_no, $total_fee, $notify_url);
        if ($res['return_code'] == "SUCCESS") {
            if ($res['return_msg'] == 'OK') {
                $result['params'] = $wxpay->getOrder($res['prepay_id']);
                $result['o_id'] = $addOrderId;
                $wechatinfo = array(
                    "appid"     => $result['params']['appid'],
                    "noncestr"  => $result['params']['noncestr'],
                    "package"   => $result['params']['package'],
                    "partnerid" => $result['params']['partnerid'],
                    "prepayid"  => $result['params']['prepayid'],
                    "timestamp" => $result['params']['timestamp'],
                    "sign"      => $result['params']['sign'],
                    "o_id"      => $result['o_id'],
                );
                Cache::set('wechat', $result);
                // 插入拉取微信的支付的信息表
                $add = Db::name('order_wechatpay')->insert($wechatinfo);
                return json(['data' => $result, 'msg' => '', 'code' => 200]);
            } else {
                return json(['data' => [], 'msg' => '拉取失败', 'code' => 100]);
            }
        } else {
            return json(['data' => [], 'msg' => '拉取失败', 'code' => 100]);
        }

    }

    /**
     * 全部订单
     */
    public function allOrder($user_id)
    {
        //全部订单
        $data = $this->with(['OrderCommodityModel', 'OrderAddress'])
            ->where('user_id', $user_id)
            ->order('o_id desc')
            ->select()->toArray();

        if (!$data) {
            $data = [];
        } else {
            foreach ($data as &$v) {
                foreach ($v['order_commodity_model'] as &$n) {
                    $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name')->find();
                    if (!$commodity) {
                        $n['c_name'] = '已下架商品';
                    } else {
                        $n['c_name'] = $commodity['c_name'];
                    }
                    $n['c_money'] = $n['c_vipprice'] * $n['buy_number'];  // c_vipprice存的是颜色商品的价格，而不是商品的初始价格
                    $n['money'] = $n['c_vipprice'] * $n['buy_number'] + $n['c_freight'];
                    $n['freight'] = $n['c_freight'] * $n['buy_number'];
                }
            }
        }
        //待支付订单
        $data1 = $this->with(['OrderCommodityModel' => function ($query) {
            $query->with('Commodity');
        }, 'OrderAddress'])
            ->where('state', 1)
            ->where('user_id', $user_id)
            ->order('o_id desc')
            ->select()->toArray();
        if (!$data1) {
            $data1 = [];
        } else {
            foreach ($data1 as &$v) {
                foreach ($v['order_commodity_model'] as &$n) {
                    $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name')->find();
                    if (!$commodity) {
                        $n['c_name'] = '已下架商品';
                    } else {
                        $n['c_name'] = $commodity['c_name'];
                    }
                    $n['c_money'] = $n['c_vipprice'] * $n['buy_number'];
                    $n['money'] = $n['c_vipprice'] * $n['buy_number'] + $n['c_freight'];
                    $n['freight'] = $n['c_freight'] * $n['buy_number'];
                }
            }
        }
        //待发货订单
        $data2 = $this->with(['OrderCommodityModel', 'OrderAddress'])
            ->where('state', 2)
            ->where('user_id', $user_id)
            ->order('o_id desc')
            ->select()->toArray();
        if (!$data2) {
            $data2 = [];
        } else {
            foreach ($data2 as &$v) {
                foreach ($v['order_commodity_model'] as &$n) {
                    $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name')->find();
                    if (!$commodity) {
                        $n['c_name'] = '已下架商品';
                    } else {
                        $n['c_name'] = $commodity['c_name'];
                    }
                    $n['c_money'] = $n['c_vipprice'] * $n['buy_number'];
                    $n['money'] = $n['c_vipprice'] * $n['buy_number'] + $n['c_freight'];
                    $n['freight'] = $n['c_freight'] * $n['buy_number'];
                }
            }
        }
        //待收货订单
        $data3 = $this->with(['OrderCommodityModel', 'OrderAddress'])
            ->where('state', 3)
            ->where('user_id', $user_id)
            ->order('o_id desc')
            ->select()->toArray();
        if (!$data3) {
            $data3 = [];
        } else {
            foreach ($data3 as &$v) {
                foreach ($v['order_commodity_model'] as &$n) {
                    $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name')->find();
                    if (!$commodity) {
                        $n['c_name'] = '已下架商品';
                    } else {
                        $n['c_name'] = $commodity['c_name'];
                    }
                    $n['c_money'] = $n['c_vipprice'] * $n['buy_number'];
                    $n['money'] = $n['c_vipprice'] * $n['buy_number'] + $n['c_freight'];
                    $n['freight'] = $n['c_freight'] * $n['buy_number'];
                }
            }
        }
        //订单取消
        $data5 = $this->with(['OrderCommodityModel', 'OrderAddress'])
            ->where('state', 5)
            ->where('user_id', $user_id)
            ->order('o_id desc')
            ->select()->toArray();
        if (!$data5) {
            $data5 = [];
        } else {
            foreach ($data5 as &$v) {
                foreach ($v['order_commodity_model'] as &$n) {
                    $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name')->find();
                    if (!$commodity) {
                        $n['c_name'] = '已下架商品';
                    } else {
                        $n['c_name'] = $commodity['c_name'];
                    }
                    $n['c_money'] = $n['c_vipprice'] * $n['buy_number'];
                    $n['money'] = $n['c_vipprice'] * $n['buy_number'] + $n['c_freight'];
                    $n['freight'] = $n['c_freight'] * $n['buy_number'];
                }
            }
        }
        //已完成订单
        $data6 = $this->with(['OrderCommodityModel', 'OrderAddress'])
            ->where('state', 6)
            ->where('user_id', $user_id)
            ->order('o_id desc')
            ->select()->toArray();
        if (!$data6) {
            $data6 = [];
        } else {
            foreach ($data6 as &$v) {
                foreach ($v['order_commodity_model'] as &$n) {
                    $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name')->find();
                    if (!$commodity) {
                        $n['c_name'] = '已下架商品';
                    } else {
                        $n['c_name'] = $commodity['c_name'];
                    }
                    $n['c_money'] = $n['c_vipprice'] * $n['buy_number'];
                    $n['money'] = $n['c_vipprice'] * $n['buy_number'] + $n['c_freight'];
                    $n['freight'] = $n['c_freight'] * $n['buy_number'];
                }
            }
        }
        //退款售后
        $data4 = $this->with(['OrderCommodityModel', 'OrderAddress'])
            ->where('state', 4)
            ->where('user_id', $user_id)
            ->order('o_id desc')
            ->select()->toArray();
        if (!$data4) {
            $data4 = [];
        } else {
            foreach ($data4 as &$v) {
                foreach ($v['order_commodity_model'] as &$n) {
                    $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name')->find();
                    if (!$commodity) {
                        $n['c_name'] = '已下架商品';
                    } else {
                        $n['c_name'] = $commodity['c_name'];
                    }
                    $n['c_money'] = $n['c_vipprice'] * $n['buy_number'];
                    $n['money'] = $n['c_vipprice'] * $n['buy_number'] + $n['c_freight'];
                    $n['freight'] = $n['c_freight'] * $n['buy_number'];
                }
            }
        }
        return json(['code' => 200, 'msg' => '', 'allorder' => $data, 'daizhifu' => $data1, 'daifahuo' => $data2, 'daishouhuo' => $data3, 'quxiao' => $data5, 'yiwancheng' => $data6, 'tuikuan' => $data4]);
    }

    public function OrderCommodityModel()
    {
        return $this->hasMany('OrderCommodityModel', 'o_id', 'o_id');
    }

    public function OrderAddress()
    {
        return $this->hasOne('OrderAddress', 'o_id', 'o_id');
    }

    public function Torder()
    {
        return $this->hasOne('Torder', 'o_id', 'o_id');
    }
}