update

data/DB_GameFree.json

@@ -6390,6 +6390,39 @@
 			],
 			"PlayerWaterRate": 100,
 			"BetWaterRate": 100
+		},
+		{
+			"Id": 6080001,
+			"Name": "娃娃机",
+			"Title": "1",
+			"GameId": 608,
+			"GameRule": 60800,
+			"GameType": 1,
+			"SceneType": 1,
+			"Desc": "0",
+			"ShowType": 3,
+			"ShowId": 60800,
+			"BaseScore": 1000,
+			"Turn": 60800,
+			"BetDec": "1000",
+			"Ai": [
+				0
+			],
+			"OtherIntParams": [
+				0
+			],
+			"RobotNumRng": [
+				0
+			],
+			"SameIpLimit": 1,
+			"GameDif": "608",
+			"GameClass": 2,
+			"PlatformName": "越南棋牌",
+			"MaxBetCoin": [
+				0
+			],
+			"PlayerWaterRate": 100,
+			"BetWaterRate": 100
 		}
 	]
 }

data/DB_GameRule.json

@@ -195,6 +195,11 @@
 			"Name": "多财多福",
 			"GameId": 307,
 			"GameDif": "307"
+		},
+		{
+			"Id": 60800,
+			"Name": "娃娃机",
+			"GameId": 608
 		}
 	]
 }

data/gameconfig/machine.json

@@ -0,0 +1,19 @@
+{
+	"GameName":"娃娃机",
+	"GameId":608,
+	"GameMode":[0],
+	"SceneType":[1],
+	"CanForceStart":false,
+	"MinPlayerCnt":1,
+	"DefaultPlayerCnt":1,
+	"MaxIndex":0,
+	"TimeFreeStart":0,
+	"TimeFreeEnd":0,
+	"DependentPlayerCnt":true,
+	"EnterAfterStart":false,
+	"PerGameTakeCard":100,
+	"ViewLogCnt":-1,
+	"BetState":0,
+	"Params":[
+	]
+}

protocol/clawdoll/clawdoll.proto

@@ -0,0 +1,103 @@
+syntax = "proto3";
+package clawdoll;
+option go_package = "mongo.games.com/game/protocol/clawdoll";
+
+//娃娃机
+enum CLAWDOLLPacketID {
+    PACKET_CLAWDOLL_ZERO = 0;              //弃用消息号
+    PACKET_SC_CLAWDOLL_ROOMINFO = 5601;    //房间信息
+    PACKET_CS_CLAWDOLL_PLAYEROP = 5602;    //玩家操作（客户->服务）
+    PACKET_SC_CLAWDOLL_PLAYEROP = 5603;    //玩家操作（服务->客户）
+    PACKET_SC_CLAWDOLL_ROOMSTATE = 5604;   //房间状态
+    PACKET_SC_CLAWDOLL_GAMEBILLED = 5605;  //游戏结算
+    PACKET_SC_CLAWDOLL_PlayerEnter = 5606; // 玩家进入
+    PACKET_SC_CLAWDOLL_PlayerLeave = 5607; // 玩家离开
+    PACKET_SC_CLAWDOLL_PLAYERINFO = 5608; // 玩家状态信息变化
+}
+
+//操作结果
+enum OpResultCode {
+    OPRC_Success = 0; //成功
+    OPRC_Error = 1; //失败
+    OPRC_CoinNotEnough = 2; //钱不够
+    OPRC_PosAlReadyPlaying = 3; //本局位置已存在玩家
+}
+
+message CLAWDOLLPlayerData {
+    string Name = 1;       //名字
+    int32 SnId = 2;        //账号
+    int32 Head = 3;        //头像
+    int32 Sex = 4;         //性别
+    int64 Coin = 5;        //金币
+    int32 HeadOutLine = 6; //头像框
+    int32 VIP = 7;
+    int32 Flag = 8;         //二进制标记 第一位:是否掉线(0:在线 1:掉线) 第二位:是否准备(0:未准备 1:已准备)
+
+    int64 WinCoin = 9;     // 本局赢分
+
+}
+
+//房间信息
+message SCCLAWDOLLRoomInfo {
+    int32 RoomId = 1;                 //房间id
+    int32 GameId = 2;                 //游戏id
+    int32 RoomMode = 3;               //游戏模式
+    repeated int32 Params = 4;        //规则参数
+    int32 State = 5;                  //房间当前状态
+    int32 TimeOut = 6;	              //该状态已经历时间 单位:秒
+    repeated CLAWDOLLPlayerData Players = 7;   //房间内的玩家信息
+    int32 TotalPlayer = 8;           //房间总人数
+	  int32 RoundId = 9;                //当前局数ID
+	  repeated int32 ParamsEx = 10;     //其他参数
+
+    int32 GameFreeId = 15;
+    int32 BaseScore = 16; //基础分
+}
+
+//玩家操作
+message CSCLAWDOLLOp {
+    int32 OpCode = 1;
+    repeated int64 Params = 2;
+}
+
+//玩家操作返回
+message SCCLAWDOLLOp {
+    int32 SnId = 1;                //玩家ID
+    int32 OpCode = 2;              //操作码
+    repeated int64 Params = 3;     //操作参数 同上 CSCLAWDOLLOp
+    OpResultCode OpRetCode = 4;    //操作结果
+}
+
+//发送给客户端的数据 单局结算
+message SCCLAWDOLLRoundGameBilled {
+	  int32 RoundId = 1;              //牌局ID
+    int32 ClowResult = 2;           //抓取结果
+    int64 Award = 3;                //获奖金额
+	  int64 Balance = 4;              //玩家余额
+}
+
+//房间状态
+message SCCLAWDOLLRoomState {
+    int32 State = 1; //房间当前状态
+    repeated float Params = 2;
+}
+
+//玩家信息
+message SCCLAWDOLLPlayerInfo {
+    int32 SnId = 1;                //玩家ID
+    int64 gainCoin = 2;             //本局赢取
+    int64 Coin = 3;                 // 玩家
+}
+
+
+//玩家进入
+//PACKET_SCCLAWDOLLPlayerEnter
+message SCCLAWDOLLPlayerEnter {
+    CLAWDOLLPlayerData Data = 1;
+}
+
+//玩家离开
+//PACKET_SCCLAWDOLLPlayerLeave
+message SCCLAWDOLLPlayerLeave {
+    int32 Pos = 1; //玩家位置
+}

