类型同步修改

This commit is contained in:
meixiongfeng 2022-06-17 14:11:12 +08:00
parent ce3440d7f9
commit a54dcebfe9
6 changed files with 15 additions and 26 deletions

View File

@ -190,12 +190,12 @@ func Test_Redis_Encoder_Hash(t *testing.T) {
// fmt.Printf("data:%v err:%v\n", data, err) // fmt.Printf("data:%v err:%v\n", data, err)
// redis.HSet("test:1003", "Name", "eeee") // redis.HSet("test:1003", "Name", "eeee")
// name := "" name := ""
// err := redis.HGet("test:103", "name", &name) err := redis.HGet("test:103", "name", &name)
// if err != nil { if err != nil {
// fmt.Println(err) fmt.Println(err)
// } }
// fmt.Println(name) fmt.Println(name)
// data1 := map[string]*TestData{"li_1": {Name: "liwei2dao", Agr: 56}, "li_2": {Name: "liwei3dao", Agr: 78}} // data1 := map[string]*TestData{"li_1": {Name: "liwei2dao", Agr: 56}, "li_2": {Name: "liwei3dao", Agr: 78}}
// err := redis.HMSet("test:1004", data1) // err := redis.HMSet("test:1004", data1)
@ -203,15 +203,4 @@ func Test_Redis_Encoder_Hash(t *testing.T) {
// data2 := make(map[string]*TestData) // data2 := make(map[string]*TestData)
// err = redis.HGetAll("test:1004", data2) // err = redis.HGetAll("test:1004", data2)
// fmt.Printf("data2:%v err:%v\n", data2, err) // fmt.Printf("data2:%v err:%v\n", data2, err)
// d1 := map[string]interface{}{"ll": "1", "age": 20}
// err := redis.HMSet("test:104", d1)
// fmt.Printf("err:%v\n", err)
// d2 := make(map[string]interface{})
// err := redis.HGetAll("test:105", d2)
// fmt.Printf("data2:%v err:%v\n", d2, err)
iskeep, err := redis.ExistsKey("test:105")
fmt.Printf("ok:%v err:%v\n", iskeep, err)
} }

View File

@ -7,12 +7,12 @@ import (
) )
//参数校验 //参数校验
func (this *Api_Comp) DelUserMailReq_Check(session comm.IUserSession, req *pb.Mail_DelMail_Req) (result map[string]interface{}, code comm.ErrorCode) { func (this *Api_Comp) DelMail_Check(session comm.IUserSession, req *pb.Mail_DelMail_Req) (result map[string]interface{}, code comm.ErrorCode) {
return return
} }
// 删除邮件 // 删除邮件
func (this *Api_Comp) DelUserMailReq(session comm.IUserSession, agrs map[string]interface{}, req *pb.Mail_DelMail_Req) (code pb.ErrorCode) { func (this *Api_Comp) DelMail(session comm.IUserSession, agrs map[string]interface{}, req *pb.Mail_DelMail_Req) (code pb.ErrorCode) {
var err error var err error
mailinfo := make([]*pb.DB_MailData, 0) mailinfo := make([]*pb.DB_MailData, 0)
defer func() { defer func() {

View File

@ -5,12 +5,12 @@ import (
"go_dreamfactory/pb" "go_dreamfactory/pb"
) )
func (this *Api_Comp) Mail_GetUserMailAttachment_Req_Check(session comm.IUserSession, req *pb.Mail_GetUserMailAttachment_Req) (result map[string]interface{}, code comm.ErrorCode) { func (this *Api_Comp) GetUserMailAttachment_Check(session comm.IUserSession, req *pb.Mail_GetUserMailAttachment_Req) (result map[string]interface{}, code comm.ErrorCode) {
return return
} }
// 领取附件 // 领取附件
func (this *Api_Comp) Mail_GetUserMailAttachment_Req(session comm.IUserSession, agrs map[string]interface{}, req *pb.Mail_GetUserMailAttachment_Req) (code pb.ErrorCode) { func (this *Api_Comp) GetUserMailAttachment(session comm.IUserSession, agrs map[string]interface{}, req *pb.Mail_GetUserMailAttachment_Req) (code pb.ErrorCode) {
var ( var (
mail *pb.DB_MailData mail *pb.DB_MailData

View File

@ -6,12 +6,12 @@ import (
"go_dreamfactory/pb" "go_dreamfactory/pb"
) )
func (this *Api_Comp) Mail_GetList_Req_Check(session comm.IUserSession, req *pb.Mail_GetList_Req) (result map[string]interface{}, code comm.ErrorCode) { func (this *Api_Comp) GetList_Check(session comm.IUserSession, req *pb.Mail_GetList_Req) (result map[string]interface{}, code comm.ErrorCode) {
return return
} }
// 查看所有邮件信息 // 查看所有邮件信息
func (this *Api_Comp) Mail_GetList_Req(session comm.IUserSession, agrs map[string]interface{}, req *pb.Mail_GetList_Req) (code pb.ErrorCode) { func (this *Api_Comp) GetList(session comm.IUserSession, agrs map[string]interface{}, req *pb.Mail_GetList_Req) (code pb.ErrorCode) {
var err error var err error
mailinfo := make([]*pb.DB_MailData, 0) mailinfo := make([]*pb.DB_MailData, 0)

View File

@ -5,12 +5,12 @@ import (
"go_dreamfactory/pb" "go_dreamfactory/pb"
) )
func (this *Api_Comp) Mail_ReadMail_Req_Check(session comm.IUserSession, req *pb.Mail_ReadMail_Req) (result map[string]interface{}, code comm.ErrorCode) { func (this *Api_Comp) ReadMail_Check(session comm.IUserSession, req *pb.Mail_ReadMail_Req) (result map[string]interface{}, code comm.ErrorCode) {
return return
} }
// 查看某一封邮件 // 查看某一封邮件
func (this *Api_Comp) Mail_ReadMail_Req(session comm.IUserSession, agrs map[string]interface{}, req *pb.Mail_ReadMail_Req) (code pb.ErrorCode) { func (this *Api_Comp) ReadMail(session comm.IUserSession, agrs map[string]interface{}, req *pb.Mail_ReadMail_Req) (code pb.ErrorCode) {
var ( var (
err error err error
mail *pb.DB_MailData mail *pb.DB_MailData

View File

@ -12,7 +12,7 @@ func (this *Api_Comp) Useitem_Check(session comm.IUserSession, req *pb.Pack_UseI
} }
//使用道具 //使用道具
func (this *Api_Comp) Useitem(session comm.IUserSession, agrs map[string]interface{}, req *pb.Pack_UseItem_Resp) (code pb.ErrorCode) { func (this *Api_Comp) Useitem(session comm.IUserSession, agrs map[string]interface{}, req *pb.Pack_UseItem_Req) (code pb.ErrorCode) {
defer func() { defer func() {
session.SendMsg(string(this.module.GetType()), UseItemResp, &pb.Pack_UseItem_Resp{}) session.SendMsg(string(this.module.GetType()), UseItemResp, &pb.Pack_UseItem_Resp{})
}() }()