feisu/application/api/controller/Order.php

<?php

// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2019 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://demo.thinkadmin.top
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
// | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------

namespace app\api\controller;

use app\api\controller\Alipay;
use app\api\controller\Base;
use think\Db;
use think\Model;
use app\api\controller\Area;
use EasyWeChat\Factory;
/**
 * @title 订单管理
 * @controller Order
 * @group member
 */
class Order extends Base
{
    function initialize(){
        $this->check_login();
    }
    /**
     * @title 提交订单
     * @desc 提交订单
     * @author QGF
     * @url /api/Order/create_order
     * @method POST
     * @tag 提交订单
     * @header name:Authorization require:1 desc:Token
     * @param name:goods_id type:int require:1 default:-- desc:服务ID
     * @param name:serve_type_id type:int require:1 default:-- desc:服务类型ID
     * @param name:phone_type_id type:int require:0 default:-- desc:手机型号ID（金刚区服务需要（cate_id等于0的就是金刚区服务））
     * @param name:lose_at type:string require:0 default:-- desc:丢失时间（金刚区服务需要（cate_id等于0的就是金刚区服务））
     * @param name:client_tel type:string require:1 default:-- desc:联系手机
     * @param name:client_qq type:string require:1 default:-- desc:联系QQ
     * @param name:pay_type type:int require:1 default:-- desc:支付类型（1：微信，2：支付宝）
     * @param name:describe type:string require:0 default:-- desc:附加信息
     * @param name:coupon_id type:int require:0 default:-- desc:选择的优惠券ID
     * @return name:config type:array default:-- desc:支付配置（微信和支付宝返回值不同）
     */
    public function create_order(){
        $uid = $this->uid;
        $goods_id = input('goods_id');
        $serve_type_id = input('serve_type_id');
        $phone_type_id = input('phone_type_id');
        $lose_at = input('lose_at');
        $client_tel = input('client_tel');
        $client_qq = input('client_qq');
        $describe = input('describe');
        $pay_type = input('pay_type');
        $coupon_id = input('coupon_id');
        if(empty($goods_id) || empty($serve_type_id) || empty($pay_type)){
            $this->error('参数错误');
        }
        $goods_info = Db::name('store_goods')->field('id,cate_id')->where('status',1)->where('id',$goods_id)->where('is_deleted',0)->find();
        if(empty($goods_info)){
            $this->error('服务信息有误');
        }
        $goods_price = get_goods_price($goods_id,$serve_type_id,$phone_type_id);
        if($goods_price['code'] == 0){
            $this->error($goods_price['msg']);
        }
        $price_total = $price_amount = $goods_price['price'];
        $coupon_amount = 0;
        if($coupon_id > 0){
            $coupon_info = Db::name('store_coupon_list')->field('id,amount')->where('id',$coupon_id)->where('user_id',$uid)->where('status',0)->where('end','>=',date('Y-m-d'))->where('low_amount','<=',$price_total)->find();
            if(empty($coupon_info)){
                $this->error('所选优惠券有误');
            }
            $coupon_amount = $coupon_info['amount'];
            $price_total = $price_total - $coupon_amount;
        }

        $serve_type_name = Db::name('store_goods_type')->where('id',$serve_type_id)->value('spec_name');
        $order_no = get_order_sn();
        $pay_no = get_order_sn();
        $order_data = array(
            'user_id' => $uid,
            'order_no' => $order_no,
            'goods_id' => $goods_id,
            'serve_type' => $serve_type_name,
            'client_tel' => $client_tel,
            'client_qq' => $client_qq,
            'describe' => $describe,
            'price_total' => $price_total,
            'price_amount' => $price_amount,
            'coupon_id' => $coupon_id,
            'coupon_amount' => $coupon_amount,
            'pay_type' => $pay_type,
            'cate_id' => $goods_info['cate_id'],
            'pay_no' => $pay_no
        );
        if($goods_info['cate_id'] == 0){     //金刚区
            $phone_type_name = Db::name('store_goods_type')->where('id',$phone_type_id)->value('spec_name');
            $order_data['phone_type'] = $phone_type_name;
            $order_data['lose_at'] = $lose_at;
        }
        Db::startTrans();
        $order_res = Db::name('store_order')->insert($order_data);
        $error = 0;
        if(!$order_res){
            $error = 1;
            Db::rollback();
        }
        //优惠券改为已用
        if($coupon_id){
            $coupon_res = Db::name('store_coupon_list')->where('id',$coupon_id)->update(array('status'=>1));
            if(!$coupon_res){
                $error = 2;
                Db::rollback();
            }
        }
        if($pay_type == 1){    //微信支付
            $notify_url = $this->request->root(true) . '/api/Pay/order_notify';
            //$price_total = 0.01;
            $config = Pay::wx_pay('订单支付',$pay_no,$price_total,$notify_url);
            if($error == 0 && $config){
                Db::commit();
                $this->success('支付成功',['config'=>$config]);
            }else{
                Db::rollback();
                $this->error('支付失败');
            }
        }else{
            $notify_url = $this->request->root(true) . '/api/Alipay/order_notify';
            //$price_total = 0.01;
            $config = Alipay::ali_pay('订单支付',$pay_no,$price_total,$notify_url);
            if($error == 0 && $config){
                Db::commit();
                $this->success('支付成功',['config'=>array('alipay'=>$config)]);
            }else{
                Db::rollback();
                $this->error('支付失败');
            }
        }
    }
    /**
     * @title 立即支付
     * @desc 立即支付
     * @author QGF
     * @url /api/Order/pay_order
     * @method POST
     * @tag 支付
     * @header name:Authorization require:1 desc:Token
     * @param name:order_id type:int require:1 default:-- desc:订单ID
     * @param name:pay_type type:int require:0 default:-- desc:支付类型（1：微信，2：支付宝）
     * @return name:config type:array default:-- desc:支付配置（微信和支付宝返回值不同）
     */
    public function pay_order(){
        $uid = $this->uid;
        $order_id = input('order_id');
        $pay_type = input('pay_type',0);
        if(empty($order_id)){
            $this->error('参数错误');
        }
        $order_info = Db::name('store_order')->field('id,price_total,pay_type')->where('user_id',$uid)->where('id',$order_id)->where('status',0)->find();
        if(empty($order_info)){
            $this->error('订单信息有误');
        }
        if(empty($pay_type)){
            $pay_type = $order_info['pay_type'];
        }
        $price_total = $order_info['price_total'];
        $pay_no = get_order_sn();
        Db::name('store_order')->where('id',$order_id)->update(array('pay_no'=>$pay_no,'pay_type'=>$pay_type));
        if($pay_type == 1){    //微信支付
            $notify_url = $this->request->root(true) . '/api/Pay/order_notify';
            //$price_total = 0.01;
            $config = Pay::wx_pay('订单支付',$pay_no,$price_total,$notify_url);
            if($config){
                Db::commit();
                $this->success('支付成功',['config'=>$config]);
            }else{
                Db::rollback();
                $this->error('支付失败');
            }
        }else{
            $notify_url = $this->request->root(true) . '/api/Alipay/order_notify';
            //$price_total = 0.01;
            $config = Alipay::ali_pay('订单支付',$pay_no,$price_total,$notify_url);
            if($config){
                Db::commit();
                $this->success('支付成功',['config'=>array('alipay'=>$config)]);
            }else{
                Db::rollback();
                $this->error('支付失败');
            }
        }
    }
    /**
     * @title 订单列表
     * @desc 订单列表
     * @author QGF
     * @url /api/Order/order_list
     * @method GET
     * @tag 订单列表
     * @header name:Authorization require:1 desc:Token
     * @param name:status type:tinyint require:0 default:-1 desc:订单的状态（-1：全部订单（默认）,0：待支付,1：待接单,2：进行中,3：已完成）
     * @param name:keyword type:string require:0 default:-- desc:搜索的服务类目名称
     * @param name:page type:int require:0 default:1 desc:页数（默认为1）
     * @param name:page_size type:int require:0 default:10 desc:每页数量（默认为10）
     * @return name:id type:int default:-- desc:订单ID
     * @return name:serve_type type:string default:-- desc:服务类型
     * @return name:price_amount type:string default:-- desc:服务费用
     * @return name:status type:int default:-- desc:订单状态（0：待支付,1：待接单,2：进行中,3：已完成）
     * @return name:is_evaluate type:int default:-- desc:是否已评价（0：未评价，1：已评价。注：只有已完成的订单才能评价）
     * @return name:serve_title type:string default:-- desc:服务类型
     */
    public function order_list(){
        $uid = $this->uid;
        $status = input('status',-1);
        $keyword = input('keyword');
        $page = input('page',1);
        $pageSize = input('page_size',10);
        if($status == -1){
            $where = 'is_deleted = 0 and user_id = '.$uid;
        }else{
            $where = 'is_deleted = 0 and user_id = '.$uid.' and status = '.$status;
        }
        if($keyword){
            $goods_id_arr = Db::name('store_goods')->where('title','like','%'.$keyword.'%')->column('id');
            if($goods_id_arr){
                $goods_id_str = implode(',',$goods_id_arr);
                $where .= ' and goods_id in ('.$goods_id_str.')';
            }else{
                $where .= ' and id = 0';
            }
        }
        $field = 'id,goods_id,serve_type,price_amount,status,is_evaluate';
        $order_list = Db::name('store_order')->field($field)->where($where)->order('id desc')->page($page,$pageSize)->select();
        foreach ($order_list as &$value){
            $value['serve_title'] = Db::name('store_goods')->where('id',$value['goods_id'])->value('title');
            unset($value['goods_id']);
        }
        $this->success('获取成功',$order_list);
    }
    /**
     * @title 订单数量
     * @desc 每个状态下的订单数量
     * @author QGF
     * @url /api/Order/order_status_number
     * @method GET
     * @tag 订单列表
     * @header name:Authorization require:1 desc:Token
     * @return name:qb_order_count type:int default:-- desc:全部订单数量
     * @return name:dzf_order_count type:int default:-- desc:待支付的订单数量
     * @return name:djd_order_count type:int default:-- desc:待接单的订单数量
     * @return name:jxz_order_count type:int default:-- desc:进行中的订单数量
     * @return name:ywc_order_count type:int default:-- desc:已完成的订单数量
     */
    public function order_status_number(){
        $uid = $this->uid;
        $where = 'is_deleted = 0 and user_id = '.$uid;
        $qb_order_count = Db::name('store_order')->where($where)->count('id');
        $dzf_order_count = Db::name('store_order')->where($where)->where('status',0)->count('id');
        $djd_order_count = Db::name('store_order')->where($where)->where('status',1)->count('id');
        $jxz_order_count = Db::name('store_order')->where($where)->where('status',2)->count('id');
        $ywc_order_count = Db::name('store_order')->where($where)->where('status',3)->count('id');
        $data = array(
            'qb_order_count' => $qb_order_count,
            'dzf_order_count' => $dzf_order_count,
            'djd_order_count' => $djd_order_count,
            'jxz_order_count' => $jxz_order_count,
            'ywc_order_count' => $ywc_order_count
        );
        $this->success('获取成功',$data);
    }
    /**
     * @title 订单详情
     * @desc 订单详情
     * @author QGF
     * @url /api/Order/order_detail
     * @method GET
     * @tag 订单详情
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:1 desc:订单ID
     * @return name:id type:int default:-- desc:订单ID
     * @return name:worker_id type:int default:-- desc:工程师工号（0：代表咱无工程师接单）
     * @return name:order_no type:string default:-- desc:订单编号
     * @return name:serve_type type:string default:-- desc:服务类型
     * @return name:phone_type type:string default:-- desc:手机型号
     * @return name:lose_at type:string default:-- desc:丢失时间
     * @return name:client_tel type:string default:-- desc:联系手机
     * @return name:client_qq type:string default:-- desc:联系QQ
     * @return name:describe type:string default:-- desc:附加信息
     * @return name:price_amount type:string default:-- desc:订单金额（实付金额等于订单金额减去优惠券抵用金额）
     * @return name:coupon_amount type:string default:-- desc:优惠券抵用金额（平台优惠）
     * @return name:pay_type type:int default:-- desc:支付方式（1：微信，2：支付宝）
     * @return name:pay_at type:string default:-- desc:支付时间
     * @return name:start_at type:string default:-- desc:开始时间
     * @return name:end_at type:string default:-- desc:完成时间
     * @return name:status type:int default:-- desc:订单状态（0：待支付,1：待接单,2：进行中,3：已完成）
     * @return name:is_evaluate type:int default:-- desc:是否已评价（0：未评价，1：已评价。注：只有已完成的订单才能评价）
     * @return name:serve_title type:string default:-- desc:服务类目
     * @return name:worker_qq type:string default:-- desc:工程师QQ号
     */
    public function order_detail(){
        $uid = $this->uid;
        $id = input('id');
        if(empty($id)){
            $this->error('参数错误');
        }
        $field = 'id,goods_id,worker_id,order_no,serve_type,phone_type,lose_at,client_tel,client_qq,describe,price_amount,coupon_amount,pay_type,pay_at,start_at,end_at,status,is_evaluate';
        $order_detail = Db::name('store_order')->field($field)->where('user_id',$uid)->where('id',$id)->find();
        if(empty($order_detail)){
            $this->error('订单信息有误');
        }
        $order_detail['serve_title'] = Db::name('store_goods')->where('id',$order_detail['goods_id'])->value('title');
        $order_detail['worker_qq'] = '';
        if($order_detail['worker_id']){
            $order_detail['worker_qq'] = Db::name('store_engineer')->where('id',$order_detail['worker_id'])->value('qq');
            //重置工程师编号
            $order_detail['worker_id'] = str_pad($order_detail['worker_id'],3,'0',STR_PAD_LEFT);
        }
        unset($order_detail['goods_id']);
        $this->success('获取成功',$order_detail);
    }
    /**
     * @title 确认完成
     * @desc 确认完成
     * @author QGF
     * @url /api/Order/confirm_completed
     * @method GET
     * @tag 确认完成
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:1 desc:订单ID
     */
    public function confirm_completed(){
        $uid = $this->uid;
        $id = input('id');
        if(empty($id)){
            $this->error('参数错误');
        }
        $order_info = Db::name('store_order')->field('id')->where('id',$id)->where('user_id',$uid)->where('status',2)->find();
        if(empty($order_info)){
            $this->error('订单信息有误');
        }
        $res = Db::name('store_order')->where('id',$id)->update(array('status'=>3,'end_at'=>date('Y-m-d H:i:s')));
        if($res){
            $this->success('确认成功');
        }else{
            $this->error('确认失败');
        }
    }
    /**
     * @title 提交评价
     * @desc 提交评价
     * @author QGF
     * @url /api/Order/submit_evaluate
     * @method GET
     * @tag 提交评价
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:-- desc:订单ID
     * @param name:rank type:int require:1 default:-- desc:评价星级 1-5颗星
     * @param name:content type:string require:1 default:-- desc:评价内容
     * @param name:images type:string require:0 default:-- desc:评价图片（多张以英文逗号分隔）
     */
    public function submit_evaluate(){
        $uid = $this->uid;
        $id = input('id');
        $rank = input('rank');
        $content = input('content');
        $images = input('images');
        if(empty($id) || empty($rank) || empty($content)){
            $this->error('参数错误');
        }
        $order_info = Db::name('store_order')->field('id,goods_id,worker_id')->where('id',$id)->where('user_id',$uid)->where('status',3)->where('is_evaluate',0)->find();
        if(empty($order_info)){
            $this->error('订单信息有误');
        }
        $data = array(
            'user_id' => $uid,
            'goods_id' => $order_info['goods_id'],
            'worker_id' => $order_info['worker_id'],
            'images' => $images,
            'rank' => $rank,
            'content' => $content
        );
        Db::name('store_evaluate')->insert($data);
        Db::name('store_order')->where('id',$id)->update(array('is_evaluate'=>1));
        $this->success('评分成功');
    }
    /**
     * @title 删除订单
     * @desc 删除订单
     * @author QGF
     * @url /api/Order/delete_order
     * @method GET
     * @tag 删除订单
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:1 desc:订单的ID
     */
    public function delete_order(){
        $uid = $this->uid;
        $id = input('id');
        if(empty($id)){
            $this->error('参数错误');
        }
        $order_info = Db::name('store_order')->field('id')->where('id',$id)->where('user_id',$uid)->where('status',3)->where('is_evaluate',1)->find();
        if(empty($order_info)){
            $this->error('订单信息有误');
        }
        $res = Db::name('store_order')->where('id',$order_info['id'])->update(array('is_deleted'=>1));
        if($res){
            $this->success('删除成功');
        }else{
            $this->error('删除失败');
        }
    }
    function test_mail(){
        $engineer_mail_arr = Db::name('store_engineer')->field('id,headimg')->where('mail is not null')->where('is_deleted',0)->column('mail');
        if($engineer_mail_arr){
            $mail_str = implode(',',$engineer_mail_arr);
            mail_push($mail_str,27);
        }
    }
}