IOT/SERVER/IotAdmin/server/api.go

//go:build !migrate && !createApp && !project

package server

import (
	"IotAdmin/app/router"
	"IotAdmin/app/schedule/jobs"
	"IotAdmin/app/system/models"
	"IotAdmin/common/database"
	"IotAdmin/common/global"
	"IotAdmin/common/middleware"
	"IotAdmin/common/storage"
	ext "IotAdmin/config"
	"IotAdmin/core/config/source/file"
	"IotAdmin/core/sdk"
	"IotAdmin/core/sdk/config"
	"IotAdmin/core/sdk/pkg"
	"IotAdmin/iot"
	iotDb "IotAdmin/iot/db"
	iotLog "IotAdmin/iot/log"
	"context"
	"errors"
	"fmt"
	"log"
	"net/http"
	"os"
	"os/signal"
	"time"

	"github.com/gin-gonic/gin"
	"github.com/spf13/pflag"
)

var (
	apiCheck = pflag.BoolP("api", "a", false, "启动服务器检查 API 数据")
)

// 初始化
func init() {
	// 注入配置扩展项
	config.ExtendConfig = &ext.ExtConfig
	//1. 读取配置
	config.Setup(
		file.NewSource(file.WithPath(*configYml)),
		database.Setup,
		storage.Setup,
	)
	//2. 注册监听函数
	queue := sdk.Runtime.GetMemoryQueue("")
	queue.Register(global.LoginLog, models.SaveLoginLog)
	queue.Register(global.OperateLog, models.SaveOperaLog)
	queue.Register(global.ApiCheck, models.SaveSysApi)
	queue.Register(global.DtuChangeStatus, iotDb.DtuChangeStatus)
	queue.Register(global.DtuDeviceChange, iotDb.DtuDeviceChange)
	queue.Register(global.UpdateMeterCalc, iotDb.UpdateMeterCalc)
	go queue.Run()

	iotLog.Clean(1, 1)
	//3. 注册路由
	// 在app/router目录下新建文件 放在init方法 参考system

	usageStr := `正在启动API服务...`
	log.Println(usageStr)
}

func Init() {
	if config.ApplicationConfig.Mode == pkg.ModeProd.String() {
		gin.SetMode(gin.ReleaseMode)
	}
	initWebServer()

	srv := &http.Server{
		Addr:    fmt.Sprintf("%s:%d", config.ApplicationConfig.Host, config.ApplicationConfig.Port),
		Handler: sdk.Runtime.GetEngine(),
	}

	// 数据采集服务
	go iot.InitIotService()
	// 定时任务
	go jobs.InitJob()

	if *apiCheck {
		var routers = sdk.Runtime.GetRouter()
		q := sdk.Runtime.GetMemoryQueue("")
		mp := make(map[string]interface{})
		mp["List"] = routers
		message, err := sdk.Runtime.GetStreamMessage("", global.ApiCheck, mp)
		if err != nil {
			log.Printf("GetStreamMessage 错误, %s \n", err.Error())
			//日志报错错误，不中断请求
		} else {
			err = q.Append(message)
			if err != nil {
				log.Printf("Append Message 错误, %s \n", err.Error())
			}
		}
	}

	go func() {
		// 服务连接
		if config.SslConfig.Enable {
			if err := srv.ListenAndServeTLS(config.SslConfig.Pem, config.SslConfig.KeyStr); err != nil && !errors.Is(err, http.ErrServerClosed) {
				log.Fatal("监听TLS错误: ", err)
			}
		} else {
			if err := srv.ListenAndServe(); err != nil && !errors.Is(err, http.ErrServerClosed) {
				log.Fatal("监听错误: ", err)
			}
		}
	}()

	fmt.Println(pkg.Green("Server Run At:"))
	fmt.Printf("-  Local:   %s://localhost:%d/ \r\n", "http", config.ApplicationConfig.Port)
	fmt.Printf("-  Network: %s://%s:%d/ \r\n", "http", pkg.GetLocalHost(), config.ApplicationConfig.Port)
	fmt.Println(pkg.Green("Swagger Run At:"))
	fmt.Printf("-  Local:   http://localhost:%d/swagger/admin/index.html \r\n", config.ApplicationConfig.Port)
	fmt.Printf("-  Network: %s://%s:%d/swagger/system/index.html \r\n", "http", pkg.GetLocalHost(), config.ApplicationConfig.Port)
	fmt.Printf("%s 输入 Control + C 关闭服务 \r\n", pkg.GetCurrentTimeStr())

	// 等待中断信号以优雅地关闭服务器（设置 5 秒的超时时间）
	quit := make(chan os.Signal, 1)
	signal.Notify(quit, os.Interrupt)
	<-quit

	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()
	fmt.Printf("%s 关闭服务... \r\n", pkg.GetCurrentTimeStr())

	if err := srv.Shutdown(ctx); err != nil {
		log.Fatal("服务关闭:", err)
	}
	log.Println("服务退出")

}

func initWebServer() {
	var r *gin.Engine
	h := sdk.Runtime.GetEngine()
	if h == nil {
		h = gin.New()
		sdk.Runtime.SetEngine(h)
	}
	switch h.(type) {
	case *gin.Engine:
		r = h.(*gin.Engine)
		// 注册中间件
		middleware.UseGinMiddleware(r)
		// 注册路由
		router.RegisterRouter()
	default:
		log.Fatal("不支持其他 Engine")
		//os.Exit(-1)
	}

}