Commit a26afbde by 李学兴

opt@feature/20210810_callbackUrgentPlan_lxx:# 紧急方案增加日志打印

parent 6f7024a7
......@@ -62,16 +62,21 @@ public class OrderCallBackServiceImpl implements OrderCallBackService{
RedisLock redisLock = RedisLock.getInstance(redisTemplate);
String lockKey = String.format(RedisKeyConstant.URGENT_CALLBACK_LOCK_KEY, requestVo.getOrderCode(),
requestVo.getOrderState(), requestVo.getOperateType(), requestVo.getMsgType());
boolean lockSucc =false;
try {
//简单控制,不考虑解他锁问题
if (!redisLock.lock(lockKey, Long.valueOf(TimeUnit.MINUTES.toSeconds(configConstants.getUrgentCallbackLockMinutes())).intValue())) {
ApiLog.infoMessage("订单orderCode:{} callback获取锁失败,lockKey:{}", requestVo.getOrderCode(), lockKey);
lockSucc = redisLock.lock(lockKey, Long.valueOf(TimeUnit.MINUTES.toSeconds(configConstants.getUrgentCallbackLockMinutes())).intValue());
if (!lockSucc) {
ApiLog.infoMessage("紧急方案 orderCode:{} 获取锁失败,lockKey:{}", requestVo.getOrderCode(), lockKey);
return;
}
mqService.sendOrderMQ(requestVo);
} finally {
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