|
@@ -373,11 +373,18 @@ public class D00008Service extends D00008BaseModel implements ExecProcessFlow {
|
|
|
//异步执行
|
|
|
@SneakyThrows
|
|
|
public void exeWater2(Integer aid,Integer jid){
|
|
|
+
|
|
|
+ try {
|
|
|
+ LogService.addLog(aid,jid,"Water","求解——————————————————开始");
|
|
|
+ DockerExe.stopDocker(aid,"Water");
|
|
|
+ DockerExe.waterExec(aid, jid, "Water");
|
|
|
+ }catch (Exception e) {
|
|
|
+ LogService.addLog(aid,jid,"Water","求解——————————————————失败");
|
|
|
+ JobError(jid);
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
CompletableFuture<Void> cf = CompletableFuture.supplyAsync(()-> {
|
|
|
try {
|
|
|
- LogService.addLog(aid,jid,"Water","求解——————————————————开始");
|
|
|
- DockerExe.stopDocker(aid,"Water");
|
|
|
- DockerExe.waterExec(aid, jid,"Water");
|
|
|
DockerExe.getDockerLogs(aid,"Water",new ResultCallback.Adapter<Frame>() {
|
|
|
@Override
|
|
|
public void onNext(Frame frame) {
|