protocol/dollmachine/dollmachine.pb.go

@@ -0,0 +1,537 @@
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// 	protoc-gen-go v1.27.1-devel
+// 	protoc        v3.19.4
+// source: dollmachine.proto
+
+package dollmachine
+
+import (
+	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+	reflect "reflect"
+	sync "sync"
+)
+
+const (
+	// Verify that this generated code is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+	// Verify that runtime/protoimpl is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
+
+//S-GAME M-娃娃机主机
+//娃娃机协议
+type DollMachinePacketID int32
+
+const (
+	DollMachinePacketID_PACKET_SMDollMachineZero DollMachinePacketID = 0
+	DollMachinePacketID_PACKET_SMDollMachineMove DollMachinePacketID = 3001
+	DollMachinePacketID_PACKET_SMDollMachineGrab DollMachinePacketID = 3002
+	DollMachinePacketID_PACKET_MSDollMachineGrab DollMachinePacketID = 3003
+	DollMachinePacketID_PACKET_MSDollMachineList DollMachinePacketID = 3004
+)
+
+// Enum value maps for DollMachinePacketID.
+var (
+	DollMachinePacketID_name = map[int32]string{
+		0:    "PACKET_SMDollMachineZero",
+		3001: "PACKET_SMDollMachineMove",
+		3002: "PACKET_SMDollMachineGrab",
+		3003: "PACKET_MSDollMachineGrab",
+		3004: "PACKET_MSDollMachineList",
+	}
+	DollMachinePacketID_value = map[string]int32{
+		"PACKET_SMDollMachineZero": 0,
+		"PACKET_SMDollMachineMove": 3001,
+		"PACKET_SMDollMachineGrab": 3002,
+		"PACKET_MSDollMachineGrab": 3003,
+		"PACKET_MSDollMachineList": 3004,
+	}
+)
+
+func (x DollMachinePacketID) Enum() *DollMachinePacketID {
+	p := new(DollMachinePacketID)
+	*p = x
+	return p
+}
+
+func (x DollMachinePacketID) String() string {
+	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
+}
+
+func (DollMachinePacketID) Descriptor() protoreflect.EnumDescriptor {
+	return file_dollmachine_proto_enumTypes[0].Descriptor()
+}
+
+func (DollMachinePacketID) Type() protoreflect.EnumType {
+	return &file_dollmachine_proto_enumTypes[0]
+}
+
+func (x DollMachinePacketID) Number() protoreflect.EnumNumber {
+	return protoreflect.EnumNumber(x)
+}
+
+// Deprecated: Use DollMachinePacketID.Descriptor instead.
+func (DollMachinePacketID) EnumDescriptor() ([]byte, []int) {
+	return file_dollmachine_proto_rawDescGZIP(), []int{0}
+}
+
+//移动
+type SMDollMachineMove struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Snid      int32 `protobuf:"varint,1,opt,name=Snid,proto3" json:"Snid,omitempty"`
+	Id        int32 `protobuf:"varint,2,opt,name=Id,proto3" json:"Id,omitempty"`               //娃娃机标识
+	Direction int32 `protobuf:"varint,3,opt,name=Direction,proto3" json:"Direction,omitempty"` // 1-前 2-后 3-左 4-右
+}
+
+func (x *SMDollMachineMove) Reset() {
+	*x = SMDollMachineMove{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_dollmachine_proto_msgTypes[0]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *SMDollMachineMove) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*SMDollMachineMove) ProtoMessage() {}
+
+func (x *SMDollMachineMove) ProtoReflect() protoreflect.Message {
+	mi := &file_dollmachine_proto_msgTypes[0]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use SMDollMachineMove.ProtoReflect.Descriptor instead.
+func (*SMDollMachineMove) Descriptor() ([]byte, []int) {
+	return file_dollmachine_proto_rawDescGZIP(), []int{0}
+}
+
+func (x *SMDollMachineMove) GetSnid() int32 {
+	if x != nil {
+		return x.Snid
+	}
+	return 0
+}
+
+func (x *SMDollMachineMove) GetId() int32 {
+	if x != nil {
+		return x.Id
+	}
+	return 0
+}
+
+func (x *SMDollMachineMove) GetDirection() int32 {
+	if x != nil {
+		return x.Direction
+	}
+	return 0
+}
+
+//下抓
+type SMDollMachineGrab struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	TypeId int32 `protobuf:"varint,1,opt,name=TypeId,proto3" json:"TypeId,omitempty"` //1-弱力抓 2 -强力抓 3-必出抓
+	Id     int32 `protobuf:"varint,2,opt,name=Id,proto3" json:"Id,omitempty"`         //娃娃机标识
+	Snid   int32 `protobuf:"varint,3,opt,name=Snid,proto3" json:"Snid,omitempty"`
+}
+
+func (x *SMDollMachineGrab) Reset() {
+	*x = SMDollMachineGrab{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_dollmachine_proto_msgTypes[1]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *SMDollMachineGrab) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*SMDollMachineGrab) ProtoMessage() {}
+
+func (x *SMDollMachineGrab) ProtoReflect() protoreflect.Message {
+	mi := &file_dollmachine_proto_msgTypes[1]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use SMDollMachineGrab.ProtoReflect.Descriptor instead.
+func (*SMDollMachineGrab) Descriptor() ([]byte, []int) {
+	return file_dollmachine_proto_rawDescGZIP(), []int{1}
+}
+
+func (x *SMDollMachineGrab) GetTypeId() int32 {
+	if x != nil {
+		return x.TypeId
+	}
+	return 0
+}
+
+func (x *SMDollMachineGrab) GetId() int32 {
+	if x != nil {
+		return x.Id
+	}
+	return 0
+}
+
+func (x *SMDollMachineGrab) GetSnid() int32 {
+	if x != nil {
+		return x.Snid
+	}
+	return 0
+}
+
+//返回下抓结果
+type MSDollMachineGrab struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Snid   int32 `protobuf:"varint,1,opt,name=Snid,proto3" json:"Snid,omitempty"`
+	Id     int32 `protobuf:"varint,2,opt,name=Id,proto3" json:"Id,omitempty"`         //娃娃机标识
+	Result int32 `protobuf:"varint,3,opt,name=Result,proto3" json:"Result,omitempty"` //1-中奖 其他未中奖
+}
+
+func (x *MSDollMachineGrab) Reset() {
+	*x = MSDollMachineGrab{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_dollmachine_proto_msgTypes[2]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *MSDollMachineGrab) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*MSDollMachineGrab) ProtoMessage() {}
+
+func (x *MSDollMachineGrab) ProtoReflect() protoreflect.Message {
+	mi := &file_dollmachine_proto_msgTypes[2]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use MSDollMachineGrab.ProtoReflect.Descriptor instead.
+func (*MSDollMachineGrab) Descriptor() ([]byte, []int) {
+	return file_dollmachine_proto_rawDescGZIP(), []int{2}
+}
+
+func (x *MSDollMachineGrab) GetSnid() int32 {
+	if x != nil {
+		return x.Snid
+	}
+	return 0
+}
+
+func (x *MSDollMachineGrab) GetId() int32 {
+	if x != nil {
+		return x.Id
+	}
+	return 0
+}
+
+func (x *MSDollMachineGrab) GetResult() int32 {
+	if x != nil {
+		return x.Result
+	}
+	return 0
+}
+
+//返回所有娃娃机连接
+type MSDollMachineList struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Data []*DollMachine `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
+}
+
+func (x *MSDollMachineList) Reset() {
+	*x = MSDollMachineList{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_dollmachine_proto_msgTypes[3]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *MSDollMachineList) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*MSDollMachineList) ProtoMessage() {}
+
+func (x *MSDollMachineList) ProtoReflect() protoreflect.Message {
+	mi := &file_dollmachine_proto_msgTypes[3]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use MSDollMachineList.ProtoReflect.Descriptor instead.
+func (*MSDollMachineList) Descriptor() ([]byte, []int) {
+	return file_dollmachine_proto_rawDescGZIP(), []int{3}
+}
+
+func (x *MSDollMachineList) GetData() []*DollMachine {
+	if x != nil {
+		return x.Data
+	}
+	return nil
+}
+
+type DollMachine struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Id     int32 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
+	Status int32 `protobuf:"varint,2,opt,name=Status,proto3" json:"Status,omitempty"` //1-空闲 2-无法使用
+}
+
+func (x *DollMachine) Reset() {
+	*x = DollMachine{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_dollmachine_proto_msgTypes[4]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *DollMachine) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*DollMachine) ProtoMessage() {}
+
+func (x *DollMachine) ProtoReflect() protoreflect.Message {
+	mi := &file_dollmachine_proto_msgTypes[4]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use DollMachine.ProtoReflect.Descriptor instead.
+func (*DollMachine) Descriptor() ([]byte, []int) {
+	return file_dollmachine_proto_rawDescGZIP(), []int{4}
+}
+
+func (x *DollMachine) GetId() int32 {
+	if x != nil {
+		return x.Id
+	}
+	return 0
+}
+
+func (x *DollMachine) GetStatus() int32 {
+	if x != nil {
+		return x.Status
+	}
+	return 0
+}
+
+var File_dollmachine_proto protoreflect.FileDescriptor
+
+var file_dollmachine_proto_rawDesc = []byte{
+	0x0a, 0x11, 0x64, 0x6f, 0x6c, 0x6c, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x2e, 0x70, 0x72,
+	0x6f, 0x74, 0x6f, 0x12, 0x0b, 0x64, 0x6f, 0x6c, 0x6c, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65,
+	0x22, 0x55, 0x0a, 0x11, 0x53, 0x4d, 0x44, 0x6f, 0x6c, 0x6c, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e,
+	0x65, 0x4d, 0x6f, 0x76, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x53, 0x6e, 0x69, 0x64, 0x18, 0x01, 0x20,
+	0x01, 0x28, 0x05, 0x52, 0x04, 0x53, 0x6e, 0x69, 0x64, 0x12, 0x0e, 0x0a, 0x02, 0x49, 0x64, 0x18,
+	0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x02, 0x49, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x44, 0x69, 0x72,
+	0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x44, 0x69,
+	0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x4f, 0x0a, 0x11, 0x53, 0x4d, 0x44, 0x6f, 0x6c,
+	0x6c, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x47, 0x72, 0x61, 0x62, 0x12, 0x16, 0x0a, 0x06,
+	0x54, 0x79, 0x70, 0x65, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x54, 0x79,
+	0x70, 0x65, 0x49, 0x64, 0x12, 0x0e, 0x0a, 0x02, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05,
+	0x52, 0x02, 0x49, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x53, 0x6e, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01,
+	0x28, 0x05, 0x52, 0x04, 0x53, 0x6e, 0x69, 0x64, 0x22, 0x4f, 0x0a, 0x11, 0x4d, 0x53, 0x44, 0x6f,
+	0x6c, 0x6c, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x47, 0x72, 0x61, 0x62, 0x12, 0x12, 0x0a,
+	0x04, 0x53, 0x6e, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x53, 0x6e, 0x69,
+	0x64, 0x12, 0x0e, 0x0a, 0x02, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x02, 0x49,
+	0x64, 0x12, 0x16, 0x0a, 0x06, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28,
+	0x05, 0x52, 0x06, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0x41, 0x0a, 0x11, 0x4d, 0x53, 0x44,
+	0x6f, 0x6c, 0x6c, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x2c,
+	0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x64,
+	0x6f, 0x6c, 0x6c, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x2e, 0x44, 0x6f, 0x6c, 0x6c, 0x4d,
+	0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0x35, 0x0a, 0x0b,
+	0x44, 0x6f, 0x6c, 0x6c, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x49,
+	0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x02, 0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x53,
+	0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x53, 0x74, 0x61,
+	0x74, 0x75, 0x73, 0x2a, 0xaf, 0x01, 0x0a, 0x13, 0x44, 0x6f, 0x6c, 0x6c, 0x4d, 0x61, 0x63, 0x68,
+	0x69, 0x6e, 0x65, 0x50, 0x61, 0x63, 0x6b, 0x65, 0x74, 0x49, 0x44, 0x12, 0x1c, 0x0a, 0x18, 0x50,
+	0x41, 0x43, 0x4b, 0x45, 0x54, 0x5f, 0x53, 0x4d, 0x44, 0x6f, 0x6c, 0x6c, 0x4d, 0x61, 0x63, 0x68,
+	0x69, 0x6e, 0x65, 0x5a, 0x65, 0x72, 0x6f, 0x10, 0x00, 0x12, 0x1d, 0x0a, 0x18, 0x50, 0x41, 0x43,
+	0x4b, 0x45, 0x54, 0x5f, 0x53, 0x4d, 0x44, 0x6f, 0x6c, 0x6c, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e,
+	0x65, 0x4d, 0x6f, 0x76, 0x65, 0x10, 0xb9, 0x17, 0x12, 0x1d, 0x0a, 0x18, 0x50, 0x41, 0x43, 0x4b,
+	0x45, 0x54, 0x5f, 0x53, 0x4d, 0x44, 0x6f, 0x6c, 0x6c, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65,
+	0x47, 0x72, 0x61, 0x62, 0x10, 0xba, 0x17, 0x12, 0x1d, 0x0a, 0x18, 0x50, 0x41, 0x43, 0x4b, 0x45,
+	0x54, 0x5f, 0x4d, 0x53, 0x44, 0x6f, 0x6c, 0x6c, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x47,
+	0x72, 0x61, 0x62, 0x10, 0xbb, 0x17, 0x12, 0x1d, 0x0a, 0x18, 0x50, 0x41, 0x43, 0x4b, 0x45, 0x54,
+	0x5f, 0x4d, 0x53, 0x44, 0x6f, 0x6c, 0x6c, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x4c, 0x69,
+	0x73, 0x74, 0x10, 0xbc, 0x17, 0x42, 0x2b, 0x5a, 0x29, 0x6d, 0x6f, 0x6e, 0x67, 0x6f, 0x2e, 0x67,
+	0x61, 0x6d, 0x65, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x61, 0x6d, 0x65, 0x2f, 0x70, 0x72,
+	0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2f, 0x64, 0x6f, 0x6c, 0x6c, 0x6d, 0x61, 0x63, 0x68, 0x69,
+	0x6e, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+}
+
+var (
+	file_dollmachine_proto_rawDescOnce sync.Once
+	file_dollmachine_proto_rawDescData = file_dollmachine_proto_rawDesc
+)
+
+func file_dollmachine_proto_rawDescGZIP() []byte {
+	file_dollmachine_proto_rawDescOnce.Do(func() {
+		file_dollmachine_proto_rawDescData = protoimpl.X.CompressGZIP(file_dollmachine_proto_rawDescData)
+	})
+	return file_dollmachine_proto_rawDescData
+}
+
+var file_dollmachine_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
+var file_dollmachine_proto_msgTypes = make([]protoimpl.MessageInfo, 5)
+var file_dollmachine_proto_goTypes = []interface{}{
+	(DollMachinePacketID)(0),  // 0: dollmachine.DollMachinePacketID
+	(*SMDollMachineMove)(nil), // 1: dollmachine.SMDollMachineMove
+	(*SMDollMachineGrab)(nil), // 2: dollmachine.SMDollMachineGrab
+	(*MSDollMachineGrab)(nil), // 3: dollmachine.MSDollMachineGrab
+	(*MSDollMachineList)(nil), // 4: dollmachine.MSDollMachineList
+	(*DollMachine)(nil),       // 5: dollmachine.DollMachine
+}
+var file_dollmachine_proto_depIdxs = []int32{
+	5, // 0: dollmachine.MSDollMachineList.data:type_name -> dollmachine.DollMachine
+	1, // [1:1] is the sub-list for method output_type
+	1, // [1:1] is the sub-list for method input_type
+	1, // [1:1] is the sub-list for extension type_name
+	1, // [1:1] is the sub-list for extension extendee
+	0, // [0:1] is the sub-list for field type_name
+}
+
+func init() { file_dollmachine_proto_init() }
+func file_dollmachine_proto_init() {
+	if File_dollmachine_proto != nil {
+		return
+	}
+	if !protoimpl.UnsafeEnabled {
+		file_dollmachine_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*SMDollMachineMove); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_dollmachine_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*SMDollMachineGrab); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_dollmachine_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*MSDollMachineGrab); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_dollmachine_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*MSDollMachineList); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_dollmachine_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*DollMachine); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+	}
+	type x struct{}
+	out := protoimpl.TypeBuilder{
+		File: protoimpl.DescBuilder{
+			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+			RawDescriptor: file_dollmachine_proto_rawDesc,
+			NumEnums:      1,
+			NumMessages:   5,
+			NumExtensions: 0,
+			NumServices:   0,
+		},
+		GoTypes:           file_dollmachine_proto_goTypes,
+		DependencyIndexes: file_dollmachine_proto_depIdxs,
+		EnumInfos:         file_dollmachine_proto_enumTypes,
+		MessageInfos:      file_dollmachine_proto_msgTypes,
+	}.Build()
+	File_dollmachine_proto = out.File
+	file_dollmachine_proto_rawDesc = nil
+	file_dollmachine_proto_goTypes = nil
+	file_dollmachine_proto_depIdxs = nil
+}

protocol/dollmachine/dollmachine.proto

@@ -0,0 +1,43 @@
+syntax = "proto3";
+package dollmachine;
+option go_package = "mongo.games.com/game/protocol/dollmachine";
+
+//S-GAME M-娃娃机主机
+//娃娃机协议
+enum DollMachinePacketID {
+	PACKET_SMDollMachineZero = 0; 
+	PACKET_SMDollMachineMove  = 3001;
+	PACKET_SMDollMachineGrab = 3002;
+	PACKET_MSDollMachineGrab = 3003;
+	PACKET_MSDollMachineList = 3004;
+}
+
+//移动
+message SMDollMachineMove{
+	int32 Snid = 1;
+	int32 Id = 2;	//娃娃机标识
+	int32 Direction = 3; // 1-前 2-后 3-左 4-右
+}
+
+//下抓
+message SMDollMachineGrab{
+	int32 TypeId = 1;//1-弱力抓 2 -强力抓 3-必出抓
+	int32 Id =2; //娃娃机标识
+	int32 Snid = 3;
+}
+
+//返回下抓结果
+message MSDollMachineGrab{
+	int32 Snid = 1;
+	int32 Id = 2; //娃娃机标识
+	int32 Result = 3;//1-中奖 其他未中奖
+}
+
+//返回所有娃娃机连接
+message MSDollMachineList{
+	repeated DollMachine data = 1;
+}
+message DollMachine{
+	int32 Id = 1;
+	int32 Status = 2;	//1-空闲 2-无法使用
+}