ソースを参照

优化器到求解组件

huangxingxing 3 ヶ月 前
コミット
6c7a5a4c88

+ 10 - 0
src/main/java/com/miniframe/bisiness/mdo/MDO0039Service.java

@@ -226,12 +226,14 @@ public class MDO0039Service extends MDO0039BaseModel implements ExecProcessFlow
 					System.err.println("日志获取失败");
 					LogService.addLog(pid, line[0]);
 					throwable.printStackTrace();
+					DockerExe.stopDocker(pid);
 					super.onError(throwable);
 				}
 				@Override
 				public void onComplete() {
 					System.out.println("日志获取完成");
 					LogService.addLog(pid, line[0]);
+					DockerExe.stopDocker(pid);
 					super.onComplete();
 				}
 			});
@@ -298,11 +300,13 @@ public class MDO0039Service extends MDO0039BaseModel implements ExecProcessFlow
 //					LogService.addLog(pid, line[0]);
 					throwable.printStackTrace();
 					super.onError(throwable);
+					DockerExe.stopDocker(pid);
 				}
 				@Override
 				public void onComplete() {
 					System.out.println("日志获取完成");
 //					LogService.addLog(pid, line[0]);
+					DockerExe.stopDocker(pid);
 					super.onComplete();
 				}
 			});
@@ -374,12 +378,14 @@ public class MDO0039Service extends MDO0039BaseModel implements ExecProcessFlow
 					System.err.println("日志获取失败");
 					LogService.addLog(pid, line[0]);
 					throwable.printStackTrace();
+					DockerExe.stopDocker(pid);
 					super.onError(throwable);
 				}
 				@Override
 				public void onComplete() {
 					System.out.println("日志获取完成");
 					LogService.addLog(pid, line[0]);
+					DockerExe.stopDocker(pid);
 					super.onComplete();
 				}
 			});
@@ -445,12 +451,14 @@ public class MDO0039Service extends MDO0039BaseModel implements ExecProcessFlow
 					System.err.println("日志获取失败");
 					LogService.addLog(pid, line[0]);
 					throwable.printStackTrace();
+					DockerExe.stopDocker(pid);
 					super.onError(throwable);
 				}
 				@Override
 				public void onComplete() {
 					System.out.println("日志获取完成");
 					LogService.addLog(pid, line[0]);
+					DockerExe.stopDocker(pid);
 					super.onComplete();
 				}
 			});
@@ -498,11 +506,13 @@ public class MDO0039Service extends MDO0039BaseModel implements ExecProcessFlow
 				public void onError(Throwable throwable) {
 					System.err.println("日志获取失败");
 					throwable.printStackTrace();
+					DockerExe.stopDocker(pid);
 					super.onError(throwable);
 				}
 				@Override
 				public void onComplete() {
 					System.out.println("日志获取完成");
+					DockerExe.stopDocker(pid);
 					super.onComplete();
 				}
 			});

+ 2 - 0
src/main/java/com/miniframe/bisiness/mdo/MDO0072Service.java

@@ -69,11 +69,13 @@ public class MDO0072Service extends MDO0072BaseModel implements ExecProcessFlow
 					public void onError(Throwable throwable) {
 						System.err.println("日志获取失败");
 						throwable.printStackTrace();
+						DockerExe.stopDocker(file.getId());
 						super.onError(throwable);
 					}
 					@Override
 					public void onComplete() {
 						System.out.println("日志获取完成");
+						DockerExe.stopDocker(file.getId());
 						sendMsg(file.getId(), line[0]);
 						super.onComplete();
 					}

+ 2 - 0
src/main/java/com/miniframe/bisiness/mdo/MDO0075Service.java

@@ -68,12 +68,14 @@ public class MDO0075Service extends MDO0075BaseModel implements ExecProcessFlow
 					public void onError(Throwable throwable) {
 						System.err.println("日志获取失败");
 						throwable.printStackTrace();
+						DockerExe.stopDocker(file.getId());
 						super.onError(throwable);
 					}
 					@Override
 					public void onComplete() {
 						System.out.println("日志获取完成");
 						sendMsg(file.getId(), line[0]);
+						DockerExe.stopDocker(file.getId());
 						super.onComplete();
 					}
 				});