DynamicService.php 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187
  1. <?php
  2. namespace App\Services;
  3. use App\Http\Params\DynamicParam;
  4. use App\Http\Params\DynamicZanParam;
  5. use App\Http\Params\UserReportParam;
  6. use App\Models\DynamicModel;
  7. use App\Models\DynamicZanModel;
  8. use App\Models\User;
  9. use App\Models\UserReportModel;
  10. use Illuminate\Support\Facades\DB;
  11. use PHPUnit\Util\Exception;
  12. use function PHPUnit\Framework\isEmpty;
  13. class DynamicService
  14. {
  15. //话题列表
  16. public function tag_list($keyword){
  17. $data = DB::table("dynamic_tag")
  18. ->where("title","like","%{$keyword}%")
  19. ->orderBy("hot","desc")
  20. ->limit(20)
  21. ->get();
  22. return $data;
  23. }
  24. /**
  25. * 发布动态
  26. */
  27. public function release(DynamicParam $dynamicParam){
  28. //如果设置了标签 新标签则添加 否则就热度加1
  29. $tag_ins = '';
  30. if(!empty($dynamicParam->tag)){
  31. $tag = json_decode($dynamicParam->tag,true);
  32. foreach ($tag as $v){
  33. if($v['id']==0){
  34. $id = DB::table('dynamic_tag')->insertGetId([
  35. "title"=>htmlspecialchars($v['title']),
  36. "hot"=>1
  37. ]);
  38. $tag_ins.=$id.',';
  39. }else{
  40. DB::table('dynamic_tag')->where(['id'=>$v['id']])->increment('hot',1);
  41. $tag_ins.=$v['id'].',';
  42. }
  43. }
  44. }
  45. $data = [
  46. "content"=>$dynamicParam->content,
  47. "img_url"=>$dynamicParam->img_url,
  48. "status"=>$dynamicParam->status,
  49. "type"=>$dynamicParam->type,
  50. "tag"=>$tag_ins,
  51. "site"=>$dynamicParam->site,
  52. "user_id"=>$dynamicParam->user_id,
  53. ];
  54. DynamicModel::create($data);
  55. return true;
  56. }
  57. /**
  58. * 动态列表
  59. */
  60. public function dynamic_list($where){
  61. $dynamic = DynamicModel::query();
  62. $dynamic = $dynamic->with(["users"=>function($query){
  63. $query->select('id','sex','is_vip');
  64. },'users_info']);
  65. //查询条件
  66. //类型 type 1全部 2关注 3附近
  67. if($where['type']==2){
  68. //关注
  69. }elseif ($where['type']==3){
  70. //附近
  71. }
  72. //男,女,全部
  73. if($where['look_type']!=3){
  74. // $dynamic = $dynamic->where('users.sex','=',$where['look_type']);
  75. }
  76. //标签
  77. if($where['tag_id']!=0){
  78. $dynamic = $dynamic->where('tag','=',$where['user_id']);
  79. }
  80. //用户id
  81. if($where['user_id']!=0){
  82. $dynamic = $dynamic->where('user_id','=',$where['user_id']);
  83. }
  84. $dynamic = $dynamic->orderByDesc('id')
  85. ->paginate(request('perPage',10));
  86. $dynamic = $dynamic->toArray();
  87. foreach ($dynamic['data'] as $k=>$v){
  88. $dynamic['data'][$k]['img_url'] = json_decode($v['img_url'],true);
  89. $dynamic['data'][$k]['tag'] = json_decode($v['tag'],true);
  90. if(!empty($v['site'])){
  91. $dynamic['data'][$k]['site'] = json_decode($v['site'],true);
  92. $site = json_decode($v['site'],true);
  93. }else{
  94. }
  95. //计算距离 如果设置了位置,使用设置位置 否则使用定位位置
  96. $dynamic['data'][$k]['distance'] = 0;
  97. }
  98. return $dynamic;
  99. }
  100. //点赞 如果已经点赞 则取消点赞
  101. public function zan(DynamicZanParam $dynamicZanParam){
  102. if(empty($dynamicZanParam->dynamic_id)){
  103. throw new Exception('参数错误');
  104. }
  105. $dynamic = DynamicModel::where(['id'=>$dynamicZanParam->dynamic_id])->first();
  106. if(!$dynamic){
  107. throw new Exception("动态不存在");
  108. }
  109. if($dynamic_zan = DynamicZanModel::query()->where(['user_id'=>$dynamicZanParam->user_id,'dynamic_id'=>$dynamicZanParam->dynamic_id])->first()){
  110. //已点赞 取消点赞
  111. DynamicModel::query()->where('id',$dynamicZanParam->dynamic_id)->decrement('zan_num',1);
  112. $dynamic_zan->delete();
  113. }else{
  114. //点赞
  115. DynamicModel::query()->where('id',$dynamicZanParam->dynamic_id)->increment('zan_num',1);
  116. DynamicZanModel::query()->create([
  117. 'user_id'=>$dynamicZanParam->user_id,
  118. 'dynamic_id'=>$dynamicZanParam->dynamic_id,
  119. 'status'=>0,
  120. 'atime'=>date('Y-m-d H:i:s'),
  121. ]);
  122. }
  123. return true;
  124. }
  125. //删除动态
  126. public function del(DynamicParam $dynamicParam){
  127. if(empty($dynamicParam->id)){
  128. throw new Exception('参数错误');
  129. }
  130. $dynamic = DynamicModel::query()->where(['id'=>$dynamicParam->id])->first();
  131. if(!$dynamic){
  132. throw new Exception("动态不存在");
  133. }
  134. $dynamic->delete();
  135. return true;
  136. }
  137. //举报动态
  138. public function report(UserReportParam $userReportParam){
  139. if(empty($userReportParam->report_id)){
  140. throw new Exception('参数错误');
  141. }
  142. if(empty($userReportParam->content)){
  143. throw new Exception('请输入举报内容');
  144. }
  145. if($userReportParam->type==2){
  146. $dynamic = DynamicModel::query()->where(['id'=>$userReportParam->report_id])->first();
  147. if(!$dynamic){
  148. throw new Exception("动态不存在");
  149. }
  150. }else{
  151. $user = User::query()->where('id',$userReportParam->report_id)->first();
  152. if(!$user){
  153. throw new Exception("用户不存在");
  154. }
  155. }
  156. UserReportModel::query()->create([
  157. "user_id"=>$userReportParam->user_id,
  158. "report_id"=>$userReportParam->report_id,
  159. "type"=>$userReportParam->type,
  160. "content"=>htmlspecialchars($userReportParam->content),
  161. "info"=>htmlspecialchars($userReportParam->info),
  162. "status"=>0,
  163. "img_url"=>$userReportParam->img_url,
  164. ]);
  165. return true;
  166. }
  167. }