早未到接口更新

娄高锋
1 parent 15258e9d
Showing 1 changed file with 146 additions and 0 deletions
src/main/java/com/bsth/server_rs/bigdata/BigscreenService.java
@@ -3113,6 +3113,152 @@ public class BigscreenService {
         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);
+    			}
+    		}
+    	}
+    	
+    	List<ScheduleRealInfo> notYetList = new ArrayList<ScheduleRealInfo>();
+    	
+    	long sum = scheduleMap.keySet().size(), zwd = 0;//早未到数
+//    	long yg_z = 0, sn_z = 0, jg_z = 0, nh_z = 0;
+    	long cd_1 = 0, cd_2 = 0, cd_3 = 0, cd_5 = 0, cd_6 = 0;
+//    	long yg_zwd = 0, sn_zwd = 0, jg_zwd = 0, nh_zwd = 0;
+    	long cd_1_zwd = 0, cd_2_zwd = 0, cd_3_zwd = 0, cd_5_zwd = 0, cd_6_zwd = 0;
+    	for(String key : scheduleMap.keySet()){
+    		ScheduleRealInfo s = scheduleMap.get(key);
+    		if("77".equals(s.getGsBm())){
+    			if("1".equals(s.getFgsBm())){
+    				cd_1 += 1;
+    			} else if("2".equals(s.getFgsBm())){
+    				cd_2 += 1;
+    			} else if("3".equals(s.getFgsBm())){
+    				cd_3 += 1;
+    			} else if("5".equals(s.getFgsBm())){
+    				cd_5 += 1;
+    			} else if("6".equals(s.getFgsBm())){
+    				cd_6 += 1;
+    			}
+	    		if("缺人".equals(s.getAdjustExps()) || "缺车".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("1".equals(s.getFgsBm())){
+	    					cd_1_zwd += 1;
+	    				} else if("2".equals(s.getFgsBm())){
+	    					cd_2_zwd += 1;
+	    				} else if("3".equals(s.getFgsBm())){
+	    					cd_3_zwd += 1;
+	    				} else if("5".equals(s.getFgsBm())){
+	    					cd_5_zwd += 1;
+	    				} else if("6".equals(s.getFgsBm())){
+	    					cd_6_zwd += 1;
+	    				}
+	    				notYetList.add(s);
+	    			}
+	    		}
+			}
+    	}
+    	
+    	resMap.put("sum", sum);
+    	resMap.put("notYet", zwd);
+    	resMap.put("sum_1", cd_1);
+    	resMap.put("notYet_1", cd_1_zwd);
+    	resMap.put("sum_2", cd_2);
+    	resMap.put("notYet_2", cd_2_zwd);
+    	resMap.put("sum_3", cd_3);
+    	resMap.put("notYet_3", cd_3_zwd);
+    	resMap.put("sum_5", cd_5);
+    	resMap.put("notYet_5", cd_5_zwd);
+    	resMap.put("sum_6", cd_6);
+    	resMap.put("notYet_6", cd_6_zwd);
+    	resMap.put("notYetList", notYetList);
+    	return resMap;
+    }
+    
+    /** 按日期查询出车的早未到情况(含回场再出场后的首班) */
+    @GET
+    @Path("/selectData/getNotYet1/{date}")
+    public Map<String, Object> getNotYet1(@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());
+        }
     	List<ScheduleRealInfo> findAll = scheduleRealInfoRepository.findAllByOrder(date);
     	List<ScheduleRealInfo> list_s = new ArrayList<ScheduleRealInfo>();