20220415_协议上传接口优化

src/main/java/com/jkcredit/invoice/component/StatisRequestIdTimeComp.java

@@ -73,7 +73,7 @@ public class StatisRequestIdTimeComp {
                 }else{
                     isLimit=false;
                 }
-                log.info("当前请求数："+map.size()+"当前耗时请求数："+count+"是否限制："+isLimit);
+              //  log.info("当前请求数："+map.size()+"当前耗时请求数："+count+"是否限制："+isLimit);
             }
         },1,1, TimeUnit.SECONDS);
     }

src/main/java/com/jkcredit/invoice/controller/business/CustomerController.java

@@ -21,6 +21,7 @@ import com.jkcredit.invoice.util.RespR;
 import com.jkcredit.invoice.util.WordUtil;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
 import org.apache.poi.util.IOUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -46,6 +47,7 @@ import java.util.*;
 * @Exception
 *
 */
+@Slf4j
 public class CustomerController {
     @Autowired
     CustomerService customerService;
@@ -263,19 +265,20 @@ public class CustomerController {
     public RespR contractDownload(String customerRecId,HttpServletResponse response){
         CustomerRec customerRec = (CustomerRec) customerService.contractDownload(customerRecId).getData();
         String fileName = customerRec.getLowerFileName();
+        InputStream inputStream = null;
+        OutputStream outputStream = null;
         if(customerRec.getLowerBase64Str()!=null){
-            byte [] byteArray = Base64.getDecoder().decode(customerRec.getLowerBase64Str());
-            InputStream inputStream = new ByteArrayInputStream(byteArray);
-
-            OutputStream outputStream = null;
             try {
+             //将base64编码的字符串解码成字节数组
+                byte[] byteArray = new sun.misc.BASE64Decoder().decodeBuffer(customerRec.getLowerBase64Str());
+                inputStream = new ByteArrayInputStream(byteArray);
                 response.setHeader("Content-Disposition", "attachment;filename="+ URLEncoder.encode(fileName, "UTF-8"));
                 outputStream = response.getOutputStream();
                 IOUtils.copy(inputStream, outputStream);
                 response.flushBuffer();
                 return new RespR(true);
             } catch (IOException e) {
-
+                log.error("协议下载CustomerController.contractDownload协议下载失败{}",e.getMessage());
             } finally {
                 IOUtils.closeQuietly(inputStream);
                 IOUtils.closeQuietly(outputStream);
@@ -313,7 +316,7 @@ public class CustomerController {
             WordUtil.ExportSimpleWord(dataMap,"/static/templates/excel/",outputStream);
             response.flushBuffer();
         }catch (Exception e){
-            e.printStackTrace();
+            log.error("文档下载CustomerController.generateWord文档下载失败{}",e.getMessage());
         }finally {
             IOUtils.closeQuietly(outputStream);
         }

src/main/java/com/jkcredit/invoice/credit/interserver/CustomerInterLowerServiceImpl.java

@@ -298,13 +298,18 @@ public class CustomerInterLowerServiceImpl implements CustomerInterLowerService
                 return  result;
             }
 
+            int base64StrLength = base64Str.length();
+            if(10 * 1024 * 1024 < base64StrLength){
+                result.setMsg("pdf不可超过10M!");
+                return  result;
+            }
 
             CustomerRec customerRec = new CustomerRec();
             customerRec.setServiceStartTime(DateUtil.getDistanceHoursFormat(serviceStartTime));//服务开始时间
             customerRec.setServiceEndTime(DateUtil.getDistanceHoursFormat(serviceEndTime));//服务结束时间
             customerRec.setServiceType(serviceType);//协议类型
             customerRec.setLowerFileName(contractFileName);//协议名称
-            customerRec.setLowerBase64Str(base64Str.replaceAll(" ","+"));//协议base64编码
+            customerRec.setLowerBase64Str(base64Str);//协议base64编码
             customerRec.setCustomerName(appKey);//客户名称
             customerRec.setCompanyNum(companyNum);
             customerRec.setInterType(0);//接口

src/main/java/com/jkcredit/invoice/util/Base64Util.java

@@ -1,12 +1,15 @@
 package com.jkcredit.invoice.util;
 
 import org.apache.commons.codec.binary.Base64;
-
 import java.io.*;
 
 public class Base64Util {
     public static void main(String [] args){
-        System.out.print(fileToBase64("d:/123.pdf"));
+        //将PDF格式文件转成base64编码
+        String base64String = getPDFBinary(new File("C:\\Users\\msy\\Desktop\\服务及承诺函.pdf"));
+        //将base64的编码转成PDF格式文件
+        base64StringToPDF(base64String);
+
     }
     public static String fileToBase64(String path) {
         int byteread = 0;
@@ -83,4 +86,108 @@ public class Base64Util {
         return size0 - ((double) size0 / 8) * 2;
     }
 
+
+
+    /**
+     *  将PDF转换成base64编码
+     *  1.使用BufferedInputStream和FileInputStream从File指定的文件中读取内容；
+     *  2.然后建立写入到ByteArrayOutputStream底层输出流对象的缓冲输出流BufferedOutputStream
+     *  3.底层输出流转换成字节数组，然后由BASE64Encoder的对象对流进行编码
+     * */
+    public  static String getPDFBinary(File file) {
+        FileInputStream fin =null;
+        BufferedInputStream bin =null;
+        ByteArrayOutputStream baos = null;
+        BufferedOutputStream bout =null;
+        try {
+            //建立读取文件的文件输出流
+            fin = new FileInputStream(file);
+            //在文件输出流上安装节点流（更大效率读取）
+            bin = new BufferedInputStream(fin);
+            // 创建一个新的 byte 数组输出流，它具有指定大小的缓冲区容量
+            baos = new ByteArrayOutputStream();
+            //创建一个新的缓冲输出流，以将数据写入指定的底层输出流
+            bout = new BufferedOutputStream(baos);
+            byte[] buffer = new byte[1024];
+            int len = bin.read(buffer);
+            while(len != -1){
+                bout.write(buffer, 0, len);
+                len = bin.read(buffer);
+            }
+            //刷新此输出流并强制写出所有缓冲的输出字节，必须这行代码，否则有可能有问题
+            bout.flush();
+            byte[] bytes = baos.toByteArray();
+            return  new sun.misc.BASE64Encoder().encodeBuffer(bytes).trim();
+
+        } catch (FileNotFoundException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }finally{
+        try {
+            fin.close();
+            bin.close();
+            //关闭 ByteArrayOutputStream 无效。此类中的方法在关闭此流后仍可被调用，而不会产生任何 IOException
+            //baos.close();
+            bout.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        }
+        return null;
+    }
+
+
+
+
+
+    /*
+     * 将base64编码转换成PDF
+     * @param base64sString
+     * 1.使用BASE64Decoder对编码的字符串解码成字节数组
+     *  2.使用底层输入流ByteArrayInputStream对象从字节数组中获取数据；
+     *  3.建立从底层输入流中读取数据的BufferedInputStream缓冲输出流对象；
+     *  4.使用BufferedOutputStream和FileOutputSteam输出数据到指定的文件中
+     */
+    public static void base64StringToPDF(String base64sString){
+        BufferedInputStream bin = null;
+        FileOutputStream fout = null;
+        BufferedOutputStream bout = null;
+        try {
+        //将base64编码的字符串解码成字节数组
+        byte[] bytes = new sun.misc.BASE64Decoder().decodeBuffer(base64sString);
+            //apache公司的API
+            //byte[] bytes = Base64.decodeBase64(base64sString);
+            //创建一个将bytes作为其缓冲区的ByteArrayInputStream对象
+            ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
+            //创建从底层输入流中读取数据的缓冲输入流对象
+            bin = new BufferedInputStream(bais);
+            //指定输出的文件http://m.nvzi91.cn/nxby/29355.html
+            File file = new File("C:\\Users\\msy\\Desktop\\马圣毅.pdf");
+            //创建到指定文件的输出流
+            fout  = new FileOutputStream(file);
+            //为文件输出流对接缓冲输出流对象
+            bout = new BufferedOutputStream(fout);
+            byte[] buffers = new byte[1024];
+            int len = bin.read(buffers);
+            while(len != -1){
+                bout.write(buffers, 0, len);
+                len = bin.read(buffers);
+            }
+            //刷新此输出流并强制写出所有缓冲的输出字节，必须这行代码，否则有可能有问题
+            bout.flush();
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        }finally{
+            try {
+            bin.close();
+                fout.close();
+                bout.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
 }

src/main/java/com/jkcredit/invoice/util/QueryDemo_Test.java

@@ -5,10 +5,7 @@ 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.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
+import java.io.*;
 import java.util.Iterator;
 
 /**
@@ -21,55 +18,46 @@ import java.util.Iterator;
 public class QueryDemo_Test {
 
 	/**
-	 * 	测试地址
+	 * 测试地址
 	 */
-	//	private static final String URL = "http://110.88.150.74:80/credit?api=credit.sec.data";
+		private static final String URL = "http://127.0.0.1:18081/gateway?api=credit.sec.data";
+	 	//private static final String URL = "http://110.88.150.74:80/credit?api=credit.sec.data_test";
 	  	//private static final String URL = "http://110.88.150.74/credit?api=credit.sec.data";
-	//	private static final String URL = "http://123.57.186.204/gateway?api=credit.sec.data";
+		//private static final String URL = "http://123.57.186.204/gateway?api=credit.sec.data_test";
 		//private static final String URL = "http://123.57.186.204/gateway?api=credit.sec.data";
-	//private static final String URL = "http://192.168.50.4:18080/gateway?api=credit.sec.data";//北京节点
-	//	private static final String URL = "http://jk.h11.site/gateway?api=credit.sec.data";
-		private static final String URL = "http://127.0.0.1:18080/gateway?api=credit.sec.data";
-	//			private static final String URL = "http://110.88.150.68:8000/gateway?api=credit.sec.data_test";
-			//	private static final String URL = "http://110.88.150.72:8000/gateway?api=credit.sec.data_test";
-	//	private static final String URL = "http://60.205.114.163:8000/gateway?api=credit.sec.data";
-		//private static final String URL = " http://45.126.120.88/gateway?api=credit.sec.data_test"; 
-		//		private static final String URL = " http://45.126.120.88/gateway?api=credit.sec.data"; 
-	//	private static final String URL = " http://119.18.195.163/gateway?api=credit.sec.data"; 
+		//private static final String URL = "http://www1.h11.site/gateway?api=credit.sec.data";
+	 	//private static final String URL = "http://110.88.150.68:8000/gateway?api=credit.sec.data";
+		//private static final String URL = "http://60.205.114.163:8000/gateway?api=credit.sec.data";
+	 	//private static final String URL = " http://45.126.120.88/gateway?api=credit.sec.data"; 
+		//private static final String URL = "http://119.18.195.163/gateway?api=credit.sec.data";
 
 	/**
-	 *	 分配的appKey
+	 * 分配的appKey
 	 */
-							  private static final String APP_KEY = "jkxy";
-							  // 	 private static final String appKey = "junxin_test";
+	 	//private static final String appKey = "junxin_test";
+	
+		private static final String appKey = "rongchengzhiyun";
+	 	//private static final String appKey = "ccx";
 
-		 	  	//			  	 private static final String appKey = "DATA_TEST";
-	 	//private static final String appKey = "JIAO_KE";
-		//private static final String appKey = "HANGZHOU_JUNXIN_72";
-
-	/**290dec3f6a243889e5ed3210cf1ad499
-	 * 	方法入口
+	/**
+	 * 方法入口
 	 *
 	 * @param args
 	 */
-	public static void main(String[] args) throws Exception {
-
-		for (int i = 0;i<=1000000;i++){
-			QueryDemo_Test demo = new QueryDemo_Test();
-			demo.runMainService(i);
-		}
-
+	public static void main(String args[]) throws Exception {
+		   QueryDemo_Test demo = new QueryDemo_Test();
+		demo.runMainService();
 	}
 
 	/**
-	 * 	调用主接口
+	 * 调用主接口
 	 */
-	public void runMainService(int i) {
+	public void runMainService() {
 		try {
 			/**
-			 *	 实名demo
+			 * 实名demo
 			 */
-			JSONObject paramJsonObj = initParamJsonObj_Realname(i);
+			JSONObject paramJsonObj = initParamJsonObj_Realname();
 			String ret = postClient(URL, paramJsonObj);
 			System.out.println(ret);
 		} catch (Exception e) {
@@ -78,66 +66,58 @@ public class QueryDemo_Test {
 	}
 
 	/**
-	 * 	整合参数(实名认证)
+	 * 整合参数(实名认证)
 	 *
 	 * @return
 	 */
-	public JSONObject initParamJsonObj_Realname(int i) {
+	public JSONObject initParamJsonObj_Realname() {
 		/**
-		 *	 基本参数
+		 * 基本参数
 		 */
 		JSONObject paramJsonObj = new JSONObject();
-		paramJsonObj.put("api", "COMPANY_QUERY_V1");//CMCC_3RD_DETAIL_V15C//CMCC_3RD_DETAIL_V32//CMCC_2ND_V17//CMCC_ONLINE_CHECK_V5
-		paramJsonObj.put("appKey", APP_KEY);
+		paramJsonObj.put("api", "PROTOCOL_ADD_V1");//CMCC_MOBILE_CHECK_V8//CMCC_3RD_V2//CMCC_3RD_DETAIL_V1//
+		//paramJsonObj.put("api", "MSISDNMD5TOIMEI");//MOBILE_CHECK_V1//CMCC_3RD_VERIFY_V4//CTCC_CHECK_V1
+		paramJsonObj.put("appKey", appKey);
 	    paramJsonObj.put("appSecret",
-	    		//		"D78C393359BF128715C65D91C67051478A4DFC13");
-	    	"7697CE9BB9D5A856CFDDE738320AD34EA53E483C");
+		"DDEF5E6D6028FCA74144290AF7EA628A9DE84B39");
+		//"84C1CE24EDF361F28072E313BD87EAB24CC727CF");
 	    
 	   
 
 		/**
-		 * 	业务参数
+		 * 业务参数
 		 */
-		JSONObject dataJson = initMainServiceParamJsonObj_Realname(i);
+		JSONObject dataJson = initMainServiceParamJsonObj_Realname();
 		paramJsonObj.put("data", dataJson);
-
 		return paramJsonObj;
 	}
 
 	/*
-	 * 	初始化业务参数(实名认证)
+	 * 初始化业务参数(实名认证)
 	 *
-	 *	 姓名,身份证,手机号
+	 * 姓名,身份证,手机号
 	 *
 	 * @return
 	 */
-	public JSONObject initMainServiceParamJsonObj_Realname(int i) {
+	public JSONObject initMainServiceParamJsonObj_Realname() {
 		/**
 		 * 具体业务参数放在data中
 		 */
 		  JSONObject dataJson = new JSONObject();
-	 /*     dataJson.put("id_number","45032719990321321X");
-	      dataJson.put("name","刘伟");//"id_number":"131126199009280345","name":"王聪","mobile":"18322155936"
-	      dataJson.put("mobile","18929408405");*///15201563103,,,15201563013
-		  //"id_number":"131126199009280345","name":"王聪","mobile":"18322155936"
-	     /* dataJson.put("name","3febda274935a59ce9ff44e2bd0f690aa33fe8ec2c7df3ce384ee0868126decf");
-	      dataJson.put("id_number","bdbcb76a4c74b6f7770e469d647d30ae674b9d089e1cb01615cc46e258201255");
-	      dataJson.put("mobile","54f3746ad9998989ebcb7a3444b5edb694314472cbb74a2fd6458dd64b378b02");
+          /*dataJson.put("name", SHA256Utils.String2SHA256("高峰明"));
+	      dataJson.put("id_number",SHA256Utils.String2SHA256("152322196311063719"));
+	      dataJson.put("mobile",SHA256Utils.String2SHA256("13104866236"));
 	      dataJson.put("encrypt","SHA256");*/
-	      //dataJson.put("bank_card_number","6253624025440494");
-          /*dataJson.put("name",MD5Util.MD5("周凤云"));
-	      dataJson.put("id_number",MD5Util.MD5("370523197112090723"));
-	      dataJson.put("mobile",MD5Util.MD5("13490329255"));*/
-	     // dataJson.put("appkey","6222350107122010");
-	   /*   dataJson.put("mobileCaller","13911084965");
-	      dataJson.put("mobileCalled","13691459653");*/
+		  dataJson.put("companyNum", "10004849");
+	      dataJson.put("serviceStartTime","2022-04-15T17:30:37");
+	      dataJson.put("serviceEndTime","2023-04-15T21:30:37");
+	      dataJson.put("contractFileName","spring高级源码笔记msy.pdf");
+	      dataJson.put("serviceType","3");
+	      dataJson.put("base64Str",Base64Util.getPDFBinary(new File("C:\\Users\\msy\\Desktop\\spring高级源码笔记.pdf")));
 		 /* List<String> list = new ArrayList<>();
 			list.add("13752639577");
 	        dataJson.put("msisdnmd5list",list);*/
-		  dataJson.put("companyName","长沙争渡网络科技有限公司" +i);
-		 // jb.put("tradeId", "3b904990aa4b461cad44ed6f4a8024e2");
-		 // jb.put("tradeId", "a2acbcef11d547c3b425c31d53868a3e");
-		 return dataJson;
+		  return dataJson;
 	}
 
 	/**