退款

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

@@ -14,6 +14,7 @@ import javax.servlet.http.HttpServletRequest;
 import java.io.ByteArrayOutputStream;
 import java.io.InputStream;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 @Slf4j
@@ -53,7 +54,7 @@ public class WxPayController extends BaseController {
      * @return
      */
     @RequestMapping(value = "/notify/{type}",method = RequestMethod.POST)
-    public String wxBillNotify(@PathVariable String type, HttpServletRequest request){
+    public String wxNotify(@PathVariable String type, HttpServletRequest request){
         log.info("支付成功回调开始，支付类型是{}",type);
         String failResult = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>" + "<return_msg><![CDATA[失败]]></return_msg>" + "</xml> ";
         String successResult = "<xml>" + "<return_code><![CDATA[SUCCESS]]></return_code>" + "<return_msg><![CDATA[OK]]></return_msg>" + "</xml> ";
@@ -92,4 +93,70 @@ public class WxPayController extends BaseController {
         return successResult;
     }
 
+    /**
+     * 微信退款成功回调接口
+     * @param type
+     * @param request
+     * @return
+     */
+    @RequestMapping(value = "/refund/{type}",method = RequestMethod.POST)
+    public String wxRefund(@PathVariable String type, HttpServletRequest request){
+        log.info("支付成功回调开始，支付类型是{}",type);
+        String failResult = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>" + "<return_msg><![CDATA[失败]]></return_msg>" + "</xml> ";
+        String successResult = "<xml>" + "<return_code><![CDATA[SUCCESS]]></return_code>" + "<return_msg><![CDATA[OK]]></return_msg>" + "</xml> ";
+        Map<String, String> resultMap = new HashMap<>();
+        try {
+            InputStream inStream = request.getInputStream();
+            ByteArrayOutputStream outSteam = new ByteArrayOutputStream();
+            byte[] buffer = new byte[1024];
+            int len = 0;
+            while ((len = inStream.read(buffer)) != -1) {
+                outSteam.write(buffer, 0, len);
+            }
+
+            // 获取微信调用我们notify_url的返回信息
+            String result = new String(outSteam.toByteArray(), "utf-8");
+            log.info("wxnotify:微信支付----result----=" + result);
+
+            // 关闭流
+            outSteam.close();
+            inStream.close();
+            // xml转换为map
+            resultMap = WXPayUtil.xmlToMap(result);
+            //处理业务需求
+            if (WXPayConstants.SUCCESS.equalsIgnoreCase(resultMap.get("result_code"))) {
+                wxPayService.wxNotify(resultMap, type);
+            }else {
+                log.error("支付回调出错{}",resultMap.get("return_msg"));
+                return failResult;
+            }
+
+        } catch (Exception e) {
+            log.error("支付回调出错{}",e.getMessage());
+            return failResult;
+        }
+
+        return successResult;
+    }
+
+    /**
+     * 微信申请退款接口
+     * @param taOrder
+     * @param request
+     * @return
+     */
+    @RequestMapping(value = "/admin/refund",method = RequestMethod.POST)
+    public ResponseBean wxRefund(@RequestBody TaOrder taOrder,
+                                       HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            wxPayService.payRefund(taOrder,getOrgId(request),getUserId(request));
+        } catch (Exception e) {
+            log.error("微信批量退款失败： {}" , e.getMessage());
+            responseBean.addError(e.getMessage());
+            return responseBean;
+        }
+        responseBean.addSuccess(taOrder);
+        return responseBean;
+    }
 }

src/main/java/com/huiju/estateagents/entity/TaOrder.java

@@ -1,6 +1,7 @@
 package com.huiju.estateagents.entity;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
@@ -85,5 +86,14 @@ public class TaOrder implements Serializable {
      */
     private String transactionId;
 
+    /**
+     * 退款单号
+     */
+    private String refundNo;
 
+    /**
+     * 退款原因
+     */
+    @TableField(exist = false)
+    private String refundReason;
 }

src/main/java/com/huiju/estateagents/interceptor/AccessInterceptor.java

@@ -70,7 +70,8 @@ public class AccessInterceptor implements HandlerInterceptor {
             "/clean/menurole",
             "/clean/buttonrole",
             "/api/admin/taPersonFromRecord",
-            "/api/notify",//微信支付所有回掉放过
+            "/api/notify",//微信支付所有回调放过
+            "/api/refund/",//微信退款所有回调放过
     };
 
     /*

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

@@ -16,4 +16,12 @@ public interface IWxPayService {
     ResponseBean payUnifiedOrder(TaOrder taOrder, String clientIp) throws Exception;
 
     void wxNotify(Map<String, String> resultMap, String type);
+
+    /**
+     * 微信退款接口
+     * @param taOrder
+     * @param orgId
+     * @param userId
+     */
+    void payRefund(TaOrder taOrder, Integer orgId, Integer userId) throws Exception;
 }

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

