Added new code for Incoming pop alert and registering campaign when inbound call comes up

@@ -277,7 +277,6 @@ class KPAMIListen implements IEventListener
 				$dialline=Dialline::where('server','=',$this->sipip)->where("dialstr","=",env("sip_dialstr"))->where("status","=","Free")->first();
 				$dialline=Dialline::where('server','=',$this->sipip)->where("dialstr","=",env("sip_dialstr"))->where("status","=","Free")->first();
 				if($dialline)
 				if($dialline)
 				{
 				{
-					
 					$nowts=microtime(true)*1000;
 					$nowts=microtime(true)*1000;
 					
 					
 					//start the call log
 					//start the call log
@@ -288,9 +287,7 @@ class KPAMIListen implements IEventListener
 					
 					
 					$crmcall->did=$exten;
 					$crmcall->did=$exten;
 
 
-					$crmcall->crm_id=0;
-					$crmcall->client=".";
-					$crmcall->department="";
+					$this->checkMobileNumberExist($crmcall);
 
 
 					$crmcall->state='Inbound';
 					$crmcall->state='Inbound';
 					$crmcall->type="Inbound";
 					$crmcall->type="Inbound";
@@ -299,6 +296,7 @@ class KPAMIListen implements IEventListener
 					$crmcall->dialline_id=$dialline->id;
 					$crmcall->dialline_id=$dialline->id;
 					
 					
 					$crmcall->setTs('ts_Wait',$nowts);
 					$crmcall->setTs('ts_Wait',$nowts);
+					$crmcall->setTs('ts_cTalk',$nowts);
 					
 					
 					$crmcall->group=$dialline->group;
 					$crmcall->group=$dialline->group;
 					
 					
@@ -313,7 +311,9 @@ class KPAMIListen implements IEventListener
 					$dialline->status='Inbound';
 					$dialline->status='Inbound';
 					$dialline->uniqueid=$uniqueid;
 					$dialline->uniqueid=$uniqueid;
 					$dialline->number=$phonenumber;
 					$dialline->number=$phonenumber;
+					$dialline->src_channel=$channel;
 					$dialline->channel=$channel;
 					$dialline->channel=$channel;
+					$dialline->regexstr=$crmcall->client;
 					$dialline->save();
 					$dialline->save();
 
 
 					/*$userStatus=User::where("updated_at",">",date("Y-m-d"))->where("exten","like","%".substr($exten,-4)."%")->where("usertype","!=","Admin")->where('presence', '=', '1')->select('*')->get();
 					/*$userStatus=User::where("updated_at",">",date("Y-m-d"))->where("exten","like","%".substr($exten,-4)."%")->where("usertype","!=","Admin")->where('presence', '=', '1')->select('*')->get();
@@ -687,11 +687,15 @@ class KPAMIListen implements IEventListener
 				$dialline=Dialline::find($crmcall->dialline_id);
 				$dialline=Dialline::find($crmcall->dialline_id);
 				if($dialline)
 				if($dialline)
 				{
 				{
+					$dialline->call_id=0;
+					$dialline->user_id=0;
 					$dialline->status="Free";
 					$dialline->status="Free";
 					$dialline->conf="";
 					$dialline->conf="";
 					$dialline->number="";
 					$dialline->number="";
 					$dialline->uniqueid="";
 					$dialline->uniqueid="";
+					$dialline->src_channel="";
 					$dialline->channel="";
 					$dialline->channel="";
+					$dialline->did="";
 					$dialline->save();
 					$dialline->save();
 				}
 				}
 				
 				
@@ -1176,7 +1180,6 @@ class KPAMIListen implements IEventListener
 
 
 							$crmcall->addEventLog($nowts,"$accountcode:$accountcodearr[1] : $eventname $dchannelstate:$dchannelstatedesc $duniqueid $dexten:$dpriority $dchannel $dialstatus");
 							$crmcall->addEventLog($nowts,"$accountcode:$accountcodearr[1] : $eventname $dchannelstate:$dchannelstatedesc $duniqueid $dexten:$dpriority $dchannel $dialstatus");
 
 
-							
 							$crmcall->save();
 							$crmcall->save();
 						}
 						}
 
 
@@ -1445,6 +1448,7 @@ class KPAMIListen implements IEventListener
 		//TODO: Need to create static values for modes
 		//TODO: Need to create static values for modes
 		$status = array('Auto', 'Inbound'); //NOTE: Be Careful before changing indexes
 		$status = array('Auto', 'Inbound'); //NOTE: Be Careful before changing indexes
 		$mode	= "";
 		$mode	= "";
+		$campaignUserIds = [];
 
 
 		$diallines=Dialline::where('server','=',$this->sipip)->whereIn("status", $status)->where("conf","=","")->get();
 		$diallines=Dialline::where('server','=',$this->sipip)->whereIn("status", $status)->where("conf","=","")->get();
 		if($diallines)
 		if($diallines)
@@ -1464,9 +1468,7 @@ class KPAMIListen implements IEventListener
 					{
 					{
 						$mode = "Predictive";
 						$mode = "Predictive";
 
 
-						$campaignUserIds = User::where('presence', '=', "1")
-											->where('sel_campaign', '=', $dialline->regexstr)
-											->select('id')->get()->toArray();
+						$campaignUserIds = $this->getUsersAvailableInCampaign($dialline->regexstr);
 
 
 						$sipid=Sipid::where('server', '=', $this->sipip)
 						$sipid=Sipid::where('server', '=', $this->sipip)
 						->whereIn("user", $campaignUserIds)
 						->whereIn("user", $campaignUserIds)
@@ -1480,14 +1482,7 @@ class KPAMIListen implements IEventListener
 					{
 					{
 						$mode = "Incoming";
 						$mode = "Incoming";
 
 
-						$this->checkMobileNumberExist($crmcall);
-
-						$sipid=Sipid::where('server', '=', $this->sipip)
-						->where("user", "!=", "0")
-						->where("status", "=", "1")
-						->where("ready", "=", "1")
-						->orderBy("updated_at", "ssc")
-						->first();
+						$sipid = $this->getSipid($dialline->regexstr);
 					}
 					}
 
 
 					if(!empty($sipid))
 					if(!empty($sipid))
@@ -1498,17 +1493,94 @@ class KPAMIListen implements IEventListener
 					}
 					}
 					else if($mode == "Incoming")
 					else if($mode == "Incoming")
 					{
 					{
+						$this->showIncomingPopupAlert($dialline->regexstr, $crmcall);
+					}
+				}
+			}
+		}
+	}
+
+	private function showIncomingPopupAlert($client, $crmcall)
+	{
+		$flag = "alert";
+
+		$sipids = $this->getSipid($client, $flag);
+
+		foreach($sipids as $sipid)
+		{
 			$newqueue=new Kqueue();
 			$newqueue=new Kqueue();
 			$newqueue->sipNotify($sipid,"popupalert"," Incoming Calls",$crmcall->number."|".$crmcall->client,$crmcall->did);
 			$newqueue->sipNotify($sipid,"popupalert"," Incoming Calls",$crmcall->number."|".$crmcall->client,$crmcall->did);
 		}
 		}
 	}
 	}
+
+	private function getSipid($client, $flag=null)
+	{
+		$data				= [];
+		$campaignUserIds	= [];
+
+		if($client!="")$campaignUserIds = $this->getUsersAvailableInCampaign($client);
+
+		if($flag == null)
+		{
+			if(!empty($campaignUserIds))
+			{
+				$sipid=Sipid::where('server', '=', $this->sipip)
+							->whereIn("user", $campaignUserIds)
+							->where("status", "=", "1")
+							->where("ready", "=", "1")
+							->orderBy("updated_at", "asc")
+							->first();
+			}
+			else
+			{
+				$sipid=Sipid::where('server', '=', $this->sipip)
+							->where("user", "!=", "0")
+							->where("status", "=", "1")
+							->where("ready", "=", "1")
+							->orderBy("updated_at", "asc")
+							->first();
+			}
+
+			$data = $sipid;
+		}
+		else
+		{
+			if(!empty($campaignUserIds))
+			{
+				$sipids=Sipid::where('server', '=', $this->sipip)
+				->whereIn("user", $campaignUserIds)
+				->where("status", "=", "1")
+				->orderBy("updated_at", "asc")
+				->get();
+			}
+			else
+			{
+				$sipids=Sipid::where('server', '=', $this->sipip)
+				->where("user", "!=", "0")
+				->where("status", "=", "1")
+				->orderBy("updated_at", "asc")
+				->get();
 			}
 			}
+
+			$data = $sipids;
 		}
 		}
+
+		return $data;
 	}
 	}
 
 
-	private function checkMobileNumberExist($crmcall)
+	private function getUsersAvailableInCampaign($client)
 	{
 	{
-		if($crmcall->client==".")
+		$data = [];
+		
+		$data = User::where('presence', '=', "1")
+				->where('sel_campaign', '=', $client)
+				->select('id')->get()
+				->toArray();
+
+		return $data;
+	}
+
+	private function checkMobileNumberExist($crmcall)
 	{
 	{
 		$wakka = new KHRMSLib();
 		$wakka = new KHRMSLib();
 		$users=$wakka->searchPhone("mobile", $crmcall->number, "");
 		$users=$wakka->searchPhone("mobile", $crmcall->number, "");
@@ -1536,7 +1608,6 @@ class KPAMIListen implements IEventListener
 
 
 		return;
 		return;
 	}
 	}
-	}
 
 
 	private function connectToAvailableSip($sipid, $dialline, $crmcall, $mode)
 	private function connectToAvailableSip($sipid, $dialline, $crmcall, $mode)
 	{
 	{