| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| |
| package controller |
| |
| import ( |
| "github.com/apache/answer/internal/base/handler" |
| "github.com/apache/answer/internal/base/middleware" |
| "github.com/apache/answer/internal/base/reason" |
| "github.com/apache/answer/internal/base/translator" |
| "github.com/apache/answer/internal/base/validator" |
| "github.com/apache/answer/internal/entity" |
| "github.com/apache/answer/internal/schema" |
| "github.com/apache/answer/internal/service/action" |
| "github.com/apache/answer/internal/service/content" |
| "github.com/apache/answer/internal/service/rank" |
| "github.com/apache/answer/pkg/uid" |
| "github.com/gin-gonic/gin" |
| "github.com/segmentfault/pacman/errors" |
| ) |
| |
| // VoteController activity controller |
| type VoteController struct { |
| VoteService *content.VoteService |
| rankService *rank.RankService |
| actionService *action.CaptchaService |
| } |
| |
| // NewVoteController new controller |
| func NewVoteController( |
| voteService *content.VoteService, |
| rankService *rank.RankService, |
| actionService *action.CaptchaService, |
| ) *VoteController { |
| return &VoteController{ |
| VoteService: voteService, |
| rankService: rankService, |
| actionService: actionService, |
| } |
| } |
| |
| // VoteUp godoc |
| // @Summary vote up |
| // @Description add vote |
| // @Tags Activity |
| // @Accept json |
| // @Produce json |
| // @Security ApiKeyAuth |
| // @Param data body schema.VoteReq true "vote" |
| // @Success 200 {object} handler.RespBody{data=schema.VoteResp} |
| // @Router /answer/api/v1/vote/up [post] |
| func (vc *VoteController) VoteUp(ctx *gin.Context) { |
| req := &schema.VoteReq{} |
| if handler.BindAndCheck(ctx, req) { |
| return |
| } |
| req.ObjectID = uid.DeShortID(req.ObjectID) |
| req.UserID = middleware.GetLoginUserIDFromContext(ctx) |
| |
| can, needRank, err := vc.rankService.CheckVotePermission(ctx, req.UserID, req.ObjectID, true) |
| if err != nil { |
| handler.HandleResponse(ctx, err, nil) |
| return |
| } |
| if !can { |
| lang := handler.GetLang(ctx) |
| msg := translator.TrWithData(lang, reason.NoEnoughRankToOperate, &schema.PermissionTrTplData{Rank: needRank}) |
| handler.HandleResponse(ctx, errors.Forbidden(reason.NoEnoughRankToOperate).WithMsg(msg), nil) |
| return |
| } |
| |
| isAdmin := middleware.GetUserIsAdminModerator(ctx) |
| if !isAdmin { |
| captchaPass := vc.actionService.ActionRecordVerifyCaptcha(ctx, entity.CaptchaActionVote, req.UserID, req.CaptchaID, req.CaptchaCode) |
| if !captchaPass { |
| errFields := append([]*validator.FormErrorField{}, &validator.FormErrorField{ |
| ErrorField: "captcha_code", |
| ErrorMsg: translator.Tr(handler.GetLang(ctx), reason.CaptchaVerificationFailed), |
| }) |
| handler.HandleResponse(ctx, errors.BadRequest(reason.CaptchaVerificationFailed), errFields) |
| return |
| } |
| } |
| |
| if !isAdmin { |
| vc.actionService.ActionRecordAdd(ctx, entity.CaptchaActionVote, req.UserID) |
| } |
| resp, err := vc.VoteService.VoteUp(ctx, req) |
| if err != nil { |
| handler.HandleResponse(ctx, err, schema.ErrTypeToast) |
| } else { |
| handler.HandleResponse(ctx, err, resp) |
| } |
| } |
| |
| // VoteDown godoc |
| // @Summary vote down |
| // @Description add vote |
| // @Tags Activity |
| // @Accept json |
| // @Produce json |
| // @Security ApiKeyAuth |
| // @Param data body schema.VoteReq true "vote" |
| // @Success 200 {object} handler.RespBody{data=schema.VoteResp} |
| // @Router /answer/api/v1/vote/down [post] |
| func (vc *VoteController) VoteDown(ctx *gin.Context) { |
| req := &schema.VoteReq{} |
| if handler.BindAndCheck(ctx, req) { |
| return |
| } |
| req.ObjectID = uid.DeShortID(req.ObjectID) |
| req.UserID = middleware.GetLoginUserIDFromContext(ctx) |
| isAdmin := middleware.GetUserIsAdminModerator(ctx) |
| |
| can, needRank, err := vc.rankService.CheckVotePermission(ctx, req.UserID, req.ObjectID, false) |
| if err != nil { |
| handler.HandleResponse(ctx, err, nil) |
| return |
| } |
| if !can { |
| lang := handler.GetLang(ctx) |
| msg := translator.TrWithData(lang, reason.NoEnoughRankToOperate, &schema.PermissionTrTplData{Rank: needRank}) |
| handler.HandleResponse(ctx, errors.Forbidden(reason.NoEnoughRankToOperate).WithMsg(msg), nil) |
| return |
| } |
| |
| if !isAdmin { |
| captchaPass := vc.actionService.ActionRecordVerifyCaptcha(ctx, entity.CaptchaActionVote, req.UserID, req.CaptchaID, req.CaptchaCode) |
| if !captchaPass { |
| errFields := append([]*validator.FormErrorField{}, &validator.FormErrorField{ |
| ErrorField: "captcha_code", |
| ErrorMsg: translator.Tr(handler.GetLang(ctx), reason.CaptchaVerificationFailed), |
| }) |
| handler.HandleResponse(ctx, errors.BadRequest(reason.CaptchaVerificationFailed), errFields) |
| return |
| } |
| } |
| if !isAdmin { |
| vc.actionService.ActionRecordAdd(ctx, entity.CaptchaActionVote, req.UserID) |
| } |
| resp, err := vc.VoteService.VoteDown(ctx, req) |
| if err != nil { |
| handler.HandleResponse(ctx, err, schema.ErrTypeToast) |
| } else { |
| handler.HandleResponse(ctx, err, resp) |
| } |
| } |
| |
| // UserVotes user votes |
| // @Summary get user personal votes |
| // @Description get user personal votes |
| // @Tags Activity |
| // @Accept json |
| // @Produce json |
| // @Security ApiKeyAuth |
| // @Param page query int false "page size" |
| // @Param page_size query int false "page size" |
| // @Success 200 {object} handler.RespBody{data=pager.PageModel{list=[]schema.GetVoteWithPageResp}} |
| // @Router /answer/api/v1/personal/vote/page [get] |
| func (vc *VoteController) UserVotes(ctx *gin.Context) { |
| req := schema.GetVoteWithPageReq{} |
| if handler.BindAndCheck(ctx, &req) { |
| return |
| } |
| |
| req.UserID = middleware.GetLoginUserIDFromContext(ctx) |
| |
| resp, err := vc.VoteService.ListUserVotes(ctx, req) |
| handler.HandleResponse(ctx, err, resp) |
| } |