bsthlq <2519941818@qq.com>线路文件生成BUG修改

李强
1 parent 2ea9f571
Showing 8 changed files with 119 additions and 81 deletions
src/main/java/com/bsth/repository/SectionRouteRepository.java
src/main/java/com/bsth/repository/StationRouteRepository.java
src/main/java/com/bsth/service/impl/StationRouteServiceImpl.java
src/main/resources/static/pages/base/timesmodel/js/add-form-reload.js
src/main/resources/static/pages/base/timesmodel/js/add-form-wizard.js
src/main/resources/static/pages/base/timesmodel/js/base-fun.js
src/main/resources/static/pages/base/timesmodel/js/d3.relationshipgraph.js
src/main/resources/static/pages/base/timesmodel/js/gantt.js
@@ -163,7 +163,7 @@ public interface SectionRouteRepository extends BaseRepository&lt;SectionRoute, Int
 					"s.speed_limit," +
 					"s.section_name " +
 					" FROM bsth_c_sectionroute c " +
-					" LEFT JOIN bsth_c_section s on c.section = s.id where c.line = ?1 and c.directions = ?2", nativeQuery=true)
+					" LEFT JOIN bsth_c_section s on c.section = s.id where c.line = ?1 and c.directions = ?2 and c.destroy = 0", nativeQuery=true)
 	List<Object[]> sectionRouteVector(Integer lineId,Integer directions);
 	@Transactional
@@ -153,7 +153,7 @@ public interface StationRouteRepository extends BaseRepository&lt;StationRoute, Int
 				   "s.station_route_code," +
 				   "s.directions," +
 				   "s.distances,"+
-				   "s.station FROM bsth_c_stationroute s where  s.line = ?1) a " +
+				   "s.station FROM bsth_c_stationroute s where  s.line = ?1 and s.destroy=0) a " +
 				   "LEFT JOIN bsth_c_station b " +
 				   " on a.station = b.id ORDER BY a.directions ASC ) k ORDER BY k.directions,k.station_route_code ASC", nativeQuery=true)
 	List<Object[]> usingSingle(Integer lineId);
@@ -24,6 +24,7 @@ import org.springframework.transaction.annotation.Transactional;
 import java.io.ByteArrayInputStream;
 import java.io.File;
+import java.io.FileOutputStream;
 import java.io.InputStream;
 import java.text.DecimalFormat;
 import java.util.*;
