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",0);
        $price_goods            =  input("post.price_goods",0);
        $price_express          =  input("post.price_express",0);
        $num                    =  input("post.num",1);
        $add_id                 =  input("post.add_id",0);
        $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",'');
        //商品验证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(!isset($spec_info['integral'])) $spec_info['integral'] = 0;
        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,
            'spec_img'  =>$spec_info['spec_img'],
            '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,
            'cl_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();
            //扣减库存
            update_goods_stock($goods_id,$goods_no,$num);
            //扣减积分
            if($integral){
                update_user_integral($this->uid,$integral * -1,5,'积分抵扣',$order_id);
            }
            // 扣除券
            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/cancelOrder
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:-- desc:订单id
     * @param name:cancel_desc type:string require:1 default:-- desc:取消描述
     */
    public function cancelOrder()
    {
        $order_id = input('post.id');
        $desc = input('post.desc');
        $order_detail = Db::table('store_order')->where(['id'=>$order_id])->find();
        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 {
            // 积分退回
            if($order_detail['integral'] > 0) {
                update_user_integral($order_detail['uid'],$order_detail['integral'],8,'订单取消退回',$order_id);
            }
            //  优惠券回档
            if($order_detail['cl_id'] > 0) {
                $user_coupon = Db::table('user_coupon_list')->find($order_detail['cl_id']);// 会员优惠券记录
                $coupon_set = Db::table('store_coupon_config')->find($user_coupon['coupon_id']);//优惠券设置
                if($coupon_set['status'] != 1 || $coupon_set['is_deleted'] == 1){
                    $coupon_status =  4;
                }else{
                    $coupon_status = $user_coupon['past_at'] > date("Y-m-d H:i:s") ? 1:3;
                }
                Db::table('user_coupon_list')->where(['id'=>$order_detail['cl_id']])->update(['status'=>$coupon_status]);
            }
            // 商品库存恢复
            $pro_info  = json_decode($order_detail['pro_info'],true);
            foreach ($pro_info as $pv) {
                update_goods_stock($pv['goods_id'],$pv['goods_no'],$pv['num']*-1);
            }
             // 取消订单
            Db::table('store_order')
                ->where(['id'=>$order_id])
                ->update(['cancel_state'=>1,'cancel_at'=>date('Y-m-d H:i:s'),'cancel_desc'=>$desc,'status'=>9]);
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
        }
        $this->success('取消成功');

    }



    /**
     * @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",0);
        $price_goods            =  input("post.price_goods",0);
        $price_express          =  input("post.price_express",0);
        $add_id                 =  input("post.add_id",0);
        $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",'');
        if(!$ids || !$price_total) $this->error('请选择要结算的商品');
        $trolley_arr = Db::table('shopping_trolley')
            ->where(['user_id'=>$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($goods_info['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'  => isset($sv['integral']) ? $sv['integral'] * $tv['num'] : 0,
                        'int_cash'  =>'--',
                        'spec_img'  =>$sv['spec_img'],
                        '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,
            'cl_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();
            // 删除购物车记录
            Db::table('shopping_trolley')->where(['id'=>explode(',',$ids)])->delete();
            //扣减积分
            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);

    }


    /**
     * @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');
        $user_info = Db::table('store_member')->where('id',$this->uid)->find();
        if(!$user_info['phone'] || !$user_info['openid']) $this->error('请先完善用户信息');
        $order_info =     Db::table('store_order')->where(['uid'=>$this->uid,'id'=>$o_id])->find();
        if(empty($order_info)) $this->error('订单不存在');
        if($order_info['status'] != 0) $this->error('订单已支付');
        if($order_info['cancel_state'] != 0) $this->error('订单已取消');
        if($order_info['price_total'] <= 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('store_order')->where(['uid'=>$this->uid,'id'=>$o_id])->update(['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:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     * @param  name:status type:int  : default:-1 desc:订单状态（-1全部, 0待支付,1已支付,2待发货,3待收货,4已收货,5已完成,9取消）
     * @return name:order_no type:string default:-- desc:订单号
     * @return name:pay_state type:int default:-- desc:支付状态(0未支付,1已支付)
     * @return name:price_total type:float default:-- desc:订单金额
     * @return name:pro_info type:float default:-- desc:订单详情
     * @return name:pay_at type:string default:-- desc:支付时间
     * @return name:create_at type:string default:-- desc:订单创建时间
     * @return name:remark 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申请
     * @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 getMyOrderList()
    {
        $status  = input('status',-1);
        $where=[];
        if($status > -1) $where['o.status'] = $status;
        $where['o.uid'] = $this->uid;
        $where['o.is_deleted'] = 0;
        $list = Db::table('store_order o')
            ->field('o.id,o.order_no,o.pay_state,o.create_at,pay_at,pro_info,o.price_total,o.remark')
            ->where($where)
            ->order('o.id desc')
            ->limit($this->off_set,$this->page_num)
            ->select();
        $this->success('获取成功',$list);

    }


    /**
     * @title 删除订单
     * @desc  删除订单
     * @author  qc
     * @url /api/Order/delOrder
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param  name:id type:int  : default:1 desc:订单id
     */
    public function delOrder()
    {
        $order_id = input('post.id');
        $order_info = Db::table('store_order')
            ->where(['uid'=>$this->uid,'is_deleted'=>0,'id'=>$order_id])
            ->find();
        if(empty($order_info)) $this->error('订单不存在');
        Db::table('store_order')->where(['id'=>$order_id])->update(['is_deleted'=>1]);
        $this->success('删除成功');
    }

    /**
     * @title 获取平台退款原因
     * @desc  获取平台退款原因
     * @author  qc
     * @url /api/Order/getRefundCause
     * @method GET
     * @header name:Authorization require:1 desc:Token
     * @return name:id type:int default:-- desc:记录id
     * @return name:title type:string default:-- desc:退款原因描述
     */
    public function getRefundCause()
    {
        $list = Db::table('store_order_cause')
            ->field('id,title')
            ->where(['status'=>1])
            ->order('sort desc , id asc')
            ->select();
        $this->success('ok',['list'=>$list]);
    }


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


}