diff --git a/src/com/platform/service/thread/ThreadMoveData.java b/src/com/platform/service/thread/ThreadMoveData.java index ed7350a4..63728914 100644 --- a/src/com/platform/service/thread/ThreadMoveData.java +++ b/src/com/platform/service/thread/ThreadMoveData.java @@ -38,6 +38,8 @@ public class ThreadMoveData{ public final static Logger log = Logger.getLogger(ThreadMoveData.class); + private static boolean iscontinue = false; + @Resource(name = "dataInfoDao") private DataInfoDao dataInfoDao; @@ -71,6 +73,10 @@ public class ThreadMoveData{ //迁移数据 -- 2016-11-30后 使用 @Scheduled(fixedDelay = 4000) public void moveDataByWebGfs(){ + if (iscontinue) { + return; + } + iscontinue = true; List result = new ArrayList(); Map volumeMap = new HashMap(); try { @@ -96,6 +102,7 @@ public class ThreadMoveData{ } catch (Exception e) { log.error(e); } + iscontinue = false; } //5秒 //2016-11-30后 不使用 @@ -370,8 +377,11 @@ public class ThreadMoveData{ //请求迁移 curMoveNum++; //TODO 判断 moveE.getDataPath()的空间大小 和 makeDstPath(moveE.getDstPath())的大小 + //迁移 try { - if(1==copy.copyFolder(moveE.getDataPath(), makeDstPath(moveE.getDstPath()))){ + int copyResult = copy.copyFolder(moveE.getDataPath(), makeDstPath(moveE.getDstPath())); + log.info("httpclient copyFolder result: "+copyResult); + if(1== copyResult){ moveE.setCompleteStatus("1"); } else {