@@ -511,57 +512,38 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 	 */
 	@Override
 	public Map<String, Object> usingSingle(Map<String, Object> map) {
-		
 		// 返回值map
 		Map<String, Object> resultMap = new HashMap<String,Object>();
-		
 		try {
-			
 			// 获取线路ID
 			Integer lineId = map.get("lineId").equals("") ? 0 : Integer.parseInt(map.get("lineId").toString());
-			
 			/** 查询线路信息 @param：<lineId：线路ID> */
 			Line line = lineRepository.findOne(lineId);
-			
 			/** 查询线路信息下的站点路由信息 @param：<lineId：线路ID> */
 			List<Object[]> objects = repository.usingSingle(lineId);
-			
 			if (objects.size()>0) {
-				
 				/** 获取配置文件里的ftp登录参数 */
 				Map<String, Object> FTPParamMap = readPropertiesGetFTPParam();
-				
 				// 压缩文件名
 				String odlGzFileName = line.getLineCode() + ".txt.gz";
-				
 				// txt文件名
 				String textFileName  = line.getLineCode() + ".txt";
-				
 				// 创建一个ftp上传实例
 				FTPClientUtils clientUtils = new FTPClientUtils();
-				
 				// IP
 				String url = FTPParamMap.get("url").toString();
-				
 				// 端口
 				int port = Integer.valueOf(FTPParamMap.get("port").toString());
-				
 				// 用户名
 				String username = FTPParamMap.get("username").toString();
-				
 				// 密码
 				String password = FTPParamMap.get("password").toString();
-				
 				// 相对路径
 				String remotePath = FTPParamMap.get("remotePath").toString();
-				
 				/** 如果已存在相同行单文件名则先删除 */
 				clientUtils.deleteFtpFile(url, port, username, password, remotePath, odlGzFileName);
-				
 				clientUtils.deleteFtpFile(url, port, username, password, remotePath, textFileName);
-				
 				String textStr = "";
-				
 				boolean tempTag = ishxType(objects);
 				if(tempTag)
@@ -575,6 +557,12 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 				InputStream input = new ByteArrayInputStream(textStr.getBytes("gbk"));
+				// FileOutputStream fos = new FileOutputStream("test.txt");
+				/*int len = 0 ; 
+				byte[] cbuf = new byte[1024];
+				while((len = input.read(cbuf)) != -1) {
+					fos.write(cbuf, 0, len);
+				}*/
 				/** 生成txt文件，上传ftp */
 				clientUtils.uploadFile(url, port, username, password, remotePath, textFileName, input);
@@ -645,25 +633,23 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 	 * @return String
 	 */ 
 	public String  newTextFileToFTP(List<Object[]> objects,Integer lineId) {
-		
 		// 返回值String
 		String stationRStr = "";
-		
 		// windows下的文本文件换行符
 		//String enterStr = "\r\n";
-		
 		// linux/unix下的文本文件换行符
 		String enterStr = "\r";
-		
+		int defaultZdxh = 0;
 		if(objects.size()>0) {
-			
 			for(int i = 0; i<objects.size();i++) {
-				
+				defaultZdxh ++ ;
 				// 经度
-				String lng = objects.get(i)[0].equals("") ? "" : objects.get(i)[0].toString();
+				String lng = objects.get(i)[0].equals("") ? "0" : objects.get(i)[0].toString();
 				// 纬度
-				String lat = objects.get(i)[1].equals("") ? "" : objects.get(i)[1].toString();
+				String lat = objects.get(i)[1].equals("") ? "0" : objects.get(i)[1].toString();
+				
+				Point point = new Point(Double.valueOf(lng), Double.valueOf(lat));
 				lat = "\t" +  lat;
@@ -673,23 +659,32 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 				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 =  objects.get(i)[4].equals("") ? "" : objects.get(i)[4].toString();
+				String stationNo =  String.valueOf(defaultZdxh);
 				stationNo = "\t" + stationNo;
 				// 站点编码
 				String stationCode = objects.get(i)[5].equals("") ? "" : objects.get(i)[5].toString();
+				int len = stationCode.length();
+				if(len<8) {
+					int dx = 8 - len;
+					String addStr = "";
+					for(int p =0;p<dx;p++) {
+						addStr  = addStr + "0";
+					}
+					stationCode = addStr + stationCode;
+				}else if(len>8){
+					stationCode = stationCode.substring(8);
+				}
+				
 				stationCode =  "\t" +stationCode;
 				double dis = objects.get(i)[6]==null  ? 0.0 : Double.parseDouble(objects.get(i)[6].toString())*1000;
@@ -709,41 +704,33 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 				// 限速
 				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);
-					
+					int dsleepStr = sobje.get(0)[2] == null || sobje.get(0)[2].equals("") ? 60 : Integer.valueOf(sobje.get(0)[2].toString());
+					sleepStr =  "\t" +  String.valueOf(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);
-							
+						int dsleepStrt = sobje.get(0)[2] == null || sobje.get(0)[2].equals("") ? 60 : Integer.valueOf(sobje.get(j)[2].toString());
+						String pointsStr = sobje.get(j)[1]==null || sobje.get(j)[1].equals("") ? null : sobje.get(j)[1].toString();
+						pointsStr = pointsStr.substring(11, pointsStr.length()-1);
+						List<Point> ps = new ArrayList<>();
+						String[] pArray = pointsStr.split(",");
+						for(int a = 0; a <pArray.length; a++) {
+							String[] tmepA = pArray[a].split(" ");
+							Point temp = new Point(Double.valueOf(tmepA[0]), Double.valueOf(tmepA[1]));
+							ps.add(temp);
+						}
+						if(GeoUtils.isInSection(ps, point)) {
+							sleepStr = "\t" + String.valueOf(dsleepStrt);
+							break;
 						}
-						
 					}
 				}
-				
+				if(sleepStr.equals("")) 
+					sleepStr  =  "\t" + "60";
 				stationRStr = stationRStr + lng + lat + stationMake + stationNo + stationCode + staitondistance + sleepStr + stationName + enterStr;
 			}
@@ -762,9 +749,12 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 			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 lng = objects.get(i)[0].equals("") ? "0" : objects.get(i)[0].toString();
+					
 					// 纬度
-					String lat = objects.get(i)[1].equals("") ? "" : objects.get(i)[1].toString();
+					String lat = objects.get(i)[1].equals("") ? "0" : objects.get(i)[1].toString();
+					
+					Point point = new Point(Double.valueOf(lng), Double.valueOf(lat));
 					lat = "\t" +  lat;
 					// 站点类型
 					String stationMakeStr =  objects.get(i)[3].equals("") ? "" : objects.get(i)[3].toString();
@@ -779,6 +769,17 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 					String stationNo = "\t" + xh;
 					// 站点编码
 					String stationCode = objects.get(i)[5].equals("") ? "" : objects.get(i)[5].toString();
+					int len = stationCode.length();
+					if(len<8) {
+						int dx = 8 - len;
+						String addStr = "";
+						for(int p =0;p<dx;p++) {
+							addStr  = addStr + "0";
+						}
+						stationCode = addStr + stationCode;
+					}else if(len>8){
+						stationCode = stationCode.substring(8);
+					}
 					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);
@@ -794,20 +795,28 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 					/** 获取路段路由信息 @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);
+						int dsleepStr = sobje.get(0)[2] == null || sobje.get(0)[2].equals("") ? 60 : Integer.valueOf(sobje.get(0)[2].toString());
+						sleepStr =  "\t" +  String.valueOf(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);
+							int dsleepStrt = sobje.get(0)[2] == null || sobje.get(0)[2].equals("") ? 60 : Integer.valueOf(sobje.get(j)[2].toString());
+							String pointsStr = sobje.get(j)[1]==null || sobje.get(j)[1].equals("") ? null : sobje.get(j)[1].toString();
+							pointsStr = pointsStr.substring(11, pointsStr.length()-1);
+							List<Point> ps = new ArrayList<>();
+							String[] pArray = pointsStr.split(",");
+							for(int a = 0; a <pArray.length; a++) {
+								String[] tmepA = pArray[a].split(" ");
+								Point temp = new Point(Double.valueOf(tmepA[0]), Double.valueOf(tmepA[1]));
+								ps.add(temp);
+							}
+							if(GeoUtils.isInSection(ps, point)) {
+								sleepStr = "\t" + String.valueOf(dsleepStrt);
+								break;
 							}
 						}
 					}
+					if(sleepStr.equals("")) 
+						sleepStr  =  "\t" + "60";
 					xh++;
 					restStr = restStr + lng + lat + stationMake + stationNo + stationCode + staitondistance + sleepStr + stationName + enterStr;
 				}
@@ -46,7 +46,8 @@
 			obj.jhlc = d[i].jhlc;// 计划里程
 			obj.lp = d[i].lp==null ? null : d[i].lp.id;// 路牌id
 			obj.lpType = d[i].lp==null ? null : d[i].lp.lpType;// 路牌类型
-			obj.parent = d[i].lp.lpName;// 路牌名称
+			obj.parent = d[i].lp.lpNo;// 路牌名称
+			obj.lpName = d[i].lp.lpName;
 			obj.lpNo = d[i].lp.lpNo;// 路牌编码
 			obj.tcc = d[i].tcc==null ? null : d[i].tcc.id;// 停车场id
 			obj.ttinfo = d[i].ttinfo==null ? null : d[i].ttinfo.id;// 时刻表id
@@ -60,7 +61,7 @@
 			resultD.push(obj);
 			if(lpA.indexOf(obj.lpNo)<0) {
 				lpA.push(obj.lpNo);
-				rsLpA.push({'lp':obj.lp,'lpNo':obj.lpNo,'lpName':obj.parent,'lpType':obj.lpType});
+				rsLpA.push({'lp':obj.lp,'lpNo':obj.lpNo,'lpName':obj.lpName,'lpType':obj.lpType});
 			}
 		}
 		// 返回渲染图形的数据格式.
@@ -407,7 +407,9 @@ var SKBFormWizard = function() {
 			obj.jhlc = d[i].jhlc;// 计划里程
 			obj.lp = d[i].lp==null ? null : d[i].lp.id;// 路牌id
 			obj.lpType = d[i].lp==null ? null : d[i].lp.lpType;// 路牌类型
-			obj.parent = d[i].lp.lpName;// 路牌名称
+			// obj.parent = d[i].lp.lpName;// 路牌名称
+			// obj.parent = parseInt(d[i].lp.lpNo);// 路牌名称
+			obj.lpName = d[i].lp.lpName;
 			obj.lpNo = d[i].lp.lpNo;// 路牌编码
 			obj.tcc = d[i].tcc==null ? null : d[i].tcc.id;// 停车场id
 			obj.ttinfo = d[i].ttinfo==null ? null : d[i].ttinfo.id;// 时刻表id
@@ -421,7 +423,7 @@ var SKBFormWizard = function() {
 			resultD.push(obj);
 			if(lpA.indexOf(obj.lpNo)<0) {
 				lpA.push(obj.lpNo);
-				rsLpA.push({'lp':obj.lp,'lpNo':obj.lpNo,'lpName':obj.parent,'lpType':obj.lpType});
+				rsLpA.push({'lp':obj.lp,'lpNo':obj.lpNo,'lpName':obj.lpName,'lpType':obj.lpType});
 			}
 		}
 		// 返回渲染图形的数据格式.
@@ -388,7 +388,7 @@ var BaseFun = function() {
 				var jar = baseF.tzsmbcsj01(
 						baseF.setbcsAndfcno(baseF.tzsmbcsj01(baseF.setbcsAndfcno(baseF.tzsztest(cara,jar01,dataMap)),dataMap.smbcsjArr,dataMap.ccsjArr,dataMap.cclcArr,dataMap.qdzArr,saa[0].lbsj,dataMap)),
 								dataMap.smbcsjArr,dataMap.ccsjArr,dataMap.cclcArr,dataMap.qdzArr,saa[0].lbsj,dataMap);
-				// return {'json':jar,'bxrcgs':bxrcgs};
+			    // return {'json':jar,'bxrcgs':bxrcgs};
 				for(var r = 0 ; r < bxrcgs.length; r++) {
 					var lpNo = bxrcgs[r].lpNo;
 					var gsv = 0 , bczs = 0;
@@ -401,8 +401,9 @@ var BaseFun = function() {
 					bxrcgs[r].sjgsV = gsv;
 					bxrcgs[r].bczs = bczs;
 				}
+				//debugger;
 				var jar3 = baseF.dqbcsAndgs(bxrcgs,jar,dataMap,cara.length);
-				// return {'json':jar3,'bxrcgs':bxrcgs};
+				//return {'json':jar3,'bxrcgs':bxrcgs};
 				/*var jar4 =  baseF.tzsmbcsj01(
 							baseF.setbcsAndfcno(baseF.tzsmbcsj01(baseF.setbcsAndfcno(baseF.tzsztest(cara,jar3,dataMap)),dataMap.smbcsjArr,dataMap.ccsjArr,dataMap.cclcArr,dataMap.qdzArr,saa[0].lbsj,dataMap)),
 									dataMap.smbcsjArr,dataMap.ccsjArr,dataMap.cclcArr,dataMap.qdzArr,saa[0].lbsj,dataMap);*/
@@ -538,9 +539,11 @@ var BaseFun = function() {
 									for(var q = 0 ; q < qbbfbc.length; q++) {
 										if(q<(qbbfbc.length-1))
 											qbbfbc[q].STOPTIME = qbbfbc[q].STOPTIME + vag;
-										if(q==0)
-											continue;
-										else {
+										if(q==0) {
+											var fcsj_ =  baseF.getDateTime(qbbfbc[q].fcsj);
+											fcsj_.setMinutes(fcsj_.getMinutes() + qbbfbc[q].bcsj);
+											qbbfbc[q].ARRIVALTIME = baseF.getTimeStr(fcsj_);
+										}else {
 											var ddsj_ =  baseF.getDateTime(qbbfbc[q-1].ARRIVALTIME);
 											ddsj_.setMinutes(ddsj_.getMinutes() + qbbfbc[q-1].STOPTIME);
 											qbbfbc[q].fcsj = baseF.getTimeStr(ddsj_);
@@ -616,6 +619,9 @@ var BaseFun = function() {
 				var dygbcfcsj =  baseF.getDateTime(obj.fcsj);
 				dygbcfcsj.setMinutes(dygbcfcsj.getMinutes() - dx);
 				obj.fcsj = baseF.getTimeStr(dygbcfcsj);
+				
+				dygbcfcsj.setMinutes(dygbcfcsj.getMinutes() + obj.bcsj);
+				obj.ARRIVALTIME = baseF.getTimeStr(dygbcfcsj);
 			},
 			zhygbcUpd: function(obj,xgOjb,dx) {
@@ -647,7 +647,6 @@ var RelationshipGraph = function () {
         			  .ordinal()
         			  .domain(this.configuration.lpNameA)
         			  .rangeRoundBands([ 0, this.configuration.height], .1);
-        	
             this.configuration.y = y;
             // 创建X轴
     		var xAxis = d3.svg
@@ -70,8 +70,28 @@
 		}else {
 			var jsonA = JSON.parse(objD);
 			// 使用已有的时刻表明细数据渲染视图.
-			data = {'json':jsonA.rsD,'bxrcgs':null};
+			// data = {'json':jsonA.rsD,'bxrcgs':null};
 			CSMap = {'gattA':null,'stopSpace': Math.round(map.zzsj/map.clzs),'maxCar':jsonA.rsLP};
+			var cara = jsonA.rsLP;
+			var rsjar = jsonA.rsD;
+			var resultJA = new Array();
+			for(var m = 0 ; m < cara.length; m++) {
+				// 获取路牌编号.
+				var lpNo_ = cara[m].lpNo;
+				// 定义路牌下的所有班次.
+				var lpbc_ = new Array();
+				// 遍历班次数.
+				for(var x =0 ; x <rsjar.length; x++) {
+					// 判断当期遍历的班次是否属于当前的路牌.
+					if(rsjar[x].lpNo == lpNo_) {
+						lpbc_.push(rsjar[x]);
+					}
+				}
+				// 按照发车序号顺序排序.
+				lpbc_.sort(function(a,b){return a.fcno-b.fcno});
+				resultJA = resultJA.concat(BaseFun.addjclbbc01(lpbc_,dataMap,stopAraay[0].lbsj,map));
+			}
+			data = {'json':rsjar,'bxrcgs':null};
 		}
 		// 创建甘特图对象.
 		var graph = d3.select('#ganttSvg').relationshipGraph(
@@ -401,6 +421,7 @@
         var hours=Math.floor(leave1/(3600*1000));
         DXHOURS = days*24+hours;
         WIDTH = DXHOURS*MINUTE*MULTIPLE;
+        debugger;
         var lpsplitA = getylp(p.yAxisCarArray);
 		var args = {
     	        'valueKeyName': VALUEKEYNAME,