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

package action

import (
	"errors"
	"fmt"
	"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/pkg/lfshook"
	"pbx-api-gin/pkg/utils"
	"strings"
	"sync"
	"time"
)

var Pads = []string{"2413", "2414", "2415", "2421", "2422", "2423", "2424", "2425", "2431", "2432", "2433", "2434", "2435", "2441", "2442", "2443", "2444",
	"2445", "2451", "2452", "2453", "2454", "2455", "2461", "2462", "2463", "2464", "2465", "2471", "2472", "2473", "2474", "2475", "2481", "2482", "2483",
	"2484", "2485", "2411", "2412"}

var Pacus = []string{"2111", "2121", "2131", "2141", "2151", "2161", "2171", "2181"}

var Speakers = []string{"2111", "2121", "2131", "2141", "2151", "2161", "2171", "2181", "2311", "2381"}

// Function triggered before no cab occupied signal interrupt
func InActiveHangup() {
	if active.ActivedCab == "" {
		HangupTask("PA")
		HangupTask("CPA")
		HangupTask("VOL")
		//HangupTask("PAD-OCC")
	} else {
		HangupTask("PA")
		HangupTask("PAD-OCC")
		HangupTask("CPA")
		HangupTask("EMG")
		HangupTask("SPC")
		HangupTask("DCS")
		HangupTask("STN")
		HangupTask("CHK")
		HangupTask("VOL")
		Hangup("2311") //hangup cabcab
	}
}

// Hangup 挂断指定分机或通道
func Hangup(channel string) {
	lfshook.NewLogger().Infof("Hangup extensions/channel :%s", channel)
	if !utils.IsChannel(channel) {
		channel = fmt.Sprintf(`/^(PJ)?SIP\/%s-.*$/`, channel)
	}

	action := map[string]string{
		"Action":  "hangup",
		"Channel": channel,
	}
	//lfshook.NewLogger().Infof("hangup action :%+v", action)
	if _, _, err := AminInstance.Send(action); err != nil {
		lfshook.NewLogger().Errorf("Hangup %+v", err)
	}
}

// Hangup 挂断所有分机,除指定分机和PAD
func HangupAllExcept(caller string) {

	//all PACU
	for _, ret := range Pacus {
		Hangup(ret)
	}

	switch caller {
	case "2311":
		Hangup("1411") //IO1
		Hangup("1481") //IO8
		//Hangup("2311") //ICP1
		Hangup("2381") //ICP8
	case "2381":
		Hangup("1411") //IO1
		Hangup("1481") //IO8
		Hangup("2311") //ICP1
		//Hangup("2381") //ICP8
	case "1411":
		//Hangup("1411") //IO1
		Hangup("1481") //IO8
		Hangup("2311") //ICP1
		Hangup("2381") //ICP8
	case "1481":
		Hangup("1411") //IO1
		//Hangup("1481") //IO8
		Hangup("2311") //ICP1
		Hangup("2381") //ICP8
	case "":
		Hangup("1411") //IO1
		Hangup("1481") //IO8
		Hangup("2311") //ICP1
		Hangup("2381") //ICP8
	}
}

