universesupermarket_api/application/api/controller/UserCenter.php

<?php
namespace app\api\controller;
use AlibabaCloud\Client\AlibabaCloud;
use AlibabaCloud\Client\Exception\ClientException;
use AlibabaCloud\Client\Exception\ServerException;
use app\common\library\AliPay;
use app\common\library\AliPay2;
use app\common\library\Shande;
use EasyWeChat\Factory;
use think\cache\driver\Redis;
use think\Db;
use think\facade\Validate;

/**
 * @title 会员个人中心
 * @controller UserCenter
 * @group base
 */
class UserCenter extends Base
{
    public function initialize()
    {
        parent::initialize();
        parent::check_login();
    }

    /**
     * @title 获取个人信息
     * @desc 个人信息
     * @author Gavin
     * @url /api/User_center/getUserInfo
     * @method POST
     * @tag 个人信息
     * @header name:Authorization require:1 desc:Token
     * @return name:id type:int default:-- desc:ID(邀请ID)
     * @return name:phone type:string default:-- desc:手机号
     * @return name:name type:string default:-- desc:昵称
     * @return name:headimg type:string default:-- desc:头像地址
     * @return name:integral type:int default:-- desc:积分
     * @return name:snap_card type:int default:-- desc:抢购卡
     * @return name:wallet_address type:int default:-- desc:钱包地址
     * @return name:true_name type:string default:-- desc:真实姓名
     * @return name:id_card type:string default:-- desc:身份证号
     * @return name:is_auth type:int default:-- desc:是否认证（0否1是）
     * @return name:auth_at type:string default:-- desc:认证时间
     * @return name:vip_name type:int default:-- desc:身份
     * @return name:is_order_no_paid type:string default:-- desc:是否有未支付订单true:有false:没有
     * @return name:is_sign type:string default:-- desc:今日是否已经签到true:已签到false:未签到
     * @return name:invite_img type:string default:-- desc:邀请二维码
     * @return name:invite_address type:string default:-- desc:邀请地址
     * @return name:lucky_number type:int default:-- desc:剩余抽奖次数
     * @return name:money type:string default:-- desc:余额
     * @return name:is_password type:string default:-- desc:是否设置二级密码
     */
    public function getUserInfo()
    {
        $uid = $this->uid;
        $user_info = Db::name('store_member')
            ->field('password',true)
            ->where('id',$uid)
            ->find();
        if(empty($user_info)) $this->error('用户信息不正确');
        $user_info['vip_name'] = $user_info['vip']==1 ? "藏友" : "创世勋章";
        //是否有待支付订单
        $order = Db::name('store_order')->where('status',0)->where('is_deleted',0)->where('mid',$uid)->count();
        $user_info['is_order_no_paid'] = $order ? true : false;
        //今日是否签到
        $date = date('Y-m-d');
        $sign = Db::name('store_member_sign')->where('mid',$uid)->where('date',$date)->count();
        $user_info['is_sign'] = $sign ? true : false;
        //获取每日免费次数
        $free_number = getConfigValue('free_lucky_number');
        //获取当日免费抽奖记录
        $date = date('Y-m-d');
        $now_date_count = Db::name('store_blind_box_log')->where('m_id',$this->uid)->where('date',$date)->where('is_free',0)->count();

        if (!$user_info['invite_img'] || !$user_info['invite_address']){
            $code = $user_info['invite_code'];
            $invite_img = setintivecode($code);
            $invite_address = getintiveaddress($code);
            Db::name('store_member')->where('id',$this->uid)->update(['invite_img'=>$invite_img,'invite_address'=>$invite_address]);
        }
        $user_info['invite_img'] = str_replace('http:','https:',$user_info['invite_img']);
        $lucky_number = $user_info['lottery_number'] + ($free_number-$now_date_count);
        $user_info['lucky_number'] =$lucky_number<=0 ? 0 : $lucky_number;
        $user_info['is_password'] = !empty($user_info['second_password']) ? 1 : 0;
        unset($user_info['second_password']);
        $this->success('获取成功',$user_info);
    }

    /**
     * @title 绑定opendid
     * @desc 绑定opendid
     * @author Gavin
     * @url /api/User_center/bindOpenid
     * @method POST
     * @tag 编辑信息
     * @header name:Authorization require:1 desc:Token
     *
     * @param name:code type:string require:0 default:-- desc:code
     */
    public function bindOpenid()
    {
        $this->success('绑定成功');
        $code = input('code');
        if(empty($code)) $this->error('参数错误');
        $appid = 'wxb5a55711e16751c4';
        $secret = 'aa959279388afa034c32081ed05ed07b';
        $res = http_get('https://api.weixin.qq.com/sns/oauth2/access_token?appid='.$appid.'&secret='.$secret.'&code='.$code.'&grant_type=authorization_code');
        $res = json_decode($res,true);
        if (isset($res['openid'])){
            $update_data['openid'] = $res['openid'];
            $update_data['update_at'] = date('Y-m-d H:i:s');
            if (Db::name('store_member')->where('id',$this->uid)->update($update_data)){
                setMemberInfoHash($this->uid);
                $this->success('绑定成功');
            }
            $this->error('绑定失败');
        }else{
            $this->error('获取openid失败');
        }
    }


