上传线路接口修改

zlz
1 parent e73b4f61
Showing 1 changed file with 22 additions and 5 deletions
src/main/java/com/bsth/service/impl/TrafficManageServiceImpl.java
@@ -15,6 +15,7 @@ import com.bsth.service.TrafficManageService;
 import com.bsth.util.TimeUtils;
 import com.bsth.util.db.DBUtils_MS;
 import com.bsth.webService.trafficManage.geotool.services.InternalPortType;
+import com.bsth.webService.trafficManage.geotool.services.Internal;
 import com.bsth.webService.trafficManage.org.tempuri.WebServiceLocator;
 import com.bsth.webService.trafficManage.org.tempuri.WebServiceSoap;
 import org.apache.commons.lang.time.DateUtils;
@@ -25,10 +26,7 @@ import org.springframework.data.domain.Sort;
 import org.springframework.data.domain.Sort.Direction;
 import org.springframework.stereotype.Service;
-import java.io.BufferedOutputStream;
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
+import java.io.*;
 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
@@ -188,6 +186,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			sBuffer.append("</XLs>");
 			System.out.println(sBuffer.toString());
 			if(sBuffer.indexOf("<XL>") != -1){
+				portType = new Internal().getInternalHttpSoap11Endpoint();
 				String portResult = portType.setXL(userNameXl, passwordXl, sBuffer.toString());
 				String portArray[] = portResult.split("\n");
 				if(portArray.length >= 4){
@@ -386,6 +385,24 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	}
 	/**
+	 * 从文件中读取xml
+	 * @param fileName  例：D:/test.txt
+	 * @return
+	 * @throws Exception
+	 */
+	private String readXmlFromFile(String fileName) throws Exception {
+		StringBuffer sf = new StringBuffer("");
+		File file = new File(fileName);
+		InputStreamReader reader = new InputStreamReader(new FileInputStream(file),"utf-8");
+		BufferedReader bufferedReader = new BufferedReader(reader);
+		String lineTxt = "";
+		while((lineTxt = bufferedReader.readLine()) != null){
+			sf.append(lineTxt);
+		}
+		reader.close();
+		return sf.toString().replaceAll("\t","");
+	}
+	/**
 	 * 上传里程油耗
 	 * @return 上传成功标识
 	 */
@@ -890,7 +907,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			int nTotalMemory = ( int ) (currRuntime.totalMemory() / 1024 / 1024);
 			System.out.println("zzz:"+nFreeMemory + "M/" + nTotalMemory +"M(free/total)");
-
+			portType = new Internal().getInternalHttpSoap11Endpoint();
 			byte[] res = portType.downloadAllDataFile("down_pdgj", "down_pdgj123");
 			String filePath = "E:\\ygc";
 			BufferedOutputStream bos = null;