<?php
namespace App\Http\Controllers\QuickApp\Book;
use App\Modules\SendOrder\Models\SendOrder;
use App\Modules\SendOrder\Services\SendOrderService;
use App\Modules\Statistic\Services\WapVisitStatService;
use App\Modules\User\Services\UserBookCombinationConfigService;
use Illuminate\Http\Request;
use App\Http\Controllers\QuickApp\BaseController;
use Redis;
use App\Modules\Book\Services\ChapterService;
use App\Modules\User\Services\ReadRecordService;
use App\Http\Controllers\QuickApp\Book\Transformers\ChapterTransformer;
use App\Modules\Book\Services\BookConfigService;
use App\Http\Controllers\QuickApp\Book\Transformers\ChapterListTransformer;
use App\Jobs\UserRententionJob;
use App\Modules\Book\Services\BookService;
use App\Modules\Subscribe\Services\BookOrderService;
use App\Modules\Subscribe\Services\ChapterOrderService;
use App\Modules\Subscribe\Services\YearOrderService;
use App\Modules\OfficialAccount\Services\ForceSubscribeService;
use App\Modules\Subscribe\Services\ChapterReminderService;
use App\Modules\User\Services\UserDeepReadTagService;
use App\Modules\UserTask\Services\BaseTask;
use App\Modules\UserTask\Services\UserTaskService;
use App\Modules\SendOrder\Models\QappSendOrder;
class ChapterController extends BaseController
{
private $book_info;
public function getCatalog(Request $request, $bid)
{
$bid = BookService::decodeBidStatic($bid);
$lists = ChapterService::getChapterLists($bid);
$book_info = BookConfigService::getBookById($bid);
if (!$book_info) {
return response()->error('PARAM_ERROR');
}
$this->book_info = $book_info;
$lists = $this->getChapterCatalog($bid, $lists, $book_info);
return response()->collection(new ChapterListTransformer, $lists);
}
public function getCatalogPerPage(Request $request, $bid)
{
$bid = BookService::decodeBidStatic($bid);
$book_info = BookConfigService::getBookById($bid);
if (!$book_info) {
return response()->error('PARAM_ERROR');
}
$this->book_info = $book_info;
$page_size = $request->input('page_size', 15);
// if ($page_size >= 100) $page_size = 100;
if ($page_size >= 20) $page_size = 20;
// $page_size = 15;
$res = ChapterService::getChapterListsPage($bid, $page_size);
$lists = $this->getChapterCatalog($bid, $res, $book_info);
return response()->pagination(new ChapterListTransformer, $lists);
}
private function getChapterCatalog(int $bid, $chapters, $book_info)
{
// 查询书籍是否限免
$isFree = BookConfigService::judgeBookIsFree($bid);
//渠道自定义vip章节
//$vip_sequence = Redis::hget('channel:chapterfee:setting:' . $this->distribution_channel_id, $bid);
$vip_sequence = BookService::getVipSequence($bid, $this->distribution_channel_id, $this->send_order_id);
list($is_split, $is_change_chapter_name) = BookService::splitContent($bid);
$change_chapter_name = 0;
if ($is_split && ($book_info->channel_name == '男频' || $is_change_chapter_name)) {
$change_chapter_name = 1;
}
$account = $this->getAccount();
$work_wechat_info = $this->getWorkWechatInfo($bid);
switch ($book_info->charge_type) {
case 'BOOK':
$price = $this->getPriceNew($book_info, 0, $account);
$is_need_charge = $this->isBookNeedCharge($bid, $price);
foreach ($chapters as $v) {
$v->next_chapter_status = 0;
$v->next_price = 0;
$v->is_need_charge = $v->is_vip ? $is_need_charge : false;
$v->price = $price;
if ($work_wechat_info['force_add_work_wechat_type'] > 0 && $v->sequence >= $work_wechat_info['force_add_work_wechat_seq']){
$v->force_add_work_wechat_type = $work_wechat_info['force_add_work_wechat_type'];
$v->force_add_work_wechat_url = $work_wechat_info['force_add_work_wechat_url'];
}else{
$v->force_add_work_wechat_type = 0;
$v->force_add_work_wechat_url = "";
}
// 限免判断
if ($isFree) {
$v->is_need_charge = false;
$v->price = 0;
}
if ($vip_sequence) {
if ($v->sequence >= $vip_sequence) {
$v->is_vip = 1;
} else {
$v->is_vip = 0;
}
}
//拆章
if ($change_chapter_name) {
$v->name = '第' . $v->sequence . '章';
}
}
break;
default:
$chapterIds = $this->getChapterIds($chapters);
$rules = ['check' => 0, 'paycid' => []];
if (!$isFree && !empty($chapterIds)) {
$rules = $this->getHandelData($bid, $chapterIds);
}
foreach ($chapters as $v) {
if ($vip_sequence) {
if ($v->sequence >= $vip_sequence) {
$v->is_vip = 1;
} else {
$v->is_vip = 0;
}
}
if ($work_wechat_info['force_add_work_wechat_type'] > 0 && $v->sequence >= $work_wechat_info['force_add_work_wechat_seq']){
$v->force_add_work_wechat_type = $work_wechat_info['force_add_work_wechat_type'];
$v->force_add_work_wechat_url = $work_wechat_info['force_add_work_wechat_url'];
}else{
$v->force_add_work_wechat_type = 0;
$v->force_add_work_wechat_url = "";
}
// 限免判断
if ($isFree) {
$v->is_need_charge = false;
$v->price = 0;
} else {
$v->price = $v->is_vip ? $this->getPriceNew($book_info, $v->size, $account) : 0;
$v->is_need_charge = $v->is_vip ? $this->isChapterNeedChargeNew($v->id, $rules, $v->price) : false;
}
// //下一章付费信息
$v->next_chapter_status = 0;
$v->next_price = 0;
// if($v->is_vip){
// if(in_array($v->next_price,$chapterIds)){
//
// }else{
// $next_chapter_order_status = $this->nextChapterOrderStatus($bid,$v->next_cid);
// $v->next_chapter_status = $next_chapter_order_status['next_chapter_status'];
// $v->next_price = $next_chapter_order_status['next_price'];
// }
//
// }
$v->next_chapter_status = $this->isSubscribe($v->id, $rules);
$v->next_price = $v->price;
//拆章
if ($change_chapter_name) {
$v->name = '第' . $v->sequence . '章';
}
}
break;
}
return $chapters;
}
private function getChapterCatalogOld(int $bid, $chapters, $book_info)
{
// 查询书籍是否限免
$isFree = BookConfigService::judgeBookIsFree($bid);
//渠道自定义vip章节
//$vip_sequence = Redis::hget('channel:chapterfee:setting:' . $this->distribution_channel_id, $bid);
$vip_sequence = BookService::getVipSequence($bid, $this->distribution_channel_id, $this->send_order_id);
list($is_split, $is_change_chapter_name) = BookService::splitContent($bid);
$change_chapter_name = 0;
if ($is_split && ($book_info->channel_name == '男频' || $is_change_chapter_name)) {
$change_chapter_name = 1;
}
switch ($book_info->charge_type) {
case 'BOOK':
$price = $this->getPrice($book_info);
$is_need_charge = $this->isBookNeedCharge($bid, $price);
foreach ($chapters as $v) {
$v->next_chapter_status = 0;
$v->next_price = 0;
$v->is_need_charge = $v->is_vip ? $is_need_charge : false;
$v->price = $price;
// 限免判断
if ($isFree) {
$v->is_need_charge = false;
$v->price = 0;
}
if ($vip_sequence) {
if ($v->sequence >= $vip_sequence) {
$v->is_vip = 1;
} else {
$v->is_vip = 0;
}
}
//拆章
if ($change_chapter_name) {
$v->name = '第' . $v->sequence . '章';
}
}
break;
default:
foreach ($chapters as $v) {
if ($vip_sequence) {
if ($v->sequence >= $vip_sequence) {
$v->is_vip = 1;
} else {
$v->is_vip = 0;
}
}
// 限免判断
if ($isFree) {
$v->is_need_charge = false;
$v->price = 0;
} else {
$v->price = $v->is_vip ? $this->getPrice($book_info, $v->size) : 0;
$v->is_need_charge = $v->is_vip ? $this->isChapterNeedCharge($bid, $v->id, $v->price) : false;
}
//下一章付费信息
$v->next_chapter_status = 0;
$v->next_price = 0;
if ($v->is_vip) {
$next_chapter_order_status = $this->nextChapterOrderStatus($bid, $v->next_cid);
$v->next_chapter_status = $next_chapter_order_status['next_chapter_status'];
$v->next_price = $next_chapter_order_status['next_price'];
}
//拆章
if ($change_chapter_name) {
$v->name = '第' . $v->sequence . '章';
}
}
break;
}
return $chapters;
}
public function index(Request $request, $bid, $cid)
{
$send_order_id = $request->header('send_order_id', '');
$package = $request->header('x-package', '');
//每次绑定用户和派单的关系
$this->bindSendOrderId($this->uid, $send_order_id);
$oldbid = $bid;
$bid = BookService::decodeBidStatic($bid);
//获取图书信息
$book_info = BookConfigService::getBookById($bid);
if (empty($book_info))
return response()->error('QAPP_SYS_ERROR');
$this->book_info = $book_info;
$book_auth = BookConfigService::bookCopyright($bid, $this->distribution_channel_id);
if ($book_auth == 2) {
return response()->error('QAPP_OFF_SHELF');
}
//yuyuedu、xinghe 快应用这两个cp的书屏蔽下 wutong，wutong2，wutong3下所有内容都不放快应用
if (in_array($book_info->cp_source, getHiddenCp($package)) && $book_auth != 1) {
return response()->error('QAPP_OFF_SHELF');
}
if ($this->distribution_channel_id == 7477 && $bid == 13765) {
$book_info->is_on_shelf = 2;
}
$special = get_special_bid();
if (in_array($this->distribution_channel_id, [9487, 9390]) && in_array($book_info->bid, $special)) {
$book_info->is_on_shelf = 2;
}
if ($bid == 58886) {
$book_info->is_on_shelf = 0;
}
// 华为整改强制下架
if ($this->distribution_channel_id == 13131 && in_array($bid,[13762,65327,66643])){
$book_info->is_on_shelf = 4;
}
if (!in_array($book_info->is_on_shelf, [1, 2])) {
if ($book_info->is_on_shelf != 4) {
return response()->error('QAPP_OFF_SHELF');
}
//补充操作：如果该用户未订阅该下架的书籍则删除其阅读记录(书架不予显示)
//判断是否属于包年用户
$year_account = YearOrderService::getRecord($this->uid);
if (!$year_account) {
//获取书籍充值类型
$charge_type = $book_info->charge_type;
if ($charge_type == 'BOOK') {
//是否购买过该书，购买过则不删除
$res = BookOrderService::getRecordByuidBid($this->uid, $bid);
} elseif ($charge_type == 'CHAPTER') {
if ($this->distribution_channel_id == 13131 && in_array($bid,[13762,65327,66643])){
$res = ReadRecordService::getReadRecord($this->uid);
if ($res){
$res = array_column($res,null,'bid');
$res = $res[$bid] ?? [];
}
if (is_empty($res)){
return response()->error('QAPP_OFF_SHELF');
}
}
//是否购买过该书章节，购买过则不删除
$res = ChapterOrderService::checkBookIsOrdered($this->uid, $bid);
} else {
$res = false;
}
if (!$res) {
ReadRecordService::delReadRecordStatic($this->uid, [$bid]);
return response()->error('QAPP_OFF_SHELF');
}
}
}
//wutong，wutong2，wutong3下所有内容都不放快应用
// if(in_array($book_info->cp_source,['wutong','wutong2','wutong3','youyan2'])){
// return response()->error('QAPP_OFF_SHELF');
// }
$this->book_info = $book_info;
//获取章节信息
$chapter = ChapterService::getChapterNameById($cid, $bid);
if (!$chapter) {
//短推长
$combination_chapter = $this->chapterNotExists($bid, $cid);
if ($combination_chapter) {
$chapter = $combination_chapter;
$bid = $chapter->bid;
$book_info = BookConfigService::getBookById($bid);
$oldbid = \Hashids::encode($bid);
$this->book_info = $book_info;
} else {
return response()->error('QAPP_SYS_ERROR');
}
}
list($is_split, $is_change_chapter_name) = BookService::splitContent($bid);
if ($is_split && ($book_info->channel_name == '男频' || $is_change_chapter_name)) {
$chapter->name = '第' . $chapter->sequence . '章';
}
$is_next_day = date('Y-m-d', strtotime($this->user_info->created_at)) == date('Y-m-d', strtotime('-1 days'));
if ($is_next_day) {
$job = new UserRententionJob($this->uid, now(), $this->user_info->created_at);
dispatch($job)->onConnection('rabbitmq')->onQueue('user_rentention_queue');
}
//自定义vip章节
//$vip_sequence = Redis::hget('channel:chapterfee:setting:' . $this->distribution_channel_id, $bid);
$vip_sequence = BookService::getVipSequence($bid, $this->distribution_channel_id, $this->send_order_id);
if ($vip_sequence) {
if ($chapter->sequence >= $vip_sequence) {
$chapter->is_vip = 1;
} else {
$chapter->is_vip = 0;
}
}
if ($chapter->is_vip == 0) {
ReadRecordService::addReadLog($this->uid, [
'distribution_channel_id' => $this->distribution_channel_id,
'bid' => $bid,
'cid' => $chapter->id,
'uid' => $this->uid,
'send_order_id' => $this->send_order_id,
'sequence' => $chapter->sequence,
]);
ReadRecordService::addReadRecord([
'uid' => $this->uid, 'bid' => $bid, 'book_name' => $book_info->book_name,
'cid' => $cid, 'chapter_name' => $chapter->name, 'sequence' => $chapter->sequence
]);
return response()->item(new ChapterTransformer, $this->getChapter($bid, $chapter->id, $chapter));
}
// 书籍是否限免
$free = BookConfigService::judgeBookIsFree($bid);
if ($free) {
ReadRecordService::addReadLog($this->uid, [
'distribution_channel_id' => $this->distribution_channel_id,
'bid' => $bid,
'cid' => $chapter->id,
'uid' => $this->uid,
'send_order_id' => $this->send_order_id,
'sequence' => $chapter->sequence,
]);
ReadRecordService::addReadRecord([
'uid' => $this->uid, 'bid' => $bid, 'book_name' => $book_info->book_name,
'cid' => $cid, 'chapter_name' => $chapter->name, 'sequence' => $chapter->sequence
]);
if ($chapter->is_vip == 1) {
$fee = $this->getPrice($book_info, $chapter->size);
$now = date('Y-m-d');
Redis::hincrby('qapp:book:free:virtual:' . $free->id, $now, $fee);
Redis::sadd('qapp:free:virtual' . $now, $free->id);
Redis::sadd('qapp:free:virtual:uids' . $now . $free->id, $this->uid);
Redis::sadd('qapp:free:virtual:uids' . $free->id, $this->uid);
}
return response()->item(new ChapterTransformer, $this->getChapter($bid, $cid, $chapter));
}
//已经付费
if ($this->getOrderRecord($bid, $cid)) {
ReadRecordService::addReadLog($this->uid, [
'distribution_channel_id' => $this->distribution_channel_id,
'bid' => $bid,
'cid' => $chapter->id,
'uid' => $this->uid,
'send_order_id' => $this->send_order_id,
'sequence' => $chapter->sequence,
]);
ReadRecordService::addReadRecord([
'uid' => $this->uid, 'bid' => $bid, 'book_name' => $book_info->book_name,
'cid' => $cid, 'chapter_name' => $chapter->name, 'sequence' => $chapter->sequence
]);
return response()->item(new ChapterTransformer, $this->getChapter($bid, $cid, $chapter));
}
//未付费 要提醒
$user_info = $this->user_info;
//未付费 余额不足
$fee = $this->getPrice($book_info, $chapter->size);
$data = [
'book_id' => $oldbid,
'book_name' => $book_info->book_name,
'chapter_name' => $chapter->name,
'chapter_id' => $cid,
'pay_type' => $book_info->charge_type,
'fee' => $fee,
'user_balance' => $user_info->balance,
'product_id' => $book_info->product_id,
'uid' => $this->uid,
'distribution_channel_id' => $this->distribution_channel_id,
'is_discount' => 0,
'discount_fee' => '',
'discount' => ''
];
if ($user_info['balance'] < $fee) {
if ($book_info->charge_type == 'BOOK') {
return response()->error('QAPP_BOOK_INSUFFICIENT_BALANCE', $data);
} elseif ($book_info->charge_type == 'CHAPTER') {
return response()->error('QAPP_CHAPTER_INSUFFICIENT_BALANCE', $data);
} else {
return response()->error('QAPP_SYS_ERROR');
}
}
if (!$this->send_order_id) {
if ($book_info->charge_type == 'BOOK') {
return response()->error('QAPP_BOOK_BUY', $data);
}/*else{
return response()->error('QAPP_CHAPTER_BUY', $data);
}*/
}
//付费 不提醒
if ($this->balancePay($book_info, $cid, $chapter->size, $chapter->name, 0)) {
UserTaskService::addUserTaskQueue($this->uid, BaseTask::read, UserTaskService::judge_trigger);
ReadRecordService::addReadLog($this->uid, [
'distribution_channel_id' => $this->distribution_channel_id,
'bid' => $bid,
'cid' => $chapter->id,
'uid' => $this->uid,
'send_order_id' => $this->send_order_id,
'sequence' => $chapter->sequence,
]);
ReadRecordService::addReadRecord([
'uid' => $this->uid, 'bid' => $bid, 'book_name' => $book_info->book_name,
'cid' => $cid, 'chapter_name' => $chapter->name, 'sequence' => $chapter->sequence
]);
//限免统计
$free_book = BookConfigService::getByBidNoFilter($bid);
if ($free_book) {
if (strtotime($free_book->end_time) + 7 * 86400 >= strtotime(date('Y-m-d'))) {
if (Redis::Sismember('qapp:free:virtual:uids' . $free_book->id, $this->uid)) {
$now = date('Y-m-d');
Redis::hincrby('qapp:book:free:actuality:' . $free_book->id, $now, $fee);
Redis::sadd('qapp:free:actuality' . $now, $free_book->id);
Redis::sadd('qapp:free:actuality:uids' . $now . $free_book->id, $this->uid);
}
}
}
if ($this->uid == 247081369) {
$item = itemTransform(new ChapterTransformer, $this->getChapter($bid, $cid, $chapter));
myLog('xueqi')->info($item);
}
return response()->item(new ChapterTransformer, $this->getChapter($bid, $cid, $chapter));
} else {
if ($book_info->charge_type == 'BOOK') {
return response()->error('QAPP_BOOK_INSUFFICIENT_BALANCE', $data);
} elseif ($book_info->charge_type == 'CHAPTER') {
return response()->error('QAPP_CHAPTER_INSUFFICIENT_BALANCE', $data);
} else {
return response()->error('QAPP_SYS_ERROR');
}
}
}
public function pay(Request $request, $bid, $cid)
{
$remind = (int)$request->input('remind');
$oldbid = $bid;
$bid = BookService::decodeBidStatic($bid);
$book_info = BookConfigService::getBookById($bid);;
if (empty($book_info)) response()->error('QAPP_SYS_ERROR');
$this->book_info = $book_info;
if ($this->distribution_channel_id == 7477 && $bid == 13765) {
$book_info->is_on_shelf = 2;
}
if ($book_info->is_on_shelf == 0 || $book_info->is_on_shelf == 3) {
if (!$this->isBookOrdered($bid)) {
response()->error('QAPP_OFF_SHELF');
}
}
//获取章节
$chapter = ChapterService::getChapterNameById($cid, $bid);
if (!$chapter) {
$combination_chapter = $this->chapterNotExists($bid, $cid);
if ($combination_chapter) {
$chapter = $combination_chapter;
$bid = $chapter->bid;
$book_info = BookConfigService::getBookById($bid);
$oldbid = \Hashids::encode($bid);
$this->book_info = $book_info;
} else {
return response()->error('QAPP_SYS_ERROR');
}
}
if ($this->getOrderRecord($bid, $cid)) {
ReadRecordService::addReadLog($this->uid, [
'distribution_channel_id' => $this->distribution_channel_id,
'bid' => $bid,
'cid' => $chapter->id,
'uid' => $this->uid,
'send_order_id' => $this->send_order_id,
'sequence' => $chapter->sequence,
]);
ReadRecordService::addReadRecord([
'uid' => $this->uid, 'bid' => $bid, 'book_name' => $book_info->book_name,
'cid' => $cid, 'chapter_name' => $chapter->name, 'sequence' => $chapter->sequence
]);
return response()->item(new ChapterTransformer, $this->getChapter($bid, $cid, $chapter));
}
if ($this->balancePay($book_info, $cid, $chapter->size, $chapter->name, $remind)) {
UserTaskService::addUserTaskQueue($this->uid, BaseTask::read, UserTaskService::judge_trigger);
ReadRecordService::addReadLog($this->uid, [
'distribution_channel_id' => $this->distribution_channel_id,
'bid' => $bid,
'cid' => $chapter->id,
'uid' => $this->uid,
'send_order_id' => $this->send_order_id,
'sequence' => $chapter->sequence,
]);
ReadRecordService::addReadRecord([
'uid' => $this->uid, 'bid' => $bid, 'book_name' => $book_info->book_name,
'cid' => $cid, 'chapter_name' => $chapter->name, 'sequence' => $chapter->sequence
]);
$free_book = BookConfigService::getByBidNoFilter($bid);
if ($free_book) {
if (strtotime($free_book->end_time) + 7 * 86400 >= strtotime(date('Y-m-d'))) {
if (Redis::Sismember('qapp:free:virtual:uids' . $free_book->id, $this->uid)) {
$now = date('Y-m-d');
$fee = $this->getPrice($book_info, $chapter->size);
Redis::hincrby('qapp:book:free:actuality:' . $free_book->id, $now, $fee);
Redis::sadd('qapp:free:actuality' . $now, $free_book->id);
Redis::sadd('qapp:free:actuality:uids' . $now . $free_book->id, $this->uid);
}
}
}
return response()->item(new ChapterTransformer, $this->getChapter($bid, $cid, $chapter));
} else {
$fee = $this->getPrice($book_info, $chapter->size);
$data = [
'book_id' => $oldbid,
'book_name' => $book_info->book_name,
'chapter_name' => $chapter->name,
'chapter_id' => $cid,
'pay_type' => $book_info->charge_type,
'fee' => $fee,
'user_balance' => $this->user_info['balance'],
'product_id' => $book_info->product_id,
'uid' => $this->uid,
'distribution_channel_id' => $this->distribution_channel_id,
'is_discount' => 0,
'discount_fee' => '',
'discount' => ''
];
if ($book_info->charge_type == 'BOOK') {
return response()->error('QAPP_BOOK_INSUFFICIENT_BALANCE', $data);
} elseif ($book_info->charge_type == 'CHAPTER') {
return response()->error('QAPP_CHAPTER_INSUFFICIENT_BALANCE', $data);
} else {
return response()->error('QAPP_SYS_ERROR');
}
}
}
/**
* 余额支付
* @param $book_info
* @param $chapter_id
* @param $chapter_size
* @return bool
*/
protected function balancePay($book_info, $chapter_id, $chapter_size, $chapter_name, $is_remind)
{
$fee = $this->getPrice($book_info, $chapter_size);
if ((int)$this->user_info['balance'] >= $fee) {
if ($this->bookOrderOrChapterOrder($book_info, $chapter_id, $fee, $chapter_name, $is_remind)) {
return true;
}
return false;
} else {
return false;
}
}
/**
* 获取章节内容
* @param $bid
* @param $cid
* @return bool|mixed
*/
protected function getChapter($bid, $cid, $chapter)
{
$chapter_content = ChapterService::getChapter($bid, $cid);
if (!$chapter_content) return false;
$chapter->content = trim(str_replace($chapter_content->name, '', $chapter_content->content));
// 格式特殊处理
$qian = array(" ", " ", "\t");
$hou = array("", "", "");
// 去掉所有空格
$chapter->content = str_replace($qian, $hou, $chapter->content);
// 2换行变1换行
$chapter->content = str_replace("\n\n", "\n", $chapter->content);
$chapter->content = str_replace("\r\n\r\n", "\r\n", $chapter->content);
// \Log::info('getChapter_chapter:'.$bid.' cid:'.$cid);
// \Log::info($chapter->content);
//统计点击率
$key = 'book_click_num_bid_' . $bid;
$field = date('Y-m-d');
$old = Redis::hget($key, $field);
if (!$old) $old = 0;
Redis::hset($key, $field, $old + 1);
[$force_add_desk_type,$is_need_query_send_order] = $this->addDesktopType($bid, $chapter->sequence);
$chapter->force_add_desk_type = $force_add_desk_type;
$force_add_work_wechat_type = 0;
$force_add_work_wechat_url = "";
if($is_need_query_send_order){
[$force_add_work_wechat_type, $force_add_work_wechat_url] = $this->addWorkWechatType($chapter->sequence);
}
$chapter->force_add_work_wechat_type = $force_add_work_wechat_type;
$chapter->force_add_work_wechat_url = $force_add_work_wechat_url;
//统计
$this->stats();
$next_chapter_order_status = $this->nextChapterOrderStatus($bid, $chapter->next_cid);
$chapter->next_chapter_status = $next_chapter_order_status['next_chapter_status'];
$chapter->next_price = $next_chapter_order_status['next_price'];
$chapter->charge_type = $this->book_info->charge_type;
$this->userBookCombination($chapter);
return $chapter;
}
private function nextChapterOrderStatus($bid, $cid)
{
$chapter = ChapterService::getChapterNameById($cid, $bid);
if (!$chapter || $chapter->is_vip == 0 || $this->book_info->charge_type == 'BOOK') {
return ['next_chapter_status' => 0, 'next_price' => 0];
}
$is_paid = $this->getOrderRecord($bid, $cid);
if ($is_paid) {
return ['next_chapter_status' => 1, 'next_price' => 0];
}
$fee = $this->getPrice($this->book_info, $chapter->size);
return ['next_chapter_status' => 2, 'next_price' => $fee];
}
//短续长
private function userBookCombination($chapter)
{
if ($chapter->prev_cid && $chapter->next_cid) {
return;
}
if ($chapter->next_cid == 0 && $this->book_info->charge_type == 'BOOK') {
$bid = UserBookCombinationConfigService::selectAndSave($this->uid, $this->book_info->bid);
if ($bid) {
$bookInfo = BookConfigService::getBookById($bid);
$chapter->next_cid = $bookInfo->first_cid;
}
}
if ($chapter->prev_cid == 0 && $this->book_info->charge_type == 'CHAPTER') {
$bid = UserBookCombinationConfigService::getShortBookFromLongBid($this->uid, $this->book_info->bid);
if ($bid) {
$bookInfo = BookConfigService::getBookById($bid);
$chapter->prev_cid = $bookInfo->last_cid;
}
}
}
private function chapterNotExists($bid, $cid)
{
//1.全局图书组合配置
$combination = BookConfigService::getCombinationInfo($bid);
if ($combination) {
$chapter = ChapterService::getChapterNameByIdNoCheck($cid);
if ($chapter) {
return $chapter;
}
return false;
}
//2.用户图书组合配置
if ($this->book_info->charge_type == 'CHAPTER') {
$user_combination = UserBookCombinationConfigService::getShortBookFromLongBook($this->uid, $bid);
} else {
$user_combination = UserBookCombinationConfigService::getLongBookFromShortBook($this->uid, $bid);
}
if ($user_combination) {
$chapter = ChapterService::getChapterNameByIdNoCheck($cid);
if ($chapter) {
return $chapter;
}
return false;
}
return false;
}
/**
* 添加订购记录
* @param $book_info
* @param $chapter_id
* @param $fee
* @return bool
*/
protected function bookOrderOrChapterOrder($book_info, $chapter_id, $fee, $chapter_name, $is_remind)
{
if ($book_info['charge_type'] == 'BOOK') {
$data = [
'uid' => $this->uid,
'fee' => $fee,
'u' => $this->send_order_id,
'distribution_channel_id' => $this->distribution_channel_id,
'bid' => $book_info->bid,
'book_name' => $book_info->book_name,
'send_order_id' => $this->send_order_id,
];
return BookOrderService::addOrderRecodeAndDecrUserBalance($data, $this->uid);
} else {
$data = [
'uid' => $this->uid,
'fee' => $fee,
'cid' => $chapter_id,
'bid' => $book_info->bid,
'distribution_channel_id' => $this->distribution_channel_id,
'book_name' => $book_info->book_name,
'chapter_name' => $chapter_name,
'send_order_id' => $this->send_order_id,
'is_remind' => $is_remind
];
if ($is_remind) {
$this->addOrderRemind($book_info->bid);
}
return ChapterOrderService::addOrderAndDecrUserBalance($data, $this->uid);
}
}
protected function addOrderRemind($bid)
{
if (ChapterReminderService::checkIsNoReminder($this->uid, $bid)) {
return true;
} else {
ChapterReminderService::add($this->uid, $bid);
return true;
}
}
/**
* 是否订购提醒
* @param $chapter_id
* @return bool
*/
protected function isOrderRemind($bid)
{
$is_no_reminder = ChapterReminderService::checkIsNoReminder($this->uid, $bid) ? 1 : 0;
return $is_no_reminder == 0;
}
/**
* 用户是否关注
* @param $uid
* @return bool
*/
protected function getSubscribe()
{
$res = ForceSubscribeService::forceSubscribeUsersByUid(['uid' => $this->uid]);
if ($res) return true;
return false;
}
/**
* 获取订购记录
* @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;
}
/**
* 计算价格
* @param $book_info
* @param $chapter_size
* @return float
*/
private function getPrice($book_info, $chapter_size = 0)
{
if ($book_info->charge_type == 'BOOK') {
if (BookOrderService::isHasBookOrder($this->uid)) {
$this->is_first_book_order = 0;
return 1399;
} else {
$this->is_first_book_order = 1;
return 899;
}
} else {
// 获取投放后台账号，
$account = '';
$account_send_order = $this->getNowSendOrderInfo();
if ($account_send_order) {
$account = isset($account_send_order['account']) ? $account_send_order['account'] : '';
}
$fee = BookService::getPrice($book_info, $this->distribution_channel_id, $chapter_size, $account);
return $fee;
}
}
/**
* 计算价格
* @param $book_info
* @param $chapter_size
* @return float
*/
private function getPriceNew($book_info, $chapter_size = 0, $account = "")
{
if ($book_info->charge_type == 'BOOK') {
if (BookOrderService::isHasBookOrder($this->uid)) {
$this->is_first_book_order = 0;
return 1399;
} else {
$this->is_first_book_order = 1;
return 899;
}
} else {
return BookService::getPrice($book_info, $this->distribution_channel_id, $chapter_size, $account);
}
}
/**
* 获取投放后台账号，
* name: getAccount
* @return mixed|string
* date 2022/10/20 11:29
*/
protected function getAccount()
{
$account = '';
$account_send_order = $this->getNowSendOrderInfo();
if ($account_send_order) {
$account = isset($account_send_order['account']) ? $account_send_order['account'] : '';
}
return $account;
}
/**
* 用户添加标签
* @param $book_info
*/
protected function addTag($book_info)
{
if (!UserDeepReadTagService::isAddTag($this->uid, $book_info->bid)) {
try {
UserDeepReadTagService::addTag([
'uid' => $this->uid,
'bid' => $book_info->bid,
'book_name' => $book_info->book_name,
'category_id' => $book_info->category_id,
'category_name' => $book_info->category_name,
'sex_preference' => $book_info->channel_name ? $book_info->channel_name : '',
'distribution_channel_id' => $this->distribution_channel_id ? $this->distribution_channel_id : '0',
'send_order_id' => $this->send_order_id,
]);
} catch (\Exception $e) {
}
}
}
protected function isBookOrdered($bid)
{
$chapter_order = ChapterOrderService::checkBookIsOrdered($this->uid, $bid);
if ($chapter_order) return true;
$res = BookOrderService::getRecordByuidBid($this->uid, $bid);
if ($res) 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 stats()
{
//阅读器统计
WapVisitStatService::recordReaderUvAndPv($this->uid, $this->distribution_channel_id);
}
//加桌类型
private function addDesktopType($bid, $sequence)
{
$deault_force_add_desk_type = 0;
$send_order_id = $this->GetBindSendOrderId($this->uid);
$is_need_query_order = 0;
if ($send_order_id) {
$send_order_info = SendOrderService::getById($send_order_id);
if (!$send_order_info) return [$deault_force_add_desk_type,$is_need_query_order];
if ($send_order_info->book_id == $bid) {
$is_need_query_order = 1;
// 派单书籍和观看书籍一致，并设置了强加桌，判断当前章节和设置的强加桌章节
if ($send_order_info->force_add_desk_type == 1 && $send_order_info->force_add_desk_seq) {
//在设置的强加桌章节前一章开始
if ($sequence >= ($send_order_info->force_add_desk_seq - 1)) {
$force_add_desk_type = $send_order_info->force_add_desk_type;
return [$force_add_desk_type,$is_need_query_order];
}
}
if ($send_order_info->force_add_desk_type == 2) {
if ($sequence >= $this->book_info->force_subscribe_chapter_seq && $sequence <= $this->book_info->force_subscribe_chapter_seq + 3) {
$force_add_desk_type = $send_order_info->force_add_desk_type;
return [$force_add_desk_type,$is_need_query_order];
}
}
if ($send_order_info->force_add_desk_type == 3) {
//弱加桌+强加桌 ，即强加桌章节之前的章节均弱加桌，之后的章节显示强加桌:
$need_sequence = $send_order_info->force_add_desk_seq;
if (!$need_sequence) {
$need_sequence = $this->book_info->force_subscribe_chapter_seq;
}
if ($sequence >= ($need_sequence - 1)) {
//之后的章节显示强加桌
return [1,$is_need_query_order];
} else {
////强加桌章节之前的章节均弱加桌
return [2,$is_need_query_order];
}
}
return [$deault_force_add_desk_type,$is_need_query_order];
}
}
//无派单，或者派单书籍与 此次书籍不一致，直接使用 原书籍的默认强关章节
$book_info = BookConfigService::getBookById($bid);
if ($book_info && $book_info->force_subscribe_chapter_seq) {
if ($sequence >= ($book_info->force_subscribe_chapter_seq - 1)) {
return [2,$is_need_query_order];
}
}
return [$deault_force_add_desk_type,$is_need_query_order];
}
private function addWorkWechatType($sequence)
{
$deault_force_add_desk_type = 0;
$work_wechat_url = "";
$send_order_id = $this->GetBindSendOrderId($this->uid);
if ($send_order_id) {
$send_order_info = QappSendOrder::getSendOrderById($send_order_id);
if (!$send_order_info) return [$deault_force_add_desk_type, $work_wechat_url];
if($send_order_info['force_add_work_wechat_status'] == 1 && $send_order_info['force_add_work_wechat_seq'] <= ($sequence+1)){
$deault_force_add_desk_type =$send_order_info['force_add_work_wechat_type'];
$work_wechat_url =$send_order_info['force_add_work_wechat_url'];
}
}
return [$deault_force_add_desk_type, $work_wechat_url];
}
/**
* [bindSendOrderId description]
* @param [type] $uid [description]
* @param [type] $send_order_id [description]
* @return [type] [description]
*/
public function bindSendOrderId($uid, $send_order_id)
{
if ($send_order_id) {
$res = Redis::hset('book_read_chapter:' . $uid, 'send_order_id', $send_order_id);
}
}
/**
* [bindSendOrderId description]
* @param [type] $uid [description]
* @param [type] $send_order_id [description]
* @return [type] [description]
*/
public function GetBindSendOrderId($uid)
{
try {
$send_order_id = Redis::hget('book_read_chapter:' . $uid, 'send_order_id');
if ($send_order_id)
return (int)$send_order_id;
} catch (\Exception $e) {
}
}
private function getChapterIds($chapters): array
{
$list = [];
if ($chapters) {
foreach ($chapters as $v) {
$list[] = $v->id;
}
}
return $list;
}
private function getHandelData(int $bid, array $chapterIds): array
{
$uid = $this->uid;
$res = YearOrderService::getRecord($uid);
if ($res) {
return $handle = ['check' => 0, 'paycid' => []];
}
$res = null;
//单本订购记录
$res = BookOrderService::getRecordByuidBid($uid, $bid);
if ($res) {
return $handle = ['check' => 0, 'paycid' => []];
}
//章节订购记录
$chapterOrder = new ChapterOrderService();
$res = $chapterOrder->getOrdersByChapterIds($uid, $bid, $chapterIds);
return $handle = ['check' => 1, 'paycid' => $res];
}
/**
* 判断是否需要充值
* name: isChapterNeedChargeNew
* @param $cid
* @param $rules
* @return bool
* date 2022/10/20 16:08
*/
private function isChapterNeedChargeNew($cid, $rules, $price = 0): bool
{
if ($rules['check'] != 1) {
return false;
}
if (empty($rules['paycid']) || !in_array($cid, $rules['paycid'])) {
$user_info = $this->user_info;
return $user_info['balance'] < $price;
} else {
return false;
}
}
/*****
* 是否订阅
* name: isSubscribe
* @param $cid
* @param $rules
* @return int
* date 2022/11/02 17:19
*/
private function isSubscribe($cid, $rules): int
{
if ($rules['check'] != 1) {
return 1;
}
if (empty($rules['paycid']) || !in_array($cid, $rules['paycid'])) {
return 2;
} else {
return 1;
}
}
private function getWorkWechatInfo($bid)
{
$info = ['force_add_work_wechat_type' => 0,'force_add_work_wechat_url' => "",'force_add_work_wechat_seq' => 0];
$send_order_id = $this->GetBindSendOrderId($this->uid);
if ($send_order_id) {
$send_order_info = QappSendOrder::getSendOrderById($send_order_id);
if (!$send_order_info) return $info;
$send_order_bid = SendOrder::where(['id' => $send_order_id])->value('book_id');
if($send_order_info['force_add_work_wechat_status'] == 1 && $send_order_bid == $bid){
$info['force_add_work_wechat_type'] = $send_order_info['force_add_work_wechat_type'];
$info['force_add_work_wechat_url'] = $send_order_info['force_add_work_wechat_url'];
$info['force_add_work_wechat_seq'] = $send_order_info['force_add_work_wechat_seq'];
}else{
return $info;
}
}
return $info;
}
}