From 7400fe71ae5b1c8abcb634b351a813bef93d5421 Mon Sep 17 00:00:00 2001
From: liwei1dao <liwei1dao@gmail.com>
Date: Tue, 26 Dec 2023 09:56:29 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E8=A1=A5=E5=85=85=E6=B4=BE?=
 =?UTF-8?q?=E9=81=A3=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 comm/const.go                         |  2 +-
 modules/robot/modulerobot_dispatch.go | 53 +++++++++++++++++++++++++++
 2 files changed, 54 insertions(+), 1 deletion(-)
 create mode 100644 modules/robot/modulerobot_dispatch.go

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
+}