118 lines
2.8 KiB
Go
118 lines
2.8 KiB
Go
package robot
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"go_dreamfactory/comm"
|
|
"go_dreamfactory/pb"
|
|
cfg "go_dreamfactory/sys/configure/structs"
|
|
|
|
"google.golang.org/protobuf/proto"
|
|
)
|
|
|
|
//用户模块 机器人
|
|
type ModuleRobot_Shop struct {
|
|
goods map[int32][]*pb.ShopItem
|
|
}
|
|
|
|
func (this *ModuleRobot_Shop) Init() (err error) {
|
|
this.goods = make(map[int32][]*pb.ShopItem)
|
|
return
|
|
}
|
|
|
|
//接收到消息
|
|
func (this *ModuleRobot_Shop) Receive(robot IRobot, stype string, message proto.Message) (err error) {
|
|
switch stype {
|
|
case "getlist":
|
|
resp := message.(*pb.ShopGetListResp)
|
|
this.goods[resp.SType] = resp.Goods
|
|
break
|
|
}
|
|
return
|
|
}
|
|
func (this *ModuleRobot_Shop) OncePipeline(robot IRobot) (err error) {
|
|
var (
|
|
errdata *pb.ErrorData
|
|
)
|
|
if _, errdata = robot.SendMessage("shop", "getlist", &pb.ShopGetListReq{
|
|
SType: 1,
|
|
}); errdata != nil {
|
|
err = errors.New(fmt.Sprintf("code:%d message:%s", errdata.Code, errdata.Message))
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
//机器人执行流
|
|
func (this *ModuleRobot_Shop) DoPipeline(robot IRobot) (err error) {
|
|
var (
|
|
errdata *pb.ErrorData
|
|
usermodule *ModuleRobot_User
|
|
)
|
|
usermodule = robot.GetModule(comm.ModuleUser).(*ModuleRobot_User)
|
|
for _, v := range this.goods[1] {
|
|
if v.LeftBuyNum > 0 && usermodule.user.Gold >= int64(v.Consume[0].N) {
|
|
if _, errdata = robot.SendMessage("shop", "buy", &pb.ShopBuyReq{
|
|
ShopType: 1,
|
|
Gid: v.Gid,
|
|
BuyNum: 1,
|
|
}); errdata != nil {
|
|
err = errors.New(fmt.Sprintf("code:%d message:%s", errdata.Code, errdata.Message))
|
|
return
|
|
}
|
|
v.LeftBuyNum--
|
|
break
|
|
}
|
|
}
|
|
for _, v := range this.goods[2] {
|
|
if v.LeftBuyNum > 0 && usermodule.user.Diamond >= int64(v.Consume[0].N) {
|
|
if _, errdata = robot.SendMessage("shop", "buy", &pb.ShopBuyReq{
|
|
ShopType: 2,
|
|
Gid: v.Gid,
|
|
BuyNum: 1,
|
|
}); errdata != nil {
|
|
err = errors.New(fmt.Sprintf("code:%d message:%s", errdata.Code, errdata.Message))
|
|
return
|
|
}
|
|
break
|
|
}
|
|
}
|
|
return
|
|
}
|
|
|
|
//做任务
|
|
func (this *ModuleRobot_Shop) DoTask(robot IRobot, taskconf *cfg.GameWorldTaskData, condconf *cfg.GameBuriedCondiData) (err error) {
|
|
var (
|
|
errdata *pb.ErrorData
|
|
)
|
|
switch comm.TaskType(condconf.Type) {
|
|
case comm.Rtype104:
|
|
var (
|
|
usermodule *ModuleRobot_User
|
|
)
|
|
usermodule = robot.GetModule(comm.ModuleUser).(*ModuleRobot_User)
|
|
if _, errdata = robot.SendMessage("shop", "getlist", &pb.ShopGetListReq{
|
|
SType: 2,
|
|
}); errdata != nil {
|
|
err = errors.New(fmt.Sprintf("code:%d message:%s", errdata.Code, errdata.Message))
|
|
return
|
|
}
|
|
|
|
for _, v := range this.goods[2] {
|
|
if v.LeftBuyNum > 0 && usermodule.user.Diamond >= int64(v.Consume[0].N) {
|
|
if _, errdata = robot.SendMessage("shop", "buy", &pb.ShopBuyReq{
|
|
ShopType: 2,
|
|
Gid: v.Gid,
|
|
BuyNum: 1,
|
|
}); errdata != nil {
|
|
err = errors.New(fmt.Sprintf("code:%d message:%s", errdata.Code, errdata.Message))
|
|
return
|
|
}
|
|
break
|
|
}
|
|
}
|
|
|
|
}
|
|
return
|
|
}
|