// Hangup task
func HangupTask(TaskName string) {
	lfshook.NewLogger().Infof("HangupTask Check TaskName:%s ", TaskName)

	if TaskName == "PAD-OCC" {
		resCaller, err := QueueStatus("0301", "") // check OCC queue, get entries
		if err != nil {
			lfshook.NewLogger().Infof("QueueStatus err:%+v", err)
			return
		}

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

	taskInfo, ok := priority.RegistryTask.Get(TaskName)
	if ok {
		HangupAllLocalChan()
		ConfbridgeKick(taskInfo.ConfbridgeID, "all")
		Hangup(taskInfo.RunChannel)
	}
}

// interrupt the running task
func InterruptRunningTask(toRunTask string) string {
	utils.LoggerDebug.Printf("InterruptRunningTask  TorunType:%s", toRunTask)

	var task priority.TaskInfo
	var taskName string
	var ok bool

	lfshook.NewLogger().Infof("InterruptRunningTask toRuntask:%s  ", toRunTask)

	if toRunTask != "PA" && toRunTask != "PAD-ICP" && toRunTask != "PAD-TMS" { // ignore C2C
		taskName, task, ok = priority.RegistryTask.HighestPriorityRunningTask1()
		if !ok {
			return ""
		}
	} else { // have to check C2C
		taskName, task, ok = priority.RegistryTask.HighestPriorityRunningTask()
		if !ok {
			return ""
		}
	}

	utils.LoggerDebug.Printf("InterruptRunningTask  RunningTask:%+v", taskName)
	//lfshook.NewLogger().Infof("InterruptRunningTask RunningTask:%+v  ", task)
	//same type return
	if toRunTask == taskName {
		if toRunTask == "PAD-ICP" || toRunTask == "PAD-TMS" || toRunTask == "PAD-OCC" {

			//Auto Answer PAD-OCC one by one, clean the old confbridge and channels before answer a new PAD .
			if toRunTask == "PAD-OCC" {
				Hangup(task.RunChannel) //pad
				ConfbridgeKick(task.ConfbridgeID, "all")
				HangupIO() //io
				//lfshook.NewLogger().Infof("===InterruptRunningTask=ret==== ")
			}
			return taskName
		}
	}

	//pad all  reset
	if toRunTask == "AlarmHoldResetAll" {
		HangupAllLocalChan()
		return taskName
	}

	switch task.RunType {
	case "SPC":
		if toRunTask == "C2C" {
			HangupICP()
		} else {
			ConfbridgeKick(task.ConfbridgeID, "all")
		}
		time.Sleep(time.Millisecond * 200)
	case "CHK":
		if toRunTask == "C2C" {
			HangupICP()
		} else {
			ConfbridgeKick(task.ConfbridgeID, "all")
		}
		time.Sleep(time.Millisecond * 200)
	case "DCS":
		if toRunTask == "STN" {
			return taskName
		} else if toRunTask == "C2C" {
			HangupICP()
		} else {
			ConfbridgeKick(task.ConfbridgeID, "all")
		}

		time.Sleep(time.Millisecond * 200)
	case "STN":
		if toRunTask == "DCS" {
			return taskName
		} else if toRunTask == "C2C" {
			HangupICP()
		} else {
			ConfbridgeKick(task.ConfbridgeID, "all")
		}
		time.Sleep(time.Millisecond * 200)
	case "CPA":
		//kick CPA members
		if toRunTask != "C2C" {
			CPAConfbridgeKick(task)
			//alstatus.PaStatus("", "CPA", "end")
		} else if toRunTask == "C2C" {
			HangupICP()
		}
		time.Sleep(time.Millisecond * 200)
	case "EMG":
		//kick EMG members
		if toRunTask == "EMG" {
			ConfbridgeKick(task.ConfbridgeID, "all")
		} else if toRunTask != "C2C" {

			EMGConfbridgeKick(task)
			//alstatus.PaStatus("", "EMG", "end")
		} else if toRunTask == "C2C" {
			HangupICP()
		}
		time.Sleep(time.Millisecond * 200)
	case "C2C": // Interrupt C2C task running,
		if toRunTask == "PA" || toRunTask == "PAD-ICP" || toRunTask == "PAD-TMS" {
			HangupICP()
			return taskName
		}

	case "PAD-ICP", "PAD-TMS": // Interrupt PAD task running,
		if toRunTask == "PAD-ICP" || toRunTask == "PAD-TMS" {
			break
		}

		priority.InterruptedPad = "PAD-ICP"

		//lfshook.NewLogger().Infof("InterruptRunningTask interrupt PAD-ICP/PAD-TMS ,Running type :%s !", task.RunType)

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

		//1. Redirect the connected PAD to 0300,hangup the other pad channel
		for _, ret := range chans {
			// Redirect the connected PAD to 0300
			if utils.IsPAIU(ret.CallerIDNum) {
				//lfshook.NewLogger().Infof("====interrupt PAD ==== %+v ", ret)

				if ret.ConnectedLineNum == "<unknown>" { //redirect pad chanspy channel
					err := Redirect(ret.Channel, "0300", "queues-icp-redirect", "", "PAD")
					if err != nil {
						lfshook.NewLogger().Infof("InterruptRunningTask Redirect err:%+v", err)
						return taskName
					}
					//lfshook.NewLogger().Infof("====interrupt PAD =1111=== %+v ", ret)
					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 PAD Channel :%+v", ret.Channel)
					Hangup(ret.Channel)
				}
			}
		}
		alstatus.PaStatus("", "PAD", "end")
		priority.RegistryTask.StopAndUnregister("PAD-ICP")
		priority.RegistryTask.StopAndUnregister("PAD-TMS")
		//2. hangup task channel (ICP + PACU)
		//lfshook.NewLogger().Infof("===InterruptRunningTask=2. hangup task channel === ")
		HangupAllLocalChan()
		HangupICP()

	case "PAD-OCC": // Interrupt PAD-OCC task running,

		if toRunTask == "C2C" {
			HangupICP()
			break

		} else {
			priority.InterruptedPad = "PAD-OCC"
			priority.OCCAnswer = 0

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

			if resCaller == nil {
				return taskName
			}

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

			priority.RegistryTask.StopAndUnregister("PAD-OCC")
			//2. Hangup connected PAD
			//lfshook.NewLogger().Infof("===InterruptRunningTask=Hangup connected PAD=== ")
			Hangup(task.RunChannel)

			//3. interrupt OCC-PAD Hangup OI
			if active.ActivedCab == "1" {
				Hangup("1411")
			} else if active.ActivedCab == "8" {
				Hangup("1481")
			} else {
				if active.ActivedCabDelay == "1" {
					Hangup("1411")
				} else if active.ActivedCabDelay == "8" {
					Hangup("1481")
				} else {
					Hangup("1411")
				}
			}

			HangupAllLocalChan()
			ConfbridgeKick(task.ConfbridgeID, "all")

			//occ pad end
			if priority.PADOccStart == 1 {
				alstatus.OccPad("end")
				alstatus.PaStatus("", "PAD", "end")
				priority.PADOccStart = 0
				priority.OCCAnswer = 0
			}
		}

	default:
		lfshook.NewLogger().Infof("InterruptRunningTask goto default !")
		//if !strings.Contains(priority.RunningPATaskChan, "0502@default") {
		//	Hangup(priority.RunningPATaskChan)
		//}
		if toRunTask != "C2C" && task.RunType != "PA" {
			Hangup(task.RunChannel)
			ConfbridgeKick(task.ConfbridgeID, "all")
		}
	}
	return taskName
}

// Hangup all ICP
func HangupICP() {
	Hangup("2311") //ICP1
	Hangup("2381") //ICP8
}

// Hangup all IO
func HangupIO() {
	Hangup("1411") //IO1
	Hangup("1481") //IO8
}

// Hangup all PACU
func HangupAllPACU() {
	//all PACU
	for _, ret := range Pacus {
		Hangup(ret)
	}
}

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

	for _, ret := range chans {
		if strings.Contains(ret.Channel, "Local") && !strings.Contains(ret.Channel, "0502@default") {
			//lfshook.NewLogger().Infof("HangupAllLocalChan=====hangup========= %+v", ret)
			Hangup(ret.Channel)
		}
	}
}

