潘钊 / bsth_control · Files

package com.bsth.vehicle.gpsdata;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.Set;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.alibaba.fastjson.JSONObject;
import com.bsth.entity.realcontrol.ScheduleRealInfo;
import com.bsth.service.realcontrol.buffer.ScheduleBuffer;
import com.bsth.util.DateUtils;
import com.bsth.util.db.DBUtils_MS;
import com.bsth.vehicle.directive.service.DirectiveService;
import com.bsth.vehicle.gpsdata.buffer.ArrivalDataBuffer;
import com.bsth.vehicle.gpsdata.entity.ArrivalInfo;
import com.bsth.websocket.handler.RealControlSocketHandler;

/**
 * 
 * @ClassName: GpsArrivalStationThread 
 * @Description: TODO(GPS到离站) 
 * @author PanZhao
 * @date 2016年6月27日 上午10:58:13 
 *
 */	
@Component
public class GpsArrivalStationThread_old extends Thread{

	Logger logger = LoggerFactory.getLogger(this.getClass());
	SimpleDateFormat sdf = new SimpleDateFormat("HH:mm");
	
	@Autowired
	DirectiveService directiveService;
	
	@Autowired
	RealControlSocketHandler socketHandler;
	
	private static int diff = 1000 * 60 * 20;
	
	@Override
	public void run() {
		List<ArrivalInfo> list = null;
		try {
			list = loadData();
		} catch (ParseException e) {
			e.printStackTrace();
		}
		ArrivalDataBuffer.putAll(list);
		//实际到离站和计划排班相匹配
		
		Set<String> keySet = ArrivalDataBuffer.allMap.keySet();
		System.out.println("开始...");
		List<ScheduleRealInfo> schList;
		for(String key : keySet){
			schList = extractSched(ScheduleBuffer.carSchListMap.get(key));
			if(null != schList)
				match(ArrivalDataBuffer.allMap.get(key), schList);
		}
		System.out.println("结束...");
	}
	
	
	/**
	 * 
	 * @Title: match 
	 * @Description: TODO(实际和计划进行匹配) 
	 * @param @param arrList 实际GPS到离站链表
	 * @param @param schList 计划排班链表
	 * @throws
	 */
	public void match(List<ArrivalInfo> arrList, List<ScheduleRealInfo> schList){
		Iterator<ScheduleRealInfo> schIterator = schList.iterator();
		
		while(schIterator.hasNext())
			match(schIterator.next(), arrList);
	}
	
	
	public void match(ScheduleRealInfo scInfo, List<ArrivalInfo> arrList){
		for(ArrivalInfo arr : arrList){
			match(scInfo, arr);
		}
	}
	
	public void match(ScheduleRealInfo scInfo, ArrivalInfo arr){
		try{
			//匹配起点
			matchStart(scInfo, arr);
			
			//匹配终点
			matchEnd(scInfo, arr);
		}catch(Exception e){
			e.printStackTrace();
		}
	}
	
	/**
	 * 
	 * @Title: matchStart 
	 * @Description: TODO(匹配起点 出站时间) 
	 * @param @param scInfo
	 * @throws
	 */
	public void matchStart(ScheduleRealInfo scInfo, ArrivalInfo arr){
		if(scInfo.getFcsjT() == null
				|| arr.getInOut() != 1 || scInfo.getFcsjActual() != null)
			return;
		
		Long ts = arr.getTs();
		//起点站和发车时间比比较
		if(scInfo.getQdzCode().equals(arr.getStopNo())
				&& Math.abs(scInfo.getFcsjT() - ts) < diff){
			scInfo.setFcsjActualTime(ts);
			scInfo.setFcsjActual(sdf.format(ts));
			
			System.out.println("成功匹配一个起点...");
			//班次状态改为正在执行
			scInfo.setStatus(1);
			ScheduleBuffer.persistentList.add(scInfo);
			//推送到页面
			sendFcsj(scInfo);
		}
	}
	
	/**
	 * @Title: sendFcsj 
	 * @Description: TODO(推送发车信息) 
	 * @param @param schedule    班次
	 * @throws
	 */
	public void sendFcsj(ScheduleRealInfo schedule){
		JSONObject json = new JSONObject();
		json.put("fn", "faChe");
		json.put("t", schedule);
		json.put("dataStr", sdf.format(new Date()));
		socketHandler.sendMessageToLine(Integer.parseInt(schedule.getXlBm()), json.toJSONString());
	}
	
