<?php

namespace App\Http\Controllers\Wap\User;

use App\Libs\AliSMS;
use App\Modules\Book\Services\BookConfigService;
use App\Modules\Book\Services\BookUrgeUpdateService;
use App\Modules\Book\Services\SignBookService;
use App\Modules\Statistic\Services\AdVisitStatService;
use App\Modules\Subscribe\Services\OrderService;
use App\Modules\User\Services\ForceGuidePersonAccountService;
use App\Modules\User\Services\ReadRecordService;
use App\Modules\User\Services\UserBindHkWelfareService;
use App\Modules\User\Services\UserBindPhoneService;
use App\Modules\User\Services\UserDivisionCpcPropertyService;
use App\Modules\User\Services\UserWealthyOperateRecordService;
use App\Modules\User\Services\WapReaderPageFissionService;
use Illuminate\Http\Request;
use App\Http\Controllers\Wap\BaseController;
use App\Modules\Subscribe\Services\YearOrderService;
use App\Modules\User\Services\UserService;
use App\Modules\User\Services\UserRandSignService;
use App\Modules\User\Services\UserSignService;
use App\Http\Controllers\Wap\User\Transformers\SignRecordTransformer;
use Log;
use Redis;
use Cookie;
use DB;
use Hashids;

class UserController extends BaseController
{
    /**
     * @apiDefine User 用户
     */


    /**
     * @apiVersion 1.0.0
     * @apiDescription 获取用户信息
     * @api {GET} userinfo 获取用户信息
     * @apiGroup User
     * @apiName index
     * @apiSuccess {Number}  id 用户ID.
     * @apiSuccess {String}  openid 微信openid.
     * @apiSuccess {String}  unionid 微信unionid.
     * @apiSuccess {Number}  distribution_channel_id 分销渠道ID.
     * @apiSuccess {String}  province 省份.
     * @apiSuccess {String}  city 城市.
     * @apiSuccess {String}  country 国家.
     * @apiSuccess {String}  headimgurl 头像地址.
     * @apiSuccess {Number}  send_order_id 派单ID.
     * @apiSuccess {Number=0,1}  sex 性别.
     * @apiSuccess {String}  balance 书币余额.
     * @apiSuccess {Int}     is_vip 是否vip
     * @apiSuccess {String}  vip_days 364天.
     * @apiSuccessExample {json} Success-Response:
     *
     *     {
     *         "code": 0,
     *         "msg": "",
     *         "data": {
     *             "id": 56,
     *             "openid": "sdfs34ssdfdsf",
     *             "unionid": "SDFSD3343S",
     *             "distribution_channel_id": 1212,
     *             "province": "浙江省",
     *             "city": "杭州",
     *             "country": "中国",
     *             "headimgurl": "http://.."
     *             "send_order_id": 323
     *             "balance": 8956
     *             "register_time": "2017-12-12 12:12:12"
     *         }
     *     }
     */
    public function index()
    {
        if (!$this->checkUid()) {
            return response()->error('NOT_LOGIN');
        }

        $data = UserService::getById($this->uid);
        $data['bind'] = 0;
        $data['bind_phone'] = '';
        $data['is_paid'] = $this->is_paid;
        if ($this->is_paid) {
            $bind_info = UserBindPhoneService::bindInfo($this->uid);
            if ($bind_info) {
                $data['bind'] = 1;
                $data['bind_phone'] = $bind_info->phone;
            }
        }

        $data['is_vip'] = 0;
        $data['vip_days'] = 0;
        $year_record = YearOrderService::getRecord($this->uid);
        if ($year_record) {
            $data['is_vip'] = 1;

            $time = strtotime($year_record['end_time']) - time();
            if ($time >= 86400) {
                $data['vip_days'] = floor($time / 86400) . '天';
            } elseif ($time > 3600) {
                $data['vip_days'] = floor($time / 3600) . '小时';
            } elseif ($time > 60) {
                $data['vip_days'] = floor($time / 60) . '分钟';
            } else {
                $data['vip_days'] = $time . '秒';
            }
        }
        $data['is_all_life'] = 0;
        $activity_id = env('FOREVER_ACTIVITY_ID');
        if ($activity_id) {
            if (OrderService::userIsParticipateActivity($this->uid, $activity_id)) {
                $data['is_vip'] = 0;
                $data['vip_days'] = '99年';
                $data['is_all_life'] = 1;
            }
        }
        return response()->success($data);
    }


