微信退款

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

@@ -1,11 +1,14 @@
 package com.huiju.estateagents.controller;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 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.entity.TaWxPayConfig;
+import com.huiju.estateagents.service.ITaWxPayConfigService;
 import com.huiju.estateagents.service.IWxPayService;
 import lombok.extern.slf4j.Slf4j;
 import org.bouncycastle.jce.provider.BouncyCastleProvider;
@@ -35,6 +38,9 @@ public class WxPayController extends BaseController {
     @Autowired
     private IWxPayService wxPayService;
 
+    @Autowired
+    private ITaWxPayConfigService taWxPayConfigService;
+
     /**
      * 微信统一下单接口
      * @param taOrder
@@ -135,10 +141,16 @@ public class WxPayController extends BaseController {
             resultMap = WXPayUtil.xmlToMap(result);
             //处理业务需求
             if (WXPayConstants.SUCCESS.equalsIgnoreCase(resultMap.get("result_code"))) {
-                SecretKeySpec key = new SecretKeySpec(MD5Utils.md5("key需要从库里获取", "UTF-8").toLowerCase().getBytes(), "AES");
+                String mchId = resultMap.get("mch_id");
+                QueryWrapper<TaWxPayConfig> queryWrapper = new QueryWrapper<>();
+                queryWrapper.eq("mch_id",mchId);
+                String mchKey = taWxPayConfigService.list(queryWrapper).get(0).getMchKey();
+                SecretKeySpec key = new SecretKeySpec(MD5Utils.md5(mchKey, "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");
+                Map<String, String> orderInfo = WXPayUtil.xmlToMap(req_info);
+                wxPayService.houseRefund(orderInfo);
             }else {
                 log.error("支付回调出错{}",resultMap.get("return_msg"));
                 return failResult;

src/main/java/com/huiju/estateagents/service/IWxPayService.java

@@ -24,4 +24,6 @@ public interface IWxPayService {
      * @param userId
      */
     void payRefund(TaOrder taOrder, Integer orgId, Integer userId) throws Exception;
+
+    void houseRefund(Map<String, String> orderInfo);
 }

src/main/java/com/huiju/estateagents/service/impl/WxPayServiceImpl.java

@@ -171,6 +171,27 @@ public class WxPayServiceImpl implements IWxPayService {
         updateRefundOrderStatus(taOrder);
     }
 
+    /**
+     * 微信退款接口
+     * @param orderInfo
+     */
+    @Override
+    public void houseRefund(Map<String, String> orderInfo) {
+        //更新订单状态为退款
+        String transactionId = orderInfo.get("transaction_id");
+        List<TaOrder> orderList = taOrderMapper.selectList(new QueryWrapper<TaOrder>().eq("transaction_id", transactionId));
+        orderList.forEach(e -> {
+            e.setPayStatus(CommConstant.PAY_STATUS_REFUNDED);
+            taOrderMapper.updateById(e);
+            if (null != e.getParentOrderId()){
+                //更新认筹单为退款
+                TaRaiseRecord taRaiseRecord = taRaiseRecordMapper.selectOne(new QueryWrapper<TaRaiseRecord>().eq("order_id", e.getParentOrderId()));
+                taRaiseRecord.setPayStatus(CommConstant.PAY_STATUS_REFUNDED);
+                taRaiseRecordMapper.updateById(taRaiseRecord);
+            }
+        });
+    }
+
     /**
      * 插入退款订单并更新认筹单的退款原因
      * @param taOrder