<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2019/11/13
 * Time: 17:04
 */

namespace api\index\controller;


use cmf\controller\RestBaseController;
use think\Cache;
use think\cache\driver\Redis;
use think\Validate;
use think\Db;
use cmf\lib\Storage;

/**
 * @title 个人中心
 * @description
 */
class UserController extends RestBaseController
{
    /**
     * @title 登录注册
     * @description 接口说明
     * @author Guosheng
     * @url /index/User/login
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:phone type:int require:1 default: other: desc:手机号
     * @param name:code type:string require:1 default: other: desc:验证码
     *
     */
    public function login()
    {
        $user_id = $this->getUserId();
        $param = $this->request->param();
        $validate = new Validate([
            'phone' => 'require|max:11',
            'code'=>'require'
        ]);
        if (!$validate->check($param)) {
            $this->error(['code'=>40005,'msg'=>$validate->getError()]);
        }
        $code = Cache::get($param['phone']);
        if($code == $param['code']){
            $res['user_id'] = $user_id;
            $res['create_time'] = time();
            $res['phone'] = $param['phone'];
            $data = Db::name('integral')
                ->insert($res);
            if($data){
                $this->success('SUCCESS');
            }
        }else{
            $this->error(['code'=>40002,'msg'=>'验证码错误或者失效，请重新发送']);
        }
    }

    /**
     * @title 获取验证码
     * @description
     * @author Guosheng
     * @url /index/User/getcode
     * @method POST
     *
     * @param name:phone type:string require:1 other: desc:手机号码
     *
     * @return code:验证码
     */
    public function getcode()
    {
        $phone = $this->request->param('phone');
        if (empty($phone)) {
            $this->error(['code' => 40005, 'msg' => '缺少必要参数']);
        }
        if (!preg_match('/^1[0-9]{10}$/', $phone)) {
            $this->error(['code' => 40005, 'msg' => "请输入正确的手机格式!"]);
        }
        //生成验证码
        $number = generateCode();
        //发送验证码
        $data = array(
            'content' => "【蓝科环保】垃圾分类，共创绿色生活，您的验证码是：" .$number."，十分钟之内有效,请勿向他人泄漏您的验证码",//短信内容
            'mobile' => $phone,//手机号码
            'productid' => '676767',//产品id
            'xh' => ''//小号
        );
        $result = send_sms($data);
        if (substr($result, 0, strpos($result, ',')) != "1") {
            $this->error(['code' => 42001, 'msg' => $result]);
        }
        Cache::set($phone,$number,600);
//        $code = Db::name('code')
//            ->where('phone',$phone)
//            ->find();
//        if (empty($code)) {
//            $arr['phone'] = $phone;
//            $arr['create_time'] = time();
//            $arr['expire_time'] = time() + 60;
//            $arr['code'] = $number;
//            $result = Db::name('code')
//                ->insertGetId($arr);
//        } else {
//            $arr['code'] = $number;
//            $arr['update_time'] = time();
//            $arr['expire_time'] = time() + 60;
//            $result = Db::name('code')
//                ->where('phone',$phone)
//                ->update($arr);
//        }
//        if (empty($result)) {
//            $this->error(['code' => 40006, 'msg' => 'sql执行失败']);
//        }

        $this->success('SUCCESS');
    }

    /**
     * @title 判断用户身份
     * @description 接口说明
     * @author Guosheng
     * @url /index/User/judge
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @return is_set:0不是回收员  1是回收员
     */
    public function judge()
    {
        $user_id = $this->getUserId();
        $data = Db::name('user')
            ->where('id',$user_id)
            ->field('is_set')
            ->find();
        $this->success('success',$data);
    }

    /**
     * @title 我的首页
     * @description 接口说明
     * @author Guosheng
     * @url /index/User/userInfo
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @return user_nickname:昵称
     * @return avatar:头像
     * @return now:当前积分
     * @return num:参与次数
     * @return add_total:累计积分
     *
     */
    public function userInfo()
    {
        $user_id = $this->getUserId();
        $info = Db::name('integral')
            ->alias('a')
            ->join('user b','a.user_id = b.id')
            ->field('a.*,b.user_nickname,b.avatar')
            ->where('a.user_id',$user_id)
            ->find();
        if(empty($info)){
            $this->error(['code'=>40006,'msg'=>'您还没有注册，请先注册!']);
        }
        $this->success('SUCCESS',$info);

    }

    /**
     * @title 充值积分列表
     * @description 接口说明
     * @author Guosheng
     * @url /index/User/pay
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @return integral:积分
     * @return money:金额
     *
     */
    public function pay(){
        $user_id = $this->getUserId();
        $data = Db::name('pay')
            ->where('delete_time',0)
            ->select();
        $this->success('SUCCESS',$data);
    }

    /**
     * @title 提现金额列表
     * @description 接口说明
     * @author Guosheng
     * @url /index/User/money
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @return integral:积分
     * @return money:金额
     *
     */
    public function money(){
        $user_id = $this->getUserId();
        $data = Db::name('money')
            ->where('delete_time',0)
            ->select();
        $this->success('SUCCESS',$data);
    }

