diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/BabyBookbuildingFacade.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/BabyBookbuildingFacade.java index 0fd64d1..f0315f2 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/BabyBookbuildingFacade.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/BabyBookbuildingFacade.java @@ -747,7 +747,7 @@ public class BabyBookbuildingFacade { if (CollectionUtils.isNotEmpty(list)) { createBuildMsg(list.get(0)); - createExtensionMsg(list.get(0)); +// createExtensionMsg(list.get(0)); } } },"babyBuildMsgThead").start(); diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java index 30b6797..adf637c 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java @@ -131,52 +131,47 @@ public class SyncDataTaskService { { for (final String url : urls.keySet()) { - pool.execute(new Runnable() { - @Override - public void run() { - try{ - System.out.println(DateUtil.getyyyy_MM_dd_hms(new Date()) +" ; request url = " + url); - String json = excePost("https://" + url + "/findSyncData", new HashMap()); - if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(json)) - { - List list = JsonUtil.toList(json, SyncDataModel.class); - System.out.println(DateUtil.getyyyy_MM_dd_hms(new Date())+url+" ; syncdata size = "+ list.size()); - int batchSize = 200; - int end = 0; - for (int i = 0; i < list.size(); i += batchSize) { - end = (end + batchSize); - if (end > list.size()) { - end = list.size(); - } - final List tempList = list.subList(i, end); - commonThreadPool.execute(new Runnable() { - @Override - public void run() { - if (CollectionUtils.isNotEmpty(tempList)) - { - StringBuffer ids = new StringBuffer(); - for (SyncDataModel model : tempList) { - boolean boo = mongoSyncService.syncData(model.getAction(), model.getDataId(), model.getClassName(), model.getJsonData()); - if (boo) { - ids.append(model.getId()); - ids.append(","); - } - } - if (ids.length() > 0) { - Map params = new HashMap(); - params.put("ids", ids.toString()); - excePost("https://" + url + "/updateSyncData", params); - } + try{ + System.out.println(DateUtil.getyyyy_MM_dd_hms(new Date()) +" ; request url = " + url); + String json = excePost("https://" + url + "/findSyncData", new HashMap()); + if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(json)) + { + List list = JsonUtil.toList(json, SyncDataModel.class); + System.out.println(DateUtil.getyyyy_MM_dd_hms(new Date())+url+" ; syncdata size = "+ list.size()); + int batchSize = 200; + int end = 0; + for (int i = 0; i < list.size(); i += batchSize) { + end = (end + batchSize); + if (end > list.size()) { + end = list.size(); + } + final List tempList = list.subList(i, end); + commonThreadPool.execute(new Runnable() { + @Override + public void run() { + if (CollectionUtils.isNotEmpty(tempList)) + { + StringBuffer ids = new StringBuffer(); + for (SyncDataModel model : tempList) { + boolean boo = mongoSyncService.syncData(model.getAction(), model.getDataId(), model.getClassName(), model.getJsonData()); + if (boo) { + ids.append(model.getId()); + ids.append(","); } } - }); + if (ids.length() > 0) { + Map params = new HashMap(); + params.put("ids", ids.toString()); + excePost("https://" + url + "/updateSyncData", params); + } + } } - } - }catch(Exception ex){ - ExceptionUtils.catchException(ex, url+": syncData Error."); + }); } } - }); + }catch(Exception ex){ + ExceptionUtils.catchException(ex, url+": syncData Error."); + } } }