kge/application/api/controller/Dispatch.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use app\common\model\Message;
use think\Db;
use app\common\library\Sms as Smslib;
/**
 * 派单接口
 */
class Dispatch extends Common
{
    protected $noNeedLogin = ['getSkillList','getReciveList'];
    protected $noNeedRight = ['*'];

    /**
     * 添加技能认证
     */
    public function addSkillAuth() {
        $skill_id = $this->request->request('skill_id',0,"intval"); // 技能ID
        $leaver_id = $this->request->request('leaver_id',0,"intval"); // 技能等级ID
        $area_id = $this->request->request('area_id',0,"intval"); // 区服ID
        $image = $this->request->request('image'); // 图片说明
        $voice = $this->request->request('voice'); // 语音说明
        $voice_time = $this->request->request('voice_time'); // 声音时长
        $price = $this->request->request('price'); // 价格说明
        $remarks = $this->request->request('remarks'); // 技能介绍
        if (!$skill_id || !$image || !$voice || !$remarks || !$price) {
            $this->error(__('Invalid parameters'));
        }

        $is_main = 0;
        // 获取技能信息
        $skillModel = new \app\common\model\DispatchSkill();
        $skillInfo = $skillModel->getSkillInfo($skill_id);
        if(!$skillInfo) {
            $this->error(__('未找到技能信息！'));
        }

        $authModel = new \app\common\model\DispatchAuth();
        // 是否已经认证过
        $where = [];
        $where["user_id"] = $this->auth->id;
        $where["skill_id"] = $skill_id;
        $authInfo = $authModel->where($where)->find();
        if($authInfo) {
            if($authInfo["status"] == 0) $this->error(__('您已提交过认证申请，请耐心等待审核！'));
            if($authInfo["status"] == 1) $this->error(__('您已经认证过了'));
        }
       if($authModel->where(["user_id"=>$this->auth->id])->count()<=0) {
           $is_main = 1;
       }
        // 添加认证信息
        $data = [];
        $data["user_id"] = $this->auth->id;
        $data["skill_id"] = $skill_id;
        $data["leaver_id"] = $leaver_id;
        $data["area_id"] = $area_id;
        $data["image"] = $image;
        $data["voice"] = $voice;
        $data["voice_time"] = $voice_time;
        $data["price"] = $price;
        $data["is_main"] = $is_main;
        $data["image"] = $image;
        $data["remarks"] = $remarks;
        $data["createtime"] = time();
        $res = $authModel->insertGetId($data);
        if($res) {
            $this->success('申请发送成功，请耐心等待审核！');
        } else {
            $this->error(__('网络错误，请稍后重试！'));
        }
    }

