Commit 8eef03aa by 徐高华

Merge branch 'developer' into 'master'

加好友队列

See merge request !972
parents 2c30edac 8299aca2
...@@ -399,8 +399,8 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -399,8 +399,8 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
return null; return null;
} }
// 加好友量大的迁移到mq2 // 加好友量大的迁移到mq2
int maxCount = 800 ;
private boolean mqCheck(QwFrientNoticeDTO dto) { private boolean mqCheck(QwFrientNoticeDTO dto) {
int maxCount = 800 ;
boolean flag = false ; boolean flag = false ;
Object obj = RedisUtil.getCache("dealQywxExternalUserMq2") ; Object obj = RedisUtil.getCache("dealQywxExternalUserMq2") ;
String corpid = dto.getCorpid() ; String corpid = dto.getCorpid() ;
...@@ -424,6 +424,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -424,6 +424,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
if("wp59NLDQAAtTbif_SxAixUQVqMld4vug".equals(corpid)) { if("wp59NLDQAAtTbif_SxAixUQVqMld4vug".equals(corpid)) {
maxCount = 2 ; maxCount = 2 ;
} }
log.info("dealQywxExternalUserMq2={},{}",times,maxCount);
if(times>maxCount) { if(times>maxCount) {
if(!needToMq2(wxEnterpriseId)) { if(!needToMq2(wxEnterpriseId)) {
log.info("加好友计数发送告警,id={}",wxEnterpriseId); log.info("加好友计数发送告警,id={}",wxEnterpriseId);
......
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