diff --git a/modules/items/api_decompose.go b/modules/items/api_decompose.go new file mode 100644 index 000000000..37d71d452 --- /dev/null +++ b/modules/items/api_decompose.go @@ -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 +} diff --git a/modules/items/api_sellItem.go b/modules/items/api_sellItem.go index 9e0705b67..57ce30d2c 100644 --- a/modules/items/api_sellItem.go +++ b/modules/items/api_sellItem.go @@ -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 }