    /**
     * @title 编辑个人信息
     * @desc 编辑个人信息
     * @author Gavin
     * @url /api/User_center/updateUserInfo
     * @method POST
     * @tag 编辑信息
     * @header name:Authorization require:1 desc:Token
     *
     * @param name:name type:string require:0 default:-- desc:姓名
     * @param name:headimg type:string require:0 default:-- desc:头像地址
     */
    public function updateUserInfo()
    {
        $headimg  = input('post.headimg');
        $name     = trim(input('post.name',''));
        if(!$headimg && !$name)   $this->error('参数错误');
        $update_data= [];
        if($name) $update_data['name'] = $name;
        if ($headimg) $update_data['headimg'] = $headimg;
        if($name){
            $check_member =  Db::name('store_member')
                ->where('name',$name)
                ->where('id','<>',$this->uid)
                ->count();
            if($check_member) $this->error('该用户名已被占用');
        }
        $update_data['update_at'] = date('Y-m-d H:i:s');
        if (Db::name('store_member')->where('id',$this->uid)->update($update_data)){
            setMemberInfoHash($this->uid);
            $this->success('编辑成功');
        }
        $this->error('编辑失败');
    }


    /**
     * @title 绑定支付宝
     * @desc 绑定支付宝
     * @author Gavin
     * @url /api/User_center/bind_zfb
     * @method POST
     * @tag 编辑信息
     * @header name:Authorization require:1 desc:Token
     *
     * @param name:account type:string require:0 default:-- desc:支付宝账号
     * @param name:zfb_real_name type:string require:0 default:-- desc:真实姓名
     */
    public function bind_zfb(){
        $this->check_login();
        $account = input('account');    //账号
        $real_name = input('real_name'); //真实姓名
        if (!$account) $this->error('支付宝账号为空');
        if (!$real_name) $this->error('真实姓名为空');
        $update_data['zfb_account'] = $account;
        $update_data['zfb_real_name'] = $real_name;
        $update_data['update_at'] = date('Y-m-d H:i:s');
        if (Db::name('store_member')->where('id',$this->uid)->update($update_data)){
            setMemberInfoHash($this->uid);
            $this->success('绑定成功');
        }
        $this->error('绑定失败');
    }

    /**
     * @title 实名认证
     * @desc 实名认证
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/userCertification
     * @header name:Authorization require:1 desc:Token
     * @param name:true_name type:string require:1 default:-- desc:真实姓名
     * @param name:phone type:string require:1 default:-- desc:手机号
     * @param name:id_card type:string require:1 default:-- desc:身份证号
     */
    public function userCertification(){
        $true_name = input('post.true_name');
        $id_card = input('post.id_card');
        $phone = input('post.phone');
        if (!$true_name || !$id_card || !$phone) $this->error('参数错误');
        if (!$true_name || !$id_card ) $this->error('参数错误');
        $check_id_card = isCreditNo($id_card);
        if (!$check_id_card) $this->error('身份证号格式错误');
        if (!Validate::regex($phone, "^1\d{10}$")) {
            $this->error('手机号格式错误');
        }
        $is_auth = Db::table('store_member')->where('id',$this->uid)->value('is_auth');
        if($is_auth) $this->error('已认证');
        $check = Db::name('store_member')->where('id_card',$id_card)->count();
        if ($check) $this->error('身份证号已经认证过');

        if (!userThreecertification($id_card,$true_name,$phone)) $this->error('身份证与姓名与手机号验证失败');
//        if (!identifyCertification($id_card,$true_name)) $this->error('身份证与姓名验证失败');

        if (Db::table('store_member')->where('id',$this->uid)->update(['is_auth'=>1,'true_name'=>$true_name,'id_card'=>$id_card,'true_phone'=>$phone,'auth_at'=>date('Y-m-d H:i:s')])){
            setMemberInfoHash($this->uid);
            $this->success('认证成功');
        }
        $this->error('认证失败');
    }

    /**
     * @title 修改密码
     * @desc 修改密码
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/updatePass
     * @header name:Authorization require:1 desc:Token
     * @param name:old_password type:string require:1 default:-- desc:旧密码
     * @param name:new_password type:string require:1 default:-- desc:新密码
     * @param name:confirm_password type:string require:1 default:-- desc:确认密码
     */
    public function updatePass()
    {
        $old_password = input('post.old_password');
        $new_password = input('post.new_password');
        $confirm_password = input('post.confirm_password');
//        $yzm = input('post.yzm');
//        if (!$old_password || !$new_password || !$confirm_password || !$yzm) $this->error('参数错误');
        if (!$old_password || !$new_password || !$confirm_password) $this->error('参数错误');
        if ($new_password!=$confirm_password) $this->error('密码与确认密码不一致');
        if (!preg_match('/^[0-9a-z]{6,12}$/i',$new_password)) $this->error('密码格式错误,请输入6-12位数字+字母');
        $member = Db::name('store_member')->where('id',$this->uid)->find();

        //验证短信验证码
        /*$time = time()-60;
        $sms = Db::name('store_sms')->where(['mobile' => $member['phone'], 'event' => 'forgetpwd'])
            ->where('createtime','>',$time)
            ->order('id', 'DESC')
            ->find();
        if (!$sms || $sms['code'] != $yzm) $this->error('短信验证码不正确！');*/

        if ($member['password']!=md5($old_password)) $this->error('旧密码错误');
        $data['password'] = md5($new_password);
        $data['update_at'] = date('Y-m-d H:i:s');
        if (Db::name('store_member')->where('id',$this->uid)->update($data)){
            setMemberInfoHash($this->uid);
            $this->success('修改成功');
        }
        $this->error('修改失败');
    }

