<?php

namespace app\api\controller;

use app\admin\model\UserWithdraw;
use app\common\controller\Api;
use app\common\library\Ems;
use app\common\library\Sms;
use fast\Random;
use think\Db;
use think\Validate;
use think\Cache;
use app\api\model\HouseJoin;
use app\api\model\UserHouse;
use app\api\model\UserMoneyLog;

/**
 * 会员接口
 */
class User extends Api
{
    protected $noNeedLogin = ['login', 'mobilelogin', 'register', 'resetpwd', 'changeemail', 'changemobile', 'authorize', 'third'];
    protected $noNeedRight = '*';

    public function _initialize()
    {
        parent::_initialize();
    }

    /**
     * 微信授权登录地址
     * @ApiWeigh    (21)
     *
     * @param string $redirect_uri 回调地址
     */
    public function authorize()
    {
        $redirect_uri = $this->request->param('redirect_uri');
        if(!$redirect_uri) {
            $this->error('地址错误');
        }
        $redirect_uri = urlencode($redirect_uri);
        $third = get_addon_config('third');
        $appid = $third['wechat']['app_id'];
        $wechat_url = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=$appid&redirect_uri=$redirect_uri&response_type=code&scope=snsapi_userinfo&state=STATE#wechat_redirect";
        $this->success('', ['wechat_url'=>$wechat_url]);
    }

    /**
     * 第三方登录
     * @ApiWeigh    (20)
     *
     * @param string $platform 平台名称
     * @param string $code     Code码
     */
    public function third()
    {
        $url = url('user/index');
        $platform = $this->request->request("platform",'wechat');
        $code = $this->request->request("code");
        $config = get_addon_config('third');
        if (!$config || !isset($config[$platform])) {
            $this->error(__('Invalid parameters'));
        }
        $app = new \addons\third\library\Application($config);
        //通过code换access_token和绑定会员
        session('state','STATE');
        $result = $app->{$platform}->getUserInfo(['state'=>'STATE','code' => $code]);
        if ($result) {
            $loginret = \addons\third\library\Service::connect($platform, $result);
            if ($loginret) {
                $data = [
                    'token' => $this->auth->getToken(),
                    'userinfo'  => $this->auth->getUserinfo(),
                    'thirdinfo' => $result
                ];
                $this->success(__('Logged in successful'), $data);
            }
        }
        $this->error(__('Operation failed'), $result);
    }

    /**
     * @ApiTitle    (个人中心-首页)
     * @ApiSummary  (个人中心-首页)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/index)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiReturn   ({
		"code": 1,
		"msg": "成功",
		"time": "1598667600",
		"data": {
			"id": 2, //用户ID
			"username": "何先生", //用户名
			"nickname": "何先生", //昵称
			"avatar": "http://cloud.caiyunpan.brotop.cn/assets/img/avatar.png", //头像
			"money": "0.00", //余额
			"id_num": "100001", //ID
			"url": "/u/2",
			"house": { //小区信息
				"id": 17, //小区ID
				"name": "碧海花园小区" //小区名称
			},
			"today_money": 10, //今日收益
			"total_money": 10, //总收益
			"message_num": 0 //未读消息数量
		}
	})
     */
    public function index()
    {
    	$user = $this->auth->getUser();
    	$data = [
    		// 当前小区信息
    		'house' => \app\api\model\House::get($user['house_id'])
    			->visible(['id','name'])->toArray(),
    		// 今日收益
    		'today_money' => UserMoneyLog::where('user_id',$this->auth->id)
    			->where('money','>',0)
	    		->whereTime('createtime', 'today')
	    		->sum('money'),
	    	// 总收益
	    	'total_money' => UserMoneyLog::where('user_id',$this->auth->id)
    			->where('money','>',0)
	    		->sum('money'),
	    	// 未读消息数量
	    	'message_num' => \app\api\model\Message::where('to_user_id',$user['id'])
                ->where('is_read',2)
                ->count()
    	];
    	$user = $user->visible([
    		'id',
    		'username',
    		'nickname',
    		'avatar',
    		'id_num',
    		'money'
    	])->toArray();
        $this->success('成功', array_merge($user,$data));
    }