// Hangup all PACU
func HangupAllPAD() {
	//all PAD
	for _, ret := range Pads {
		Hangup(ret)
	}
}

// Hangup all calls
func HangupAll() {
	utils.ExecCmdAsync("/usr/sbin/asterisk", "-rx", "hangup request all")
}

// Dial 拨打号码
func Dial(src, dst, dialrule, callerID, callerName string, callType string) {
	chanel := fmt.Sprintf("%s/%s@default", "Local", src)
	action := map[string]string{
		"Action":   "Originate",
		"Channel":  chanel,
		"Exten":    dst,
		"Context":  dialrule,
		"CallerID": fmt.Sprintf("%s<%s>", callerName, callerID),
		"Priority": "1",
		"Variable": fmt.Sprintf("CAB=%s", callType),
		"async":    "true",
	}
	//lfshook.NewLogger().Infof("================dial action %+v", action)
	res, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Errorf("%+v", err)
	}
	lfshook.NewLogger().Info(res)
}

// Dial 拨打号码
func DialICP(src, dst, dialrule, callerID, callerName string) {
	chanel := fmt.Sprintf("%s/%s@call-icp", "Local", src)
	action := map[string]string{
		"Action":   "Originate",
		"Channel":  chanel,
		"Exten":    dst,
		"Context":  dialrule,
		"CallerID": fmt.Sprintf("%s<%s>", callerName, callerID),
		"Priority": "1",
		"Variable": fmt.Sprintf("CBID=%s", callerID),
		"async":    "true",
	}
	lfshook.NewLogger().Infof("dial action %+v", action)
	res, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Errorf("%+v", err)
	}
	lfshook.NewLogger().Info(res)
}

