批量上传线路站级数据

zlz
1 parent 5e9579e6
Showing 3 changed files with 169 additions and 57 deletions
src/main/java/com/bsth/controller/schedule/TrafficManageController.java
src/main/java/com/bsth/service/TrafficManageService.java
src/main/java/com/bsth/service/impl/TrafficManageServiceImpl.java
@@ -30,6 +30,15 @@ public class TrafficManageController {
         }
     }
+    @RequestMapping(value = "/setXLByInUse", method = RequestMethod.GET)
+    public String setXLByInUse(@RequestParam("inUse") String inUse) throws Exception {
+        try {
+            return trManageService.setXLByInUse(inUse);
+        } catch (Exception exp) {
+            throw new Exception(exp.getCause());
+        }
+    }
+
     @RequestMapping(value = "/setCL", method = RequestMethod.GET)
     public String setCL() throws Exception {
         try {
@@ -57,6 +66,15 @@ public class TrafficManageController {
         }
     }
+    @RequestMapping(value = "/setLDByDate", method = RequestMethod.GET)
+    public String setLDByDate(@RequestParam("theDate") String theDate) throws Exception {
+        try {
+            return trManageService.setLD(theDate);
+        } catch (Exception exp) {
+            throw new Exception(exp.getCause());
+        }
+    }
+
     @RequestMapping(value = "/setLDFile", method = RequestMethod.GET)
     public String setLDFile() throws Exception {
         try {
 package com.bsth.service;
-import java.util.Map;
-
 /**
  *
  * @Interface: LineService(线路service业务层实现接口)
@@ -27,6 +25,13 @@ public interface TrafficManageService {
 	String setXL(String ids);
 	/**
+	 * 上传线路信息
+	 *
+	 * @return 调用接口返回信息
+	 */
+	String setXLByInUse(String ids);
+
+	/**
 	 * 上传车辆信息
 	 *
 	 * @return 调用接口返回信息
@@ -65,6 +70,8 @@ public interface TrafficManageService {
 	 */
 	String setJHBC();
+	String setLD(String theDate);
+
 	String setLD();
 	String setLDFile();
@@ -19,7 +19,6 @@ import com.bsth.service.TrafficManageService;
 import com.bsth.service.traffic.YgcBasicDataService;
 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.org.tempuri.Results;
 import com.bsth.webService.trafficManage.org.tempuri.WebServiceLocator;
 import com.bsth.webService.trafficManage.org.tempuri.WebServiceSoap;
@@ -40,6 +39,7 @@ import java.sql.ResultSet;
 import java.text.DecimalFormat;
 import java.text.SimpleDateFormat;
 import java.util.*;
+import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 /**
@@ -67,10 +67,16 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	@Autowired
 	private LineRepository lineRepository;
+	@Autowired
+	private LineInformationRepository lineInformationRepository;
+
 	// 站点路由repository
 	@Autowired
 	private StationRouteRepository stationRouteRepository;
+	@Autowired
+	private SectionRepository sectionRepository;
+
 	// 车辆repository
 	@Autowired
 	private CarsRepository carsRepository;
@@ -104,8 +110,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	private YgcBasicDataService ygcBasicDataService;
-	// 运管处接口
-	private InternalPortType portType = null;//new Internal().getInternalHttpSoap11Endpoint();
+	// 运管处上传接口
+	private com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap webServiceSoapUp;
 	private WebServiceSoap ssop ;
 	{
 		try {
@@ -127,6 +133,23 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	private final String userNameOther = "user";
 	// 密码
 	private final String passwordOther = "user";
+
+	// 用户名
+	private final String userNameUp = "user";
+	// 密码
+	private final String passwordUp = "user";
+
+	private synchronized com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap  getWebServiceSoapUp(){
+		try {
+			if(webServiceSoapUp == null){
+				webServiceSoapUp = new com.bsth.webService.trafficManage.up.org.tempuri.WebServiceLocator().getWebServiceSoap();
+			}
+		}catch (Exception e){
+			e.printStackTrace();
+		}finally {
+			return webServiceSoapUp;
+		}
+	}
 	/**
 	 * 上传线路信息
 	 */
@@ -137,26 +160,44 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 		String[] idArray = ids.split(",");
 		try {
 			for (String id : idArray) {
+				if(id == null || id.trim().equals("")){
+					continue;
+				}
 				Map<String,Object> map = new HashMap<>();
 				map.put("lineCode_eq", id);
 				Line line ;
+				LineInformation lineInformation;
 				line = lineRepository.findOne(new CustomerSpecs<Line>(map));
 				if(line == null){
 					continue;
 				}
 				List<StationRoute> upStationsList ;// 上行站点路由集
-				List<StationRoute> downStationsList = null;// 下行站点路由集
-				sBuffer.append("<Data>");
-				sBuffer.append("<RequestOrg>上海巴士拓华科技发展有限公司</RequestOrg>");
-				sBuffer.append("<DataList>");
+				List<StationRoute> downStationsList;// 下行站点路由集
+				List<Object[]> downPointList;// 下行站点集
+				List<Object[]> upPointList;// 上行站点集
+				sBuffer.append("<XLs>");
+				sBuffer.append("<XL>");
 				if(BasicData.lineId2ShangHaiCodeMap.get(line.getId()) == null){
 					return result;
 				}
-				sBuffer.append("<LINE_ID>").append(line.getId()).append("</LINE_ID>");
-				sBuffer.append("<LINE_CODE>").append(BasicData.lineId2ShangHaiCodeMap.get(line.getId())).append("</LINE_CODE>");
-				sBuffer.append("<LINE_NAME>").append(line.getName()).append("</LINE_NAME>");
+				map = new HashMap<>();
+				map.put("line.id_eq",line.getId());
+				lineInformation = lineInformationRepository.findOne(new CustomerSpecs<LineInformation>(map));
+				if(lineInformation == null){
+					continue;
+				}
+				sBuffer.append("<XLBM>").append(BasicData.lineId2ShangHaiCodeMap.get(line.getId())).append("</XLBM>");
+				sBuffer.append("<XLMC>").append(line.getName()).append("</XLMC>");
+				sBuffer.append("<QDZ>").append(line.getStartStationName()).append("</QDZ>");
+				sBuffer.append("<ZDZ>").append(line.getEndStationName()).append("</ZDZ>");
+				sBuffer.append("<QZLC>").append(lineInformation.getUpMileage()).append("</QZLC>");
+				sBuffer.append("<ZQLC>").append(lineInformation.getDownMileage()).append("</ZQLC>");
+				sBuffer.append("<XLGH>").append(line.getLinePlayType()).append("</XLGH>");
+				sBuffer.append("<UPDATE_DATE>").append(sdfnyr.format(new Date())).append("</UPDATE_DATE>");
+
 				// 循环添加站点信息
-				sBuffer.append("<LineStationList>");
+				sBuffer.append("<StationList>");
+
 				// 先查上行
 				upStationsList = stationRouteRepository.findByLine(line.getLineCode(), 0);
 				int startId = 1;
@@ -167,25 +208,23 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					downStationsList = stationRouteRepository.findByLine(line.getLineCode(), 1);
 					packagStationXml(downStationsList, sBuffer, startId);
 				}
-				sBuffer.append("</LineStationList>");
+				sBuffer.append("</StationList>");
 				// 循环添加站点点位信息
 				sBuffer.append("<LinePointList>");
+				upPointList = sectionRepository.getSectionDirByLineId(line.getId(),0);
 				startId = 1;
-				startId = packagStationPointXml(upStationsList, sBuffer, startId);
+				startId = packagStationPointXml(upPointList, sBuffer, startId);
 				// 环线不查下行
 				if(line.getLinePlayType() != 1){
-					packagStationPointXml(downStationsList, sBuffer, startId);
+					downPointList = sectionRepository.getSectionDirByLineId(line.getId(),1);
+					packagStationPointXml(downPointList, sBuffer, startId);
 				}
 				sBuffer.append("</LinePointList>");
-				sBuffer.append("</DataList>");
-				sBuffer.append("</Data>");
+				sBuffer.append("</XL>");
+				sBuffer.append("</XLs>");
 				// 调用上传方法
-				result = ygcBasicDataService.invokeMethod("UpdateBusLineStation",sBuffer.toString());
-				String str = "ReturnCode";
-				// 解析返回值
-				result = result.substring(result.indexOf(str)+str.length()+1,result.lastIndexOf(str)-2);
-				if(result.equals("1")){
+				if(getWebServiceSoapUp().setXL(userNameUp,passwordUp,sBuffer.toString()).isSuccess()){
 					result = "success";
 				}else{
 					result = "failure";
@@ -201,6 +240,36 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	}
 	/**
+	 * 上传线路信息(按in_use上传)
+	 */
+	@Override
+	public String setXLByInUse(String inUse) {
+		StringBuffer result = new StringBuffer();
+		try {
+			Map<String,Object> map = new HashMap<>();
+			if(inUse != null && inUse.equals("1")){
+				map.put("inUse_eq", inUse);
+			}
+			List<Line> lines ;
+			Line line;
+			lines = lineRepository.findAll(new CustomerSpecs<Line>(map));
+			if(lines != null && lines.size() > 0){
+				for(int i = 0 ; i < lines.size() ; i ++){
+					line = lines.get(i);
+					if(line != null && line.getId() != null){
+						result.append(line.getLineCode()).append(":").append(setXL(line.getLineCode())).append(";");
+					}
+				}
+			}
+		} catch (Exception e) {
+			result.append("failure");
+			logger.error("setXLByInUse:",e);
+			e.printStackTrace();
+		}
+		return result.toString();
+	}
+
+	/**
 	 * 上传车辆信息
 	 */
 	@Override
@@ -279,14 +348,30 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	}
 	/**
+	 * 上传路单 指定日期 yyyy-MM-dd
+	 * @param theDate
+	 * @return
+	 */
+	public String setLD(String theDate){
+		return uploadLD(theDate);
+	}
+
+	/**
+	 * 上传路单 上传前一天的路单
+	 * @return
+	 */
+	public String setLD(){
+		return uploadLD(null);
+	}
+	/**
 	 * 上传路单
 	 * @return 上传成功标识
 	 */
-	public String setLD(){
+	private String uploadLD(String theDate){
 		String result = "failure";
 		Line line;
 		// 取昨天 的日期
-		String date = sdfnyr.format(DateUtils.addDays(new Date(), -1));
+		String date = theDate == null ?sdfnyr.format(DateUtils.addDays(new Date(), -1)) : theDate;
 		StringBuffer sf = new StringBuffer();
 		String str;
 		try {
@@ -710,7 +795,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			// 判断XML是否以</BCList>结尾，如果不是，则加上
 			String regex = "^*</JHBC>$";
 			Pattern p = Pattern.compile(regex);
-			java.util.regex.Matcher m = p.matcher(sBuffer);
+			Matcher m = p.matcher(sBuffer);
 			boolean isEndWithTrueFlag = false;
 			while (m.find()) {
 				isEndWithTrueFlag = true;
@@ -1146,15 +1231,15 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			}
 			paraMap = packageYgcStationNumParam(srRoute,null);
 			sBuffer.append("<Station>");
-			sBuffer.append("<STATION_ID>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paraMap)).append("</STATION_ID>");
-			sBuffer.append("<UPDDOWN>").append(srRoute.getDirections()).append("</UPDDOWN>");
-			sBuffer.append("<STATION_NO>").append(i).append("</STATION_NO>");
-			sBuffer.append("<STATION_CODE>").append(srRoute.getStationCode()).append("</STATION_CODE>");
-			sBuffer.append("<STATION_NAME>").append(srRoute.getStationName()).append("</STATION_NAME>");
-			sBuffer.append("<STATION_LON>").append(srRoute.getStation().getgLonx()).append("</STATION_LON>");
-			sBuffer.append("<STATION_LAT>").append(srRoute.getStation().getgLaty()).append("</STATION_LAT>");
-			sBuffer.append("<STATION_TYPE>").append(zdlx).append("</STATION_TYPE>");
-			sBuffer.append("<STATION_DISTANCE>").append(srRoute.getDistances()).append("</STATION_DISTANCE>");
+			sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paraMap)).append("</ZDXH>");
+			sBuffer.append("<SXX>").append(srRoute.getDirections()).append("</SXX>");
+			sBuffer.append("<ZDMC>").append(srRoute.getStationName()).append("</ZDMC>");
+			sBuffer.append("<ZDBM>").append(srRoute.getStationCode()).append("</ZDBM>");
+			sBuffer.append("<ZDJD>").append(srRoute.getStation().getgLonx()).append("</ZDJD>");
+			sBuffer.append("<ZDWD>").append(srRoute.getStation().getgLaty()).append("</ZDWD>");
+			sBuffer.append("<ZZ>").append(srRoute.getStation().getAddr() == null ? "" : srRoute.getStation().getAddr()).append("</ZZ>");
+			sBuffer.append("<ZDLX>").append(zdlx).append("</ZDLX>");
+			sBuffer.append("<ZJLC>").append(srRoute.getDistances()).append("</ZJLC>");
 			sBuffer.append("</Station>");
 			startId++;
 		}
@@ -1162,35 +1247,37 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	}
 	/**
-	 * @param stationsList 站点路由集
+	 * @param pointList 站点点位集
 	 * @param sBuffer sBuffer
 	 * @param startId 站点序号起始ID
 	 *
 	 * @return 站点序号累加后的ID
 	 */
-	private int packagStationPointXml(List<StationRoute> stationsList,StringBuffer sBuffer,int startId){
-		int size = stationsList.size();
-		StationRoute srRoute;
-		HashMap<String,String> paraMap;
-		String zdlx ;// 站点类型：0：起点站、1：终点站、2：中途站
+	private int packagStationPointXml(List<Object[]> pointList,StringBuffer sBuffer,int startId){
+		int size = pointList.size();
+		Object[] objs;
+		String bsection,dir,section;
+		String[] sections ;
 		for (int i = 0; i < size; i++) {
-			srRoute = stationsList.get(i);
-			zdlx = srRoute.getStationMark();
-			if(zdlx.equals("B")){
-				zdlx = "0";
-			}else if(zdlx.equals("E")){
-				zdlx = "1";
-			}else{
-				zdlx = "2";
+			objs = pointList.get(i);
+			bsection = objs[0]+"";
+			dir = objs[1]+"";
+			// 取括号内的内容
+			Pattern pattern = Pattern.compile("(?<=\\()(.+?)(?=\\))");
+			Matcher matcher = pattern.matcher(bsection);
+			if(matcher.find()){
+				sections = matcher.group().split(",");
+				for (int j = 0 ; j < sections.length ; j ++){
+					section = sections[j];
+					sBuffer.append("<LinePoint>");
+					sBuffer.append("<ZDXH>").append(startId).append("</ZDXH>");
+					sBuffer.append("<SXX>").append(dir).append("</SXX>");
+					sBuffer.append("<ZDJD>").append(section.split(" ")[0]).append("</ZDJD>");
+					sBuffer.append("<ZDWD>").append(section.split(" ")[1]).append("</ZDWD>");
+					sBuffer.append("</LinePoint>");
+					startId++;
+				}
 			}
-			paraMap = packageYgcStationNumParam(srRoute,null);
-			sBuffer.append("<Point>");
-			sBuffer.append("<POINT_ID>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paraMap)).append("</POINT_ID>");
-			sBuffer.append("<UPDDOWN>").append(srRoute.getDirections()).append("</UPDDOWN>");
-			sBuffer.append("<POINTLON>").append(srRoute.getStation().getgLonx()).append("</POINTLON>");
-			sBuffer.append("<POINTLAT>").append(srRoute.getStation().getgLaty()).append("</POINTLAT>");
-			sBuffer.append("</Point>");
-			startId++;
 		}
 		return startId;
 	}