退款

src/main/java/com/huiju/estateagents/controller/WxPayController.java

@@ -2,21 +2,31 @@ package com.huiju.estateagents.controller;
 
 import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.MD5Utils;
 import com.huiju.estateagents.common.wxpay.WXPayConstants;
 import com.huiju.estateagents.common.wxpay.WXPayUtil;
 import com.huiju.estateagents.entity.TaOrder;
 import com.huiju.estateagents.service.IWxPayService;
 import lombok.extern.slf4j.Slf4j;
+import org.bouncycastle.jce.provider.BouncyCastleProvider;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
+import sun.misc.BASE64Decoder;
+import sun.security.provider.MD5;
 
+import javax.crypto.Cipher;
+import javax.crypto.spec.SecretKeySpec;
 import javax.servlet.http.HttpServletRequest;
 import java.io.ByteArrayOutputStream;
 import java.io.InputStream;
+import java.security.Security;
+import java.util.Base64;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+import static sun.security.x509.CertificateAlgorithmId.ALGORITHM;
+
 @Slf4j
 @RestController
 @RequestMapping("/api")
@@ -116,7 +126,7 @@ public class WxPayController extends BaseController {
 
             // 获取微信调用我们notify_url的返回信息
             String result = new String(outSteam.toByteArray(), "utf-8");
-            log.info("wxnotify:微信支付----result----=" + result);
+            log.info("wxnotify:微信退款----result----=" + result);
 
             // 关闭流
             outSteam.close();
@@ -125,7 +135,10 @@ public class WxPayController extends BaseController {
             resultMap = WXPayUtil.xmlToMap(result);
             //处理业务需求
             if (WXPayConstants.SUCCESS.equalsIgnoreCase(resultMap.get("result_code"))) {
-                wxPayService.wxNotify(resultMap, type);
+                SecretKeySpec key = new SecretKeySpec(MD5Utils.md5("key需要从库里获取", "UTF-8").toLowerCase().getBytes(), "AES");
+                Cipher cipher = Cipher.getInstance("AES/ECB/PKCS5Padding");
+                cipher.init(Cipher.DECRYPT_MODE, key);
+                String req_info = new String(cipher.doFinal(new BASE64Decoder().decodeBuffer(resultMap.get("req_info"))), "UTF-8");
             }else {
                 log.error("支付回调出错{}",resultMap.get("return_msg"));
                 return failResult;