// 获取分机状态
func ExtenStatus(exten string) (Status string) {
	action := map[string]string{
		"Action":  "ExtensionState",
		"Exten":   exten,
		"Context": "default",
	}

	res, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Errorf("%+v", err)
		return ""
	}

	//lfshook.NewLogger().Infof("================ExtensionState:res %+v", res)
	return res["StatusText"]
}

// PACU ChanSpy
func ChanSpy(src, dst string, whisper, bargein bool) {
	lfshook.NewLogger().Infof("chan spy src:%s dst:%s", src, dst)

	//channel := fmt.Sprintf("%s/%s", utils.DialPrefix, dst)
	channel := fmt.Sprintf("Local/%s@aio-rule", dst)
	data := fmt.Sprintf("%s/%s,qBE", utils.DialPrefix, src)
	/*
		if whisper {
			data = fmt.Sprintf("%s,w", data)
		}

		if bargein {
			data = fmt.Sprintf("%s,B", data)
		}
	*/
	action := map[string]string{
		"Action":      "Originate",
		"Channel":     channel, // 不存在的通话
		"Application": "ChanSpy",
		"Data":        data, // 存在的通话
		"CallerID":    dst,
		"Async":       "true",
	}
	lfshook.NewLogger().Infof("PACU ChanSpy action %+v", action)
	_, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Errorf("%+v", err)
	}
}

// Redirect 转接
func RedirectInQueue(channel, dst, dialrule, callerID string) (err error) {
	//callerID := "redirect"
	//lfshook.NewLogger().Infof("redirect src %s to dst %s", channel, dst)
	if !utils.IsChannel(channel) {
		//callerID = channel
		if channel, err = GetChannelByExtenNotBridged(channel); err != nil {
			return err
		}
	}

	action := map[string]string{
		"Action":   "Redirect",
		"Channel":  channel,
		"Exten":    dst,
		"Context":  dialrule,
		"CallerID": callerID,
		"Priority": "1",
		"async":    "true",
	}
	lfshook.NewLogger().Infof("RedirectInQueue: %+v", action)
	res, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Error(err)
	}
	lfshook.NewLogger().Info(res)
	return err
}

// Redirect 转接
func Redirect(channel, dst, dialrule, callerID, callerName string) (err error) {
	//callerID := "redirect"
	//lfshook.NewLogger().Infof("redirect src %s to dst %s", channel, dst)
	if !utils.IsChannel(channel) {
		callerID = channel
		if channel, err = GetChannelByExten(channel); err != nil {
			return err
		}
	}

	action := map[string]string{
		"Action":   "Redirect",
		"Channel":  channel,
		"Exten":    dst,
		"Context":  dialrule,
		"CallerID": fmt.Sprintf("%s<%s>", callerName, callerID),
		"Priority": "1",
		"async":    "true",
	}
	lfshook.NewLogger().Infof("Redirect: %+v", action)
	res, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Error(err)
	}
	lfshook.NewLogger().Info(res)
	return err
}

