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

package action

import (
	"fmt"
	"pbx-api-gin/pkg/lfshook"
	"pbx-api-gin/pkg/utils"
	"strings"
	"time"
)

// 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 挂断所有分机
func HangupAll() {
	var Pacus = []string{"2111", "2121", "2131", "2141", "2151", "2161", "2171", "2181"}
	//all PACU
	for _, ret := range Pacus {
		Hangup(ret)
	}

	Hangup("1411") //IO1
	Hangup("1481") //IO8
	Hangup("2311") //ICP1
	Hangup("2381") //ICP8
}

// 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)
}

// 获取分机状态
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)
	}
}

// Page
func Page(src string, extensions []string, duplex bool) {
	channel := fmt.Sprintf("%s/%s", utils.DialPrefix, src)
	data := make([]string, 0)
	for _, exten := range extensions {
		data = append(data, fmt.Sprintf("%s/%s", utils.DialPrefix, exten))
	}
	appData := strings.Join(data, "&")
	if duplex {
		appData = fmt.Sprintf("%s,db(header-handler^addheader^1)", appData)
	} else {
		appData = fmt.Sprintf("%s,b(header-handler^addheader^1)", appData)
	}
	//timeout
	appData = fmt.Sprintf("%s,30", appData)
	action := map[string]string{
		"Action":      "Originate",
		"Channel":     channel,
		"Application": "page",
		"Data":        appData,
		"CallerID":    src,
		"CallerSrc":   src,
		"Variable":    "PJSIP_HEADER(add,answer-after)=0",
		"async":       "true",
	}
	lfshook.NewLogger().Infof("page action %+v", action)
	res, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Errorf("%+v", err)
	}
	lfshook.NewLogger().Infof("%+v", res)
}

// Play 转 AGI 播放
func Play(name, UUID string, extensions []string, hangupAll bool, autoanswer string) {
	if hangupAll {
		lfshook.NewLogger().Infof("hangup all before play to %+v", extensions)
		for _, extension := range extensions {
			Hangup(extension)
		}
		time.Sleep(3 * time.Second)
	}

	channel := "Local/broadcast@broadcast"
	data := make([]string, 0)
	for _, exten := range extensions {
		data = append(data, fmt.Sprintf("%s/%s", utils.DialPrefix, exten))
	}
	appData := strings.Join(data, "&")
	//timeout
	/*if autoanswer == "yes" {
		appData = fmt.Sprintf("%s,%s,%d", appData, "b(header-handler^addheader^1)", configs.ConfigGlobal.AsteriskBroadcastTimeout)
	} else {
		appData = fmt.Sprintf("%s,,%d", appData, configs.ConfigGlobal.AsteriskBroadcastTimeout)
	}*/
	variable := fmt.Sprintf("task_UUID=%s", UUID)
	action := map[string]string{
		"Action":      "Originate",
		"Channel":     channel,
		"Application": "page",
		"Data":        appData,
		"Variable":    variable,
		//"CallerID":    fmt.Sprintf("%s<%s>", configs.ConfigGlobal.AsteriskBroadcastName, configs.ConfigGlobal.AsteriskBroadcastID),
		"CallerID": fmt.Sprintf("%s<%s>", name, name),
		"CallSrc":  name,
		"async":    "true",
	}
	lfshook.NewLogger().Infof("play action %+v", action)
	_, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Errorf("%+v", err)
	}
}

// Redirect 转接
func Redirect(channel, dst, dialrule 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": 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
}

// 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("redirect %+v", action)
	res, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Error(err)
	}
	lfshook.NewLogger().Info(res)
	return err
}

// Redirect 转接
func BlindTransfer(channel, dst, dialrule string) (err error) {

	lfshook.NewLogger().Infof("BlindTransfer src %s to dst %s", channel, dst)
	if !utils.IsChannel(channel) {
		if channel, err = GetExtenChan(channel); err != nil {
			return err
		}
	}
	action := map[string]string{
		"Action":  "BlindTransfer",
		"Channel": channel,
		"Exten":   dst,
		"Context": dialrule,
	}
	lfshook.NewLogger().Infof("BlindTransfer %+v", action)
	res, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Error(err)
	}
	lfshook.NewLogger().Info(res)
	return err
}

// Atxfer
func Atxfer(channel, dst, dialrule string) (err error) {
	// 获取通道
	if !utils.IsChannel(channel) {
		if channel, err = GetChannelByExten(channel); err != nil {
			return err
		}
	}

	action := map[string]string{
		"Action":  "Atxfer",
		"Channel": channel,
		"Exten":   dst,
		"Context": dialrule,
	}
	lfshook.NewLogger().Infof("atxfer action %+v", action)
	res, _, err := AminInstance.Send(action)
	if err != nil {
		lfshook.NewLogger().Errorf("%+v", err)
		return err
	}
	lfshook.NewLogger().Debugf("atxfer res %+v", res)
	return err
}