王通 / control4cloud · Files

package com.bsth.realschedule;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.security.MessageDigest;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.bsth.utils.Arith;
import com.bsth.utils.HttpUtils;

/**
 * 
 * @author LGF
 *
 */

@Component
public class DataUpload {

	private final static Logger logger = LoggerFactory.getLogger(com.bsth.realschedule.DataUpload.class.getName());
	
//	private final static String ip = "114.80.178.12:9089";
	private final static String ip = "10.10.150.24:9089";
	
	/**
	 * 实际排班信息（BusDispatch_TodayBusLineScheduleInfo）
	 * 云平台数据需求对接（建交委）
	 * @throws Exception
	 */
	@Scheduled(cron = "0 00 06 * * ? ")
	public void realScheduleUpload() throws Exception{
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		SimpleDateFormat sdf2 = new SimpleDateFormat("yyyyMMdd");
		long ts=new Date().getTime();
    	StringBuffer hexstr = new StringBuffer();
		MessageDigest md = MessageDigest.getInstance("SHA-1");
		String str = ts+"7da994576ccbe6ea1f8e83936d4da84820756b3a"+"a1503";
		md.update(str.getBytes());
		byte[] digest = md.digest();
		String shaHex = "";
		for (int i = 0; i < digest.length; i++) {
			shaHex = Integer.toHexString(digest[i] & 0xFF);
			if (shaHex.length() < 2) {
				hexstr.append(0);
			}
			hexstr.append(shaHex);
		}
		String sign =hexstr.toString();
		
		String[] strs = {"55", "22", "05", "26"};
		String rq = sdf2.format(sdf2.parse("20200820"));
		String accessToken = "abfed98867c64fde99f7f88a4532efa8";
		
		List<Map<String, Object>> resList = new ArrayList<Map<String, Object>>();
		
		for(int s = 0; s < strs.length; s++){
			String company = strs[s];
			
			String carJson= getHttpInterface("http://"+ip+"/webservice/rest/car/company/"+company+"?timestamp="+ts+"&nonce=a1503&password=7da994576ccbe6ea1f8e83936d4da84820756b3a&sign="+sign);
			List<Map<String, Object>> list_car=(List<Map<String, Object>>) JSONObject.parse(carJson);
			
	    	String json= getHttpInterface("http://"+ip+"/webservice/rest/schedule_real/sch_jk/"+company+"/"+rq+"?timestamp="+ts+"&nonce=a1503&password=7da994576ccbe6ea1f8e83936d4da84820756b3a&sign="+sign);
			List<Map<String, Object>> list_map=(List<Map<String, Object>>) JSONObject.parse(json);
			
			Map<String, Map<String, Object>> carMap = new HashMap<String, Map<String, Object>>();
			for(Map<String, Object> m : list_car){
				carMap.put(m.get("nbbm").toString(), m);
			}
			
			Map<String, List<Map<String, Object>>> keyMap = new HashMap<String, List<Map<String,Object>>>();
			List<String> keyList = new ArrayList<String>();
			
			for(Map<String, Object> m : list_map){
	//			System.out.println(m.get("scheduleDate") +" / " + m.get("lineName") +" / " + m.get("nbbm") + " / " + m.get("fcsjT"));
				String date = m.get("scheduleDate").toString();
				String lineCode = m.get("lineCode").toString();
				String lpName = m.get("lpName").toString();
				String nbbm = m.get("nbbm").toString();
				
				String key = date + "/" + lineCode + "/" + nbbm + "/" + lpName;
				
				if(keyMap.containsKey(key)){
					keyMap.get(key).add(m);
				} else {
					List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
					list.add(m);
					keyMap.put(key, list);
					keyList.add(key);
				}
			}
			
			for(String key : keyList){
				List<Map<String, Object>> list = keyMap.get(key);
				Collections.sort(list, new Comparator<Map<String, Object>>() {
					@Override
					public int compare(Map<String, Object> c1, Map<String, Object> c2) {
						
						long l1 = c1.get("fcsjT")!=null?Long.valueOf(c1.get("fcsjT").toString()):9000000000000000000l;
						long l2 = c2.get("fcsjT")!=null?Long.valueOf(c2.get("fcsjT").toString()):9000000000000000000l;
						
						long diff = l1 - l2;
						if (diff > 0l) {
							return 1;
						}else if (diff < 0l) {
							return -1;
						}
						return 0; //相等为0
					}
				});
				
				Map<String, Object> m = new HashMap<String, Object>();
				m.put("ScheduleDate", sdf.parse(list.get(0).get("scheduleDate").toString()));
				m.put("BusLineCode", list.get(0).get("lineCode"));
				m.put("BusLineName", list.get(0).get("lineName"));
				m.put("TemplateID", "");
				m.put("MainBusID", "");
				m.put("MainBusCode", "");
				m.put("MainBusNumber", "");//牌照号
				m.put("MainBusCompanyNumber", list.get(0).get("nbbm"));
				m.put("TerminalCode", "");//终端编码
				m.put("GuideBoardID", "");
				m.put("GuideBoardName", list.get(0).get("lpName"));
				
				if(carMap.containsKey(list.get(0).get("nbbm").toString())){
					Map<String, Object> map = carMap.get(list.get(0).get("nbbm").toString());
					m.put("MainBusNumber", map.get("carPlate")!=null?map.get("carPlate").toString():"");//牌照号
					m.put("TerminalCode", map.get("equipmentCode")!=null?map.get("equipmentCode").toString():"");//终端编码
				}
				
				Set<String> jsySpy = new HashSet<String>();
				List<String> strList = new ArrayList<String>();
	//			System.out.println("-------------------------");
				for(Map<String, Object> temp : list){
					String jsy = temp.get("jsy")!=null?temp.get("jsy").toString():"";
					String spy = temp.get("spy")!=null?temp.get("spy").toString():"";
					if(jsySpy.add(jsy + "_" + spy)){
						strList.add(jsy + "_" + spy);
	//					System.out.println(temp.get("fcsjT"));
					}
				}
				
				for(int i = 1; i <= 3; i++){
					m.put("DriverEmpCode" + i, "");
					m.put("ConductorEmpCode" + i, "");
					if(strList.size() >= i){
						String string = strList.get(i - 1);
						String[] split = string.split("_");
						if(split[0].length() > 1 && split[0].contains("/")){
							String[] jsy = split[0].split("/");
							m.put("DriverEmpName" + i, jsy[1]);
							m.put("DriverEmpNumber" + i, jsy[0]);
						} else {
							m.put("DriverEmpName" + i, "");
							m.put("DriverEmpNumber" + i, "");
						}
						if(split.length > 1 && split[1].length() > 1 && split[1].contains("/")){
							String[] spy = split[1].split("/");
							m.put("ConductorEmpName" + i, spy[1]);
							m.put("ConductorEmpNumber" + i, spy[0]);
						} else {
							m.put("ConductorEmpName" + i, "");
							m.put("ConductorEmpNumber" + i, "");
						}
					} else {
						m.put("DriverEmpName" + i, "");
						m.put("DriverEmpNumber" + i, "");
						m.put("ConductorEmpName" + i, "");
						m.put("ConductorEmpNumber" + i, "");
					}
				}
				resList.add(m);
			}
		}
		
		if(resList.size() > 0){
			List<List<Map<String, Object>>> listGroup = new ArrayList<List<Map<String, Object>>>();
			int size = resList.size();
			int index = 1000;
			for(int i = 0; i < size; i += index){
				if(i + index > size){
					index = size - i;
				}
				List<Map<String, Object>> newList = resList.subList(i, i + index);
				listGroup.add(newList);
			}
			
			String json= getHttpInterface("http://180.167.126.126:8992/api/getcode");
			Map<String, Object> map=(Map<String, Object>) JSONObject.parse(json);
			String token = encrypt(accessToken, map.get("result").toString());
			String deleteAll = "TRUE";
			
			for(List<Map<String, Object>> list : listGroup){
				Map<String, String> header = new HashMap<String, String>();
				header.put("Access-Token", token);
				Map<String, Object> param = new HashMap<String, Object>();
//				param.put("AccessToken", token);
//				param.put("DeleteAll", deleteAll);
//				param.put("DataList", JSON.toJSONString(list));
				param.put("list", URLEncoder.encode(JSON.toJSONStringWithDateFormat(list, "yyyy-MM-dd HH:mm:ss"), "UTF-8"));
//				HttpUtils.request("http://180.167.126.126:8992/api/todaybuslinescheduleinfo/addEntityList",
//						new BackClass(), "POST", header, param);
				deleteAll = "FALSE";
			}
			System.out.println(resList.size());
			logger.info("实际排班共上传：" + resList.size() + "条");
		}
	}
	
