crrc/internal/app/stc/active/index.go

package active

import (
	"fmt"
	"net/http"
	"pbx-api-gin/pkg/lfshook"
	"time"
)

// var ActiveCab string
var CabNum string
var ActivedCab = "1"

var Master = false

var QueueTimer *time.Timer = nil

// ICP join PAD-OCC confbridge id
var ICPCONBID = "" //for cab cab interrupt
var ICPCONBTYP = ""

var EMGCONFID = "" //for other broadcast interrupt
var CPACONFID = "" //for CPA interrupt

type TaskInfo struct {
	RunChannel string `json:"runChannel"`
	RunType    string `json:"runType"`
	Priority   int    `json:"priority"`
}

var InfoEMG TaskInfo
var InfoCPA TaskInfo

// 挂断所有报警器
func NotifyPaiu(Exten, Action string) {
	url := ""
	switch Action {
	case "answer":
		url = fmt.Sprintf("http://10.0.24.%s/api/sipphone?action=answer", Exten[2:])
	case "hold":
		url = fmt.Sprintf("http://10.0.24.%s/api/sipphone?action=hold", Exten[2:])
	case "hangup":
		url = fmt.Sprintf("http://10.0.24.%s/api/sipphone?action=hangup", Exten[2:])
	}

	lfshook.NewLogger().Logger.Infof("======Notify PAIU Alarm====:%+v ", url)
	resp, err := http.Get(url)
	if err != nil {
		lfshook.NewLogger().Logger.Infof("======Notify PAIU Alarm====:%+v ", err)
		return
	}
	defer resp.Body.Close()
	/*
	   body, err := io.ReadAll(resp.Body)

	   	if err != nil {
	   		// 读取数据错误
	   		lfshook.NewLogger().Warn("ioutil ReadAll failed :", err.Error())
	   		return
	   	}

	   fmt.Printf("状态码: %d\n", resp.StatusCode)
	   fmt.Printf("响应内容: %s\n", body)
	*/
}