yiyonghulian_new/app/Http/Controllers/Api/AskController.php

<?php
namespace App\Http\Controllers\Api;

use App\Http\Requests\Api\PostsRequests\AskRequest;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use App\Wen\Utils\Utils;
use App\Models\WxOrder;
use App\Models\User\WxUser;
use App\Http\Controllers\Api\Traits\PayTrait;
use App\Wen\Utils\Settings;
use App\Wen\Utils\UserUtils;
use App\Models\WxSlideshow;
use App\Wen\Utils\GatewayUtils;

class AskController extends BaseController
{
    use PayTrait;

    public function test(Request $request){
        $chat_content = '你好'.date('Y-m-d H:i:s');
        $chat_image = '';
        $uid = $request->uid;
        $oid = 4395;
        $websocket_id = GatewayUtils::uid2client_id($oid);
        $websocket_id = 'all';
        if($websocket_id){
            GatewayUtils::success($websocket_id, 5, ['chat_content'=>_mini_emoji($chat_content, true), 'chat_image'=>$chat_image,
                'from_user'=>UserUtils::get_cached_user($uid) ]);
        }
    }

    public function config(Request $request){
        $result = [
            'askorder_default_question' => Settings::get('askorder_default_question', ''),
            'askorder_default_hidden' => Settings::get('askorder_default_hidden', ''),
            'askorder_default_public' => Settings::get('askorder_default_public', ''),
            'askorder_default_rule' => Settings::get('askorder_default_rule', ''),
        ];

        return $this->success($result);
    }

    //发起一个咨询
    public function createNew(AskRequest $request){
        // 验证
        $request->validate('createnew');

        //提示绑定手机号
        $userinfo = DB::table('wx_user')->where('id',$request->uid)->first();
        if(empty($userinfo->phone)){
            return $this->fail(200016,[],'请先绑定手机号');
        }

        //
        $question = trim($request->question);
        if(mb_strlen($question) > 300){
            return $this->fail(200016,[],'咨询内容不能超过300字');
        }

        //
        $images   = trim($request->images);
        $images   = trim($images,',');
        if(count(explode(',',$images)) > 9){
            return $this->fail(200016,[],'咨询图片最大9张');
        }

        //验证答主
        if($request->uid == $request->blogger_user_id){
            return $this->fail(200016,[],'不能咨询自己');
        }
        $blogger = DB::table('blogger')->where('user_id',$request->blogger_user_id)->first();
        if(empty($blogger)){
            return $this->fail(200016,[],'此答主没有经过认证');
        }
        if($blogger->status != 1){
            return $this->fail(200016,[],'此答主没有经过认证');
        }
        if($blogger->ask_status != 1){
            return $this->fail(200016,[],'此答主暂时不接受咨询');
        }

        //
        $data = [
            'user_id' => $request->uid,
            'blogger_user_id' => $request->blogger_user_id,
            'question' => $question,
            'images' => $images,
            'createtime' => time(),
            'ask_price' => $blogger->ask_price,
            'sit_price' => $blogger->sit_price,
            'ask_minute' => $blogger->ask_minute,

            'is_hidden' => $request->is_hidden,
            'is_public' => $request->is_public,

            'blogger_rate' => Settings::get('askorder_blogger_balance_rate'),
        ];
        $data['blogger_price'] = bcdiv(bcmul($data['ask_price'],$data['blogger_rate'],2),100,2);

        //0元的直接已付
        $need_pay = 1;
        if($blogger->ask_price == 0){
            $data['status'] = 10;
            $data['paytime'] = time();

            $need_pay = 0;
        }

        $order_id = DB::table('ask_order')->insertGetId($data);

        //给答主发短信
        $blogger_userinfo = DB::table('wx_user')->where('id',$request->blogger_user_id)->first();
        if($blogger_userinfo && $blogger_userinfo->phone && $blogger_userinfo->country_code){
            $idd   = $blogger_userinfo->country_code;
            $phone = $blogger_userinfo->phone;

            //
            $res = Utils::sendSMSnotice($idd,$phone);
        }


        return $this->success(['order_id'=>$order_id,'need_pay'=>$need_pay]);
    }

