Commit f75405d6 by fudahua

导购刷新好友超时时间

parent 7f51c732
......@@ -72,6 +72,11 @@ public class FriendSyncNewOperation implements BaseSyncOperation {
String taskId = dealParamMqDTO.getTaskId();
String externalUserId = dataPre.getDataContent();
if (dataPre.getStatusFlag() != PreDealStatusEnum.pre.getVal()) {
logger.info("已经处理过,无需重复处理:{}", JSONObject.toJSONString(dataPre));
return;
}
ExternalUserDTO externalUserDTO = memberUnionidRelatedApiService.getExternalUseridInfo(wxEnterpriseId, wxUserId, externalUserId);
if (externalUserDTO == null) {
dealFlag = false;
......
......@@ -128,7 +128,7 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation {
} else {
dealDepartmentToMq(taskId, new HashSet<>(dataIds), SyncTaskStatusEnum.friend_sync);
}
RedisUtil.unlock(key);
RedisUtil.unlock(lockKey);
}
@Override
......
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