fssy/application/api/controller/Order.php

<?php
namespace app\api\controller;
use think\Db;
use EasyWeChat\Factory;
/**
 * @title 会员订单管理
 * @controller Order
 * @group base
 */
class Order extends Base
{
    public function initialize()
    {
        parent::check_login();
    }


    /**
     * @title 生成订单（立即购买）
     * @desc  生成订单（立即购买）
     * @author  qc
     * @url /api/Order/createOrderByImmediately
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param name:goods_id type:int require:1 default:-- desc:商品id
     * @param name:goods_no type:int require:1 default:-- desc:商品货号
     * @param name:price_total type:float require:1 default:-- desc:支付金额(优惠后的商品金额+运费)
     * @param name:num type:int require:1 default:1 desc:商品数量
     * @param name:price_goods type:float require:0 default:0 desc:商品总金额（没优惠的）
     * @param name:price_express type:float require:0 default:0 desc:运费
     * @param name:add_id type:int require:1 default:0 desc:收货地址id
     * @param name:remark type:string require:0 default:0 desc:订单备注
     * @param name:source type:int require:0 default:0 desc:商城的为0（默认），积分商城的值为1
     * @param name:integral type:int require:0 default:0 desc:使用多少积分，source为1时必传
     * @param name:int_cash type:float require:0 default:0 desc:积分抵扣多少钱，source为1时必传
     * @param name:cl_id type:int require:0 default:0 desc:会员优惠券id，使用优惠券必传
     * @param name:coupon_cash type:float require:0 default:0 desc:会员优惠券抵扣金额
     * @return  name:order_id type:int require:0 default:0 desc:成功时返回订单id
     */
    public function createOrderByImmediately()
    {
        $goods_id               =  input("post.goods_id");
        $goods_no               =  input("post.goods_no");
        $price_total            =  input("post.price_total");
        $price_goods            =  input("post.price_goods");
        $price_express          =  input("post.price_express");
        $num                    =  input("post.num",1);
        $add_id                 =  input("post.add_id");
        $source                 =  input("post.source",0);
        $integral               =  input("post.integral",0);
        $int_cash               =  input("post.int_cash",0);
        $cl_id                  =  input("post.cl_id",0);
        $coupon_cash            =  input("post.coupon_cash",0);
        $remark                 =  input("post.remark",0);
        //商品验证start
        $goods_info = Db::table('store_goods')->field('id,spec,stock,is_integral')
            ->where(['id'=>$goods_id,'status'=>1,'is_deleted'=>0])
            ->find();
        if(empty($goods_info))  $this->error('商品已下架');
        $spec_info = [];
        $goods_spec = json_decode($goods_info['spec'],true);
        foreach ($goods_spec as &$c){
            if($c['goods_no'] == $goods_no) {
                $spec_info =$c;
                $c['store_num'] -=$num;
                break;
            }
        }
        if($spec_info['store_num'] < $num || $goods_info['stock'] < $num) $this->error('商品库存不足');
        // 券验证
        if($cl_id) {
            $cl_info = Db::table('user_coupon_list')
                ->where(['user_id'=>$this->uid,'id'=>$cl_id,'status'=>1])
                ->find();
            if(empty($cl_info)) $this->error('优惠券不存在');
            if($cl_info['past_at'] < date('Y-m-d H:i:s')) $this->error('优惠券已过期');
            if($cl_info['low_amount'] > bcsub($price_total,$price_express,2) ) $this->error('订单金额不够，再看看吧');
            if($cl_info['amount'] != $coupon_cash ) $this->error('优惠金额错误');
        }
        // 积分验证
        $user = Db::table('store_member')->find($this->uid);
        if($integral && $user['integral'] < $integral) $this->error('积分余额不足');
        $pro_info[]=[
            'goods_id'  =>$goods_id,
            'goods_no'  =>$goods_no,
            'num'       => $num,
            'integral'  =>$spec_info['integral'] * $num,
            'int_cash'  =>$int_cash,
            'sell_money'=>$spec_info['sell_money'],
            'spec_exp'  =>$spec_info['spec_exp'],
            'spec_key'  =>$spec_info['spec_key'],
        ];
        $order_int =[
            'uid'=>$this->uid,
            'order_no'      => get_order_sn(),
            'price_total'   => $price_total,
            'price_goods'   => $price_goods,
            'price_express' => $price_express,
            'create_at'     => date("Y-m-d H:i:s"),
            'address_id'    =>$add_id,
            'source'        =>$source,
            'integral'      =>$integral,
            'int_cash'      =>$int_cash,
            'coupon_id'     =>$cl_id,
            'coupon_cash'   =>$coupon_cash,
            'remark'        =>$remark,
            'goods_num'     =>$num,
            'pro_info'      =>json_encode($pro_info)
        ];
        Db::startTrans();
        $msg= '';$com=true;
        try{
            // 生成订单
            Db::table('store_order')->insert($order_int);
            $order_id = Db::getLastInsID();
            //扣减库存
            Db::table('store_goods')->where(['id'=>$goods_id])->update(['spec'=>json_encode($goods_spec),'stock'=>$goods_info['stock'] - $num]);
            //扣减积分
            if($integral){
                Db::table('store_member')->where(['id'=>$this->uid])->setDec('integral',$integral);
                //积分扣减记录
                $integral_info=[
                    'user_id'=> $this->uid,
                    'create_at'=> date("Y-m-d H:i:s"),
                    'integral'=> $integral*-1,
                    'before'=> $user['integral'],
                    'after'=> $user['integral'] - $integral,
                    'desc'=> '积分抵现',
                    'rel_id'=> $order_id,
                ];
                Db::table('integral_info')->insert($integral_info);
            }
            // 扣除券
            if($cl_id) {
                Db::table('user_coupon_list')->where(['id'=>$cl_id])->update(['status'=>2,'used_time'=>date('Y-m-d H:i:s')]);
            }
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            $com=false;
            $msg = $e->getMessage();
        }
        if($com){
            $this->success('ok',['order_id'=>$order_id]);
        }else{
            $this->error($msg);
        }
    }