    /**
     * @title 我的回收订单
     * @description 我的回收订单
     * @author Guosheng
     * @url /index/User/recycleorder
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:status require:1 other desc:订单状态(不传或者为0是 已预约，1已接单，2已完成)
     *
     * @return id:订单ID
     * @return num:订单号
     * @return rgoods_name:商品名称
     * @return create_time:创建时间
     * @return sub_time:预约时间
     * @return ping:是否评价过 (1未评价2已评价过)
     *
     */
    public function recycleorder()
    {
        $user_id = $this->getUserId();
        $status = $this->request->param('status',0,'intval');
        if(empty($status) || $status == 0){
            //已预约的回收订单
           $data = Db::name('subscribe')
               ->where('user_id',$user_id)
               ->where('status',0)
               ->field('id,num,create_time,sub_time,attr_id')
               ->select()
               ->toArray();
            $res = $this->r_foreach($data);
            $this->success('SUCCESS',$res);
        }elseif ($status == 1){
            //已接单的回收订单
            $data = Db::name('subscribe')
                ->where('user_id',$user_id)
                ->where('status',1)
                ->field('id,num,create_time,sub_time,attr_id')
                ->select()
                ->toArray();
            $res = $this->r_foreach($data);
            $this->success('SUCCESS',$res);
        }elseif ($status == 2){
            //已完成的回收订单
            $data = Db::name('subscribe')
                ->where('user_id',$user_id)
                ->where('status',2)
                ->field('id,num,create_time,sub_time,attr_id')
                ->select()
                ->toArray();
            foreach ($data as &$v){
                $arr = Db::name('recyclecomment')
                    ->where('user_id',$user_id)
                    ->where('recycleorder_id',$v['id'])
                    ->find();
                if(empty($arr)){
                    $v['ping'] = 1;
                }else{
                    $v['ping'] = 2;
                }
                $v['attr_id'] = explode(',',$v['attr_id']);
                $v['create_time'] = date('Y-m-d H:i:s',$v['create_time']);
                foreach ($v['attr_id'] as &$v1){
                    $v1 = Db::name('attr')
                        ->alias('a')
                        ->join('rgoods r','a.rgoods_id=r.id')
                        ->field('r.rgoods_name')
                        ->where('a.id',$v1)
                        ->find();
                }
            }
            $this->success('SUCCESS',$data);
        }
    }

    //封装回收订单循环逻辑
    public function r_foreach($res){
        foreach ($res as &$v){
            $v['attr_id'] = explode(',',$v['attr_id']);
            $v['create_time'] = date('Y-m-d H:i:s',$v['create_time']);
            foreach ($v['attr_id'] as &$v1){
                $v1 = Db::name('attr')
                    ->alias('a')
                    ->join('rgoods r','a.rgoods_id=r.id')
                    ->field('r.rgoods_name')
                    ->where('a.id',$v1)
                    ->find();
            }
        }
        return $res;
    }

    /**
     * @title 取消回收订单
     * @description 取消回收订单
     * @author Guosheng
     * @url /index/User/cancleorder
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:order_id require:1 other desc:订单id
     *
     *
     */
    public function cancleorder(){
        $id = $this->request->param('order_id');
        if(empty($id)){
            $this->error(['code'=>41006,'msg'=>'缺少必要参数']);
        }
        $data = Db::name('subscribe')
            ->where('id',$id)
            ->delete();
        if($data){
            $this->success('SUCCESS');
        }else{
            $this->error('sql语句执行失败');
        }
    }

    /**
     * @title 取消商城订单
     * @description 取消商城订单
     * @author Guosheng
     * @url /index/User/cancleshoporder
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:order_id require:1 other desc:订单id
     *
     *
     */
    public function cancleshoporder(){
        $user_id = $this->getUserId();
        $id = $this->request->param('order_id');
        if(empty($id)){
            $this->error(['code'=>41006,'msg'=>'缺少必要参数']);
        }
        $list = Db::name('shoporder')
            ->where('id',$id)
            ->find();
        $info['total'] = $list['total'];
        $info['type'] = 7;
        $info['create_time'] = time();
        $info['user_id'] = $user_id;
        Db::name('detail')->insertGetId($info);
        $login = Db::name('integral')
            ->where('user_id',$user_id)
            ->find();
        $now_integral = $login['now_integral'] + $list['total'];
        $update_time = time();
        Db::name('integral')->where('user_id',$user_id)->update(['now_integral'=>$now_integral,'update_time'=>$update_time]);
        $data = Db::name('shoporder')
            ->where('id',$id)
            ->delete();
        if($data){
            $this->success('SUCCESS');
        }else{
            $this->error('sql语句执行失败');
        }
    }

    /**
     * @title 取消家政预约订单
     * @description 取消家政预约订单
     * @author Guosheng
     * @url /index/User/canclehomeorder
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:order_id require:1 other desc:订单id
     *
     *
     */
    public function canclehomeorder(){
        $user_id = $this->getUserId();
        $id = $this->request->param('order_id');
        if(empty($id)){
            $this->error(['code'=>41006,'msg'=>'缺少必要参数']);
        }
        $list = Db::name('subhome')
            ->where('id',$id)
            ->find();
        $info['total'] = $list['total'];
        $info['type'] = 8;
        $info['create_time'] = time();
        $info['user_id'] = $user_id;
        Db::name('detail')->insertGetId($info);
        $login = Db::name('integral')
            ->where('user_id',$user_id)
            ->find();
        $now_integral = $login['now_integral'] + $list['total'];
        $update_time = time();
        Db::name('integral')->where('user_id',$user_id)->update(['now_integral'=>$now_integral,'update_time'=>$update_time]);
        $data = Db::name('subhome')
            ->where('id',$id)
            ->delete();
        if($data){
            $this->success('SUCCESS');
        }else{
            $this->error('sql语句执行失败');
        }
    }

