ChapterController.php 78 KB

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