fix:商机管理消息推送修改

rpc/internal/common/task.go

@@ -17,7 +17,6 @@ import (
 var GlobMsgMap map[int]map[string]interface{}
 
 func LoadTask() {
-	fmt.Println(len(StatisticalUser(false)))
 	// 每隔10分钟执行一次
 	LoadMsgOnTime()
 	c := cron.New(cron.WithSeconds())
@@ -142,7 +141,7 @@ func StatisticalUser(isFree bool) []string {
 				},
 			},
 		},
-	}, nil, "", false, -1, -1)
+	}, nil, `{"i_userid":1}`, false, -1, -1)
 	if ok && entPayUser != nil && len(*entPayUser) > 0 {
 		var userIds []string
 		for k, m := range *entPayUser {