    /**
     * @title 回收订单详情
     * @description
     * @author GuoSheng
     * @url /index/User/orderDetail
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:order_id type:int require:1 default:desc:回收订单ID
     *
     * @return status:状态(0已预约，1已接单，2已完成)
     * @return num:订单号
     * @return create_time:下单时间
     * @return sub_time:预约时间
     * @return image:回收物品图片
     * @return content:留言备注
     * @return attr_id:[attr_name:属性名称 rgoods_name:商品名称]
     * @return serve:服务费
     * @return get_integral:获得积分
     *
     */
    public function orderDetail()
    {
        $user_id = $this->getUserId();
        //接收订单ID
        $id = $this->request->param('order_id');

        if(empty($id)){
            $this->error(['code'=>41006,'msg'=>'缺少必要参数']);
        }
        $res = Db::name('subscribe')
            ->where('id',$id)
            ->find();
        $data['status'] = $res['status'];
        $data['num'] = $res['num'];
        $data['create_time'] = date('Y-m-d H:i:s',$res['create_time']);
        $recycle_id = Db::name('recycle')->where('id',$res['recycle_id'])->field('address')->find();
        $data['recycle_id'] = $recycle_id['address'];
        $data['attr_id'] = explode(',',$res['attr_id']);
        foreach ($data['attr_id'] as &$v){
            $v = Db::name('attr')
                ->alias('a')
                ->join('rgoods r','a.rgoods_id = r.id')
                ->where('a.id',$v)
                ->field('a.attr_name,r.rgoods_name')
                ->find();
        }
        $data['sub_time'] = $res['sub_time'];
        $data['image'] = explode(',',$res['image']);
        $data['content'] = cmf_replace_content_file_url(htmlspecialchars_decode($res['content']));
        $data['get_integral'] = $res['get_integral'];
        $serve = Db::name('recyclefee')->where('id',1)->field('fee')->find();
        $data['serve'] = $serve['fee'];
        $this->success('SUCCESS',$data);
    }

    /**
     * @title 我的商城订单
     * @description 我的商城订单
     * @author Guosheng
     * @url /index/User/shoporder
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:status require:1 other desc:订单状态(不传或者为1是 已兑换，2已发货，3已完成)
     *
     * @return id:订单ID
     * @return num:订单号
     * @return goods_name:商品名称
     * @return create_time:创建时间
     * @return num:购买数量
     * @return total:总价
     *
     */
    public function shoporder()
    {
        $user_id = $this->getUserId();
        $status = $this->request->param('status',0,'intval');
        if(empty($status) || $status == 1){
            //已兑换的商城订单
            $data = Db::name('shoporder')
                ->where('user_id',$user_id)
                ->where('orderstatus',1)
                ->field('id,number,create_time,num,shopgoods_id')
                ->select()
                ->toArray();
            $data = $this->s_foreach($data);
            $this->success('SUCCESS',$data);
        }elseif ($status == 2){
            //已发货的商城订单
            $data = Db::name('shoporder')
                ->where('user_id',$user_id)
                ->where('orderstatus',2)
                ->field('id,number,create_time,num,shopgoods_id')
                ->select()
                ->toArray();
            $data = $this->s_foreach($data);
            $this->success('SUCCESS',$data);
        }elseif ($status == 3){
            //已完成的商城订单
            $data = Db::name('shoporder')
                ->where('user_id',$user_id)
                ->where('orderstatus',3)
                ->field('id,number,create_time,num,shopgoods_id')
                ->select()
                ->toArray();
            foreach ($data as &$v){
                $arr = Db::name('shopcomment')
                    ->where('user_id',$user_id)
                    ->where('shoporder_id',$v['id'])
                    ->find();
                if(empty($arr)){
                    $v['ping'] = 1;
                }else{
                    $v['ping'] = 2;
                }
                $v['create_time'] = date('Y-m-d H:i:s',$v['create_time']);
                $v['shopgoods_id'] = Db::name('shopgoods')
                    ->where('id',$v['shopgoods_id'])
                    ->field('id as goods_id,goods_name,thumbnail,price')
                    ->find();
            }
            $this->success('SUCCESS',$data);
        }
    }

    //封装商城订单循环逻辑
    public function s_foreach($res){
        foreach ($res as &$v){
            $v['create_time'] = date('Y-m-d H:i:s',$v['create_time']);
            $v['shopgoods_id'] = Db::name('shopgoods')
                ->where('id',$v['shopgoods_id'])
                ->field('goods_name,thumbnail,price')
                ->find();
        }
        return $res;
    }

