xiugai

src/jfw/modules/pushsubscribe/src/push/job/pushjob.go

@@ -274,15 +274,27 @@ func (p *PushJob) UpdateBulk(sess *mgo.Session, array_q, array_s *[]map[string]i
 }
 func (p *PushJob) DelBulk(sess *mgo.Session, array *[]interface{}) {
 	coll := sess.DB(DbName).C("pushspace_temp")
+	count := 0
 	bulk := coll.Bulk()
 	for _, v := range *array {
+		count++
 		bulk.Remove(map[string]interface{}{
 			"_id": v,
 		})
+		if count == BulkSize {
+			_, err := bulk.Run()
+			if nil != err {
+				logger.Info("DelBulkError", err)
+			}
+			count = 0
+			bulk = coll.Bulk()
+		}
 	}
-	_, err := bulk.Run()
-	if nil != err {
-		logger.Info("DelBulkError", err)
+	if count > 0 {
+		_, err := bulk.Run()
+		if nil != err {
+			logger.Info("DelBulkError", err)
+		}
 	}
 	*array = []interface{}{}
 }