package com.hy; import java.io.BufferedReader; import java.io.FileInputStream; import java.io.InputStreamReader; public class TiQuUtil { public static String patchFile="C:/Users/Administrator/Desktop/20190214/147/接口订单号.txt";//补丁文件路径 public static String patchFile1="C:/Users/Administrator/Desktop/20190214/147/出票成功订单.txt";//补丁文件路径 /** * @param args * @throws Exception */ public static void main(String[] args) throws Exception { b(); } @SuppressWarnings("unused") private static void a5() throws Exception { String line; String errorInfo = ""; FileInputStream f = new FileInputStream("C:/Users/Administrator/Desktop/数据整理/test.txt"); BufferedReader dr = new BufferedReader(new InputStreamReader(f,"utf-8")); while((line=dr.readLine())!=null){ line=line.replaceAll("\\s*", ""); /*String mainOrderId = line.split(",")[0]; String agentId = line.split(",")[2]; System.out.println("update TrainOrderOffline set agentid="+agentId+" where OrderNumber = '"+mainOrderId+"';");*/ System.out.print("'"+line+"',"); } } @SuppressWarnings("unused") private static void a3() throws Exception { String line; String errorInfo = ""; FileInputStream f = new FileInputStream("C:/Users/Administrator/Desktop/数据整理/下单接受成功未入库ID.txt"); BufferedReader dr = new BufferedReader(new InputStreamReader(f,"utf-8")); while((line=dr.readLine())!=null){ line=line.replaceAll("\\s*", ""); String mainOrderId = line.split(",")[0]; String id = line.split(",")[1]; FileInputStream f1 = new FileInputStream("C:/Users/Administrator/Desktop/数据整理/线下票_公共出票部分_panDuanChupiao.log"); BufferedReader dr1 = new BufferedReader(new InputStreamReader(f1,"utf-8")); String chupaioData = ""; String line1 = ""; while((line1=dr1.readLine())!=null){ try { if(line1.indexOf(id+"_出票点回填出票信息_车厢号:") != -1){ line1=line1.replaceAll("\\s*", ""); chupaioData += line1.substring(line1.indexOf(id+"_出票点回填出票信息_车厢号:")+18, line1.indexOf(";expressNum"))+","; } } catch (Exception e) { errorInfo += line1+","; } } if(chupaioData.equals("")){ System.out.println(line); }else{ String[] strs = chupaioData.substring(0, chupaioData.length()-1).split(","); for (int i = 0; i < strs.length; i++) { String SeatNo = ""; String Coach = ""; String sealPrice = ""; String ticketNo = "1"; String realSeat = ""; String[] a = strs[i].split(";"); for (String str : a) { if(str.indexOf("座位号") != -1) SeatNo = str.split(":")[1]; if(str.indexOf("车厢号") != -1) Coach = str.split(":")[1]; if(str.indexOf("出票价格") != -1) sealPrice = str.split(":")[1]; if(str.indexOf("票号") != -1) ticketNo = str.split(":")[1]; if(str.indexOf("realSeat") != -1) realSeat = str.split(":")[1]; } } } } } @SuppressWarnings("unused") private static void a2() throws Exception { String line; String ids = ""; String errorInfo = ""; FileInputStream f = new FileInputStream("C:/Users/Administrator/Desktop/数据整理/下单接受成功未入库.txt"); BufferedReader dr = new BufferedReader(new InputStreamReader(f,"utf-8")); /*while((line=dr.readLine())!=null){ try { if(line.indexOf("reqData") != -1){ line=line.replaceAll("\\s*", ""); line=line.substring(line.indexOf("main_order_id")+15, line.length()); line=line.substring(0, line.indexOf("}")); ids += "'"+line+"',"; } } catch (Exception e) { errorInfo += line+","; } } System.out.println(ids.split(",").length); System.out.println(ids); System.out.println(errorInfo);*/ System.out.print("["); while((line=dr.readLine())!=null){ try { if(line.indexOf("reqData") != -1){ System.out.println(line.substring(line.indexOf("reqData")+10, line.length())+","); } } catch (Exception e) { errorInfo += line+","; } } System.out.print("]"); } @SuppressWarnings("unused") private static void a4() throws Exception { String line; String ids = ""; String errorInfo = ""; FileInputStream f = new FileInputStream("C:/Users/Administrator/Desktop/数据整理/下单接受成功未入库数据.txt"); BufferedReader dr = new BufferedReader(new InputStreamReader(f,"utf-8")); System.out.print("["); while((line=dr.readLine())!=null){ System.out.print(line); } System.out.print("]"); } @SuppressWarnings("unused") private static void a() throws Exception { String line; String ids = ""; String errorInfo = ""; FileInputStream f = new FileInputStream(patchFile); BufferedReader dr = new BufferedReader(new InputStreamReader(f,"utf-8")); while((line=dr.readLine())!=null){ try { if(line.indexOf("main_order_id") != -1){ line=line.replaceAll("\\s*", ""); line=line.substring(line.indexOf("main_order_id")+14, line.length()); line=line.substring(0, line.indexOf(",")); ids += "'"+line+"',"; } } catch (Exception e) { errorInfo += line+","; } } System.out.println(ids.split(",").length); System.out.println(ids); System.out.println(errorInfo); } @SuppressWarnings("unused") private static void a1() throws Exception { String line; String ids = ""; String errorInfo = ""; FileInputStream f = new FileInputStream("C:/Users/Administrator/Desktop/数据整理/下单接受成功未入库.txt"); BufferedReader dr = new BufferedReader(new InputStreamReader(f,"utf-8")); /*while((line=dr.readLine())!=null){ try { if(line.indexOf("reqData") != -1){ line=line.replaceAll("\\s*", ""); line=line.substring(line.indexOf("main_order_id")+15, line.length()); line=line.substring(0, line.indexOf("}")); ids += "'"+line+"',"; } } catch (Exception e) { errorInfo += line+","; } } System.out.println(ids.split(",").length); System.out.println(ids); System.out.println(errorInfo);*/ System.out.print("["); while((line=dr.readLine())!=null){ try { if(line.indexOf("reqData") != -1){ System.out.println(line.substring(line.indexOf("reqData")+10, line.length())+","); } } catch (Exception e) { errorInfo += line+","; } } System.out.print("]"); } /** * 提取出票失败的接口订单号 * @throws Exception */ @SuppressWarnings("resource") private static void b() throws Exception{ String line; String ids = ""; String idss = ""; String errorInfo = ""; String noids = ""; FileInputStream f = new FileInputStream("C:/Users/Administrator/Desktop/数据整理/test.txt"); BufferedReader dr = new BufferedReader(new InputStreamReader(f,"utf-8")); while((line=dr.readLine())!=null){ /*try { if(line.indexOf("main_order_id") != -1){ line=line.replaceAll("\\s*", ""); line=line.substring(line.indexOf("main_order_id")+14, line.length()); ids+=line.substring(0, line.indexOf(",")+1); } } catch (Exception e) { errorInfo += line+","; }*/ ids+=line+","; } FileInputStream f1 = new FileInputStream("C:/Users/Administrator/Desktop/数据整理/test1.txt"); BufferedReader dr1 = new BufferedReader(new InputStreamReader(f1,"utf-8")); while((line=dr1.readLine()) != null){ try { idss+=line.replaceAll("\\s*", "")+","; } catch (Exception e) { errorInfo += line+","; } } for (String str : ids.split(",")) { boolean is = false; for (String strs : idss.split(",")) { if(strs.equals(str)){ is = true; break; } } if(!is){ System.out.println(str); noids += str+","; } } System.out.println(noids.split(",").length); System.out.println(noids); System.out.println(errorInfo); } /** * * @throws Exception */ @SuppressWarnings("resource") private static void c() throws Exception{ String line; String ids = ""; String idss = ""; String errorInfo = ""; String noids = ""; FileInputStream f = new FileInputStream(patchFile); BufferedReader dr = new BufferedReader(new InputStreamReader(f,"utf-8")); while((line=dr.readLine())!=null){ try { if(line.indexOf("main_order_id") != -1){ line=line.replaceAll("\\s*", ""); line=line.substring(line.indexOf("main_order_id")+14, line.length()); ids+=line.substring(0, line.indexOf(",")+1); } } catch (Exception e) { errorInfo += line+","; } } FileInputStream f1 = new FileInputStream(patchFile1); BufferedReader dr1 = new BufferedReader(new InputStreamReader(f1,"utf-8")); while((line=dr1.readLine()) != null){ try { idss+=line.replaceAll("\\s*", "")+","; } catch (Exception e) { errorInfo += line+","; } } for (String str : ids.split(",")) { boolean is = false; for (String strs : idss.split(",")) { if(strs.equals(str)){ is = true; break; } } if(!is){ System.out.println(str); } } System.out.println(noids.split(",").length); System.out.println(noids); System.out.println(errorInfo); } }