按车辆统计营运公里的接口

娄高锋
1 parent c146dcd0
Showing 2 changed files with 143 additions and 4 deletions
src/main/java/com/bsth/repository/ScheduleRealInfoRepository.java
src/main/java/com/bsth/server_rs/bigdata/BigdataService.java
@@ -69,4 +69,14 @@ public interface ScheduleRealInfoRepository extends PagingAndSortingRepository&lt;S
 	@EntityGraph(value = "scheduleRealInfo_cTasks", type = EntityGraph.EntityGraphType.FETCH)
 	@Query("select DISTINCT s from ScheduleRealInfo s where s.scheduleDateStr in (?1) and s.updateDate>=?2")
 	List<ScheduleRealInfo> findByDates(List<String> schDates, Date timestamp);
+	
+	/**
+	 * 根据日期区间获取班次信息
+	 * @param startDate
+	 * @param endDate
+	 * @return
+	 */
+	@EntityGraph(value = "scheduleRealInfo_cTasks", type = EntityGraph.EntityGraphType.FETCH)
+	@Query(value="select DISTINCT s from ScheduleRealInfo s where s.scheduleDateStr between ?1 and ?2 order by s.scheduleDateStr, s.gsBm, s.fgsBm, s.xlBm")
+	List<ScheduleRealInfo> findScheduleByDates(String startDate, String endDate);
 }
@@ -3,12 +3,16 @@ package com.bsth.server_rs.bigdata;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.text.DecimalFormat;
+import java.text.ParseException;
 import java.text.SimpleDateFormat;
+import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.Date;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
  
 import javax.ws.rs.GET;
 import javax.ws.rs.Path;
@@ -19,11 +23,20 @@ import javax.ws.rs.core.MediaType;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.support.collections.RedisMap;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.jdbc.core.RowMapper;
 import org.springframework.stereotype.Component;
  
 import com.alibaba.fastjson.JSONObject;
+import com.bsth.entity.ChildTaskPlan;
+import com.bsth.entity.DestroySituation;
+import com.bsth.entity.ScheduleRealInfo;
+import com.bsth.repository.DestroySituationRepository;
+import com.bsth.repository.ScheduleRealInfoRepository;
+import com.bsth.server_rs.base_info.car.buffer.CarBufferData;
+import com.bsth.util.Arith;
+import com.mysql.fabric.xmlrpc.base.Array;
  
 @Component
 @Path("/bigdata")