	/**
	 * 
	 * @Title: matchEnd 
	 * @Description: TODO(匹配终点 进站时间) 
	 * @throws
	 */
	public void matchEnd(ScheduleRealInfo scInfo, ArrivalInfo arr){
		if(scInfo.getZdsjT() == null
				|| arr.getInOut() != 0 || scInfo.getZdsjActual() != null)
			return;
		
		Long ts = arr.getTs();
		//终点站和发车时间比较
		if(scInfo.getZdzCode().equals(arr.getStopNo())
				&& Math.abs(scInfo.getZdsjT() - ts) < diff){
			scInfo.setZdsjActualTime(ts);
			scInfo.setZdsjActual(sdf.format(ts));
			
			System.out.println("成功匹配一个终点...");
			//完成当前班次
			ScheduleRealInfo nextSch = ScheduleBuffer.finishSch(scInfo);
			//到达终点，发送下一班次的调度指令
			int finish = ScheduleBuffer.getFinishSchNo(nextSch.getClZbh());
			directiveService.send60Dispatch(nextSch, finish);
			//推送到页面
			sendZdsj(scInfo, nextSch, finish);
		}
	}
	
	/**
	 * @Title: sendFcsj 
	 * @Description: TODO(推送到达终点时间) 
	 * @param @param schedule    班次
	 * @throws
	 */
	public void sendZdsj(ScheduleRealInfo schedule,ScheduleRealInfo nextSch, int finish){
		JSONObject json = new JSONObject();
		json.put("fn", "zhongDian");
		json.put("t", schedule);
		json.put("nt", nextSch);
		json.put("finish", finish);
		json.put("dataStr", sdf.format(new Date()));
		
		socketHandler.sendMessageToLine(Integer.parseInt(schedule.getXlBm()), json.toJSONString());
	}
	
	/**
	 * @throws ParseException 
	 * 
	 * @Title: loadData 
	 * @Description: TODO(从数据库加载到离站信息) 
	 * @return List<ArrivalInfo>    返回类型 
	 * @throws
	 */
	private List<ArrivalInfo> loadData() throws ParseException{
		Calendar cal = Calendar.getInstance();
		//周数，表分区字段
		int weeks_year = cal.get(Calendar.WEEK_OF_YEAR);
		//按时间标记增量加载
		if(null == ArrivalDataBuffer.markTime){
			//第一次从当天0点开始
			ArrivalDataBuffer.markTime = DateUtils.getTimesmorning() * 1000L;
		}
		
		String sql = "select * from bsth_c_arrival_info where weeks_year=? and create_date > ? order by ts";
		
		List<ArrivalInfo> list = new ArrayList<>();
		Connection conn = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		try {
			conn = DBUtils_MS.getConnection();
			ps = conn.prepareStatement(sql);
			ps.setInt(1, weeks_year);
			ps.setLong(2, ArrivalDataBuffer.markTime);
			
			Long t = System.currentTimeMillis();
			rs = ps.executeQuery();
			
			while(rs.next()){
				list.add(new ArrivalInfo(rs.getString("device_id"), rs.getLong("ts"), rs.getString("line_id")
						, rs.getInt("up_down"), rs.getString("stop_no"), rs.getInt("in_out"), rs.getLong("create_date"), rs.getInt("weeks_year")));
			}
			
			//重新打时间标记
			ArrivalDataBuffer.markTime = t;
			
		} catch (Exception e) {
			logger.error("", e);
		}finally {
			DBUtils_MS.close(rs, ps, conn);
		}
		return list;
	}
	
	Long rang = 1000 * 60 * 60L;
	/**
	 * 
	 * @Title: extractSched 
	 * @Description: TODO(提取当前时间前后一小时的计划) 
	 * @param @param allList
	 * @throws
	 */
	public List<ScheduleRealInfo> extractSched(List<ScheduleRealInfo> allList){
		List<ScheduleRealInfo> subList = new ArrayList<>();
		System.out.println("原计划：" + allList.size());
		Long t = System.currentTimeMillis();
		for(ScheduleRealInfo sch : allList){
			if(Math.abs(sch.getFcsjT() - t) < rang
					|| (sch.getZdsjT() != null && Math.abs(sch.getZdsjT()) - t < rang)){
				subList.add(sch);
			}
		}
		System.out.println("按时间提取：" + subList.size());
		return subList;
	}
}