    /**
     * @title 商城订单详情
     * @description 商城订单详情
     * @author GuoSheng
     * @url /index/User/sorderDetail
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:order_id type:int require:1 default: desc:商城订单ID
     *
     * @return status:状态(0已下单，1已发货，2已完成)
     * @return number:订单号
     * @return create_time:下单时间
     * @return express_num:快递单号
     * @return shoprecycle_id:收货地址
     * @return thumbnail:商品图片
     * @return goods_id:商品ID
     * @return goods_name:商品名称
     * @return content:留言备注
     * @return freight:运费
     * @return total:价格
     * @return num:购买数量
     * @return total_sum:总计
     * @return shopgoods_id:商品信息
     *
     */
    public function sorderDetail()
    {
        $user_id = $this->getUserId();
        //接收商品订单ID
        $id = $this->request->param('order_id');
        if(empty($id)){
            $this->error(['code'=>41006,'msg'=>'缺少必要参数']);
        }
        $res = Db::name('shoporder')
            ->where('id',$id)
            ->find();
        $data['status'] = $res['status'];
        $data['number'] = $res['number'];
        $data['create_time'] = date('Y-m-d H:i:s',$res['create_time']);
        $data['express_num'] = $res['express_num'];
        $recycle_id = Db::name('shoprecycle')->where('id',$res['shoprecycle_id'])->field('address')->find();
        $data['shoprecycle_id'] = $recycle_id['address'];
        $shopgoods_id = Db::name('shopgoods')
            ->where('id',$res['shopgoods_id'])
            ->field('id,goods_name,thumbnail,freight,price')
            ->find();
        $data['goods_id'] = $res['shopgoods_id'];
        $data['freight'] = $shopgoods_id['freight'];
        $data['price'] = $shopgoods_id['price'];
        $data['total'] = $res['total'];
        $data['num'] = $res['num'];
        $data['total_sum'] = $data['total'] + $data['freight'];
        $data['thumbnail'] = cmf_get_image_preview_url($shopgoods_id['thumbnail']);
        $data['goods_name'] = $shopgoods_id['goods_name'];
        $data['content'] = cmf_replace_content_file_url(htmlspecialchars_decode($res['content']));
        $this->success('SUCCESS',$data);
    }

    /**
     * @title 我的家政预约订单
     * @description 我的家政预约订单
     * @author Guosheng
     * @url /index/User/subhomeorder
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:status require:1 other desc:订单状态(1已预约，2已接单，3已完成)
     *
     * @return id:订单ID
     * @return num:订单号
     * @return home_id:家政公司名称
     * @return service_id:服务项目名称
     * @return price:价格
     * @return sub_time:预约时间
     *
     */
    public function subhomeorder()
    {
        $user_id = $this->getUserId();
        $status = $this->request->param('status',0,'intval');
        if(empty($status) || $status == 1){
            //已预约的回收订单
            $data = Db::name('subhome')
                ->where('user_id',$user_id)
                ->where('status',1)
                ->field('id,num,create_time,sub_time,home_id,service_id')
                ->select()
                ->toArray();
            foreach ($data as &$v){
                $v['create_time'] = date('Y-m-d H:i:s',$v['create_time']);
                $home = Db::name('home')->where('id',$v['home_id'])->field('home_name')->find();
                $v['home_id'] = $home['home_name'];
                $service = Db::name('service')->where('id',$v['service_id'])->field('sever_name,price')->find();
                $v['service_id'] = $service['sever_name'];
                $v['price'] = $service['price'];
            }
            $this->success('SUCCESS',$data);
        }elseif ($status == 2){
            //已接单的回收订单
            $data = Db::name('subhome')
                ->where('user_id',$user_id)
                ->where('status',2)
                ->field('id,num,create_time,sub_time,home_id,service_id')
                ->select()
                ->toArray();
            foreach ($data as &$v){
                $v['create_time'] = date('Y-m-d H:i:s',$v['create_time']);
                $home = Db::name('home')->where('id',$v['home_id'])->field('home_name')->find();
                $v['home_id'] = $home['home_name'];
                $service = Db::name('service')->where('id',$v['service_id'])->field('sever_name,price')->find();
                $v['service_id'] = $service['sever_name'];
                $v['price'] = $service['price'];
            }
            $this->success('SUCCESS',$data);
        }elseif ($status == 3){
            //已完成的回收订单
            $data = Db::name('subhome')
                ->where('user_id',$user_id)
                ->where('status',3)
                ->field('id,num,create_time,sub_time,home_id,service_id')
                ->select()
                ->toArray();
            foreach ($data as &$v){
                $arr = Db::name('homecomment')
                    ->where('user_id',$user_id)
                    ->where('order_id',$v['id'])
                    ->find();
                if(empty($arr)){
                    $v['ping'] = 1;
                }else{
                    $v['ping'] = 2;
                }
                $v['create_time'] = date('Y-m-d H:i:s',$v['create_time']);
                $home = Db::name('home')->where('id',$v['home_id'])->field('home_name')->find();
                $v['home_name'] = $home['home_name'];
                $service = Db::name('service')->where('id',$v['service_id'])->field('sever_name,price')->find();
                $v['service_id'] = $service['sever_name'];
                $v['price'] = $service['price'];
            }
            $this->success('SUCCESS',$data);
        }
    }

