潘钊 / bsth_control · Files

package com.bsth.service.impl;

import com.bsth.data.BasicData;
import com.bsth.entity.*;
import com.bsth.entity.realcontrol.ChildTaskPlan;
import com.bsth.entity.realcontrol.ScheduleRealInfo;
import com.bsth.entity.schedule.SchedulePlanInfo;
import com.bsth.entity.schedule.TTInfo;
import com.bsth.entity.schedule.TTInfoDetail;
import com.bsth.entity.search.CustomerSpecs;
import com.bsth.repository.*;
import com.bsth.repository.realcontrol.ScheduleRealInfoRepository;
import com.bsth.repository.schedule.*;
import com.bsth.service.TrafficManageService;
import com.bsth.util.TimeUtils;
import com.bsth.util.db.DBUtils_MS;
import com.bsth.webService.trafficManage.geotool.services.InternalPortType;
import com.bsth.webService.trafficManage.org.tempuri.WebServiceLocator;
import com.bsth.webService.trafficManage.org.tempuri.WebServiceSoap;
import org.apache.commons.lang.time.DateUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Direction;
import org.springframework.stereotype.Service;

import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.regex.Pattern;

/**
 *
 * @ClassName: TrafficManageServiceImpl(运管处接口service业务层实现类)
 *
 * @Extends : BaseService
 *
 * @Description: TODO(运管处接口service业务层)
 *
 * @Author bsth@zq
 *
 * @Date 2016年10月28日 上午9:21:17
 *
 * @Version 公交调度系统BS版 0.1
 *
 */

@Service
public class TrafficManageServiceImpl  implements TrafficManageService{

	Logger logger = LoggerFactory.getLogger(this.getClass());

	// 线路repository
	@Autowired
	private LineRepository lineRepository;

	// 站点路由repository
	@Autowired
	private StationRouteRepository stationRouteRepository;

	// 线路标准信息repository
	@Autowired
	private LineInformationRepository lineInformationRepository;

	// 车辆repository
	@Autowired
	private CarsRepository carsRepository;

	// 人员repository
	@Autowired
	private PersonnelRepository personnelRepository;

	// 时刻模板repository
	@Autowired
	private TTInfoRepository ttInfoRepository;

	// 时刻模板明细repository
	@Autowired
	private TTInfoDetailRepository ttInfoDetailRepository;

	// 车辆配置信息repository
	@Autowired
	private CarConfigInfoRepository carConfigInfoRepository;

	// 人员配置信息repository
	@Autowired
	private EmployeeConfigInfoRepository employeeConfigInfoRepository;

	// 排班计划明细repository
	@Autowired
	private SchedulePlanInfoRepository schedulePlanInfoRepository;

	// 实际排班计划明细repository
	@Autowired
	private ScheduleRealInfoRepository scheduleRealInfoRepository;


