Commit 0b55be49 by 墨竹

refactor:增加日志

parent 6b4ce2b6
......@@ -69,6 +69,7 @@ public class AddMemberUnionRelateConsumerProcessor extends AbstractConsumerProce
@Override
void doProcess(MemberUnionRelatedBO bo) {
logger.info("企业刷新历史好友start:{}",JSON.toJSONString(bo));
RRateLimiter rateLimiter = RedisUtil.getRedisClient().getRateLimiter("add:mbr:rel:list:limit");
rateLimiter.trySetRate(RateType.OVERALL, 5, 1, RateIntervalUnit.SECONDS);
rateLimiter.acquire();
......@@ -181,6 +182,7 @@ public class AddMemberUnionRelateConsumerProcessor extends AbstractConsumerProce
related.setStatusFlag(1);
externalClerkRelatedService.insert(related);
}
logger.info("企业刷新历史好友end");
}
private MemberUnionidRelatedDTO getAndMergeMemberUnion(MemberUnionRelatedBO bo) {
......
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