<?php

namespace app\api\controller;

use app\admin\model\UserWithdraw;
use app\api\model\HouseAdmin as HouseAdminModel;
use app\api\model\HouseComment;
use app\api\model\Message;
use app\api\model\StoreComment;
use app\api\validate\StoreValidate;
use app\common\controller\Api;
use app\common\library\Ems;
use app\common\library\Sms;
use fast\Random;
use think\Db;
use think\Exception;
use think\exception\PDOException;
use think\Validate;
use think\Cache;
use app\api\model\House;
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
            "identity": 0, //身份0普通用户1主管理员2子管理员3商家
            "url": "/u/2",
            "is_store": 1, //商家入驻状态1待支付2待审核3审核通过4审核驳回
            "house": { //小区信息
                "id": 17, //小区ID
                "name": "碧海花园小区" //小区名称
            },
            "today_money": 10, //今日收益
            "total_money": 10, //总收益
            "message_num": 0 //未读消息数量
        }
    })
     */
    public function index()
    {
    	$user = $this->auth->getUser();
        $house = House::get($user['house_id']);
        // 计算今日收益
        $plus_today = UserMoneyLog::where('user_id',$user['id'])
            ->where('money','>',0)
            ->whereTime('createtime', 'today')
            ->select();
        $today_money = 0;
        foreach ($plus_today as $v) {
            if($v['before'] < $v['after']) {
                $today_money += $v['money'];
            }
        }
        // 计算总收益
        $plus = UserMoneyLog::where('user_id',$user['id'])
            ->where('money','>',0)
            ->select();
        $total_money = 0;
        foreach ($plus as $v) {
            if($v['before'] > $v['after']) {
                $total_money = bcsub($total_money,$v['money'],2);
            } else {
                $total_money = bcadd($total_money,$v['money'],2);
            }
        }
        $store = \app\api\model\Store::where('user_id',$this->auth->id)->order('id','DESC')->value('status');
        if($store == 3) {
            $where_house = [
                'user_id' => $this->auth->id,
                'store_id' => $store['id'],
                'house_id' => $house['id'],
                // 'end_time' => ['>',time()]
            ];
            $store_house = Db::name('store_house')->where($where_house)->count();
            if(!$store_house) {
                $store_house = 2;
            }
        } else {
            $store_house = $store ? $store : 0;
        }
    	$data = [
    		// 当前小区信息
    		'house' => !empty($house) ? $house->visible(['id','name'])->toArray() : [],
    		// 今日收益
    		'today_money' => $today_money,
	    	// 总收益
	    	'total_money' => $total_money,
	    	// 未读消息数量
	    	'message_num' => \app\api\model\Message::where('user_id',$user['id'])
                ->where('is_read_user',2)
                ->count(),
            // 是否入驻店铺
            'is_store' => $store_house,
            'sql' => Db::name('store_house')->getLastSql()
    	];
    	$user = $user->visible([
    		'id',
    		'username',
    		'nickname',
            'mobile',
    		'avatar',
    		'id_num',
    		'money',
            'identity'
    	])->toArray();
        $info = HouseAdminModel::where(['user_id'=>$this->auth->id])
            ->where(['house_id'=>$house['id']])
            ->order(['is_direct'=>'asc','createtime'=>'asc'])
            ->field('id,house_id,is_direct,nickname,avatar')
            ->find();
        if($info) {
            $user['identity'] = 1;
        } else {
            $user['identity'] = 0;
        }
        $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 = [
            'status' => ['in',[1,2]]
        ];
        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/houseChange)
     *
     * @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('缺少必要参数');

        $house = House::get($house_id);
        empty($house) && $this->error('社区信息不存在');

        $info = Db::name('user_house')->where(['user_id'=>$user['id'],'house_id'=>$house_id])->order('id','DESC')->find();
        empty($info) && $this->error('绑定信息不存在');

        $info['status'] != 2 && $this->error('您还没有绑定该小区，无法解绑');
        // 启动事务
		Db::startTrans();
		try{
			UserHouse::destroy($info['id']);
            // 解绑当前小区
            if($user['house_id'] == $house_id){
                $user->house_id = 0;
                $user->save();
            }
            // 绑定数量减1
            if($house['bindnum'] > 0){
                House::where('id',$house_id)->setDec('bindnum');
            }
		    // 提交事务
		    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']);
            // 列表内容返回纯文本
            $content1 = htmlspecialchars_decode($v['content']);
            $content2 = str_replace(['&nbsp;','&emsp;'],['',''],$content1);
            $v['content'] = strip_tags($content2);
            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));
    }

    /**
     * 留言消息
     * @ApiWeigh    (24)
     *
     * @ApiTitle    (留言消息)
     * @ApiSummary  (留言消息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/comment_list)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="page", 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": {
        "list": [
            {
            "id": 3,
            "user_id": 1,
            "object_id": 1,
            "object_user_id": 1,
            "type": 消息类型1=平台2=商家3=社区,
            "content": "文字内容",
            "image": "图片",
            "is_read_user": 是否已读1=是2=否,
            "name": "平台/店铺/社区名称"
            "createtime": "2020-08-30 10:43:55",
            },
            {
            "id": 1,
            "user_id": 1,
            "object_id": 1,
            "object_user_id": 1,
            "type": 1,
            "content": "123",
            "image": "",
            "is_read_user": 1,
            "name": "平台消息"
            "createtime": "2020-08-30 09:36:45",
            }
        ],
        "this_page": 当前页数,
        "total_page": 总页数
    }
    })
     */
    public function comment_list()
    {
        if($this->request->isPost()){
            $param = (new StoreValidate())->goCheck('common');
            $page = $param['page'];
            $where = [
                'where' => ['user_id'=>$this->auth->id],
            ];
            $order = ['updatetime'=>'DESC'];
            $model = new Message();
            $comment = $model->pageSelect($page,$where,'*',$order,config('option.num'));
            $list = $comment->items();
            foreach ($list as &$v){
                $v['name'] = '平台消息';
                if($v['type'] == 2) {
                    $v['name'] = Db::name('store')->where('id',$v['object_id'])->value('store_name');
                }
                if($v['type'] == 3) {
                    $v['name'] = Db::name('house')->where('id',$v['object_id'])->value('name');
                }
            }
            $return = [
                'list' => $list,
                'this_page' => $comment->currentPage(),
                'total_page' => $comment->lastPage()
            ];
            $this->success('请求成功',$return);
        }
    }

    /**
     * 留言消息详情（社区/商家）
     * @ApiWeigh    (23)
     *
     * @ApiTitle    (留言消息详情（社区/商家）)
     * @ApiSummary  (留言消息详情（社区/商家）)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/comment_detail)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="msg_id", type="integer", required=true, description="留言id")
     * @ApiParams   (name="page", 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": {
        "list": [
            {
            "id": 1,
            "user_id": 1,
            "store_id": 1,
            "store_user_id": 1,
            "type": 发送人1=用户2=社区/商家,
            "content": "文字内容",
            "image": "图片",
            "createtime": "2020-08-28 13:36:30",
            "user": {
                "id": 1,
                "nickname": "admin",
                "avatar": "http://community.qiniu.brotop.cn/assets/img/avatar.png"
                }
            }
        ],
        "this_page": 当前页数,
        "total_page": 总页数
    }
    })
     */
    public function comment_detail()
    {
        if($this->request->isPost()){
            $param = (new StoreValidate())->goCheck('comment_detail');
            $where = [
                'where' => ['id'=>$param['msg_id']],
            ];
            $msg_model = new Message();
            $msg = $msg_model->findOrFail($where);
            $edit = [
                'id' => $msg['id'],
                'is_read_user' => 1,
            ];
            $msg_model->edit($edit);
            if($msg['type'] == 2) {
                $model = new StoreComment();
                $object_model = new \app\api\model\Store();
                $object_field = 'id,store_name as nickname,store_icon as avatar';
                $object_id = 'store_id';
                $object_user_id = 'store_user_id';
            } elseif($msg['type'] == 3) {
                $model = new HouseComment();
                $object_model = new \app\api\model\HouseAdmin();
                $object_field = 'id,nickname,avatar';
                $object_id = 'house_id';
                $object_user_id = 'house_user_id';
            } else {
                $this->error('消息类型错误');
            }
            $where_c = [
                'where' => [
                    'user_id' => $msg['user_id'],
                    $object_id => $msg['object_id'],
                    $object_user_id => $msg['object_user_id'],
                ]
            ];
            $order = ['createtime'=>'DESC'];
            $comment = $model->pageSelect($param['page'],$where_c,'*',$order,config('option.num'));
            $list = $comment->items();
            array_multisort(array_column($list,'createtime'),SORT_ASC,$list);
            $user_model = new \app\api\model\User();
            foreach ($list as &$v) {
                if($v['type'] == 1) {
                $user = $user_model->field('id,nickname,avatar')->where('id',$v['user_id'])->find();
                } else {
                    if($msg['type'] == 2) {
                        $user = $object_model->field($object_field)->where('id',$v[$object_id])->find();
                    } elseif ($msg['type'] == 3) {
                        $user = $object_model->field($object_field)->where(['house_id'=>$v[$object_id],'user_id'=>$v[$object_user_id]])->find();
                    }
                }
                $user['avatar'] = cdnurl($user['avatar']);
                $v['user'] = $user;
            }
            $return = [
                'list' => $list,
                'this_page' => $comment->currentPage(),
                'total_page' => $comment->lastPage()
            ];
            $this->success('请求成功',$return);
        }
    }

    /**
     * 留言消息详情（平台）
     * @ApiWeigh    (23)
     *
     * @ApiTitle    (留言消息详情（平台）)
     * @ApiSummary  (留言消息详情（平台）)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/comment_detail_pt)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="msg_id", type="integer", required=true, description="留言id")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功',
    "data": {
        "msg": {
            "id": 1,
            "user_id": 1,
            "content": "文字内容",
            "image": "图片",
            "createtime": "2020-08-30 09:36:45",
        }
    }
    })
     */
    public function comment_detail_pt()
    {
        if($this->request->isPost()){
            $param = (new StoreValidate())->goCheck('comment_detail_pt');
            $where = [
                'where' => ['id'=>$param['msg_id']],
            ];
            $msg_model = new Message();
            $msg = $msg_model->findOrFail($where);
            $edit = [
                'id' => $msg['id'],
                'is_read_user' => 1,
            ];
            $msg_model->edit($edit);
            $admin_msg = Db::name('admin_msg')->where('id',$msg['object_id'])->find();
            $msg['title'] = $admin_msg['title'];
            $msg['content'] = $admin_msg['content'];
            $return = [
                'msg' => $msg,
            ];
            $this->success('请求成功',$return);
        }
    }

    /**
     * 留言回复
     * @ApiWeigh    (22)
     *
     * @ApiTitle    (留言回复)
     * @ApiSummary  (留言回复)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/comment_reply)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="msg_id", type="integer", required=true, description="留言id")
     * @ApiParams   (name="content", type="string", required=true, description="留言内容")
     * @ApiParams   (name="image", type="string", required=true, description="图片")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function comment_reply()
    {
        $param = (new StoreValidate())->goCheck('comment_reply');
        if(empty($param['content']) && empty($param['image'])) {
            $this->error('请填写内容或上传图片');
        }
        $msg_model = new Message();
        $where = [
            'where' => [
                'id' => $param['msg_id']
            ]
        ];
        $msg = $msg_model->findOrFail($where);
        if($msg['type'] == 2) {
            $model = new StoreComment();
            $object_id = 'store_id';
            $object_user_id = 'store_user_id';
        } elseif($msg['type'] == 3) {
            $model = new HouseComment();
            $object_id = 'house_id';
            $object_user_id = 'house_user_id';
        } else {
            $this->error('无法回复该类型消息');
        }
        Db::startTrans();
        $result = false;
        try{
            $add = [
                'user_id' => $msg['user_id'],
                $object_id => $msg['object_id'],
                $object_user_id => $msg['object_user_id'],
                'type' => 1,
                'content' => $param['content'],
                'image' => $param['image'],
            ];
            $result = $model->add($add);
            // 记录最新内容
            $where_m = [
                'user_id' => $msg['user_id'],
                'object_id' => $msg['object_id'],
                'object_user_id' => $msg['object_user_id'],
            ];
            $msg = $msg_model->where($where_m)->find();
            $update = [
                'id' => $msg['id'],
                'content' => $param['content'],
                'image' => $param['image'],
                'is_read_user' => 1,
                'is_read_object' => 2,
            ];
            $res_msg = $msg_model->edit($update);
            // 发送模板消息
            $send_data = array(
                "first"  => '您有一条新的消息',
                'keyword1' => $param['content'] ? $param['content'] : '【图片消息】',
                "keyword2"  => date('Y-m-s H:i:s',time()),
                "remark" => ['点击查看详情','#FF0000'],
            );
            $openid = Db::name('third')->where('user_id',$msg['object_user_id'])->value('openid');
            if($msg['type'] == 2) {
                $url = config('option.vue_url') . '/messageto?is_template=1&id='.$msg['id'];
            } elseif($msg['type'] == 3) {
                $url = config('option.vue_url') . '/liuyanxiaoxi?is_template=1&id='.$msg['id'].'&house_id='.$msg['object_id'];
            }
            (new \app\index\controller\Ajax)->wxsendmessage($openid,$send_data,config('option.template')['msg'],$url);
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if(!$result || !$res_msg) {
            $this->error('回复失败');
        }
        $this->success('回复成功');
    }

    /**
     * @ApiTitle    (个人中心-收益明细)
     * @ApiSummary  (个人中心-收益明细)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/moneyLog)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="page", type="inter", required=false, description="当前页(默认1)")
     * @ApiParams   (name="pageNum", type="inter", required=false, description="每页显示数据个数（默认10）")
     *
     * @ApiReturn({
		"code": 1,
		"msg": "成功",
		"time": "1598692386",
		"data": [{
			"memo": "测试", //标题
			"money": "10.00", //金额
            "before": 0, //变更前余额
            "after": 0, //变更后余额
            "status": 0, //状态:0=无状态,1=审核中,2=审核通过,3=审核失败
			"createtime": "2020-08-29 17:07:56" // 时间
		}]
	})
     */
    public function moneyLog()
    {
        $page = $this->request->param('page', 1, 'intval');
        $pageNum = $this->request->param('pageNum', 10, 'intval');
        $where = ['user_id'=>$this->auth->id];
        $total_num = UserMoneyLog::where($where)->count();
        $list = UserMoneyLog::where($where)
        	->field("memo,money,before,after,status,createtime")
            ->page($page,$pageNum)
            ->order('createtime','DESC')
        	->select();
        foreach ($list as &$v) {
            $v['createtime'] = date('Y-m-d H:i:s',$v['createtime']);
        }
        $this->success('成功',compact('total_num','list'));
    }

    /**
     * 提现
     * @ApiWeigh   (15)
     *
     * @ApiTitle    (提现)
     * @ApiSummary  (提现)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/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);
            // 记录余额变更
            $insert_data = array(
                'user_id' => $this->auth->id,
                'money' => $param['money'],
                'before'   => $this->auth->money,
                'after'   => $this->auth->money - $param['money'],
                'createtime' => time(),
                'status' => 1,
                'memo' => '用户提现',
            );
            $res_log = Db::name('user_money_log')->insert($insert_data);
            // 记录用户余额
            $result_user = $user_model->isUpdate(true)->save(['id'=>$this->auth->id,'money' => $user['money'] - $param['money']]);
            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 $nickname 昵称
     */
    public function profile()
    {
        $user = $this->auth->getUser();
        $nickname = $this->request->request('nickname');
        $avatar = $this->request->request('avatar', '', 'trim,strip_tags,htmlspecialchars');
        if($nickname || $avatar) {
            if($nickname) {
                $user->nickname = $nickname;
            }
            if($avatar) {
                $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());
        }
    }
}