    /**
     * @ApiTitle    (个人中心-选择社区)
     * @ApiSummary  (个人中心-选择社区)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/houseList)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="area", type="string", required=true, description="市区地址例如:'天津市/西青区'")
     * @ApiParams   (name="keyword", type="string", required=false, description="关键字")
     *
     * @ApiReturn({
		"code": 1,
		"msg": "success",
		"time": "1598688508",
		"data": [{
			"id": 16, //小区ID
			"name": "兴安苑", //小区名称
			"area": "北京/北京市/朝阳区", //小区所在地区
			"status": 1, //状态:1=申请中,2=已绑定
			"is_current": 0 //是否当前小区:0=否,1=是
		}]
	})
     */
    public function houseList()
    {
        $user = $this->auth->getUser();
        $area = $this->request->param('area');
        $keyword = $this->request->param('keyword');
        $where = [];
        if(!empty($area)){
            $where['h.area'] = ['like',"%$area%"];
        }
        if(!empty($keyword)){
            $where['h.name'] = ['like',"%$keyword%"];
        }
        // 查出该用户已绑定的和申请中的小区
        $list = UserHouse::alias('uh')
        	->join('house h','h.id = uh.house_id')
        	->where('uh.user_id',$user['id'])
        	->where($where)
        	->field("h.id,h.name,h.area,uh.status")
        	->order('uh.status desc')
        	->select();
        foreach($list as &$v){
        	$v['is_current'] = $user['house_id'] == $v['id'] ? 1 : 0;
        }
        $this->success('success',$list);
    }

    /**
     * @ApiTitle    (个人中心-选择社区-切换)
     * @ApiSummary  (个人中心-选择社区-切换)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/houseUnbind)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_id", type="inter", required=true, description="小区ID")
     *
     * @ApiReturn({
		"code": 1,
		"msg": "切换成功"
	})
     */
    public function houseChange()
    {
        $user = $this->auth->getUser();
        $house_id = $this->request->param('house_id');
        empty($house_id) && $this->error('缺少必要参数');
        $info = UserHouse::get(['user_id'=>$user['id'],'house_id'=>$house_id]);
        empty($info) && $this->error('绑定信息不存在');
        $info['status'] != 2 && $this->error('您还没有绑定该小区，无法切换');
        $user->house_id = $house_id;
		$user->save();
        $this->success('切换成功');
    }

    /**
     * @ApiTitle    (个人中心-选择社区-解绑)
     * @ApiSummary  (个人中心-选择社区-解绑)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/houseUnbind)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_id", type="inter", required=true, description="小区ID")
     *
     * @ApiReturn({
		"code": 1,
		"msg": "解绑成功"
	})
     */
    public function houseUnbind()
    {
        $user = $this->auth->getUser();
        $house_id = $this->request->param('house_id');
        empty($house_id) && $this->error('缺少必要参数');
        $info = UserHouse::get(['user_id'=>$user['id'],'house_id'=>$house_id]);
        empty($info) && $this->error('绑定信息不存在');
        $info['status'] != 2 && $this->error('您还没有绑定该小区，无法解绑');
        // 启动事务
		Db::startTrans();
		try{
			$info->delete();
		    $user->house_id = 0;
		    $user->save();
		    // 提交事务
		    Db::commit();    
		} catch (\Exception $e) {
		    // 回滚事务
		    Db::rollback();
		    $this->error($e->getMessage());
		}
        $this->success('解绑成功');
    }

    /**
     * @ApiTitle    (个人中心-我的活动)
     * @ApiSummary  (个人中心-我的活动)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/activity)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiReturn   ({
		"code": 1,
		"msg": "成功",
		"time": "1598673648",
		"data": [{
			"id": 20, //活动报名ID
			"title": "澳大利亚政府这人品：我只要不承认，就不是针对中国", //活动标题
			"content": "", //活动内容
			"activity_time": "2020-08-28-2020-08-28" //活动时间
		}]
	})
     */
    public function activity()
    {
    	$list = HouseJoin::where('user_id',$this->auth->id)
    		->where('join_status','1')
    		->field('id,title,content,start_time,end_time')
    		->select();
    	foreach ($list as &$v) {
    		// 活动日期
            $v['activity_time'] = date('Y-m-d',$v['start_time']).'-'.date('Y-m-d',$v['end_time']);
            unset($v['start_time'],$v['end_time']);
    	}
        $this->success('成功', $list);
    }

