diff --git a/pigx-common/pigx-common-idempotent/pom.xml b/pigx-common/pigx-common-idempotent/pom.xml index bf9728c5b..82abd36a0 100644 --- a/pigx-common/pigx-common-idempotent/pom.xml +++ b/pigx-common/pigx-common-idempotent/pom.xml @@ -18,6 +18,10 @@ + + com.pig4cloud + pigx-common-core + org.springframework.boot diff --git a/pigx-common/pigx-common-idempotent/src/main/java/com/pig4cloud/pigx/common/idempotent/aspect/IdempotentAspect.java b/pigx-common/pigx-common-idempotent/src/main/java/com/pig4cloud/pigx/common/idempotent/aspect/IdempotentAspect.java index 25b9b8420..682e5213b 100644 --- a/pigx-common/pigx-common-idempotent/src/main/java/com/pig4cloud/pigx/common/idempotent/aspect/IdempotentAspect.java +++ b/pigx-common/pigx-common-idempotent/src/main/java/com/pig4cloud/pigx/common/idempotent/aspect/IdempotentAspect.java @@ -1,5 +1,6 @@ package com.pig4cloud.pigx.common.idempotent.aspect; +import com.pig4cloud.pigx.common.core.util.KeyStrResolver; import com.pig4cloud.pigx.common.idempotent.annotation.Idempotent; import com.pig4cloud.pigx.common.idempotent.exception.IdempotentException; import com.pig4cloud.pigx.common.idempotent.expression.KeyResolver; @@ -51,6 +52,9 @@ public class IdempotentAspect { @Autowired private KeyResolver keyResolver; + @Autowired + private KeyStrResolver keyStrResolver; + @Pointcut("@annotation(com.pig4cloud.pigx.common.idempotent.annotation.Idempotent)") public void pointCut() { } @@ -80,6 +84,7 @@ public class IdempotentAspect { // 使用jstl 规则区分 key = keyResolver.resolver(idempotent, joinPoint); } + key = keyStrResolver.extract(key,":"); long expireTime = idempotent.expireTime(); String info = idempotent.info();