diff --git a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/controller/app/comauth/AppComAuthController.java b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/controller/app/comauth/AppComAuthController.java index 9fd3c67..457b332 100644 --- a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/controller/app/comauth/AppComAuthController.java +++ b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/controller/app/comauth/AppComAuthController.java @@ -1,6 +1,8 @@ package cn.iocoder.yudao.module.member.controller.app.comauth; import cn.iocoder.yudao.framework.common.pojo.CommonResult; +import cn.iocoder.yudao.framework.idempotent.core.annotation.Idempotent; +import cn.iocoder.yudao.framework.idempotent.core.keyresolver.impl.UserIdempotentKeyResolver; import cn.iocoder.yudao.module.member.controller.admin.comauth.vo.ComAuthSaveReqVO; import cn.iocoder.yudao.module.member.controller.app.comauth.vo.CreateManAuthReqVo; import cn.iocoder.yudao.module.member.controller.app.comauth.vo.CreateWechatAuthReqVo; @@ -16,6 +18,8 @@ import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.validation.Valid; +import java.util.concurrent.TimeUnit; + import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success; import static cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils.getLoginUserId; @@ -29,6 +33,7 @@ public class AppComAuthController { private ComAuthService comAuthService; @PostMapping("/create-wecaht-error-auth") + @Idempotent(timeout = 3, timeUnit = TimeUnit.SECONDS, keyResolver = UserIdempotentKeyResolver.class, message = "正在提交中,请稍后重试") @Operation(summary = "创建微信错误认证") public CommonResult createWechatErrorAuth(@Valid @RequestBody CreateWechatErrorAuthReqVo dto) { dto.setOperationMemberId(getLoginUserId()); diff --git a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/comauth/ComAuthServiceImpl.java b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/comauth/ComAuthServiceImpl.java index acd6dcc..eb8fc6b 100644 --- a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/comauth/ComAuthServiceImpl.java +++ b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/comauth/ComAuthServiceImpl.java @@ -2,6 +2,8 @@ package cn.iocoder.yudao.module.member.service.comauth; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.IterUtil; +import cn.hutool.core.date.DatePattern; +import cn.hutool.core.date.LocalDateTimeUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.extra.spring.SpringUtil; import cn.hutool.json.JSONUtil; @@ -87,6 +89,11 @@ public class ComAuthServiceImpl implements ComAuthService { .eq(ComAuthDO::getBizType, MemberComAuthEnum.WECHAT_NUMBER_ERROR.getType()) .eq(ComAuthDO::getBizId, String.valueOf(dto.getMemberId())) .eq(ComAuthDO::getAuthStatus, MemberComAuthStatusEnum.WAIT_AUTH.getType()) + .between( + ComAuthDO::getCreateTime, + LocalDateTimeUtil.format(LocalDateTime.now(), DatePattern.NORM_DATE_PATTERN), + LocalDateTimeUtil.format(LocalDateTime.now().plusDays(1), DatePattern.NORM_DATE_PATTERN) + ) ); if (ObjectUtil.isNotEmpty(comAuth)) { throw exception(MemberErrorCode.EMPTY, "已举报,请勿重复举报"); @@ -96,6 +103,11 @@ public class ComAuthServiceImpl implements ComAuthService { .eq(OperationDO::getMemberId, dto.getMemberId()) .eq(OperationDO::getOperatorMemberId, dto.getOperationMemberId()) .eq(OperationDO::getBizType, MemberRecentOperateEnum.MEMBER_LOOK_WECHAT.getType()) + .between( + OperationDO::getTapTime, + LocalDateTimeUtil.format(LocalDateTime.now(), DatePattern.NORM_DATE_PATTERN), + LocalDateTimeUtil.format(LocalDateTime.now().plusDays(1), DatePattern.NORM_DATE_PATTERN) + ) ); if (ObjectUtil.isEmpty(operationDO)) { throw exception(MemberErrorCode.EMPTY, "未找到操作记录");