    /**
     * @ApiTitle    (个人中心-我的活动-详情)
     * @ApiSummary  (个人中心-我的活动-详情)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/activityInfo)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_join_id", type="inter", required=true, description="报名ID")

     * @ApiReturn   ({
		"code": 1,
		"msg": "成功",
		"time": "1598684603",
		"data": {
			"order_no": "2020082852995199", //订单号
			"pay_price": "60.00", //合计费用
			"price": "30.00", // 报名费用
			"total_num": 2, // 报名数量
			"title": "澳大利亚政府这人品：我只要不承认，就不是针对中国", //活动标题
			"content": "", //活动描述
			"spec_type": "2", //活动规格:0=无规格-免费,1=单规格,2=多规格
			"activity_attr": "", //规格
			"activity_time": "2020-08-28-2020-08-28", //活动时间
			"join_time": "2020-08-28 18:45:56" //报名时间
		}
	})
     */
    public function activityInfo()
    {
        $house_join_id = $this->request->param('house_join_id');
        empty($house_join_id) && $this->error('请传入必填参数');
        $info = HouseJoin::get(['user_id'=>$this->auth->id,'id'=>$house_join_id]);
        empty($info) && $this->error('活动信息不存在');
        $data = [
        	// 活动时间
        	'activity_time' => date('Y-m-d',$info['start_time']).'-'.date('Y-m-d',$info['end_time']),
        	// 报名时间
        	'join_time' => date('Y-m-d H:i:s',!empty($info['pay_time']) ? $info['pay_time'] : $info['createtime'])
        ];
        $info = $info->visible([
        	'title',
        	'content',
        	'spec_type',
        	'price',
        	'order_no',
        	'total_num',
        	'pay_price',
        	'activity_attr'
        ])->toArray();
        $this->success('成功', array_merge($info,$data));
    }

    /**
     * @ApiTitle    (个人中心-收益明细)
     * @ApiSummary  (个人中心-收益明细)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/moneyLog)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiReturn({
		"code": 1,
		"msg": "成功",
		"time": "1598692386",
		"data": [{
			"memo": "测试", //标题
			"money": "10.00", //金额
			"createtime": "2020-08-29 17:07:56" // 时间
		}]
	})
     */
    public function moneyLog()
    {
        $list = UserMoneyLog::where('user_id',$this->auth->id)
        	->field("memo,money,from_unixtime(createtime, '%Y-%m-%d %H:%i:%S') createtime")
        	->select();
        $this->success('成功',$list);
    }

    /**
     * 提现
     * @ApiWeigh   (15)
     *
     * @ApiTitle    (提现)
     * @ApiSummary  (提现)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/withdraw)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="money", type="integer", required=true, description="提现金额")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功',
    "data": {
    })
     */
    public function withdraw()
    {
        if($this->request->isPost()) {
            $param = $this->request->param();
            $validate = new \think\Validate([
                'money' => 'require|number',
            ]);
            $validate->message([
                'money.require' => '请输入提现金额!',
                'money.number' => '提现金额必须为数字!',
            ]);
            if (!$validate->check($param)) {
                $this->error($validate->getError());
            }
            if ($param['money'] < 1) {
                $this->error('提现金额不可小于1元');
            }
            if ($param['money'] > 1000) {
                $this->error('提现金额不可大于1000元');
            }
            // 判断余额是否充足
            if ($param['money'] > $this->auth->money) {
                $this->error('余额不足，无法提现');
            }
            // 提现记录
            Db::startTrans();
            $user_model = $this->auth->getUser();
            $withdraw_model = new UserWithdraw();
            $user = $user_model->where('id', $this->auth->id)->find();
            $order_sn = date('YmdHis').rand(0000,9999);
            $withdraw = [
                'type' => 2,
                'user_id' => $this->auth->id,
                'before_money' => $this->auth->money,
                'after_money' => $this->auth->money - $param['money'],
                'order_sn' => $order_sn,
                'money' => $param['money'],
            ];
            $result = $withdraw_model->isUpdate(false)->save($withdraw);
            // 记录用户余额
            $result_user = $user_model->isUpdate(true)->save(['money' => $user['money'] - $param['money']]);
            // 记录余额变更
            $insert_data = array(
                'user_id' => $this->auth->id,
                'score' => $param['money'],
                'before'   => $this->auth->money,
                'after'   => $this->auth->money - $param['money'],
                'createtime' => time(),
                'memo' => '用户提现',
            );
            $res_log = Db::name('user_money_log')->insert($insert_data);
            if (!$result || !$result_user || !$res_log) {
                Db::rollback();
                $this->error('提现申请失败', [$result, $result_user]);
            }
            Db::commit();
            $this->success('提现申请成功');
        }
    }

