250 lines
7.0 KiB
Go
250 lines
7.0 KiB
Go
package caravan
|
|
|
|
import (
|
|
"go_dreamfactory/comm"
|
|
"go_dreamfactory/lego/sys/log"
|
|
"go_dreamfactory/pb"
|
|
cfg "go_dreamfactory/sys/configure/structs"
|
|
)
|
|
|
|
//参数校验
|
|
func (this *apiComp) BuyOrSellCheck(session comm.IUserSession, req *pb.CaravanBuyOrSellReq) (errdata *pb.ErrorData) {
|
|
if len(req.Items) == 0 || req.City == 0 {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_ReqParameterError,
|
|
Title: pb.ErrorCode_ReqParameterError.ToString(),
|
|
}
|
|
}
|
|
return
|
|
}
|
|
|
|
func (this *apiComp) BuyOrSell(session comm.IUserSession, req *pb.CaravanBuyOrSellReq) (errdata *pb.ErrorData) {
|
|
var (
|
|
update map[string]interface{}
|
|
addScore int32 // 收益
|
|
cityInfo *pb.CityInfo
|
|
ok bool
|
|
)
|
|
update = make(map[string]interface{})
|
|
if errdata = this.BuyOrSellCheck(session, req); errdata != nil {
|
|
return // 参数校验失败直接返回
|
|
}
|
|
caravan, _ := this.module.modelCaravan.getCaravanList(session.GetUserId())
|
|
|
|
if cityInfo, ok = caravan.City[req.City]; !ok {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_ConfigNoFound,
|
|
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
|
}
|
|
return
|
|
}
|
|
c, err := this.module.configure.GetCaravanLv(caravan.Lv)
|
|
if err != nil {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_ConfigNoFound,
|
|
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
|
Message: err.Error(),
|
|
}
|
|
return
|
|
}
|
|
caravan.Baglimit = c.Bagtop
|
|
// special 城市卖给玩家的商品
|
|
// exspecial 城市想要玩家卖给他的商品库
|
|
if !req.IsBuy { // 卖给npc
|
|
|
|
var cb int32 // 成本价
|
|
for k, v := range req.Items {
|
|
// 校验背包数据够不够
|
|
caravan.Items[k].Count -= v
|
|
if caravan.Items[k].Count < 0 {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_TrollItemNoEnough, // 道具数量不足
|
|
Title: pb.ErrorCode_TrollItemNoEnough.ToString(),
|
|
}
|
|
return
|
|
}
|
|
items := caravan.Items[k]
|
|
var price int32
|
|
cb = items.Price // 获取成本价
|
|
price = items.Price
|
|
bFound := false
|
|
for _, v := range cityInfo.Special {
|
|
if v == k {
|
|
if cityConf, err := this.module.configure.GetCaravanCity(req.City); err == nil {
|
|
price = cityConf.Specialnum * price / 1000
|
|
bFound = true
|
|
} else {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_TrollItemNoEnough, // 道具数量不足
|
|
Title: pb.ErrorCode_TrollItemNoEnough.ToString(),
|
|
Message: err.Error(),
|
|
}
|
|
return
|
|
}
|
|
break
|
|
}
|
|
}
|
|
if !bFound {
|
|
price = cityInfo.ExspecialPCT * price / 1000
|
|
}
|
|
if price > cb { // 赚了
|
|
addScore = (price - cb) * v // 卖出收益
|
|
if err := this.module.ModuleUser.AddUserProfit(session.GetUserId(), int64(addScore)); err != nil {
|
|
this.module.Error("玩家Profit更新",
|
|
log.Field{Key: "uid", Value: session.GetUserId()},
|
|
log.Field{Key: "update", Value: update},
|
|
)
|
|
return
|
|
}
|
|
}
|
|
|
|
if errdata = this.module.DispenseRes(session, []*cfg.Gameatn{{
|
|
A: "attr",
|
|
T: "merchantmoney",
|
|
N: price * v,
|
|
}}, true); errdata != nil {
|
|
this.module.Errorf("获得虚拟币失败:%v", errdata)
|
|
}
|
|
//addScore += price * v // 卖出收益
|
|
}
|
|
this.module.ArrayBag(caravan)
|
|
// 统计 收益
|
|
var lvReward []*cfg.Gameatn
|
|
caravan.Profit += int64(addScore)
|
|
update["profit"] = caravan.Profit
|
|
curLv := this.module.CheckCaravavLvUp(caravan)
|
|
if curLv > caravan.Lv {
|
|
for i := caravan.Lv; i <= curLv-caravan.Lv; i++ {
|
|
if c, err := this.module.configure.GetCaravanLv(int32(i)); err == nil {
|
|
lvReward = append(lvReward, c.Reward...)
|
|
update["lv"] = curLv
|
|
update["baglimit"] = c.Bagtop
|
|
} else {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_ConfigNoFound, // 道具数量不足
|
|
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
|
Message: err.Error(),
|
|
}
|
|
return
|
|
}
|
|
}
|
|
caravan.Lv = curLv
|
|
// update user caravanlv
|
|
if err = this.module.ModuleUser.SetUserCaravanLvChange(session, curLv); err != nil {
|
|
this.module.Errorf("update caravanlv error: %v", err)
|
|
}
|
|
}
|
|
if len(lvReward) > 0 { // 商队等级奖励
|
|
if reward := this.module.DispenseRes(session, lvReward, true); reward != nil {
|
|
this.module.Errorf("lv reward dispenseRes err:%v", lvReward)
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_ConfigNoFound, // 道具数量不足
|
|
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
|
Message: err.Error(),
|
|
}
|
|
return
|
|
}
|
|
}
|
|
|
|
// 商队盈利收益奖励
|
|
reward := this.configure.GetCaravanReward()
|
|
for _, v := range reward {
|
|
if v.Key > 0 {
|
|
if caravan.Profit > int64(v.Key) {
|
|
if _, ok := caravan.Reward[v.Key]; !ok {
|
|
var res []*pb.UserAssets
|
|
for _, v1 := range v.Reward {
|
|
res = append(res, &pb.UserAssets{
|
|
A: v1.A,
|
|
T: v1.T,
|
|
N: v1.N,
|
|
})
|
|
}
|
|
this.module.ModuleMail.SendMailByCid(session, "CaravanProfitRewards", res)
|
|
caravan.Reward[v.Key] = true
|
|
update["reward"] = caravan.Reward
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else { // 买入
|
|
for k, v := range req.Items {
|
|
if _, ok := caravan.Items[k]; !ok {
|
|
caravan.Items[k] = &pb.BagInfo{
|
|
Count: 0,
|
|
Price: 0,
|
|
}
|
|
}
|
|
bFound := false
|
|
// 计算均价
|
|
totla := caravan.Items[k].Count * caravan.Items[k].Price
|
|
var price int32
|
|
price = caravan.Goods[k].Price
|
|
for _, v := range cityInfo.Special {
|
|
if v == k {
|
|
bFound = true
|
|
break
|
|
}
|
|
}
|
|
if !bFound {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_TrollCityUnSellItem, // 城市不卖这个物品
|
|
Title: pb.ErrorCode_TrollCityUnSellItem.ToString(),
|
|
}
|
|
return
|
|
}
|
|
caravan.Items[k].Count += v
|
|
|
|
totla += price * v
|
|
caravan.Items[k].Price = totla / caravan.Items[k].Count
|
|
// 同步更新该城市的 出售货物信息
|
|
cityInfo.Count[k] += v
|
|
|
|
if itemConf, err := this.configure.GetCaravanGoods(k); err == nil { // 更新商店库存
|
|
if cityInfo.Count[k] > itemConf.Goodsnum {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_TrollBuyMax, // 商品数量不足
|
|
Title: pb.ErrorCode_TrollBuyMax.ToString(),
|
|
}
|
|
return
|
|
}
|
|
update["city"] = caravan.City
|
|
addScore -= price * v
|
|
} else {
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_ConfigNoFound, // 商品数量不足
|
|
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
|
Message: err.Error(),
|
|
}
|
|
return
|
|
}
|
|
}
|
|
if this.module.CheckOverweight(caravan) { // 背包满了
|
|
errdata = &pb.ErrorData{
|
|
Code: pb.ErrorCode_TrollMaxItemCount,
|
|
Title: pb.ErrorCode_TrollMaxItemCount.ToString(),
|
|
}
|
|
return
|
|
}
|
|
|
|
// 减少虚拟币
|
|
// caravan.Merchantmoney -= addScore
|
|
// update["merchantmoney"] = caravan.Merchantmoney
|
|
if errdata = this.module.DispenseRes(session, []*cfg.Gameatn{{
|
|
A: "attr",
|
|
T: "merchantmoney",
|
|
N: addScore,
|
|
}}, true); errdata != nil {
|
|
this.module.Errorf("获得虚拟币失败:%v", errdata)
|
|
}
|
|
}
|
|
|
|
update["items"] = caravan.Items
|
|
update["baglimit"] = caravan.Baglimit
|
|
this.module.modelCaravan.modifyCaravanDataByObjId(session.GetUserId(), update)
|
|
session.SendMsg(string(this.module.GetType()), "buyorsell", &pb.CaravanBuyOrSellResp{
|
|
Data: caravan,
|
|
})
|
|
return
|
|
}
|