func SetPadTimer() {

	//toRunPadpriority := priority.GetPriorityByKey(priority.InterruptedPad) //Get PAD priori 获取之前打断的报警优先级
	toRunPadpriority := priority.GetPriorityByKey("PAD-ICP")
	_, taskTmp, ok := priority.RegistryTask.HighestPriorityRunningTask()
	if ok {
		if taskTmp.Priority < toRunPadpriority { //higher priority task running ,do not set timer
			utils.LoggerDebug.Printf("PAD SetPadTimer runing priority:%d toRun priority:%d , return !", taskTmp.Priority, toRunPadpriority)
			return
		}
	}

	utils.LoggerDebug.Printf("PAD SetPadTimer check 0300")
	res, err := QueueStatus("0300", "")
	if err != nil {
		lfshook.NewLogger().Infof("QueueStatus err%+v", err)
		return
	}
	if res == nil {
		return
	}
	if res.Calls != "0" {

		utils.LoggerDebug.Printf("PAD SetPadTimer Set QueueTimer timeout %ds !", active.PADTimeout)
		//active.SetTimer = true
		//lfshook.NewLogger().Logger.Infof("=========Start PAD timer !=============")
		if active.QueueTimer != nil {
			if active.QueueTimer.Stop() {
				//lfshook.NewLogger().Logger.Infof("=========Release PAD timer true !============")
			} else {
				//lfshook.NewLogger().Logger.Infof("=========Release PAD timer false ! ============")
			}
		}
		//lfshook.NewLogger().Logger.Infof("=========Start PAD timer !======%d=======", active.PADTimeout)
		active.QueueTimer = time.AfterFunc(time.Duration(active.PADTimeout)*time.Second, func() { // check the PAD 30s timeout
			//active.QueueTimer = time.AfterFunc(30*time.Second, func() { // check the PAD 30s timeout
			//if both not active , return
			if active.ActivedCab == "" {
				return
			}

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

			if res == nil {
				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 err:%+v", err)
					return
				}

				if resCaller.Entrys != nil {
					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
						//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
					}
				}*/
				for _, ret := range alstatus.PadQueues {
					//utils.LoggerDebug.Printf("PAD to OCC exten:%s", ret.Exten)
					priority.ICPAnswer = 0
					//order by pos
					RedirectInQueue(ret.Exten, "0301", "queues-occ", ret.Exten) // redirect All ICP-PAD redirect to OCC queue
					time.Sleep(time.Millisecond * 100)
				}
			}
		})
	}

}

func ConfbridgeKick(confnum, channel string) (res map[string]string, err error) {

	action := map[string]string{
		"Action":     "ConfbridgeKick",
		"Conference": confnum,
		"Channel":    channel,
	}

	res, _, err = AminInstance.Send(action)
	if err != nil {
		return nil, err
	}
	lfshook.NewLogger().Infof("ConfbridgeKick res:%+v", res)

	if res["Response"] != "Success" {
		return nil, errors.New(res["Message"])
	}

	return res, nil
}

func CPAConfbridgeKick(confInfo priority.TaskInfo) (res map[string]string, err error) {

	if !confInfo.Running {
		utils.LoggerDebug.Printf("CPA CPAConfbridgeKick , not running, return .")
		return
	}

	utils.LoggerDebug.Printf("CPA CPAConfbridgeKick , kick all members .")

	chans, err := ConfbridgeList(confInfo.ConfbridgeID)
	if err != nil {
		return nil, errors.New(res["Message"])
	}

	for _, confChan := range chans {
		if active.TrainDevide == 1 {
			if active.CabNum == "1" { //在1车车厢内
				if !strings.Contains(confChan, "PJSIP/1411") {
					ConfbridgeKick(confInfo.ConfbridgeID, confChan)
				}
			} else { //在8车车厢内
				if !strings.Contains(confChan, "PJSIP/1481") {
					ConfbridgeKick(confInfo.ConfbridgeID, confChan)
				}
			}
		} else {
			if active.ActivedCab != "1" {
				if !strings.Contains(confChan, "PJSIP/1411") {
					ConfbridgeKick(confInfo.ConfbridgeID, confChan)
				}
			} else {
				if !strings.Contains(confChan, "PJSIP/1481") {
					ConfbridgeKick(confInfo.ConfbridgeID, confChan)
				}
			}
		}
	}
	if confInfo.Running {
		alstatus.PaStatus("", "CPA", "end")
	}
	priority.RegistryTask.UpdateStatus("CPA", false)
	return res, nil
}