    //评价此次咨询
    public function evaluate(AskRequest $request){
        // 验证
        $request->validate('evaluate');

        //
        $eva_content = trim($request->eva_content);
        if(mb_strlen($eva_content) > 100){
            return $this->fail(200016,[],'咨询内容不能超过100字');
        }

        //
        $score = $request->eva_score;
        if($score < 0){
            $score = 0;
        }
        if($score > 5){
            $score = 5;
        }

        //
        $order_id = _empty_default_($request->order_id,0);

        $order = DB::table('ask_order')->where('id',$order_id)->where('user_id',$request->uid)->where('status','>',0)->first();
        if(empty($order)){
            return $this->fail(200016,[],'没有找到该咨询');
        }
        if($order->status != 20){
            return $this->fail(200016,[],'咨询还没有结束');
        }
        if($order->eva_time != 0){
            return $this->fail(200016,[],'已经评价过了');
        }

        //
        $update = [
            'eva_score'   => $request->eva_score,
            'eva_content' => $request->eva_content,
            'eva_time'    => time(),
        ];
        DB::table('ask_order')->where('id',$order_id)->update($update);

        //给答主冗余平均分
        $eva_score = DB::table('ask_order')->where('blogger_user_id',$order->blogger_user_id)->where('status',20)->where('eva_time','!=',0)->avg('eva_score');
        if($eva_score < 0){
            $eva_score = 0;
        }
        if($eva_score > 5){
            $eva_score = 5;
        }
        $eva_score = bcadd($eva_score,0,1);
        DB::table('blogger')->where('user_id',$order->blogger_user_id)->update(['order_eva_score'=>$eva_score]);

        return $this->success();

    }

    //结束此次咨询，用户或答主都可操作
    public function finish(Request $request){
        //
        $order_id = _empty_default_($request->order_id,0);
        $uid      = $request->uid;

        $order = DB::table('ask_order')->where('id',$order_id)->where('status','>',0)
//            ->where('user_id',$request->uid)
            ->where(function($query) use ($uid) {
                $query->orWhere('user_id',         $uid)
                      ->orWhere('blogger_user_id', $uid);
            })
            ->first();

        if(empty($order)){
            return $this->fail(200016,[],'没有找到该咨询');
        }
        if($order->status == 20){
            return $this->fail(200016,[],'咨询已经结束了');
        }

        //给答主钱
        UserUtils::update_user_financial($order->blogger_user_id, 103, $order->blogger_price, '咨询收益'.$order->blogger_price);

        //更新状态
        $update = [
            'status'      => 20,
            'finish_time' => time(),
        ];
        DB::table('ask_order')->where('id',$order_id)->update($update);

        //更新答主的完成订单数
        $order_number = DB::table('ask_order')->where('blogger_user_id',$order->blogger_user_id)->where('status',20)->count();
        DB::table('blogger')->where('user_id',$order->blogger_user_id)->update(['order_number' => $order_number]);

        return $this->success();
    }

    //点赞
    public function good(Request $request){
        //
        $order_id = _empty_default_($request->order_id,0);
        $uid      = $request->uid;

        $good = DB::table('ask_order_good')->where('order_id',$order_id)->where('user_id',$request->uid)->first();
        if(!empty($good)){
            return $this->fail(200016,[],'您已经赞过了');
        }

        DB::table('ask_order_good')->insertGetId([
            'order_id' => $order_id,
            'user_id'  => $request->uid,
            'createtime' => time(),
        ]);

        //冗余
        $good_number = DB::table('ask_order_good')->where('order_id',$order_id)->count();
        DB::table('ask_order')->where('id',$order_id)->update(['good_number'=>$good_number]);

        return $this->success();
    }