    /**
     * @title 家政预约订单详情
     * @description 家政预约订单详情
     * @author GuoSheng
     * @url /index/User/homeOrderDetail
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:order_id type:int require:1 default: desc:家政预约订单ID
     *
     * @return status:状态(1已预约，2已接单，3已完成)
     * @return num:订单号
     * @return create_time:下单时间
     * @return sub_time:预约时间
     * @return homeaddress_id:预约地址
     * @return home_id:家政公司名称
     * @return thumbnail:家政公司缩略图
     * @return price:价格
     * @return service_id:服务名称
     * @return content:留言备注
     *
     */
    public function homeOrderDetail()
    {
        $user_id = $this->getUserId();
        //接收订单ID
        $id = $this->request->param('order_id');
        if(empty($id)){
            $this->error(['code'=>41006,'msg'=>'缺少必要参数']);
        }
        $res = Db::name('subhome')
            ->where('id',$id)
            ->find();
        $data['status'] = $res['status'];
        $data['num'] = $res['num'];
        $data['create_time'] = date('Y-m-d H:i:s',$res['create_time']);
        $data['sub_time'] = $res['sub_time'];
        $homeaddress_id = Db::name('homeadress')->where('id',$res['homeaddress_id'])->field('name')->find();
        $data['homeaddress_id'] = $homeaddress_id['name'];
        $home = Db::name('home')->where('id',$res['home_id'])->field('id,home_name,thumbnail')->find();
        $service = Db::name('service')->where('id',$res['service_id'])->field('sever_name,price')->find();
        $data['thumbnail'] = $home['thumbnail'];
        $data['home_id'] = $res['home_id'];
        $data['home_name'] = $home['home_name'];
        $data['service_id'] = $service['sever_name'];
        $data['price'] = $service['price'];
        $data['content'] = cmf_replace_content_file_url(htmlspecialchars_decode($res['content']));
        $this->success('SUCCESS',$data);
    }

    /**
     * @title 回收员已预约订单
     * @description 回收员已预约订单
     * @author Guosheng
     * @url /index/User/collect
     * @method POST
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @return id:订单ID
     * @return num:订单号
     * @return goods_name:商品名称
     * @return create_time:创建时间
     * @return sub_time:预约时间
     *
     */
    public function collect()
    {
        $user_id = $this->getUserId();
        $where['status'] = ['eq',0];
        $data = Db::name('subscribe')
            ->where($where)
            ->field('id,num,create_time,sub_time,attr_id')
            ->select()
            ->toArray();
        foreach ($data as &$v){
            $v['goods_name'] = [];
            $attr_id = explode(',',$v['attr_id']);
            foreach ($attr_id as &$v1){
                $v1 = Db::name('attr')
                    ->alias('a')
                    ->join('rgoods r','a.rgoods_id=r.id')
                    ->field('r.rgoods_name')
                    ->where('a.id',$v1)
                    ->find();
                array_push($v['goods_name'],$v1['rgoods_name']);
            }
            $v['goods_name'] = implode(',',$v['goods_name']);
        }
        $this->success('success',$data);
    }

    /**
     * @title 回收员已接单订单
     * @description 回收员已接单订单
     * @author Guosheng
     * @url /index/User/jie
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @return id:订单ID
     * @return num:订单号
     * @return goods_name:商品名称
     * @return create_time:创建时间
     * @return sub_time:预约时间
     *
     */
    public function jie()
    {
        $user_id = $this->getUserId();
        $list = Db::name('collector')
            ->where('user_id',$user_id)
            ->where('status',1)
            ->column('order_id');
        foreach ($list as &$val){
            $val = Db::name('subscribe')
                ->where('id',$val)
                ->field('id,num,create_time,sub_time,attr_id')
                ->find();
            $val['create_time'] = date('Y-m-d H:i:s',$val['create_time']);
            $val['attr_id'] = explode(',',$val['attr_id']);
            $val['goods_name'] = [];
            foreach ($val['attr_id'] as &$v){
                $v1 = Db::name('attr')
                    ->alias('a')
                    ->join('rgoods r','a.rgoods_id=r.id')
                    ->field('r.rgoods_name')
                    ->where('a.id',$v)
                    ->find();
                array_push($val['goods_name'],$v1['rgoods_name']);

            }
            $val['goods_name'] = implode(',',$val['goods_name']);
        }
        $this->success('success',$list);


    }

    /**
     * @title 回收员已完成订单
     * @description 回收员已完成订单
     * @author Guosheng
     * @url /index/User/finish
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @return id:订单ID
     * @return num:订单号
     * @return goods_name:商品名称
     * @return create_time:创建时间
     * @return sub_time:预约时间
     *
     */
    public function finish()
    {
        $user_id = $this->getUserId();
        $list = Db::name('collector')
            ->where('user_id',$user_id)
            ->where('status',2)
            ->column('order_id');
        foreach ($list as &$val){
            $val = Db::name('subscribe')
                ->where('id',$val)
                ->field('id,num,create_time,sub_time,attr_id,get_integral')
                ->find();
            $val['create_time'] = date('Y-m-d H:i:s',$val['create_time']);
            $val['attr_id'] = explode(',',$val['attr_id']);
            $val['goods_name'] = [];
            foreach ($val['attr_id'] as &$v){
                $v1 = Db::name('attr')
                    ->alias('a')
                    ->join('rgoods r','a.rgoods_id=r.id')
                    ->field('r.rgoods_name')
                    ->where('a.id',$v)
                    ->find();
                array_push($val['goods_name'],$v1['rgoods_name']);

            }
            $val['goods_name'] = implode(',',$val['goods_name']);
        }
        $this->success('success',$list);


    }

