Browse Source

分支合并

lianbingjie 5 years ago
parent
commit
fa3fd58532
1 changed files with 3 additions and 0 deletions
  1. 3 0
      src/jfw/modules/pushsubscribe/src/push/pusher/normalpush.go

+ 3 - 0
src/jfw/modules/pushsubscribe/src/push/pusher/normalpush.go

@@ -50,6 +50,9 @@ func (n *NormalPush) OncePushBatch(taskType, batchIndex int, startId *string) (b
 			"vipstatus": map[string]interface{}{
 				"$in": []int{1, 2},
 			},
+			"ratemode": map[string]interface{}{
+				"$in": []int{1, 3, 4},
+			},
 		}
 	} else {
 		logger.Error("taskType error", taskType)