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 UpdateCommentsLogic struct { ctx context.Context svcCtx *svc.ServiceContext logx.Logger } func NewUpdateCommentsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateCommentsLogic { return &UpdateCommentsLogic{ ctx: ctx, svcCtx: svcCtx, Logger: logx.WithContext(ctx), } } func (l *UpdateCommentsLogic) UpdateComments(in *pb.UpdateCommentsReq) (*pb.UpdateCommentsResp, error) { if in.GetId() <= 0 { return nil, errors.New("id is required") } store := l.svcCtx.Store store.Mu.Lock() defer store.Mu.Unlock() comment, ok := store.Comments[in.GetId()] if !ok || comment.GetDeletedAt() > 0 { return nil, errors.New("comment not found") } if in.GetPostId() > 0 { comment.PostId = in.GetPostId() } if in.GetAuthorId() > 0 { comment.AuthorId = in.GetAuthorId() } if in.GetContent() != "" { comment.Content = in.GetContent() } if in.GetLikeCount() > 0 { comment.LikeCount = in.GetLikeCount() } if in.GetDeletedAt() > 0 { comment.DeletedAt = in.GetDeletedAt() } if in.GetCreatedAt() > 0 { comment.CreatedAt = in.GetCreatedAt() } return &pb.UpdateCommentsResp{}, nil }