zhuishuyun_quickapp/app/Http/Controllers/QuickApp/User/ReadRecordController.php

<?php

namespace App\Http\Controllers\QuickApp\User;

use App\Consts\SysConsts;
use App\Modules\Subscribe\Services\BookOrderService;
use App\Modules\Subscribe\Services\ChapterOrderService;
use App\Modules\Subscribe\Services\YearOrderService;
use Illuminate\Http\Request;
use App\Http\Controllers\QuickApp\BaseController;
use App\Modules\Book\Services\BookConfigService;
use App\Modules\Book\Services\UserShelfBooksService;
use App\Http\Controllers\QuickApp\User\Transformers\ReadRecordTransformer;
use App\Modules\Book\Services\BookService;
use App\Modules\ShareFree\Services\ShareUsersService;
use App\Modules\User\Services\ReadRecordService;
use Redis;

class ReadRecordController extends BaseController
{

    /**
     * @apiDefine ReadRecord 阅读记录
     */


    /**
     * @apiVersion 1.0.0
     * @apiDescription 获取阅读记录
     * @api {get} readrecord 获取阅读记录
     * @apiHeader {String} [Authorization]  token
     * @apiGroup ReadRecord
     * @apiName index
     * @apiSuccess {int}         code 状态码
     * @apiSuccess {String}      msg  信息
     * @apiSuccess {object}      data 结果集
     * @apiSuccess {Int}         data.book_name    书名
     * @apiSuccess {String}      data.chapter_name  章节名
     * @apiSuccess {Int}         data.bid   bid
     * @apiSuccess {Int}         data.time   时间
     * @apiSuccess {Int}         data.cid    章节id
     * @apiSuccess {Int}         data.chapter_name    章节名
     * @apiSuccess {Int}         data.cover    封面
     * @apiSuccess {Int}         data.last_chapter    最后一张
     * @apiSuccessExample {json} Success-Response:
     *     HTTP/1.1 200 OK
     *     {
     *       code: 0,
     *       msg: "",
     *       data:[
     *           {
     *               book_name: "我来好好爱你",
     *               bid: 2,
     *               cid: 10402,
     *               time: 1511783120,
     *               chapter_name: "你言重了"
     *           },
     *           {
     *               book_name: "京华烟云",
     *               bid: 1,
     *               cid: 4,
     *               time: 1511783068,
     *               chapter_name: "背水一战"
     *           }
     *           ]
     */
    public function index(Request $request)
    {
        $user = $this->user_info;
        $res  = ReadRecordService::getReadRecord($this->uid);
        //补充操作：如果该用户未订阅该下架的书籍则删除其阅读记录(书架不予显示)
        //判断是否属于包年用户
        $year_account = YearOrderService::getRecord($this->uid);

        if ($res) {
            $id_arr = [];
            foreach ($res as $key => $value) {
                $id_arr[] = $value['bid'];
            }

            $book = BookConfigService::getBooksByIds($id_arr, [], false);//下架图书最近阅读可看到
            foreach ($res as $key => &$value) {
                $value['cover']        = '';
                $value['last_chapter'] = 0;
                $value['intro'] = '';
                $value['status'] = '';
                $value['size'] = 0;
                $value['author'] = '';
                foreach ($book as $val) {
                    if ($value['bid'] == $val->bid) {
                        $value['book_name']    = $val->book_name;
                        $value['cover']        = $val->cover;
                        $value['last_chapter'] = $val->last_chapter;
                        $value['intro'] = $val->intro;
                        $value['status'] = $val->status;
                        $value['size'] = $val->size;
                        $value['author'] = $val->author;
                        if(!$year_account &&  !in_array($val->is_on_shelf,[1,2]) ){
                            //获取书籍充值类型
                            $charge_type = $val->charge_type;
                            if($charge_type == 'BOOK'){
                                //是否购买过该书，购买过则不删除
                                $result = BookOrderService::getRecordByuidBid($this->uid,$val->bid);
                            }elseif($charge_type == 'CHAPTER'){
                                //是否购买过该书章节，购买过则不删除
                                $result = ChapterOrderService::checkBookIsOrdered($this->uid,$val->bid);
                            }else{
                                $result = false;
                            }
                            if ($result) {
                                unset($value);
                                ReadRecordService::delReadRecordStatic($this->uid,[$val->bid]);
                            }
                        }
                        break;
                    }
                }
            }
        }
        if(count($res) > 0){
            \Log::info($res);
            usort($res, function ($a, $b) {
                if ($a['time'] >= $b['time']) return -1;
                return 1;
            });
            return response()->collection(new ReadRecordTransformer(), array_to_object($res));
        }
        \Log::info("$res");
        \Log::info($res);
        return response();
    }


    /**
     * @apiVersion 1.0.0
     * @apiDescription 添加阅读记录
     * @api {post} readrecord 添加阅读记录
     * @apiGroup ReadRecord
     * @apiName addReadRecord
     * @apiHeader {String} [Authorization]  token
     * @apiParam   {Int}         book_name    书名
     * @apiParam   {String}      chapter_name  章节名
     * @apiParam   {Int}         bid     bid
     * @apiParam   {Int}         cid    章节id
     * @apiSuccess {int}         code 状态码
     * @apiSuccess {String}      msg  信息
     * @apiSuccess {object}      data 结果集
     * @apiSuccessExample {json} Success-Response:
     *     HTTP/1.1 200 OK
     *     {
     *       code: 0,
     *       msg: "",
     *       data:{}
     *
     */
    public function addReadRecord(Request $request)
    {
        $param = $request->except('_url');
        if (checkParam($param, ['bid', 'cid', 'chapter_name'])) {
            return response()->error('LACK_PARAM');
        }
        $param['uid'] = $this->uid;
        $param['bid'] = BookService::decodeBidStatic($param['bid']);
        Redis::hget('book_read:' . $this->uid, $param['bid']);
        $param['book_name'] = '';
        ReadRecordService::addReadRecord($param);
        return response()->success();
    }


    /**
     * @apiVersion 1.0.0
     * @apiDescription 删除阅读记录
     * @api {get} readrecord/delete 删除阅读记录
     * @apiGroup ReadRecord
     * @apiHeader {String} [Authorization]  token
     * @apiName delReadRecord
     * @apiParam   {String}         bid     多个bid以,分隔
     * @apiSuccess {int}         code 状态码
     * @apiSuccess {String}      msg  信息
     * @apiSuccess {object}      data 结果集
     * @apiSuccessExample {json} Success-Response:
     *     HTTP/1.1 200 OK
     *     {
     *       code: 0,
     *       msg: "",
     *       data:{}
     *
     */
    public function delReadRecord(Request $request)
    {
        $param = $request->except('_url');
        if (checkParam($param, ['bid'])) {
            return response()->error('LACK_PARAM');
        }
        $bids = explode(',', $param['bid']);
        array_walk($bids, function (&$item) {
            $item = BookService::decodeBidStatic($item);
        });
        ReadRecordService::delReadRecordStatic($this->uid, $bids);
        return response()->success();
    }
}