潘钊 / bsth_control · Files

package com.bsth.data.match;
//package com.bsth.data.match;
//
//import java.util.ArrayList;
//import java.util.Collections;
//import java.util.List;
//import java.util.Set;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.beans.BeansException;
//import org.springframework.context.ApplicationContext;
//import org.springframework.context.ApplicationContextAware;
//import org.springframework.stereotype.Component;
//
//import com.bsth.data.arrival.ArrivalComparator;
//import com.bsth.data.arrival.ArrivalData_GPS;
//import com.bsth.data.arrival.ArrivalEntity;
//import com.bsth.data.schedule.DayOfSchedule;
//import com.bsth.data.schedule.ScheduleComparator;
//import com.bsth.entity.realcontrol.ScheduleRealInfo;
//import com.bsth.service.directive.DirectiveService;
//import com.bsth.websocket.handler.SendUtils;
//
///**
// * 
// * @ClassName: Arrival2Schedule 
// * @Description: TODO(进出数据匹配班次) 
// * @author PanZhao 
// * @date 2016年8月10日 下午2:26:22 
// *
// */
//@Component
//public class Arrival2Schedule implements ApplicationContextAware{
//	
//	private static ScheduleComparator.FCSJ schComparator;
//	private static ArrivalComparator arrComparator;
//	private static SendUtils sendUtils;
//	private static DayOfSchedule dayOfSchedule;
//	private static DirectiveService directiveService;
//	
//	private final static long MAX_RANGE = 1000 * 60 * 60 * 1L;
//	
//	static{
//		schComparator = new ScheduleComparator.FCSJ();
//		arrComparator = new ArrivalComparator();
//	}
//	
//	static Logger logger = LoggerFactory.getLogger(Arrival2Schedule.class);
//	
//	/**
//	 * 
//	 * @Title: start 
//	 * @Description: TODO(开始) 
//	 * @param @param cars    需要匹配的车辆集合
//	 */
//	public static void start(Set<String> cars){
//		
//		for(String car : cars){
//			new GpsMatchThread(car).start();
//		}
//	}
//	
//	public static class GpsMatchThread extends Thread{
//
//		String nbbm;
//		public GpsMatchThread(String nbbm){
//			this.nbbm = nbbm;
//		}
//		
//		@Override
//		public void run() {
//			//班次列表
//			List<ScheduleRealInfo> schList = dayOfSchedule.findByNbbm(nbbm);
//			//进出起终点数据
//			List<ArrivalEntity> arrList = ArrivalData_GPS.getIncrement(nbbm);
//			logger.info("####匹配进出站增量数据 " + arrList.size());
//			//排序
//			Collections.sort(schList, schComparator);
//			Collections.sort(arrList, arrComparator);
//			
//			int si = lastMatchPoint(schList);
//			int ai = afterByTime(arrList, lastMatchTime(schList.get(si)));
//			
//			//按起始索引开始匹配
//			match(arrList, ai, schList, si);
//		}
//		
//		public void match(List<ArrivalEntity> arrList, int ai, List<ScheduleRealInfo> schList, int si){
//			
//			int sLen = schList.size();
//			for(; si < sLen; si ++)
//				match(arrList, ai, schList.get(si));
//		}
//		
//		public void match(List<ArrivalEntity> arrList, int ai, ScheduleRealInfo sch){
//			//烂班不参与
//			if(sch.isDestroy())
//				return;
//			
//			int aLen = arrList.size();
//			
//			List<MatchResult> inRsList = new ArrayList<>()
//						,outRsList = new ArrayList<>();
//			
//			MatchResult mrs;
//			for(;ai < aLen; ai ++){
//				mrs = match(arrList.get(ai), sch);
//				if(!mrs.success)
//					continue;
//				
//				if(mrs.inOut == 0)
//					inRsList.add(mrs);
//				else if(mrs.inOut == 1)
//					outRsList.add(mrs);
//			}
//			
//			if(outRsList.size() > 0){
//				//排序后的第一个 就是最合适的匹配
//				Collections.sort(outRsList, new MatchResultComparator());
//				mrs = outRsList.get(0);
//				
//				mrs.sch.setFcsjActualAll(mrs.ts);
//				//通知客户端
//				sendUtils.sendFcsj(mrs.sch);
//				//持久化
//				dayOfSchedule.save(mrs.sch);
//			}
//			
//			if(inRsList.size() > 0){
//				//排序后的第一个 就是最合适的匹配
//				Collections.sort(inRsList, new MatchResultComparator());
//				mrs = inRsList.get(0);
//				
//				/*if(!dayOfSchedule.validEndTime(mrs.sch, mrs.ts)){
//					return;
//				}*/
//				
//				mrs.sch.setZdsjActualAll(mrs.ts);
//				int doneSum = dayOfSchedule.doneSum(mrs.sch.getClZbh());
//				ScheduleRealInfo next = dayOfSchedule.next(mrs.sch);
//				if(null != next){
//					next.setQdzArrDateSJ(mrs.sch.getZdsjActual());
//					//下发调度指令
//					directiveService.send60Dispatch(next, doneSum, "系统");
//				}
//				else{
//					//下发文本指令（已结束运营）
//					directiveService.send60Phrase(nbbm, "到达终点 " + mrs.sch.getZdzName() + "，已完成当日所有排班。", "系统");
//				}
//				//通知客户端
//				sendUtils.sendZdsj(mrs.sch, next, doneSum);
//				//持久化
//				dayOfSchedule.save(mrs.sch);
//			}
//		}
//		
//		public MatchResult match(ArrivalEntity arr, ScheduleRealInfo sch){
//			MatchResult mrs = new MatchResult();
//			mrs.inOut = arr.getInOut();
//			mrs.sch = sch;
//			mrs.ts = arr.getTs();
//			
//			if(Integer.parseInt(sch.getXlDir()) != arr.getUpDown()){
//				return mrs;
//			}
//			
//			if(arr.getInOut() == 1){
//				if(sch.getFcsjActual() == null
//						&& sch.getQdzCode().equals(arr.getStopNo())
//						&& dayOfSchedule.validStartTime(sch, arr.getTs())){
//					
//						mrs.diff = arr.getTs() - sch.getDfsjT();
//						if(Math.abs(mrs.diff) < MAX_RANGE)
//							mrs.success = true;
//				}
//			}
//			else if(arr.getInOut() == 0 && sch.getZdsj() != null){
//				if(sch.getZdsjActual() == null 
//						&& sch.getZdzCode().equals(arr.getStopNo())
//						&& dayOfSchedule.validEndTime(sch, arr.getTs())){
//						
//						mrs.diff = arr.getTs() - sch.getZdsjT();
//						if(Math.abs(mrs.diff) < MAX_RANGE)
//							mrs.success = true;
//				}
//			}
//			
//			return mrs;
//		}
//		
//		/**
//		 * 
//		 * @Title: lastMatchPoint 
//		 * @Description: TODO(最后一个已实发的班次索引) 
//		 */
//		public int lastMatchPoint(List<ScheduleRealInfo> schList){
//			int len = schList.size()
//						,rs = 0;
//			
//			ScheduleRealInfo sch;
//			for(int i = len - 2; i >= 0; i --){
//				sch = schList.get(i);
//				if(sch.getFcsjActual() != null){
//					rs = i;
//					if(sch.getStatus() == 2)
//						rs ++;
//					break;
//				}
//			}
//			return rs;
//		}
//		
//		public long lastMatchTime(ScheduleRealInfo sch){
//			Long t = 0L;
//			if(null != sch.getFcsjActualTime())
//				t = sch.getFcsjActualTime();
//			if(null != sch.getZdsjActualTime())
//				t = sch.getZdsjActualTime();
//			return t;
//		}
//		
//		/**
//		 * 
//		 * @Title: afterByTime 
//		 * @Description: TODO(参数时间戳之后的起始索引) 
//		 */
//		public int afterByTime(List<ArrivalEntity> arrList, long t){
//			int len = arrList.size()
//				,rs = len - 1;
//			
//			for(int i = 0; i < len; i ++){
//				if(arrList.get(i).getTs() > t){
//					rs = i;
//					break;
//				}
//			}
//			return rs;
//		}
//	}
//
//	@Override
//	public void setApplicationContext(ApplicationContext arg0) throws BeansException {
//		sendUtils = arg0.getBean(SendUtils.class);
//		dayOfSchedule = arg0.getBean(DayOfSchedule.class);
//		directiveService = arg0.getBean(DirectiveService.class);
//	}
//}