NN2023021801/app/api/controller/v1/User.php

<?php

namespace app\api\controller\v1;


use app\api\services\UserServices;
use app\common\model\ActiveLogModel;
use app\common\model\BoxRecordModel;
use app\common\model\CouponnumLogModel;
use app\common\model\MedalLogModel;
use app\common\model\MoneyLogModel;
use app\common\model\PaymentModel;
use app\common\model\RedStorePoolModel;
use app\common\model\ScoreAwayLogModel;
use app\common\model\ScoreLock1LogModel;
use app\common\model\ScorelockLogModel;
use app\common\model\ScoreLog;
use app\common\model\ScoreLogModel;
use app\common\model\SuggestModel;
use app\common\model\TzLogModel;
use app\common\model\UserDataModel;
use app\common\model\UserModel;
use app\common\model\UserMoneyModel;
use app\common\model\UserUnmoneyModel;
use app\common\model\WithDrawLogModel;
use app\common\model\XzLogModel;
use app\common\service\ShopGoodsService;
use app\model\UserWithdrawalModel;
use app\Request;
use app\api\validate\UserValidate;
use jobs\UserJobs;
use think\cache\driver\Redis;
use think\Exception;
use think\exception\ValidateException;
use think\facade\Db;
use utils\Queue;
use function Sodium\library_version_minor;

class User
{
    protected  $service = null;

    public function __construct( UserServices $services)
    {
        $this->service = $services;
    }

    // 用户注册
    public function register(Request $request)
    {

        // 这是测试 上线要干掉
//        echo '网站正在更新';
//        die();

        $params = $request->post();
        try {
            validate(UserValidate::class)->scene('register')->check($params);
            if (!vertifyPass(AESjiemi($params['password']))){
                throw new Exception('密码必须包含字母和数字,长度大于8位');
            }


            if (!vertifyUserName($params['user_name'])){
                throw new Exception('用户名必须包含字母和数字,长度大于6位小于15位');
            }

            $params['password'] = AESjiemi($params['password']);

            return api_succ_return($this->service->userRegister($params));
        }catch (ValidateException $e){
            return api_error_return($e->getMessage());
        }catch (Exception $e){
            return api_error_return($e->getMessage());
        }

    }

    // 注册获取上级信息
    public function registerUpUser(Request $request, UserModel $model){
        Db::startTrans();
        try {
//            $scanCode = AESjiemi($request->post('scan_code'));
            $scanCode = $request->post('scan_code');

            if (empty($scanCode) || !$scanCode){
                return api_error_return('参数错误');
            }

            $params = getUrlParams($scanCode);
            $is_px = false;
            $upuser = $model->where('code', $params['code'])->field('nickname,mobile,px_code,code,avatar')->withAttr('avatar', function($val, $data){
                return __HTTPIMG($val);
            })->find();

            if (!$upuser){
                $upuser = $model->where('px_code', $params['code'])->field('nickname,px_code,code,avatar,mobile')->withAttr('avatar', function($val, $data){
                    return __HTTPIMG($val);
                })->find();
                $is_px = true;
            }


            if (!$upuser){
                return api_error_return('查询失败,暂无用户');
            }
            $upuser['mobile'] = substr($upuser['mobile'], 0, 3).'****'.substr($upuser['mobile'], 7);
            $upuser['share_way'] = $is_px?2:1;

            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return($e->getMessage());
        }

//        if ($upuser){
//            return api_succ_return(['msg'=>'成功', 'data'=>['user'=>$upuser]]);
//        }else{
//            return api_error_return('查询失败,暂无用户');
//        }

        return api_succ_return(['msg'=>'成功', 'data'=>['user'=>$upuser]]);

    }



    // 退出登录
    public function logout(Request $request){
        Db::startTrans();
        try {
//            Db::name('user')->where('id', $request->uid)->save(['jg_regid'=>'']);
            Db::commit();
        }catch (\Exception $e){

            Db::rollback();
        }
        return api_succ_return('成功');
    }


    // 登录
    public function login(Request $request){


        $curandroid = env('app.CUR_ANDROID_VERSION', '');
        $curios = env('app.CUR_IOS_VERSION', '');;

        $curAndroidVersion = str_replace('.', '', $curandroid);
        $curAndroidVersion = dispRepair($curAndroidVersion, 4, '0', '0');
        $curIosVersion = str_replace('.', '', $curios);
        $curIosVersion = dispRepair($curIosVersion, 4, '0', '0');
        $app_sources = $request->param('app_sources');
        $app_version = $request->param('app_version');
        $app_version = str_replace('.', '', $app_version);
        $app_version = dispRepair($app_version, 4, '0', '0');

        $param = $request->param();
        Db::startTrans();
        try {

            validate(UserValidate::class)->scene('login')->check($param);
            $data = $this->service->userLogin($param);
            Db::commit();
            return api_succ_return($data);
        }catch (ValidateException $e){
            Db::rollback();
            return api_error_return($e->getMessage());
        }catch (Exception $e){
            Db::rollback();
            return api_error_return(['msg'=>$e->getMessage(), 'code'=>$e->getCode()]);
        }
    }