    /**
     * @title 生成订单（购物车）
     * @desc  生成订单（购物车）
     * @author  qc
     * @url /api/Order/createOrderByTrolley
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param name:ids type:string  : default:1 desc:购物车记录id串（逗号分开）
     * @param name:price_total type:float require:1 default:-- desc:支付金额(优惠后的商品金额+运费)
     * @param name:price_goods type:float require:0 default:0 desc:商品总金额（没优惠的）
     * @param name:price_express type:float require:0 default:0  desc:运费
     * @param name:add_id type:int require:1 default:0 desc:收货地址id
     * @param name:remark type:string require:0 default:0 desc:订单备注
     * @param name:source type:int require:0 default:0 desc:商城的为0（默认），积分商城的值为1
     * @param name:integral type:int require:0 default:0 desc:使用多少积分，source为1时必传
     * @param name:int_cash type:float require:0 default:0 desc:积分抵扣多少钱，source为1时必传
     * @param name:cl_id type:int require:0 default:0 desc:会员优惠券id，使用优惠券必传
     * @param name:coupon_cash type:float require:0 default:0 desc:会员优惠券抵扣金额
     * @return name:order_id type:int require:0 default:0 desc:成功时返回订单id
     */
    public function createOrderByTrolley()
    {
        $ids                    =  input("post.ids");
        $price_total            =  input("post.price_total");
        $price_goods            =  input("post.price_goods");
        $price_express          =  input("post.price_express");
        $add_id                 =  input("post.add_id");
        $source                 =  input("post.source",0);
        $integral               =  input("post.integral",0);
        $int_cash               =  input("post.int_cash",0);
        $cl_id                  =  input("post.cl_id",0);
        $coupon_cash            =  input("post.coupon_cash",0);
        $remark                 =  input("post.remark",0);
        if(!$ids) $this->error('请选择要结算的商品');
        $trolley_arr = Db::table('shopping_trolley')
            ->where(['uid'=>$this->uid,'id'=>explode(',',$ids)])
            ->select();
        $pro_info = [];$total_num = 0;$check_goods = true;
        // 验证商品是否下架 && 获取订单商品详情
        foreach ($trolley_arr as $tv) {
            $goods_info = Db::table('store_goods')->field('id,spec,name')
                ->where(['id'=>$tv['goods_id'],'is_deleted'=>0,'status'=>1])
                ->find();
            if(!empty($goods_info)){
                $check_goods =false;
                break;
            }
            foreach (json_decode($tv['spec'],true) as $sv)
            {
                if($sv['goods_no'] == $tv['goods_no']) {
                    $pro_info[]=[
                        'goods_id'  =>$tv['goods_id'],
                        'goods_no'  =>$tv['goods_no'],
                        'num'       =>$tv['num'],
                        'integral'  =>$sv['integral'] * $tv['num'],
                        'int_cash'  =>'--',
                        'sell_money'=>$sv['sell_money'],
                        'spec_exp'  =>$sv['spec_exp'],
                        'spec_key'  =>$sv['spec_key'],
                    ];
                    $total_num +=$tv['num'];
                }
            }
        }
        if(!$check_goods) $this->error('所选商品已下架');
        // 券验证
        if($cl_id) {
            $cl_info = Db::table('user_coupon_list')
                ->where(['user_id'=>$this->uid,'id'=>$cl_id,'status'=>1])
                ->find();
            if(empty($cl_info)) $this->error('优惠券不存在');
            if($cl_info['past_at'] < date('Y-m-d H:i:s')) $this->error('优惠券已过期');
            if($cl_info['low_amount'] > bcsub($price_total,$price_express,2) ) $this->error('订单金额不够，再看看吧');
            if($cl_info['amount'] != $coupon_cash ) $this->error('优惠金额错误');
        }
        // 积分验证
        $user = Db::table('store_member')->find($this->uid);
        if($integral && $user['integral'] < $integral) $this->error('积分余额不足');
        $order_int =[
            'uid'=>$this->uid,
            'order_no'      => get_order_sn(),
            'price_total'   => $price_total,
            'price_goods'   => $price_goods,
            'price_express' => $price_express,
            'create_at'     => date("Y-m-d H:i:s"),
            'address_id'    =>$add_id,
            'source'        =>$source,
            'integral'      =>$integral,
            'int_cash'      =>$int_cash,
            'coupon_id'     =>$cl_id,
            'coupon_cash'   =>$coupon_cash,
            'remark'        =>$remark,
            'goods_num'     =>$total_num,
            'pro_info'      =>json_encode($pro_info)
        ];
        Db::startTrans();
        $msg= '';$com=true;
        try{
            // 生成订单
            Db::table('store_order')->insert($order_int);
            $order_id = Db::getLastInsID();
            //扣减积分
            if($integral){
                Db::table('store_member')->where(['id'=>$this->uid])->setDec('integral',$integral);
                //积分扣减记录
                $integral_info=[
                    'user_id'=> $this->uid,
                    'create_at'=> date("Y-m-d H:i:s"),
                    'integral'=> $integral * -1,
                    'before'=> $user['integral'],
                    'after'=> $user['integral'] - $integral,
                    'desc'=> '积分抵现',
                    'rel_id'=> $order_id,
                ];
                Db::table('integral_info')->insert($integral_info);
            }
            // 扣除券
            if($cl_id) {
                Db::table('user_coupon_list')->where(['id'=>$cl_id])->update(['status'=>2,'used_time'=>date('Y-m-d H:i:s')]);
            }
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            $com=false;
            $msg = $e->getMessage();
        }
        if($com){
            $this->success('ok',['order_id'=>$order_id]);
        }else{
            $this->error($msg);
        }
    }


