支持怀旧端的gm配置

Author: liuguangw

bhandler/enter_game_handler.go

@@ -1,7 +1,10 @@
 package bhandler
 
 import (
+	"strconv"
+
 	"github.com/liuguangw/billing_go/common"
+	"github.com/liuguangw/billing_go/models"
 	"github.com/liuguangw/billing_go/services"
 	"golang.org/x/text/encoding/simplifiedchinese"
 )
@@ -40,6 +43,8 @@ func (h *EnterGameHandler) GetResponse(request *common.BillingPacket) *common.Bi
 		CharName: string(charName),
 	}
 	markOnline(h.Resource.LoginUsers, h.Resource.OnlineUsers, h.Resource.MacCounters, string(username), clientInfo)
+	//角色id
+	charguid := packetReader.ReadInt()
 	//
 	h.Resource.Logger.Info("user [" + string(username) + "] " + string(charName) + " entered game")
 	//Packets::BLRetBillingStart
@@ -58,6 +63,18 @@ func (h *EnterGameHandler) GetResponse(request *common.BillingPacket) *common.Bi
 		padLen = 16
 	}
 	extraData := make([]byte, padLen)
+	//检查角色是否为gm(仅限怀旧)
+	if h.BillType == common.BillTypeHuaiJiu {
+		if isGm, err := models.CheckIsGm(h.Resource.Db, charguid); err != nil {
+			h.Resource.Logger.Error("check is gm failed: " + err.Error())
+		} else {
+			// 登录的角色为gm
+			if isGm {
+				extraData[padLen-1] = 1
+				h.Resource.Logger.Info(string(charName) + "(guid: " + strconv.Itoa(charguid) + ") is gm")
+			}
+		}
+	}
 	opData = append(opData, extraData...)
 	response.OpData = opData
 	return response

common/billing_packet.go

@@ -121,7 +121,7 @@ func (packet *BillingPacket) String() string {
 }
 
 // InitBillingPacketHead 初始化头部标识
-func InitBillingPacketHead(billType byte) {
+func InitBillingPacketHead(billType int) {
 	if billType == BillTypeCommon {
 		BillingPacketHead = [2]byte{0xAA, 0x55}
 	} else if billType == BillTypeHuaiJiu {

models/account_cfg.go

@@ -0,0 +1,7 @@
+package models
+
+// AccountCfg GM配置
+type AccountCfg struct {
+	Charguid int //角色id
+	Isgm     int //是否为gm
+}

models/check_gm.go

@@ -0,0 +1,20 @@
+package models
+
+import "database/sql"
+
+// CheckIsGm 查询角色是否为gm,怀旧专用
+func CheckIsGm(db *sql.DB, charguid int) (bool, error) {
+	var accountCfg AccountCfg
+	row := db.QueryRow("SELECT charguid, isgm FROM account_cfg WHERE charguid=?", charguid)
+	if err := row.Err(); err != nil {
+		return false, err
+	}
+	if err := row.Scan(&accountCfg.Charguid, &accountCfg.Isgm); err != nil {
+		if err == sql.ErrNoRows {
+			// 查询不到此记录
+			return false, nil
+		}
+		return false, err
+	}
+	return accountCfg.Isgm > 0, nil
+}

services/billing/server.go

@@ -29,7 +29,7 @@ func NewServer() (*Server, error) {
 		return nil, err
 	}
 	//初始化头部标识
-	common.InitBillingPacketHead(byte(serverConfig.BillType))
+	common.InitBillingPacketHead(serverConfig.BillType)
 	return &Server{config: serverConfig}, nil
 }