|
|
@@ -461,7 +461,7 @@ func (s *subscribePush) getDatasFromMysql(spqp *SubPushQueryParam, starttime, en
|
|
|
}
|
|
|
searchSql = fmt.Sprintf(" from %s a LEFT JOIN %s b ON a.infoid = b.infoid LEFT JOIN %s t on t.infoid = b.infoid and t.labelcode=2 where %s"+
|
|
|
" order by a.id desc", aboutDbMsg[s.ModuleFlag].MysqlTable, Baseinfo, BidTags, strings.Join(querys, " and "))
|
|
|
- fmt.Println("searchSql", searchSql)
|
|
|
+ logx.Info("searchSql", searchSql)
|
|
|
//查询总数
|
|
|
count = spqp.BaseServiceMysql.CountBySql(fmt.Sprintf("select count(a.id)" + searchSql))
|
|
|
logx.Info("count:", count, "---", s.ModuleFlag)
|
|
|
@@ -474,8 +474,10 @@ func (s *subscribePush) getDatasFromMysql(spqp *SubPushQueryParam, starttime, en
|
|
|
if isLimit {
|
|
|
findSql += fmt.Sprintf(" limit %d,%d", (spqp.PageNum-1)*size, size)
|
|
|
}
|
|
|
+ logx.Info("findSql", findSql)
|
|
|
logx.Info(spqp.NewUserId, "subscribePush query sql：", findSql)
|
|
|
list := spqp.BaseServiceMysql.SelectBySql(findSql)
|
|
|
+ logx.Info("数据库数据", list)
|
|
|
if list != nil && len(*list) > 0 {
|
|
|
pushCas := s.GetJyPushs(*list)
|
|
|
if !spqp.Export {
|
|
|
@@ -486,6 +488,7 @@ func (s *subscribePush) getDatasFromMysql(spqp *SubPushQueryParam, starttime, en
|
|
|
} else {
|
|
|
result = []*bxsubscribe.SubscribeInfo{}
|
|
|
}
|
|
|
+ logx.Info("result", result)
|
|
|
return
|
|
|
}
|
|
|
|
WH01243