	/**
	 * 空驶里程(BusDispatch_UnCarryMileage)
	 * 云平台数据需求对接（建交委）
	 * @throws Exception
	 */
	@Scheduled(cron = "0 10 06 * * ? ")
	public void ksLcUpload() throws Exception{
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		SimpleDateFormat sdf2 = new SimpleDateFormat("yyyyMMdd");
		long ts=new Date().getTime();
    	StringBuffer hexstr = new StringBuffer();
		MessageDigest md = MessageDigest.getInstance("SHA-1");
		String str = ts+"7da994576ccbe6ea1f8e83936d4da84820756b3a"+"a1503";
		md.update(str.getBytes());
		byte[] digest = md.digest();
		String shaHex = "";
		for (int i = 0; i < digest.length; i++) {
			shaHex = Integer.toHexString(digest[i] & 0xFF);
			if (shaHex.length() < 2) {
				hexstr.append(0);
			}
			hexstr.append(shaHex);
		}
		String sign =hexstr.toString();
		
		String[] strs = {"55", "22", "05", "26"};
		String rq = sdf2.format(sdf2.parse("20200822"));
		String accessToken = "abfed98867c64fde99f7f88a4532efa8";
		
		List<Map<String, Object>> resList = new ArrayList<Map<String, Object>>();
		
		for(int s = 0; s < strs.length; s++){
			String company = strs[s];
			System.out.println(company);
			
			String lineJson= getHttpInterface("http://"+ip+"/webservice/rest/line/company/"+company+"?timestamp="+ts+"&nonce=a1503&password=7da994576ccbe6ea1f8e83936d4da84820756b3a&sign="+sign);
			List<Map<String, Object>> list_line=(List<Map<String, Object>>) JSONObject.parse(lineJson);
			
	    	String json= getHttpInterface("http://"+ip+"/webservice/rest/schedule_real/sch_jk/"+company+"/"+rq+"?timestamp="+ts+"&nonce=a1503&password=7da994576ccbe6ea1f8e83936d4da84820756b3a&sign="+sign);
			List<Map<String, Object>> list_map=(List<Map<String, Object>>) JSONObject.parse(json);
			
			Map<String, Map<String, Object>> lineMap = new HashMap<String, Map<String, Object>>();
			for(Map<String, Object> m : list_line){
				lineMap.put(m.get("lineCode").toString(), m);
			}
			
			Map<String, List<Map<String, Object>>> keyMap = new HashMap<String, List<Map<String,Object>>>();
			List<String> keyList = new ArrayList<String>();
			
			for(Map<String, Object> m : list_map){
				
				String date = m.get("scheduleDate").toString();
				String lineCode = m.get("lineCode").toString();
				String bcType = m.get("bcType")!=null?m.get("bcType").toString():"";
				
				String key = date + "/" + lineCode + "/" + bcType;
				
				if(keyMap.containsKey(key)){
					keyMap.get(key).add(m);
				} else {
					List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
					list.add(m);
					keyMap.put(key, list);
					keyList.add(key);
				}
			}
			
			for(String key : keyList){
				List<Map<String, Object>> list = keyMap.get(key);
				
				Map<String, Object> m = new HashMap<String, Object>();
				
				m.put("ReportDate", sdf.parse(list.get(0).get("scheduleDate").toString()));
				m.put("BusLineCode", list.get(0).get("lineCode"));
				m.put("BusLineName", list.get(0).get("lineName"));
				
				if(lineMap.get(list.get(0).get("lineCode").toString()) != null){
					Map<String, Object> map = lineMap.get(list.get(0).get("lineCode"));
					String gs = map.get("company")!=null?map.get("company").toString():"";
					String fgs = map.get("brancheCompany")!=null?map.get("brancheCompany").toString():"";
					m.put("CompanyCode", gs);
					m.put("SubCompanyCode", fgs);
					m.put("CompanyName", "");
					m.put("SubCompanyName", "");
					
					String gsFgsName = getGsFgsName(gs, fgs);
					if(gsFgsName.length() > 1){
						String[] split = gsFgsName.split("_");
						if(split.length > 1){
							m.put("CompanyName", split[0]);
							m.put("SubCompanyName", split[1]);
						}
					}
					
				} else {
					continue;
				}
				
				double kslc = 0;
				
				for(Map<String, Object> temp : list){
					List<Map<String, Object>> cTasks = (List<Map<String, Object>>)temp.get("cTasks");
					if(cTasks.size() > 0){
						for(Map<String, Object> task : cTasks){
							if("false".equals(task.get("destroy")!=null?task.get("destroy").toString():"")){
								if("empty".equals(task.get("mileageType")!=null?task.get("mileageType").toString():"")){
									kslc = Arith.add(kslc, task.get("mileage")==null?0:task.get("mileage"));
								}
							}
						}
					} else {
						String bcType = temp.get("bcType")!=null?temp.get("bcType").toString():"";
						if(bcType.equals("in") || bcType.equals("out") || bcType.equals("ldks")){
							if(temp.get("status") != null && !("-1".equals(temp.get("status").toString()))){
								kslc = Arith.add(kslc, temp.get("jhlc")==null?0:temp.get("jhlc"));
							}
						}
					}
				}
				if(kslc > 0d){
					m.put("Mileage", kslc);
					
					if("in".equals(list.get(0).get("bcType").toString())){
						m.put("MileageType", "进场");
					} else if("out".equals(list.get(0).get("bcType").toString())){
						m.put("MileageType", "出场");
					} else {
						m.put("MileageType", "其他");
					}
					
					resList.add(m);//2020-08-20：785条
				}
			}
		}
		
		if(resList.size() > 0){
			List<List<Map<String, Object>>> listGroup = new ArrayList<List<Map<String, Object>>>();
			int size = resList.size();
			int index = 1000;
			for(int i = 0; i < size; i += index){
				if(i + index > size){
					index = size - i;
				}
				List<Map<String, Object>> newList = resList.subList(i, i + index);
				listGroup.add(newList);
			}
			
			String json= getHttpInterface("http://180.167.126.126:8992/api/getcode");
			Map<String, Object> map=(Map<String, Object>) JSONObject.parse(json);
			String token = encrypt(accessToken, map.get("result").toString());
			String deleteAll = "TRUE";
			
			for(List<Map<String, Object>> list : listGroup){
				Map<String, String> header = new HashMap<String, String>();
				header.put("Access-Token", token);
				Map<String, Object> param = new HashMap<String, Object>();
//				param.put("AccessToken", token);
//				param.put("DeleteAll", deleteAll);
//				param.put("DataList", JSON.toJSONString(list));
				param.put("list", URLEncoder.encode(JSON.toJSONStringWithDateFormat(list, "yyyy-MM-dd HH:mm:ss"), "UTF-8"));
				HttpUtils.request("http://180.167.126.126:8992/api/busdispatchuncarrymileage/addEntityList",
						new BackClass(), "POST", header, param);
				deleteAll = "FALSE";
			}
			System.out.println(resList.size());
			logger.info("空驶里程共上传：" + resList.size() + "条");
		}
	}
	
