<?php
/**
 * +-----------------------------------------------------------------------------------------------------------------------
 * 逻辑层：用户 服务类，处理业务逻辑
 * +-----------------------------------------------------------------------------------------------------------------------
 *
 * PHP version 7
 *
 * @category  App\Services\User
 * @package   App\Services\User
 * @author    Richer <yangzi1028@163.com>
 * @date      2020年11月16日 17:23:22
 * @copyright 2021-2022 Richer (http://www.Richer.com/)
 * @license   http://www.Richer.com/ License
 * @link      http://www.Richer.com/
 */

namespace App\Services\User;

use App\Http\Requests\UserRequest;
use App\Models\Favorite;
use App\Models\System\Bank;
use App\Models\User\Role;
use App\Models\User\User;
use App\Models\User\WithdrawRecord;
use App\Services\BaseService;
use Illuminate\Http\Request;
use Illuminate\Support\Arr;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\DB;
use JWTAuth;

/**
 * Class UserService.
 *
 * @category  App\Services\User
 * @package   App\Services\User
 * @author    Richer <yangzi1028@163.com>
 * @date      2020年11月16日 17:23:22
 * @copyright 2021-2022 Richer (http://www.Richer.com/)
 * @license   http://www.Richer.com/ License
 * @link      http://www.Richer.com/
 */
class UserService extends BaseService
{
    /**
     * UserService constructor.
     *
     * @param User $model
     */
    public function __construct(User $model)
    {
        // 执行父类构造方法
        parent::__construct($model);
    }

    /**
     * Display the specified resource.
     *
     * @param int $id 主键id
     * @param array $columns 列
     *
     * @return array|bool|\Illuminate\Support\Collection
     */
    public function show($id, $columns = ['*'])
    {
        $model = parent::show($id, $columns);
        $type = request('type');

        $model->function = 'show';
        return $model;
    }

    /**
     * @return array
     */
    public function me($request)
    {
        request()->offsetSet('function', 'show');
        $user = $this->getLoginUser();

        return $user;
    }

    /**
     * 更新我的信息
     *
     * @param UserRequest $request 请求
     *
     * @return bool
     */
    public function updateMe($request)
    {
        // 获取登录用户信息
        $user = $this->getLoginUser();
        // 获取用户的角色
        $role = $user->role;
        // 设置可以批量赋值的字段
        $user->fill($request->all());
        $user->save();
        //
        return true;
    }

    /**
     * 更新我的信息
     *
     * @param UserRequest $request 请求
     *
     * @return array
     */
    public function submitMe($request)
    {
        // 获取登录用户信息
        $user = $this->getLoginUser();
        if (!$user->isPassenger()) {
            $this->message = '您不是游客，无法操作！';
            return false;
        }

        // 判断是否已经提交了信息
        $customer = $this->customer;
        if ($customer) {
            $this->message = '您已经提交了信息，无法操作！';
            return false;
        }

        // 设置可以批量赋值的字段
        $user->fill($request->all());
        $result = $user->save();
        // 新增客户信息
        $user->customer()->create([
            'company_name' => $request->company_name,
            'province_code' => $request->province_code,
            'city_code' => $request->city_code,
            'district_code' => $request->district_code,
            'address' => $request->address,
            'main_business' => $request->main_business,
            'demand' => $request->demand,
        ]);

        return $result;
    }

    /**
     * 修改我的密码
     *
     * @param Request $request 请求
     *
     * @return bool
     */
    public function updatePassword($request)
    {
        //获取登录用户信息
        $user = $this->getLoginUser();
        if (is_admin()) {
            $user->password = bcrypt($request->password);
            $user->token = '';
            $result = $user->save();
            JWTAuth::parseToken()->invalidate();
            return $result;
        } else {
            $this->message = '你不是管理员！';
            return false;
        }
    }

    /**
     * 我的浏览记录
     *
     * @return mixed
     */
    public function accessRecords()
    {
        $user = $this->getLoginUser();

        return $result = $user->accessRecords()->with(['accessable'])->when($q = request('type'), function ($query) use ($q) {
            $query->where('accessable_type', $q);
        })->latest()->paginate(request('per_page', config('constants.PER_PAGE')));
    }


