修复ape类型判断

zhangzengfei

2024-05-25 8ba0a125eb7302d8c51d3c85cf8ea8a4de5413db

 main.go

@@ -3,14 +3,14 @@
import (
   "context"
   "fmt"
   "gat1400Exchange/cron"
   "net/http"
   "os"
   "os/signal"
   "syscall"
   "time"

   "gat1400Exchange/client"
   "gat1400Exchange/config"
   "gat1400Exchange/cron"
   "gat1400Exchange/models"
   "gat1400Exchange/pkg/logger"
   "gat1400Exchange/routes"
@@ -37,8 +37,14 @@
      Handler: r,
   }

   // 启动1400客户端
   ctx, cancel := context.WithCancel(context.Background())
   go client.Init1400Client(ctx)

   // 启动网络视频字符叠加器服务
   go service.NVCSServer()
   go service.StartNVCSServer()

   go service.InitSubscribeTask()

   // 启动定时任务
   cron.Init()
@@ -65,11 +71,13 @@

   // The context is used to inform the server it has 5 seconds to finish
   // the request it is currently handling
   ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
   //ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
   defer cancel()
   if err := srv.Shutdown(ctx); err != nil {
      logger.Error("Server forced to shutdown:", err)
   }

   service.StopSubscribeTask()

   logger.Info("Server exiting!")
}