|
@@ -254,7 +254,7 @@ func (s *SecondPush) SecondPushTask() {
|
|
|
"$lte":endtime,
|
|
|
},
|
|
|
}
|
|
|
- d,_:=MgoSecondPush.Find("usermail",q,nil,nil,false,0,0)
|
|
|
+ d,_:=MgoSecondPush.Find("usermail_0806_01",q,nil,nil,false,0,0)
|
|
|
for _,l := range *d{
|
|
|
xlsxArr=append(xlsxArr, l)
|
|
|
}
|
|
@@ -298,6 +298,7 @@ func UpdateHistoryState(state int, s_pushid string, count int) {
|
|
|
"$set": map[string]interface{}{
|
|
|
"state": state,
|
|
|
"result_count": count,
|
|
|
+ "finishtime":time.Now().Unix(),
|
|
|
},
|
|
|
}, false, false)
|
|
|
return
|
|
@@ -580,6 +581,7 @@ func (s *SecondPush) SecondPushClone(hid string) {
|
|
|
(*data)["result_count"] = nil
|
|
|
(*data)["createtime"] = time.Now().Unix()
|
|
|
(*data)["updatetime"] = time.Now().Unix()
|
|
|
+ delete((*data),"finishtime")
|
|
|
Mgo.Save("second_push", *data)
|
|
|
}
|
|
|
}
|