Initial commit

4f15a6a6 · hujiebin · 4f15a6a6 · 4f15a6a6 · 4f15a6a6 · 4f15a6a6
Commit 4f15a6a6 authored May 19, 2023 by hujiebin
24 changed files
--- a/.env
+++ b/.env
+MODE=local
--- a/.gitignore
+++ b/.gitignore
+.idea
+/protocol/userProxy/
+/protocol/userCenter/
+/protocol/biz/
--- a/Makefile
+++ b/Makefile
+proto:
+	protoc --go_out=./ --go-grpc_out=. ./protocol/*.proto
\ No newline at end of file
--- a/common/coder.go
+++ b/common/coder.go
+package common
+import (
+	"encoding/binary"
+	"errors"
+	"fmt"
+	"hash/crc32"
+	"time"
+)
+const (
+	Login_success       = 0
+	Login_valid_token   = 1
+	Login_token_expired = 2
+)
+const (
+	ROUTE_SUCCESS = iota
+	ROUTE_CHANNEL_NOT_FOUND
+)
+const (
+	MsgTypeLogin = 1 + iota
+	MsgTypeLoginRsp
+	MsgTypeHeartBeat
+	MsgTypeHeartBeatRsp
+	MsgTypeKickUser
+	MsgTypeBiz = 7
+	MsgTypeBizRsp
+)
+const (
+	MsgTypeMatchSuccess = 100 + iota
+	MsgTypeMatchConfirm
+	MsgTypeCallReady
+	MsgTypeAddTimeGift
+	MsgTypeAddTimeFree
+)
+const (
+	MsgTypeRecallWindow             = 109
+	MsgTypeVideo                    = 110 // 1v1视频-v1-黄钻
+	MsgTypeVideoCallReady           = 111
+	MsgTypeLikeEach                 = 112
+	MsgTypeLikeMe                   = 113
+	MsgTypeDailyInAppDiamond        = 114
+	MsgTypeGlobalGiftBanner         = 115 // 礼物横幅
+	MsgTypeGlobalGiftBannerRsp      = 116
+	MsgTypeLuckyWheel               = 117 //已丢弃
+	MsgTypeLuckyWheelBanner         = 118
+	MsgTypeDiamondChange            = 119 // Kludge：事实上是通用的钻石变更通知了
+	MsgTypeConfigChange             = 120 // 配置变更通知
+	MsgTypeGlobalRocketNotice       = 121 // 火箭全局横幅
+	MsgTypeGroupChatNotice          = 122 // 群发消息弹窗
+	MsgTypeGlobalBroadcast          = 123 // 群发消息弹窗
+	MsgMicTaskFinish                = 124 // 麦上任务完成
+	MsgFruitMachine                 = 125 // 水果机开奖
+	MsgTypeNobleChange              = 126 // 贵族变更
+	MsgTypeJoinGroup                = 127 // 加入群组成功
+	MsgTypeVideoTimeMinuteSuccess   = 128 // 1对1视频加时成功
+	MsgTypeVideoTimeMinuteCheck     = 129 // 1对1视频加时检查
+	MsgTypeVideoMiss                = 130 // 1对1视频错过
+	MsgTypeRoomGroupActivity        = 131 // 进房，群组活动推送
+	MsgTypeVideoV2                  = 132 // 1v1视频-v2-粉钻
+	MsgTypeVideoV2TimeMinuteCheck   = 133 // 1v1视频-v2-加时检查
+	MsgTypeVideoV2CallReady         = 134 // 1v1视频-v2-callReady
+	MsgTypeVideoV2TimeMinuteSuccess = 135 // 1v1视频-v2-加时成功
+	MsgTypeMatchV2Success           = 140 // 匹配-v2-成功
+	MsgTypeMatchV2Confirm           = 141 // 匹配-v2-确认
+	MsgTypeMatchV2CallReady         = 142 // 匹配-v2-callReady
+	MsgTypeMatchV2AddTimeGift       = 143 // 匹配-v2-送礼加时长
+)
+const (
+	RoomBannerChange  = 1 // 房间banner变更
+	GiftConfigChange  = 2 // 礼物配置变更
+	OpenScreenChange  = 3 // 开屏配置变更
+	MatchConfigChange = 4 // 匹配配置发生了变化
+)
+func EncodeMessage(msgType uint32, serialNum uint64, userdata []byte) []byte {
+	msg := make([]byte, 26)
+	dataLen := len(userdata)
+	binary.BigEndian.PutUint16(msg, 1)
+	binary.BigEndian.PutUint32(msg[2:], msgType)
+	binary.BigEndian.PutUint64(msg[6:], serialNum)
+	binary.BigEndian.PutUint64(msg[14:], uint64(time.Now().UnixNano()/1000))
+	binary.BigEndian.PutUint32(msg[22:], uint32(dataLen))
+	msg = append(msg, userdata...)
+	checkSum := crc32.ChecksumIEEE(msg)
+	msg = append(msg, 0, 0, 0, 0)
+	binary.BigEndian.PutUint32(msg[26+dataLen:], checkSum)
+	return msg
+}
+func DecodeMessage(message []byte) (uint32, uint64, uint64, []byte, error) {
+	length := len(message)
+	// 保证消息至少有26bytes
+	if length >= 26 {
+		//version := binary.BigEndian.Uint16(message[0:2])
+		msgType := binary.BigEndian.Uint32(message[2:6])
+		msgId := binary.BigEndian.Uint64(message[6:14])
+		timeStamp := binary.BigEndian.Uint64(message[14:22])
+		dataLen := binary.BigEndian.Uint32(message[22:26])
+		//log.Printf("DecodeMessage version = %d, msgType = %d, msgId = %d, timeStamp = %d, dataLen = %d\n", version, msgType, msgId, timeStamp, dataLen)
+		// 保证ws消息至少有msgLen长
+		if uint32(length) >= dataLen+30 {
+			pbData := message[26 : dataLen+26]
+			checksum := binary.BigEndian.Uint32(message[dataLen+26 : dataLen+30])
+			//fmt.Printf("pbData size = %d, checksum = %d\n", len(pbData), checksum)
+			myCheckSum := crc32.ChecksumIEEE(message[0 : dataLen+26])
+			if checksum != myCheckSum {
+				return 0, msgId, timeStamp, nil, errors.New("checksum error")
+			}
+			return msgType, msgId, timeStamp, pbData, nil
+		} else {
+			fmt.Printf("payload too short length = %d, msgType = %d\n", length, msgType)
+			return 0, msgId, timeStamp, nil, errors.New("payload too short")
+		}
+	} else {
+		fmt.Printf("message too short for header %d\n ", length)
+		return 0, 0, 0, nil, errors.New("message too short")
+	}
+}
--- a/common/config/config.go
+++ b/common/config/config.go
--- a/common/dingding/dingding.go
+++ b/common/dingding/dingding.go
+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
+}
--- a/common/jwt.go
+++ b/common/jwt.go
+package common
+import (
+	"github.com/dgrijalva/jwt-go"
+)
+// 载荷，增加用户别名
+type Claims struct {
+	UserId uint64
+	jwt.StandardClaims
+}
+func SetJWTSecret(secret string) {
+	jwtSecret = []byte(secret)
+}
+var jwtSecret []byte
+//解析token
+func ParseToken(token string) (*Claims, error) {
+	tokenClaims, err := jwt.ParseWithClaims(token, &Claims{}, func(token *jwt.Token) (interface{}, error) {
+		return jwtSecret, nil
+	})
+	if err != nil {
+		return nil, err
+	}
+	if tokenClaims != nil {
+		claims, ok := tokenClaims.Claims.(*Claims)
+		if ok && tokenClaims.Valid {
+			return claims, nil
+		}
+	}
+	return nil, err
+}
\ No newline at end of file
--- a/common/mylogrus/log.go
+++ b/common/mylogrus/log.go
+package mylogrus
+import (
+	"github.com/lestrrat-go/file-rotatelogs"
+	"github.com/rifflock/lfshook"
+	"github.com/sirupsen/logrus"
+	"hilo-userCenter/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]) + "."
+	// 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
+}
--- a/common/mylogrus/log_unix.go
+++ b/common/mylogrus/log_unix.go
+//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
+}
--- a/common/mylogrus/log_windows.go
+++ b/common/mylogrus/log_windows.go
+//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
+}
--- a/common/utils.go
+++ b/common/utils.go
+package common
+import (
+	"fmt"
+	"net"
+	"runtime/debug"
+	"hilo-userCenter/common/mylogrus"
+)
+func CheckGoPanic() {
+	if r := recover(); r != nil {
+		//打印错误堆栈信息
+		mylogrus.MyLog.Errorf("ACTION PANIC: %v, stack: %v", r, string(debug.Stack()))
+	}
+}
+// 获取内网地址
+func GetClientIpV2() (string, error) {
+	addrs, err := net.InterfaceAddrs()
+	if err != nil {
+		return "", err
+	}
+	for _, address := range addrs {
+		// 检查ip地址判断是否回环地址
+		if ipNet, ok := address.(*net.IPNet); ok && ipNet.IP.IsGlobalUnicast() {
+			//if ipNet, ok := address.(*net.IPNet); ok && !ipNet.IP.IsLoopback() {
+			if ipNet.IP.To4() != nil {
+				return ipNet.IP.String(), nil
+			}
+		}
+	}
+	return "", fmt.Errorf("can not find the client ip address")
+}
--- a/debug.ini
+++ b/debug.ini
+[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
--- a/go.mod
+++ b/go.mod
+module hilo-userCenter
+go 1.17
+require (
+	github.com/armon/go-metrics v0.0.0-20180917152333-f0300d1749da // indirect
+	github.com/cespare/xxhash/v2 v2.1.1 // indirect
+	github.com/dgrijalva/jwt-go v3.2.0+incompatible // indirect
+	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
+	github.com/fatih/color v1.9.0 // indirect
+	github.com/go-redis/redis/v8 v8.3.3 // indirect
+	github.com/go-sql-driver/mysql v1.5.0 // indirect
+	github.com/golang/protobuf v1.4.3 // indirect
+	github.com/hashicorp/consul/api v1.7.0 // indirect
+	github.com/hashicorp/go-cleanhttp v0.5.1 // indirect
+	github.com/hashicorp/go-hclog v0.12.0 // indirect
+	github.com/hashicorp/go-immutable-radix v1.0.0 // indirect
+	github.com/hashicorp/go-rootcerts v1.0.2 // indirect
+	github.com/hashicorp/golang-lru v0.5.0 // indirect
+	github.com/hashicorp/serf v0.9.3 // indirect
+	github.com/jinzhu/inflection v1.0.0 // indirect
+	github.com/jinzhu/now v1.1.1 // 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/mattn/go-colorable v0.1.6 // indirect
+	github.com/mattn/go-isatty v0.0.12 // indirect
+	github.com/mitchellh/go-homedir v1.1.0 // indirect
+	github.com/mitchellh/mapstructure v1.1.2 // 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
+	go.opentelemetry.io/otel v0.13.0 // indirect
+	golang.org/x/net v0.0.0-20201006153459-a7d1128ccaa0 // indirect
+	golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f // indirect
+	golang.org/x/text v0.3.3 // indirect
+	google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 // indirect
+	google.golang.org/grpc v1.42.0 // indirect
+	google.golang.org/protobuf v1.25.0 // indirect
+	gopkg.in/ini.v1 v1.63.2 // indirect
+	gorm.io/driver/mysql v1.0.3 // indirect
+	gorm.io/gorm v1.20.12 // indirect
+)
--- a/go.sum
+++ b/go.sum
--- a/local.ini
+++ b/local.ini
+[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
--- a/main.go
+++ b/main.go
--- a/manager/bizManager.go
+++ b/manager/bizManager.go
+package manager
+import (
+	"context"
+	"google.golang.org/grpc"
+	"log"
+	"sync"
+	"time"
+)
+var BizMgr = BizManager{}
+type BizManager struct {
+	mutex   sync.RWMutex
+	clients map[string]*grpc.ClientConn
+}
+func init() {
+	BizMgr.clients = make(map[string]*grpc.ClientConn, 0)
+}
+// 创建Client连接，保存并返回
+func (m *BizManager) MakeClient(addr string) *grpc.ClientConn {
+	conn := m.GetClient(addr)
+	if conn == nil {
+		ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
+		defer cancel()
+		c, err := grpc.DialContext(ctx, addr, grpc.WithInsecure(), grpc.WithBlock())
+		if err == nil {
+			if c == nil {
+				log.Printf("Failed in connecting to %s:\n", addr)
+			} else {
+				conn = c
+				m.SetClient(addr, conn)
+				log.Printf("Connection to %s established.\n", addr)
+			}
+		} else {
+			log.Printf("Failed to connect %s: %v\n", addr, err)
+		}
+	} else {
+		//log.Printf("Connection to %s already exists, state = %s\n", addr, conn.GetState().String())
+	}
+	return conn
+}
+func (m *BizManager) GetClient(addr string) *grpc.ClientConn {
+	m.mutex.RLock()
+	defer m.mutex.RUnlock()
+	return m.clients[addr]
+}
+func (m *BizManager) SetClient(addr string, c *grpc.ClientConn) {
+	m.mutex.Lock()
+	defer m.mutex.Unlock()
+	m.clients[addr] = c
+}
--- a/manager/terminalManager.go
+++ b/manager/terminalManager.go
+package manager
+import (
+	"context"
+	"github.com/go-redis/redis/v8"
+	"log"
+	"strconv"
+)
+const (
+	terminal_key = "terminal"
+)
+type TerminalManager struct {
+	Ctx         context.Context
+	RedisClient *redis.Client
+}
+func (m *TerminalManager) GetTerminal(uid uint64) *string {
+	field := strconv.FormatUint(uid, 10)
+	//ctx, _ := context.WithTimeout(m.Ctx, time.Millisecond*500)
+	//result := m.RedisClient.Get(ctx, field)
+	result, err := m.RedisClient.HGet(m.Ctx, terminal_key, field).Result()
+	if err != nil {
+		log.Printf("HGet error %s\n", err.Error())
+		return nil
+	}
+	return &result
+}
+func (m *TerminalManager) SetTerminal(uid uint64, value string) error {
+	field := strconv.FormatUint(uid, 10)
+	result, err := m.RedisClient.HSet(m.Ctx, terminal_key, field, value).Result()
+	if err != nil {
+		log.Printf("HSet error %s\n")
+	} else {
+		log.Printf("HSet %s:%s result: %d\n", terminal_key, field, result)
+	}
+	return err
+}
+func (m *TerminalManager) RemoveTerminal(uid uint64) error {
+	field := strconv.FormatUint(uid, 10)
+	result, err := m.RedisClient.HDel(m.Ctx, terminal_key, field).Result()
+	if err != nil {
+		log.Printf("HDel error: %s\n", err.Error())
+	} else {
+		log.Printf("HDel %s return %d\n", field, result)
+	}
+	return err
+}
+func (m *TerminalManager) GetAll() *map[string]string {
+	//ctx, _ := context.WithTimeout(m.Ctx, time.Millisecond*500)
+	//result := m.RedisClient.Get(ctx, field)
+	result, err := m.RedisClient.HGetAll(m.Ctx, terminal_key).Result()
+	if err != nil {
+		log.Printf("HGetAll error: %s\n", err.Error())
+		return nil
+	} else {
+		return &result
+	}
+}
--- a/manager/userManager.go
+++ b/manager/userManager.go
+package manager
+import (
+	"context"
+	"github.com/go-redis/redis/v8"
+	"log"
+	"strconv"
+)
+const (
+	user_key = "user"
+)
+type UserManager struct {
+	Ctx         context.Context
+	RedisClient *redis.Client
+}
+func (m *UserManager) GetUser(uid uint64) *string {
+	field := strconv.FormatUint(uid, 10)
+	//ctx, _ := context.WithTimeout(m.Ctx, time.Millisecond*500)
+	//result := m.RedisClient.Get(ctx, field)
+	result, err := m.RedisClient.HGet(m.Ctx, user_key, field).Result()
+	if err != nil {
+		log.Printf("HGet error %s\n", err.Error())
+		return nil
+	}
+	return &result
+}
+func (m *UserManager) AddUser(uid uint64, value string) error {
+	field := strconv.FormatUint(uid, 10)
+	result, err := m.RedisClient.HSet(m.Ctx, user_key, field, value).Result()
+	if err != nil {
+		log.Printf("HSet error %s\n")
+	} else {
+		log.Printf("HSet %s:%s result: %d\n", user_key, field, result)
+	}
+	return err
+}
+func (m *UserManager) RemoveUser(uid uint64) error {
+	field := strconv.FormatUint(uid, 10)
+	result, err := m.RedisClient.HDel(m.Ctx, user_key, field).Result()
+	if err != nil {
+		log.Printf("HDel error: %s\n", err.Error())
+	} else {
+		log.Printf("HDel %s return %d\n", field, result)
+	}
+	return err
+}
+func (m *UserManager) GetAll() *map[string]string {
+	//ctx, _ := context.WithTimeout(m.Ctx, time.Millisecond*500)
+	//result := m.RedisClient.Get(ctx, field)
+	result, err := m.RedisClient.HGetAll(m.Ctx, user_key).Result()
+	if err != nil {
+		log.Printf("HGetAll error: %s\n", err.Error())
+		return nil
+	} else {
+		return &result
+	}
+}
--- a/manager/userProxyManager.go
+++ b/manager/userProxyManager.go
+package manager
+import (
+	"context"
+	"google.golang.org/grpc"
+	"log"
+	"sync"
+	"time"
+)
+var UserProxyMgr = UserProxyManager{}
+type UserProxyManager struct {
+	mutex   sync.RWMutex
+	clients map[string]*grpc.ClientConn
+}
+func init() {
+	UserProxyMgr.clients = make(map[string]*grpc.ClientConn, 0)
+}
+// 创建Client连接，保存并返回
+func (m *UserProxyManager) MakeClient(addr string) *grpc.ClientConn {
+	conn := m.GetClient(addr)
+	if conn == nil {
+		ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
+		defer cancel()
+		c, err := grpc.DialContext(ctx, addr, grpc.WithInsecure(), grpc.WithBlock())
+		if err == nil {
+			if c == nil {
+				log.Printf("Failed in connecting to %s:\n", addr)
+			} else {
+				conn = c
+				m.SetClient(addr, conn)
+				log.Printf("Connection to %s established.\n", addr)
+			}
+		} else {
+			log.Printf("Failed to connect %s: %v\n", addr, err)
+		}
+	} else {
+		//log.Printf("Connection to %s already exists, state = %s\n", addr, conn.GetState().String())
+	}
+	return conn
+}
+func (m *UserProxyManager) GetClient(addr string) *grpc.ClientConn {
+	m.mutex.RLock()
+	defer m.mutex.RUnlock()
+	return m.clients[addr]
+}
+func (m *UserProxyManager) SetClient(addr string, c *grpc.ClientConn) {
+	m.mutex.Lock()
+	defer m.mutex.Unlock()
+	m.clients[addr] = c
+}
--- a/protocol/biz.proto
+++ b/protocol/biz.proto
+syntax = "proto3";
+package biz;
+option go_package = "protocol/biz";
+/* id = 1 */
+message BizMessage {
+  uint32 type = 2;
+  string payLoad = 3;
+}
+/* id = 2 */
+message BizMessageRsp {
+  uint32 status = 1;
+}
+service Transmitter {
+  rpc process(BizMessage) returns (BizMessageRsp) {}
+}
\ No newline at end of file
--- a/protocol/userCenter.proto
+++ b/protocol/userCenter.proto
+syntax = "proto3";
+package userCenter;
+option go_package = "protocol/userCenter";
+/* id = 1 */
+message RouteMessage {
+  uint64 uid = 1;
+  uint32 msgType = 2;
+  bytes payLoad = 3;
+}
+/* id = 2 */
+message RouteMessageRsp {
+  uint32 status = 1;
+}
+/* id = 3 */
+message LoginMessage {
+  string proxyAddr = 1; // userProxy的地址：ip:port
+  string token = 2;
+  string clientAddr = 3; // 客户端地址(websocket)：ip:port
+}
+/* id = 4 */
+message LoginMessageRsp {
+  uint32 status = 1;
+  uint64 uid = 2;
+}
+/* id = 5 */
+message LogoutMessage {
+  string clientAddr = 1; // 客户端地址(websocket)：ip:port
+  uint64 uid = 2;
+}
+/* id = 6 */
+message LogoutMessageRsp {
+  uint32 status = 1;
+}
+/* id = 7 */
+message MulticastMessage {
+  repeated uint64 uids = 1;
+  uint32 msgType = 2;
+  bytes payLoad = 3;
+}
+/* id = 8 */
+message MulticastMessageRsp {
+  repeated uint64 failedUids = 1;
+}
+/* id = 9 */
+message KickMessage {
+  uint64 uid = 1;
+  string addr = 2;
+}
+/* id = 10 */
+message KickMessageRsp {
+  uint32 status = 1;
+}
+/* id = 11 */
+message BroadcastMessage {
+  uint32 msgType = 2;
+  bytes payLoad = 3;
+}
+/* id = 12 */
+message BroadcastMessageRsp {
+  repeated uint64 failedUids = 1;
+}
+/* id = 13 */
+message BizMessage {
+  uint64 uid = 1;
+  uint32 msgType = 2;
+  string payLoad = 3;
+}
+/* id = 14 */
+message BizMessageRsp {
+  uint32 status = 1;
+}
+service Router {
+  rpc route(RouteMessage) returns (RouteMessageRsp) {}
+  rpc kickUser(KickMessage) returns (KickMessageRsp) {}
+}
+service User {
+  rpc login(LoginMessage) returns (LoginMessageRsp) {}
+  rpc logout(LogoutMessage) returns (LogoutMessageRsp) {}
+  rpc multicast(MulticastMessage) returns (MulticastMessageRsp) {}
+  rpc broadcast(BroadcastMessage) returns (BroadcastMessageRsp) {}
+  rpc transmit(BizMessage) returns (BizMessageRsp) {}
+}
\ No newline at end of file
--- a/protocol/userProxy.proto
+++ b/protocol/userProxy.proto
+syntax = "proto3";
+package userProxy;
+option go_package = "protocol/userProxy";
+/* user*/
+message User {
+    uint64 id = 1;
+    string externalId = 2;
+    string nick = 3;
+    string avatar = 4;
+    string country = 5;
+    string countryIcon = 6;
+    uint64 birthday = 7;
+    bool isVip = 8;
+    bool isLike = 9;
+    bool isLikeMe = 10;
+}
+/* Svip*/
+message Svip {
+    uint64 svipLevel = 1;
+    repeated SvipPrivilege privileges = 2;
+}
+message SvipPrivilege {
+    int32 type = 1;
+    bool canSwitch = 2;
+    bool userSwitch = 3;
+    string mysteryCode = 4;
+}
+/* id = 1 登录*/
+message Login {
+    string token = 1;
+}
+/* id = 2 登录的回应 */
+message LoginRsp {
+    uint32 status = 1;
+}
+/* id = 3 客户端心跳 */
+message HeartBeat {
+    string externalUid = 1;
+}
+/* id = 4 客户端心跳的回应 */
+message HeartBeatRsp {
+    uint32 status = 1;
+}
+/* id = 7 客户端上行消息 */
+message BizRequest {
+    uint32 type = 1;
+    string payLoad = 2;
+}
+/* id = 8 客户端上行消息的应答 */
+message BizResponse {
+    uint32 status = 1;
+}
+/* id == 100 | 140 匹配结果通知 waitDuration：开始/下一个时间 matchUniqueId：匹配一对的唯一标识码， status:是否是落单 singleWaitTimeInSec:单方等待连接最长时间 dualWaitTimeInSec:双方连接中最长时间*/
+message MatchSuccess {
+    string localUserId = 1;
+    string remoteUserId = 2;
+    uint32 waitDuration = 3;
+    string matchUniqueId = 4;
+    bool status = 5;
+    uint32 singleWaitTimeInSec = 6;
+    uint32 dualWaitTimeInSec = 7;
+    User remoteUser = 8;
+}
+/* id == 101 匹配后用户选择结果通知, failType: 只有status=2 才有值，其它为0，failType=1:等待时间到了，拒绝 failType=2:主动拒绝 */
+message MatchConfirm {
+    uint32 status = 1;
+    string channelId = 2;
+    string token = 3;
+    string localUserId = 4;
+    string remoteUserId = 5;
+    uint32 remoteAgoraId = 6;
+    uint32 callDuration = 7;
+    uint32 localAgoraId = 8;
+    uint32 diamondBalance = 9;
+    string matchUniqueId = 10;
+    uint32 failType = 11;
+}
+/* id == 102 视频通话准备 */
+message CallReady {
+    uint64 startTimestamp = 1;
+    uint64 endTimestamp = 2;
+    uint64 callDuration = 3;
+    string channelId = 4;
+    uint64 remainDiamond = 5;
+}
+/* id == 103 礼物加时 */
+message AddTimeGift {
+    uint32 giftId = 1;
+    string token = 2;
+    uint32 duration = 3;
+    uint64 endTimestamp = 4;
+    string channelId = 5;
+    bool isSender = 6;
+    uint32 giftNum = 7;
+    string iconUrl = 8;
+    string svgaUrl = 9;
+    string senderAvatar = 10;
+    string receiverAvatar = 11;
+}
+/* id == 104 免费加时 */
+message AddTimeFree {
+    string token = 1;
+    uint32 duration = 2;
+    uint64 endTimestamp = 3;
+    string channelId = 4;
+    uint32 senderAgoraId = 5;
+}
+/* id == 105 退出 */
+message ConnectsQuit {
+    uint64 from_user_id = 1;
+}
+/* id == 106 连接状态 */
+message ConnectStatus {
+    uint64 from_user_id = 1;
+    float user_diamonds = 2;
+    bool diamonds_enough = 3;
+}
+/* id == 107 ??? */
+message ConnectsCall {
+    uint64 from_user_id = 1;
+    string rong_room_name = 2;
+    bool is_join = 3;
+}
+/* id == 108 */
+message ConnectCommon {
+    string rong_room_name = 1;
+    uint64 from_user_id = 2;
+    string extra = 3;
+    string message = 4;
+}
+/* id == 109 召回授权弹框 */
+message RecallWindow {
+}
+/* id == 110 | 132 视频发送 status:(1:接收到邀请, 2:接收到对方同意, 3:双方拒绝（还没接通）, 4：对方挂断（接通后）diamondBalance 只有status=2,才出现)*/
+message Video {
+    string videoUniqueId = 1;
+    string channelId = 2;
+    uint32 localAgoraId = 3;
+    uint32 remoteAgoraId = 4;
+    string agoraToken = 5;
+    string sendUserId = 6;
+    string receiveUserId = 7;
+    uint32 status = 8;
+    uint32 diamondBalance = 9;
+    User sendUser = 10;
+}
+/* id == 111 视频通话准备 */
+message VideoCallReady {
+    uint64 startTimestamp = 1;
+    uint64 endTimestamp = 2;
+    uint64 callDuration = 3;
+    string channelId = 4;
+    uint64 remainDiamond = 5;
+}
+/* id == 112 互相喜欢 */
+message LikeEach {
+    string remoteUserId = 1;
+}
+/* id == 113 喜欢我 */
+message LikeMe {
+    string remoteUserId = 1;
+    string remoteNick = 2;
+    string channelId = 3;
+}
+/* id == 114 日常进入app，获取钻石 */
+message DailyInAppDiamond {
+    uint32 diamondNum = 1;
+}
+/* id == 115 横幅 */
+message GlobalGiftBanner {
+    uint32 bannerLevel = 1;
+    uint64 giftId = 2;
+    uint32 giftNum = 3;
+    string sendUserId = 4;
+    string receiveUserId = 5;
+    string groupId = 6;
+    string sendUserCode = 7;
+    string sendUserAvatar = 8;
+    string sendUserNick = 9;
+    string receiveUserNick = 10;
+    string giftPicUrl = 11;
+    Svip svip = 12;
+    Svip receiveSvip = 13;
+}
+/* id == 116 横幅的回应，用来测量RTT */
+message GlobalGiftBannerRsp {
+    uint32 bannerLevel = 1;
+    uint64 giftId = 2;
+    uint32 giftNum = 3;
+    string sendUserId = 4;
+    string receiveUserId = 5;
+    string groupId = 6;
+}
+/*id==117 幸运转盘通知,客户端重新拉取查询, type：客户端不用理*/
+message LuckyWheel {
+    string groupId = 1;
+    uint32 type = 2;
+}
+/* id == 118 幸运转盘获胜者全服广播 */
+message LuckyWheelBanner {
+    uint32 diamondNum = 1;
+    string sendUserId = 2;
+    string groupId = 3;
+    string nick = 4;
+    string code = 5;
+    string avatar = 6;
+    Svip svip = 7;
+}
+/* id == 119 幸运转盘钻石变化 */
+message LuckyWheelDiamondChange {
+    string groupId = 1;
+}
+/* id == 120 服务器配置变更 */
+message ConfigChange {
+    uint32 type = 1;
+}
+/* id == 121 全局火箭横幅 */
+message GlobalRocketNotice {
+    string groupId = 1;
+    string period = 2;
+    uint32 round = 3;
+    uint32 stage = 4;
+    string topUserIcon = 5;
+    string nick = 6;
+    string code = 7;
+    string avatar = 8;
+    Svip svip = 9;
+}
+/* id == 122 群发功能弹窗 */
+message GroupSendNotice {
+    string senderExtId = 1;
+    string senderCode = 2;
+    uint32 senderSex = 3;
+    string senderAvatar = 4;
+    string text = 5;
+    string groupName = 6;
+    string groupCode = 7;
+    string groupAvatar = 8;
+    uint32 userInNum = 9; // 最近进入房间的人数
+    string groupId = 10;
+}
+/* id == 123 全球消息 */
+message GlobalBroadcast {
+    string senderExtId = 1;
+    string senderCode = 2;
+    uint32 senderSex = 3;
+    string senderAvatar = 4;
+    string senderNick = 5;
+    string msg = 6;
+    string groupId = 7;
+    uint32 senderNobleLevel = 8;
+}
+/* id == 124 全球消息 */
+message MicTaskFinish {
+    string userId = 1;
+    uint32 diamond = 2;
+}
+/* id == 125 水果机开奖通知 */
+message FruitMachine {
+    string date = 1;
+    uint32 round = 2;
+}
+/* id == 126 贵族变化 */
+message NobleChange {
+}
+/* id == 127 加入群组成功 */
+message JoinGroup {
+    string groupId = 1;
+    string externalId = 2;
+}
+/* id == 128 1对1视频1分钟加时成功 */
+message VideoTimeMinuteSuccess {
+    string token = 1;
+    uint32 duration = 2;
+    uint64 endTimestamp = 3;
+    string channelId = 4;
+    uint32 senderAgoraId = 5;
+    string videoUniqueId = 6;
+    bool isSend = 7;
+    uint32 sendRemainDiamond = 8;
+}
+/* id == 129 1对1视频1分钟加时询问检查 */
+message VideoTimeMinuteCheck {
+    string videoUniqueId = 1;
+    uint32 diamond = 2;
+    string uuid = 3;
+}
+/* id == 130 1对1视频，错过 */
+message VideoMiss {
+    uint32 totalNum = 1;
+}
+/* id == 131 进房，群组活动信息 */
+message GroupActivity {
+    string ActivityId = 1;// id
+    uint64 StartAt = 2;   // 开始时间戳，东八区时间戳
+    uint64 EndAt = 3;     // 结束时间戳，东八区时间戳
+    string Banner = 4;    // banner url
+    int32 AcType = 5;     // 类型1.游戏2.比赛3.排队4.诗歌
+    string Theme = 6;     // 活动主题
+    int32 PersonNum = 7;  // 订阅人数
+    bool IsSubscribe = 8; // 我是否订阅该活动
+    string GroupId = 9;   // 群id
+}
+/* id == 144 邀请用户成为房间会员 */
+message RoomInviteMember {
+    string group_id = 1;
+}
\ No newline at end of file
--- a/release.ini
+++ b/release.ini
+[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