    /**
     * @title 获取订单详情
     * @desc  获取订单详情
     * @author  qc
     * @url /api/Order/getOrderDetail
     * @method GET
     * @header name:Authorization require:1 desc:Token
     * @param  name:id type:int require:1 default:-- desc:订单id
     * @return name:order_no type:string default:-- desc:订单号
     * @return name:status type:int default:-- desc:支付状态:0待支付,1已支付,2待发货,3待收货,4已收货,5已完成,9取消
     * @return name:price_total type:float default:-- desc:订单金额(需要支付金额【包含运费，扣除所有优惠】)
     * @return name:price_goods type:float default:-- desc:商品金额
     * @return name:price_express type:float default:-- desc:运费
     * @return name:pay_state type:int default:-- desc:支付状态（0未支付，1已支付）
     * @return name:order_no type:string default:-- desc:订单号
     * @return name:pay_no type:string default:-- desc:支付单号
     * @return name:create_at type:string default:-- desc:订单创建时间
     * @return name:pay_at type:string default:-- desc:支付时间
     * @return name:cancel_at type:string default:-- desc:取消时间（status=9）
     * @return name:cancel_desc type:string default:-- desc:取消描述（status=9）
     * @return name:refund_type type:int default:-- desc:订单申请退款、退换货状态0未申请,1部分申请,2全部申请
     * @return name:source type:int default:0 desc:订单来源：0商城，1积分商城
     * @return name:integral type:int default:0 desc:使用多少积分
     * @return name:int_cash type:int default:0 desc:积分抵扣多少金额
     * @return name:cl_id type:int default:0 desc:使用优惠券的id
     * @return name:coupon_cash type:float default:0 desc:券抵扣金额
     */
    public function getOrderDetail()
    {
        $order_id = input('id',0);
        $detail = Db::table('store_order')->find($order_id);
        $this->success('获取成功',$detail);

    }