    /**
     * 判断当前技能是否已认证
     */
    public function skillIsAuth() {
        $skill_id = $this->request->request('skill_id',0,"intval"); // 技能ID
        if (!$skill_id) {
            $this->error(__('Invalid parameters'));
        }
        $authModel = new \app\common\model\DispatchAuth();
        // 是否已经认证过
        $where = [];
        $where["user_id"] = $this->auth->id;
        $where["skill_id"] = $skill_id;
        $authInfo = $authModel->field("status")->where($where)->find();
        if($authInfo) {
            if($authInfo["status"] == 0) $this->error(__('当前技能已提交过认证申请，请耐心等待审核！'));
            if($authInfo["status"] == 1) $this->error(__('当前技能已经认证过了'));
        }

        $skillLevelInfo = \app\common\model\DispatchSkillLeaver::where(["skill_id"=>$skill_id])->find();
        $skillAreaInfo = \app\common\model\DispatchSkillArea::where(["skill_id"=>$skill_id])->find();
        $res = [];
        $res["level"] = $skillLevelInfo?1:0;
        $res["area"] = $skillAreaInfo?1:0;
        $this->success("没有认证过，可以去认证！", $res);
    }

//    /**
//     * 创建接单信息
//     */
//    public function addRecive() {
//        $skill_id = $this->request->request('skill_id',0,"intval"); // 技能ID
//        $back_image = $this->request->request('back_image'); // 背景图
//        $price = $this->request->request('price'); // 服务价格
//        $describe = $this->request->request('describe'); // 一句话描述
////        $tags = $this->request->request('tags'); // 标签列表(中文半角逗号隔开)
//        if (!$skill_id || !$back_image || !$describe) {
//            $this->error(__('Invalid parameters'));
//        }
//        $reciveModel = new \app\common\model\DispatchRecive();
//        $where = [];
//        $where["user_id"] = $this->auth->id;
//        $where["skill_id"] = $skill_id;
//        $where["status"] = 1;
//        $reciveInfo = $reciveModel->where($where)->find();
//        if($reciveInfo) {
//            $this->error(__('您已存在当前技能的接单信息，请勿重复提单'));
//        }
//
//        // 获取技能信息
//        $skillModel = new \app\common\model\DispatchSkill();
//        $skillInfo = $skillModel->getSkillInfo($skill_id);
//        if(!$skillInfo) {
//            $this->error(__('未找到技能信息！'));
//        }
//
//        // 添加接单信息
//        $data = [];
//        $data["user_id"] = $this->auth->id;
//        $data["skill_id"] = $skill_id;
//        $data["back_image"] = $back_image;
//        $data["price"] = $price;
//        $data["unit"] = $skillInfo["unit"];
//        $data["describe"] = $describe;
////        $data["tags"] = $tags;
//        $data["createtime"] = time();
//        $res = $reciveModel->insertGetId($data);
//        if($res) {
//            $this->success('恭喜，接单信息已发送！');
//        } else {
//            $this->error(__('网络错误，请稍后重试！'));
//        }
//    }

//    /**
//     * 创建订单
//     */
//    public function addOrder() {
//        $recive_id = $this->request->request('recive_id',0,"intval"); // 接单ID
//        $num = $this->request->request('num',0,"intval"); // 数量
//        $describe = $this->request->request('describe'); // 备注要求
//        if (!$recive_id || !$num || !$describe) {
//            $this->error(__('Invalid parameters'));
//        }
//
//        // 获取接单信息
//        $reciveModel = new \app\common\model\DispatchRecive();
//        $where = [];
//        $where["id"] = $recive_id;
//        $reciveInfo = $reciveModel->where($where)->find();
//        if(!$reciveInfo) {
//            $this->error(__('接单信息不存在！'));
//        }
//        if($reciveInfo["status"] == 2) {
//            $this->error(__('订单已关闭！'));
//        }
//        // 判断用户余额
//        $userModel = new \app\common\model\User();
//        $where = [];
//        $where["id"] = $this->auth->id;
//        $jewel = $userModel->where($where)->value("jewel");
//        $price = 0;
//        $reciveInfo["price"] >= 0 || $price = 0;
//        $reciveInfo["price"] >= 0 && $price = $reciveInfo["price"];
//        if($price * $num >= $jewel) {
//            $this->error(__('钻石余额不足，请先充值！'));
//        }
//        // 添加订单信息
//        $orderModel = new \app\common\model\DispatchOrder();
//        $data = [];
//        $data["user_id"] = $this->auth->id;
//        $data["recive_id"] = $recive_id;
//        $data["price"] = $reciveInfo["price"];
//        $data["num"] = $num;
//        $data["describe"] = $describe;
//        $data["createtime"] = time();
//        $res = $orderModel->insertGetId($data);
//        if($res) {
//            $this->success('订单创建成功！');
//        } else {
//            $this->error(__('订单创建失败！'));
//        }
//
//    }

//    /**
//     * 获取接单信息
//     */
//    public function getReciveInfo() {
//        $recive_id = $this->request->request('recive_id',0,"intval"); // 接单ID
//        if (!$recive_id) {
//            $this->error(__('Invalid parameters'));
//        }
//        // 获取接单信息
//        $reciveModel = new \app\common\model\DispatchRecive();
//        $where = [];
//        $where["r.id"] = $recive_id;
//        $reciveInfo = $reciveModel->alias("r")
//            ->field("r.id,u.id as user_id,r.back_image,a.voice,u.avatar,u.nickname,s.name as skill_name,r.price,s.unit,r.service_time,r.describe,r.tags")
//            ->join("hx_user u","u.id = r.user_id")
//            ->join("hx_dispatch_skill s","s.id = r.skill_id")
//            ->join("hx_dispatch_auth a","a.skill_id = s.id")
//            ->where($where)
//            ->find();
//        if(!$reciveInfo) {
//            $this->error(__('数据为空！'));
//        }
//        // 在线状态和ID
//        $reciveInfo["is_online"] = 1;
//        $reciveInfo["line_id"] = 234224;
//        // 已服务人数
//        $where = [];
//        $where["user_id"] = $reciveInfo["user_id"];
//        $where["status"] = 2;
//        $reciveInfo["service_num"] = \app\common\model\DispatchOrder::where(["user_id"])->count();
//        // 主播认证通过的所有技能标签
//        $authModel = new \app\common\model\DispatchAuth();
//        $where = [];
//        $where["a.user_id"] = $reciveInfo["user_id"];
//        $where["a.status"] = $reciveInfo["user_id"];
//        $skillArr = $authModel->alias("a")
//            ->field("s.id,s.name")
//            ->join("hx_dispatch_skill s","s.id = a.skill_id")
//            ->where(["user_id"])->select();
//
//        $reciveInfo["skills"] = $skillArr;
//
//        $this->success('获取成功！',$reciveInfo);
//    }