    /**
     * 会员登录
     *
     * @param string $account  账号
     * @param string $password 密码
     */
    public function login()
    {
        $account = $this->request->request('account');
        $password = $this->request->request('password');
        if (!$account || !$password) {
            $this->error(__('Invalid parameters'));
        }
        $ret = $this->auth->login($account, $password);
        if ($ret) {
            $data = ['userinfo' => $this->auth->getUserinfo()];
            $this->success(__('Logged in successful'), $data);
        } else {
            $this->error($this->auth->getError());
        }
    }

    /**
     * 手机验证码登录
     *
     * @param string $mobile  手机号
     * @param string $captcha 验证码
     */
    public function mobilelogin()
    {
        $mobile = $this->request->request('mobile');
        $captcha = $this->request->request('captcha');
        if (!$mobile || !$captcha) {
            $this->error(__('Invalid parameters'));
        }
        if (!Validate::regex($mobile, "^1\d{10}$")) {
            $this->error(__('Mobile is incorrect'));
        }
        if (!Sms::check($mobile, $captcha, 'mobilelogin')) {
            $this->error(__('Captcha is incorrect'));
        }
        $user = \app\common\model\User::getByMobile($mobile);
        if ($user) {
            if ($user->status != 'normal') {
                $this->error(__('Account is locked'));
            }
            //如果已经有账号则直接登录
            $ret = $this->auth->direct($user->id);
        } else {
            $ret = $this->auth->register($mobile, Random::alnum(), '', $mobile, []);
        }
        if ($ret) {
            Sms::flush($mobile, 'mobilelogin');
            $data = ['userinfo' => $this->auth->getUserinfo()];
            $this->success(__('Logged in successful'), $data);
        } else {
            $this->error($this->auth->getError());
        }
    }

    /**
     * 注册会员
     *
     * @param string $username 用户名
     * @param string $password 密码
     * @param string $email    邮箱
     * @param string $mobile   手机号
     * @param string $code   验证码
     */
    public function register()
    {
        $username = $this->request->request('username');
        $password = $this->request->request('password');
        $email = $this->request->request('email');
        $mobile = $this->request->request('mobile');
        $code = $this->request->request('code');
        if (!$username || !$password) {
            $this->error(__('Invalid parameters'));
        }
        if ($email && !Validate::is($email, "email")) {
            $this->error(__('Email is incorrect'));
        }
        if ($mobile && !Validate::regex($mobile, "^1\d{10}$")) {
            $this->error(__('Mobile is incorrect'));
        }
        $ret = Sms::check($mobile, $code, 'register');
        if (!$ret) {
            $this->error(__('Captcha is incorrect'));
        }
        $ret = $this->auth->register($username, $password, $email, $mobile, []);
        if ($ret) {
            $data = ['userinfo' => $this->auth->getUserinfo()];
            $this->success(__('Sign up successful'), $data);
        } else {
            $this->error($this->auth->getError());
        }
    }

    /**
     * 注销登录
     */
    public function logout()
    {
        $this->auth->logout();
        $this->success(__('Logout successful'));
    }