    public function getOrderReturn()
    {

    }


    /**
     * 获取退款订单详情
     * @param $order_id
     */
    public function getReturnDetail($order_id)
    {
        $return_detail = Db::table('order_return')
            ->find($order_id);
        return $return_detail;
    }


    /**
     * @title 去支付
     * @desc  去支付
     * @author  qc
     * @url /api/Order/payOrder
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param name:o_id type:int require:1 default:-- desc:订单id
     * @param name:is_remind type:int require:1 default:0 desc:订单是否提醒，0不提醒，1提醒
     */
    public function payOrder()
    {
        $o_id = input('post.o_id');
        $is_remind = input('post.is_remind');
        $user_info = Db::table('store_member')->where('id',$this->uid)->find();
        if(!$user_info['phone'] || !$user_info['openid']) $this->error('请先完善用户信息');
        $order_info =     Db::table('ticket_order')->where(['uid'=>$this->uid,'id'=>$o_id,'cancel_state'=>0])->find();
        if(empty($order_info)) $this->error('订单不存在');
        if($order_info['price_total'] <= 0 ) $this->error('订单金额错误');
        if($order_info['status'] != 0 ) $this->error('订单状态错误');
        Db::startTrans();
        $config = false;$msg= '';
        try{
            $notify_url = $this->request->root(true) . '/api/Pay/payNotify';
            $pay_no = get_order_sn();
            Db::table('ticket_order')
                ->where(['uid'=>$this->uid,'id'=>$o_id])
                ->update(['is_remind'=>$is_remind,'pay_no'=>$pay_no]);
            $config = Pay::wxPay('订单支付',$pay_no,$order_info['price_total'],$notify_url,'JSAPI',$user_info['openid']);
            if($config){
                Db::commit();
            }else{
                Db::rollback();
            }
        }catch (\Exception $e){
            Db::rollback();
            $msg = $e->getMessage();
        }
        if($config){
            $this->success('ok',['jump'=>1,'config'=>$config]);
        }else{
            $this->error($msg);
        }
    }


