二次推送开始任务后更新状态

src/service/second_push.go

@@ -221,6 +221,7 @@ 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 {
@@ -287,6 +288,10 @@ 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)