NoticeService.php 4.9 KB

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