    /**
     * @title 获取订单列表
     * @desc  获取订单列表
     * @author  qc
     * @url /api/Order/getMyOrderList
     * @method GET
     * @header name:Authorization require:1 desc:Token
     * @param  name:type type:int  : default:1 desc:查询类型，1所有，2待核销，3待评价,4已完成
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     * @return name:order_no type:string default:-- desc:订单号
     * @return name:total_num type:int default:-- desc:订单总票数（包含儿童票）
     * @return name:children_num type:int default:-- desc:儿童票数
     * @return name:pay_state type:int default:-- desc:支付状态(0未支付,1已支付)
     * @return name:price_total type:float default:-- desc:订单金额
     * @return name:create_at type:string default:-- desc:订单创建时间
     * @return name:tel type:string default:-- desc:订单预留电话
     * @return name:remark type:string default:-- desc:备注
     * @return name:f_id type:string default:-- desc:电影id
     * @return name:film_name type:string default:-- desc:电影名称
     * @return name:cover type:string default:-- desc:电影封面
     * @return name:duration type:string default:-- desc:电影时长（分钟）
     * @return name:day_time type:string default:-- desc:播放时间（天）
     * @return name:point_time type:string default:-- desc:电影播放时间（点）
     * @return name:end_time type:string default:-- desc:播放结束时间（点）
     * @return name:qrcode type:string default:-- desc:核销码
     * @return name:is_hx type:int default:0 desc:是否核销
     * @return name:is_discuss type:int default:0 desc:是否评价
     * @return name:ticket_price type:float default:0 desc:票价（成人）
     */
    public function getMyOrderList()
    {
        $type = input('type',1);
        $page = input('page',1);
        $page_num = input('page_num',20);
        $off_set   =  $page*$page_num - $page_num;
        $where=[];
        $where['o.uid'] = $this->uid;
        $where['o.pay_state'] = 1;
        switch ($type)
        {
            case 1: // 全部
                break;
            case 2: // 待核销
                $where['o.is_hx'] = 0;
                break;
            case 3:// 待评价
                $where['o.is_discuss'] = 0;
                $where['o.is_hx'] = 1;
                break;
            case 4:// 已完成
                $where['o.is_discuss'] = 1;
                $where['o.is_hx'] = 1;
                break;
        }
        $list = Db::table('ticket_order o')
            ->field('o.id,o.total_num,order_no,o.pay_state,o.create_at,children_num,pay_at,o.price_total,o.tel,o.remark,o.is_hx,o.ticket_price,o.is_discuss,f.name as film_name,o.qrcode ,o.f_id,f.duration,f.desc as film_desc,f.cover,s.day_time,s.point_time')
            ->join('film_list f',' o.f_id = f.id ','LEFT')
            ->join('film_info s',' o.s_id = s.id ','LEFT')
            ->where($where)
            ->order('o.id desc')
            ->limit($off_set,$page_num)
            ->select();
        $this->success('获取成功',$list);

    }



    /**
     * @title 取消订单
     * @desc  取消订单
     * @author  qc
     * @url /api/Order/cancelOrder
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:-- desc:订单id
     * @param name:desc type:string require:1 default:-- desc:取消描述
     * @param name:is_remind type:int require:1 default:0 desc:订单是否提醒，0不提醒，1提醒
     */
    public function cancelOrder()
    {
        $o_id = input('post.id');
        $desc = input('post.desc');
        $order_detail = Db::table('ticket_order')->where(['id'=>$o_id])->find($o_id);
        if(empty($order_detail)) $this->error('订单不存在');
        if($order_detail['pay_state'] != 0)      $this->error('订单已支付');
        if($order_detail['cancel_state'] != 0)   $this->error('订单已取消,不能重复取消');
        Db::startTrans();
        try {
            Db::table('ticket_order')->where(['id'=>$o_id])->update(['cancel_state'=>1,'cancel_at'=>date('Y-m-d H:i:s'),'desc'=>$desc]);
            Db::table('film_info')->where('id', $order_detail['s_id'])->setInc('surplus_num', $order_detail['total_num']);//增加场次余票
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
        }
        $this->success('取消成功');

    }


}