Skip to content

Commit 743329d

Browse files
committed
Adjust the notification message
1 parent e4a261c commit 743329d

File tree

1 file changed

+8
-1
lines changed
  • streamis-jobmanager/streamis-jobmanager-server/src/main/java/com/webank/wedatasphere/streamis/jobmanager/restful/api

1 file changed

+8
-1
lines changed

streamis-jobmanager/streamis-jobmanager-server/src/main/java/com/webank/wedatasphere/streamis/jobmanager/restful/api/JobRestfulApi.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ public Message getJobList(HttpServletRequest req,
7676
@RequestParam(value = "jobCreator", required = false) String jobCreator) throws JobException {
7777
String username = SecurityFilter.getLoginUsername(req);
7878
if(StringUtils.isBlank(projectName)){
79-
return Message.error("ProjectName cannot be empty(项目名不能为空,请指定)");
79+
return Message.error("Project name cannot be empty(项目名不能为空,请指定)");
8080
}
8181
if (Objects.isNull(pageNow)) {
8282
pageNow = 1;
@@ -98,6 +98,13 @@ public Message getJobList(HttpServletRequest req,
9898
@RequestMapping(path = "/createOrUpdate", method = RequestMethod.POST)
9999
public Message createOrUpdate(HttpServletRequest req, @Validated @RequestBody MetaJsonInfo metaJsonInfo) throws Exception {
100100
String username = SecurityFilter.getLoginUsername(req);
101+
String projectName = metaJsonInfo.getProjectName();
102+
if (StringUtils.isBlank(projectName)){
103+
return Message.error("Project name cannot be empty(项目名不能为空,请指定)");
104+
}
105+
if(!this.privilegeService.hasAccessPrivilege(req, projectName)){
106+
return Message.error("Have no permission to create or update StreamJob in project [" + projectName + "]");
107+
}
101108
StreamJobVersion job = streamJobService.createOrUpdate(username, metaJsonInfo);
102109
return Message.ok().data("jobId", job.getJobId());
103110
}

0 commit comments

Comments
 (0)