NoticeService.php 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125
  1. <?php
  2. namespace App\Services;
  3. use App\Models\DynamicZanModel;
  4. use App\Models\UserLikeModel;
  5. use App\Models\UserSystemMessageModel;
  6. use PHPUnit\Util\Exception;
  7. use function Symfony\Component\Translation\t;
  8. class NoticeService
  9. {
  10. /**
  11. * 获取消息列表
  12. */
  13. public function get_notice_list(){
  14. }
  15. /**
  16. * 获取喜欢列表
  17. */
  18. public function get_like_list($param){
  19. $query = UserLikeModel::query();
  20. if($param['type']==1){
  21. //我喜欢
  22. $query = $query->with(['like_user'=>function($query){
  23. $query->select('id','sex','is_vip','tencent_im_user_id');
  24. },'like_user_info'])->where('user_id',$param['user_id']);
  25. // $query = $query->leftJoin('users','users_like.like_id','=','users.id')
  26. // ->leftJoin('users_info','users_like.like_id','=','users_info.user_id')
  27. // ->where('users_like.user_id',$param['user_id'])
  28. // ->select(['users_like.id','users_like.user_id','users_like.like_id','users_like.atime','users.sex','users.is_vip','users.tencent_im_user_id','users_info.nickname','users_info.avatar','users_info.birthday','users_info.work','users_info.height','users_info.weight']);
  29. }else{
  30. //喜欢我
  31. // $query = $query->with(['user'=>function($query){
  32. // $query->select('id','sex','is_vip','tencent_im_user_id');
  33. // },'user_info'])->where('like_id',$param['user_id']);
  34. $query = $query->leftJoin('users','users_like.user_id','=','users.id')
  35. ->leftJoin('users_info','users_like.user_id','=','users_info.user_id')
  36. ->where('users_like.like_id',$param['user_id'])
  37. ->select(['users_like.id','users_like.user_id','users_like.like_id','users_like.atime','users.sex','users.is_vip','users.tencent_im_user_id','users_info.nickname','users_info.avatar','users_info.birthday','users_info.work','users_info.height','users_info.weight']);
  38. //清除喜欢我未读状态
  39. UserLikeModel::query()->where(['like_id'=>$param['user_id'],'status'=>0])->update(['status'=>1]);
  40. }
  41. $query = $query->orderByDesc('id')
  42. ->paginate(request('perPage',20));
  43. $query = $query->toArray();
  44. foreach ($query['data'] as $k=>$v){
  45. $query['data'][$k]['distance'] = 0; //计算距离
  46. $query['data'][$k]['age'] = !empty($v['birthday'])?birthday($v['birthday']):0; //计算距离
  47. }
  48. return $query;
  49. }
  50. /**
  51. * 获取点赞列表
  52. */
  53. public function get_zan_list($param){
  54. $query = DynamicZanModel::query();
  55. if($param['type']==1){
  56. //他赞了我
  57. $query = $query->with(['dynamic','user'=>function($query){
  58. $query->select('id','sex','is_vip','tencent_im_user_id');
  59. },'user_info'=>function($query){
  60. $query->select(['user_id','nickname','avatar','height','weight','work','birthday']);
  61. }])->whereHas('dynamic',function ($query)use($param){
  62. $query->where('user_id',$param['user_id'])->select();
  63. });
  64. //清除他赞了我未读状态
  65. DynamicZanModel::query()->with(['dynamic'])->where('status','=',0)->whereHas('dynamic',function ($query)use($param){
  66. $query->where('user_id',$param['user_id'])->select('id','user_id','content','img_url');
  67. })->update(['status'=>1]);
  68. }else{
  69. //我赞了他
  70. $query = $query->with(['dynamic'=>function($query){
  71. $query->select('id','user_id','content','img_url');
  72. },'dynamic.user'=>function($querty){
  73. $querty->select('id','sex','is_vip','tencent_im_user_id');
  74. },'dynamic.user_info'=>function($querty){
  75. $querty->select(['user_id','nickname','avatar','height','weight','work','birthday']);
  76. }])
  77. ->where('user_id',$param['user_id']);
  78. }
  79. $query = $query->orderByDesc('id')
  80. ->paginate(request('perPage',20));
  81. $query = $query->toArray();
  82. foreach ($query['data'] as $k=>$v){
  83. $query['data'][$k]['atime'] = uc_time_ago(strtotime($v['atime']));
  84. $query['data'][$k]['dynamic']['img_url'] = json_decode($v['dynamic']['img_url'],true);
  85. }
  86. return $query;
  87. }
  88. /**
  89. * 删除消息
  90. */
  91. public function del_message($id){
  92. if(empty($id)){
  93. throw new Exception("参数错误");
  94. }
  95. $user = auth('api')->user();
  96. if(!$message = UserSystemMessageModel::query()->where(['id'=>$id,'user_id'=>$user->id])->find($id)){
  97. throw new Exception("消息不存在");
  98. }
  99. $message->is_delete = 1;
  100. $message->save();
  101. return true;
  102. }
  103. }