    /**
     * @apiVersion 1.0.0
     * @apiDescription 用户签到记录
     * @api {GET} user/sign_record 用户签到记录
     * @apiGroup User
     * @apiName signRecord
     * @apiSuccess {int}         code 状态码
     * @apiSuccess {String}      msg  信息
     * @apiSuccess {object}      data 结果集
     * @apiSuccess {reward}     data.reward 奖励金额.
     * @apiSuccess {sign_time}  data.sign_time 签到时间.
     * @apiParam {page}  page
     * @apiSuccessExample {json} Success-Response:
     *
     *    {
     *       code: 0,
     *       msg: "",
     *       data: {
     *           list: [
     *           {
     *               reward: 50,
     *               sign_time: "2018-03-20 13:43:11"
     *           },
     *           {
     *               reward: 50,
     *               sign_time: "2018-01-18 16:22:33"
     *           },
     *       ],
     *       meta: {
     *           total: 12,
     *           per_page: 15,
     *           current_page: 1,
     *           last_page: 1,
     *           next_page_url: "",
     *           prev_page_url: ""
     *       }
     *       }
     *   }
     */
    public function signRecord(Request $request)
    {
        $sign_result = paginationTransform(new SignRecordTransformer(), UserSignService::getUserSignRecord($this->uid));
        $sign_status = UserSignService::isSign($this->uid);
        $sign_today = [];
        if ($sign_status) {
            $sign_today = ReadRecordService::getByField($this->uid, 'sign_info');
            if ($sign_today) $sign_today = json_decode($sign_today, 1);
            isset($sign_today['sign_time']) && $sign_today['sign_time'] = date('Y-m-d H:i:s', $sign_today['sign_time']);
            isset($sign_today['sign_at']) && $sign_today['sign_time'] = $sign_today['sign_at'];
            isset($sign_today['price']) && $sign_today['reward'] = $sign_today['price'];
        }
        $result = [
            'sign_status' => $sign_status,
            'sign_result' => $sign_result,
            'sign_today' => $sign_today
        ];
        return response()->success($result);
    }

    public function getCoupons(Request $request)
    {
        $activity_id = $request->input('activity_id');
        if (!DB::table('discount_coupons')->where('uid', $this->uid)->where('activity_id', $activity_id)->count()) {
            DB::table('discount_coupons')->insert([
                'uid' => $this->uid,
                'activity_id' => $activity_id,
                'created_at' => date('Y-m-d H:i:s'),
                'updated_at' => date('Y-m-d H:i:s')
            ]);
        }

        return response()->success();
    }

    public function sign(Request $request)
    {
        //sign_days
        //$day = date('Y-m-d');
        $sign = UserSignService::isSign($this->uid);
        $sign_count = ReadRecordService::getSignCount($this->uid);
        if ($sign) {
            //如果已经签过到
            if (!$sign_count) {
                ReadRecordService::setSignCount($this->uid, 1);
                ReadRecordService::setSignDay($this->uid);
                $sign_count = 1;
            }
            $fee = 30;
            if ($sign_count >= 3) {
                $fee = 50;
            }
            $data = ['sign_days' => $sign_count, 'sign_reard' => $fee, 'status' => 1];
            return response()->success($data);
        }

        //还没有签到
        $status = UserSignService::signToday($this->uid);
        $sign_count = ReadRecordService::getSignCount($this->uid);
        $data = ['sign_days' => $sign_count, 'sign_reard' => $status, 'status' => 0];
        return response()->success($data);
    }

