From 72f43644f615875fe2de6d98712661c19d7421df Mon Sep 17 00:00:00 2001
From: rentaiming <806181062@qq.com>
Date: 星期三, 22 五月 2024 12:02:23 +0800
Subject: [PATCH] 对接支付宝和微信
---
ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/domain/pojo/OrderAuctionBond.java | 5
ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/PaylogServiceImpl.java | 414 +++++++++++++++++++++++++++
ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderAuctionBondServiceImpl.java | 50 ++
ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/IOrderAuctionBondService.java | 4
ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/controller/PaylogController.java | 350 ----------------------
ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/IPaylogService.java | 35 ++
6 files changed, 513 insertions(+), 345 deletions(-)
diff --git a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/controller/PaylogController.java b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/controller/PaylogController.java
index 0133a6a..8016476 100644
--- a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/controller/PaylogController.java
+++ b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/controller/PaylogController.java
@@ -8,6 +8,7 @@
import com.ruoyi.common.core.domain.R;
import com.ruoyi.order.domain.pojo.Paylog;
import com.ruoyi.order.service.IPaylogService;
+import com.ruoyi.order.service.impl.PaylogServiceImpl;
import com.ruoyi.order.util.DateUtil;
import com.ruoyi.order.util.SinataUtil;
import com.ruoyi.order.util.alipay.config.AlipayConfig;
@@ -67,99 +68,23 @@
@Resource
private IPaylogService iPaylogService;
+
+ @Resource
+ private PaylogServiceImpl paylogServiceImpl;
+
Logger log = LoggerFactory.getLogger(getClass());
@ResponseBody
- @RequestMapping("getPayInfo")
+ @RequestMapping("/getPayInfo")
public R<Map<String, Object>> getPayInfo(Integer uid, Integer type, String subject, String body, String orderID,
HttpServletRequest request) {
- Double price = 0.0;
-
try {
- if(judgeContainsStr(orderID)){
- price= Double.valueOf(1);
- body = "商品支付";
- subject = "商品支付";
- Map<String, Object> map = new HashMap<String, Object>();
- if (type == 1) {
- // 支付宝预下单
- return alipay("1", subject, body, price, request);
- } else {
- // 微信预下单
- return wxpay(1, "1", body, price, request);
- }
- }
+ return paylogServiceImpl.getPayInfo(uid, type, subject, body, orderID,request);
} catch (Exception e) {
- e.printStackTrace();
+ return R.fail("获取异常");
}
- return R.fail("获取异常");
+
}
- /**
- * 支付宝订单退款
- *
- * @author tzj
- * @param out_trade_no
- * 商品订单号
- * @param trade_no
- * 支付宝交易号
- * @param refund_amount
- * 退款金额
- * @return
- */
- public boolean refundForAlipay(String out_trade_no, String trade_no, Double refund_amount) {
- try {
- // 实例化客户端
- AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do",
- AlipayConfig.app_id, AlipayConfig.private_key, "json", AlipayConfig.input_charset,
- AlipayConfig.ali_public_key,"RSA2");
- // 实例化具体API对应的request类,类名称和接口名称对应
- AlipayTradeRefundRequest request = new AlipayTradeRefundRequest();
- // SDK已经封装掉了公共参数，这里只需要传入业务参数
- // 此次只是参数展示，未进行字符串转义，实际情况下请转义
- request.setBizContent("{" + "\"out_trade_no\":\"" + out_trade_no + "\", " + "\"trade_no\":\"" + trade_no
- + "\", " + "\"refund_amount\":" + refund_amount + ", " + "\"refund_reason\":\"正常退款\","
- + "\"out_request_no\":\"HZ01RF001\"" + "}");
- AlipayTradeRefundResponse response = alipayClient.execute(request);
- // 调用成功，则处理业务逻辑
- if (response.isSuccess()) {
- return true;
- }
- } catch (Exception e) {
- e.printStackTrace();
- return false;
- }
- return false;
- }
-
- /**
- * 获取支付信息支付(签约app支付2.0)
- *
- * @param subject
- * @param body
- * @param price
- * @param request
- * @return
- */
- public R<Map<String, Object>> alipay(String orderNo, String subject, String body, Double price,
- HttpServletRequest request) {
- try {
- // 接口封装支付宝请求参数
- // Map<String, Object> mData = new HashMap<String, Object>();
-
- // 构建请求支付签名参数
- Map<String, Object> pay = PayDemoActivity.appPay(subject, body, price, orderNo);
- /*
- * Set<Entry<String, String>> entrySet = pay.entrySet();
- * Iterator<Entry<String, String>> iterator = entrySet.iterator();
- * while (iterator.hasNext()) { Entry<String, String> next =
- * iterator.next(); mData.put(next.getKey(), next.getValue()); }
- */
- return R.ok(pay);
- } catch (Exception e) {
- e.printStackTrace();
- return R.fail("支付异常!");
- }
- }
/**
* 服务器异步通知处理支付宝
@@ -168,116 +93,15 @@
* @param res
*/
@RequestMapping("/alipay/notify")
- public void notifyUrl(HttpServletRequest request, HttpServletResponse res) {
- HttpServletResponse response = (HttpServletResponse) res;
- response.setContentType("text/html;charset=UTF-8");
- PrintWriter out;
+ public void notifyUrl(HttpServletRequest request, HttpServletResponse response) {
try {
- out = response.getWriter();
- // 获取支付宝POST过来反馈信息
- Map<String, String> params = new HashMap<String, String>();
- Map requestParams = request.getParameterMap();
- log.debug("AlipayController.notifyUrl__requestParams：\n" + requestParams);
- for (Iterator iter = requestParams.keySet().iterator(); iter.hasNext();) {
- String name = (String) iter.next();
- String[] values = (String[]) requestParams.get(name);
- String valueStr = "";
- for (int i = 0; i < values.length; i++) {
- valueStr = (i == values.length - 1) ? valueStr + values[i] : valueStr + values[i] + ",";
- }
- // 乱码解决，这段代码在出现乱码时使用。如果mysign和sign不相等也可以使用这段代码转化
- valueStr = new String(valueStr.getBytes("ISO-8859-1"), "gbk");
- params.put(name, valueStr);
- }
+ paylogServiceImpl.notifyUrl(request,response);
+ } catch (Exception e) {
- Paylog paylog = getPayLog_alipay(request);
-
- // 验证成功
- if ("TRADE_FINISHED".equals(paylog.getTradeStatus())) {
- System.out.println("AlipayController.notifyUrl__验证成功：success");
- // 支付失败
- } else if ("TRADE_SUCCESS".equals(paylog.getTradeStatus())) {
- // 支付成功
- try {
- if(judgeContainsStr(paylog.getOutTradeNo())){
-
-
- }
- // ——请根据您的业务逻辑来编写程序（以上代码仅作参考）——
- log.debug("AlipayController.notifyUrl__回调处理：success");
- out.println("success"); // 请不要修改或删除
- // ——请根据您的业务逻辑来编写程序（以上代码仅作参考）——
- log.debug("AlipayController.notifyUrl__回调处理：success");
- out.println("success"); // 请不要修改或删除
- } catch (Exception e) {
- log.debug("AlipayController.notifyUrl__回调逻辑代码处理异常！fail");
- // 返回失败
- out.println("fail");
- e.printStackTrace();
- }
- // ////////////////////////////////////////////////////////////////////////////////////////
- } else {// 验证失败
- log.debug("AlipayController.notifyUrl__回调处理失败！fail");
- out.println("fail");
}
- } catch (
- IOException e) {
- log.debug("AlipayController.notifyUrl__支付宝服务器异步通知数据处理失败！");
- e.printStackTrace();
- }
}
///////////////////////////////////////////////////////////////////////////////////////////////////
-/**
- * 统一下单
- *
- * @param apptype
- * @param outTradeNo
- * @param body
- * @param price
- * @param request
- * @return
- */
-public static R<Map<String, Object>> wxpay(Integer apptype, String outTradeNo, String body, Double price,
- HttpServletRequest request) {
- // 获取预支付接口返回参数
- Map<String, Object> map = new HashMap<String, Object>();
- Map<String, Object> appPayMap = new HashMap<String, Object>();
- try {
- // 构建接口请求参数
- UnifiedorderReqData unifiedorderReqData = new UnifiedorderReqData(apptype, outTradeNo, body, price,
- Configure.wx_notify_url);
- // 请求接口获取返回接口
- String result = requestUnifiedorderService(apptype, unifiedorderReqData);
- System.out.println(result);
- System.out.println("WxpayController.createOrder__result：\n" + result);
- // 获取预支付接口返回参数
- map = XMLParser.getMapFromXML(result);
- System.out.println("WxpayController.createOrder__result：\n" + result);
- // 捕获预支付接口错误提示
- if ("FAIL".equals(map.get("result_code")) || "FAIL".equals(map.get("return_code"))) {
- return R.fail(String.valueOf(map.get("return_msg")));
- }
-
- // 对获取预支付返回接口参数进行封装（生成支付订单接口数据）
- AppPayReqData appPay = new AppPayReqData(apptype, (String) map.get("appid"), (String) map.get("mch_id"),
- (String) map.get("prepay_id"), unifiedorderReqData.getNonce_str());
-
- // 对获取预支付返回接口参数进行封装（生成支付订单接口数据）
- appPayMap.put("appid", appPay.getAppid());// 公众账号ID
- appPayMap.put("nonceStr", appPay.getNoncestr());// 随机字符串(32位)
- appPayMap.put("package", appPay.get_package());// 扩展字段(暂填写固定值Sign=WXPay)
- appPayMap.put("partnerId", appPay.getPartnerid());// 商户号
- appPayMap.put("prepayId", appPay.getPrepayid());// 预支付编号（微信返回的支付交易会话ID）
- appPayMap.put("timeStamp", appPay.getTimestamp());// 时间戳
- appPayMap.put("sign", appPay.getSign());// 根据API给的签名规则进行签名
- return R.ok(appPayMap);
- } catch (Exception e) {
- System.out.println("统一下单_API_处理异常！");
- e.printStackTrace();
- }
- return R.fail("统一下单失败");
-}
/**
* 微信支付回调（参考财付通回调接口）
@@ -288,159 +112,13 @@
@RequestMapping("/wxpay/notify")
public void wxnotify(HttpServletRequest request, HttpServletResponse response) {
try {
- System.out.println("微信支付回调！！！！！！！！！！！！！！！！！！！！！！！！！");
- // 异步通知返回报文
- StringBuffer notityXml = new StringBuffer();
- String inputLine;
- while ((inputLine = request.getReader().readLine()) != null) {
- notityXml.append(inputLine);
- }
- request.getReader().close();
- // log.debug("WxpayController.notify__notityXml：\n" + notityXml);
- System.out.println("WxpayController.notify__notityXml：\n" + notityXml);
-
- // 验证签名
- if (Signature.checkIsSignValidFromResponseString(1, notityXml.toString())
- || Signature.checkIsSignValidFromResponseString(2, notityXml.toString())) {
- Map<String, Object> map = XMLParser.getMapFromXML(notityXml.toString());
- // log.debug("WxpayController.notify__map：\n" + map);
- // 接口返回状态
- String result_code = (String) map.get("result_code");
- if ("SUCCESS".equals(result_code)) {
- // // 商户订单号
- String out_trade_no = (String) map.get("out_trade_no");
- // // 微信支付交易号
- String trade_no = (String) map.get("transaction_id");
- // // 金额,以分为单位
- String total_fee = (String) map.get("total_fee");
- // // 优惠金额
- // String discount = (String) map.get("discount");
- // // 支付完成时间
- String time_end = (String) map.get("time_end");
- // // 支付者唯一Id（对应买家账号的一个加密串 ）
- String buyer_id = (String) map.get("buyer_id");
-
- ///////////////////////////// 这里程序处理支付回调逻辑
- ///////////////////////////// ////////////////////
- Paylog paylog = new Paylog();
- paylog.setOutTradeNo(out_trade_no);
- paylog.setPayType(2);
- paylog.setBuyerId(buyer_id);
- paylog.setTradeNo(trade_no);
- paylog.setPayMoney(Double.parseDouble(total_fee) / 100);
- paylog.setState(1);
- System.out.println("支付完成时间"+time_end);
- paylog.setAddTime(LocalDateTime.now());
- iPaylogService.save(paylog);
- if(judgeContainsStr(paylog.getOutTradeNo())){
-
-
-
- log.debug("WxpayController.notify__回调处理成功：SUCCESS");
- response.getOutputStream().print("success");
- }
- log.debug("WxpayController.notify__回调处理成功：SUCCESS");
- response.getOutputStream().print("success");
- } else {
- log.debug("WxpayController.notify__回调处理：验证状态错误！" + result_code);
- System.out.println("验证状态错误！" + result_code);
- }
- } else {
- log.debug("WxpayController.notify__回调处理：通知签名验证失败！");
- System.out.println("通知签名验证失败！");
- }
+ paylogServiceImpl.notifyUrl(request,response);
} catch (Exception e) {
- e.printStackTrace();
+
}
}
-/**
- * 微信退款
- *
- * @param transactionID
- * 【支付交易号】是微信系统为每一笔支付交易分配的订单号，通过这个订单号可以标识这笔交易，
- * 它由支付订单API支付成功时返回的数据里面获取到。建议优先使用
- * @param outTradeNo
- * 【商品订单编号】商户系统内部的订单号,transaction_id
- * 、out_trade_no二选一，如果同时存在优先级：transaction_id>out_trade_no
- * @param outRefundNo
- * 【退款编号】商户系统内部的退款单号，商户系统内部唯一，同一退款单号多次请求只退一笔
- * 订单总金额，单位为分
- * @param refundFee
- * 退款总金额，单位为分,可以做部分退款
- * @return
- */
-public static boolean refundForWxpay(Integer apptype, String transactionID, String outTradeNo, String outRefundNo,
- Integer totalFee, Integer refundFee, String pay_type) {
- Map<String, Object> map = new HashMap<String, Object>();
- try {
- // 构建接口请求参数
- com.tencent.protocol.RefundReqData refundReqData = new com.tencent.protocol.RefundReqData(transactionID, outTradeNo, outRefundNo, totalFee, refundFee,
- pay_type);
- // 请求接口返回结果
- String result = requestRefundService(apptype, refundReqData);
- System.out.println("微信退款返回内容：" + result);
- // 获取预支付接口返回参数
- map = XMLParser.getMapFromXML(result);
- System.out.println("微信退款返回参数：" + map);
- // 退款成功处理
- if ("SUCCESS".equals(map.get("result_code"))) {
- return true;
- }
- } catch (Exception e) {
- e.printStackTrace();
- return false;
- }
- return false;
-}
-
-/**
- * 获取支付宝
- *
- * @param request
- * @return
- * @throws Exception
- */
-private Paylog getPayLog_alipay(HttpServletRequest request) throws IOException {
- //////// 获取支付宝的通知返回参数，可参考技术文档中页面跳转同步通知参数列表(以下仅供参考)////////
- // 商户订单号
- String out_trade_no = new String(request.getParameter("out_trade_no").getBytes("ISO-8859-1"), "UTF-8");
- // 支付宝交易号
- String trade_no = new String(request.getParameter("trade_no").getBytes("ISO-8859-1"), "UTF-8");
- // 交易状态
- String trade_status = new String(request.getParameter("trade_status").getBytes("ISO-8859-1"), "UTF-8");
- // 支付者唯一Id
- String buyer_id = new String(request.getParameter("buyer_id").getBytes("ISO-8859-1"), "UTF-8");
- // 支付帐号
- String buyer_email = "";
- if (SinataUtil.isNotEmpty(request.getParameter("buyer_logon_id"))) {
- buyer_email = new String(request.getParameter("buyer_logon_id").getBytes("ISO-8859-1"), "UTF-8");
- }
- // 支付金额
- String total_fee = new String(request.getParameter("total_amount").getBytes("ISO-8859-1"), "UTF-8");
- // 支付时间
- String notify_time = new String(request.getParameter("notify_time").getBytes("ISO-8859-1"), "UTF-8");
-
- //////// 获取支付宝的通知返回参数，可参考技术文档中页面跳转同步通知参数列表(以下仅供参考)////////
- Paylog paylog = new Paylog();
- paylog.setOutTradeNo(out_trade_no);
- paylog.setPayType(1);
- paylog.setBuyerId(buyer_id);
- paylog.setTradeNo(trade_no);
- paylog.setPayMoney(Double.parseDouble(total_fee));
- paylog.setState(1);
- paylog.setAddTime(LocalDateTime.now());
- paylog.setTradeStatus(trade_status.toString());
- iPaylogService.save(paylog);
- return paylog;
-}
-
-public boolean judgeContainsStr(String cardNum) {
- String regex=".*[a-zA-Z]+.*";
- Matcher m= Pattern.compile(regex).matcher(cardNum);
- return m.matches();
-}
}
diff --git a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/domain/pojo/OrderAuctionBond.java b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/domain/pojo/OrderAuctionBond.java
index 75dfe4a..0577669 100644
--- a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/domain/pojo/OrderAuctionBond.java
+++ b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/domain/pojo/OrderAuctionBond.java
@@ -73,6 +73,11 @@
@ApiModelProperty(value = "删除标志（0代表存在 1代表删除）")
@TableLogic
private Integer delFlag;
+ @ApiModelProperty(value = "支付方式 1=微信 2=支付宝")
+ private Integer paymentMethod;
+
+ @ApiModelProperty(value = "保证金订单编号")
+ private String orderNo;
}
diff --git a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/IOrderAuctionBondService.java b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/IOrderAuctionBondService.java
index e8aaf5d..30c5c47 100644
--- a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/IOrderAuctionBondService.java
+++ b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/IOrderAuctionBondService.java
@@ -1,8 +1,10 @@
package com.ruoyi.order.service;
+import com.ruoyi.common.core.domain.R;
import com.ruoyi.order.domain.pojo.OrderAuctionBond;
import com.baomidou.mybatisplus.extension.service.IService;
import com.ruoyi.system.api.domain.dto.OrderAuctionBondDTO;
+import org.apache.poi.ss.formula.functions.T;
import org.springframework.web.bind.annotation.RequestBody;
/**
@@ -14,6 +16,6 @@
* @since 2024-05-16
*/
public interface IOrderAuctionBondService extends IService<OrderAuctionBond> {
- void getOrderAuctionBond( OrderAuctionBondDTO orderAuctionBondDTO);
+ R<T> getOrderAuctionBond(OrderAuctionBondDTO orderAuctionBondDTO);
}
diff --git a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/IPaylogService.java b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/IPaylogService.java
index ba443df..d861f56 100644
--- a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/IPaylogService.java
+++ b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/IPaylogService.java
@@ -1,7 +1,21 @@
package com.ruoyi.order.service;
+import com.ruoyi.common.core.domain.R;
import com.ruoyi.order.domain.pojo.Paylog;
import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.order.util.tencent.common.Signature;
+import com.ruoyi.order.util.tencent.common.XMLParser;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
/**
* <p>
@@ -13,4 +27,25 @@
*/
public interface IPaylogService extends IService<Paylog> {
+ R<Map<String, Object>> getPayInfo(Integer uid, Integer type, String subject, String body, String orderID,
+ HttpServletRequest request);
+
+
+ /**
+ * 服务器异步通知处理支付宝
+ *
+ * @param request
+ * @param res
+ */
+ @RequestMapping("/alipay/notify")
+ public void notifyUrl(HttpServletRequest request, HttpServletResponse res);
+///////////////////////////////////////////////////////////////////////////////////////////////////
+
+ /**
+ * 微信支付回调（参考财付通回调接口）
+ *
+ * @param request
+ * @param response
+ */
+ void wxnotify(HttpServletRequest request, HttpServletResponse response);
}
diff --git a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderAuctionBondServiceImpl.java b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderAuctionBondServiceImpl.java
index 7f5ccd6..244b3bf 100644
--- a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderAuctionBondServiceImpl.java
+++ b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderAuctionBondServiceImpl.java
@@ -2,11 +2,16 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.ruoyi.common.core.domain.R;
import com.ruoyi.order.domain.pojo.OrderAuctionBond;
+import com.ruoyi.order.domain.pojo.Paylog;
import com.ruoyi.order.mapper.OrderAuctionBondMapper;
import com.ruoyi.order.service.IOrderAuctionBondService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.order.service.IPaylogService;
+import com.ruoyi.order.util.SinataUtil;
import com.ruoyi.system.api.domain.dto.OrderAuctionBondDTO;
+import org.apache.poi.ss.formula.functions.T;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@@ -26,16 +31,45 @@
@Resource
private IOrderAuctionBondService iOrderAuctionBondService;
- @Override
- public void getOrderAuctionBond( OrderAuctionBondDTO orderAuctionBondDTO) {
- LambdaQueryWrapper<OrderAuctionBond> wrapper= Wrappers.lambdaQuery();
- wrapper.notIn(OrderAuctionBond::getMemberId,orderAuctionBondDTO.getUserList());
- wrapper.eq(OrderAuctionBond::getDelFlag,0);
- wrapper.eq(OrderAuctionBond::getAuctionSalesroomId,orderAuctionBondDTO.getAuctionSalesroomId());
- List<OrderAuctionBond> orderAuctionBondList=iOrderAuctionBondService.list(wrapper);
- for (OrderAuctionBond orderAuctionBond:orderAuctionBondList){
+ @Resource
+ private IPaylogService iPaylogService;
+
+ @Resource
+ private PaylogServiceImpl paylogServiceImpl;
+
+ @Override
+ public R<T> getOrderAuctionBond(OrderAuctionBondDTO orderAuctionBondDTO) {
+
+ LambdaQueryWrapper<OrderAuctionBond> wrapper = Wrappers.lambdaQuery();
+ wrapper.notIn(OrderAuctionBond::getMemberId, orderAuctionBondDTO.getUserList());
+ wrapper.eq(OrderAuctionBond::getDelFlag, 0);
+ wrapper.eq(OrderAuctionBond::getAuctionSalesroomId, orderAuctionBondDTO.getAuctionSalesroomId());
+ List<OrderAuctionBond> orderAuctionBondList = iOrderAuctionBondService.list(wrapper);
+ for (OrderAuctionBond orderAuctionBond : orderAuctionBondList) {
+
+ LambdaQueryWrapper<Paylog> wrapper1 = Wrappers.lambdaQuery();
+ wrapper1.notIn(Paylog::getOutTradeNo, orderAuctionBond.getOrderNo());
+ wrapper1.last("limit 1");
+ Paylog paylog = iPaylogService.getOne(wrapper1);
+
+ if (paylog.getPayType() == 1) {//支付宝
+ boolean bo = paylogServiceImpl.refundForAlipay(paylog.getOutTradeNo(), paylog.getTradeNo(), orderAuctionBond.getBond().doubleValue());
+ if (!bo) {
+ return R.fail("支付宝退款失败！");
+ }
+ } else {//微信
+ String refundMoney = SinataUtil.doubleRetainTwo(orderAuctionBond.getBond().doubleValue() * 100d);
+ Integer refundFee = Integer.parseInt(refundMoney.substring(0, refundMoney.length() - 3));
+ String money = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100d);
+ Integer totalFee = Integer.parseInt(money.substring(0, money.length() - 3));
+ boolean bo = paylogServiceImpl.refundForWxpay(1, paylog.getTradeNo(), paylog.getOutTradeNo(), orderAuctionBond.getOrderNo(), totalFee, refundFee, "2");
+ if (!bo) {
+ return R.fail("微信退款失败！");
+ }
+ }
}
+ return R.ok();
}
}
diff --git a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/PaylogServiceImpl.java b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/PaylogServiceImpl.java
index 36a6863..4d2cccf 100644
--- a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/PaylogServiceImpl.java
+++ b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/PaylogServiceImpl.java
@@ -1,10 +1,40 @@
package com.ruoyi.order.service.impl;
+import com.alipay.api.AlipayClient;
+import com.alipay.api.DefaultAlipayClient;
+import com.alipay.api.request.AlipayTradeRefundRequest;
+import com.alipay.api.response.AlipayTradeRefundResponse;
+import com.ruoyi.common.core.domain.R;
import com.ruoyi.order.domain.pojo.Paylog;
import com.ruoyi.order.mapper.PaylogMapper;
import com.ruoyi.order.service.IPaylogService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.order.util.SinataUtil;
+import com.ruoyi.order.util.alipay.config.AlipayConfig;
+import com.ruoyi.order.util.alipay.util.PayDemoActivity;
+import com.ruoyi.order.util.tencent.common.Configure;
+import com.ruoyi.order.util.tencent.common.Signature;
+import com.ruoyi.order.util.tencent.common.XMLParser;
+import com.ruoyi.order.util.tencent.protocol.AppPayReqData;
+import com.ruoyi.order.util.tencent.protocol.UnifiedorderReqData;
import org.springframework.stereotype.Service;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+import static com.ruoyi.order.util.tencent.WXPay.requestRefundService;
+import static com.ruoyi.order.util.tencent.WXPay.requestUnifiedorderService;
/**
* <p>
@@ -17,4 +47,388 @@
@Service
public class PaylogServiceImpl extends ServiceImpl<PaylogMapper, Paylog> implements IPaylogService {
+ @Resource
+ private PaylogServiceImpl paylogServiceImpl;
+
+ @Resource
+ private IPaylogService iPaylogService;
+
+ @Override
+ public R<Map<String, Object>> getPayInfo(Integer uid, Integer type, String subject, String body, String orderID,
+ HttpServletRequest request) {
+ Double price = 0.0;
+
+ try {
+ if(judgeContainsStr(orderID)){
+ price= Double.valueOf(1);
+ body = "商品支付";
+ subject = "商品支付";
+ Map<String, Object> map = new HashMap<String, Object>();
+ if (type == 1) {
+ // 支付宝预下单
+ return paylogServiceImpl.alipay("1", subject, body, price, request);
+ } else {
+ // 微信预下单
+ return wxpay(1, "1", body, price, request);
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return R.fail("获取异常");
+ }
+
+
+ /**
+ * 服务器异步通知处理支付宝
+ *
+ * @param request
+ * @param res
+ */
+ @Override
+ public void notifyUrl(HttpServletRequest request, HttpServletResponse res) {
+ HttpServletResponse response = (HttpServletResponse) res;
+ response.setContentType("text/html;charset=UTF-8");
+ PrintWriter out;
+ try {
+ out = response.getWriter();
+ // 获取支付宝POST过来反馈信息
+ Map<String, String> params = new HashMap<String, String>();
+ Map requestParams = request.getParameterMap();
+ log.debug("AlipayController.notifyUrl__requestParams：\n" + requestParams);
+ for (Iterator iter = requestParams.keySet().iterator(); iter.hasNext();) {
+ String name = (String) iter.next();
+ String[] values = (String[]) requestParams.get(name);
+ String valueStr = "";
+ for (int i = 0; i < values.length; i++) {
+ valueStr = (i == values.length - 1) ? valueStr + values[i] : valueStr + values[i] + ",";
+ }
+ // 乱码解决，这段代码在出现乱码时使用。如果mysign和sign不相等也可以使用这段代码转化
+ valueStr = new String(valueStr.getBytes("ISO-8859-1"), "gbk");
+ params.put(name, valueStr);
+ }
+
+ Paylog paylog = getPayLog_alipay(request);
+
+ // 验证成功
+ if ("TRADE_FINISHED".equals(paylog.getTradeStatus())) {
+ System.out.println("AlipayController.notifyUrl__验证成功：success");
+ // 支付失败
+ } else if ("TRADE_SUCCESS".equals(paylog.getTradeStatus())) {
+ // 支付成功
+ try {
+ if(judgeContainsStr(paylog.getOutTradeNo())){
+
+
+ }
+ // ——请根据您的业务逻辑来编写程序（以上代码仅作参考）——
+ log.debug("AlipayController.notifyUrl__回调处理：success");
+ out.println("success"); // 请不要修改或删除
+ // ——请根据您的业务逻辑来编写程序（以上代码仅作参考）——
+ log.debug("AlipayController.notifyUrl__回调处理：success");
+ out.println("success"); // 请不要修改或删除
+ } catch (Exception e) {
+ log.debug("AlipayController.notifyUrl__回调逻辑代码处理异常！fail");
+ // 返回失败
+ out.println("fail");
+ e.printStackTrace();
+ }
+ // ////////////////////////////////////////////////////////////////////////////////////////
+ } else {// 验证失败
+ log.debug("AlipayController.notifyUrl__回调处理失败！fail");
+ out.println("fail");
+ }
+ } catch (
+ IOException e) {
+ log.debug("AlipayController.notifyUrl__支付宝服务器异步通知数据处理失败！");
+ e.printStackTrace();
+ }
+ }
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+
+ /**
+ * 微信支付回调（参考财付通回调接口）
+ *
+ * @param request
+ * @param response
+ */
+ @Override
+ public void wxnotify(HttpServletRequest request, HttpServletResponse response) {
+ try {
+ System.out.println("微信支付回调！！！！！！！！！！！！！！！！！！！！！！！！！");
+ // 异步通知返回报文
+ StringBuffer notityXml = new StringBuffer();
+ String inputLine;
+ while ((inputLine = request.getReader().readLine()) != null) {
+ notityXml.append(inputLine);
+ }
+ request.getReader().close();
+ // log.debug("WxpayController.notify__notityXml：\n" + notityXml);
+ System.out.println("WxpayController.notify__notityXml：\n" + notityXml);
+
+ // 验证签名
+ if (Signature.checkIsSignValidFromResponseString(1, notityXml.toString())
+ || Signature.checkIsSignValidFromResponseString(2, notityXml.toString())) {
+ Map<String, Object> map = XMLParser.getMapFromXML(notityXml.toString());
+ // log.debug("WxpayController.notify__map：\n" + map);
+ // 接口返回状态
+ String result_code = (String) map.get("result_code");
+ if ("SUCCESS".equals(result_code)) {
+ // // 商户订单号
+ String out_trade_no = (String) map.get("out_trade_no");
+ // // 微信支付交易号
+ String trade_no = (String) map.get("transaction_id");
+ // // 金额,以分为单位
+ String total_fee = (String) map.get("total_fee");
+ // // 优惠金额
+ // String discount = (String) map.get("discount");
+ // // 支付完成时间
+ String time_end = (String) map.get("time_end");
+ // // 支付者唯一Id（对应买家账号的一个加密串 ）
+ String buyer_id = (String) map.get("buyer_id");
+
+ ///////////////////////////// 这里程序处理支付回调逻辑
+ ///////////////////////////// ////////////////////
+ Paylog paylog = new Paylog();
+ paylog.setOutTradeNo(out_trade_no);
+ paylog.setPayType(2);
+ paylog.setBuyerId(buyer_id);
+ paylog.setTradeNo(trade_no);
+ paylog.setPayMoney(Double.parseDouble(total_fee) / 100);
+ paylog.setState(1);
+ System.out.println("支付完成时间" + time_end);
+ paylog.setAddTime(LocalDateTime.now());
+ iPaylogService.save(paylog);
+ if (judgeContainsStr(paylog.getOutTradeNo())) {
+
+
+ log.debug("WxpayController.notify__回调处理成功：SUCCESS");
+ response.getOutputStream().print("success");
+ }
+ log.debug("WxpayController.notify__回调处理成功：SUCCESS");
+ response.getOutputStream().print("success");
+ } else {
+ log.debug("WxpayController.notify__回调处理：验证状态错误！" + result_code);
+ System.out.println("验证状态错误！" + result_code);
+ }
+ } else {
+ log.debug("WxpayController.notify__回调处理：通知签名验证失败！");
+ System.out.println("通知签名验证失败！");
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+
+ /**
+ * 支付宝订单退款
+ *
+ * @author tzj
+ * @param out_trade_no
+ * 商品订单号
+ * @param trade_no
+ * 支付宝交易号
+ * @param refund_amount
+ * 退款金额
+ * @return
+ */
+ public boolean refundForAlipay(String out_trade_no, String trade_no, Double refund_amount) {
+ try {
+ // 实例化客户端
+ AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do",
+ AlipayConfig.app_id, AlipayConfig.private_key, "json", AlipayConfig.input_charset,
+ AlipayConfig.ali_public_key,"RSA2");
+ // 实例化具体API对应的request类,类名称和接口名称对应
+ AlipayTradeRefundRequest request = new AlipayTradeRefundRequest();
+ // SDK已经封装掉了公共参数，这里只需要传入业务参数
+ // 此次只是参数展示，未进行字符串转义，实际情况下请转义
+ request.setBizContent("{" + "\"out_trade_no\":\"" + out_trade_no + "\", " + "\"trade_no\":\"" + trade_no
+ + "\", " + "\"refund_amount\":" + refund_amount + ", " + "\"refund_reason\":\"正常退款\","
+ + "\"out_request_no\":\"HZ01RF001\"" + "}");
+ AlipayTradeRefundResponse response = alipayClient.execute(request);
+ // 调用成功，则处理业务逻辑
+ if (response.isSuccess()) {
+ return true;
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ return false;
+ }
+
+ /**
+ * 获取支付信息支付(签约app支付2.0)
+ *
+ * @param subject
+ * @param body
+ * @param price
+ * @param request
+ * @return
+ */
+ public R<Map<String, Object>> alipay(String orderNo, String subject, String body, Double price,
+ HttpServletRequest request) {
+ try {
+ // 接口封装支付宝请求参数
+ // Map<String, Object> mData = new HashMap<String, Object>();
+
+ // 构建请求支付签名参数
+ Map<String, Object> pay = PayDemoActivity.appPay(subject, body, price, orderNo);
+ /*
+ * Set<Entry<String, String>> entrySet = pay.entrySet();
+ * Iterator<Entry<String, String>> iterator = entrySet.iterator();
+ * while (iterator.hasNext()) { Entry<String, String> next =
+ * iterator.next(); mData.put(next.getKey(), next.getValue()); }
+ */
+ return R.ok(pay);
+ } catch (Exception e) {
+ e.printStackTrace();
+ return R.fail("支付异常!");
+ }
+ }
+
+
+ /**
+ * 统一下单
+ *
+ * @param apptype
+ * @param outTradeNo
+ * @param body
+ * @param price
+ * @param request
+ * @return
+ */
+ public static R<Map<String, Object>> wxpay(Integer apptype, String outTradeNo, String body, Double price,
+ HttpServletRequest request) {
+ // 获取预支付接口返回参数
+ Map<String, Object> map = new HashMap<String, Object>();
+ Map<String, Object> appPayMap = new HashMap<String, Object>();
+ try {
+ // 构建接口请求参数
+ UnifiedorderReqData unifiedorderReqData = new UnifiedorderReqData(apptype, outTradeNo, body, price,
+ Configure.wx_notify_url);
+ // 请求接口获取返回接口
+ String result = requestUnifiedorderService(apptype, unifiedorderReqData);
+ System.out.println(result);
+ System.out.println("WxpayController.createOrder__result：\n" + result);
+ // 获取预支付接口返回参数
+ map = XMLParser.getMapFromXML(result);
+ System.out.println("WxpayController.createOrder__result：\n" + result);
+ // 捕获预支付接口错误提示
+ if ("FAIL".equals(map.get("result_code")) || "FAIL".equals(map.get("return_code"))) {
+ return R.fail(String.valueOf(map.get("return_msg")));
+ }
+
+ // 对获取预支付返回接口参数进行封装（生成支付订单接口数据）
+ AppPayReqData appPay = new AppPayReqData(apptype, (String) map.get("appid"), (String) map.get("mch_id"),
+ (String) map.get("prepay_id"), unifiedorderReqData.getNonce_str());
+
+ // 对获取预支付返回接口参数进行封装（生成支付订单接口数据）
+ appPayMap.put("appid", appPay.getAppid());// 公众账号ID
+ appPayMap.put("nonceStr", appPay.getNoncestr());// 随机字符串(32位)
+ appPayMap.put("package", appPay.get_package());// 扩展字段(暂填写固定值Sign=WXPay)
+ appPayMap.put("partnerId", appPay.getPartnerid());// 商户号
+ appPayMap.put("prepayId", appPay.getPrepayid());// 预支付编号（微信返回的支付交易会话ID）
+ appPayMap.put("timeStamp", appPay.getTimestamp());// 时间戳
+ appPayMap.put("sign", appPay.getSign());// 根据API给的签名规则进行签名
+ return R.ok(appPayMap);
+ } catch (Exception e) {
+ System.out.println("统一下单_API_处理异常！");
+ e.printStackTrace();
+ }
+ return R.fail("统一下单失败");
+ }
+
+
+
+ /**
+ * 微信退款
+ *
+ * @param transactionID
+ * 【支付交易号】是微信系统为每一笔支付交易分配的订单号，通过这个订单号可以标识这笔交易，
+ * 它由支付订单API支付成功时返回的数据里面获取到。建议优先使用
+ * @param outTradeNo
+ * 【商品订单编号】商户系统内部的订单号,transaction_id
+ * 、out_trade_no二选一，如果同时存在优先级：transaction_id>out_trade_no
+ * @param outRefundNo
+ * 【退款编号】商户系统内部的退款单号，商户系统内部唯一，同一退款单号多次请求只退一笔
+ * 订单总金额，单位为分
+ * @param refundFee
+ * 退款总金额，单位为分,可以做部分退款
+ * @return
+ */
+ public static boolean refundForWxpay(Integer apptype, String transactionID, String outTradeNo, String outRefundNo,
+ Integer totalFee, Integer refundFee, String pay_type) {
+ Map<String, Object> map = new HashMap<String, Object>();
+ try {
+ // 构建接口请求参数
+ com.tencent.protocol.RefundReqData refundReqData = new com.tencent.protocol.RefundReqData(transactionID, outTradeNo, outRefundNo, totalFee, refundFee,
+ pay_type);
+
+ // 请求接口返回结果
+ String result = requestRefundService(apptype, refundReqData);
+ System.out.println("微信退款返回内容：" + result);
+ // 获取预支付接口返回参数
+ map = XMLParser.getMapFromXML(result);
+ System.out.println("微信退款返回参数：" + map);
+ // 退款成功处理
+ if ("SUCCESS".equals(map.get("result_code"))) {
+ return true;
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ return false;
+ }
+
+ /**
+ * 获取支付宝
+ *
+ * @param request
+ * @return
+ * @throws Exception
+ */
+ private Paylog getPayLog_alipay(HttpServletRequest request) throws IOException {
+ //////// 获取支付宝的通知返回参数，可参考技术文档中页面跳转同步通知参数列表(以下仅供参考)////////
+ // 商户订单号
+ String out_trade_no = new String(request.getParameter("out_trade_no").getBytes("ISO-8859-1"), "UTF-8");
+ // 支付宝交易号
+ String trade_no = new String(request.getParameter("trade_no").getBytes("ISO-8859-1"), "UTF-8");
+ // 交易状态
+ String trade_status = new String(request.getParameter("trade_status").getBytes("ISO-8859-1"), "UTF-8");
+ // 支付者唯一Id
+ String buyer_id = new String(request.getParameter("buyer_id").getBytes("ISO-8859-1"), "UTF-8");
+ // 支付帐号
+ String buyer_email = "";
+ if (SinataUtil.isNotEmpty(request.getParameter("buyer_logon_id"))) {
+ buyer_email = new String(request.getParameter("buyer_logon_id").getBytes("ISO-8859-1"), "UTF-8");
+ }
+ // 支付金额
+ String total_fee = new String(request.getParameter("total_amount").getBytes("ISO-8859-1"), "UTF-8");
+ // 支付时间
+ String notify_time = new String(request.getParameter("notify_time").getBytes("ISO-8859-1"), "UTF-8");
+
+ //////// 获取支付宝的通知返回参数，可参考技术文档中页面跳转同步通知参数列表(以下仅供参考)////////
+ Paylog paylog = new Paylog();
+ paylog.setOutTradeNo(out_trade_no);
+ paylog.setPayType(1);
+ paylog.setBuyerId(buyer_id);
+ paylog.setTradeNo(trade_no);
+ paylog.setPayMoney(Double.parseDouble(total_fee));
+ paylog.setState(1);
+ paylog.setAddTime(LocalDateTime.now());
+ paylog.setTradeStatus(trade_status.toString());
+ iPaylogService.save(paylog);
+ return paylog;
+ }
+
+ public boolean judgeContainsStr(String cardNum) {
+ String regex=".*[a-zA-Z]+.*";
+ Matcher m= Pattern.compile(regex).matcher(cardNum);
+ return m.matches();
+ }
+
}
--
Gitblit v1.7.1