getPayUser.go 527 B

123456789101112131415161718192021222324
  1. package public
  2. import (
  3. "context"
  4. "fmt"
  5. "github.com/gogf/gf/v2/frame/g"
  6. "github.com/gogf/gf/v2/util/gconv"
  7. )
  8. var (
  9. ctx = context.Background()
  10. )
  11. func GetPayUser() map[string]bool {
  12. payTidb := g.Cfg().MustGet(ctx, "payTidb", "Jianyu_subjectdb.dwd_f_data_equity_info").String()
  13. pay := make(map[string]bool)
  14. res, err := g.DB().Query(ctx, fmt.Sprintf(`SELECT id,user_id FROM %s`, payTidb))
  15. if err == nil && !res.IsEmpty() {
  16. for _, m := range res.List() {
  17. pay[gconv.String(m["user_id"])] = true
  18. }
  19. }
  20. return pay
  21. }