    /**
     * @title 回收员确认接单
     * @description 回收员确认接单
     * @author Guosheng
     * @url /index/User/affirm
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:order_id type:int require:1 other: desc:订单ID
     *
     * @return id:订单ID
     * @return num:订单号
     * @return goods_name:商品名称
     * @return create_time:创建时间
     * @return sub_time:预约时间
     *
     */
    public function affirm()
    {
        $user_id = $this->getUserId();
        $order_id = $this->request->param('order_id');
        if(empty($order_id)){
            $this->error('缺少必要参数');
        }
        $data['order_id'] = $order_id;
        $data['user_id'] = $user_id;
        $data['create_time'] = time();
        Db::name('subscribe')
            ->where('id',$order_id)
            ->update(['status'=>1]);
        $res = Db::name('collector')
            ->insertGetId($data);
        if($res){
            $this->success('接单成功');
        }else{
            $this->error('sql语句错误');
        }
    }

    /**
     * @title 回收员确认完成
     * @description 回收员确认完成
     * @author Guosheng
     * @url /index/User/aff_finish
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:order_id type:int require:1 other: desc:订单ID
     * @param name:get_integral type:int require:1 other: desc:获得积分
     *
     * @return id:订单ID
     * @return num:订单号
     * @return goods_name:商品名称
     * @return create_time:创建时间
     * @return sub_time:预约时间
     *
     */
    public function aff_finish()
    {
        $user_id = $this->getUserId();
        $order_id = $this->request->param('order_id');
        $get_integral = $this->request->param('get_integral');
        if(empty($order_id)){
            $this->error('缺少必要参数');
        }
        //对应的数据加入回收员已完成订单中
        $data['order_id'] = $order_id;
        $data['user_id'] = $user_id;
        $data['create_time'] = time();
        $data['status'] = 2;

        //查询我的积分信息
        $info = Db::name('integral')
            ->where('user_id',$user_id)
            ->find();
        $res['num'] = $info['num'] + 1;
        $res['add_total'] = $info['add_total'] + $get_integral;
        $res['now_integral'] = $info['now_integral'] + $get_integral;

        //添加对应的积分明细
        $detail['user_id'] = $user_id;
        $detail['total'] = $get_integral;
        $detail['create_time'] = time();
        $detail['type'] = 5;

        // 启动事务
        Db::startTrans();
        try{
            $result = Db::name('subscribe')
                ->where('id',$order_id)
                ->update(['status'=>2,'get_integral'=>$get_integral]);
            $integral = Db::name('integral')
                ->where('user_id',$user_id)
                ->update($res);
            $detail = Db::name('detail')->insertGetId($detail);

            //对应的数据加入回收员已完成订单中
            $collector = Db::name('collector')
                ->insertGetId($data);
            if($result && $integral && $detail && $collector){
                // 提交事务
                Db::commit();
                true;
            }
        } catch (\Exception $e) {
            // 回滚事务
            Db::rollback();
        }
        $this->success('成功');
    }

    /**
     * @title 有奖分享（二维码）
     * @description 有奖分享（二维码）
     * @author Guosheng
     * @url /index/User/code
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:route type:string require:1 other: desc:页面路径与参数
     *
     */
    public function code()
    {
        $user_id = $this->getUserId();
        $url = $this->request->param('route');
        if(empty($url)){
            $this->error(['code'=>40005,'msg'=>'缺少必要参数']);
        }
        $savePath = './../upload/poster/';
        if (!file_exists($savePath)){
            mkdir($savePath, 0777,true);
        }
        if(!file_exists("./upload/qrcode/code_$user_id.jpg")){
            $code = $this->getusercode($user_id,$url);
        }else{
            $code = "qrcode/code_$user_id.jpg";
        }
        $data = 'http://scrap.w.bronet.cn/upload/'.$code;
        $this->success('SUCCESS',$data);
    }

    //判断当前操作系统
    public function getOperateSys(){
        $os_name = php_uname('s');
        //判断
        if(strpos($os_name,"Linux")!==false){
            $os_str="Linux";
        }else if(strpos($os_name,"Windows")!==false){
            $os_str="Windows";
        }else{
            $os_str='';
        }
        return $os_str;
    }

    public function getusercode($user_id,$url){
        $savePath = './../upload/get_code/';
        $filename = "code_$user_id.jpg";
        if(!file_exists($savePath.$filename)){
            $access_token = $this->get_access_token();
            $qrcode = $this->imgShare($user_id,$access_token,$url);
        }elsE{
            $qrcode = "qrcode/code_".$user_id.".jpg";
        }
        return $qrcode;
    }

