FloorRepository.php 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137
  1. <?php
  2. namespace App\Repositories;
  3. use App\Models\Floor;
  4. use App\Models\MemberGroup;
  5. use App\Models\MemberGroupInfo;
  6. use App\Models\TopicGroup;
  7. use App\Models\TopicGroupInfo;
  8. use App\Models\VideoGroup;
  9. use App\Models\VideoGroupInfo;
  10. use App\Traits\UserTrait;
  11. use Illuminate\Support\Facades\Log;
  12. use Symfony\Component\HttpKernel\Exception\HttpException;
  13. use Dingo\Api\Http\Response;
  14. use Illuminate\Support\Facades\DB;
  15. use Illuminate\Database\QueryException;
  16. /**
  17. * Created by PhpStorm.
  18. * User: durong
  19. * Date: 2019/6/15
  20. * Time: 下午4:36
  21. */
  22. class FloorRepository
  23. {
  24. use UserTrait;
  25. public function __construct(Floor $floor,
  26. MemberGroup $memberGroup,
  27. MemberGroupInfo $memberGroupInfo,
  28. VideoGroup $videoGroup,
  29. VideoGroupInfo $videoGroupInfo,
  30. TopicGroup $topicGroup,
  31. TopicGroupInfo $topicGroupInfo)
  32. {
  33. $this->floor = $floor;
  34. $this->memberGroup = $memberGroup;
  35. $this->memberGroupInfo = $memberGroupInfo;
  36. $this->videoGroup = $videoGroup;
  37. $this->videoGroupInfo = $videoGroupInfo;
  38. $this->topicGroup = $topicGroup;
  39. $this->topicGroupInfo = $topicGroupInfo;
  40. }
  41. public function index($request)
  42. {
  43. $perPage = isset($request['per_page']) ? $request['per_page'] : 20;
  44. $where = [];
  45. $where[] = ['is_open', 1];
  46. return $this->floor->where($where)->orderBy('floor_location', 'asc')->paginate($perPage);
  47. }
  48. public function info()
  49. {
  50. Log::debug('推荐内容楼层-开始请求');
  51. $userInfo = $this->getUserInfo();
  52. if(!$userInfo){
  53. return jsonError('获取用户信息失败');
  54. }
  55. Log::debug('推荐内容楼层-用户信息'.json_encode($userInfo));
  56. $floor = $this->floor
  57. ->where('is_open', 1)
  58. ->whereIn('floor_type', [0,1,2,3])
  59. ->whereBetween('floor_location', [1,20])
  60. ->get();
  61. Log::debug('推荐内容楼层-楼层列表'.json_encode($floor));
  62. $data = [];
  63. foreach($floor as $item){
  64. if($item->floor_type == 0){
  65. //banner
  66. $banner = $this->getBanner($item->group_ids);
  67. Log::debug('推荐内容楼层-banner'.json_encode($banner));
  68. if($banner){
  69. $data[$item->floor_location] = [
  70. 'show_type' => 'banner',
  71. 'data' => $banner
  72. ];
  73. }
  74. }elseif($item->floor_type == 1){
  75. //user
  76. $memberIds = $this->memberGroup
  77. ->join('member_group_info', 'member_group_info.member_group_id', '=', 'member_group.id')
  78. ->where('member_group.id', $item->group_ids)
  79. ->limit(20)
  80. ->pluck('member_group_info.uid')
  81. ->toArray();
  82. if(!$memberIds) continue;
  83. $memberIds = implode($memberIds, ',');
  84. $member = $this->getMemberGroup($memberIds);
  85. Log::debug('推荐内容楼层-user'.json_encode($member));
  86. if(!$member) continue;
  87. $data[$item->floor_location] = [
  88. 'show_type' => 'user',
  89. 'data' => $member
  90. ];
  91. }elseif($item->floor_type == 2){
  92. //video
  93. $videoIds = $this->videoGroup
  94. ->join('video_group_info', 'video_group_info.video_group_id', '=', 'video_group.id')
  95. ->where('video_group.id', $item->group_ids)
  96. ->limit(20)
  97. ->pluck('video_group_info.post_id')
  98. ->toArray();
  99. if(!$videoIds) continue;
  100. $videoIds = implode($videoIds, ',');
  101. $video = $this->getPostVideo($videoIds);
  102. Log::debug('推荐内容楼层-video'.json_encode($video));
  103. if(!$video) continue;
  104. $data[$item->floor_location] = [
  105. 'show_type' => 'video',
  106. 'data' => $video
  107. ];
  108. }elseif($item->floor_type == 3){
  109. //topic
  110. $topicIds = $this->topicGroup
  111. ->join('topic_group_info', 'topic_group_info.topic_group_id', '=', 'topic_group.id')
  112. ->where('topic_group.id', $item->group_ids)
  113. ->limit(20)
  114. ->pluck('topic_group_info.topic_id')
  115. ->toArray();
  116. if(!$topicIds) continue;
  117. $topicIds = implode($topicIds, ',');
  118. $topic = $this->getTopic($topicIds);
  119. Log::debug('推荐内容楼层-topic'.json_encode($topic));
  120. if(!$topic) continue;
  121. $data[$item->floor_location] = [
  122. 'show_type' => 'topic',
  123. 'data' => $topic
  124. ];
  125. }
  126. }
  127. return $data;
  128. }
  129. }