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" "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 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") { //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 alstatus.PaStatus(event["CallerIDNum"], "PAD", "start") alstatus.AlarmStatus(event["CallerIDNum"], "dial") } case "SoftHangupRequest": //pre-recored broadcast end //lfshook.NewLogger().Infof("=========%s", event["Event"]) if event["CallerIDName"] == "EMG" && event["Exten"] == "0502" { // EMG broadcast hangup priority.CleanPriorityTag() alstatus.PaStatus(event["CallerIDName"], "EMG", "end") } else if event["CallerIDName"] == "STN" && event["Exten"] == "0503" { priority.CleanPriorityTag() alstatus.PaStatus(event["CallerIDName"], "STN", "end") } else if event["CallerIDName"] == "DCS" && event["Exten"] == "0504" { priority.CleanPriorityTag() alstatus.PaStatus(event["CallerIDName"], "DCS", "end") } else if event["CallerIDName"] == "SPC" && event["Exten"] == "0505" { priority.CleanPriorityTag() alstatus.PaStatus(event["CallerIDName"], "SPC", "end") } else if event["CallerIDName"] == "CHK" && event["Exten"] == "0510" { priority.CleanPriorityTag() alstatus.PaStatus(event["CallerIDName"], "CHK", "end") } else if event["CallerIDName"] == "VOL" && event["Exten"] == "0510" { priority.CleanPriorityTag() alstatus.PaStatus(event["CallerIDName"], "VOL", "end") } case "Hangup": //lfshook.NewLogger().Infof("=========%s", event["Event"]) if utils.IsPACU(event["CallerIDNum"]) && utils.IsICP(event["ConnectedLineNum"]) { // TMS-ICP answer PAD, hangup HangupAllLocalChan() res, _ := QueueStatus("0300", "") // check ICP queue ,if empty PAD end if res.Calls == "0" { priority.CleanPriorityTag() alstatus.PaStatus(event["CallerIDNum"], "PAD", "end") //priority.ICPAnswer = 0 break } } if utils.IsPAIU(event["CallerIDNum"]) && utils.IsICP(event["ConnectedLineNum"]) { // TMS-ICP answer PAD(PACU not availabe), hangup HangupAllLocalChan() res, _ := QueueStatus("0300", "") // check ICP queue ,if empty PAD end if res.Calls == "0" { priority.CleanPriorityTag() alstatus.PaStatus(event["CallerIDNum"], "PAD", "end") //priority.ICPAnswer = 0 break } } if (event["CallerIDNum"] == "ani1" || event["CallerIDNum"] == "ani8") && utils.IsICP(event["ConnectedLineNum"]) { // ICP answer PAD, hangup HangupAllLocalChan() res, _ := QueueStatus("0300", "") // check ICP queue ,if empty PAD end if res.Calls == "0" { priority.CleanPriorityTag() alstatus.PaStatus(event["CallerIDNum"], "PAD", "end") //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") //priority.OCCAnswer = 0 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) } if res.Calls == "0" { // OCC queue empty resCaller, err := QueueStatus("0300", "") // check ICP queue, get entries if err != nil { lfshook.NewLogger().Infof("===QueueStatus==%+v", err) } 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 alstatus.OccPad("start") 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" { alstatus.OccPad("start") 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"]) //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 } //set priority and send PA status msg switch event["CallerIDName"] { case "EMG": alstatus.PaStatus(event["CallerIDNum"], "EMG", "start") priority.RunningPATaskChan = event["Channel"] priority.RunningType = "EMG" //Pa status report priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.EMG) alstatus.PaStatus("", "EMG", "start") case "SPC": alstatus.PaStatus(event["CallerIDNum"], "SPC", "start") priority.RunningPATaskChan = event["Channel"] priority.RunningType = "SPC" //Pa status report priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.SPC) alstatus.PaStatus("", "EMG", "start") case "DCS": alstatus.PaStatus(event["CallerIDNum"], "DCS", "start") priority.RunningPATaskChan = event["Channel"] priority.RunningType = "DCS" //Pa status report priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.DCS) alstatus.PaStatus("", "EMG", "start") case "STN": alstatus.PaStatus(event["CallerIDNum"], "STN", "start") priority.RunningPATaskChan = event["Channel"] priority.RunningType = "STN" //Pa status report priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.STN) alstatus.PaStatus("", "STN", "start") case "CHK": alstatus.PaStatus(event["CallerIDNum"], "CHK", "start") priority.RunningPATaskChan = event["Channel"] priority.RunningType = "CHK" //Pa status report priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.CHK) alstatus.PaStatus("", "CHK", "start") case "VOL": alstatus.PaStatus(event["CallerIDNum"], "VOL", "start") priority.RunningPATaskChan = event["Channel"] priority.RunningType = "VOL" //Pa status report priority.RunningTypePriority, _ = strconv.Atoi(priority.Priority.VOL) alstatus.PaStatus("", "VOL", "start") } //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 utils.IsIO(event["CallerIDNum"]) && event["Exten"] == "0501" { //CPA end lfshook.NewLogger().Infof("====CPA status =====%s", "end") priority.CleanPriorityTag() alstatus.PaStatus(event["CallerIDNum"], "CPA", "end") } 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"]) { // 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 }