	/**
	 * 烂班里程(BusDispatch_UnDoneMileage)
	 * 云平台数据需求对接（建交委）
	 * @throws Exception
	 */
	@Scheduled(cron = "0 20 06 * * ? ")
	public void lbLcUpload() throws Exception{
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		SimpleDateFormat sdf2 = new SimpleDateFormat("yyyyMMdd");
		long ts=new Date().getTime();
    	StringBuffer hexstr = new StringBuffer();
		MessageDigest md = MessageDigest.getInstance("SHA-1");
		String str = ts+"7da994576ccbe6ea1f8e83936d4da84820756b3a"+"a1503";
		md.update(str.getBytes());
		byte[] digest = md.digest();
		String shaHex = "";
		for (int i = 0; i < digest.length; i++) {
			shaHex = Integer.toHexString(digest[i] & 0xFF);
			if (shaHex.length() < 2) {
				hexstr.append(0);
			}
			hexstr.append(shaHex);
		}
		String sign =hexstr.toString();
		
		String[] strs = {"55", "22", "05", "26"};
		String rq = sdf2.format(sdf2.parse("20200822"));
		String accessToken = "abfed98867c64fde99f7f88a4532efa8";
		
		String[] lbTypes = {"路阻", "吊慢", "故障", "纠纷", "肇事", "缺人", "缺车", "客稀", "配车", "保养", "气候", "援外", "抽减", "其他"};
		
		List<Map<String, Object>> resList = new ArrayList<Map<String, Object>>();
		
		for(int s = 0; s < strs.length; s++){
			String company = strs[s];
			System.out.println(company);
			
			String lineJson= getHttpInterface("http://"+ip+"/webservice/rest/line/company/"+company+"?timestamp="+ts+"&nonce=a1503&password=7da994576ccbe6ea1f8e83936d4da84820756b3a&sign="+sign);
			List<Map<String, Object>> list_line=(List<Map<String, Object>>) JSONObject.parse(lineJson);
			
	    	String json= getHttpInterface("http://"+ip+"/webservice/rest/schedule_real/sch_jk/"+company+"/"+rq+"?timestamp="+ts+"&nonce=a1503&password=7da994576ccbe6ea1f8e83936d4da84820756b3a&sign="+sign);
			List<Map<String, Object>> list_map=(List<Map<String, Object>>) JSONObject.parse(json);
			
			Map<String, Map<String, Object>> lineMap = new HashMap<String, Map<String, Object>>();
			for(Map<String, Object> m : list_line){
				lineMap.put(m.get("lineCode").toString(), m);
			}
			
			Map<String, List<Map<String, Object>>> keyMap = new HashMap<String, List<Map<String,Object>>>();
			List<String> keyList = new ArrayList<String>();
			
			for(Map<String, Object> m : list_map){
				
				String date = m.get("scheduleDate").toString();
				String lineCode = m.get("lineCode").toString();
				
				String key = date + "/" + lineCode;
				
				if(keyMap.containsKey(key)){
					keyMap.get(key).add(m);
				} else {
					List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
					list.add(m);
					keyMap.put(key, list);
					keyList.add(key);
				}
			}
			
			for(String key : keyList){
				List<Map<String, Object>> list = keyMap.get(key);
				
				for(String lbType : lbTypes){
					
					Map<String, Object> m = new HashMap<String, Object>();
					
					m.put("ReportDate", sdf.parse(list.get(0).get("scheduleDate").toString()));
					m.put("BusLineCode", list.get(0).get("lineCode"));
					m.put("BusLineName", list.get(0).get("lineName"));
					m.put("MileageType", lbType);
					
					if(lineMap.get(list.get(0).get("lineCode").toString()) != null){
						Map<String, Object> map = lineMap.get(list.get(0).get("lineCode"));
						String gs = map.get("company")!=null?map.get("company").toString():"";
						String fgs = map.get("brancheCompany")!=null?map.get("brancheCompany").toString():"";
						m.put("CompanyCode", gs);
						m.put("SubCompanyCode", fgs);
						m.put("CompanyName", "");
						m.put("SubCompanyName", "");
						
						String gsFgsName = getGsFgsName(gs, fgs);
						if(gsFgsName.length() > 1){
							String[] split = gsFgsName.split("_");
							if(split.length > 1){
								m.put("CompanyName", split[0]);
								m.put("SubCompanyName", split[1]);
							}
						}
						
					} else {
						continue;
					}
					
					double lblc = 0;
					
					for(Map<String, Object> temp : list){
						if("true".equals(temp.get("sflj")!=null?temp.get("sflj").toString():"")){
							continue;
						}
						List<Map<String, Object>> cTasks = (List<Map<String, Object>>)temp.get("cTasks");
						if(cTasks.size() > 0){
							for(Map<String, Object> task : cTasks){
								if("true".equals(task.get("destroy")!=null?task.get("destroy").toString():"")){
									String destroyReason = task.get("destroyReason")!=null?task.get("destroyReason").toString().trim():"";
									if("其他".equals(lbType) && destroyReason.length() == 0){
										lblc = Arith.add(lblc, task.get("mileage")==null?0:task.get("mileage"));
									}
									if(lbType.equals(destroyReason)){
										lblc = Arith.add(lblc, task.get("mileage")==null?0:task.get("mileage"));
									}
								}
							}
						} else {
							String bcType = temp.get("bcType")!=null?temp.get("bcType").toString():"";
							if(bcType.equals("in") || bcType.equals("out") || bcType.equals("ldks")){
								continue;
							}
							if(temp.get("status") != null && "-1".equals(temp.get("status").toString())){
								String adjustExps = temp.get("adjustExps")!=null?temp.get("adjustExps").toString().trim():"";
								if("其他".equals(lbType) && adjustExps.length() == 0){
									lblc = Arith.add(lblc, temp.get("mileage")==null?0:temp.get("mileage"));
								}
								if(lbType.equals(adjustExps)){
									lblc = Arith.add(lblc, temp.get("mileage")==null?0:temp.get("mileage"));
								}
							} else if("其他".equals(lbType)){
								String jhlc = temp.get("jhlc")!=null?temp.get("jhlc").toString():"0";
								String jhlcOrig = temp.get("jhlcOrig")!=null?temp.get("jhlcOrig").toString():"0";
								double sub = Arith.sub(jhlcOrig,jhlc);
								if(sub > 0){
									lblc = Arith.add(lblc, sub);
								}
							}
						}
					}
					if(lblc > 0d){
						m.put("Mileage", lblc);
						m.put("MileageType", lbType);
						
						resList.add(m);//2020-08-20：63条
					}
				}
			}
		}
		
		if(resList.size() > 0){
			List<List<Map<String, Object>>> listGroup = new ArrayList<List<Map<String, Object>>>();
			int size = resList.size();
			int index = 1000;
			for(int i = 0; i < size; i += index){
				if(i + index > size){
					index = size - i;
				}
				List<Map<String, Object>> newList = resList.subList(i, i + index);
				listGroup.add(newList);
			}
			
			String json= getHttpInterface("http://180.167.126.126:8992/api/getcode");
			Map<String, Object> map=(Map<String, Object>) JSONObject.parse(json);
			String token = encrypt(accessToken, map.get("result").toString());
			String deleteAll = "TRUE";
			
			for(List<Map<String, Object>> list : listGroup){
				Map<String, String> header = new HashMap<String, String>();
				header.put("Access-Token", token);
				Map<String, Object> param = new HashMap<String, Object>();
//				param.put("AccessToken", token);
//				param.put("DeleteAll", deleteAll);
//				param.put("DataList", JSON.toJSONString(list));
				param.put("list", URLEncoder.encode(JSON.toJSONStringWithDateFormat(list, "yyyy-MM-dd HH:mm:ss"), "UTF-8"));
				HttpUtils.request("http://180.167.126.126:8992/api/busdispatchundonemileage/addEntityList",
						new BackClass(), "POST", header, param);
				deleteAll = "FALSE";
			}
			System.out.println(resList.size());
			logger.info("烂班里程共上传：" + resList.size() + "条");
		}
	}
	
	
	public static String getHttpInterface(String path){
        BufferedReader in = null;
        StringBuffer result = null;
        try {
            URL url = new URL(path);
            //打开和url之间的连接
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
            connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
            connection.setRequestProperty("Charset", "utf-8");
            connection.connect();

            result = new StringBuffer();
            //读取URL的响应
            in = new BufferedReader(new InputStreamReader(
                    connection.getInputStream(),"utf-8"));
            String line;
            while ((line = in.readLine()) != null) {
                result.append(line);
            }
            return result.toString();
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try {
                if (in != null) {
                    in.close();
                }
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }
        return null;
    }
	
	public static String encrypt(String token, String code) throws Exception {
		if (token.length() != 32) throw new Exception("token 长度不正确");
		code = padRight(code, 16, '0');
		String tmpToken = "";
		for (int i = 0; i < 8; i++){
			String subString = code.substring(i * 2, (i + 1) * 2);
			tmpToken += subString + token.substring(i * 4, (i + 1) * 4);
		}
		int pos = tmpToken.length() / 2;
		tmpToken = tmpToken.substring(pos) + tmpToken.substring(0, pos);
		
		pos = tmpToken.length() / 4;
		tmpToken = tmpToken.substring(pos * 3) + tmpToken.substring(pos, pos * 3) + tmpToken.substring(0, pos);
		return URLEncoder.encode(tmpToken, "GBK");
	}
	
	public static String padRight(String s, int len, char ch){
		int diff = len - s.length();
		if(diff <= 0){
			return s;
		}
		
		char[] charr = new char[len];
		System.arraycopy(s.toCharArray(), 0, charr, 0, s.length());
		for(int i = s.length(); i < len; i++){
			charr[i] = ch;
		}
		
		return new String(charr);
	}
	
	public static String getGsFgsName(String gs, String fgs){
		String gsFgs = "";
		if("22".equals(gs)){
			gsFgs += "金高公司_";
			
			if("1".equals(fgs)){
				gsFgs += "四分公司";
				return gsFgs;
			} else if("2".equals(fgs)){
				gsFgs += "二分公司";
				return gsFgs;
			} else if("3".equals(fgs)){
				gsFgs += "三分公司";
				return gsFgs;
			} else if("5".equals(fgs)){
				gsFgs += "一分公司";
				return gsFgs;
			}
		} else if("26".equals(gs)){
			gsFgs += "南汇公司_";
			
			if("1".equals(fgs)){
				gsFgs += "南汇一分";
				return gsFgs;
			} else if("2".equals(fgs)){
				gsFgs += "南汇二分";
				return gsFgs;
			} else if("3".equals(fgs)){
				gsFgs += "南汇三分";
				return gsFgs;
			} else if("4".equals(fgs)){
				gsFgs += "南汇维修公司";
				return gsFgs;
			} else if("5".equals(fgs)){
				gsFgs += "南汇公司";
				return gsFgs;
			} else if("6".equals(fgs)){
				gsFgs += "南汇六分";
				return gsFgs;
			}
		} else if("55".equals(gs)){
			gsFgs += "上南公司_";
			
			if("1".equals(fgs)){
				gsFgs += "上南二分公司";
				return gsFgs;
			} else if("2".equals(fgs)){
				gsFgs += "上南三分公司";
				return gsFgs;
			} else if("3".equals(fgs)){
				gsFgs += "上南六分公司";
				return gsFgs;
			} else if("4".equals(fgs)){
				gsFgs += "上南一分公司";
				return gsFgs;
			}
		} else if("05".equals(gs)){
			gsFgs += "杨高公司_";
			
			if("1".equals(fgs)){
				gsFgs += "川沙分公司";
				return gsFgs;
			} else if("2".equals(fgs)){
				gsFgs += "金桥分公司";
				return gsFgs;
			} else if("3".equals(fgs)){
				gsFgs += "芦潮港分公司";
				return gsFgs;
			} else if("5".equals(fgs)){
				gsFgs += "杨高分公司";
				return gsFgs;
			} else if("6".equals(fgs)){
				gsFgs += "周浦分公司";
				return gsFgs;
			}
		}
		return "";
	}
	
}