刘韬 4 years ago
parent
commit
6f3787e454

+ 1 - 1
DataFusion/src/com/zskk/config/ZskkConfig.java

@@ -95,7 +95,7 @@ public class ZskkConfig extends JFinalConfig {
 		me.add(inData);
 		
 		Cron4jPlugin cgData = new Cron4jPlugin();
-		cgData.addTask("*/1 * * * *", new CGetTask());
+		cgData.addTask("*/2 * * * *", new CGetTask());
 		me.add(cgData);
 	}
 

+ 9 - 1
DataFusion/src/com/zskk/task/CGetTask.java

@@ -12,10 +12,18 @@ public class CGetTask implements ITask {
 	@Override
 	public void run() {
 		// TODO Auto-generated method stub
-		Record studyidfind = Db.use("local").findFirst("select * from study where status =1 order by createAt asc");
+		Record studyidfind = Db.use("local").findFirst("select * from study where status =1 or status =4 order by createAt asc");
+		if (studyidfind == null) {
+			return;
+		}
 		studyidfind.set("status", 2);
 		Db.use("local").update("study", studyidfind);
 		String execCmd = ExecUtil.execCmd("/zskk_system/other/cget.sh " + studyidfind.getStr("studyuid"));
+		if (execCmd.contains("Connection refused")) {
+			studyidfind.set("status", 4);
+			Db.use("local").update("study", studyidfind);
+			return;
+		}
 		studyidfind.set("status", 3);
 		Db.use("local").update("study", studyidfind);
 	}

+ 2 - 2
DataFusion/src/com/zskk/tools/ExecUtil.java

@@ -43,8 +43,8 @@ public class ExecUtil {
 	  }
 	 
 	  public static void main(String[] args) {
-	    String command = "ping 192.168.0.10";
-	    String result = ExecUtil.execCmd(command);
+	    String command = "ping 192.168.1.1";
+	    String result = ExecUtil.execCmd(command+" -c4");
 	    System.out.println(result);
 	  }
 }