    /**
     * @title 修改二级密码
     * @desc 修改二级密码
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/updateSecondPass
     * @header name:Authorization require:1 desc:Token
     * @param name:second_password type:string require:1 default:-- desc:二级密码
     * @param name:confirm_second_password type:string require:1 default:-- desc:确认密码
     */
    public function updateSecondPass()
    {
        $second_password = input('post.second_password');
        $confirm_second_password = input('post.confirm_second_password');
        $yzm = input('post.yzm');
        if (!$second_password || !$confirm_second_password) $this->error('参数错误');
        if ($second_password!=$confirm_second_password) $this->error('密码与确认密码不一致');
        if (!preg_match('/^[0-9]{6}$/i',$second_password)) $this->error('支付密码格式错误,请输入6位纯数字');

        $member = getMemberInfoHash($this->uid); //获取用户信息
        //验证短信验证码
//        $time = time()-60;
//        $sms = Db::name('store_sms')->where(['mobile' => $member['phone'], 'event' => 'forgetpwd'])
//            ->where('createtime','>',$time)
//            ->order('id', 'DESC')
//            ->find();
//        if (!$sms || $sms['code'] != $yzm) $this->error('短信验证码不正确！');

        $data['second_password'] = md5($second_password);
        $data['update_at'] = date('Y-m-d H:i:s');
        if (Db::name('store_member')->where('id',$this->uid)->update($data)){
            setMemberInfoHash($this->uid);
            $this->success('修改成功');
        }
        $this->error('修改失败');
    }

    /**
     * @title 我的藏品
     * @desc 我的藏品
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/myCollection
     * @header name:Authorization require:1 desc:Token
     *
     * @param name:type type:int require:1 default:0 desc:类型0全部；1藏品；3盲盒
     *
     * @return  name:id type:int require:0 default:0 desc:藏品ID
     * @return  name:tag type:string require:0 default:0 desc:唯一标签
     * @return  name:name type:string require:0 default:0 desc:藏品名称
     * @return  name:cover type:string require:0 default:0 desc:藏品图片
     * @return  name:auth_img type:string require:0 default:0 desc:作者头像
     * @return  name:auth_name type:string require:0 default:0 desc:作者名称
     * @return  name:num type:int require:0 default:0 desc:藏品数量
     * @return  name:type type:int require:0 default:0 desc:藏品类型1藏品3盲盒
     * @return  name:buy_num type:int require:0 default:0 desc:寄售中
     * @return  name:hold_num type:int require:0 default:0 desc:持有
     */
    public function myCollection(){
        $type = input('post.type');
        switch ($type){
            case 0: $type = "1,3,4";break;
            case 1: $type = "1,4";break;
            case 3: $type = "3";break;
        }
        $list = Db::name('store_order_info')
            ->where('mid',$this->uid)
            ->where('status','neq','2')
            ->where('is_destruction',1)
            ->where('resale_status','neq',3)
            ->whereIn('type',$type)
            ->field('id,tag,pro_info,count(c_id) as num,type,c_id')
            ->group('c_id')
            ->order('id desc')
            ->select();
        foreach ($list as &$v){
            $pro_info = json_decode($v['pro_info'],true);
            $v['name'] = $pro_info['name'];
            $v['cover'] = $pro_info['cover'];
            $v['auth_img'] = $pro_info['auth_img'];
            $v['auth_name'] = $pro_info['auth_name'];
            //查询持有、寄售
            $countData = [
                'uid' => $this->uid,
                'c_id' => $v['c_id'],
                'type' => $type,
                'resale_status' => 1,
            ];
            $v['hold_num'] = $this->getStatusCollectionCount($countData);
            $countData['resale_status'] = 2;
            $v['buy_num'] = $this->getStatusCollectionCount($countData);

            unset($v['pro_info']);
        }
        $this->success('成功',$list);
    }
    /**
     * @title 藏品列表
     * @desc 藏品列表
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/myCollectionList
     * @header name:Authorization require:1 desc:Token
     *
     * @param name:cid type:int require:1 default:0 desc:藏品id
     * @param name:type type:int require:1 default:0 desc:类型0全部；1藏品；3盲盒
     *
     * @return  name:id type:int require:0 default:0 desc:藏品ID
     * @return  name:tag type:string require:0 default:0 desc:唯一标签
     * @return  name:name type:string require:0 default:0 desc:藏品名称
     * @return  name:cover type:string require:0 default:0 desc:藏品图片
     * @return  name:auth_img type:string require:0 default:0 desc:作者头像
     * @return  name:auth_name type:string require:0 default:0 desc:作者名称
     * @return  name:type type:int require:0 default:0 desc:藏品类型1藏品3盲盒
     * @return  name:resale_status type:int require:0 default:0 desc:持有状态1持有中2挂售中
//     * @return  name:buy_num type:int require:0 default:0 desc:寄售中
//     * @return  name:hold_num type:int require:0 default:0 desc:持有
     */
    public function myCollectionList(){
        $cid = input('post.cid');
        if(empty($cid)) $this->error('参数错误');
        $type = input('post.type');
        switch ($type){
            case 0: $type = "1,3,4";break;
            case 1: $type = "1,4";break;
            case 3: $type = "3";break;
        }
        $list = Db::name('store_order_info')
            ->where('mid',$this->uid)
            ->where('status','neq','2')
            ->where('is_destruction',1)
            ->where('resale_status','neq',3)
            ->where('c_id',$cid)
            ->whereIn('type',$type)
            ->field('id,tag,pro_info,type,resale_status')
            ->order('resale_status asc,id desc')
            ->select();
        foreach ($list as &$v){
            $pro_info = json_decode($v['pro_info'],true);
            $v['name'] = $pro_info['name'];
            $v['cover'] = $pro_info['cover'];
            $v['auth_img'] = $pro_info['auth_img'];
            $v['auth_name'] = $pro_info['auth_name'];
            unset($v['pro_info']);
        }
        $this->success('成功',$list);
    }
    /**
     * 获取对于状态藏品数量
     * @param $result
     * @return bool
     */
    function getStatusCollectionCount($result){
        return  Db::name('store_order_info')
            ->where('mid',$result['uid'])
            ->where('status','neq','2')
            ->where('is_destruction',1)
            ->where('resale_status','eq',$result['resale_status'])
            ->where('c_id',$result['c_id'])
            ->whereIn('type',$result['type'])
            ->order('id desc')
            ->count('c_id');
    }
    /**
     * @title 我的盲盒
     * @desc 我的盲盒
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/myBoxCollection
     * @header name:Authorization require:1 desc:Token
     *
     * @return  name:id type:int require:0 default:0 desc:藏品ID
     * @return  name:tag type:string require:0 default:0 desc:唯一标签
     * @return  name:name type:string require:0 default:0 desc:藏品名称
     * @return  name:cover type:string require:0 default:0 desc:藏品图片
     * @return  name:auth_img type:string require:0 default:0 desc:作者头像
     * @return  name:auth_name type:string require:0 default:0 desc:作者名称
     */
    public function myBoxCollection(){
        parent::check_login();
        $list = Db::name('store_order_info')
            ->where('mid',$this->uid)
            ->where('status','neq','2')
            ->where('type',3)
            ->where('is_destruction',1)
            ->where('resale_status',1)
            ->field('id,tag,pro_info')
            ->order('id desc')
            ->select();
        foreach ($list as &$v){
            $pro_info = json_decode($v['pro_info'],true);
            $v['name'] = $pro_info['name'];
            $v['cover'] = $pro_info['cover'];
            $v['auth_img'] = $pro_info['auth_img'];
            $v['auth_name'] = $pro_info['auth_name'];
            unset($v['pro_info']);
        }
        $this->success('成功',$list);
    }
    /**
     * @title 藏品详情
     * @desc 藏品详情
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/myCollectionDetail
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:-- desc:藏品ID
     *
     * @return  name:id type:int require:0 default:0 desc:藏品ID
     * @return  name:tag type:string require:0 default:0 desc:唯一标签
     * @return  name:collectors_name type:string require:0 default:0 desc:收藏者
     * @return  name:collectors_hash type:string require:0 default:0 desc:收藏者hash
     * @return  name:create_at type:string require:0 default:0 desc:收藏时间
     * @return  name:company type:string require:0 default:0 desc:流转公司
     * @return  name:company_hash type:string require:0 default:0 desc:流转公司hash
     * @return  name:examples_illustrate type:string require:0 default:0 desc:转赠说明
     * @return  name:pro_info@name type:string require:0 default:0 desc:藏品名称
     * @return  name:pro_info@price type:string require:0 default:0 desc:藏品价格
     * @return  name:pro_info@label type:string require:0 default:0 desc:藏品标签
     * @return  name:pro_info@cover type:string require:0 default:0 desc:藏品图片
     * @return  name:pro_info@auth_img type:string require:0 default:0 desc:作者头像
     * @return  name:pro_info@auth_name type:string require:0 default:0 desc:作者姓名
     * @return  name:pro_info@warm_prompt type:string require:0 default:0 desc:温馨提示
     * @return  name:pro_info@share_img type:string require:0 default:0 desc:分享二维码
     */
    public function myCollectionDetail(){
        $id = input('id');
        if (!$id) $this->error('参数错误');
        $info = Db::name('store_order_info')
            ->where('mid',$this->uid)
            ->where('id',$id)
            ->find();
        if (!$info) $this->error('藏品不存在');
        $info['pro_info'] = json_decode($info['pro_info'],true);
        if (!isset($info['pro_info']['share_img'])){
            $info['pro_info']['share_img'] = Db::name('store_collection')->where('id',$info['pro_info']['id'])->value('share_img');
        }
        $info['collectors_name'] = Db::name('store_member')->where('id',$this->uid)->value('name');
        $info['collectors_hash'] = $info['collectors_hash']=='' ? "发放中" : $info['collectors_hash'];
        $info['collectors_hash_time'] = $info['collectors_hash_time']=='' ? "发放中" : $info['collectors_hash_time'];
        $info['examples_illustrate'] = Db::table('system_config')->where('name','examples_illustrate')->value('value');
        $info['contract_address'] = "dd82c57d4b7389a688f9f2247f84e455e76a8da9bb5a7272a1b6b0a83ba25bff";
        $this->success('成功',$info);
    }

