Skip to content

H
hilo-micCenter
Commit b390a967 authored by hujiebin's avatar hujiebin
Browse files
Options

init commit

parents
Pipeline #1897 failed with stages
      Expand all Hide whitespace changes
      Inline Side-by-side
      Showing with 1346 additions and 0 deletions
      .env 0 → 100644
      View file @ b390a967
      MODE=local
      .gitignore 0 → 100644
      View file @ b390a967
      .idea
      /protocol/userProxy/
      /protocol/userCenter/
      /protocol/biz/
      common/config/config.go 0 → 100644
      View file @ b390a967
      This diff is collapsed.
      common/dingding/dingding.go 0 → 100644
      View file @ b390a967
      package dingding
      import (
      "bytes"
      "encoding/json"
      "fmt"
      "io/ioutil"
      "net/http"
      )
      var (
      ROBOTWEBHOOK = "https://oapi.dingtalk.com/robot/send?access_token=5207fd753d28661ea0716ea0ef5b9e9e0aea392c9a148307c0b186e3d09b4aec"
      HILO = "hilo:"
      )
      type dingResponse struct {
      Errcode int
      Errmsg string
      }
      type dingtextMessage struct {
      MsgType string `json:"msgtype"`
      Text dingtextParams `json:"text"`
      At dingdingAt `json:"at"`
      }
      type dingtextParams struct {
      Content string `json:"content"`
      }
      // At at struct
      type dingdingAt struct {
      AtMobiles []string `json:"atMobiles"`
      IsAtAll bool `json:"isAtAll"`
      }
      func SendDingRobot(url string, content string, isAtAll bool) error {
      msg := dingtextMessage{MsgType: "text", Text: dingtextParams{Content: HILO + content}, At: dingdingAt{IsAtAll: isAtAll}}
      m, err := json.Marshal(msg)
      if err != nil {
      return err
      }
      resp, err := http.Post(url, "application/json", bytes.NewReader(m))
      if err != nil {
      return err
      }
      defer resp.Body.Close()
      data, err := ioutil.ReadAll(resp.Body)
      if err != nil {
      return err
      }
      var dr dingResponse
      err = json.Unmarshal(data, &dr)
      if err != nil {
      return err
      }
      if dr.Errcode != 0 {
      return fmt.Errorf("dingrobot send failed: %v", dr.Errmsg)
      }
      return nil
      }
      common/mylogrus/log.go 0 → 100644
      View file @ b390a967
      package mylogrus
      import (
      rotatelogs "github.com/lestrrat-go/file-rotatelogs"
      "github.com/rifflock/lfshook"
      "github.com/sirupsen/logrus"
      "hilo-micCenter/common/config"
      "io"
      "os"
      "path/filepath"
      "time"
      )
      const logDir = "/var/log/hilo/"
      var filenamePrefix string
      var MyLog = logrus.New()
      func Info(v interface{}) {
      MyLog.Info("")
      }
      func init() {
      filenamePrefix = logDir + filepath.Base(os.Args[0]) + "."
      //if runtime.GOOS == "darwin" { // mac本地调试
      // filenamePrefix = "./log/hilo/" + filepath.Base(os.Args[0]) + "."
      //}
      // stderr日志重定向
      MyLog.SetOutput(os.Stdout)
      RewriteStderrFile()
      if config.AppIsRelease() {
      MyLog.SetFormatter(&logrus.JSONFormatter{
      DisableHTMLEscape: true,
      TimestampFormat: "2006-01-02 15:04:05.000",
      })
      hook := lfshook.NewHook(lfshook.WriterMap{
      logrus.DebugLevel: getLevelWrite(logrus.DebugLevel),
      logrus.InfoLevel: getLevelWrite(logrus.InfoLevel),
      logrus.WarnLevel: getLevelWrite(logrus.WarnLevel),
      logrus.ErrorLevel: getLevelWrite(logrus.ErrorLevel),
      logrus.FatalLevel: getLevelWrite(logrus.FatalLevel),
      logrus.PanicLevel: getLevelWrite(logrus.PanicLevel),
      }, &logrus.JSONFormatter{DisableHTMLEscape: true, TimestampFormat: time.RFC3339Nano})
      MyLog.AddHook(hook)
      MyLog.SetLevel(logrus.InfoLevel)
      MyLog.SetReportCaller(true)
      } else {
      MyLog.SetFormatter(&logrus.TextFormatter{
      ForceQuote: false,
      DisableQuote: true,
      TimestampFormat: "2006-01-02 15:04:05.000",
      FullTimestamp: true,
      })
      hook := lfshook.NewHook(lfshook.WriterMap{
      logrus.DebugLevel: getLevelWrite(logrus.DebugLevel),
      logrus.InfoLevel: getLevelWrite(logrus.InfoLevel),
      logrus.WarnLevel: getLevelWrite(logrus.WarnLevel),
      logrus.ErrorLevel: getLevelWrite(logrus.ErrorLevel),
      logrus.FatalLevel: getLevelWrite(logrus.FatalLevel),
      logrus.PanicLevel: getLevelWrite(logrus.PanicLevel),
      }, &logrus.TextFormatter{ForceQuote: false, DisableQuote: true, TimestampFormat: time.RFC3339Nano})
      MyLog.AddHook(hook)
      MyLog.SetLevel(logrus.InfoLevel)
      MyLog.SetReportCaller(true)
      }
      }
      func GetInfoLog() io.Writer {
      return getLevelWrite(logrus.InfoLevel)
      }
      func getLevelWrite(level logrus.Level) io.Writer {
      var name string
      switch level {
      case logrus.DebugLevel:
      name = "debug.log"
      case logrus.InfoLevel:
      name = "info.log"
      case logrus.WarnLevel:
      name = "warn.log"
      case logrus.ErrorLevel:
      name = "error.log"
      case logrus.FatalLevel:
      name = "fatal.log"
      case logrus.PanicLevel:
      name = "panic.log"
      }
      name = filenamePrefix + name
      writer, err := rotatelogs.New(
      name+".%Y%m%d%H",
      rotatelogs.WithLinkName(name), // 生成软链，指向最新日志文件
      rotatelogs.WithMaxAge(7*24*time.Hour), // 文件最大保存时间
      rotatelogs.WithRotationTime(time.Hour), // 日志切割时间间隔
      )
      if err != nil {
      MyLog.Fatal("Failed to create log file:", err.Error())
      }
      return writer
      }
      func GetSqlLog() io.Writer {
      //if !config.AppIsRelease() {
      // return GetInfoLog()
      //}
      //name := filenamePrefix + "sql.log"
      //file, err := os.OpenFile(name, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666)
      //if err == nil {
      // return file
      //} else {
      // MyLog.Fatal("Failed to create sql log file:", err.Error())
      //}
      var name string = "sql.log"
      name = filenamePrefix + name
      writer, err := rotatelogs.New(
      name+".%Y%m%d%H",
      rotatelogs.WithLinkName(name), // 生成软链，指向最新日志文件
      rotatelogs.WithMaxAge(7*24*time.Hour), // 文件最大保存时间
      rotatelogs.WithRotationTime(time.Hour), // 日志切割时间间隔
      )
      if err != nil {
      MyLog.Fatal("Failed to create log file:", err.Error())
      }
      return writer
      }
      common/mylogrus/log_unix.go 0 → 100644
      View file @ b390a967
      //go:build !windows
      // +build !windows
      package mylogrus
      import (
      "fmt"
      "os"
      "path/filepath"
      "runtime"
      "syscall"
      "time"
      )
      var stdErrFileHandler *os.File
      func RewriteStderrFile() {
      filename := logDir + filepath.Base(os.Args[0]) + ".stderr.log"
      //if runtime.GOOS == "darwin" { // mac本地调试
      // filename = "./log/hilo/" + filepath.Base(os.Args[0]) + ".stderr.log"
      //}
      if exits, _ := pathExists(filename); exits {
      os.Rename(filename, filename+"_"+time.Now().Format("20060102150405"))
      }
      file, err := os.OpenFile(filename, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)
      if err != nil {
      fmt.Println(err)
      return
      }
      stdErrFileHandler = file //把文件句柄保存到全局变量，避免被GC回收
      if err = syscall.Dup2(int(file.Fd()), int(os.Stderr.Fd())); err != nil {
      fmt.Println(err)
      return
      }
      // 内存回收前关闭文件描述符
      runtime.SetFinalizer(stdErrFileHandler, func(fd *os.File) {
      fd.Close()
      })
      return
      }
      func pathExists(path string) (bool, error) {
      _, err := os.Stat(path)
      if err == nil {
      return true, nil
      }
      if os.IsNotExist(err) {
      return false, nil
      }
      return false, err
      }
      common/mylogrus/log_windows.go 0 → 100644
      View file @ b390a967
      //go:build windows
      // +build windows
      package mylogrus
      import (
      "os"
      "path/filepath"
      "time"
      )
      func RewriteStderrFile() {
      filename := logDir + filepath.Base(os.Args[0]) + ".stderr.log"
      if exits, _ := pathExists(filename); exits {
      os.Rename(filename, filename+"_"+time.Now().Format("20060102150405"))
      }
      file, err := os.OpenFile(filename, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)
      MyLog.Errorf("stderr log in:%v,err:%v", file, err)
      }
      func pathExists(path string) (bool, error) {
      _, err := os.Stat(path)
      if err == nil {
      return true, nil
      }
      if os.IsNotExist(err) {
      return false, nil
      }
      return false, err
      }
      common/redisCli/redis.go 0 → 100644
      View file @ b390a967
      package redisCli
      import (
      "context"
      "github.com/go-redis/redis/v8"
      "hilo-micCenter/common/config"
      "hilo-micCenter/common/mylogrus"
      "log"
      )
      var RedisClient *redis.Client
      var RedisClient1 *redis.Client
      func init() {
      RedisClient = redis.NewClient(&redis.Options{
      Addr: config.GetConfigRedis().REDIS_HOST,
      Password: config.GetConfigRedis().REDIS_PASSWORD, // no password set
      DB: 0, // use default DB
      PoolSize: 2000,
      MinIdleConns: 200,
      })
      mylogrus.MyLog.Infoln(config.GetConfigRedis().REDIS_HOST)
      mylogrus.MyLog.Infoln(config.GetConfigRedis().REDIS_PASSWORD)
      pong, err := RedisClient.Ping(context.Background()).Result()
      if err != nil {
      mylogrus.MyLog.Warn(err)
      mylogrus.MyLog.Fatal("redis db0 connect fail")
      } else {
      mylogrus.MyLog.Info("redis db0 connection success - ", pong)
      }
      RedisClient1 = redis.NewClient(&redis.Options{
      Addr: config.GetConfigRedis().REDIS_HOST,
      Password: config.GetConfigRedis().REDIS_PASSWORD, // no password set
      DB: 1, // use default DB
      PoolSize: 200,
      MinIdleConns: 20,
      })
      mylogrus.MyLog.Infoln(config.GetConfigRedis().REDIS_HOST)
      mylogrus.MyLog.Infoln(config.GetConfigRedis().REDIS_PASSWORD)
      pong, err = RedisClient1.Ping(context.Background()).Result()
      if err != nil {
      mylogrus.MyLog.Warn(err)
      mylogrus.MyLog.Fatal("redis db1 connect fail")
      } else {
      log.Println("redis db1 connection success - " + pong)
      }
      // log hook
      //RedisClient.AddHook(redisHook{})
      }
      func GetRedis() *redis.Client {
      return RedisClient
      }
      func GetRedis1() *redis.Client {
      return RedisClient1
      }
      common/redisCli/redis_hook.go 0 → 100644
      View file @ b390a967
      package redisCli
      import (
      "context"
      "github.com/go-redis/redis/v8"
      "hilo-micCenter/common/mylogrus"
      "time"
      )
      type redisCost struct{}
      var redisCostKey = redisCost{}
      type redisHook struct{}
      func (redisHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error) {
      ctx = context.WithValue(ctx, redisCostKey, time.Now())
      return ctx, nil
      }
      func (redisHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error {
      traceId, userId := ctx.Value("traceId"), ctx.Value("userId")
      start := ctx.Value(redisCostKey)
      var cost int64
      if s, ok := start.(time.Time); ok {
      cost = time.Now().Sub(s).Milliseconds()
      }
      mylogrus.MyLog.Infof("redis cmd: <%s>,err:%v traceId:%v,userId:%v,cost:%v ms", cmd.String(), cmd.Err(), traceId, userId, cost)
      return nil
      }
      func (redisHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error) {
      return ctx, nil
      }
      func (redisHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error {
      return nil
      }
      common/redisCli/util.go 0 → 100644
      View file @ b390a967
      package redisCli
      import (
      "context"
      "hilo-micCenter/common/mylogrus"
      "strconv"
      "time"
      )
      //这个用户避免多个服务器并发问题。
      func SetNX(key string, value interface{}, expiration time.Duration, callBack func()) {
      flag, err := RedisClient.SetNX(context.Background(), key, value, expiration).Result()
      if err != nil {
      mylogrus.MyLog.Errorf("key:%v lock start setNx err: %v", key, err)
      }
      if !flag {
      mylogrus.MyLog.Infof("key:%v lock setNx has lock", key)
      return
      }
      mylogrus.MyLog.Infof("key:%v lock setNx begin", key)
      callBack()
      //执行结束之后，移除key
      //RedisClient.Del(context.Background(), key)
      mylogrus.MyLog.Infof("key:%v lock setNx end", key)
      }
      //setNx没有，结束后，没有移除
      /*func SetNxNoDel(key string, value interface{}, expiration time.Duration, callBack func()) {
      flag, err := RedisClient.SetNX(context.Background(), key, value, expiration).Result()
      if err != nil {
      mylogrus.MyLog.Errorf("key:%v lock start setNx err: %v", key, err)
      }
      if !flag {
      mylogrus.MyLog.Infof("key:%v lock setNx has lock", key)
      return
      }
      mylogrus.MyLog.Infof("key:%v lock setNx begin", key)
      callBack()
      mylogrus.MyLog.Infof("key:%v lock setNx end", key)
      }*/
      func ClearExpired(key string, expireSec int64) error {
      return GetRedis().ZRemRangeByScore(context.Background(), key,
      "0", strconv.FormatInt(time.Now().Unix()-expireSec, 10)).Err()
      }
      func Lock(key string, expiration time.Duration) bool {
      flag, err := RedisClient.SetNX(context.Background(), key, 1, expiration).Result()
      if err != nil {
      return false
      }
      if !flag {
      return false
      }
      return true
      }
      common/tencentyun/tencentyun.go 0 → 100644
      View file @ b390a967
      package tencentyun
      import (
      "bytes"
      "encoding/json"
      "fmt"
      "io/ioutil"
      "math/rand"
      "net/http"
      "strconv"
      "strings"
      "time"
      "hilo-micCenter/common/config"
      "github.com/sirupsen/logrus"
      "github.com/tencentyun/tls-sig-api-v2-golang/tencentyun"
      )
      const (
      timUrl = "https://console.tim.qq.com/v4"
      overseaUrl = "https://adminapiger.im.qcloud.com/v4"
      basicParameters = "sdkappid={appid}&identifier=administrator&usersig={userSig}&random={random}&contenttype=json"
      sendSystemMsgUrl = timUrl + "/group_open_http_svc/send_group_system_notification?" + basicParameters
      overseaSendSystemMsgUrl = overseaUrl + "/group_open_http_svc/send_group_system_notification?" + basicParameters
      )
      func getAdminSig() (string, error) {
      return tencentyun.GenSig(config.GetTencentyunAppId(), config.GetTencentyunKey(), "administrator", 86400*180)
      }
      func getOverseaAdminSig() (string, error) {
      return tencentyun.GenSig(config.GetTxOverSeaAppId(), config.GetTxOverSeaAppKey(), "administrator", 86400*180)
      }
      // RespStruct 基本的返回结构
      type RespStruct struct {
      ActionStatus string
      ErrorCode int
      ErrorInfo string
      }
      func SendSystemMsg(logger *logrus.Entry, groupId string, members []string, content string) error {
      if config.AppIsRelease() {
      return SendSystemMsgBy(logger, groupId, members, content, overseaSendSystemMsgUrl,
      func() (string, error) {
      return getOverseaAdminSig()
      }, config.GetTxOverSeaAppId())
      } else {
      return SendSystemMsgBy(logger, groupId, members, content, sendSystemMsgUrl,
      func() (string, error) {
      return getAdminSig()
      }, config.GetTencentyunAppId())
      }
      }
      func SendSystemMsgBy(logger *logrus.Entry, txGroupId string, members []string, content string, reqUrl string, getAdminSig func() (string, error), appId int) error {
      logger = logger.WithField("appId", appId).WithField("txGroupId", txGroupId)
      logger.Infof("SendSystemMsg content: %s", content)
      beginTime := time.Now()
      type BodyStruct struct {
      GroupId string
      ToMembers_Account []string
      Content string
      }
      sig, err := getAdminSig()
      if err != nil {
      return err
      }
      url := strings.ReplaceAll(strings.ReplaceAll(strings.ReplaceAll(reqUrl,
      "{appid}", strconv.Itoa(appId)),
      "{userSig}", sig),
      "{random}", strconv.FormatUint(uint64(rand.Uint32()), 10))
      body := BodyStruct{
      GroupId: txGroupId,
      ToMembers_Account: members,
      Content: content,
      }
      jsonStr, err := json.Marshal(body)
      if err != nil {
      return err
      }
      rsp, err := http.Post(url, "application/json", bytes.NewBuffer(jsonStr))
      if err != nil {
      return err
      }
      defer rsp.Body.Close()
      result, err := ioutil.ReadAll(rsp.Body)
      if err != nil {
      return err
      }
      response := RespStruct{}
      if err := json.Unmarshal(result, &response); err != nil {
      return err
      }
      endTime := time.Now()
      logger.Infof("SendSystemMsg takes %dms: rsp: %+v", endTime.Sub(beginTime).Milliseconds(), response)
      if response.ErrorCode == 0 {
      return nil
      } else {
      return fmt.Errorf("tencentyun SendSystemMsg rsp ErrorCode:%v, ErrorInfo:%v", response.ErrorCode, response.ErrorInfo)
      }
      }
      debug.ini 0 → 100644
      View file @ b390a967
      [DATABASE]
      MYSQL_HOST=47.244.34.27:3306
      MYSQL_USERNAME=root
      MYSQL_PASSWORD=yX0jPAhO0I4s2zlA
      MYSQL_DB=hilo
      [DATABASECODE]
      MYSQL_HOST=47.244.34.27:3306
      MYSQL_USERNAME=root
      MYSQL_PASSWORD=yX0jPAhO0I4s2zlA
      MYSQL_DB=hilo_code
      [REDIS]
      REDIS_HOST=47.244.34.27:6379
      REDIS_PASSWORD=8QZ9JD1zLvPR3yHf
      [JWT]
      SECRET=hilo1632
      ISSUER_API=hiloApi
      ISSUER_Mgr=hiloMgr
      EXPIRE=240h
      [APP]
      MASTER=true
      BIZ_SECRET=biz
      WEB_SECRET=webHilo1258
      OPERATION_SECRET=operation1258236
      SUPERUSER=2701,2831,4504
      OFFICIAL_STAFF=2701,2831,3411,2511
      OFFICIAL_GROUP=@TGS#3FDW3MPHZ
      MINIMAL_VERSION_ANDROID=22001
      MINIMAL_VERSION_IOS=22000
      MODERATE=TENCENT
      [OSS]
      OSS_ACCESS_KEY_ID=LTAIxdazV2pCuV3T
      OSS_ACCESS_KEY_SECRET=zuAnreAXQ6vlAKnvvmolFLfb1N5w5S
      OSS_ROLE_ARN=acs:ram::1509841556585969:role/aliyunosstokengeneratorrole
      OSS_END_POINT=http://oss-accelerate.aliyuncs.com
      OSS_BUCKET=starvoice
      OSS_CDN=https://oss.chathot.me/
      OSS_EXPIRED_TIME=3600
      OSS_STS_POINT=me-east-1
      OSS_STS=sts-faceline-demo
      OSS_STS_AES=484194d4d0f968a7
      [AWS]
      AWS_BUCKET=starchat
      AWS_CDN=https://image.whoisamy.shop/
      AWS_DIR=hilo/
      CONFIDENCE=80
      [RONGYUN]
      RONG_CLOUD_APP_KEY=pvxdm17jpe9tr
      RONG_CLOUD_APP_SECRET=rI4giiKWaBS4
      RONG_CLOUD_URL=https://api-sg01.ronghub.com
      [TENCENTYUN]
      TENCENTYUN_APP_ID=1400548270
      TENCENTYUN_KEY=321bd60f73096b059c7350f1cd97d51028850b34fa58c5c0d26bb4a19e783de8
      TX_OVERSEA_APP_ID=40000066
      TX_OVERSEA_KEY=3ab68ea5bddc8774d90b8c764ae71188914bd5fd06f30b28790c51e44ca7885c
      [EMAS]
      REGION_ID=cn-hangzhou
      ACCESS_KEY_ID=LTAIdQZv5H1kNZp5
      ACCESS_KEY_SECRET=UnwY0ClDkqBMLwPx3OJJiLYyk9xYLO
      ANDROID_APP_KEY=30250713
      ANDROID_APP_SECRET=cae7b9a9d3e54577d2c3b60bf6d23047
      IOS_APP_KEY=30790728
      IOS_APP_SECRET=4fd69ca084c67d4b5a8d15452f0af26a
      APNS=DEV
      [AGORA]
      APP_ID=fc3e087f701b4f788099e1924c3cc7b0
      APP_CERTIFICATE=ff29c100a613433db82324e8411eabc8
      CUSTOMER_KEY=6b132c0ff7164560a2bc53fda06ea85a
      CUSTOMER_SECRET=eedad2cd16d24834990d5450ace9f1ce
      CALLBACK_SECRET=n_ZizS_N8
      [CHECKOUT]
      AUTHORIZATION=sk_test_9b5e771c-5a3f-4a8d-a4da-31b19bd43d83
      URL=https://api.sandbox.checkout.com/hosted-payments
      H5=https://test.chathot.me/action/hiloHtml/22_05_30_recharge/topup.html
      HILO_SECRET_KEY=sk_test_dfbaa3b6-135d-4376-9996-2089b7d8a086
      [MATCH]
      MATCH_FREE_TIME=60
      MATCH_FREE_TIME_VIP=60
      MATCH_ADD_TIME_FREE=90
      MATCH_AGORA_TIME=30
      MATCH_CYCLE=8
      MATCH_USER_EXPIRES=480
      MATCH_SUCCESS_WAIT_DURATION=10
      MATCH_SUCCESS_SINGLE_WAIT_TIME_IN_SEC=12
      MATCH_SUCCESS_DUAL_WAIT_TIME_IN_SEC=15
      [ONLINE]
      ONLINE_CYCLE=600
      ONLINE_USER_EXPIRES=259200
      [VIDEO]
      VIDEO_DAILY_FREE_NUM=20
      VIDEO_FREE_TIME=60
      VIDEO_FREE_TIME_VIP=300
      VIDEO_ADD_TIME_FREE=60
      VIDEO_AGORA_TIME=30
      VIDEO_MINUTE_NORMAL=30
      VIDEO_MINUTE_UNION=30
      [SESSION]
      SESSION_DAILY_FREE_NUM=50
      GUILD_USER_HELLO_DAY=30
      [BEAN]
      DIAMOND_BEAN_RATE=90
      [GEM]
      DIAMOND_GEM_RATE=10
      [H5]
      USER_LEVEL=http://test.chathot.me/action/hiloHtml/hiloUserLevel/index.html
      GROUP_SUPPORT=http://test.chathot.me/action/activityhtml/21_12_06/page.html
      LUCKY_WHEEL=https://test.chathot.me/action/activityhtml/21_12_30/page.html
      WEEKLY_STAR=http://test.chathot.me/action/hiloHtml/lxt_h5/page.html
      WEEKLY_CP=https://test.chathot.me/action/hiloHtml/Valentines_22_1_18/page.html
      COUNTRY_STAR=https://test.chathot.me/action/hiloHtml/22_08_18_nation_star/page.html
      NOBLE_BUY_IOS=https://test.chathot.me/action/hiloHtml/22_05_26_buy_nobility/page.html
      NOBLE_BUY_IOS_AUDIT=https://test.chathot.me/action/hiloHtml/lxt_h5/page.html
      GUILD_DATA_URL=https://test.chathot.me/action/hiloHtml/22_10_18_app_data_coins/index.html
      MGR_GUILD_DATA_URL=https://test.chathot.me/action/hiloHtml/22_10_18_app_data_coins/union.html
      RANKING_PINK_DIAMOND_URL=https://test.chathot.me/action/activitiesPage/2022_10_17HiloLiveH5/index.html
      GROUP_POWER_GRADE_URL=https://test.chathot.me/action/hiloHtml/2023Activity/2023_3_21FamilyLevel/index.html
      GROUP_POWER_ACT_URL=
      SHEEP_H5_URL=https://gzds.vip/yangyang?game_id=hilo_sheep
      ID_URL=https://h5.whoisamy.shop/action/hiloHtml/new_upgrade/index.html
      [GROUPIM]
      MSG_SORT_EXPIRE=21600
      MSG_SORT_SNAP=300
      MSG_PARALLEL_SIZE=10
      [GRADE]
      CHARM_SPEED_VIP=15
      ACTITY_SPEED_VIP=15
      WEALTH_SPEED_VIP=15
      [LIKE]
      I_LIKE_NUM=30
      I_LIKE_NUM_VIP=300
      I_LIKE_NUM_NOBLE=1000
      [APPLEPAY]
      PASSWORD=38702750a05c4cb09c9d6ca646835634
      [REGISTER]
      IMEI_TOTAL=3
      IMEI_OAUTH=2
      ACCOUNT_IP=100
      ACCOUNT_IP_DURATION=21600
      [BANNER]
      GIFT_BANNER_LEVEL1=500
      GIFT_BANNER_LEVEL2=2000
      GIFT_BANNER_LEVEL3=5000
      [DIAMOND]
      DAILY_LOGIN_IMEI_LIMIT=2
      DAILY_LOGIN_IP_LIMIT=5
      PRIVATE_GIFT_RETURN=10
      [LUCKY_WHEEL]
      MINIMAL_PARTICIPANT=2
      WAIT_TIMELONG=10
      WINNER_DIAMOND_BANNER=10
      [GROUP_CUSTOM_THEME]
      PIC_LIMIT=5
      DAY=10
      [GIFT]
      WALL_DIAMOND=10
      [DAILY]
      LOGIN_COMMON=5
      LOGIN_VIP=300
      [FRUIT_TYCOON]
      POOL_RATIO=80
      WATERMELON_RATIO=24
      [RISK_CONTROL]
      USER_QPS_LIMIT=60
      [PAYER_MAX]
      URL=https://pay-gate-uat.payermax.com/aggregate-pay-gate/api/gateway
      KEY=d50d149a883b8bb6
      MERCHANT_ID=SP11018326
      BIZ_TYPE=CUSTOMIZE
      VERSION=2.3
      FRONT_CALLBACK_URL=https://www.hiloconn.com
      SHOW_RESULT=1
      EXPIRE_TIME=1800
      LANGUAGE=en
      [PAYPAL]
      PAYPAL_CLIENT_ID=AQCXHyXFhNLNWoorcj3Du0J4WwBDy25DoQ7SZKNKRe4PNY0BLpeCzV_zm1HKwAvd7reWeOBCte-vMakM
      PAYPAL_SECRET_ID=EDBTK99v6wXhGXhDqDTOksK2j8NPAfJKT-wRTqTrNGrUmn8xsjkrVcO_xSvMVR6CB2bN74rGl_AFm098
      RETURN_URL=https://test.apiv1.faceline.live/v1/callback/paypal
      \ No newline at end of file
      go.mod 0 → 100644
      View file @ b390a967
      module hilo-micCenter
      go 1.17
      require (
      github.com/cespare/xxhash/v2 v2.1.1 // indirect
      github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
      github.com/go-redis/redis/v8 v8.3.3 // indirect
      github.com/joho/godotenv v1.3.0 // indirect
      github.com/lestrrat-go/file-rotatelogs v2.4.0+incompatible // indirect
      github.com/lestrrat-go/strftime v1.0.6 // indirect
      github.com/pkg/errors v0.9.1 // indirect
      github.com/rifflock/lfshook v0.0.0-20180920164130-b9218ef580f5 // indirect
      github.com/sirupsen/logrus v1.7.0 // indirect
      github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.479 // indirect
      github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ims v1.0.479 // indirect
      github.com/tencentyun/tls-sig-api-v2-golang v1.0.0 // indirect
      go.opentelemetry.io/otel v0.13.0 // indirect
      golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f // indirect
      gopkg.in/ini.v1 v1.63.2 // indirect
      )
      go.sum 0 → 100644
      View file @ b390a967
      github.com/cespare/xxhash/v2 v2.1.1 h1:6MnRN8NT7+YBpUIWxHtefFZOKTAPgGjpQSxqLNn0+qY=
      github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
      github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
      github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
      github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
      github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
      github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
      github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ=
      github.com/go-redis/redis/v8 v8.3.3 h1:e0CL9fsFDK92pkIJH2XAeS/NwO2VuIOAoJvI6yktZFk=
      github.com/go-redis/redis/v8 v8.3.3/go.mod h1:jszGxBCez8QA1HWSmQxJO9Y82kNibbUmeYhKWrBejTU=
      github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
      github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8=
      github.com/golang/protobuf v1.4.0-rc.1.0.20200221234624-67d41d38c208/go.mod h1:xKAWHe0F5eneWXFV3EuXVDTCmh+JuBKY0li0aMyXATA=
      github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrUpVNzEA03Pprs=
      github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w=
      github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0=
      github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI=
      github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
      github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
      github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
      github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
      github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
      github.com/joho/godotenv v1.3.0 h1:Zjp+RcGpHhGlrMbJzXTrZZPrWj+1vfm90La1wgB6Bhc=
      github.com/joho/godotenv v1.3.0/go.mod h1:7hK45KPybAkOC6peb+G5yklZfMxEjkZhHbwpqxOKXbg=
      github.com/lestrrat-go/envload v0.0.0-20180220234015-a3eb8ddeffcc/go.mod h1:kopuH9ugFRkIXf3YoqHKyrJ9YfUFsckUU9S7B+XP+is=
      github.com/lestrrat-go/file-rotatelogs v2.4.0+incompatible h1:Y6sqxHMyB1D2YSzWkLibYKgg+SwmyFU9dF2hn6MdTj4=
      github.com/lestrrat-go/file-rotatelogs v2.4.0+incompatible/go.mod h1:ZQnN8lSECaebrkQytbHj4xNgtg8CR7RYXnPok8e0EHA=
      github.com/lestrrat-go/strftime v1.0.6 h1:CFGsDEt1pOpFNU+TJB0nhz9jl+K0hZSLE205AhTIGQQ=
      github.com/lestrrat-go/strftime v1.0.6/go.mod h1:f7jQKgV5nnJpYgdEasS+/y7EsTb8ykN2z68n3TtcTaw=
      github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A=
      github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
      github.com/onsi/ginkgo v1.12.1/go.mod h1:zj2OWP4+oCPe1qIXoGWkgMRwljMUYCdkwsT2108oapk=
      github.com/onsi/ginkgo v1.14.2/go.mod h1:iSB4RoI2tjJc9BBv4NKIKWKya62Rps+oPG/Lv9klQyY=
      github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7JYyY=
      github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1ybHNo=
      github.com/onsi/gomega v1.10.3/go.mod h1:V9xEwhxec5O8UDM77eCW8vLymOMltsqPVYWrpDsH8xc=
      github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
      github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
      github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
      github.com/rifflock/lfshook v0.0.0-20180920164130-b9218ef580f5 h1:mZHayPoR0lNmnHyvtYjDeq0zlVHn9K/ZXoy17ylucdo=
      github.com/rifflock/lfshook v0.0.0-20180920164130-b9218ef580f5/go.mod h1:GEXHk5HgEKCvEIIrSpFI3ozzG5xOKA2DVlEX/gGnewM=
      github.com/sirupsen/logrus v1.7.0 h1:ShrD1U9pZB12TX0cVy0DtePoCH97K8EtX+mg7ZARUtM=
      github.com/sirupsen/logrus v1.7.0/go.mod h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0=
      github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
      github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
      github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
      github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
      github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.479 h1:3kwDb6p1J3LxmwnNgSSEheemPffo+vMewoDzKysYdig=
      github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.479/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
      github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ims v1.0.479 h1:xDmo1rBmSJ7Hw3iOa6DQ/++z1d7pgsEVKrZno35zR7w=
      github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ims v1.0.479/go.mod h1:3YlJ1g/Ko/iFgyBJdok+dRPTH6zRB6BBopAcFkbujPc=
      github.com/tencentyun/tls-sig-api-v2-golang v1.0.0 h1:NavMw9XO2iCLv8hTKaJW2kTaGR2SdNljMABbe39yu6Q=
      github.com/tencentyun/tls-sig-api-v2-golang v1.0.0/go.mod h1:u7WiArmCTXTaQAHJwAOaLgpJ5e2xdY5/cgMEy3ubL60=
      go.opentelemetry.io/otel v0.13.0 h1:2isEnyzjjJZq6r2EKMsFj4TxiQiexsM04AVhwbR/oBA=
      go.opentelemetry.io/otel v0.13.0/go.mod h1:dlSNewoRYikTkotEnxdmuBHgzT+k/idJSfDv/FxEnOY=
      golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
      golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
      golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
      golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
      golang.org/x/net v0.0.0-20200520004742-59133d7f0dd7/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
      golang.org/x/net v0.0.0-20201006153459-a7d1128ccaa0/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
      golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
      golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
      golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
      golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
      golang.org/x/sys v0.0.0-20190904154756-749cb33beabd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
      golang.org/x/sys v0.0.0-20191005200804-aed5e4c7ecf9/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
      golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
      golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
      golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
      golang.org/x/sys v0.0.0-20200519105757-fe76b779f299/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
      golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f h1:+Nyd8tzPX9R7BWHguqsrbFdRx3WQ/1ib8I44HXV5yTA=
      golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
      golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
      golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
      golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
      golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
      golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
      google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
      google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
      google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM=
      google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE=
      google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo=
      google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
      gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
      gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys=
      gopkg.in/ini.v1 v1.63.2 h1:tGK/CyBg7SMzb60vP1M03vNZ3VDu3wGQJwn7Sxi9r3c=
      gopkg.in/ini.v1 v1.63.2/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
      gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
      gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
      gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
      gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
      local.ini 0 → 100644
      View file @ b390a967
      [DATABASE]
      MYSQL_HOST=47.244.34.27:3306
      MYSQL_USERNAME=root
      MYSQL_PASSWORD=yX0jPAhO0I4s2zlA
      MYSQL_DB=hilo
      [DATABASECODE]
      MYSQL_HOST=47.244.34.27:3306
      MYSQL_USERNAME=root
      MYSQL_PASSWORD=yX0jPAhO0I4s2zlA
      MYSQL_DB=hilo_code
      [REDIS]
      REDIS_HOST=47.244.34.27:6379
      REDIS_PASSWORD=8QZ9JD1zLvPR3yHf
      [JWT]
      SECRET=hilo1632
      ISSUER_API=hiloApi
      ISSUER_Mgr=hiloMgr
      EXPIRE=240h
      [APP]
      MASTER=false
      BIZ_SECRET=biz
      WEB_SECRET=webHilo1258
      OPERATION_SECRET=operation1258236
      SUPERUSER=2701,2831
      OFFICIAL_STAFF=2701,2831
      OFFICIAL_GROUP=@TGS#3NC2ATRHS,@TGS#33W3KNLHK
      MINIMAL_VERSION_ANDROID=212
      MINIMAL_VERSION_IOS=100
      MODERATE=AWS
      [OSS]
      OSS_ACCESS_KEY_ID=LTAIxdazV2pCuV3T
      OSS_ACCESS_KEY_SECRET=zuAnreAXQ6vlAKnvvmolFLfb1N5w5S
      OSS_ROLE_ARN=acs:ram::1509841556585969:role/aliyunosstokengeneratorrole
      OSS_END_POINT=http://oss-accelerate.aliyuncs.com
      OSS_BUCKET=starvoice
      OSS_CDN=https://oss.chathot.me/
      OSS_EXPIRED_TIME=3600
      OSS_STS_POINT=me-east-1
      OSS_STS=sts-faceline-demo
      OSS_STS_AES=484194d4d0f968a7
      [AWS]
      AWS_BUCKET=starchat
      AWS_CDN=https://image.whoisamy.shop/
      AWS_DIR=hilo/
      CONFIDENCE=80
      [RONGYUN]
      RONG_CLOUD_APP_KEY=pvxdm17jpe9tr
      RONG_CLOUD_APP_SECRET=rI4giiKWaBS4
      RONG_CLOUD_URL=https://api-sg01.ronghub.com
      [TENCENTYUN]
      TENCENTYUN_APP_ID=1400548270
      TENCENTYUN_KEY=321bd60f73096b059c7350f1cd97d51028850b34fa58c5c0d26bb4a19e783de8
      TX_OVERSEA_APP_ID=40000066
      TX_OVERSEA_KEY=3ab68ea5bddc8774d90b8c764ae71188914bd5fd06f30b28790c51e44ca7885c
      [EMAS]
      REGION_ID=cn-hangzhou
      ACCESS_KEY_ID=LTAI4FhNPzxdzD4w6bHirL9Z
      ACCESS_KEY_SECRET=OQvUJpXDrjGi3g1F2aHiAIFWIvLdbP
      ANDROID_APP_KEY=30250713
      ANDROID_APP_SECRET=cae7b9a9d3e54577d2c3b60bf6d23047
      IOS_APP_KEY=30240346
      IOS_APP_SECRET=57f33ab9ca6a957a8c659f2b0b6d1205
      APNS=DEV
      [AGORA]
      APP_ID=fc3e087f701b4f788099e1924c3cc7b0
      APP_CERTIFICATE=ff29c100a613433db82324e8411eabc8
      CUSTOMER_KEY=6b132c0ff7164560a2bc53fda06ea85a
      CUSTOMER_SECRET=eedad2cd16d24834990d5450ace9f1ce
      CALLBACK_SECRET=n_ZizS_N8
      [CHECKOUT]
      AUTHORIZATION=sk_test_9b5e771c-5a3f-4a8d-a4da-31b19bd43d83
      URL=https://api.sandbox.checkout.com/hosted-payments
      H5=http://test.chathot.me/action/hiloHtml/22_05_30_recharge/topup.html
      HILO_SECRET_KEY=sk_test_dfbaa3b6-135d-4376-9996-2089b7d8a086
      [MATCH]
      MATCH_FREE_TIME=60
      MATCH_FREE_TIME_VIP=300
      MATCH_ADD_TIME_FREE=90
      MATCH_AGORA_TIME=30
      MATCH_CYCLE=8
      MATCH_USER_EXPIRES=480
      MATCH_SUCCESS_WAIT_DURATION=10
      MATCH_SUCCESS_SINGLE_WAIT_TIME_IN_SEC=12
      MATCH_SUCCESS_DUAL_WAIT_TIME_IN_SEC=15
      [ONLINE]
      ONLINE_CYCLE=600
      ONLINE_USER_EXPIRES=259200
      [VIDEO]
      VIDEO_DAILY_FREE_NUM=20
      VIDEO_FREE_TIME=60
      VIDEO_FREE_TIME_VIP=300
      VIDEO_ADD_TIME_FREE=60
      VIDEO_AGORA_TIME=30
      VIDEO_MINUTE_NORMAL=1000
      VIDEO_MINUTE_UNION=2000
      [SESSION]
      SESSION_DAILY_FREE_NUM=50
      [BEAN]
      DIAMOND_BEAN_RATE=90
      [GEM]
      DIAMOND_GEM_RATE=10
      [H5]
      USER_LEVEL=http://test.chathot.me/action/activityhtml/hiloUserLevel/index.html
      GROUP_SUPPORT=http://test.chathot.me/action/activityhtml/21_12_06/page.html
      LUCKY_WHEEL=https://h5.whoisamy.shop/action/activityhtml/21_12_30/page.html
      NOBLE_BUY_IOS=https://h5.whoisamy.shop/action/hiloHtml/lxt_h5/page.html
      NOBLE_BUY_IOS_AUDIT=https://h5.whoisamy.shop/action/hiloHtml/lxt_h5/page.html
      GROUP_POWER_GRADE_URL=https://test.chathot.me/action/hiloHtml/2023Activity/2023_3_21FamilyLevel/index.html
      GROUP_POWER_ACT_URL=https://www.baidu.com
      SHEEP_H5_URL=https://gzds.vip/yangyang?game_id=hilo_sheep
      ID_URL=https://h5.whoisamy.shop/action/hiloHtml/new_upgrade/index.html
      [GROUPIM]
      MSG_SORT_EXPIRE=43200
      MSG_SORT_SNAP=300
      [GRADE]
      CHARM_SPEED_VIP=15
      ACTITY_SPEED_VIP=15
      WEALTH_SPEED_VIP=15
      [LIKE]
      I_LIKE_NUM=30
      I_LIKE_NUM_VIP=100
      I_LIKE_NUM_NOBLE=1000
      [APPLEPAY]
      PASSWORD=38702750a05c4cb09c9d6ca646835634
      [REGISTER]
      IMEI_TOTAL=3
      IMEI_OAUTH=2
      ACCOUNT_IP=100
      ACCOUNT_IP_DURATION=21600
      [BANNER]
      GIFT_BANNER_LEVEL1=100
      GIFT_BANNER_LEVEL2=2000
      GIFT_BANNER_LEVEL3=5000
      [DIAMOND]
      DAILY_LOGIN_IMEI_LIMIT=200
      DAILY_LOGIN_IP_LIMIT=5
      PRIVATE_GIFT_RETURN=1440
      NEW_USER_INVITE_AWARD=5000
      [LUCKY_WHEEL]
      MINIMAL_PARTICIPANT=2
      WAIT_TIMELONG=10
      WINNER_DIAMOND_BANNER=100
      [GROUP_CUSTOM_THEME]
      PIC_LIMIT=5
      DAY=10
      [GIFT]
      WALL_DIAMOND=10
      [DAILY]
      LOGIN_COMMON=5
      LOGIN_VIP=300
      [DAILY]
      LOGIN_COMMON=5
      LOGIN_VIP=300
      [FRUIT_TYCOON]
      POOL_RATIO=20
      WATERMELON_RATIO=70
      [ACTIVITY]
      COUNTRY_STAR_POOL_RATIO=20
      COUNTRY_STAR_ORDINARY_RATIO=20
      [PAYER_MAX]
      URL=https://pay-gate-uat.payermax.com/aggregate-pay-gate/api/gateway
      KEY=d50d149a883b8bb6
      MERCHANT_ID=SP11018326
      BIZ_TYPE=CUSTOMIZE
      VERSION=2.3
      FRONT_CALLBACK_URL=https://www.hiloconn.com
      SHOW_RESULT=1
      EXPIRE_TIME=1800
      LANGUAGE=en
      \ No newline at end of file
      main.go 0 → 100644
      View file @ b390a967
      package main
      import (
      "context"
      "encoding/json"
      "fmt"
      "github.com/go-redis/redis/v8"
      "hilo-micCenter/common/dingding"
      "hilo-micCenter/common/mylogrus"
      "hilo-micCenter/common/redisCli"
      "hilo-micCenter/common/tencentyun"
      "time"
      )
      const SEND_WORKER = 2000 // 消费端协程数量
      const MONITOR_LENGTH = 100 // 队列告警数量
      var sendChan chan GroupSystemMsg
      func main() {
      //if !config.IsMaster() {
      // return
      //}
      mylogrus.MyLog.Infof("cron micChangeSys start")
      // 8核 n send + 4 blpop
      sendChan = make(chan GroupSystemMsg, SEND_WORKER)
      for i := 0; i < 4; i++ {
      go func() {
      deal()
      }()
      }
      for i := 0; i < SEND_WORKER; i++ {
      go func() {
      send()
      }()
      }
      go check()
      select {}
      }
      func check() {
      tick := time.NewTicker(time.Second * 3)
      defer tick.Stop()
      for {
      select {
      case <-tick.C:
      l, err := redisCli.GetRedis().LLen(context.Background(), micInfoChange).Result()
      if err != nil {
      mylogrus.MyLog.Infof("cron micChangeSys msg error,left %v-%v", l, err)
      }
      if l > MONITOR_LENGTH {
      go func() {
      if sErr := dingding.SendDingRobot(dingding.ROBOTWEBHOOK, fmt.Sprintf("麦位变化通知延迟,队列%s长度:%d", micInfoChange, l), true); sErr != nil {
      mylogrus.MyLog.Errorf("dingding msg fail:%v", sErr)
      }
      }()
      }
      if l > 0 {
      mylogrus.MyLog.Infof("cron micChangeSys msg,left %v", l)
      }
      }
      }
      }
      func deal() {
      for true {
      //不需要加锁，注意，阻塞。
      strs, err := redisCli.GetRedis().BLPop(context.Background(), time.Second, micInfoChange).Result()
      if err != nil {
      if err != redis.Nil {
      mylogrus.MyLog.Errorf("cron micChangeSys redisCli.GetRedis().BLPop err:+%v", err)
      }
      }
      if len(strs) >= 2 {
      content := strs[1]
      mylogrus.MyLog.Infof("cron micChangeSys content:%v", content)
      micSystemMsg := MicSystemMsg{}
      if err := json.Unmarshal([]byte(content), &micSystemMsg); err != nil {
      mylogrus.MyLog.Errorf("cron micChangeSys Unmarshal err:%+v, content:%v", err, content)
      }
      sendChan <- GroupSystemMsg{
      MsgGroupUid: micSystemMsg.GroupUid,
      MsgId: micSystemMsg.MsgId,
      Source: micSystemMsg.Source,
      Target: micSystemMsg.Target,
      Content: micSystemMsg.Content,
      }
      }
      }
      }
      //var limiter = rate.NewLimiter(2000, 2000)
      func send() {
      for msg := range sendChan {
      //if err := limiter.Wait(context.Background()); err == nil {
      SendSignalMsg(msg.MsgGroupUid, msg)
      //}
      }
      }
      const micInfoChange = "mic_info_change"
      type MicSystemMsg struct {
      GroupUid string //房间ID
      Source string
      Target string
      MsgId uint8
      Content string //要发送的内容
      }
      type GroupSystemMsg struct {
      MsgGroupUid string `json:"-"`
      MsgId uint8 `json:"msgId"`
      Source string `json:"source"`
      Target string `json:"target"`
      Content string `json:"content"`
      }
      // SendSignalMsg 发送群信令。入参是内部imGroupId，这里做转换
      func SendSignalMsg(groupId string, msg GroupSystemMsg) {
      buffer, err := json.Marshal(msg)
      if err == nil {
      str := string(buffer)
      mylogrus.MyLog.Infof("cron micChangeSys SendSignalMsg: %s", str)
      logger := mylogrus.MyLog.WithField("msgId", msg.MsgId)
      if err = tencentyun.SendSystemMsg(logger, groupId, []string{}, str); err != nil {
      mylogrus.MyLog.Errorf("cron micChangeSys SendSignalMsg sync failed for %s, msgId = %d, content:%v, err:%+v", groupId, msg.MsgId, str, err)
      content := fmt.Sprintf("腾讯云推送失败,content:%v,err:%v", str, err.Error())
      if err := dingding.SendDingRobot(dingding.ROBOTWEBHOOK, content, true); err != nil {
      mylogrus.MyLog.Errorf("cron micChangeSys SendSignalMsg send dingding fail%s", err.Error())
      }
      } else {
      mylogrus.MyLog.Infof("cron micChangeSys SendSignalMsg sync success for %s, msgId = %d, content:%v", groupId, msg.MsgId, str)
      }
      } else {
      mylogrus.MyLog.Errorf("cron micChangeSys SendSignalMsg failure, msgId = %d : %s , msg:%+v", msg.MsgId, err.Error(), msg)
      }
      }
      release.ini 0 → 100644
      View file @ b390a967
      [DATABASE]
      MYSQL_HOST=ua4papc3hmgqf351pbej-rw4rm.rwlb.dubai.rds.aliyuncs.com
      MYSQL_USERNAME=nextvideo
      MYSQL_PASSWORD=ihlUwI4nhi9W88MI
      MYSQL_DB=hilo
      [DATABASECODE]
      MYSQL_HOST=ua4papc3hmgqf351pbej-rw4rm.rwlb.dubai.rds.aliyuncs.com
      MYSQL_USERNAME=nextvideo
      MYSQL_PASSWORD=ihlUwI4nhi9W88MI
      MYSQL_DB=hilo_code
      [REDIS]
      REDIS_HOST=r-eb3btxn8vfdsuwdbuf.redis.dubai.rds.aliyuncs.com:6379
      REDIS_PASSWORD=
      [JWT]
      SECRET=hilo1504
      ISSUER_API=hiloApi
      ISSUER_Mgr=hiloMgr
      EXPIRE=720h
      [APP]
      MASTER=true
      BIZ_SECRET=biz
      OPERATION_SECRET=operation1258236
      WEB_SECRET=webHilo1258
      SUPERUSER=28201,23951,133101,41,2020531,955271,1575531
      OFFICIAL_STAFF=133101,435731,486461,41
      OFFICIAL_GROUP=@TGS#33W3KNLHK,@TGS#3XA5RJ5HH,@TGS#3O6PKBTH6
      MINIMAL_VERSION_ANDROID=22600
      MINIMAL_VERSION_IOS=22600
      ROOM_MODE=AVChatRoom
      MODERATE=TENCENT
      [OSS]
      OSS_ACCESS_KEY_ID=LTAIxdazV2pCuV3T
      OSS_ACCESS_KEY_SECRET=zuAnreAXQ6vlAKnvvmolFLfb1N5w5S
      OSS_ROLE_ARN=acs:ram::1509841556585969:role/aliyunosstokengeneratorrole
      OSS_END_POINT=https://oss-accelerate.aliyuncs.com
      OSS_BUCKET=starvoice
      OSS_CDN=https://oss.chathot.me/
      OSS_EXPIRED_TIME=3600
      OSS_STS_POINT=me-east-1
      OSS_STS=sts-faceline-demo
      OSS_STS_AES=484194d4d0f968a7
      [AWS]
      AWS_BUCKET=starchat
      AWS_CDN=https://image.whoisamy.shop/
      AWS_DIR=hilo/
      CONFIDENCE=80
      [RONGYUN]
      RONG_CLOUD_APP_KEY=uwd1c0sxu5t41
      RONG_CLOUD_APP_SECRET=vo9djozyBl9bZ
      RONG_CLOUD_URL=https://api-sg01.ronghub.com
      [TENCENTYUN]
      TENCENTYUN_APP_ID=1400487464
      TENCENTYUN_KEY=cb4c1f2e3398a88e0e9468b403f671e60d66a564df86f7db925c6ab4f18b66e5
      TX_OVERSEA_APP_ID=40000066
      TX_OVERSEA_KEY=3ab68ea5bddc8774d90b8c764ae71188914bd5fd06f30b28790c51e44ca7885c
      [EMAS]
      REGION_ID=cn-hangzhou
      ACCESS_KEY_ID=LTAIdQZv5H1kNZp5
      ACCESS_KEY_SECRET=UnwY0ClDkqBMLwPx3OJJiLYyk9xYLO
      ANDROID_APP_KEY=30774987
      ANDROID_APP_SECRET=297a0f231f1286a2de9aab097cc8ff5c
      IOS_APP_KEY=30790728
      IOS_APP_SECRET=4fd69ca084c67d4b5a8d15452f0af26a
      APNS=PRODUCT
      [AGORA]
      APP_ID=6291d069123642d9929a49c734c50719
      APP_CERTIFICATE=d5de40350aa54e60bcdce90c71e9598a
      CUSTOMER_KEY=6b132c0ff7164560a2bc53fda06ea85a
      CUSTOMER_SECRET=eedad2cd16d24834990d5450ace9f1ce
      [CHECKOUT]
      AUTHORIZATION=sk_fca6e213-b7df-4bd7-99f4-7c0a9f7c778c
      URL=https://api.checkout.com/hosted-payments
      H5=https://h5.whoisamy.shop/action/hiloHtml/22_05_30_recharge/topup.html
      HILO_SECRET_KEY=sk_26806bf4-e6e3-45e2-a093-c72c5b53eaf5
      [MATCH]
      MATCH_FREE_TIME=60
      MATCH_FREE_TIME_VIP=60
      MATCH_ADD_TIME_FREE=90
      MATCH_AGORA_TIME=30
      MATCH_CYCLE=8
      MATCH_USER_EXPIRES=480
      MATCH_SUCCESS_WAIT_DURATION=10
      MATCH_SUCCESS_SINGLE_WAIT_TIME_IN_SEC=12
      MATCH_SUCCESS_DUAL_WAIT_TIME_IN_SEC=15
      [ONLINE]
      ONLINE_CYCLE=600
      ONLINE_USER_EXPIRES=259200
      [VIDEO]
      VIDEO_DAILY_FREE_NUM=20
      VIDEO_FREE_TIME=60
      VIDEO_FREE_TIME_VIP=300
      VIDEO_ADD_TIME_FREE=60
      VIDEO_AGORA_TIME=30
      VIDEO_MINUTE_NORMAL=60
      VIDEO_MINUTE_UNION=60
      [SESSION]
      SESSION_DAILY_FREE_NUM=50
      GUILD_USER_HELLO_DAY=30
      [BEAN]
      DIAMOND_BEAN_RATE=90
      [GEM]
      DIAMOND_GEM_RATE=10
      [H5]
      USER_LEVEL=https://h5.whoisamy.shop/action/hiloHtml/hiloUserLevel/index.html
      GROUP_SUPPORT=https://h5.whoisamy.shop/action/activityhtml/21_12_06/page.html
      LUCKY_WHEEL=https://h5.whoisamy.shop/action/activityhtml/21_12_30/page.html
      WEEKLY_STAR=https://h5.whoisamy.shop/action/hiloHtml/lxt_h5/page.html
      WEEKLY_CP=https://h5.whoisamy.shop/action/hiloHtml/Valentines_22_1_18/page.html
      COUNTRY_STAR=https://h5.whoisamy.shop/action/hiloHtml/22_08_18_nation_star/page.html
      NOBLE_BUY_IOS=https://h5.whoisamy.shop/action/hiloHtml/22_05_26_buy_nobility/page.html
      NOBLE_BUY_IOS_AUDIT=https://h5.whoisamy.shop/action/hiloHtml/lxt_h5/page.html
      GUILD_DATA_URL=https://h5.whoisamy.shop/action/hiloHtml/22_10_18_app_data_coins/index.html
      MGR_GUILD_DATA_URL=https://h5.whoisamy.shop/action/hiloHtml/22_10_18_app_data_coins/union.html
      RANKING_PINK_DIAMOND_URL=https://h5.whoisamy.shop/action/activitiesPage/2022_10_17HiloLiveH5/index.html
      GROUP_POWER_GRADE_URL=https://h5.whoisamy.shop/action/hiloHtml/2023Activity/2023_3_21FamilyLevel/index.html
      ID_URL=https://h5.whoisamy.shop/action/hiloHtml/new_upgrade/index.html
      GROUP_POWER_ACT_URL=https://h5.whoisamy.shop/action/hiloHtml/2023Activity/2023_4_21FamilyMonth/index.html
      SHEEP_H5_URL=https://h5.whoisamy.shop/action/slotRelease/sheep0322v1/index.html?game_id=hilo_sheep
      [GROUPIM]
      MSG_SORT_EXPIRE=1209600
      MSG_SORT_SNAP=300
      MSG_PARALLEL_SIZE=10
      [GRADE]
      CHARM_SPEED_VIP=15
      ACTITY_SPEED_VIP=15
      WEALTH_SPEED_VIP=15
      [LIKE]
      I_LIKE_NUM=500
      I_LIKE_NUM_VIP=1000
      I_LIKE_NUM_NOBLE=5000
      [APPLEPAY]
      PASSWORD=38702750a05c4cb09c9d6ca646835634
      [REGISTER]
      IMEI_TOTAL=5
      IMEI_OAUTH=2
      ACCOUNT_IP=100
      ACCOUNT_IP_DURATION=21600
      [BANNER]
      GIFT_BANNER_LEVEL1=3000
      GIFT_BANNER_LEVEL2=5000
      GIFT_BANNER_LEVEL3=10000
      [DIAMOND]
      DAILY_LOGIN_IMEI_LIMIT=5
      DAILY_LOGIN_IP_LIMIT=30
      PRIVATE_GIFT_RETURN=1440
      NEW_USER_INVITE_AWARD=5000
      [LUCKY_WHEEL]
      MINIMAL_PARTICIPANT=2
      WAIT_TIMELONG=10
      WINNER_DIAMOND_BANNER=200
      [GROUP_CUSTOM_THEME]
      PIC_LIMIT=50
      DAY=10
      [GIFT]
      WALL_DIAMOND=2000
      [DAILY]
      LOGIN_COMMON=10
      LOGIN_VIP=1000
      [FRUIT_TYCOON]
      BIG_WINNER_THRESDHOLD=30000
      BIG_WINNER_LOW=10000
      BIG_WINNER_HIGH=20000
      POOL_RATIO=5
      WATERMELON_RATIO=24
      [ACTIVITY]
      COUNTRY_STAR_POOL_RATIO=20
      COUNTRY_STAR_ORDINARY_RATIO=20
      [RISK_CONTROL]
      USER_QPS_LIMIT=128
      USER_URL_QPS_LIMIT=64
      [PAYER_MAX]
      URL=https://pay-gate.payermax.com/aggregate-pay-gate/api/gateway
      KEY=503a970695756efa
      MERCHANT_ID=SP11018326
      BIZ_TYPE=CUSTOMIZE
      VERSION=2.3
      FRONT_CALLBACK_URL=https://www.hiloconn.com
      SHOW_RESULT=1
      EXPIRE_TIME=1800
      LANGUAGE=en
      [PAYPAL]
      PAYPAL_CLIENT_ID=AXn-z2U6D2uKW0eJBoH3Hg0MzH6i8mLackAP9bcub2W_YmfMC-YBuPD3sTQgwJSecmAVtHIS9IsqBiIy
      PAYPAL_SECRET_ID=EBNCFnSEwbteb8TDVtCMcOUcQBimG7hABmSe0bgC05HriWmje7cKFV2F4xI9pZnt1hDetKLnYxfmWYSY
      RETURN_URL=https://apiv1.faceline.live/v1/callback/paypal
      \ No newline at end of file
      run.sh 0 → 100644
      View file @ b390a967
      #!/usr/bin/bash
      if [ $# -lt 1 ]
      then
      echo "Parameters missing."
      echo "Usage: $0 <executable name>"
      exit
      fi
      while :
      do
      $1
      printf "$(date) : $1 return $?, wait for 5 seconds to restart\n"
      sleep 5
      done
      \ No newline at end of file
      Markdown is supported
      0% or
      You are about to add 0 people to the discussion. Proceed with caution.
      Finish editing this message first!
      Please register or to comment