You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
328 lines
10 KiB
Go
328 lines
10 KiB
Go
3 years ago
|
package icssessionmanager
|
||
|
|
|
||
|
|
import (
|
||
|
|
"encoding/json"
|
||
|
|
"strings"
|
||
|
|
|
||
|
|
"gitlab.com/cinnamon/voiceagent/icsconf"
|
||
|
|
"gitlab.com/cinnamon/voiceagent/icserror"
|
||
|
|
"gitlab.com/cinnamon/voiceagent/icsevent"
|
||
|
|
"gitlab.com/cinnamon/voiceagent/icshttpclient"
|
||
|
|
"gitlab.com/cinnamon/voiceagent/icslog"
|
||
|
|
"gitlab.com/cinnamon/voiceagent/icsnet"
|
||
|
|
"gitlab.com/cinnamon/voiceagent/recorddata/responsecs"
|
||
|
|
"gitlab.com/cinnamon/voiceagent/stt"
|
||
|
|
"gitlab.com/cinnamon/voiceagent/tts"
|
||
|
|
)
|
||
|
|
|
||
|
|
/////////////////////////////////////////////
|
||
|
|
// bot scenario
|
||
|
|
func (s *IcsSession) DoScenario(request *icshttpclient.IcsHttpClient) {
|
||
|
|
l := icslog.GetIcsLog()
|
||
|
|
conf := s.AgentConfig
|
||
|
|
|
||
|
|
resBody, err := icshttpclient.ClientDo(request)
|
||
|
|
if err != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "ClientDo error - %s", err.GetMessage())
|
||
|
|
s.botStatus = nil
|
||
|
|
return
|
||
|
|
}
|
||
|
|
//l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "%s {%+v}", request.URL, resBody)
|
||
|
|
|
||
|
|
if strings.Contains(request.URL, conf.BotConfig.URL1) { //serviceinfo
|
||
|
|
l.Print(icslog.LOG_LEVEL_DEBUG2, s.ID, "URL: service info")
|
||
|
|
|
||
|
|
var svcInfoResp *icshttpclient.ServiceInfoResp
|
||
|
|
err1 := json.Unmarshal(resBody, &svcInfoResp)
|
||
|
|
if err1 != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "URL: service info - unmarshal error(%s)", err1)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
} else if strings.Contains(request.URL, conf.BotConfig.URL2) { //process
|
||
|
|
l.Print(icslog.LOG_LEVEL_DEBUG2, s.ID, "URL: process")
|
||
|
|
|
||
|
|
var processResp *icshttpclient.ProcessResp
|
||
|
|
err1 := json.Unmarshal(resBody, &processResp)
|
||
|
|
if err1 != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "URL: process - unmarshal error(%s)", err1)
|
||
|
|
s.botStatus = nil
|
||
|
|
//TODO: error!
|
||
|
|
return
|
||
|
|
}
|
||
|
|
s.botStatus = processResp
|
||
|
|
if len(s.botToken) == 0 {
|
||
|
|
s.botToken = s.botStatus.Token
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "%+v", s.botStatus)
|
||
|
|
s.botScenario()
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *IcsSession) botScenario() {
|
||
|
|
if s.botStatus == nil {
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
l := icslog.GetIcsLog()
|
||
|
|
|
||
|
|
switch s.botStatus.Action {
|
||
|
|
case "STT":
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "STT> TTS announce: %s", s.botStatus.AnnounceMents)
|
||
|
|
s.TTSandSTT()
|
||
|
|
|
||
|
|
case "DTMF":
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "DTMF> TTS announce: %s", s.botStatus.AnnounceMents)
|
||
|
|
s.TTSandDTMF()
|
||
|
|
|
||
|
|
case "TRANSFER":
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "TRANSFER> TTS announce: %s", s.botStatus.AnnounceMents)
|
||
|
|
s.TTSandTransfer()
|
||
|
|
|
||
|
|
case "END":
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "END> TTS announce: %s", s.botStatus.AnnounceMents)
|
||
|
|
s.TTSandEnd()
|
||
|
|
|
||
|
|
default:
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
////////////////////////////////////////////////////
|
||
|
|
func (s *IcsSession) STTResultCB(sttResult *stt.STTResult) {
|
||
|
|
l := icslog.GetIcsLog()
|
||
|
|
|
||
|
|
botRequest := icshttpclient.NewPostProcess(s.url, s.botStatus.Action, sttResult.GetResult(), s.custid, "ICS_RCP", s.callId, s.sstation, s.botToken, "")
|
||
|
|
////////////////////////////////////////////////
|
||
|
|
//post event to the session
|
||
|
|
h := icsevent.NewEventH()
|
||
|
|
var evt *icsevent.Event
|
||
|
|
var evtErr *icserror.IcsError
|
||
|
|
if evt, evtErr = h.AllocEvent(botRequest); evtErr != nil {
|
||
|
|
l.Print(icslog.LOG_LEVEL_ERROR, s.ID, "Response Error")
|
||
|
|
s.SendVoiceGatewayByeSignal()
|
||
|
|
return
|
||
|
|
}
|
||
|
|
l.Printf(icslog.LOG_LEVEL_INFO, -1, "Post BOT Request[%d] to Session[%03d]", evt.ID, s.ID)
|
||
|
|
h.PostEvent(s.ID, evt)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *IcsSession) TTSandSTT() {
|
||
|
|
l := icslog.GetIcsLog()
|
||
|
|
conf := icsconf.GetIcsConfig()
|
||
|
|
|
||
|
|
agentname := s.AgentConfig.Name
|
||
|
|
telno := s.botStatus.Data.TelNo
|
||
|
|
|
||
|
|
//tts
|
||
|
|
pcm, ttsErr := tts.TTS(s.botStatus.AnnounceMents, 8000)
|
||
|
|
if ttsErr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "TTS Error[%s] - %s",
|
||
|
|
s.botStatus.AnnounceMents, ttsErr.GetError())
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
return
|
||
|
|
} else {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_INFO, s.ID, "%s!!! TTS Result: [%s]%d bytes",
|
||
|
|
agentname, s.botStatus.AnnounceMents, len(pcm))
|
||
|
|
|
||
|
|
//send tts data to voice gateway
|
||
|
|
r := responsecs.NewResponse(agentname, telno, responsecs.TTS_COMMAND, responsecs.RC_SUCCESS, len(pcm))
|
||
|
|
addr := icsnet.NewNetAddrWithIPPort(conf.VGWCommandConfig.IP, conf.VGWCommandConfig.Port)
|
||
|
|
t, wlen, werr := icsnet.SendCallSignal2(&addr, nil, r.GetData())
|
||
|
|
//wlen, werr := s.TcpConn.Write(r.GetData())
|
||
|
|
if werr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "Failed to send TTS header - %s [%+v]",
|
||
|
|
werr.GetError(), s.TcpConn)
|
||
|
|
return
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
}
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "Sent TTS header : %d", wlen)
|
||
|
|
|
||
|
|
s.TcpConn = t
|
||
|
|
wlen, werr = s.TcpConn.Write(pcm)
|
||
|
|
if werr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "Failed to send TTS data - %s",
|
||
|
|
werr.GetError())
|
||
|
|
return
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
}
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "Sent TTS data : %d", wlen)
|
||
|
|
|
||
|
|
l.Printf(icslog.LOG_LEVEL_INFO, s.ID, "Barge-In: %s", s.botStatus.Data.BargeIn)
|
||
|
|
switch s.botStatus.Data.BargeIn {
|
||
|
|
case "Y":
|
||
|
|
//s.StartSTT(wlen)
|
||
|
|
s.isSTTStart = true
|
||
|
|
case "N":
|
||
|
|
s.StartSTT(wlen)
|
||
|
|
//s.isSTTStart = false
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *IcsSession) DTMFCB() {
|
||
|
|
l := icslog.GetIcsLog()
|
||
|
|
conf := icsconf.GetIcsConfig()
|
||
|
|
dtmfEnd := conf.DtmfEndSignal.Signal
|
||
|
|
|
||
|
|
dtmf := s.GetDtmf(dtmfEnd)
|
||
|
|
if s.botStatus.Action == "DTMF" && dtmf != "" { // dtmf
|
||
|
|
botRequest := icshttpclient.NewPostProcess(s.url, s.botStatus.Action, dtmf, s.custid, "ICS_RCP", s.callId, s.sstation, s.botToken, "")
|
||
|
|
////////////////////////////////////////////////
|
||
|
|
//post event to the session
|
||
|
|
h := icsevent.NewEventH()
|
||
|
|
var evt *icsevent.Event
|
||
|
|
var evtErr *icserror.IcsError
|
||
|
|
if evt, evtErr = h.AllocEvent(botRequest); evtErr != nil {
|
||
|
|
l.Print(icslog.LOG_LEVEL_ERROR, s.ID, "Response Error")
|
||
|
|
s.SendVoiceGatewayByeSignal()
|
||
|
|
return
|
||
|
|
}
|
||
|
|
l.Printf(icslog.LOG_LEVEL_INFO, -1, "Post BOT Request[%d] to Session[%03d]", evt.ID, s.ID)
|
||
|
|
h.PostEvent(s.ID, evt)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *IcsSession) TTSandDTMF() {
|
||
|
|
l := icslog.GetIcsLog()
|
||
|
|
conf := icsconf.GetIcsConfig()
|
||
|
|
|
||
|
|
agentname := s.AgentConfig.Name
|
||
|
|
telno := s.botStatus.Data.TelNo
|
||
|
|
|
||
|
|
s.ResetDtmf()
|
||
|
|
|
||
|
|
//tts
|
||
|
|
pcm, ttsErr := tts.TTS(s.botStatus.AnnounceMents, 8000)
|
||
|
|
if ttsErr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "TTS Error[%s] - %s",
|
||
|
|
s.botStatus.AnnounceMents, ttsErr.GetError())
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
return
|
||
|
|
} else {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_INFO, s.ID, "%s!!! TTS Result: [%s]%d bytes",
|
||
|
|
agentname, s.botStatus.AnnounceMents, len(pcm))
|
||
|
|
|
||
|
|
//send tts data to voice gateway
|
||
|
|
r := responsecs.NewResponse(agentname, telno, responsecs.DTMF_COMMAND, responsecs.RC_SUCCESS, len(pcm))
|
||
|
|
addr := icsnet.NewNetAddrWithIPPort(conf.VGWCommandConfig.IP, conf.VGWCommandConfig.Port)
|
||
|
|
t, wlen, werr := icsnet.SendCallSignal2(&addr, nil, r.GetData())
|
||
|
|
//wlen, werr := s.TcpConn.Write(r.GetData())
|
||
|
|
if werr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "Failed to send TTS header - %s [%+v]",
|
||
|
|
werr.GetError(), s.TcpConn)
|
||
|
|
return
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
}
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "Sent TTS header : %d", wlen)
|
||
|
|
|
||
|
|
s.TcpConn = t
|
||
|
|
wlen, werr = s.TcpConn.Write(pcm)
|
||
|
|
if werr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "Failed to send TTS data - %s",
|
||
|
|
werr.GetError())
|
||
|
|
return
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
}
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "Sent TTS data : %d", wlen)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *IcsSession) TTSandTransfer() {
|
||
|
|
l := icslog.GetIcsLog()
|
||
|
|
conf := icsconf.GetIcsConfig()
|
||
|
|
|
||
|
|
agentname := s.AgentConfig.Name
|
||
|
|
telno := s.botStatus.Data.TelNo
|
||
|
|
|
||
|
|
//tts
|
||
|
|
pcm, ttsErr := tts.TTS(s.botStatus.AnnounceMents, 8000)
|
||
|
|
if ttsErr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "TTS Error[%s] - %s",
|
||
|
|
s.botStatus.AnnounceMents, ttsErr.GetError())
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
return
|
||
|
|
} else {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_INFO, s.ID, "%s!!! TTS Result: [%s]%d bytes",
|
||
|
|
agentname, s.botStatus.AnnounceMents, len(pcm))
|
||
|
|
|
||
|
|
//send tts data to voice gateway
|
||
|
|
r := responsecs.NewResponse(agentname, telno, responsecs.REFER_COMMAND, responsecs.RC_SUCCESS, len(pcm))
|
||
|
|
addr := icsnet.NewNetAddrWithIPPort(conf.VGWCommandConfig.IP, conf.VGWCommandConfig.Port)
|
||
|
|
t, wlen, werr := icsnet.SendCallSignal2(&addr, nil, r.GetData())
|
||
|
|
|
||
|
|
//wlen, werr := s.TcpConn.Write(r.GetData())
|
||
|
|
if werr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "Failed to send TTS header - %s [%+v]",
|
||
|
|
werr.GetError(), s.TcpConn)
|
||
|
|
return
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
}
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "Sent TTS header : %d", wlen)
|
||
|
|
|
||
|
|
s.TcpConn = t
|
||
|
|
wlen, werr = s.TcpConn.Write(pcm)
|
||
|
|
if werr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "Failed to send TTS data - %s",
|
||
|
|
werr.GetError())
|
||
|
|
return
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
}
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "Sent TTS data : %d", wlen)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *IcsSession) TTSandEnd() {
|
||
|
|
l := icslog.GetIcsLog()
|
||
|
|
conf := icsconf.GetIcsConfig()
|
||
|
|
|
||
|
|
agentname := s.AgentConfig.Name
|
||
|
|
telno := s.botStatus.Data.TelNo
|
||
|
|
|
||
|
|
//tts
|
||
|
|
pcm, ttsErr := tts.TTS(s.botStatus.AnnounceMents, 8000)
|
||
|
|
if ttsErr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "TTS Error[%s] - %s",
|
||
|
|
s.botStatus.AnnounceMents, ttsErr.GetError())
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
return
|
||
|
|
} else {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_INFO, s.ID, "%s!!! TTS Result: [%s]%d bytes",
|
||
|
|
agentname, s.botStatus.AnnounceMents, len(pcm))
|
||
|
|
|
||
|
|
//send tts data to voice gateway
|
||
|
|
r := responsecs.NewResponse(agentname, telno, responsecs.BYE_COMMAND, responsecs.RC_SUCCESS, len(pcm))
|
||
|
|
addr := icsnet.NewNetAddrWithIPPort(conf.VGWCommandConfig.IP, conf.VGWCommandConfig.Port)
|
||
|
|
t, wlen, werr := icsnet.SendCallSignal2(&addr, nil, r.GetData())
|
||
|
|
//wlen, werr := s.TcpConn.Write(r.GetData())
|
||
|
|
if werr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "Failed to send TTS header - %s [%+v]",
|
||
|
|
werr.GetError(), s.TcpConn)
|
||
|
|
return
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
}
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "Sent TTS header : %d", wlen)
|
||
|
|
|
||
|
|
s.TcpConn = t
|
||
|
|
wlen, werr = s.TcpConn.Write(pcm)
|
||
|
|
if werr != nil {
|
||
|
|
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "Failed to send TTS data - %s",
|
||
|
|
werr.GetError())
|
||
|
|
return
|
||
|
|
// s.SendVoiceGatewayBotByeSignal(url, custid, sstation)
|
||
|
|
// break
|
||
|
|
}
|
||
|
|
l.Printf(icslog.LOG_LEVEL_DEBUG2, s.ID, "Sent TTS data : %d", wlen)
|
||
|
|
}
|
||
|
|
}
|