    /**
     * @title 转赠
     * @desc 转赠
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/examples
     * @header name:Authorization require:1 desc:Token

     * @param name:id type:int require:1 default:-- desc:藏品ID
     * @param name:phone type:string require:1 default:-- desc:手机号
     * @param name:wallet_address type:int require:1 default:-- desc:钱包地址
     * @param name:second_password type:int require:1 default:-- desc:二级密码
     *
     */
    public function examples(){
        $this->error('暂时关闭');
        $id = input('id');
        $redis = new Redis([ 'select'=> 2]);
        $redis_value = $redis->get('examples'.$this->uid);
        if ($redis_value){
            $this->error('请求过快,请稍后重试');
        }else{
            $redis->set('examples'.$this->uid,1,2);
        }
        $phone = input('phone');
        $wallet_address = input('wallet_address');
        $second_password = input('second_password');
        if (!$id || !$phone || !$wallet_address) $this->error('参数错误');
        $info = Db::name('store_order_info')->where('id',$id)->where('mid',$this->uid)->find();
        if (!$info) $this->error('藏品不存在');
        if ($info['status']==2) $this->error('藏品已转赠');
        $member = Db::name('store_member')->where('phone',$phone)->where('wallet_address',$wallet_address)->find();
        if (!$member) $this->error('转赠用户不存在');

        if (!$info['collectors_hash']) $this->error('发放中，无法转赠');

        $mem = getMemberInfoHash($this->uid);
        if ($mem['second_password']!=md5($second_password)) $this->error('密码错误');

        $pro_info = Db::name('store_collection')->where('id',$info['c_id'])->find();
        $log = Db::name('store_collect_examples_log')
            ->where('order_info_id',$id)
            ->find();
        if (!$log){
            if ($pro_info['one_given_day']!=0){
                $exam_time = strtotime($info['create_at'])+($pro_info['one_given_day']*24*60*60);
                if ($exam_time>time()) $this->error('持有时间限制，无法转赠');
            }
        }else{
            if ($pro_info['other_given_day']!=0){
                $exam_time = strtotime($log['create_at'])+($pro_info['other_given_day']*24*60*60);
                if ($exam_time>time()) $this->error('持有时间限制，无法转赠');
            }
        }

        $com = true;

        Db::startTrans();
        try {
            Db::name('store_order_info')
                ->where('id',$id)
                ->update(['status'=>2,'over_time'=>date('Y-m-d H:i:s'),'to_mid'=>$member['id']]);
            $to_date = [
                'order_id'=>$info['order_id'],
                'order_no'=>get_order_sn(),
                'tag'=>$info['tag'],
                'mid'=>$member['id'],
                'c_id'=>$info['c_id'],
                'name'=>$pro_info['name'],
                'cover'=>$pro_info['cover'],
                'pro_info'=>$info['pro_info'],
                'status'=>3,
                'to_mid'=>$this->uid,
                'over_time'=>date('Y-m-d H:i:s'),
                'company'=>'南宁中科数艺科技有限公司',
                'company_hash'=>$info['company_hash'],
                'company_hash_time'=>$info['company_hash_time'],
                'ddcid'=>$info['ddcid'],
                'collectors_hash'=>'',
                'collectors_hash_time'=>date('Y-m-d H:i:s')
            ];
            $new_id = Db::name('store_order_info')->insertGetId($to_date);
            $log_date = [
                'order_info_id'=>$new_id,
                'mid'=>$this->uid,
                'to_mid'=>$member['id'],
                'date'=>date('Y-m')
            ];
            Db::name('store_collect_examples_log')->insert($log_date);
            Db::commit();
        }catch (\Exception $e){
            $com = false;
            Db::rollback();
        }
        if ($com){
            $this->success('转赠成功');
        }
        $this->error('转赠失败');
    }