@@ -34,6 +47,12 @@ public class BigdataService {
     @Autowired
     JdbcTemplate jdbcTemplate;
  
+    @Autowired
+    private DestroySituationRepository destroySituationRepository;
+
+    @Autowired
+    private ScheduleRealInfoRepository scheduleRealInfoRepository;
+    
 	DecimalFormat df = new DecimalFormat("0.00");
  
 	SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -1287,14 +1306,15 @@ public class BigdataService {
      * @param starDate
      * @param endDate
      * @return
+     * @throws ParseException 
      */
     @GET
-    @Path("/getScheduleZs/starDate/{starDate}/endDate/{endDate}")
-    public List<Map<String, Object>> getScheduleZs(@PathParam("starDate") String starDate,
-    		@PathParam("endDate") String endDate) {
+    @Path("/getScheduleAccident/startDate/{startDate}/endDate/{endDate}")
+    public List<Map<String, Object>> getScheduleAccident(@PathParam("startDate") String startDate,
+    		@PathParam("endDate") String endDate) throws ParseException {
     	String sql="select gs_bm,fgs_bm,real_exec_date,fcsj,fcsj_actual,xl_name,j_gh,j_name,cl_zbh,car_plate,remarks "
     			+ " from bsth_c_s_sp_info_real r left join bsth_c_cars c on r.cl_zbh = c.inside_code "
-    			+ " where schedule_date_str>='"+starDate+"' and schedule_date_str<= '"+endDate+"' "
+    			+ " where schedule_date_str>='"+startDate+"' and schedule_date_str<= '"+endDate+"' "
     			+ " and adjust_exps like '%肇事%' and status = '-1' "
     			+ " order by real_exec_date, schedule_date_str, fcsj";
  
@@ -1317,7 +1337,116 @@ public class BigdataService {
 						return m;
 					}
 		});
+    	
+    	SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+    	Date d1 = sdf.parse(startDate);
+    	Date d2 = sdf.parse(endDate);
+    	while(d1.getTime() <= d2.getTime()){
+    		String rq = sdf.format(d1);
+    		List<DestroySituation> destroys = destroySituationRepository.findByDateAndReason(rq, "肇事");
+    		for(DestroySituation ds : destroys){
+    			ScheduleRealInfo s = scheduleRealInfoRepository.findOne(Long.parseLong(ds.getIdsStr().split(",")[0]));
+    			Map<String, Object> m = new HashMap<String, Object>();
+    			m.put("gs_bm", ds.getGsBm());
+    			m.put("fgs_bm", ds.getFgsBm());
+    			m.put("real_exec_date", rq);
+    			m.put("fcsj", s==null?"00:00":(s.getFcsj()!=null&&s.getFcsj().trim().length()>0?s.getFcsj():""));
+    			m.put("fcsj_actual", s==null?"00:00":(s.getFcsjActual()!=null&&s.getFcsjActual().trim().length()>0?s.getFcsjActual():""));
+    			m.put("xl_name", ds.getLineName());
+    			m.put("j_gh", ds.getjGh());
+				m.put("j_name", s==null?"":(s.getjName()!=null&&s.getjName().trim().length()>0?s.getjName():""));
+    			m.put("cl_zbh", ds.getNbbm());
+    			m.put("car_plate", CarBufferData.findOne(ds.getNbbm()).getCarPlate());
+    			m.put("remarks", (s==null?"":(s.getQdzName()+"->"+s.getZdzName()+"；"))+ds.getRemark());
+    		}
+    	}
+    	
     	return list;
     }
  
+    /**
+     * 给机务（徐铉、郑鑫）按车辆统计营运公里
+     * @param starDate
+     * @param endDate
+     * @return
+     * @throws ParseException 
+     */
+    @GET
+    @Path("/mileageByVehicle/startDate/{startDate}/endDate/{endDate}")
+    public List<Map<String, Object>> mileageByVehicle(@PathParam("startDate") String starDate,
+    		@PathParam("endDate") String endDate) throws ParseException {
+    	List<Map<String, Object>> resList = new ArrayList<Map<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());
+    		}
+    	}
+    	
+    	BigscreenService bigscreenService = new BigscreenService();
+    	List<ScheduleRealInfo> dataList = scheduleRealInfoRepository.findScheduleByDates(starDate, endDate);
+    	Map<String, List<ScheduleRealInfo>> keyMap = new HashMap<String, List<ScheduleRealInfo>>();
+    	List<String> keyList = new ArrayList<String>();
+    	
+    	for(ScheduleRealInfo s : dataList){
+    		if(s.getXlBm() != null && yyLine.contains(s.getXlBm())){//营运线路
+	    		String dateStr = s.getScheduleDateStr();
+	    		String gsBm = s.getGsBm();
+	    		String cl = s.getClZbh();
+	    		String key = dateStr + "/" + gsBm + "/" + cl;
+	    		if(!(keyMap.containsKey(key))){
+	    			keyMap.put(key, new ArrayList<ScheduleRealInfo>());
+	    			keyList.add(key);
+	    		}
+	    		keyMap.get(key).add(s);
+    		}
+    	}
+    	
+    	for(String key : keyList){
+    		List<ScheduleRealInfo> list = keyMap.get(key);
+        	List<ScheduleRealInfo> listSche = new ArrayList<ScheduleRealInfo>();//全部班次
+        	List<ScheduleRealInfo> list_s = new ArrayList<ScheduleRealInfo>();//已执行班次
+    		for(ScheduleRealInfo s : list){
+    			listSche.add(s);
+    			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);
+    				}
+    			}
+    		}
+    		
+			double sjgl = bigscreenService.culateSjgl(list_s);//实际营运公里（不含临加）
+			double sjljgl = bigscreenService.culateLjgl(listSche);//实际临加公里
+			double sjyygl = Arith.add(sjgl, sjljgl);//实际营运公里
+	    	double sjjccgl = bigscreenService.culateJccgl(list_s);
+	    	double sjksgl = bigscreenService.culateKsgl(list_s);
+	    	double zksgl = Arith.add(sjjccgl, sjksgl);//实际空驶总公里
+	    	
+	    	Map<String, Object> m = new HashMap<String, Object>();
+	    	m.put("date", key.split("/")[0]);
+	    	m.put("companyCode", key.split("/")[1]);
+	    	m.put("car", key.split("/")[2]);
+	    	m.put("businessMileage", sjyygl);
+	    	m.put("emptyMileage", zksgl);
+	    	resList.add(m);
+    	}
+    	
+    	return resList;
+    }
+    
 }