|
@@ -221,7 +221,6 @@ func (s *SecondPush) SaveSpushRule() {
|
|
|
func (s *SecondPush) SecondPushTask() {
|
|
|
log.Println("开始二次推送任务...")
|
|
|
s_pushid := s.GetString("s_pushid")
|
|
|
- go UpdateHistoryState(1, s_pushid, 0)
|
|
|
if s_pushid != "" {
|
|
|
customer, _ := Mgo.Find("second_push", map[string]interface{}{"_id": mongoutil.StringTOBsonId(s_pushid)}, nil, nil, false, -1, -1)
|
|
|
if len(*customer) == 1 {
|
|
@@ -286,10 +285,6 @@ func (s *SecondPush) SecondPushTask() {
|
|
|
}
|
|
|
if len(xlsxArr) == 0 {
|
|
|
log.Println("查询数据为空")
|
|
|
- go UpdateHistoryState(2, s_pushid, 0)
|
|
|
- s.ServeJson(map[string]interface{}{
|
|
|
- "status": true,
|
|
|
- })
|
|
|
} else {
|
|
|
log.Println(len(xlsxArr))
|
|
|
GetXlsxs(xlsxArr, customer_name, email, s_pushid)
|