Commit 019a6735 by qwmqiuwenmin

fix

parent f7085be0
......@@ -71,21 +71,17 @@ public class FriendMergeSyncOperation implements BaseSyncOperation{
@Override
public void checkDepartmentTask(String taskId) {
String key = "sync_wx_lock_";
boolean b = preDealService.checkTask(taskId, PreDealTypeEnum.friend_merge.getVal());
if (!b) {
return;
}
logger.info("好友合并成功:{}", taskId);
TabHaobanSyncTask syncTask = syncTaskService.getSyncTask(taskId);
int errorCount = preDealService.countByTaskId(taskId, PreDealTypeEnum.friend_merge.getVal(), 3);
if(errorCount > 0){
syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.exception_compute.getVal());
}else{
syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.compute.getVal());
}
//同步成功 进入门店处理
RedisUtil.delCache(key + syncTask.getWxEnterpriseId());
}
}
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