Commit 809c953c by 李学兴

Merge branch 'feature/20210810_callbackUrgentPlan_lxx' into qa

parents fbbc7837 a26afbde
...@@ -63,15 +63,20 @@ public class OrderCallBackServiceImpl implements OrderCallBackService{ ...@@ -63,15 +63,20 @@ public class OrderCallBackServiceImpl implements OrderCallBackService{
RedisLock redisLock = RedisLock.getInstance(redisTemplate); RedisLock redisLock = RedisLock.getInstance(redisTemplate);
String lockKey = String.format(RedisKeyConstant.URGENT_CALLBACK_LOCK_KEY, requestVo.getOrderCode(), String lockKey = String.format(RedisKeyConstant.URGENT_CALLBACK_LOCK_KEY, requestVo.getOrderCode(),
requestVo.getOrderState(), requestVo.getOperateType(), requestVo.getMsgType()); requestVo.getOrderState(), requestVo.getOperateType(), requestVo.getMsgType());
boolean lockSucc =false;
try { try {
//简单控制,不考虑解他锁问题 //简单控制,不考虑解他锁问题
if (!redisLock.lock(lockKey, Long.valueOf(TimeUnit.MINUTES.toSeconds(configConstants.getUrgentCallbackLockMinutes())).intValue())) { lockSucc = redisLock.lock(lockKey, Long.valueOf(TimeUnit.MINUTES.toSeconds(configConstants.getUrgentCallbackLockMinutes())).intValue());
ApiLog.infoMessage("订单orderCode:{} callback获取锁失败,lockKey:{}", requestVo.getOrderCode(), lockKey); if (!lockSucc) {
ApiLog.infoMessage("紧急方案 orderCode:{} 获取锁失败,lockKey:{}", requestVo.getOrderCode(), lockKey);
return; return;
} }
mqService.sendOrderMQ(requestVo); mqService.sendOrderMQ(requestVo);
} finally { } finally {
redisLock.unlock(lockKey); if (lockSucc){
ApiLog.infoMessage("紧急方案 orderCode:{} 理论成功lockKey:{}", requestVo.getOrderCode(), requestVo.getRequestId(),lockKey);
redisLock.unlock(lockKey);
}
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment