修复停止的信号

internal/middleware/bgm.go

@@ -32,7 +32,6 @@ func PlayBgm() leaf.HandlerFunc {
 
 			wait.Add(1)
 			go func() {
-				// 等待结束
 				defer wait.Done()
 
 				logger.Infoln("开始播放背景音乐")
@@ -41,7 +40,7 @@ func PlayBgm() leaf.HandlerFunc {
 				ctrl, closer, e := audio.PlayBgmMP3(bgm)
 				defer closer()
 				if e != nil {
-					logger.Errorln("播放背景音乐失败", e)
+					logger.Errorln("播放背景音乐异常", e)
 					return
 				}
 

internal/middleware/stop.go

@@ -17,14 +17,15 @@ func EmergencyStop(stopper common.Stopper) leaf.HandlerFunc {
 		// 发送结束信号
 		defer close(a)
 
+		logger.Infoln("监听停止信号")
 		go func() {
-			defer logger.Infoln("结束停止信号监控")
+			defer logger.Infoln("结束停止信号监听")
 
 			select {
 			case <-a:
 			case <-stopper.Done():
 				{
-					logger.Infoln("紧急停止信号触发")
+					logger.Infoln("停止信号触发")
 					cancel()
 					leaf.WithValue[leaf.EndType](c, leaf.EndKey, leaf.EndStop)
 				}

internal/middleware/ticker.go

@@ -35,7 +35,6 @@ func TickerAction() leaf.HandlerFunc {
 		wait.Add(1)
 		go func() {
 			start := time.Now()
-			// 等待结束
 			defer wait.Done()
 			// 定时器
 			ticker := time.NewTicker(time.Second)

internal/middleware/timer.go

@@ -34,7 +34,6 @@ func TimeoutOver(maxTimeout int) leaf.HandlerFunc {
 		cancel := leaf.WithCancel(c)
 		wait.Add(1)
 		go func() {
-			// 等待结束
 			defer wait.Done()
 
 			logger.Infoln("超时 Timer 监控开始")

internal/server.go

@@ -10,7 +10,6 @@ import (
 	"game-driver/internal/schema"
 	"game-driver/leaf"
 	"game-driver/pkg/logger"
-	"game-driver/pkg/relay"
 	"game-driver/pkg/tts"
 	"game-driver/pkg/utils"
 	"github.com/eclipse/paho.golang/autopaho"
@@ -106,13 +105,13 @@ func Run() {
 	tts.DefaultTTS = tts.New(ctx, config.C.Aliyun)
 
 	// 构建继电器对象
-	r, err := relay.New(config.C.Relay, func(msg string) {
+	//r, err := relay.New(config.C.Relay, func(msg string) {
-		logger.Infoln("串口返回: ", msg)
+	//	logger.Infoln("串口返回: ", msg)
-	})
+	//})
-	if err != nil {
+	//if err != nil {
-		logger.Panicln("串口连接异常: ", err)
+	//	logger.Panicln("串口连接异常: ", err)
-	}
+	//}
-	defer r.Close()
+	//defer r.Close()
 
 	// 构建全局设备变量
 	device := common.DefaultDevice(ctx, cm, publishTopic)