crrc/internal/app/ami/action/index.go

package action

import (
	"pbx-api-gin/internal/app/stc/active"
	"pbx-api-gin/internal/app/stc/priority"
	alstatus "pbx-api-gin/internal/app/stc/sendstatus"
	"pbx-api-gin/internal/pkg/configs"
	"pbx-api-gin/pkg/lfshook"
	"pbx-api-gin/pkg/utils"
	"strconv"
	"strings"
	"time"

	"github.com/sirupsen/logrus"
	"github.com/tqcenglish/amigo-go"
	"github.com/tqcenglish/amigo-go/pkg"
)

var AminInstance *amigo.Amigo

func HandleAMI(event map[string]string) {
	//lfshook.NewLogger().Infof("===start======%s", event["Event"])
	//return if not actived
	if !active.Actived {
		return
	}

	switch event["Event"] {

	case "UserEvent": // RCD filename; PA;CPA; CabCab
		lfshook.NewLogger().Infof("========event:%s   File:%s", event["Event"], event["FILENAME"])
		if event["UserEvent"] == "SetRecordFile" { //get  record file name
			alstatus.SendRecordFile(event["FILENAME"], event["RecordType"])

		} else if event["UserEvent"] == "CallType" && (event["Type"] == "PA" || event["Type"] == "CPA") { //PA start; check manual PA priority
			//check active signal  before PA; hangup if not actived
			if active.CabNum == "1" && !active.Actived && event["CallerIDNum"] == "2311" {
				Hangup(event["CallerIDNum"])
			} else if active.CabNum == "8" && !active.Actived && event["CallerIDNum"] == "2381" {
				Hangup(event["CallerIDNum"])
			}

			//PA & CPA interrupt others
			if utils.IsICP(event["CallerIDNum"]) {
				if priority.CheckPriority("ManuPa") {
					//hangup others if priority is higher
					HangupRunningTask("PA") //PA interrupt other
				} else {
					Hangup(event["CallerIDNum"]) //lowwer priority ,hangup caller
				}

			} else if utils.IsIO(event["CallerIDNum"]) { // CPA
				if priority.CheckPriority("CPA") {

					//check active signal  before CPA; hangup if not actived
					if active.CabNum == "1" && !active.Actived && event["CallerIDNum"] == "1411" {
						Hangup(event["CallerIDNum"])
					} else if active.CabNum == "8" && !active.Actived && event["CallerIDNum"] == "1481" {
						Hangup(event["CallerIDNum"])
					}

					//hangup others if priority is higher
					if priority.RunningType != "C2C" {
						HangupRunningTask("CPA") //CPA interrupt other
					} else {
						//call to ICP ; can not stop calling ICP
						lfshook.NewLogger().Info("==Running CabCab , CPA start call ICP(ICP is on the phone)=====")
					}
				} else {
					Hangup(event["CallerIDNum"]) //lowwer priority ,hangup caller
				}
			}
		} else if event["UserEvent"] == "CallType" && event["Type"] == "C2C" { //CabCab start; check cab cab priority

			if priority.CheckPriority("CabCab") {

				if priority.RunningType == "PA" || priority.RunningType == "PAD-ICP" || priority.RunningType == "PAD-TMS" {
					HangupRunningTask("C2C") //C2C interrupt other
				} else {
					//Hangup the other ICP
					if event["CallerIDNum"] == "2311" {
						Hangup("2381")
					} else {
						Hangup("2311")
					}
				}
			} else { // hangup caller; C2C start failed
				Hangup(event["CallerIDNum"])
			}
		}

	case "Newchannel":
		//lfshook.NewLogger().Infof("=========%s", event["Event"])
		if utils.IsPAIU(event["CallerIDNum"]) && event["Exten"] == "0300" { // Alarm dial queue start; PAD dialing
			if priority.PADStart == 0 {
				priority.PADStart = 1
				alstatus.PaStatus(event["CallerIDNum"], "PAD", "start")
			}

			alstatus.AlarmStatus(event["CallerIDNum"], "dial")
		}

	case "Hangup":

		lfshook.NewLogger().Infof("=========%s", event["Event"])
		if utils.IsPAIU(event["CallerIDNum"]) && !strings.Contains(event["Channel"], "Local") { // PAD hangup ， check if PAD all end

			res, _ := QueueStatus("0300", "") // check ICP queue ,if empty PAD end
			if res.Calls == "0" {
				priority.CleanPriorityTag()
				HangupAllLocalChan()
				if priority.PADStart == 1 {
					alstatus.PaStatus(event["CallerIDNum"], "PAD", "end")
					priority.PADStart = 0
				}
				if priority.ResumeEmgPara.FileName != "" {
					CheckEmgResume()
				}
				//priority.ICPAnswer = 0
				break
			}
		}

		//OCC answer PAD, hangup, redirect the next PAD to OCC
		if (event["CallerIDNum"] == "ano1" || event["CallerIDNum"] == "ano8") && utils.IsIO(event["ConnectedLineNum"]) {
			HangupAllLocalChan()
			res, _ := QueueStatus("0301", "") // check OCC queue ,if empty PAD end
			if res.Calls == "0" {             //OCC queue is empty
				priority.CleanPriorityTag()
				alstatus.OccPad("end")

				if priority.ResumeEmgPara.FileName != "" {
					CheckEmgResume()
				}

				break
			} else { //OCC queue is not empty
				HangupAllLocalChan()
				if active.CabNum == "1" && active.Actived && ExtenStatus("1411") == "Idle" { //check active and OCC status
					Dial("0401", "0512", "pad-rule-pacus-occ", "ano1", event["CallerIDNum"], "1") // PACUs dial OCC1
					//goto ConfbridgeJoin, OCC1 answer PAD
				} else if active.CabNum == "8" && active.Actived && ExtenStatus("1481") == "Idle" {
					Dial("0401", "0512", "pad-rule-pacus-occ", "ano8", event["CallerIDNum"], "8") // PACUs dial OCC8
					//goto ConfbridgeJoin, OCC8 answer PAD
				}
			}
		}

	case "QueueCallerJoin":
		lfshook.NewLogger().Infof("=========%s", event["Event"])
		if priority.OCCAnswer == 1 && event["Queue"] == "0300" { //New PAD Goto the OCC queue in the first time, if OCC answered
			alstatus.AlarmStatus(event["CallerIDNum"], "queue") //send status to STC
			go RedirectInQueue(event["CallerIDNum"], "0301", "queues-occ", event["CallerIDNum"])
			break
		}

		if utils.IsPAIU(event["CallerIDNum"]) && event["Queue"] == "0300" { // Alarm join the queue, PAD in the queue
			alstatus.AlarmStatus(event["CallerIDNum"], "queue") //send status to STC

			time.AfterFunc(30*time.Second, func() { // check the PAD 30s timeout
				if priority.ICPAnswer == 0 { //ICP did not answer any

					res, err := QueueStatus("0301", "") // check OCC queue , if empty OCC-PAD start
					if err != nil {
						lfshook.NewLogger().Infof("===OCC-QueueStatus==%+v", err)
						return
					}
					if res.Calls == "0" { // OCC queue empty

						resCaller, err := QueueStatus("0300", "") // check ICP queue, get entries
						if err != nil {
							lfshook.NewLogger().Infof("==ICP=QueueStatus==%+v", err)
							return
						}

						for _, caller := range resCaller.Entrys {
							go RedirectInQueue(caller.CallerIDNum, "0301", "queues-occ", caller.CallerIDNum) // redirect All ICP-PAD redirect to OCC queue
						}
					}
				}
			})
			break
		}

		//first PAD caller goto OCC
		//PACUs dial OCC;
		//PAD chanspy(WqE) OCC;
		//ICPs chanspy(qE) PAD;
		if utils.IsPAIU(event["CallerIDNum"]) && event["Queue"] == "0301" && priority.OCCAnswer == 0 { // The first PAD to OCC ,caller is PAD
			if priority.CheckPriority("PAD-OCC") {
				HangupRunningTask("PAD-OCC") //PAD-OCC interrupt other
				priority.OCCAnswer = 1

				if active.CabNum == "1" && active.Actived && ExtenStatus("1411") == "Idle" { //check active and OCC status
					if priority.PADOccStart == 0 {
						alstatus.OccPad("start")
						priority.PADOccStart = 1
					}
					Dial("0401", "0512", "pad-rule-pacus-occ", "ano1", event["CallerIDNum"], "1") // PACUs dial OCC1
					//Goto event=ConfbridgeJoin;OCC answer PAD
				} else if active.CabNum == "8" && active.Actived && ExtenStatus("1481") == "Idle" {
					if priority.PADOccStart == 0 {
						alstatus.OccPad("start")
						priority.PADOccStart = 1
					}
					Dial("0401", "0512", "pad-rule-pacus-occ", "ano8", event["CallerIDNum"], "8") // PACUs dial OCC8
					//Goto event=ConfbridgeJoin;OCC answer PAD
				}
			}
		}

	case "ConfbridgeJoin":
		lfshook.NewLogger().Infof("=========%s", event["Event"])

		//set priority and send PA status msg
		switch event["CallerIDName"] {
		case "EMG":
			if event["Exten"] == "0502" {
				priority.RunningPATaskChan = event["Channel"]
				priority.RunningType = "EMG"
				//Pa status report
				priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.EMG)
				alstatus.PaStatus("", "EMG", "start")
				return
			}
		case "SPC":
			if event["Exten"] == "0505" {
				priority.RunningPATaskChan = event["Channel"]
				priority.RunningType = "SPC"
				//Pa status report
				priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.SPC)
				alstatus.PaStatus("", "SPC", "start")
				return
			}
		case "DCS":
			if event["Exten"] == "0504" {
				priority.RunningPATaskChan = event["Channel"]
				priority.RunningType = "DCS"
				//Pa status report
				priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.DCS)
				alstatus.PaStatus("", "DCS", "start")
				return
			}
		case "STN":
			if event["Exten"] == "0503" {
				priority.RunningPATaskChan = event["Channel"]
				priority.RunningType = "STN"
				//Pa status report
				priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.STN)
				alstatus.PaStatus("", "STN", "start")
				return
			}
		case "CHK":
			if event["Exten"] == "0510" {
				priority.RunningPATaskChan = event["Channel"]
				priority.RunningType = "CHK"
				//Pa status report
				priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.CHK)
				alstatus.PaStatus("", "CHK", "start")
				return
			}
		case "VOL": // tone-test
			if event["Exten"] == "0513" {
				priority.RunningPATaskChan = event["Channel"]
				priority.RunningType = "VOL"
				//Pa status report
				priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.VOL)
				alstatus.PaStatus("", "VOL", "start")
				return
			}
		}

		//Send PA start msg to STC
		if utils.IsICP(event["CallerIDNum"]) && event["Exten"] == "0500" { // PA start
			lfshook.NewLogger().Infof("====PA status:%s=====", "start")
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.ManuPa)
			alstatus.PaStatus(event["CallerIDNum"], "PA", "start")
			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "PA"
			break
		} else if utils.IsIO(event["CallerIDNum"]) && event["Exten"] == "0501" { //CPA start
			lfshook.NewLogger().Infof("====CPA status:%s=====", "start")
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.CPA)
			alstatus.PaStatus(event["CallerIDNum"], "CPA", "start")
			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "CPA"
			break
		}

		//ICP answer PAD;
		if event["ConnectedLineNum"] == "ani1" && event["Exten"] == "0511" { //PAD answered by ICP; PACUs connected ICP1
			lfshook.NewLogger().Infof("====PAD answered by ICP1:%s=====", event["ConnectedLineName"])
			alstatus.AlarmStatus(event["ConnectedLineName"], "connect")

			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "PAD-ICP"
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.PADICP)
			go RedirectInQueue(event["ConnectedLineName"], "2311", "chanspy-rule-whisper", event["ConnectedLineName"])               //PAD chanspy(EqW) ICP1
			go Dial("0402", event["ConnectedLineName"], "chanspy-rule", event["ConnectedLineName"], event["ConnectedLineName"], "8") //ICP8 chanspy PAD
			//goto event=ChanSpyStart; PAD whisper ICP8
			break
		}
		if event["ConnectedLineNum"] == "ani8" && event["Exten"] == "0511" { //PAD ansered by ICP8; PACUs connected ICP8
			lfshook.NewLogger().Infof("====PAD answered by ICP8:%s=====", event["ConnectedLineName"])
			alstatus.AlarmStatus(event["ConnectedLineName"], "connect")

			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "PAD-ICP"
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.PADICP)
			go RedirectInQueue(event["ConnectedLineName"], "2381", "chanspy-rule-whisper", event["ConnectedLineName"])               //PAD chanspy(EqW) ICP8
			go Dial("0402", event["ConnectedLineName"], "chanspy-rule", event["ConnectedLineName"], event["ConnectedLineName"], "1") //ICP1 chanspy PAD
			//goto event=ChanSpyStart; PAD whisper ICP1
			break
		}

		//OCC answer PAD;
		if event["ConnectedLineNum"] == "ano1" && event["Exten"] == "0512" { //PAD answered by OCC; PACUs connected IO1
			lfshook.NewLogger().Infof("====PAD answered by OCC1:%s=====", event["ConnectedLineName"])
			alstatus.AlarmStatus(event["ConnectedLineName"], "connect")
			priority.OCCAnswer = 1
			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "PAD-OCC"
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.PADOCC)
			go RedirectInQueue(event["ConnectedLineName"], "1411", "chanspy-rule-whisper", event["ConnectedLineName"]) //PAD chanspy(EqW) IO1
			//goto event=ChanSpyStart; ICPs spy PAD
			break
		}
		if event["ConnectedLineNum"] == "ano8" && event["Exten"] == "0512" { //PAD ansered by OCC8; PACUs connected IO8
			lfshook.NewLogger().Infof("====PAD answered by OCC8:%s=====", event["ConnectedLineName"])
			alstatus.AlarmStatus(event["ConnectedLineName"], "connect")
			priority.OCCAnswer = 1
			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "PAD-OCC"
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.PADOCC)
			go RedirectInQueue(event["ConnectedLineName"], "1481", "chanspy-rule-whisper", event["ConnectedLineName"]) //PAD chanspy(EqW) IO8
			//goto event=ChanSpyStart; ICPs spy PAD
			break
		}

	case "ChanSpyStart":
		lfshook.NewLogger().Infof("=========event:%s   callerid:%s   SpyeeConnectedLineName:%s  SpyerExten:%s", event["Event"], event["CallerIDNum"], event["SpyeeConnectedLineName"], event["SpyerExten"])
		//PAD answered by OCC; ICPs chanspy PAD
		if utils.IsPAIU(event["SpyeeConnectedLineName"]) && utils.IsIO(event["SpyerExten"]) { // check if it is PAD whisper IO/OCC
			go Dial("0404", event["SpyeeConnectedLineName"], "chanspy-rule", "ano", "ano", "") //ICPs chanspy PAD
		}

	case "ConfbridgeLeave":
		lfshook.NewLogger().Infof("=========%s", event["Event"])
		if utils.IsICP(event["CallerIDNum"]) && event["Exten"] == "0500" { // PA end
			lfshook.NewLogger().Infof("====PA  status =====%s", "end")
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDNum"], "PA", "end")
			if priority.ResumeEmgPara.FileName != "" {
				CheckEmgResume()
			}

		} else if utils.IsIO(event["CallerIDNum"]) && event["Exten"] == "0501" { //CPA end
			lfshook.NewLogger().Infof("====CPA  status =====%s", "end")
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDNum"], "CPA", "end")
			if priority.ResumeEmgPara.FileName != "" {
				CheckEmgResume()
			}

			//lfshook.NewLogger().Infof("=========%s", event["Event"])
		} else if event["CallerIDName"] == "EMG" && event["Exten"] == "0502" { // EMG broadcast hangup
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "EMG", "end")
			priority.ResumeEmgPara = priority.BroadcastResumeParas{}

		} else if event["CallerIDName"] == "STN" && event["Exten"] == "0503" {
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "STN", "end")
			if priority.ResumeEmgPara.FileName != "" {
				CheckEmgResume()
			}

		} else if event["CallerIDName"] == "DCS" && event["Exten"] == "0504" {
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "DCS", "end")
			if priority.ResumeEmgPara.FileName != "" {
				CheckEmgResume()
			}

		} else if event["CallerIDName"] == "SPC" && event["Exten"] == "0505" {
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "SPC", "end")
			if priority.ResumeEmgPara.FileName != "" {
				CheckEmgResume()
			}

		} else if event["CallerIDName"] == "CHK" && event["Exten"] == "0510" {
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "CHK", "end")
			if priority.ResumeEmgPara.FileName != "" {
				CheckEmgResume()
			}

		} else if event["CallerIDName"] == "VOL" && event["Exten"] == "0513" {
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "VOL", "end")
			if priority.ResumeEmgPara.FileName != "" {
				CheckEmgResume()
			}

		}

	case "DialEnd":
		//lfshook.NewLogger().Infof("=========%s", event["Event"])
		//Cab Cab start
		if utils.IsICP(event["CallerIDNum"]) && utils.IsICP(event["ConnectedLineNum"]) && event["DialStatus"] == "ANSWER" {
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.CabCab)
			priority.RunningType = "C2C"
			alstatus.PaStatus(event["CallerIDNum"], "C2C", "start")
		}

	case "BridgeLeave":
		//lfshook.NewLogger().Infof("=========%s", event["Event"])
		//Cab Cab end
		if utils.IsICP(event["CallerIDNum"]) && utils.IsICP(event["ConnectedLineNum"]) && event["Exten"] == "0400" {
			priority.RunningTypePriority = 0
			priority.RunningType = ""
			alstatus.PaStatus(event["CallerIDNum"], "C2C", "end")
		}

	case "ExtensionStatus":
		//lfshook.NewLogger().Infof("=========event:%s  Ext:%s status:%s ", event["Event"], event["Exten"], event["StatusText"])

		//update extension status
		if event["StatusText"] == "Idle" || event["StatusText"] == "Unavailable" {
			if len(event["Exten"]) > 3 && utils.IsPAIU(event["Exten"]) {
				alstatus.AlarmStatus(event["Exten"], event["StatusText"]) // PAD idle + unavailable
			}
		}

	case "BridgeEnter": // TMS-ICP answer PAD; PACU connect ICP
		lfshook.NewLogger().Infof("=========event:%s   callerid:%s", event["Event"], event["CallerIDNum"])

		if utils.IsPACU(event["CallerIDNum"]) && utils.IsPAIU(event["CallerIDName"]) { //ICP and PACU connected
			lfshook.NewLogger().Infof("====BridgeEnter==IN action===%s===ID:%s   Name:%s", event["Event"], event["CallerIDNum"], event["CallerIDName"])
			alstatus.AlarmStatus(event["CallerIDName"], "connect") // Alarm connected

			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "PAD-TMS"
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.PADTMS)
			if active.CabNum == "1" && active.Actived {
				go RedirectInQueue(event["CallerIDName"], "2311", "chanspy-rule-whisper", "") //PAD chanspy(EqW) ICP1
				go Dial("0403", event["CallerIDName"], "chanspy-rule", "2381", "2381", "8")   //ICP8---chanspy----PAD
			} else if active.CabNum == "8" && active.Actived {
				go RedirectInQueue(event["CallerIDName"], "2381", "chanspy-rule-whisper", "") //PAD chanspy(EqW) ICP8
				go Dial("0403", event["CallerIDName"], "chanspy-rule", "2311", "2311", "1")   //ICP1---chanspy----PAD
			}
		} else if utils.IsPAIU(event["CallerIDNum"]) && event["Exten"] == "0405" { // PAD connect ICP-TMS;PACU not available

			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "PAD-TMS"
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.PADTMS)
			lfshook.NewLogger().Infof("====send pad status=====")
			alstatus.AlarmStatus(event["CallerIDNum"], "connect") // PAD connect ICP-TMS
		}
	}
}

