充值功能--接入支付宝
This commit is contained in:
206
src/main/java/com/ai/da/controller/AliPayController.java
Normal file
206
src/main/java/com/ai/da/controller/AliPayController.java
Normal file
@@ -0,0 +1,206 @@
|
||||
package com.ai.da.controller;
|
||||
|
||||
import com.ai.da.common.response.Response;
|
||||
import com.ai.da.mapper.entity.OrderInfo;
|
||||
import com.ai.da.service.AliPayService;
|
||||
import com.ai.da.service.OrderInfoService;
|
||||
import com.alipay.api.AlipayApiException;
|
||||
import com.alipay.api.AlipayConstants;
|
||||
import com.alipay.api.internal.util.AlipaySignature;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.core.env.Environment;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.math.BigDecimal;
|
||||
import java.util.Map;
|
||||
|
||||
@CrossOrigin
|
||||
@RestController
|
||||
@RequestMapping("/api/ali-pay")
|
||||
@Api(tags = "网站支付宝支付")
|
||||
@Slf4j
|
||||
public class AliPayController {
|
||||
|
||||
@Resource
|
||||
private AliPayService aliPayService;
|
||||
|
||||
@Resource
|
||||
private Environment config;
|
||||
|
||||
@Resource
|
||||
private OrderInfoService orderInfoService;
|
||||
|
||||
@ApiOperation("统一收单下单并支付页面接口的调用")
|
||||
@PostMapping("/trade/page/pay/{productId}")
|
||||
public Response<String> tradePagePay(@PathVariable Long productId){
|
||||
|
||||
log.info("统一收单下单并支付页面接口的调用");
|
||||
//支付宝开放平台接受 request 请求对象后
|
||||
// 会为开发者生成一个html 形式的 form表单，包含自动提交的脚本
|
||||
String formStr = aliPayService.tradeCreate(productId);
|
||||
//我们将form表单字符串返回给前端程序，之后前端将会调用自动提交脚本，进行表单的提交
|
||||
//此时，表单会自动提交到action属性所指向的支付宝开放平台中，从而为用户展示一个支付页面
|
||||
return Response.success(formStr);
|
||||
}
|
||||
|
||||
@ApiOperation("支付通知")
|
||||
@PostMapping("/trade/notify")
|
||||
public String tradeNotify(@RequestParam Map<String, String> params){
|
||||
|
||||
log.info("支付通知正在执行");
|
||||
log.info("通知参数 ===> {}", params);
|
||||
|
||||
String result = "failure";
|
||||
|
||||
try {
|
||||
//异步通知验签
|
||||
boolean signVerified = AlipaySignature.rsaCheckV1(
|
||||
params,
|
||||
config.getProperty("alipay.alipay-public-key"),
|
||||
AlipayConstants.CHARSET_UTF8,
|
||||
AlipayConstants.SIGN_TYPE_RSA2); //调用SDK验证签名
|
||||
|
||||
if(!signVerified){
|
||||
//验签失败则记录异常日志，并在response中返回failure.
|
||||
log.error("支付成功异步通知验签失败！");
|
||||
return result;
|
||||
}
|
||||
|
||||
// 验签成功后
|
||||
log.info("支付成功异步通知验签成功！");
|
||||
|
||||
//按照支付结果异步通知中的描述，对支付结果中的业务内容进行二次校验，
|
||||
//1 商户需要验证该通知数据中的 out_trade_no 是否为商户系统中创建的订单号
|
||||
String outTradeNo = params.get("out_trade_no");
|
||||
OrderInfo order = orderInfoService.getOrderByOrderNo(outTradeNo);
|
||||
if(order == null){
|
||||
log.error("订单不存在");
|
||||
return result;
|
||||
}
|
||||
|
||||
//2 判断 total_amount 是否确实为该订单的实际金额（即商户订单创建时的金额）
|
||||
String totalAmount = params.get("total_amount");
|
||||
int totalAmountInt = new BigDecimal(totalAmount).multiply(new BigDecimal("100")).intValue();
|
||||
int totalFeeInt = order.getTotalFee().intValue();
|
||||
if(totalAmountInt != totalFeeInt){
|
||||
log.error("金额校验失败");
|
||||
return result;
|
||||
}
|
||||
|
||||
//3 校验通知中的 seller_id（或者 seller_email) 是否为 out_trade_no 这笔单据的对应的操作方
|
||||
String sellerId = params.get("seller_id");
|
||||
String sellerIdProperty = config.getProperty("alipay.seller-id");
|
||||
if(!sellerId.equals(sellerIdProperty)){
|
||||
log.error("商家pid校验失败");
|
||||
return result;
|
||||
}
|
||||
|
||||
//4 验证 app_id 是否为该商户本身
|
||||
String appId = params.get("app_id");
|
||||
String appIdProperty = config.getProperty("alipay.app-id");
|
||||
if(!appId.equals(appIdProperty)){
|
||||
log.error("appid校验失败");
|
||||
return result;
|
||||
}
|
||||
|
||||
//在支付宝的业务通知中，只有交易通知状态为 TRADE_SUCCESS时，
|
||||
// 支付宝才会认定为买家付款成功。
|
||||
String tradeStatus = params.get("trade_status");
|
||||
if(!"TRADE_SUCCESS".equals(tradeStatus)){
|
||||
log.error("支付未成功");
|
||||
return result;
|
||||
}
|
||||
|
||||
//处理业务 修改订单状态 记录支付日志
|
||||
aliPayService.processOrder(params);
|
||||
|
||||
//校验成功后在response中返回success并继续商户自身业务处理，校验失败返回failure
|
||||
result = "success";
|
||||
} catch (AlipayApiException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户取消订单
|
||||
* @param orderNo
|
||||
* @return
|
||||
*/
|
||||
@ApiOperation("用户取消订单")
|
||||
@PostMapping("/trade/close/{orderNo}")
|
||||
public Response<String> cancel(@PathVariable String orderNo){
|
||||
|
||||
log.info("取消订单");
|
||||
aliPayService.cancelOrder(orderNo);
|
||||
return Response.success("订单已取消");
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询订单
|
||||
* @param orderNo
|
||||
* @return
|
||||
*/
|
||||
@ApiOperation("查询订单：测试订单状态用")
|
||||
@GetMapping("/trade/query/{orderNo}")
|
||||
public Response<String> queryOrder(@PathVariable String orderNo) {
|
||||
|
||||
log.info("查询订单");
|
||||
|
||||
String result = aliPayService.queryOrder(orderNo);
|
||||
return Response.success(result);
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 申请退款
|
||||
* @param orderNo
|
||||
* @param reason
|
||||
* @return
|
||||
*/
|
||||
@ApiOperation("申请退款")
|
||||
@PostMapping("/trade/refund/{orderNo}/{reason}")
|
||||
public Response<String> refunds(@PathVariable String orderNo, @PathVariable String reason){
|
||||
|
||||
log.info("申请退款");
|
||||
aliPayService.refund(orderNo, reason);
|
||||
return Response.success();
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询退款
|
||||
* @param orderNo
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
@ApiOperation("查询退款：测试用")
|
||||
@GetMapping("/trade/fastpay/refund/{orderNo}")
|
||||
public Response<String> queryRefund(@PathVariable String orderNo) throws Exception {
|
||||
|
||||
log.info("查询退款");
|
||||
|
||||
String result = aliPayService.queryRefund(orderNo);
|
||||
return Response.success(result);
|
||||
}
|
||||
|
||||
/**
|
||||
* 根据账单类型和日期获取账单url地址
|
||||
*
|
||||
* @param billDate
|
||||
* @param type
|
||||
* @return
|
||||
*/
|
||||
@ApiOperation("获取账单url")
|
||||
@GetMapping("/bill/downloadurl/query/{billDate}/{type}")
|
||||
public Response<String> queryTradeBill(
|
||||
@PathVariable String billDate,
|
||||
@PathVariable String type) {
|
||||
log.info("获取账单url");
|
||||
String downloadUrl = aliPayService.queryBill(billDate, type);
|
||||
return Response.success(downloadUrl);
|
||||
}
|
||||
|
||||
}
|
||||
50
src/main/java/com/ai/da/controller/OrderInfoController.java
Normal file
50
src/main/java/com/ai/da/controller/OrderInfoController.java
Normal file
@@ -0,0 +1,50 @@
|
||||
package com.ai.da.controller;
|
||||
|
||||
import com.ai.da.common.enums.OrderStatusEnum;
|
||||
import com.ai.da.common.response.Response;
|
||||
import com.ai.da.mapper.entity.OrderInfo;
|
||||
import com.ai.da.service.OrderInfoService;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.List;
|
||||
|
||||
@CrossOrigin //开放前端的跨域访问
|
||||
@Api(tags = "商品订单管理")
|
||||
@RestController
|
||||
@RequestMapping("/api/order-info")
|
||||
public class OrderInfoController {
|
||||
|
||||
@Resource
|
||||
private OrderInfoService orderInfoService;
|
||||
|
||||
@ApiOperation("订单列表")
|
||||
@GetMapping("/list")
|
||||
public Response<List<OrderInfo>> list(){
|
||||
|
||||
List<OrderInfo> list = orderInfoService.listOrderByCreateTimeDesc();
|
||||
return Response.success(list);
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询本地订单状态
|
||||
* @param orderNo
|
||||
* @return
|
||||
*/
|
||||
@ApiOperation("查询本地订单状态")
|
||||
@GetMapping("/query-order-status/{orderNo}")
|
||||
public Response<String> queryOrderStatus(@PathVariable String orderNo){
|
||||
|
||||
String orderStatus = orderInfoService.getOrderStatus(orderNo);
|
||||
if(OrderStatusEnum.SUCCESS.getType().equals(orderStatus)){
|
||||
return Response.success("支付成功"); //支付成功
|
||||
}
|
||||
|
||||
return Response.success(101,"支付中......");
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
42
src/main/java/com/ai/da/controller/ProductController.java
Normal file
42
src/main/java/com/ai/da/controller/ProductController.java
Normal file
@@ -0,0 +1,42 @@
|
||||
package com.ai.da.controller;
|
||||
|
||||
|
||||
import com.ai.da.common.response.Response;
|
||||
import com.ai.da.mapper.entity.Product;
|
||||
import com.ai.da.service.ProductService;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.springframework.web.bind.annotation.CrossOrigin;
|
||||
import org.springframework.web.bind.annotation.GetMapping;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
@CrossOrigin //开放前端的跨域访问
|
||||
@Api(tags = "商品管理")
|
||||
@RestController
|
||||
@RequestMapping("/api/product")
|
||||
public class ProductController {
|
||||
|
||||
@Resource
|
||||
private ProductService productService;
|
||||
|
||||
@ApiOperation("测试接口")
|
||||
@GetMapping("/test")
|
||||
public Response<String> test(){
|
||||
|
||||
return Response.success("now" + new Date());
|
||||
}
|
||||
|
||||
@ApiOperation("商品列表")
|
||||
@GetMapping("/list")
|
||||
public Response<List<Product>> list(){
|
||||
|
||||
List<Product> list = productService.list();
|
||||
return Response.success(list);
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user