valhalla / fw-valhalla

Commit 5654bd3695e830461594ba8562cde0455faa8efb

Authored by 张志伟
1 parent a8956fb2

:fire: feat(*): bug修复 

- bug修复
Inline Side-by-side
Showing 1 changed file with 1 additions and 2 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/cust/CustomerChangeBizService.java
  View file @5654bd3
... ... @@ -119,8 +119,7 @@ public class CustomerChangeBizService extends AbstractCustomerService {
119 119 String key = MessageFormatUtil.MessageFormatTransfer(CUSTOMER_CHANGE_CODE, customerChangeDto.getShopId(), str);
120 120 String customerString = JSON.toJSONString(customerChangeDto);
121 121 Pair<Boolean, RLock> lockPair = distributedLocker.tryLock(key, TimeUnit.SECONDS, 0, 1000 * 15);
122   - RLock rLock = lockPair.getRight();
123   - boolean flag = rLock.isLocked();
  122 + boolean flag = lockPair.getKey();
124 123 BV.isTrue(flag, "重复操作，请稍后重试");
125 124 int expires = 60 * 30;
126 125 stringRedisTemplate.opsForValue().set(key, customerString, expires, TimeUnit.SECONDS);
... ...