Skip to content

Commit

Permalink
#114 Add workflow execution association request
Browse files Browse the repository at this point in the history
  • Loading branch information
tangjiawei committed Nov 5, 2024
1 parent f05be69 commit 6f2af73
Showing 1 changed file with 15 additions and 0 deletions.
15 changes: 15 additions & 0 deletions taskman-server/api/v2/request/request.go
Original file line number Diff line number Diff line change
Expand Up @@ -228,6 +228,8 @@ func GetRequestHistory(c *gin.Context) {
func PluginCreateRequest(c *gin.Context) {
response := models.PluginRequestCreateResp{ResultCode: "0", ResultMessage: "success", Results: models.PluginRequestCreateOutput{}}
var err error
var users []string
var exist bool
defer func() {
if err != nil {
log.Logger.Error("Plugin request create handle fail", log.Error(err))
Expand All @@ -248,6 +250,19 @@ func PluginCreateRequest(c *gin.Context) {
requestToken := c.GetHeader("Authorization")
requestLanguage := "en"
for _, input := range param.Inputs {
users, err = service.GetRoleService().QueryUserByRoles([]string{input.ReportRole},
c.GetHeader("Authorization"), c.GetHeader(middleware.AcceptLanguageHeader))
exist = false
for _, user := range users {
if user == input.ReportUser {
exist = true
}
}
if !exist {
// 用户和角色填写不匹配,返回错误
err = fmt.Errorf("role:%s and user:%s do not match", input.ReportUser, input.ReportRole)
return
}
output, tmpErr := handlePluginRequestCreate(input, param.RequestId, requestToken, requestLanguage)
if tmpErr != nil {
output.ErrorCode = "1"
Expand Down

0 comments on commit 6f2af73

Please sign in to comment.