Commit 3233b45c88a0612f3b1d5292a4a2ad767e58643c
1 parent
5654bd36
feat(*): bug修复
- bug修复
Showing
1 changed file
with
1 additions
and
1 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/report/PublicReportBizService.java
... | ... | @@ -63,7 +63,7 @@ public class PublicReportBizService { |
63 | 63 | log.info("开始抽取公共池报表数据,日期:{} 集团:{}", nowDate, groupId); |
64 | 64 | final String lockKey = generateKey(groupId); |
65 | 65 | RLock lock = (RLock) distributedLocker.lock(lockKey); |
66 | - if (lock == null || !lock.isLocked()) { | |
66 | + if (lock == null || !lock.isLocked() || !lock.isHeldByCurrentThread()) { | |
67 | 67 | return; |
68 | 68 | } |
69 | 69 | try { | ... | ... |