    /**
     * @title 消息列表
     * @desc 消息列表
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/messageList
     * @header name:Authorization require:1 desc:Token
     *
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     *
     * @return  name:id type:int require:0 default:0 desc:消息ID
     * @return  name:title type:string require:0 default:0 desc:标题
     * @return  name:content type:string require:0 default:0 desc:内容
     * @return  name:create_at type:string require:0 default:0 desc:发布时间
     * @return  name:is_read type:string require:0 default:0 desc:是否查看true:已查看false:未查看
     */
    public function messageList(){
        $count = Db::name('store_message')->where('is_deleted',0)->count();
        $list = Db::name('store_message')
            ->field('is_deleted,update_at',true)
            ->where('is_deleted',0)
            ->order('id desc')
            ->limit($this->off_set,$this->page_num)
            ->select();
//        echo Db::name('store_message')->getLastSql();die;
        foreach ($list as &$v){
            $is_read = Db::name('store_message_read_log')->where('mid',$this->uid)->where('message_id',$v['id'])->count();
            $v['is_read'] = $is_read ? true : false;
        }
        $this->success('成功',compact('count','list'));
    }

    /**
     * @title 点击消息
     * @desc 点击消息,查看消息
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/readMessage
     * @header name:Authorization require:1 desc:Token
     *
     * @param  name:id type:int  : default:1 desc:消息ID
     *
     */
    public function readMessage(){
        $id = input('id');
        if (!$id) $this->error('参数错误');
        $log = Db::name('store_message_read_log')->where('message_id',$id)->where('mid',$this->uid)->count();
        if (!$log){
            $data = [
                'mid'=>$this->uid,
                'message_id'=>$id
            ];
            Db::name('store_message_read_log')->insert($data);
        }
        $this->success('成功');
    }


    /**
     * @title 人脸认证sign
     * @desc 人脸认证sign
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/getFaceSign
     * @header name:Authorization require:1 desc:Token
     *
     *
     * @param  name:name type:string  default:1 desc:姓名
     * @param  name:idNo type:string  default:1 desc:身份证号
     *
     * @return  name:sign type:string require: default:-- desc:签名
     *
     */
    public function getFaceSign(){
        $name = input('name');
        $idNo = input('idNo');
        if (!$name || !$idNo) $this->error('参数错误');
        $userId =  $this->uid;
        //$userId = get32Str();
        $data = getfaceid($name,$idNo,$userId);
        $this->success('成功',$data);
    }

    /**
     * @title 邀请记录
     * @desc 邀请记录
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/invitedRecord
     * @header name:Authorization require:1 desc:Token
     *
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     *
     * @return  name:id type:int require:0 default:0 desc:用户ID
     * @return  name:headimg type:string require:0 default:0 desc:头像
     * @return  name:name type:string require:0 default:0 desc:名称
     * @return  name:phone type:string require:0 default:0 desc:手机号
     * @return  name:create_at type:string require:0 default:0 desc:时间
     */
    public function invitedRecord(){
        $count = Db::name('store_member')->where('pid',$this->uid)->count();
        $list = Db::name('store_member')
            ->field('id,headimg,name,phone,create_at')
            ->where('pid',$this->uid)
            ->order('id desc')
            ->limit($this->off_set,$this->page_num)
            ->select();
        foreach ($list as &$v){
            $v['phone'] = substr_replace($v['phone'],'****',3,4);
            $v['create_at'] = date('Y-m-d',strtotime($v['create_at']));
        }
        $this->success('成功',compact('count','list'));
    }


