SendVoice
(message, logsign string)
| 9 | |
| 10 | // SendVoice |
| 11 | func SendVoice(message, logsign string) string { |
| 12 | open := beego.AppConfig.String("open-voice") |
| 13 | if open != "1" { |
| 14 | logs.Info(logsign, "[voicemessage]", "语音播报配置未开启,请先配置open-voice为1") |
| 15 | return "语音播报配置未开启,请先配置open-voice为1" |
| 16 | } |
| 17 | v_ip := beego.AppConfig.String("VOICE_IP") |
| 18 | v_port := beego.AppConfig.String("VOICE_PORT") |
| 19 | //发送tcp语音消息文本 |
| 20 | v_addr, err := net.ResolveTCPAddr("tcp", v_ip+":"+v_port) |
| 21 | if err != nil { |
| 22 | logs.Error(logsign, "[voicemessage]", err.Error()) |
| 23 | return "语音组件连接初始化失败：" + err.Error() |
| 24 | } |
| 25 | conn, err := net.DialTCP("tcp", nil, v_addr) |
| 26 | if err != nil { |
| 27 | logs.Error(logsign, "[voicemessage]", err.Error()) |
| 28 | return "语音组件连接失败：" + err.Error() |
| 29 | } |
| 30 | _, err = conn.Write([]byte(message)) |
| 31 | if err != nil { |
| 32 | logs.Error(logsign, "[voicemessage]", err.Error()) |
| 33 | return "语音组件发送消息失败：" + err.Error() |
| 34 | } |
| 35 | logs.Info(logsign, "[voicemessage]", message+" 语音播报消息发送成功") |
| 36 | conn.Close() |
| 37 | models.AlertToCounter.WithLabelValues("voice").Add(1) |
| 38 | ChartsJson.Voice += 1 |
| 39 | return message + " 语音播报消息发送成功" |
| 40 | } |
no outgoing calls
no test coverage detected