    /**
     * @return string
     */
    public function signi()
    {
        /*if(in_array($this->distribution_channel_id,explode(',',redisEnv('NEW_SIGN_CHANNELS','')))){
            $version = UserSignService::getUserSignVersion($this->uid);
        }else{
            $version = 'v1';
        }*/
        $version = UserSignService::getUserSignVersion($this->uid);

        if ($version == 'v1') {
            $page = 'wap.sign';
        } else {
            $page = 'wap.signv2';
        }
        $book1 = $book2 = null;
        if ($version == 'v2') {
            $sex = $this->_user_info->sex;
            $sex = $sex ? $sex : 2;
            $book1 = BookConfigService::getRandomOneHighQualityBook($sex);
            $book1->url = sprintf('/reader?bid=%s&cid=%s&source=wechatmsg&fromtype=sign_recommend', Hashids::encode($book1->bid), $book1->first_cid);
            $book2 = SignBookService::getRandomBook($sex);
            \Log::info($book2);
            foreach ($book2 as $item) {
                $item->url = sprintf('/reader?bid=%s&cid=%s&source=wechatmsg&fromtype=sign_recommend', Hashids::encode($item->bid), $item->first_cid);
            }

        }
        $tomorrow_pool = $fee_pool = [0, 30, 50, 120, 50, 50, 50, 150];
        $day = [0, '一', '二', '三', '四', '五', '六', '七'];
        list($sign, $sign_count) = ReadRecordService::getByMultiField($this->uid, 'sign_day', 'sign_counts');
        if ($sign && $sign == date('Y-m-d')) {
            if ($version == 'v1') {
                $fee = $sign_count >= 3 ? 50 : 30;
            } else {
                if ($sign_count % 7 == 1 && $sign_count <= 7) {
                    $fee = 30;
                } elseif ($sign_count % 7 == 3) {
                    $fee = 120;
                } elseif ($sign_count % 7 == 0) {
                    $fee = 150;
                } else {
                    $fee = 50;
                }
            }
            if ($sign_count >= 8) {
                $fee_pool[1] = 50;
            }

            $tomorrow = (($sign_count + 1) % 7 == 0 ? 7 : ($sign_count + 1) % 7);
            if ($sign_count + 1 >= 8) {
                $tomorrow_pool[1] = 50;
            }
            //签过到了
            $data = ['sign_count' => $sign_count, 'fee' => $fee, 'fee_pool' => $fee_pool, 'day' => $day, 'book1' => $book1, 'book2' => $book2, 'tomorrow_fee' => $tomorrow_pool[$tomorrow]];
            return view($page, $data);
        }
        $fee = UserSignService::signToday($this->uid, $version);
        if (!$fee) {
            return response()->error('WAP_SYS_ERROR');
        }
        $sign_count = ReadRecordService::getSignCount($this->uid);
        if ($sign_count >= 8) {
            $fee_pool[1] = 50;
        }
        if ($sign_count + 1 >= 8) {
            $tomorrow_pool[1] = 50;
        }
        $tomorrow = (($sign_count + 1) % 7 == 0 ? 7 : ($sign_count + 1) % 7);
        $data = ['sign_count' => $sign_count, 'fee' => $fee, 'fee_pool' => $fee_pool, 'day' => $day, 'book1' => $book1, 'book2' => $book2, 'tomorrow_fee' => $tomorrow_pool[$tomorrow]];
        return view($page, $data);
    }

    public function signV3()
    {
        //修改签到页面，version=v2
        $fee_pool = [0, 30, 50, 120, 50, 50, 50, 150];
        list($sign, $sign_count) = ReadRecordService::getByMultiField($this->uid, 'sign_day', 'sign_counts');
        $read_record = $this->getSignPageReadRecord($all_bid);
        if (!$all_bid) $all_bid = [];
        $user = $this->_user_info;
        $recommend_book = $this->getSignRecomandBook($user->sex, $all_bid);
        $bind_status = 0;
        $bind_link = '';
        if ($sign && $sign == date('Y-m-d')) {
            if ($sign_count % 7 == 1 && $sign_count <= 7) {
                $fee = 30;
            } elseif ($sign_count % 7 == 3) {
                $fee = 120;
            } elseif ($sign_count % 7 == 0) {
                $fee = 150;
            } else {
                $fee = 50;
            }
            if ($sign_count >= 8) {
                $fee_pool[1] = 50;
            }
            $day = $sign_count % 7;
            if ($day == 0) {
                $day = 7;
            }

            //签过到了
            $name = $user->nickname;
            $head_img = $user->head_img;
            $balance = $user->balance;
            $data = ['sign_count' => $sign_count, 'fee' => $fee, 'fee_pool' => $fee_pool,
                'day' => $day, 'is_alert' => 0, 'read_record' => $read_record, 'name' => $name,
                'head_img' => $head_img,
                'balance' => $balance,
                'recommend_book' => $recommend_book,
                'bind_status'=>$bind_status,
                'bind_link'=>$bind_link
            ];
            return view('wap.signV3', $data);
        }
        $fee = UserSignService::signToday($this->uid, 'v2');
        if (!$fee) {
            return response()->error('WAP_SYS_ERROR');
        }
        $sign_count = ReadRecordService::getSignCount($this->uid);
        //$sign_count++;
        if ($sign_count >= 8) {
            $fee_pool[1] = 50;
        }
        $day = $sign_count % 7;
        if ($day == 0) {
            $day = 7;
        }
        //签过到了
        $name = $user->nickname;
        $head_img = $user->head_img;
        $balance = $user->balance;

        //导粉
        list($inner_sites,$active_qrcode) =  redisEnvMulti(
            'GUIDE_PERSONAL_ACCOUNT_SITES',
            'ACTIVE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE'
        );
        if ($active_qrcode && $inner_sites && in_array($this->distribution_channel_id, explode(',', $inner_sites))){
            $get_info = UserBindHkWelfareService::isHasGet($this->uid);
            if(!$get_info){
                $property = UserDivisionCpcPropertyService::getUserPropertyV2($this->uid);
                $charge = false;
                if (in_array($property, ['medium', 'high'])) {
                    $charge = true;
                } else {
                    if ($property == 'undefined' && OrderService::getChargeNum($this->uid) >= 10) {
                        $charge = true;
                    }
                }
                if($charge){
                    $bind_status = 1;
                    $bind_link = '/guidestrem?uid=' . $this->uid . '&fee=500';
                }
            }
        }
        $data = ['sign_count' => $sign_count, 'fee' => $fee, 'fee_pool' => $fee_pool,
            'day' => $day, 'is_alert' => 1, 'read_record' => $read_record,
            'name' => $name,
            'head_img' => $head_img,
            'balance' => $balance,
            'recommend_book' => $recommend_book,
            'bind_status'=>$bind_status,
            'bind_link'=>$bind_link
        ];

        return view('wap.signV3', $data);
    }