    /**
     * @title 邀请排行榜
     * @desc 邀请排行榜
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/invitedList
     * @header name:Authorization require:1 desc:Token
     *
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     *
     * @return  name:id type:int require:0 default:0 desc:用户ID
     * @return  name:headimg type:string require:0 default:0 desc:头像
     * @return  name:name type:string require:0 default:0 desc:名称
     * @return  name:phone type:string require:0 default:0 desc:手机号
     * @return  name:create_at type:string require:0 default:0 desc:时间
     */
    public function invitedList(){

        $count = Db::name('store_member as a')
            ->field('a.id,a.name,a.headimg,a.phone,a.pid,(select count(b.id) from store_member as b where b.pid=a.id) as count')
            ->group('a.id')
            ->having('count>0')
            ->count();
        $list = Db::name('store_member as a')
            ->field('a.id,a.name,a.headimg,a.phone,a.pid,(select count(b.id) from store_member as b where b.pid=a.id) as count')
            ->group('a.id')
            ->having('count>0')
            ->order('count desc')
            ->limit($this->off_set,$this->page_num)
            ->select();
        $this->success('成功',compact('count','list'));
    }


    /**
     * @title 签到
     * @desc 签到
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/sign
     * @header name:Authorization require:1 desc:Token
     *
     */
    public function sign(){
        $date = date('Y-m-d');
        $log = Db::name('store_member_sign')->where('mid',$this->uid)->where('date',$date)->count();
        if ($log) $this->error('今日已签到');
        $data = [
            'mid'=>$this->uid,
            'date'=>$date
        ];
        $com = true;
        Db::startTrans();
        try {
            $id = Db::name('store_member_sign')->insertGetId($data);
            $sign_integral = getConfigValue('sign_integral');
            if ($sign_integral>0){
                memberMoneyChange($sign_integral,1,$this->uid,'签到',1,$id);
            }
            Db::commit();
        }catch (\Exception $e){
            $com=false;
            Db::rollback();
        }
        if ($com){
            $this->success('签到成功');
        }
        $this->error('签到失败');
    }



    /**
     * @title 积分记录
     * @desc 积分记录
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/integralLog
     * @header name:Authorization require:1 desc:Token
     *
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     *
     * @return  name:id type:int require:0 default:0 desc:id
     * @return  name:change type:string require:0 default:0 desc:变动数值
     * @return  name:title type:string require:0 default:0 desc:标题
     * @return  name:create_at type:string require:0 default:0 desc:时间
     */
    public function integralLog(){
        $where = [
            'm_id'=>$this->uid,
            'type'=>1
        ];
        $count = Db::name('store_member_log')->where($where)->count();
        $list = Db::name('store_member_log')
            ->field('id,pm,change,title,create_at')
            ->where($where)
            ->order('id desc')
            ->limit($this->off_set,$this->page_num)
            ->select();
        foreach ($list as &$v){
            if ($v['pm']==1){
                $v['change'] = '+'.$v['change'];
            }else{
                $v['change'] = '-'.$v['change'];
            }
        }
        $this->success('成功',compact('count','list'));
    }


    /**
     * @title 余额记录
     * @desc 余额记录
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/moneyLog
     * @header name:Authorization require:1 desc:Token
     *
     * @param  name:source type:int  : default:0 desc:类型0全部；1消费；2充值；3提现；4出售佣金
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     *
     * @return  name:id type:int require:0 default:0 desc:id
     * @return  name:change type:string require:0 default:0 desc:变动数值
     * @return  name:title type:string require:0 default:0 desc:标题
     * @return  name:create_at type:string require:0 default:0 desc:时间
     */
    public function moneyLog(){
        $where = [
            'm_id'=>$this->uid,
            'type'=>3
        ];
        $type = input('post.type');
        if(!empty($type)) $where['source'] = $type;
        $count = Db::name('store_member_log')->where($where)->count();
        $list = Db::name('store_member_log')
            ->field('id,pm,change,title,create_at')
            ->where($where)
            ->order('id desc')
            ->limit($this->off_set,$this->page_num)
            ->select();
        foreach ($list as &$v){
            if ($v['pm']==1){
                $v['change'] = '+'.$v['change'];
            }else{
                $v['change'] = '-'.$v['change'];
            }
        }
        $this->success('成功',compact('count','list'));
    }



    /**
     * @title 提现
     * @desc 提现
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/withdraw
     * @header name:Authorization require:1 desc:Token
     *
     * @param  name:money type:int  : default: desc:提现金额
     * @param  name:withdraw_type type:int  : default: desc:提现方式
     * @param  name:withdraw_bank type:int  : default: desc:银行卡号
     * @param  name:withdraw_name type:int  : default: desc:姓名
     *
     */
    public function withdraw(){
        $v = getConfigValue('withdraw_switch');
        if (!$v) $this->error('维护中，暂时关闭');
        $redis = new Redis(['select'=>2]);
        $redis_value = $redis->get('withdraw'.$this->uid);
        if ($redis_value){
            $this->error('请求过快,请稍后重试');
        }else{
            $redis->set('withdraw'.$this->uid,1,3);
        }


        $money = input('money');
        $withdraw_type = input('withdraw_type','wx');
        $withdraw_bank = input('withdraw_bank','');
        $withdraw_name = input('withdraw_name','');
        if (!$money || !$withdraw_bank || !$withdraw_name) $this->error('参数错误');
        $user = Db::name('store_member')->where('id',$this->uid)->find();
        if ($user['money']<$money) $this->error('余额不足');
        $withdraw_min_price = getConfigValue('withdraw_min_price');  //最小提现金额
        $withdraw_max_price = getConfigValue('withdraw_max_price');  //最大提现金额
        $poundage_proportion = getConfigValue('poundage_proportion');    //手续费百分比

        if ($money < $withdraw_min_price)
            $this->error('最低提现'.$withdraw_min_price.'元');
        if ($money > $withdraw_max_price)
            $this->error('最大提现'.$withdraw_min_price.'元');

        if ($withdraw_type=='bank'){
            if (!$withdraw_bank || !$withdraw_name) $this->error('请输入提现银行卡信息');
        }

        $data['mid'] = $this->uid;
        $order_no = get_order_sn();
        $data['order_no'] = $order_no;
        $data['price'] = $money;
        $data['poundage_proportion'] = $poundage_proportion;
        $proportion = sprintf("%.2f", $money*($poundage_proportion/100));    //四舍五入保留两位小数点
        $data['proportion'] = $proportion;
        $real_money = $money-$proportion;
        $data['real_money'] = $real_money;
        $data['withdraw_type'] = $withdraw_type;
        $data['withdraw_bank'] = $withdraw_bank;
        $data['withdraw_name'] = $withdraw_name;
        $id =Db::name('store_member_withdraw')->insertGetId($data);
        if ($id){
            Db::startTrans();
            try {
                //减少用户余额
                $res = memberMoneyChange($money,3,$this->uid,'余额提现',0,$id,['source'=>3]);
                //更新用户信息
                setMemberInfoHash($this->uid);
                Db::commit();
                $this->success('提现成功');
            }catch (Exception $e) {
                Db::rollback();
                $this->error('提现失败,请稍后重试1');
            }
        }else{
            $this->error('提现失败,请稍后重试2');
        }

    }

