李强

李强
1 parent 43c95db6
Showing 10 changed files with 139 additions and 62 deletions
src/main/java/com/bsth/controller/StationRouteController.java
src/main/java/com/bsth/repository/SectionRouteRepository.java
src/main/java/com/bsth/repository/StationRouteRepository.java
src/main/java/com/bsth/service/StationRouteService.java
src/main/java/com/bsth/service/impl/StationRouteServiceImpl.java
src/main/java/com/bsth/util/FTPClientUtils.java
src/main/resources/static/pages/base/line/js/line-add-form.js
src/main/resources/static/pages/base/line/js/line-edit-form.js
src/main/resources/static/pages/base/line/js/line-list-table.js
src/main/resources/static/pages/base/line/list.html
@@ -92,11 +92,10 @@ public class StationRouteController extends BaseController&lt;StationRoute, Integer
 	 * 
 	 * @param map <id:线路ID>
 	 * 
-	 * @return Map<String, Object> <SUCCESS ; ERROR>
+	 * @return Map<String, Object> <SUCCESS ; ERROR ; NOTDATA>
 	 */
 	@RequestMapping(value = "/usingSingle",method = RequestMethod.POST)
 	public Map<String, Object> usingSingle(@RequestParam Map<String, Object> map) {
-		
 		return service.usingSingle(map);
 	}
  
@@ -142,6 +142,13 @@ public interface SectionRouteRepository extends BaseRepository&lt;SectionRoute, Int
 	@Query(value = " select  MAX(r.sectionroute_code) as sectionrouteCode   from bsth_c_sectionroute r  WHERE r.line=?1 and r.directions =?2 and r.sectionroute_code< ?3", nativeQuery=true)
 	List<Object[]> findUpSectionRouteCode(Integer lineId,Integer direction,Integer stationRouteCode);
  
+	/**
+	 * @Description :TODO(获取路段路由信息)
+	 * 
+	 * @param lineId：线路ID；directions：方向
+	 * 
+	 * @return List<Map<String, Object>> {[0]：directions（方向）；[1]：bsection_vector(路段坐标)；[2]：speed_limit(限速)；[3]：section_name(路段名称)}
+	 */
 	@Query(value =  "SELECT " +
 					"c.directions," +
 					"AsText(s.bsection_vector) as bsection_vector," +
@@ -149,5 +156,5 @@ public interface SectionRouteRepository extends BaseRepository&lt;SectionRoute, Int
 					"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)
-List<Object[]> sectionRouteVector(Integer lineId,Integer directions);
+	List<Object[]> sectionRouteVector(Integer lineId,Integer directions);
 }
@@ -126,7 +126,11 @@ public interface StationRouteRepository extends BaseRepository&lt;StationRoute, Int
 	 * 
 	 * @param  lineId:线路ID 
 	 * 
