NoticeService.php 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
  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. }else{
  26. //喜欢我
  27. $query = $query->with(['user'=>function($query){
  28. $query->select('id','sex','is_vip','tencent_im_user_id');
  29. },'user_info as userinfo'])->where('like_id',$param['user_id']);
  30. //清除喜欢我未读状态
  31. UserLikeModel::query()->where(['like_id'=>$param['user_id'],'status'=>0])->update(['status'=>1]);
  32. }
  33. $query = $query->orderByDesc('id')
  34. ->paginate(request('perPage',20));
  35. $query = $query->toArray();
  36. foreach ($query['data'] as $k=>$v){
  37. $query['data'][$k]['distance'] = 0; //计算距离
  38. }
  39. return $query;
  40. }
  41. /**
  42. * 获取点赞列表
  43. */
  44. public function get_zan_list($param){
  45. $query = DynamicZanModel::query();
  46. if($param['type']==1){
  47. //他赞了我
  48. $query = $query->with(['dynamic','user'=>function($query){
  49. $query->select('id','sex','is_vip','tencent_im_user_id');
  50. },'user_info'=>function($query){
  51. $query->select(['user_id','nickname','avatar','height','weight','work','birthday']);
  52. }])->whereHas('dynamic',function ($query)use($param){
  53. $query->where('user_id',$param['user_id'])->select();
  54. });
  55. //清除他赞了我未读状态
  56. DynamicZanModel::query()->with(['dynamic'])->where('status','=',0)->whereHas('dynamic',function ($query)use($param){
  57. $query->where('user_id',$param['user_id'])->select('id','user_id','content','img_url');
  58. })->update(['status'=>1]);
  59. }else{
  60. //我赞了他
  61. $query = $query->with(['dynamic'=>function($query){
  62. $query->select('id','user_id','content','img_url');
  63. },'dynamic.user'=>function($querty){
  64. $querty->select('id','sex','is_vip','tencent_im_user_id');
  65. },'dynamic.user_info'=>function($querty){
  66. $querty->select(['user_id','nickname','avatar','height','weight','work','birthday']);
  67. }])
  68. ->where('user_id',$param['user_id']);
  69. }
  70. $query = $query->orderByDesc('id')
  71. ->paginate(request('perPage',20));
  72. $query = $query->toArray();
  73. foreach ($query['data'] as $k=>$v){
  74. $query['data'][$k]['atime'] = uc_time_ago(strtotime($v['atime']));
  75. $query['data'][$k]['dynamic']['img_url'] = json_decode($v['dynamic']['img_url'],true);
  76. }
  77. return $query;
  78. }
  79. /**
  80. * 删除消息
  81. */
  82. public function del_message($id){
  83. if(empty($id)){
  84. throw new Exception("参数错误");
  85. }
  86. $user = auth('api')->user();
  87. if(!$message = UserSystemMessageModel::query()->where(['id'=>$id,'user_id'=>$user->id])->find($id)){
  88. throw new Exception("消息不存在");
  89. }
  90. $message->is_delete = 1;
  91. $message->save();
  92. return true;
  93. }
  94. }