    //旁听
    public function sit(Request $request){
        $order_id = _empty_default_($request->order_id,0);

        $order = DB::table('ask_order')->where('id',$order_id)->first();
        if(empty($order)){
            return $this->fail(200016,[],'没有找到该咨询');
        }
        if($order->status != 20){
            return $this->fail(200016,[],'咨询还没有结束');
        }
        if($order->is_public != 1){
            return $this->fail(200016,[],'咨询没有公开');
        }
        if($order->user_id == $request->uid){
            return $this->fail(200016,[],'不需要旁听自己咨询的内容');
        }
        if($order->blogger_user_id == $request->uid){
            return $this->fail(200016,[],'不需要旁听自己回答的内容');
        }

        //是否需要支付
        $need_pay = 1;

        //检查旁听订单
        $sit_order_id = 0;
        $sit_order = DB::table('ask_sit_order')->where('order_id',$order_id)->where('sit_user_id',$request->uid)->first();
        if($sit_order){
            $sit_order_id = $sit_order->id;
            if($sit_order->status == 10){
                return $this->fail(200016,[],'已经旁听过了');
            }else{
                //去支付即可
            }
        }else{
            $data = [
                'user_id' => $order->user_id,
                'order_id' => $order_id,
                'sit_user_id' => $request->uid,
                'createtime' => time(),
                'sit_price' => $order->sit_price,
                //咨询者收益
                'user_rate' => Settings::get('sitorder_user_balance_rate'),
            ];
            $data['user_price'] = bcdiv(bcmul($data['sit_price'],$data['user_rate'],2),100,2);

            if($order->sit_price == 0){
                $need_pay = 0; //零元不需要支付
                $data['status'] = 10;
                $data['paytime'] = time();
            }
            $sit_order_id = DB::table('ask_sit_order')->insertGetId($data);
        }

        return $this->success(['sit_order_id'=>$sit_order_id,'need_pay'=>$need_pay]);
    }

    //付费咨询订单，余额支付+拉起
    public function payAskOrder(Request $request)
    {
        $order_id = _empty_default_($request->order_id,0);
        $uid = $request->uid;

        $order = DB::table('ask_order')->where('id',$order_id)->where('user_id',$request->uid)->first();
        if(empty($order)){
            return $this->fail(200016,[],'没有找到该咨询');
        }
        if($order->status != 0){
            return $this->fail(200016,[],'该咨询已经支付过了');
        }

        //使用余额支付
        if($request->pay_type == 'balance'){

            //检查支付密码
            $rs = $this->check_paycode($uid,$request->paycode);
            if($rs !== true){
                return $rs;
            }

            //检查余额
            $balance = UserUtils::user_balance($uid);
            if($balance <= $order->ask_price){
                return $this->fail(200012);
            }

            DB::beginTransaction();

            //余额支付
            $pay_res = UserUtils::update_user_financial($uid, 101, $order->ask_price, '您花费了￥'.$order->ask_price.'余额，付费咨询');
            if(!$pay_res){
                DB::rollBack();
                return $this->fail(200012);
            }
            //直接修改订单状态，支付完成
            $rs1 = DB::table('ask_order')->where('id',$order_id)->update(['status'=>10,'paytime'=>time()]);
            if(!$rs1){
                DB::rollBack();
                return $this->fail([],200,'支付失败');
            }

            DB::commit();

            return $this->success([],200,'余额支付成功');
        }

        //拉起三方支付
        $body = '付费咨询';
        $data['body'] = '付费咨询';
        $total_fee = $order->ask_price;
        $orderSn = 'A' . Utils::getSn('A');

        $parame = serialize($data);
        // 创建订单
        $this->createOrder($uid,101,$body,$total_fee,$total_fee,$orderSn,$parame,'ask_order',$order_id);

        $openid = WxUser::where('id', $uid)->value('weixin_openid');
        $appid = Settings::get('app_id');
        $mch_id = Settings::get('mch_id');
        $key = Settings::get('mch_secret');
        $out_trade_no = $orderSn;
        if(_empty_($openid)){
            return $this->fail(200043, [
                'title' => '未绑定微信',
                'content' => '还没有获取到您的小程序openId，无法拉起支付',
                'confirmText' => '去绑定',
                'target_type' => 6,
                'target_id' => '/pagesA/mine/editmine/accountbind'
            ], '未绑定微信');
        }
        $total_fee = 0.01;//测试临时用价格
        return $this->payHandler($uid, $request->pay_type, $request->platform, $total_fee, $data['body'], $out_trade_no, 1);

    }

