拉取任务拆分

api-admin/src/main/java/com/glxp/sale/admin/idc/service/IdcService.java

@@ -24,6 +24,7 @@ public interface IdcService {
 	BaseResponse download(HttpServletRequest request,Map<String,Object> params);
 	
 	public void asyncFetchTask();
+	public void asyncFetchUdiTask();
 
 	BaseResponse downlaodSuccess(HttpServletRequest request,Map<String,Object> params);
 	

api-admin/src/main/java/com/glxp/sale/admin/idc/service/impl/IdcServiceImpl.java

@@ -130,9 +130,25 @@ public class IdcServiceImpl implements IdcService {
 	/*拉取前一级中继服务数据*/
 	@Async
 	@Override
+	public void asyncFetchUdiTask() {
+		fetchTask(false);
+	}
+	@Async
+	@Override
 	public void asyncFetchTask() {
+		fetchTask(true);
 	
+	
+	}
+
+	
+	private void fetchTask(boolean isIdc) {
 		String host = getNextHost();
+		if(!isIdc) {
+			Map<String,Object> map = dbDao.get("select * from sync_data_set limit 1");
+			if(map!=null&&map.get("syncIp")!=null)
+				host = map.get("syncIp").toString();
+		}
 		logger.info("fetch from ip:"+host);
 		if(!StringUtils.isEmpty(host)) {
 			String result = post(host+"/spssync/common/list",null);
@@ -151,7 +167,6 @@ public class IdcServiceImpl implements IdcService {
 				}
 			}
 		}
-	
 	}
 	
 	@Async

api-admin/src/main/java/com/glxp/sale/admin/thread/AsyncFetchTask.java

@@ -1,4 +1,4 @@
-package com.glxp.sale.admin.idc.thread;
+package com.glxp.sale.admin.thread;
 
 import javax.annotation.Resource;