| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046 | <?phpnamespace App\Http\Controllers\QuickApp\Book;use App\Consts\BaseConst;use App\Libs\Utils;use App\Modules\Book\Services\BookAuditService;use App\Modules\Channel\Models\ChannelAdvert;use App\Modules\Channel\Services\ChannelAdvertService;use App\Modules\Channel\Services\ChannelRecommendBookConfigService;use App\Modules\Channel\Services\ChannelRecommendBooksService;use App\Modules\RecommendBook\Services\QappRecommendService;use App\Modules\RecommendBook\Services\RecommendService;use App\Modules\Book\Services\RecoBannerService;use App\Modules\Trade\Services\OrderService;use App\Modules\User\Models\ChannelAdUser;use App\Modules\User\Models\QappPackage;use App\Modules\User\Services\QappUserService;use Illuminate\Http\Request;use App\Http\Controllers\QuickApp\BaseController;use App\Http\Controllers\QuickApp\Book\Transformers\BookTransformer;use App\Http\Controllers\QuickApp\Book\Transformers\KeywordTransformer;use App\Modules\Book\Models\BookConfig;use App\Modules\Book\Services\BookConfigService;use App\Modules\Book\Services\BookService;use App\Modules\Book\Services\BookUrgeUpdateService;use App\Modules\Book\Services\UserShelfBooksService;use App\Modules\Book\Services\ChapterService;use App\Modules\Subscribe\Services\BookOrderService;use App\Modules\Subscribe\Services\ChapterOrderService;use App\Modules\Subscribe\Services\YearOrderService;use App\Modules\User\Services\ReadRecordService;use Hashids;use Log;use Illuminate\Support\Facades\Redis;class BookController extends BaseController{    public function index(Request $request, $bid)    {        $bid       = BookService::decodeBidStatic($bid);        $book_info = BookConfigService::getBookById($bid);        if (!$book_info) {            return response()->error('QAPP_SYS_ERROR');        }        //yuyuedu、xinghe  快应用这两个cp的书屏蔽下        if(in_array($book_info->cp_source,getHiddenCp())){            return response()->error('QAPP_SYS_ERROR');        }        if($this->distribution_channel_id == 7477 && $bid == 13765){            $book_info->is_on_shelf = 2;        }        if($bid == 58886){            $book_info->is_on_shelf = 0;        }        if (!in_array($book_info->is_on_shelf, [1,2])) {            return response()->error('QAPP_OFF_SHELF');        }        $is_on_shelf                   = UserShelfBooksService::getUserShelfBooksListByUidAndBid($this->uid, $bid);        $book_info['is_on_user_shelf'] = 0;        if ($is_on_shelf) {            $book_info['is_on_user_shelf'] = 1;        }        $last_chapter                     = ChapterService::getChapterNameById($book_info['last_cid'], $bid);        $book_info->last_chapter = $last_chapter['name'];        list($is_split,$is_change_chapter_name) = BookService::splitContent($bid);        if($is_split && ($book_info->channel_name == '男频' || $is_change_chapter_name) ){            $book_info->last_chapter = '第'.$book_info->chapter_count.'章';        }        $book_info['last_chapter_is_vip'] = $last_chapter['is_vip'];        $book_info['is_need_charge']      = $this->isNeedCharge($bid, $last_chapter, $book_info);        $record                           = ReadRecordService::getBookReadRecordStatic($this->uid, $bid);        if ($record) {            $book_info['record_chapter_id']   = $record['record_chapter_id'];            $book_info['record_chapter_name'] = $record['record_chapter_name'];        }        return response()->item(new BookTransformer(), $book_info);    }    /**     * 获取订购记录     * @param $book_info     * @param $chapter_id     * @return bool     */    protected function getOrderRecord($bid, $chapter_id)    {        //包年记录        $uid = $this->uid;        $res = YearOrderService::getRecord($uid);        if ($res) return true;        $res = null;        //单本订购记录        $res = BookOrderService::getRecordByuidBid($uid, $bid);        if ($res) return true;        $res = null;        //章节订购记录        $chapterOrder = new ChapterOrderService();        if ($chapterOrder->checkIsOrdered($uid, $bid, $chapter_id)) return true;        return false;    }    /**     * 判断是否需要充值     */    private function isBookNeedCharge(int $bid, float $price)    {        $book_order = $this->getOrderRecord($bid, 0);        if ($book_order) {            return false;        } else {            $user_info = $this->user_info;            return $user_info['balance'] < $price;        }    }    /**     * 判断章节是否需要充值     */    private function isChapterNeedCharge(int $bid, int $cid, float $price)    {        $book_order = $this->getOrderRecord($bid, $cid);        if ($book_order) {            return false;        } else {            $user_info = $this->user_info;            return $user_info['balance'] < $price;        }    }    /**     * 判断是否需要充值     */    private function isNeedCharge(int $bid, $last_chapter, $book_info)    {        $is_free = BookConfigService::judgeBookIsFree($bid);        if ($is_free) {            return false;        }        switch ($book_info->charge_type) {            case 'BOOK':                $price = $this->getPrice($book_info);                return $this->isBookNeedCharge($bid, $price);            default:                $price = isset($last_chapter->is_vip) ? $this->getPrice($book_info, $last_chapter->size) : 0;                return isset($last_chapter->is_vip) ? $this->isChapterNeedCharge($bid, $last_chapter->id, $price) : false;        }    }    /**     * 计算价格     * @param $book_info     * @param $chapter_size     * @return float     */    protected function getPrice($book_info, $chapter_size = 0)    {        if ($book_info->charge_type == 'BOOK')            return $book_info->price * 100;        return ceil($chapter_size / 100);    }    /**     * 首页     */    public function getBookLists(Request $request, $sex)    {        // 获取基本数据        $package     = $request->header('x-package', '');        $brand       = $request->header('x-nbrand', '');        $codeVersion = $request->header('x-codeversion', '');        $isAuth = check_qapp_auth($package ,0);        // 根据包名、平台、版本号判断是否审核        if (Utils::checkIsAudit($package, $brand, $codeVersion) || $isAuth == false) {            $result = BookAuditService::getHomeBooksData($sex, $package,$isAuth);            return response()->success($result);        }        $user =  (new QappUserService)->getGolableUser();        if($package == "com.beidao.kuaiying.yueai" && $sex == "male" && isset($user->uid) && !empty($user->uid) &&  $user->send_order_id  >  0){            $orderRecord = ChapterOrderService::hasUserRecord($user->uid);            if($orderRecord){                $result  = BookAuditService::getYueaiHomeBooksData($sex, $package,$isAuth,1);                return  response()->success($result);            }        }        if ($sex == 'male') {            $channel          = 1;            $reco_banner_type = ['MALE', 'PUBLIC'];        } else {            $reco_banner_type = ['FEMALE', 'PUBLIC'];            $channel          = 2;        }        if($isAuth){            $books = $this->getDefaultBanner();        }else{            $home = config('home.ycsd');            $banner      = $home['reco_banner'];            $books = $banner[$sex];        }        //新判断: 根据包名来获取对应所需的bid        $qapp_package = QappPackage::getPackageByPackage($package);        if($qapp_package){            $package_id = $qapp_package->id;        }else{            $package_id = 0;        }        \Log::info('un_send_order_book:package_id1:'.$package_id.' $package:'.$package);        if(isset($user->uid) && !empty($user->uid)){            if(!$this->send_order_id || $this->send_order_id == 0 ){                \Log::info('un_send_order_book:uid:'.$this->uid.' $package:'.$package);                $result = $this->getCheckBids($channel,$books,$package_id,$package);                if(isset($result[1]['books']) && count((array)$result[1]['books']) > 1){                    return response()->success($result);                }                $result = $this->getCheckBids($channel,$books,0,$package);                return response()->success($result);            }else{                $package_id = 0;            }            \Log::info('un_send_order_book:package_id2:'.$package_id.' $package:'.$package);        }else{            $package_id = 0;        }        \Log::info('un_send_order_book:package_id3:'.$package_id.' $package:'.$package);        $result = $this->getCheckBids($channel,$books,$package_id,$package);        return response()->success($result);    }    /**     * 根据包名     * @param $channel     * @param $books     * @param $package_id     * @return array     */    private function getCheckBids($channel,$books,$package_id,$package)    {        $isAuthor = check_qapp_auth($package_id,1);        $hotBids   = $this->getCheckBooks(QappRecommendService::getRecommendByPacketId($channel, 'hot',$package_id),$channel,$package,$isAuthor);        $liveBids  = $this->getCheckBooks(QappRecommendService::getRecommendByPacketId($channel, 'live',$package_id),$channel,$package,$isAuthor);        $recomBids = $this->getCheckBooks(QappRecommendService::getRecommendByPacketId($channel, 'recom',$package_id),$channel,$package,$isAuthor);        $newBids   = $this->getCheckBooks(QappRecommendService::getRecommendByPacketId($channel, 'new_recom',$package_id),$channel,$package,$isAuthor);        return array_filter([            ['type' => 'reco_banner', 'lable' => '首页banner', 'books' => $books],            ['type' => 'hot', 'lable' => '热门书单', 'books' => collectionTransform(new BookTransformer, BookConfigService::getBooksByIds($hotBids))],            ['type' => 'zhibo', 'lable' => '神书直播', 'books' => collectionTransform(new BookTransformer, BookConfigService::getBooksByIds($liveBids))],            ['type' => 'recom', 'lable' => '小编精选', 'books' => collectionTransform(new BookTransformer, BookConfigService::getBooksByIds($recomBids))],            ['type' => 'new_recom', 'lable' => '人气新书', 'books' => collectionTransform(new BookTransformer, BookConfigService::getBooksByIds($newBids))]        ]);    }    /**     * 检测并补充不满足条件的书籍id     * @param $bid_list     * @param $channel : 频道     * @param $package : 频道     * @return array     */    private function getCheckBooks($bid_list,$channel,$package,$is_author)    {        $hidden_cp = getHiddenCp();        if($package !== 'com.beidao.kuaiying.zsy'){            $hidden_cp = array_merge($hidden_cp,['lianshang']);        }        //获取书本数量        $count = count($bid_list);        if (!$is_author){            $where = [                ['book_configs.charge_type','!=','BOOK'],                ['book_configs.cp_source','=','ycsd'],            ];        }else{            $where = [                ['book_configs.charge_type','!=','BOOK'],            ];        }        //获取当前有效书本数量        $book_count = BookConfig::join('books', 'book_configs.bid', '=', 'books.id')            ->leftjoin('book_categories', 'books.category_id', 'book_categories.id')            ->whereIn('book_configs.bid',$bid_list)            ->where('book_configs.is_on_shelf',2)            ->where('book_configs.charge_type','!=','BOOK')            ->whereNotIn('book_configs.cp_source',$hidden_cp)            ->where($where)            ->where('book_categories.pid',$channel)            ->count();        if($count == $book_count){            return $bid_list;        }        //获取需要补充的书籍数量        $supplement_count = (($count - $book_count) > 0) ? $count - $book_count : 0;        if($supplement_count <= 0){            return $bid_list;        }        //获取书籍交集bid,过滤掉不符合要求的书        $bids = BookConfig::join('books', 'book_configs.bid', '=', 'books.id')            ->leftjoin('book_categories', 'books.category_id', 'book_categories.id')            ->whereIn('book_configs.bid',$bid_list)            ->where('book_configs.is_on_shelf',2)            ->where($where)            ->whereNotIn('book_configs.cp_source',$hidden_cp)            ->where('book_categories.pid',$channel)            ->pluck('book_configs.bid')->all();        $bid_list = array_intersect($bid_list,$bids);        //获取随机的有效的书籍bid        $rand_bid = BookConfig::join('books', 'book_configs.bid', '=', 'books.id')            ->leftjoin('book_categories', 'books.category_id', 'book_categories.id')            ->where('book_configs.is_on_shelf',2)            // ->where('book_configs.charge_type','!=','BOOK')            ->where($where)            ->whereNotIn('book_configs.cp_source',$hidden_cp)            ->where('book_categories.pid',$channel)            ->inRandomOrder()            ->limit($supplement_count)            ->get()->pluck('bid')->toArray();        return array_filter(array_merge($bid_list,$rand_bid));    }    private function getBidCidFromUrl(string $url)    {        if (preg_match('/\?bid=(\w+)\S+cid=(\w+)/', $url, $matches) || preg_match('/\?id=(\w+)/', $url, $matches)) {            return [                'bid' => $matches[1],                'cid' => isset($matches[2]) ? $matches[2] : 0,            ];        } else {            return [                'bid' => '',                'cid' => 0,            ];        }    }    public function library(Request $request)    {        $where                = [];        $order                = [];        $where['is_on_shelf'] = [2];        $category_id          = $request->input('category_id');        if ($category_id) {            if ($category_id == 1) {                $where['channel_name'] = '男频';            } elseif ($category_id == 2) {                $where['channel_name'] = '女频';            } else {                $where['category_id'] = $category_id;            }        }        $key = $request->input('key');        $uid = $request->input('uid', 0);        if ($key && $uid && is_numeric($uid)) {            BookConfigService::saveUserSearchLog($key, $uid);        }        $where['key'] = $key;        $order_field  = $request->input('order_field');        $order_seq    = $request->input('order_seq');        if ($order_field != '' && in_array($order_field, ['recommend_index', 'click_count', 'update', 'size', 'create'])) {            if ($order_field == 'update') {                $order = ['book_configs.updated_at', 'desc'];            } elseif ($order_field == 'create') {                $order = ['book_configs.created_at', 'desc'];            } else {                $order = [$order_field, 'desc'];            }            if ($order_seq == 'asc') {                $order = [$order_field, 'asc'];            }            if ($order_seq == 'desc') {                $order = [$order_field, 'desc'];            }        }        // 审核状态默认值        $package     = $request->header('x-package', '');        $brand       = $request->header('x-nbrand', '');        $codeVersion = $request->header('x-codeversion', '');        if ($order_field === 'recommend_index' && Utils::checkIsAudit($package, $brand, $codeVersion)) {            $order = ['book_configs.bid', 'desc'];        }        // 是否只使用原创书殿的书        $isAuth = check_qapp_auth($package ,0);        if (!$isAuth){            $where['cp_source'] = "ycsd";        }        $status = $request->input('status');        if ($status != '') {            $where['status'] = $status;        }        // 搜索关键词的情况下,屏蔽书籍完本状态        if ($key && isset($where['status'])) {            unset($where['status']);        }        $page_size = $request->input('page_size', 15);        $where['channel_id'] = ($package === 'com.beidao.kuaiying.zsy') ? 7477 : 0;        $books     = BookConfigService::getBooks($where, $order, $page_size);        return response()->pagination(new BookTransformer, $books);    }    public function hotWords(Request $request)    {        $result = BookConfigService::findBookKeywords();        return response()->pagination(new KeywordTransformer, $result);    }    public function similarRecom(Request $request)    {        $package     = $request->header('x-package', '');        $category_id = $request->input('category_id');        $bid         = $request->input('bid');        $package     = $request->header('x-package', '');        if (empty($bid) || (empty($category_id) && $category_id != 0)) {            return response()->error('PARAM_ERROR');        }        $isAuth = check_qapp_auth($package ,0);        $bid   = BookService::decodeBidStatic($bid);        $where = ['category_id' => $category_id, 'is_on_shelf' => [2]];        if (!$isAuth){            $where['cp_source'] = "ycsd";        }        $where['channel_id'] = ($package === 'com.beidao.kuaiying.zsy') ? 7477 : 0;        $books = BookConfigService::getBooks($where, [], 4);        $data  = [];        foreach ($books as $v) {            if ($v->bid != $bid && count($data) < 3) {                $data[] = $v;            }        }        return response()->collection(new BookTransformer(), $data);    }    public function readOverRecommend(Request $request)    {        $bid = $request->input('bid');        if (empty($bid)) {            return response()->error('PARAM_ERROR');        }        $bid         = BookService::decodeBidStatic($bid);        $book_info   = BookConfigService::getBookById($bid);        $res         = BookConfigService::getRecommendBooks($bid, $book_info->channel_name);        $urge_status = 0;        if ($book_info->status == 0 && !BookUrgeUpdateService::isHadUrged($this->uid, $bid)) {            $urge_status = 1;        }        $recommend_result = collectionTransform(new BookTransformer(), $res);        $book_status      = [            'status'      => $book_info->status,            'urge_status' => $urge_status        ];        $data             = [            'recommend_result' => $recommend_result,            'book_status'      => $book_status        ];        return response()->success($data);    }    public function rank(Request $request)    {        // 1:男频,2:女频        $sex = (int)$request->input('sex');        if (!in_array($sex, [1, 2], true)) {            return response()->error('PARAM_ERROR');        }        // 默认        $bids = [11529, 11941, 12720, 11990, 11988, 11976, 11977, 4183, 12717, 11833,            7287,14297,12716,14312,14000,13577,16712,13002,12717,15103,13928,14793,            12708,13286];        if ($sex === 2) {            $bids = [8469, 11660, 9117, 7891, 12281, 12470, 8167, 11661, 11670, 8476, 8557, 11662,                11680, 11926, 12462, 7836, 11681, 11664, 11928, 8631];        }        /**         * pid:1为男频 2为女频        SELECT        CONCAT( books.id, ',' )        FROM        books        LEFT JOIN book_configs ON books.id = book_configs.bid        WHERE        book_configs.is_on_shelf = 2        AND books.category_id IN ( SELECT id FROM book_categories WHERE pid = 2 )        ORDER BY        book_configs.recommend_index DESC        LIMIT 10;         */        // 根据包名、平台、版本号判断是否审核        $package     = $request->header('x-package', '');        $brand       = $request->header('x-nbrand', '');        $codeVersion = $request->header('x-codeversion', '');        if (Utils::checkIsAudit($package, $brand, $codeVersion)) {            $bids = [2266, 3838, 9700, 10175, 10301, 3422, 1166, 4546, 9163, 2509,                7287,14297,12716,14312,14000,13577,16712,13002,12717,15103,13928,                14793,12708,13286,13336,13275,13073,15121,13929,12693,13254,3526,                10313,3483,13278,14004,4098,10378,14072,21376,21139,21757,19449];            if ($sex === 2) {                $bids = [159, 2439, 6276, 10074, 5409, 9379, 10323, 9078, 3603, 487];            }        }                $isAuth = check_qapp_auth($package,0);        if (!$isAuth){            $rank = config('home.rank');            $bids = $rank['male'];            if ($sex === 2) {                $bids =  $rank['female'];;            }        }        $channel_id = ($package === 'com.beidao.kuaiying.zsy') ? 7477 : 0;        $books = collectionTransform(new BookTransformer, BookConfigService::getBookLists(compact('bids','channel_id')));        return response()->success($books);    }    /**     * 推荐书     */    public function recommen()    {        $books = $this->getDefaultBanner();        return response()->success($books);    }    /**     * 阅爱小说任务轮播图     */    public function recommenYueAi()    {        $user =  (new QappUserService)->getGolableUser();        if(isset($user->uid) && !empty($user->uid) && $user->send_order_id >  0){            $orderRecord = ChapterOrderService::hasUserRecord($user->uid);            if($orderRecord){                $data = config('home.yueai');                $books = $data['task_banner'];                foreach ($books as  &$value){                    $value['bid'] =Hashids::encode($value['bid']);                    $value['redirect_url '] = empty($value['cid']) ? "views/Detail" :  "views/Reader";                }                unset($value);                return response()->success($books);            }        }        $books = $this->getDefaultBanner();        return response()->success($books);    }    /**     * 新获取各种广告列表     * @param Request $request     * @return mixed     */    public function getRecommendBanners(Request $request)    {        $release_type = $request->get('release_type','');        $distribution_id = $this->distribution_channel_id;        if(empty($release_type)){            //默认原banner            $banner = $this->getDefaultBanner();            return response()->success($banner);        }        if($release_type == '4' || $release_type == '5'){            //弹窗和充值页返回需要先判断频率跟权限            $advert = ChannelAdvert::select('id','photo as banner_url','type','content','person','frequency')                ->where('distribution_id',$distribution_id)                ->where('release_type',$release_type)                ->where('status',1)                ->first();            if(!$advert){                return response()->success([]);            }            $advert = $advert->toArray();            $advert['ids'] = Hashids::encode($advert['id']);            if($advert['type'] == 1){                $advert['redirect_url'] = 'views/Reader';                $content = explode(';',$advert['content']);                $advert['bid'] = isset($content[2]) ? $content[2] : '';                $advert['cid'] = isset($content[3]) ? $content[3] : '';            }else{                $advert['redirect_url'] = 'views/Detail';            }            if($release_type == '4'){                //弹窗需要判断频率                if($advert['frequency'] == 'always'){                    $advert = self::getBackFormat($advert);                    return response()->success($advert);                }                $day = strtotime(date('Y-m-d H:i:s'));                $nextDay = strtotime( date('Y-m-d'). ' +1 day');                $nextWeek = strtotime(date('Y-m-d',strtotime('+1 week last monday')));                if($advert['frequency'] == 'day'){                    if(!Redis::exists('banner:'.$distribution_id.':'.$this->uid)){                        Redis::setex('banner:'.$distribution_id.':'.$this->uid,($nextDay-$day),1);                        $advert = self::getBackFormat($advert);                        return response()->success($advert);                    }                }                if($advert['frequency'] == 'week'){                    if(!Redis::exists('banner:'.$distribution_id.':'.$this->uid)){                        Redis::setex('banner:'.$distribution_id.':'.$this->uid,($nextWeek-$day),1);                        $advert = self::getBackFormat($advert);                        return response()->success($advert);                    }                }                return response()->success([]);            }            if($release_type == '5'){                //充值页返回需要判断用户权限                $check_user = $this->checkUsers($advert['person']);                if(!$check_user){                    return response()->success([]);                }                $advert = self::getBackFormat($advert);                return response()->success($advert);            }        }        //男女频,书架列表        $banner = ChannelAdvertService::getAdvertList($distribution_id,$release_type);        if($banner->isEmpty()){            $banner = $this->getDefaultBanner();            return response()->success($banner);        }        $banner->transform(function ($item) {            $item->ids = Hashids::encode($item->id);            if($item->type == 1){                $item->redirect_url = 'views/Reader';                $content = explode(';',$item->content);                $item->bid = isset($content[2]) ? $content[2] : '';                $item->cid = isset($content[3]) ? $content[3] : '';            }else{                $item->redirect_url = 'views/Detail';            }            self::getBackFormat($item);            return $item;        });        return response()->success($banner);    }    static function getBackFormat($data)    {        if(isset($data['id']) || $data->id) unset($data['id'],$data->id);        if(isset($data['type']) || $data->type) unset($data['type'],$data->type);        if(isset($data['person']) || $data->person) unset($data['person'],$data->person);        if(isset($data['frequency']) || $data->frequency) unset($data['frequency'],$data->frequency);        return $data;    }    /**     * 默认获取banner     * @return mixed     */    protected function getDefaultBanner()    {        $reco_banner_type = ['FEMALE', 'PUBLIC'];        $banner            = (new RecoBannerService)->getByType($reco_banner_type, 2);        $banner->transform(function ($item) {            $result    = $this->getBidCidFromUrl($item->redirect_url);            $item->bid = $result['bid'];            $item->cid = $result['cid'];            $item->ids  = Hashids::encode($item->id);            $item->type  = 'default';            if ($result['cid']) {                $item->redirect_url = "views/Reader";            } else {                $item->redirect_url = "views/Detail";            }            unset($item->id);            return $item;        });        return $banner;    }    /**     * 限免     */    public function free(int $sex)    {        $result = BookConfigService::findFreeBooks($sex);        return response()->success($result);    }    public function yueaiBackRecom(Request $request)    {        $package     = $request->header('x-package', '');        if (empty($package) || $package != 'com.beidao.kuaiying.yueai') {            return response()->success([]);        }        $user =  (new QappUserService)->getGolableUser();        if(isset($user->uid) && !empty($user->uid) && $user->send_order_id >  0){            $orderRecord = ChapterOrderService::hasUserRecord($user->uid);            if($orderRecord){                $bid =  [58238,60534,63220,14500,13254,63221,63548,14022,59334,58888,63417,61701];                $bid = array_random($bid,4);                $books = BookConfigService::getBooksByIds($bid,[],false);                return response()->collection(new BookTransformer(), $books);            }        }        return response()->success([]);        $where = ['is_on_shelf' => [2]];        $where['channel_id'] = ($package === 'com.beidao.kuaiying.zsy') ? 7477 : 0;        $books = BookConfigService::getBooks($where, [], 4);        return response()->collection(new BookTransformer(), $books);    }    public function shelfRecom(Request $request)    {        $category_id = $request->input('category_id');        $bid         = $request->input('bid');        $package     = $request->header('x-package', '');        if (empty($package) || $package != 'com.beidao.kuaiying.yueai') {            return response()->success([]);        }        $user =  (new QappUserService)->getGolableUser();        if(isset($user->uid) && !empty($user->uid) && $user->send_order_id  >  0){            $orderRecord = ChapterOrderService::hasUserRecord($user->uid);            if($orderRecord){                $bid =  [58238,60534,63220,14500,13254,63221,63548,14022,59334,58888,63417,61701];                $bid = array_random($bid,4);                $books = BookConfigService::getBooksByIds($bid,[],false);                return response()->collection(new BookTransformer(), $books);            }        }        return response()->success([]);        $where = ['is_on_shelf' => [2]];        $where['channel_id'] = ($package === 'com.beidao.kuaiying.zsy') ? 7477 : 0;        $books = BookConfigService::getBooks($where, [], 4);        return response()->collection(new BookTransformer(), $books);    }    /**     * 新推荐书单     * @param Request $request     * @return mixed     */    public function recommendBooks(Request $request)    {        $distribution_id = $this->distribution_channel_id;        $bid = $request->get('bid',0);        if(empty($distribution_id)){            \Log::info('recommendBooks:1');            return response()->success([]);        }        if(!empty($bid)){            \Log::info('recommendBooks:2');            $bid = Hashids::decode($bid)[0];        }        //判断包是否存在        $package_info = QappPackage::getPackage($distribution_id);        if(empty($package_info) || !isset($package_info->channel_id)){            \Log::info('recommendBooks:3');            return response()->success([]);        }        //包对应有没有配置开启推荐书单        $config = ChannelRecommendBookConfigService::getRecommendConfigs($distribution_id);        if(empty($config) || !isset($config->status) || $config->status == 0){            \Log::info('recommendBooks:4');            return response()->success([]);        }        //根据频率和用户属性决定是否需要返回        $res = $this->checkUsersAuth($config);        if(!$res){            \Log::info('recommendBooks:5');            return response()->success([]);        }        $list = ChannelRecommendBooksService::getRecommendBooks($distribution_id,$bid);        if(!$list->isEmpty()){            foreach($list as $key => $item){                $this->incrRecommendNum($distribution_id,$item->bid);            }            \Log::info('recommendBooks:6');            return response()->collection(new BookTransformer(), $list);        }        \Log::info('recommendBooks:7');        return response()->success([]);    }    /**     * 点击推荐书籍记录点击次数     * @param Request $request     * @return mixed     */    public function clickRecommendBooks(Request $request)    {        $distribution_id = $this->distribution_channel_id;        $bid = $request->get('bid','');        if(empty($bid)){            return response()->success();        }        //判断包是否存在        $package_info = QappPackage::getPackage($distribution_id);        if(empty($package_info) || !isset($package_info->channel_id)){            return response()->success([]);        }        $date = date('Ymd');        $bid = Hashids::decode($bid)[0];        $cacheKey = 'recommend:click:'.$date.':'.$distribution_id.$bid;        $this->incrRedisKey($cacheKey);        return response()->success();    }    /**     * 判断用户是否需要推荐     * @param $config     * @return bool     */    protected function checkUsersAuth($config)    {        \Log::info($config);        \Log::info('$config->person:'.$config->person);        \Log::info($this->uid);        $res = $this->checkUsers($config->person);        if($res === false){            return false;        }        //频率判断        if($config->frequency == 'back'){            //返回即推送            return true;        }        $day = strtotime(date('Y-m-d H:i:s'));        $nextDay = strtotime( date('Y-m-d'). ' +1 day');        $nextWeek = strtotime(date('Y-m-d',strtotime('+1 week last monday')));        if($config->frequency == 'day'){            //每日推送            if(!Redis::exists('recommend:'.$config->channel_id.':'.$this->uid)){                Redis::setex('recommend:'.$config->channel_id.':'.$this->uid,($nextDay-$day),1);                return true;            }            \Log::info('当天已经推送过了');            return false;        }        if($config->frequency == 'week'){            //每周推送            if(!Redis::exists('recommend:'.$config->channel_id.':'.$this->uid)){                Redis::setex('recommend:'.$config->channel_id.':'.$this->uid,($nextWeek-$day),1);                return true;            }            \Log::info('该周已经推送过了');            return false;        }    }    /**     * 判断用户是否有权限     * @param $type     * @return bool     */    protected function checkUsers($type)    {        $res = false;        switch($type)        {            case 'pay':                //付费用户                $orders = OrderService::getUserLastestOrder($this->uid);                if($orders){                    $res = true;                }                \Log::info('用户是否付费:');                \Log::info($orders);                break;            case 'send_order':                //派单用户                if($this->send_order_id != 0){                    $res = true;                }                \Log::info('用户是否是派单用户:$this->send_order_id:'.$this->send_order_id);                break;            case 'pay_send_order':                //付费派单用户                $orders = OrderService::getUserLastestOrder($this->uid);                if($orders && $this->send_order_id != 0){                    $res = true;                }                \Log::info('用户是否是付费派单用户:$this->send_order_id:'.$this->send_order_id);                \Log::info($orders);                break;            case 'unpaid':                $orders = OrderService::getUserLastestOrder($this->uid);                if(!$orders){                    $res = true;                }                break;            case 'all':                $res = true;                \Log::info('所有用户返回');                break;        }        return $res;    }    /**     * 推广书籍推荐次数     * @param $channel_id     * @param $bid     */    protected function incrRecommendNum($channel_id,$bid)    {        $date = date('Ymd');        $cacheKey = 'recommend:sum:'.$date.':'.$channel_id.$bid;        $this->incrRedisKey($cacheKey);    }    /**     * 点击广告统计     * @param Request $request     * @return mixed     */    public function getCheckAdvertisement(Request $request)    {        $type = $request->get('type','');        $id = $request->get('ids','');        $distribution_id = $this->distribution_channel_id;        if(empty($type) || empty($id) || empty($distribution_id)){            return response()->success();        }        $id = Hashids::decode($id)[0];        if(!$id){            return response()->success();        }        if($type == 'default'){            //默认原表reco_banners广告,区分跟新表channel_advert的id            $id = -$id;        }else{            $advert = ChannelAdvert::find($id);            if(!$advert){                \Log::info('getCheckAdvertisement:error:不存在该广告');                \Log::info(json_encode($request->all()));                return response()->success();            }        }        $where = ['channel_ad_id' => $id, 'uid' => $this->uid, 'distribution_id' => $distribution_id];        ChannelAdUser::firstOrCreate($where);        $date = date('Ymd');        $cacheKey = 'advertisement:pv:'.$date.':'.$distribution_id.$id;        $this->incrRedisKey($cacheKey);        //设置当前用户的所属广告有效期一周        $key = 'advertisement:uid:'.$this->uid.':id';        Redis::set($key,$id);        Redis::expire($key,BaseConst::ONE_WEEK_SECONDS);        return response()->success();    }    /**     * redis新增     * @param $cacheKey     */    protected function incrRedisKey($cacheKey)    {        if(!Redis::exists($cacheKey)){            Redis::set($cacheKey,1);        }else{            Redis::incrBy($cacheKey, 1);        }    }    /**     * 绑定广告和订单     * @param Request $request     * @return mixed     */    public function getAdvertOrders(Request $request)    {        $order_id = $request->get('order_id','');        $uid = $this->uid;        $distribution_id = $this->distribution_channel_id;        $cacheKey = 'advertisement:uid:'.$uid.':id';        if(Redis::exists($cacheKey)){            $channel_ad_id = Redis::get($cacheKey);            $type = ($channel_ad_id > 0) ? 1 : 0;            $created_at = $updated_at = date('Y-m-d H:i:s');            DB::table('channel_advert_orders')->insert(compact('order_id','uid','distribution_id','channel_ad_id','type','created_at','updated_at'));            return response()->success();        }else{            return response()->success();        }    }}
 |