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

道具分解api补充

Browse Source
This commit is contained in:
liwei1dao 2022-11-22 14:06:08 +08:00
parent a1a15aaef8
commit d95ece7464
2 changed files with 81 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

78
modules/items/api_decompose.go Normal file
View File

@ -0,0 +1,78 @@
package items
import (
"go_dreamfactory/comm"
"go_dreamfactory/pb"
cfg "go_dreamfactory/sys/configure/structs"
"google.golang.org/protobuf/proto"
)
//参数校验
func (this *apiComp) SellItemCheck(session comm.IUserSession, req *pb.ItemsSellItemReq) (code pb.ErrorCode) {
if req.GridId == "" || req.Amount <= 0 {
code = pb.ErrorCode_ReqParameterError
}
return
}
//出售道具
func (this *apiComp) SellItem(session comm.IUserSession, req *pb.ItemsSellItemReq) (code pb.ErrorCode, data proto.Message) {
var (
err error
item *pb.DB_UserItemData
itemcf *cfg.GameItemData
sale []*cfg.Gameatn
)
if code = this.SellItemCheck(session, req); code != pb.ErrorCode_Success {
return
}
if item, err = this.module.modelItems.QueryUserPackByGridId(session.GetUserId(), req.GridId); err != nil {
code = pb.ErrorCode_ReqParameterError
return
}
if itemcf, err = this.module.configure.GetItemConfigure(item.ItemId); err != nil {
code = pb.ErrorCode_ConfigurationException
return
}
if itemcf.Sale == nil || len(itemcf.Sale) == 0 {
code = pb.ErrorCode_ItemsUseNoCanSell
return
}
if itemcf.DecomposeDeplete == nil || len(itemcf.DecomposeDeplete) == 0 {
code = pb.ErrorCode_ItemsUseNoCanSell
return
}
sale = make([]*cfg.Gameatn, 0, len(itemcf.DecomposeDeplete))
for _, v := range itemcf.DecomposeDeplete {
sale = append(sale, &cfg.Gameatn{
A: v.A,
T: v.T,
N: v.N * int32(req.Amount),
})
}
if code = this.module.ConsumeRes(session, sale, true); code != pb.ErrorCode_Success {
return
}
if req.Amount > item.Amount {
code = pb.ErrorCode_ReqParameterError
this.module.Errorf("SellItemCheck over all amount:[%d:%d]", req.Amount, item.Amount)
return
}
sale = make([]*cfg.Gameatn, len(itemcf.Sale))
for i, v := range itemcf.Sale {
temp := *v
sale[i] = &temp
sale[i].N = v.N * int32(req.Amount)
}
if code = this.module.DispenseRes(session, sale, true); code != pb.ErrorCode_Success {
return
}
item.Amount = item.Amount - req.Amount
if code = this.module.AddItemforGrid(session, req.GridId, -1*int32(req.Amount), true); code != pb.ErrorCode_Success {
return
}
session.SendMsg(string(this.module.GetType()), "sellitem", &pb.ItemsSellItemResp{GridId: req.GridId, Amount: req.Amount, Issucc: true})
return
}

17
modules/items/api_sellItem.go
View File

@ -9,7 +9,7 @@ import (
)
//参数校验
func (this *apiComp) SellItemCheck(session comm.IUserSession, req *pb.ItemsSellItemReq) (code pb.ErrorCode) {
func (this *apiComp) DecomposeCheck(session comm.IUserSession, req *pb.ItemsDecomposeReq) (code pb.ErrorCode) {
if req.GridId == "" || req.Amount <= 0 {
code = pb.ErrorCode_ReqParameterError
}
@ -17,14 +17,14 @@ func (this *apiComp) SellItemCheck(session comm.IUserSession, req *pb.ItemsSellI
}
//出售道具
func (this *apiComp) SellItem(session comm.IUserSession, req *pb.ItemsSellItemReq) (code pb.ErrorCode, data proto.Message) {
func (this *apiComp) Decompose(session comm.IUserSession, req *pb.ItemsDecomposeReq) (code pb.ErrorCode, data proto.Message) {
var (
err error
item *pb.DB_UserItemData
itemcf *cfg.GameItemData
sale []*cfg.Gameatn
)
if code = this.SellItemCheck(session, req); code != pb.ErrorCode_Success {
if code = this.DecomposeCheck(session, req); code != pb.ErrorCode_Success {
return
}
if item, err = this.module.modelItems.QueryUserPackByGridId(session.GetUserId(), req.GridId); err != nil {
@ -57,17 +57,6 @@ func (this *apiComp) SellItem(session comm.IUserSession, req *pb.ItemsSellItemRe
if code = this.module.AddItemforGrid(session, req.GridId, -1*int32(req.Amount), true); code != pb.ErrorCode_Success {
return
}
// if item.Amount == 0 {
// if err = this.module.modelItems.DelUserPack(session.GetUserId(), item.GridId); err != nil {
// code = pb.ErrorCode_DBError
// return
// }
// } else {
// if err = this.module.modelItems.UpdateUserPack(session.GetUserId(), item); err != nil {
// code = pb.ErrorCode_DBError
// return
// }
// }
session.SendMsg(string(this.module.GetType()), "sellitem", &pb.ItemsSellItemResp{GridId: req.GridId, Amount: req.Amount, Issucc: true})
return
}