swspkmas.git - Gitblit

			@@ -2,8 +2,12 @@

			import com.alibaba.fastjson2.JSONObject;
			import com.gkhy.exam.pay.entity.PayReqData;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.codec.digest.DigestUtils;
			import org.apache.http.*;
			import org.apache.http.HttpEntity;
			import org.apache.http.HttpResponse;
			import org.apache.http.NameValuePair;
			import org.apache.http.StatusLine;
			import org.apache.http.client.ClientProtocolException;
			import org.apache.http.client.HttpClient;
			import org.apache.http.client.HttpResponseException;
			@@ -25,13 +29,21 @@
			import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
			import org.apache.http.message.BasicNameValuePair;
			import org.apache.http.util.EntityUtils;
			import org.dom4j.Element;
			import org.dom4j.io.OutputFormat;
			import org.dom4j.io.XMLWriter;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.http.ResponseEntity;
			import org.springframework.stereotype.Component;

			import javax.annotation.Resource;
			import javax.net.ssl.SSLContext;
			import javax.net.ssl.TrustManager;
			import javax.net.ssl.X509TrustManager;
			import java.io.ByteArrayOutputStream;
			import java.io.IOException;
			import java.io.OutputStreamWriter;
			import java.io.UnsupportedEncodingException;
			import java.nio.charset.StandardCharsets;
			import java.security.KeyManagementException;
			import java.security.NoSuchAlgorithmException;
			import java.security.cert.X509Certificate;
			@@ -40,38 +52,60 @@
			/**
			* 缴费相关接口
			*/
			@Component
			@Slf4j
			public class PayUtils {

			private final static String appid="ED76A5F1703540BE977D34780B371FEB";
			// private final static String appid = "ED76A5F1703540BE977D34780B371FEB";

			@Value("${finance.orderUrl}")
			private String orderUrl;

			public static ResultVo sendApiPost(PayReqData payReqData) throws IOException {
			@Value("${finance.payNotifyUrl}")
			private String payNotifyUrl;

			//正式
			String proUrl="http://finpt.xjcz.gov.cn/fs-service/fs-pay/invoice.do";
			//测试
			String testUrl= "http://finpt.xjcz.gov.cn/fs-service-test/fs-pay/invoice.do";
			@Value("${finance.payQueryUrl}")
			private String payQueryUrl;

			@Value("${finance.apiId}")
			private String appId;

			@Value("${finance.queryUrl}")
			private String queryUrl;

			@Value("${finance.uploadXmlUrl}")
			private String uploadXmlUrl;

			/**
			* 请求开票，发起支付
			* @param payReqData
			* @return
			* @throws IOException
			*/
			public ResultVo sendApiPost(PayReqData payReqData) throws IOException {

			Map<String, String> param = new HashMap<>();

			HttpPost httpPost = new HttpPost(testUrl);
			HttpPost httpPost = new HttpPost(orderUrl);

			//请求参数转为json格式base64编码
			String reqData = Base64.getEncoder().encodeToString(JSONObject.toJSONString(payReqData).getBytes());
			String mac = appid+"\|\|"+reqData;
			String mac = appId + "\|\|" + reqData;
			mac = DigestUtils.md5Hex(mac.getBytes());
			param.put("appid",appid);
			param.put("reqdata",reqData);
			param.put("mac",mac);
			param.put("appid", appId);
			param.put("reqdata", reqData);
			param.put("mac", mac);

			httpPost.setEntity(assemblyFormEntity(param,"utf-8"));
			HttpClient httpClient = getHttpClient(testUrl);
			httpPost.setEntity(assemblyFormEntity(param, "utf-8"));
			HttpClient httpClient = getHttpClient(orderUrl);
			HttpResultVo execute = httpClient.execute(httpPost, getResponseHandler());
			String stringContent = execute.getStringContent();
			ResultVo resultVo = JSONObject.parseObject(stringContent, ResultVo.class);
			log.info("请求结果为:"+resultVo);
			return resultVo;
			}

			//组装请求体
			private static UrlEncodedFormEntity assemblyFormEntity(Map<String, String> parameters, String charset) {
			List<NameValuePair> formParameters = assemblyParameter(parameters);
			UrlEncodedFormEntity formEntity = null;
			@@ -107,6 +141,7 @@

			}

			//在调用SSL之前需要重写验证方法，取消检测SSL 创建ConnectionManager，添加Connection配置信息
			private static HttpClient sslClient() {
			try {
			// 在调用SSL之前需要重写验证方法，取消检测SSL
			@@ -117,13 +152,15 @@
			}

			@Override
			public void checkClientTrusted(X509Certificate[] xcs, String str) {}
			public void checkClientTrusted(X509Certificate[] xcs, String str) {
			}

			@Override
			public void checkServerTrusted(X509Certificate[] xcs, String str) {}
			public void checkServerTrusted(X509Certificate[] xcs, String str) {
			}
			};
			SSLContext ctx = SSLContext.getInstance(SSLConnectionSocketFactory.TLS);
			ctx.init(null, new TrustManager[] {trustManager}, null);
			ctx.init(null, new TrustManager[]{trustManager}, null);
			SSLConnectionSocketFactory socketFactory =
			new SSLConnectionSocketFactory(ctx, NoopHostnameVerifier.INSTANCE);
			// 创建Registry
			@@ -147,6 +184,7 @@

			}

			//获取响应结果处理器，将响应结果封装为HttpResult对象
			private static ResponseHandler<HttpResultVo> getResponseHandler() {
			ResponseHandler<HttpResultVo> responseHandler = new ResponseHandler<HttpResultVo>() {
			@Override
			@@ -187,6 +225,7 @@
			return responseHandler;
			}

			//判断相应内容是否为文本类型
			private static boolean isTextType(ContentType contentType) {
			if (contentType == null) {
			throw new RuntimeException("ContentType is null");
			@@ -210,81 +249,158 @@


			//缴费结果通知
			public static Map<String,String> receive(JSONObject jsonObject) throws IOException {
			public Map<String, String> receive(JSONObject jsonObject) throws IOException {

			Map<String, String> params = new HashMap<>();
			JSONObject reqdata = new JSONObject();

			Map<String,String> result = (Map<String, String>) jsonObject.get("reqdata");
			Map<String, String> result = (Map<String, String>) jsonObject.get("reqdata");
			String orderNo = result.get("orderNo");

			//确认是否成功
			String notarize= affirmPost(orderNo);
			reqdata.put("orderNo",orderNo);
			reqdata.put("status",notarize);
			String notarize = affirmPost(orderNo);
			reqdata.put("orderNo", orderNo);
			reqdata.put("status", notarize);

			String req = Base64.getEncoder().encodeToString(reqdata.toJSONString().getBytes());
			String mac = appid+"\|\|"+req;
			String mac = appId + "\|\|" + req;
			mac = DigestUtils.md5Hex(mac.getBytes());
			params.put("appid",appid);
			params.put("reqdata",req);
			params.put("mac",mac);
			params.put("appid", appId);
			params.put("reqdata", req);
			params.put("mac", mac);

			return params;
			}

			//缴费结果确认查询
			public static String affirmPost(String orderNo) throws IOException {
			String porUrl="http://finpt.xjcz.gov.cn/fs-service/fs-pay/notifyConfirm.do";
			String testUrl="http://finpt.xjcz.gov.cn/fs-service-test/fs-pay/notifyConfirm.do";
			public String affirmPost(String orderNo) throws IOException {

			HashMap<String, String> param = new HashMap<>();

			JSONObject jsonObject = new JSONObject();
			jsonObject.put("orderNo",orderNo);
			jsonObject.put("orderNo", orderNo);
			String reqdata = Base64.getEncoder().encodeToString(jsonObject.toJSONString().getBytes());
			String mac = appid+"\|\|"+reqdata;
			mac=DigestUtils.md5Hex(mac.getBytes());
			param.put("appid",appid);
			param.put("reqdata",reqdata);
			param.put("mac",mac);
			String mac = appId + "\|\|" + reqdata;
			mac = DigestUtils.md5Hex(mac.getBytes());
			param.put("appid", appId);
			param.put("reqdata", reqdata);
			param.put("mac", mac);

			HttpPost httppost = new HttpPost(testUrl);
			httppost.setEntity(assemblyFormEntity(param,"utf-8"));
			HttpClient httpClient = getHttpClient(testUrl);
			HttpPost httppost = new HttpPost(payNotifyUrl);
			httppost.setEntity(assemblyFormEntity(param, "utf-8"));
			HttpClient httpClient = getHttpClient(payNotifyUrl);
			HttpResultVo execute = httpClient.execute(httppost, getResponseHandler());
			String stringContent = execute.getStringContent();
			ResultVo resultVo = JSONObject.parseObject(stringContent, ResultVo.class);
			System.out.printf("请求结果为："+resultVo);
			if (resultVo.getRespcode().equals("BUS0000")){
			log.info("请求结果为：" + resultVo);
			if (resultVo.getRespcode().equals("BUS0000")) {
			return "success";
			}
			return "fail";
			}

			//缴费结果查询
			public static JSONObject query(String orderNo) throws IOException {
			String proUrl="http://finpt.xjcz.gov.cn/fs-service/fs-pay/query.do";
			String testUrl="http://finpt.xjcz.gov.cn/fs-service-test/fs-pay/query.do";

			public JSONObject query(String orderNo) throws IOException {
			HashMap<String, String> param = new HashMap<>();

			JSONObject jsonObject = new JSONObject();
			jsonObject.put("orderNo",orderNo);
			jsonObject.put("orderNo", orderNo);
			String reqdata = Base64.getEncoder().encodeToString(jsonObject.toJSONString().getBytes());
			String mac = appid+"\|\|"+reqdata;
			String mac = appId + "\|\|" + reqdata;
			mac = DigestUtils.md5Hex(mac.getBytes());
			param.put("appid",appid);
			param.put("reqdata",reqdata);
			param.put("mac",mac);
			param.put("appid", appId);
			param.put("reqdata", reqdata);
			param.put("mac", mac);

			HttpPost httppost = new HttpPost(testUrl);
			httppost.setEntity(assemblyFormEntity(param,"utf-8"));
			HttpClient httpClient = getHttpClient(testUrl);
			HttpPost httppost = new HttpPost(payQueryUrl);
			httppost.setEntity(assemblyFormEntity(param, "utf-8"));
			HttpClient httpClient = getHttpClient(payQueryUrl);
			HttpResultVo execute = httpClient.execute(httppost, getResponseHandler());
			String stringContent = execute.getStringContent();
			JSONObject result = JSONObject.parseObject(stringContent);
			System.out.printf("请求结果json为："+result);
			log.info("请求结果json为：" + result);
			return result;
			}


			//票据查询
			public ResponseEntity<String> findBill(String billNO) throws IOException {
			Map<String, String> params = new HashMap<>();

			JSONObject jsonObject = new JSONObject();
			jsonObject.put("billNo",billNO);
			String reqdata = Base64.getEncoder().encodeToString(jsonObject.toJSONString().getBytes());
			String mac = appId+"\|\|"+reqdata;
			mac = DigestUtils.md5Hex(mac.getBytes());
			params.put("appid",appId);
			params.put("reqdata",reqdata);
			params.put("mac",mac);

			HttpPost httpPost = new HttpPost(queryUrl);
			httpPost.setEntity(assemblyFormEntity(params,"utf-8"));
			HttpClient httpClient = getHttpClient(queryUrl);
			HttpResultVo execute = httpClient.execute(httpPost, getResponseHandler());
			String stringContent = execute.getStringContent();
			JSONObject jsonObject1 = JSONObject.parseObject(stringContent);
			log.info("请求结果转json后为:"+jsonObject1);
			String result = (String) jsonObject1.get("reqdata");
			return ResponseEntity.ok(result);

			}

			//上传财政电子票据签名文件
			public ResultVo uploadXml(String orderId, String plain) throws IOException {
			Map<String, String> params = new HashMap<>();

			Sign sign = new Sign();
			Element signature = sign.getSignature(plain);

			JSONObject jsonObject = new JSONObject();
			jsonObject.put("orderNo",orderId);
			jsonObject.put("fileData", Base64.getEncoder().encodeToString(convertElementToByteArray(signature)));

			String reqdata = Base64.getEncoder().encodeToString(jsonObject.toJSONString().getBytes());
			String mac = appId+"\|\|" +reqdata;
			mac = DigestUtils.md5Hex(mac.getBytes());

			params.put("appid",appId);
			params.put("reqdata",reqdata);
			params.put("mac",mac);

			HttpPost httpPost = new HttpPost(uploadXmlUrl);
			httpPost.setEntity(assemblyFormEntity(params,"utf-8"));
			HttpClient httpClient = getHttpClient(uploadXmlUrl);
			HttpResultVo execute = httpClient.execute(httpPost, getResponseHandler());
			String stringContent = execute.getStringContent();
			ResultVo resultVo = JSONObject.parseObject(stringContent, ResultVo.class);
			log.info("请求结果转为:"+resultVo);
			return resultVo;
			}

			//获取XML文件字节码
			public static byte[] convertElementToByteArray(Element element) {
			ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();

			try {
			// 设置输出格式
			OutputFormat format = OutputFormat.createPrettyPrint();
			format.setEncoding("UTF-8"); // 设置编码为UTF-8

			// 创建 XMLWriter
			XMLWriter writer = new XMLWriter(new OutputStreamWriter(byteArrayOutputStream, StandardCharsets.UTF_8), format);

			// 写入 Element 对象
			writer.write(element.getDocument());
			writer.close(); // 关闭 writer，确保所有数据都被写入

			} catch (IOException e) {
			e.printStackTrace(); // 打印异常信息
			// 处理异常，比如返回一个空的字节数组或重新抛出异常
			return new byte[0];
			}

			// 返回字节数组
			return byteArrayOutputStream.toByteArray();
			}

			}