|
@@ -410,9 +410,9 @@ func (s *subscribePush) getDatasFromMysql(spqp *SubPushQueryParam, starttime, en
|
|
//附件
|
|
//附件
|
|
if spqp.FileExists != "" {
|
|
if spqp.FileExists != "" {
|
|
if spqp.FileExists == "1" {
|
|
if spqp.FileExists == "1" {
|
|
- querys = append(querys, fmt.Sprintf("attachment_count > 0"))
|
|
|
|
|
|
+ querys = append(querys, fmt.Sprintf("attachment_count is not null"))
|
|
} else if spqp.FileExists == "-1" {
|
|
} else if spqp.FileExists == "-1" {
|
|
- querys = append(querys, fmt.Sprintf("attachment_count = null"))
|
|
|
|
|
|
+ querys = append(querys, fmt.Sprintf("attachment_count is null"))
|
|
}
|
|
}
|
|
}
|
|
}
|
|
searchSql := fmt.Sprintf(" from %s where %s order by id desc", aboutDbMsg[s.ModuleFlag].MysqlTable, strings.Join(querys, " and "))
|
|
searchSql := fmt.Sprintf(" from %s where %s order by id desc", aboutDbMsg[s.ModuleFlag].MysqlTable, strings.Join(querys, " and "))
|