diff --git a/comm/const.go b/comm/const.go index 331aefcef..250bf6e0e 100644 --- a/comm/const.go +++ b/comm/const.go @@ -124,7 +124,7 @@ const ( ModuleEgghunt core.M_Modules = "egghunt" //彩蛋 ModuleCatchbugs core.M_Modules = "catchbugs" //捉虫子 ModuleMoonlv core.M_Modules = "moonlv" //护月等级 - ModuleWhackamole core.M_Modules = "whackamole" //大豚鼠 + ModuleWhackamole core.M_Modules = "whackamole" //打豚鼠 ModuleMonkey core.M_Modules = "monkey" //猴拳 ModuleIntegral core.M_Modules = "integral" // 积分boss ) diff --git a/modules/robot/modulerobot_dispatch.go b/modules/robot/modulerobot_dispatch.go new file mode 100644 index 000000000..d94cb88b8 --- /dev/null +++ b/modules/robot/modulerobot_dispatch.go @@ -0,0 +1,53 @@ +package robot + +import ( + "errors" + "fmt" + "go_dreamfactory/pb" + cfg "go_dreamfactory/sys/configure/structs" + + "google.golang.org/protobuf/proto" +) + +//派遣模块 机器人 +type ModuleRobot_Dispatch struct { + dispatch *pb.Noticeboard +} + +func (this *ModuleRobot_Dispatch) Init() (err error) { + + return +} + +//接收到消息 +func (this *ModuleRobot_Dispatch) Receive(robot IRobot, stype string, message proto.Message) (err error) { + switch stype { + case "notice": + resp := message.(*pb.DispatchNoticeResp) + this.dispatch = resp.Dispatch + break + } + return +} +func (this *ModuleRobot_Dispatch) OncePipeline(robot IRobot) (err error) { + var ( + errdata *pb.ErrorData + ) + if _, errdata = robot.SendMessage("dispatch", "notice", &pb.DispatchNoticeReq{}); errdata != nil { + err = errors.New(fmt.Sprintf("code:%d message:%s", errdata.Code, errdata.Message)) + return + } + return +} + +//机器人执行流 +func (this *ModuleRobot_Dispatch) DoPipeline(robot IRobot) (err error) { + + return +} + +//做任务 +func (this *ModuleRobot_Dispatch) DoTask(robot IRobot, taskconf *cfg.GameWorldTaskData, condconf *cfg.GameBuriedCondiData) (err error) { + + return +}