http文件导出写文件

public class ?ReadExcel{ ???private String filePath; ???private List<String[]> list = new ArrayList(); ???public ReadExcel(String filePath){ ???????this.filePath = filePath; ???} ???public List<String[]> readExcel() throws IOException, BiffException{ ???????//创建输入流 ?????????InputStream stream = new FileInputStream(filePath); ???????//获取Excel文件对象 ?????????Workbook ?rwb = Workbook.getWorkbook(stream); ???????//获取文件的指定工作表 默认的第一个 ?????????Sheet sheet = rwb.getSheet(0); ???????//行数(表头的目录不需要，从1开始) ?????????for(int i=0; i<sheet.getRows(); i++){ ???????????//创建一个数组 用来存储每一列的值 ???????????String[] str = new String[sheet.getColumns()]; ???????????Cell cell = null; ???????????//列数 ?????????????for(int j=0; j<sheet.getColumns(); j++){ ???????????????//获取第i行，第j列的值 ???????????????cell = sheet.getCell(j,i); ???????????????str[j] = cell.getContents(); ???????????} ???????????//把刚获取的列存入list ???????????list.add(str); ???????} ???????return list; ???} ???public void outData(){ ???????for(int i=0;i<list.size();i++){ ???????????String[] str = (String[])list.get(i); ???????????for(int j=0;j<str.length;j++){ ???????????????System.out.print(str[j]+‘\t‘); ???????????} ???????????System.out.println(); ???????} ???} ???public static void main(String args[]) throws BiffException, IOException{ ???????ReadExcel excel = new ReadExcel("C:\\Users\\hasee\\Documents\\263EM\\108251@ycgwl.com\\receive_file\\aa.xls"); ???????excel.readExcel(); ???????excel.outData(); ???}}

public class FileOperation { ???/** ????* 创建文件 ????* @param fileName ????* @return ????*/ ???public static boolean createFile(File fileName)throws Exception{ ???????boolean flag=false; ???????try{ ???????????if(!fileName.exists()){ ???????????????fileName.createNewFile(); ???????????????flag=true; ???????????} ???????}catch(Exception e){ ???????????e.printStackTrace(); ???????} ???????return true; ???} ???/** ????* 读TXT文件内容 ????* @param fileName ????* @return ????*/ ???public static String readTxtFile(File fileName)throws Exception{ ???????String result=null; ???????FileReader fileReader=null; ???????BufferedReader bufferedReader=null; ???????try{ ???????????fileReader=new FileReader(fileName); ???????????bufferedReader=new BufferedReader(fileReader); ???????????try{ ???????????????String read=null; ???????????????while((read=bufferedReader.readLine())!=null){ ???????????????????result=result+read+"\r\n"; ???????????????} ???????????}catch(Exception e){ ???????????????e.printStackTrace(); ???????????} ???????}catch(Exception e){ ???????????e.printStackTrace(); ???????}finally{ ???????????if(bufferedReader!=null){ ???????????????bufferedReader.close(); ???????????} ???????????if(fileReader!=null){ ???????????????fileReader.close(); ???????????} ???????} ???????System.out.println("读取出来的文件内容是："+"\r\n"+result); ???????return result; ???} ???public static boolean writeTxtFile(String content,File ?fileName)throws Exception{ ???????RandomAccessFile mm=null; ???????boolean flag=false; ???????FileOutputStream o=null; ???????try { ???????????o = new FileOutputStream(fileName); ???????????o.write(content.getBytes("GBK")); ???????????o.close();// ??mm=new RandomAccessFile(fileName,"rw");// ??mm.writeBytes(content); ???????????flag=true; ???????} catch (Exception e) { ???????????// TODO: handle exception ???????????e.printStackTrace(); ???????}finally{ ???????????if(mm!=null){ ???????????????mm.close(); ???????????} ???????} ???????return flag; ???} ???public static void contentToTxt(String filePath, String content) { ???????String str = new String(); //原有txt内容 ???????String s1 = new String();//内容更新 ???????try { ???????????File f = new File(filePath); ???????????if (f.exists()) { ???????????????System.out.print("文件存在"); ???????????} else { ???????????????System.out.print("文件不存在"); ???????????????f.createNewFile();// 不存在则创建 ???????????} ???????????BufferedReader input = new BufferedReader(new FileReader(f)); ???????????while ((str = input.readLine()) != null) { ???????????????s1 += str + "\n"; ???????????} ???????????System.out.println(s1); ???????????input.close(); ???????????s1 += content; ???????????BufferedWriter output = new BufferedWriter(new FileWriter(f)); ???????????output.write(s1); ???????????output.close(); ???????} catch (Exception e) { ???????????e.printStackTrace(); ???????} ???}}

@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration(locations = {"classpath:spring/spring-context.xml"})public class HttpClientUtil { ???private String excelUrl = "C:\\Users\\hasee\\Documents\\263EM\\108251@ycgwl.com\\receive_file\\aa.xls"; ???@Autowired ???private IPpApiService ppApiService; ???@Autowired ???private IBaseRedisCacheService baseRedisCacheService; ???private static MultiThreadedHttpConnectionManager connectionManager = new MultiThreadedHttpConnectionManager(); ???private static final int TIMEOUT = 5 * 1000000;//5 * 1000 ???// ???????????StringUtils.strToInteger(propFactory.getConfig("max_http_connection"), 50);// 50 ???private static final int MAX_HTTP_CONNECTION = 50; ???private static final int MAX_CONNECTION_PER_HOST = 10;// 10 ???private static final String CHARSET_UTF8 = "UTF-8"; ???private static HttpClientUtil instance = null; ???private static final String APP_KEY = "BOS"; ???private static final String APP_SECRET = "WREW223421FDR134R"; ???// ?private static Logger logger = Logger.getLogger(HttpClientUtil.class); ???static { ???????//HttpClient 连接池属性设置，HOST并发数默认为50, 客户端总并发数为200, TimeOut时间为5s. ???????HttpConnectionManagerParams httpConnectionManagerParams = new HttpConnectionManagerParams(); ???????// 文档参数说明：Sets the maximum number of connections allowed. ???????httpConnectionManagerParams.setMaxTotalConnections(MAX_HTTP_CONNECTION); ???????// 文档参数说明： Sets the default maximum number of connections allowed for a given host config. ???????httpConnectionManagerParams.setDefaultMaxConnectionsPerHost(MAX_CONNECTION_PER_HOST); ???????// 读取数据超时时间 ???????httpConnectionManagerParams.setSoTimeout(TIMEOUT); ???????// 连接超时时间 ???????httpConnectionManagerParams.setConnectionTimeout(TIMEOUT); ???????connectionManager.setParams(httpConnectionManagerParams); ???} ???public HttpClientUtil() { ???} ???public static HttpClientUtil getInstance() { ???????if (null == instance) { ???????????synchronized (HttpClientUtil.class) { ???????????????if (instance == null) { ???????????????????instance = new HttpClientUtil(); ???????????????} ???????????} ???????} ???????return instance; ???} ???public HttpClient createHttpClient() { ???????HttpClient httpClient = new HttpClient(connectionManager); ???????return httpClient; ???} ???/** ????* 进行 http请求返回String结果 ????* ????* @param url ????* @return ????*/ ???public String getHttpClientJson(String url) { ???????HttpClient httpClient = createHttpClient(); ???????GetMethod getMethod = new GetMethod(url); ???????try { ???????????httpClient.executeMethod(getMethod); ???????????InputStreamReader in = new InputStreamReader(getMethod.getResponseBodyAsStream(), ???????????????????HttpClientUtil.CHARSET_UTF8); ???????????// ???????????String jsonString = getMethod.getResponseBodyAsString(); ???????????String jsonString = getStringByParams(in); ???????????return jsonString; ???????} catch (Exception e) { ????????????/* ??logger.error("Http Client GetMethod Execute is Exception , Message = " + e.getMessage(), e);*/ ???????????return "{\"msg\":\"获取账户余额信息失败！\",\"success\":\"false\"}"; ???????} finally { ???????????if (getMethod != null) ???????????????getMethod.releaseConnection(); ???????} ???} ???/** ????* 进行 http post请求返回String结果 ????* ????* @param url ????* @return ????*/ ???public String postHttpClientJson(String url, String params) { ???????HttpClient httpClient = createHttpClient(); ???????PostMethod postMethod = getPostMethod(url, params); ???????try { ???????????//logger.info(" Request Navigate Url is : " + url); ???????????httpClient.executeMethod(postMethod); ???????????// ???????????String jsonString = postMethod.getResponseBodyAsString(); ???????????InputStreamReader in = new InputStreamReader(postMethod.getResponseBodyAsStream(), ???????????????????HttpClientUtil.CHARSET_UTF8); ???????????String jsonString = getStringByParams(in); ???????????// 当地址端口错误时，返回为空，为防止Json解析异常 ???????????if (jsonString == null || "".equals(jsonString)) { ???????????????jsonString = "[{\"msg\":\"获取折扣信息失败！\",\"success\":\"false\"}]"; ???????????} ???????????return jsonString; ???????} catch (Exception e) { ???????????// ?logger.error("Http Client PostMethod Execute is Exception , Message = " + e.getMessage(), e); ???????????return e.getMessage(); ???????} finally { ???????????if (postMethod != null) ???????????????postMethod.releaseConnection(); ???????} ???} ???/** ????* @param params ????* @return List<NameValuePair> ???返回类型 ????* @throws ????* @Title: getCheckParam ????* @Description: (设置验证参数) ????*/ ???private List<NameValuePair> getCheckParam(String params) { ???????String digest = SecurityUtil.getDigest(params + APP_KEY + APP_SECRET); ???????String timestamp = "" + new Date().getTime(); ???????final List<NameValuePair> nameValueList = new ArrayList<NameValuePair>(); ???????// 接口调用的请求格式 ???????nameValueList.add(new NameValuePair("params", params)); ???????nameValueList.add(new NameValuePair(Constants.DEFAULT_ALP_DIGEST_NAME, digest)); ???????nameValueList.add(new NameValuePair(Constants.DEFAULT_ALP_TIMESTAMP_NAME, timestamp)); ???????nameValueList.add(new NameValuePair("appkey", APP_KEY)); ???????return nameValueList; ???} ???/** ????* @param url ????* @param params ????* @return PostMethod ???返回类型 ????* @throws ????* @Title: getPostMethod ????* @Description: (设置params参数) ????*/ ???private PostMethod getPostMethod(String url, String params) { ???????PostMethod postMethod = new PostMethod(url); ???????List<NameValuePair> nameValueList = getCheckParam(params); ???????postMethod.addRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8"); ???????postMethod.setRequestBody(nameValueList.toArray(new NameValuePair[nameValueList.size()])); ???????// ???????postMethod.addRequestHeader("Connection", "close"); ???????return postMethod; ???} ???/** ????* @param in ????* @return String ???返回类型 ????* @throws IOException ????* @throws ????* @Title: getStringByParams ????* @Description: (将流文件转换成字符) ????*/ ???private String getStringByParams(InputStreamReader in) throws IOException { ???????BufferedReader reader = new BufferedReader(in); ???????StringBuffer stringBuffer = new StringBuffer(); ???????String str = ""; ???????while ((str = reader.readLine()) != null) { ???????????stringBuffer.append(str); ???????} ???????String ts = stringBuffer.toString(); ???????return ts; ???} ???public String getParams(String siteCode) { ???????StringBuilder str = new StringBuilder(); ???????str.append("{"); ???????str.append("\"siteCode\":\"" + siteCode + "\""); ???????str.append("}"); ???????return str.toString(); ???} ???@Test ???public void test0(){ ???} ???@Test ???public void test() throws Exception { ???????HttpClientUtil hcu = HttpClientUtil.getInstance(); ???????String url2 = "http://fo.ycgwl.com/rosefinch-web/ppapi/rest/queryFreightCount.api"; ???????List<DiscountOrPriceEntity> list = getList(); ???????StringBuilder sb = new StringBuilder(); ???????for (DiscountOrPriceEntity entity : list) { ???????????if (entity.getSendSiteCode() != null) { ???????????????entity.setFromTime(new Date()); ???????????????String params = JSON.toJSONString(entity); ???????????????String result2 = hcu.postHttpClientJson(url2, params); ???????????????try { ???????????????????DiscountOrPriceReturnEntity discountOrPriceReturnEntity = JSON.parseObject(result2, DiscountOrPriceReturnEntity.class); ???????????????????sb.append(discountOrPriceReturnEntity.getPrice()+"\n"); ???????????????} catch (Exception ex) { ???????????????????sb.append(result2+"\n"); ???????????????} ???????????} else { ???????????????sb.append("发件网点或派件网点不存在"+"\n"); ???????????} ???????} ???????FileOperation.writeTxtFile(sb.toString(), new File("C:\\Users\\hasee\\Documents\\263EM\\108251@ycgwl.com\\receive_file\\aa.txt")); ???} ???@Test ???public void testOne(){ ???????HttpClientUtil hcu = HttpClientUtil.getInstance(); ???????String url2 = "http://fo.ycgwl.com/rosefinch-web/ppapi/rest/queryFreightCount.api"; ???????DiscountOrPriceEntity entity = new DiscountOrPriceEntity(); ???????entity.setSendSiteCode("TMS008"); ???????entity.setDispatchSiteCode("Z03419"); ???????entity.setCalcWeight(405.0); ???????entity.setFromTime(new Date()); ???????String params = JSON.toJSONString(entity); ???????String result2 = hcu.postHttpClientJson(url2, params); ???????System.out.println(result2); ???} ???private List<DiscountOrPriceEntity> getList() throws IOException, BiffException { ???????ReadExcel readExcel = new ReadExcel(excelUrl); ???????final List<String[]> strings = readExcel.readExcel(); ???????List<DiscountOrPriceEntity> discountOrPriceEntities = new ArrayList<>(); ???????int i = 0; ???????for (String[] ary : strings) { ???????????if (i == 0) { ???????????????i++; ???????????????continue; ???????????} ???????????i++; ??????????/* if (i ==100) { ???????????????return discountOrPriceEntities; ???????????}*/ ???????????DiscountOrPriceEntity entity = new DiscountOrPriceEntity(); ???????????String sendSite = ary[2]; ???????????String destination = ary[4]; ???????????Double weight = Double.parseDouble(ary[9]); ???????????if (StringUtils.isNotEmpty(sendSite)) { ???????????????BaseSiteEntity baseSiteEntityNameFromCache = this.baseRedisCacheService.getBaseSiteEntityNameFromCache(sendSite); ???????????????if (baseSiteEntityNameFromCache == null) { ???????????????????entity.setSendSiteCode(null); ???????????????} else { ???????????????????entity.setSendSiteCode(baseSiteEntityNameFromCache.getSiteCode()); ???????????????} ???????????} else { ???????????????entity.setSendSiteCode(null); ???????????} ???????????if (StringUtils.isNotEmpty(destination)) { ???????????????BaseSiteEntity baseSiteEntityNameFromCache1 = this.baseRedisCacheService.getBaseSiteEntityNameFromCache(destination); ???????????????if (baseSiteEntityNameFromCache1 == null) { ???????????????????entity.setSendSiteCode(null); ???????????????} else { ???????????????????entity.setDispatchSiteCode(baseSiteEntityNameFromCache1.getSiteCode()); ???????????????} ???????????} else { ???????????????entity.setSendSiteCode(null); ???????????} ???????????entity.setCalcWeight(weight); ???????????discountOrPriceEntities.add(entity); ???????????System.out.println("拼装完成"+i+"个"); ???????} ???????return discountOrPriceEntities; ???}}