internal/app/ami/action/index.go

@@ -1,9 +1,9 @@
 package action
 
 import (
-	"net"
 	"pbx-api-gin/internal/app/ami/model"
 	"pbx-api-gin/internal/app/mysql"
+	"pbx-api-gin/internal/app/stc/active"
 	alstatus "pbx-api-gin/internal/app/stc/sendstatus"
 	"pbx-api-gin/internal/app/stc/socket"
 	"pbx-api-gin/internal/pkg/configs"
@@ -28,9 +28,16 @@ const pacu8 = "2181"
 
 //type Operation func(src, dst string, whisper, bargein bool)
 
-func HandleAMI(event map[string]string, conn net.Conn) {
+func HandleAMI(event map[string]string) {
+
+	//return if not actived
+	if !active.Actived {
+		return
+	}
+
+	// MC1 conn or MC8 conn
+	conn := socket.Conn
 
-	conn = socket.Conn
 	if conn == nil {
 		lfshook.NewLogger().Infof("===HandleAMI===conn==nil=")
 		return
@@ -122,7 +129,7 @@ func StartAMI(connectOKCallBack func(), handleEvents []func(event map[string]str
 		// lfshook.NewLogger().Infof("ami event on %+v", payload[0])
 		event := payload[0].(map[string]string)
 
-		HandleAMI(event, socket.Conn)
+		HandleAMI(event)
 
 		for _, handle := range handleEvents {
 			go handle(event)

internal/app/ami/model/sip.go

@@ -2,16 +2,14 @@ package model
 
 import "encoding/json"
 
-// Event: EndpointList
-// ObjectType: endpoint
-// ObjectName: www
-// Transport: UDP
-// Aor: www
-// Auths: www
-// OutboundAuths: www
-// Contacts:
-// DeviceState: Unavailable
-// ActiveChannels:
+type Sysinfo struct {
+	Name  string `xorm:"name" json:"name"`
+	Value string `xorm:"value" json:"value"`
+}
+
+func (*Sysinfo) TableName() string {
+	return "t_sysinfo"
+}
 
 // Event: EndpointList
 // ObjectType: endpoint

internal/app/index.go

@@ -1,19 +1,36 @@
 package app
 
 import (
+	"fmt"
+	"os/exec"
 	"pbx-api-gin/internal/app/ami/action"
 	"pbx-api-gin/internal/app/mysql"
 	"pbx-api-gin/internal/app/stc"
+	"pbx-api-gin/internal/app/stc/active"
 	"pbx-api-gin/internal/app/stc/socket"
 	"pbx-api-gin/pkg/lfshook"
+	"strings"
 )
 
 func StartApp() {
 	//init mysql
 	mysql.CreateDBInstance()
 
+	//Get cab number acording to IP
+	IP, err := getIPByCommand()
+	if err != nil {
+		lfshook.NewLogger().Infof("Get IP err :%+v", err)
+	}
+	if IP[len(IP)-2:] == "81" {
+		active.CabNum = "8"
+	} else {
+		active.CabNum = "1"
+	}
+	lfshook.NewLogger().Infof("=================cab number:%s===========", active.CabNum)
+
 	// 启动带有重连机制的连接管理协程
 	go stc.StartStcConnection(socket.Conn)
+
 	// 启动其他服务...
 	// 启动 AMI
 	go func() {
@@ -22,3 +39,19 @@ func StartApp() {
 		}, []func(event map[string]string){})
 	}()
 }
+
+// Get eth0 IP
+func getIPByCommand() (string, error) {
+	cmd := "ifconfig eth0 | grep 'inet addr:' | awk '{print $2}' | cut -d: -f2"
+	out, err := exec.Command("bash", "-c", cmd).CombinedOutput()
+	if err != nil {
+		return "", err
+	}
+
+	ip := strings.TrimSpace(string(out))
+	if ip == "" {
+		return "", fmt.Errorf("no IP address found")
+	}
+
+	return ip, nil
+}

internal/app/stc/active/index.go

@@ -0,0 +1,7 @@
+package active
+
+var ActiveCab string
+var CabNum string
+var Actived bool
+
+var ActivedMC int

internal/app/stc/broadcast/stc-broadcast.go

@@ -10,6 +10,7 @@ import (
 	"pbx-api-gin/internal/app/ami/action"
 	"pbx-api-gin/internal/app/ami/model"
 	"pbx-api-gin/internal/app/mysql"
+	"pbx-api-gin/internal/app/stc/active"
 	msgdata "pbx-api-gin/internal/app/stc/data"
 	"pbx-api-gin/pkg/lfshook"
 	"strings"
@@ -40,7 +41,6 @@ func HandleStcCmd(ctx context.Context, conn net.Conn) {
 					}
 					return
 				}
-
 				// 将新读取的数据追加到缓冲区
 				buf.Write(tmp[:n])
 			}
@@ -63,34 +63,37 @@ func processPacket(packet []byte) {
 		fmt.Println("Invalid packet length")
 		return
 	}
-
 	lfshook.NewLogger().Logger.Infof("Get data from STC ===============:%x", packet)
+	//check if the cmd type is avtive
+	if packet[5] == 0x03 { // ACTIVE
+		Active([1]byte{packet[7]})
+	}
 
-	switch packet[5] {
-	case 0x01: // heartbeat
-		// handle heartbeat
-	case 0x02: // STN
-		StationAnn(packet)
-	case 0x03: // ACTIVE
-		Active([1]byte{packet[8]})
-	case 0x05: // SPC
-		SpecialAnn(packet)
-	case 0x06: // EMG
-		EmgMsg(packet)
-	case 0x07: // STOP
-		AnnStop([4]byte{packet[8], packet[9], packet[10], packet[11]})
-	case 0x08: // DCS
-		DcsAnn(packet)
-	case 0x09: // SELF CHECK
-		SelfCheck(packet)
-	case 0x0a:
-		AlarmHandle(packet)
-	case 0x0b:
-		AlarmResetAll()
-	case 0x0c:
-		RecordStorageConf(packet[8:])
-	default:
-		fmt.Printf("Unknown command: %x\n", packet[5])
+	if active.Actived {
+		switch packet[5] {
+		case 0x01: // heartbeat
+			// handle heartbeat
+		case 0x02: // STN
+			StationAnn(packet)
+		case 0x05: // SPC
+			SpecialAnn(packet)
+		case 0x06: // EMG
+			EmgMsg(packet)
+		case 0x07: // STOP
+			AnnStop([4]byte{packet[8], packet[9], packet[10], packet[11]})
+		case 0x08: // DCS
+			DcsAnn(packet)
+		case 0x09: // SELF CHECK
+			SelfCheck(packet)
+		case 0x0a:
+			AlarmHandle(packet)
+		case 0x0b:
+			AlarmResetAll()
+		case 0x0c:
+			RecordStorageConf(packet[8:])
+		default:
+			fmt.Printf("Unknown command: %x\n", packet[5])
+		}
 	}
 }
 
@@ -122,15 +125,55 @@ func StationAnn(data []byte) (err error) {
 // 激活信号
 func Active(data [1]byte) {
 
+	var info model.Sysinfo
+
 	Num := int(data[0])
+	lfshook.NewLogger().Logger.Infof("Active data : %x", Num)
 
 	switch Num { // 设置全局的激活信号，并通过协议（待定）通知终端注册到对应的激活主机上
 	case 0:
+
+		info.Name = "cab_active"
+		info.Value = "0"
+
+		_, er := mysql.DBOrmInstance.Where("name = ?", "cab_active").Update(&info)
+		if er != nil {
+			lfshook.NewLogger().Logger.Infof("update sysinfo err : %+v", er.Error())
+			return
+		}
 	case 1:
+		if active.CabNum == "1" {
+			info.Name = "cab_active"
+			info.Value = "1"
+			active.Actived = true
+		} else {
+			info.Name = "cab_active"
+			info.Value = "0"
+			active.Actived = false
+		}
+		_, er := mysql.DBOrmInstance.Where("name = ?", "cab_active").Update(&info)
+		if er != nil {
+			lfshook.NewLogger().Logger.Infof("update sysinfo err : %+v", er.Error())
+			return
+		}
 	case 8:
-	case 9:
-	}
 
+		if active.CabNum == "8" {
+			info.Name = "cab_active"
+			info.Value = "1"
+			active.Actived = true
+		} else {
+			info.Name = "cab_active"
+			info.Value = "0"
+			active.Actived = false
+		}
+
+		_, er := mysql.DBOrmInstance.Where("name = ?", "cab_active").Update(&info)
+		if er != nil {
+			lfshook.NewLogger().Logger.Infof("update sysinfo err : %+v", er.Error())
+			return
+		}
+	}
 }
 
 // SPC ,特殊服务消息广播
@@ -247,7 +290,7 @@ func SelfCheck(data []byte) {
 // 全局变量：记录正在抑制的 exten
 var (
 	suppressedExts = sync.Map{} // map[string]struct{}，值存在即表示被抑制
-	suppressionMu  sync.Mutex   // 保护初始化和清理操作（可选）
+	//suppressionMu  sync.Mutex   // 保护初始化和清理操作（可选）
 )
 
 // suppressKey 生成用于抑制的 key（可以根据需求扩展）
@@ -266,6 +309,7 @@ func AlarmHandle(data []byte) {
 	lfshook.NewLogger().Logger.Infof("================ICP Answer PAD================:%s ", exten)
 	key := suppressKey(exten, handler)
 
+	//Drop other handler in 2 sec
 	// 只对 handler == 0x01 做 2 秒去重
 	if handler == 0x01 {
 		if _, loaded := suppressedExts.LoadOrStore(key, struct{}{}); loaded {
@@ -274,7 +318,7 @@ func AlarmHandle(data []byte) {
 		}
 
 		// 设置2秒后删除该 key，允许下次通过
-		time.AfterFunc(4*time.Second, func() {
+		time.AfterFunc(2*time.Second, func() {
 			suppressedExts.Delete(key)
 			lfshook.NewLogger().Logger.Debugf("Suppression released for key: %s", key)
 		})
@@ -289,25 +333,20 @@ func AlarmHandle(data []byte) {
 	switch handler {
 	case 0x01: //answer(ICP+Alarm+PACU)
 		//NotifyPaiu(exten, "answer")
-		err := action.RedirectInQueue(exten, "0402", "ani-rule", "1") // 1车ICP接听PAIU
-		if err != nil {
-			lfshook.NewLogger().Logger.Infof("================ICP Answer PAD====ERR============ : %+v", err.Error())
-		}
-		//invite PACU join in
-		//action.Hangup("PACU")
-		//action.ChanSpy("PACU", exten, false, true)
-
-	case 0x04: //answer(ICP+Alarm+PACU)
-
-		err := action.RedirectInQueue(exten, "0401", "ano-rule", "1") // 1车OCC接听PAIU
-		if err != nil {
-			//lfshook.NewLogger().Info(err)
-			lfshook.NewLogger().Logger.Infof("================ICP Answer PAD====ERR============ : %+v", err.Error())
+		if active.CabNum == "1" {
+			err := action.RedirectInQueue(exten, "0402", "ani-rule", "1") // 1车ICP接听PAIU
+			if err != nil {
+				lfshook.NewLogger().Logger.Infof("=========Cab1=======ICP Answer PAD====ERR============ : %+v", err.Error())
+			}
+		} else {
+			err := action.RedirectInQueue(exten, "0402", "ani-rule", "8") // 8车ICP接听PAIU
+			if err != nil {
+				lfshook.NewLogger().Logger.Infof("=========Cab8=======ICP Answer PAD====ERR============ : %+v", err.Error())
+			}
 		}
 		//invite PACU join in
 		//action.Hangup("PACU")
 		//action.ChanSpy("PACU", exten, false, true)
-		lfshook.NewLogger().Logger.Infof("================ICP Answer PAD================:%s ", exten)
 	case 0x02: //hold  重新放回队列里面
 		NotifyPaiu(exten, "hold")
 

internal/app/stc/index.go

@@ -14,18 +14,10 @@ import (
 	"time"
 )
 
-const RemotePort = 10100
-const LocalPort = 10201
-
-//const RemoteAddr = "192.168.17.14"
-
-const RemoteAddr = "10.0.11.11"
-
 func StartStcConnection(conn net.Conn) {
-	//var conn net.Conn
-	//var wg sync.WaitGroup
+
 	var connMux sync.Mutex // 保护 conn 的读写
-	//var err error
+
 	for {
 		// 尝试建立连接
 		conn1, err := CreateConnection()
@@ -33,6 +25,7 @@ func StartStcConnection(conn net.Conn) {
 			time.Sleep(2 * time.Second)
 			continue
 		}
+
 		connMux.Lock()
 		oldConn := conn
 		socket.Conn = conn1
@@ -46,22 +39,21 @@ func StartStcConnection(conn net.Conn) {
 
 		// 使用 context 控制所有协程的生命周期
 		ctx, cancel := context.WithCancel(context.Background())
-		lfshook.NewLogger().Logger.Infof("Connect success :%s:%d", RemoteAddr, RemotePort)
-		// 启动消息处理和心跳协程
-		// 启动消息处理
+
+		// 启动消息处理MC1
 		go func() {
 			defer func() {
 				cancel() // 一旦任一协程退出，取消所有
 			}()
-			broadcast.HandleStcCmd(ctx, conn1) // 改造 HandleStcCmd 接收 ctx
+			broadcast.HandleStcCmd(ctx, socket.Conn) // 改造 HandleStcCmd 接收 ctx
 		}()
 
-		// 启动心跳
+		// 启动心跳MC1
 		go func() {
 			defer func() {
 				cancel()
 			}()
-			Sendheartbeat(ctx, conn1) // 改造 Sendheartbeat 接收 ctx
+			Sendheartbeat(ctx, socket.Conn) // 改造 Sendheartbeat 接收 ctx
 		}()
 
 		// 等待连接断开（监听连接状态）
@@ -78,20 +70,20 @@ func StartStcConnection(conn net.Conn) {
 
 // 返回错误而不是终止程序
 func CreateConnection() (net.Conn, error) {
-	lfshook.NewLogger().Logger.Infof("========Connect server  IP:%s  :Port:%d", RemoteAddr, RemotePort)
+	lfshook.NewLogger().Logger.Infof("========Connect server  IP:%s  :Port:%d", socket.RemoteAddr, socket.RemotePort)
 	// 创建 Dialer
 	dialer := &net.Dialer{
-		LocalAddr: &net.TCPAddr{IP: net.ParseIP("0.0.0.0"), Port: LocalPort}, // 固定本地端口
+		LocalAddr: &net.TCPAddr{IP: net.ParseIP("0.0.0.0"), Port: socket.LocalPort}, // 固定本地端口
 		Control:   controlTCPConn,
 	}
 
-	DialAddr := fmt.Sprintf("%s:%d", RemoteAddr, RemotePort)
+	DialAddr := fmt.Sprintf("%s:%d", socket.RemoteAddr, socket.RemotePort)
 	conn, err := dialer.Dial("tcp", DialAddr)
 	if err != nil {
 		lfshook.NewLogger().Logger.Infof("========Connect server err :%+v", err)
 		return nil, err
 	}
-
+	lfshook.NewLogger().Logger.Infof("Connect success :%s:%d", socket.RemoteAddr, socket.RemotePort)
 	return conn, nil
 }
 

internal/app/stc/sendstatus/status.go

@@ -3,6 +3,7 @@ package alstatus
 import (
 	"fmt"
 	"net"
+	"pbx-api-gin/internal/app/stc/active"
 	msgdata "pbx-api-gin/internal/app/stc/data"
 	"pbx-api-gin/pkg/lfshook"
 	"pbx-api-gin/pkg/utils"
@@ -57,8 +58,11 @@ func AlarmStatus(exten string, status string, conn net.Conn) {
 		fmt.Println("Encode error:", errEn)
 		return
 	}
-	lfshook.NewLogger().Logger.Infof("===AlarmStatus=ext:%s===carr:%x==========pos:%x=========status:%x", exten, protocol.Data[0], protocol.Data[1], protocol.Data[2])
-	SendToStc(conn, encoded)
+	//check if actived
+	if active.Actived {
+		lfshook.NewLogger().Logger.Infof("===AlarmStatus=ext:%s===carr:%x==========pos:%x=========status:%x", exten, protocol.Data[0], protocol.Data[1], protocol.Data[2])
+		SendToStc(conn, encoded)
+	}
 }
 
 // report broadcast status to STC

internal/app/stc/socket/index.go

@@ -3,3 +3,12 @@ package socket
 import "net"
 
 var Conn net.Conn
+var Conn8 net.Conn
+
+const RemotePort = 10100
+const LocalPort = 10201
+
+//const RemoteAddr = "192.168.17.14"
+
+const RemoteAddr = "10.0.11.11"
+const RemoteAddr8 = "10.0.11.81"