    /**
     * 获取接单列表
     */
    public function getReciveList() {
        $skill_id = $this->request->request('skill_id',0,"intval"); // 技能ID
        $is_recommend = $this->request->request('is_recommend'); // 是否推荐:1=是,0=否
        $gender = $this->request->request('gender',-1); // 性别:1=男,0=女,-1=全部
        $page = $this->request->request('page',1); // 分页
        $pageNum = $this->request->request('pageNum',10); // 分页
        // 分页搜索构建
        $pageStart = ($page-1)*$pageNum;

        if(!in_array($gender,[-1,0,1])) {
            $gender = -1;
        }

        $authModel = new \app\common\model\DispatchAuth();
        $where = [];
        if ($skill_id > 0) {
            $where["a.skill_id"] = $skill_id;
        } else if($is_recommend == 1) {
            $where["a.is_recommend"] = $is_recommend;
            $where["a.is_main"] = 1;
        }
        $where["a.status"] = 1;
        $gender == -1 || $where["u.gender"] = $gender;
        $authList = $authModel->alias("a")
            ->field("a.id,u.avatar,ds.name as skill_name,a.voice,a.voice_time,a.price,ds.unit,u.nickname,u.gender")
            ->join("hx_user u","u.id = a.user_id")
            ->join("hx_dispatch_skill ds","ds.id = a.skill_id")
            ->limit($pageStart,$pageNum)
            ->where($where)
            ->select();

        $this->success('获取成功！',$authList);

    }

    /**
     * 获取推荐列表
     */
    public function getReciveCommentList() {
        $page = $this->request->request('page',1); // 分页
        $pageNum = $this->request->request('pageNum',10); // 分页
        // 分页搜索构建
        $pageStart = ($page-1)*$pageNum;

        $authModel = new \app\common\model\DispatchAuth();
        $where = [];
        $where["a.is_main"] = 1;
        $where["a.status"] = 1;
        $where["a.is_recommend"] = 1;
        $authList = $authModel->alias("a")
            ->field("a.id,u.avatar,ds.name as skill_name,a.voice,a.voice_time,a.price,ds.unit,u.nickname,u.gender")
            ->join("hx_user u","u.id = a.user_id")
            ->join("hx_dispatch_skill ds","ds.id = a.skill_id")
            ->limit($pageStart,$pageNum)
            ->where($where)
            ->select();

        $this->success('获取成功！',$authList);

    }