-	 * @return List<Object[]>
+	 * @return List<Object[]>：{[0]：g_lonx（GPS经度）；[1]：g_laty（GPS纬度）；[2]：b_jwpoints（百度经纬度坐标）
+	 * 							
+	 * 							[3]：station_mark（站点类型）；[4]：station_route_code（站点序号）；[5]：station_cod（站点编码）；
+	 * 
+	 * 							[6]：distances（站点距离）；[7]：station_name（站点名称）；[8]：directions（方向）}
 	 */
 	@Query(value = "SELECT * FROM ("+
 				   "SELECT b.g_lonx," +
@@ -65,7 +65,7 @@ public interface StationRouteService extends BaseService&lt;StationRoute, Integer&gt; 
 	  * 
 	  * @param map <id:线路ID>
 	  * 
-	  * @return Map<String, Object> <SUCCESS ; ERROR>
+	  * @return Map<String, Object> <SUCCESS ; ERROR ; NOTDATA>
 	  */
 	 Map<String, Object> usingSingle(Map<String, Object> map);
  
 package com.bsth.service.impl;
  
-import java.awt.Point;
 import java.io.ByteArrayInputStream;
 import java.io.File;
 import java.io.InputStream;
+import java.text.DecimalFormat;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -23,7 +23,7 @@ import com.bsth.repository.StationRepository;
 import com.bsth.repository.StationRouteRepository;
 import com.bsth.service.StationRouteService;
 import com.bsth.util.FTPClientUtils;
-import com.bsth.util.Test;
+import com.bsth.util.PackTarGZUtils;
 import com.bsth.util.db.DBUtils_MS;
  
 /**
@@ -505,11 +505,12 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 	 * 
 	 * @param map <lineId:线路ID>
 	 * 
-	 * @return Map<String, Object> <SUCCESS ; ERROR>
+	 * @return Map<String, Object> <SUCCESS ; ERROR ; NOTDATA>
 	 */
 	@Override
 	public Map<String, Object> usingSingle(Map<String, Object> map) {
  
+		// 返回值map
 		Map<String, Object> resultMap = new HashMap<String,Object>();
  
 		try {
@@ -517,65 +518,75 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 			// 获取线路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参数 */
+				/** 获取配置文件里的ftp登录参数 */
 				Map<String, Object> FTPParamMap = readPropertiesGetFTPParam();
  
 				// 压缩文件名
 				String odlGzFileName = line.getLineCode() + ".txt.gz";
  
-				// text文件名
+				// 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);
  
+				/** 行单文件内容 @param：<objects：站点路由；lineId：线路ID>*/
 				String textStr = newTextFileToFTP(objects,lineId);
  
-				/*textStr = line.getName() + "\t" + "2" + "\r\n" + textStr;*/
+				/*textStr = line.getName() + "\t" + "2" + "\r" + textStr;*/
  
-				textStr = line.getName() + "\t" + "2" + "\r" + textStr;
+				textStr = line.getName() + " " + "2" + "\r" + textStr;
  
 				InputStream input = new ByteArrayInputStream(textStr.getBytes("gbk"));
  
-				/** 生成text文件 */
+				/** 生成txt文件，上传ftp */
 				clientUtils.uploadFile(url, port, username, password, remotePath, textFileName, input);
  
-				Test test= new Test();
-				
+				// 创建打包实例
+				PackTarGZUtils packTarGZUtils= new PackTarGZUtils();
  
+				/** 获取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);
-				  
-				File targetFile = test.pack(sources, target);
+				 
+				// 将txt文件打包
+				File targetFile = packTarGZUtils.pack(sources, target);
  
 				/*clientUtils.testUpLoadFromDisk(targetFile,targetFile.getName());*/
  
-				clientUtils.testUpLoadFromDisk(targetFile, targetFile.getName(), url, port, username, password, remotePath);
+				clientUtils.FTPUpLoadFromDisk(targetFile, targetFile.getName(), url, port, username, password, remotePath);
  
 				resultMap.put("status", ResponseCode.SUCCESS);
  
@@ -595,15 +606,31 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 		return resultMap;
 	}
  
+	/**
+	 * @Description : TODO(形成行单文件内容)
+	 * 
+	 * @param objects ：站点路由信息
+	 * 	
+	 * 					{[0]：g_lonx（GPS经度）；[1]：g_laty（GPS纬度）；[2]：b_jwpoints（百度经纬度坐标）
+	 * 							
+	 * 					[3]：station_mark（站点类型）；[4]：station_route_code（站点序号）；[5]：station_cod（站点编码）；
+	 * 
+	 * 				    [6]：distances（站点距离）；[7]：station_name（站点名称）；[8]：directions（方向）}
+	 * 
+	 * @param lineId ：线路ID
+	 * 
+	 * @return String
+	 */ 
 	public String  newTextFileToFTP(List<Object[]> objects,Integer lineId) {
  
+		// 返回值String
 		String stationRStr = "";
  
 		// windows下的文本文件换行符
 		//String enterStr = "\r\n";
  
 		// linux/unix下的文本文件换行符
-		 String enterStr = "\r";
+		String enterStr = "\r";
  
 		if(objects.size()>0) {
  
@@ -618,15 +645,17 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 				lat = "\t" +  lat;
  
 				// 站点类型
-				String stationMake =  objects.get(i)[3].equals("") ? "" : objects.get(i)[3].toString();
+				String stationMakeStr =  objects.get(i)[3].equals("") ? "" : objects.get(i)[3].toString();
  
-				if(stationMake.equals("E")) {
+				String stationMake = "";
+				
+				if(stationMakeStr.equals("E")) {
  
-					stationMake = "\t" + "2";
+					stationMake = "\t2";
  
 				}else {
  
-					stationMake ="\t" + "1";
+					stationMake ="\t1";
  
 				}
  
@@ -640,30 +669,35 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
  
 				stationCode =  "\t" +stationCode;
  
-				double dis = objects.get(i)[6]==null  ? 0.0 : Double.parseDouble(objects.get(i)[6].toString());
+				double dis = objects.get(i)[6]==null  ? 0.0 : Double.parseDouble(objects.get(i)[6].toString())*1000;
  
-				double tempd = dis*1000;
+				String tempDistc = String.valueOf((int) dis);
  
 				// 站点距离
-				String staitondistance = "\t" + String.valueOf((int) tempd);
+				String staitondistance = "\t" + tempDistc;
  
 				// 站点名称
 				String stationName =  objects.get(i)[7].equals("") ? "" : objects.get(i)[7].toString();
  
+				stationName = "\t" +stationName;
+				
 				// 限速
 				// String sleepStr = " " + "60";
  
+				// 限速
 				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) {
  
-					sleepStr = sobje.get(0)[2] == null ? "" : sobje.get(0)[2].toString();
+					double dsleepStr = sobje.get(0)[2] == null ? 60d : Double.valueOf(sobje.get(0)[2].toString());
  
-					sleepStr =  "\t" + sleepStr;
+					sleepStr =  "\t" +  new DecimalFormat("0").format(dsleepStr);
  
 				}else if(sobje.size()>1){
  
@@ -676,9 +710,11 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
  
 						if(stationName.equals(sectionNameA[0])){
  
-							sleepStr = sobje.get(j)[2].toString();
+							/*sleepStr = sobje.get(j)[2].toString();*/
+							
+							double dsleepStrt = sobje.get(0)[2] == null ? 60d : Double.valueOf(sobje.get(j)[2].toString());
  
-							sleepStr =  "\t" + sleepStr;
+							sleepStr =  "\t" +  new DecimalFormat("0").format(dsleepStrt);
  
 						}
  
@@ -700,12 +736,6 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 					sleepStr = sleepStr + GetFormPointOnPolylineSeleepLimit(pointsM,sobje);*/
 				}
  
-				if(sleepStr.equals(""))
-					sleepStr = "\t" + "60";
-					
-				
-				stationName = "\t" +stationName;
-				
 				stationRStr = stationRStr + lng + lat + stationMake + stationNo + stationCode + staitondistance + sleepStr + stationName + enterStr;
  
 			}
@@ -800,8 +830,14 @@ public class StationRouteServiceImpl extends BaseServiceImpl&lt;StationRoute, Integ
 		return success;
 	}
  
+	/**
+	 * @Description：TOOD(获取FTP登录参数) 这里暂时只做一个map值返回，以后可以作为ftp登录类提出来
+	 * 
+	 * @return ： Map<String, Object> <url：IP；port：端口；username：用户名；password：密码；remotePath：相对路径>
+	 */
 	public Map<String, Object> readPropertiesGetFTPParam(){
  
+		// 返回值map
 		Map<String, Object> resultMap = new HashMap<String, Object>();
  
 		Properties env = new Properties();
 package com.bsth.util;
  
-import java.io.BufferedReader;
 import java.io.ByteArrayInputStream;
 import java.io.File;
 import java.io.FileInputStream;
@@ -8,7 +7,6 @@ import java.io.FileNotFoundException;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
-import java.io.InputStreamReader;
 import java.io.OutputStream;
 import java.io.UnsupportedEncodingException;
  
@@ -103,8 +101,25 @@ public class FTPClientUtils {
 		return success;
 	}
  
-	// 将本地文件上传到FTP服务器上
-	public void testUpLoadFromDisk(File file,String name,String url, int port, String username, String password, String remotePath){
+	/**
+	 * @Description : TOOD(将本地文件上传到FTP服务器上)
+	 * 
+	 * @param file
+	 * 
+	 * @param name
+	 * 
+	 * @param url
+	 * 
+	 * @param port
+	 * 
+	 * @param username
+	 * 
+	 * @param password
+	 * 
+	 * @param remotePath
+	 * 
+	 */
+	public void FTPUpLoadFromDisk(File file,String name,String url, int port, String username, String password, String remotePath){
  
 		 try { 
 		        FileInputStream in=new FileInputStream(file); 
@@ -143,16 +158,21 @@ public class FTPClientUtils {
 	}
  
 	/** 
-     * <删除FTP上的文件> 
-     * <远程删除FTP服务器上的录音文件> 
+     * @Description (删除FTP上的文件)
+     * 
      * @param url FTP服务器IP地址 
+     * 
      * @param port FTP服务器端口 
+     * 
      * @param username FTP服务器登录名 
+     * 
      * @param password FTP服务器密码 
+     * 
      * @param remotePath 远程文件路径 
+     * 
      * @param fileName 待删除的文件名 
-     * @return 
-     * @see [类、类#方法、类#成员] 
+     * 
+     * @return boolean
      */  
     public static boolean deleteFtpFile(String url, int port, String username, String password, String remotePath, String fileName){  
  
@@ -49,6 +49,8 @@ $(function(){
 	 // 填充公司下拉框选择值
 	 $get('/business/all', {upCode_eq: '77'}, function(array){
  
+		 console.log(array);
+		 
 		 // 公司下拉options属性值
 		 var options = '<option value="">-- 请选择公司 --</option>';
  
@@ -12,7 +12,7 @@
 		// 初始化公司下拉框
 		selectTemp(function(){
  
-			// 根据ID查询详细信息
+			/** 根据ID查询详细信息 */
 			$get('/line/' + lineId ,null, function(result){
  
 				// 如果不为空
@@ -24,7 +24,7 @@
 					// 设置日期
 					result.openDate = moment(result.openDate).format(fs);
  
-					// 填充修改线路表单元素值
+					/** 填充修改线路表单元素值 @param：<result：数据结果集；line_edit_form：表单元素> */
 					putFormData(result, '#line_edit_form');
  
 					// 设置公司值
@@ -60,7 +60,7 @@
 	// 输入线路名称，自动生成英文名称和线路简称
 	$('#nameInput').on('keyup', setPinYin);
  
-	// 根据线路名称值设置英文名称值和线路简称
+	/** 根据线路名称值设置英文名称值和线路简称 */
 	function setPinYin(){
  
 		// 获取线路名称值
@@ -74,7 +74,7 @@
 	 }
  
  
-	// 公司下拉框
+	/** 公司下拉框 @param：<callback：回调函数> */
 	function selectTemp(callback) {
  
 		// 填充公司下拉框选择值
@@ -453,7 +453,7 @@
 		}
 	});
  
-	// 联系电话(手机/电话皆可)验证 
+	/** 联系电话(手机/电话皆可)验证  */
 	$.validator.addMethod("isPhone", function(value,element) {
  
 		// 长度
 /**
  * 
- * @JSName : list.js(线路信息list.html页面js)
+ * @JSName : line-list-table.js(线路信息list.html页面js)
  * 
  * @Author : bsth@lq
  * 
@@ -27,14 +27,16 @@
  
 		 });
  
-		 // 填充公司下拉框options,并添加公司下拉框值改变事件setbrancheCompanySelectOptions
+		 // 填充公司下拉框options
 		 $('#companySelect').html(options)
+		 
+		 /** 闵行没下属公司，这里暂时注释公司值改变事件  */
 		 //$('#companySelect').html(options).on('change', setbrancheCompanySelectOptions);
  
 	 });
  
-	 /** 填充分公司下拉框 */ 
-	 setbrancheCompanySelectOptions();
+	 /** 填充分公司下拉框。--- 闵行没下属公司，这里暂时注释*/ 
+	/* setbrancheCompanySelectOptions();*/
  
 	 /** 填充分公司下拉框选择值 */ 
 	 function setbrancheCompanySelectOptions(){
@@ -53,7 +55,7 @@
  
 		  } else {
  
-			  // 查询出所属公司下的分公司名称和相应分公司代码
+			  /** 查询出所属公司下的分公司名称和相应分公司代码 @param：<upCode_eq：公司代码> */
 			  $get('/business/all', {upCode_eq: businessCode}, function(array){
  
 				  // 遍历array
@@ -75,7 +77,7 @@
 	// 选择框
 	var icheckOptions = {checkboxClass: 'icheckbox_flat-blue',increaseArea: '20%'};
  
-	// 表格数据分页加载
+	/** 表格数据分页加载 @param：<null：搜索参数；true：是否重新分页> */
 	loadTableDate(null,true);
  
 	/** 重置按钮事件 */
@@ -84,7 +86,7 @@
 		 // 清空搜索框值
 		 $('tr.filter input,select').val('').change();
  
-		 // 重新加载表格数据
+		 /** 表格数据分页加载 @param：<null：搜索参数；true：是否重新分页> */
 		 loadTableDate(null,true);
 	});
  
@@ -120,8 +122,10 @@
 				}
 			}
 		});
+		
 		page = 0;
  
+		/** 表格数据分页加载 @param：<params：搜索参数；true：是否重新分页> */
 		loadTableDate(params,true);
 	});
  
@@ -149,8 +153,6 @@
 		// 异步请求获取表格数据
 		$.get('/line',params,function(result){
  
-			console.log(result);
-			
 			// 添加序号
 			result.content.page =  page;
  
@@ -244,7 +246,7 @@
 		});
 	}
  
-	// 生成行单
+	/** 生成行单，这里暂时只做了单选生成。 */
 	$('#datatable_ajax_tools #createUsingSingle').on('click', function() {
  
 		// 获取选中行
@@ -275,11 +277,13 @@
  
     		lineName = arrChk.val();
  
+    		// 请求参数
     		var params = {lineId:id};
  
     		// 弹出正在加载层
     		var index = layer.load(0);
  
+    		/** 生成线路行单 @pararm：<params：请求参数> */
 			$post('/stationroute/usingSingle',params,function(data) {
  
 				 // 关闭弹出框
@@ -53,6 +53,7 @@
 								<th width="7%">线路编码</th>
 								<th width="8%">线路名称</th>
 								<th width="7%">所属公司</th>
+								<!-- 闵行没有下属公司，这里暂时注释掉 -->
 								<!-- <th width="8%">所属分公司</th> -->
 								<th width="6%">线路性质</th>
 								<th width="6%">线路等级</th>
@@ -72,12 +73,15 @@
 									<input type="text"  class="form-control form-filter input-sm" name="name_like">
 								</td>
 								<td>
+									 <!-- 公司这里没使用字典表，暂时查的公司表 -->
 									 <select name="company_eq" class="form-control" id="companySelect"></select>
 								</td>
+								<!-- 闵行没有下属公司，这里暂时注释掉 -->
 								<!-- <td>
 									 <select name="brancheCompany_eq" class="form-control" id="brancheCompanySelect"></select>
 								</td> -->
 								<td>
+									<!-- 这里没使用字典表，暂时写在页面上 -->
 									<select name="nature_like" class="form-control" id="natureSelect">
 										<option value="">请选择...</option>
 										<option value="lj">路救</option>
@@ -93,6 +97,7 @@
 									</select>
 								</td>
 								<td>
+									<!-- 这里没使用字典表，暂时写在页面上 -->
 									<select name="level_eq" class="form-control" id="levelSelect">
 										<option value="">请选择...</option>
 										<option value="1">一级线路</option>
@@ -104,6 +109,7 @@
 									 <input type="text" class="form-control form-filter input-sm" name="shanghaiLinecode_eq">
 								</td>
 								<td>
+									<!-- 这里没使用字典表，暂时写在页面上 -->
 									<select class="form-control form-filter " name="destroy_eq">
                                          <option value="">请选择...</option>
                                          <option value="0">运营</option>
@@ -225,7 +231,6 @@
 					闵行公司
 				{{/if}}
 			</td>
-			
 			<td>
 				{{if obj.nature == 'lj'}}
 						路救