    /**
     * @title 充值余额设置
     * @desc 充值余额设置
     * @author Gavin
     * @method POST
     * @tag
     * @url /api/User_center/rechargeBalanceSet
     * @header name:Authorization require:1 desc:Token
     *
     *
     */
    public function rechargeBalanceSet(){
        $recharge_min_price = getConfigValue('recharge_min_price');  //最小充值金额
        $recharge_service_charge = getConfigValue('recharge_service_charge');    //手续费百分比
        $retrun_data['min_price'] = $recharge_min_price;
        $retrun_data['service_charge'] = $recharge_service_charge;
        $this->success('成功',$retrun_data);
    }

    /**
     * @title 充值余额
     * @desc 充值余额
     * @author Gavin
     * @method POST
     * @tag
     * @url /api/User_center/rechargeBalance
     * @header name:Authorization require:1 desc:Token
     *
     * @param  name:money type:int  : default: desc:充值金额
     * @param  name:pay_type type:string require:1 default:wx desc:wx:微信zfb:支付宝
     * @param  name:from type:string require:1 default:wx desc:wx:微信公众号h5:网页
     *
     */
    public function rechargeBalance(){
        $v = getConfigValue('recharge_switch');
        if (!$v) $this->error('维护中，暂时关闭');
        $redis = new Redis(['select'=>2]);
        $redis_value = $redis->get('recharge'.$this->uid);
        if ($redis_value){
            $this->error('请求过快,请稍后重试');
        }else{
            $redis->set('recharge'.$this->uid,1,3);
        }


        $money = input('money');
        $pay_type = input('pay_type','wx');
        $from = input('from','wx');
        if (!$money) $this->error('参数错误');
        $user = Db::name('store_member')->where('id',$this->uid)->find();

        if ($from == 'wx'){
            if (!$user['openid']) $this->error('微信未授权，无法购买');
        }

        if ($from == 'h5'){
            $this->error('微信h5未开通');
        }

        if ($pay_type == 'zfb'){
            $this->error('支付宝暂未开通');
        }
        $recharge_min_price = getConfigValue('recharge_min_price');  //最小充值金额
        $recharge_service_charge = getConfigValue('recharge_service_charge');    //手续费百分比
        if ($money < $recharge_min_price)
            $this->error('最低充值'.$recharge_min_price.'元');



        $body   = "会员充值余额";
        $order_no = get_order_sn();

        $redis_data = [
            'uid'      => $this->uid,
            'order_no' => $order_no,
            'create_at' => date('Y-m-d H:i:s'),
            'pay_price' => $money,
            'pay_type'  => $pay_type,
            'status'  => 0,
            'remark'    => $body
        ];
        $redis_data['service_charge'] = $recharge_service_charge;
        $fee = sprintf("%.2f", $money*($recharge_service_charge/100));    //四舍五入保留两位小数点
        $redis_data['fee'] = $fee;
        $real_money = $money-$fee;
        $redis_data['real_money'] = $real_money;
        $order_id = Db::name('store_recharge_order')->insertGetId($redis_data);
        $com = true;
        $total_fee = $money;
        switch ($pay_type){
            case 'wx':
                $config = retrunWxConfig();
                $total_fee = $total_fee * 100;
                $config['notify_url'] = $this->request->root(true).'/api/Pay/WxRechargeOrderNotify';
                $app = Factory::payment($config);

                $post_data = [
                    'body' => $body,
                    'out_trade_no' => $order_no,
                    'total_fee' => $total_fee,
                    'attach'=>$this->uid,     //自定义传值
                ];
                //trade_type   SAPI--JSAPI支付（或小程序支付）、NATIVE--Native支付、APP--app支付，MWEB--H5支付
                if ($from=='wx'){
                    $post_data['openid'] = $user['openid'];
                    $post_data['trade_type'] = 'JSAPI';
                }elseif ($from=='h5'){
                    $post_data['trade_type'] = 'MWEB';
                }

                $result = $app->order->unify($post_data);
                debug($result);
                if ($result['return_msg']=='OK'){
                    if ($result['result_code']=='FAIL'){
                        $com = false;
                    }else{
                        $order1 = $app->jssdk->bridgeConfig($result['prepay_id']);//执行二次签名返回参数
                        $retrun_data['order_no'] = $order_no;
                        $retrun_data['pay'] = json_decode($order1,true);
                    }
                }else{
                    $com = false;
                }
                break;
            case 'zfb':
                $zfb = new AliPay();
                $notify_url = $this->request->root(true).'/api/Pay/alipayRechargeOrderNotify?attach='.$this->uid;//回调地址
                $order = $zfb->ali_pay_pc($body, $total_fee, $order_no, $notify_url,'https://'.$_SERVER['SERVER_NAME'].'/web/h5/pages/mine/order-list?num=1');//调用支付宝支付的方法
                $retrun_data['order_no'] = $order_no;
                $retrun_data['pay'] = $order;
                break;
            case 'sd':
                $client = new Shande();
                $notify_url = 'https://'.$_SERVER['SERVER_NAME'].'/api/Pay/shandeRechargeOrderNotify';//回调地址
                $total_fee = $total_fee*100;
                $lenth = strlen($total_fee);
                $total_fee = get0number($lenth).$total_fee;
                $result = $client->orderPay($order_no.'S'.$this->uid,$total_fee,$body,$notify_url,'https://'.$_SERVER['SERVER_NAME'].'/pages/mine/mine');
                $retrun_data['order_no'] = $order_no;
                $retrun_data['pay'] = json_decode($result['data'],true);
                Db::commit();
                break;
        }
        if ($com){
//            $redis = new Redis();
//            $redis->hMSet('rechargeorder_not_pay_'.$this->uid,[$order_no=>json_encode($redis_data)]); //存入redis
            $this->success('成功',$retrun_data);
        }else{
            $this->error('服务器繁忙，请稍后重试');
        }


    }


