Commit 489f17f7 by qwmqiuwenmin

fix

parent 019a6735
...@@ -77,7 +77,9 @@ public class FriendMergeSyncOperation implements BaseSyncOperation{ ...@@ -77,7 +77,9 @@ public class FriendMergeSyncOperation implements BaseSyncOperation{
} }
logger.info("好友合并成功:{}", taskId); logger.info("好友合并成功:{}", taskId);
int errorCount = preDealService.countByTaskId(taskId, PreDealTypeEnum.friend_merge.getVal(), 3); int errorCount = preDealService.countByTaskId(taskId, PreDealTypeEnum.friend_merge.getVal(), 3);
if(errorCount > 0){ int errorSelfCount = preDealService.countByTaskId(taskId, PreDealTypeEnum.self_friend.getVal(), 3);
int errorFriendCount = preDealService.countByTaskId(taskId, PreDealTypeEnum.friend.getVal(), 3);
if(errorCount > 0 || errorFriendCount > 0 || errorSelfCount > 0){
syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.exception_compute.getVal()); syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.exception_compute.getVal());
}else{ }else{
syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.compute.getVal()); syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.compute.getVal());
......
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