批量上传站级数据

zlz
1 parent 5e705681
Showing 3 changed files with 55 additions and 0 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 {
@@ -27,6 +27,13 @@ public interface TrafficManageService {
 	String setXL(String ids);
 	/**
+	 * 上传线路信息
+	 *
+	 * @return 调用接口返回信息
+	 */
+	String setXLByInUse(String ids);
+
+	/**
 	 * 上传车辆信息
 	 *
 	 * @return 调用接口返回信息
@@ -160,6 +160,9 @@ 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 ;
@@ -237,6 +240,42 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	}
 	/**
+	 * 上传线路信息(按in_use上传)
+	 */
+	@Override
+	public String setXLByInUse(String inUse) {
+		String result = "failure";
+		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));
+			String[] ids ;
+			if(lines != null && lines.size() > 0){
+				ids = new String[lines.size()];
+				for(int i = 0 ; i < lines.size() ; i ++){
+					line = lines.get(i);
+					if(line != null && line.getId() != null){
+						ids[i] = String.valueOf(line.getId());
+					}
+				}
+				if(ids != null && ids.length > 0 ){
+					System.out.println(ids.length);
+					setXL(StringUtils.join(ids,","));
+				}
+			}
+		} catch (Exception e) {
+			result = "failure";
+			logger.error("setXLByInUse:",e);
+			e.printStackTrace();
+		}
+		return result;
+	}
+
+	/**
 	 * 上传车辆信息
 	 */
 	@Override