crrc/internal/app/index.go

package app

import (
	"pbx-api-gin/internal/app/ami/action"
	"pbx-api-gin/internal/app/stc"
	"pbx-api-gin/internal/app/stc/active"
	"pbx-api-gin/internal/app/stc/priority"
	"pbx-api-gin/internal/app/stc/socket"
	"pbx-api-gin/pkg/lfshook"
	"pbx-api-gin/pkg/utils"
	"time"
)

func StartApp() {
	time.Sleep(2 * time.Second)
	//Get cab number acording to IP
	socket.SetMasterCabNum()

	lfshook.NewLogger().Infof("============ Get cab number:%s  Master:%+v", active.CabNum, active.Master)

	//init the active status
	//active.ActivedCab = ""

	//get priority
	priority.GetPriority()

	//初始化列车信息map 列车号+车厢号
	active.InitTrainInfoMap()

	// 启动带有重连机制的连接管理协程MC1
	go stc.StartStcConnection(socket.Conn, "1")

	// 启动带有重连机制的连接管理协程MC8
	go stc.StartStcConnection(socket.Conn8, "8")

	//启动连接到Master服务器,检查Master是否在线
	if active.CabNum == "1" {
		go stc.StartConnectionToSipServer(socket.ConnToSlave)
	} else {
		go stc.RecvFromSipServer()
	}

	lfshook.NewLogger().Infof("=====Check asterisk=======")

	//init asterisk
	if !utils.CheckAsterisk() {
		lfshook.NewLogger().Infof("Check asterisk , if not running , run cmd /usr/sbin/asterisk !")
		utils.ExecCmdAsync("/usr/sbin/asterisk")
		time.Sleep(3 * time.Second)
	}

	lfshook.NewLogger().Infof("=====Connect asterisk=======")
	// 启动其他服务...
	// 启动 AMI
	go func() {
		action.StartAMI(func() {
			lfshook.NewLogger().Info("ami callback")
		}, []func(event map[string]string){})
	}()

	//refresh extension status
	time.Sleep(1 * time.Second)

	utils.ExecCmdAsync("/usr/sbin/asterisk", "-rx", "reload")
}