@@ -25,12 +25,14 @@ import java.util.Map;
 
 @Slf4j
 @Service
-@Transactional(rollbackFor = Exception.class)
 public class WxPayServiceImpl implements IWxPayService {
 
     @Value("${pay-notify}")
     private String payNotify;
 
+    @Value("${pay-refund}")
+    private String payRefund;
+
     @Autowired
     private TaWxPayConfigMapper taWxPayConfigMapper;
 
@@ -57,6 +59,7 @@ public class WxPayServiceImpl implements IWxPayService {
      * @return
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public ResponseBean payUnifiedOrder(TaOrder taOrder, String clientIp) throws Exception {
         //构建微信配置
         WxConfig config = getWxConfig(taOrder.getOrgId());
@@ -126,6 +129,88 @@ public class WxPayServiceImpl implements IWxPayService {
 
     }
 
+    /**
+     * 微信退款
+     * @param taOrder
+     * @param orgId
+     * @param userId
+     * @throws Exception
+     */
+    @Override
+    public void payRefund(TaOrder taOrder, Integer orgId, Integer userId) throws Exception {
+        //构建微信配置
+        WxConfig config = getWxConfig(taOrder.getOrgId());
+        WXPay wxpay = new WXPay(config);
+
+        //获取支付的钱数并且判断是自动锁房还是手动锁房,自动锁房需要锁定房源，手动锁房跳过
+        String payPrice = getRefundPrice(taOrder);
+        if (null == payPrice){
+            throw new Exception("此认筹单异常请联系置业顾问！");
+        }
+
+        //退款单
+        Map<String, String> data = new HashMap<String, String>();
+        //商品号唯一
+        data.put("transaction_id", taOrder.getTransactionId());
+        data.put("out_refund_no", taOrder.getRefundNo());
+        data.put("fee_type", "CNY");
+        //金额 后台计算
+        data.put("total_fee", payPrice);
+        data.put("refund_fee", payPrice);
+        //退款原因
+        data.put("refund_desc", taOrder.getRefundReason());
+        //回调地址
+        data.put("notify_url", payRefund+taOrder.getTargetType());
+        Map<String, String> resp = wxpay.refund(data);
+        log.info("退款下单成功：{}", resp);
+        if (resp.get("result_code").equalsIgnoreCase(WXPayConstants.FAIL)){
+            throw new Exception(resp.get("err_code_des"));
+        }
+
+        //更新退款状态并插入退款订单并更新认筹单的退款原因
+        updateRefundOrderStatus(taOrder);
+    }
+
+    /**
+     * 插入退款订单并更新认筹单的退款原因
+     * @param taOrder
+     */
+    private void updateRefundOrderStatus(TaOrder taOrder) {
+        //插入退款单
+        taOrder.setCreateDate(LocalDateTime.now());
+        taOrderMapper.insert(taOrder);
+        //更新认筹单退款原因
+        TaRaiseRecord taRaiseRecord = taRaiseRecordMapper.selectById(taOrder.getTargetId());
+        taRaiseRecord.setRefundReason(taOrder.getRefundReason());
+        taRaiseRecordMapper.updateById(taRaiseRecord);
+    }
+
+    /**
+     * 获取退款金额
+     * @param taOrder
+     * @return
+     */
+    private String getRefundPrice(TaOrder taOrder) throws Exception {
+        if (taOrder.getTargetType().equals(CommConstant.ORDER_TARGET_TYPE_HOUSE)){
+            TaRaiseRecord taRaiseRecord = taRaiseRecordMapper.selectById(taOrder.getTargetId());
+            if (null == taRaiseRecord){
+                throw new Exception("此认筹单不存在！请联系置业顾问！");
+            }
+            //获取订单中的价格
+            TaOrder refundOrder = taOrderMapper.selectById(taRaiseRecord.getOrderId());
+            //退款单号
+            taOrder.setRefundNo("T"+refundOrder.getTradeNo());
+            taOrder.setParentOrderId(refundOrder.getOrderId());
+            taOrder.setOrgId(refundOrder.getOrgId());
+            taOrder.setPayTime(refundOrder.getPayTime());
+            taOrder.setPersonId(refundOrder.getPersonId());
+            taOrder.setTradeNo(refundOrder.getTradeNo());
+            taOrder.setTotalFee(refundOrder.getTotalFee());
+            return String.valueOf(refundOrder.getTotalFee());
+        }
+        return null;
+    }
+
     /**
      * 处理认筹房源的相关数据
      * @param resultMap

src/main/resources/application-blue.yml

@@ -74,4 +74,6 @@ sms:
     code: "0501"
 
 # 支付回调
-pay-notify: https://dev.pawoma.cn/api/notify/
+pay-notify: https://dev.pawoma.cn/api/notify/
+#退款回调
+pay-refund: https://dev.pawoma.cn/api/refund/