diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/callback/MultidimensionalTableCallback.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/callback/MultidimensionalTableCallback.java index 1188ac7..99c2c0a 100644 --- a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/callback/MultidimensionalTableCallback.java +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/callback/MultidimensionalTableCallback.java @@ -19,6 +19,7 @@ import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.Date; import java.util.List; +import java.util.concurrent.TimeUnit; /** * @author yuxiangyong @@ -88,13 +89,13 @@ public class MultidimensionalTableCallback extends CallbackAbstract { event = JSONObject.parseObject(eventStr, Event.class); } //如果已经存在处理中的就不需要操作数据库了 - if (event != null && EventOperateStatus.PENDING.getCode().equals(event.getOperateStatus())) { + if (event != null && EventOperateStatus.PENDING.getCode().equals(event.getOperateStatus()) && event.getNumbers() < 3) { continue; } event = this.buildDto(request, event,recordId); if (event.getId() == null) { eventService.insertEvent(event); - redisTemplate.opsForValue().set(cacheKey, JSONObject.toJSONString(event)); + redisTemplate.opsForValue().set(cacheKey, JSONObject.toJSONString(event),1, TimeUnit.MINUTES); } else { updateEventList.add(event.getId()); }