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

爬塔db 错误

Browse Source
This commit is contained in:
meixiongfeng 2022-08-16 10:30:03 +08:00
parent 9a040f7b94
commit 42ee59ff2f
2 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
modules/pagoda/api_getlist.go
View File

@ -16,28 +16,25 @@ func (this *apiComp) GetListCheck(session comm.IUserSession, req *pb.PagodaGetLi
///获取主线关卡信息 ///获取主线关卡信息
func (this *apiComp) GetList(session comm.IUserSession, req *pb.PagodaGetListReq) (code pb.ErrorCode, data proto.Message) { func (this *apiComp) GetList(session comm.IUserSession, req *pb.PagodaGetListReq) (code pb.ErrorCode, data proto.Message) {
_data := &pb.DBPagoda{}
code = this.GetListCheck(session, req) code = this.GetListCheck(session, req)
if code != pb.ErrorCode_Success { if code != pb.ErrorCode_Success {
return // 参数校验失败直接返回 return // 参数校验失败直接返回
} }
list, err := this.module.modelPagoda.getPagodaList(session.GetUserId()) list, _ := this.module.modelPagoda.getPagodaList(session.GetUserId())
if err != nil {
code = pb.ErrorCode_DBError
return
}
if list == nil { // redis没有数据 if list == nil { // redis没有数据
_data.Id = primitive.NewObjectID().Hex() list.Id = primitive.NewObjectID().Hex()
_mData := make(map[string]interface{}, 0) _mData := make(map[string]interface{}, 0)
_data.Uid = session.GetUserId() list.Uid = session.GetUserId()
_mData[_data.Id] = _data _mData[list.Id] = list
this.module.modelPagoda.addNewPagoda(session.GetUserId(), _mData) this.module.modelPagoda.addNewPagoda(session.GetUserId(), _mData)
} }
session.SendMsg(string(this.module.GetType()), PagodaGetListResp, &pb.PagodaGetListResp{Data: _data}) session.SendMsg(string(this.module.GetType()), PagodaGetListResp, &pb.PagodaGetListResp{Data: list})
return return
} }

7
modules/pagoda/model_pagoda.go
View File

@ -24,7 +24,10 @@ func (this *ModelPagoda) Init(service core.IService, module core.IModule, comp c
// 获取爬塔信息 // 获取爬塔信息
func (this *ModelPagoda) getPagodaList(uid string) (result *pb.DBPagoda, err error) { func (this *ModelPagoda) getPagodaList(uid string) (result *pb.DBPagoda, err error) {
result = &pb.DBPagoda{} result = &pb.DBPagoda{}
if err = this.Get(uid, result); err != nil && redis.RedisNil != err { if err = this.Get(uid, result); err != nil {
if redis.RedisNil != err {
result = nil
}
return return
} }
err = nil err = nil
@ -39,7 +42,7 @@ func (this *ModelPagoda) modifyPagodaDataByObjId(uid string, objid string, data
// 创建一个新的塔数据 // 创建一个新的塔数据
func (this *ModelPagoda) addNewPagoda(uId string, data map[string]interface{}) (err error) { func (this *ModelPagoda) addNewPagoda(uId string, data map[string]interface{}) (err error) {
if err = this.AddLists(uId, data); err != nil { if err = this.Add(uId, data); err != nil {
this.module.Errorf("err:%v", err) this.module.Errorf("err:%v", err)
return return
} }