添加接口：首班车因缺人而烂班（早未到）

娄高锋
1 parent 6f8c052c
Showing 1 changed file with 141 additions and 3 deletions
src/main/java/com/bsth/server_rs/bigdata/BigscreenService.java
@@ -24,7 +24,6 @@ import javax.ws.rs.Path;
 import javax.ws.rs.PathParam;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
-import javax.ws.rs.ext.MessageBodyWriter;
 import org.apache.commons.lang.StringUtils;
 import org.slf4j.Logger;
@@ -2753,6 +2752,146 @@ public class BigscreenService {
     	return resList;
     }
+    /** 按日期查询出车的早未到情况 */
+    @GET
+    @Path("/selectData/getNotYet/{date}")
+    public Map<String, Object> getNotYet(@PathParam("date") String date){
+    	Map<String, Object> resMap = new HashMap<String, Object>();
+    	
+    	String yyxlSql="SELECT line_code from bsth_c_line "
+    			+ " where nature in ('yxl','cgxl','gjxl','csbs','cctxl')";
+    	List<Map<String, Object>> yyxlList=jdbcTemplate.query(yyxlSql,
+				new RowMapper<Map<String, Object>>(){
+					@Override
+					public Map<String, Object>  mapRow(ResultSet rs, int rowNum) throws SQLException {
+						Map<String, Object> m=new HashMap<String,Object>();
+						m.put("lineCode", rs.getString("line_code"));
+						return m;
+					}
+				});
+    	Set<String> yyLine = new HashSet<String>();
+    	for(Map<String, Object> t : yyxlList){
+    		if(t.get("lineCode") != null){
+    			yyLine.add(t.get("lineCode").toString());
+    		}
+    	}
+    	
+    	String sqlMinYysj="select line, start_opt from bsth_c_line_config where "
+         		+ " id in (select max(id) from bsth_c_line_config group by line)";
+    	List<Map<String, Object>> minfcsjList = jdbcTemplate.query(sqlMinYysj,
+				new RowMapper<Map<String, Object>>(){
+				@Override
+				public Map<String, Object> mapRow(ResultSet rs, int rowNum) throws SQLException {
+					Map<String, Object> map = new HashMap<String, Object>();
+					map.put("line", rs.getString("line")!=null?rs.getString("line"):"");
+					map.put("minfcsj", rs.getString("start_opt")!=null?rs.getString("start_opt"):"02:00");
+					return map;
+				}
+		});
+        
+    	Map<String, Object> minfcsjMap = new HashMap<String, Object>();
+        for(Map<String, Object> map : minfcsjList){
+        	minfcsjMap.put(map.get("line").toString(), map.get("minfcsj").toString());
+        }
+        
+        SimpleDateFormat sdf = new SimpleDateFormat("HH:mm");
+        String format = sdf.format(new Date());
+
+    	List<ScheduleRealInfo> findAll = scheduleRealInfoRepository.findAll(date);
+    	List<ScheduleRealInfo> list_s = new ArrayList<ScheduleRealInfo>();
+    	Map<String, ScheduleRealInfo> scheduleMap = new HashMap<String, ScheduleRealInfo>();
+    	for(ScheduleRealInfo s : findAll){
+    		if(s.getXlBm() != null && yyLine.contains(s.getXlBm())){//营运线路
+    			Set<ChildTaskPlan> cts = s.getcTasks();
+    			if (cts != null && cts.size() > 0) {
+                    list_s.add(s);
+                } else if (s.getZdsjActual() != null && s.getFcsjActual() != null) {
+                    list_s.add(s);
+                } else if(s.getStatus() != 0){
+                	list_s.add(s);
+                }
+    		}
+    	}
+    	
+    	for(ScheduleRealInfo s : list_s){
+    		if(!(isInOut(s)) && !s.isCcService()){
+    			String[] split = s.getFcsj().split(":");
+				Long time = Long.valueOf(split[0]) * 60 + Long.valueOf(split[1]);
+				String minfcsj = minfcsjMap.get(s.getXlBm())!=null?minfcsjMap.get(s.getXlBm()).toString():"02:00";
+				String[] split_min = minfcsj.trim().split(":");
+				Long min = Long.valueOf(split_min[0]) * 60 + Long.valueOf(split_min[1]);
+				if(time < min){
+					time += 1440;
+				}
+				s.setFcsjT(time);
+    			String cl = s.getClZbh();
+    			if(scheduleMap.containsKey(cl)){
+    				ScheduleRealInfo s2 = scheduleMap.get(cl);
+					if(time < s2.getFcsjT()){
+						scheduleMap.put(cl, s);
+					}
+    			} else {
+    				scheduleMap.put(cl, s);
+    			}
+    		}
+    	}
+    	
+    	long sum = scheduleMap.keySet().size(), zwd = 0;//早未到数
+    	long yg_z = 0, sn_z = 0, jg_z = 0, nh_z = 0;
+    	long yg_zwd = 0, sn_zwd = 0, jg_zwd = 0, nh_zwd = 0;
+    	for(String key : scheduleMap.keySet()){
+    		ScheduleRealInfo s = scheduleMap.get(key);
+    		if("05".equals(s.getGsBm())){
+    			yg_z += 1;
+			} else if("55".equals(s.getGsBm())){
+				sn_z += 1;
+			} else if("22".equals(s.getGsBm())){
+				jg_z += 1;
+			} else if("26".equals(s.getGsBm())){
+				nh_z += 1;
+			}
+    		if("缺人".equals(s.getAdjustExps())){
+    			List<ScheduleRealInfo> list = new ArrayList<ScheduleRealInfo>();
+    			list.add(s);
+    			BigDecimal sjgl = new BigDecimal(culateSjgl(list));
+    			BigDecimal ljgl = new BigDecimal(culateLjgl(list));
+    			BigDecimal zero = new BigDecimal(0.0);
+    			if(sjgl.compareTo(zero) == 0 && ljgl.compareTo(zero) == 0){
+    				zwd += 1;
+    				if("05".equals(s.getGsBm())){
+    					yg_zwd += 1;
+    				} else if("55".equals(s.getGsBm())){
+    					sn_zwd += 1;
+    				} else if("22".equals(s.getGsBm())){
+    					jg_zwd += 1;
+    				} else if("26".equals(s.getGsBm())){
+    					nh_zwd += 1;
+    				}
+    			}
+    		}
+    	}
+    	
+    	resMap.put("sum", sum);
+    	resMap.put("notYet", zwd);
+    	resMap.put("sum_05", yg_z);
+    	resMap.put("notYet_05", yg_zwd);
+    	resMap.put("sum_55", sn_z);
+    	resMap.put("notYet_55", sn_zwd);
+    	resMap.put("sum_22", jg_z);
+    	resMap.put("notYet_22", jg_zwd);
+    	resMap.put("sum_26", nh_z);
+    	resMap.put("notYet_26", nh_zwd);
+    	return resMap;
+    }
+    
+    public static void main(String[] args){
+    	double a = 0.10;
+    	double b = 0.0;
+    	BigDecimal a1 = new BigDecimal(a);
+    	BigDecimal b1 = new BigDecimal(b);
+    	System.out.println(a1.compareTo(b1));
+    }
+    
     public List<Map<String, Object>> createMap(String type, String[] dates){
     	List<Map<String, Object>> mapList = new ArrayList<Map<String, Object>>();
@@ -2810,7 +2949,6 @@ public class BigscreenService {
 								}else{
 									sjgl=Arith.add(sjgl,jhlc);
 								}
-								
 							}
 						}else{
 							Iterator<ChildTaskPlan> it = childTaskPlans.iterator();
@@ -2826,7 +2964,7 @@ public class BigscreenService {
 			                    }
 			                }
 						}
-				   }
+					}
 			}
 		}
 		return sjgl;