Commit ac6b2ba2 by fudahua

导购刷新好友超时时间

parent f75405d6
...@@ -201,7 +201,7 @@ public class FriendSyncNewOperation implements BaseSyncOperation { ...@@ -201,7 +201,7 @@ public class FriendSyncNewOperation implements BaseSyncOperation {
if (!b) { if (!b) {
return; return;
} }
logger.info("同步第三方服务商好友:{},{}", taskId, pDataId); logger.info("同步第三方服务商好友结束:{},{}", taskId, pDataId);
String key = "haoban_sync_third_friend_task_" + taskId; String key = "haoban_sync_third_friend_task_" + taskId;
RedisUtil.lock(key, 3L); RedisUtil.lock(key, 3L);
TabHaobanPreDealLog preDealLog = preDealService.getByDataId(taskId, pDataId, PreDealTypeEnum.friend_clerk.getVal(), PreDealStatusEnum.dealing.getVal()); TabHaobanPreDealLog preDealLog = preDealService.getByDataId(taskId, pDataId, PreDealTypeEnum.friend_clerk.getVal(), PreDealStatusEnum.dealing.getVal());
......
...@@ -108,7 +108,7 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation { ...@@ -108,7 +108,7 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation {
if (!b) { if (!b) {
return; return;
} }
logger.info("同步第三方服务商好友:{},{}", taskId, pDataId); logger.info("同步第三方服务商好友开始:{},{}", taskId, pDataId);
String key = "haoban_sync_self_friend_task_" + taskId + ":" + pDataId; String key = "haoban_sync_self_friend_task_" + taskId + ":" + pDataId;
String lockKey = "haoban_sync_self_friend_task_lock_" + taskId + ":" + pDataId; String lockKey = "haoban_sync_self_friend_task_lock_" + taskId + ":" + pDataId;
RedisUtil.lock(lockKey, 3L); RedisUtil.lock(lockKey, 3L);
......
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