    //付费旁听订单，余额支付+拉起
    public function paySitOrder(Request $request)
    {
        $order_id = _empty_default_($request->order_id,0);
        $uid = $request->uid;

        $order = DB::table('ask_sit_order')->where('id',$order_id)->where('sit_user_id',$request->uid)->first();
        if(empty($order)){
            return $this->fail(200016,[],'没有找到该旁听');
        }
        if($order->status != 0){
            return $this->fail(200016,[],'该旁听已经支付过了');
        }

        //使用余额支付
        if($request->pay_type == 'balance'){

            //检查支付密码
            $rs = $this->check_paycode($uid,$request->paycode);
            if($rs != true){
                return $rs;
            }

            //检查余额
            $balance = UserUtils::user_balance($uid);
            if($balance <= $order->sit_price){
                return $this->fail(200012);
            }

            DB::beginTransaction();

            //余额支付
            $pay_res = UserUtils::update_user_financial($uid, 102, $order->sit_price, '您花费了￥'.$order->sit_price.'余额，付费旁听');
            if(!$pay_res){
                DB::rollBack();
                return $this->fail(200012);
            }

            //分钱给咨询者，扣除平台服务费及IOS渠道费
            UserUtils::update_user_financial($order->user_id, 104, $order->user_price, '旁听收益'.$order->user_price);

            //直接修改订单状态，支付完成
            $rs1 = DB::table('ask_sit_order')->where('id',$order_id)->update(['status'=>10,'paytime'=>time()]);
            if(!$rs1){
                DB::rollBack();
                return $this->fail([],200,'支付失败');
            }

            //冗余旁听订单数量
            $ask_order_id = $order->order_id;
            $sit_number   = DB::table('ask_sit_order')->where('order_id',$ask_order_id)->where('status',10)->count();
            DB::table('ask_order')->where('id',$ask_order_id)->update(['sit_number'=>$sit_number]);

            DB::commit();

            return $this->success([],200,'余额支付成功');
        }

        //拉起三方支付
        $body = '付费旁听';
        $data['body'] = '付费旁听';
        $total_fee = $order->sit_price;
        $orderSn = 'S' . Utils::getSn('S');

        $parame = serialize($data);
        // 创建订单
        $this->createOrder($uid,102,$body,$total_fee,$total_fee,$orderSn,$parame,'ask_sit_order',$order_id);

        $openid = WxUser::where('id', $uid)->value('weixin_openid');
        $appid = Settings::get('app_id');
        $mch_id = Settings::get('mch_id');
        $key = Settings::get('mch_secret');
        $out_trade_no = $orderSn;
        if(_empty_($openid)){
            return $this->fail(200043, [
                'title' => '未绑定微信',
                'content' => '还没有获取到您的小程序openId，无法拉起支付',
                'confirmText' => '去绑定',
                'target_type' => 6,
                'target_id' => '/pagesA/mine/editmine/accountbind'
            ], '未绑定微信');
        }
        $total_fee = 0.01;//测试临时用价格
        return $this->payHandler($uid, $request->pay_type, $request->platform, $total_fee, $data['body'], $out_trade_no, 1);

    }

    //检查支付密码
    private function check_paycode($uid, $paycode){

        //验证支付密码
        if(_empty_($paycode)){
            return $this->fail(200004, [], '请先输入支付密码');
        }

        if(is_array($paycode) && str_replace(',', '', implode(',', $paycode)) !== get_user_meta($uid, 'paycode', 's')){
            return $this->fail(200043, [
                'title' => '支付密码错误',
                'content' => '已忘记，前往修改？',
                'confirmText' => '去修改',
                'target_type' => 6,
                'target_id' => '/pagesA/mine/paycode/forget'
            ], '支付密码错误');
        }
        if(is_string($paycode) && $paycode !== get_user_meta($uid, 'paycode', 's')){
            return $this->fail(200004, [], '支付密码不匹配');
        }

        return true;
    }

    /**
     * 创建支付订单
     * $order_type = 101 咨询订单
     * $order_type = 102 旁听订单
     */
    private function createOrder($user_id,$order_type,$order_information,$order_price,$order_pay_price,$order_number,$parame='',$table_name,$table_id)
    {
        $orderModel = new WxOrder();
        $orderModel->user_id = $user_id;
        $orderModel->order_type = $order_type;
        $orderModel->order_information = $order_information;
        $orderModel->order_price = $order_price;
        $orderModel->order_pay_price = $order_pay_price;
        $orderModel->order_number = $order_number;
        $orderModel->parame = $parame;
        $orderModel->table_name = $table_name;
        $orderModel->table_id = $table_id;
        $orderModel->save();
        return $orderModel;
    }