    /**
     * @title 打开盲盒
     * @desc 打开盲盒
     * @author Gavin
     * @method POST
     * @tag 编辑信息
     * @url /api/User_center/openBoxCollection
     * @header name:Authorization require:1 desc:Token
     *
     * @param  name:id type:int  : default: desc:藏品ID
     *
     */
    public function openBoxCollection(){
        //redis原子锁
        if (redisSetNx('openBox'.$this->uid,3)){
            $id = input('id');
            if (!$id) $this->error('参数错误');
            $info = Db::name('store_order_info')
                ->where('id',$id)
                ->where('mid',$this->uid)
                ->where('is_destruction',1)
                ->find();
            if (!$info) $this->error('盲盒不存在');
            if ($info['resale_status']!=1) $this->error('盲盒挂售中或已出售');
            $com = true;
            Db::startTrans();
            try {
                //销毁
                Db::name('store_order_info')->where('id',$id)->update(['is_destruction'=>0]);

                $prize_arr = Db::name('store_box')
                    ->where('status',1)
                    ->where('coll_id',$info['c_id'])
                    ->where('is_del',1)
                    ->field('id,rate')
                    ->select();
                foreach ($prize_arr as $key => $val) {
                    $arr[$val['id']] = $val['rate'];//概率数组
                }
                $rid = get_rand($arr); //根据概率获取奖项id
                $pr_info = Db::name('store_box')->where('id',$rid)->field('id,title,prize,is_prize')->find();
                $return = [
                    'is_prize'=>$pr_info['is_prize']
                ];
                $coll_info =  getCollectionInfoHash($pr_info['prize']);
                if ($pr_info['is_prize']==1){
                    $json_info = json_encode($coll_info,true);
                    $return['name'] = $pr_info['title'];
                    $return['cover'] = $coll_info['cover'];
                }else{
                    $json_info = '';
                    $return['name'] = '未中奖';
                    $return['cover'] = '';
                }
                $data = [
                    'm_id'=>$this->uid,
                    'b_id'=>$rid,
                    'is_prize'=>$pr_info['is_prize'],
                    'name'=>$return['name'],
                    'cover'=>$return['cover'],
                    'info'=>$json_info,
                    'date'=>date('Y-m-d'),
                    'is_free'=>1
                ];
                Db::name('store_blind_box_log')->insert($data);
                if ($pr_info['is_prize']==1){
                    //获取排名
                    $rank = getRanking($pr_info['prize'])+1;
                    $tag = getTag($pr_info['prize'],$rank,$coll_info['inventory']);
                    saveRanking($pr_info['prize']);
                    $company = '奥艺数字文创购买藏品';
                    $hash = getCompanyHash($pr_info['prize']);
                    $company_hash = $hash['hash'];
                    $company_hash_time = $hash['create_at'];
                    $tokenid = $hash['tokenid'];
                    Db::name('hash')->where('hash',$hash['hash'])->update(['status'=>1]);
                    $collectors_hash = '';
                    $date = [
                        'order_id'=>0,
                        'order_no'=>get_order_sn(),
                        'tag'=>$tag,
                        'mid'=>$this->uid,
                        'c_id'=>$pr_info['prize'],
                        'name'=>$coll_info['name'],
                        'cover'=>$coll_info['cover'],
                        'pro_info'=>$json_info,
                        'company'=>$company,
                        'company_hash'=>$company_hash,
                        'company_hash_time'=>$company_hash_time,
                        'ddcid'=>$tokenid,
                        'collectors_hash'=>$collectors_hash,
                        'collectors_hash_time'=>'',
                        'status'=>1
                    ];
                    Db::name('store_order_info')->insert($date);
                }
                Db::commit();
            }catch (Exception $e) {
                $com = false;
                Db::rollback();
            }
            if ($com){
                setMemberInfoHash($this->uid);
                if ($pr_info['is_prize']==1){
                    //减掉库存
                    loseCollectionInventory($pr_info['prize'],1);
                }
                DelRedisSetNx('openBox'.$this->uid);
                $this->success('成功',$return);
            }else{
                DelRedisSetNx('openBox'.$this->uid);
                $this->error('开启失败，请稍后重试');
            }
        }else{
            $this->error('请求过快');
        }
    }



}