|
|
@@ -379,7 +379,7 @@ func (s *subscribePush) getDatasFromMysql(spqp *SubPushQueryParam, starttime, en
|
|
|
} else if spqp.UserType == MemberFlag {
|
|
|
userStr = fmt.Sprintf(" a.userid='%s' and ( (a.source=1 and a.product=2 ) or a.source>1 ) ", common.If(s.ModuleFlag == EntnicheFlag, spqp.EntUserId, common.InterfaceToStr(spqp.NewUserId)))
|
|
|
} else {
|
|
|
- userStr = fmt.Sprintf(" a.userid='%s' and ( (a.source=1 and a.product<1 ) or a.source>1 ) ", common.If(s.ModuleFlag == EntnicheFlag, spqp.EntUserId, common.InterfaceToStr(spqp.NewUserId)))
|
|
|
+ userStr = fmt.Sprintf(" a.userid='%s' and ( (a.source=1 and a.product is null ) or a.source>1 ) ", common.If(s.ModuleFlag == EntnicheFlag, spqp.EntUserId, common.InterfaceToStr(spqp.NewUserId)))
|
|
|
}
|
|
|
} else {
|
|
|
if s.ModuleFlag == EntnicheFlag {
|
WH01243