    //首页轮播
    public function banner(Request $request){
        $ids = Settings::get('app_ask_banner', '', true);
        //$ids = '30,32,33,34,35,36,37';
        $list = WxSlideshow::wherein('id', explode(',', $ids))->orderBy(DB::raw('FIND_IN_SET(id, "' . $ids . '")'))
            ->get(['id', 'poster', 'target_id', 'slideshow_type']);

        return $this->success($list);
    }

    //我购买的旁听列表ok
    public function sitList(Request $request){

        //分页
        $page = $request->page ?? 1;
        $limit = $request->limit ?? 10;
        $offset = ($page - 1) * $limit;

        //
        $order_ids = DB::table('ask_sit_order')->where('sit_user_id',$request->uid)->where('status',10)->orderBy('id','desc')->pluck('order_id');
        $order_ids = json_decode(json_encode($order_ids),true);
        if(empty($order_ids)){
            return $this->success();
        }

        //
        $list = DB::table('ask_order')
            ->leftJoin('wx_user as user','user.id','=','ask_order.user_id')
            ->leftJoin('wx_user as buser','buser.id','=','ask_order.blogger_user_id')
            ->leftJoin('blogger','blogger.user_id','=','ask_order.blogger_user_id')
            ->select('ask_order.*','user.user_avatar','user.user_name','buser.user_avatar as blogger_avatar','buser.user_name as blogger_name','blogger.info as blogger_info')
            ->offset($offset)->limit($limit)
            ->where('ask_order.status',20)
            ->where('ask_order.is_public',1)
            ->whereIN('ask_order.id',$order_ids)
            ->orderBy(DB::raw('FIND_IN_SET(ask_order.id, "' . implode(',', $order_ids) . '")'))
            ->get();
        $list = json_decode(json_encode($list),true);

        foreach($list as &$val){

            if($val['user_id'] == $request->uid){
                //登录者是咨询者
            }elseif($val['is_hidden'] == 0 && $val['blogger_user_id'] == $request->uid){
                //登录者是答主，并且非匿名
            }else{
                $val['user_avatar'] = Settings::get('askorder_hidden_user_avatar');//匿名头像
                $val['user_name'] = '匿名用户的提问';
            }

            unset($val['images']);
            unset($val['user_id']);
        }

        return $this->success($list);
    }

    //所有咨询列表
    public function askList(Request $request){
        //分页
        $page = $request->page ?? 1;
        $limit = $request->limit ?? 10;
        $offset = ($page - 1) * $limit;

        //
        $where = [];

        //答主
        $blogger_user_id = _empty_default_($request->blogger_user_id,0);
        if($blogger_user_id){
            $where[] = ['ask_order.blogger_user_id','=',$blogger_user_id];
        }

        //用户
        $user_id = _empty_default_($request->user_id,0);
        if($user_id){
            $where[] = ['ask_order.user_id','=',$user_id];
        }

        //搜索
        $keyword = _empty_default_($request->keyword,'');
        if($keyword){
            $where[] = ['ask_order.question','like','%'.$keyword.'%'];
        }

        //
        $list = DB::table('ask_order')
            ->leftJoin('wx_user as user','user.id','=','ask_order.user_id')
            ->leftJoin('wx_user as buser','buser.id','=','ask_order.blogger_user_id')
            ->leftJoin('blogger','blogger.user_id','=','ask_order.blogger_user_id')
            ->select('ask_order.*','user.user_avatar','user.user_name','buser.user_avatar as blogger_avatar','buser.user_name as blogger_name','blogger.info as blogger_info')
            ->offset($offset)->limit($limit)
            ->where($where);

        //如果登录了
        if(($request->uid && $request->uid > 0) && ($request->uid == $user_id || $request->uid == $blogger_user_id)){
            $list = $list->whereIn('ask_order.status',[10,15,20]);
        }else{
            $list = $list->where([
                ['ask_order.status','=',20],
                ['ask_order.is_public','=',1]
            ]);
        }

        $list = $list->orderBy('ask_order.status','asc')->orderBy('ask_order.id','desc')->get();
        $list = json_decode(json_encode($list),true);

        if(!empty($list)){

            //获取未读信息
            $count_data = [];
            if(($request->uid && $request->uid > 0) && ($request->uid == $user_id || $request->uid == $blogger_user_id)){
                $order_ids = array_column($list,'id');

                $count_data = DB::table('wx_chat')->Where('object_id', $request->uid)->where('is_read',0)->where('chat_state',0)->where('expand_type',9)->whereIN('expand_id',$order_ids)->groupBy('expand_id')->select(Db::raw('count(id) as unread_number,expand_id'))->pluck('unread_number','expand_id');
                $count_data = json_decode(json_encode($count_data),true);
            }

            foreach($list as &$val){

                if($val['user_id'] == $request->uid){
                    //登录者是咨询者
                }elseif($val['is_hidden'] == 0 && $val['blogger_user_id'] == $request->uid){
                    //登录者是答主，并且非匿名
                }else{
                    $val['user_avatar'] = Settings::get('askorder_hidden_user_avatar');//匿名头像
                    $val['user_name'] = '匿名用户的提问';
                }

                //未读数量
                $val['unread_number'] = isset($count_data[$val['id']]) ? $count_data[$val['id']] : 0;

                //答主看到的，如果未读为0，且没回复过，给算作1
                if($val['unread_number'] == 0 && $val['status'] == 10 && $val['blogger_user_id'] == $request->uid){
                    $val['unread_number'] = 1;
                }

                unset($val['images']);
                unset($val['user_id']);
            }
        }

        return $this->success($list);
    }