	// 运管处接口
	private InternalPortType portType = null;//new Internal().getInternalHttpSoap11Endpoint();
	private WebServiceSoap ssop ;
	{
		try {
			ssop = new WebServiceLocator().getWebServiceSoap();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	// 格式化 年月日时分秒 nyrsfm是年月日时分秒的拼音首字母
	private SimpleDateFormat sdfnyrsfm = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

	// 格式化  年月日
	private SimpleDateFormat sdfnyr = new SimpleDateFormat("yyyy-MM-dd");

	// 数字格式化
	DecimalFormat format = new DecimalFormat("0.00");

	// 用户名
	private final String userNameXl = "pudong";
	// 密码
	private final String passwordXl = "pudong123";

	// 用户名
	private final String userNameOther = "user";
	// 密码
	private final String passwordOther = "user";
	/**
	 * 上传线路信息
	 */
	@Override
	public String setXL() {
		String result = "failure";
		StringBuffer sBuffer = new StringBuffer();
		try {
			Iterator<Line> lineIterator = lineRepository.findAll().iterator();
			Line line = null;
			List<StationRoute> stationsList = null;// 站点路由集
			List<LineInformation> lineInformationsList = null;
			LineInformation lineInformation = null;
			sBuffer.append("<XLs>");
			while(lineIterator.hasNext()){
				line = lineIterator.next();
				if(BasicData.lineId2ShangHaiCodeMap.get(line.getId()) == null
						|| line.getInUse() == 0){
					continue;
				}
				sBuffer.append("<XL>");
				sBuffer.append("<XLBM>").append(BasicData.lineId2ShangHaiCodeMap.get(line.getId())).append("</XLBM>");
				sBuffer.append("<XLMC>").append(line.getName()).append("</XLMC>");
				sBuffer.append("<QDZ>").append(line.getStartStationName()).append("</QDZ>");
				sBuffer.append("<ZDZ>").append(line.getEndStationName()).append("</ZDZ>");
				// 线路标准信息实体
				lineInformationsList = lineInformationRepository.findByLine(line);
				int size = lineInformationsList.size();
				if(lineInformationsList != null && size > 0){
					double upMileage = 0.0; // 上行里程
					double downMileage = 0.0; // 下行里程
					// 如果线路标准有多个，累加上行里程和下行里程
					for (int i = 0; i < size; i++) {
						lineInformation = lineInformationsList.get(i);
						upMileage +=lineInformation.getUpMileage();
						downMileage +=lineInformation.getDownMileage();
					}
					sBuffer.append("<QZLC>").append(upMileage).append("</QZLC>");
					sBuffer.append("<ZQLC>").append(downMileage).append("</ZQLC>");
				}
				sBuffer.append("<XLGH>").append(line.getLinePlayType() == null ?"0":line.getLinePlayType())
						.append("</XLGH>");
				// 循环添加站点信息
				sBuffer.append("<StationList>");
				// 先查上行
				stationsList = stationRouteRepository.findByLine(line.getLineCode(), 0);
				int startId = 1;
				startId = packagStationXml(stationsList, sBuffer, startId);
				// 再查下行
				stationsList = stationRouteRepository.findByLine(line.getLineCode(), 1);
				packagStationXml(stationsList, sBuffer, startId);
				sBuffer.append("</StationList>");
				sBuffer.append("</XL>");
			}
			sBuffer.append("</XLs>");
			System.out.println(sBuffer.toString());
			if(sBuffer.indexOf("<XL>") != -1){
				String portResult = portType.setXL(userNameXl, passwordXl, sBuffer.toString());
				String portArray[] = portResult.split("\n");
				if(portArray.length >= 4){
					// 返回数据的编码
					String returnCode = portArray[1].substring(portArray[1].indexOf(">")+1,portArray[1].indexOf("</"));
					// 返回的信息
					String returnDescription = portArray[2].substring(portArray[2].indexOf(">")+1,portArray[2].indexOf("</"));
					if(returnCode.equals("1")){
						result = "success";
					}else{
						result = returnDescription;
					}
				}
			}
		} catch (Exception e) {
			logger.error("setXL:",e);
			e.printStackTrace();
		}finally{
			logger.info("setXL:"+sBuffer.toString());
			logger.info("setXL:"+result);
		}
		return result;
	}

	/**
	 * 上传车辆信息
	 */
	@Override
	public String setCL() {
		String result = "failure";
		StringBuffer sBuffer =new StringBuffer();
		try {
			sBuffer.append("<CLs>");
			Cars cars = null;
			String company;
			Iterator<Cars> carsIterator = carsRepository.findAll().iterator();
			while(carsIterator.hasNext()){
				cars = carsIterator.next();
				sBuffer.append("<CL>");
				company = cars.getCompany();
				setCompanyName(company);// 统一公司名称
				sBuffer.append("<GSJC>").append(company).append("</GSJC>");
				sBuffer.append("<NBH>").append(cars.getInsideCode()).append("</NBH>");
				sBuffer.append("<CPH>").append(cars.getCarPlate()).append("</CPH>");
				sBuffer.append("<YYZBH>").append(cars.getServiceNo()).append("</YYZBH>");
				sBuffer.append("<CZCPH>").append(cars.getCarPlate()).append("</CZCPH>");//******这个数据没有***********
				sBuffer.append("<CZZDBH>").append(cars.getEquipmentCode()).append("</CZZDBH>");
				sBuffer.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
				sBuffer.append("</CL>");
			}
			sBuffer.append("</CLs>");
			if(ssop.setCL(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
				result = "success";
			}
		} catch (Exception e) {
			logger.error("setCL:",e);
			e.printStackTrace();
		}finally{
			logger.info("setCL:"+sBuffer.toString());
			logger.info("setCL:"+result);
		}
		return result;
	}

	/**
	 * 上传司机信息
	 */
	@Override
	public String setSJ() {
		String result = "failure";
		StringBuffer sBuffer =new StringBuffer();
		try {
			sBuffer.append("<SJs>");
			Personnel personnel = null;
			String company;
			Iterator<Personnel> personIterator = personnelRepository.findAll().iterator();
			while(personIterator.hasNext()){
				personnel = personIterator.next();
				sBuffer.append("<SJ>");
				company = personnel.getCompany();
				setCompanyName(company);// 统一公司名称
				sBuffer.append("<GSJC>").append(company).append("</GSJC>");
				sBuffer.append("<SJGH>").append(personnel.getJobCode()).append("</SJGH>");
				sBuffer.append("<CYZGZH>").append(personnel.getPapersCode()).append("</CYZGZH>");//***********
				sBuffer.append("<XM>").append(personnel.getPersonnelName()).append("</XM>");
				sBuffer.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
				sBuffer.append("</SJ>");
			}
			sBuffer.append("</SJs>");
			if(ssop.setSJ(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
				result = "success";
			};
		} catch (Exception e) {
			logger.error("setSJ:",e);
			e.printStackTrace();
		}finally{
			logger.info("setSJ:"+sBuffer.toString());
			logger.info("setSJ:"+result);
		}
		return result;
	}

	/**
	 * 上传路单
	 * @return 上传成功标识
	 */
	public String setLD(){
		String result = "failure";
		Line line;
		// 取昨天 的日期
		String date = sdfnyr.format(DateUtils.addDays(new Date(), -1));
		StringBuffer sf = new StringBuffer();
		try {
			sf.append("<DLDS>");
			List<ScheduleRealInfo> list = scheduleRealInfoRepository.setLD(date);
			List<Map<String,Object>> listGroup = scheduleRealInfoRepository.setLDGroup(date);
			Map<String,Object> map = new HashMap<String,Object>();
			for(Map<String,Object> schRealInfo:listGroup){
				if(schRealInfo != null){
					//根据车辆自编号查询车牌号
					map.put("insideCode_eq", schRealInfo.get("clZbh")+"");
					Cars car = carsRepository.findOne(new CustomerSpecs<Cars>(map));
					// 获取线路是否使用标识，如果未使用，则不查该线路数据
					line = lineRepository.findByLineCode(schRealInfo.get("xlBm")+"");
					if(line.getInUse() == null || line.getInUse() == 0){
						continue;
					}
					sf.append("<DLD>");
					sf.append("<RQ>"+date+"</RQ>");
					sf.append("<XLBM>"+BasicData.lineCode2ShangHaiCodeMap.get(schRealInfo.get("xlBm")+"")+"</XLBM>");
					sf.append("<LPBH>"+schRealInfo.get("lpName")+"</LPBH>");
					sf.append("<CPH>"+car.getCarPlate()+"</CPH>");
					sf.append("<UPDT>"+sdfnyrsfm.format(new Date())+"</UPDT>");
					sf.append("<LDList>");

					int seqNumber = 0;
					for(ScheduleRealInfo scheduleRealInfo:list){
						if((schRealInfo.get("xlBm")+"").equals(scheduleRealInfo.getXlBm()) && (schRealInfo.get("lpName")+"")
								.equals(scheduleRealInfo.getLpName())
								&& (schRealInfo.get("clZbh")+"").equals(scheduleRealInfo.getClZbh())){
							if(scheduleRealInfo.getFcsjActual() == null ||scheduleRealInfo.getBcType().equals("in")
									|| scheduleRealInfo.getBcType().equals("out")){
								continue;
							}
							scheduleRealInfo.getQdzCode();
							sf.append("<LD>");
							sf.append("<SJGH>"+scheduleRealInfo.getjGh()+"</SJGH>");
							sf.append("<SXX>"+scheduleRealInfo.getXlDir()+"</SXX>");
							sf.append("<FCZDMC>"+scheduleRealInfo.getQdzName()+"</FCZDMC>");
							sf.append("<FCZDXH>" + getYgcStationNumByLineCodeAndDirectionAndStationName(
									scheduleRealInfo.getXlBm(), scheduleRealInfo.getXlDir(), scheduleRealInfo.getQdzName()) + "</FCZDXH>");
							sf.append("<FCZDBM>"+scheduleRealInfo.getQdzCode()+"</FCZDBM>");
							sf.append("<JHFCSJ>"+scheduleRealInfo.getFcsj()+"</JHFCSJ>");
							sf.append("<DFSJ>"+scheduleRealInfo.getDfsj()+"</DFSJ>");
							sf.append("<SJFCSJ>"+scheduleRealInfo.getFcsjActual()+"</SJFCSJ>");
							sf.append("<FCZDLX>"+""+"</FCZDLX>");
							sf.append("<DDZDMC>"+scheduleRealInfo.getZdzName()+"</DDZDMC>");
							sf.append("<DDZDXH>"+ getYgcStationNumByLineCodeAndDirectionAndStationName(
									scheduleRealInfo.getXlBm(), scheduleRealInfo.getXlDir(), scheduleRealInfo.getZdzName()) +"</DDZDXH>");
							sf.append("<DDZDBM>"+scheduleRealInfo.getZdzCode()+"</DDZDBM>");
							sf.append("<JHDDSJ>"+scheduleRealInfo.getZdsj()+"</JHDDSJ>");
							sf.append("<SJDDSJ>"+scheduleRealInfo.getZdsjActual()+"</SJDDSJ>");
							sf.append("<DDZDLX>"+""+"</DDZDLX>");
							sf.append("<LDSCBZ>"+0+"</LDSCBZ>");
							sf.append("<DDBZ>"+scheduleRealInfo.getRemarks()+"</DDBZ>");
							sf.append("</LD>");
						}
					}
					sf.append("</LDList>");
					sf.append("</DLD>");
				}
			}
			sf.append("</DLDS>");
			if(ssop.setLD(userNameOther, passwordOther, sf.toString()).isSuccess()){
				result = "success";
			}
		} catch (Exception e) {
			logger.error("setLD:",e);
			e.printStackTrace();
		}finally{
			logger.info("setLD:"+sf.toString());
			logger.info("setLD:"+result);
		}
		return result;
	}

	/**
	 * 上传里程油耗
	 * @return 上传成功标识
	 */
	public String setLCYH(){
		String result = "failure";
		// 取昨天 的日期
		String date = sdfnyr.format(DateUtils.addDays(new Date(), -1));
		StringBuffer sf = new StringBuffer();
		try {
			sf.append("<LCYHS>");
			List<Map<String,Object>> listGroup = scheduleRealInfoRepository.setLCYHGroup(date);
			List<ScheduleRealInfo> list = scheduleRealInfoRepository.findByDate(date);
			Map<String,Object> map = new HashMap<String,Object>();
			for(Map<String,Object> schRealInfo:listGroup){
				if(schRealInfo != null){
					map.put("insideCode_eq", schRealInfo.get("clZbh")+"");
					Cars car = carsRepository.findOne(new CustomerSpecs<Cars>(map));
					/**
					 * 如果car==null，则说明该车辆是从线调中换车功能中加进去的，
					 * 在cars基础信息中查不到车辆的信息，所以忽略该车辆
 					 */
					if(car == null){
						continue;
					}
					//计算总公里和空驶公里，营运公里=总公里-空驶公里
					double totalKilometers = 0,emptyKilometers =0;
					sf.append("<LCYH>");
					sf.append("<RQ>"+date+"</RQ>");
					sf.append("<XLBM>"+BasicData.lineCode2ShangHaiCodeMap.get(schRealInfo.get("xlBm"))+"</XLBM>");
					sf.append("<CPH>"+car.getCarPlate()+"</CPH>");
					if(list != null && list.size() > 0){
						for(ScheduleRealInfo scheduleRealInfo:list){
							if((schRealInfo.get("xlBm")+"").equals(scheduleRealInfo.getXlBm()) && (schRealInfo.get("clZbh")+"")
									.equals(scheduleRealInfo.getClZbh())){
								Set<ChildTaskPlan> childTaskPlans = scheduleRealInfo.getcTasks();
								//如果没有子任务，里程就是已执行（Status=2）;有子任务的，忽略主任务，子任务的烂班
								if(childTaskPlans.isEmpty()){
									if(scheduleRealInfo.getStatus() == 2){
										totalKilometers += scheduleRealInfo.getJhlc()==null?0.0:scheduleRealInfo.getJhlc();
										if(scheduleRealInfo.getBcType().equals("in") || scheduleRealInfo.getBcType().equals("out")
												|| scheduleRealInfo.getBcType().equals("venting")){
											emptyKilometers += scheduleRealInfo.getJhlc()==null?0.0:scheduleRealInfo.getJhlc();
										}
									}
								}else{
									Iterator<ChildTaskPlan> it = childTaskPlans.iterator();
									while(it.hasNext()){
										ChildTaskPlan childTaskPlan = it.next();
										if(!childTaskPlan.isDestroy()){
											totalKilometers += childTaskPlan.getMileage()==null?0.0:childTaskPlan.getMileage();
											if(childTaskPlan.getMileageType().equals("empty")){
												emptyKilometers += childTaskPlan.getMileage()==null?0.0:childTaskPlan.getMileage();;
											}
										}
									}
								}
							}
						}
					}
					sf.append("<ZLC>"+totalKilometers+"</ZLC>");
					sf.append("<YYLC>"+emptyKilometers+"</YYLC>");
					sf.append("<YH>"+""+"</YH>");
					sf.append("<JZYL>"+""+"</JZYL>");
					sf.append("<DH>"+""+"</DH>");
					sf.append("<UPDT>"+sdfnyrsfm.format(new Date())+"</UPDT>");
					sf.append("<BBSCBZ>"+0+"</BBSCBZ>");
					sf.append("</LCYH>");
				}
			}
			sf.append("</LCYHS>");
			if(ssop.setLCYH(userNameOther, passwordOther, sf.toString()).isSuccess()){
				result = "success";
			}
		} catch (Exception e) {
			logger.error("setLCYH:",e);
			e.printStackTrace();
		}finally{
			logger.info("setLCYH:"+sf.toString());
			logger.info("setLCYH:"+result);
		}
		return result;
	}

	/**
	 * 上传线路调度日报
	 * @return
	 */
	public String setDDRB(){
		String result = "failure";
		// 取昨天 的日期
		String date = sdfnyr.format(DateUtils.addDays(new Date(), -1));
		StringBuffer sf = new StringBuffer();
		try {
			sf.append("<DDRBS>");
			List<Map<String,Object>> listGroup = scheduleRealInfoRepository.setDDRBGroup(date);
			List<ScheduleRealInfo> list = scheduleRealInfoRepository.findByDate(date);
			for(Map<String,Object> schRealInfo:listGroup){
				if(schRealInfo != null){
					double jhlc = 0,zlc = 0,jhkslc = 0,sjkslc = 0;
					int jhbc = 0,sjbc = 0,jhzgfbc = 0,sjzgfbc = 0,jhwgfbc = 0,sjwgfbc = 0;
					sf.append("<DDRB>");
					sf.append("<RQ>"+date+"</RQ>");
					sf.append("<XLBM>"+BasicData.lineCode2ShangHaiCodeMap.get(schRealInfo.get("xlBm"))+"</XLBM>");
					for(ScheduleRealInfo scheduleRealInfo:list){
						if(scheduleRealInfo != null){
							if((schRealInfo.get("xlBm")+"").equals(scheduleRealInfo.getXlBm())){
								//计划
								if(!scheduleRealInfo.isSflj()){
									jhlc += scheduleRealInfo.getJhlc()==null?0.0:scheduleRealInfo.getJhlc();
									//计划空驶
									if(scheduleRealInfo.getBcType().equals("in") || scheduleRealInfo.getBcType().equals("out")){
										jhkslc += scheduleRealInfo.getJhlc()==null?0.0:scheduleRealInfo.getJhlc();
									}
									//计划早高峰,计划晚高峰
									if(TimeUtils.morningPeak(scheduleRealInfo.getFcsj())){
										jhzgfbc++;
									} else if(TimeUtils.evenignPeak(scheduleRealInfo.getFcsj())){
										jhwgfbc++;
									}
								}
								jhbc++;

								//实际
								Set<ChildTaskPlan> childTaskPlans = scheduleRealInfo.getcTasks();
								//如果没有子任务，里程就是已执行（Status=2）;有子任务的，忽略主任务，子任务的烂班
								if(childTaskPlans.isEmpty()){
									if(scheduleRealInfo.getStatus() == 2){
										sjbc++;
										zlc += scheduleRealInfo.getJhlc()==null?0.0:scheduleRealInfo.getJhlc();
										if(scheduleRealInfo.getBcType().equals("in") || scheduleRealInfo.getBcType().equals("out")
												|| scheduleRealInfo.getBcType().equals("venting")){
											sjkslc += scheduleRealInfo.getJhlc()==null?0.0:scheduleRealInfo.getJhlc();;
										}
									}
								}else{
									sjbc++;
									Iterator<ChildTaskPlan> it = childTaskPlans.iterator();
									while(it.hasNext()){
										ChildTaskPlan childTaskPlan = it.next();
										if(!childTaskPlan.isDestroy()){
											zlc += childTaskPlan.getMileage()==null?0.0:childTaskPlan.getMileage();
											if(childTaskPlan.getMileageType().equals("empty")){
												sjkslc += childTaskPlan.getMileage()==null?0.0:childTaskPlan.getMileage();;
											}
										}
									}
								}
								//实际早高峰,计划晚高峰
								if(scheduleRealInfo.getFcsjActual() != null){
									if(TimeUtils.morningPeak(scheduleRealInfo.getFcsj())){
										sjzgfbc++;
									} else if(TimeUtils.evenignPeak(scheduleRealInfo.getFcsj())){
										sjwgfbc++;
									}
								}
							}
						}
					}
					sf.append("<JHLC>"+format.format(jhlc)+"</JHLC>");
					sf.append("<SSLC>"+format.format((zlc-sjkslc))+"</SSLC>");
					sf.append("<JHKSLC>"+format.format(jhkslc)+"</JHKSLC>");
					sf.append("<SJKSLC>"+format.format(sjkslc)+"</SJKSLC>");
					sf.append("<JHBC>"+jhbc+"</JHBC>");
					sf.append("<SJBC>"+sjbc+"</SJBC>");
					sf.append("<JHZGFBC>"+jhzgfbc+"</JHZGFBC>");
					sf.append("<SJZGFBC>"+sjzgfbc+"</SJZGFBC>");
					sf.append("<JHWGFBC>"+jhwgfbc+"</JHWGFBC>");
					sf.append("<SJWGFBC>"+sjwgfbc+"</SJWGFBC>");
					sf.append("<UPDT>"+sdfnyrsfm.format(new Date())+"</UPDT>");
					sf.append("<RBSCBZ>"+0+"</RBSCBZ>");
					sf.append("</DDRB>");
				}
			}
			sf.append("</DDRBS>");
			if(ssop.setDDRB(userNameOther, passwordOther, sf.toString()).isSuccess()){
				result = "success";
			}
		} catch (Exception e) {
			logger.error("setDDRB:",e);
			e.printStackTrace();
		}finally{
			logger.info("setDDRB:"+sf.toString());
			logger.info("setDDRB:"+result);
		}
		return result;
	}

	/**
	 * 上传线路计划班次表
	 */
	@Override
	public String setJHBC() {
		String result = "failure";
		Line line;
		StringBuffer sBuffer =new StringBuffer();
		try {
			sBuffer.append("<JHBCs>");
			// 声明变量
			SchedulePlanInfo schedulePlanInfo;
			String xlbm,zbh = "";
			Long lp = 0L;
			// 取明天的日期
			String tomorrow = sdfnyr.format(DateUtils.addDays(new Date(), +1));
			// 查询所有班次
			List<SchedulePlanInfo> schedulePlanList = schedulePlanInfoRepository.findLineScheduleBc(tomorrow);
			int j = 0; // 初始化标识
			if(schedulePlanList != null ){
				int size = schedulePlanList.size();
				for (int i = 0; i < size; i++) {
					schedulePlanInfo = schedulePlanList.get(i);
					xlbm = schedulePlanInfo.getXlBm();
					// 获取线路是否使用标识，如果未使用，则不查该线路数据
					line = lineRepository.findByLineCode(xlbm);
					if(line.getInUse() == null || line.getInUse() == 0){
						continue;
					}
					if(++j == 1){// 第一次，则初始化值
						zbh = schedulePlanInfo.getClZbh();
						lp = schedulePlanInfo.getLp();
						// 拼装XML
						assembleJHBC(sBuffer, schedulePlanInfo, xlbm, zbh, lp);
					}
					// 比较是否为同一条线路同一辆车
					if(xlbm.equals(schedulePlanInfo.getXlBm())
							&& zbh.equals(schedulePlanInfo.getClZbh())
							&& lp == schedulePlanInfo.getLp()){
						if(schedulePlanInfo.getBcType().equals("in") || schedulePlanInfo.getBcType().equals("out")){
							continue;
						}
						sBuffer.append("<BC>");
						sBuffer.append("<SJGH>").append(schedulePlanInfo.getjGh()).append("</SJGH>");
						sBuffer.append("<SXX>").append(schedulePlanInfo.getXlDir()).append("</SXX>");
						sBuffer.append("<FCZDMC>").append(schedulePlanInfo.getQdzName()).append("</FCZDMC>");
						sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
								schedulePlanInfo.getXlBm(), schedulePlanInfo.getXlDir(), schedulePlanInfo.getQdzName())).append("</ZDXH>");
						sBuffer.append("<JHFCSJ>").append(schedulePlanInfo.getFcsj()).append("</JHFCSJ>");
						sBuffer.append("<DDZDMC>").append(schedulePlanInfo.getZdzName()).append("</DDZDMC>");
						sBuffer.append("<DDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
								schedulePlanInfo.getXlBm(), schedulePlanInfo.getXlDir(), schedulePlanInfo.getZdzName())).append("</DDXH>");
						sBuffer.append("<JHDDSJ>").append(calcDdsj(schedulePlanInfo.getFcsj(),schedulePlanInfo.getBcsj()))
								.append("</JHDDSJ>");
						sBuffer.append("</BC>");
						if(i == size -1 ){
							sBuffer.append("</BCList>");
							sBuffer.append("</JHBC>");
						}
					}else{
						zbh = schedulePlanInfo.getClZbh();
						lp = schedulePlanInfo.getLp();
						sBuffer.append("</BCList>");
						sBuffer.append("</JHBC>");
						// 拼装XML
						assembleJHBC(sBuffer, schedulePlanInfo, xlbm, zbh, lp);
					}
				}
			}
			// 判断XML是否以</BCList>结尾，如果不是，则加上
			String regex = "^*</JHBC>$";
			Pattern p = Pattern.compile(regex);
			java.util.regex.Matcher m = p.matcher(sBuffer);
			boolean isEndWithTrueFlag = false;
			while (m.find()) {
				isEndWithTrueFlag = true;
			}
			// 加上缺失的标签
			if(!isEndWithTrueFlag){
				sBuffer.append("</BCList>");
				sBuffer.append("</JHBC>");
			}
			sBuffer.append("</JHBCs>");
			if(ssop.setJHBC(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
				result = "success";
			}
		} catch (Exception e) {
			logger.error("setJHBC:",e);
			e.printStackTrace();
		}finally{
			logger.info("setJHBC:"+sBuffer.toString());
			logger.info("setJHBC:"+result);
		}
		return result;
	}

	/**
	 * 上传线路班次时刻表数据
	 */
	@Override
	public String setSKB(String ids) {
		String result = "failure";
		StringBuffer sBuffer = new StringBuffer();
		try {
			String[] idArray = ids.split(",");
			StringBuffer sBufferA;
			StringBuffer sBufferB;
			TTInfo ttInfo;
			TTInfoDetail ttInfoDetail;
			Iterator<TTInfoDetail> ttInfoDetailIterator;
			HashMap<String,Object> param = new HashMap<String, Object>();
			String lineCode ;
			sBuffer.append("<SKBs>");
			for (int i = 0; i < idArray.length; i++) {
				ttInfo = ttInfoRepository.findOne(Long.valueOf(idArray[i]));
				if(ttInfo == null)
					continue;
				param.put("ttinfo.id_eq", ttInfo.getId());
				ttInfoDetailIterator = ttInfoDetailRepository.findAll(new CustomerSpecs<TTInfoDetail>(param),
						new Sort(Direction.ASC, "xlDir")).iterator();
				if(ttInfoDetailIterator.hasNext()){
					sBuffer.append("<SKB>");
					sBuffer.append("<XLBM>").append(BasicData.lineId2ShangHaiCodeMap.get(ttInfo.getXl().getId()))
							.append("</XLBM>");
					sBufferB = new StringBuffer();
					sBufferB.append("<KSRQ>").append(sdfnyr.format(ttInfo.getQyrq())).append("</KSRQ>");
					// 结束日期暂时不要，节假日的班次表才需要，如春节的班次表
					sBufferB.append("<JSRQ>").append("").append("</JSRQ>");
					sBufferB.append("<ZJZX>").append(changeRuleDay(ttInfo.getRule_days())).append("</ZJZX>");
					sBufferB.append("<TBYY>").append("").append("</TBYY>");
					sBufferB.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
					sBufferB.append("<BCList>");
					int num = 1;
					while (ttInfoDetailIterator.hasNext()) {
						ttInfoDetail = ttInfoDetailIterator.next();
						if(ttInfoDetail.getBcType().equals("in") || ttInfoDetail.getBcType().equals("out")){
							continue;
						}
						if(num++ == 1){
							sBufferA = new StringBuffer();
							sBufferA.append("<JHZLC>").append(ttInfoDetail.getJhlc()).append("</JHZLC>");
							sBufferA.append("<JHYYLC>").append(ttInfoDetail.getJhlc()).append("</JHYYLC>");
							sBuffer.append(sBufferA).append(sBufferB);
						}
						lineCode = ttInfoDetail.getXl().getLineCode();
						// 如果发车时间格式错误，忽略此条
						if(changeTimeFormat(ttInfoDetail) == null){
							continue;
						}
						sBuffer.append("<BC>");
						sBuffer.append("<LPBH>").append(ttInfoDetail.getLp().getLpNo()).append("</LPBH>");
						sBuffer.append("<SXX>").append(ttInfoDetail.getXlDir()).append("</SXX>");
						sBuffer.append("<FCZDMC>").append(ttInfoDetail.getQdz().getStationName()).append("</FCZDMC>");
						sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
								lineCode, ttInfoDetail.getXlDir(), ttInfoDetail.getQdz().getStationName())).append("</ZDXH>");
						sBuffer.append("<JHFCSJ>").append(changeTimeFormat(ttInfoDetail)).append("</JHFCSJ>");
						sBuffer.append("<DDZDMC>").append(ttInfoDetail.getZdz().getStationName()).append("</DDZDMC>");
						sBuffer.append("<DDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
								lineCode, ttInfoDetail.getXlDir(), ttInfoDetail.getZdz().getStationName())).append("</DDXH>");
						sBuffer.append("<JHDDSJ>").append(calcDdsj(ttInfoDetail.getFcsj(),ttInfoDetail.getBcsj())).append("</JHDDSJ>");
						sBuffer.append("</BC>");
					}
					sBuffer.append("</BCList>");
					sBuffer.append("</SKB>");
				}
			}
			sBuffer.append("</SKBs>");
			if(ssop.setSKB(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
				result = "success";
			}
		} catch (Exception e) {
			logger.error("setSKB:", e);
			e.printStackTrace();
		}finally{
			logger.info("setSKB:"+sBuffer.toString());
			logger.info("setSKB:"+result);
		}
		return result;
	}

