微信退款接口

悠悠 2022-06-01 06:24 208阅读 0赞

package com.tanie.db.utils;
    
    import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.InputStreamReader;
    import java.security.KeyStore;
    import java.security.KeyStoreException;
    import java.util.HashMap;
    import java.util.Iterator;
    import java.util.Map;
    import java.util.Random;
    import java.util.Set;
    import java.util.SortedMap;
    import java.util.TreeMap;
    
    import javax.annotation.Resource;
    import javax.net.ssl.SSLContext;
    
    import org.apache.http.HttpEntity;
    import org.apache.http.client.methods.CloseableHttpResponse;
    import org.apache.http.client.methods.HttpPost;
    import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
    import org.apache.http.conn.ssl.SSLContexts;
    import org.apache.http.entity.StringEntity;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.util.EntityUtils;
    import org.hibernate.SQLQuery;
    import org.hibernate.SessionFactory;
    import org.hibernate.classic.Session;
    import org.hibernate.transform.Transformers;
    
    import com.tanie.fenxiao.action.BaseAction;
    import com.unstoppedable.common.Configure;
    import com.unstoppedable.common.MD5;
    
    public class Wxrefund {
    
    	public Boolean refund(String no) throws Exception {
    		// Session sqlSession = sessionFactory.openSession();
    		// q.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
    		// SQLQuery q = sqlSession.createSQLQuery("select * from pay_record where
    		// outTradeNo='"+no+"'");
    		// q.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
    		// Map obj = (Map) q.uniqueResult();
    		Map obj = new HashMap();
    		Configure cif = new Configure();
    		SortedMap<Object, Object> parameters = new TreeMap<Object, Object>();
    		parameters.put("appid", cif.getAppid());
    		parameters.put("mch_id", cif.getMchid());
    		parameters.put("nonce_str", CreateNoncestr());
    		// 在notify_url中解析微信返回的信息获取到 transaction_id，此项不是必填，详细请看上图文档
    		parameters.put("transaction_id", obj.get("transactionId"));
    		parameters.put("out_trade_no", obj.get("outTradeNo"));
    		parameters.put("out_refund_no", obj.get("outTradeNo")); // 我们自己设定的退款申请号，约束为UK
    		parameters.put("total_fee", obj.get("totalFee")); // 单位为分
    		parameters.put("refund_fee", obj.get("cashFee")); // 单位为分
    		parameters.put("op_user_id", cif.getMchid());
    		String sign = createSign("utf-8", parameters);
    		parameters.put("sign", sign);
    
    		String reuqestXml = getRequestXml(parameters);
    		KeyStore keyStore = KeyStore.getInstance("PKCS12");
    		FileInputStream instream = new FileInputStream(new File(cif.getCertLocalPath()));// 放退款证书的路径
    		try {
    			keyStore.load(instream, cif.getMchid().toCharArray());
    		} finally {
    			instream.close();
    		}
    		SSLContext sslcontext = SSLContexts.custom().loadKeyMaterial(keyStore, cif.getMchid().toCharArray()).build();
    		SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext, new String[] { "TLSv1" }, null,
    				SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);
    		CloseableHttpClient httpclient = HttpClients.custom().setSSLSocketFactory(sslsf).build();
    		try {
    			HttpPost httpPost = new HttpPost(cif.REFUND_API);// 退款接口
    
    			System.out.println("executing request" + httpPost.getRequestLine());
    			StringEntity reqEntity = new StringEntity(reuqestXml);
    			// 设置类型
    			reqEntity.setContentType("application/x-www-form-urlencoded");
    			httpPost.setEntity(reqEntity);
    			CloseableHttpResponse response = httpclient.execute(httpPost);
    			try {
    				HttpEntity entity = response.getEntity();
    				System.out.println("----------------------------------------");
    				System.out.println(response.getStatusLine());
    				if (entity != null) {
    					System.out.println("Response content length: " + entity.getContentLength());
    					BufferedReader bufferedReader = new BufferedReader(
    							new InputStreamReader(entity.getContent(), "UTF-8"));
    					String text;
    					while ((text = bufferedReader.readLine()) != null) {
    						System.out.println(text);
    					}
    
    				}
    				EntityUtils.consume(entity);
    			} finally {
    				response.close();
    			}
    		} finally {
    			httpclient.close();
    		}
    
    		return null;
    
    	}
    
    	public static String CreateNoncestr() {
    		String chars = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456709";
    		String res = "";
    		for (int i = 0; i < 16; i++) {
    			Random rd = new Random();
    			res += chars.charAt(rd.nextInt(chars.length() - 1));
    		}
    		return res;
    	}
    
    	public static String createSign(String charSet, SortedMap<Object, Object> parameters) {
    		StringBuffer sb = new StringBuffer();
    		Set es = parameters.entrySet();
    		Iterator it = es.iterator();
    		while (it.hasNext()) {
    			Map.Entry entry = (Map.Entry) it.next();
    			String k = (String) entry.getKey();
    			Object v = entry.getValue();
    			if (null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) {
    				sb.append(k + "=" + v + "&");
    			}
    		}
    		sb.append("key=" + "TyqLcsKvjEAsl1Agel0EuXekoa83mQ62");
    		String sign = MD5.MD5Encode(sb.toString()).toUpperCase();
    		return sign;
    	}
    
    	public static String getRequestXml(SortedMap<Object, Object> parameters) {
    		StringBuffer sb = new StringBuffer();
    		sb.append("<xml>");
    		Set es = parameters.entrySet();
    		Iterator it = es.iterator();
    		while (it.hasNext()) {
    			Map.Entry entry = (Map.Entry) it.next();
    			String k = (String) entry.getKey();
    			String v = (String) entry.getValue();
    			if ("attach".equalsIgnoreCase(k) || "body".equalsIgnoreCase(k) || "sign".equalsIgnoreCase(k)) {
    				sb.append("<" + k + ">" + "<![CDATA[" + v + "]]></" + k + ">");
    			} else {
    				sb.append("<" + k + ">" + v + "</" + k + ">");
    			}
    		}
    		sb.append("</xml>");
    		return sb.toString();
    	}
    
    }