PostRepositories.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: edz
  5. * Date: 2019-06-10
  6. * Time: 17:53
  7. */
  8. namespace App\Repositories;
  9. use App\Models\Behavior;
  10. use App\Models\MemberFollowTopic;
  11. use App\Models\Post;
  12. use App\Models\PostCollect;
  13. use App\Models\PostComment;
  14. use App\Models\PostData;
  15. use App\Models\PostDislike;
  16. use App\Models\PostImgs;
  17. use App\Models\PostLike;
  18. use App\Models\PostLog;
  19. use App\Models\PostShare;
  20. use App\Models\Topic;
  21. use App\Service\AliYunVodService;
  22. use App\Service\DetectionService;
  23. use App\Traits\CmsTrait;
  24. use App\Traits\PostTrait;
  25. use App\Traits\UserTrait;
  26. use Illuminate\Database\QueryException;
  27. use Illuminate\Support\Carbon;
  28. use Illuminate\Support\Facades\Log;
  29. use Illuminate\Support\Facades\Redis;
  30. use Illuminate\Support\Facades\DB;
  31. use Tymon\JWTAuth\Facades\JWTAuth;
  32. class PostRepositories
  33. {
  34. use UserTrait;
  35. use PostTrait;
  36. use CmsTrait;
  37. public function __construct(Post $post,
  38. PostData $postData,
  39. PostImgs $postImgs,
  40. PostComment $postComment,
  41. PostCollect $postCollect,
  42. PostShare $postShare,
  43. PostLog $postLog,
  44. DetectionService $detectionService,
  45. AliYunVodService $aliYunVodService,
  46. MemberFollowTopic $memberFollowTopic,
  47. Topic $topic)
  48. {
  49. $this->post = $post;
  50. $this->postData = $postData;
  51. $this->postImgs = $postImgs;
  52. $this->postComment = $postComment;
  53. $this->postCollect = $postCollect;
  54. $this->postShare = $postShare;
  55. $this->postLog = $postLog;
  56. $this->detectionService = $detectionService;
  57. $this->topic = $topic;
  58. $this->memberFollowTopic = $memberFollowTopic;
  59. $this->aliYunVodService = $aliYunVodService;
  60. }
  61. /**
  62. * 发布内容
  63. */
  64. public function create($request)
  65. {
  66. //验证小号
  67. $userInfo = $this->getUserInfo();
  68. if (empty($userInfo)) {
  69. return jsonError('获取用户信息失败');
  70. }
  71. if(!$userInfo['sns_status']){
  72. return jsonError('您已被禁言');
  73. }
  74. $isValid = 0;
  75. if($userInfo['strength']){
  76. $isValid = 1;
  77. }
  78. // $oneHourTime = Carbon::now()->addHours(-1)->toDateTimeString();
  79. // $oneHourPostCount = $this->post->where('uid', $userInfo['uid'])->where('created_at', '>', $oneHourTime)->count();
  80. // if($oneHourPostCount > 5){
  81. // return jsonError('创作欲望太强啦,休息一下,看看其他用户的内容吧!');
  82. // }
  83. $detectionText = $request['title'] .','. $request['content'];
  84. $detectionTextResult = $this->detectionService->checkText($detectionText);
  85. if ($detectionTextResult['code']<0) {
  86. return jsonError('内容违规,请修正哦');
  87. }
  88. $topicIds = json_decode($request['topic_ids'], true);
  89. $topicCount = count($topicIds);
  90. if($topicCount == 0 || $topicCount > 5){
  91. return jsonError('所选话题必须1-5个');
  92. }
  93. //验证话题
  94. $hasTopicCount = $this->topic->whereIn('id', $topicIds)->count();
  95. if($topicCount != $hasTopicCount){
  96. Log::error('所选话题非法'.$request['topic_ids']);
  97. return jsonError('所选话题非法');
  98. }
  99. $imgs = [];
  100. if($request['type'] == 'image'){
  101. $imgs = json_decode($request['imgs'], true);
  102. $imgCount = count($imgs);
  103. if($imgCount == 0 || $imgCount > 9){
  104. return jsonError('所传图集必须1-9个');
  105. }
  106. }
  107. $allImg = array_merge($imgs, [$request['img']]);
  108. foreach($allImg as &$img){
  109. $img = $img .'&x-oss-process=image/resize,p_50/quality,Q_50';
  110. }
  111. $detectionImageResult = $this->detectionService->checkImg($allImg);
  112. if ($detectionImageResult['code']<0) {
  113. return jsonError('图片违规,请修正哦');
  114. }
  115. $videoUrl = "";
  116. $videoId = "";
  117. if(isset($request['video']) && $request['video']){
  118. $videoId = $request['video'];
  119. for($i=0;$i<3;$i++){
  120. $videoUrl = $this->aliYunVodService->getPlayUrlByVideoId($request['video']);
  121. Log::debug('video-url:'.$videoUrl);
  122. if($videoUrl){
  123. break;
  124. }
  125. }
  126. if(empty($videoUrl)){
  127. return jsonError('发布失败,请重试');
  128. }
  129. }
  130. $fresh = (Carbon::now()->timestamp) - (Carbon::parse("2019-05-01 00:00:00")->timestamp);
  131. $score = $fresh / 86400;
  132. $data = [
  133. 'uid' => $userInfo['uid'],
  134. 'username' => $userInfo['username'],
  135. 'mobile' => $userInfo['mobile'],
  136. 'avatar' => $userInfo['avatar']??'',
  137. 'type' => $request['type'],
  138. 'img' => $request['img'],
  139. 'video' => $videoUrl,
  140. 'video_id' => $videoId,
  141. 'topic_ids' => implode(',', $topicIds),
  142. 'title' => isset($request['title'])? $request['title'] : '',
  143. 'content' => $request['content'],
  144. 'location' => isset($request['location'])? $request['location'] : '',
  145. 'is_suggest' => 0,
  146. 'is_hide' => 0,
  147. 'weight' => $score
  148. ];
  149. $date = date('Y-m-d H:i:s');
  150. DB::beginTransaction();
  151. try{
  152. $post = $this->post->create($data);
  153. $postData = $this->postData->create([
  154. 'post_id' => $post->id,
  155. 'pv' => 0,
  156. 'pv_real' => 0,
  157. 'dislike_count' => 0,
  158. 'praise_count' => 0,
  159. 'praise_real_count' => 0,
  160. 'share_count' => 0,
  161. 'share_real_count' => 0,
  162. 'comment_count' => 0,
  163. 'collect_count' => 0,
  164. 'collect_real_count' => 0,
  165. 'available_bean' => $this->availableBean(),
  166. 'will_collect_bean' => rand(100, 200),
  167. 'collect_bean' => 0
  168. ]);
  169. if($imgs){
  170. $imgData = [];
  171. foreach($imgs as $img){
  172. $imgData[] = [
  173. 'post_id' => $post->id,
  174. 'img' => $img,
  175. 'created_at' => $date,
  176. 'updated_at' => $date
  177. ];
  178. }
  179. $this->postImgs->insert($imgData);
  180. }
  181. DB::commit();
  182. Redis::zadd('post_trigger_type', $isValid, $post->id);
  183. foreach($topicIds as $id){
  184. Redis::zincrby('topic.user_uid'.$userInfo['uid'], 1, $id);
  185. }
  186. Redis::HSET('post_info_'.$post->id,
  187. 'id', $post->id,
  188. 'uid', $post->uid,
  189. 'type', $post->type,
  190. 'img', $post->img,
  191. 'imgs', json_encode($imgs),
  192. 'video', $post->video,
  193. 'topic_ids', $post->topic_ids,
  194. 'title', $post->title,
  195. 'content', $post->content,
  196. 'location', $post->location,
  197. 'pv', $postData->pv,
  198. 'dislike_count', $postData->dislike_count,
  199. 'praise_count', $postData->praise_count,
  200. 'share_count', $postData->share_count,
  201. 'comment_count', $postData->comment_count,
  202. 'collect_count', $postData->collect_count,
  203. 'available_bean', $postData->available_bean,
  204. 'will_collect_bean', $postData->will_collect_bean,
  205. 'create_bean', $postData->create_bean,
  206. 'collect_bean', $postData->collect_bean);
  207. return jsonSuccess([
  208. 'post_id' => $post->id,
  209. 'h5url' => config('customer.share_post_h5url')."?post_id={$post->id}&invite_code={$userInfo['invite_code']}",
  210. 'bean' => $postData->available_bean,
  211. ]);
  212. }catch (QueryException $exception){
  213. DB::rollBack();
  214. Log::debug('发布内容失败:'.$exception->getMessage());
  215. return jsonError('发布内容失败,请重试');
  216. }
  217. }
  218. /**
  219. * 评论&回复
  220. */
  221. public function comment($request)
  222. {
  223. //验证小号
  224. $userInfo = $this->getUserInfo();
  225. if (empty($userInfo)) {
  226. return jsonError('获取用户信息失败');
  227. }
  228. if(!$userInfo['sns_status']){
  229. return jsonError('您已被禁言');
  230. }
  231. $oneHourTime = Carbon::now()->addHours(-1)->toDateTimeString();
  232. $oneHourCommentCount = $this->postComment->where('uid', $userInfo['uid'])->where('created_at', '>', $oneHourTime)->count();
  233. if($oneHourCommentCount > 59){
  234. return jsonError('回复了这么多,休息休息,喝口水吧!');
  235. }
  236. $detectionTextResult = $this->detectionService->checkText($request['content']);
  237. if ($detectionTextResult['code']<0) {
  238. return jsonError('内容违规,请修正哦');
  239. }
  240. $post = $this->post->find($request['post_id']);
  241. if(!$post){
  242. return jsonError('获取内容信息失败');
  243. }
  244. $data = [
  245. 'uid' => $userInfo['uid'],
  246. 'post_id' => $request['post_id'],
  247. 'parent_id' => 0,
  248. 'username' => $userInfo['username'],
  249. 'reply_uid' => 0,
  250. 'reply_username' => '',
  251. 'avatar' => $userInfo['avatar']??'',
  252. 'content' => $request['content'],
  253. 'is_delete' => 0,
  254. ];
  255. if(isset($request['parent_id']) && $request['parent_id'] != 0){
  256. $comment = $this->postComment->find($request['parent_id']);
  257. if(!$comment || $comment->post_id != $post->id){
  258. return jsonError('获取评论信息失败');
  259. }
  260. if($comment->parent_id){
  261. return jsonError('只能回复评论');
  262. }
  263. if($comment->is_delete){
  264. return jsonError('不能回复已删除评论');
  265. }
  266. $data['parent_id'] = $request['parent_id'];
  267. if(isset($request['reply_uid']) && isset($request['reply_username'])){
  268. $data['reply_uid'] = $request['reply_uid'];
  269. $data['reply_username'] = $request['reply_username'];
  270. }else{
  271. $data['reply_uid'] = 0;
  272. $data['reply_username'] = '';
  273. }
  274. }
  275. DB::beginTransaction();
  276. try{
  277. $comment = $this->postComment->create($data);
  278. DB::commit();
  279. if(!$comment->parent_id){
  280. Redis::DEL('post_new_comment_'.$comment->post_id);
  281. }else{
  282. Redis::DEL('post_new_reply_'.$comment->id);
  283. }
  284. return jsonSuccess(['id' => $comment->id], '评论成功');
  285. }catch (QueryException $exception){
  286. DB::rollBack();
  287. Log::debug('评论内容失败:'.$exception->getMessage());
  288. return jsonError('评论内容失败,请重试');
  289. }
  290. }
  291. /**
  292. * 删除评论
  293. */
  294. public function commentDelete($request)
  295. {
  296. $userInfo = $this->getUserInfo();
  297. if (empty($userInfo)) {
  298. return jsonError('获取用户信息失败');
  299. }
  300. $comment = $this->postComment->find($request['id']);
  301. if (!$comment) {
  302. return jsonError('获取评论信息失败');
  303. }
  304. if($userInfo['uid'] != $comment->uid){
  305. return jsonError('只能删除自己的评论');
  306. }
  307. if ($comment->is_delete == 1) {
  308. return jsonError('该评论已经删除');
  309. }
  310. DB::beginTransaction();
  311. try {
  312. $comment->is_delete = 1;
  313. $comment->save();
  314. DB::commit();
  315. if(!$comment->parent_id){
  316. Redis::DEL('post_new_comment_'.$comment->post_id);
  317. }else{
  318. Redis::DEL('post_new_reply_'.$comment->id);
  319. }
  320. Redis::SADD('delete_post_comment_ids', $comment->id);
  321. return jsonSuccess('删除评论成功');
  322. } catch (QueryException $exception) {
  323. DB::rollBack();
  324. Log::debug('删除评论:' . $request['id'] . $exception->getMessage());
  325. return jsonError('删除评论失败');
  326. }
  327. }
  328. /**
  329. * 内容列表
  330. */
  331. public function lists($request)
  332. {
  333. Log::debug('内容列表'.json_encode($request));
  334. $perPage = isset($request['per_page']) ? $request['per_page'] : 20;
  335. return $this->post
  336. ->where(function($query) use ($request){
  337. if(isset($request['keyword'])){
  338. $query->where('title', 'like', "%{$request['keyword']}%")
  339. ->orWhere('content', 'like', "%{$request['keyword']}%");
  340. }
  341. })
  342. ->where(function($query) use ($request){
  343. if(isset($request['topic_ids']) && $request['topic_ids']){
  344. $topicIds = json_decode($request['topic_ids'], true);
  345. foreach ($topicIds as $key=>$id) {
  346. if ($key==0) {
  347. $query->whereRaw('FIND_IN_SET('.$id.', topic_ids)');
  348. } else {
  349. $query->orWhereRaw('FIND_IN_SET('.$id.', topic_ids)');
  350. }
  351. }
  352. }
  353. })
  354. ->orderBy('weight','desc')
  355. ->paginate($perPage);
  356. }
  357. /**
  358. * 视频列表
  359. */
  360. public function video($request)
  361. {
  362. $perPage = isset($request['per_page']) ? $request['per_page'] : 20;
  363. $where = [];
  364. $id = 0;
  365. if(isset($request['id'])){
  366. $id = $request['id'];
  367. }
  368. $where[] = ['type', 'video'];
  369. if(isset($request['type'])){
  370. if($request['type'] == 'hot'){
  371. $ids = Redis::get('hotVideoIds');
  372. if(!$ids){
  373. $ids = $this->hotVideoIds();
  374. if(!$ids){
  375. $ids = '';
  376. }
  377. }
  378. Log::debug('热门视频ids'.$ids);
  379. return $this->post
  380. ->select('*', DB::raw("IF (id = {$id},1,0) as sort"))
  381. ->where($where)
  382. ->whereIn('id', explode(',', $ids))
  383. ->orderBy('sort', 'desc')
  384. ->orderByRaw(DB::raw("FIELD(id,{$ids})"))
  385. ->paginate($perPage);
  386. }elseif($request['type'] == 'one'){
  387. $where[] = ['id', $id];
  388. return $this->post
  389. ->where($where)
  390. ->paginate($perPage);
  391. }
  392. }
  393. return $this->post
  394. ->select('*', DB::raw("IF (id = {$id},1,0) as sort"))
  395. ->where($where)
  396. ->where(function($query) use ($request){
  397. if(isset($request['topic_id']) && $request['topic_id']){
  398. $query->whereRaw('FIND_IN_SET('.$request['topic_id'].', topic_ids)');
  399. }
  400. })
  401. ->orderBy('sort', 'desc')
  402. ->orderBy('weight','desc')
  403. ->paginate($perPage);
  404. }
  405. /**
  406. * 个人中心内容列表
  407. */
  408. public function myPost($request, $uid)
  409. {
  410. $type = $request['type'];
  411. $perPage = isset($request['per_page']) ? $request['per_page'] : 18;
  412. $where = [];
  413. if($type == 'create'){
  414. $where[] = ['post.uid', $uid];
  415. $post = $this->post;
  416. $order = 'post.id';
  417. }elseif($type == 'collect'){
  418. $post = $this->post->withTrashed()->join('post_collect', 'post_collect.post_id', '=', 'post.id');
  419. $where[] = ['post_collect.uid', $uid];
  420. $order = 'post_collect.id';
  421. }else{
  422. $post = $this->post->withTrashed()->join('post_share', 'post_share.post_id', '=', 'post.id');
  423. $where[] = ['post_share.uid', $uid];
  424. $order = 'post_share.updated_at';
  425. }
  426. return $post
  427. ->select('post.*')
  428. ->where($where)
  429. ->orderBy($order,'desc')
  430. ->paginate($perPage);
  431. }
  432. /**
  433. * 内容详情
  434. */
  435. public function detail($id)
  436. {
  437. return $this->post
  438. ->find($id);
  439. }
  440. /**
  441. * 内容是否存在
  442. */
  443. public function detailExists($id)
  444. {
  445. return $this->post->where('id', $id)->exists();
  446. }
  447. /**
  448. * 推荐内容列表
  449. */
  450. public function suggestPost($request)
  451. {
  452. $perPage = isset($request['per_page']) ? $request['per_page'] : 20;
  453. return $this->post
  454. ->orderBy('is_suggest','desc')
  455. ->orderBy('weight','desc')
  456. ->paginate($perPage);
  457. }
  458. /**
  459. * 话题内容
  460. */
  461. public function topicPost($request)
  462. {
  463. $perPage = isset($request['per_page']) ? $request['per_page'] : 20;
  464. return $this->post
  465. ->whereRaw('FIND_IN_SET(' . $request['id'] . ',topic_ids)')
  466. ->orderBy('id','desc')
  467. ->paginate($perPage);
  468. }
  469. /**
  470. * 评论列表
  471. */
  472. public function commentList($request)
  473. {
  474. $perPage = isset($request['per_page']) ? $request['per_page'] : 20;
  475. return $this->postComment
  476. ->where('post_id', $request['post_id'])
  477. ->where('parent_id', 0)
  478. ->orderBy('id','desc')
  479. ->paginate($perPage);
  480. }
  481. /**
  482. * 回复列表
  483. */
  484. public function replyList($request)
  485. {
  486. $perPage = isset($request['per_page']) ? $request['per_page'] : 20;
  487. return $this->postComment
  488. ->where('parent_id', $request['id'])
  489. ->orderBy('id','desc')
  490. ->paginate($perPage);
  491. }
  492. /**
  493. * 话题列表
  494. */
  495. public function topicList($request)
  496. {
  497. $perPage = isset($request['per_page']) ? $request['per_page'] : 20;
  498. $where = [];
  499. $topic = $this->topic;
  500. if(isset($request['category_id']) && $request['category_id']){
  501. if($request['category_id'] == -2){
  502. $where[] = ['topic.is_hot', 1];
  503. }else{
  504. $topic = $topic->join('category_topic', 'category_topic.topic_id', '=', 'topic.id')->select('topic.*');
  505. $where[] = ['category_topic.category_id', $request['category_id']];
  506. }
  507. }
  508. if(isset($request['name'])){
  509. $where[] = ['topic.name', 'like', "%{$request['name']}%"];
  510. }
  511. return $topic
  512. ->where($where)
  513. ->orderBy('id','desc')
  514. ->paginate($perPage);
  515. }
  516. /**
  517. * 我的话题列表
  518. */
  519. public function myTopicList($request)
  520. {
  521. $perPage = isset($request['per_page']) ? $request['per_page'] : 20;
  522. $uid = 0;
  523. $user = $this->getUserInfo();
  524. if($user){
  525. $uid = $user['uid'];
  526. }
  527. return $this->memberFollowTopic
  528. ->where('uid', $uid)
  529. ->orderBy('id','desc')
  530. ->paginate($perPage);
  531. }
  532. /**
  533. * 更新帖子统计数量
  534. * @param $request
  535. * @return mixed
  536. */
  537. public function updatePostData($request)
  538. {
  539. $postId = isset($request['post_id'])?$request['post_id']:0;
  540. if(empty($postId)){
  541. Log::debug("非帖子类操作,不操作帖子统计数量".json_encode($request));
  542. return true;
  543. }
  544. //帖子缓存信息key
  545. $postInfoKey = "post_info_".$postId;
  546. $post = PostData::where('post_id', $postId)->first();
  547. if(!$post) return true;
  548. if (isset($request['behavior_flag']) && $request['behavior_flag'] == 'read') {
  549. $post->pv += 1;
  550. $post->pv_real += 1;
  551. Redis::HINCRBY($postInfoKey,'pv',1);
  552. Log::debug("帖子:".$postId."被阅读,pv +1");
  553. } elseif (isset($request['behavior_flag']) && $request['behavior_flag'] == 'unlike') {
  554. //用户不喜欢帖子key
  555. $postUnLikeKey = "post_unlike_".$postId;
  556. $post->dislike_count += 1;
  557. PostDislike::create(['uid'=>$request['target_id'],'post_id'=>$request['post_id']]);
  558. Redis::sadd($postUnLikeKey,$request['target_id']);
  559. Redis::HINCRBY($postInfoKey,'dislike_count',1);
  560. Log::debug("帖子:".$postId."被不喜欢,unlike +1");
  561. } elseif (isset($request['behavior_flag']) && $request['behavior_flag'] == 'like') {
  562. //用户点赞帖子
  563. $postLikeKey = "post_like_".$postId;
  564. if($request['behavior_value']){
  565. $post->praise_count += 1;
  566. $post->praise_real_count += 1;
  567. PostLike::create(['uid'=>$request['target_id'],'post_id'=>$request['post_id']]);
  568. Redis::sadd($postLikeKey,$request['target_id']);
  569. Redis::HINCRBY($postInfoKey,'praise_count',1);
  570. Log::debug("帖子:".$postId."被点赞,praise_count +1");
  571. }else{
  572. $post->praise_count -= 1;
  573. $post->praise_real_count -= 1;
  574. PostLike::where(['uid'=>$request['target_id'],'post_id'=>$request['post_id']])->delete();
  575. Redis::srem($postLikeKey,$request['target_id']);
  576. Redis::HINCRBY($postInfoKey,'praise_count',-1);
  577. Log::debug("帖子:".$postId."被取消点赞,praise_count -1");
  578. }
  579. } elseif (isset($request['behavior_flag']) && $request['behavior_flag'] == 'forward') {
  580. $post->share_count += 1;
  581. $post->share_real_count += 1;
  582. Redis::HINCRBY($postInfoKey,'share_count',1);
  583. $shareRow = PostShare::where(['uid'=>$request['target_id'],'post_id'=>$request['post_id']])->first();
  584. if($shareRow){
  585. PostShare::where(['uid'=>$request['target_id'],'post_id'=>$request['post_id']])->update(['uid'=>$request['target_id'],'post_id'=>$request['post_id']]);
  586. }else{
  587. PostShare::create(['uid'=>$request['target_id'],'post_id'=>$request['post_id']]);
  588. }
  589. Log::debug("帖子:".$postId."被分享,share_count +1");
  590. } elseif (isset($request['behavior_flag']) && $request['behavior_flag'] == 'comment') {
  591. $post->comment_count += 1;
  592. Redis::HINCRBY($postInfoKey,'comment_count',1);
  593. Log::debug("帖子:".$postId."被评论,comment_count +1");
  594. } elseif (isset($request['behavior_flag']) && $request['behavior_flag'] == 'collect') {
  595. //用户收藏帖子
  596. $postCollectKey = "post_collect_".$postId;
  597. if($request['behavior_value']) {
  598. $post->collect_count += 1;
  599. $post->collect_real_count += 1;
  600. PostCollect::create(['uid'=>$request['target_id'],'post_id'=>$request['post_id']]);
  601. Redis::sadd($postCollectKey,$request['target_id']);
  602. Redis::HINCRBY($postInfoKey,'collect_count',1);
  603. Log::debug("帖子:".$postId."被收藏,collect_count +1");
  604. }else{
  605. $post->collect_count -= 1;
  606. $post->collect_real_count -= 1;
  607. PostCollect::where(['uid'=>$request['target_id'],'post_id'=>$request['post_id']])->delete();
  608. Redis::srem($postCollectKey,$request['target_id']);
  609. Redis::HINCRBY($postInfoKey,'collect_count',-1);
  610. Log::debug("帖子:".$postId."被取消收藏,collect_count -1");
  611. }
  612. }
  613. $this->collectPostId($request['post_id']);
  614. return $post->save();
  615. }
  616. /**
  617. * 收集所有有操作的帖子,存入redis
  618. * 供后续计算帖子权重
  619. * @param $id
  620. */
  621. public function collectPostId($id)
  622. {
  623. $key = "community_calc_post_score";
  624. Redis::sadd($key,$id);
  625. Log::debug('存入帖子'.$id.'到权重列表');
  626. }
  627. /**
  628. * 话题详情
  629. */
  630. public function topicDetail($id)
  631. {
  632. return $this->topic
  633. ->find($id);
  634. }
  635. /**
  636. * 获取话题
  637. */
  638. public function getTopic($ids)
  639. {
  640. $topics = $this->topic
  641. ->whereIn('id', explode(',',$ids))
  642. ->orderByRaw(DB::raw("FIELD(id,{$ids})"))
  643. ->get();
  644. $data = [];
  645. foreach($topics as $topic){
  646. $data[] = [
  647. 'id' => $topic->id,
  648. 'name' => $topic->name,
  649. 'img' => $topic->img,
  650. 'follow_count' => getNumber($topic->follow->count() + $topic->base_count),
  651. ];
  652. }
  653. return $data;
  654. }
  655. /**
  656. * 获取内容视频组
  657. */
  658. public function getPostVideo($ids)
  659. {
  660. $posts = $this->post
  661. ->select('id', 'img', 'uid')
  662. ->whereIn('id', explode(',',$ids))
  663. ->where('type', 'video')
  664. ->get();
  665. foreach($posts as &$post){
  666. $user = $this->userInfo($post->uid);
  667. $post->username = $user['username'];
  668. $post->avatar = $user['avatar'];
  669. }
  670. return $posts;
  671. }
  672. //用户内容数,转发数,收藏数统计
  673. public function memberPostStatistics($uid){
  674. $postCount = $this->post->where('uid',$uid)->count();
  675. $postCollectCount = $this->postCollect->where('uid',$uid)->count();
  676. $postShareCount = $this->postShare->where('uid',$uid)->count();
  677. $data = ['post_count'=>$postCount,'share_count'=>$postShareCount,'collect_count'=>$postCollectCount];
  678. return jsonSuccess($data);
  679. }
  680. /**
  681. * 删除内容
  682. */
  683. public function delete($request)
  684. {
  685. //验证用户信息
  686. $userInfo = $this->getUserInfo();
  687. if (empty($userInfo)) {
  688. return jsonError('获取用户信息失败');
  689. }
  690. $post = $this->post->find($request['id']);
  691. if(!$post){
  692. return jsonError('获取内容信息失败');
  693. }
  694. if($post->uid != $userInfo['uid']){
  695. return jsonError('只能删除自己发布的内容');
  696. }
  697. $logData = [
  698. 'uid' => $userInfo['uid'],
  699. 'operator_type' => 'user',
  700. 'post_id' => $request['id'],
  701. 'username' => $userInfo['username'],
  702. 'log_type' => 'delete',
  703. 'content' => json_encode(['delete' => $request['id']]),
  704. ];
  705. DB::beginTransaction();
  706. try{
  707. $post->delete();
  708. $this->postLog->create($logData);
  709. DB::commit();
  710. Redis::SADD('delete_post_ids', $request['id']);
  711. Log::debug('删除内容失败:'.$request['id']);
  712. return jsonSuccess('删除内容成功');
  713. }catch (QueryException $exception){
  714. DB::rollBack();
  715. Log::debug('删除内容失败:'.$request['id'].$exception->getMessage());
  716. return jsonError('删除内容失败,请重试');
  717. }
  718. }
  719. /**
  720. * 内容评论数
  721. */
  722. public function getCommentCount($id)
  723. {
  724. $commentCount = 0;
  725. $post = $this->post->find($id);
  726. if($post){
  727. $commentCount = $post->data->comment_count;
  728. }
  729. return $commentCount;
  730. }
  731. }