@@ -90,7 +90,7 @@ func GetUserSubList(day int) ([]*UserSubAction, error) {
pipeline := []bson.M{
{
// 第一个阶段:筛选符合条件的文档
- "$match": bson.M{"l_date": bson.M{"$gt": startTime.Unix(), "$lt": endTime.Unix()}, "s_event": "subscribe"},
+ "$match": bson.M{"l_date": bson.M{"$gt": startTime.Unix(), "$lt": endTime.Unix()}, "s_event": "subscribe", "s_code": bson.M{"$exists": 0}},
},
"$group": bson.M{