func StartAMI(connectOKCallBack func(), handleEvents []func(event map[string]string)) {
	lfshook.NewLogger().Info("Start AMI")
	settings := &amigo.Settings{
		Host:     configs.ConfigGlobal.AsteriskAMIHost,
		Port:     configs.ConfigGlobal.AsteriskAMIPort,
		Username: configs.ConfigGlobal.AsteriskAMIUser,
		Password: configs.ConfigGlobal.AsteriskAMISecret,
		LogLevel: logrus.ErrorLevel}
	lfshook.NewLogger().Infof("ami setting: %+v", settings)
	AminInstance = amigo.New(settings, lfshook.NewLogger())
	AminInstance.EventOn(func(payload ...interface{}) {
		// lfshook.NewLogger().Infof("ami event on %+v", payload[0])
		event := payload[0].(map[string]string)

		go HandleAMI(event)

		for _, handle := range handleEvents {
			go handle(event)
		}

	})
	AminInstance.ConnectOn(func(payload ...interface{}) {
		lfshook.NewLogger().Infof("ami connect on %+v", payload[0])
		if payload[0] == pkg.Connect_OK {

			connectOKCallBack()
		} else {
			lfshook.NewLogger().Errorf("ami connect failure %+v", payload)
		}
	})
	AminInstance.Connect()
}

func Connected() bool {
	if AminInstance != nil {
		return AminInstance.Connected()
	}
	return false
}