线路文件(环线)生成代码改动

李强
1 parent 6321c1ec
Showing 4 changed files with 131 additions and 41 deletions
src/main/java/com/bsth/entity/SectionRoute.java
src/main/java/com/bsth/service/impl/StationRouteServiceImpl.java
src/main/java/com/bsth/util/Geo/SHCJ2BDJW.java
src/main/resources/static/pages/base/station/edit_select.html
@@ -52,7 +52,7 @@ public class SectionRoute {
 	// 是否撤销
 	private Integer destroy;
-	/** 是否有路段限速数据  <0：无；1：有>*/
+	/** 是否有路段限速数据  <0：未分段；1：分段>*/
 	private Integer isRoadeSpeed;
 	// 描述
@@ -11,6 +11,8 @@ import com.bsth.repository.StationRouteRepository;
 import com.bsth.service.StationRouteService;
 import com.bsth.util.FTPClientUtils;
 import com.bsth.util.PackTarGZUtils;
+import com.bsth.util.Geo.GeoUtils;
+import com.bsth.util.Geo.Point;
 import com.bsth.util.db.DBUtils_MS;
 import com.google.common.base.Splitter;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -556,9 +558,15 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 				clientUtils.deleteFtpFile(url, port, username, password, remotePath, textFileName);
-				/** 行单文件内容 @param：<objects：站点路由；lineId：线路ID>*/
-				String textStr = newTextFileToFTP(objects,lineId);
+				String textStr = "";
+				boolean tempTag = ishxType(objects);
+				
+				if(tempTag)
+					textStr = hxTextFileToFtp(objects,lineId);// 环线行单文件内容
+				else
+					textStr = newTextFileToFTP(objects,lineId);/** 双向行单文件内容 @param：<objects：站点路由；lineId：线路ID>*/
+					
 				/*textStr = line.getName() + "\t" + "2" + "\r" + textStr;*/
 				textStr = line.getName() + " " + "2" + "\r" + textStr;
@@ -574,9 +582,6 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 				/** 获取txt文件 */
 				File textFile = clientUtils.GetFtpFile(url, port, username, password, remotePath, textFileName);
-				/*File[] sources = new File[] {textFile};*/
-				//File[] sources = new File[] {textFile};
-				
 				File target = new File(odlGzFileName);
 				// 将txt文件打包
@@ -603,6 +608,24 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 		}  
 		return resultMap;
 	}
+	public boolean ishxType(List<Object[]> listObj) {
+		boolean tag = true;
+		String pointBStr[] = null,pointEStr[] = null;
+		int numzd = 0;
+		for(int i =0;i<listObj.size();i++) {
+			if(listObj.get(i)[3].equals("B") && Integer.valueOf(listObj.get(i)[8].toString())==0)
+				pointBStr = listObj.get(i)[2].toString().split(" ");
+			else if(listObj.get(i)[3].equals("E") && Integer.valueOf(listObj.get(i)[8].toString())==0)
+				pointEStr = listObj.get(i)[2].toString().split(" ");
+			if(Integer.valueOf(listObj.get(i)[8].toString())==1)
+				numzd++;
+		}
+		Point p1 = new Point(Double.valueOf(pointBStr[0]),Double.valueOf(pointBStr[1])); 
+		Point p2 = new Point(Double.valueOf(pointEStr[0]),Double.valueOf(pointEStr[1]));
+		if(GeoUtils.getDistance(p1, p2)>100 && numzd>2) 
+			tag = false;
+		return tag;
+	}
 	/**
 	 * @Description : TODO(形成行单文件内容)
@@ -717,31 +740,79 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 						}
 					}
-					
-					/*
-					String bdJWPointStr = objects.get(i)[2].toString();
-					
-					String bdJWPointA[] = bdJWPointStr.split(" ");
-					
-					Map<String, Object> pointsM = new HashMap<String,Object>();
-					
-					pointsM.put("lng", bdJWPointA[0]);
-					
-					pointsM.put("lat", bdJWPointA[1]);
-					
-					System.out.println(objects.get(i)[7].toString());
-					
-					sleepStr = sleepStr + GetFormPointOnPolylineSeleepLimit(pointsM,sobje);*/
 				}
 				stationRStr = stationRStr + lng + lat + stationMake + stationNo + stationCode + staitondistance + sleepStr + stationName + enterStr;
-				
 			}
 		}
-		
 		return stationRStr;
