Commit 63bd123c by 徐高华

Merge branch 'developer' into 'master'

加好友队列

See merge request !960
parents 85371db9 ecc93ed9
...@@ -399,7 +399,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -399,7 +399,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
return null; return null;
} }
// 加好友量大的迁移到mq2 // 加好友量大的迁移到mq2
int maxCount = 2 ; int maxCount = 800 ;
private boolean mqCheck(QwFrientNoticeDTO dto) { private boolean mqCheck(QwFrientNoticeDTO dto) {
boolean flag = false ; boolean flag = false ;
Object obj = RedisUtil.getCache("dealQywxExternalUserMq2") ; Object obj = RedisUtil.getCache("dealQywxExternalUserMq2") ;
...@@ -412,12 +412,18 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -412,12 +412,18 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
return flag ; return flag ;
} }
} }
if(null != obj && obj.toString().equals("0")) {
return false ;
}
TabHaobanWxEnterprise wxEnterprise = this.wxEnterpriseService.getEnterpriseBycorpId(corpid) ; TabHaobanWxEnterprise wxEnterprise = this.wxEnterpriseService.getEnterpriseBycorpId(corpid) ;
if(null != wxEnterprise) { if(null != wxEnterprise) {
String wxEnterpriseId = wxEnterprise.getWxEnterpriseId() ; String wxEnterpriseId = wxEnterprise.getWxEnterpriseId() ;
flag = this.needToMq2(wxEnterpriseId) ; flag = this.needToMq2(wxEnterpriseId) ;
if(!flag) { if(!flag) {
long times = this.getTimes(wxEnterpriseId) ; long times = this.getTimes(wxEnterpriseId) ;
if("wp59NLDQAAtTbif_SxAixUQVqMld4vug".equals(corpid)) {
maxCount = 2 ;
}
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