liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

上传代码

Browse Source
This commit is contained in:
liwei1dao 2022-11-19 00:45:25 +08:00
parent 8329f8c19c
commit 07bd5cbf8a
2 changed files with 47 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
sys/configure/configure.go
View File

@ -249,12 +249,12 @@ func (this *Configure) readoffsettime() {
err error err error
) )
if file, err = os.Open(this.options.TimestampFile); err != nil { if file, err = os.Open(this.options.TimestampFile); err != nil {
log.Errorf("[Configure Sys] readoffsettime err:%v", err) // log.Errorf("[Configure Sys] readoffsettime err:%v", err)
return return
} }
defer file.Close() defer file.Close()
if data, err = ioutil.ReadAll(file); err != nil { if data, err = ioutil.ReadAll(file); err != nil {
log.Errorf("[Configure Sys] readoffsettime err:%v", err) // log.Errorf("[Configure Sys] readoffsettime err:%v", err)
return return
} }
offtimeStr = codec.BytesToString(data) offtimeStr = codec.BytesToString(data)
@ -268,7 +268,7 @@ func (this *Configure) writeoffsettime(offset time.Duration) {
err error err error
) )
if file, err = os.OpenFile(this.options.TimestampFile, os.O_CREATE|os.O_WRONLY|os.O_TRUNC, 0666); err != nil { if file, err = os.OpenFile(this.options.TimestampFile, os.O_CREATE|os.O_WRONLY|os.O_TRUNC, 0666); err != nil {
log.Errorf("[Configure Sys] writeoffsettime err:%v", err) // log.Errorf("[Configure Sys] writeoffsettime err:%v", err)
return return
} }
defer file.Close() defer file.Close()

44
sys/db/init_test.go
View File

@ -6,6 +6,7 @@ import (
"go_dreamfactory/comm" "go_dreamfactory/comm"
"go_dreamfactory/lego/core" "go_dreamfactory/lego/core"
"go_dreamfactory/lego/sys/mgo" "go_dreamfactory/lego/sys/mgo"
"go_dreamfactory/lego/sys/redis"
"go_dreamfactory/pb" "go_dreamfactory/pb"
"math/rand" "math/rand"
"sync" "sync"
@ -14,6 +15,7 @@ import (
"go.mongodb.org/mongo-driver/bson" "go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/bson/primitive" "go.mongodb.org/mongo-driver/bson/primitive"
"go.mongodb.org/mongo-driver/mongo" "go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options" "go.mongodb.org/mongo-driver/mongo/options"
) )
@ -81,3 +83,45 @@ func Test_2D(t *testing.T) {
} }
} }
} }
//测试api_getlist
func Test_Json_RTask(t *testing.T) {
if sys, err := redis.NewSys(
redis.SetRedisType(redis.Redis_Single),
redis.SetRedis_Single_Addr("10.0.0.9:10011"),
redis.SetRedis_Single_Password("li13451234"),
redis.SetRedis_Single_DB(3),
); err != nil {
fmt.Printf("err:%v", err)
return
} else {
// ret, err := json.MarshalMap(&pb.DBRtaskRecord{
// Id: "ASDASD",
// Uid: "ASDASDASD",
// Vals: map[int32]*pb.RtaskData{
// 1: {Data: map[int32]int32{1: 2}, Rtype: 2, Timestamp: 12312},
// },
// })
err = sys.HMSet("test001", &pb.DBRtaskRecord{
Id: "ASDASD",
Uid: "ASDASDASD",
Vals: map[int32]*pb.RtaskData{
1: {Data: map[int32]int32{1: 2}, Rtype: 2, Timestamp: 12312},
},
})
fmt.Printf("err:%v", err)
}
// sys.
// fmt.Printf("ret:%v err:%v", ret, err)
// ret, err = json.MarshalMap(&TestData{
// Name: "asdasd",
// Age: 10,
// List: []string{"12asd3", "45sdaa6", "asdasd"},
// Map: map[string]interface{}{
// "asd": 586,
// "asdasd": "asd1231",
// },
// })
// fmt.Printf("ret:%v err:%v", ret, err)
}