ChapterController.php 62 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669
  1. <?php
  2. namespace App\Http\Controllers\Wap\Book;
  3. use App\Console\Commands\YqBook;
  4. use App\Modules\Book\Models\DataAnalysisBookConfig;
  5. use App\Modules\Book\Services\BookService;
  6. use App\Modules\Book\Services\ChapterCommentsService;
  7. use App\Modules\Book\Services\ChapterShareWechatConfigService;
  8. use App\Modules\Statistic\Models\DataAnalysisSelectUser;
  9. use App\Modules\Statistic\Services\AdVisitStatService;
  10. use App\Modules\Statistic\Services\DataAnalysisChapterService;
  11. use App\Modules\Statistic\Services\DataAnalysisSelectUserService;
  12. use App\Modules\Statistic\Services\WapVisitStatService;
  13. use App\Modules\Subscribe\Services\OrderService;
  14. use App\Modules\User\Services\ReadRecordStatsService;
  15. use App\Modules\YunQi\Services\BookUserService;
  16. use Illuminate\Http\Request;
  17. use App\Http\Controllers\Wap\BaseController;
  18. use Cookie;
  19. use Redis;
  20. use App\Modules\Book\Services\ChapterService;
  21. use App\Modules\User\Services\ReadRecordService;
  22. use App\Http\Controllers\Wap\Book\Transformers\ChapterTransformer;
  23. use App\Modules\Book\Services\BookConfigService;
  24. use App\Http\Controllers\Wap\Book\Transformers\ChapterListTransformer;
  25. use App\Modules\Subscribe\Services\BookOrderService;
  26. use App\Modules\Subscribe\Services\ChapterOrderService;
  27. use App\Modules\Subscribe\Services\YearOrderService;
  28. use App\Modules\OfficialAccount\Services\ForceSubscribeService;
  29. use App\Modules\Subscribe\Services\ChapterReminderService;
  30. use App\Modules\OfficialAccount\Services\OfficialAccountService;
  31. use Hashids;
  32. use GuzzleHttp\Client;
  33. use Log;
  34. use DB;
  35. use App\Modules\User\Services\UserSignService;
  36. use App\Modules\SendOrder\Services\SendOrderService;
  37. use App\Modules\User\Services\UserDeepReadTagService;
  38. use App\Modules\Book\Services\BookSubscribleChapterService;
  39. use App\Modules\Channel\Services\ChannelSubscribeSettingService;
  40. class ChapterController extends BaseController
  41. {
  42. /**
  43. * @apiDefine Chapter 章节
  44. */
  45. //用户是否强关
  46. private $is_had_subscribe = false;
  47. //章节是否需要强关
  48. private $is_need_subscribe;
  49. //用户信息
  50. private $user;
  51. //图书信息
  52. private $book_info;
  53. //cid
  54. private $cid;
  55. //加密的bid
  56. private $en_bid;
  57. //章节信息
  58. private $chapter;
  59. //强关时间
  60. private $force_subscribe_time = null;
  61. /**
  62. * @apiVersion 1.0.0
  63. * @apiDescription 章节列表不分页
  64. * @api {get} books/{bid}/allcatalog 章节列表不分页
  65. * @apiGroup Chapter
  66. * @apiName getCatalog
  67. * @apiSuccess {int} code 状态码
  68. * @apiSuccess {String} msg 信息
  69. * @apiSuccess {object} data 结果集
  70. * @apiSuccess {Array} data.list 分页结果集
  71. * @apiSuccess {Int} data.list.bid bid
  72. * @apiSuccess {Int} data.list.chapter_id 章节id
  73. * @apiSuccess {String} data.list.chapter_name 章节名称
  74. * @apiSuccess {Int} data.list.chapter_sequence 序号
  75. * @apiSuccess {Int} data.list.chapter_is_vip 是否vip
  76. * @apiSuccess {Int} data.list.chapter_size 章节大小
  77. * @apiSuccess {Int} data.list.prev_cid 上一章节id
  78. * @apiSuccess {Int} data.list.next_cid 下一章节
  79. * @apiSuccess {String} data.list.recent_update_at 更新时间
  80. * @apiSuccess {String} data.list.is_need_subscirbe 是否强制关注
  81. * @apiSuccess {String} data.list.is_show_price 是否显示价格
  82. * @apiSuccess {String} data.list.price 价格
  83. * @apiSuccess {object} data.meta 分页信息
  84. * @apiSuccess {Int} data.meta.total 总条数
  85. * @apiSuccess {Int} data.meta.per_page 每页条数
  86. * @apiSuccess {Int} data.meta.current_page 当前页
  87. * @apiSuccess {Int} data.meta.last_page 最后页
  88. * @apiSuccess {String} data.meta.next_page_url 下一页
  89. * @apiSuccess {String} data.meta.prev_page_url 上一页
  90. * @apiSuccessExample {json} Success-Response:
  91. * HTTP/1.1 200 OK
  92. * {
  93. * code: 0,
  94. * msg: "",
  95. * data:
  96. * [
  97. * {
  98. * bid: 5,
  99. * chapter_id: 5,
  100. * chapter_name: "第1240章 不是我",
  101. * chapter_sequence: 1239,
  102. * chapter_is_vip: 1,
  103. * chapter_size: 2422,
  104. * prev_cid: 0,
  105. * next_cid: 0,
  106. * recent_update_at: 2017-11-20 15:01:56,
  107. * is_need_subscirbe: 1,
  108. * },
  109. * {
  110. * bid: 5,
  111. * chapter_id: 5,
  112. * chapter_name: "第1240章 不是我",
  113. * chapter_sequence: 1239,
  114. * chapter_is_vip: 1,
  115. * chapter_size: 2422,
  116. * prev_cid: 0,
  117. * next_cid: 0,
  118. * recent_update_at: 2017-11-20 15:01:56,
  119. * is_need_subscirbe: 1,
  120. * },
  121. * ]
  122. * }
  123. */
  124. public function getCatalog(Request $request, $t, $domain, $bid)
  125. {
  126. $this->en_bid = $bid;
  127. $bid = Hashids::decode($bid)[0];
  128. $lists = ChapterService::getChapterLists($bid);
  129. $book_info = BookConfigService::getBookById($bid);
  130. if (!$book_info) {
  131. return response()->error('PARAM_ERROR');
  132. }
  133. $this->book_info = $book_info;
  134. $is_show_price = $this->showChapterPrice($bid, $book_info->charge_type);
  135. foreach ($lists as $v) {
  136. $v->is_show_price = $is_show_price;
  137. $v->price = '';
  138. if ($is_show_price) {
  139. $v->price = $this->getPrice($book_info, $v);
  140. }
  141. }
  142. return response()->collection(new ChapterListTransformer, $lists);
  143. }
  144. /**
  145. * @apiVersion 1.0.0
  146. * @apiDescription 章节列表分页
  147. * @api {get} books/{bid}/catalog 章节列表分页
  148. * @apiGroup Chapter
  149. * @apiName getCatalogPerPage
  150. * @apiParam {Int} page_size 分页大小(默认15)
  151. * @apiParam {Int} page 页码(默认1)
  152. * @apiSuccess {int} code 状态码
  153. * @apiSuccess {String} msg 信息
  154. * @apiSuccess {object} data 结果集
  155. * @apiSuccess {Array} data.list 分页结果集
  156. * @apiSuccess {Int} data.list.bid bid
  157. * @apiSuccess {Int} data.list.chapter_id 章节id
  158. * @apiSuccess {String} data.list.chapter_name 章节名称
  159. * @apiSuccess {Int} data.list.chapter_sequence 序号
  160. * @apiSuccess {Int} data.list.chapter_is_vip 是否vip
  161. * @apiSuccess {Int} data.list.chapter_size 章节大小
  162. * @apiSuccess {Int} data.list.prev_cid 上一章节id
  163. * @apiSuccess {Int} data.list.next_cid 下一章节
  164. * @apiSuccess {String} data.list.recent_update_at 更新时间
  165. * @apiSuccess {String} data.list.is_need_subscirbe 是否强制关注
  166. * @apiSuccess {String} data.list.is_show_price 是否显示价格
  167. * @apiSuccess {String} data.list.price 价格
  168. * @apiSuccess {object} data.meta 分页信息
  169. * @apiSuccess {Int} data.meta.total 总条数
  170. * @apiSuccess {Int} data.meta.per_page 每页条数
  171. * @apiSuccess {Int} data.meta.current_page 当前页
  172. * @apiSuccess {Int} data.meta.last_page 最后页
  173. * @apiSuccess {String} data.meta.next_page_url 下一页
  174. * @apiSuccess {String} data.meta.prev_page_url 上一页
  175. * @apiSuccessExample {json} Success-Response:
  176. * HTTP/1.1 200 OK
  177. * {
  178. * code: 0,
  179. * msg: "",
  180. * data:
  181. * list:[
  182. * {
  183. * bid: 5,
  184. * chapter_id: 5,
  185. * chapter_name: "第1240章 不是我",
  186. * chapter_sequence: 1239,
  187. * chapter_is_vip: 1,
  188. * chapter_size: 2422,
  189. * prev_cid: 0,
  190. * next_cid: 0,
  191. * recent_update_at: 2017-11-20 15:01:56,
  192. * is_need_subscirbe: 1,
  193. * },
  194. * {
  195. * bid: 5,
  196. * chapter_id: 5,
  197. * chapter_name: "第1240章 不是我",
  198. * chapter_sequence: 1239,
  199. * chapter_is_vip: 1,
  200. * chapter_size: 2422,
  201. * prev_cid: 0,
  202. * next_cid: 0,
  203. * recent_update_at: 2017-11-20 15:01:56,
  204. * is_need_subscirbe: 1,
  205. * },
  206. * ]
  207. * meta:{
  208. * total: 1253,
  209. * per_page: 15,
  210. * current_page: 1,
  211. * last_page: 84,
  212. * next_page_url: "http://myapi.cn/api/books/1/chapter?page=2",
  213. * prev_page_url: ""
  214. * }
  215. * }
  216. */
  217. public function getCatalogPerPage(Request $request, $t, $domain, $bid)
  218. {
  219. $this->en_bid = $bid;
  220. $bid_array = Hashids::decode($bid);
  221. if (isset($bid_array[0])) {
  222. $bid = $bid_array[0];
  223. } else {
  224. return response()->error('PARAM_ERROR');
  225. }
  226. $book_info = BookConfigService::getBookById($bid);
  227. if (!$book_info) {
  228. return response()->error('PARAM_ERROR');
  229. }
  230. $this->book_info = $book_info;
  231. $page_size = $request->input('page_size', 15);
  232. $res = ChapterService::getChapterListsPage($bid, $page_size);
  233. $is_show_price = $this->showChapterPrice($bid, $book_info->charge_type);
  234. foreach ($res as $v) {
  235. $v->is_show_price = $is_show_price;
  236. $v->price = '';
  237. if ($is_show_price) {
  238. $v->price = $this->getPrice($book_info, $v);
  239. }
  240. }
  241. return response()->pagination(new ChapterListTransformer, $res);
  242. }
  243. /**
  244. * @apiVersion 1.0.0
  245. * @apiDescription 章节内容
  246. * @api {get} books/{bid}/chapters/{chapter_id} 章节内容
  247. * @apiGroup Chapter
  248. * @apiName index
  249. * @apiSuccess {int} code 状态码
  250. * @apiSuccess {String} msg 信息
  251. * @apiSuccess {object} data 结果集
  252. * @apiSuccess {Int} data.chapter_id 章节id
  253. * @apiSuccess {String} data.chapter_name 章节名称
  254. * @apiSuccess {Int} data.chapter_sequence 序号
  255. * @apiSuccess {Int} data.chapter_is_vip 是否vip
  256. * @apiSuccess {Int} data.chapter_size 章节大小
  257. * @apiSuccess {Int} data.prev_cid 上一章节id
  258. * @apiSuccess {Int} data.next_cid 下一章节
  259. * @apiSuccess {String} data.recent_update_at 更新时间
  260. * @apiSuccess {String} data.chapter_content 章节内容
  261. * @apiSuccess {Int} data.is_need_subscirbe 是否强制关注(删除)
  262. * @apiSuccess {Int} data.is_show_subscribe_link 是否显示底部强关链接
  263. * @apiSuccessExample {json} Success-Response:
  264. * HTTP/1.1 200 OK
  265. * {
  266. * code: 0,
  267. * msg: "",
  268. * data: {
  269. * chapter_id: 5,
  270. * chapter_name: "第1240章 不是我",
  271. * chapter_sequence: 1239,
  272. * chapter_is_vip: 1,
  273. * chapter_size: 2422,
  274. * prev_cid: 0,
  275. * next_cid: 0,
  276. * recent_update_at: 2017-11-20 15:01:56,
  277. * chapter_content: "叶妩被司行霈的阴阳怪气一吓,思路偏得太远了。 她张口结舌,忘记了自己要说什么。",
  278. * }
  279. * }
  280. */
  281. public function index(Request $request, $t, $domain, $bid, $cid)
  282. {
  283. //注意:内部约定用 有此参数不需要强关
  284. $inter_not_need_sub = $request->has('inter_not_need_sub') ? true : false;
  285. $ad_status = $request->get('ad_status');
  286. $ad_status = 0;
  287. $has_force_show_qrcode_cookie = Cookie::get('force_show_qrcode');
  288. Cookie::queue('force_show_qrcode', 1, -1);
  289. if (!$this->checkUid()) {
  290. return response()->error('WAP_NOT_LOGIN');
  291. }
  292. $this->en_bid = $bid;
  293. $bid = explode(',',$bid)[0];
  294. $bid = Hashids::decode($bid)[0];
  295. //获取图书信息
  296. $book_info = BookConfigService::getBookById($bid);
  297. //是否开启全站按章模式
  298. $global_charge_by_chapter_channels = explode(',',env('GLOBAL_CHARGE_BY_CHAPTER_CHANNEL'));
  299. if(in_array($this->distribution_channel_id,$global_charge_by_chapter_channels))
  300. {
  301. $book_info->charge_type = 'CHAPTER';
  302. }
  303. if (empty($book_info)) return response()->error('WAP_SYS_ERROR');
  304. $this->book_info = $book_info;
  305. $this->cid = $cid;
  306. //下架图书不能看
  307. if ($this->isOffShelf()) {
  308. return response()->error('WAP_OFF_SHELF');
  309. }
  310. //获取章节信息
  311. $chapter = ChapterService::getChapterNameById($cid, $bid);
  312. $this->chapter = $chapter;
  313. //章节被删除
  314. if (($is_delete = $this->chapterNotExists())) {
  315. return response()->error('WAP_DOMAIN_NOT_MATCH', [
  316. 'url' => $is_delete
  317. ]);
  318. }
  319. //获取强关章节数
  320. $subscribe_seq = $this->getSubscribeChapterNum($book_info);
  321. //章节是否需要强关 TRUE:不需要,false:需要
  322. $force_subscribe = $subscribe_seq > $chapter->sequence;
  323. $this->is_need_subscribe = !$force_subscribe;
  324. //图书域名,book_configs表的promotion_domain 要跟当前的主机名匹配 在强关章节后
  325. if ($this->is_need_subscribe && $this->isVisitDomainEqualBookDomain($domain)) {
  326. return response()->error('WAP_DOMAIN_NOT_MATCH', [
  327. 'url' => $this->getCorrespondBookUrl()
  328. ]);
  329. }
  330. $user_info = $this->_user_info;
  331. $this->user = $user_info;
  332. //用户是否强关
  333. $this->is_had_subscribe = $is_had_subscribe = $inter_not_need_sub ? true : $this->getSubscribe();
  334. //阅读记录
  335. ReadRecordService::addReadRecord(['uid' => $this->uid, 'bid' => $bid, 'book_name' => $book_info->book_name,
  336. 'cid' => $cid, 'chapter_name' => $chapter->name]);
  337. //判断当前是否有强制显示服务号信息的cookie、已经关注 跳转到服务号信息引导页
  338. if($has_force_show_qrcode_cookie && $is_had_subscribe)
  339. {
  340. $force_read_url = '/subscribe/getFromUser';//服务号信息引导页
  341. $force_read_data = ['src' => $force_read_url];
  342. return response()->error('WAP_NOT_SUBSCRIBE', $force_read_data);
  343. }
  344. if ($force_subscribe || $chapter->is_vip == 0) {
  345. //vip前一张和枪管前一张的访问统计
  346. $this->beforeForceSubAndBeforeVipUvAndPv($book_info, $subscribe_seq, $chapter);
  347. }
  348. //不用关注且不是vip章节
  349. if ($force_subscribe && $chapter->is_vip == 0) {
  350. //获取公共号
  351. $officialAccount = $this->getOfficialAccount();
  352. $this->chapter->is_show_subscribe_link = 0;
  353. //非强关,但是设置了弱关,阅读页底部显示强关链接
  354. if ($officialAccount && isset($officialAccount->appid) && !empty($officialAccount->appid)) {
  355. $sub_type = $this->getSubscribeType($officialAccount->appid, $bid);
  356. if (in_array(2, $sub_type['type']) && !$is_had_subscribe) {
  357. $this->chapter->is_show_subscribe_link = 1;
  358. }
  359. }
  360. $this->getChapter();
  361. return response()->item(new ChapterTransformer, $this->chapter);
  362. }
  363. //需要强制关注 不是vip章节 已经关注了
  364. if (!$force_subscribe && $chapter->is_vip == 0 && $is_had_subscribe) {
  365. $this->getChapter();
  366. return response()->item(new ChapterTransformer, $this->chapter);
  367. }
  368. //需要强制关注 没关注
  369. if ((!$force_subscribe) && !$is_had_subscribe) {
  370. $force_data = $this->forceSubscribe();
  371. if ($force_data) {
  372. $this->subscribeStats();
  373. return response()->error($force_data['error_type'], $force_data['data']);
  374. }
  375. //取不到公众号则不用强关
  376. if ($chapter->is_vip == 0) {
  377. $this->getChapter();
  378. return response()->item(new ChapterTransformer, $this->chapter);
  379. }
  380. }
  381. //已经付费
  382. if ($this->getOrderRecord($bid, $cid)) {
  383. $this->getChapter();
  384. return response()->item(new ChapterTransformer, $this->chapter);
  385. }
  386. //获取价格
  387. $fee = $this->getPrice($book_info, $chapter);
  388. //广告
  389. if($this->isUserInAdSample() && $ad_status && $ad_status == 1 && $user_info->balance < $fee){
  390. $this->getChapter();
  391. //广告解锁2张
  392. if($this->chapter->next_cid){
  393. $next_chapter = ChapterService::getChapterNameById($this->chapter->next_cid, $bid);
  394. if($next_chapter){
  395. $next_chapter_name = $next_chapter->name;
  396. $this->bookOrderOrChapterOrder($book_info, $this->chapter->next_cid, 0, $next_chapter_name, 1);
  397. AdVisitStatService::create($this->uid,$this->book_info->bid,$this->chapter->next_cid,'UNLOCK_2');
  398. }
  399. }
  400. $this->chapter->is_show_ad = 0;
  401. $this->bookOrderOrChapterOrder($book_info, $cid, 0, $chapter->name, 1);
  402. return response()->item(new ChapterTransformer, $this->chapter);
  403. }
  404. //以上都是不用付费的情况******************************************************
  405. //未付费
  406. //返回的价格信息
  407. $data = [
  408. 'book_id' => $this->en_bid,
  409. 'book_name' => $book_info->book_name,
  410. 'chapter_name' => $chapter->name,
  411. 'chapter_id' => $cid,
  412. 'pay_type' => $book_info->charge_type,
  413. 'fee' => $fee,
  414. 'user_balance' => $user_info->balance,
  415. 'product_id' => $book_info->product_id,
  416. 'uid' => $this->uid,
  417. 'distribution_channel_id' => $this->distribution_channel_id,
  418. 'is_discount' => 0,
  419. 'discount_fee' => '',
  420. 'discount' => ''
  421. ];
  422. //余额不足 弹窗提醒
  423. if ($user_info['balance'] < $fee) {
  424. $this->smartPushTestBookPayPageUv($bid);
  425. //$this->sendOrderPayPageUv($bid);
  426. //除了单本订购 其他的都不提醒,直接跳转到充值页面
  427. if ($book_info->charge_type == 'CHAPTER') {
  428. return response()->error('WAP_CHAPTER_SECOND_BALANCE_PAY', $data);
  429. }
  430. //需要提箱
  431. if ($this->isOrderRemind($bid)) {
  432. return response()->error('WAP_BOOK_BALANCE_PAY', $data);
  433. } else {
  434. return response()->error('WAP_BOOK_SECOND_BALANCE_PAY', $data);
  435. }
  436. }
  437. //余额充足 单本弹窗提醒,章节直接扣费
  438. if ($this->isOrderRemind($bid) && $book_info->charge_type == 'BOOK') {
  439. return response()->error('WAP_BOOK_BUY', $data);
  440. }
  441. //付费 不提醒
  442. if ($this->balancePay($book_info, $chapter, 0)) {
  443. $this->getChapter();
  444. return response()->item(new ChapterTransformer, $this->chapter);
  445. } else {
  446. //付费 异常
  447. return response()->error('WAP_SYS_ERROR');
  448. }
  449. }
  450. /**
  451. * @apiVersion 1.0.0
  452. * @apiDescription 余额支付
  453. * @api {get} books/{bid}/balance/chapterOrders/{cid} 余额支付
  454. * @apiGroup Chapter
  455. * @apiName pay
  456. * @apiParam (Int) remind 提醒
  457. * @apiSuccess {int} code 状态码
  458. * @apiSuccess {String} msg 信息
  459. * @apiSuccess {object} data 结果集
  460. * @apiSuccess {Int} data.chapter_id 章节id
  461. * @apiSuccess {String} data.chapter_name 章节名称
  462. * @apiSuccess {Int} data.chapter_sequence 序号
  463. * @apiSuccess {Int} data.chapter_is_vip 是否vip
  464. * @apiSuccess {Int} data.chapter_size 章节大小
  465. * @apiSuccess {Int} data.prev_cid 上一章节id
  466. * @apiSuccess {Int} data.next_cid 下一章节
  467. * @apiSuccess {String} data.recent_update_at 更新时间
  468. * @apiSuccess {String} data.chapter_content 章节内容
  469. * @apiSuccess {Int} data.is_need_subscirbe 是否强制关注(删除)
  470. * @apiSuccessExample {json} Success-Response:
  471. * HTTP/1.1 200 OK
  472. * {
  473. * code: 0,
  474. * msg: "",
  475. * data: {
  476. * chapter_id: 5,
  477. * chapter_name: "第1240章 不是我",
  478. * chapter_sequence: 1239,
  479. * chapter_is_vip: 1,
  480. * chapter_size: 2422,
  481. * prev_cid: 0,
  482. * next_cid: 0,
  483. * recent_update_at: 2017-11-20 15:01:56,
  484. * chapter_content: "叶妩被司行霈的阴阳怪气一吓,思路偏得太远了。 她张口结舌,忘记了自己要说什么。",
  485. * }
  486. * }
  487. */
  488. public function pay(Request $request, $t, $domain, $bid, $cid)
  489. {
  490. if (!$this->checkUid()) {
  491. return response()->error('NOT_LOGIN');
  492. }
  493. $remind = (int)$request->input('remind');
  494. $this->en_bid = $bid;
  495. $oldbid = $bid;
  496. $bid = Hashids::decode($bid)[0];
  497. $book_info = BookConfigService::getBookById($bid);;
  498. if (empty($book_info)) response()->error('WAP_SYS_ERROR');
  499. //获取章节
  500. $chapter = ChapterService::getChapterNameById($cid, $bid);
  501. if (!$chapter) {
  502. return response()->error('WAP_SYS_ERROR');
  503. }
  504. $this->chapter = $chapter;
  505. $this->book_info = $book_info;
  506. $this->cid = $cid;
  507. if ($this->balancePay($book_info, $chapter, $remind)) {
  508. ReadRecordService::addReadRecord(['uid' => $this->uid, 'bid' => $bid, 'book_name' => $book_info->book_name,
  509. 'cid' => $cid, 'chapter_name' => $chapter->name]);
  510. $this->getChapter();
  511. return response()->item(new ChapterTransformer, $this->chapter);
  512. } else {
  513. $fee = $this->getPrice($book_info, $chapter);
  514. $data = [
  515. 'book_id' => $oldbid,
  516. 'book_name' => $book_info->book_name,
  517. 'chapter_name' => $chapter->name,
  518. 'chapter_id' => $cid,
  519. 'pay_type' => $book_info->charge_type,
  520. 'fee' => $fee,
  521. 'user_balance' => $this->_user_info['balance'],
  522. 'product_id' => $book_info->product_id,
  523. 'uid' => $this->uid,
  524. 'distribution_channel_id' => $this->distribution_channel_id,
  525. 'is_discount' => 0,
  526. 'discount_fee' => '',
  527. 'discount' => ''
  528. ];
  529. //不需要提醒
  530. if ($book_info->charge_type == 'BOOK') {
  531. return response()->error('WAP_BOOK_SECOND_BALANCE_PAY', $data);
  532. } elseif ($book_info->charge_type == 'CHAPTER') {
  533. return response()->error('WAP_CHAPTER_SECOND_BALANCE_PAY', $data);
  534. } else {
  535. return response()->error('WAP_SYS_ERROR');
  536. }
  537. }
  538. }
  539. /**
  540. * 余额支付
  541. * @param $book_info
  542. * @param $chapter_id
  543. * @param $chapter_size
  544. * @return bool
  545. */
  546. protected function balancePay($book_info, $chapter, $is_remind)
  547. {
  548. $fee = $this->getPrice($book_info, $chapter);
  549. if ((int)$this->_user_info['balance'] >= $fee) {
  550. if ($this->bookOrderOrChapterOrder($book_info, $chapter->id, $fee, $chapter->name, $is_remind)) {
  551. $this->chapterOrderStats($fee);
  552. if($this->user){
  553. $this->user->balance -= $fee;
  554. }
  555. return true;
  556. }
  557. }
  558. return false;
  559. }
  560. /**
  561. * 获取章节内容
  562. * @param $bid
  563. * @param $cid
  564. * @return bool|mixed
  565. */
  566. private function getChapter()
  567. {
  568. //初始化 默认字段
  569. $this->initChapterDefaultField();
  570. //章节内容
  571. $chapter_content = ChapterService::getChapter($this->book_info->bid, $this->cid);
  572. $this->chapter->content = str_replace($chapter_content->name, '', $chapter_content->content);
  573. //统计
  574. $this->chapterStats();
  575. //123特殊强关
  576. $this->specialSubscribeFlag();
  577. //签到奖励
  578. $this->sign();
  579. //#短篇推送长篇需求#
  580. //$this->shortPushLong();
  581. //#短推长、短推短对比
  582. $this->shortPushshort();
  583. //阅读器分享
  584. $this->share();
  585. //广告
  586. $this->isShowAd();
  587. //完整阅读纪录 阅读纪录
  588. $this->readRecordOther();
  589. }
  590. /**
  591. * 章节阅读接口需要配置返回的字段
  592. */
  593. private function initChapterDefaultField()
  594. {
  595. if (!$this->chapter) {
  596. return;
  597. }
  598. //内容
  599. $this->chapter->content = '';
  600. //签到默认字段
  601. $this->chapter->sign_days = 1;
  602. $this->chapter->sign_status = 0;
  603. $this->chapter->sign_reard = 0;
  604. //#短篇推送长篇需求#
  605. $this->chapter->next_jump = 0;
  606. $this->chapter->next_jump_url = '';
  607. $this->chapter->show_push_title = 0;
  608. $this->chapter->push_title_url = '';
  609. $this->chapter->push_title = [];
  610. //分享
  611. $this->chapter->is_show_share_button = 0;
  612. //阅读底部强关图片 只有123有
  613. $this->chapter->is_had_subscribe = 0;
  614. //广告
  615. $this->chapter->is_show_ad = 0;
  616. }
  617. private function sign()
  618. {
  619. //渠道123 未关注的签到放到强关前一章
  620. if ($this->distribution_channel_id == 123 && !$this->is_had_subscribe) {
  621. if ($this->book_info->force_subscribe_chapter_seq - 1 == $this->chapter->sequence) {
  622. $sign_status = $this->userSign($this->uid);
  623. //$sign_status = 0;
  624. $this->chapter->sign_status = $sign_status ? 1 : 0;
  625. $this->chapter->sign_reard = $sign_status;
  626. $this->chapter->sign_days = ReadRecordService::getSignCount($this->uid);
  627. }
  628. } else {
  629. $sign_status = $this->userSign($this->uid);
  630. //$sign_status =0;
  631. $this->chapter->sign_status = $sign_status ? 1 : 0;
  632. $this->chapter->sign_reard = $sign_status;
  633. $this->chapter->sign_days = ReadRecordService::getSignCount($this->uid);
  634. }
  635. }
  636. private function forceSubscribe()
  637. {
  638. //获取公众号信息
  639. $officialAccount = $this->getOfficialAccount();
  640. if (!$officialAccount || empty($officialAccount->appid)) {
  641. return false;
  642. }
  643. //如果是链接强关,则跳转
  644. $sub_type = $this->getSubscribeType($officialAccount->appid, $this->book_info->bid);
  645. if (in_array(3, $sub_type['type']) && $sub_type['url']) {
  646. return ['error_type' => 'WAP_LINK_SUBSCRIBE', 'data' => ['url' => $sub_type['url']]];
  647. }
  648. //普通强关
  649. if (in_array(1, $sub_type['type'])) {
  650. $src = $this->getRcodeInfo(['appid' => $officialAccount->appid], $this->book_info->bid);
  651. if (empty($src)) return false;
  652. if ($officialAccount->head_img) {
  653. $url = '/subscribe/qrcode?img=' . urlencode($src) . '&title=' . $officialAccount->nickname . '&head_img=' . urlencode($officialAccount->head_img) . '&uid=' . $this->uid;
  654. } else {
  655. $url = '/subscribe/qrcode?img=' . urlencode($src) . '&title=' . $officialAccount->nickname . '&uid=' . $this->uid;
  656. }
  657. return ['error_type' => 'WAP_NOT_SUBSCRIBE', 'data' => ['src' => $url, 'head_img' => $officialAccount->head_img]];
  658. }
  659. return false;
  660. }
  661. private function getOfficialAccountForceReadNotice()
  662. {
  663. }
  664. //强关页面的统计
  665. private function subscribeStats()
  666. {
  667. if ($this->send_order_id) {
  668. //$this->sendOrderSubscribePageUv($this->book_info->bid);
  669. //强关页面的uv
  670. /*try {
  671. Redis::sadd('subscribe_page_uv' . $this->send_order_id, $this->uid);
  672. Redis::sadd('subscribe_page_uv_send_order_ids', $this->send_order_id);
  673. } catch (\Exception $e) {
  674. }*/
  675. }
  676. }
  677. /**
  678. * 短推长
  679. */
  680. private function shortPushLong()
  681. {
  682. if ($this->book_info->charge_type = 'CHAPTER') return;
  683. $is_has_book_order = BookOrderService::isHasBookOrder($this->uid);
  684. if ($this->chapter->is_vip && $is_has_book_order) {
  685. $this->chapter->show_push_title = 1;
  686. $this->chapter->push_title = DataAnalysisBookConfig::getUserReaderPagePushBook($this->uid, $this->distribution_channel_id);
  687. }
  688. if (!$this->chapter->next_cid && $is_has_book_order) {
  689. $link = DataAnalysisBookConfig::getUserReaderPagePushBook($this->uid, $this->distribution_channel_id, 1);
  690. if ($link && isset($link['link']) && !empty($link['link'])) {
  691. $this->chapter->next_jump = 1;
  692. $this->chapter->next_jump_url = $link['link'];
  693. }
  694. }
  695. }
  696. /**
  697. * 短推长、短推短对比需求
  698. * 目标用户:全站短篇进入新注册且订阅短篇的付费用户
  699. * 方式:根据uid奇偶取用,奇:测试用户1 偶:测试用户2
  700. * 测试用户1:底部链接+完本推荐 均使用短篇小说
  701. * 测试用户2:底部链接+完本推荐 均使用长篇小说
  702. * 目标用户:全站短篇进入新注册且订阅短篇的付费用户
  703. */
  704. private function shortPushshort()
  705. {
  706. //新用户 注册时间大于某个值
  707. if(!$this->user){
  708. return ;
  709. }
  710. if(!env('SHORT_PUSH_SHORT_START_TIME') || strtotime($this->user->created_at) < env('SHORT_PUSH_SHORT_START_TIME')){
  711. return ;
  712. }
  713. //没有派单
  714. if(!$this->user->send_order_id) return ;
  715. //只在vip章节底部显示
  716. if(!$this->chapter->is_vip){
  717. return ;
  718. }
  719. //强关
  720. if(!$this->is_had_subscribe){
  721. return ;
  722. }
  723. //短篇进入
  724. $send_order_info = SendOrderService::getById($this->user->send_order_id);
  725. if(!$send_order_info || $send_order_info->charge_type != 'BOOK'){
  726. return ;
  727. }
  728. //订阅短篇的付费用户
  729. $is_has_book_order = BookOrderService::isHasBookOrder($this->uid);
  730. if(!$is_has_book_order) return ;
  731. //是否付费用户
  732. if(!OrderService::isPaidUser($this->uid)) return ;
  733. $type = $this->uid %2 == 1? 'BOOK':'CHAPTER';
  734. $result = DataAnalysisSelectUserService::create($this->uid, $this->distribution_channel_id, $type, 500, $attach = 'short2s2l');
  735. if(!$result) return ;
  736. //底部链接
  737. $this->chapter->show_push_title = 1;
  738. $this->chapter->push_title = DataAnalysisBookConfig::getUserReaderPagePushBookV2($this->uid, $this->distribution_channel_id,$type);
  739. //完本推荐
  740. if (!$this->chapter->next_cid ) {
  741. $link = DataAnalysisBookConfig::getUserReaderPagePushBookV2($this->uid, $this->distribution_channel_id,$type, 1);
  742. if($link && $link['link']){
  743. $this->chapter->next_jump = 1;
  744. $this->chapter->next_jump_url = $link['link'];
  745. }
  746. }
  747. }
  748. private function share()
  749. {
  750. if ($this->is_had_subscribe && in_array($this->distribution_channel_id, [2, 14, 211,4025,4147,691,123]) && $this->user) {//,4147,691,123,4025
  751. $this->chapter->is_show_share_button = 1;
  752. }
  753. }
  754. /**
  755. * 123 渠道阅读底部强关图片
  756. */
  757. private function specialSubscribeFlag()
  758. {
  759. if ($this->distribution_channel_id == 123 && !$this->is_had_subscribe) {
  760. $this->chapter->is_had_subscribe = 1;
  761. }
  762. }
  763. //订阅统计
  764. private function chapterOrderStats($fee)
  765. {
  766. $day = date('Y--m-d');
  767. try {
  768. Redis::hincrby('wap:chapterandbookorder:bid:' . $this->book_info->bid, $day, $fee);
  769. } catch (\Exception $e) {
  770. }
  771. $this->smartPushTestBook($this->book_info->bid, $fee);
  772. $specialChannelIdStats = env('SPECIAL_CHANNEL_STATS', 211);
  773. if (in_array($this->distribution_channel_id, explode(',', $specialChannelIdStats))) {
  774. WapVisitStatService::specialChannelIdStatsSave($this->uid, $this->book_info->bid, $fee);
  775. }
  776. }
  777. /**
  778. * 签到
  779. * @param $uid
  780. * @return int
  781. */
  782. protected function userSign($uid)
  783. {
  784. if (UserSignService::isSign($uid)) {
  785. //签过到了
  786. return 0;
  787. }
  788. if ($res = UserSignService::signToday($uid)) {
  789. //$sign_key = 'leyuee:wap:usersigni';
  790. //Redis::hset($sign_key, $uid, $res);
  791. return $res;
  792. }
  793. return 0;
  794. }
  795. /**
  796. * 添加订购记录
  797. * @param $book_info
  798. * @param $chapter_id
  799. * @param $fee
  800. * @return bool
  801. */
  802. protected function bookOrderOrChapterOrder($book_info, $chapter_id, $fee, $chapter_name, $is_remind)
  803. {
  804. if ($book_info['charge_type'] == 'BOOK') {
  805. $data = [
  806. 'uid' => $this->uid,
  807. 'fee' => $fee,
  808. 'u' => Cookie::get('send_order_id'),
  809. 'distribution_channel_id' => $this->distribution_channel_id,
  810. 'bid' => $book_info->bid,
  811. 'book_name' => $book_info->book_name,
  812. 'send_order_id' => Cookie::get('send_order_id') ? Cookie::get('send_order_id') : 0,
  813. ];
  814. return BookOrderService::addOrderRecodeAndDecrUserBalance($data, $this->uid);
  815. } else {
  816. $data = [
  817. 'uid' => $this->uid,
  818. 'fee' => $fee,
  819. 'cid' => $chapter_id,
  820. 'bid' => $book_info->bid,
  821. 'distribution_channel_id' => $this->distribution_channel_id,
  822. 'book_name' => $book_info->book_name,
  823. 'chapter_name' => $chapter_name,
  824. 'send_order_id' => Cookie::get('send_order_id') ? Cookie::get('send_order_id') : 0,
  825. 'is_remind' => $is_remind
  826. ];
  827. //print_r($data);
  828. if ($is_remind) {
  829. $this->addOrderRemind($book_info->bid);
  830. }
  831. return ChapterOrderService::addOrderAndDecrUserBalance($data, $this->uid);
  832. }
  833. }
  834. protected function addOrderRemind($bid)
  835. {
  836. if (ChapterReminderService::checkIsNoReminder($this->uid, $bid)) {
  837. return true;
  838. } else {
  839. ChapterReminderService::add($this->uid, $bid);
  840. return true;
  841. }
  842. }
  843. /**
  844. * 是否订购提醒
  845. * @param $chapter_id
  846. * @return bool
  847. */
  848. protected function isOrderRemind($bid)
  849. {
  850. $is_no_reminder = ChapterReminderService::checkIsNoReminder($this->uid, $bid) ? 1 : 0;
  851. return $is_no_reminder == 0;
  852. }
  853. /**
  854. * 用户是否关注
  855. * @param $uid
  856. * @return bool
  857. */
  858. protected function getSubscribe()
  859. {
  860. $res = ForceSubscribeService::forceSubscribeUsersByUid(['uid' => $this->uid]);
  861. if ($res) {
  862. $this->force_subscribe_time = isset($res->created_at)?$res->created_at:null;
  863. return true;
  864. }
  865. return false;
  866. }
  867. /**
  868. * 获取公众号信息
  869. * @param $distribution_channel_id
  870. */
  871. protected function getOfficialAccount()
  872. {
  873. $distribution_channel_id = $this->distribution_channel_id;
  874. $res = OfficialAccountService::canUseOfficialAccountByChannelId(compact('distribution_channel_id'));
  875. if (isset($res->nickname) && !empty($res->nickname)) {
  876. Cookie::queue('force_subscribe_name', $res->nickname, env('U_COOKIE_EXPIRE'));
  877. }
  878. return $res;
  879. }
  880. /**
  881. * 获取二维码
  882. * @param $param
  883. * @return bool
  884. */
  885. private function getRcodeInfo($param, $bid)
  886. {
  887. //return "https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=gQGI8DwAAAAAAAAAAS5odHRwOi8vd2VpeGluLnFxLmNvbS9xLzAyZEZ0T0ZoSHljM2kxOTUwQU5zY08AAgRF8-xbAwQAjScA";
  888. $param_need = [
  889. 'gzh_app_id' => $param['appid'],
  890. 'scene_id' => $this->uid,
  891. 'timestamp' => time(),
  892. ];
  893. $param_need['sign'] = $this->getSign($param_need);
  894. $client = new Client(['timeout' => 3.0,]);
  895. try {
  896. Log::info('get qrcode url is:' . 'https://zsyauth.aizhuishu.com/api/get_qrcode_url?' . http_build_query($param_need));
  897. $qrcode_url_res = $client->request('get', 'https://zsyauth.aizhuishu.com/api/get_qrcode_url?' . http_build_query($param_need))->getBody()->getContents();
  898. if ($qrcode_url_res) {
  899. $qrcode_url = json_decode($qrcode_url_res, true);
  900. if ($qrcode_url['code'] == 1) {
  901. //保存强关时的bid
  902. if (isset($qrcode_url['data']) && !empty($qrcode_url['data'])) {
  903. Redis::hset('force_subscribe_from_bid', $param['appid'] . '_' . $this->uid, $bid);
  904. $send_order_id = Cookie::get('send_order_id') ? Cookie::get('send_order_id') : 0;
  905. Redis::hset('force_subscribe_from_send_order_id', $param['appid'] . '_' . $this->uid, $send_order_id);
  906. Log::info('uid is' . $this->uid . '--qrcode is:' . $qrcode_url['data']);
  907. return $qrcode_url['data'];
  908. }
  909. }
  910. }
  911. } catch (\Exception $e) {
  912. //\Log::info($e);
  913. //Redis::sadd('force_subscribe_qrcode:error', $param['appid'] . '_' . time());
  914. }
  915. return false;
  916. }
  917. /**
  918. * 获取订购记录
  919. * @param $book_info
  920. * @param $chapter_id
  921. * @return bool
  922. */
  923. private function getOrderRecord($bid, $chapter_id)
  924. {
  925. //包年记录
  926. $uid = $this->uid;
  927. $res = YearOrderService::getRecord($uid);
  928. if ($res) return true;
  929. $res = null;
  930. //单本订购记录
  931. $res = BookOrderService::getRecordByuidBid($uid, $bid);
  932. if ($res) return true;
  933. $res = null;
  934. //章节订购记录
  935. $chapterOrder = new ChapterOrderService();
  936. if ($chapterOrder->checkIsOrdered($uid, $bid, $chapter_id)) return true;
  937. return false;
  938. }
  939. /**
  940. * 计算价格
  941. * @param $book_info
  942. * @param $chapter_size
  943. * @return float
  944. */
  945. private function getPrice($book_info, $chapter)
  946. {
  947. if ($book_info->charge_type == 'BOOK') {
  948. $fee = $book_info->price * 100;
  949. } else {
  950. //$fee = ceil($chapter->size/100);
  951. //$channel_fee = BookService::getChapterPrice()
  952. $channel_fee = BookService::getChapterPrice($this->distribution_channel_id);
  953. if ($channel_fee) {
  954. $price_rate = $channel_fee / 100;
  955. } else {
  956. //$price_rate = 0.012;
  957. $price_rate = env('DEFAULT_CHAPTER_PRICE', 0.015);
  958. }
  959. //Log::info($price_rate);
  960. $fee = ceil($chapter->size * $price_rate);
  961. /*if($this->isRaisePrice()){
  962. $fee = round($chapter->size * 0.018);
  963. }*/
  964. }
  965. //首个计费章节书币价格以35书币为基准,低于35提升至35,原价高于35书币,维持原价
  966. if (isset($chapter->sequence) && isset($book_info->vip_seq)) {
  967. if ($chapter->sequence == $book_info->vip_seq) {
  968. if ($fee < 35) {
  969. $fee = 35;
  970. }
  971. }
  972. }
  973. return $fee;
  974. }
  975. //降低付费用户书币价值
  976. private function isRaisePrice(){
  977. if(!$this->uid)
  978. return false;
  979. if(!$this->user)
  980. return false;
  981. if($this->user->balance < 100){
  982. return false;
  983. }
  984. if(!in_array($this->distribution_channel_id,[211,123])){
  985. return false;
  986. }
  987. if(DataAnalysisSelectUserService::getByUidAndType($this->uid,'RAISE')){
  988. return true;
  989. }
  990. return false;
  991. }
  992. /**
  993. * 获取强关章节数
  994. * @param $book
  995. * @return int
  996. */
  997. private function getSubscribeChapterNum($book)
  998. {
  999. //派单强关
  1000. if ($this->send_order_id) {
  1001. $send_order_info = SendOrderService::getById($this->send_order_id);
  1002. if ($send_order_info && $send_order_info->book_id == $book->bid && $send_order_info->subscribe_chapter_seq) {
  1003. return $send_order_info->subscribe_chapter_seq;
  1004. }
  1005. }
  1006. $subscribe = BookSubscribleChapterService::getSubcribleChapter($book->bid, $this->distribution_channel_id);
  1007. if ($subscribe) {
  1008. return (isset($subscribe->subscribe_chapter_id) && $subscribe->subscribe_chapter_id > 0) ? $subscribe->subscribe_chapter_id : $book->force_subscribe_chapter_seq;
  1009. }
  1010. return $book->force_subscribe_chapter_seq;
  1011. }
  1012. /**
  1013. * 判断访问的域名和数据库指定的域名是否一致,一致返回false ,不一致 true
  1014. * @param $domain 当前访问的doain
  1015. * @return bool
  1016. */
  1017. private function isVisitDomainEqualBookDomain($domain)
  1018. {
  1019. if ($domain == 'zhuishuyun' && stripos($this->book_info->promotion_domain, 'leyuee') !== false) {
  1020. return false;
  1021. }
  1022. return stripos($this->book_info->promotion_domain, $domain) === false;
  1023. }
  1024. //获取对当前图书对应域名的链接
  1025. private function getCorrespondBookUrl()
  1026. {
  1027. $url = sprintf(
  1028. 'https://site%s.%s/reader?bid=%s&cid=%s&send_order_id=%s&fromtype=%s&stats=2',
  1029. $this->en_distribution_channel_id,
  1030. $this->book_info->promotion_domain,
  1031. $this->en_bid,
  1032. $this->cid,
  1033. $this->send_order_id,
  1034. $this->from_type
  1035. );
  1036. return $url;
  1037. }
  1038. /**
  1039. * 用户添加标签
  1040. * @param $book_info
  1041. */
  1042. private function addTag($book_info)
  1043. {
  1044. if (!UserDeepReadTagService::isAddTag($this->uid, $book_info->bid)) {
  1045. try {
  1046. UserDeepReadTagService::addTag([
  1047. 'uid' => $this->uid,
  1048. 'bid' => $book_info->bid,
  1049. 'book_name' => $book_info->book_name,
  1050. 'category_id' => $book_info->category_id,
  1051. 'category_name' => $book_info->category_name,
  1052. 'sex_preference' => $book_info->channel_name ? $book_info->channel_name : '',
  1053. 'distribution_channel_id' => $this->distribution_channel_id ? $this->distribution_channel_id : '0',
  1054. 'send_order_id' => Cookie::get('send_order_id') ? Cookie::get('send_order_id') : 0,
  1055. ]);
  1056. } catch (\Exception $e) {
  1057. }
  1058. }
  1059. }
  1060. private function newUserRewardRead()
  1061. {
  1062. $count = ChapterOrderService::getUserRecordCount($this->uid);
  1063. return $count > 2;
  1064. }
  1065. private function isBookOrdered($bid)
  1066. {
  1067. $chapter_order = ChapterOrderService::checkBookIsOrdered($this->uid, $bid);
  1068. if ($chapter_order) return true;
  1069. $res = BookOrderService::getRecordByuidBid($this->uid, $bid);
  1070. if ($res) return true;
  1071. return false;
  1072. }
  1073. private function beforeForceSubAndBeforeVipUvAndPv($book, $book_force_seq, $chapter)
  1074. {
  1075. $send_order_id = Cookie::get('send_order_id') ? Cookie::get('send_order_id') : 14;
  1076. $prev_sub_seq = 0;
  1077. if ($book_force_seq) {
  1078. $prev_sub_seq = $book_force_seq - 1;
  1079. }
  1080. $prev_vip_seq = 0;
  1081. $date = date('Y-m-d');
  1082. if (isset($book->vip_seq) && !empty($book->vip_seq)) {
  1083. $prev_vip_seq = $book->vip_seq - 1;
  1084. }
  1085. if ($chapter->sequence == $prev_vip_seq) {
  1086. $uv_key = 'book:' . $book->bid . ':beforevip:uv:date:' . $date . ':send_order_id:' . $send_order_id;
  1087. $pv_key = 'book:' . $book->bid . ':beforevip:pv:send_order_id:' . $send_order_id;
  1088. Redis::hincrby($pv_key, $date, 1);
  1089. Redis::hincrby($pv_key, 'total', 1);
  1090. Redis::sadd($uv_key, $this->uid);
  1091. Redis::sadd('beforevip' . $date, $book->bid . '-' . $send_order_id);
  1092. }
  1093. if ($chapter->sequence == $prev_sub_seq) {
  1094. $uv_key = 'book:' . $book->bid . ':beforeforcesub:uv:date:' . $date . ':send_order_id:' . $send_order_id;
  1095. $pv_key = 'book:' . $book->bid . ':beforeforcesub::pvsend_order_id:' . $send_order_id;
  1096. Redis::hincrby($pv_key, $date, 1);
  1097. Redis::hincrby($pv_key, 'total', 1);
  1098. Redis::sadd($uv_key, $this->uid);
  1099. Redis::sadd('beforeforcesub' . $date, $book->bid . '-' . $send_order_id);
  1100. }
  1101. }
  1102. private function readRecordOther()
  1103. {
  1104. $bid = $this->book_info->bid;
  1105. $cid = $this->cid;
  1106. $distribution_channel_id = $this->distribution_channel_id;
  1107. $send_order_id = $this->send_order_id;
  1108. $from = $this->from_type;
  1109. $sequence = $this->chapter->sequence;
  1110. ReadRecordStatsService::record($this->uid,$bid,$cid,$distribution_channel_id,$send_order_id,$from,$sequence);
  1111. /*$chapter = $this->chapter;
  1112. try {
  1113. $data = [];
  1114. $data['uid'] = $this->uid;
  1115. $data['bid'] = $chapter->bid;
  1116. $data['cid'] = $chapter->id;
  1117. $data['is_vip'] = $chapter->is_vip;
  1118. $data['seq'] = $chapter->sequence;
  1119. $data['created_at'] = date('Y-m-d H:i:s');
  1120. $data['updated_at'] = date('Y-m-d H:i:s');
  1121. DB::table('read_records')->insert($data);
  1122. } catch (\Exception $e) {
  1123. }*/
  1124. }
  1125. /**
  1126. * 下架图书 true:下架不能阅读了, false:可以正常阅读
  1127. * @return bool
  1128. */
  1129. private function isOffShelf()
  1130. {
  1131. $book_info = $this->book_info;
  1132. if ($book_info->is_on_shelf == 0 || $book_info->is_on_shelf == 3) {
  1133. return true;
  1134. }
  1135. //屏蔽一本书1042 2626
  1136. if (in_array($book_info->bid, [1042, 2626]) && $this->distribution_channel_id == 123) {
  1137. return true;
  1138. }
  1139. if ($book_info->is_on_shelf == 4) {
  1140. //版权到期,有阅读记录还可以继续阅读,订购
  1141. /*if (!ReadRecordService::getRecordByUidBid($this->uid, $book_info->bid)) {
  1142. return true;
  1143. }*/
  1144. //版权到期,有包年可以继续阅读
  1145. $year_order = YearOrderService::getRecord($this->uid);
  1146. if($year_order){
  1147. return false;
  1148. }
  1149. //版权到期,有订购记录还可以继续阅读,订购
  1150. $chapter_order = ChapterOrderService::checkBookIsOrdered($this->uid, $book_info->bid);
  1151. if (!$chapter_order) return true;
  1152. }
  1153. if($book_info->is_on_shelf == 10){
  1154. //Log::info('ddddddddddddddddddddddddddd');
  1155. $yq_book_user = BookUserService::selectUser($this->uid);
  1156. //Log::info($yq_book_user);
  1157. if($yq_book_user && $yq_book_user->type == 'ENABLE'){
  1158. return false;
  1159. }
  1160. return true;
  1161. }
  1162. return false;
  1163. }
  1164. //章节被删除的情况
  1165. private function chapterNotExists()
  1166. {
  1167. $chapter = $this->chapter;
  1168. $cid = $this->cid;
  1169. if ($chapter) return false;
  1170. //章节不存在的情况
  1171. $no_check = ChapterService::getChapterNameByIdNoCheck($cid);
  1172. $h5_scheme = 'https';
  1173. if (!$no_check) {
  1174. //章节真正不存在的情况
  1175. $url = $h5_scheme . '://' . _domain() . '/catalog?id=' . $this->en_bid;
  1176. return $url;
  1177. }
  1178. //章节被删除的情况
  1179. if ($no_check->next_cid) {
  1180. $url = $h5_scheme . '://' . _domain() . '/reader?bid=' . $this->en_bid . '&cid=' . $no_check->next_cid;
  1181. return $url;
  1182. }
  1183. //章节被删除的是最后一章的情况
  1184. $url = $h5_scheme . '://' . _domain() . '/catalog?id=' . $this->en_bid . '&sequence=' . $no_check->sequence;
  1185. return $url;
  1186. }
  1187. /**
  1188. * 深度阅读
  1189. * @param $chapter
  1190. */
  1191. private function deepReadRecord()
  1192. {
  1193. if (!env('ON_BOOK_UV_PV', false)) {
  1194. return;
  1195. }
  1196. $chapter = $this->chapter;
  1197. $key = 'book:' . $chapter->bid . ':deepread:uv';
  1198. $chapter_key = 'book:' . $chapter->bid . ':chapterseq:' . $chapter->sequence;
  1199. if (Redis::scard($key) > 50000) {
  1200. if (Redis::Sismember($key, $this->uid)) {
  1201. Redis::sadd($chapter_key, $this->uid);
  1202. }
  1203. } else {
  1204. Redis::sadd($key, $this->uid);
  1205. Redis::sadd($chapter_key, $this->uid);
  1206. }
  1207. }
  1208. /**
  1209. * 强关类型
  1210. * @param $appid
  1211. * @return array
  1212. */
  1213. private function getSubscribeType($appid, $bid)
  1214. {
  1215. $send_order_id = Cookie::get('send_order_id') ? Cookie::get('send_order_id') : 0;
  1216. $sub_setting = ChannelSubscribeSettingService::getSubscribeTypeByAppId($appid);
  1217. if (!$sub_setting) return ['type' => [1], 'url' => ''];
  1218. $types = explode(',', $sub_setting->force_subscribe_type);
  1219. $url = '';
  1220. if (in_array(3, $types) && !empty($sub_setting->resource_url)) {
  1221. $h5_scheme = env('H5_SCHEME', 'https');
  1222. $url = $h5_scheme . '://' . _domain() . '/subscribeauth/?uid=' . $this->uid . '&distribution_channel_id=' . $this->distribution_channel_id . '&appid=' . $appid . '&bid=' . $bid . '&send_order_id=' . $send_order_id;
  1223. }
  1224. return ['type' => $types, 'url' => $url];
  1225. }
  1226. private function showChapterPrice($bid, $charge_type)
  1227. {
  1228. if ($charge_type == 'BOOK') {
  1229. return false;
  1230. }
  1231. $show_chapter_price_bid = env('SHOW_CHAPTER_PRICE_BID', 'all');
  1232. if ($show_chapter_price_bid != 'all') {
  1233. $show_chapter_price_bid_array = explode(',', $show_chapter_price_bid);
  1234. if (!in_array($bid, $show_chapter_price_bid_array)) {
  1235. return false;
  1236. }
  1237. }
  1238. $show_chapter_price_channel = env('SHOW_CHAPTER_PRICE_CHANNEL', '');
  1239. if (!$show_chapter_price_channel) {
  1240. return false;
  1241. }
  1242. if ($show_chapter_price_channel == 'all') {
  1243. return true;
  1244. }
  1245. $show_chapter_price_channel_array = explode(',', $show_chapter_price_channel);
  1246. if (in_array($this->distribution_channel_id, $show_chapter_price_channel_array)) {
  1247. return true;
  1248. }
  1249. return false;
  1250. }
  1251. /**
  1252. * 阅读统计
  1253. */
  1254. private function chapterStats()
  1255. {
  1256. $chapter = $this->chapter;
  1257. $bid = $this->book_info->bid;
  1258. //派单精确统计
  1259. if ($chapter->sequence <= 30) {
  1260. //$this->sendOrderChapterUv($bid, $chapter->sequence);
  1261. }
  1262. //智能推送 测书统计章节uv
  1263. if ($chapter->sequence <= 60) {
  1264. //测书数据 由30改到60 2018-11-26 18:00
  1265. $this->smartPushTestBookChapterUv($bid, $chapter->sequence);
  1266. }
  1267. //智能推送 测书统计第二章 uv
  1268. if ($chapter->sequence == 2) {
  1269. $this->smartPushTestBookSecondChapterUv($bid);
  1270. }
  1271. // 统计前5张uv 会放在book_five_chapter_uv表中,脚本在 \App\Console\Commands\BookTest::data1里面
  1272. // 作用早忘记了
  1273. $field = date('Y-m-d');
  1274. /*
  1275. if ($chapter->sequence <= 5 && $this->send_order_id) {
  1276. try {
  1277. Redis::sadd(sprintf('book_before_five_uv_%s_%s_%s', $field, $bid, $chapter->sequence), $this->uid);
  1278. Redis::sadd('book_before_five_uvs', sprintf('%s_%s_%s', $field, $bid, $chapter->sequence));
  1279. } catch (\Exception $e) {
  1280. }
  1281. }*/
  1282. //统计点击率
  1283. $key = 'book_click_num_bid_' . $bid;
  1284. try {
  1285. Redis::HINCRBY($key, $field, 1);
  1286. } catch (\Exception $e) {
  1287. }
  1288. //阅读页面pvuv
  1289. $this->recordReaderUvAndPv();
  1290. }
  1291. private function smartPushTestBook($bid, $balance)
  1292. {
  1293. $smart_bid = ReadRecordService::getSmartPush($this->uid);
  1294. if ($smart_bid && in_array($bid, $smart_bid)) {
  1295. $field = sprintf('%s_amount', $bid);
  1296. try {
  1297. Redis::HINCRBY('smart_push_test_book', $field, $balance);
  1298. Redis::sadd('smart_push_test_book_user_count' . $bid, $this->uid);
  1299. } catch (\Exception $e) {
  1300. }
  1301. }
  1302. }
  1303. private function smartPushTestBookSecondChapterUv($bid)
  1304. {
  1305. $smart_bid = ReadRecordService::getSmartPush($this->uid);
  1306. if ($smart_bid && in_array($bid, $smart_bid)) {
  1307. try {
  1308. Redis::sadd('smart_push_test_book_second_uv' . $bid, $this->uid);
  1309. } catch (\Exception $e) {
  1310. }
  1311. }
  1312. }
  1313. private function smartPushTestBookChapterUv($bid, $sequence)
  1314. {
  1315. $smart_bid = ReadRecordService::getSmartPush($this->uid);
  1316. if ($smart_bid && in_array($bid, $smart_bid)) {
  1317. try {
  1318. $key = 'smartPushTestBookChapterUv:bid:%s:seq:%s';
  1319. Redis::sadd(sprintf($key, $bid, $sequence), $this->uid);
  1320. } catch (\Exception $e) {
  1321. }
  1322. }
  1323. }
  1324. /**
  1325. * 测书 智能推送统计
  1326. * @param $bid
  1327. */
  1328. private function smartPushTestBookPayPageUv($bid)
  1329. {
  1330. $smart_bid = ReadRecordService::getSmartPush($this->uid);
  1331. if ($smart_bid && in_array($bid, $smart_bid)) {
  1332. try {
  1333. $key = 'smartPushTestBookPayPageUv:bid:%s';
  1334. Redis::sadd(sprintf($key, $bid), $this->uid);
  1335. } catch (\Exception $e) {
  1336. }
  1337. }
  1338. }
  1339. /**
  1340. * 派单精确统计--章节
  1341. * @param $bid
  1342. * @param $sequence
  1343. */
  1344. private function sendOrderChapterUv($bid, $sequence)
  1345. {
  1346. if ($this->send_order_id) {
  1347. $send_order_bid = Redis::hget('sendOrderIdToBid', $this->send_order_id);
  1348. if (!$send_order_bid) {
  1349. $send_order_info = SendOrderService::getById($this->send_order_id);
  1350. if ($send_order_info) {
  1351. $send_order_bid = $send_order_info->book_id;
  1352. Redis::hset('sendOrderIdToBid', $this->send_order_id, $send_order_bid . '-' . time());
  1353. }
  1354. } else {
  1355. $send_order_bid_arr = explode('-', $send_order_bid);
  1356. $send_order_bid = $send_order_bid_arr[0];
  1357. }
  1358. if ($send_order_bid && $send_order_bid == $bid) {
  1359. try {
  1360. $key = 'accurateSendOrderChapterUv:bid:%s:seq:%s:sendorderid:' . $this->send_order_id;
  1361. Redis::sadd(sprintf($key, $bid, $sequence), $this->uid);
  1362. } catch (\Exception $e) {
  1363. }
  1364. }
  1365. }
  1366. }
  1367. /**
  1368. * 派单精确统计--强关页面uv
  1369. * @param $bid
  1370. */
  1371. private function sendOrderSubscribePageUv($bid)
  1372. {
  1373. if ($this->send_order_id) {
  1374. $send_order_bid = Redis::hget('sendOrderIdToBid', $this->send_order_id);
  1375. if (!$send_order_bid) {
  1376. $send_order_info = SendOrderService::getById($this->send_order_id);
  1377. if ($send_order_info) {
  1378. $send_order_bid = $send_order_info->book_id;
  1379. Redis::hset('sendOrderIdToBid', $this->send_order_id, $send_order_bid . '-' . time());
  1380. }
  1381. } else {
  1382. $send_order_bid_arr = explode('-', $send_order_bid);
  1383. $send_order_bid = $send_order_bid_arr[0];
  1384. }
  1385. if ($send_order_bid && $send_order_bid == $bid) {
  1386. try {
  1387. $key = 'accurateSendOrderSubscribePageUv:bid:%s:sendorderid:' . $this->send_order_id;
  1388. Redis::sadd(sprintf($key, $bid), $this->uid);
  1389. } catch (\Exception $e) {
  1390. }
  1391. }
  1392. }
  1393. }
  1394. /**
  1395. * 派单精确统计--支付页面uv
  1396. * @param $bid
  1397. */
  1398. private function sendOrderPayPageUv($bid)
  1399. {
  1400. if ($this->send_order_id) {
  1401. $send_order_bid = Redis::hget('sendOrderIdToBid', $this->send_order_id);
  1402. if (!$send_order_bid) {
  1403. $send_order_info = SendOrderService::getById($this->send_order_id);
  1404. if ($send_order_info) {
  1405. $send_order_bid = $send_order_info->book_id;
  1406. Redis::hset('sendOrderIdToBid', $this->send_order_id, $send_order_bid . '-' . time());
  1407. }
  1408. } else {
  1409. $send_order_bid_arr = explode('-', $send_order_bid);
  1410. $send_order_bid = $send_order_bid_arr[0];
  1411. }
  1412. if ($send_order_bid && $send_order_bid == $bid) {
  1413. try {
  1414. $key = 'accurateSendOrderPayPageUv:bid:%s:send_order_id:' . $this->send_order_id;
  1415. Redis::sadd(sprintf($key, $bid), $this->uid);
  1416. } catch (\Exception $e) {
  1417. }
  1418. }
  1419. }
  1420. }
  1421. private function recordReaderUvAndPv()
  1422. {
  1423. WapVisitStatService::recordReaderUvAndPv($this->uid, $this->distribution_channel_id);
  1424. }
  1425. //用户是否在广告样本中
  1426. private function isUserInAdSample(){
  1427. $res = DataAnalysisSelectUserService::getByUidAndType($this->uid,'AD');
  1428. if($res){
  1429. return true;
  1430. }else{
  1431. return false;
  1432. }
  1433. }
  1434. //阅读页面底部是否显示广告
  1435. private function isShowAd(){
  1436. $ad_status = env('AD_STATUS',1);
  1437. if(!$ad_status){
  1438. return ;
  1439. }
  1440. if(!in_array($this->distribution_channel_id,[2,14,123,211])){
  1441. return ;
  1442. }
  1443. //按章付费才显示
  1444. if($this->book_info->charge_type != 'CHAPTER'){
  1445. return ;
  1446. }
  1447. //用户是否在广告样本中
  1448. if(!$this->isUserInAdSample()) return ;
  1449. $cid = 0;
  1450. if($this->chapter && $this->chapter->next_cid){
  1451. $cid = $this->chapter->next_cid;
  1452. }
  1453. if(!$cid){
  1454. return ;
  1455. }
  1456. //付费用户没有广告
  1457. if(OrderService::isPaidUser($this->uid)) return ;
  1458. //如果下一张已经付费,广告不显示
  1459. if($this->getOrderRecord($this->book_info->bid, $cid)){
  1460. return ;
  1461. }
  1462. $next_chapter = ChapterService::getChapterNameById($cid, $this->book_info->bid);
  1463. //下一章事vip的话 才显示广告
  1464. if(!$next_chapter || !$next_chapter->is_vip){
  1465. return ;
  1466. }
  1467. $price = $this->getPrice($this->book_info,$next_chapter);
  1468. $flag = $price > $this->user->balance;
  1469. if( $flag ){
  1470. $this->chapter->is_show_ad = 1;
  1471. AdVisitStatService::create($this->uid,$this->book_info->bid,$this->cid,'EXPOSURE');
  1472. }
  1473. }
  1474. public function getWechatJsConfig(Request $request)
  1475. {
  1476. //try {
  1477. // $chapter->is_show_share_button = 1;
  1478. $bid = $request->input('bid', '');
  1479. $cid = $request->input('cid', '');
  1480. $url = $request->input('url', '');
  1481. $url = urldecode($url);
  1482. \Log::info('url:' . ($this->uid) . $url);
  1483. if (empty($bid) || empty($cid) || empty($url)) {
  1484. return response()->error('PARAM_EMPTY');
  1485. }
  1486. $share_url = 'https://'._domain().'/detail?fromtype=readershare&id='.$bid.'&fromflag='.($this->uid).'&fromcid='.$cid;
  1487. //$js_config = ChapterShareWechatConfigService::getConfig($url);
  1488. $app_hash = array(
  1489. 4025=>['appid'=>'wx80b618c9dcc940f7','appsecret'=>'255a2de8db51e4084b5e9087d26d4ecb'],
  1490. 4147=>['appid'=>'wx2a99699cd9572812','appsecret'=>'0e0d57f94eeba50abb3af6883df05a5c'],
  1491. 691=>['appid'=>'wx5cefcd251dc40693','appsecret'=>'755f64c85173dad21f20870e38f59d8a'],
  1492. 123=>['appid'=>'wx983808610aa9dcc5','appsecret'=>'91002999590b79f3c7be35fd73c04049'],
  1493. 211=>['appid'=>'wx39338e374cc2055b','appsecret'=>'1a4c2039be271b3811182be5bb53eb34'],
  1494. );
  1495. $appId = $app_hash[$this->distribution_channel_id]['appid'];
  1496. $appSecret = $app_hash[$this->distribution_channel_id]['appsecret'];
  1497. $js_config = (new ChapterShareWechatConfigService($appId,$appSecret))->getSignPackage($url);
  1498. /*$appid = DB::table('official_accounts')->where('distribution_channel_id',$this->distribution_channel_id)->first();//(['distribution_channel_id'=>$this->distribution_channel_id]);
  1499. $appid = $appid->appid;
  1500. //\Log::info('get_appid:'.($appid));
  1501. $js_config = (new ChapterShareWechatConfigService($appid))->getSignPackage($url);
  1502. //$chapter->js_config = $js_config;
  1503. //$chapter->share_url = $share_url;
  1504. $book = BookService::getBookById(Hashids::decode($bid)[0]);
  1505. $first_cid = $book->first_cid;
  1506. $share_url = 'https://site' . encodeDistributionChannelId($this->distribution_channel_id) . '.' . env('SHARE_DOMAIN') . '/reader?fromtype=readershare&bid=' . $bid . '&cid=' . ($first_cid) . '&fromflag=' . ($this->uid) . '&fromcid=' . $cid;
  1507. /*if (in_array($this->uid, explode(',', env('TEST_SHARE_UIDS')))) {
  1508. $share_url = 'https://site5017zqeyzwgyx9n8.zhuishuyun.com/reader?fromtype=readershare&bid=' . $bid . '&fromflag=' . ($this->uid) . '&fromcid=' . $cid;
  1509. }*/
  1510. $book = BookService::getBookById(Hashids::decode($bid)[0]);
  1511. $first_cid = $book->first_cid;
  1512. $share_url = 'https://site' . encodeDistributionChannelId($this->distribution_channel_id) . '.' . env('SHARE_DOMAIN') . '/reader?fromtype=readershare&bid=' . $bid . '&cid=' . ($first_cid) . '&fromflag=' . ($this->uid) . '&fromcid=' . $cid;
  1513. if (in_array($this->distribution_channel_id, [2, 14])) {
  1514. $js_config = ChapterShareWechatConfigService::getConfig($url);
  1515. $share_url = 'https://site' . ($this->distribution_channel_id) . '.' . env('SHARE_DOMAIN') . '/reader?fromtype=readershare&bid=' . $bid . '&cid=' . ($first_cid) . '&fromflag=' . ($this->uid) . '&fromcid=' . $cid;
  1516. }
  1517. $js_config['share_url'] = $share_url;
  1518. /*} catch (\Exception $e) {
  1519. \Log::error($e->getMessage());
  1520. }*/
  1521. //\Log::info($js_config);
  1522. return response()->success($js_config);
  1523. }
  1524. }