func CPAConfbridgeReinvite(task priority.TaskInfo) bool {

	if task.Running {
		utils.LoggerDebug.Printf("CPA CPAConfbridgeReinvite , already running, return .")
		return false
	}

	time.Sleep(time.Millisecond * 100)
	utils.LoggerDebug.Printf("CPA CPAConfbridgeReinvite , resume CPA .")

	chans, err := ConfbridgeList(task.ConfbridgeID)
	if len(chans) > 1 || err != nil {
		utils.LoggerDebug.Printf("CPA CPAConfbridgeReinvite , return . ConfbridgeList chans > 1 or err !")
		return false
	}

	if priority.PAInterrupt == 1 { // PA 打断标签判断
		utils.LoggerDebug.Printf("CPA ConfbridgeReinvite , PA ready to go , return !")
		return false
	} else if priority.CABInterrupt == 1 { //CABCAB 打断标签判断

		priority.TaskCreating = "CPA"
		for _, ext := range Speakers { //高优先级被cabcab打断，或者高优先级直接挂断
			if utils.IsICP(ext) {
				if priority.CABInterrupt == 1 {
					utils.LoggerDebug.Printf("CPA ConfbridgeReinvite , Get CABCAB Interrupt resume CPA , ignore %s continue .", ext)
					continue
				}
			}
			ConfbridgeReinvite(ext, "call-speakers-cpa", task.ConfbridgeID)
		}
		//task.Running = true
		priority.RegistryTask.UpdateStatus("CPA", true)
		time.Sleep(time.Millisecond * 200) //等待通道建立
		priority.TaskCreating = ""
		alstatus.PaStatus("", "CPA", "start")
		priority.CPAActived = 0
	} else if priority.TaskCreating != "" {
		utils.LoggerDebug.Printf("CPA ConfbridgeReinvite , other PA ready to go , return !")
		return false
	} else {
		priority.TaskCreating = "CPA"
		for _, ext := range Speakers {
			ConfbridgeReinvite(ext, "call-speakers-cpa", task.ConfbridgeID)
		}
		//task.Running = true
		priority.RegistryTask.UpdateStatus("CPA", true)
		time.Sleep(time.Millisecond * 200) //等待通道建立
		priority.TaskCreating = ""
		alstatus.PaStatus("", "CPA", "start")
		priority.CPAActived = 0
	}
	return true
}

func EMGConfbridgeKick(confInfo priority.TaskInfo) (res map[string]string, err error) {

	if !confInfo.Running {
		utils.LoggerDebug.Printf("EMG EMGConfbridgeKick , not running, return .")
		return
	}

	utils.LoggerDebug.Printf("EMG EMGConfbridgeKick , kick all members .")
	chans, err := ConfbridgeList(confInfo.ConfbridgeID)
	if err != nil {
		return nil, errors.New(res["Message"])
	}

	for _, confChan := range chans {
		if !strings.Contains(confChan, "0502@default") {
			ConfbridgeKick(confInfo.ConfbridgeID, confChan)
		}
	}

	if confInfo.Running {
		alstatus.PaStatus("", "EMG", "end")
	}
	//confInfo.Running = false
	priority.RegistryTask.UpdateStatus("EMG", false)
	return res, nil
}

func EMGConfbridgeReinvite(task priority.TaskInfo) {

	if priority.CPAActived == 1 && priority.AllTasks.EMG.Priority > priority.AllTasks.CPA.Priority {
		utils.LoggerDebug.Printf("EMG ConfbridgeReinvite , CPA actived , return .")
		return
	}

	//if priority.CABInterrupt != 1 {
	//	time.Sleep(time.Millisecond * 100)
	//} else {
	//time.Sleep(time.Second * 1) //wait cpa start first
	//}

	utils.LoggerDebug.Printf("EMG ConfbridgeReinvite , resume EMG .")
	if task.Running {
		utils.LoggerDebug.Printf("EMG ConfbridgeReinvite , already running ,return .")
		return
	}

	if priority.PAInterrupt == 1 { // PA 打断标签判断
		utils.LoggerDebug.Printf("EMG ConfbridgeReinvite , PA ready to go , return !")
		return
	} else if priority.CABInterrupt == 1 { //CABCAB 打断标签判断
		priority.TaskCreating = "EMG"
		for _, ext := range Speakers { //高优先级被cabcab打断，或者高优先级直接挂断
			if utils.IsICP(ext) {
				if priority.CABInterrupt == 1 {
					utils.LoggerDebug.Printf("EMG ConfbridgeReinvite , Get CABCAB Interrupt resume EMG , ignore %s continue .", ext)
					continue
				}
			}
			ConfbridgeReinvite(ext, "call-speakers-emg", task.ConfbridgeID)
		}
		//task.Running = true
		priority.RegistryTask.UpdateStatus("EMG", true)
		time.Sleep(time.Millisecond * 200) //等待通道建立
		priority.TaskCreating = ""
		alstatus.PaStatus("", "EMG", "start")
	} else if priority.TaskCreating != "" {
		utils.LoggerDebug.Printf("EMG ConfbridgeReinvite , other PA ready to go , return !")
		return
	} else {
		priority.TaskCreating = "EMG"
		for _, ext := range Speakers {
			ConfbridgeReinvite(ext, "call-speakers-emg", task.ConfbridgeID)
		}
		//task.Running = true
		priority.RegistryTask.UpdateStatus("EMG", true)
		time.Sleep(time.Millisecond * 200) //等待通道建立
		priority.TaskCreating = ""
		alstatus.PaStatus("", "EMG", "start")
	}
}

