78 lines
1.6 KiB
Go
78 lines
1.6 KiB
Go
package guildgve_test
|
|
|
|
import (
|
|
"fmt"
|
|
"go_dreamfactory/comm"
|
|
"go_dreamfactory/lego"
|
|
"go_dreamfactory/lego/base/rpcx"
|
|
"go_dreamfactory/lego/core"
|
|
"go_dreamfactory/lego/sys/log"
|
|
"go_dreamfactory/modules/chat"
|
|
"go_dreamfactory/services"
|
|
"go_dreamfactory/sys/db"
|
|
"os"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/go-redis/redis/v8"
|
|
)
|
|
|
|
func newService(ops ...rpcx.Option) core.IService {
|
|
s := new(TestService)
|
|
s.Configure(ops...)
|
|
return s
|
|
}
|
|
|
|
// 梦工厂基础服务对象
|
|
type TestService struct {
|
|
services.ServiceBase
|
|
}
|
|
|
|
// 初始化相关系统
|
|
func (this *TestService) InitSys() {
|
|
this.ServiceBase.InitSys()
|
|
if err := db.OnInit(this.GetSettings().Sys["db"], db.SetServiceId(this.GetTag())); err != nil {
|
|
panic(fmt.Sprintf("init sys.db err: %s", err.Error()))
|
|
} else {
|
|
log.Infof("init sys.db success!")
|
|
}
|
|
}
|
|
|
|
var service core.IService
|
|
var s_gateComp comm.ISC_GateRouteComp = services.NewGateRouteComp()
|
|
var module = new(chat.Chat)
|
|
|
|
// 测试环境下初始化db和cache 系统
|
|
func TestMain(m *testing.M) {
|
|
service = newService(
|
|
rpcx.SetConfPath("../../bin/conf/dfli_worker0.yaml"),
|
|
rpcx.SetVersion("1.0.0.0"),
|
|
)
|
|
service.OnInstallComp( //装备组件
|
|
s_gateComp, //此服务需要接受用户的消息 需要装备网关组件
|
|
)
|
|
go func() {
|
|
lego.Run(service) //运行模块
|
|
|
|
}()
|
|
time.Sleep(time.Second * 3)
|
|
defer os.Exit(m.Run())
|
|
}
|
|
|
|
func Test_Module(t *testing.T) {
|
|
var (
|
|
key string
|
|
score float64
|
|
menbers *redis.Z
|
|
conn *db.DBConn
|
|
err error
|
|
)
|
|
key = "guildgvebattlerank:3"
|
|
score = 1
|
|
menbers = &redis.Z{Score: (score), Member: "member"}
|
|
conn, err = db.Local()
|
|
if err = conn.Redis.ZAdd(key, menbers); err != nil {
|
|
log.Errorln(err)
|
|
}
|
|
}
|