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

package priority

import (
	"os"
	"pbx-api-gin/pkg/lfshook"
	"strconv"

	"github.com/sirupsen/logrus"
	"gopkg.in/ini.v1"
)

var ICPAnswer = 0
var OCCAnswer = 0

var RunningTypePriority = 0
var RunningType = ""
var RunningPATaskChan = ""

var TmpRunningTypePriority = 0
var TmpRunningType = ""

var SpecialVoice = 0

var PADStart = 0
var PADOccStart = 0
var PAStart = 0

var InterruptedPad = ""

type BroadcastResumeParas struct {
	FileName      string `json:"filename"`
	Count         int    `json:"count"`
	Delay         int    `json:"delay"`
	BroadcastType string `json:"broadcastType"`
}

var ResumeEmgPara BroadcastResumeParas

type PriorityAll struct {
	ManuPa string `json:"manualPa"`
	CabCab string `json:"cabCab"`
	PADICP string `json:"padIcp"`
	PADTMS string `json:"padTms"`
	PADOCC string `json:"padOcc"`
	CPA    string `json:"cpa"`
	EMG    string `json:"emg"`
	SPC    string `json:"spc"`
	DCS    string `json:"dcs"`
	STN    string `json:"stn"`
	CHK    string `json:"chk"`
	VOL    string `json:"vol"`
}

var Priority PriorityAll

func GetPriority() {
	filePath := "/etc/asterisk/priority.conf"
	_, err := os.Stat(filePath)
	if err != nil {
		logrus.Error(err)
		return
	}
	iniFile, err := ini.Load(filePath)
	if err != nil {
		logrus.Error(err)
		return
	}

	Priority.CHK = iniFile.Section("general").Key("CHK").Value()
	Priority.STN = iniFile.Section("general").Key("STN").Value()
	Priority.DCS = iniFile.Section("general").Key("DCS").Value()
	Priority.SPC = iniFile.Section("general").Key("SPC").Value()
	Priority.EMG = iniFile.Section("general").Key("EMG").Value()
	Priority.CPA = iniFile.Section("general").Key("CPA").Value()
	Priority.PADOCC = iniFile.Section("general").Key("PAD-OCC").Value()
	Priority.PADTMS = iniFile.Section("general").Key("PAD-TMS").Value()
	Priority.PADICP = iniFile.Section("general").Key("PAD-ICP").Value()
	Priority.CabCab = iniFile.Section("general").Key("CabCab").Value()
	Priority.ManuPa = iniFile.Section("general").Key("ManuPa").Value()
	Priority.VOL = iniFile.Section("general").Key("VOL").Value()
}

func GetPriorityByKey(key string) string {

	switch key {
	case "VOL":
		return Priority.VOL
	case "CHK":
		return Priority.CHK
	case "STN":
		return Priority.STN
	case "DCS":
		return Priority.DCS
	case "SPC":
		return Priority.SPC
	case "EMG":
		return Priority.EMG
	case "CPA":
		return Priority.CPA
	case "PAD-OCC":
		return Priority.PADOCC
	case "PAD-TMS":
		return Priority.PADTMS
	case "PAD-ICP":
		return Priority.PADICP
	case "CabCab":
		return Priority.CabCab
	case "ManuPa":
		return Priority.ManuPa
	default:
		return ""
	}
}

// check priority , if the running priority is lowwer than the to run priority
func CheckPriority(runType string) bool {
	//return true
	lfshook.NewLogger().Logger.Infof("=========Check Pri runType:%s====RunningTypePriority:%d====SpecialVoice:%d========", runType, RunningTypePriority, SpecialVoice)
	//Check special voice can not interrupt
	if SpecialVoice == 1 {
		return false
	}

	//No any runing task now
	if RunningTypePriority == 0 {
		return true
	}

	//Get the to run priority number in the config file
	ret, err := strconv.Atoi(GetPriorityByKey(runType))
	if err != nil {
		lfshook.NewLogger().Logger.Infof("=========Check Pri GetPriorityByKey err:%+v", err)
		return false
	}

	//special same priority number task return true
	if ret == RunningTypePriority {
		switch runType {
		case "PAD-ICP":
			return true
		case "PAD-TMS":
			return true
			/*	case "VOL":
					return true
				case "CHK":
					return true*/
		}
	}

	//if the running task priority is lowwer
	if ret < RunningTypePriority && ret != 0 {
		return true
	} else {
		//C2C run together with other task except ..
		if RunningType == "C2C" {
			if runType != "PA" && runType != "PAD-ICP" && runType != "PAD-TMS" && runType != "C2C" {
				return true
			}
		} else if runType == "C2C" {
			if RunningType != "PA" && RunningType != "PAD-ICP" && RunningType != "PAD-TMS" && RunningType != "C2C" {
				return true
			}
		}
	}
	return false
}

// Clean all priority tag
func CleanPriorityTag() {
	lfshook.NewLogger().Logger.Infof("=========CleanPriorityTag===============")

	ICPAnswer = 0
	OCCAnswer = 0
	RunningTypePriority = 0
	RunningType = ""
	SpecialVoice = 0
	RunningPATaskChan = ""
}