package cc.mrbird.febs.pay.service.impl; import cc.mrbird.febs.common.properties.XcxProperties; import cc.mrbird.febs.common.utils.AppContants; import cc.mrbird.febs.common.utils.SpringContextHolder; import cc.mrbird.febs.mall.entity.MallInvoice; import cc.mrbird.febs.mall.entity.MallOrderInfo; import cc.mrbird.febs.mall.entity.MallOrderItem; import cc.mrbird.febs.mall.mapper.MallInvoiceMapper; import cc.mrbird.febs.mall.mapper.MallOrderInfoMapper; import cc.mrbird.febs.mall.mapper.MallOrderItemMapper; import cc.mrbird.febs.pay.model.FPCertificateVo; import cc.mrbird.febs.pay.model.FPCertificates; import cc.mrbird.febs.pay.model.FPEncryptCertificate; import cc.mrbird.febs.pay.service.WxFaPiaoService; import cc.mrbird.febs.pay.util.JCEUtil; import cc.mrbird.febs.pay.util.RandomStringGenerator; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; import com.wechat.pay.contrib.apache.httpclient.util.AesUtil; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import okhttp3.HttpUrl; import org.apache.http.HttpEntity; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPatch; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.protocol.HttpClientContext; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.message.BasicNameValuePair; import org.apache.http.util.EntityUtils; import org.springframework.core.io.ClassPathResource; import org.springframework.stereotype.Service; import org.springframework.util.Base64Utils; import org.springframework.web.bind.annotation.RequestBody; import javax.servlet.http.HttpServletRequest; import java.io.*; import java.nio.charset.StandardCharsets; import java.security.*; import java.security.cert.CertificateFactory; import java.security.cert.X509Certificate; import java.security.spec.InvalidKeySpecException; import java.security.spec.PKCS8EncodedKeySpec; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; import java.util.stream.Collectors; @Slf4j @Service @RequiredArgsConstructor public class WxFaPiaoServiceImpl implements WxFaPiaoService { private final MallOrderInfoMapper mallOrderInfoMapper; private final MallOrderItemMapper mallOrderItemMapper; private final MallInvoiceMapper mallInvoiceMapper; private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class); @Override public String createAuthorization(String method, String canonicalUrl, String body, PrivateKey keyPair) throws UnsupportedEncodingException, NoSuchAlgorithmException { String nonceStr = RandomStringGenerator.getRandomStringByLength(32);//随机字符串 long timestamp = System.currentTimeMillis() / 1000;//时间戳 HttpUrl httpurl = HttpUrl.parse(canonicalUrl); String message = buildMessage(method, httpurl, timestamp, nonceStr, body); log.info("签名串：\n"+message); log.info("签名串长度：\n"+getWordCount(message)); String signature = sign2(message.getBytes("utf-8"), keyPair); log.info("签名串sign：\n"+signature); log.info("签名串长度sign：\n"+getWordCount(signature)); // String yourCertificateSerialNo = "221D49AEC4EA538A63941D1936709C8559EB05C5"; return "mchid=\"" + xcxProperties.getWecharpayMchid() + "\"," + "nonce_str=\"" + nonceStr + "\"," + "timestamp=\"" + timestamp + "\"," + "serial_no=\"" + AppContants.WX_CARD_NUM + "\"," + "signature=\"" + signature + "\""; } public int getWordCount(String s) { int length = 0 ; for ( int i = 0 ; i < s.length(); i ++ ) { int ascii = Character.codePointAt(s, i); if (ascii >= 0 && ascii <= 255 ) length ++ ; else length += 2 ; } return length; } public String sign2(byte[] message,PrivateKey keyPair) throws NoSuchAlgorithmException { Signature sign = Signature.getInstance("SHA256withRSA"); String s = null; try { sign.initSign(keyPair); sign.update(message); s = Base64.getEncoder().encodeToString(sign.sign()); } catch (InvalidKeyException e) { e.printStackTrace(); } catch (SignatureException e) { e.printStackTrace(); } return s; } public String buildMessage(String method, HttpUrl url, long timestamp, String nonceStr, String body) { String canonicalUrl = url.encodedPath(); if (url.encodedQuery() != null) { canonicalUrl += "?" + url.encodedQuery(); } return method + "\n" + canonicalUrl + "\n" + timestamp + "\n" + nonceStr + "\n" + body + "\n"; } @Override public PrivateKey getPrivateKeyV3() throws IOException { InputStream inputStream = new ClassPathResource("wxP12/apiclient_key.pem") .getInputStream(); String content = new BufferedReader(new InputStreamReader(inputStream)) .lines().collect(Collectors.joining(System.lineSeparator())); try { String privateKey = content.replace("-----BEGIN PRIVATE KEY-----", "") .replace("-----END PRIVATE KEY-----", "") .replaceAll("\\s+", ""); KeyFactory kf = KeyFactory.getInstance("RSA"); return kf.generatePrivate( new PKCS8EncodedKeySpec(Base64.getDecoder().decode(privateKey))); } catch (NoSuchAlgorithmException e) { throw new RuntimeException("当前Java环境不支持RSA", e); } catch (InvalidKeySpecException e) { throw new RuntimeException("无效的密钥格式"); } } @Override public String sendPatch(String url, String params, String token) { String result = ""; CloseableHttpClient httpClient = HttpClients.createDefault(); HttpPatch httpPatch = new HttpPatch(url); CloseableHttpResponse response = null; httpPatch.setHeader("Content-type", "application/json"); httpPatch.setHeader("Charset", "utf-8"); httpPatch.setHeader("Accept", "application/json"); httpPatch.setHeader("Accept-Charset", "utf-8"); httpPatch.setHeader("Authorization", token); try { StringEntity data = new StringEntity(params, "utf-8"); httpPatch.setEntity(data); response = httpClient.execute(httpPatch); HttpEntity entity = response.getEntity(); result = EntityUtils.toString(entity); } catch (Exception e) { result = "{\"status\":\"1\",\"error\":\"" + e.getMessage() + "\"}"; }finally { try { httpClient.close(); if (response != null) { response.close(); } } catch (IOException var22) { var22.printStackTrace(); } } return result; } @Override public String sendPost(String url, String params, String token) { String result = ""; int err = 0; while (true) { CloseableHttpClient client = HttpClients.createDefault(); HttpPost httpPost = new HttpPost(url); CloseableHttpResponse response = null; try { httpPost.addHeader("Content-type", "application/json"); httpPost.addHeader("Charset", "utf-8"); httpPost.addHeader("Accept", "application/json"); httpPost.addHeader("Accept-Charset", "utf-8"); httpPost.addHeader("Authorization", token); StringEntity data = new StringEntity(params, "utf-8"); httpPost.setEntity(data); response = client.execute(httpPost); HttpEntity resEntity = response.getEntity(); result = EntityUtils.toString(resEntity); return result; } catch (IOException e) { result = "{\"status\":\"1\",\"errors\":\"" + e.getMessage() + "\"}"; if (err++ > 2) { break; } try { Thread.sleep((err + 2) * 1000); } catch (InterruptedException e1) { result = "{\"status\":\"1\",\"errors\":\"" + e1.getMessage() + "\"}"; } }finally { try { client.close(); if (response != null) { response.close(); } } catch (IOException var22) { var22.printStackTrace(); } } } return result; } @Override public String sendGet(String url, Map params, String token) { String result = ""; int err = 0; while (true) { CloseableHttpClient httpClient = HttpClients.createDefault(); CloseableHttpResponse response = null; try { List parameters = new ArrayList<>(); for (Map.Entry entry : params.entrySet()) { parameters.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString())); } StringBuilder dataparm = new StringBuilder(); params.forEach((k, v) -> dataparm.append("&" + k + "=" + v)); String urlparm = ""; String string = dataparm.toString(); if (!"".equals(string)) { urlparm = dataparm.toString().substring(1); } HttpGet httpget = new HttpGet(url + "?" + urlparm); httpget.addHeader("Accept", "application/json"); httpget.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/51.0.2704.106 Safari/537.36"); httpget.addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8"); httpget.addHeader("Authorization", token); response = httpClient.execute(httpget, HttpClientContext.create()); HttpEntity resEntity = response.getEntity(); result = EntityUtils.toString(resEntity); return result; } catch (IOException e) { result = "{\"status\":\"1\",\"errors\":\"" + e.getMessage() + "\"}"; if (err++ > 2) { break; } try { Thread.sleep((err + 2) * 1000); } catch (InterruptedException e1) { result = "{\"status\":\"1\",\"errors\":\"" + e1.getMessage() + "\"}"; } }finally { try { httpClient.close(); if (response != null) { response.close(); } } catch (IOException var22) { var22.printStackTrace(); } } } return result; } @Override public Map fapiaoCallBack(HttpServletRequest request, @RequestBody Map requestBody){ Map map = new HashMap<>(); String signature = request.getHeader("Wechatpay-Signature"); String timestamp = request.getHeader("Wechatpay-Timestamp"); String nonce = request.getHeader("Wechatpay-Nonce"); //平台证书序列号不是API证书序列号 String serial = request.getHeader("Wechatpay-Serial"); String body = com.alibaba.fastjson.JSONObject.toJSONString(requestBody); log.info("头信息---签名：" + signature); log.info("头信息---时间戳：" + timestamp); log.info("头信息---随机字符：" + nonce); log.info("头信息---平台证书序列号：" + serial); log.info("获取到的body信息：" + body); //应对签名探测流量 if(signature.contains("WECHATPAY/SIGNTEST")){ map.put("code",500); map.put("message", "失败"); return map; } //验签 boolean signCheck = false; try { signCheck = signCheck(timestamp, nonce, requestBody, signature); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } catch (SignatureException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } catch (InvalidKeyException e) { e.printStackTrace(); } catch (ParseException e) { e.printStackTrace(); } log.info("验签结果：" + signCheck); if (signCheck) { try { //解析请求体 JSONObject jsonObject = JSONUtil.parseObj(body); log.info("微信电子发票回调接口....解析请求体:"+jsonObject); String id = jsonObject.getStr("id");//可能是支付业务的回调数据 String create_time = jsonObject.getStr("create_time");//可能是支付业务的回调数据 String resource_type = jsonObject.getStr("resource_type");//可能是支付业务的回调数据 String event_type = jsonObject.getStr("event_type");//可能是支付业务的回调数据 String resource = jsonObject.getStr("resource");//可能是支付业务的回调数据 log.info("微信电子发票回调接口....id:"+ id); log.info("微信电子发票回调接口....create_time:"+ create_time); log.info("微信电子发票回调接口....resource_type:"+ resource_type); log.info("微信电子发票回调接口....event_type:"+ event_type); log.info("微信电子发票回调接口....resource:"+ resource); if ("FAPIAO.USER_APPLIED".equals(event_type)//用户发票抬头填写完成类型：FAPIAO.USER_APPLIED && "encrypt-resource".equals(resource_type)) {//通知的资源数据类型，确认成功通知为encryptresource。 JCEUtil.removeCryptographyRestrictions(); //解密 AesUtil aesUtil = new AesUtil(xcxProperties.getWecharpaySecretV3().getBytes("utf-8")); JSONObject jsonObjectResource = JSONUtil.parseObj(resource); String original_type = jsonObjectResource.getStr("original_type");//可能是支付业务的回调数据 String algorithm = jsonObjectResource.getStr("algorithm");//可能是支付业务的回调数据 String ciphertext = jsonObjectResource.getStr("ciphertext");//可能是支付业务的回调数据 String associated_data = jsonObjectResource.getStr("associated_data");//可能是支付业务的回调数据 String nonceStr = jsonObjectResource.getStr("nonce");//可能是支付业务的回调数据 String decryptToString = aesUtil.decryptToString( associated_data.getBytes("utf-8"), nonceStr.getBytes("utf-8"), ciphertext); log.info("微信电子发票回调接口....resource解密:"+decryptToString); JSONObject parseObj = JSONUtil.parseObj(decryptToString); log.info("微信电子发票回调接口....resource解密-JSONObject:"+parseObj); String fapiao_apply_id = parseObj.getStr("fapiao_apply_id"); log.info("微信电子发票回调接口....resource解密-fapiao_apply_id:"+fapiao_apply_id); MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectBypayOrderNo(fapiao_apply_id); if(ObjectUtil.isEmpty(mallOrderInfo)){ map.put("code",404); map.put("message", "订单不存在"); return map; } if(ObjectUtil.isNotEmpty(mallOrderInfo)){ //更新订单状态 // mallOrderInfo.setIsInvoice(1); // mallOrderInfoMapper.updateById(mallOrderInfo); //获取用户的抬头信息 String userInvoiceInfo = this.getUserInvoiceInfo(fapiao_apply_id); JSONObject userInvoiceInfoJson = JSONUtil.parseObj(userInvoiceInfo); //查看当前订单是否已经开具发票 Long memberId = mallOrderInfo.getMemberId(); String payOrderNo = mallOrderInfo.getPayOrderNo(); List mallInvoices = mallInvoiceMapper.selectByFapiaoApplyIdAndMemberId(fapiao_apply_id, mallOrderInfo.getMemberId()); if(CollUtil.isEmpty(mallInvoices)){ MallInvoice mallInvoice = new MallInvoice(); mallInvoice.setMemberId(memberId); mallInvoice.setFapiaoApplyId(payOrderNo); mallInvoice.setOrderNo(mallOrderInfo.getOrderNo()); mallInvoice.setOrderId(mallOrderInfo.getId()); mallInvoice.setStatus(mallOrderInfo.getStatus()); mallInvoice.setAmount(mallOrderInfo.getAmount()); List mallOrderItemList = mallOrderItemMapper.selectListByOrderId(mallOrderInfo.getId()); mallInvoice.setGoodsImg(mallOrderItemList.get(0).getSkuImage()); mallInvoice.setState(1); mallInvoice.setType(userInvoiceInfoJson.getStr("type")); mallInvoice.setName(userInvoiceInfoJson.getStr("name")); mallInvoice.setTaxpayerId(userInvoiceInfoJson.getStr("taxpayer_id")); mallInvoice.setAddress(userInvoiceInfoJson.getStr("address")); mallInvoice.setTelephone(userInvoiceInfoJson.getStr("telephone")); mallInvoice.setBankName(userInvoiceInfoJson.getStr("bank_name")); mallInvoice.setBankAccount(userInvoiceInfoJson.getStr("bank_account")); mallInvoiceMapper.insert(mallInvoice); }else{ MallInvoice mallInvoice = mallInvoices.get(0); if(2 != mallInvoice.getState()){ mallInvoice.setState(1); mallInvoice.setType(userInvoiceInfoJson.getStr("type")); mallInvoice.setName(userInvoiceInfoJson.getStr("name")); mallInvoice.setTaxpayerId(userInvoiceInfoJson.getStr("taxpayer_id")); mallInvoice.setAddress(userInvoiceInfoJson.getStr("address")); mallInvoice.setTelephone(userInvoiceInfoJson.getStr("telephone")); mallInvoice.setBankName(userInvoiceInfoJson.getStr("bank_name")); mallInvoice.setBankAccount(userInvoiceInfoJson.getStr("bank_account")); mallInvoiceMapper.updateById(mallInvoice); } } //省略查询订单 //此处处理业务 map.put("code","SUCCESS"); map.put("message","成功"); //消息推送成功 return map; } } map.put("code",404); map.put("message", "订单不存在"); return map; }catch (Exception e) { e.printStackTrace(); } } map.put("code",500); map.put("message", "失败"); return map; } /** * 获取用户的抬头信息 */ @Override public String getUserInvoiceInfo(String fapiaoApplyId) throws IOException { //初始化请求参数 Map params = new HashMap<>(); params.put("scene","WITH_WECHATPAY"); // params.put("fapiao_apply_id","4200002070202401175245187105"); params.put("fapiao_apply_id",fapiaoApplyId); String baseUrl = "https://api.mch.weixin.qq.com"; String canonicalUrl = "/v3/new-tax-control-fapiao/user-title"; String urlparm = baseUrl+canonicalUrl;//有参数的get请求，加密是需要把参数加载进去URL List parameters = new ArrayList<>(); for (Map.Entry entry : params.entrySet()) { parameters.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString())); } StringBuilder dataparm = new StringBuilder(); params.forEach((k, v) -> dataparm.append("&" + k + "=" + v)); String string = dataparm.toString(); if (!"".equals(string)) { urlparm = baseUrl+canonicalUrl + "?" + dataparm.substring(1); } PrivateKey privateKey = this.getPrivateKeyV3(); String postStr = null; try { postStr = this.createAuthorization( "GET", urlparm, "", privateKey ); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } return this.sendGet(baseUrl+canonicalUrl, params, "WECHATPAY2-SHA256-RSA2048 "+postStr); } /** * 验证签名 * * @param timestamp 微信平台传入的时间戳 * @param nonce 微信平台传入的随机字符串 * @param requestBody 微信平台传入的消息体 * @param signature 微信平台传入的签名 * @return * @throws NoSuchAlgorithmException * @throws SignatureException * @throws IOException * @throws InvalidKeyException */ public boolean signCheck(String timestamp, String nonce, Map requestBody, String signature) throws NoSuchAlgorithmException, SignatureException, IOException, InvalidKeyException, ParseException { //构造验签名串 String signatureStr = timestamp + "\n" + nonce + "\n" + com.alibaba.fastjson.JSONObject.toJSONString(requestBody) + "\n"; // 加载SHA256withRSA签名器 Signature signer = Signature.getInstance("SHA256withRSA"); // 用微信平台公钥对签名器进行初始化（调上一节中的获取平台证书方法） signer.initVerify(getCertificates()); // 把我们构造的验签名串更新到签名器中 signer.update(signatureStr.getBytes(StandardCharsets.UTF_8)); // 把请求头中微信服务器返回的签名用Base64解码 并使用签名器进行验证 boolean result = signer.verify(Base64Utils.decodeFromString(signature)); return result; } /** * 获取平台证书 */ public X509Certificate getCertificates() throws IOException, NoSuchAlgorithmException, SignatureException, InvalidKeyException, ParseException { JCEUtil.removeCryptographyRestrictions(); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss"); PrivateKey privateKey = this.getPrivateKeyV3(); String baseUrl = "https://api.mch.weixin.qq.com"; String canonicalUrl = "/v3/certificates"; String postStr = null; try { postStr = this.createAuthorization( "GET", baseUrl+canonicalUrl, "", privateKey ); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } //完成签名并执行请求 X509Certificate x509Certificate = null; try { String responseBodyAsString = this.sendGet(baseUrl + canonicalUrl, new HashMap<>(), "WECHATPAY2-SHA256-RSA2048 "+postStr); FPCertificateVo certificateVo = com.alibaba.fastjson.JSONObject.parseObject(responseBodyAsString, FPCertificateVo.class); for (FPCertificates certificates : certificateVo.getData()) { if (format.parse(certificates.getEffective_time()).before(new Date()) && format.parse(certificates.getExpire_time()).after(new Date())) { FPEncryptCertificate encrypt_certificate = certificates.getEncrypt_certificate(); //解密 AesUtil aesUtil = new AesUtil(xcxProperties.getWecharpaySecretV3().getBytes("utf-8")); String pulicKey = aesUtil.decryptToString( encrypt_certificate.getAssociated_data().getBytes("utf-8"), encrypt_certificate.getNonce().getBytes("utf-8"), encrypt_certificate.getCiphertext()); //获取平台证书 final CertificateFactory cf = CertificateFactory.getInstance("X509"); ByteArrayInputStream inputStream = new ByteArrayInputStream(pulicKey.getBytes(StandardCharsets.UTF_8)); x509Certificate = (X509Certificate) cf.generateCertificate(inputStream); } } return x509Certificate; } catch (GeneralSecurityException | ParseException e) { e.printStackTrace(); } return null; } public static void main(String[] args) throws UnsupportedEncodingException, GeneralSecurityException { String signature = "WECHATPAY/SIGNTEST/9WwfXW/noMdzDPcOrFD51Bf5YIThXLTtLCl5hoGlSfIBdY2UpE+5eHLs0XyF7y2cQc4OlzTzDDxSMTp/p/8ZenE2hMBaQjxVrdbTtrOLA1h13/WjCNaTr1URTqQ5+IF5bLCxAW8BmZ0jEqpmI/HYR3wdK8/7W91c1zfKODYgkvJzxFzd8OWi2GtELE5tLamkOLyb0GEcsGww2DUOypO5HjNyITgsy9R00w3OH92UInCD8Z6c5BAsQNySqFK8N52y38AlIWTtKROHmJtu+kHbt+nMOU0kbB5bZcPAptsnVYpp9KMmjMrmyjiKtHZb2TGIWiN/L+bgceyN3g=="; if(signature.contains("WECHATPAY/SIGNTEST")){ System.out.println(1); } // JCEUtil.removeCryptographyRestrictions(); // String body = "{\"id\":\"5fb7f522-466f-5c99-a325-0eb4001f1ec3\",\"create_time\":\"2024-01-17T15:38:33+08:00\",\"resource_type\":\"encrypt-resource\",\"event_type\":\"FAPIAO.USER_APPLIED\",\"summary\":\"用户已申请开票\",\"resource\":{\"original_type\":\"fapiao\",\"algorithm\":\"AEAD_AES_256_GCM\",\"ciphertext\":\"bBOs5WTUV1AhwiYSIUugaw9z4EHXxC28ZVsGHOppCNP4qpxYgnR+W+l983UyETmD/Wgu8ukJhe/xYkSsF947pgDP1ElTXC8MJA3lCc8NlsXQ1csPfWTS6A0XrxBoNMgwGEsYFo/7tPW/zDrEpzRZL/GgEwEtK6X1Y4Ci9IofzeI=\",\"associated_data\":\"fapiao\",\"nonce\":\"7a5dzuYqStef\"}}"; // JSONObject jsonObject = JSONUtil.parseObj(body); // log.info("微信电子发票回调接口....解析请求体:"+jsonObject); // // String id = jsonObject.getStr("id");//可能是支付业务的回调数据 // String create_time = jsonObject.getStr("create_time");//可能是支付业务的回调数据 // String resource_type = jsonObject.getStr("resource_type");//可能是支付业务的回调数据 // String event_type = jsonObject.getStr("event_type");//可能是支付业务的回调数据 // String resource = jsonObject.getStr("resource");//可能是支付业务的回调数据 // log.info("微信电子发票回调接口....id:"+ id); // log.info("微信电子发票回调接口....create_time:"+ create_time); // log.info("微信电子发票回调接口....resource_type:"+ resource_type); // log.info("微信电子发票回调接口....event_type:"+ event_type); // log.info("微信电子发票回调接口....resource:"+ resource); // // if ("FAPIAO.USER_APPLIED".equals(event_type)//用户发票抬头填写完成类型：FAPIAO.USER_APPLIED // && !"encryptresource".equals(resource_type)) {//通知的资源数据类型，确认成功通知为encryptresource。 // //解密 // AesUtil aesUtil = new AesUtil("daL341aN5orDt13puXadsAf2rpuX12v3".getBytes("utf-8")); // JSONObject jsonObjectResource = JSONUtil.parseObj(resource); //// String original_type = jsonObjectResource.getStr("original_type");//可能是支付业务的回调数据 //// String algorithm = jsonObjectResource.getStr("algorithm");//可能是支付业务的回调数据 // String ciphertext = jsonObjectResource.getStr("ciphertext");//可能是支付业务的回调数据 // String associated_data = jsonObjectResource.getStr("associated_data");//可能是支付业务的回调数据 // String nonce = jsonObjectResource.getStr("nonce");//可能是支付业务的回调数据 // String decryptToString = aesUtil.decryptToString( // associated_data.getBytes("utf-8"), // nonce.getBytes("utf-8"), // ciphertext); // log.info("微信电子发票回调接口....resource解密:"+decryptToString); // // JSONObject parseObj = JSONUtil.parseObj(decryptToString); // log.info("微信电子发票回调接口....resource解密-JSONObject:"+parseObj); // String fapiao_apply_id = parseObj.getStr("fapiao_apply_id"); // log.info("微信电子发票回调接口....resource解密-fapiao_apply_id:"+fapiao_apply_id); // // } } }