hxx 3 vuotta sitten
vanhempi
säilyke
bc691e768c

+ 2 - 0
src/main/java/com/caesolver/mq/Solver.java

@@ -57,6 +57,8 @@ public class Solver {
 				channel.basicReject(message.getMessageProperties().getDeliveryTag(),false);//消息确认
 			}
 		} catch (Exception e) {
+			e.printStackTrace();
+			log.info(e.getMessage());
 			log.info("消息处理异常 不处理消息 退出");
 			SolverService.ISRUN=false;
 			// TODO: handle exception

+ 1 - 1
src/main/java/com/caesolver/server/SolverHcfdOrderUtil.java

@@ -45,7 +45,7 @@ public class SolverHcfdOrderUtil {
 	     */
 	    private String createUnixexe(String projectId,Integer vfreq,Integer afreq,String resources) throws IOException {
 	        String exeorder;
-	        String[] res =resources.split("*");
+	        String[] res =resources.split("\\.");
 	        exeorder= getUnixRunOrder(projectId,vfreq,afreq,Integer.valueOf(res[1]));
 	        Path pFilePaths = Files.walk(Paths.get(this.HCFD_workdir+"/"+projectId))
 	        		.filter(path -> path.toFile().isDirectory())

+ 4 - 4
src/main/java/com/caesolver/server/SolverService.java

@@ -54,10 +54,10 @@ public class SolverService {
 	public void precessController(SolverBatchHcfd vo) throws IOException, Exception {
 		String startTime =TimeUtils.getNow();
 		logPut(vo, "Solver start");
-		filehHcfdDown(vo);// 下载文件
-		String jobOrder = hcfdOrderUtil.createOrder(vo);
-		jobExec(jobOrder, vo);
-		sftpUtil.uploadBatchDataOut(vo);
+//		filehHcfdDown(vo);// 下载文件
+//		String jobOrder = hcfdOrderUtil.createOrder(vo);
+//		jobExec(jobOrder, vo);
+//		sftpUtil.uploadBatchDataOut(vo);
 //		//求解结束
 		logPut(vo, "Solver end");
 		String endTime =TimeUtils.getNow();