func ConfbridgeList(confnum string) (chans []string, err error) {

	action := map[string]string{
		"Action":     "ConfbridgeList",
		"Conference": confnum,
	}

	res, events, err := AminInstance.Send(action)
	if err != nil {
		return nil, err
	}
	lfshook.NewLogger().Infof("ConfbridgeList res:%+v", res)

	if res["Response"] == "Success" {
		for _, event := range events {
			if event.Data["Event"] == "ConfbridgeList" {
				chans = append(chans, event.Data["Channel"])
			}
		}
		return chans, nil
	} else {
		return nil, errors.New(res["Message"])
	}
}

func ConfbridgeReinvite(src, context, confID string) {
	if ExtenStatus(src) != "Idle" {
		lfshook.NewLogger().Infof(" ConfbridgeReinvite ext:%s Not Idle !", src)
		return
	}

	chanel := fmt.Sprintf("Local/%s@%s", src, context)
	action := map[string]string{
		"Action":   "Originate",
		"Channel":  chanel,
		"Exten":    "000",
		"Context":  "confbridge-join",
		"CallerID": fmt.Sprintf("%s<%s>", "", ""),
		"Priority": "1",
		"Variable": fmt.Sprintf("CBID=%s", confID),
		"async":    "true",
	}

	lfshook.NewLogger().Infof("dial action %+v", action)
	res, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Errorf("%+v", err)
	}
	lfshook.NewLogger().Info(res)
}

func ICPConfbridgeReinvite(confID, paType string) {

	if priority.CABInterrupt == 1 || priority.CABInterrupt == 1 {
		utils.LoggerDebug.Printf("ICPConfbridgeReinvite, Get PA/CABCAB Interrupt resume %s faild .", paType)
		return
	}

	switch paType {
	case "PAD-OCC":
		go DialICP("8", "2311", "confbridge-join", confID, "1") //ICP1---call
		go DialICP("8", "2381", "confbridge-join", confID, "8") //ICP8---call
	case "CPA":
		go DialICP("2", "2311", "confbridge-join", confID, "1") //ICP1---call
		go DialICP("2", "2381", "confbridge-join", confID, "8") //ICP8---call
	case "EMG":
		go DialICP("3", "2311", "confbridge-join", confID, "1") //ICP1---call
		go DialICP("3", "2381", "confbridge-join", confID, "8") //ICP8---call
	case "SPC":
		go DialICP("6", "2311", "confbridge-join", confID, "1") //ICP1---call
		go DialICP("6", "2381", "confbridge-join", confID, "8") //ICP8---call
	case "STN":
		go DialICP("4", "2311", "confbridge-join", confID, "1") //ICP1---call
		go DialICP("4", "2381", "confbridge-join", confID, "8") //ICP8---call
	case "DCS":
		go DialICP("5", "2311", "confbridge-join", confID, "1") //ICP1---call
		go DialICP("5", "2381", "confbridge-join", confID, "8") //ICP8---call
	case "CHK":
		go DialICP("10", "2311", "confbridge-join", confID, "1") //ICP1---call
		go DialICP("10", "2381", "confbridge-join", confID, "8") //ICP8---call
	case "VOL":
		go DialICP("11", "2311", "confbridge-join", confID, "1") //ICP1---call
		go DialICP("11", "2381", "confbridge-join", confID, "8") //ICP8---call

	}
}

var waitMutex sync.Mutex

