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

package action

import (
	"fmt"
	"os"
	"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"
	"sort"
	"strconv"
	"strings"
	"time"

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

var AminInstance *amigo.Amigo
var trainInfo = ""

func HandleAMI(event map[string]string) {

	switch event["Event"] {

	case "DTMFBegin": //ICP interrupt PAD
		lfshook.NewLogger().Infof("=========%s====caller:%s=====digit:%s==", event["Event"], event["CallerIDNum"], event["Digit"])
		if priority.RunningType != "PAD-ICP" && priority.RunningType != "PAD-TMS" && priority.RunningType != "PAD-OCC" {
			break
		}

		if utils.IsICP(event["CallerIDNum"]) && event["Exten"] != "" {

			chans, err := CoreShowChannels()
			if err != nil {
				lfshook.NewLogger().Errorf("CoreShowChannels %+v", err)
			}

			//PA interrupt PAD
			if event["Digit"] == "#" {

				//1. Redirect the connected PAD to 0300
				if priority.RunningType == "PAD-ICP" || priority.RunningType == "PAD-TMS" {
					for _, ret := range chans {
						//hangup pad call ICP channel
						if utils.IsPAIU(ret.CallerIDNum) {
							if ret.ConnectedLineNum == "<unknown>" { //redirect pad chanspy channel
								err := Redirect(ret.Channel, "0300", "queues-icp-redirect", "", "PAD")
								if err != nil {
									lfshook.NewLogger().Errorf("Redirect %+v", err)
								}

								number := strings.Split(strings.Split(ret.Channel, "-")[0], "/")[1]
								active.NotifyPaiu(number, "hold")
								//HangupAllLocalChan()
							}
						}
					}

					for _, ret := range chans {
						//hangup pad call ICP channel
						if utils.IsPAIU(ret.CallerIDNum) {
							if utils.IsPAIU(ret.CallerIDNum) && ret.ChannelStateDesc == "Up" && utils.IsICP(ret.ConnectedLineNum) {
								lfshook.NewLogger().Infof("===Hangup=Chan===%+v==== ", ret.Channel)
								Hangup(ret.Channel)
							}
						}
					}
					HangupRunningTask("PA")
				} else if priority.RunningType == "PAD-OCC" {
					//2. hangup connected PAD, and redirect all PADs in 0301 to 0300
					priority.OCCAnswer = 0

					resCaller, err := QueueStatus("0301", "") // check OCC queue, get entries
					if err != nil {
						lfshook.NewLogger().Infof("===QueueStatus==%+v", err)
					}
					for _, caller := range resCaller.Entrys {
						lfshook.NewLogger().Infof("===QueueStatus=entry=%+v", caller)
						time.Sleep(time.Millisecond * 100)
						RedirectInQueue(caller.CallerIDNum, "0300", "queues-icp-redirect", caller.CallerIDNum) // redirect All PAD redirect to ICP queue
					}

					/*	for _, ret := range chans {
						//hangup pad call ICP channel
						if utils.IsPAIU(ret.CallerIDNum) {
							lfshook.NewLogger().Infof("===DTMFBegin=hangup=%+v==%s=== ", ret.Channel, ret.ChannelStateDesc)

							if ret.ConnectedLineNum == "<unknown>" && ret.ChannelStateDesc != "Ring" { //redirect pad chanspy channel
								Hangup(ret.Channel)
							} else if utils.IsICP(ret.ConnectedLineNum) && ret.ChannelStateDesc == "Up" {
								Hangup(ret.Channel)
							}
						}
					}*/
					HangupRunningTask("PA")
					//HangupAllLocalChan()
				}
			} else if event["Digit"] == "*" { //Cab cab interrupt PAD
				lfshook.NewLogger().Infof("===Cab cab interrupt PAD====== ")
				if priority.RunningType == "PAD-ICP" || priority.RunningType == "PAD-TMS" {
					for _, ret := range chans {

						if utils.IsPAIU(ret.CallerIDNum) {
							if ret.ConnectedLineNum == "<unknown>" && ret.ChannelStateDesc == "Up" { //redirect pad chanspy channel
								err := Redirect(ret.Channel, "0300", "queues-icp-redirect", "", "PAD")
								if err != nil {
									lfshook.NewLogger().Errorf("Redirect %+v", err)
								}

								number := strings.Split(strings.Split(ret.Channel, "-")[0], "/")[1]
								active.NotifyPaiu(number, "hold")
								//HangupAllLocalChan()

							} else if utils.IsPAIU(ret.CallerIDNum) && ret.ChannelStateDesc == "Up" && utils.IsICP(ret.ConnectedLineNum) {
								lfshook.NewLogger().Infof("===Hangup=Chan===%+v==== ", ret.Channel)
								Hangup(ret.Channel)
							}
						}
					}
					priority.InterruptedPad = priority.RunningType
					HangupAllLocalChan()
					if !strings.Contains(priority.RunningPATaskChan, "0502@default") {
						Hangup(priority.RunningPATaskChan)
					}
					priority.CleanPriorityTag()
					//HangupRunningTask("C2C")
				} else if priority.RunningType == "PAD-OCC" {
					HangupICP()
				}
			}
		}

	case "UserEvent": // RCD filename; PA;CPA; CabCab
		lfshook.NewLogger().Infof("========event:%s   File:%s", event["Event"], event["FILENAME"])

		if event["UserEvent"] == "CallType" && (event["Type"] == "PA" || event["Type"] == "CPA") { //PA start; check manual PA priority
			//PA & CPA interrupt others
			if utils.IsICP(event["CallerIDNum"]) {

				if active.ActivedCab == "" { //No active Signal on both side,Hangup caller
					Hangup(event["CallerIDNum"])
				}

				if priority.CheckPriority("ManuPa") {
					//hangup others if priority is higher
					lfshook.NewLogger().Infof("=====UserEvent===event======PA start=======")
					HangupRunningTask("PA") //PA interrupt other
					priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.ManuPa)
				} else {
					Hangup(event["CallerIDNum"]) //lowwer priority ,hangup caller
				}

			} else if utils.IsIO(event["CallerIDNum"]) { // CPA
				if priority.CheckPriority("CPA") {
					if active.ActivedCab == "" { //No active Signal on both side,Hangup caller
						Hangup(event["CallerIDNum"])
					} else if active.ActivedCab == "1" && event["CallerIDNum"] == "1411" {
						Hangup(event["CallerIDNum"])
					} else if active.ActivedCab == "8" && event["CallerIDNum"] == "1481" {
						Hangup(event["CallerIDNum"])
					}

					//hangup others if priority is higher
					if priority.RunningType != "" {
						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") { // interrupt OCC-PAD
				//C2C start PAD interrupt
				if priority.RunningType == "PAD-ICP" || priority.RunningType == "PAD-TMS" || priority.RunningType == "PA" {
					HangupRunningTask("C2C")
					//Hangup the other ICP
				} else {
					lfshook.NewLogger().Infof("========CabCab  hangup other one====caller %s", event["CallerIDNum"])
					if event["CallerIDNum"] == "2311" {
						Hangup("2381")
					} else {
						Hangup("2311")
					}
				}
				priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.CabCab)
			} else { // hangup caller; C2C start failed
				lfshook.NewLogger().Infof("========CabCab  hangup caller====%s", event["CallerIDNum"])
				Hangup(event["CallerIDNum"])
			}

			//Get  record file name ,encode and upload
		} else if event["UserEvent"] == "SetRecordFile" {

			if configs.ConfigGlobal.ProcessRecord != "yes" {
				break
			}

			//检测录音文件是否存在;最多检测5次，每次间隔1秒
			var fileExists bool
			for i := 0; i < 5; i++ {
				time.Sleep(time.Second) // 等待1秒

				if _, err := os.Stat(event["FILENAME"]); err == nil {
					fileExists = true
					lfshook.NewLogger().Infof("File found: %s", event["FILENAME"])
					break
				} else if os.IsNotExist(err) {
					lfshook.NewLogger().Infof("File not found (attempt %d): %s", i+1, event["FILENAME"])
				} else {
					lfshook.NewLogger().Infof("Error checking file: %v", err)
				}
			}

			if !fileExists { //5秒内没有生成录音文件
				lfshook.NewLogger().Infof("File %s not found after 5 attempts", event["FILENAME"])
				break
			}

			//获取录音文件时长，检测录音文件是否超过3min;
			duration, err := utils.GetDuration(event["FILENAME"])
			if err != nil {
				utils.Logger.Printf("Get duration err: %+v", err)
				break
			}
			//lfshook.NewLogger().Infof("==========duration===== %d", duration)
			//转wav文件的采样率到22kHz，并切割位180秒每段
			var FileNames []string
			if duration >= 600 { //超过600秒的超长文件，不处理
				lfshook.NewLogger().Infof("File over 600 sec, Ignored !")
				break
			} else if duration < 600 { //小于600秒文件进行转换和切割
				FileNames, err = utils.ConvertAndSegmentWAV(event["FILENAME"], strings.Replace(event["FILENAME"], ".wav", "", -1))
				if err != nil {
					lfshook.NewLogger().Infof("Get duration err: %+v", err)
					break
				}
				//lfshook.NewLogger().Infof("=============== File %+v found after convert", FileNames)
			}

			//执行加密操作,并将录音信息写入日志文件
			DstFile := ""
			if len(FileNames) > 0 { // 文件切割之后进入循环处理
				for _, filepath := range FileNames {

					file := strings.Replace(filepath, ".wav", "", -1)
					DstFile = fmt.Sprintf("%s-encrypted.wav", file)

					lfshook.NewLogger().Infof("Bin file====%s", DstFile)
					err = utils.AudioFileEncode(DstFile, filepath)
					if err != nil {
						lfshook.NewLogger().Infof("Encode file: %s err: %+v", DstFile, err)
						continue
					}
					//切割&加密之后发送生成的文件名到STC;
					alstatus.SendRecordFile(DstFile, event["RecordType"])

					trainInfo = active.ActivedCab

					if strings.Contains(event["FILENAME"], "PAD") {
						_, caller, callee := utils.GetPadInfo(event["FILENAME"])
						utils.Logger.Printf("Train Information: CabNumber %s, MessageType: PAD , CabNumber: %c , LocationCode: %c, Connected: %s, RecordFileName:%s", trainInfo, caller[2], caller[3], callee, DstFile)
					} else if strings.Contains(event["FILENAME"], "PA") {
						_, caller, _ := utils.GetPadInfo(event["FILENAME"])
						utils.Logger.Printf("Train Information: CabNumber %s, MessageType: PA, Caller: %s, RecordFileName: %s", trainInfo, caller, DstFile)
					} else if strings.Contains(event["FILENAME"], "C2C") {
						_, caller, _ := utils.GetPadInfo(event["FILENAME"])
						utils.Logger.Printf("Train Information: CabNumber %s, MessageType: CabCab, Caller: %s, RecordFileName: %s", trainInfo, caller, DstFile)
					} else if strings.Contains(event["FILENAME"], "CPA") {
						_, caller, _ := utils.GetPadInfo(event["FILENAME"])
						utils.Logger.Printf("Train Information: CabNumber %s, MessageType: CPA, Caller: %s, RecordFileName: %s", trainInfo, caller, DstFile)
					} else if strings.Contains(event["FILENAME"], "EMG") {
						utils.Logger.Printf("Train Information: CabNumber %s, MessageType: EMG, RecordFileName: %s", trainInfo, DstFile)
					} else if strings.Contains(event["FILENAME"], "STN") {
						utils.Logger.Printf("Train Information: CabNumber %s, MessageType: STN, RecordFileName: %s", trainInfo, DstFile)
					} else if strings.Contains(event["FILENAME"], "DCS") {
						utils.Logger.Printf("Train Information: CabNumber %s, MessageType: DCS, RecordFileName: %s", trainInfo, DstFile)
					} else if strings.Contains(event["FILENAME"], "SPC") {
						utils.Logger.Printf("Train Information: CabNumber %s, MessageType: SPC, RecordFileName: %s", trainInfo, DstFile)
					} else if strings.Contains(event["FILENAME"], "CHK") {
						utils.Logger.Printf("Train Information: CabNumber %s, MessageType: Self Check, RecordFileName: %s", trainInfo, DstFile)
					} else if strings.Contains(event["FILENAME"], "TONE") {
						utils.Logger.Printf("Train Information: CabNumber %s, MessageType: TONE Test, RecordFileName: %s", trainInfo, DstFile)
					}
				}
			} else {
				lfshook.NewLogger().Infof("No files to upload!!!")
				break
			}
		}

	case "Hangup":

		lfshook.NewLogger().Infof("=========%s", event["Event"])
		//OCC answer PAD, hangup, redirect the next PAD to OCC
		if utils.IsIO(event["CallerIDNum"]) && (event["ConnectedLineNum"] == "ano1" || event["ConnectedLineNum"] == "ano8") && event["Context"] == "default" {
			lfshook.NewLogger().Infof("====Hangup OCC-PAD=====%+v", event)
			// OCC hangup detected, hangup other running channels
			HangupAllLocalChan()
			if !strings.Contains(priority.RunningPATaskChan, "0502@default") {
				Hangup(priority.RunningPATaskChan)
			}

			res, _ := QueueStatus("0301", "") // check OCC queue ,if empty PAD end
			if res.Calls == "0" {             //OCC queue is empty
				priority.CleanPriorityTag()
				alstatus.OccPad("end")
				priority.OCCAnswer = 0
				priority.PADOccStart = 0

				if active.EMGCONFID != "" {
					priority.RunningType = "EMG"
					priority.RunningTypePriority = active.InfoEMG.Priority
					priority.RunningPATaskChan = active.InfoEMG.RunChannel

					time.Sleep(time.Millisecond * 300)
					active.ICPCONBID = active.EMGCONFID
					EMGConfbridgeReinvite(active.EMGCONFID)
					return
				}

				if active.ICPCONBID != "" {
					ConfbridgeKick(active.ICPCONBID, "all")
					active.ICPCONBID = ""
				}
				break
			} else { //OCC queue is not empty
				//	HangupAllLocalChan()
				time.Sleep(time.Millisecond * 300)
				lfshook.NewLogger().Infof("====Start OCC-PAD===next==%+v", res)
				if active.ActivedCab == "1" && ExtenStatus("1411") == "Idle" { //check active and OCC status
					time.Sleep(time.Second)
					PADChan := ""
					for _, chanEntry := range res.Entrys {
						lfshook.NewLogger().Infof("====PAD answered by OCC1 pos:%s===chan:%s=", chanEntry.Position, chanEntry.Channel)
						if chanEntry.Position == "1" {
							PADChan = chanEntry.Channel
							break
						}
					}

					if PADChan != "" {
						Ext := strings.Split(strings.Split(res.Entrys[0].Channel, "/")[1], "-")[0]

						alstatus.AlarmStatus(Ext, "connect")
						go RedirectInQueue(PADChan, "1411", "pad-page-occ-icp", Ext) //PAD Page(OCC+ICPs)

						go Dial("0401", "0512", "pad-rule-pacus-occ", "ano1", "ano1", "1") // PACUs dial OCC1
					} else {
						lfshook.NewLogger().Infof("===OCC-QueueStatus==PADCchan NULL")
					}
					break
				} else if active.ActivedCab == "8" && ExtenStatus("1481") == "Idle" {
					time.Sleep(time.Second)
					PADChan := ""
					for _, chanEntry := range res.Entrys {
						lfshook.NewLogger().Infof("====PAD answered by OCC1 pos:%s===chan:%s=", chanEntry.Position, chanEntry.Channel)
						if chanEntry.Position == "1" {
							PADChan = chanEntry.Channel
							break
						}
					}

					if PADChan != "" {
						Ext := strings.Split(strings.Split(res.Entrys[0].Channel, "/")[1], "-")[0]

						alstatus.AlarmStatus(Ext, "connect")
						go RedirectInQueue(PADChan, "1481", "pad-page-occ-icp", Ext) //PAD Page(OCC+ICPs)

						go Dial("0401", "0512", "pad-rule-pacus-occ", "ano8", "ano8", "8") // PACUs dial OCC1
					} else {
						lfshook.NewLogger().Infof("===OCC-QueueStatus==PADCchan NULL")
					}
					break
				}
			}
		}

		if utils.IsPAIU(event["CallerIDNum"]) { // PAD hangup, check if PAD all end, send PAD end status

			number := strings.Split(strings.Split(event["Channel"], "-")[0], "/")[1]

			lfshook.NewLogger().Infof("===hangup PAD =======================%s", number)

			if utils.IsPAIU(number) {
				res, _ := QueueStatus("0300", "")  // check ICP queue ,if empty PAD end
				res1, _ := QueueStatus("0301", "") // check OCC queue ,if empty PAD end

				lfshook.NewLogger().Infof("==calls:%s===calls1:%s====", res.Calls, res1.Calls)
				if res.Calls == "0" && res1.Calls == "0" {
					//priority.CleanPriorityTag()
					//HangupAllLocalChan()
					if priority.PADStart == 1 {
						SetPadTimer()
						alstatus.PaStatus(event["CallerIDNum"], "PAD", "end")
						priority.PADStart = 0

						priority.CleanPriorityTag()
						if active.EMGCONFID != "" {
							priority.RunningType = "EMG"
							priority.RunningTypePriority = active.InfoEMG.Priority
							priority.RunningPATaskChan = active.InfoEMG.RunChannel
							time.Sleep(time.Millisecond * 300)
							active.ICPCONBID = active.EMGCONFID
							EMGConfbridgeReinvite(active.EMGCONFID)
							return
						}
						if active.ICPCONBID != "" {
							ConfbridgeKick(active.ICPCONBID, "all")
							active.ICPCONBID = ""
						}
					}

					priority.ICPAnswer = 0
					priority.OCCAnswer = 0
					break
				}
			}
		}

	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"]) && utils.IsPAIU(event["CallerIDName"]) && event["Queue"] == "0300" { // Alarm join the queue, PAD in the queue
			alstatus.AlarmStatus(event["CallerIDNum"], "queue") //send status to STC

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

			if priority.ICPAnswer == 0 && ICPQueue.Calls == "1" { //ICP did not answer any first call to the ICP queue ; Ready to Set Occ Queue Timer
				toRunpriority := priority.GetPriorityByKey("PAD-ICP")

				//PAD press key
				lfshook.NewLogger().Infof("===QueueCallerJoin===runing:%d=====toRun:=%d==Status:%s", priority.RunningTypePriority, toRunpriority, event["ChannelStateDesc"])
				if (priority.RunningTypePriority > toRunpriority || priority.RunningTypePriority == 0) && event["ChannelStateDesc"] != "Up" {

					active.QueueTimer = time.AfterFunc(30*time.Second, func() { // check the PAD 30s timeout

						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
							}
							sort.Slice(resCaller.Entrys, func(i, j int) bool {
								return resCaller.Entrys[i].Position < resCaller.Entrys[j].Position
							})

							for _, caller := range resCaller.Entrys {
								priority.ICPAnswer = 0
								lfshook.NewLogger().Infof("====QueueCallerJoin==QueueTimer===%s", event["Event"])
								lfshook.NewLogger().Infof("====Redirect to 0301 entry:%s=Pos:%s==", caller.CallerIDNum, caller.Position)
								//order by pos
								RedirectInQueue(caller.CallerIDNum, "0301", "queues-occ", caller.CallerIDNum) // redirect All ICP-PAD redirect to OCC queue
								time.Sleep(time.Millisecond * 100)                                            //200 ms delay
							}
						}
					})
				}
			}

			break
		}

		//first PAD caller goto OCC
		//OCC dial PACUs;
		//PAD Page OCC+ICPs;
		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

				time.Sleep(time.Millisecond * 300)
				if active.ActivedCab == "1" && ExtenStatus("1411") == "Idle" { //check active and OCC status
					/*if priority.PADOccStart == 0 {
						alstatus.OccPad("start")
						priority.PADOccStart = 1
						if priority.PADStart == 0 {
							alstatus.PaStatus(event["CallerIDNum"], "PAD", "start")
							priority.PADStart = 1
						}
					}*/

					alstatus.AlarmStatus(event["CallerIDNum"], "connect")
					go RedirectInQueue(event["Channel"], "1411", "pad-page-occ-icp", event["CallerIDNum"]) //PAD Page(OCC+ICPs)
					go Dial("0401", "0512", "pad-rule-pacus-occ", "ano1", "ano1", "1")                     // PACUs dial OCC1

				} else if active.ActivedCab == "8" && ExtenStatus("1481") == "Idle" {
					/*if priority.PADOccStart == 0 {
						alstatus.OccPad("start")
						priority.PADOccStart = 1
						if priority.PADStart == 0 {
							alstatus.PaStatus(event["CallerIDNum"], "PAD", "start")
							priority.PADStart = 1
						}
					}*/

					alstatus.AlarmStatus(event["CallerIDNum"], "connect")
					go RedirectInQueue(event["Channel"], "1481", "pad-page-occ-icp", event["CallerIDNum"]) //PAD Page(OCC+ICPs)
					go Dial("0401", "0512", "pad-rule-pacus-occ", "ano8", "ano8", "8")                     // PACUs dial OCC8
				}
			} else {
				lfshook.NewLogger().Infof("====PAD-OCC Priority false===")
			}
		}

	case "ConfbridgeJoin":
		lfshook.NewLogger().Infof("=========%+v", 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)
				//active.ICPCONBID = event["Conference"]
				//active.ICPCONBTYP = "EMG"
				active.EMGCONFID = event["Conference"]
				//================================
				active.InfoEMG.RunChannel = event["Channel"]
				active.InfoEMG.Priority = priority.RunningTypePriority
				active.InfoEMG.RunType = "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)
				active.ICPCONBID = event["Conference"]
				active.ICPCONBTYP = "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)
				active.ICPCONBID = event["Conference"]
				active.ICPCONBTYP = "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)
				active.ICPCONBID = event["Conference"]
				active.ICPCONBTYP = "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)
				active.ICPCONBID = event["Conference"]
				active.ICPCONBTYP = "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)
				active.ICPCONBID = event["Conference"]
				active.ICPCONBTYP = "VOL"
				alstatus.PaStatus("", "VOL", "start")
				return
			}
		}

		//get confbridge id for join back to confbridge
		if event["Context"] == "pad-page-occ-icp" && utils.IsPAIU(event["CallerIDNum"]) {
			active.ICPCONBID = event["Conference"] //pad-occ
		}

		//Send PA start msg to STC
		if utils.IsICP(event["CallerIDNum"]) && event["Exten"] == "0500" { // PA start

			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.ManuPa)
			alstatus.PaStatus(event["CallerIDNum"], "PA", "start")
			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "PA"
			active.ICPCONBID = event["Conference"] //cpa
			active.ICPCONBTYP = "PA"
			break
		} else if utils.IsIO(event["CallerIDNum"]) && event["Exten"] == "0501" { //CPA start

			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.CPA)
			alstatus.PaStatus(event["CallerIDNum"], "CPA", "start")
			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "CPA"
			//active.ICPCONBID = event["Conference"] //cpa icp
			//active.ICPCONBTYP = "CPA"
			active.CPACONFID = event["Conference"] //cpa

			//=====================================
			active.InfoCPA.RunChannel = event["Channel"]
			active.InfoCPA.Priority = priority.RunningTypePriority
			active.InfoCPA.RunType = "CPA"

			return
		}

		//ICP answer PAD;PACUs connected ICP
		//PAD chanspy ICP1
		//ICP8 call 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

			if ExtenStatus("2381") == "Idle" {
				go Dial("0402", event["ConnectedLineName"], "call-pad-rule", event["ConnectedLineName"], event["ConnectedLineName"], "8") // PAD call ICP8
			}
		}
		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

			if ExtenStatus("2311") == "Idle" {
				go Dial("0402", event["ConnectedLineName"], "call-pad-rule", event["ConnectedLineName"], event["ConnectedLineName"], "1") // PAD call ICP1
			}
			break
		}

		//OCC answer PAD;Set the task channel
		if utils.IsPAIU(event["CallerIDNum"]) && utils.IsIO(event["Exten"]) && event["Context"] == "pad-page-occ-icp" { //PAD Page OCC1+ICPs connected
			lfshook.NewLogger().Infof("====PAD answered by OCC:====")

			priority.RunningPATaskChan = event["Channel"]
			priority.RunningType = "PAD-OCC"
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.PADOCC)
			break
		}

	case "ConfbridgeLeave":
		lfshook.NewLogger().Infof("=========%s", event["Event"])
		if utils.IsICP(event["CallerIDNum"]) && event["Exten"] == "0500" { // PA end

			SetPadTimer()
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDNum"], "PA", "end")

			lfshook.NewLogger().Infof("====active.EMGCONFID:%s ====active.ICPCONBID:=%s", active.EMGCONFID, active.ICPCONBID)

			if active.EMGCONFID != "" {
				priority.RunningType = "EMG"
				priority.RunningTypePriority = active.InfoEMG.Priority
				priority.RunningPATaskChan = active.InfoEMG.RunChannel
				time.Sleep(time.Millisecond * 300)
				active.ICPCONBID = active.EMGCONFID
				EMGConfbridgeReinvite(active.EMGCONFID)
				return
			}

			if active.ICPCONBID != "" {
				ConfbridgeKick(active.ICPCONBID, "all")
				active.ICPCONBID = ""
			}
		} else if utils.IsIO(event["CallerIDNum"]) && event["Exten"] == "0501" { //CPA end

			SetPadTimer()
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDNum"], "CPA", "end")

			if active.EMGCONFID != "" {
				priority.RunningType = "EMG"
				priority.RunningTypePriority = active.InfoEMG.Priority
				priority.RunningPATaskChan = active.InfoEMG.RunChannel
				time.Sleep(time.Millisecond * 300)

				active.ICPCONBID = active.EMGCONFID
				EMGConfbridgeReinvite(active.EMGCONFID)
				return
			}
			if active.ICPCONBID != "" {
				ConfbridgeKick(active.ICPCONBID, "all")
				active.ICPCONBID = ""
			}
			//lfshook.NewLogger().Infof("=========%s", event["Event"])
		} else if event["CallerIDName"] == "EMG" && event["Exten"] == "0502" { // EMG broadcast hangup

			SetPadTimer()
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "EMG", "end")

		} else if event["CallerIDName"] == "STN" && event["Exten"] == "0503" {

			SetPadTimer()
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "STN", "end")

			if active.EMGCONFID != "" {
				priority.RunningType = "EMG"
				priority.RunningTypePriority = active.InfoEMG.Priority
				priority.RunningPATaskChan = active.InfoEMG.RunChannel
				time.Sleep(time.Millisecond * 300)
				active.ICPCONBID = active.EMGCONFID
				EMGConfbridgeReinvite(active.EMGCONFID)
				return
			}
			if active.ICPCONBID != "" {
				ConfbridgeKick(active.ICPCONBID, "all")
				active.ICPCONBID = ""
			}
		} else if event["CallerIDName"] == "DCS" && event["Exten"] == "0504" {

			SetPadTimer()
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "DCS", "end")

			if active.EMGCONFID != "" {
				priority.RunningType = "EMG"
				priority.RunningTypePriority = active.InfoEMG.Priority
				priority.RunningPATaskChan = active.InfoEMG.RunChannel
				time.Sleep(time.Millisecond * 300)
				active.ICPCONBID = active.EMGCONFID
				EMGConfbridgeReinvite(active.EMGCONFID)
				return
			}
			if active.ICPCONBID != "" {
				ConfbridgeKick(active.ICPCONBID, "all")
				active.ICPCONBID = ""
			}
		} else if event["CallerIDName"] == "SPC" && event["Exten"] == "0505" {

			SetPadTimer()
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "SPC", "end")

			if active.EMGCONFID != "" {
				priority.RunningType = "EMG"
				priority.RunningTypePriority = active.InfoEMG.Priority
				priority.RunningPATaskChan = active.InfoEMG.RunChannel
				time.Sleep(time.Millisecond * 300)
				active.ICPCONBID = active.EMGCONFID
				EMGConfbridgeReinvite(active.EMGCONFID)
				return
			}
			if active.ICPCONBID != "" {
				ConfbridgeKick(active.ICPCONBID, "all")
				active.ICPCONBID = ""
			}
		} else if event["CallerIDName"] == "CHK" && event["Exten"] == "0510" {
			SetPadTimer()
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "CHK", "end")

			if active.EMGCONFID != "" {
				priority.RunningType = "EMG"
				priority.RunningTypePriority = active.InfoEMG.Priority
				priority.RunningPATaskChan = active.InfoEMG.RunChannel
				time.Sleep(time.Millisecond * 300)
				active.ICPCONBID = active.EMGCONFID
				EMGConfbridgeReinvite(active.EMGCONFID)
				return
			}

			if active.ICPCONBID != "" {
				ConfbridgeKick(active.ICPCONBID, "all")
				active.ICPCONBID = ""
			}
		} else if event["CallerIDName"] == "VOL" && event["Exten"] == "0513" {
			SetPadTimer()
			priority.CleanPriorityTag()
			alstatus.PaStatus(event["CallerIDName"], "VOL", "end")

			if active.EMGCONFID != "" {
				priority.RunningType = "EMG"
				priority.RunningTypePriority = active.InfoEMG.Priority
				priority.RunningPATaskChan = active.InfoEMG.RunChannel
				time.Sleep(time.Millisecond * 300)
				active.ICPCONBID = active.EMGCONFID
				EMGConfbridgeReinvite(active.EMGCONFID)
				return
			}

			if active.ICPCONBID != "" {
				ConfbridgeKick(active.ICPCONBID, "all")
				active.ICPCONBID = ""
			}
		}

	case "DialEnd":
		//lfshook.NewLogger().Infof("=========%s", event["Event"])
		//Cab Cab start
		if utils.IsICP(event["CallerIDNum"]) && utils.IsICP(event["ConnectedLineNum"]) && event["DialStatus"] == "ANSWER" {

			priority.TmpRunningTypePriority = priority.RunningTypePriority
			priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.CabCab)

			priority.TmpRunningType = priority.RunningType
			priority.RunningType = "C2C"

			alstatus.PaStatus(event["CallerIDNum"], "C2C", "start")
		} else if utils.IsICP(event["CallerIDNum"]) && utils.IsICP(event["ConnectedLineNum"]) && event["DialStatus"] == "NOANSWER" {

			lfshook.NewLogger().Infof("===%s======%s", event["Event"], priority.RunningType)
			//ICPs go back to confbridge
			//ICPConfbridgeReinvite(active.ICPCONBID, active.ICPCONBTYP)

			time.Sleep(time.Millisecond * 300)
			//check cpa & emg & opa confbridge
			if active.CPACONFID != "" && active.EMGCONFID != "" && priority.RunningTypePriority != 0 {
				if priority.GetPriorityByKey("CPA") < priority.GetPriorityByKey("EMG") && priority.GetPriorityByKey("CPA") < priority.RunningTypePriority {
					ICPConfbridgeReinvite(active.CPACONFID, "CPA")
					active.CPACONFID = ""
				} else if priority.GetPriorityByKey("EMG") < priority.GetPriorityByKey("CPA") && priority.GetPriorityByKey("EMG") < priority.RunningTypePriority {
					ICPConfbridgeReinvite(active.EMGCONFID, "EMG")
					active.EMGCONFID = ""
				} else if priority.RunningTypePriority < priority.GetPriorityByKey("EMG") && priority.GetPriorityByKey("CPA") > priority.RunningTypePriority {
					ICPConfbridgeReinvite(active.ICPCONBID, priority.RunningType)
					active.ICPCONBID = ""
					active.ICPCONBTYP = ""
				}

				//check cpa & emg confbridge
			} else if active.CPACONFID != "" && active.EMGCONFID != "" {
				if priority.GetPriorityByKey("CPA") < priority.GetPriorityByKey("EMG") {
					ICPConfbridgeReinvite(active.CPACONFID, "CPA")
					active.CPACONFID = ""
				} else {
					ICPConfbridgeReinvite(active.EMGCONFID, "EMG")
					active.EMGCONFID = ""
				}

				//check  emg & opa confbridge
			} else if active.EMGCONFID != "" && priority.RunningTypePriority != 0 {
				if priority.GetPriorityByKey("EMG") < priority.RunningTypePriority {
					ICPConfbridgeReinvite(active.EMGCONFID, "EMG")
					active.EMGCONFID = ""
				} else {
					ICPConfbridgeReinvite(active.ICPCONBID, priority.RunningType)
					active.ICPCONBID = ""
					active.ICPCONBTYP = ""
				}

				//check  cpa & opa confbridge
			} else if active.CPACONFID != "" && priority.RunningTypePriority != 0 {
				if priority.GetPriorityByKey("CPA") < priority.RunningTypePriority {
					ICPConfbridgeReinvite(active.CPACONFID, "CPA")
					active.CPACONFID = ""
				} else {
					ICPConfbridgeReinvite(active.ICPCONBID, priority.RunningType)
					active.ICPCONBID = ""
					active.ICPCONBTYP = ""
				}
			} else if active.CPACONFID != "" {

				ICPConfbridgeReinvite(active.CPACONFID, "CPA")
				active.CPACONFID = ""
			} else if active.EMGCONFID != "" {

				ICPConfbridgeReinvite(active.EMGCONFID, "EMG")
				active.EMGCONFID = ""
			} else if priority.RunningTypePriority != 0 {

				ICPConfbridgeReinvite(active.ICPCONBID, priority.RunningType)
				active.ICPCONBID = ""
				active.ICPCONBTYP = ""
			}
		}

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

			time.Sleep(time.Millisecond * 300)
			//check cpa & emg & opa confbridge
			if active.CPACONFID != "" && active.EMGCONFID != "" && priority.RunningTypePriority != 0 {
				if priority.GetPriorityByKey("CPA") < priority.GetPriorityByKey("EMG") && priority.GetPriorityByKey("CPA") < priority.RunningTypePriority {
					ICPConfbridgeReinvite(active.CPACONFID, "CPA")
					active.CPACONFID = ""
				} else if priority.GetPriorityByKey("EMG") < priority.GetPriorityByKey("CPA") && priority.GetPriorityByKey("EMG") < priority.RunningTypePriority {
					ICPConfbridgeReinvite(active.EMGCONFID, "EMG")
					active.EMGCONFID = ""
				} else if priority.RunningTypePriority < priority.GetPriorityByKey("EMG") && priority.GetPriorityByKey("CPA") > priority.RunningTypePriority {
					ICPConfbridgeReinvite(active.ICPCONBID, priority.RunningType)
					active.ICPCONBID = ""
					active.ICPCONBTYP = ""
				}

				//check cpa & emg confbridge
			} else if active.CPACONFID != "" && active.EMGCONFID != "" {
				if priority.GetPriorityByKey("CPA") < priority.GetPriorityByKey("EMG") {
					ICPConfbridgeReinvite(active.CPACONFID, "CPA")
					active.CPACONFID = ""
				} else {
					ICPConfbridgeReinvite(active.EMGCONFID, "EMG")
					active.EMGCONFID = ""
				}

				//check  emg & opa confbridge
			} else if active.EMGCONFID != "" && priority.RunningTypePriority != 0 {
				if priority.GetPriorityByKey("EMG") < priority.RunningTypePriority {
					ICPConfbridgeReinvite(active.EMGCONFID, "EMG")
					active.EMGCONFID = ""
				} else {
					ICPConfbridgeReinvite(active.ICPCONBID, priority.RunningType)
					active.ICPCONBID = ""
					active.ICPCONBTYP = ""
				}

				//check  cpa & opa confbridge
			} else if active.CPACONFID != "" && priority.RunningTypePriority != 0 {
				if priority.GetPriorityByKey("CPA") < priority.RunningTypePriority {
					ICPConfbridgeReinvite(active.CPACONFID, "CPA")
					active.CPACONFID = ""
				} else {
					ICPConfbridgeReinvite(active.ICPCONBID, priority.RunningType)
					active.ICPCONBID = ""
					active.ICPCONBTYP = ""
				}
			} else if active.CPACONFID != "" {

				ICPConfbridgeReinvite(active.CPACONFID, "CPA")
				active.CPACONFID = ""
			} else if active.EMGCONFID != "" {

				ICPConfbridgeReinvite(active.EMGCONFID, "EMG")
				active.EMGCONFID = ""
			} else if priority.RunningTypePriority != 0 {

				ICPConfbridgeReinvite(active.ICPCONBID, priority.RunningType)
				active.ICPCONBID = ""
				active.ICPCONBTYP = ""
			}

			//check other broadcast confbridge
			//ICPs go back to confbridge
			priority.TmpRunningType = ""
			priority.TmpRunningTypePriority = 0

		}

	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.IsIO(event["CallerIDNum"]) && utils.IsPAIU(event["ConnectedLineNum"]) {
			if priority.PADOccStart == 0 {
				alstatus.OccPad("start")
				priority.PADOccStart = 1
				if priority.PADStart == 0 {
					alstatus.PaStatus(event["CallerIDNum"], "PAD", "start")
					priority.PADStart = 1
				}
			}
		}

		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.ActivedCab == "1" {
				go RedirectInQueue(event["CallerIDName"], "2311", "chanspy-rule-whisper", "") //PAD chanspy(EqW) ICP1
				go Dial("0403", event["CallerIDName"], "call-pad-rule", "2381", "2381", "8")  //ICP8---call----PAD
			} else if active.ActivedCab == "8" {
				go RedirectInQueue(event["CallerIDName"], "2381", "chanspy-rule-whisper", "") //PAD chanspy(EqW) ICP8
				go Dial("0403", event["CallerIDName"], "call-pad-rule", "2311", "2311", "1")  //ICP1---call----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
}