go_dreamfactory/modules/plunder/api_reach.go
2024-01-18 20:22:17 +08:00

74 lines
1.7 KiB
Go

package plunder
import (
"go_dreamfactory/comm"
"go_dreamfactory/pb"
)
// 参数校验
func (this *apiComp) ReachCheck(session comm.IUserSession, req *pb.PlunderReachReq) (errdata *pb.ErrorData) {
if len(req.Oid) == 0 {
errdata = &pb.ErrorData{
Code: pb.ErrorCode_ReqParameterError,
Title: pb.ErrorCode_ReqParameterError.ToString(),
}
}
return
}
// 船准备出发
func (this *apiComp) Reach(session comm.IUserSession, req *pb.PlunderReachReq) (errdata *pb.ErrorData) {
var (
err error
list *pb.DBPlunder
land *pb.DBPlunderLand // 岛屿数据
)
if errdata = this.ReachCheck(session, req); errdata != nil {
return // 参数校验失败直接返回
}
if list, err = this.module.modelPlunder.getPlunderData(session.GetUserId()); err != nil {
errdata = &pb.ErrorData{
Code: pb.ErrorCode_DBError,
Message: err.Error(),
}
return
}
if land, err = this.module.modelLand.getPlunderLandData(list.Landid); err != nil {
errdata = &pb.ErrorData{
Code: pb.ErrorCode_DBError,
Message: err.Error(),
}
return
}
for _, oid := range req.Oid {
if _, ok := land.Ship[oid]; !ok {
errdata = &pb.ErrorData{
Code: pb.ErrorCode_DBError,
Message: err.Error(),
}
return
} else {
for _, v := range list.Line {
if v.Oid == oid {
v.Oid = ""
}
}
delete(land.Ship, oid)
}
}
this.module.modelPlunder.changePlunderData(session.GetUserId(), map[string]interface{}{
"line": list.Line,
})
this.module.modelLand.changePlunderLandData(land.Id, map[string]interface{}{
"ship": land.Ship,
})
session.SendMsg(string(this.module.GetType()), "reach", &pb.PlunderReachResp{
Line: []*pb.PlunderLine{},
Ship: land.Ship,
})
return
}