    private function getSignPageReadRecord(&$all_id)
    {
        $res = ReadRecordService::getReadRecord($this->uid);
        if ($res) {
            $id_arr = [];
            foreach ($res as $key => $value) {
                if ($key < 2) {
                    $id_arr[] = $value['bid'];
                }
                $all_id[] = $value['bid'];
            }

            $book = BookConfigService::getBooksByIds($id_arr);
            foreach ($res as $key => &$value) {
                $value['cover'] = '';
                $value['url'] = sprintf('/reader?bid=%s&cid=%s', Hashids::encode($value['bid']), $value['cid']);
                $value['last_chapter'] = 0;
                $value['update_count'] = 0;
                foreach ($book as $val) {
                    if ($value['bid'] == $val->bid) {
                        $value['cover'] = $val->cover;
                        $value['last_chapter'] = $val->last_chapter;
                        if ($val->status == 0) {
                            $value['update_count'] = DB::table('book_updates')
                                ->where('bid', $val->bid)->where('update_type', 'add_chapter')
                                ->where('created_at', '>=', date('Y-m-d H:i:s', $value['time']))
                                ->sum('update_chapter_count');
                        }
                        break;
                    }


                }
            }
        }
        return $res;
    }

    private function getSignRecomandBook(int $sex, array $all_bid):array
    {
        if ($sex == 1) {
            $set_key = 'male_high_reco_bids';
        } else {
            $set_key = 'female_high_reco_bids';
        }
        $bids = Cookie::get('sign_recomand_bids');
        if (!$bids) {
            $bid_array = Redis::Srandmember($set_key, 16);
            //Log::info($bid_array);
            $time = strtotime(date('Y-m-d', time() + 86400)) - time();
            $new_bid_array = [];
            foreach ($bid_array as $item) {
                if (in_array($item, $all_bid)) {
                    array_unshift($new_bid_array, $item);
                } else {
                    array_push($new_bid_array, $item);
                }
            }
            $bids = implode(',', $new_bid_array);
            Cookie::queue('sign_recomand_bids', $bids, $time);
        }
        //Log::info($bids);
        $result = DB::select(sprintf('select book_configs.book_name,intro,bid,books.category_name,book_configs.cover,first_cid,
(select GROUP_CONCAT(tags) from book_tags where bid = book_configs.bid and `status` = 1) as tag from book_configs 
left join books on books.id = book_configs.bid left join book_categories on book_categories.id = books.category_id 
where bid in (%s) and is_on_shelf =2 ORDER  by field(book_configs.bid,%s)', $bids, $bids));
        $data = [];
        foreach ($result as $item) {
            $tag_list = [];
            if ($item->tag) {
                $tag_list = explode(',', $item->tag);
            }
            $data[] = [
                'book_name' => $item->book_name,
                'intro' => $item->intro,
                'bid' => $item->bid,
                'category_name' => $item->category_name,
                'cover' => $item->cover,
                'tag' => $item->tag,
                'tag_list' => $tag_list,
                'url' => sprintf('/reader?bid=%s&cid=%s&source=wechatmsg&fromtype=sign_recommend', Hashids::encode($item->bid), $item->first_cid),
            ];
        }
        return $data;

    }

    public function recordShare(Request $request)
    {
        if (!$this->checkUid()) {
            return response()->error('NOT_LOGIN');
        }
        $uid = $this->uid;
        $distribution_channel_id = $this->distribution_channel_id;
        $type = 'click';
        $bid = $request->get('bid');
        $cid = $request->get('cid', 0);
        if (!$bid) {
            return response()->error('PARAM_ERROR');
        }
        !is_numeric($bid) && $bid = Hashids::decode($bid)[0];
        WapReaderPageFissionService::createV2($uid, $bid, $distribution_channel_id, $type, 0, $cid);
        $user = $this->_user_info;
        $data = [];
        if (in_array($distribution_channel_id, [2, 14, 211]) && $user) {
            $data['username'] = $user->nickname;
            $data['head_img'] = $user->head_img;
            $url = 'https://' . _domain() . '/detail?fromtype=readershare&id=' . Hashids::encode($bid) . '&fromflag=' . $uid;
            //$url = str_replace('http://', $h5_scheme . '://', url()->current() . '?' . http_build_query($params));
            $data['share_url'] = $url;
        }
        return response()->success($data);
    }

    /**
     * @apiVersion 1.0.0
     * @apiDescription 用户点击广告统计
     * @api {post} user/advisitstat 用户点击广告统计
     * @apiGroup User
     * @apiName signRecord
     * @apiParam {Int} bid      bid
     * @apiParam {Int} cid      cid
     * @apiParam {Int} type     type类型(CLICK|UNLOCK)
     * @apiSuccess {int}         code 状态码
     * @apiSuccess {String}      msg  信息
     * @apiSuccess {object}      data 结果集
     * @apiParam {page}  page
     * @apiSuccessExample {json} Success-Response:
     *
     *    {
     *       code: 0,
     *       msg: "",
     *       data: {
     *           {
     *               reward: 50,
     *               sign_time: "2018-03-20 13:43:11"
     *           },
     *           {
     *               reward: 50,
     *               sign_time: "2018-01-18 16:22:33"
     *           },
     *       }
     *   }
     */
    public function adVisitStat(Request $request)
    {
        $bid = $request->get('bid');
        $cid = $request->get('cid', 0);
        $type = $request->get('type');
        if (!$bid || !$type) {
            return response()->error('PARAM_ERROR');
        }
        !is_numeric($bid) && $bid = Hashids::decode($bid)[0];
        AdVisitStatService::create($this->uid, $bid, $cid, $type);
        return response()->success();
    }

    public function urgeUpdate(Request $request)
    {
        $bid = $request->get('bid');
        if (!$bid) {
            return response()->error('PARAM_ERROR');
        }
        $bid = Hashids::decode($bid)[0];

        $result = BookUrgeUpdateService::UrgeRecord($this->uid, $bid);
        if ($result && !$result->id) {
            BookUrgeUpdateService::UrgeUpdate($this->uid, $bid, $result->updated_at);
        }
        return response()->success();
    }

    function logout(Request $request, $channel_id, $domain)
    {
        //echo $channel_id.'----';
        //echo $domain;
        $domains = ['zhuishuyun', '66kshu', 'iycdm', 'leyuee'];

        setcookie(env('COOKIE_AUTH_WEB_WECHAT'), '', -1);
        setcookie('u', '', -1);
        setcookie('force_show_qrcode', '', -1);
        setcookie('sub_random_num', '', -1);
        setcookie('cpc_ad_status', '', -1);
        //return response('logout');
        $param = $request->except('_url');
        $url_format = '%s://site%s.%s.com/logout?%s';
        if (in_array($domain, $domains)) {
            $i = 0;
            foreach ($domains as $k => $v) {
                if ($v == $domain) {
                    $i = $k;
                }
            }
            if (isset($domains[$i + 1])) {
                $link = sprintf($url_format, env('PROTOCOL'), $channel_id, $domains[$i + 1], http_build_query($param));
                return redirect()->to($link);
            }
        }
        return view('help.logout');
    }

    function setOrderDelCookie(Request $request)
    {
        $param = $request->except('_url');
        $type = isset($param['type']) ? $param['type'] : 'set';

        foreach ($param as $k => $v) {
            if ($k == 'type') continue;
            if ($type == 'set') {
                Cookie::queue($k, $v, 1000, null, null, false, false);
            } else {
                setcookie($k, '', -1);
            }
        }
        return response('ok');
    }

    function test_add_user_login_cookie(Request $request)
    {
        $uid = $request->get('uid');
        \Log::info('test_add_user_login_cookie:' . $uid);
        Cookie::queue(env('COOKIE_AUTH_WEB_WECHAT'), $uid, env('U_COOKIE_EXPIRE'), null, null, false, false);
        return response('add_cookie:' . $uid);
    }

    //日常随机签到
    function day_rand_sign(Request $request)
    {
        $uid = $this->uid;
        $day = date('Y-m-d');
        $hasSigned = UserRandSignService::hasSigned(compact('uid', 'day'));
        $fee = 0;
        if (!$hasSigned) {
            $fee = mt_rand(5, 15);
            UserRandSignService::sign(compact('uid', 'day', 'fee'));
        }
        return view('wap.rand_sign', compact('hasSigned', 'fee'));
    }

    public function sendCode(Request $request)
    {
        $phone = $request->post('phone');
        $code = random_int(1000, 9999);
        Redis::setex('code:' . $phone, 120, $code);
        AliSMS::send($phone, 'paid_user_bind_phone', ['code' => $code]);
        return response()->success();
    }

    public function bindPhone(Request $request)
    {
        $code = $request->post('code');
        $phone = $request->post('phone');
        $from = $request->post('from');
        $old = Redis::get('code:' . $phone);
        if ($old && $old == $code) {
            Redis::del('code:' . $phone);
            $user_info = UserService::getById($this->uid);
            if (!$user_info) {
                return response()->error();
            }
            try {
                $result = UserBindPhoneService::bind($this->uid, $user_info->openid, $phone, $from);
                if ($result == 0) {
                    UserService::addBalance($this->uid, 100, 0, 100);
                    UserWealthyOperateRecordService::create($this->uid, 100, $this->distribution_channel_id, 'bind_phone');
                    return response()->success();
                }
                if ($result == -1) {
                    return response()->error('WAP_BIND_PHONE_EXIST');
                }
                if ($result == -2) {
                    return response()->error('WAP_SEND_OPENID_EXIST');
                }
            } catch (\Exception $e) {
            }

        } else {
            return response()->error('WAP_SEND_CODE_ERROR');
        }
        return response()->error();
    }

    public function bindPhoneView(Request $request)
    {
        $from = 'personal';
        $order = '';
        $url = '/personal';
        return view('pay.order.bindPhone', compact('order', 'url', 'from'));
    }

    public function guidePersonalAccount(Request $request)
    {
        $bid = $request->get('bid');
        $cid = $request->get('cid');
        $prev_cid = $request->get('prev_cid');
        $book_name = $request->get('book_name');
        $bid_no = Hashids::decode($bid)[0];
        if (Redis::SISMEMBER('crm:out_channel_sites', $this->distribution_channel_id)) {
            $group = 'OUT_FORCE';
        } else {
            $group = 'FORCE';
        }
        $env_config = redisEnvMulti($group . '_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE', $group . '_GUIDE_PERSONAL_ACCOUNT_MAX_UV',
            $group . '_GUIDE_PERSONAL_ACCOUNT_ID', $group . '_GUIDE_PERSONAL_ACCOUNT_MAX_EVERY_UV');
        if (empty($env_config[0])) return back();
        $img = $env_config[0];
        $max = empty($env_config[1]) ? 100 : $env_config[1];
        $one_loop_max = empty($env_config[3]) ? 10 : $env_config[3];
        $now_id = (int)$env_config[2];
        $uv = Redis::scard(strtolower($group) . '_guide_personal_uv');
        $personal_info = DB::table('personal_account_list')->where('id', $now_id)->select('count')->first();
        $total_max = $personal_info->count + $uv;
        //Log::info('$total_max is: '.);
        if ($uv >= $one_loop_max || $total_max >= $max) {
            if ($total_max >= $max) {
                DB::table('personal_account_list')->where('id', $now_id)->update([
                    'status' => 2,
                    'count' => $total_max,
                    'updated_at' => date('Y-m-d H:i:s')
                ]);
            } else {
                DB::table('personal_account_list')->where('id', $now_id)->increment('count', $uv, [
                    'updated_at' => date('Y-m-d H:i:s')
                ]);
            }

            $account = DB::table('personal_account_list')
                ->where('is_enable', 1)
                ->whereIn('status', [1, 0])
                ->select('id', 'url')
                ->where('count', '<', $max)
                ->where('group', $group)
                ->orderBy('count', 'asc')
                ->orderBy('id')
                ->first();
            Redis::del(strtolower($group) . '_guide_personal_uv');
            if ($account) {
                DB::table('personal_account_list')->where('id', $account->id)->update([
                    'status' => 1,
                    'updated_at' => date('Y-m-d H:i:s')
                ]);
                $img = $account->url;
                $now_id = $account->id;
                Redis::Hmset('env', $group . '_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE', $account->url, $group . '_GUIDE_PERSONAL_ACCOUNT_ID', $account->id);
            } else {
                Redis::Hmset('env', $group . '_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE', '', $group . '_GUIDE_PERSONAL_ACCOUNT_ID', '');
            }
        }
        Redis::sadd(strtolower($group) . '_guide_personal_uv', $this->uid);
        if ($group == 'OUT_FORCE') {
            $data = UserService::getById($this->uid);
            Redis::hset('crm:out_guide_exposure_user', $data->openid, $this->uid);
        }
        $personal_info = DB::table('personal_account_list')->where('id', $now_id)->select('name')->first();
        DB::table('ad_pdd')->insert([
            'uid' => $this->uid,
            'img' => $group . '_GUIDE_PERSONAL_ACCOUNT_' . $now_id,
            'date' => date('Y-m-d'),
            'created_at' => date('Y-m-d H:i:s'),
            'updated_at' => date('Y-m-d H:i:s')
        ]);

        ForceGuidePersonAccountService::create($this->uid, $bid_no, $cid);

        $link['next'] = sprintf('/reader?bid=%s&cid=%s', $bid, $cid);
        $link['prev'] = sprintf('/reader?bid=%s&cid=%s', $bid, $prev_cid);
        $link['catalog'] = sprintf('/catalog?id=%s', $bid);

        return view('jump.forceGuidePersonalAccountV2', ['img' => $img, 'link' => $link, 'title' => $book_name, 'name' => $personal_info->name]);
    }

    /*public function crmPushView(Request $request)
    {
        $out_status = Redis::SISMEMBER('crm:out_channel_sites', $this->distribution_channel_id);
        if ($out_status) {
            $group = 'OUT_ACTIVE';
        } else {
            $group = 'ACTIVE';
        }
        list($qrcode, $max_uv, $account_id, $one_uv) = redisEnvMulti($group . '_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE', $group . '_GUIDE_PERSONAL_ACCOUNT_MAX_UV',
            $group . '_GUIDE_PERSONAL_ACCOUNT_ID', $group . '_GUIDE_PERSONAL_ACCOUNT_MAX_EVERY_UV');
        $uv = Redis::scard(strtolower($group) . '_guide_personal_uv');
        if (!$max_uv) $max_uv = 100;
        if ($uv >= $max_uv) {
            //名额不足
            $data = ['code' => -1, 'read_url' => '/continue'];
            return view('crm.crmPush', $data);
        }
        $sql = 'SELECT friend_link_uid_bind.uid FROM friend_link_uid_bind where openid = (SELECT openid FROM users WHERE id = %s) ORDER by id desc limit 1';
        $friend_link_uid_bind = DB::select(sprintf($sql, $this->uid));
        //$get_info = UserBindHkWelfareService::isHasGet($this->uid);
        if ($friend_link_uid_bind) {
            $info = DB::table('ad_pdd')->where('uid', $friend_link_uid_bind[0]->uid)->orderBy('id', 'desc')->first();
            if ($info) {
                $personal_account_id = preg_replace('/\D+/', '', $info->img);
                if ($info) {
                    $personal_info = DB::table('personal_account_list')
                        ->where('id', $personal_account_id)
                        ->where('is_enable', 1)
                        ->select('name', 'url', 'status', 'is_enable')->first();
                    //$user_info = UserService::getById($friend_link_uid_bind[0]->uid);
                    //$link = sprintf('https://site%s.leyuee.com',encodeDistributionChannelId($user_info->distribution_channel_id));
                    if ($personal_info) {
                        $data = ['code' => -2, 'name' => $personal_info->name, 'read_url' => '/guidestrem?uid=' . $this->uid . '&name=' . $personal_info->name . '&img=' . urlencode($personal_info->url)];
                        return view('crm.crmPush', $data);
                    }
                }
            }
            $data = ['code' => -3, 'read_url' => '/guidestrem?uid=' . $this->uid . '&fee=500', 'name' => ''];
            return view('crm.crmPush', $data);
        } else {
            $data = ['code' => 0, 'read_url' => '/guidestrem?uid=' . $this->uid . '&fee=500', 'name' => ''];
            return view('crm.crmPush', $data);
        }
    }*/


    public function crmPushView(Request $request)
    {
        $crm_config = redisEnvMulti('ACTIVE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE',
            'ACTIVE_GUIDE_PERSONAL_ACCOUNT_MAX_UV', 'ACTIVE_GUIDE_PERSONAL_ACCOUNT_ID',
            'ACTIVE_GUIDE_PERSONAL_ACCOUNT_MAX_EVERY_UV');
        $img = $crm_config[0];
        $max = empty($crm_config[1]) ? 100 : $crm_config[1];
        $max = (int)$max;
        $one_loop_max = empty($crm_config[3]) ? 10 : $crm_config[3];
        $now_id = (int)$crm_config[2];
        $uv_key = 'active_guide_personal_uv';
        $uv = Redis::scard($uv_key);
        $personal_info = DB::table('personal_account_list')->where('id', $now_id)->select('id','count','name')->first();
        $total_max = (int)($personal_info->count + $uv);
        if (empty($img) || empty($now_id) || $total_max >= $max) {
            //没有名额
            $data = ['code' => -1, 'read_url' => '/sign'];
            return view('crm.crmPush', $data);
        }
        $sql = 'SELECT friend_link_uid_bind.uid FROM friend_link_uid_bind where openid = (SELECT openid FROM users WHERE id = %s) ORDER by id desc limit 1';
        $friend_link_uid_bind = DB::select(sprintf($sql, $this->uid));
        //$get_info = UserBindHkWelfareService::isHasGet($this->uid);
        if ($friend_link_uid_bind) {
            $info = DB::table('ad_pdd')->where('uid', $friend_link_uid_bind[0]->uid)->orderBy('id', 'desc')->first();
            if ($info) {
                $personal_account_id = preg_replace('/\D+/', '', $info->img);
                if ($info) {
                    $personal_info = DB::table('personal_account_list')
                        ->where('id', $personal_account_id)
                        ->where('is_enable', 1)
                        ->select('name', 'url', 'status', 'is_enable')->first();
                    if ($personal_info) {
                        $data = ['code' => -2, 'name' => $personal_info->name];
                        return view('crm.crmPush', $data);
                    }
                }
            }
            $user_info = UserService::getById($friend_link_uid_bind[0]->uid);
            $link = 'https://site'.encodeDistributionChannelId($user_info->distribution_channel_id).'.leyuee.com/sign';
            $data = ['code' => -3, 'read_url' => $link];
            return view('crm.crmPush', $data);
        }
        $property = UserDivisionCpcPropertyService::getUserPropertyV2($this->uid);
        $charge = false;
        if (in_array($property, ['medium', 'high'])) {
            $charge = true;
        } else {
            if ($this->property == 'undefined' && OrderService::getChargeNum($this->uid) >= 10) {
                $charge = true;
            }
        }
        if (!$charge) {
            //不符合条件
            $data = ['code' => -1, 'read_url' => '/sign'];
            return view('crm.crmPush', $data);
        }

        Redis::sadd($uv_key, $this->uid);

        DB::table('ad_pdd')->insert([
            'uid' => $this->uid,
            'img' => 'GUIDE_PERSONAL_ACCOUNT_' . $now_id,
            'date' => date('Y-m-d'),
            'created_at' => date('Y-m-d H:i:s'),
            'updated_at' => date('Y-m-d H:i:s')
        ]);
        return view('crm.crmPush2', ['name' => $personal_info->name, 'img' => $img]);
    }

}