zhangxinlei1996 5 年之前
父節點
當前提交
f48b97b84f
共有 1 個文件被更改,包括 3 次插入0 次删除
  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)