娃娃机log打印修改

This commit is contained in:
by 2024-08-26 10:50:03 +08:00
parent ba9dde2005
commit 377482ce6d
2 changed files with 14 additions and 16 deletions

View File

@ -169,11 +169,11 @@ func DollMachineGrabResult(session *netlib.Session, conn *machinedoll.Conn, snid
num := int64(1) num := int64(1)
for { for {
// 读取数据 // 读取数据
fmt.Println("监听抓取结果返回!") logger.Logger.Trace("监听抓取结果返回!")
buf := make([]byte, 1024) buf := make([]byte, 1024)
n, err := conn.Read(buf) n, err := conn.Read(buf)
if err != nil { if err != nil {
fmt.Println("Failed to read response from client:", err) logger.Logger.Error("Failed to read response from client:", err)
return return
} }
// 将读取到的数据按照 221 进行分割 // 将读取到的数据按照 221 进行分割
@ -185,7 +185,7 @@ func DollMachineGrabResult(session *netlib.Session, conn *machinedoll.Conn, snid
for i, part := range parts { for i, part := range parts {
if len(part) > 0 { if len(part) > 0 {
part = part[:len(part)-1] // 去除最后一个字节,该字节为分隔符 part = part[:len(part)-1] // 去除最后一个字节,该字节为分隔符
fmt.Println("比较返回结果 part = ", part) //fmt.Println("比较返回结果 part = ", part)
if bytes.Contains(part, instruction) && num != 1 { if bytes.Contains(part, instruction) && num != 1 {
fmt.Printf("Part %d: %s\n", i+1, part) fmt.Printf("Part %d: %s\n", i+1, part)
//回应数据 //回应数据
@ -200,7 +200,7 @@ func DollMachineGrabResult(session *netlib.Session, conn *machinedoll.Conn, snid
Result: 0, Result: 0,
TypeId: 2, TypeId: 2,
}) })
fmt.Println("没有抓到礼品snid = ", snid, "num = ", num) logger.Logger.Trace("没有抓到礼品snid = ", snid, "num = ", num)
return return
} }
if bytes.Contains(part, instruction1) && num != 1 { if bytes.Contains(part, instruction1) && num != 1 {
@ -208,7 +208,7 @@ func DollMachineGrabResult(session *netlib.Session, conn *machinedoll.Conn, snid
//回应数据 //回应数据
_, err = conn.Write([]byte{0xAA, 0x04, 0x01, 0x50, 0x09, 0x5c, 0xdd}) _, err = conn.Write([]byte{0xAA, 0x04, 0x01, 0x50, 0x09, 0x5c, 0xdd})
if err != nil { if err != nil {
fmt.Println("Failed to read response from server:", err) logger.Logger.Error("Failed to read response from server:", err)
return return
} }
session.Send(int(machine.DollMachinePacketID_PACKET_MSDollMachineoPerateResult), &machine.MSDollMachineoPerateResult{ session.Send(int(machine.DollMachinePacketID_PACKET_MSDollMachineoPerateResult), &machine.MSDollMachineoPerateResult{
@ -217,14 +217,13 @@ func DollMachineGrabResult(session *netlib.Session, conn *machinedoll.Conn, snid
Result: 1, Result: 1,
TypeId: 2, TypeId: 2,
}) })
fmt.Println("抓到礼品了snid = ", snid, "num = ", num) logger.Logger.Trace("抓到礼品了snid = ", snid, "num = ", num)
return return
} }
//上分成功 //上分成功
coinData := []byte{0xAA, 0x04, 0x02, 0x03, 0x01} coinData := []byte{0xAA, 0x04, 0x02, 0x03, 0x01}
if bytes.Contains(part, coinData) { if bytes.Contains(part, coinData) {
//返回消息 //返回消息
fmt.Println("上分成功!")
session.Send(int(machine.DollMachinePacketID_PACKET_MSDollMachineoPerateResult), &machine.MSDollMachineoPerateResult{ session.Send(int(machine.DollMachinePacketID_PACKET_MSDollMachineoPerateResult), &machine.MSDollMachineoPerateResult{
Snid: snid, Snid: snid,
Id: id, Id: id,
@ -236,7 +235,6 @@ func DollMachineGrabResult(session *netlib.Session, conn *machinedoll.Conn, snid
coinData = []byte{0xAA, 0x04, 0x02, 0x03, 0x00} coinData = []byte{0xAA, 0x04, 0x02, 0x03, 0x00}
if bytes.Contains(part, coinData) { if bytes.Contains(part, coinData) {
//返回消息 //返回消息
fmt.Println("上分失败!")
session.Send(int(machine.DollMachinePacketID_PACKET_MSDollMachineoPerateResult), &machine.MSDollMachineoPerateResult{ session.Send(int(machine.DollMachinePacketID_PACKET_MSDollMachineoPerateResult), &machine.MSDollMachineoPerateResult{
Snid: snid, Snid: snid,
Id: id, Id: id,
@ -295,10 +293,10 @@ func SMGetTokenHandler(session *netlib.Session, packetId int, data interface{})
//生成token //生成token
token, err := token04.GenerateToken04(appId, string(userId), serverSecret, effectiveTimeInSeconds, payload) token, err := token04.GenerateToken04(appId, string(userId), serverSecret, effectiveTimeInSeconds, payload)
if err != nil { if err != nil {
fmt.Println(err) logger.Logger.Error(err)
return err return err
} }
fmt.Println(token) logger.Logger.Trace(token)
info := &machine.MSSendToken{} info := &machine.MSSendToken{}
info.Snid = msg.Snid info.Snid = msg.Snid
info.Token = token info.Token = token

View File

@ -46,11 +46,11 @@ func (this *MachineManager) Init() {
var serverAddrs []string var serverAddrs []string
programDir, err := os.Getwd() programDir, err := os.Getwd()
if err != nil { if err != nil {
fmt.Println("Error getting working directory:", err) logger.Logger.Error("Error getting working directory:", err)
return return
} }
configFile := filepath.Join(programDir, "machineIPConfig.json") configFile := filepath.Join(programDir, "machineIPConfig.json")
fmt.Println("构建配置文件的路径", configFile) logger.Logger.Trace("构建配置文件的路径", configFile)
fileData, err := os.ReadFile(configFile) fileData, err := os.ReadFile(configFile)
if err != nil { if err != nil {
logger.Logger.Error("Read robot account file error:", err) logger.Logger.Error("Read robot account file error:", err)
@ -66,7 +66,7 @@ func (this *MachineManager) Init() {
for i, addr := range serverAddrs { for i, addr := range serverAddrs {
conn, err := net.DialTimeout("tcp", addr, 5*time.Second) conn, err := net.DialTimeout("tcp", addr, 5*time.Second)
if err != nil { if err != nil {
fmt.Println("Failed to connect to server:", err) logger.Logger.Error("Failed to connect to server:", err)
continue continue
} }
this.ConnMap[i+1] = &Conn{ this.ConnMap[i+1] = &Conn{
@ -75,7 +75,7 @@ func (this *MachineManager) Init() {
Addr: addr, Addr: addr,
} }
SetBaseParam(conn) SetBaseParam(conn)
fmt.Println("设置每台娃娃机基础配置!") logger.Logger.Trace("设置每台娃娃机基础配置!")
} }
/* fmt.Println("Connected to server:\n", this.ConnMap[1].RemoteAddr()) /* fmt.Println("Connected to server:\n", this.ConnMap[1].RemoteAddr())
@ -98,7 +98,7 @@ func (this *MachineManager) Update() {
delConn = append(delConn, v) delConn = append(delConn, v)
v.Close() v.Close()
logger.Logger.Tracef("断开连接:%v", v.Addr) logger.Logger.Tracef("断开连接:%v", v.Addr)
fmt.Println("娃娃机断开连接!!!!!!!!!!!") logger.Logger.Error("娃娃机断开连接!!!!!!!!!!!")
this.UpdateToGameServer(v, 0) this.UpdateToGameServer(v, 0)
} }
} }
@ -118,7 +118,7 @@ func (this *MachineManager) Update() {
continue continue
} }
logger.Logger.Tracef("重连成功:%v", addr) logger.Logger.Tracef("重连成功:%v", addr)
fmt.Println("娃娃机重连成功!!!!!!!!!!!") logger.Logger.Trace("娃娃机重连成功!!!!!!!!!!!")
delIds = append(delIds, &Conn{ delIds = append(delIds, &Conn{
Id: id, Id: id,
Conn: conn, Conn: conn,