|
|
@@ -33,8 +33,9 @@ func main() {
|
|
|
}
|
|
|
log.Println("start...", query)
|
|
|
it := sess.DB("qfw").C("user").Find(query).Select(map[string]interface{}{
|
|
|
- "_id": 1,
|
|
|
- "base_user_id": 1,
|
|
|
+ "_id": 1,
|
|
|
+ "base_user_id": 1,
|
|
|
+ "i_member_sub_status": 1,
|
|
|
}).Sort("_id").Iter()
|
|
|
var index int64
|
|
|
for m := make(map[string]interface{}); it.Next(&m); {
|
|
|
@@ -45,6 +46,9 @@ func main() {
|
|
|
<-pool
|
|
|
wait.Done()
|
|
|
}()
|
|
|
+ if common.IntAllDef(u["i_member_sub_status"], -1) == 1 {
|
|
|
+ return
|
|
|
+ }
|
|
|
if !allUser[common.Int64All(u["base_user_id"])] {
|
|
|
return
|
|
|
}
|
