<?php

/**
 * 用户管理
 * @author x.b
 */
declare (strict_types=1);
namespace Modules\Manage\Controllers;

use App\Constants\ChangeLogConstant;
use App\Exception\ApiException;
use App\Model\Mongo\SendCardHistoryModel;
use App\Model\VipOrderModel;
use App\Repositories\Service\QueueService;
use App\Repositories\UserRepository as UserRepository;
use App\Model\CoinsLogModel;
use App\Model\VipCardModel;
use App\Model\UserModel as Model;
use Carbon\Carbon;
use Hyperf\DbConnection\Db;
use Hyperf\Validation\Contract\ValidatorFactoryInterface;
use App\Repositories\MessageRepository;
class UserController extends BaseController
{
    use \Hyperf\Di\Aop\ProxyTrait;
    use \Hyperf\Di\Aop\PropertyHandlerTrait;
    function __construct()
    {
        if (method_exists(parent::class, '__construct')) {
            parent::__construct(...func_get_args());
        }
        $this->__handlePropertyHandler(__CLASS__);
    }
    /**
     * 详细
     * @param yes id int $id 用户ID 如 100
     * @return mixed
     * @example param_json_data string: {"handshake":"","data":{"id":14550388}}
     */
    public function detail(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $rules = ['id' => 'required|numeric'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            return json_fail($validator->errors()->first());
        }
        $id = $inputData['id'];
        $select = ['*'];
        $model = Model::query();
        $result = $model->select($select)->where('id', $id)->first();
        if (!$result) {
            return json_fail('用户不存在');
        }
        // 查他的上级邀请人的名字
        $result['parent_nick'] = '';
        if ($result['parent_uid']) {
            $select = ['nick'];
            $r = Model::query()->select($select)->where('code', $result['parent_uid'])->first();
            if ($r) {
                $result['parent_nick'] = $r['nick'];
            }
        }
        $userRepo = make(UserRepository::class);
        $userDataInfo = $userRepo->getUserInfoData($result['code']);
        $result['qrcode'] = $userDataInfo['account_qrcode_content'];
        $orderCount = VipOrderModel::where(['user_code' => $result['code']])->count();
        $payCount = VipOrderModel::where(['user_code' => $result['code']])->where(['status' => 1])->count();
        $result['order_count'] = $orderCount;
        $result['pay_count'] = $payCount;
        return json_success($result);
    }
    /**
     * 列表
     * @param ValidatorFactoryInterface $validatorFactory
     * @return mixed
     * @example param_json_data string:  {"handshake":"","data":{"page":1,"page_size":5,"search":{"nick":"用户CH3J30","stime":"","otime":""},"order":"created_at","order_sort":"desc"}}
     */
    public function list(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $page = isset($inputData['page']) ? (int) $inputData['page'] : 1;
        $page_size = isset($inputData['page_size']) ? (int) $inputData['page_size'] : 20;
        $select = ['*'];
        $model = Model::query();
        $order_key = isset($inputData['order']) ? $inputData['order'] : 'id';
        $order_value = isset($inputData['order_sort']) ? $inputData['order_sort'] : 'desc';
        if (!$order_key) {
            $order_key = 'id';
            //不要信任前端，他可能会传个空字符串过来!
        }
        if (!$order_value) {
            $order_value = 'desc';
        }
        $search = isset($inputData['search']) ? $inputData['search'] : array();
        if ($search) {
            foreach ($search as $k => $v) {
                if (!strlen((string) $v)) {
                    continue;
                }
                $operator = '=';
                if ($k == 'channel_id' && $v == 'official') {
                    // 官方代表空
                    $v = "";
                }
                if ($k == 'max_view') {
                    preg_match('/^(=|>|<)(\\d{1,10})$/', $v, $matches);
                    if (isset($matches[2])) {
                        $operator = $matches[1];
                        $v = $matches[2];
                    }
                }
                switch ($k) {
                    case "nick":
                    // 用户名
                    case "mobile":
                        // 手机号
                        $model->where($k, 'like', "{$v}%");
                        break;
                    case "stime":
                        // 自定义-开始日期
                        $model->where('created_at', '>=', $v);
                        break;
                    case "otime":
                        // 自定义-结束日期
                        $model->where('created_at', '<=', Carbon::parse($v)->endOfDay()->toDateTimeString());
                        break;
                    default:
                        $model->where($k, $operator, $v);
                }
            }
        }
        $result = $model->select($select)->orderBy((string) $order_key, (string) $order_value)->paginate($page_size, ['*'], 'page', $page);
        return json_success($result);
    }
    /**
     * 删除
     */
    public function delete()
    {
    }
    /**
     * 更新
     * @return mixed
     * @example param_json_data string: {"handshake":"","data":{"id":14550388,"status":"1"}}
     */
    public function update(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $rules = ['id' => 'required|numeric'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            return json_fail($validator->errors()->first());
        }
        $id = $inputData['id'];
        $status = isset($inputData['status']) ? $inputData['status'] : '';
        if ($status) {
            if (!in_array($status, array(1, 2, 3))) {
                return json_fail('请按文档正确传参,用户的状态值');
            }
        }
        $user_info = Model::query()->where('id', $id)->first();
        if (!$user_info) {
            return json_fail('用户不存在');
        }
        $data = array();
        if (isset($inputData['nick'])) {
            $data['nick'] = trim($inputData['nick']);
        }
        if (isset($inputData['avatar'])) {
            $data['avatar'] = trim($inputData['avatar']);
        }
        if (isset($inputData['bg_cover'])) {
            $data['bg_cover'] = trim($inputData['bg_cover']);
        }
        if (isset($inputData['intro'])) {
            $data['intro'] = rtrim($inputData['intro']);
        }
        if (isset($inputData['status'])) {
            $data['status'] = intval($inputData['status']);
        }
        if (isset($inputData['mobile'])) {
            $data['mobile'] = intval($inputData['mobile']);
        }
        $data = action_data($data);
        if ($data) {
            $result = Model::query()->where('id', $id)->update($data);
            if (!$result) {
                return json_fail('更新失败');
            }
        }
        // 创建管理员日志
        $oldItem = clone $user_info;
        $newitem = Model::query()->where('id', $id)->first();
        $logSubject = '修改一个用户信息,名称:' . $user_info['nick'];
        $logSvalue = $oldItem->id;
        $logDbData = ['after_items' => [$newitem->toArray()], 'before_items' => [$oldItem->toArray()]];
        $this->log($logSubject, $logSvalue, $logDbData);
        make(UserRepository::class)->delUserCache($user_info['code']);
        return json_success('', '更新成功');
    }
    /**
     * 发放金币
     * @param int yes $id 用户ID, 如 14550388
     * @param int yes $coins 金币数, 如 50 则是加; 如 -100 则是减少
     * @return mixed
     * @example param_json_data string: {"handshake":"","data":{"id":14550388,"coins":50}}
     */
    public function sendCoins(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $rules = ['id' => 'required|numeric', 'coins' => 'required|numeric'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            return json_fail($validator->errors()->first());
        }
        $id = $inputData['id'];
        $coins = $inputData['coins'];
        $user_info = Model::query()->where('id', $id)->first();
        if (!$user_info) {
            return json_fail('用户不存在');
        }
        if ($coins > 0) {
            $result = Model::query()->where('id', $id)->increment('coins', $coins);
        } else {
            $_coins = abs((int) $coins);
            //取绝对值
            if ($user_info->coins < $_coins) {
                return json_fail('用户金币不够，不能扣减');
            }
            $result = Model::query()->where('id', $id)->decrement('coins', $_coins);
        }
        if (!$result) {
            return json_fail('处理失败');
        }
        make(UserRepository::class)->delUserCache($user_info['code']);
        //清除用户信息redis缓存
        if ($coins < 0) {
            $way = ChangeLogConstant::WAY_2;
            $type = ChangeLogConstant::TYPE_22;
        } else {
            $way = ChangeLogConstant::WAY_1;
            $type = ChangeLogConstant::TYPE_18;
        }
        // 记录帐变使用日志
        $changeData = ['user_uid' => $user_info['code'], 'currency_type' => ChangeLogConstant::CHANGE_COIN, 'amount' => abs((int) $coins), 'way' => $way, 'type' => $type];
        // 帐变记录
        make(QueueService::class)->saveChangeLogJob($changeData);
        // 创建管理员日志
        $oldItem = clone $user_info;
        $newitem = Model::query()->where('id', $id)->first();
        $logSubject = '对一个用户发放金币,名称:' . $user_info['nick'];
        $logSvalue = $oldItem->id;
        $logDbData = ['after_items' => [$newitem->toArray()], 'before_items' => [$oldItem->toArray()]];
        $this->log($logSubject, $logSvalue, $logDbData);
        return json_success('', '处理成功');
    }
    /**
     * bindPhone 绑定老用户
     *  业务逻辑:
     *   1. 后台对指定新用户  输入 老用户对手机号
     *   2。查询出 老用户对设备号，设备类型
     *   3。将新/老用户的仅 设备号和设备类型，互换一下。
     *   4。调接口，退出新老用户（即 缓存中清理下 ）
     * @param int yes $id 新用户的ID，如100
     * @param int yes $mobile 老用户的手机号
     * @return mixed
     * @example param_json_data string:  {"handshake":"","data":{"id":14550389,"mobile":"13873840000"}}
     */
    public function bindPhone(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $rules = ['id' => 'required|numeric', 'mobile' => 'required|numeric'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            return json_fail($validator->errors()->first());
        }
        $id = $inputData['id'];
        $mobile = $inputData['mobile'];
        $user_info_new = Model::query()->where('id', $id)->first();
        if (!$user_info_new) {
            return json_fail('新用户不存在');
        }
        $user_info_old = Model::query()->where('mobile', $mobile)->first();
        if (!$user_info_old) {
            return json_fail('老用户对应的电话号码不存在');
        }
        // 交换更新用户设备号，设备类型
        Db::beginTransaction();
        try {
            $data = array('device_no' => $user_info_old['device_no'], 'device_type' => $user_info_old['device_type'], 'finger_hash' => $user_info_old['finger_hash']);
            $r = Model::query()->where('id', $id)->update($data);
            if (!$r) {
                throw new ApiException('更新新用户设备信息失败');
            }
            $data = array('device_no' => $user_info_new['device_no'], 'device_type' => $user_info_new['device_type'], 'finger_hash' => $user_info_new['finger_hash']);
            $r = Model::query()->where('mobile', $mobile)->update($data);
            if (!$r) {
                throw new ApiException('更新老用户设备信息失败');
            }
            // 清理新/旧用户缓存数据
            $m = make(UserRepository::class);
            $m->userLogout($user_info_new['code']);
            $m->userLogout($user_info_old['code']);
            Db::commit();
        } catch (\Exception $e) {
            Db::rollBack();
        }
        // 创建管理员日志
        $oldItem = clone $user_info_new;
        $oldItem2 = clone $user_info_old;
        $newitem = Model::query()->where('id', $id)->first();
        $newitem2 = Model::query()->where('id', $user_info_old['id'])->first();
        $logSubject = "绑定老用户,用户id:{$user_info_new['id']}->{$user_info_old['id']}";
        $logSvalue = $oldItem->id;
        $logDbData = ['after_items' => [$newitem->toArray(), $newitem2->toArray()], 'before_items' => [$oldItem->toArray(), $oldItem2->toArray()]];
        $this->log($logSubject, $logSvalue, $logDbData);
        return json_success('', '处理成功');
    }
    /**
     * 对指定用户发放会员卡
     * @param int yes $id 用户id
     * @param int yes $card_id 会员卡ID，来源会员卡列表的字段id
     * @return mixed
     * @example param_json_data string: {"handshake":"","data":{"id":424432,"card_id":1}}
     */
    public function sendCard(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $rules = ['id' => 'required', 'card_id' => 'required'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            return json_fail($validator->errors()->first());
        }
        $uid = $inputData['id'];
        $card_id = $inputData['card_id'];
        $card_info = VipCardModel::query()->where('id', $card_id)->first();
        if (!$card_info) {
            return json_fail('会员卡不存在');
        }
        if (!$card_info['status']) {
            return json_fail('会员卡未启动');
        }
        $user_info = Model::query()->where('id', $uid)->first();
        if (!$user_info) {
            return json_fail('用户不存在');
        }
        try {
            //加会员天数
            $userInfo = make(UserRepository::class)->getUserInfoFromCache($user_info['code']);
            if ($userInfo['is_vip'] == 'y') {
                $vipTime = Carbon::parse($userInfo['vip_expired'])->addDays($card_info['day'])->toDateTimeString();
            } else {
                $vipTime = Carbon::now()->addDays($card_info['day'])->toDateTimeString();
            }
            $result = Model::query()->where('id', $user_info['id'])->update(['vip_expired' => $vipTime]);
            if (!$result) {
                return json_fail('添加用户会员卡时间失败');
            }
            make(UserRepository::class)->delUserCache($user_info['code']);
            //清除用户信息redis缓存
        } catch (\Exception $e) {
            return json_fail('处理失败');
        }
        //$managerInfo = $authService->getManagerInfo();
        // $roleId = $managerInfo['role_id'];
        // $managerId = $managerInfo['manager_id'];
        $managerInfo = $this->getCurrentManagerInfo();
        make(SendCardHistoryModel::class)->db()->insertOne(['mid_id' => $managerInfo['manager_id'], 'user_code' => $user_info['code'], 'vip_id' => $card_info['id'], 'vip_days' => $card_info['day']]);
        // 创建管理员日志
        $oldItem = clone $user_info;
        $newitem = Model::query()->where('id', $user_info['id'])->first();
        $logSubject = "发放{$card_info['day']}天的会员卡,会员卡配置ID:{$card_info['id']},用户id:{$user_info['id']}";
        $logSvalue = $oldItem->id;
        $logDbData = ['after_items' => [$newitem->toArray()], 'before_items' => [$oldItem->toArray()]];
        $this->log($logSubject, $logSvalue, $logDbData);
        return json_success('', '处理成功');
    }
    /**
     * 指定用户的邀请详细
     * @param yes id int $id 用户ID 如 100
     * @return mixed
     * @example param_json_data string: {"handshake":"","page":1,"page_size":5,"data":{"id":30}}
     */
    public function inviteDetail(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $page = isset($inputData['page']) ? (int) $inputData['page'] : 1;
        $page_size = isset($inputData['page_size']) ? (int) $inputData['page_size'] : 20;
        $rules = ['id' => 'required|numeric'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            return json_fail($validator->errors()->first());
        }
        $order_key = isset($inputData['order']) ? $inputData['order'] : 'id';
        $order_value = isset($inputData['order_sort']) ? $inputData['order_sort'] : 'desc';
        if (!$order_key) {
            $order_key = 'id';
            //不要信任前端，他可能会传个空字符串过来!
        }
        if (!$order_value) {
            $order_value = 'desc';
        }
        $id = $inputData['id'];
        $select = ['*'];
        $user_info = Model::query()->select($select)->where('id', $id)->first();
        if (!$user_info) {
            return json_fail('用户不存在');
        }
        $select = ['nick', 'id', 'mobile', 'created_at'];
        $invite_list = Model::query()->select($select)->where('parent_uid', $user_info['code'])->orderBy((string) $order_key, (string) $order_value)->paginate($page_size, ['*'], 'page', $page);
        if (!$invite_list) {
            $invite_list = array();
        }
        $result = array('user_info' => $user_info, 'invite_list' => $invite_list);
        return json_success($result);
    }
    /**
     * 邀请列表
     * @param ValidatorFactoryInterface $validatorFactory
     * @return mixed
     * @example param_json_data string:  {"handshake":"","data":{"page":1,"page_size":5,"search":{"nick":"用户CH3J30","id":"","mobile":"","code":"","stime":"","otime":""},"order":"invite","order_sort":"desc"}}
     */
    public function inviteList(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $page = isset($inputData['page']) ? (int) $inputData['page'] : 1;
        $page_size = isset($inputData['page_size']) ? (int) $inputData['page_size'] : 20;
        $select = ['id', 'nick', 'mobile', 'mobile', 'device_no', 'device_type', 'channel_id', 'code', 'status', 'invite', 'coins', 'ip'];
        $model = Model::query();
        $order_key = isset($inputData['order']) ? $inputData['order'] : 'id';
        $order_value = isset($inputData['order_sort']) ? $inputData['order_sort'] : 'desc';
        if (!$order_key) {
            $order_key = 'id';
            //不要信任前端，他可能会传个空字符串过来!
        }
        if (!$order_value) {
            $order_value = 'desc';
        }
        $search = isset($inputData['search']) ? $inputData['search'] : array();
        if ($search) {
            foreach ($search as $k => $v) {
                if (!strlen((string) $v)) {
                    continue;
                }
                switch ($k) {
                    case "nick":
                    // 用户名
                    case "mobile":
                    // 手机号
                    case "code":
                        // 邀请码
                        $model->where($k, 'like', "{$v}%");
                        break;
                    case "stime":
                        // 自定义-开始日期
                        $model->where('created_at', '>=', $v);
                        break;
                    case "otime":
                        // 自定义-结束日期
                        $model->where('created_at', '<=', Carbon::parse($v)->endOfDay()->toDateTimeString());
                        break;
                    default:
                        $model->where($k, $v);
                }
            }
        }
        $model->where('invite', '>', '0');
        //仅查询有邀请人数的
        $invite_all_select = [Db::raw('count(*) as id_all'), Db::raw('sum(invite) as invite_all')];
        $invite_all = $model->select($invite_all_select)->first();
        if ($invite_all) {
            if (!$invite_all['id_all']) {
                $invite_all['average'] = 0;
            } else {
                $invite_all['average'] = round($invite_all['invite_all'] / $invite_all['id_all'], 1);
            }
        } else {
            $invite_all = array("id_all" => 0, "invite_all" => 0, 'average' => 0);
        }
        $invite_list = $model->select($select)->orderBy((string) $order_key, (string) $order_value)->paginate($page_size, ['*'], 'page', $page);
        $result = array('invite_all' => $invite_all, 'invite_list' => $invite_list);
        return json_success($result);
    }
    /**
     * 发送系统消息给单个用户
     */
    public function sendMessageToUser(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $rules = ['subject' => 'required|string|max:255', 'receive_uid' => 'required|max:32', 'content' => 'required|string'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            // 如果有错误（可能是多个信息），这里只取第一个错误信息返回.
            return json_fail($validator->errors()->first());
        }
        $receiveUid = data_get($inputData, 'receive_uid', '');
        $content = data_get($inputData, 'content', '');
        $subject = data_get($inputData, 'subject', '');
        $msgRepo = make(MessageRepository::class);
        $msgRepo->sendTextFromSys($receiveUid, $content, $subject);
        return json_success(['result' => 'success']);
    }
}