ChapterController.php 62 KB

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