错误信息输出

This commit is contained in:
meixiongfeng 2024-01-19 21:51:48 +08:00
parent 12909167e9
commit 0960ffa71d
2 changed files with 12 additions and 9 deletions

View File

@ -80,7 +80,9 @@ func (this *modelLand) createPlunderLandData(uid string) (land *pb.DBPlunderLand
} }
} }
} }
info, _ = this.module.modelPlunder.queryPlunderInfos(uids, land.Id) if info, err = this.module.modelPlunder.queryPlunderInfos(uids, land.Id); err != nil {
return
}
for _, v := range info { for _, v := range info {
if v.Landid != "" { // 过滤 if v.Landid != "" { // 过滤

View File

@ -128,19 +128,19 @@ func (this *modelPlunder) queryPlunderInfos(uids []string, landid string) (data
var ( var (
mp map[string]struct{} // 没找到的数据 mp map[string]struct{} // 没找到的数据
results []*pb.DBPlunder results []*pb.DBPlunder
onfound []string //onfound []string
newdata map[string]interface{} = make(map[string]interface{}) newdata map[string]interface{} = make(map[string]interface{})
unfound []string unfound []string
) )
results = make([]*pb.DBPlunder, 0) results = make([]*pb.DBPlunder, 0)
mp = make(map[string]struct{}) mp = make(map[string]struct{})
if onfound, err = this.Gets(uids, &results); err != nil { if _, err = this.Gets(uids, &results); err != nil {
this.module.Errorln(err) this.module.Errorln(err)
return return
} }
for _, v := range onfound { for _, v := range results {
mp[v] = struct{}{} mp[v.Uid] = struct{}{}
} }
for _, v := range uids { for _, v := range uids {
if _, ok := mp[v]; !ok { if _, ok := mp[v]; !ok {
@ -167,10 +167,11 @@ func (this *modelPlunder) queryPlunderInfos(uids []string, landid string) (data
break break
} }
} }
if len(newdata) > 0 {
if err = this.Adds(newdata); err != nil { if err = this.Adds(newdata); err != nil {
this.module.Errorln(err) this.module.Errorln(err)
return return
}
} }
for _, v := range results { for _, v := range results {