    /**
     * 收藏-列表
     *
     * @return mixed
     */
    public function favorites()
    {
        // add by Richer 于 2022年2月16日16:43:30 收藏的结构需要调整，企业的直接查询，颜色和产品需要分组
        /*
                return $query->groupBy('recorded_at')->whereHas('records', function ($query) {
                    $query->with(['trackable','user','customer','product'])
                        ->when($q = request('q'), function ($query) use ($q) {
                            $query->whereHas('customer', function ($query) use ($q) {
                                $query->where('name', 'like', '%'.$q.'%')->orWhere('company_name', 'like', '%'.$q.'%');
                            });
                        })->latest();
                })->latest()->paginate(request('per_page', config('constants.PER_PAGE')));
                */

        $user = $this->getLoginUser();
        $type = request('type');
//        if (!$type) {
//            $this->message = '请选择收藏类型！';
//            return false;
//        }
        $columns = ['*'];
        $type = request('type');
//        switch ($type) {
//
//        }

//        $columns = ['id','name','price','cover_image'];
        $class = Favorite::getClassType();
        $result = $query = $user->favorites()
            ->whereHasMorph('favoriteable', $class, function ($query) {
                // 获取关联模型
                $obj_model = $query->getModel();
                // 获取关联模型需要查询的字段
                $columns = $obj_model::LIST_QUERY_FIELDS;
//                dump($columns);
                // add by Richer 于 2022年8月10日10:49:06 下架的商品不展示
                $query->select($columns);
                $query->where('unshelved_status', config('constants.SHELVED')); // 上架状态
            })
            ->with(['favoriteable' => function ($query) use ($columns) {
//                $query->select($columns);
            }])
            ->when($q = request('type'), function ($query) use ($q) {
                $query->where('favoriteable_type', $q);
            })->latest()->paginate(request('per_page', config('constants.PER_PAGE')));

        return $result;
    }

    /**
     * 意见反馈-列表
     *
     * @return mixed
     */
    public function myFeedbacks()
    {
        $user = $this->getLoginUser();

        return $result = $user->feedbacks()->when($q = request('q'), function ($query) use ($q) {
            $query->where('title', 'LIKE', '%' . $q . '%');
        })->latest()->paginate(request('per_page', config('constants.PER_PAGE')));
    }

    /**
     * 我的消息-列表
     *
     * @return mixed
     */
    public function myNotifications()
    {
        $user = $this->getLoginUser();
        if ($user) {
            $list = $user->notifications()
                ->orderBy('read_at')
                ->orderByDesc('created_at')
                //->orderBy(\DB::Raw("case when read_at is null then 1 else read_at end"),'ASC')
                //  ->orderBy(\DB::Raw('case when ifnull(read_at,\'\')=\'\' then 1 else 0 end desc, read_at asc'))
                ->paginate(request('per_page', config('constants.PER_PAGE')));

            // 标记为已读，未读数量清零
            $list->markAsRead();
            return $list;
        }
    }

    /**
     * 我的消息-未读数量
     *
     * @return mixed
     */
    public function myUnreadNotificationsCount()
    {
        $user = $this->getLoginUser();
        if ($user) {
            return optional($user->unreadNotifications)->count();
        }

        return 0;
    }

    /**
     * 我的-收货地址-新增
     *
     * @return mixed
     */
    public function storeMyAddresses($request)
    {
        $user = $this->getLoginUser();

        $enterprise = $user->enterprise;
        if (!$enterprise) {
            $this->message = '您还未提交认证信息，请先提交认证！';
            return false;
        }

        // 判断是否是审核通过状态
        if ($enterprise->audited_status == config('constants.AUDIT_PASSED')) {
            $this->message = '您的认证已经审核通过！';
            return false;
        }

        // 状态设置为待审核
        $request['audited_status'] = config('constants.UNAUDITED');

        return $enterprise->update($request->all());
    }

    /**
     * 我的-地址信息-提交
     *
     * @return mixed
     */
    public function updateMyAddresses($request)
    {
        $user = $this->getLoginUser();

        $enterprise = $user->enterprise;
        if (!$enterprise) {
            $this->message = '您还未提交认证信息，请先提交认证！';
            return false;
        }

        // 判断是否是审核通过状态
        if ($enterprise->audited_status == config('constants.AUDIT_PASSED')) {
            $this->message = '您的认证已经审核通过！';
            return false;
        }

        // 状态设置为待审核
        $request['audited_status'] = config('constants.UNAUDITED');

        return $enterprise->update($request->all());
    }

    /**
     *  我的次数明细
     *
     * @return mixed
     */
    public function myTimesRecords()
    {
        $user = $this->getLoginUser();
        return $user->timesRecords()
            ->latest()
            ->paginate(100);
//            ->paginate(request('per_page', config('constants.PER_PAGE')));
    }

    /**
     *  我的聊天记录
     *
     * @return mixed
     */
    public function myChatRecords()
    {
        $user = $this->getLoginUser();

//        $type = request('type', 1);
        $list =  $user->chatRecordItems()
            ->when($q = request('category_id'), function ($query) use ($q) {
                $query->where('category_id', $q);
            })
            ->when($q = request('type', 1), function ($query) use ($q) {
                $query->where('chat_type', $q);
            })
            ->where('cleared', 0)
//            ->oldest()
//            ->paginate(1000);
            ->latest()
            ->paginate(request('per_page', config('constants.PER_PAGE')), ['id','user_type','ai_model','body','created_at'])->toArray();

        $data = $list['data'];
        // 反转
        $return['data'] = array_reverse($data);
        $return['current_page'] = $list['current_page'];
        $return['last_page']    = $list['last_page'];
        $return['per_page'] = $list['per_page'];
        $return['total']    = $list['total'];

        return $return;
//
//        foreach ( $list['data'] as &$vo) {
//
//        }
//        dump($data);
//
//        dd($list);
//        foreach ($list->items as $item) {
//            dump($item);
//        }
//        $items = array_flip($list->items());
//
//        //
//        dd($items);
//
//        dd($list->items());
    }

