DynamicService.php 7.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238
  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. //throw new Exception(json_encode($dynamicParam->tag));
  31. if(!empty($dynamicParam->tag)){
  32. //$tag = json_decode($dynamicParam->tag,true);
  33. $tag = $dynamicParam->tag;
  34. foreach ($tag as $v){
  35. if($v['id']==0){
  36. $id = DB::table('dynamic_tag')->insertGetId([
  37. "title"=>htmlspecialchars($v['title']),
  38. "hot"=>1
  39. ]);
  40. $tag_ins.= $id.',';
  41. }else{
  42. DB::table('dynamic_tag')->where(['id'=>$v['id']])->increment('hot',1);
  43. $tag_ins.= $v['id'].',';
  44. }
  45. }
  46. if(strlen($tag_ins)>0){
  47. $tag_ins = substr($tag_ins,0,-1);
  48. }
  49. }
  50. $data = [
  51. "content"=>$dynamicParam->content,
  52. "img_url"=>json_encode($dynamicParam->img_url),
  53. "status"=>$dynamicParam->status,
  54. "type"=>$dynamicParam->type,
  55. "tag"=>$tag_ins,
  56. "user_id"=>$dynamicParam->user_id,
  57. "city"=>$dynamicParam->city,
  58. "latitude"=>$dynamicParam->latitude,
  59. "longitude"=>$dynamicParam->longitude,
  60. ];
  61. DynamicModel::create($data);
  62. return true;
  63. }
  64. /**
  65. * 动态列表
  66. */
  67. public function dynamic_list($where){
  68. $user = auth('api')->user();
  69. if($user){
  70. $lat = $user->latitude;
  71. $lng = $user->longitude;
  72. if($where['user_id']==0){
  73. $where['look_type'] = $user->sex==1?2:1;
  74. }
  75. }else{
  76. $lat = "0";
  77. $lng = "0";
  78. }
  79. $dynamic = DynamicModel::query();
  80. $dynamic = $dynamic
  81. ->with(["user"=>function($query){
  82. $query->select('id','sex','is_vip','tencent_im_user_id');
  83. },'user_info']);
  84. //查询条件
  85. //类型 type 1全部 2附近
  86. if($where['type']==2){
  87. //附近
  88. }
  89. //性别
  90. if($where['look_type']!=3){
  91. $dynamic = $dynamic->whereHas('user',function($query)use($where){
  92. $query->where('sex',$where['look_type'])->select();
  93. });
  94. }
  95. //用户id
  96. if($where['user_id']!=0){
  97. $dynamic = $dynamic->where('user_id','=',$where['user_id']);
  98. }
  99. //标签
  100. if($where['tag_id']!=0){
  101. $dynamic = $dynamic->whereRaw('FIND_IN_SET(?,tag)',[$where['tag_id']]);
  102. }
  103. $dynamic = $dynamic->orderByDesc('id')
  104. ->paginate(request('perPage',20));
  105. $dynamic = $dynamic->toArray();
  106. foreach ($dynamic['data'] as $k=>$v){
  107. $dynamic['data'][$k]['img_url'] = json_decode($v['img_url'],true);
  108. //计算距离 如果设置了位置,使用设置位置 否则使用定位位置
  109. if(!$v['latitude']||!$v['longitude']){
  110. //没有设置位置 取用户位置
  111. $v_user = User::query()->where(['id'=>$v['user_id']])->first();
  112. if(!$v_user['latitude'] || !$v_user['longitude']){
  113. $distance = 0;
  114. }else{
  115. $distance = GetDistance($lat,$lng,$v_user['latitude'],$v_user['longitude']);
  116. }
  117. }else{
  118. $distance = GetDistance($lat,$lng,$v['latitude'],$v['longitude']);
  119. }
  120. if($distance>=1){
  121. $distance = round($distance);
  122. }else{
  123. $distance = round($distance*1000);
  124. }
  125. $dynamic['data'][$k]['distance'] = $distance;
  126. $dynamic['data'][$k]['atime'] = uc_time_ago(strtotime($v['created_at']));
  127. $dynamic['data'][$k]['tag'] = DB::table("dynamic_tag")->whereIn('id',explode(',',$v['tag']))->get();
  128. $is_zan = 0;
  129. if($user = auth('api')->user()){
  130. if(DynamicZanModel::query()->where(['user_id'=>$user->id,'dynamic_id'=>$v['id']])->first()){
  131. $is_zan = 1;
  132. }
  133. }
  134. $dynamic['data'][$k]['is_zan'] = $is_zan;
  135. }
  136. return $dynamic;
  137. }
  138. //点赞 如果已经点赞 则取消点赞
  139. public function zan(DynamicZanParam $dynamicZanParam){
  140. if(empty($dynamicZanParam->dynamic_id)){
  141. throw new Exception('参数错误');
  142. }
  143. $dynamic = DynamicModel::where(['id'=>$dynamicZanParam->dynamic_id])->first();
  144. if(!$dynamic){
  145. throw new Exception("动态不存在");
  146. }
  147. if($dynamic_zan = DynamicZanModel::query()->where(['user_id'=>$dynamicZanParam->user_id,'dynamic_id'=>$dynamicZanParam->dynamic_id])->first()){
  148. $zan = 0;
  149. //已点赞 取消点赞
  150. DynamicModel::query()->where('id',$dynamicZanParam->dynamic_id)->decrement('zan_num',1);
  151. $dynamic_zan->delete();
  152. }else{
  153. $zan = 1;
  154. //点赞
  155. DynamicModel::query()->where('id',$dynamicZanParam->dynamic_id)->increment('zan_num',1);
  156. DynamicZanModel::query()->create([
  157. 'user_id'=>$dynamicZanParam->user_id,
  158. 'dynamic_id'=>$dynamicZanParam->dynamic_id,
  159. 'status'=>0,
  160. 'atime'=>date('Y-m-d H:i:s'),
  161. ]);
  162. }
  163. return $zan;
  164. }
  165. //删除动态
  166. public function del(DynamicParam $dynamicParam){
  167. if(empty($dynamicParam->id)){
  168. throw new Exception('参数错误');
  169. }
  170. $dynamic = DynamicModel::query()->where(['id'=>$dynamicParam->id])->first();
  171. if(!$dynamic){
  172. throw new Exception("动态不存在");
  173. }
  174. $dynamic->delete();
  175. return true;
  176. }
  177. //举报动态
  178. public function report(UserReportParam $userReportParam){
  179. if(empty($userReportParam->report_id)){
  180. throw new Exception('参数错误');
  181. }
  182. if(empty($userReportParam->content)){
  183. throw new Exception('请输入举报内容');
  184. }
  185. if($userReportParam->type==2){
  186. $dynamic = DynamicModel::query()->where(['id'=>$userReportParam->report_id])->first();
  187. if(!$dynamic){
  188. throw new Exception("动态不存在");
  189. }
  190. }else{
  191. $user = User::query()->where('id',$userReportParam->report_id)->first();
  192. if(!$user){
  193. throw new Exception("用户不存在");
  194. }
  195. }
  196. UserReportModel::query()->create([
  197. "user_id"=>$userReportParam->user_id,
  198. "report_id"=>$userReportParam->report_id,
  199. "type"=>$userReportParam->type,
  200. "content"=>htmlspecialchars($userReportParam->content),
  201. "info"=>htmlspecialchars($userReportParam->info),
  202. "status"=>0,
  203. "img_url"=>$userReportParam->img_url,
  204. ]);
  205. return true;
  206. }
  207. }