refactor♻️:redis对象和mysql对象持久化和读取

王家文
1 parent 4c5f3412
Showing 44 changed files with 780 additions and 948 deletions Show diff stats
README.md
common/svconst/consts.go
common/svconst/vars.go
common/svdto/dto.go
common/svdto/init.go
common/svdto/interface.go
common/svdto/record.go
common/svlog/ali-log.go
common/svlog/log.go
common/svmysql/index.go
common/svmysql/interface.go
common/svredis/index.go
common/svredis/interface.go
common/thinkingdata/index.go
configs/feat-api.go
configs/feat-cardholder.go
configs/index.go
configs/registry.go
controllers/base.go
main.go
 ## 项目目录结构
-| 项目目录        | 目录说明     |
-|-------------|----------|
-| conf        | beego配置  |
-| controllers | 控制器      |
-| dto         | 数据库存储对象  |
-| models      | 与客户端传输对象 |
-| routers     | 路由       |
-| sdk         | SDK      |
-| service     | 游戏服务器逻辑  |
-| sign        | 签名       |
-| util        | 公共库      |
-| util-lx     | 公共库(李旭)  |
+| 项目目录           | 目录说明     |
+|----------------|----------|
+| conf           | beego配置  |
+| configs        | 游戏配置处理   |
+| controllers    | 控制器      |
+| middleware     | 中间件      |
+| models         | 与客户端传输对象 |
+| routers        | 路由       |
+| service-common | 服务器公共模块  |
+| service        | 游戏服务器逻辑  |
+| util           | 公共库      |
+| util-lx        | 公共库(李旭)  |
 ## 游戏和游戏功能列表
-| 功能模块名         | 所属功能 | 负责人 |
-|---------------|------|-----|
+| 功能模块名      | 所属功能 | 负责人 |
+|------------|------|-----|
 | cardholder | 卡包卡牌 | 王家文 |
@@ -1 +0,0 @@
-package svconst
@@ -1,13 +0,0 @@
-package svconst
-
-import "gorm.io/gorm"
-
-var (
-	AppName = ""
-
-	DbApi    *gorm.DB
-	DbCommon *gorm.DB
-	DbConfig *gorm.DB
-
-	GameListCardHolder = []string{"10149"}
-)
@@ -1,68 +0,0 @@
-package svdto
-
-import (
-	"apigame/util/utdto"
-	"apigame/util/util-lx/lxalilog"
-)
-
-func InitTable(tb IDtoData, gameId string) {
-	rule := tb.GetRule(gameId)
-	utdto.InitTable(rule.DbMysql, tb, rule.TableName)
-}
-
-func Insert(data IDtoData, gameId string) (err error) {
-	rule := data.GetRule(gameId)
-	result := utdto.Insert(rule.DbMysql, data, rule.TableName)
-	err = result.Error
-	if err != nil {
-		lxalilog.Errors(err, gameId)
-		return
-	}
-	return
-}
-
-func Update(data IDtoData, gameId string) (err error) {
-	rule := data.GetRule(gameId)
-	result := utdto.Update(rule.DbMysql, data, rule.TableName)
-	err = result.Error
-	if err != nil {
-		lxalilog.Errors(err, gameId)
-		return
-	}
-	return
-}
-
-func Save(data IDtoData, gameId string) (err error) {
-	rule := data.GetRule(gameId)
-	result := utdto.Save(rule.DbMysql, data, rule.TableName)
-	err = result.Error
-	if err != nil {
-		lxalilog.Errors(err, gameId)
-		return
-	}
-	return
-}
-
-func First(data IDtoData, gameId string) (has bool, err error) {
-	rule := data.GetRule(gameId)
-	result := utdto.First(rule.DbMysql, data, rule.TableName)
-	has = result.RowsAffected != 0
-	err = result.Error
-	if err != nil {
-		lxalilog.Errors(err, gameId)
-		return
-	}
-	return
-}
-
-func Find(data any, dataTemp IDtoData, gameId string) (has bool, err error) {
-	rule := dataTemp.GetRule(gameId)
-	result := utdto.Find(rule.DbMysql, data, rule.TableName)
-	has = result.RowsAffected != 0
-	err = result.Error
-	if err != nil {
-		lxalilog.Errors(err, rule.TableName)
-		return
-	}
-	return
-}
@@ -1,2 +0,0 @@
-package svdto
-
@@ -1,23 +0,0 @@
-package svdto
-
-import "gorm.io/gorm"
-
-const (
-	REDIS_CACHEP_REFIX = "apigame" // 缓存前缀
-)
-
-// DtoRule dto参数
-type DtoRule struct {
-	DbMysql   *gorm.DB
-	TableName string
-	CacheKey  string
-	CacheTime int
-}
-
-// IDtoData dto数据
-type IDtoData interface {
-	// TableName 表名模板
-	TableName() string
-	// GetRule 表名模板
-	GetRule(gameId string) *DtoRule
-}
@@ -1,10 +0,0 @@
-package svdto
-
-import (
-	"apigame/util/utdto"
-)
-
-func SaveRecord(gameId string, data IDtoData) {
-	rule := data.GetRule(gameId)
-	utdto.Insert(rule.DbMysql, data, rule.TableName)
-}
@@ -1,40 +0,0 @@
-package svlog
-
-import (
-	"apigame/util/util-lx/lxalilog"
-	"fmt"
-	"github.com/astaxie/beego"
-	lalilog "github.com/lixu-any/go-tools/ali/log"
-)
-
-func InitAliLog(appName string) {
-
-	//初始化阿里云日志
-	logm, _ := beego.AppConfig.GetSection("alilog")
-	lxalilog.InitAliLog(lxalilog.MapAlilogConfig{
-		Endpoint:        logm["endpoint"],
-		AccessKeyId:     logm["accesskeyid"],
-		AccessKeySecret: logm["accesskeysecret"],
-		Project:         logm["project"],
-		AppNaame:        appName,
-		On:              logm["on"],
-		Debug:           logm["debug"],
-		TableError:      "api_code_merge",
-		TableDebug:      logm["tabledebug"],
-		Env:             beego.AppConfig.String("env"),
-	})
-
-	lalilog.InitAliLog(lalilog.MapAlilogConfig{
-		Endpoint:        logm["endpoint"],
-		AccessKeyId:     logm["accesskeyid"],
-		AccessKeySecret: logm["accesskeysecret"],
-		Project:         logm["project"],
-		On:              logm["on"],
-		Debug:           logm["debug"],
-		TableError:      logm["tableerror"],
-		TableDebug:      logm["tabledebug"],
-		Env:             beego.AppConfig.String("env"),
-	})
-
-	fmt.Println(appName + " alilog init success")
-}
@@ -1,22 +0,0 @@
-package svlog
-
-import (
-	"apigame/common/svconst"
-	"apigame/util/util-lx/lxbeego"
-	"fmt"
-	"github.com/astaxie/beego"
-)
-
-func Init() {
-
-	// 初始化日志文件
-	conf, _ := beego.AppConfig.GetSection("log")
-	conf["filename"] = conf["path"] + "api.log"
-
-	if err := lxbeego.Inits(conf); err != nil {
-		fmt.Println("svlog.Inits Error::" + err.Error())
-	}
-
-	fmt.Println(svconst.AppName + " svlog init success")
-
-}
@@ -1,119 +0,0 @@
-package svmysql
-
-import (
-	"apigame/common/svconst"
-	"apigame/service/constd"
-	"apigame/util/utdto"
-	"apigame/util/util-lx/lxalilog"
-	"fmt"
-	"github.com/astaxie/beego"
-	"gorm.io/gorm"
-	"strings"
-)
-
-func Init() bool {
-
-	// ConnectMySQL
-	if db, err := utdto.ConnectMySQL(beego.AppConfig.String("mysql::" + constd.MYSQL_DBAPI)); err == nil {
-		svconst.DbApi = db
-	} else {
-		fmt.Println("svmysql.Init DbApi Error::" + err.Error())
-		return false
-	}
-	if db, err := utdto.ConnectMySQL(beego.AppConfig.String("mysql::mergecommon")); err == nil {
-		svconst.DbCommon = db
-	} else {
-		fmt.Println("svmysql.Init DbCommon Error::" + err.Error())
-		return false
-	}
-	if db, err := utdto.ConnectMySQL(beego.AppConfig.String("mysql::" + constd.MYSQL_MERGECONFIG)); err == nil {
-		svconst.DbConfig = db
-	} else {
-		fmt.Println("svmysql.Init DbConfig Error::" + err.Error())
-		return false
-	}
-	return true
-
-}
-
-func InitTable(obj IMysqlData, gameId string) {
-	info := obj.MysqlInfo(gameId)
-	utdto.InitTable(info.DbMysql, obj, info.TableName)
-}
-
-func Insert(obj IMysqlData, gameId string) (err error) {
-	info := obj.MysqlInfo(gameId)
-	db := info.DbMysql
-	stmt := db.Session(&gorm.Session{DryRun: true}).Create(obj).Statement
-	stmtSQL := stmt.SQL.String()
-	sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
-	result := db.Exec(sql, stmt.Vars...)
-	err = result.Error
-	if err != nil {
-		lxalilog.Errors(err, gameId)
-		return
-	}
-	return
-}
-
-func Updates(obj IMysqlData, gameId string) (err error) {
-	info := obj.MysqlInfo(gameId)
-	db := info.DbMysql
-	stmt := db.Session(&gorm.Session{DryRun: true}).Updates(obj).Statement
-	stmtSQL := stmt.SQL.String()
-	sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
-	result := db.Exec(sql, stmt.Vars...)
-	err = result.Error
-	if err != nil {
-		lxalilog.Errors(err, gameId)
-		return
-	}
-	return
-}
-
-func Save(obj IMysqlData, gameId string) (err error) {
-	info := obj.MysqlInfo(gameId)
-	db := info.DbMysql
-	stmt := db.Session(&gorm.Session{DryRun: true}).Save(obj).Statement
-	stmtSQL := stmt.SQL.String()
-	sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
-	result := db.Exec(sql, stmt.Vars...)
-	err = result.Error
-	if err != nil {
-		lxalilog.Errors(err, gameId)
-		return
-	}
-	return
-}
-
-func First(obj IMysqlData, gameId string) (has bool, err error) {
-	info := obj.MysqlInfo(gameId)
-	db := info.DbMysql
-	stmt := db.Session(&gorm.Session{DryRun: true}).First(obj).Statement
-	stmtSQL := stmt.SQL.String()
-	sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
-	result := db.Raw(sql, stmt.Vars...).Scan(obj)
-	has = result.RowsAffected != 0
-	err = result.Error
-	if err != nil {
-		lxalilog.Errors(err, gameId)
-		return
-	}
-	return
-}
-
-func Find(obj IMysqlData, gameId string) (has bool, err error) {
-	info := obj.MysqlInfo(gameId)
-	db := info.DbMysql
-	stmt := db.Session(&gorm.Session{DryRun: true}).Find(obj).Statement
-	stmtSQL := stmt.SQL.String()
-	sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
-	result := db.Raw(sql, stmt.Vars...).Scan(obj)
-	has = result.RowsAffected != 0
-	err = result.Error
-	if err != nil {
-		lxalilog.Errors(err, gameId)
-		return
-	}
-	return
-}
@@ -1,15 +0,0 @@
-package svmysql
-
-import "gorm.io/gorm"
-
-// MysqlInfo mysql存储信息
-type MysqlInfo struct {
-	DbMysql   *gorm.DB
-	TableName string
-}
-
-// IMysqlData mysql存储对象
-type IMysqlData interface {
-	// MysqlInfo mysql存储信息
-	MysqlInfo(gameId string) *MysqlInfo
-}
@@ -1,58 +0,0 @@
-package svredis
-
-import (
-	"apigame/common/svconst"
-	"apigame/util/utstring"
-	"apigame/util/zjson"
-	"apigame/util/zredis"
-	"fmt"
-	"github.com/astaxie/beego"
-	"github.com/mitchellh/mapstructure"
-)
-
-type RedisConfig struct {
-	Host   string `json:"host"`
-	Port   string `json:"port"`
-	Pwd    string `json:"pwd"`
-	Db     string `json:"Db"`
-	Prefix string `json:"prefix"`
-}
-
-func Init() bool {
-	//初始化Redis
-	confText, _ := beego.AppConfig.GetSection("redis")
-	var conf RedisConfig
-	err := mapstructure.Decode(confText, &conf)
-	if err != nil {
-		fmt.Println("svredis.Init mapstructure.Decode Error::" + err.Error())
-	}
-	zredis.Init(conf.Host+":"+conf.Port, conf.Pwd, utstring.StringToInt(conf.Db))
-	if !zredis.Check() {
-		return false
-	}
-
-	fmt.Println(svconst.AppName + " redis init success")
-	return true
-}
-
-func SaveData(gameId string, obj IRedisData) {
-	info := obj.RedisInfo(gameId)
-	_ = zredis.SetEx(zredis.GetConn(), info.CacheKey, zjson.Str(obj), info.CacheTime)
-}
-
-func LoadData[T IRedisData](gameId string, obj T) (has bool) {
-	has = true
-	info := obj.RedisInfo(gameId)
-	text, err := zredis.Get(zredis.GetConn(), info.CacheKey)
-	if err != nil {
-		has = false
-		return
-	}
-	err = zjson.Obj(text, &obj)
-	if err != nil {
-		fmt.Println(err)
-		has = false
-		return
-	}
-	return
-}
@@ -1,13 +0,0 @@
-package svredis
-
-// RedisInfo redis存储信息
-type RedisInfo struct {
-	CacheKey  string
-	CacheTime int
-}
-
-// IRedisData redis存储对象
-type IRedisData interface {
-	// RedisInfo redis存储信息
-	RedisInfo(gameId string) *RedisInfo
-}
@@ -1,119 +0,0 @@
-package thinkingdata
-
-import (
-	"crypto/tls"
-	"encoding/json"
-	"errors"
-	"fmt"
-	"gitee.com/lxgow/lxconv"
-	"github.com/astaxie/beego"
-	"github.com/astaxie/beego/httplib"
-	lconv "github.com/lixu-any/go-tools/conv"
-	"time"
-)
-
-// index
-// 创建时间:2023/10/23 10:06
-// 创建人:lixu
-
-// index 数数科技
-// 创建时间:2023/7/18 16:03
-// 创建人:lixu
-
-// GetNowDateTime 当前日期时间
-func GetNowDateTime() string {
-	tim := time.Unix(time.Now().Unix(), 0).Format("2006-01-02 15:04:05")
-	return fmt.Sprintf("%s", tim)
-}
-
-type MThinkDataConfig struct {
-	Url   string `json:"url"`
-	Debug int    `json:"debug"`
-}
-
-type MRespData struct {
-	Msg  string `json:"Msg"`
-	Code int    `json:"code"`
-}
-
-var THINKINGDATACONFIG MThinkDataConfig
-
-// InitThinkData 初始化数数
-func InitThinkData() (err error) {
-	thinkingdata, _ := beego.AppConfig.GetSection("thinkingdata")
-	THINKINGDATACONFIG.Url = thinkingdata["url"]
-	THINKINGDATACONFIG.Debug = lxconv.ParseInt(thinkingdata["debug"])
-	return
-}
-
-// AddOneData 数据上报
-func AddOneData(appid, account_id, distinct_id string, event string, data map[string]interface{}, typ string) (resp MRespData, err error) {
-
-	_data := map[string]interface{}{
-		"#type": typ,
-		//"#event_name":  event,
-		"#time":        GetNowDateTime(),
-		"#account_id":  account_id,
-		"#distinct_id": distinct_id,
-		"properties":   data,
-	}
-
-	if typ == "track" && event != "" {
-		_data["#event_name"] = event
-	}
-
-	postdata := map[string]interface{}{
-		"appid": appid,
-		"debug": THINKINGDATACONFIG.Debug,
-		"data":  _data,
-	}
-
-	req := httplib.Post(THINKINGDATACONFIG.Url + "/sync_json")
-
-	req.SetTLSClientConfig(&tls.Config{InsecureSkipVerify: true})
-
-	_, err = req.JSONBody(&postdata)
-	if err != nil {
-		err = errors.New("thinkingdata-AddOneData  req.JSONBody() error::" + err.Error() + "::" + lconv.JsonEncode(postdata))
-		return
-	}
-
-	var (
-		bytes []byte
-	)
-
-	bytes, err = req.Bytes()
-	if err != nil {
-		err = errors.New("thinkingdata-AddOneData  req.Bytes() error::" + err.Error() + "::" + lconv.JsonEncode(postdata) + "::" + string(bytes))
-		return
-	}
-
-	_ = json.Unmarshal(bytes, &resp)
-
-	if resp.Code != 0 {
-		err = errors.New("thinkingdata-AddOneData  resp.Code error:: " + lconv.JsonEncode(postdata) + "::" + string(bytes))
-		return
-	}
-
-	return
-}
-
-// TrackOne 向事件表传入一个事件
-func TrackOne(appid, account_id string, event string, data map[string]interface{}) (resp MRespData, err error) {
-	return AddOneData(appid, account_id, "", event, data, "track")
-}
-
-// UserSet 对用户表进行操作，覆盖一个或多个用户属性，如果该属性已有值存在，覆盖先前值
-func UserSet(appid, account_id string, data map[string]interface{}) (resp MRespData, err error) {
-	return AddOneData(appid, account_id, "", "", data, "user_set")
-}
-
-// UserSetOnce 对用户表进行操作，初始化一个或多个用户属性，如果该属性已有值存在，则忽略本次操作
-func UserSetOnce(appid, account_id string, data map[string]interface{}) (resp MRespData, err error) {
-	return AddOneData(appid, account_id, "", "", data, "user_setOnce")
-}
-
-// UserAdd 对用户表进行操作，为一个或多个数值型用户属性做累加计算
-func UserAdd(appid, account_id string, data map[string]interface{}) (resp MRespData, err error) {
-	return AddOneData(appid, account_id, "", "", data, "user_add")
-}
 package configs
 import (
-	"apigame/common/svconst"
-	"apigame/common/svdto"
-	"apigame/common/svmysql"
-	"apigame/common/svredis"
+	"apigame/service-common/svconst"
+	"apigame/service-common/svmysql"
+	"apigame/service-common/svredis"
 	"fmt"
 )
