Commit be8586c3 by fudahua

导购刷新好友超时时间

parent 9d52beec
...@@ -175,7 +175,7 @@ public class FriendClerkSyncNewOperation implements BaseSyncOperation { ...@@ -175,7 +175,7 @@ public class FriendClerkSyncNewOperation implements BaseSyncOperation {
TabHaobanSyncTask syncTask = syncTaskService.getSyncTask(taskId); TabHaobanSyncTask syncTask = syncTaskService.getSyncTask(taskId);
if (syncTask.getStatusFlag() == SyncTaskStatusEnum.compute.getVal() if (syncTask.getStatusFlag() == SyncTaskStatusEnum.compute.getVal()
|| syncTask.getStatusFlag() == SyncTaskStatusEnum.exception_compute.getVal()) { || syncTask.getStatusFlag() == SyncTaskStatusEnum.exception_compute.getVal()) {
logger.info("已经处理成功"); logger.info("已经处理成功:{}", taskId);
return; return;
} }
int errCount = preDealService.countByTaskId(taskId, -1, PreDealStatusEnum.exception.getVal()); int errCount = preDealService.countByTaskId(taskId, -1, PreDealStatusEnum.exception.getVal());
......
...@@ -212,7 +212,7 @@ public class FriendSyncNewOperation implements BaseSyncOperation { ...@@ -212,7 +212,7 @@ public class FriendSyncNewOperation implements BaseSyncOperation {
RedisUtil.unlock(lockKey); RedisUtil.unlock(lockKey);
return; return;
} }
RedisUtil.setCache(key, pDataId, 1L, TimeUnit.MINUTES); RedisUtil.setCache(key, pDataId, 30L, TimeUnit.SECONDS);
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());
if (preDealLog != null) { if (preDealLog != null) {
preDealService.updateStatusByDataId(taskId, pDataId, PreDealTypeEnum.friend_clerk.getVal(), PreDealStatusEnum.computed.getVal(), "成功"); preDealService.updateStatusByDataId(taskId, pDataId, PreDealTypeEnum.friend_clerk.getVal(), PreDealStatusEnum.computed.getVal(), "成功");
......
...@@ -118,7 +118,7 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation { ...@@ -118,7 +118,7 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation {
RedisUtil.unlock(lockKey); RedisUtil.unlock(lockKey);
return; return;
} }
RedisUtil.setCache(key, pDataId, 1L, TimeUnit.MINUTES); RedisUtil.setCache(key, pDataId, 30L, TimeUnit.SECONDS);
List<String> dataIds = preDealService.listReDataIdByPDataId(taskId, pDataId, PreDealTypeEnum.friend.getVal()); List<String> dataIds = preDealService.listReDataIdByPDataId(taskId, pDataId, PreDealTypeEnum.friend.getVal());
if (CollectionUtils.isEmpty(dataIds)) { if (CollectionUtils.isEmpty(dataIds)) {
//更新父级别 //更新父级别
......
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