manage_invoice/src/main/java/com/jkcredit/invoice/util/QueryDemo_3rd3.java

package com.jkcredit.invoice.util;

import net.sf.json.JSONObject;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.NameValuePair;
import org.apache.commons.httpclient.methods.PostMethod;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.LineNumberReader;
import java.util.HashMap;
import java.util.Iterator;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

public class QueryDemo_3rd3 {

    /**
     * 测试地址
     */
    private static final String URL = "http://127.0.0.1:18081/api/rest";

    /**
     * 分配的appKey
     */
    private static final String appKey = "data_test";

    static String filename = "/Users/mashengyi/Downloads/";
    static String logname = "请求参数.txt";

    /**
     * 方法入口
     *
     * @param args
     */

    public static void main(String args[]) throws Exception {

        QueryDemo_3rd3 demo = new QueryDemo_3rd3();



        int count = 0;
        int total = 0;

        HashMap hashMap = new HashMap();

        try {
            File file = new File(filename + logname);
            FileInputStream fis = new FileInputStream(file);
            InputStreamReader isr = new InputStreamReader(fis, "UTF-8");
            LineNumberReader lr = new LineNumberReader(isr, 512);
            String laststr = "";
            int count_d = 0;
            int total_d = 0;
            while (true) {

                String str = lr.readLine();

                try {
                    if (str == null)
                        break;
                    String base64Str = str.replaceAll(" ", "+");
                    System.out.println(base64Str);

                    com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(str);
                   com.alibaba.fastjson.JSONObject jsonObject1 = jsonObject.getJSONObject("data");

                    demo.runMainService(jsonObject.getString("waybillFileName"),jsonObject.getInteger("contractType"),jsonObject.getString("base64Str"));


                    /**	if(str.contains("18:")){
                     continue;
                     }
                     if(str.contains("requestid")|| str.contains("未解密成功")){
                     System.out.println(str);
                     }

                     if( str.contains("未解密成功")){
                     System.out.println(str);
                     continue;
                     }
                     String str1 = getsrt("\"msg\":\"", "\"", str);
                     System.out.println(str1);**/

                  //  String mobile = getsrt("tradeIds=[", "]},", str).trim();
                  //  System.out.println(mobile);
                    //String idcard = getsrt("idcard:", "name:", str).trim();

                    //String name = getsrt1("name:",str).trim();


                    //demo.runMainService(name,idcard,mobile);

                } catch (Exception e) {

                    System.out.println("无法解析：" + str);
                }
            }
            lr.close();

        } catch (FileNotFoundException e) {
            System.out.println("FILENAME:" + filename);
            System.out.println("File not found");
        } catch (IOException e) {
            System.out.println("IO error");
        }

        Iterator it = hashMap.keySet().iterator();

        while (it.hasNext()) {

            String key = (String) it.next();
            Integer ttttttt = (Integer) hashMap.get(key);

            System.out.println(key + "====" + ttttttt);
        }

    }

    public static String getsrt(String startkeystr, String endstr, String str) {
        int customerindex = str.indexOf(startkeystr);
        String temp = str.substring(customerindex + startkeystr.length());
        int endindex = temp.indexOf(endstr);
        String sss = temp.substring(0, endindex);
        return sss;
    }

    public static String getsrt1(String startkeystr, String str) {
        int customerindex = str.indexOf(startkeystr);
        String temp = str.substring(customerindex + startkeystr.length());
        return temp;
    }

    /**
     * 利用正则表达式判断字符串是否是数字
     *
     * @param str
     * @return
     */
    public static boolean isNumeric(String str) {
        Pattern pattern = Pattern.compile("[0-9]*");
        Matcher isNum = pattern.matcher(str);
        if (!isNum.matches()) {
            return false;
        }
        return true;
    }

    /**
     * 调用主接口
     */
    public void runMainService(String name,Integer idcard,String mobile) {
        try {
            /**
             * 实名demo
             */

                JSONObject paramJsonObj = initParamJsonObj_Realname(name,idcard,mobile);
                String ret = postClient(URL, paramJsonObj);
                System.out.println(ret);


        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 整合参数(实名认证)
     *
     * @return
     */
    public JSONObject initParamJsonObj_Realname(String name,Integer idcard,String mobile) {
        /**
         * 基本参数
         */
        JSONObject paramJsonObj = new JSONObject();
        paramJsonObj.put("api", "WAY_BILL_HISTORY_START");
        paramJsonObj.put("appKey", appKey);
        paramJsonObj.put("appSecret",
                "6MD50FA127P1ACNP9C64272X13C1FA1BEA20H406");


        /**
         * 业务参数
         */
        JSONObject dataJson = initMainServiceParamJsonObj_Realname(name,idcard,mobile);
        paramJsonObj.put("data", dataJson);
        return paramJsonObj;
    }

    /*
     * 初始化业务参数(实名认证)
     *
     * 姓名,身份证,手机号
     *
     * @return
     */
    public JSONObject initMainServiceParamJsonObj_Realname(String name,Integer idcard,String mobile) {
        /**
         * 具体业务参数放在data中
         */
        JSONObject dataJson = new JSONObject();
        dataJson.put("num", "1556502455-72");
        dataJson.put("plateNumber", "京CF0237");
        dataJson.put("plateColor", 1);
        dataJson.put("startTime", "2023-09-13T19:25:56");
        dataJson.put("sourceAddr", "北京市朝阳区");
        dataJson.put("destAddr", "北京市朝阳区");
        dataJson.put("predictEndTime", "2023-11-16T09:25:56");
        dataJson.put("fee", 10000);
        dataJson.put("titleType", 1);
        dataJson.put("taxplayerCode", "91330106MA28LMW9XQ");
        dataJson.put("waybillFileName", name);
        dataJson.put("base64Str", mobile);
        dataJson.put("contractType",idcard);
        return dataJson;
    }

    /**
     * 实现http post请求 注意编码 UTF-8
     *
     * @param url
     * @param paramObj
     * @return
     */
    public String postClient(String url, JSONObject paramObj) {
        String str = "";
        HttpClient client = null;
        PostMethod method = null;
        try {
            client = new HttpClient();
            method = new PostMethod(url);
            method.setRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");
            NameValuePair[] param = new NameValuePair[paramObj.size()];
            Iterator<String> keys = paramObj.keys();
            int i = 0;
            while (keys.hasNext()) {
                String key = (String) keys.next();
                String value = paramObj.getString(key);
                param[i] = new NameValuePair(key, value);
                i++;
            }
            method.setRequestBody(param);
            client.executeMethod(method);
            str = convertStreamToString(method.getResponseBodyAsStream());
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (method != null) {
                method.releaseConnection();
            }
        }
        return str;
    }

    /**
     * 流转字符串
     *
     * @param is
     * @return
     */
    public static String convertStreamToString(InputStream is) {
        BufferedReader reader = new BufferedReader(new InputStreamReader(is));
        StringBuilder builder = new StringBuilder();
        String line = null;
        try {
            while ((line = reader.readLine()) != null) {
                builder.append(line + "\n");
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                is.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return builder.toString();
    }

}