    /**
     * 修改会员个人信息
     *
     * @param string $avatar   头像地址
     * @param string $username 用户名
     * @param string $nickname 昵称
     */
    public function profile()
    {
        $user = $this->auth->getUser();
        $username = $this->request->request('username');
        $nickname = $this->request->request('nickname');
        $avatar = $this->request->request('avatar', '', 'trim,strip_tags,htmlspecialchars');
        if ($username) {
            $exists = \app\common\model\User::where('username', $username)->where('id', '<>', $this->auth->id)->find();
            if ($exists) {
                $this->error(__('Username already exists'));
            }
            $user->username = $username;
        }
        $user->nickname = $nickname;
        $user->avatar = $avatar;
        $user->save();
        $this->success();
    }

    /**
     * 修改邮箱
     *
     * @param string $email   邮箱
     * @param string $captcha 验证码
     */
    public function changeemail()
    {
        $user = $this->auth->getUser();
        $email = $this->request->post('email');
        $captcha = $this->request->request('captcha');
        if (!$email || !$captcha) {
            $this->error(__('Invalid parameters'));
        }
        if (!Validate::is($email, "email")) {
            $this->error(__('Email is incorrect'));
        }
        if (\app\common\model\User::where('email', $email)->where('id', '<>', $user->id)->find()) {
            $this->error(__('Email already exists'));
        }
        $result = Ems::check($email, $captcha, 'changeemail');
        if (!$result) {
            $this->error(__('Captcha is incorrect'));
        }
        $verification = $user->verification;
        $verification->email = 1;
        $user->verification = $verification;
        $user->email = $email;
        $user->save();

        Ems::flush($email, 'changeemail');
        $this->success();
    }

    /**
     * 修改手机号
     *
     * @param string $mobile   手机号
     * @param string $captcha 验证码
     */
    public function changemobile()
    {
        $user = $this->auth->getUser();
        $mobile = $this->request->request('mobile');
        $captcha = $this->request->request('captcha');
        if (!$mobile || !$captcha) {
            $this->error(__('Invalid parameters'));
        }
        if (!Validate::regex($mobile, "^1\d{10}$")) {
            $this->error(__('Mobile is incorrect'));
        }
        if (\app\common\model\User::where('mobile', $mobile)->where('id', '<>', $user->id)->find()) {
            $this->error(__('Mobile already exists'));
        }
        $code = Cache::get($mobile);
        if ($code != $captcha) {
            $this->error(__('Captcha is incorrect'));
        }
        $verification = $user->verification;
        $verification->mobile = 1;
        $user->verification = $verification;
        $user->mobile = $mobile;
        $user->save();

        Cache::rm($mobile); 
        $this->success();
    }

    /**
     * 重置密码
     *
     * @param string $mobile      手机号
     * @param string $newpassword 新密码
     * @param string $captcha     验证码
     */
    public function resetpwd()
    {
        $type = $this->request->request("type");
        $mobile = $this->request->request("mobile");
        $email = $this->request->request("email");
        $newpassword = $this->request->request("newpassword");
        $captcha = $this->request->request("captcha");
        if (!$newpassword || !$captcha) {
            $this->error(__('Invalid parameters'));
        }
        if ($type == 'mobile') {
            if (!Validate::regex($mobile, "^1\d{10}$")) {
                $this->error(__('Mobile is incorrect'));
            }
            $user = \app\common\model\User::getByMobile($mobile);
            if (!$user) {
                $this->error(__('User not found'));
            }
            $ret = Sms::check($mobile, $captcha, 'resetpwd');
            if (!$ret) {
                $this->error(__('Captcha is incorrect'));
            }
            Sms::flush($mobile, 'resetpwd');
        } else {
            if (!Validate::is($email, "email")) {
                $this->error(__('Email is incorrect'));
            }
            $user = \app\common\model\User::getByEmail($email);
            if (!$user) {
                $this->error(__('User not found'));
            }
            $ret = Ems::check($email, $captcha, 'resetpwd');
            if (!$ret) {
                $this->error(__('Captcha is incorrect'));
            }
            Ems::flush($email, 'resetpwd');
        }
        //模拟一次登录
        $this->auth->direct($user->id);
        $ret = $this->auth->changepwd($newpassword, '', true);
        if ($ret) {
            $this->success(__('Reset password successful'));
        } else {
            $this->error($this->auth->getError());
        }
    }
}