    // 编辑用户信息
    public function editUserInfo(Request $request){
        $param = $request->param();
        try {
//            validate(UserValidate::class)->scene('editUserInfo')->check($param);
            //
            return api_succ_return($this->service->setUserInfo($request->uid, $param));
        }catch (Exception $e){
            return api_error_return(['msg'=>$e->getMessage(), 'code'=>$e->getCode()]);
        }
    }

    // 编辑用户信息
    public function setSellerPayWay(Request $request){
        $param = $request->param();
        try {
//            validate(UserValidate::class)->scene('editUserInfo')->check($param);
            return api_succ_return($this->service->setSellerPayWay($request->uid, $param));
        }catch (Exception $e){
            return api_error_return(['msg'=>$e->getMessage(), 'code'=>$e->getCode()]);
        }
    }

    // 用户信息
    public function userInfo(Request $request, UserModel $model)
    {
        Db::startTrans();
        try {
            $post = $request->param();

            $user = $model->getUserDetailByUid($request->uid);

            $time = time();
//            $user['avatar'] .= '?' . $time;
//            $user['avatar'] = __HTTPIMG($user['avatar']);
//            $user['avatar'] = $user['avatar']=='static/img/user/default_avatar.jpg'?__HTTPLOCALIMG($user['avatar']) :__HTTPIMG($user['avatar']);
//            unset($user['id']);

//            卷轴任务不隐藏(新用户隐藏 老用户不隐藏  ，userinfo  后台返回一个字段来控制)


            unset($user['password']);
            unset($user['status']);
            unset($user['login_count']);
            unset($user['login_ip']);
            unset($user['login_time']);

//            unset($user['getinfo_count']);
//            Db::name('user')->where('id', $request->uid)->inc('getinfo_count', 1)->update();
            Db::commit();
            return api_succ_return(['msg'=>'个人信息获取成功', 'data'=>$user]);
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return($e->getMessage());
        }
    }

    // 修改登录密码
    public function editLoginPass(Request $request, UserModel $model)
    {
        try {

            return $model->editLoginPass($request);
        }catch (\Exception $e){
            return api_error_return($e->getMessage());
        }
    }

    // 修改安全密码
    public function editSecurityPass(Request $request, UserModel $model)
    {
        try {

            return $model->editSecurityPass($request);
        }catch (\Exception $e){
            return api_error_return($e->getMessage());
        }
    }