    /**
     *  清除 我的聊天记录
     *
     * @return mixed
     */
    public function clearMyChatRecords()
    {
        $user = $this->getLoginUser();

        // 获取当前最新的ID
        $query = $user->chatRecordItems()
            ->when($q = request('category_id'), function ($query) use ($q) {
                $query->where('category_id', $q);
            })
            ->when($q = request('type', 1), function ($query) use ($q) {
                $query->where('chat_type', $q);
            })
            ->where('cleared', 0);
        $id = $query->latest()->max('id');

        if ($id > 0) {
            $query->where('id', '<=', $id)->update(['cleared' => 1]);
        }

        return true;
    }

    /**
     * 我的钱包
     *
     * @return mixed
     */
    public function myWallet()
    {
        $user = $this->getLoginUser();

        // 获取钱包信息
        $wallet = $user->getWallet();

        // 昨日收益
        $yesterday_income = $user->commissions()->whereDate('created_at',Carbon::yesterday()->toDateString())->sum('amount');

        return [
            'balance'   => format_money($wallet->balance),
            'withdrawn' => format_money($wallet->withdrawn),
            'yesterday_income' => format_money($yesterday_income),
        ];
    }

    /**
     * 我的钱包
     *
     * @return mixed
     */
    public function myTeamCount()
    {
        $user = $this->getLoginUser();

        // 团队总人数
        // 如果用户是合作方
        $total_count = 0;
        $query = null;
        if ($user->partner === 1) {
            $query = User::where(function ($query) use ($user) {
                $query->where('pid', $user->id)->orWhere('gid', $user->id);
            });
        } else {
            $query = $user->children();
        }

        return ['count' => $total_count = $query->count()];
    }

    /**
     * 我的钱包
     *
     * @return mixed
     */
    public function myTeam()
    {
        $user = $this->getLoginUser();

        $query = null;
        if ($user->partner === 1) {
            $query = User::where(function ($query) use ($user) {
                $query->where('pid', $user->id)->orWhere('gid', $user->id);
            });
        } else {
            $query = $user->children();
        }

        // 昨日收益
        return $query->latest()->paginate(request('per_page', config('constants.PER_PAGE')));
    }

    /**
     * 我的钱包
     *
     * @return mixed
     */
    public function myCommissions()
    {
        $user = $this->getLoginUser();

        // 昨日收益
        return $user->commissions()->with(['recordable.user'])->latest()->paginate(request('per_page', config('constants.PER_PAGE')));
    }

    /**
     * 提现
     *
     * @param $request
     * @return mixed
     */
    public function withdrawal($request)
    {
        $user = $this->getLoginUser();

        DB::beginTransaction();
        try {

            // 获取钱包信息
            $wallet = $user->getWallet();

            $amount = $request->amount;
            if ($amount < 100) {
                $this->message = '提现失败，最少提现 100 元。';
                return false;
            }
            // 判断金额
            if ($wallet->balance < $amount) {
                $this->message = '提现失败，账户余额不足。';
                return false;
            }

            // 最低需要保留1元
//            if ($wallet->balance - $amount < 1) {
//                $this->message = '提现失败，账户最少需要保留 1 元。';
//                return false;
//            }

            // 判断是否有还未审核通过的提现记录
            if ($user->withdrawals()->where('status', WithdrawRecord::UNAUDITED)->first()) {
                $this->message = '提现失败,还有未审核的提现，请等待管理员审核。';
                return false;
            }

            $bank_name = '';
            if ($request->type == 1 && $request->bank_id) {
                $bank_name = Bank::find($request->bank_id)->name;
            }

            $data = $request->all();
            $data['bank_name'] = $bank_name;
            $data['ratio'] = WithdrawRecord::RATIO;

            $withdrawal = $user->withdrawals()->create($data);

            // 冻结用户的余额
            $user->frozenAmount($wallet, $amount);

            //提交事务
            DB::commit();

            return $withdrawal;
        } catch (\Exception $e) {
            $this->message = $e->getMessage();
            DB::rollBack();
            return false;
        }
    }

    /**
     * 我的钱包
     *
     * @return mixed
     */
    public function myWithdrawals()
    {
        $user = $this->getLoginUser();

        // 昨日收益
        return $user->withdrawals()->latest()->paginate(request('per_page', config('constants.PER_PAGE')));
    }
}