    /**
     * 获取接单信息
     */
    public function getReciveInfo() {
        $auth_id = $this->request->request('auth_id',0,"intval"); // 技能认证ID
        if (!$auth_id) {
            $this->error(__('Invalid parameters'));
        }
        // 获取接单信息
        $authModel = new \app\common\model\DispatchAuth();
        $where = [];
        $where["a.id"] = $auth_id;
        $authInfo = $authModel->alias("a")
            ->field("a.id,a.user_id,a.image,a.voice,a.voice_time,u.avatar,u.nickname,u.u_id,u.is_online,s.id as skill_id,s.name as skill_name,s.image as skill_icon, a.price,s.unit,a.remarks")
            ->join("hx_user u","u.id = a.user_id")
            ->join("hx_dispatch_skill s","s.id = a.skill_id")
            ->where($where)
            ->find();
        if(!$authInfo) {
            $this->error(__('数据为空！'));
        }
        // 已服务人数
        $where = [];
        $where["recive_id"] = $authInfo["user_id"];
        $where["status"] = 3;
        $authInfo["service_num"] = \app\common\model\DispatchOrder::where($where)->count();
        // 主播认证通过的所有技能标签
        $viewuserskillModel = new \app\common\model\ViewUserSkill();
        $skillArr = $viewuserskillModel->getSkillInfoId($authInfo["user_id"]);
        // 查看者是否已关注
        $followid = \app\common\model\UserFansFollow::where(["fans_id"=>$this->auth->id,"user_id"=>$authInfo["user_id"]])->value("id");
        $authInfo["is_follow"] = $followid>0?1:0;

        $authInfo["skills"] = $skillArr;

        $this->success('获取成功！',$authInfo);
    }

    /**
     * 创建订单
     */
    public function addOrder() {
        $user_id = $this->request->request('user_id',0,"intval"); // 主播用户ID
        $skill_id = $this->request->request('skill_id',0,"intval"); // 技能ID
        $num = $this->request->request('num',0,"intval"); // 数量
        $make_time = $this->request->request('make_time'); // 预约时间 格式：时间戳。
        $describe = $this->request->request('describe'); // 备注要求
        $makeTimeLen = strlen($make_time);
        if (!empty($make_time) && $makeTimeLen > 10) {//处理时间戳位数问题
            $make_time = substr($make_time,0,10);
        }
        if (!$skill_id || !$num) {
            $this->error(__('Invalid parameters'));
        }
        if ($this->auth->power->payorder == 1) {
            $this->error('您已被禁止下单');
        }
        $orderModel = new \app\common\model\DispatchOrder();

        // 获取接单信息
        $authModel = new \app\common\model\DispatchAuth();
        $where = [];
        $where["user_id"] = $user_id;
        $where["skill_id"] = $skill_id;
        $where["status"] = 1;
        $authInfo = $authModel->where($where)->find();
        if(!$authInfo) {
            $this->error(__('技能认证信息不存在,或认证未通过！'),[],103);
        }

        // 获取技能信息
        $skillModel = new \app\common\model\DispatchSkill();
        $where = [];
        $where["id"] = $skill_id;
        $skillInfo = $skillModel->where($where)->find();
        if(!$skillInfo) {
            $this->error(__('技能信息未找到，请稍后重试！'));
        }

        // 判断用户余额
        $jewel = Db::name('user_wallet')->where('user_id',$this->auth->id)->value('jewel');
        $price = 0;
        $authInfo["price"] >= 0 || $price = 0;
        $authInfo["price"] >= 0 && $price = $authInfo["price"];
        $money = $price * $num;
        if($money > $jewel) {
            $this->error(__('钻石余额不足，请先充值！'),[],100);
        }

        // 禁止自己下单
        if($this->auth->id == $authInfo["user_id"]) {
            $this->error(__('禁止自己下单！'),[],101);
        }

        // 查看当前用户是否有未支付订单
        $where = [];
        $where["user_id"] = $this->auth->id;
        $where["status"] = 0;
        $orderInfo = $orderModel->where($where)->find();
//        $orderInfo && $this->error(__('您有未支付订单，请先支付！'),[],102);

        Db::startTrans();
        try{
            // 添加订单信息
            $out_trade_no = date("YmdHis").rand(100000,999999);// 产生订单号
            $data = [];
            $data["user_id"] = $this->auth->id;
            $data["order_no"] = $out_trade_no;
            $data["recive_id"] = $authInfo["user_id"];
            $data["auth_id"] = $authInfo["id"];
            $data["price"] = $authInfo["price"];
            $data["num"] = $num;
            $data["skill_image"] = $skillInfo["image"];
            $data["skill_name"] = $skillInfo["name"];
            $data["skill_unit"] = $skillInfo["unit"];
            $data["make_time"] = $make_time;
            $data["describe"] = $describe;
            $data["status"] = 0;
            $data["createtime"] = time();
            $res = $orderModel->insertGetId($data);
            if($res) {

                \app\common\model\Message::addMessage($authInfo["user_id"],"派单通知","您的技能：".$skillInfo["name"]."有人下单啦，请注意查看！");
                Db::commit();
                $this->success('订单创建成功！',["order_no"=>$out_trade_no]);
            } else {
                $this->error(__('订单创建失败！'));
            }
        }catch (ValidateException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }

    }

