潘钊 / bsth_control · Files

package com.bsth.service.impl;

import com.bsth.data.BasicData;
import com.bsth.email.SendEmailController;
import com.bsth.email.entity.EmailBean;
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.entity.sys.SysUser;
import com.bsth.entity.traffic.SKBUploadLogger;
import com.bsth.repository.*;
import com.bsth.repository.realcontrol.ScheduleRealInfoRepository;
import com.bsth.repository.schedule.*;
import com.bsth.repository.traffic.SKBUploadLoggerRepository;
import com.bsth.security.util.SecurityUtils;
import com.bsth.service.TrafficManageService;
import com.bsth.service.traffic.YgcBasicDataService;
import com.bsth.util.TimeUtils;
import com.bsth.util.db.DBUtils_MS;
import com.bsth.webService.trafficManage.org.tempuri.Results;
import com.bsth.webService.trafficManage.org.tempuri.WebServiceLocator;
import com.bsth.webService.trafficManage.org.tempuri.WebServiceSoap;
import org.apache.commons.lang.StringEscapeUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateUtils;
import org.joda.time.DateTime;
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.security.core.context.SecurityContextHolder;
import org.springframework.stereotype.Service;

import java.io.*;
import java.net.InetAddress;
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.Matcher;
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());
	// 运管处上传日志类型
	public static final String UPLOAD_TYPE_SKB = "1";
	public static final String UPLOAD_TYPE_XL = "2";
	public static final String UPLOAD_TYPE_LD = "3";

	// 线路repository
	@Autowired
	private LineRepository lineRepository;

	@Autowired
	private LineInformationRepository lineInformationRepository;

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

	// 历史站点路由repository
	@Autowired
	private LsStationRouteRepository lsStationRouteRepository;

	@Autowired
	private SectionRepository sectionRepository;

	// 车辆repository
	@Autowired
	private CarsRepository carsRepository;

	// 人员repository
	@Autowired
	private PersonnelRepository personnelRepository;

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

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

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

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

	// 时刻表上传记录repository
	@Autowired
	private SKBUploadLoggerRepository skbUploadLoggerRepository;

	// 线路站点repository
	@Autowired
	private YgcBasicDataService ygcBasicDataService;

	// 发送邮件
	@Autowired
	private SendEmailController sendEmailController;

	/**
	 * 线路版本repository
	 */
	@Autowired
	private LineVersionsRepository lineVersionsRepository;

	// 运管处上传接口
	private com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap webServiceSoapUp;
	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 userNameOther = "user";
	// 密码
	private final String passwordOther = "user";

	// 用户名
	private final String userNameUp = "user";
	// 密码
	private final String passwordUp = "user";
	// 接收邮件人
	private final String emailSendToAddress = "113252620@qq.com";
	// 记录路单上线的成功、失败线路数
	private Integer countSuccess,countFailure;

	private synchronized com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap  getWebServiceSoapUp(){
		try {
			if(webServiceSoapUp == null){
				webServiceSoapUp = new com.bsth.webService.trafficManage.up.org.tempuri.WebServiceLocator().getWebServiceSoap();
			}
		}catch (Exception e){
			e.printStackTrace();
		}finally {
			return webServiceSoapUp;
		}
	}
	/**
	 * 上传线路信息
	 */
	@Override
	public String setXL(String ids) {
		String result = "failure";
		String xml ;
		String[] idArray = ids.split(",");
		try {
			for (String id : idArray) {
				if(id == null || id.trim().equals("")){
					continue;
				}
				Map<String,Object> map = new HashMap<>();
				map.put("lineCode_eq", id);
				Line line ;
				LineInformation lineInformation;
				Optional<Line> optionalLine = lineRepository.findOne(new CustomerSpecs<Line>(map));
				line = optionalLine.isPresent() ? optionalLine.get() : null;
				if(line == null){
					continue;
				}
				if(BasicData.lineId2ShangHaiCodeMap.get(line.getId()) == null){
					return result;
				}
				map = new HashMap<>();
				map.put("line.id_eq",line.getId());
				Optional<LineInformation> optionalLineInformation = lineInformationRepository.findOne(new CustomerSpecs<LineInformation>(map));
				lineInformation = optionalLineInformation.isPresent() ? optionalLineInformation.get() : null;
				if(lineInformation == null){
					continue;
				}
				// 取得封装好的xml
				xml = getSetXlXml(line,lineInformation);
				// 站点序号不能为0，如果为0，则返回错误
				if(xml.indexOf("<ZDXH>0</ZDXH>") != -1){
					return "0";
				}
				String state;// 是否上传成功
				// 调用上传方法
				if(getWebServiceSoapUp().setXL(userNameUp,passwordUp,xml).isSuccess()){
					result = "success";
					state = "1";
				}else{
					result = "failure";
					state = "0";
				}
				logger.info("setXL:"+xml);
				logger.info("setXL:"+result);
				// 保存运管处上传记录
				saveYgcUploadLog(line,xml,TrafficManageServiceImpl.UPLOAD_TYPE_XL,state);
			}
		} catch (Exception e) {
			logger.error("setXL:",e);
			e.printStackTrace();
		}
		return result;
	}

	/**
	 * 加载运管处的站点及序号
	 * 上行从1开始，下行顺序续编
	 */
	private Map<String, Integer> getStationName2YgcNumberMap (String lineCode){
		Map<String, Integer> resultMap = new HashMap<>();
		List<Map<String, String>> ygcLines = stationRouteRepository.findLineWithYgcByLine(lineCode);
		if(ygcLines != null && ygcLines.size() > 0){
			int size = ygcLines.size();
			Map<String, String> tempMap ;
			int num = 1;
			String key;
			for (int i = 0; i < size; i ++){
				tempMap = ygcLines.get(i);
				key = tempMap.get("lineCode") + "_"+String.valueOf(tempMap.get("directions"))
						+ "_"+tempMap.get("stationCode")+ "_"+tempMap.get("stationMark");
				resultMap.put(key,num++);
			}
		}
		return resultMap;
	}

	/**
	 * 上传线路信息(按in_use上传)
	 */
	@Override
	public String setXLByInUse(String inUse) {
		StringBuffer result = new StringBuffer();
		try {
			Map<String,Object> map = new HashMap<>();
			if(inUse != null && inUse.equals("1")){
				map.put("inUse_eq", inUse);
			}
			List<Line> lines ;
			Line line;
			lines = lineRepository.findAll(new CustomerSpecs<Line>(map));
			if(lines != null && lines.size() > 0){
				for(int i = 0 ; i < lines.size() ; i ++){
					line = lines.get(i);
					if(line != null && line.getId() != null){
						result.append(line.getLineCode()).append(":").append(setXL(line.getLineCode())).append(";");
					}
				}
			}
		} catch (Exception e) {
			result.append("failure");
			logger.error("setXLByInUse:",e);
			e.printStackTrace();
		}
		return result.toString();
	}

	/**
	 * 上传车辆信息
	 */
	@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;
	}

	/**
	 * 上传路单 指定日期 yyyy-MM-dd
	 * @param theDate
	 * @return
	 */
	public String setLD(String theDate){
		return uploadLD(theDate);
	}

	/**
	 * 上传路单 上传前一天的路单
	 * @return
	 */
	public String setLD(){
		return uploadLD(null);
	}
	/**
	 * 上传路单
	 * @return 上传成功标识
	 */
	private String uploadLD(String theDate){
		// 取昨天 的日期
		String date = theDate == null ?sdfnyr.format(DateUtils.addDays(new Date(), -1)) : theDate;
		StringBuffer sf = new StringBuffer();
		Results results = null;
		String str = "", xlbm = null, oldXlbm = null;
		List<Map<String,Object>> listGroup = null;
		int scount = 0, ccount = 0;
		long start = System.currentTimeMillis();
		try {
			// 计数器
			int counter = 0;
			// 每几条线路上传一次路单
			int per = 10;
			List<ScheduleRealInfo> list = scheduleRealInfoRepository.setLD(date);
			listGroup = scheduleRealInfoRepository.setLDGroup(date);
			Map<String,Object> map = new HashMap();
			HashMap<String,String> paramMap;
			HashMap<String,String> otherMap = new HashMap();

			// 车辆内部编码和车牌做映射
			Map<String, String> inside2plate = new HashMap<>();
			Iterable<Cars> cars = carsRepository.findAll();
			for (Cars car : cars)  {
				inside2plate.put(car.getInsideCode(), car.getCarPlate());
			}

			// 线路编码和线路信息映射
			Map<String, Line> code2line = new HashMap<>();
			Iterable<Line> lines = lineRepository.findAll();
			for (Line line : lines) {
				code2line.put(line.getLineCode(), line);
			}

			// 线路编码和线路版本映射(电子路单日期)
			Map<String, Integer> code2version = new HashMap<>();
			Iterable<LineVersions> versions = lineVersionsRepository.findLineVersionsByDate((int)(DateTime.parse(date).getMillis() / 1000));
			for (LineVersions version : versions) {
				code2version.put(version.getLineCode(), version.getVersions());
			}

			Map<String, Integer> stationNumMap = null;
			for(Map<String,Object> schRealInfo:listGroup){
				if(schRealInfo != null){
					// 获取线路是否使用标识，如果未使用，则不查该线路数据
					String lineCode = schRealInfo.get("xlBm")+"";
					Line line = code2line.get(lineCode);
					if(line == null || line.getInUse() == null || line.getInUse() == 0){
						ccount++;
						continue;
					}
					if(counter % per == 0){
						sf = new StringBuffer();
						sf.append("<DLDS>");
					}
					counter ++;
					xlbm = BasicData.lineCode2ShangHaiCodeMap.get(lineCode);
					if (!xlbm.equals(oldXlbm)) {
						oldXlbm = xlbm;
						Integer ver = code2version.get(lineCode);
						if (ver != null) {
							stationNumMap = getLsStationRoute(lineCode, ver);
						}
					}

					sf.append("<DLD>");
					sf.append("<RQ>").append(date).append("</RQ>");
					sf.append("<XLBM>").append(xlbm).append("</XLBM>");
					sf.append("<LPBH>").append(schRealInfo.get("lpName")).append("</LPBH>");
					sf.append("<CPH>").append(inside2plate.get(schRealInfo.get("clZbh"))).append("</CPH>");
					sf.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
					sf.append("<LDList>");
					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.isDestroy()){
								if(scheduleRealInfo.isReissue()){
									scheduleRealInfo.setFcsjActualAll(scheduleRealInfo.getDfsj());
									scheduleRealInfo.setZdsjActualAll(scheduleRealInfo.getZdsj());
								}
								else
									continue;
							}

							if(scheduleRealInfo.getBcType().equals("in")
									|| scheduleRealInfo.getBcType().equals("out")){
								continue;
							}

							sf.append("<LD>");
							sf.append("<SJGH>").append(scheduleRealInfo.getjGh()).append("</SJGH>");
							sf.append("<SXX>").append(scheduleRealInfo.getXlDir()).append("</SXX>");
							sf.append("<FCZDMC>").append(scheduleRealInfo.getQdzName()).append("</FCZDMC>");
							// 起点站的参数
							otherMap.put("stationMark","B");
							paramMap = packageYgcStationNumParam(scheduleRealInfo,otherMap);
							sf.append("<FCZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,stationNumMap)).append("</FCZDXH>");
							sf.append("<FCZDBM>").append(scheduleRealInfo.getQdzCode()).append("</FCZDBM>");
							sf.append("<JHFCSJ>").append(scheduleRealInfo.getFcsj()).append("</JHFCSJ>");
							sf.append("<DFSJ>").append(scheduleRealInfo.getDfsj()).append("</DFSJ>");
							sf.append("<SJFCSJ>").append(scheduleRealInfo.getFcsjActual()).append("</SJFCSJ>");
							sf.append("<FCZDLX></FCZDLX>");
							sf.append("<DDZDMC>").append(scheduleRealInfo.getZdzName()).append("</DDZDMC>");
							// 终点站的参数
							otherMap.put("stationMark","E");
							paramMap = packageYgcStationNumParam(scheduleRealInfo,otherMap);
							sf.append("<DDZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,stationNumMap)).append("</DDZDXH>");
							sf.append("<DDZDBM>").append(scheduleRealInfo.getZdzCode()).append("</DDZDBM>");
							sf.append("<JHDDSJ>").append(scheduleRealInfo.getZdsj()).append("</JHDDSJ>");
							sf.append("<SJDDSJ>").append(scheduleRealInfo.getZdsjActual()).append("</SJDDSJ>");
							sf.append("<DDZDLX></DDZDLX>");
							sf.append("<LDSCBZ>0</LDSCBZ>");
							sf.append("<DDBZ>").append(scheduleRealInfo.getRemarks()).append("</DDBZ>");
							sf.append("</LD>");
						}
					}
					sf.append("</LDList>");
					sf.append("</DLD>");
				}
				if(counter % per == per - 1){
					sf.append("</DLDS>");
					// 去掉'号
					str = sf.toString().replace("'","");
					scount += invokeSetLD(str, counter);
					counter = 0;
				}
			}
			// 每per条线路上传后剩下的数据再上传
			if(counter > 0){
				sf.append("</DLDS>");
				// 去掉'号
				str = sf.toString().replace("'","");
				scount += invokeSetLD(str, counter);
			}
		} catch (Exception e) {
			e.printStackTrace();
			logger.error("setLD:", e);
		} finally {
			try {
				//发送邮件
				EmailBean mail = new EmailBean();
				mail.setSubject(InetAddress.getLocalHost().getHostAddress()+":路单日志数据"+date);
				mail.setContent("总数：" + (listGroup == null ? 0 : listGroup.size()) + "<br/>成功数：" + scount + "<br/>跳过数：" + ccount + "<br/>耗时：" + (System.currentTimeMillis() - start));
				sendEmailController.sendMail(emailSendToAddress, mail);
				logger.info("setLD-sendMail:邮件发送成功！");
			} catch (Exception e) {
				e.printStackTrace();
				logger.error("setLD-sendMail:",e);
			}
		}
		return "success";
	}

	/**
	 * 调用运管处电子路单接口，如果上传失败或有网络问题，最多执行10次
	 * @param xml 拼接的xml字符串
	 * @param counter 分组数
	 * @return 成功返回counter 失败返回0
	 */
	private int invokeSetLD(String xml, int counter) {
		for (int i = 0;i < 10;i++) {
			try {
				Results results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(xml));
				if (results.isSuccess()) {
					logger.info("setLD: " + xml);
					logger.info("setLD: 成功");
					return counter;
				}
				Thread.sleep(2000);
			} catch (Exception e) {
				logger.error("运管处接口调用异常", e);
				try {
					Thread.sleep(2000);
				} catch (InterruptedException ex) {
					ex.printStackTrace();
				}
			}
		}

		return 0;
	}

	/**
	 * 上传路单 xml来自文件
	 * @return 上传成功标识
	 */
	public String setLDFile(){
		String result = "failure";
		try {
			String tmp = readXmlFromFile("F:/ld.txt");
			Results rss = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(tmp));
			if(rss.isSuccess()){
				result = "success";
			}
		} catch (Exception e) {
			logger.error("setLD:",e);
			e.printStackTrace();
		}finally{

		}
		return result;
	}

	/**
	 * 从文件中读取xml
	 * @param fileName  例：D:/test.txt
	 * @return
	 * @throws Exception
	 */
	private String readXmlFromFile(String fileName) throws Exception {
		StringBuffer sf = new StringBuffer("");
		File file = new File(fileName);
		InputStreamReader reader = new InputStreamReader(new FileInputStream(file),"GBK");
		BufferedReader bufferedReader = new BufferedReader(reader);
		String lineTxt = "";
		while((lineTxt = bufferedReader.readLine()) != null){
			sf.append(lineTxt);
		}
		reader.close();
		return sf.toString().replaceAll("\t","");
	}
	/**
	 * 上传里程油耗
	 * @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")+"");
					Optional<Cars> optionalCars = carsRepository.findOne(new CustomerSpecs<Cars>(map));
					Cars car = optionalCars.isPresent() ? optionalCars.get() : null;
					/**
					 * 如果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;
	}

	/**
	 * 上传计划班次 指定日期 yyyy-MM-dd
	 * @param theDate
	 * @return
	 */
	public String setJHBC(String theDate){
		return uploadJHBC(theDate);
	}

	/**
	 * 上传计划班次
	 * @return
	 */
	public String setJHBC(){
		return uploadJHBC(null);
	}
	/**
	 * 上传线路计划班次表
	 */

	private String uploadJHBC(String theDate) {
		String result = "failure";
		Line line;
		StringBuffer sBuffer =new StringBuffer();
		try {
			sBuffer.append("<JHBCs>");
			// 声明变量
			SchedulePlanInfo schedulePlanInfo;
			String xlbm,zbh = "";
			Long lp = 0L;
			// 取得计划班次时间
			String tomorrow = theDate == null ? sdfnyr.format(DateUtils.addDays(new Date(), +1)) : theDate;
			// 查询所有班次
			List<SchedulePlanInfo> schedulePlanList = schedulePlanInfoRepository.findLineScheduleBc(tomorrow);
			int j = 0; // 初始化标识
			if(schedulePlanList != null ){
				HashMap<String,String> paramMap;
				HashMap<String,String> otherMap = new HashMap<String, String>();
				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>");
						// 起点站的参数
						otherMap.put("stationMark","B");
						paramMap = packageYgcStationNumParam(schedulePlanInfo,otherMap);
						sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,null)).append("</ZDXH>");
						sBuffer.append("<JHFCSJ>").append(schedulePlanInfo.getFcsj()).append("</JHFCSJ>");
						sBuffer.append("<DDZDMC>").append(schedulePlanInfo.getZdzName()).append("</DDZDMC>");
						// 起点站的参数
						otherMap.put("stationMark","E");
						paramMap = packageYgcStationNumParam(schedulePlanInfo,otherMap);
						sBuffer.append("<DDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,null)).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);
			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 = "上传失败，";
		StringBuffer sBuffer = new StringBuffer("<SKBs>");
		DecimalFormat df = new DecimalFormat("######0.000");
		Map<String,String> lsStationCode2NameMap = null;
		Map<String, Integer> lsStationName2YgcNumber = null;
		try {
			String[] idArray = ids.split(",");
			StringBuffer sBufferA ,sBufferB ,sBufferC ;
			double zlc,yylc,singleLc,emptyLc;// 总里程、营运里程、单程、空放里程
			String bcType,sxx;// 班次类型、上下行
			// 上传的时刻表集合
			List<TTInfo> ttinfoList = new ArrayList<>();
			TTInfo ttInfo;
			TTInfoDetail ttInfoDetail;
			LineInformation lineInformation;
			Iterator<TTInfoDetail> ttInfoDetailIterator;
			HashMap<String,Object> param ;
			HashMap<String,String> paramMap;
			HashMap<String,String> otherMap = new HashMap<>();
			// 线路编码、周几执行、发车站点名称、发车站点序号、到达站点名称、到达站点序号
			String xlbm,zjzx,fczdmc,zdxh,ddzdmc,ddxh;
			// 得到时刻表版本号
			int lineVersion;
			long ttinfoId;
			// 是否输出站点信息
			boolean isLogStation;
			for (int i = 0; i < idArray.length; i++) {
				ttinfoId = Long.valueOf(idArray[i]);
				Optional<TTInfo> optionalTTInfo = ttInfoRepository.findById(ttinfoId);
				ttInfo = optionalTTInfo.isPresent() ? optionalTTInfo.get() : null;
				if(ttInfo == null)
					continue;
				ttinfoList.add(ttInfo); // 保存时刻表
				// 得到时刻表版本号
				lineVersion = ttInfo.getLineVersion();
				// 查询历史站点路由
				lsStationCode2NameMap = getLsStationCode(ttInfo.getXl().getLineCode(),lineVersion);
				// 查询历史站点路由
				lsStationName2YgcNumber = getLsStationRoute(ttInfo.getXl().getLineCode(),lineVersion);
				zlc = 0.0f;
				yylc = 0.0f;
				// 获得时刻表
				param = new HashMap();
				param.put("ttinfo.id_eq", ttInfo.getId());
				ttInfoDetailIterator = ttInfoDetailRepository.findAll(new CustomerSpecs<TTInfoDetail>(param),
						new Sort(Direction.ASC, "xlDir")).iterator();
				// 获得lineInformation
				param = new HashMap();
				param.put("line.id_eq", ttInfo.getXl().getId());
				Optional<LineInformation> optionalLineInformation = lineInformationRepository.findOne(new CustomerSpecs<LineInformation>(param));
				lineInformation = optionalLineInformation.isPresent() ? optionalLineInformation.get() : null;
				// 初始化
				isLogStation = true;
				if(ttInfoDetailIterator.hasNext()){
					// 得到线路信息
					Optional<Line> optionalLine = lineRepository.findById(ttInfo.getXl().getId());
					Line line = optionalLine.isPresent() ? optionalLine.get() : null;
					if(line == null){
						result += "未找到相应的线路信息，请设置线路信息后再上传";
						return result;
					}
					// 得到上海市线路编码
					xlbm = line.getShanghaiLinecode();
					if("".equals(xlbm) || "null".equals(xlbm)){
						result += "线路编码为空，请设置线路编码后再上传";
						return result;
					}
					// 拿到周几执行
					zjzx = changeRuleDay(ttInfo.getRule_days());
					if("".equals(zjzx) || "null".equals(zjzx)){
						result += "时刻表执行时间为空，请设置执行时间后再上传";
						return result;
					}
					sBuffer.append("<SKB>");
					sBuffer.append("<XLBM>").append(xlbm).append("</XLBM>");
					sBufferB = new StringBuffer();
					sBufferC = new StringBuffer();
					sBufferB.append("<KSRQ>").append(sdfnyr.format(ttInfo.getQyrq())).append("</KSRQ>");
					// 结束日期暂时不要，节假日的班次表才需要，如春节的班次表
					sBufferB.append("<JSRQ>").append("").append("</JSRQ>");
					sBufferB.append("<ZJZX>").append(zjzx).append("</ZJZX>");
					sBufferB.append("<TBYY>").append("").append("</TBYY>");
					sBufferB.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
					sBufferB.append("<BCList>");
					while (ttInfoDetailIterator.hasNext()) {
						ttInfoDetail = ttInfoDetailIterator.next();
						bcType = ttInfoDetail.getBcType();
						sxx = ttInfoDetail.getXlDir();
						// 进出场班次的里程，加入总里程
						if(bcType.equals("in") || bcType.equals("out")){
							// 进出班次的计划里程，算空驶里程
							emptyLc = ttInfoDetail.getJhlc();
							// 总里程需要加上空驶里程
							zlc += emptyLc;
							continue;
						}
						// 不是正常班次，不传到运管处
						if(!bcType.equals("normal")){
							continue;
						}
						// 如果发车时间格式错误，忽略此条
						if(changeTimeFormat(ttInfoDetail) == null){
							continue;
						}
						// 发生站点名称
						fczdmc = lsStationCode2NameMap.get(ttInfoDetail.getXl().getLineCode()+"_"+ttInfoDetail.getXlDir()+"_"+ttInfoDetail.getQdzCode());
						if("".equals(fczdmc) || "null".equals(fczdmc)){
							result += "发车站点名称为空，请根据时刻表当前的版本号设置好历史站点路由再上传";
							return result;
						}
						sBufferC.append("<BC>");
						sBufferC.append("<LPBH>").append(ttInfoDetail.getLp().getLpNo()).append("</LPBH>");
						sBufferC.append("<SXX>").append(sxx).append("</SXX>");
						sBufferC.append("<FCZDMC>").append(fczdmc).append("</FCZDMC>");
						// 起点站的参数
						otherMap.put("stationMark","B");
						paramMap = packageYgcStationNumParam(ttInfoDetail,otherMap);
						if(isLogStation){// 输出起点站信息
							logger.info("setSKB:"+"起点站信息："+paramMap);
						}
						// 发车站点序号
						zdxh = String.valueOf(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,lsStationName2YgcNumber));
						if("".equals(zdxh) || "null".equals(zdxh) || "0".equals(zdxh)){
							result += "发车站点序号为空，请根据时刻表当前的版本号设置好历史站点路由再上传";
							return result;
						}
						// 到达站点名称
						ddzdmc = lsStationCode2NameMap.get(ttInfoDetail.getXl().getLineCode()+"_"+ttInfoDetail.getXlDir()+"_"+ttInfoDetail.getZdzCode());
						if("".equals(ddzdmc) || "null".equals(ddzdmc)){
							result += "到达站点名称为空，请根据时刻表当前的版本号设置好历史站点路由再上传";
							return result;
						}
						sBufferC.append("<ZDXH>").append(zdxh).append("</ZDXH>");
						sBufferC.append("<JHFCSJ>").append(changeTimeFormat(ttInfoDetail)).append("</JHFCSJ>");
						sBufferC.append("<DDZDMC>").append(ddzdmc).append("</DDZDMC>");
						// 终点站的参数
						otherMap.put("stationMark","E");
						paramMap = packageYgcStationNumParam(ttInfoDetail,otherMap);
						if(isLogStation){// 输出终点站信息
							logger.info("setSKB:"+"终点站信息："+paramMap);
						}
						// 到达站点序号
						ddxh = String.valueOf(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,lsStationName2YgcNumber));
						if("".equals(ddxh) || "null".equals(ddxh) || "0".equals(ddxh)){
							result += "到达站点序号为空，请根据时刻表当前的版本号设置好历史站点路由再上传";
							return result;
						}
						isLogStation = false; // 一条线路只输出一次，后面的不输出了
						sBufferC.append("<DDXH>").append(ddxh).append("</DDXH>");
						sBufferC.append("<JHDDSJ>").append(calcDdsj(ttInfoDetail.getFcsj(),ttInfoDetail.getBcsj())).append("</JHDDSJ>");
						sBufferC.append("</BC>");
						// 0：上行；1：下行
						if("0".equals(sxx)){
							singleLc = lineInformation.getUpMileage();
						}else{
							singleLc = lineInformation.getDownMileage();
						}
						zlc += singleLc ;
						yylc += singleLc;
					}
					sBufferC.append("</BCList>");
					sBufferC.append("</SKB>");
					sBufferA = new StringBuffer();
					sBufferA.append("<JHZLC>").append(df.format(zlc)).append("</JHZLC>");
					sBufferA.append("<JHYYLC>").append(df.format(yylc)).append("</JHYYLC>");
					sBuffer.append(sBufferA).append(sBufferB).append(sBufferC);
				}
				logger.info("setSKB:"+"ttinfoId:"+ttinfoId+";当前站点版本号："+lineVersion+"；查询历史站点路由:"+lsStationCode2NameMap+";查询历史站点编号:"+lsStationName2YgcNumber);
			}
			sBuffer.append("</SKBs>");
            String state;// 是否上传成功
            if(ssop.setSKB(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
                result = "上传成功";
                state = "1";
            }else{// 上传失败
                result = "上传失败";
                state = "0";
            }
            // 保存运管处上传记录
            saveYgcUploadLog(ttinfoList,sBuffer.toString(),TrafficManageServiceImpl.UPLOAD_TYPE_SKB,state);
		} catch (Exception e) {
			logger.error("setSKB:", e);
			e.printStackTrace();
		}finally{
            logger.info("setSKB:"+sBuffer.toString());
            logger.info("setSKB:"+result);
		}
		return result;
	}

	/**
	 * 保存上传运管处的日志
	 * @param obj 参数
	 * @param type 日志类型
	 * @param xml 上传参数
	 */
	private void saveYgcUploadLog(Object obj,String xml,String type,String state){
		SKBUploadLogger skbUploadLogger  = new SKBUploadLogger();
		SysUser user;
		// 如果不是人为上传，SysUser则为空，设置上传人员为管理员
		if(SecurityContextHolder.getContext() == null || SecurityContextHolder.getContext().getAuthentication() == null){
			user = new SysUser();
			user.setId(1);
		}else{// 获取上传人员
			user = SecurityUtils.getCurrentUser();
		}
		// 最大的字符长度
		int maxLength = 60000;
		int cutLength = 50000;// 需要截取的字符长度
		String xml_sub = null;
		skbUploadLogger.setType(type);// 设置类型
		// 判断xml是否超长，如果超长，则截取
		if(xml != null && xml.length() > maxLength){
			int xmlLength = xml.length();
			int cutCount = xmlLength / cutLength + (xmlLength % cutLength > 0 ? 1 : 0);
			if(cutCount > 2){
				xml = "由于上传参数内容超长，请查看服务器的系统日志";
			}else if(cutCount == 2){
				xml_sub =xml.substring(cutLength);
				xml = xml.substring(0,cutLength);
			}else{
				// 不做处理
			}
		}
//		skbUploadLogger.setUploadXml(xml);// 上传的参数
//		skbUploadLogger.setUploadXmlSub(xml_sub);
		skbUploadLogger.setState(state);// 状态：是否成功
		skbUploadLogger.setUser(user);
		// 时刻表
		if(type.equals(TrafficManageServiceImpl.UPLOAD_TYPE_SKB)){
			List<TTInfo> ttInfoList = (List<TTInfo>)obj;
			String name = "";
			Line line = null;
			for(TTInfo ttInfo : ttInfoList){
				name += ttInfo.getName() + " ";
				line = ttInfo.getXl();
			}
			skbUploadLogger.setLine(line);
			skbUploadLogger.setUser(user);
			skbUploadLogger.setName(name);
			skbUploadLoggerRepository.save(skbUploadLogger);
		}else{
			if(type.equals(TrafficManageServiceImpl.UPLOAD_TYPE_XL)){
				Line line = (Line) obj;
				String name = line.getName() + "线路停靠站上传";
				skbUploadLogger.setLine(line);
				skbUploadLogger.setName(name);
				skbUploadLoggerRepository.save(skbUploadLogger);
			}else if(type.equals(TrafficManageServiceImpl.UPLOAD_TYPE_LD)){
				Map<String ,Line>  logLineMap = (Map<String ,Line> )obj;
				for (String key : logLineMap.keySet()) {
					Line line = logLineMap.get(key);
					String name = line.getName() + "路单上传";
					skbUploadLogger  = new SKBUploadLogger();
					skbUploadLogger.setType(type);// 设置类型
//					skbUploadLogger.setUploadXml(xml);// 上传的参数
//					skbUploadLogger.setUploadXmlSub(xml_sub);
					skbUploadLogger.setState(state);// 状态：是否成功
					skbUploadLogger.setUser(user);
					skbUploadLogger.setLine(line);
					skbUploadLogger.setName(name);
//					skbUploadLoggerRepository.save(skbUploadLogger);
				}
			}
		}
	}
	/**
	 * 上传线路人员车辆配置信息
	 */
	@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 = "failure";
		try {
			try {
				if(ygcBasicDataService.download("admin","000000","abc.zip")){
					result = "success";
				}
			} catch (Exception e) {
				e.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;
			}
			if(flag > 0){
				result += flag + ",";
			}
		}
		// 去掉最后一个字符
		if(StringUtils.endsWith(result,",")){
			result = StringUtils.removeEnd(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,Map<String, Integer> stationNumMap){
		int size = stationsList.size();
		StationRoute srRoute;
		HashMap<String,String> paraMap;
		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";
			}
			paraMap = packageYgcStationNumParam(srRoute,null);
			sBuffer.append("<Station>");
			sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paraMap,stationNumMap)).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() == null ? "" : 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 pointList 站点点位集
	 * @param sBuffer sBuffer
	 * @param startId 站点序号起始ID
	 *
	 * @return 站点序号累加后的ID
	 */
	private int packagStationPointXml(List<Object[]> pointList,StringBuffer sBuffer,int startId){
		int size = pointList.size();
		Object[] objs;
		String bsection,dir,section;
		String[] sections ;
		for (int i = 0; i < size; i++) {
			objs = pointList.get(i);
			bsection = objs[0]+"";
			dir = objs[1]+"";
			// 取括号内的内容
			Pattern pattern = Pattern.compile("(?<=\\()(.+?)(?=\\))");
			Matcher matcher = pattern.matcher(bsection);
			if(matcher.find()){
				sections = matcher.group().split(",");
				for (int j = 0 ; j < sections.length ; j ++){
					section = sections[j];
					sBuffer.append("<LinePoint>");
					sBuffer.append("<ZDXH>").append(startId).append("</ZDXH>");
					sBuffer.append("<SXX>").append(dir).append("</SXX>");
					sBuffer.append("<ZDJD>").append(section.split(" ")[0]).append("</ZDJD>");
					sBuffer.append("<ZDWD>").append(section.split(" ")[1]).append("</ZDWD>");
					sBuffer.append("</LinePoint>");
					startId++;
				}
			}
		}
		return startId;
	}

	/**
	 *  获取运管处站点序号
	 * @param map
	 * @return 运管处站点序号
	 */
	private Integer getYgcStationNumByLineCodeAndDirectionAndStationName(HashMap<String,String> map,Map<String, Integer> stationNumMap){
		// 线路编码
		String lineCode = map.get("lineCode");
		// 线路走向 0：上行  1：下行
		String direction = map.get("direction");
		// 站点编码
		String stationCode = map.get("stationCode");
		// 站点类型：B：起点站 Z：中途站 E：终点站 T：停车场
		String stationMark = map.get("stationMark");
		String[] marks = null;
		// 起点站，先从起点找，找不到再从中途站找，最后从终点找
		if(stationMark.equals("B")){
			marks= new String[]{"B","Z","E"};
		}else if(stationMark.equals("E")){// 终点站相反
			marks= new String[]{"E","Z","B"};
		}else if(stationMark.equals("Z")){
			marks= new String[]{"Z"};
		}
		// 默认从缓存BasicData.stationName2YgcNumber
		Map<String, Integer> tempMap = BasicData.stationName2YgcNumber;
		// 如果传入的stationNumMap不为空，则不是缓存取，而从stationNumMap取
		if(stationNumMap != null){
			tempMap = stationNumMap;
		}
		Integer number = null;
		for (int i = 0 ;i < marks.length ; i ++){
			number = tempMap.get(lineCode+"_"+direction+"_"+stationCode+"_"+marks[i]);
			if(number != null){
				break;
			}
		}
		return number == null ? 0 : number;
	}

	/**
	 * 封装查询站序条件
	 * @param obj
	 * @return
	 */
	private HashMap packageYgcStationNumParam(Object obj,HashMap<String,String> otherParam){
		HashMap<String,String> map = new HashMap<String,String>();
		String lineCode = "",direction = "",stationCode = "",stationMark = "";
		// 站点路由
		if(obj instanceof StationRoute){
			StationRoute sr = (StationRoute)obj;
			lineCode = sr.getLineCode();
			direction = String.valueOf(sr.getDirections());
			stationCode = sr.getStationCode();
			stationMark = sr.getStationMark();
		}else if(obj instanceof ScheduleRealInfo){ //实际排班计划明细。
			ScheduleRealInfo sri = (ScheduleRealInfo)obj;
			lineCode = sri.getXlBm();
			direction = sri.getXlDir();
			if(otherParam != null && otherParam.get("stationMark") != null){
				stationMark = otherParam.get("stationMark");
				if(stationMark.equals("B")){ // 起点站
					stationCode = sri.getQdzCode();
				}else if(stationMark.equals("E")){ // 终点站
					stationCode = sri.getZdzCode();
				}
			}
		}else if(obj instanceof SchedulePlanInfo){ //排班计划明细
			SchedulePlanInfo spi = (SchedulePlanInfo)obj;
			lineCode = spi.getXlBm();
			direction = spi.getXlDir();
			if(otherParam != null && otherParam.get("stationMark") != null){
				stationMark = otherParam.get("stationMark");
				if(stationMark.equals("B")){ // 起点站
					stationCode = spi.getQdzCode();
				}else if(stationMark.equals("E")){ // 终点站
					stationCode = spi.getZdzCode();
				}
			}
		}else if(obj instanceof TTInfoDetail){ //时刻表明细
			TTInfoDetail ttid = (TTInfoDetail)obj;
			lineCode = ttid.getXl().getLineCode();
			direction = ttid.getXlDir();
			if(otherParam != null && otherParam.get("stationMark") != null){
				stationMark = otherParam.get("stationMark");
				if(stationMark.equals("B")){ // 起点站
					stationCode = ttid.getQdzCode();
				}else if(stationMark.equals("E")){ // 终点站
					stationCode = ttid.getZdzCode();
				}
			}
		}
		map.put("lineCode",lineCode);// 站点编码
		map.put("direction",direction); // 上下行
		map.put("stationCode",stationCode); // 站点编号
		map.put("stationMark",stationMark); // 站点类型
		return map;
	}

	/**
	 * 取得历史站点编码和站点名称的对应关系
	 * @return
	 */
	private Map<String, String> getLsStationCode(String lineCode,int lineVersion){
		Map<String,Object> map = new HashMap<>();
		map.put("lineCode_eq", lineCode);
		map.put("versions_eq",lineVersion);
		LsStationRoute lsroute;
		Iterator<LsStationRoute> iterator = lsStationRouteRepository.findAll(new CustomerSpecs<LsStationRoute>(map)).iterator();
		Map<String, String> stationCode2Name = new HashMap<>();
		while (iterator.hasNext()) {
			lsroute = iterator.next();
			stationCode2Name.put(lsroute.getLineCode() + "_" + lsroute.getDirections() + "_" + lsroute.getStationCode(), lsroute.getStationName());
		}
		return stationCode2Name;
	}

	private Map<String, Integer> getLsStationRoute(String xlbm,int lineVersion){
		Map<String, Integer> tempStationName2YgcNumber = new HashMap<String, Integer>();
		/**
		 * 加载运管处的站点及序号
		 * 上行从1开始，下行顺序续编
		 */
		List<Map<String, String>> ygcLines = lsStationRouteRepository.findLineWithLineCode4Ygc(xlbm,lineVersion);
		if(ygcLines != null && ygcLines.size() > 0){
			int size = ygcLines.size();
			Map<String, String> tempMap ;
			int num = 1;
			String key;
			String lineCode = "";
			for (int i = 0; i < size; i ++){
				tempMap = ygcLines.get(i);
				if(lineCode.equals("")){
					lineCode = tempMap.get("lineCode");
				}else if(!lineCode.equals(tempMap.get("lineCode"))){
					num = 1;
					lineCode = tempMap.get("lineCode");
				}
				key = tempMap.get("lineCode") + "_"+String.valueOf(tempMap.get("directions"))
						+ "_"+tempMap.get("stationCode")+ "_"+tempMap.get("stationMark");
				tempStationName2YgcNumber.put(key,num++);
			}
		}
		return tempStationName2YgcNumber;
	}

	private String getSetXlXml(Line line,LineInformation lineInformation){
		StringBuffer sBuffer = new StringBuffer();
		List<StationRoute> upStationsList ;// 上行站点路由集
		List<StationRoute> downStationsList;// 下行站点路由集
		List<Object[]> downPointList;// 下行站点集
		List<Object[]> upPointList;// 上行站点集
		sBuffer.append("<XLs>");
		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>");
		sBuffer.append("<QZLC>").append(lineInformation.getUpMileage()).append("</QZLC>");
		sBuffer.append("<ZQLC>").append(lineInformation.getDownMileage()).append("</ZQLC>");
		sBuffer.append("<XLGH>").append(line.getLinePlayType()).append("</XLGH>");
		sBuffer.append("<UPDATE_DATE>").append(sdfnyr.format(new Date())).append("</UPDATE_DATE>");
		// 循环添加站点信息
		sBuffer.append("<StationList>");
		// 先查上行
		upStationsList = stationRouteRepository.findByLine(line.getLineCode(), 0);
		Map<String, Integer> stationNumMap = getStationName2YgcNumberMap(line.getLineCode());
		int startId = 1;
		startId = packagStationXml(upStationsList, sBuffer, startId,stationNumMap);
		// 环线不查下行
		if(line.getLinePlayType() != 1){
			// 再查下行
			downStationsList = stationRouteRepository.findByLine(line.getLineCode(), 1);
			packagStationXml(downStationsList, sBuffer, startId,stationNumMap);
		}
		sBuffer.append("</StationList>");
		// 循环添加站点点位信息
		sBuffer.append("<LinePointList>");
		upPointList = sectionRepository.getSectionDirByLineId(line.getId(),0);
		startId = 1;
		startId = packagStationPointXml(upPointList, sBuffer, startId);
		// 环线不查下行
		if(line.getLinePlayType() != 1){
			downPointList = sectionRepository.getSectionDirByLineId(line.getId(),1);
			packagStationPointXml(downPointList, sBuffer, startId);
		}
		sBuffer.append("</LinePointList>");
		sBuffer.append("</XL>");
		sBuffer.append("</XLs>");
		return sBuffer.toString();
	}
}