管道灾源

src/main/java/com/miniframe/bisiness/system/D00008Service.java

@@ -4,9 +4,13 @@ import java.io.BufferedReader;
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
 import com.miniframe.core.ExecProcessFlow;
 import com.miniframe.generate.business.system.model.D00008BaseModel;
 import com.miniframe.template.TemplateGenerator;
+import lombok.SneakyThrows;
 
 /**
  * 基础系统,“灾情演练”逻辑处理（重新生成不覆盖）。
@@ -25,19 +29,23 @@ public class D00008Service extends D00008BaseModel implements ExecProcessFlow {
 			TemplateGenerator.createFireControl(aid);
 			TemplateGenerator.createFireRunsh(aid);
 			TemplateGenerator.createFireInit(aid);
-			Runtime runtime = Runtime.getRuntime();
-        	Process p =null;
-        	p= runtime.exec("sh "+TemplateGenerator.BPATH+"/"+aid+"/"+"runFile.sh");
-			InputStream fis = p.getInputStream();
-			InputStreamReader isr = new InputStreamReader(fis);
-			BufferedReader br = new BufferedReader(isr);
-			String line = null;
-			while ((line = br.readLine()) != null) {
-				System.out.println(line);
-			}
+			exeFier(aid);
 		}
 
 	}
+	@SneakyThrows
+	public void exeFier(Integer aid) throws Exception{
+		Runtime runtime = Runtime.getRuntime();
+		Process p =null;
+		p= runtime.exec("sh "+TemplateGenerator.BPATH+"/"+aid+"/"+"runFile.sh");
+		InputStream fis = p.getInputStream();
+		InputStreamReader isr = new InputStreamReader(fis);
+		BufferedReader br = new BufferedReader(isr);
+		String line = null;
+		while ((line = br.readLine()) != null) {
+			System.out.println(line);
+		}
+	}
 	
 	/**
 	 * 基础系统,“灾情演练”业务前处理