-		
+	}
+	
+	public String hxTextFileToFtp(List<Object[]> objects,Integer lineId) {
+		String restStr = "";
+		// windows下的文本文件换行符
+		//String enterStr = "\r\n";
+		// linux/unix下的文本文件换行符
+		String enterStr = "\r";
+		int xh = 1 ;
+		for(int x =0;x<2;x++) {
+			for(int i = 0; i<objects.size();i++) {
+				if(Integer.valueOf(objects.get(i)[8].toString())==0) {
+					// 经度
+					String lng = objects.get(i)[0].equals("") ? "" : objects.get(i)[0].toString();
+					// 纬度
+					String lat = objects.get(i)[1].equals("") ? "" : objects.get(i)[1].toString();
+					lat = "\t" +  lat;
+					// 站点类型
+					String stationMakeStr =  objects.get(i)[3].equals("") ? "" : objects.get(i)[3].toString();
+					String stationMake = "";
+					if(stationMakeStr.equals("E")) {
+						stationMake = "\t2";
+					}else {
+						stationMake ="\t1";
+					}
+					// 站点序号 
+					// String stationNo =  objects.get(i)[4].equals("") ? "" : objects.get(i)[4].toString();
+					String stationNo = "\t" + xh;
+					// 站点编码
+					String stationCode = objects.get(i)[5].equals("") ? "" : objects.get(i)[5].toString();
+					stationCode =  "\t" +stationCode;
+					double dis = objects.get(i)[6]==null  ? 0.0 : Double.parseDouble(objects.get(i)[6].toString())*1000;
+					String tempDistc = String.valueOf((int) dis);
+					// 站点距离
+					String staitondistance = "\t" + tempDistc;
+					// 站点名称
+					String stationName =  objects.get(i)[7].equals("") ? "" : objects.get(i)[7].toString();
+					stationName = "\t" +stationName;
+					// 限速
+					String sleepStr = "";
+					// 方向
+					int directions = objects.get(i)[8]==null ? null : Integer.valueOf(objects.get(i)[8].toString());
+					/** 获取路段路由信息 @pararm：<lineId：线路ID；directions：方向> */
+					List<Object[]> sobje = routeRepository.sectionRouteVector(lineId,directions);
+					if(sobje.size()==1) {
+						double dsleepStr = sobje.get(0)[2] == null ? 60d : Double.valueOf(sobje.get(0)[2].toString());
+						sleepStr =  "\t" +  new DecimalFormat("0").format(dsleepStr);
+					}else if(sobje.size()>1){
+						/** 这里暂时只根据站点名称去匹配所在路段的限速值 ，如果路段名称"至"之前的地名与站点名称等同，就认为站点在路段上。 */
+						for(int j =0;j<sobje.size();j++) {
+							String sectionName = sobje.get(j)[3].toString();
+							String sectionNameA[] = sectionName.split("至");
+							if(stationName.equals(sectionNameA[0])){
+								/*sleepStr = sobje.get(j)[2].toString();*/
+								double dsleepStrt = sobje.get(0)[2] == null ? 60d : Double.valueOf(sobje.get(j)[2].toString());
+								sleepStr =  "\t" +  new DecimalFormat("0").format(dsleepStrt);
+							}
+						}
+					}
+					xh++;
+					restStr = restStr + lng + lat + stationMake + stationNo + stationCode + staitondistance + sleepStr + stationName + enterStr;
+				}
+			}
+		}
+		System.out.println(restStr);
+		return restStr;
 	}
 	public String GetFormPointOnPolylineSeleepLimit(Map<String, Object> p,List<Object[]> listObjArra) {
@@ -27,9 +27,11 @@ public class SHCJ2BDJW {
 		/*String sqlSelect = "SELECT b.SHAPESTRING as SHAPE , b.id as ID FROM jjwgps_t_gjldb b where  SHAPESTRING is not null order by b.ldbh asc  ";*/
 		/*String sqlSelect = "select s.id,s.descriptions from bsth_c_station s order by s.id asc  ";*/
-		String sqlSelect = "SELECT s.id,s.descriptions FROM bsth_c_section s order by s.id asc ";
+		String sqlSelect = "select s.id,s.x,s.y from bsth_c_station s where id >=26882  order by s.id asc";
+		/*String sqlSelect = "SELECT s.id,s.descriptions FROM bsth_c_section s order by s.id asc ";*/
-		String sqlUpdate = "UPDATE bsth_c_section SET csection_vector = ST_GeomFromText(?) , bsection_vector=ST_GeomFromText(?) , gsection_vector=ST_GeomFromText(?) where id = ?";
+		/*String sqlUpdate = "UPDATE bsth_c_section SET csection_vector = ST_GeomFromText(?) , bsection_vector=ST_GeomFromText(?) , gsection_vector=ST_GeomFromText(?) where id = ?";*/
+		String sqlUpdate = "UPDATE bsth_c_station SET b_jwpoints= ? , g_lonx=? , g_laty=? where id = ?";
 		List<Map<String, Object>> list = new ArrayList<>();
@@ -44,8 +46,9 @@ public class SHCJ2BDJW {
 				Map<String, Object> map = new HashMap<String, Object>();
-				map.put("descriptions", rs.getString("descriptions"));
-				
+				/*map.put("descriptions", rs.getString("descriptions"));*/
+				map.put("x", rs.getString("x"));
+				map.put("y", rs.getString("y"));
 				map.put("id", rs.getInt("id"));
 				list.add(map);
@@ -55,10 +58,21 @@ public class SHCJ2BDJW {
 				Map<String, Object> temp = list.get(i);
 				// POINT (8229.30921617 -933.16425265)
-				String lineString = temp.get("descriptions").toString();
-				int id = Integer.parseInt(temp.get("id").toString());
+				//String lineString = temp.get("descriptions").toString();
+				
+				Double lng = Double.parseDouble(temp.get("x").toString());
+				Double lat = Double.parseDouble(temp.get("y").toString());
+				Map map_2 = JWDUtil.ConvertSHToJW(lng,lat);
-				String arrayP[] = lineString.substring(lineString.indexOf("(")+1, lineString.length()-1).split(", ");
+				String b_jwpoints = "";
+				Float g_lonx=0.0f,g_laty=0.0f;
+				int id = Integer.parseInt(temp.get("id").toString());
+				g_lonx = Float.parseFloat(map_2.get("x").toString());
+				g_laty = Float.parseFloat(map_2.get("y").toString());
+				Location location = TransGPS.LocationMake(Float.parseFloat(map_2.get("x").toString()), Float.parseFloat(map_2.get("y").toString()));
+				location = TransGPS.bd_encrypt(TransGPS.transformFromWGSToGCJ(location));
+				b_jwpoints = (location.getLng()+0.000727) + " " + (location.getLat() - 0.0000624);
+				//String arrayP[] = lineString.substring(lineString.indexOf("(")+1, lineString.length()-1).split(", ");
 				/*String arrayP[] = lineString.substring(lineString.indexOf("(")+1, lineString.length()-1).split(" ");
 				String b_jwpoints = "";
 				Float g_lonx=0.0f,g_laty=0.0f,x=0.0f,y=0.0f;*/
@@ -76,7 +90,7 @@ public class SHCJ2BDJW {
 				b_jwpoints = (location.getLng()+0.000727) + " " + (location.getLat() - 0.0000624);*/
 				//b_jwpoints = (location.getLng()) + " " + (location.getLat());
-				String csection_vector="",bsection_vector="",gsection_vector="";
+			/*	String csection_vector="",bsection_vector="",gsection_vector="";
 				for(int k =0;k<arrayP.length;k++) {
@@ -103,20 +117,20 @@ public class SHCJ2BDJW {
 					}
-				}
+				}*/
 				ps = null;
-				bsection_vector = "LINESTRING(" + bsection_vector +")";
-				csection_vector = "LINESTRING(" + csection_vector +")";
-				gsection_vector = "LINESTRING(" + gsection_vector +")";
+				//bsection_vector = "LINESTRING(" + bsection_vector +")";
+				//csection_vector = "LINESTRING(" + csection_vector +")";
+				//gsection_vector = "LINESTRING(" + gsection_vector +")";
 				ps = conn.prepareStatement(sqlUpdate);
 				// String sqlUpdate = "UPDATE bsth_c_section SET csection_vector = ? , bsection_vector=? , gsection_vector=? where id = ?";
-				ps.setString(1, csection_vector);
-				ps.setString(2, bsection_vector);
-				ps.setString(3, gsection_vector);
-				ps.setInt(4, id);
+				//ps.setString(1, csection_vector);
+				//ps.setString(2, bsection_vector);
+				//ps.setString(3, gsection_vector);
+				//ps.setInt(4, id);
 				//int stauts = ps.executeUpdate();
 				// String sqlUpdate = "UPDATE bsth_c_station SET b_jwpoints = ?1 , g_lonx=?2 , g_laty=?3 , x = ?4 , y = ?5 where id = ?6";
@@ -126,6 +140,11 @@ public class SHCJ2BDJW {
 				ps.setFloat(4, x);
 				ps.setFloat(5, y);
 				ps.setFloat(6, id);*/
+				
+				ps.setString(1, b_jwpoints);
+				ps.setFloat(2, g_lonx);
+				ps.setFloat(3, g_laty);
+				ps.setFloat(4, id);
 				int stauts = ps.executeUpdate();
 				System.out.println(stauts);
 			}
@@ -177,7 +177,7 @@ $(&#39;#editPositions_select_mobal&#39;).on(&#39;editSelectMobal_show&#39;, function(e, map,drm,
 				map.clearMarkAndOverlays();
 				// 打开绘制工具
-				PositionsDrawingManagerObj.openDrawingManager();
+				drm.openDrawingManager();
 				// 根据站点位置在地图定位
 				map.localtionPoint(editStationName);