package logic import ( "context" "errors" "juwan-backend/app/community/rpc/internal/svc" "juwan-backend/app/community/rpc/pb" "github.com/zeromicro/go-zero/core/logx" ) type DelCommentLikesLogic struct { ctx context.Context svcCtx *svc.ServiceContext logx.Logger } func NewDelCommentLikesLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DelCommentLikesLogic { return &DelCommentLikesLogic{ ctx: ctx, svcCtx: svcCtx, Logger: logx.WithContext(ctx), } } func (l *DelCommentLikesLogic) DelCommentLikes(in *pb.DelCommentLikesReq) (*pb.DelCommentLikesResp, error) { if in.GetId() <= 0 { return nil, errors.New("id is required") } store := l.svcCtx.Store store.Mu.Lock() defer store.Mu.Unlock() if in.UserId != nil && in.GetUserId() > 0 { key := commentLikeKey(in.GetId(), in.GetUserId()) if _, ok := store.CommentLikes[key]; ok { delete(store.CommentLikes, key) if comment, ok := store.Comments[in.GetId()]; ok && comment.LikeCount > 0 { comment.LikeCount-- } } return &pb.DelCommentLikesResp{}, nil } removed := int64(0) for key, like := range store.CommentLikes { if like.GetCommentId() == in.GetId() { delete(store.CommentLikes, key) removed++ } } if removed > 0 { if comment, ok := store.Comments[in.GetId()]; ok { if comment.LikeCount >= removed { comment.LikeCount -= removed } else { comment.LikeCount = 0 } } } return &pb.DelCommentLikesResp{}, nil }