Compare commits

...

2 Commits

  1. 5
      bnyer-services/bnyer-order/src/main/java/com/bnyer/order/aop/LimitRepeatRequestAspect.java
  2. 3
      bnyer-services/bnyer-order/src/main/java/com/bnyer/order/controller/VipOrderController.java
  3. 5
      bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/aop/LimitRepeatRequestAspect.java
  4. 4
      bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/controller/DYPayController.java
  5. 5
      bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/controller/UnifiedPayController.java

5
bnyer-services/bnyer-order/src/main/java/com/bnyer/order/aop/LimitRepeatRequestAspect.java

@ -8,6 +8,7 @@ import com.bnyer.common.core.enums.ResponseEnum;
import com.bnyer.common.core.exception.ServiceException; import com.bnyer.common.core.exception.ServiceException;
import com.bnyer.common.core.utils.MD5Util; import com.bnyer.common.core.utils.MD5Util;
import com.bnyer.common.core.utils.StringUtils; import com.bnyer.common.core.utils.StringUtils;
import com.bnyer.common.core.utils.bean.EntityConvertUtil;
import com.bnyer.common.core.vo.UserInfoVo; import com.bnyer.common.core.vo.UserInfoVo;
import com.bnyer.common.redis.service.RedissonService; import com.bnyer.common.redis.service.RedissonService;
import com.bnyer.common.security.utils.SecurityUtils; import com.bnyer.common.security.utils.SecurityUtils;
@ -81,7 +82,7 @@ public class LimitRepeatRequestAspect {
//部分参数做重复请求限制 //部分参数做重复请求限制
if (Objects.nonNull(requestParams)){ if (Objects.nonNull(requestParams)){
String[] bodyParam = limitRepeatRequest.bodyParam(); String[] bodyParam = limitRepeatRequest.bodyParam();
if (bodyParam != null){ if (bodyParam.length > 0){
for (String param : bodyParam) { for (String param : bodyParam) {
key.append("#"); key.append("#");
Object obj = requestParams.get(param); Object obj = requestParams.get(param);
@ -121,7 +122,7 @@ public class LimitRepeatRequestAspect {
private JSONObject getRequestParams(ProceedingJoinPoint joinPoint) { private JSONObject getRequestParams(ProceedingJoinPoint joinPoint) {
Object[] args = joinPoint.getArgs(); Object[] args = joinPoint.getArgs();
if (args != null && args.length != 0){ if (args != null && args.length != 0){
return JSON.parseObject(args[0].toString()); return EntityConvertUtil.convertBean(args[0],JSONObject.class);
} }
return null; return null;
} }

3
bnyer-services/bnyer-order/src/main/java/com/bnyer/order/controller/VipOrderController.java

@ -1,5 +1,6 @@
package com.bnyer.order.controller; package com.bnyer.order.controller;
import com.bnyer.common.core.annotation.LimitRepeatRequest;
import com.bnyer.common.core.domain.R; import com.bnyer.common.core.domain.R;
import com.bnyer.common.core.web.controller.BaseController; import com.bnyer.common.core.web.controller.BaseController;
import com.bnyer.order.bean.dto.AddVipOrderDto; import com.bnyer.order.bean.dto.AddVipOrderDto;
@ -38,7 +39,7 @@ public class VipOrderController extends BaseController {
/** /**
* 提交订单 * 提交订单
*/ */
//@LimitRepeatRequest(bodyAllParam = true, message = "您的订单已提交,请勿频繁操作") @LimitRepeatRequest(bodyAllParam = true, message = "您的订单已提交,请勿频繁操作")
@PostMapping("/addVipOrder") @PostMapping("/addVipOrder")
@Operation(summary = "生成会员订单,返回订单号" , description = "生成会员订单,返回订单号,通过订单号调用支付接口") @Operation(summary = "生成会员订单,返回订单号" , description = "生成会员订单,返回订单号,通过订单号调用支付接口")
public R<String> addVipOrder(@Valid @RequestBody AddVipOrderDto addVipOrderDto) { public R<String> addVipOrder(@Valid @RequestBody AddVipOrderDto addVipOrderDto) {

5
bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/aop/LimitRepeatRequestAspect.java

@ -9,6 +9,7 @@ import com.bnyer.common.core.enums.ResponseEnum;
import com.bnyer.common.core.exception.ServiceException; import com.bnyer.common.core.exception.ServiceException;
import com.bnyer.common.core.utils.MD5Util; import com.bnyer.common.core.utils.MD5Util;
import com.bnyer.common.core.utils.StringUtils; import com.bnyer.common.core.utils.StringUtils;
import com.bnyer.common.core.utils.bean.EntityConvertUtil;
import com.bnyer.common.core.vo.UserInfoVo; import com.bnyer.common.core.vo.UserInfoVo;
import com.bnyer.common.redis.service.RedissonService; import com.bnyer.common.redis.service.RedissonService;
import com.bnyer.common.security.utils.SecurityUtils; import com.bnyer.common.security.utils.SecurityUtils;
@ -81,7 +82,7 @@ public class LimitRepeatRequestAspect {
//部分参数做重复请求限制 //部分参数做重复请求限制
if (Objects.nonNull(requestParams)){ if (Objects.nonNull(requestParams)){
String[] bodyParam = limitRepeatRequest.bodyParam(); String[] bodyParam = limitRepeatRequest.bodyParam();
if (bodyParam != null){ if (bodyParam.length > 0){
for (String param : bodyParam) { for (String param : bodyParam) {
key.append("#"); key.append("#");
Object obj = requestParams.get(param); Object obj = requestParams.get(param);
@ -121,7 +122,7 @@ public class LimitRepeatRequestAspect {
private JSONObject getRequestParams(ProceedingJoinPoint joinPoint) { private JSONObject getRequestParams(ProceedingJoinPoint joinPoint) {
Object[] args = joinPoint.getArgs(); Object[] args = joinPoint.getArgs();
if (args != null && args.length != 0){ if (args != null && args.length != 0){
return JSON.parseObject(args[0].toString()); return EntityConvertUtil.convertBean(args[0],JSONObject.class);
} }
return null; return null;
} }

4
bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/controller/DYPayController.java

@ -13,8 +13,6 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
/** /**
* @author :WXC * @author :WXC
* @Date :2023/04/24 * @Date :2023/04/24
@ -31,7 +29,7 @@ public class DYPayController {
@ApiOperation(value = "抖音支付结果通知") @ApiOperation(value = "抖音支付结果通知")
@ResponseBody @ResponseBody
@PostMapping("/dypayBack") @PostMapping("/dypayBack")
public JSONObject dyPayNotify(@RequestBody JSONObject object, HttpServletRequest request) { public JSONObject dyPayNotify(@RequestBody JSONObject object) {
log.info("抖音支付异步通知开始==============》{}", object); log.info("抖音支付异步通知开始==============》{}", object);
IPayStrategy payStrategy = PayFactory.getInstance().getConcreteStrategy(EnumPayType.DY_PAY.getType()); IPayStrategy payStrategy = PayFactory.getInstance().getConcreteStrategy(EnumPayType.DY_PAY.getType());
String payNotify = payStrategy.parsePayNotify(JSON.toJSONString(object)); String payNotify = payStrategy.parsePayNotify(JSON.toJSONString(object));

5
bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/controller/UnifiedPayController.java

@ -1,5 +1,6 @@
package com.bnyer.pay.controller; package com.bnyer.pay.controller;
import com.bnyer.common.core.annotation.LimitRepeatRequest;
import com.bnyer.common.core.domain.R; import com.bnyer.common.core.domain.R;
import com.bnyer.common.core.enums.ResponseEnum; import com.bnyer.common.core.enums.ResponseEnum;
import com.bnyer.common.core.exception.ServiceException; import com.bnyer.common.core.exception.ServiceException;
@ -39,7 +40,7 @@ public class UnifiedPayController {
@Autowired @Autowired
private UnifiedPayService unifiedPayService; private UnifiedPayService unifiedPayService;
//@LimitRepeatRequest(bodyAllParam = true, message = "您的订单已提交,请勿频繁操作") @LimitRepeatRequest(bodyAllParam = true, message = "您的订单已提交,请勿频繁操作")
@PostMapping("/unifiedOrder") @PostMapping("/unifiedOrder")
@Operation(summary = "统一下单,并生成支付订单" , description = "生成支付订单,返回前端支付所需参数") @Operation(summary = "统一下单,并生成支付订单" , description = "生成支付订单,返回前端支付所需参数")
public R<UnifiedOrderVo> unifiedOrder(@Valid @RequestBody UnifiedOrderDto dto, HttpServletRequest request){ public R<UnifiedOrderVo> unifiedOrder(@Valid @RequestBody UnifiedOrderDto dto, HttpServletRequest request){
@ -57,7 +58,7 @@ public class UnifiedPayController {
return R.ok(queryOrderVo); return R.ok(queryOrderVo);
} }
//@LimitRepeatRequest(time = 10, message = "请勿频繁操作") @LimitRepeatRequest(time = 10, message = "请勿频繁操作")
@PostMapping("/refund") @PostMapping("/refund")
@Operation(summary = "统一退款" , description = "统一退款") @Operation(summary = "统一退款" , description = "统一退款")
public R<?> refund(@Valid @RequestBody RefundDto dto){ public R<?> refund(@Valid @RequestBody RefundDto dto){

Loading…
Cancel
Save