|
|
@@ -2,8 +2,8 @@ package util
|
|
|
|
|
|
//实时统计状态
|
|
|
import (
|
|
|
- "log"
|
|
|
"fmt"
|
|
|
+ "log"
|
|
|
"qfw/util/mongodb"
|
|
|
"sync/atomic"
|
|
|
"time"
|
|
|
@@ -24,9 +24,11 @@ func subscribeStats() {
|
|
|
total := atomic.SwapInt32(&tmp, 0)
|
|
|
//
|
|
|
if total > times {
|
|
|
- log.Printf("flash black user [%d - %d] \n ",starttime,endtime)
|
|
|
+ log.Printf("flash black user [%d - %d] %d \n ", starttime, endtime, total)
|
|
|
//刷数据
|
|
|
mongodb.Update("user", fmt.Sprintf(`{"l_registedate":{"$gte":%d,"$lte":%d}}`, starttime, endtime), `{"$set":{"black":1}}`, false, true)
|
|
|
+ } else {
|
|
|
+ log.Printf("subscribe filter %d Minutes,create %d users \n", dutrat.Minutes(), total)
|
|
|
}
|
|
|
starttime = time.Now().Unix()
|
|
|
endtime = starttime
|