	/**
	 * 上传线路人员车辆配置信息
	 */
	@Override
	public String setXLPC() {
		String result = "failure";
		StringBuffer sBuffer =new StringBuffer();
		try {
			sBuffer.append("<XLPCs>");
			// 声明变量
			Line line = null;
			Cars cars = null;
			List<Personnel> personnelList = null;
			List<Cars> carsList = null;
			int totalPersonnel,totalCar ;// 人员数量。车辆数量
			// 查询所有线路
			Iterator<Line> lineIterator = lineRepository.findAll().iterator();
			// 循环查找线路下的信息
			while(lineIterator.hasNext()){
				line = lineIterator.next();
				sBuffer.append("<XLPC>");
				sBuffer.append("<XLBM>").append(BasicData.lineId2ShangHaiCodeMap.get(line.getId())).append("</XLBM>");
				// 查询驾驶员数量
				personnelList = personnelRepository.findJsysByLineId(line.getId());
				totalPersonnel = personnelList != null ? personnelList.size():0;
				sBuffer.append("<SJRS>").append(totalPersonnel).append("</SJRS>");
				// 查询售票员人员数量
				personnelList = personnelRepository.findSpysByLineId(line.getId());
				totalPersonnel = personnelList != null ? personnelList.size():0;
				sBuffer.append("<SPYRS>").append(totalPersonnel).append("</SPYRS>");
				// 查询车辆
				carsList = carsRepository.findCarsByLineId(line.getId());
				totalCar = carsList != null ? carsList.size():0;
				sBuffer.append("<PCSL>").append(totalCar).append("</PCSL>");
				sBuffer.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
				int carsNum = 0;
				// 取车牌号
				if(carsList != null){
					carsNum = carsList.size();
					sBuffer.append("<CPHList>");
					for (int i = 0; i < carsNum; i++) {
						cars = carsList.get(i);
						sBuffer.append("<CPH>").append("沪").append(cars.getCarCode()).append("</CPH>");
					}
					sBuffer.append("</CPHList>");
				}
				sBuffer.append("</XLPC>");
			}
			sBuffer.append("</XLPCs>");
			if(ssop.setXLPC(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
				result = "success";
			}
		} catch (Exception e) {
			logger.error("setXLPC:",e);
			e.printStackTrace();
		}finally{
			logger.info("setXLPC:"+sBuffer.toString());
			logger.info("setXLPC:"+result);
		}
		return result;
	}


	/**
	 * 上传超速数据
	 */
	@Override
	public String setCS() {
		String result = "failure";
		StringBuffer sBuffer =new StringBuffer();
		sBuffer.append("<CSs>");
		String sql = "SELECT * FROM bsth_c_speeding where DATE_FORMAT(create_date,'%Y-%m-%d') = ? order by create_date ";
		Connection conn = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		// 取昨天 的日期
		String yesterday = sdfnyr.format(DateUtils.addDays(new Date(), -1));
		try {
			conn = DBUtils_MS.getConnection();
			ps = conn.prepareStatement(sql);
			ps.setString(1, yesterday);
			rs = ps.executeQuery();
			Float lon, lat;
			String kssk;
			String speed;
			while (rs.next()) {
				kssk = sdfnyrsfm.format(rs.getLong("TIMESTAMP"));
				speed = rs.getString("SPEED");
				// 经纬度
				lon = rs.getFloat("LON");
				lat = rs.getFloat("LAT");
				sBuffer.append("<CS>");
				sBuffer.append("<RQ>").append(sdfnyr.format(rs.getDate("CREATE_DATE"))).append("</RQ>");
				sBuffer.append("<XLBM>").append(BasicData.lineCode2ShangHaiCodeMap.get(rs.getString("LINE"))).append("</XLBM>");////////
				sBuffer.append("<CPH>").append(rs.getString("VEHICLE")).append("</CPH>");
				sBuffer.append("<KSSK>").append(kssk).append("</KSSK>");
				sBuffer.append("<KSDDJD>").append(lon).append("</KSDDJD>");
				sBuffer.append("<KSDDWD>").append(lat).append("</KSDDWD>");
				sBuffer.append("<KSLD>").append("").append("</KSLD>");//**********************
				sBuffer.append("<JSSK>").append(kssk).append("</JSSK>");
				sBuffer.append("<JSDDJD>").append(lon).append("</JSDDJD>");
				sBuffer.append("<JSDDWD>").append(lat).append("</JSDDWD>");
				sBuffer.append("<JSLD>").append("").append("</JSLD>");//**********************
				sBuffer.append("<PJSD>").append(speed).append("</PJSD>");
				sBuffer.append("<ZGSS>").append(speed).append("</ZGSS>");
				sBuffer.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
				sBuffer.append("</CS>");
			}
			sBuffer.append("</CSs>");
			if(ssop.setCS(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
				result = "success";
			}
		} catch (Exception e) {
			logger.error("setCS:",e);
			e.printStackTrace();
		} finally {
			logger.info("setCS:"+sBuffer.toString());
			logger.info("setCS:"+result);
			DBUtils_MS.close(rs, ps, conn);
		}
		return result;
	}


	/**
	 * 下载全量的公交基础数据
	 */
	public String getDownLoadAllDataFile() {
		String result = "success";
		try {
			Runtime currRuntime = Runtime.getRuntime ();

			int nFreeMemory = ( int ) (currRuntime.freeMemory() / 1024 / 1024);

			int nTotalMemory = ( int ) (currRuntime.totalMemory() / 1024 / 1024);

			System.out.println("zzz:"+nFreeMemory + "M/" + nTotalMemory +"M(free/total)");

			byte[] res = portType.downloadAllDataFile("down_pdgj", "down_pdgj123");
			String filePath = "E:\\ygc";
			BufferedOutputStream bos = null;
			FileOutputStream fos = null;
			File file = null;
			try {
				File dir = new File(filePath);
				if(!dir.exists()&&dir.isDirectory()){//判断文件目录是否存在
					dir.mkdirs();
				}
				file = new File(filePath+"\\abc.rar");
				fos = new FileOutputStream(file);
				bos = new BufferedOutputStream(fos);
				bos.write(res);
			} catch (Exception e) {
				e.printStackTrace();
			} finally {
				if (bos != null) {
					try {
						bos.close();
					} catch (IOException e1) {
						e1.printStackTrace();
					}
				}
				if (fos != null) {
					try {
						fos.close();
					} catch (IOException e1) {
						e1.printStackTrace();
					}
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}

		return result;
	}

	/**
	 * 下载增量的公交基础数据
	 */
	public String getDownLoadIncreaseDataFile() {
		String result = "success";
		try {
			//System.out.println(portType.downloadIncreaseDataFile(args0, args1, args2));
		} catch (Exception e) {
			e.printStackTrace();
		}

		return result;
	}

	/**
	 *  指定线路查询方式公交基础数据下载
	 */
	public String getDownLoadWarrantsBusLineStation() {
		String result = "success";
		try {

			//portType.setXL(userNameXl, passwordXl, sBuffer.toString());
		} catch (Exception e) {
			e.printStackTrace();
		}

		return result;
	}

	/**
	 * 计算结束时间
	 * @param fcsj 发车时间
	 * @param bcsj 班次历时
	 * @return
	 */
	private String calcDdsj(String fcsj,Integer bcsj){
		String result = "";
		if(fcsj.indexOf(":") != -1){
			if(bcsj == null){
				return fcsj;
			}
			// 时和分隔开
			String[] fcsjArray = fcsj.split(":");
			// 分和历时时间相加
			Integer fullTime = Integer.valueOf(fcsjArray[1])+ bcsj;
			int hour,min,sumHour;
			hour = fullTime / 60;
			min = fullTime % 60;
			sumHour = Integer.valueOf(fcsjArray[0])+hour;
			if(sumHour >= 24){
				result = String.format("%02d",sumHour - 24);
			}else{
				result = String.format("%02d",sumHour);;
			}
			result +=":"+String.format("%02d", min);
		}else{
			result = fcsj;
		}
		return result;
	}

	/**
	 * 改变时间格式
	 * @param ttInfoDetail 时刻表详细
	 * @return xx:yy
	 */
	private String changeTimeFormat(TTInfoDetail ttInfoDetail){
		String result = "00:00";
		String fcsj = ttInfoDetail.getFcsj();
		if(fcsj.indexOf(":") != -1){
			// 时和分隔开
			String[] fcsjArray = fcsj.split(":");
			result = String.format("%02d", Integer.valueOf(fcsjArray[0]))+":";
			result +=String.format("%02d", Integer.valueOf(fcsjArray[1]));
		}else{
			result = null;
			logger.info("setSKB:发车时间错误：ttInfoDetail.id="+ttInfoDetail.getId());
		}
		return result;
	}

	/**
	 * 拼装线路计划班次表的XML
	 * @param sBuffer
	 * @param schedulePlanInfo
	 * @param xlbm
	 * @param zbh
	 * @param lp
	 */
	private void assembleJHBC(StringBuffer sBuffer,SchedulePlanInfo schedulePlanInfo,String xlbm,String zbh,Long lp){
		sBuffer.append("<JHBC>");
		sBuffer.append("<RQ>").append(sdfnyr.format(schedulePlanInfo.getScheduleDate())).append("</RQ>");
		sBuffer.append("<XLBM>").append(BasicData.lineCode2ShangHaiCodeMap.get(xlbm)).append("</XLBM>");
		sBuffer.append("<CPH>").append("沪"+zbh).append("</CPH>");
		sBuffer.append("<LPBH>").append(lp).append("</LPBH>");
		sBuffer.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
		sBuffer.append("<BCList>");
	}
	/**
	 * 转换排班规则
	 * @param ruleDay
	 * @return
	 */
	private String changeRuleDay(String ruleDay){
		String result = "";
		int flag ;
		String[] ruleDayArray = ruleDay.split(",");
		for (int i = 0; i < ruleDayArray.length; i++) {
			if(ruleDayArray[i].equals("1")){
				flag = i+1;
			}else{
				flag = 0;
			}
			result += flag;
			if(i !=ruleDayArray.length -1){
				result +=",";
			}
		}
		return result;
	}
	/**
	 * 设置统一的公司名称
	 * @param company
	 */
	private void setCompanyName(String company){
		if(company.equals("闵行公司")){
			company = "浦东闵行公交公司";
		}else if(company.equals("杨高公司")){
			company = "浦东杨高公交公司";
		}else if(company.equals("上南公司")){
			company = "浦东上南公交公司";
		}else if(company.equals("金高公司")){
			company = "浦东金高公交公司";
		}else if(company.equals("南汇公司")){
			company = "浦东南汇公交公司";
		}else if(company.equals("青浦公交")){
			company = "浦东青浦公交公司";
		}
	}
	/**
	 * @param stationsList 站点路由集
	 * @param sBuffer sBuffer
	 * @param startId 站点序号起始ID
	 *
	 * @return 站点序号累加后的ID
	 */
	private int packagStationXml(List<StationRoute> stationsList,StringBuffer sBuffer,int startId){
		int size = stationsList.size();
		StationRoute srRoute;
		String zdlx ;// 站点类型：0：起点站、1：终点站、2：中途站
		for (int i = 0; i < size; i++) {
			srRoute = stationsList.get(i);
			zdlx = srRoute.getStationMark();
			if(zdlx.equals("B")){
				zdlx = "0";
			}else if(zdlx.equals("E")){
				zdlx = "1";
			}else{
				zdlx = "2";
			}
			sBuffer.append("<Station>");
			sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(srRoute.getLineCode(),srRoute.getDirections()+"",srRoute.getStationName())).append("</ZDXH>");
			sBuffer.append("<SXX>").append(srRoute.getDirections()).append("</SXX>");
			sBuffer.append("<ZDMC>").append(srRoute.getStationName()).append("</ZDMC>");
			sBuffer.append("<ZDBM>").append(srRoute.getStationCode()).append("</ZDBM>");
			sBuffer.append("<ZDJD>").append(srRoute.getStation().getgLonx()).append("</ZDJD>");
			sBuffer.append("<ZDWD>").append(srRoute.getStation().getgLaty()).append("</ZDWD>");
			sBuffer.append("<ZZ>").append(srRoute.getStation().getAddr()).append("</ZZ>");//站点的具体地址
			sBuffer.append("<ZDLX>").append(zdlx).append("</ZDLX>");
			sBuffer.append("<ZJLC>").append(srRoute.getDistances()).append("</ZJLC>");
			sBuffer.append("</Station>");
			startId++;
		}
		return startId;
	}

	/**
	 *
	 * @param lineCode 线路编码
	 * @param direction 线路方向
	 * @param stationName 让点名称
	 * @return 运管处站点序号
	 */
	private Integer getYgcStationNumByLineCodeAndDirectionAndStationName(String lineCode,String direction,String stationName){
		Integer number = 0;
		number = BasicData.stationName2YgcNumber.get(lineCode+"_"+direction+"_"+stationName);
		return number;
	}
}