// 设置全局变量控制任务创建过程，避免被其他任务打乱任务创建过程
func WaitTaskCreate(task string, args ...string) { //arg1(task chan)
	utils.LoggerDebug.Printf("%s check task creating ..... ,TaskCreating = %s", task, priority.TaskCreating)

	waitMutex.Lock()
	defer waitMutex.Unlock()

	switch priority.TaskCreating {
	case "C2C":
		if /*task == "PA" ||*/ task == "CPA" {
			//获取正在创建的任务的优先级
			//priorityC2C := priority.GetPriorityByKey("C2C")
			//获取将要创建的任务的优先级
			//priorityTask := priority.GetPriorityByKey(task)
			//比较优先级，确定是否终止正在创建的任务

			/*if priorityC2C < priorityTask {
				utils.LoggerDebug.Printf("%s check task C2C creating , hangup CPA %s ", task, args[0])

				//结束task(CPA)
				if len(args) > 0 {
					Hangup(args[0])
					goto DELAY
				}
			} else {
				//结束C2C,PA 则不需要挂断ICP（由ICP自行处理优先级）
				utils.LoggerDebug.Printf("%s check task C2C creating , hangup C2C ICPs ", task)
				HangupICP()
				goto DELAY
			}*/
		}
		return
	case "CPA":
		if task == "PA" /*|| task == "C2C"*/ {
			//获取正在创建的任务的优先级
			priorityCPA := priority.GetPriorityByKey("CPA")
			//获取将要创建的任务的优先级
			priorityTask := priority.GetPriorityByKey(task)
			//比较优先级，确定是否终止正在创建的任务

			if priorityCPA < priorityTask {
				utils.LoggerDebug.Printf("%s check task CPA creating , hangup %s %s", task, task, args[0])
				//结束task(PA,CPA)
				if len(args) > 0 {
					Hangup(args[0])
					goto DELAY
				}
			} else {
				//结束CPA,获取CPA通道
				if active.ActivedCab == "1" {
					utils.LoggerDebug.Printf("%s check task  creating , hangup CPA %s ", task, args[0])
					Hangup("1481")
					goto DELAY
				} else if active.ActivedCab == "8" {
					utils.LoggerDebug.Printf("%s check task C2C creating , hangup CPA %s ", task, args[0])
					Hangup("1411")
					goto DELAY
				}
			}
		}
		return
	case "PA":
		if task == "CPA" /*|| task == "C2C"*/ {
			//获取正在创建的任务的优先级
			priorityPA := priority.GetPriorityByKey("PA")
			//获取将要创建的任务的优先级
			priorityTask := priority.GetPriorityByKey(task)

			//比较优先级，确定是否终止正在创建的任务
			if priorityPA < priorityTask {
				utils.LoggerDebug.Printf("%s check task PA creating , hangup CPA %s ", task, args[0])
				//结束task(CPA)
				if len(args) > 0 {
					Hangup(args[0])
					goto DELAY
				}
			} else {
				//结束PA，获取PA通道
				if active.ActivedCab == "1" {
					utils.LoggerDebug.Printf("%s check task PA creating , hangup PA %s ", task, "2311")
					Hangup("2311")
					goto DELAY
				} else if active.ActivedCab == "8" {
					utils.LoggerDebug.Printf("%s check task PA creating , hangup PA %s ", task, "2381")
					Hangup("2381")
					goto DELAY
				}
			}
		}
		return

	default:
		//utils.LoggerDebug.Printf("%s waiting trd=============previous task:%s creating ..... ", task, priority.TaskCreating)

		for i := 0; i < 4; i++ {
			if priority.TaskCreating != "" {
				utils.LoggerDebug.Printf("%s waiting previous task:%s creating ..... ", task, priority.TaskCreating)
				time.Sleep(time.Millisecond * 500)
			} else {
				utils.LoggerDebug.Printf("TaskCreating is nill, Set TaskCreating=%s", task)
				priority.TaskCreating = task
				return
			}
		}
		priority.TaskCreating = task
		utils.LoggerDebug.Printf("%s waiting previous task:%s creating timeout ! Set TaskCreating=%s", task, priority.TaskCreating, task)
		return
	}

DELAY:
	time.Sleep(100 * time.Millisecond)
}