|
|
|
@ -497,9 +497,10 @@ public class SDNYMainProcessController extends AbstractController { |
|
|
|
|
String param = JSONObject.toJSONString(pramsMap); |
|
|
|
|
//加分布式锁
|
|
|
|
|
String lockKey = Base64Utils.encodeToString(param.getBytes()); |
|
|
|
|
boolean isLock = false; |
|
|
|
|
RLock lock = redisson.getLock(lockKey); |
|
|
|
|
try { |
|
|
|
|
boolean isLock = lock.tryLock(); |
|
|
|
|
isLock = lock.tryLock(); |
|
|
|
|
|
|
|
|
|
if (!isLock) { |
|
|
|
|
log.info("当前已有线程获取到锁"); |
|
|
|
@ -726,7 +727,9 @@ public class SDNYMainProcessController extends AbstractController { |
|
|
|
|
} |
|
|
|
|
finally { |
|
|
|
|
//关锁
|
|
|
|
|
lock.unlock(); |
|
|
|
|
if (isLock) { |
|
|
|
|
lock.unlock(); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
return ResponseEntity.ok(JSONObject.toJSONString(R.error().put("data", "请求正在处理,不要重复提交"))); |
|
|
|
|
} |
|
|
|
|