|
@@ -27,6 +27,7 @@ import java.util.ArrayList; |
|
@@ -27,6 +27,7 @@ import java.util.ArrayList; |
27
|
import java.util.HashMap;
|
27
|
import java.util.HashMap;
|
28
|
import java.util.List;
|
28
|
import java.util.List;
|
29
|
import java.util.Map;
|
29
|
import java.util.Map;
|
|
|
30
|
+import java.util.concurrent.CompletableFuture;
|
30
|
|
31
|
|
31
|
|
32
|
|
32
|
@RestController
|
33
|
@RestController
|
|
@@ -81,6 +82,8 @@ public class DockerBuildCtrl { |
|
@@ -81,6 +82,8 @@ public class DockerBuildCtrl { |
81
|
model.addAttribute("releaseWorkJob_projectDeployType", map.get("projectDeployType")==null?"":(String)map.get("projectDeployType"));
|
82
|
model.addAttribute("releaseWorkJob_projectDeployType", map.get("projectDeployType")==null?"":(String)map.get("projectDeployType"));
|
82
|
model.addAttribute("releaseWorkJob_branch", map.get("branch")==null?"":(String)map.get("branch"));
|
83
|
model.addAttribute("releaseWorkJob_branch", map.get("branch")==null?"":(String)map.get("branch"));
|
83
|
model.addAttribute("releaseWorkJob_imageFile", map.get("imageFile")==null?"":(String)map.get("imageFile"));
|
84
|
model.addAttribute("releaseWorkJob_imageFile", map.get("imageFile")==null?"":(String)map.get("imageFile"));
|
|
|
85
|
+ model.addAttribute("releaseWorkJob_uploadCDN", map.get("uploadCDN")==null?"":String.valueOf(map.get("uploadCDN")));
|
|
|
86
|
+ model.addAttribute("releaseWorkJob_cdnBranch", map.get("cdnBranch")==null?"":String.valueOf(map.get("cdnBranch")));
|
84
|
model.addAttribute("releaseWorkJob_project",releaseWorkJob_project);
|
87
|
model.addAttribute("releaseWorkJob_project",releaseWorkJob_project);
|
85
|
model.addAttribute("releaseWorkJob_id", workJobId);
|
88
|
model.addAttribute("releaseWorkJob_id", workJobId);
|
86
|
}
|
89
|
}
|
|
@@ -103,7 +106,7 @@ public class DockerBuildCtrl { |
|
@@ -103,7 +106,7 @@ public class DockerBuildCtrl { |
103
|
BaseResponse response=httpRestClient.defaultGet("/dockerProject/getDockerProjectMapByIds", BaseResponse.class, mapIds);
|
106
|
BaseResponse response=httpRestClient.defaultGet("/dockerProject/getDockerProjectMapByIds", BaseResponse.class, mapIds);
|
104
|
Map projectMap=JSON.parseObject((String)response.getData(),Map.class);
|
107
|
Map projectMap=JSON.parseObject((String)response.getData(),Map.class);
|
105
|
|
108
|
|
106
|
- if("deploy".equalsIgnoreCase(operate_name)){
|
109
|
+ if("deploy".equalsIgnoreCase(operate_name)&&"git".equals(project_deploy_type)){
|
107
|
for(String buildIdWithProjectId:buildIds.split(",")){
|
110
|
for(String buildIdWithProjectId:buildIds.split(",")){
|
108
|
int index = buildIdWithProjectId.indexOf("-");
|
111
|
int index = buildIdWithProjectId.indexOf("-");
|
109
|
String projectId=buildIdWithProjectId.substring(0,index);
|
112
|
String projectId=buildIdWithProjectId.substring(0,index);
|
|
@@ -116,6 +119,7 @@ public class DockerBuildCtrl { |
|
@@ -116,6 +119,7 @@ public class DockerBuildCtrl { |
116
|
buildInfoList.add(map);
|
119
|
buildInfoList.add(map);
|
117
|
}
|
120
|
}
|
118
|
}else{
|
121
|
}else{
|
|
|
122
|
+ //回滚 或者 镜像文件发布
|
119
|
String projectId=project_id;
|
123
|
String projectId=project_id;
|
120
|
Map map=new HashMap();
|
124
|
Map map=new HashMap();
|
121
|
map.put("projectId",projectId);
|
125
|
map.put("projectId",projectId);
|
|
@@ -136,6 +140,7 @@ public class DockerBuildCtrl { |
|
@@ -136,6 +140,7 @@ public class DockerBuildCtrl { |
136
|
model.addAttribute("clusters_text", clusters_text);
|
140
|
model.addAttribute("clusters_text", clusters_text);
|
137
|
model.addAttribute("operate_name", operate_name);
|
141
|
model.addAttribute("operate_name", operate_name);
|
138
|
model.addAttribute("branch_name", branch_name);
|
142
|
model.addAttribute("branch_name", branch_name);
|
|
|
143
|
+ model.addAttribute("project_deploy_type", project_deploy_type);
|
139
|
model.addAttribute("image_file_name", image_file_name);
|
144
|
model.addAttribute("image_file_name", image_file_name);
|
140
|
model.addAttribute("workid_name", workid_name);
|
145
|
model.addAttribute("workid_name", workid_name);
|
141
|
model.addAttribute("rollbackfile_name", rollbackImageStore);
|
146
|
model.addAttribute("rollbackfile_name", rollbackImageStore);
|
|
@@ -251,13 +256,13 @@ public class DockerBuildCtrl { |
|
@@ -251,13 +256,13 @@ public class DockerBuildCtrl { |
251
|
**/
|
256
|
**/
|
252
|
@RequestMapping(value = "/rollback")
|
257
|
@RequestMapping(value = "/rollback")
|
253
|
@ResponseBody
|
258
|
@ResponseBody
|
254
|
- public BaseResponse rollback(String project_id, String environment_name, String clusters_name,String rollbackImageStore){
|
259
|
+ public BaseResponse deployByImageStore(String project_id, String environment_name, String clusters_name,String rollbackImageStore){
|
255
|
Map<String, String> map = new HashMap<>();
|
260
|
Map<String, String> map = new HashMap<>();
|
256
|
map.put("projectId", project_id);
|
261
|
map.put("projectId", project_id);
|
257
|
map.put("environment", environment_name);
|
262
|
map.put("environment", environment_name);
|
258
|
map.put("clusters_name", clusters_name);
|
263
|
map.put("clusters_name", clusters_name);
|
259
|
map.put("rollbackImageStore", rollbackImageStore);
|
264
|
map.put("rollbackImageStore", rollbackImageStore);
|
260
|
- return httpRestClient.defaultGet("/dockerProject/rollback", BaseResponse.class, map);
|
265
|
+ return httpRestClient.defaultGet(HttpUriContants.DOCKER_DEPLOY_ROLLBACK_BY_IMAGE, BaseResponse.class, map);
|
261
|
}
|
266
|
}
|
262
|
|
267
|
|
263
|
/**
|
268
|
/**
|
|
@@ -268,12 +273,32 @@ public class DockerBuildCtrl { |
|
@@ -268,12 +273,32 @@ public class DockerBuildCtrl { |
268
|
@RequestMapping(value = "/mirrorAndDeploy")
|
273
|
@RequestMapping(value = "/mirrorAndDeploy")
|
269
|
@ResponseBody
|
274
|
@ResponseBody
|
270
|
public BaseResponse mirrorAndDeploy(String project_id, String project_name,
|
275
|
public BaseResponse mirrorAndDeploy(String project_id, String project_name,
|
271
|
- String environment_name,String clusters_name, String operate_name,String project_deploy_type, String branch_name,String image_file_name,
|
|
|
272
|
- String rollbackfile_name,String workid_name, Model model, HttpSession session) {
|
|
|
273
|
- DockerJenkinsReq dockerJenkinsReq=new DockerJenkinsReq();
|
276
|
+ String environment_name,String clusters_name, String operate_name,String project_deploy_type,
|
|
|
277
|
+ String branch_name,String image_file_name,
|
|
|
278
|
+ String rollbackfile_name,String workid_name,int uploadCDN,String cdnBranch, Model model, HttpSession session) {
|
274
|
User user = (User) session.getAttribute("user");
|
279
|
User user = (User) session.getAttribute("user");
|
275
|
- dockerJenkinsReq.setUserName(user.getName());
|
|
|
276
|
- dockerJenkinsReq.setUserMail(user.getEmail());
|
280
|
+ String userName=user.getName();
|
|
|
281
|
+ String userEmail=user.getEmail();
|
|
|
282
|
+ if("image".equals(project_deploy_type)){
|
|
|
283
|
+ if(1==uploadCDN){
|
|
|
284
|
+ //发布异步任务
|
|
|
285
|
+ CompletableFuture.runAsync(new Runnable() {
|
|
|
286
|
+ @Override
|
|
|
287
|
+ public void run() {
|
|
|
288
|
+ Map<String,String> param=new HashMap<>();
|
|
|
289
|
+ param.put("projectId",project_id);
|
|
|
290
|
+ param.put("cdnBranch",cdnBranch);
|
|
|
291
|
+ param.put("workid_name",workid_name);
|
|
|
292
|
+ param.put("operatorEmail",userEmail);
|
|
|
293
|
+ httpRestClient.defaultGet("/dockerProject/uploadCDN",BaseResponse.class,param);
|
|
|
294
|
+ }
|
|
|
295
|
+ });
|
|
|
296
|
+ }
|
|
|
297
|
+ return deployByImageStore(project_id,environment_name,clusters_name,image_file_name);
|
|
|
298
|
+ }
|
|
|
299
|
+ DockerJenkinsReq dockerJenkinsReq=new DockerJenkinsReq();
|
|
|
300
|
+ dockerJenkinsReq.setUserName(userName);
|
|
|
301
|
+ dockerJenkinsReq.setUserMail(userEmail);
|
277
|
dockerJenkinsReq.setProjectIds(project_id);
|
302
|
dockerJenkinsReq.setProjectIds(project_id);
|
278
|
dockerJenkinsReq.setNodeEnv(environment_name);
|
303
|
dockerJenkinsReq.setNodeEnv(environment_name);
|
279
|
dockerJenkinsReq.setClusterId(clusters_name);
|
304
|
dockerJenkinsReq.setClusterId(clusters_name);
|