chou qu oracle

src/com/platform/controller/DataModelController.java

@@ -31,6 +31,7 @@ import com.platform.entities.FolderNode;
 import com.platform.entities.GatherOracleInfo;
 import com.platform.entities.PagerOptions;
 import com.platform.entities.VolumeEntity;
+import com.platform.entities.oracleForm;
 import com.platform.entities.volumeMoveForm;
 import com.platform.service.DataInfoService;
 import com.platform.service.ICodeService;
@@ -136,29 +137,11 @@ public class DataModelController extends BaseController{
 
 	@RequestMapping(value="/oracle/{name}/extract", method= RequestMethod.POST)
 	public void oracleExtract(HttpServletRequest res,
-			HttpServletResponse req,@PathVariable String name) throws Exception {
+			HttpServletResponse req,@RequestBody oracleForm form) throws Exception {
 		res.setCharacterEncoding("UTF-8");
-		System.out.println("------extract-------");
+		if (null != form.getCollOracle() && form.getCollOracle().size() > 0) {
-		System.out.println(name);
+			OracleExtract.extractOracle(form.getTotalOracleName(), form.getCollOracle(), form.getTotalOracle());
-		Map<String, String[]> paramMap = res.getParameterMap();
-		//汇总库 对象信息--带有tableName-
-		String[] nodes = paramMap.get("target");
-		Map map = null;
-		for (String string : nodes) {
-			JSONObject jsonobject = JSONObject.fromObject(string);
-			map = jsonobject;
-			System.out.println(map);
-		}
-		
-		// 采集库对象--(多个采集库抽取到1个汇总库的1个tableName下)
-		String[] inneed = paramMap.get("inneed");
-		List<Map<String, String>> colleclist = new ArrayList<Map<String,String>>();
-		for (String string : nodes) {
-			JSONObject jsonobject = JSONObject.fromObject(string);
-			 Map inneedMap = jsonobject;
-			colleclist.add(inneedMap);
 		}
-		OracleExtract.extractOracle(name, colleclist, map);
 		req.setStatus(200);
 	}
 //	public void oracleExtract(HttpServletRequest res,

src/com/platform/entities/oracleForm.java

@@ -0,0 +1,55 @@
+package com.platform.entities;
+
+import java.util.List;
+
+public class oracleForm {
+	
+	private GatherOracleInfo totalOracle;
+	
+	private List<OracleConnectorParams> collOracle;
+	
+	private String totalOracleName;
+
+	/**
+	 * @return the totalOracle
+	 */
+	public GatherOracleInfo getTotalOracle() {
+		return totalOracle;
+	}
+
+	/**
+	 * @param totalOracle the totalOracle to set
+	 */
+	public void setTotalOracle(GatherOracleInfo totalOracle) {
+		this.totalOracle = totalOracle;
+	}
+
+	/**
+	 * @return the collOracle
+	 */
+	public List<OracleConnectorParams> getCollOracle() {
+		return collOracle;
+	}
+
+	/**
+	 * @param collOracle the collOracle to set
+	 */
+	public void setCollOracle(List<OracleConnectorParams> collOracle) {
+		this.collOracle = collOracle;
+	}
+
+	/**
+	 * @return the totalOracleName
+	 */
+	public String getTotalOracleName() {
+		return totalOracleName;
+	}
+
+	/**
+	 * @param totalOracleName the totalOracleName to set
+	 */
+	public void setTotalOracleName(String totalOracleName) {
+		this.totalOracleName = totalOracleName;
+	}
+
+}

src/com/platform/service/IOracleExtractService.java

@@ -18,5 +18,5 @@ public interface IOracleExtractService {
 	 */
 //	public boolean extractOracle(String name, List<OracleConnectorParams> dataInfos, GatherOracleInfo oracleConnect) throws Exception;
 //	public boolean extractOracle(String name, List<DataInfoEntity> dataInfos, Map<String, String> oracleConnect) throws Exception;
-	public boolean extractOracle(String name, List<Map<String, String>> dataInfo, Map<String, String> oracleConnect) throws Exception;
+	public boolean extractOracle(String name, List<OracleConnectorParams> dataInfo, GatherOracleInfo oracleConnect) throws Exception;
 }

src/com/platform/service/impl/OracleExtractServiceImpl.java

@@ -32,19 +32,14 @@ public class OracleExtractServiceImpl implements IOracleExtractService {
 	private OracleConnector connect = new OracleConnector();
 	
 	@Override
-	public boolean extractOracle(String name, List<Map<String, String>> dataInfoMap,
+	public boolean extractOracle(String name, List<OracleConnectorParams> dataInfolist,
-			Map<String, String> oracleConnect) throws Exception {
+			GatherOracleInfo oracleConnect) throws Exception {
 		boolean isSuccess = false;
 		try{
 			//map转  bean(汇总库信息-带tableName的)
-			GatherOracleInfo oracleModel = (GatherOracleInfo) Bean2MapUtils.convertMap(GatherOracleInfo.class, oracleConnect);
+			GatherOracleInfo oracleModel =  oracleConnect;
-			
 			//采集库连接参数
-			List<OracleConnectorParams> datainfos = new ArrayList<OracleConnectorParams>();
+			List<OracleConnectorParams> datainfos = dataInfolist;
-			for (Map<String, String> map : dataInfoMap) {
-				OracleConnectorParams dataInfoEntity = (OracleConnectorParams) Bean2MapUtils.convertMap(OracleConnectorParams.class, oracleConnect);
-				datainfos.add(dataInfoEntity);
-			}
 			
 			Connection conn = OracleConnector.ConnectionBuilder("jdbc:oracle:thin:@" + oracleModel.getIp() + ":" + oracleModel.getPort() + "/"
 					+ oracleModel.getDatabaseName(), oracleModel.getUser(), oracleModel.getPassword());			

src/com/platform/service/thread/ThreadMoveData.java

@@ -97,6 +97,7 @@ public class ThreadMoveData{
 						}
 						// 查询大小：。//gfs  获取size，
 						long srcSize = show.getFolderSize(dataMove.getDataPath());
+						srcSize = (long) (srcSize * 0.998);
 						long dstSize = show.getFolderSize(dataMove.getDstPath());
 						if (srcSize < 0) {
 							log.error(dataMove.getDataPath() + " : 路径不存在！ ");
@@ -118,6 +119,7 @@ public class ThreadMoveData{
 					if("1".equals(dataMove.getCompleteStatus()) && dataMove.getRate() > 0){
 						//传输完毕：进行校验
 						if (realRate == 100) {
+							//TODO 查看当前拷贝目录进程是否结束？
 							//TODO 进行MD5校验
 							int resl = check.checkoutMD5Folder(dataMove.getDataPath(), dataMove.getDstPath());
 							//TODO 校验成功--则删除数据库记录