<?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)
    {
        $res  = ReadRecordService::getReadRecord($this->uid);
        $package = $request->header('x-package', '');
        //补充操作：如果该用户未订阅该下架的书籍则删除其阅读记录(书架不予显示)
        //判断是否属于包年用户
        $year_account = YearOrderService::getRecord($this->uid);

        if ($res) {
            $bids = array_column($res,'bid');
            $channel_id = $request->input('distribution_channel_id',0);
            $book = BookConfigService::getBooksByIds($bids, [], 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(is_public_package_channel_id($channel_id)){
                            $hidden = getHiddenCp();
                        }else{
                            $hidden = array_merge(getHiddenCp(),['lianshang']);
                        }
                        if((!$year_account && !in_array($val->is_on_shelf,[1,2])) || in_array($val->cp_source,$hidden)){
                            //获取书籍充值类型
                            $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($res[$key]);
                                ReadRecordService::delReadRecordStatic($this->uid,[$val->bid]);
                            }
                        }
                        break;
                    }
                }
            }
        }
        usort($res, function ($a, $b) {
            if ($a['time'] >= $b['time']) return -1;
            return 1;
        });
        return response()->collection(new ReadRecordTransformer(), array_to_object($res));
    }

    /***
     * 获取上次阅读记录
     * name: lastReadRecord
     * @param Request $request
     * @return mixed
     * date 2022/08/17 15:07
     */
    public function lastReadRecord(Request $request)
    {
        $res  = ReadRecordService::getReadRecord($this->uid);
        $package = $request->header('x-package', '');
        //补充操作：如果该用户未订阅该下架的书籍则删除其阅读记录(书架不予显示)
        //判断是否属于包年用户
        $year_account = YearOrderService::getRecord($this->uid);

        if ($res) {
            $bids = array_column($res,'bid');
            $channel_id = $request->input('distribution_channel_id',0);
            $book = BookConfigService::getBooksByIds($bids, [], false);//下架图书最近阅读可看到
            $book = array_column(($book->toArray()),null,'bid');
            foreach ($res as  &$value) {
                $value['cover']        = '';
                $value['last_chapter'] = 0;
                $value['intro'] = '';
                $value['status'] = '';
                $value['size'] = 0;
                $value['author'] = '';
                if(isset($book[$value['bid']])){
                    $info = $book[$value['bid']];
                    $value['book_name']    = $info['book_name'];
                    $value['cover']        =  $info['cover'];
                    $value['last_chapter'] = $info['last_chapter'];
                    $value['intro'] =  $info['intro'];
                    $value['status'] =  $info['status'];
                    $value['size'] =  $info['size'];
                    $value['author'] =  $info['author'];
                    if(is_public_package_channel_id($channel_id)){
                        $hidden = getHiddenCp();
                    }else{
                        $hidden = array_merge(getHiddenCp(),['lianshang']);
                    }
                    if((!$year_account && !in_array( $info['is_on_shelf'],[1,2])) || in_array( $info['cp_source'],$hidden)){
                        //获取书籍充值类型
                        $charge_type =  $info['charge_type'];
                        if($charge_type == 'BOOK'){
                            //是否购买过该书，购买过则不删除
                            $result = BookOrderService::getRecordByuidBid($this->uid, $info['bid']);
                        }elseif($charge_type == 'CHAPTER'){
                            //是否购买过该书章节，购买过则不删除
                            $result = ChapterOrderService::checkBookIsOrdered($this->uid,$info['bid']);
                        }else{
                            $result = false;
                        }
                        if (!$result) {
                            unset($value);
                            ReadRecordService::delReadRecordStatic($this->uid,[$info['bid']]);
                        }
                    }
                }else{
                    unset($value);
                }
            }
            unset($value);
        }

        usort($res, function ($a, $b) {
            if ($a['time'] >= $b['time']) return -1;
            return 1;
        });
        if (count($res) >  0){
            return response()->success((new ReadRecordTransformer())->transform(array_to_object($res[0])));
        }
        return response()->success();
    }
    /**
     * @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();
    }
}