    public function imgShare($user_id,$access_token,$path){
        $url = "https://api.weixin.qq.com/wxa/getwxacode?access_token=".$access_token;
        $post['path'] = $path;
        $post['width'] = 280;
        $result = $this->curl($url, json_encode($post));
        $array = json_decode($result, true);
        if($array['errmsg']) {
            return false;
        }
        // 分享二维码保存到用户数据
        if (!file_exists(ROOT_PATH . 'public' . DS . 'upload/qrcode/')) {
            mkdir(ROOT_PATH . 'public' . DS . 'upload/qrcode/', 0777, true);
        }
        $filename = "code_".$user_id.".jpg";
        $furl = ROOT_PATH . 'public' . DS . 'upload/qrcode/'.$filename;
        file_put_contents($furl, $result);
        return "qrcode/".$filename;
    }
    // curl方法
    protected function curl($url, $post = null, $header = null) {
        // 初始化
        $curl = curl_init();
        // 设置抓取的url
        curl_setopt($curl, CURLOPT_URL, $url);
        // 请求头
        if($header) {
            curl_setopt($curl,CURLOPT_HTTPHEADER,$header);
        }
        // 设置头文件的信息作为数据流输出
        curl_setopt($curl, CURLOPT_HEADER, 0);
        curl_setopt($curl, CURLOPT_NOBODY, 0);
        curl_setopt($curl, CURLOPT_TIMEOUT, 500);
        // 设置获取的信息以文件流的形式返回，而不是直接输出。
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
        if($post) {
            curl_setopt($curl, CURLOPT_POST, 1);
            //把POST的变量加上
            curl_setopt($curl, CURLOPT_POSTFIELDS, $post);
        }
        // 执行命令
        $data = curl_exec($curl);
        if (curl_errno($curl)) {
            $data = curl_error($curl);
        }
        return $data;
    }
    //获取access_token
    public function get_access_token()
    {
        $app_id = config('app_id');
        $app_secret = config('app_secret');
        $url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid='.$app_id.'&secret='.$app_secret;
        $res = $this->http_get($url);
        $json_arr = json_decode($res,true);
        $token = $json_arr['access_token'];
        return $token;
    }
    //curl  get请求
    public function http_get($url){
        $curl = curl_init();//启动一个CURL会话
        curl_setopt($curl, CURLOPT_URL,$url);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); // 对认证证书来源的检查
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
        curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
        curl_setopt($curl, CURLOPT_HEADER, false);//不开启header
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 获取的信息以文件流的形式返回
        $result = curl_exec($curl); //执行操作
        curl_close($curl);
        return $result;
    }
    //curl post请求
    public function http_post($url,$data){
        $curl = curl_init();//启动一个CURL会话
        curl_setopt($curl, CURLOPT_URL, $url); // 要访问的地址
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); // 对认证证书来源的检查
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
        curl_setopt($curl, CURLOPT_POST, true); // 发送一个常规的Post请求
        curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($data)); // Post提交的数据包
        curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
        curl_setopt($curl, CURLOPT_HEADER, false); // 开启header
        //curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);//请求头部
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 获取的信息以文件流的形式返回
        $result = curl_exec($curl); //执行操作
        curl_close($curl);
        return $result;
    }

    /**
     * @title 添加回收订单评价
     * @description
     * @author GuoSheng
     * @url /index/User/comment
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:recycleorder_id type:int require:1 other: desc:订单id
     * @param name:speed type:int require:1 other: desc:上门速度
     * @param name:service type:int require:1 other: desc:服务态度
     * @param name:recycle type:int require:1 other: desc:回收体验
     * @param name:content type:string require:1 other: desc:评价内容
     * @param name:thumbnail type:string require:1 other: desc:图片
     *
     */
    public function comment()
    {
        $user_id = $this->getUserId();
        $param = $this->request->param();
        $param['user_id'] = $user_id;
        $param['create_time'] = time();
        $validate = new Validate([
            'recycleorder_id' => 'require',
            'speed' => 'require',
            'service'=>'require',
            'recycle'=>'require',
            'content'=>'require'
        ]);
        $validate->message([
            'recycle_id'=>'订单ID不能为空',
            'speed'=>'上门速度不能为空',
            'service'=>'服务态度不能为空',
            'recycle'=>'回收体验不能为空',
            'content'=>'评价不能为空'
        ]);
        if (!$validate->check($param)) {
            $this->error(['code'=>40005,'msg'=>$validate->getError()]);
        }
        $data = Db::name('recyclecomment')
            ->insert($param);
        if(empty($data)){
            $this->error(['code'=>40006,'msg'=>'sql执行失败']);
        }
        $this->success('SUCCESS');

    }

    /**
     * @title 添加商城订单评价
     * @description
     * @author GuoSheng
     * @url /index/User/shopcomment
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:shoporder_id type:int require:1 other: desc:订单id
     * @param name:shopgood_id type:int require:1 other: desc:商品ID
     * @param name:speed type:int require:1 other: desc:上门速度
     * @param name:service type:int require:1 other: desc:服务态度
     * @param name:recycle type:int require:1 other: desc:回收体验
     * @param name:content type:string require:1 other: desc:评价内容
     * @param name:thumbnail type:string require:1 other: desc:图片
     *
     */
    public function shopcomment()
    {
        $user_id = $this->getUserId();
        $param = $this->request->param();
        $param['user_id'] = $user_id;
        $param['create_time'] = time();
        $validate = new Validate([
            'shoporder_id' => 'require',
            'shopgood_id'=>'require',
            'speed' => 'require',
            'service'=>'require',
            'recycle'=>'require',
            'content'=>'require'
        ]);
        $validate->message([
            'shoporder_id'=>'订单ID不能为空',
            'shopgood_id'=>'商品ID不能为空',
            'speed'=>'上门速度不能为空',
            'service'=>'服务态度不能为空',
            'recycle'=>'回收体验不能为空',
            'content'=>'评价不能为空'
        ]);
        if (!$validate->check($param)) {
            $this->error(['code'=>40005,'msg'=>$validate->getError()]);
        }
        $data = Db::name('shopcomment')
            ->insert($param);
        if(empty($data)){
            $this->error(['code'=>40006,'msg'=>'sql执行失败']);
        }
        $this->success('SUCCESS');

    }

    /**
     * @title 添加家政预约订单评价
     * @description
     * @author GuoSheng
     * @url /index/User/homecomment
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:order_id type:int require:1 other: desc:订单ID
     * @param name:home_id type:int require:1 other: desc:家政公司ID
     * @param name:speed type:int require:1 other: desc:服务质量
     * @param name:service type:int require:1 other: desc:服务态度
     * @param name:recycle type:int require:1 other: desc:服务体验
     * @param name:content type:string require:1 other: desc:评价内容
     * @param name:thumbnail type:string require:1 other: desc:图片
     *
     */
    public function homecomment()
    {
        $user_id = $this->getUserId();
        $param = $this->request->param();
        $param['user_id'] = $user_id;
        $param['create_time'] = time();
        $validate = new Validate([
            'order_id' => 'require',
            'home_id'=>'require',
            'speed' => 'require',
            'service'=>'require',
            'recycle'=>'require',
            'content'=>'require'
        ]);
        $validate->message([
            'order_id'=>'订单ID不能为空',
            'home_id'=>'家政公司ID不能为空',
            'speed'=>'服务质量不能为空',
            'service'=>'服务态度不能为空',
            'recycle'=>'服务体验不能为空',
            'content'=>'评价不能为空'
        ]);
        if (!$validate->check($param)) {
            $this->error(['code'=>40005,'msg'=>$validate->getError()]);
        }
        $data = Db::name('homecomment')
            ->insert($param);
        if(empty($data)){
            $this->error(['code'=>40006,'msg'=>'sql执行失败']);
        }
        $this->success('SUCCESS');

    }


    /**
     * @title 查看回收订单评价
     * @description
     * @author GuoSheng
     * @url /index/User/selectcomment
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:recycleorder_id type:int require:1 other: desc:订单id
     *
     * @return speed:上门速度
     * @return service:服务态度
     * @return recycle:回收体验
     * @return content:评价内容
     * @return thumbnail:图片
     *
     */
    public function selectcomment()
    {
        $user_id = $this->getUserId();
        $recycleorder_id = $this->request->param('recycleorder_id');
        if(empty($recycleorder_id)){
            $this->error(['code'=>2,'msg'=>'缺少必要参数']);
        }
        $data = Db::name('recyclecomment')
            ->where('recycleorder_id',$recycleorder_id)
            ->find();
        $data['content'] = cmf_replace_content_file_url(htmlspecialchars_decode($data['content']));
        $data['thumbnail'] = explode(',',$data['thumbnail']);
        $this->success('SUCCESS',$data);

    }

    /**
     * @title 查看商城订单评价
     * @description
     * @author GuoSheng
     * @url /index/User/selshopcomment
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:shoporder_id type:int require:1 other: desc:订单id
     *
     * @return speed:上门速度
     * @return service:服务态度
     * @return recycle:回收体验
     * @return content:评价内容
     * @return thumbnail:图片
     *
     */
    public function selshopcomment()
    {
        $user_id = $this->getUserId();
        $shoporder_id = $this->request->param('shoporder_id');
        if(empty($shoporder_id)){
            $this->error(['code'=>2,'msg'=>'缺少必要参数']);
        }

        $data = Db::name('shopcomment')
            ->where('user_id',$user_id)
            ->where('shoporder_id',$shoporder_id)
            ->find();
        $data['content'] = cmf_replace_content_file_url(htmlspecialchars_decode($data['content']));
        $data['thumbnail'] = explode(',',$data['thumbnail']);
        $this->success('SUCCESS',$data);

    }

    /**
     * @title 查看家政预约订单评价
     * @description
     * @author GuoSheng
     * @url /index/User/selhomecomment
     * @method GET
     *
     * @header name:XX-Token require:1 default: desc:token
     *
     * @param name:order_id type:int require:1 other: desc:订单ID
     *
     * @return speed:服务质量
     * @return service:服务态度
     * @return recycle:服务体验
     * @return content:评价内容
     * @return thumbnail:图片
     *
     */
    public function selhomecomment()
    {
        $user_id = $this->getUserId();
        $num = $this->request->param('order_id');
        if(empty($num)){
            $this->error(['code'=>2,'msg'=>'缺少必要参数']);
        }
        $data = Db::name('homecomment')
            ->where('user_id',$user_id)
            ->where('order_id',$num)
            ->find();
        $data['content'] = cmf_replace_content_file_url(htmlspecialchars_decode($data['content']));
        $data['thumbnail'] = explode(',',$data['thumbnail']);
        $this->success('SUCCESS',$data);

    }


}