    //咨询详情
    public function askInfo(Request $request){

        $order_id = _empty_default_($request->order_id,0);

        $info = DB::table('ask_order')
            ->leftJoin('wx_user as user','user.id','=','ask_order.user_id')
            ->leftJoin('wx_user as buser','buser.id','=','ask_order.blogger_user_id')
            ->leftJoin('blogger','blogger.user_id','=','ask_order.blogger_user_id')
            ->select('ask_order.*','user.user_avatar','user.user_name','buser.user_avatar as blogger_avatar','buser.user_name as blogger_name','blogger.info as blogger_info')
            ->where('ask_order.id',$order_id)
            ->first();
        $info = json_decode(json_encode($info),true);

        //匿名
        if($info['user_id'] == $request->uid){
            //登录者是咨询者
        }elseif($info['is_hidden'] == 0 && $info['blogger_user_id'] == $request->uid){
            //登录者是答主，并且非匿名
        }else{
            $info['user_avatar'] = Settings::get('askorder_hidden_user_avatar');//匿名头像
            $info['user_name'] = '匿名用户的提问';
        }

        //是否点赞
        $good = DB::table('ask_order_good')->where('order_id',$order_id)->where('user_id',$request->uid)->first();
        $info['is_good'] = !empty($good) ? 1 : 0;

        return $this->success($info);
    }


    //某答主的评价列表
    public function bloggerEvaList(Request $request){
        //分页
        $page = $request->page ?? 1;
        $limit = $request->limit ?? 10;
        $offset = ($page - 1) * $limit;
        $blogger_user_id = $request->user_id;

        //
        $list = DB::table('ask_order')
            ->leftJoin('wx_user','wx_user.id','=','ask_order.user_id')
            ->select('ask_order.id','ask_order.user_id','ask_order.blogger_user_id','ask_order.eva_time','ask_order.eva_score','ask_order.eva_content','ask_order.is_hidden','wx_user.user_avatar','wx_user.user_name')
            ->where('ask_order.blogger_user_id',$blogger_user_id)
            ->where('ask_order.eva_time','>',0)
            ->where('ask_order.status',20)
            ->orderBy('ask_order.eva_time','desc')
            ->offset($offset)->limit($limit)
            ->get();
        $list = json_decode(json_encode($list),true);

        if(empty($list)){
            return $this->success([]);
        }

        foreach($list as &$val){

            if($val['user_id'] == $request->uid){
                //自己提问的
            }elseif($val['is_hidden'] == 0 && $val['blogger_user_id'] == $request->uid){
                //登录者是答主，并且非匿名
            }else{
                $val['user_avatar'] = Settings::get('askorder_hidden_user_avatar');//匿名头像
                $val['user_name'] = '匿名用户';
            }
        }

        return $this->success($list);
    }


}