update

internal/app/ami/action/index.go

@@ -507,29 +507,7 @@ func HandleAMI(event map[string]string) {
 						alstatus.PaStatus("", "PAD", "end")
 						priority.PADStart = 0
 						//priority.PADTMSStart = 0
-						/*
-							//clean confbridge
-							//PAD-ICP
-							taskTmp, ok := priority.RegistryTask.Get("PAD-ICP")
-							if ok {
-								ConfbridgeKick(taskTmp.ConfbridgeID, "all")
-							}
-							priority.RegistryTask.StopAndUnregister("PAD-ICP")
-
-							// PAD-TMS
-							taskTmp, ok = priority.RegistryTask.Get("PAD-TMS")
-							if ok {
-								ConfbridgeKick(taskTmp.ConfbridgeID, "all")
-							}
-							priority.RegistryTask.StopAndUnregister("PAD-TMS")
 
-							//PAD-OCC
-							taskTmp, ok = priority.RegistryTask.Get("PAD-OCC")
-							if ok {
-								ConfbridgeKick(taskTmp.ConfbridgeID, "all")
-							}
-							priority.RegistryTask.StopAndUnregister("PAD-OCC")
-						*/
 						//check resume
 						taskName, task, ok := priority.RegistryTask.HighestPriorityRunningTask1()
 						if ok {
@@ -548,6 +526,19 @@ func HandleAMI(event map[string]string) {
 					priority.OCCAnswer = 0
 					break
 				}
+
+				//check resume
+				taskName, task, ok := priority.RegistryTask.HighestPriorityRunningTask1()
+				if ok {
+					if taskName == "EMG" {
+						EMGConfbridgeReinvite(task.ConfbridgeID)
+						//alstatus.PaStatus("", "EMG", "start")
+					} else if taskName == "CPA" {
+						if CPAConfbridgeReinvite(task.ConfbridgeID) {
+							alstatus.PaStatus("", "CPA", "start")
+						}
+					}
+				}
 			}
 		}