|
|
@@ -80,9 +80,10 @@ func CloseTask() {
|
|
|
"l_complete": map[string]interface{}{
|
|
|
"$lt": unix_time + 86400,
|
|
|
},
|
|
|
- "s_type": map[string]interface{}{
|
|
|
- "$ne": "7",
|
|
|
- },
|
|
|
+ "s_type": "1",
|
|
|
+ // "s_type": map[string]interface{}{
|
|
|
+ // "$ne": "7",
|
|
|
+ // },
|
|
|
}
|
|
|
logger.Debug("query:", query)
|
|
|
set := map[string]interface{}{
|
|
|
@@ -753,7 +754,7 @@ func SaveResult() {
|
|
|
wg.Wait()
|
|
|
lock.Lock()
|
|
|
if len(savearr) > 0 {
|
|
|
- MgoE.SaveBulk("luataskinfo_test", savearr...)
|
|
|
+ MgoE.SaveBulk("luataskinfo", savearr...)
|
|
|
savearr = []map[string]interface{}{}
|
|
|
}
|
|
|
lock.Unlock()
|