    // 余额记录
    public function moneyLog (Request $request, MoneyLogModel $model)
    {
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        } catch (\Exception $e) {
            return api_error_return('失败');
        }
    }

    // 积分记录
    public function scoreLog (Request $request, ScoreLogModel $model)
    {
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        } catch (\Exception $e) {
            return api_error_return('失败');
        }
    }

    // jh记录
    public function jhLog (Request $request, TzLogModel $model)
    {
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        } catch (\Exception $e) {
            return api_error_return('失败');
        }
    }


    // 福利积分记录
    public function scoreAwayLog (Request $request, ScoreAwayLogModel $model)
    {
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        } catch (\Exception $e) {
            return api_error_return('失败');
        }
    }

    public function scoreLockLog (Request $request, ScoreLock1LogModel $model)
    {
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        } catch (\Exception $e) {
            return api_error_return('失败');
        }
    }





    // 抢购值记录
    public function couponNumLog (Request $request, CouponnumLogModel $model)
    {
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        } catch (\Exception $e) {
            return api_error_return('失败');
        }
    }

    // 星钻记录
    public function xzLog (Request $request, XzLogModel $model)
    {
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        } catch (\Exception $e) {
            return api_error_return('失败');
        }
    }



    // 勋章记录
    public function medalLog (Request $request, MedalLogModel $model)
    {
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        } catch (\Exception $e) {
            return api_error_return('失败');
        }
    }

    // 团队数据
    public function teamData(Request $request, UserModel $model){
        try {
//            return $model->getFansData($request->uid);
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getFansData($request->uid)]);
        } catch (\Exception $e) {
            return api_error_return($e->getMessage());
        }
    }

    // 团队列表
    public function teamList(Request $request, UserModel $model){


        try {

            return api_succ_return(['msg'=>'成功', 'data'=>$model->getFansList($request->uid, $request->post('limit'), $request->post('type'), $request->post('keyword'))]);
        } catch (\Exception $e) {
            return api_error_return($e->getMessage());
        }
    }

    // 团队信息
    public function teamInfo(Request $request){
        $uid = $request->uid;

        $display_ids = env('app.NOT_OPEN_GOODS_ID');


        $has_display = false;
        if (strpos($display_ids, strval($uid)) !== false){
            $has_display = true;
        }

        $data = [
            'zt_valid'=>Db::name('user')->where('pid', $uid)->where('has_fd', 1)->count('id'),
            'zt_total'=>Db::name('user')->where('pid', $uid)->count('id'),
            'zt_teamtotal'=>Db::name('user')->whereFindInSet('path', $uid)->count('id'),
            'zt_teamvalid'=>Db::name('user')->whereFindInSet('path', $uid)->where('has_fd', 1)->count('id'),
            'display_str' => $has_display?('团队总充值：'.$request->user_info['total_team_income'].'，团队总提现：'.$request->user_info['total_team_withdraw']):''
        ];
        return api_succ_return(['msg'=>'成功', 'data'=>$data]);
    }

    // 直推列表
    public function directListData(Request $request, UserModel $model){
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getDirectDataList($request->uid, $request->post('is_auth'), $request->post('limit'), $request->post('keyworld'))]);
        }catch (Exception $e){
            return api_error_return($e->getMessage());
        }
    }





    // 活跃点明细
    public function activeLog(Request $request, ActiveLogModel $model){
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        }catch (Exception $e){
            return api_error_return($e->getMessage());
        }
    }

    // 反馈建议
    public function suggestSubmit(Request $request, SuggestModel $model){
        $post = $request->post();
        Db::startTrans();
        try {
            $model->insert([
                'type'=>2,
                'uid'=>$request->uid,
                'created_time'=>sr_getcurtime(time()),
                'content'=>$post['content']
            ]);
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return('失败'.$e->getMessage());
        }

        return api_succ_return('成功');
    }

    // 用户升星
    public function upgradeLevel (Request $request, UserServices $services)
    {

        try {
            return $services->upgradeStar($request);
        } catch (Exception $e) {
            return api_succ_return(['code'=>$e->getCode(), 'msg'=>$e->getMessage()]);
        }
    }

    // 用户星钻升星
    public function upgradeXzLevel (Request $request, UserServices $services)
    {

        return api_error_return('success');

        if (!getServiceTop()){
            return api_error_return('success');
        }
        try {
            return $services->upgradeXzStar($request);
        } catch (Exception $e) {
            return api_succ_return(['code'=>$e->getCode(), 'msg'=>$e->getMessage()]);
        }
    }

    // 勋章兑换
    public function medalExchange (Request $request, UserModel $model)
    {

        $post = $request->post();
        Db::startTrans();
        try {
            $model->medalExchange($request->uid, $post['number']);
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();

//            if ($e->getCode() == 399){
//                return api_error_return(['msg'=>'请设置安全密码', 'code'=>399]);
//            }
            return api_error_return($e->getMessage());
        }

        return api_succ_return('兑换成功');

    }

    // redPoolList
    public function redStorePoolList(Request $request, RedStorePoolModel $model)
    {
        try {
//            return $model->getUserStoreRedPoolList($request->uid, $request->post('limit'), $request, $request->post('page'));
            return api_succ_return(['msg'=>'获取成功', 'data'=>$model->getUserStoreRedPoolList($request->uid, $request->post('limit'), $request, $request->post('page'))]);
        } catch (\Exception $e) {
            return api_error_return('获取失败'.$e->getMessage());
        }
    }

    // 获取红包
    public function getStoreRed(Request $request, RedStorePoolModel $model)
    {

        if (!$request->data['id']){
            return api_error_return('参数错误');
        }

        Db::startTrans();
        try {

            $model->getStoreRed($request);
            Db::commit();
        }   catch (Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return('领取成功');
    }


    // 提货券列表
    public function getLockScoreLog(Request $request, ScorelockLogModel $model){
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        } catch (\Exception $e) {
            return api_error_return('失败');
        }
    }

    // 积分兑换成余额
    public function scoreExchangeMoney(Request $request, UserModel $model){

        return api_error_return('兑换失败,此功能将在后续关闭');
        // 校验订单是否正确
        if (getSysOrderStatusBackError()){
            return api_error_return('订单校验失败,请联系客服');
        }


        Db::startTrans();
        try {

            $model->scoreExchangeMoney($request->uid, $request->post('score'));
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();

//            if ($e->getCode() == 399){
//                return api_error_return(['msg'=>'请设置安全密码', 'code'=>399]);
//            }

            return api_error_return($e->getMessage());
        }

        return api_succ_return('兑换成功');
    }

    // 余额兑换成积分
    public function moneyExchangeScore(Request $request, UserModel $model){

        Db::startTrans();
        try {

            $model->moneyExchangescore($request->uid, $request->post('money'));
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return($e->getMessage());
        }

        return api_succ_return('兑换成功');
    }

    // 分红任务包分红记录
    public function getRwMoneyLog(Request $request, UserMoneyModel $model){
        $type_conf = config('type.money');
        $list = $model->where('uid', $request->uid)
            ->where('type', 5)
            ->field('money,id,type,create_at,state')
            ->withAttr('type', function ($value, $data) use ($type_conf) {
                return isset($type_conf[$value]) ? $type_conf[$value] : '未知类型';
            })
            ->withAttr('create_at', function ($value, $data){
                return date("Y-m-d",strtotime($value));
            })
            ->order('create_at', 'desc')
            ->paginate($request->data['limit'])
            ->toArray();

        return api_succ_return(['msg'=>'成功', 'data'=>$list['data']]);
    }

    //视频开始播放
    public function openAdBegin(Request $request){

//        if (!getServiceTop()){
//            return api_error_return('优惠券抢购中,请稍后在试');
//        }

//        getUserDeny($request);

        Db::name('user')->where('id', $request->uid)->save(['today_task_down'=>2]);
        if (!Db::name('ad_finishlog')->where('uid', $request->uid)->where('type', 1)->whereDay('create_time', 'today')->find()){
            // 每日完成任务日志
            Db::name('ad_finishlog')->insert([
                'uid'=>$request->uid,
                'create_time'=>sr_getcurtime(time()),
                'type'=>1
            ]);
        }

        return api_succ_return('成功');

        $type = $request->post('type');
        if (!in_array($type, [1])){
            return api_error_return('参数错误');
        }
        $sources = $request->post('app_sources');
        if ($sources == 'ios' || $sources == 'android'){
            // 苹果直接完成任务奖励
//            Db::name('user')->where('id', $request->uid)->save(['today_task_down'=>2]);
            if (!Db::name('ad_finishlog')->where('uid', $request->uid)->where('type', 1)->whereDay('create_time', 'today')->find()){
                // 每日完成任务日志
                Db::name('ad_finishlog')->insert([
                    'uid'=>$request->uid,
                    'create_time'=>sr_getcurtime(time()),
                    'type'=>1
                ]);
            }
            return api_succ_return('苹果手机用户直接领取奖励');
        }
        Db::startTrans();
        try {

            // 查询上一次成功间隔时间
//            $last_id = Db::name('ad_log')->where('uid', $request->uid)->where('status', 2)->whereDay('create_time', 'today')->max('id');
//            if (!empty($last_id)){
//                $info = Db::name('ad_log')->where('id', $last_id)->find();
//                if (time() - strtotime($info['end_time']) < 10){
//                    throw new Exception('具体上次观看视频时间太短,请稍后在试^_^', 304);
//                }
//            }

            $rid = Db::name('ad_log')->insertGetId([
                'uid'=>$request->uid,
                'create_time'=>sr_getcurtime(time()),
                'type'=> 1
            ]);
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            if ($e->getCode() == 304){
                Db::name('adfauiler_log')->insert([
                    'uid'=>$request->uid,
                    'create_time'=>sr_getcurtime(time()),
                    'other'=>$type.'---'.'距离上次观看视频时间太短,请稍后在试^_^'
                ]);
            }
            return api_error_return($e->getMessage());
        }
        return api_succ_return(['msg'=>'成功', 'data'=>['order_id'=>$rid]]);
    }

    //视频结束播放
    public function openAdEnd(Request $request){
//        if (!getServiceTop()){
//            return api_error_return('优惠券抢购中,请稍后在试');
//        }

        return api_succ_return('成功');
        $order_id = $request->post('order_id');
        $info = Db::name('ad_log')->where('id', $order_id)->find();
        if (!$info){
            return api_error_return('参数错误');
        }

        if (time() - strtotime($info['create_time']) < 15){
            Db::name('adfauiler_log')->insert([
               'uid'=>$request->uid,
                'create_time'=>sr_getcurtime(time()),
                'other'=>$request->ip()
            ]);
            return api_error_return('观看广告时间过短，请稍后在试');
        }

        Db::startTrans();
        try {
            Db::name('ad_log')->where('id', $order_id)->save(['status'=>2,'end_time'=>sr_getcurtime(time())]);
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return($e->getMessage());
        }

        $count = Db::name('ad_log')->whereDay('create_time', 'today')->where('type', 1)->where('status', 2)->where('uid', $request->uid)->count();
        if ($count >= env('AD.ONE_DAY_TASK_NUM')){
//            Db::name('user')->where('id', $request->uid)->save(['today_task_down'=>2]);
            if (!Db::name('ad_finishlog')->where('uid', $request->uid)->where('type', 1)->whereDay('create_time', 'today')->find()){
                // 每日完成任务日志
                Db::name('ad_finishlog')->insert([
                    'uid'=>$request->uid,
                    'create_time'=>sr_getcurtime(time()),
                    'type'=>1
                ]);
            }


        }
        return api_succ_return(['msg'=>'成功']);
    }

    // 今日播放视频数据
    public function openAdTodayData(Request $request){
        $type = $request->post('type');
        $sources = $request->post('app_sources');
        if (!in_array($type, [1,2])){
            return api_error_return('参数错误');
        }

        return api_succ_return(['msg'=>'成功', 'data'=>['total'=>env('AD.ONE_DAY_TASK_NUM'),'today_count'=>env('AD.ONE_DAY_TASK_NUM')]]);
        Db::startTrans();
        try {
            $count = Db::name('ad_log')->whereDay('create_time', 'today')->where('type', $type)->where('status', 2)->where('uid', $request->uid)->count();
            if ($count>env('AD.ONE_DAY_TASK_NUM')){
                $count = env('AD.ONE_DAY_TASK_NUM');
            }
            if ($sources == 'ios'){
                $count = env('AD.ONE_DAY_TASK_NUM');
            }
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return($e->getMessage());
        }
        return api_succ_return(['msg'=>'成功', 'data'=>['total'=>env('AD.ONE_DAY_TASK_NUM'),'today_count'=>$count]]);
    }


    //提现记录
    public function withdrawLog (Request $request, WithDrawLogModel $model)
    {
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request)]);
        } catch (\Exception $e) {
            return api_error_return($e->getMessage());
        }
    }

    // 绑定提现账号
    public function bangWithdrawInfo(Request $request, UserServices $service)
    {


        Db::startTrans();
        try {

            $service->bangWithdrawInfo($request->uid, $request->post('type'), $request->post('number'), $request->post('name'));
            Db::commit();
        }catch (Exception $e){
            Db::rollback();
            return api_error_return($e->getMessage());
        }

        return api_succ_return('绑定成功');
    }

    // 解绑提现账号
    public function unBangWithdrawInfo(Request $request, UserServices $service)
    {

        Db::startTrans();
        try {

            $service->unbangWithdrawInfo($request->uid, $request->post('type'));
            Db::commit();
        }catch (Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return('解绑成功');
    }

    // 用户转赠提交
    public function exchargeSubmit(Request $request, UserServices $service){


        return api_error_return("星钻转赠以下线");
        $post = $request->post();
        if ($request->user['mobile'] == $post['mobile']){
            return api_error_return('不能给自己转赠');
        }
        Db::startTrans();
        try {

            $info = $service->exchargeSubmit($request->uid, $post['xz_num'], $post['mobile']);
            Db::commit();
        }catch (Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return(['msg'=>'请求成功', 'data'=>$info]);
    }

    // 用户转赠确认
    public function exchargeDone(Request $request, UserServices $service){


        $post = $request->post();
        Db::startTrans();
        try {
            getActionSecury($request->uid, $request->post('security_pass', ''));

            $info = $service->exchargeDone($request->uid, $post['xz_num'], $post['mobile']);
            Db::commit();
        }catch (Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return(['msg'=>'请求成功', 'data'=>$info]);
    }

    // 用户转赠提交
    public function exchargeMedalSubmit(Request $request, UserServices $service){


        $post = $request->post();
        if ($request->user['mobile'] == $post['mobile']){
            return api_error_return('不能给自己转赠');
        }
        Db::startTrans();
        try {

            $info = $service->exchargeMedalSubmit($request->uid, $post['medal_num'], $post['mobile']);
            Db::commit();
        }catch (Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return(['msg'=>'请求成功', 'data'=>$info]);
    }

    // 用户转赠确认
    public function exchargeMedalDone(Request $request, UserServices $service){


        $post = $request->post();
        Db::startTrans();
        try {
            getActionSecury($request->uid, $request->post('security_pass', ''));

            $info = $service->exchargeMedalDone($request->uid, $post['medal_num'], $post['mobile']);
            Db::commit();
        }catch (Exception $e){
            Db::rollback();

//            if ($e->getCode() == 399){
//                return api_error_return(['msg'=>'请设置安全密码', 'code'=>399]);
//            }
            return api_error_return($e->getMessage());
        }

        return api_succ_return(['msg'=>'请求成功', 'data'=>$info]);
    }



    // 用户播放视频报错
    public function watchAdError(Request $request, UserServices $service){
        $code = $request->post('error', '');
        $message = $request->post('error1', '');

        Db::startTrans();
        try {
            $error_codes = explode(',', env('APP.AD_ERROR_CODE'));
            $error_msgs = explode(',', env('APP.AD_ERROR_MESSAGE'));
            if (!(in_array($code, $error_codes) && in_array($message, $error_msgs))){
                if (!Db::name('ad_error_records')->where('uid', $request->uid)->where('error_code', $code)->where('status', 1)->find()){
                    Db::name('ad_error_records')->insert([
                        'uid'=>$request->uid,
                        'error_code'=>$code,
                        'error_msg'=>$message,
                        'create_time'=>sr_getcurtime(time())
                    ]);

                }

            }else{
                throw new Exception('请求失败');
            }

            Db::commit();
        }catch (\Exception $e){

            Db::rollback();
            return api_error_return($e->getMessage());
        }
        return api_succ_return(['msg'=>'加载广告失败，请直接领取任务包奖励', 'code'=>200]);
    }


    // 首页必读公告获取
    public function getHomeMsg(Request $request){
        $list = Db::name('system_article')->where('type', 9)->order('create_time desc')->select();
        $user = Db::name('user')->where('id', $request->uid)->find();
        foreach ($list as $key=>$val){
            if (!Db::name('article_get')->where('uid', $request->uid)->where('article_id', $val['id'])->find()){
                if ($user['reg_time'] < $val['create_time']){
                    return api_succ_return(['msg'=>'成功','data'=> [$val]]);
                }

            }
        }
        return api_succ_return('成功');
    }

    // 用户消息已读
    public function getMsgDown(Request $request){
        $article_id = $request->post('article_id');

        if (Db::name('system_article')->where('id', $article_id)->where('type', 9)->find()){
            Db::name('article_get')->insert([
               'uid'=>$request->uid,
                'article_id'=>$article_id,
                'create_time'=>sr_getcurtime(time())
            ]);
        }
        return api_succ_return('成功');
    }

    // 用户通知信息列表
    public function messageList(Request  $request){
        $page = $request->post('page', 1);
        $limit = $request->post('limit', 10);
        return api_succ_return(['msg'=>'成功', 'data'=>Db::name('user_message')->where('uid', $request->uid)->page($page, $limit)->field('title,type,banner_desc,create_time,uid')->select()->toArray()]);
    }


    // 用户余额转赠提交
    public function moneyExchargeSubmit(Request $request, UserServices $service){

        $post = $request->post();
        if ($request->user['mobile'] == $post['mobile']){
            return api_error_return('不能给自己转赠');
        }
        Db::startTrans();
        try {

            $info = $service->exchargeMoneySubmit($request->uid, $post['money'], $post['mobile']);
            Db::commit();
        }catch (Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return(['msg'=>'请求成功', 'data'=>$info]);
    }

    // 余额赠送
    public function  moneyExcharge(Request  $request, UserServices $service){
        $post = $request->post();
        Db::startTrans();
        try {
            getActionSecury($request->uid, $request->post('security_pass', ''));
            $info = $service->exchargeMoneyDone($request->uid, $post['money'], $post['mobile'], $request->user['mobile']);
            Db::commit();
        }catch (Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return(['msg'=>'请求成功', 'data'=>$info]);
    }

    // 用户余额转赠提交
    public function jhExchargeSubmit(Request $request, UserServices $service){

        $post = $request->post();
        if ($request->user['mobile'] == $post['mobile']){
            return api_error_return('不能给自己转赠');
        }
        Db::startTrans();
        try {

            $info = $service->exchargeJhSubmit($request->uid, $post['money'], $post['mobile']);
            Db::commit();
        }catch (Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return(['msg'=>'请求成功', 'data'=>$info]);
    }

    // JH转赠
    public function  jhExcharge(Request  $request, UserServices $service){
        $post = $request->post();
        Db::startTrans();
        try {
            getActionSecury($request->uid, $request->post('security_pass', ''));
            $info = $service->exchargeJHDone($request->uid, $post['money'], $post['mobile']);
            Db::commit();
        }catch (Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return('赠送成功');
    }

    // jh购买
    public function jhBuy(Request $request, UserServices $service){
        $post = $request->post();
//        return api_error_return('暂未开放');
//        return api_error_return("由于系统更新 暂不支持兑换 开放时间另行通知");
        Db::startTrans();
        try {
            getActionSecury($request->uid, $request->post('security_pass', ''));
            $info = $service->JHBuy($request->uid, $post['count']);
            Db::commit();
        }catch (Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return(['msg'=>'购买成功,本期剩余'.$info]);
    }

    /**
     * 取消收藏商品
     * @param Request $request
     * @return \think\Response
     */
    public function cancelAttension(Request $request){
        $goodsId = $request->post('goods_id');
        if(ShopGoodsService::make()->cancelAttension($request->uid, $goodsId)){
            return api_succ_return('成功');
        }else{
            return api_error_return('失败');
        }
    }

    // 商品收藏列表
    public function goodsAttList(Request $request){
        $post = $request->post();
        $list = Db::name('goods_attension')
            ->alias('a')
            ->where('a.uid', '=', $request->uid)
            ->leftJoin('shop_goods g', 'g.goods_id = a.goods_id')
            ->field('a.id,a.goods_id, g.goods_img, g.goods_name,g.goods_sn, g.attension_count,g.price, g.rebate_score')
            ->page($post['page'], $post['limit'])
            ->select()->toArray();

        return api_succ_return(['msg'=>'成功', 'data'=>$list]);
    }

    // 用户注销
    public function denyOff(Request $request){

//        Db::startTrans();
//        try {
//
//            if ($request->user['status'] != 1){
//                sr_throw('用户状态错误');
//            }
//
//            Db::name('user')->where('id', $request->uid)->save(['status'=>3, 'mobile'=>'12345678', 'desc'=>'之前手机号：'.$request->user['mobile'], 'user_name'=>'已注销'.$request->user['user_name']]);
//
//            Db::commit();
//        }catch (\Exception $e){
//            Db::rollback();
//            return api_error_return($e->getMessage());
//        }
        return api_succ_return('注销成功');
    }


    public function rechargeOrderList(Request $request){
        $post = $request->post();
        $list = Db::name('recharge_order')->where('user_id', $request->uid)->page($post['page'], $post['limit'])->order('order_id desc')->select()->toArray();
        return api_succ_return(['msg'=>'成功', 'data'=>$list]);
    }



    public function rechargeUsdtVerify(Request $request){
        $post = $request->post();

        Db::startTrans();
        try {
            $orderinfo = Db::name('recharge_order')->where('recharge_sn', $post['recharge_id'])->find();
            if (!$orderinfo){
                sr_throw('参数错误');
            }


            if ($orderinfo['user_id'] != $request->uid){
                sr_throw('不是你的订单');
            }
            if ($orderinfo['pay_type'] != 19){
                sr_throw("充值类型错误");
            }

            if ($orderinfo['status'] != 1){
                sr_throw('状态错误');
            }

            Db::name('recharge_order')->where('order_id', $orderinfo['order_id'])->save([
                'charge_img'=>env('app.API_WEB_URL').'/'.$post['img'],
                'status'=>3
            ]);

            Db::commit();
        }catch (\Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }

        return api_succ_return('提交成功');
    }

    public function getSellerPayWay(Request $request){
        return api_succ_return(['msg'=>'成功', 'data'=>getUserPayWay($request->uid)]);
    }



    // 用户签到
    public function daySign(Request $request){
        Db::startTrans();

        try {
//            Db::name('user')->where('id', $request->uid)->save(['today_task_down'=>2]);

            if (!Db::name('ad_finishlog')->where('uid', $request->uid)->where('type', 1)->whereDay('create_time', 'today')->find()){
                // 每日完成任务日志
                Db::name('ad_finishlog')->insert([
                    'uid'=>$request->uid,
                    'create_time'=>sr_getcurtime(time()),
                    'type'=>1
                ]);
            }
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }
        return api_succ_return('签到成功');
    }

    // 省代理购买
    public function provinceAgentBuy(Request $request){
        return ;
        Db::startTrans();
        try {
            getActionSecury($request->uid, $request->post('security_pass', ''));
            $price = 175000;
            $user = Db::name('user')->where('id', $request->uid)->find();
            if ($user['money'] < $price){
                sr_throw('余额不足');
            }
            if ($user['agent_type'] != 0){
                sr_throw('购买失败,已是代理');
            }
            edit_user_money(15, $request->uid, $price);
//            edit_user_tz(13, $request->uid, 20000);
            Db::name('user')->where('id', $request->uid)->save(['agent_type'=>1]);

            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return($e->getMessage());
        }
        return api_succ_return('购买成功');
    }

    // 市代理购买
    public function cityAgentBuy(Request $request){
        return ;
        Db::startTrans();
        try {
            getActionSecury($request->uid, $request->post('security_pass', ''));
            $price = 56000;
            $user = Db::name('user')->where('id', $request->uid)->find();
            if ($user['money'] < $price){
                sr_throw('余额不足');
            }
            if ($user['agent_type'] != 0){
                sr_throw('购买失败,已是代理');
            }
            edit_user_money(16, $request->uid, $price);
//            edit_user_tz(14, $request->uid, 8000);
            Db::name('user')->where('id', $request->uid)->save(['agent_type'=>2]);

            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return($e->getMessage());
        }
        return api_succ_return('购买成功');
    }


    // 回收卡信息
    public function recycleCardInfo(Request $request){
        $data = [];
        $user_info = Db::name('user')->where('id', $request->uid)->field('today_money,todayaward_money,store_type')->find();

        $data['every_day_recycle_count'] = $user_info['store_type'] == 1?120:20;
        $zt_numcount = Db::name('user')->where('pid', $request->uid)->where('has_fd', 1)->count();

        $data['zt_count'] = $zt_numcount * env('boxsetting.ONE_DIRECT_RECYCLE_COUNT');
        $has_get = Db::name('recyclecard_log')->where('type', 1)->where('uid', $request->uid)->whereDay('create_at', 'today')->find();
        $has_ztget = Db::name('recyclecard_log')->where('type', 2)->where('uid', $request->uid)->whereDay('create_at', 'today')->find();

        $data['has_today_get'] = $has_get?1:0;
        $data['has_today_ztget'] = $has_ztget?1:0;

//        $data['has_today_get'] = 0;
//        $data['has_today_ztget'] = 0;

        $data['todayaward_money'] = $user_info['todayaward_money'];
        $data['today_money']=$user_info['today_money'];
        $data['services_store_price']=env('boxsetting.SERVICES_STORE_OPEN_PRICE');

        return api_succ_return(['msg'=>'成功', 'data'=>$data]);
    }

    // 领取回收卡
    public function getRecycleCard(Request $request){
        $type = $request->post('type');
        $model = new UserModel();

        Db::startTrans();
        try {
            $model->getRecycleCard($request->uid, $type, $request->user);
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return($e->getMessage());

        }

        return api_succ_return('领取成功');
    }


    // 领取每日奖金
    public function getUserTeamMoney(Request $request){
        $model = new UserModel();

        return api_error_return('奖金已在每天21后自动领取');
        Db::startTrans();
        try {

//            getActionBefore(6);
            $model->getUserTeamMoney($request->uid);
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return($e->getMessage());

        }

        return api_succ_return('领取成功');
    }

    // 今日奖金记录
    public function todayTeamMoneyLog(Request $request){
        $model = new MoneyLogModel();
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getTeamMoneyLog($request)]);
        } catch (\Exception $e) {
            return api_error_return('失败');
        }
    }

    // 利润结算记录
    public function incomeMoneyLog(Request $request){
        $model = new MoneyLogModel();
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request, 8)]);
        } catch (\Exception $e) {
            return api_error_return('失败'.$e->getMessage());
        }
    }

    // 利润结算
    public function getUserIncomeTeam(Request $request){
        $model = new UserModel();
        Db::startTrans();
        try {

            $model->getUserIncomeTeam($request->uid);
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
            return api_error_return('结算失败'.$e->getMessage());
//            return api_error_return($e->getMessage());
        }

        return api_succ_return('结算成功');
    }

    // 消费记录
    public function consumeLog(Request $request){
        $model = new PaymentModel();
        try {
            return api_succ_return(['msg'=>'成功', 'data'=>$model->getLog($request, 8)]);
        } catch (\Exception $e) {
            return api_error_return('失败'.$e->getMessage());
        }
    }

    // 商务合作申请
    public function bussinessApply(Request $request){
        $model = new UserModel();
        Db::startTrans();
        try {
            $model->bussinessApply($request->uid, $request->post());
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }
        return api_succ_return('申请成功');
    }

    // 用户利润信息
    public function userProfitInfo(Request $request){
        $user_info = Db::name('user')->where('id', $request->uid)->find();
        return api_succ_return(['msg'=>'成功', 'data'=>[
            'total'=>$user_info['total_profit_money'],
            'cur_profit'=>$user_info['profit_money'],
            'desc'=>'按照100的倍数结算到余额'
        ]]);
    }

    // 邀请好友 绑定上级好友
    public function bangUpFriend(Request $request){
        $model = new UserModel();
        Db::startTrans();
        try {
            $model->bangUpFriend($request->uid, $request->post());
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();

            return api_error_return($e->getMessage());
        }
        return api_succ_return('绑定成功');
    }

    // 获得直推上级信息
     public function getUpUserInfo(Request $request){
        $user_info = $request->user_info;
            if ($user_info['pid'] > 0){
                $pid_info = Db::name('user')->where('id', $user_info['pid'])->field('nickname,mobile,id')->find();
                $pid_info['mobile'] = substr($pid_info['mobile'], 0, 3).'****'.substr($pid_info['mobile'], 7);
                return api_succ_return(['msg'=>'成功', 'data'=>$pid_info]);
            }else{
                return api_succ_return(['msg'=>'成功', 'data'=>[]]);
            }

     }

     // 获取用户订单状态 处理
    public function orderUnreadInfo(Request $request){
        $data = [];
        Db::startTrans();
        try {

            $count1 = Db::name('shop_order')->where('user_id', $request->uid)->where('status', 0)->count();
            $count2 = Db::name('shop_order')->where('user_id', $request->uid)->where('status', 1)->count();
            $count3 = Db::name('shop_order')->where('user_id', $request->uid)->where('status', 2)->count();

            $data = [$count1, $count2, $count3, 0];

            Db::commit();
        }catch (\Exception $e){
            Db::rollback();

            return api_error_return('接口请求失败');
        }

        return api_succ_return(['msg'=>'成功', 'data'=>$data]);
    }


}