    /**
     * 添加订单评价内容
     */
    public function addOrderComment() {
        $order_no = $this->request->request('order_no'); // 订单编号
        $content = $this->request->request('content'); // 评价内容
        if (!$order_no && !$content) {
            $this->error(__('Invalid parameters'));
        }

        Db::startTrans();
        try{
            $ordercommentModel = new \app\common\model\DispatchOrderComment();
            $orderModel = new \app\common\model\DispatchOrder();
            $orderInfo = $orderModel->where(["order_no"=>$order_no])->find();
            if(!$orderInfo) $this->error(__('未查询到订单信息！'));
            if($orderInfo["status"] != 3) $this->error(__('当前订单状态不允许评价！'));
            $data= [];
            $data["user_id"] = $this->auth->id;
            $data["order_id"] = $orderInfo["id"];
            $data["content"] = $content;
            $data["createtime"] = time();
            $res1 = $ordercommentModel->insert($data);
            $res2 = $orderModel->update(["is_comment"=>1],["order_no"=>$order_no]);
            if($res1 && $res2) {
                Db::commit();
                $this->success('评价成功！');
            } else {
                $this->error(__('订单创建失败！'));
            }
        }catch (ValidateException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
    }



    /**
     * 钻石余额支付订单
     */
    public function jewelPay() {
        $order_no = $this->request->request('order_no'); // 订单号
        if (!$order_no) {
            $this->error(__('Invalid parameters'));
        }
        // 获取订单信息
        $orderModel = new \app\common\model\DispatchOrder();
        $where = [];
        $where["order_no"] = $order_no;
        $orderInfo = $orderModel->where($where)->find();
        if(!$orderInfo) {
            $this->error(__('订单信息获取失败！'));
        }
        if($orderInfo["status"] != 0) {
            $this->error(__('订单状态有误！'),[],104);
        }
        // 判断用户余额
        $userModel = new \app\common\model\User();
        $where = [];
        $where["id"] = $this->auth->id;
        $jewel = Db::name('user_wallet')->where('user_id',$this->auth->id)->value('jewel');
        $money = $orderInfo["price"] * $orderInfo["num"];
        if($money > $jewel) {
            $this->error(__('钻石余额不足，请先充值！'),[],100);
        }
        // 去支付
        Db::startTrans();
        try{
            // 扣除用户余额

            $res1 = true;
            $res2 = $userModel->where($where)->setInc("frozen",$money);
            // 添加用户余额变动记录
            $res3 = true;
            //增加用户钻石余额
            $rs_wallet = model('wallet')->lockChangeAccountRemain($this->auth->id, $money, "-", 0, "下单扣除余额", 0,'jewel');
            if($rs_wallet['status'] == false){
                Db::rollback();
                $this->error($rs_wallet['msg']);
            }


            // 添加订单信息
            $orderModel = new \app\common\model\DispatchOrder();
            // 修改订单状态
            $where = [];
            $where["order_no"] = $order_no;
            $data = [];
            $data["status"] = 1;
            $res4 = $orderModel->update($data,$where);
            if($res1 && $res2 && $res3 && $res4) {
                Db::commit();
                // 短信通知
                $reciveuserInfo = $userModel->where(["id"=>$orderInfo["recive_id"]])->find();
                //Smslib::notice($reciveuserInfo->mobile, $orderInfo["skill_name"],"有人接单啦",'orderNotice');
                // 系统消息通知
                \app\common\model\Message::addMessage($orderInfo["recive_id"],"派单通知","您的派单，技能：".$orderInfo["skill_name"]."有人下单啦，请注意查看！");

                $this->success('支付成功！');
            } else {
                $this->error(__('订单创建失败！'));
            }
        }catch (ValidateException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
    }

    /**
     * 更新订单状态
     */
    public function changeOrder() {
        $order_no = $this->request->request('order_no'); // 订单号
        $status = $this->request->request('status'); // 状态:-2=已取消,-1=拒绝接单,2=进行中,3=已完成
        if (!$order_no || !$status) {
            $this->error(__('Invalid parameters'));
        }
        if(!in_array($status,["-2","-1","2","3"])) {
            $this->error("非法的订单状态参数");
        }
        // 获取订单信息
        $orderModel = new \app\common\model\DispatchOrder();
        $where = [];
        $where["order_no"] = $order_no;
        $orderInfo = $orderModel->where($where)->find();
        if(!$orderInfo) {
            $this->error(__('订单信息获取失败！'));
        }
        if($orderInfo["status"] == $status) {
            $this->error(__('当前订单状态无变更要求！'),[],104);
        }
        // 验证用户权限
        if($status == -1 && $orderInfo["recive_id"] != $this->auth->id) {
            $this->error(__('无权限操作！'),[],103);
        }

        // 验证用户权限
        if(($status == -2 || $status == 3) && $orderInfo["user_id"] != $this->auth->id) {
            $this->error(__('无权限操作！'),[],103);
        }

        if($status == -1) { // 拒绝订单
            if($orderInfo["status"] != 1) {
                $this->error(__('当前订单状态不支持拒绝订单！'),[],104);
            }
            // 完成订单操作需要更新余额记录
            Db::startTrans();
            try{
                $userModel = new \app\common\model\User();
                $money = $orderInfo["price"] * $orderInfo["num"];
                // 解冻用户余额
                $where = [];
                $where["id"] = $orderInfo["user_id"];
                $userInfo = $userModel->where($where)->find();
                if($userInfo["frozen"] - $money < 0) {
                    $this->error(__('账户资金异常，请联系管理员！'),[],105);
                }
                $res1 = $userModel->where($where)->setDec("frozen",$money);//下单用户
                $res2 = true;//下单用户
                // 添加用户余额变动记录
                $res3 = true;

                //增加用户钻石余额
                $rs_wallet = model('wallet')->lockChangeAccountRemain($orderInfo["user_id"], $money, "+", 0, "拒绝订单返还余额", 7,'jewel');
                if($rs_wallet['status'] == false){
                    Db::rollback();
                    $this->error($rs_wallet['msg']);
                }

                // 更新订单状态
                $data = [];
                $data["status"] = $status;
                $where = [];
                $where["order_no"] = $order_no;
                $res4 = $orderModel->update($data,$where);

                if($res1 && $res2 && $res3 && $res4) {
                    Db::commit();
                    // 短信通知
                    //$reciveuserInfo = $userModel->where(["id"=>$orderInfo["user_id"]])->find();
                    //Smslib::notice($reciveuserInfo->mobile, $orderInfo["skill_name"],"被拒绝接单",'orderNotice');
                    // 系统消息通知
                    \app\common\model\Message::addMessage($orderInfo["user_id"],"派单通知","您的订单，技能：".$orderInfo["skill_name"]."已被拒绝接单，请注意查看！");

                    $this->success('订单已拒绝。');
                } else {
                    $this->error(__('订单更新失败！请稍后重试'));
                }
            }catch (ValidateException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            } catch (PDOException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            } catch (Exception $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }
        } elseif($status == 3) { // 订单完成
            if($orderInfo["status"] != 2) {
                $this->error(__('当前订单状态不支持直接变更为已完成！'),[],104);
            }
            // 完成订单操作需要更新余额记录
            Db::startTrans();
            try{
                $userModel = new \app\common\model\User();
                $money = $orderInfo["price"] * $orderInfo["num"];
                // 增加用户余额
                $res1 = true;
                //
                $where = [];
                $where["id"] = $orderInfo['user_id'];
                $res2 = $userModel->where($where)->setDec("frozen",$money);
                // 添加用户余额变动记录
                $res3 = true;

                $remark = $orderInfo['skill_name'].'服务';
                $jewelMoneyRate = config('site.money_to_jewel');//1人民币兑换钻石数
                $moneyRmb = bcdiv($money,$jewelMoneyRate);
                $rs_wallet = model('wallet')->lockChangeAccountRemain($orderInfo["recive_id"],$moneyRmb,'+',0,$remark,106,'money');
                if($rs_wallet['status'] == false){
                    Db::rollback();
                    $this->error($rs_wallet['msg']);
                }
                // 更新订单状态
                $data = [];
                $data["status"] = $status;
                $data["is_comment"] = 1;//要求直接自动已评价，为了前端不显示立即评价按钮
                $where = [];
                $where["order_no"] = $order_no;
                $res4 = $orderModel->update($data,$where);

                if($res1 && $res2 && $res3 && $res4) {
                    Db::commit();
                    // 短信通知
                    //$reciveuserInfo = $userModel->where(["id"=>$orderInfo["recive_id"]])->find();
                    //Smslib::send($reciveuserInfo->mobile, $orderInfo["skill_name"], "顺利完成啦！",'orderNotice');

                    // 系统消息通知
                    \app\common\model\Message::addMessage($orderInfo["recive_id"],"派单通知","您的派单，技能：".$orderInfo["skill_name"]." 完成啦！，请注意查看！");

                    $this->success('恭喜！订单完成。');
                } else {
                    $this->error(__('订单更新失败！请稍后重试'));
                }
            }catch (ValidateException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            } catch (PDOException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            } catch (Exception $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }
        }if($status == -2) { // 取消订单
            if($orderInfo["status"] != 1) {
                $this->error(__('当前订单状态不支持拒绝订单！'),[],104);
            }
            // 完成订单操作需要更新余额记录
            Db::startTrans();
            try{
                $userModel = new \app\common\model\User();
                $money = $orderInfo["price"] * $orderInfo["num"];
                // 解冻用户余额
                $where = [];
                $where["id"] = $orderInfo['user_id'];
                $userInfo = $userModel->where($where)->find();
                if($userInfo["frozen"] - $money < 0) {
                    $this->error(__('账户资金异常，请联系管理员！'),[],105);
                }
                $res1 = $userModel->where($where)->setDec("frozen",$money);
                $res2 = true;
                // 添加用户余额变动记录
                $res3 = true;

                $rs_wallet = model('wallet')->lockChangeAccountRemain($orderInfo["user_id"], $money, "+", 0, "取消订单返还余额", 7,'money');
                if($rs_wallet['status'] == false){
                    Db::rollback();
                    $this->error($rs_wallet['msg']);
                }

                // 更新订单状态
                $data = [];
                $data["status"] = $status;
                $where = [];
                $where["order_no"] = $order_no;
                $res4 = $orderModel->update($data,$where);

                if($res1 && $res2 && $res3 && $res4) {
                    Db::commit();
                    // 短信通知
                    //$reciveuserInfo = $userModel->where(["id"=>$orderInfo["user_id"]])->find();
                    //Smslib::notice($reciveuserInfo->mobile, $orderInfo["skill_name"],"被拒绝接单",'orderNotice');
                    // 系统消息通知
                    \app\common\model\Message::addMessage($orderInfo["recive_id"],"派单通知","您的订单，技能：".$orderInfo["skill_name"]."已被取消，请登录查看！");

                    $this->success('订单取消成功。');
                } else {
                    $this->error(__('订单更新失败！请稍后重试'));
                }
            }catch (ValidateException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            } catch (PDOException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            } catch (Exception $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }
        } else {
            $data = [];
            $data["status"] = $status;
            $where = [];
            $where["order_no"] = $order_no;
            $res = $orderModel->update($data,$where);
            if($res) {
                if ($status == 2) {//接单发
                    \app\common\model\Message::addMessage($orderInfo['user_id'],"订单单通知","您的订单：".$order_no."已被接单，请登录查看！");
                }
                $this->success('更新成功！');
            } else {
                $this->error(__('订单创建失败！'));
            }
        }
    }

    /**
     * 获取技能列表
     */
    public function getSkillList() {
        $skillModel = new \app\common\model\DispatchSkill();
        $skillList = $skillModel->select();
        if ($skillList) {
            $this->success(__('获取成功！'), $skillList);
        } else {
            $this->success(__('数据为空！'));
        }
    }

    /**
     * 获取技能等级列表
     */
    public function getSkillLevelList() {
        $skill_id = $this->request->request('skill_id'); // 技能ID
        if (!$skill_id) {
            $this->error(__('Invalid parameters'));
        }
        $skilllevelModel = new \app\common\model\DispatchSkillLeaver();
        $where = [];
        $where["skill_id"] = $skill_id;
        $skilllevelList = $skilllevelModel->where($where)->select();
        if ($skilllevelList) {
            $this->success(__('获取成功！'), $skilllevelList);
        } else {
            $this->success(__('数据为空！'));
        }
    }

    /**
     * 获取技能区域列表
     */
    public function getSkillAreaList() {
        $skill_id = $this->request->request('skill_id'); // 技能ID
        if (!$skill_id) {
            $this->error(__('Invalid parameters'));
        }
        $skillareaModel = new \app\common\model\DispatchSkillArea();
        $where = [];
        $where["skill_id"] = $skill_id;
        $skillareaList = $skillareaModel->where($where)->select();
        if ($skillareaList) {
            $this->success(__('获取成功！'), $skillareaList);
        } else {
            $this->success(__('数据为空！'));
        }
    }


    /**
     * 获取订单列表
     */
    public function getOrderList() {
        $type = $this->request->request('type',1); // 订单类型:1=我的下单,2=我的接单
        $status = $this->request->request('status',999); // 订单状态:999=全部,-2=已取消,-1=拒绝接单,0=待付款,1=待确定,2=进行中,3=已完成
        $page = $this->request->request('page',1); // 分页
        $pageNum = $this->request->request('pageNum',10); // 分页
        // 分页搜索构建
        $pageStart = ($page-1)*$pageNum;
        $user = "o.recive_id";
        $type == 1 && $user = "o.recive_id";
        $type == 2 && $user = "o.user_id";
        // 主体列表信息
        $orderModel = new \app\common\model\DispatchOrder();
        $where = [];
        $type == 1 && $where["o.user_id"] = $this->auth->id;
        $type == 2 && $where["o.recive_id"] = $this->auth->id;
        $status != 999 && $where["o.status"] = $status;
        $orderList = $orderModel->alias("o")
            ->field("o.id,".$user." as user_id,o.make_time,o.describe,o.order_no,u.avatar,u.nickname,o.skill_image,o.skill_name,o.price,o.skill_unit,o.num,o.status,o.is_comment,o.createtime")
            ->join("hx_user u","u.id = ".$user)
            ->where($where)
            ->order("createtime","desc")
            ->limit($pageStart,$pageNum)
            ->select();
        if(!$orderList) {
            $this->success(__('数据为空！'),[]);
        }
        foreach($orderList as $k => &$v) {
            $v["make_time"] = date("Y-m-d H:i",$v["make_time"]);
            $v["createtime"] = date("Y-m-d",$v["createtime"]);
            $v["status_text"] = $orderModel->getStateAttr($v["status"]);
        }
        $this->success(__('获取成功！'), $orderList);
    }

}