|
|
@@ -123,7 +123,7 @@ func InterruptRunningTask(toRunTask string) {
|
|
|
|
|
|
if toRunTask == "PAD-OCC" {
|
|
|
Hangup(task.RunChannel) //pad
|
|
|
-
|
|
|
+ ConfbridgeKick(task.ConfbridgeID, "all")
|
|
|
HangupIO() //io
|
|
|
lfshook.NewLogger().Infof("===InterruptRunningTask=ret==== ")
|
|
|
}
|
|
|
@@ -140,17 +140,12 @@ func InterruptRunningTask(toRunTask string) {
|
|
|
switch task.RunType {
|
|
|
case "CPA":
|
|
|
//kick CPA members
|
|
|
- //taskTmp, ok := priority.RegistryTask.Get("CPA")
|
|
|
- //if ok {
|
|
|
- CPAConfbridgeKick(task.ConfbridgeID)
|
|
|
- //}
|
|
|
|
|
|
+ CPAConfbridgeKick(task.ConfbridgeID)
|
|
|
case "EMG":
|
|
|
//kick EMG members
|
|
|
- //taskTmp, ok := priority.RegistryTask.Get("EMG")
|
|
|
- //if ok {
|
|
|
+
|
|
|
EMGConfbridgeKick(task.ConfbridgeID)
|
|
|
- //}
|
|
|
|
|
|
case "C2C": // Interrupt C2C task running,
|
|
|
if toRunTask == "PA" || toRunTask == "PAD-ICP" || toRunTask == "PAD-TMS" {
|
|
|
@@ -235,12 +230,14 @@ func InterruptRunningTask(toRunTask string) {
|
|
|
//3. Hangup OI & ICP
|
|
|
HangupIO()
|
|
|
HangupAllLocalChan()
|
|
|
+ ConfbridgeKick(task.ConfbridgeID, "all")
|
|
|
|
|
|
//occ pad end
|
|
|
if priority.PADOccStart == 1 {
|
|
|
alstatus.OccPad("end")
|
|
|
priority.PADOccStart = 0
|
|
|
}
|
|
|
+
|
|
|
}
|
|
|
|
|
|
default:
|