@@ -20,7 +19,7 @@ type ApiGameConfig struct {
 func (c *ApiGameConfig) RedisInfo(gameId string) *svredis.RedisInfo {
 	tableName := "s_game_config"
 	return &svredis.RedisInfo{
-		CacheKey:  fmt.Sprintf("%s:%s:%s", svdto.REDIS_CACHEP_REFIX, tableName, gameId),
+		CacheKey:  fmt.Sprintf("%s:%s:%s", svconst.REDIS_CACHEP_REFIX, tableName, gameId),
 		CacheTime: 300,
 	}
 }
 package configs
 import (
-	"apigame/common/svconst"
-	"apigame/common/svdto"
-	"apigame/common/svmysql"
-	"apigame/common/svredis"
-	"apigame/service/constd"
+	"apigame/service-common/svconst"
+	"apigame/service-common/svmysql"
+	"apigame/service-common/svredis"
 	"fmt"
 )
@@ -33,9 +31,9 @@ type CardActivityConfig struct {
 }
 func (c *CardActivityConfig) RedisInfo(gameId string) *svredis.RedisInfo {
-	tableName := constd.MYSQL_TABLE_S_CARDHOLDER_CONFIG
+	tableName := svconst.MYSQL_TABLE_S_CARDHOLDER_CONFIG
 	return &svredis.RedisInfo{
-		CacheKey:  fmt.Sprintf("%s:%s:%s", svdto.REDIS_CACHEP_REFIX, tableName, gameId),
+		CacheKey:  fmt.Sprintf("%s:%s:%s", svconst.REDIS_CACHEP_REFIX, tableName, gameId),
 		CacheTime: 300,
 	}
 }
@@ -61,7 +59,7 @@ type CardActivityConfigRaw struct {
 }
 func (c *CardActivityConfigRaw) MysqlInfo(gameId string) *svmysql.MysqlInfo {
-	tableName := constd.MYSQL_TABLE_S_CARDHOLDER_CONFIG
+	tableName := svconst.MYSQL_TABLE_S_CARDHOLDER_CONFIG
 	return &svmysql.MysqlInfo{
 		DbMysql:   svconst.DbConfig.Where("status = ?", 1),
 		TableName: tableName + gameId,
@@ -1,14 +0,0 @@
-package configs
-
-import (
-	"apigame/common/svdto"
-)
-
-//	func GetConfigRedis[T svconfig.IDtoData](gameId string) (result *T, has bool) {
-//		t = new(T)
-//		var rule = t.GetRule(gameId)
-//		return
-//	}
-func GetConfigMysql[T svdto.IDtoData](gameId string, t T) (result *T, has bool) {
-	return
-}
 package configs
 import (
-	"apigame/common/svmysql"
-	"apigame/common/svredis"
+	"apigame/service-common/svmysql"
+	"apigame/service-common/svredis"
 	"fmt"
 )
@@ -2,7 +2,7 @@ package controllers
 import (
 	"apigame/middleware/sign"
-	"apigame/service/constd"
+	"apigame/service/code-msg"
 	"encoding/json"
 	"github.com/astaxie/beego"
 )
@@ -27,7 +27,7 @@ func (c *BaseController) RetRspData(rspData any) {
 // RetRspCodeData 返回封装
 func (c *BaseController) RetRspCodeData(code string, rspData any) {
 	resp := make(map[string]any)
-	resp = constd.CodeMsg(resp, code)
+	resp = code_msg.CodeMsg(resp, code)
 	resp["data"] = rspData
 	c.RetData(resp)
 }
@@ -35,7 +35,7 @@ func (c *BaseController) RetRspCodeData(code string, rspData any) {
 // RetCode 返回错误封装
 func (c *BaseController) RetCode(code string) {
 	resp := make(map[string]any)
-	resp = constd.CodeMsg(resp, code)
+	resp = code_msg.CodeMsg(resp, code)
 	c.RetData(resp)
 }
@@ -48,7 +48,7 @@ func (c *BaseController) GetPostData(postData any) bool {
 	if checkLocal() {
 		err := json.Unmarshal(req, &postData)
 		if err != nil {
-			c.RetCode(constd.RECODE_PARAMERROR)
+			c.RetCode(code_msg.RECODE_PARAMERROR)
 			return false
 		}
 		return true
@@ -58,7 +58,7 @@ func (c *BaseController) GetPostData(postData any) bool {
 	code, err := sign.Check(req, &postData, true, true)
 	if err != nil {
 		resp := make(map[string]interface{})
-		resp = constd.CodeMsg(resp, code)
+		resp = code_msg.CodeMsg(resp, code)
 		c.RetData(resp)
 		return false
 	}
 package main
 import (
-	"apigame/common/svconst"
-	"apigame/common/svlog"
-	"apigame/common/svmysql"
-	"apigame/common/svredis"
 	"apigame/configs"
 	_ "apigame/routers"
+	"apigame/service-common/svconst"
+	"apigame/service-common/svlog"
+	"apigame/service-common/svmysql"
+	"apigame/service-common/svredis"
 	"apigame/service/cardholder"
 	"github.com/astaxie/beego"
 	"github.com/astaxie/beego/logs"
@@ -3,7 +3,7 @@ package sign
 import (
 	"apigame/configs"
 	"apigame/middleware/sdk"
-	"apigame/service/constd"
+	"apigame/service/code-msg"
 	"apigame/util/util-lx/lxalilog"
 	"apigame/util/util-lx/lxarray"
 	"apigame/util/util-lx/lxconv"
@@ -77,7 +77,7 @@ func InitCheck(postdata interface{}, cgg MCheckConfig) (code string, gameconfig 
 	time_stamp = getTimeStamp(tempData["time_stamp"])
 	if time_stamp < (nowtime-JG) || time_stamp > (nowtime+JG) {
-		code = constd.RECODE_REQUESTTIME_ERROR
+		code = code_msg.RECODE_REQUESTTIME_ERROR
 		err = errors.New(code)
 		lxalilog.Errors("RECODE_REQUESTTIME_ERROR error:", string(cgg.Bodys))
 		return
@@ -100,7 +100,7 @@ func InitCheck(postdata interface{}, cgg MCheckConfig) (code string, gameconfig 
 	}
 	if cgg.CheckUrlGameID && urlGameId == "" {
-		code = constd.RECODE_PARAMERROR
+		code = code_msg.RECODE_PARAMERROR
 		err = errors.New(code)
 		lxalilog.Errors("urlGameid error:")
 		return
@@ -109,21 +109,21 @@ func InitCheck(postdata interface{}, cgg MCheckConfig) (code string, gameconfig 
 	postGameId, ty = lxlimit.CheckLimit(c)
 	if cgg.CheckUrlGameID && postGameId != urlGameId {
-		code = constd.RECODE_PARAMERROR
+		code = code_msg.RECODE_PARAMERROR
 		err = errors.New(code)
 		lxalilog.Errors("urlGameid !=postGameId:", urlGameId, postdata)
 		return
 	}
 	if ty != "" {
-		code = constd.RECODE_REQUESTXIANLIU_ERROR
+		code = code_msg.RECODE_REQUESTXIANLIU_ERROR
 		err = errors.New(ty)
 		return
 	}
 	err = json.Unmarshal(cgg.Bodys, &postdata)
 	if err != nil {
-		code = constd.RECODE_PARAMERROR
+		code = code_msg.RECODE_PARAMERROR
 		lxalilog.Errors("json.Unmarshal error:", err, string(cgg.Bodys))
 		return
 	}
@@ -134,13 +134,13 @@ func InitCheck(postdata interface{}, cgg MCheckConfig) (code string, gameconfig 
 	b, err = valid.Valid(postdata)
 	if err != nil {
-		code = constd.RECODE_PARAMERROR
+		code = code_msg.RECODE_PARAMERROR
 		lxalilog.Errors("valid.Valid error:", err, string(cgg.Bodys), valid.Errors)
 		return
 	}
 	if !b {
-		code = constd.RECODE_PARAMERROR
+		code = code_msg.RECODE_PARAMERROR
 		err = errors.New(code)
 		lxalilog.Errors("valid.Valid error:", err, string(cgg.Bodys), valid.Errors)
 		return
@@ -161,7 +161,7 @@ func Check(req []byte, postdata interface{}, checkSign bool, checkToken bool) (c
 	err = json.Unmarshal(req, &postdata)
 	if err != nil {
-		code = constd.RECODE_PARAMERROR
+		code = code_msg.RECODE_PARAMERROR
 		lxalilog.Errors("json.Unmarshal error:", err, string(req))
 		return
 	}
@@ -172,13 +172,13 @@ func Check(req []byte, postdata interface{}, checkSign bool, checkToken bool) (c
 	b, err = valid.Valid(postdata)
 	if err != nil {
-		code = constd.RECODE_PARAMERROR
+		code = code_msg.RECODE_PARAMERROR
 		lxalilog.Errors("valid.Valid error:", err, string(req), valid.Errors)
 		return
 	}
 	if !b {
-		code = constd.RECODE_PARAMERROR
+		code = code_msg.RECODE_PARAMERROR
 		err = errors.New(code)
 		lxalilog.Errors("valid.Valid error:", err, string(req), valid.Errors)
 		return
@@ -209,13 +209,13 @@ func CheckSign(data interface{}, checkToken bool) (code string, gameconfig *conf
 	err = json.Unmarshal(jsonBody, &newdata)
 	if err != nil {
-		code = constd.RECODE_SIGNERROR
+		code = code_msg.RECODE_SIGNERROR
 		lxalilog.Errors("json.Unmarshal error:", err)
 		return
 	}
 	if newdata["gameid"] == "" || newdata["channel"] == "" || newdata["sign"] == "" || newdata["sign_type"] == "" || newdata["time_stamp"] == "" || newdata["ver"] == "" {
-		code = constd.RECODE_SIGNERROR
+		code = code_msg.RECODE_SIGNERROR
 		err = errors.New("签名错误,参数错误" + logstr)
 		lxalilog.Errors(err)
 		return
@@ -236,7 +236,7 @@ func CheckSign(data interface{}, checkToken bool) (code string, gameconfig *conf
 	appkey := gameconfig.AppKey
 	if appkey == "" {
-		code = constd.RECODE_SIGNERROR
+		code = code_msg.RECODE_SIGNERROR
 		err = errors.New("签名错误,参数错误" + gameid + "no appkey")
 		lxalilog.Errors(err)
 		return
@@ -262,7 +262,7 @@ func CheckSign(data interface{}, checkToken bool) (code string, gameconfig *conf
 	}
 	if len(fiterkey) > 0 {
-		code = constd.RECODE_WEIXINAZIFU_ERROR
+		code = code_msg.RECODE_WEIXINAZIFU_ERROR
 		err = errors.New("fiterkey error" + logstr)
 		lxalilog.Errors(err, lxconv.JsonEncode(fiterkey), "data:", lxconv.JsonEncode(newdata))
 		return
@@ -282,7 +282,7 @@ func CheckSign(data interface{}, checkToken bool) (code string, gameconfig *conf
 	md5key := strings.ToLower(lxconv.EncryMD5(valstr))
 	if md5key != sign {
-		code = constd.RECODE_SIGNERROR
+		code = code_msg.RECODE_SIGNERROR
 		err = errors.New(code)
 		lxalilog.Errors("sign error,md5key::", md5key, ",sign:", sign, logstr, "data:", lxconv.JsonEncode(newdata))
 		return
@@ -291,7 +291,7 @@ func CheckSign(data interface{}, checkToken bool) (code string, gameconfig *conf
 	if checkToken {
 		if newdata["uid"] == nil || newdata["token"] == nil {
-			code = constd.RECODE_PARAMERROR
+			code = code_msg.RECODE_PARAMERROR
 			err = errors.New(code)
 			lxalilog.Errors("no uid or token", "data:", lxconv.JsonEncode(newdata))
 			return
@@ -299,7 +299,7 @@ func CheckSign(data interface{}, checkToken bool) (code string, gameconfig *conf
 		err = sdk.CheckSdkToken(gameid, lxconv.ToInt64(newdata["uid"]), lxconv.InterfaceToStr(newdata["token"]))
 		if err != nil {
-			code = constd.RECODE_LOGINCHECK_ERROR
+			code = code_msg.RECODE_LOGINCHECK_ERROR
 			return
 		}
@@ -0,0 +1,5 @@
+package svconst
+
+const (
+	REDIS_CACHEP_REFIX = "apigame" // 缓存前缀
+)
@@ -0,0 +1,21 @@
+package svconst
+
+// mysql
+// 创建时间:2023/4/3 15:28
+// 创建人:lixu
+
+const (
+	MYSQL_DEFAULT                = "default"
+	MYSQL_DBAPI                  = "api"
+	MYSQL_MERGECOMMON            = "merge_common"
+	MYSQL_MERGECONFIG            = "merge_config"
+	MYSQL_DEFAULT_QUERY_MAXCOUNT = 100
+
+	MYSQL_TABLE_S_CARDHOLDER_CONFIG             = "s_card_activity_"                 // 开卡包活动配置
+	MYSQL_TABLE_S_CARDHOLDER_DATA               = "s_cardholder_data_"               // 开卡包活动数据
+	MYSQL_TABLE_S_CARDHOLDER_RECORD_GETNEW      = "s_cardholder_record_getnew_"      // 开卡包活动日志获得卡包
+	MYSQL_TABLE_S_CARDHOLDER_RECORD_OPEN        = "s_cardholder_record_open_"        // 开卡包活动日志开卡包
+	MYSQL_TABLE_S_CARDHOLDER_RECORD_REWARDALBUM = "s_cardholder_record_rewardalbum_" // 开卡包活动日志领取卡组奖励
+	MYSQL_TABLE_S_CARDHOLDER_RECORD_REWARDROUND = "s_cardholder_record_rewardround_" // 开卡包活动日志领取轮次奖励
+
+)
@@ -0,0 +1,13 @@
+package svconst
+
+import "gorm.io/gorm"
+
+var (
+	AppName = ""
+
+	DbApi    *gorm.DB
+	DbCommon *gorm.DB
+	DbConfig *gorm.DB
+
+	GameListCardHolder = []string{"10149"}
+)
@@ -0,0 +1,40 @@
+package svlog
+
+import (
+	"apigame/util/util-lx/lxalilog"
+	"fmt"
+	"github.com/astaxie/beego"
+	lalilog "github.com/lixu-any/go-tools/ali/log"
+)
+
+func InitAliLog(appName string) {
+
+	//初始化阿里云日志
+	logm, _ := beego.AppConfig.GetSection("alilog")
+	lxalilog.InitAliLog(lxalilog.MapAlilogConfig{
+		Endpoint:        logm["endpoint"],
+		AccessKeyId:     logm["accesskeyid"],
+		AccessKeySecret: logm["accesskeysecret"],
+		Project:         logm["project"],
+		AppNaame:        appName,
+		On:              logm["on"],
+		Debug:           logm["debug"],
+		TableError:      "api_code_merge",
+		TableDebug:      logm["tabledebug"],
+		Env:             beego.AppConfig.String("env"),
+	})
+
+	lalilog.InitAliLog(lalilog.MapAlilogConfig{
+		Endpoint:        logm["endpoint"],
+		AccessKeyId:     logm["accesskeyid"],
+		AccessKeySecret: logm["accesskeysecret"],
+		Project:         logm["project"],
+		On:              logm["on"],
+		Debug:           logm["debug"],
+		TableError:      logm["tableerror"],
+		TableDebug:      logm["tabledebug"],
+		Env:             beego.AppConfig.String("env"),
+	})
+
+	fmt.Println(appName + " alilog init success")
+}
@@ -0,0 +1,22 @@
+package svlog
+
+import (
+	"apigame/service-common/svconst"
+	"apigame/util/util-lx/lxbeego"
+	"fmt"
+	"github.com/astaxie/beego"
+)
+
+func Init() {
+
+	// 初始化日志文件
+	conf, _ := beego.AppConfig.GetSection("log")
+	conf["filename"] = conf["path"] + "api.log"
+
+	if err := lxbeego.Inits(conf); err != nil {
+		fmt.Println("svlog.Inits Error::" + err.Error())
+	}
+
+	fmt.Println(svconst.AppName + " svlog init success")
+
+}
@@ -0,0 +1,84 @@
+package svmysql
+
+import (
+	"apigame/util/util-lx/lxalilog"
+	"gorm.io/gorm"
+	"strings"
+)
+
+func Insert(obj IMysqlData, gameId string) (err error) {
+	info := obj.MysqlInfo(gameId)
+	db := info.DbMysql
+	stmt := db.Session(&gorm.Session{DryRun: true}).Create(obj).Statement
+	stmtSQL := stmt.SQL.String()
+	sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
+	result := db.Exec(sql, stmt.Vars...)
+	err = result.Error
+	if err != nil {
+		lxalilog.Errors(err, gameId)
+		return
+	}
+	return
+}
+
+func Updates(obj IMysqlData, gameId string) (err error) {
+	info := obj.MysqlInfo(gameId)
+	db := info.DbMysql
+	stmt := db.Session(&gorm.Session{DryRun: true}).Updates(obj).Statement
+	stmtSQL := stmt.SQL.String()
+	sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
+	result := db.Exec(sql, stmt.Vars...)
+	err = result.Error
+	if err != nil {
+		lxalilog.Errors(err, gameId)
+		return
+	}
+	return
+}
+
+func Save(obj IMysqlData, gameId string) (err error) {
+	info := obj.MysqlInfo(gameId)
+	db := info.DbMysql
+	stmt := db.Session(&gorm.Session{DryRun: true}).Save(obj).Statement
+	stmtSQL := stmt.SQL.String()
+	sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
+	result := db.Exec(sql, stmt.Vars...)
+	err = result.Error
+	if err != nil {
+		lxalilog.Errors(err, gameId)
+		return
+	}
+	return
+}
+
+func First(obj IMysqlData, gameId string) (has bool, err error) {
+	info := obj.MysqlInfo(gameId)
+	db := info.DbMysql
+	stmt := db.Session(&gorm.Session{DryRun: true}).First(obj).Statement
+	stmtSQL := stmt.SQL.String()
+	sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
+	result := db.Raw(sql, stmt.Vars...).Scan(obj)
+	has = result.RowsAffected != 0
+	err = result.Error
+	if err != nil {
+		lxalilog.Errors(err, gameId)
+		return
+	}
+	return
+}
+
+func Find(obj IMysqlData, gameId string) (has bool, err error) {
+	info := obj.MysqlInfo(gameId)
+	db := info.DbMysql
+	stmt := db.Session(&gorm.Session{DryRun: true}).Find(obj).Statement
+	stmtSQL := stmt.SQL.String()
+	sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
+	result := db.Raw(sql, stmt.Vars...).Scan(obj)
+	has = result.RowsAffected != 0
+	err = result.Error
+	if err != nil {
+		lxalilog.Errors(err, gameId)
+		return
+	}
+	return
+}
@@ -0,0 +1,38 @@
+package svmysql
+
+import (
+	"apigame/service-common/svconst"
+	"fmt"
+	"github.com/astaxie/beego"
+	"gorm.io/driver/mysql"
+	"gorm.io/gorm"
+)
+
+func Init() bool {
+
+	// ConnectMySQL
+	if db, err := ConnectMySQL(beego.AppConfig.String("mysql::" + svconst.MYSQL_DBAPI)); err == nil {
+		svconst.DbApi = db
+	} else {
+		fmt.Println("svmysql.Init DbApi Error::" + err.Error())
+		return false
+	}
+	if db, err := ConnectMySQL(beego.AppConfig.String("mysql::mergecommon")); err == nil {
+		svconst.DbCommon = db
+	} else {
+		fmt.Println("svmysql.Init DbCommon Error::" + err.Error())
+		return false
+	}
+	if db, err := ConnectMySQL(beego.AppConfig.String("mysql::" + svconst.MYSQL_MERGECONFIG)); err == nil {
+		svconst.DbConfig = db
+	} else {
+		fmt.Println("svmysql.Init DbConfig Error::" + err.Error())
+		return false
+	}
+	return true
+
+}
+
+func ConnectMySQL(dsn string) (db *gorm.DB, err error) {
+	return gorm.Open(mysql.Open(dsn), &gorm.Config{})
+}
@@ -0,0 +1,15 @@
+package svmysql
+
+import "gorm.io/gorm"
+
+// MysqlInfo mysql存储信息
+type MysqlInfo struct {
+	DbMysql   *gorm.DB
+	TableName string
+}
+
+// IMysqlData mysql存储对象
+type IMysqlData interface {
+	// MysqlInfo mysql存储信息
+	MysqlInfo(gameId string) *MysqlInfo
+}
@@ -0,0 +1,135 @@
+package svmysql
+
+import (
+	"fmt"
+	"gorm.io/driver/mysql"
+	"gorm.io/gorm"
+	"gorm.io/gorm/clause"
+	"gorm.io/gorm/migrator"
+	"strings"
+)
+
+func InitTable(obj IMysqlData, gameId string) {
+	info := obj.MysqlInfo(gameId)
+	db := info.DbMysql
+	tableName := info.TableName
+	m := db.Migrator().(mysql.Migrator).Migrator
+	queryTx, execTx := m.GetQueryAndExecTx()
+	if HasTable(queryTx.Migrator().(mysql.Migrator).Migrator, obj, tableName) {
+		fmt.Println(tableName + " exist, skip!")
+	} else {
+		err := CreateTable(execTx, obj, tableName)
+		if err != nil {
+			fmt.Println("err", err)
+		}
+	}
+}
+
+func HasTable(m migrator.Migrator, obj any, tableName string) bool {
+	var count int64
+
+	m.RunWithValue(obj, func(stmt *gorm.Statement) error {
+		currentDatabase := m.DB.Migrator().CurrentDatabase()
+		return m.DB.Raw("SELECT count(*) FROM information_schema.tables WHERE table_schema = ? AND table_name = ? AND table_type = ?", currentDatabase, tableName, "BASE TABLE").Row().Scan(&count)
+	})
+
+	return count > 0
+}
+
+func CreateTable(execTx *gorm.DB, value any, tableName string) error {
+	m := execTx.Migrator().(mysql.Migrator).Migrator
+	tx := m.DB.Session(&gorm.Session{})
+
+	if err := m.RunWithValue(value, func(stmt *gorm.Statement) (err error) {
+		var (
+			createTableSQL          = "CREATE TABLE ? ("
+			values                  = []interface{}{clause.Table{Name: tableName}}
+			hasPrimaryKeyInDataType bool
+		)
+
+		for _, dbName := range stmt.Schema.DBNames {
+			field := stmt.Schema.FieldsByDBName[dbName]
+			if !field.IgnoreMigration {
+				createTableSQL += "? ?"
+				hasPrimaryKeyInDataType = hasPrimaryKeyInDataType || strings.Contains(strings.ToUpper(m.DataTypeOf(field)), "PRIMARY KEY")
+				values = append(values, clause.Column{Name: dbName}, m.DB.Migrator().FullDataTypeOf(field))
+				createTableSQL += ","
+			}
+		}
+
+		if !hasPrimaryKeyInDataType && len(stmt.Schema.PrimaryFields) > 0 {
+			createTableSQL += "PRIMARY KEY ?,"
+			primaryKeys := make([]interface{}, 0, len(stmt.Schema.PrimaryFields))
+			for _, field := range stmt.Schema.PrimaryFields {
+				primaryKeys = append(primaryKeys, clause.Column{Name: field.DBName})
+			}
+
+			values = append(values, primaryKeys)
+		}
+
+		for _, idx := range stmt.Schema.ParseIndexes() {
+			if m.CreateIndexAfterCreateTable {
+				defer func(value interface{}, name string) {
+					if err == nil {
+						err = tx.Migrator().CreateIndex(value, name)
+					}
+				}(value, idx.Name)
+			} else {
+				if idx.Class != "" {
+					createTableSQL += idx.Class + " "
+				}
+				createTableSQL += "INDEX ? ?"
+
+				if idx.Comment != "" {
+					createTableSQL += fmt.Sprintf(" COMMENT '%s'", idx.Comment)
+				}
+
+				if idx.Option != "" {
+					createTableSQL += " " + idx.Option
+				}
+
+				createTableSQL += ","
+				values = append(values, clause.Column{Name: idx.Name}, tx.Migrator().(migrator.BuildIndexOptionsInterface).BuildIndexOptions(idx.Fields, stmt))
+			}
+		}
+
+		if !m.DB.DisableForeignKeyConstraintWhenMigrating && !m.DB.IgnoreRelationshipsWhenMigrating {
+			for _, rel := range stmt.Schema.Relationships.Relations {
+				if rel.Field.IgnoreMigration {
+					continue
+				}
+				if constraint := rel.ParseConstraint(); constraint != nil {
+					if constraint.Schema == stmt.Schema {
+						sql, vars := constraint.Build()
+						createTableSQL += sql + ","
+						values = append(values, vars...)
+					}
+				}
+			}
+		}
+
+		for _, uni := range stmt.Schema.ParseUniqueConstraints() {
+			createTableSQL += "CONSTRAINT ? UNIQUE (?),"
+			values = append(values, clause.Column{Name: uni.Name}, clause.Expr{SQL: stmt.Quote(uni.Field.DBName)})
+		}
+
+		for _, chk := range stmt.Schema.ParseCheckConstraints() {
+			createTableSQL += "CONSTRAINT ? CHECK (?),"
+			values = append(values, clause.Column{Name: chk.Name}, clause.Expr{SQL: chk.Constraint})
+		}
+
+		createTableSQL = strings.TrimSuffix(createTableSQL, ",")
+
+		createTableSQL += ")"
+
+		if tableOption, ok := m.DB.Get("gorm:table_options"); ok {
+			createTableSQL += fmt.Sprint(tableOption)
+		}
+
+		err = tx.Exec(createTableSQL, values...).Error
+		return err
+	}); err != nil {
+		return err
+	}
+	return nil
+}
@@ -0,0 +1,58 @@
+package svredis
+
+import (
+	"apigame/service-common/svconst"
+	"apigame/util/utstring"
+	"apigame/util/zjson"
+	"apigame/util/zredis"
+	"fmt"
+	"github.com/astaxie/beego"
+	"github.com/mitchellh/mapstructure"
+)
+
+type RedisConfig struct {
+	Host   string `json:"host"`
+	Port   string `json:"port"`
+	Pwd    string `json:"pwd"`
+	Db     string `json:"Db"`
+	Prefix string `json:"prefix"`
+}
+
+func Init() bool {
+	//初始化Redis
+	confText, _ := beego.AppConfig.GetSection("redis")
+	var conf RedisConfig
+	err := mapstructure.Decode(confText, &conf)
+	if err != nil {
+		fmt.Println("svredis.Init mapstructure.Decode Error::" + err.Error())
+	}
+	zredis.Init(conf.Host+":"+conf.Port, conf.Pwd, utstring.StringToInt(conf.Db))
+	if !zredis.Check() {
+		return false
+	}
+
+	fmt.Println(svconst.AppName + " redis init success")
+	return true
+}
+
+func SaveData(gameId string, obj IRedisData) {
+	info := obj.RedisInfo(gameId)
+	_ = zredis.SetEx(zredis.GetConn(), info.CacheKey, zjson.Str(obj), info.CacheTime)
+}
+
+func LoadData[T IRedisData](gameId string, obj T) (has bool) {
+	has = true
+	info := obj.RedisInfo(gameId)
+	text, err := zredis.Get(zredis.GetConn(), info.CacheKey)
+	if err != nil {
+		has = false
+		return
+	}
+	err = zjson.Obj(text, &obj)
+	if err != nil {
+		fmt.Println(err)
+		has = false
+		return
+	}
+	return
+}
@@ -0,0 +1,13 @@
+package svredis
+
+// RedisInfo redis存储信息
+type RedisInfo struct {
+	CacheKey  string
+	CacheTime int
+}
+
+// IRedisData redis存储对象
+type IRedisData interface {
+	// RedisInfo redis存储信息
+	RedisInfo(gameId string) *RedisInfo
+}
@@ -0,0 +1,119 @@
+package thinkingdata
+
+import (
+	"crypto/tls"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"gitee.com/lxgow/lxconv"
+	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/httplib"
+	lconv "github.com/lixu-any/go-tools/conv"
+	"time"
+)
+
+// index
+// 创建时间:2023/10/23 10:06
+// 创建人:lixu
+
+// index 数数科技
+// 创建时间:2023/7/18 16:03
+// 创建人:lixu
+
+// GetNowDateTime 当前日期时间
+func GetNowDateTime() string {
+	tim := time.Unix(time.Now().Unix(), 0).Format("2006-01-02 15:04:05")
+	return fmt.Sprintf("%s", tim)
+}
+
+type MThinkDataConfig struct {
+	Url   string `json:"url"`
+	Debug int    `json:"debug"`
+}
+
+type MRespData struct {
+	Msg  string `json:"Msg"`
+	Code int    `json:"code"`
+}
+
+var THINKINGDATACONFIG MThinkDataConfig
+
+// InitThinkData 初始化数数
+func InitThinkData() (err error) {
+	thinkingdata, _ := beego.AppConfig.GetSection("thinkingdata")
+	THINKINGDATACONFIG.Url = thinkingdata["url"]
+	THINKINGDATACONFIG.Debug = lxconv.ParseInt(thinkingdata["debug"])
+	return
+}
+
+// AddOneData 数据上报
+func AddOneData(appid, account_id, distinct_id string, event string, data map[string]interface{}, typ string) (resp MRespData, err error) {
+
+	_data := map[string]interface{}{
+		"#type": typ,
+		//"#event_name":  event,
+		"#time":        GetNowDateTime(),
+		"#account_id":  account_id,
+		"#distinct_id": distinct_id,
+		"properties":   data,
+	}
+
+	if typ == "track" && event != "" {
+		_data["#event_name"] = event
+	}
+
+	postdata := map[string]interface{}{
+		"appid": appid,
+		"debug": THINKINGDATACONFIG.Debug,
+		"data":  _data,
+	}
+
+	req := httplib.Post(THINKINGDATACONFIG.Url + "/sync_json")
+
+	req.SetTLSClientConfig(&tls.Config{InsecureSkipVerify: true})
+
+	_, err = req.JSONBody(&postdata)
+	if err != nil {
+		err = errors.New("thinkingdata-AddOneData  req.JSONBody() error::" + err.Error() + "::" + lconv.JsonEncode(postdata))
+		return
+	}
+
+	var (
+		bytes []byte
+	)
+
+	bytes, err = req.Bytes()
+	if err != nil {
+		err = errors.New("thinkingdata-AddOneData  req.Bytes() error::" + err.Error() + "::" + lconv.JsonEncode(postdata) + "::" + string(bytes))
+		return
+	}
+
+	_ = json.Unmarshal(bytes, &resp)
+
+	if resp.Code != 0 {
+		err = errors.New("thinkingdata-AddOneData  resp.Code error:: " + lconv.JsonEncode(postdata) + "::" + string(bytes))
+		return
+	}
+
+	return
+}
+
+// TrackOne 向事件表传入一个事件
+func TrackOne(appid, account_id string, event string, data map[string]interface{}) (resp MRespData, err error) {
+	return AddOneData(appid, account_id, "", event, data, "track")
+}
+
+// UserSet 对用户表进行操作，覆盖一个或多个用户属性，如果该属性已有值存在，覆盖先前值
+func UserSet(appid, account_id string, data map[string]interface{}) (resp MRespData, err error) {
+	return AddOneData(appid, account_id, "", "", data, "user_set")
+}
+
+// UserSetOnce 对用户表进行操作，初始化一个或多个用户属性，如果该属性已有值存在，则忽略本次操作
+func UserSetOnce(appid, account_id string, data map[string]interface{}) (resp MRespData, err error) {
+	return AddOneData(appid, account_id, "", "", data, "user_setOnce")
+}
+
+// UserAdd 对用户表进行操作，为一个或多个数值型用户属性做累加计算
+func UserAdd(appid, account_id string, data map[string]interface{}) (resp MRespData, err error) {
+	return AddOneData(appid, account_id, "", "", data, "user_add")
+}
 package cardholder
 import (
-	"apigame/common/svconst"
-	"apigame/common/svmysql"
-	"apigame/service/constd"
+	"apigame/service-common/svconst"
+	"apigame/service-common/svmysql"
 	"apigame/util/util-lx/lxalilog"
 	"apigame/util/util-lx/lxtime"
 	"encoding/json"
@@ -20,7 +19,7 @@ type DataCardHolder struct {
 }
 func (d *DataCardHolder) MysqlInfo(gameId string) *svmysql.MysqlInfo {
-	tableName := constd.MYSQL_TABLE_S_CARDHOLDER_DATA
+	tableName := svconst.MYSQL_TABLE_S_CARDHOLDER_DATA
 	return &svmysql.MysqlInfo{
 		DbMysql:   svconst.DbCommon,
 		TableName: tableName + gameId,
 package cardholder
 import (
-	"apigame/common/svconst"
-	"apigame/common/svmysql"
-	"apigame/service/constd"
+	"apigame/service-common/svconst"
+	"apigame/service-common/svmysql"
 	"apigame/util/util-lx/lxtime"
 )
@@ -41,7 +40,7 @@ type RecordCardHolderOpen struct {
 }
 func (d *RecordCardHolderOpen) MysqlInfo(gameId string) *svmysql.MysqlInfo {
-	tableName := constd.MYSQL_TABLE_S_CARDHOLDER_RECORD_OPEN
+	tableName := svconst.MYSQL_TABLE_S_CARDHOLDER_RECORD_OPEN
 	return &svmysql.MysqlInfo{
 		DbMysql:   svconst.DbCommon,
 		TableName: tableName + gameId,
@@ -66,7 +65,7 @@ type RecordCardHolderRewardAlbum struct {
 }
 func (d *RecordCardHolderRewardAlbum) MysqlInfo(gameId string) *svmysql.MysqlInfo {
-	tableName := constd.MYSQL_TABLE_S_CARDHOLDER_RECORD_REWARDALBUM
+	tableName := svconst.MYSQL_TABLE_S_CARDHOLDER_RECORD_REWARDALBUM
 	return &svmysql.MysqlInfo{
 		DbMysql:   svconst.DbCommon,
 		TableName: tableName + gameId,
@@ -89,7 +88,7 @@ type RecordCardHolderRewardRound struct {
 }
 func (d *RecordCardHolderRewardRound) MysqlInfo(gameId string) *svmysql.MysqlInfo {
-	tableName := constd.MYSQL_TABLE_S_CARDHOLDER_RECORD_REWARDROUND
+	tableName := svconst.MYSQL_TABLE_S_CARDHOLDER_RECORD_REWARDROUND
 	return &svmysql.MysqlInfo{
 		DbMysql:   svconst.DbCommon,
 		TableName: tableName + gameId,
@@ -3,7 +3,7 @@ package cardholder
 import (
 	"apigame/configs"
 	"apigame/models"
-	"apigame/service/constd"
+	"apigame/service/code-msg"
 	"apigame/util/util-lx/lxalilog"
 	"apigame/util/util-lx/lxtime"
 	"apigame/util/utslice"
@@ -13,7 +13,7 @@ import (
 // HandleGetConfig 活动配置
 func HandleGetConfig(req *models.ReqCardHolderGetConfig) (code string, rsp models.RspCardHolderGetConfig) {
 	rsp = models.RspCardHolderGetConfig{}
-	code = constd.RECODE_OK
+	code = code_msg.RECODE_OK
 	// 尝试更新配置
 	config, _ := configs.GetCardActivityConfig(req.GameID)
@@ -31,19 +31,19 @@ func HandleGetConfig(req *models.ReqCardHolderGetConfig) (code string, rsp model
 // HandleInfo 卡包信息
 func HandleInfo(req *models.ReqCardHolderInfo) (code string, rsp models.RspCardHolderInfo) {
 	rsp = models.RspCardHolderInfo{}
-	code = constd.RECODE_OK
+	code = code_msg.RECODE_OK
 	// 尝试更新配置
 	config, hasConfig := configs.GetCardActivityConfig(req.GameID)
 	if !hasConfig {
-		code = constd.RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR
+		code = code_msg.RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR
 		return
 	}
 	// 判断预告时间
 	sec := lxtime.NowUninx()
 	if sec < config.StartTime {
-		code = constd.RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR
+		code = code_msg.RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR
 		return
 	}
@@ -61,25 +61,25 @@ func HandleOpen(req *models.ReqCardHolderOpen) (code string, rsp models.RspCardH
 		NewCards:   make([][]int, 0),
 		AwardAlbum: make(map[int]string),
 	}
-	code = constd.RECODE_OK
+	code = code_msg.RECODE_OK
 	// 尝试更新配置
 	config, hasConfig := configs.GetCardActivityConfig(req.GameID)
 	if !hasConfig {
-		code = constd.RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR
+		code = code_msg.RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR
 		return
 	}
 	// 检查活动状态
 	code = CheckStatus(config)
-	if code != constd.RECODE_OK {
+	if code != code_msg.RECODE_OK {
 		return
 	}
 	// 检查卡包ID
 	for _, idCardholder := range req.Ids {
 		_, okCardholder := config.CardholderConfig[strconv.Itoa(idCardholder)]
 		if !okCardholder {
-			code = constd.RECODE_MERGE_CARDHOLDER_CARDHOLDERID_ERROR
+			code = code_msg.RECODE_MERGE_CARDHOLDER_CARDHOLDERID_ERROR
 			return
 		}
 	}
@@ -88,7 +88,7 @@ func HandleOpen(req *models.ReqCardHolderOpen) (code string, rsp models.RspCardH
 	gameData := LoadData(req.GameID, req.UID, config)
 	// 检查游戏数据 轮次等
 	code = CheckGameData(gameData, config)
-	if code != constd.RECODE_OK {
+	if code != code_msg.RECODE_OK {
 		return
 	}
@@ -136,24 +136,24 @@ func HandleShopExchange(req *models.ReqStarShopExchange) (code string, rsp model
 		NewCards:   make([]int, 0),
 		AwardAlbum: make(map[int]string),
 	}
-	code = constd.RECODE_OK
+	code = code_msg.RECODE_OK
 	// 尝试更新配置
 	config, hasConfig := configs.GetCardActivityConfig(req.GameID)
 	if !hasConfig {
-		code = constd.RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR
+		code = code_msg.RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR
 		return
 	}
 	// 检查活动状态
 	code = CheckStatus(config)
-	if code != constd.RECODE_OK {
+	if code != code_msg.RECODE_OK {
 		return
 	}
 	// 检查星星商店ID
 	confStarShop, okStarShopConfig := config.StarShopConfig[req.Id]
 	if !okStarShopConfig {
-		code = constd.RECODE_MERGE_CARDHOLDER_STARSHOPID_ERROR
+		code = code_msg.RECODE_MERGE_CARDHOLDER_STARSHOPID_ERROR
 		return
 	}
@@ -161,39 +161,39 @@ func HandleShopExchange(req *models.ReqStarShopExchange) (code string, rsp model
 	gameData := LoadData(req.GameID, req.UID, config)
 	// 检查游戏数据 轮次等
 	code = CheckGameData(gameData, config)
-	if code != constd.RECODE_OK {
+	if code != code_msg.RECODE_OK {
 		return
 	}
 	// 判断星星数是否足够
 	if gameData.Details.StarCount < confStarShop.NeedStarNumber {
-		code = constd.RECODE_MERGE_CARDHOLDER_STAR_NOTENOUGH_ERROR
+		code = code_msg.RECODE_MERGE_CARDHOLDER_STAR_NOTENOUGH_ERROR
 		return
 	}
 	// 判断配置
 	if len(confStarShop.CardBagIds) < 3 {
 		lxalilog.Errors("StarShopConfig.CardBagIds error", confStarShop.Id)
-		code = constd.RECODE_MERGE_CONFIG_ERROR
+		code = code_msg.RECODE_MERGE_CONFIG_ERROR
 		return
 	}
 	cardholderId := confStarShop.CardBagIds[1]
 	cardholderCount := confStarShop.CardBagIds[2]
 	if cardholderCount < 1 {
 		lxalilog.Errors("StarShopConfig.CardBagIds error", confStarShop.Id)
-		code = constd.RECODE_MERGE_CONFIG_ERROR
+		code = code_msg.RECODE_MERGE_CONFIG_ERROR
 		return
 	}
 	confCardholder, okCardholder := config.CardholderConfig[strconv.Itoa(cardholderId)]
 	if !okCardholder {
-		code = constd.RECODE_MERGE_CONFIG_ERROR
+		code = code_msg.RECODE_MERGE_CONFIG_ERROR
 		return
 	}
 	// 按照规则扣除星星
 	enough, cardList := GetStarCardList(gameData, config, confStarShop.NeedStarNumber)
 	if !enough {
-		code = constd.RECODE_MERGE_CARDHOLDER_STAR_NOTENOUGH_ERROR
+		code = code_msg.RECODE_MERGE_CARDHOLDER_STAR_NOTENOUGH_ERROR
 		return
 	}
 	for i, i2 := range cardList {
@@ -242,18 +242,18 @@ func HandleAutoExchangeInfo(req *models.ReqAutoExchangeInfo) (code string, rsp m
 		AwardAlbum:         make(map[int]string),
 		AutoExchangeHolder: make([]int, 0),
 	}
-	code = constd.RECODE_OK
+	code = code_msg.RECODE_OK
 	// 尝试更新配置
 	config, hasConfig := configs.GetCardActivityConfig(req.GameID)
 	if !hasConfig {
-		code = constd.RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR
+		code = code_msg.RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR
 		return
 	}
 	// 检查活动状态
 	code = CheckStatus(config)
-	if code != constd.RECODE_OK {
+	if code != code_msg.RECODE_OK {
 		return
 	}
@@ -261,12 +261,12 @@ func HandleAutoExchangeInfo(req *models.ReqAutoExchangeInfo) (code string, rsp m
 	gameData := LoadData(req.GameID, req.UID, config)
 	// 检查游戏数据 轮次等
 	code = CheckGameData(gameData, config)
-	if code != constd.RECODE_OK {
+	if code != code_msg.RECODE_OK {
 		return
 	}
 	if gameData.Details.LastStarCount <= 0 {
-		code = constd.RECODE_MERGE_CARDHOLDER_NOAUTOEXCHANGEINFO_ERROR
+		code = code_msg.RECODE_MERGE_CARDHOLDER_NOAUTOEXCHANGEINFO_ERROR
 		return
 	}
 package cardholder
 import (
-	"apigame/common/svconst"
-	"apigame/common/svmysql"
+	"apigame/service-common/svconst"
+	"apigame/service-common/svmysql"
 )
 func Init() {
 package cardholder
 import (
-	"apigame/common/svmysql"
 	"apigame/configs"
 	"apigame/models"
-	"apigame/service/constd"
+	"apigame/service-common/svmysql"
+	"apigame/service/code-msg"
 	"apigame/util/util-lx/lxalilog"
 	"apigame/util/util-lx/lxtime"
 	"apigame/util/utjson"
@@ -65,23 +65,23 @@ func LoadData(gameId string, uid int64, config *configs.CardActivityConfig) (d *
 func CheckStatus(conf *configs.CardActivityConfig) string {
 	sec := lxtime.NowUninx()
 	if conf.Id == 0 {
-		return constd.RECODE_MERGE_CARDHOLDER_NOTOPEN1_ERROR
+		return code_msg.RECODE_MERGE_CARDHOLDER_NOTOPEN1_ERROR
 	}
 	if sec < conf.StartTime {
-		return constd.RECODE_MERGE_CARDHOLDER_NOTOPEN1_ERROR
+		return code_msg.RECODE_MERGE_CARDHOLDER_NOTOPEN1_ERROR
 	}
 	if sec > conf.EndTime {
-		return constd.RECODE_MERGE_CARDHOLDER_NOTOPEN2_ERROR
+		return code_msg.RECODE_MERGE_CARDHOLDER_NOTOPEN2_ERROR
 	}
-	return constd.RECODE_OK
+	return code_msg.RECODE_OK
 }
 // CheckGameData 检查游戏数据 轮次等
 func CheckGameData(d *DataCardHolder, conf *configs.CardActivityConfig) string {
 	if d.Details.Round > conf.Round {
-		return constd.RECODE_MERGE_CARDHOLDER_ROUNDFINISH_ERROR
+		return code_msg.RECODE_MERGE_CARDHOLDER_ROUNDFINISH_ERROR
 	}
-	return constd.RECODE_OK
+	return code_msg.RECODE_OK
 }
 // GetUserSequenceIdAndCohort 获取 用户序列组ID(sequenceId) 用户分组(cohort)
@@ -0,0 +1,121 @@
+package code_msg
+
+import (
+	"apigame/util/util-lx/lxalilog"
+	"apigame/util/util-lx/lxtime"
+)
+
+const (
+	RECODE_OK                   = "0"
+	RECODE_FALIED               = "1000"
+	RECODE_UNKNOWERR            = "1001"
+	RECODE_PARAMERROR           = "1002"
+	RECODE_SIGNERROR            = "1003"
+	RECODE_DATA_BUCUNZIA_ERROR  = "1004"
+	RECODE_PARAMDECODE_ERROR    = "1005"
+	RECODE_DATANOEXIST_ERROR    = "1006"
+	RECODE_CREATEUID_ERROR      = "1007"
+	RECODE_LOGINCHECK_ERROR     = "1008"
+	RECODE_WEIXINAZIFU_ERROR    = "1009"
+	RECODE_SDKMEMBER_ERROR      = "1010"
+	RECODE_CAOZUOPINFAN_ERROR   = "1011"
+	RECODE_REQUESTXIANLIU_ERROR = "1110"
+	RECODE_REQUESTTIME_ERROR    = "1111"
+
+	RECODE_MERGE_CONFIG_ERROR            = "2000"
+	RECODE_MERGE_CFLQ_ERROR              = "2001"
+	RECODE_MERGE_AZSXLQ_ERROR            = "2002"
+	RECODE_MERGE_QXGMSP_ERROR            = "2003"
+	RECODE_MERGE_MEMBERSHIP_QXCZZK_ERROR = "2010"
+	RECODE_MERGE_MEMBERSHIP_QXCZYK_ERROR = "2011"
+	RECODE_MERGE_MEMBERSHIP_QXCZ_ERROR   = "2012"
+	RECODE_MERGE_MEMBERSHIP_BNCFLQ_ERROR = "2013"
+
+	RECODE_MERGE_NOVICE_QXCZ_ERROR           = "2021"
+	RECODE_MERGE_NOVICE_BNCFLQ_ERROR         = "2032"
+	RECODE_MERGE_NOVICE_MYDDLQTJ_ERROR       = "2033"
+	RECODE_MERGE_HUODONGWEIKAISHI_ERROR      = "2040"
+	RECODE_MERGE_HUODONGYIJIESHU_ERROR       = "2041"
+	RECODE_MERGE_CCZDXX_ERROR                = "2042"
+	RECODE_MERGE_TONGXINGZHENGBUCUNZAI_ERROR = "2051"
+	RECODE_MERGE_QINGXIANGMTXZ_ERROR         = "2052"
+
+	RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR            = "2100"
+	RECODE_MERGE_CARDHOLDER_NOTOPEN1_ERROR           = "2101"
+	RECODE_MERGE_CARDHOLDER_NOTOPEN2_ERROR           = "2102"
+	RECODE_MERGE_CARDHOLDER_ROUNDFINISH_ERROR        = "2103"
+	RECODE_MERGE_CARDHOLDER_CARDHOLDERID_ERROR       = "2104"
+	RECODE_MERGE_CARDHOLDER_STARSHOPID_ERROR         = "2105"
+	RECODE_MERGE_CARDHOLDER_STAR_NOTENOUGH_ERROR     = "2106"
+	RECODE_MERGE_CARDHOLDER_NOAUTOEXCHANGEINFO_ERROR = "2107"
+)
+
+var recodeText = map[string]string{
+	RECODE_OK:                   "成功",
+	RECODE_FALIED:               "操作失败",
+	RECODE_UNKNOWERR:            "未知错误",
+	RECODE_PARAMERROR:           "参数错误",
+	RECODE_SIGNERROR:            "签名错误",
+	RECODE_DATA_BUCUNZIA_ERROR:  "数据不存在",
+	RECODE_PARAMDECODE_ERROR:    "解析参数失败，请检查参数合法性",
+	RECODE_DATANOEXIST_ERROR:    "数据不存在",
+	RECODE_CREATEUID_ERROR:      "创建用户UID失败",
+	RECODE_LOGINCHECK_ERROR:     "登录验证失败,请重新登录",
+	RECODE_WEIXINAZIFU_ERROR:    "参数存在危险字符",
+	RECODE_SDKMEMBER_ERROR:      "获取SDK用户信息失败",
+	RECODE_CAOZUOPINFAN_ERROR:   "操作频繁",
+	RECODE_REQUESTXIANLIU_ERROR: "操作被限流",
+	RECODE_REQUESTTIME_ERROR:    "time errors",
+
+	RECODE_MERGE_CONFIG_ERROR: "获取配置文件错误",
+	RECODE_MERGE_CFLQ_ERROR:   "不能重复领取",
+	RECODE_MERGE_AZSXLQ_ERROR: "请按照顺序领取",
+	RECODE_MERGE_QXGMSP_ERROR: "请先购买对应商品",
+
+	RECODE_MERGE_MEMBERSHIP_QXCZZK_ERROR: "请先购买周卡",
+	RECODE_MERGE_MEMBERSHIP_QXCZYK_ERROR: "请先购买月卡",
+	RECODE_MERGE_MEMBERSHIP_QXCZ_ERROR:   "请先购买对应商品",
+	RECODE_MERGE_MEMBERSHIP_BNCFLQ_ERROR: "不能重复领取",
+
+	RECODE_MERGE_NOVICE_QXCZ_ERROR:     "请先购买对应商品",
+	RECODE_MERGE_NOVICE_BNCFLQ_ERROR:   "不能重复领取",
+	RECODE_MERGE_NOVICE_MYDDLQTJ_ERROR: "没有达到领取条件",
+
+	RECODE_MERGE_HUODONGWEIKAISHI_ERROR: "活动未开始",
+	RECODE_MERGE_HUODONGYIJIESHU_ERROR:  "活动已结束",
+	RECODE_MERGE_CCZDXX_ERROR:           "超出最大限制",
+
+	RECODE_MERGE_TONGXINGZHENGBUCUNZAI_ERROR: "通行证不存在",
+	RECODE_MERGE_QINGXIANGMTXZ_ERROR:         "请先购买通行证",
+
+	RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR:            "活动未开放",
+	RECODE_MERGE_CARDHOLDER_NOTOPEN1_ERROR:           "活动未开始",
+	RECODE_MERGE_CARDHOLDER_NOTOPEN2_ERROR:           "活动已结束",
+	RECODE_MERGE_CARDHOLDER_ROUNDFINISH_ERROR:        "活动轮次已全部完成",
+	RECODE_MERGE_CARDHOLDER_CARDHOLDERID_ERROR:       "卡包ID错误",
+	RECODE_MERGE_CARDHOLDER_STARSHOPID_ERROR:         "商店ID错误",
+	RECODE_MERGE_CARDHOLDER_STAR_NOTENOUGH_ERROR:     "星星商店星星不足",
+	RECODE_MERGE_CARDHOLDER_NOAUTOEXCHANGEINFO_ERROR: "没有星星商店自动兑换信息",
+}
+
+func RecodeText(code string) string {
+	str, ok := recodeText[code]
+	if ok {
+		return str
+	}
+	return RecodeText(RECODE_UNKNOWERR)
+}
+
+func CodeMsg(data map[string]interface{}, code interface{}) map[string]interface{} {
+	data["code"] = code
+	data["msg"] = RecodeText(code.(string))
+	lxtime.NowUninx()
+	data["servertime"] = lxtime.NowUninx()
+	return data
+}
+
+func CodeMsgLog(data map[string]interface{}, code interface{}, log ...interface{}) map[string]interface{} {
+	// 写入日志
+	lxalilog.ErrorCode(code, log)
+	return CodeMsg(data, code)
+}
@@ -1,121 +0,0 @@
-package constd
-
-import (
-	"apigame/util/util-lx/lxalilog"
-	"apigame/util/util-lx/lxtime"
-)
-
-const (
-	RECODE_OK                   = "0"
-	RECODE_FALIED               = "1000"
-	RECODE_UNKNOWERR            = "1001"
-	RECODE_PARAMERROR           = "1002"
-	RECODE_SIGNERROR            = "1003"
-	RECODE_DATA_BUCUNZIA_ERROR  = "1004"
-	RECODE_PARAMDECODE_ERROR    = "1005"
-	RECODE_DATANOEXIST_ERROR    = "1006"
-	RECODE_CREATEUID_ERROR      = "1007"
-	RECODE_LOGINCHECK_ERROR     = "1008"
-	RECODE_WEIXINAZIFU_ERROR    = "1009"
-	RECODE_SDKMEMBER_ERROR      = "1010"
-	RECODE_CAOZUOPINFAN_ERROR   = "1011"
-	RECODE_REQUESTXIANLIU_ERROR = "1110"
-	RECODE_REQUESTTIME_ERROR    = "1111"
-
-	RECODE_MERGE_CONFIG_ERROR            = "2000"
-	RECODE_MERGE_CFLQ_ERROR              = "2001"
-	RECODE_MERGE_AZSXLQ_ERROR            = "2002"
-	RECODE_MERGE_QXGMSP_ERROR            = "2003"
-	RECODE_MERGE_MEMBERSHIP_QXCZZK_ERROR = "2010"
-	RECODE_MERGE_MEMBERSHIP_QXCZYK_ERROR = "2011"
-	RECODE_MERGE_MEMBERSHIP_QXCZ_ERROR   = "2012"
-	RECODE_MERGE_MEMBERSHIP_BNCFLQ_ERROR = "2013"
-
-	RECODE_MERGE_NOVICE_QXCZ_ERROR           = "2021"
-	RECODE_MERGE_NOVICE_BNCFLQ_ERROR         = "2032"
-	RECODE_MERGE_NOVICE_MYDDLQTJ_ERROR       = "2033"
-	RECODE_MERGE_HUODONGWEIKAISHI_ERROR      = "2040"
-	RECODE_MERGE_HUODONGYIJIESHU_ERROR       = "2041"
-	RECODE_MERGE_CCZDXX_ERROR                = "2042"
-	RECODE_MERGE_TONGXINGZHENGBUCUNZAI_ERROR = "2051"
-	RECODE_MERGE_QINGXIANGMTXZ_ERROR         = "2052"
-
-	RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR            = "2100"
-	RECODE_MERGE_CARDHOLDER_NOTOPEN1_ERROR           = "2101"
-	RECODE_MERGE_CARDHOLDER_NOTOPEN2_ERROR           = "2102"
-	RECODE_MERGE_CARDHOLDER_ROUNDFINISH_ERROR        = "2103"
-	RECODE_MERGE_CARDHOLDER_CARDHOLDERID_ERROR       = "2104"
-	RECODE_MERGE_CARDHOLDER_STARSHOPID_ERROR         = "2105"
-	RECODE_MERGE_CARDHOLDER_STAR_NOTENOUGH_ERROR     = "2106"
-	RECODE_MERGE_CARDHOLDER_NOAUTOEXCHANGEINFO_ERROR = "2107"
-)
-
-var recodeText = map[string]string{
-	RECODE_OK:                   "成功",
-	RECODE_FALIED:               "操作失败",
-	RECODE_UNKNOWERR:            "未知错误",
-	RECODE_PARAMERROR:           "参数错误",
-	RECODE_SIGNERROR:            "签名错误",
-	RECODE_DATA_BUCUNZIA_ERROR:  "数据不存在",
-	RECODE_PARAMDECODE_ERROR:    "解析参数失败，请检查参数合法性",
-	RECODE_DATANOEXIST_ERROR:    "数据不存在",
-	RECODE_CREATEUID_ERROR:      "创建用户UID失败",
-	RECODE_LOGINCHECK_ERROR:     "登录验证失败,请重新登录",
-	RECODE_WEIXINAZIFU_ERROR:    "参数存在危险字符",
-	RECODE_SDKMEMBER_ERROR:      "获取SDK用户信息失败",
-	RECODE_CAOZUOPINFAN_ERROR:   "操作频繁",
-	RECODE_REQUESTXIANLIU_ERROR: "操作被限流",
-	RECODE_REQUESTTIME_ERROR:    "time errors",
-
-	RECODE_MERGE_CONFIG_ERROR: "获取配置文件错误",
-	RECODE_MERGE_CFLQ_ERROR:   "不能重复领取",
-	RECODE_MERGE_AZSXLQ_ERROR: "请按照顺序领取",
-	RECODE_MERGE_QXGMSP_ERROR: "请先购买对应商品",
-
-	RECODE_MERGE_MEMBERSHIP_QXCZZK_ERROR: "请先购买周卡",
-	RECODE_MERGE_MEMBERSHIP_QXCZYK_ERROR: "请先购买月卡",
-	RECODE_MERGE_MEMBERSHIP_QXCZ_ERROR:   "请先购买对应商品",
-	RECODE_MERGE_MEMBERSHIP_BNCFLQ_ERROR: "不能重复领取",
-
-	RECODE_MERGE_NOVICE_QXCZ_ERROR:     "请先购买对应商品",
-	RECODE_MERGE_NOVICE_BNCFLQ_ERROR:   "不能重复领取",
-	RECODE_MERGE_NOVICE_MYDDLQTJ_ERROR: "没有达到领取条件",
-
-	RECODE_MERGE_HUODONGWEIKAISHI_ERROR: "活动未开始",
-	RECODE_MERGE_HUODONGYIJIESHU_ERROR:  "活动已结束",
-	RECODE_MERGE_CCZDXX_ERROR:           "超出最大限制",
-
-	RECODE_MERGE_TONGXINGZHENGBUCUNZAI_ERROR: "通行证不存在",
-	RECODE_MERGE_QINGXIANGMTXZ_ERROR:         "请先购买通行证",
-
-	RECODE_MERGE_CARDHOLDER_NOTOPEN_ERROR:            "活动未开放",
-	RECODE_MERGE_CARDHOLDER_NOTOPEN1_ERROR:           "活动未开始",
-	RECODE_MERGE_CARDHOLDER_NOTOPEN2_ERROR:           "活动已结束",
-	RECODE_MERGE_CARDHOLDER_ROUNDFINISH_ERROR:        "活动轮次已全部完成",
-	RECODE_MERGE_CARDHOLDER_CARDHOLDERID_ERROR:       "卡包ID错误",
-	RECODE_MERGE_CARDHOLDER_STARSHOPID_ERROR:         "商店ID错误",
-	RECODE_MERGE_CARDHOLDER_STAR_NOTENOUGH_ERROR:     "星星商店星星不足",
-	RECODE_MERGE_CARDHOLDER_NOAUTOEXCHANGEINFO_ERROR: "没有星星商店自动兑换信息",
-}
-
-func RecodeText(code string) string {
-	str, ok := recodeText[code]
-	if ok {
-		return str
-	}
-	return RecodeText(RECODE_UNKNOWERR)
-}
-
-func CodeMsg(data map[string]interface{}, code interface{}) map[string]interface{} {
-	data["code"] = code
-	data["msg"] = RecodeText(code.(string))
-	lxtime.NowUninx()
-	data["servertime"] = lxtime.NowUninx()
-	return data
-}
-
-func CodeMsgLog(data map[string]interface{}, code interface{}, log ...interface{}) map[string]interface{} {
-	// 写入日志
-	lxalilog.ErrorCode(code, log)
-	return CodeMsg(data, code)
-}
@@ -1,21 +0,0 @@
-package constd
-
-// mysql
-// 创建时间:2023/4/3 15:28
-// 创建人:lixu
-
-const (
-	MYSQL_DEFAULT                = "default"
-	MYSQL_DBAPI                  = "api"
-	MYSQL_MERGECOMMON            = "merge_common"
-	MYSQL_MERGECONFIG            = "merge_config"
-	MYSQL_DEFAULT_QUERY_MAXCOUNT = 100
-
-	MYSQL_TABLE_S_CARDHOLDER_CONFIG             = "s_card_activity_"                 // 开卡包活动配置
-	MYSQL_TABLE_S_CARDHOLDER_DATA               = "s_cardholder_data_"               // 开卡包活动数据
-	MYSQL_TABLE_S_CARDHOLDER_RECORD_GETNEW      = "s_cardholder_record_getnew_"      // 开卡包活动日志获得卡包
-	MYSQL_TABLE_S_CARDHOLDER_RECORD_OPEN        = "s_cardholder_record_open_"        // 开卡包活动日志开卡包
-	MYSQL_TABLE_S_CARDHOLDER_RECORD_REWARDALBUM = "s_cardholder_record_rewardalbum_" // 开卡包活动日志领取卡组奖励
-	MYSQL_TABLE_S_CARDHOLDER_RECORD_REWARDROUND = "s_cardholder_record_rewardround_" // 开卡包活动日志领取轮次奖励
-
-)
@@ -1,44 +0,0 @@
-package utdto
-
-import (
-	"gorm.io/gorm"
-	"strings"
-)
-
-// Insert 插入
-func Insert(db *gorm.DB, value any, tableName string) *gorm.DB {
-	stmt := db.Session(&gorm.Session{DryRun: true}).Create(value).Statement
-	stmtSQL := stmt.SQL.String()
-	sql := strings.Replace(stmtSQL, MYSQL_TABLE_TEMPLATE, tableName, -1)
-	return db.Exec(sql, stmt.Vars...)
-}
-
-// Update 更新
-func Update(db *gorm.DB, value any, tableName string) *gorm.DB {
-	stmt := db.Session(&gorm.Session{DryRun: true}).Updates(value).Statement
-	stmtSQL := stmt.SQL.String()
-	sql := strings.Replace(stmtSQL, MYSQL_TABLE_TEMPLATE, tableName, -1)
-	return db.Exec(sql, stmt.Vars...)
-}
-
-// Save 保存
-func Save(db *gorm.DB, value any, tableName string) *gorm.DB {
-	stmt := db.Session(&gorm.Session{DryRun: true}).Save(value).Statement
-	stmtSQL := stmt.SQL.String()
-	sql := strings.Replace(stmtSQL, MYSQL_TABLE_TEMPLATE, tableName, -1)
-	return db.Exec(sql, stmt.Vars...)
-}
-
-func First(db *gorm.DB, value any, tableName string) *gorm.DB {
-	stmt := db.Session(&gorm.Session{DryRun: true}).First(value).Statement
-	stmtSQL := stmt.SQL.String()
-	sql := strings.Replace(stmtSQL, MYSQL_TABLE_TEMPLATE, tableName, -1)
-	return db.Raw(sql, stmt.Vars...).Scan(value)
-}
-
-func Find(db *gorm.DB, value any, tableName string) *gorm.DB {
-	stmt := db.Session(&gorm.Session{DryRun: true}).Find(value).Statement
-	stmtSQL := stmt.SQL.String()
-	sql := strings.Replace(stmtSQL, MYSQL_TABLE_TEMPLATE, tableName, -1)
-	return db.Raw(sql, stmt.Vars...).Scan(value)
-}
@@ -1,12 +0,0 @@
-package utdto
-
-import (
-	"gorm.io/driver/mysql"
-	"gorm.io/gorm"
-)
-
-const MYSQL_TABLE_TEMPLATE = "all_table_template" // 表名模板
-
-func ConnectMySQL(dsn string) (db *gorm.DB, err error) {
-	return gorm.Open(mysql.Open(dsn), &gorm.Config{})
-}
@@ -1,132 +0,0 @@
-package utdto
-
-import (
-	"fmt"
-	"gorm.io/driver/mysql"
-	"gorm.io/gorm"
-	"gorm.io/gorm/clause"
-	"gorm.io/gorm/migrator"
-	"strings"
-)
-
-func InitTable(db *gorm.DB, value any, tableName string) {
-	m := db.Migrator().(mysql.Migrator).Migrator
-	queryTx, execTx := m.GetQueryAndExecTx()
-	if HasTable(queryTx.Migrator().(mysql.Migrator).Migrator, value, tableName) {
-		fmt.Println(tableName + " exist, skip!")
-	} else {
-		err := CreateTable(execTx, value, tableName)
-		if err != nil {
-			fmt.Println("err", err)
-		}
-	}
-}
-
-func HasTable(m migrator.Migrator, value interface{}, tableName string) bool {
-	var count int64
-
-	m.RunWithValue(value, func(stmt *gorm.Statement) error {
-		currentDatabase := m.DB.Migrator().CurrentDatabase()
-		return m.DB.Raw("SELECT count(*) FROM information_schema.tables WHERE table_schema = ? AND table_name = ? AND table_type = ?", currentDatabase, tableName, "BASE TABLE").Row().Scan(&count)
-	})
-
-	return count > 0
-}
-
-func CreateTable(execTx *gorm.DB, value any, tableName string) error {
-	m := execTx.Migrator().(mysql.Migrator).Migrator
-	tx := m.DB.Session(&gorm.Session{})
-
-	if err := m.RunWithValue(value, func(stmt *gorm.Statement) (err error) {
-		var (
-			createTableSQL          = "CREATE TABLE ? ("
-			values                  = []interface{}{clause.Table{Name: tableName}}
-			hasPrimaryKeyInDataType bool
-		)
-
-		for _, dbName := range stmt.Schema.DBNames {
-			field := stmt.Schema.FieldsByDBName[dbName]
-			if !field.IgnoreMigration {
-				createTableSQL += "? ?"
-				hasPrimaryKeyInDataType = hasPrimaryKeyInDataType || strings.Contains(strings.ToUpper(m.DataTypeOf(field)), "PRIMARY KEY")
-				values = append(values, clause.Column{Name: dbName}, m.DB.Migrator().FullDataTypeOf(field))
-				createTableSQL += ","
-			}
-		}
-
-		if !hasPrimaryKeyInDataType && len(stmt.Schema.PrimaryFields) > 0 {
-			createTableSQL += "PRIMARY KEY ?,"
-			primaryKeys := make([]interface{}, 0, len(stmt.Schema.PrimaryFields))
-			for _, field := range stmt.Schema.PrimaryFields {
-				primaryKeys = append(primaryKeys, clause.Column{Name: field.DBName})
-			}
-
-			values = append(values, primaryKeys)
-		}
-
-		for _, idx := range stmt.Schema.ParseIndexes() {
-			if m.CreateIndexAfterCreateTable {
-				defer func(value interface{}, name string) {
-					if err == nil {
-						err = tx.Migrator().CreateIndex(value, name)
-					}
-				}(value, idx.Name)
-			} else {
-				if idx.Class != "" {
-					createTableSQL += idx.Class + " "
-				}
-				createTableSQL += "INDEX ? ?"
-
-				if idx.Comment != "" {
-					createTableSQL += fmt.Sprintf(" COMMENT '%s'", idx.Comment)
-				}
-
-				if idx.Option != "" {
-					createTableSQL += " " + idx.Option
-				}
-
-				createTableSQL += ","
-				values = append(values, clause.Column{Name: idx.Name}, tx.Migrator().(migrator.BuildIndexOptionsInterface).BuildIndexOptions(idx.Fields, stmt))
-			}
-		}
-
-		if !m.DB.DisableForeignKeyConstraintWhenMigrating && !m.DB.IgnoreRelationshipsWhenMigrating {
-			for _, rel := range stmt.Schema.Relationships.Relations {
-				if rel.Field.IgnoreMigration {
-					continue
-				}
-				if constraint := rel.ParseConstraint(); constraint != nil {
-					if constraint.Schema == stmt.Schema {
-						sql, vars := constraint.Build()
-						createTableSQL += sql + ","
-						values = append(values, vars...)
-					}
-				}
-			}
-		}
-
-		for _, uni := range stmt.Schema.ParseUniqueConstraints() {
-			createTableSQL += "CONSTRAINT ? UNIQUE (?),"
-			values = append(values, clause.Column{Name: uni.Name}, clause.Expr{SQL: stmt.Quote(uni.Field.DBName)})
-		}
-
-		for _, chk := range stmt.Schema.ParseCheckConstraints() {
-			createTableSQL += "CONSTRAINT ? CHECK (?),"
-			values = append(values, clause.Column{Name: chk.Name}, clause.Expr{SQL: chk.Constraint})
-		}
-
-		createTableSQL = strings.TrimSuffix(createTableSQL, ",")
-
-		createTableSQL += ")"
-
-		if tableOption, ok := m.DB.Get("gorm:table_options"); ok {
-			createTableSQL += fmt.Sprint(tableOption)
-		}
-
-		err = tx.Exec(createTableSQL, values...).Error
-		return err
-	}); err != nil {
-		return err
-	}
-	return nil
-}
1		1
2	## 项目目录结构	2	## 项目目录结构
3		3
4	-\| 项目目录 \| 目录说明 \|
5	-\|-------------\|----------\|
6	-\| conf \| beego配置 \|
7	-\| controllers \| 控制器 \|
8	-\| dto \| 数据库存储对象 \|
9	-\| models \| 与客户端传输对象 \|
10	-\| routers \| 路由 \|
11	-\| sdk \| SDK \|
12	-\| service \| 游戏服务器逻辑 \|
13	-\| sign \| 签名 \|
14	-\| util \| 公共库 \|
15	-\| util-lx \| 公共库(李旭) \|	4	+\| 项目目录 \| 目录说明 \|
		5	+\|----------------\|----------\|
		6	+\| conf \| beego配置 \|
		7	+\| configs \| 游戏配置处理 \|
		8	+\| controllers \| 控制器 \|
		9	+\| middleware \| 中间件 \|
		10	+\| models \| 与客户端传输对象 \|
		11	+\| routers \| 路由 \|
		12	+\| service-common \| 服务器公共模块 \|
		13	+\| service \| 游戏服务器逻辑 \|
		14	+\| util \| 公共库 \|
		15	+\| util-lx \| 公共库(李旭) \|
16		16
17	## 游戏和游戏功能列表	17	## 游戏和游戏功能列表
18		18
19	-\| 功能模块名 \| 所属功能 \| 负责人 \|
20	-\|---------------\|------\|-----\|	19	+\| 功能模块名 \| 所属功能 \| 负责人 \|
		20	+\|------------\|------\|-----\|
21	\| cardholder \| 卡包卡牌 \| 王家文 \|	21	\| cardholder \| 卡包卡牌 \| 王家文 \|
	@@ -1,13 +0,0 @@	@@ -1,13 +0,0 @@
1	-package svconst
2	-
3	-import "gorm.io/gorm"
4	-
5	-var (
6	- AppName = ""
7	-
8	- DbApi *gorm.DB
9	- DbCommon *gorm.DB
10	- DbConfig *gorm.DB
11	-
12	- GameListCardHolder = []string{"10149"}
13	-)
	@@ -1,68 +0,0 @@	@@ -1,68 +0,0 @@
1	-package svdto
2	-
3	-import (
4	- "apigame/util/utdto"
5	- "apigame/util/util-lx/lxalilog"
6	-)
7	-
8	-func InitTable(tb IDtoData, gameId string) {
9	- rule := tb.GetRule(gameId)
10	- utdto.InitTable(rule.DbMysql, tb, rule.TableName)
11	-}
12	-
13	-func Insert(data IDtoData, gameId string) (err error) {
14	- rule := data.GetRule(gameId)
15	- result := utdto.Insert(rule.DbMysql, data, rule.TableName)
16	- err = result.Error
17	- if err != nil {
18	- lxalilog.Errors(err, gameId)
19	- return
20	- }
21	- return
22	-}
23	-
24	-func Update(data IDtoData, gameId string) (err error) {
25	- rule := data.GetRule(gameId)
26	- result := utdto.Update(rule.DbMysql, data, rule.TableName)
27	- err = result.Error
28	- if err != nil {
29	- lxalilog.Errors(err, gameId)
30	- return
31	- }
32	- return
33	-}
34	-
35	-func Save(data IDtoData, gameId string) (err error) {
36	- rule := data.GetRule(gameId)
37	- result := utdto.Save(rule.DbMysql, data, rule.TableName)
38	- err = result.Error
39	- if err != nil {
40	- lxalilog.Errors(err, gameId)
41	- return
42	- }
43	- return
44	-}
45	-
46	-func First(data IDtoData, gameId string) (has bool, err error) {
47	- rule := data.GetRule(gameId)
48	- result := utdto.First(rule.DbMysql, data, rule.TableName)
49	- has = result.RowsAffected != 0
50	- err = result.Error
51	- if err != nil {
52	- lxalilog.Errors(err, gameId)
53	- return
54	- }
55	- return
56	-}
57	-
58	-func Find(data any, dataTemp IDtoData, gameId string) (has bool, err error) {
59	- rule := dataTemp.GetRule(gameId)
60	- result := utdto.Find(rule.DbMysql, data, rule.TableName)
61	- has = result.RowsAffected != 0
62	- err = result.Error
63	- if err != nil {
64	- lxalilog.Errors(err, rule.TableName)
65	- return
66	- }
67	- return
68	-}
	@@ -1,23 +0,0 @@	@@ -1,23 +0,0 @@
1	-package svdto
2	-
3	-import "gorm.io/gorm"
4	-
5	-const (
6	- REDIS_CACHEP_REFIX = "apigame" // 缓存前缀
7	-)
8	-
9	-// DtoRule dto参数
10	-type DtoRule struct {
11	- DbMysql *gorm.DB
12	- TableName string
13	- CacheKey string
14	- CacheTime int
15	-}
16	-
17	-// IDtoData dto数据
18	-type IDtoData interface {
19	- // TableName 表名模板
20	- TableName() string
21	- // GetRule 表名模板
22	- GetRule(gameId string) *DtoRule
23	-}
	@@ -1,10 +0,0 @@	@@ -1,10 +0,0 @@
1	-package svdto
2	-
3	-import (
4	- "apigame/util/utdto"
5	-)
6	-
7	-func SaveRecord(gameId string, data IDtoData) {
8	- rule := data.GetRule(gameId)
9	- utdto.Insert(rule.DbMysql, data, rule.TableName)
10	-}
	@@ -1,40 +0,0 @@	@@ -1,40 +0,0 @@
1	-package svlog
2	-
3	-import (
4	- "apigame/util/util-lx/lxalilog"
5	- "fmt"
6	- "github.com/astaxie/beego"
7	- lalilog "github.com/lixu-any/go-tools/ali/log"
8	-)
9	-
10	-func InitAliLog(appName string) {
11	-
12	- //初始化阿里云日志
13	- logm, _ := beego.AppConfig.GetSection("alilog")
14	- lxalilog.InitAliLog(lxalilog.MapAlilogConfig{
15	- Endpoint: logm["endpoint"],
16	- AccessKeyId: logm["accesskeyid"],
17	- AccessKeySecret: logm["accesskeysecret"],
18	- Project: logm["project"],
19	- AppNaame: appName,
20	- On: logm["on"],
21	- Debug: logm["debug"],
22	- TableError: "api_code_merge",
23	- TableDebug: logm["tabledebug"],
24	- Env: beego.AppConfig.String("env"),
25	- })
26	-
27	- lalilog.InitAliLog(lalilog.MapAlilogConfig{
28	- Endpoint: logm["endpoint"],
29	- AccessKeyId: logm["accesskeyid"],
30	- AccessKeySecret: logm["accesskeysecret"],
31	- Project: logm["project"],
32	- On: logm["on"],
33	- Debug: logm["debug"],
34	- TableError: logm["tableerror"],
35	- TableDebug: logm["tabledebug"],
36	- Env: beego.AppConfig.String("env"),
37	- })
38	-
39	- fmt.Println(appName + " alilog init success")
40	-}
	@@ -1,22 +0,0 @@	@@ -1,22 +0,0 @@
1	-package svlog
2	-
3	-import (
4	- "apigame/common/svconst"
5	- "apigame/util/util-lx/lxbeego"
6	- "fmt"
7	- "github.com/astaxie/beego"
8	-)
9	-
10	-func Init() {
11	-
12	- // 初始化日志文件
13	- conf, _ := beego.AppConfig.GetSection("log")
14	- conf["filename"] = conf["path"] + "api.log"
15	-
16	- if err := lxbeego.Inits(conf); err != nil {
17	- fmt.Println("svlog.Inits Error::" + err.Error())
18	- }
19	-
20	- fmt.Println(svconst.AppName + " svlog init success")
21	-
22	-}
	@@ -1,119 +0,0 @@	@@ -1,119 +0,0 @@
1	-package svmysql
2	-
3	-import (
4	- "apigame/common/svconst"
5	- "apigame/service/constd"
6	- "apigame/util/utdto"
7	- "apigame/util/util-lx/lxalilog"
8	- "fmt"
9	- "github.com/astaxie/beego"
10	- "gorm.io/gorm"
11	- "strings"
12	-)
13	-
14	-func Init() bool {
15	-
16	- // ConnectMySQL
17	- if db, err := utdto.ConnectMySQL(beego.AppConfig.String("mysql::" + constd.MYSQL_DBAPI)); err == nil {
18	- svconst.DbApi = db
19	- } else {
20	- fmt.Println("svmysql.Init DbApi Error::" + err.Error())
21	- return false
22	- }
23	- if db, err := utdto.ConnectMySQL(beego.AppConfig.String("mysql::mergecommon")); err == nil {
24	- svconst.DbCommon = db
25	- } else {
26	- fmt.Println("svmysql.Init DbCommon Error::" + err.Error())
27	- return false
28	- }
29	- if db, err := utdto.ConnectMySQL(beego.AppConfig.String("mysql::" + constd.MYSQL_MERGECONFIG)); err == nil {
30	- svconst.DbConfig = db
31	- } else {
32	- fmt.Println("svmysql.Init DbConfig Error::" + err.Error())
33	- return false
34	- }
35	- return true
36	-
37	-}
38	-
39	-func InitTable(obj IMysqlData, gameId string) {
40	- info := obj.MysqlInfo(gameId)
41	- utdto.InitTable(info.DbMysql, obj, info.TableName)
42	-}
43	-
44	-func Insert(obj IMysqlData, gameId string) (err error) {
45	- info := obj.MysqlInfo(gameId)
46	- db := info.DbMysql
47	- stmt := db.Session(&gorm.Session{DryRun: true}).Create(obj).Statement
48	- stmtSQL := stmt.SQL.String()
49	- sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
50	- result := db.Exec(sql, stmt.Vars...)
51	- err = result.Error
52	- if err != nil {
53	- lxalilog.Errors(err, gameId)
54	- return
55	- }
56	- return
57	-}
58	-
59	-func Updates(obj IMysqlData, gameId string) (err error) {
60	- info := obj.MysqlInfo(gameId)
61	- db := info.DbMysql
62	- stmt := db.Session(&gorm.Session{DryRun: true}).Updates(obj).Statement
63	- stmtSQL := stmt.SQL.String()
64	- sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
65	- result := db.Exec(sql, stmt.Vars...)
66	- err = result.Error
67	- if err != nil {
68	- lxalilog.Errors(err, gameId)
69	- return
70	- }
71	- return
72	-}
73	-
74	-func Save(obj IMysqlData, gameId string) (err error) {
75	- info := obj.MysqlInfo(gameId)
76	- db := info.DbMysql
77	- stmt := db.Session(&gorm.Session{DryRun: true}).Save(obj).Statement
78	- stmtSQL := stmt.SQL.String()
79	- sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
80	- result := db.Exec(sql, stmt.Vars...)
81	- err = result.Error
82	- if err != nil {
83	- lxalilog.Errors(err, gameId)
84	- return
85	- }
86	- return
87	-}
88	-
89	-func First(obj IMysqlData, gameId string) (has bool, err error) {
90	- info := obj.MysqlInfo(gameId)
91	- db := info.DbMysql
92	- stmt := db.Session(&gorm.Session{DryRun: true}).First(obj).Statement
93	- stmtSQL := stmt.SQL.String()
94	- sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
95	- result := db.Raw(sql, stmt.Vars...).Scan(obj)
96	- has = result.RowsAffected != 0
97	- err = result.Error
98	- if err != nil {
99	- lxalilog.Errors(err, gameId)
100	- return
101	- }
102	- return
103	-}
104	-
105	-func Find(obj IMysqlData, gameId string) (has bool, err error) {
106	- info := obj.MysqlInfo(gameId)
107	- db := info.DbMysql
108	- stmt := db.Session(&gorm.Session{DryRun: true}).Find(obj).Statement
109	- stmtSQL := stmt.SQL.String()
110	- sql := strings.Replace(stmtSQL, stmt.Table, info.TableName, -1)
111	- result := db.Raw(sql, stmt.Vars...).Scan(obj)
112	- has = result.RowsAffected != 0
113	- err = result.Error
114	- if err != nil {
115	- lxalilog.Errors(err, gameId)
116	- return
117	- }
118	- return
119	-}
	@@ -1,15 +0,0 @@	@@ -1,15 +0,0 @@
1	-package svmysql
2	-
3	-import "gorm.io/gorm"
4	-
5	-// MysqlInfo mysql存储信息
6	-type MysqlInfo struct {
7	- DbMysql *gorm.DB
8	- TableName string
9	-}
10	-
11	-// IMysqlData mysql存储对象
12	-type IMysqlData interface {
13	- // MysqlInfo mysql存储信息
14	- MysqlInfo(gameId string) *MysqlInfo
15	-}
	@@ -1,58 +0,0 @@	@@ -1,58 +0,0 @@
1	-package svredis
2	-
3	-import (
4	- "apigame/common/svconst"
5	- "apigame/util/utstring"
6	- "apigame/util/zjson"
7	- "apigame/util/zredis"
8	- "fmt"
9	- "github.com/astaxie/beego"
10	- "github.com/mitchellh/mapstructure"
11	-)
12	-
13	-type RedisConfig struct {
14	- Host string `json:"host"`
15	- Port string `json:"port"`
16	- Pwd string `json:"pwd"`
17	- Db string `json:"Db"`
18	- Prefix string `json:"prefix"`
19	-}
20	-
21	-func Init() bool {
22	- //初始化Redis
23	- confText, _ := beego.AppConfig.GetSection("redis")
24	- var conf RedisConfig
25	- err := mapstructure.Decode(confText, &conf)
26	- if err != nil {
27	- fmt.Println("svredis.Init mapstructure.Decode Error::" + err.Error())
28	- }
29	- zredis.Init(conf.Host+":"+conf.Port, conf.Pwd, utstring.StringToInt(conf.Db))
30	- if !zredis.Check() {
31	- return false
32	- }
33	-
34	- fmt.Println(svconst.AppName + " redis init success")
35	- return true
36	-}
37	-
38	-func SaveData(gameId string, obj IRedisData) {
39	- info := obj.RedisInfo(gameId)
40	- _ = zredis.SetEx(zredis.GetConn(), info.CacheKey, zjson.Str(obj), info.CacheTime)
41	-}
42	-
43	-func LoadData[T IRedisData](gameId string, obj T) (has bool) {
44	- has = true
45	- info := obj.RedisInfo(gameId)
46	- text, err := zredis.Get(zredis.GetConn(), info.CacheKey)
47	- if err != nil {
48	- has = false
49	- return
50	- }
51	- err = zjson.Obj(text, &obj)
52	- if err != nil {
53	- fmt.Println(err)
54	- has = false
55	- return
56	- }
57	- return
58	-}