";print_r($response);die;
                if ($response == true) {
                    return  array(
                        'success' => 1,
                        'message' => 'Webphone In Call Status Active',
                        'data' => $response,
                        'code' => 301
                    );
                } else {
                    throw new RenderableException('Webphone In Call Status Inactive', [401], 401);
                }
            } catch (Exception $ex) {
                throw new RenderableException('Webphone In Call Status Inactive', [401], 401);
            }
        } else {
            try {
                $number = $request->input('number');
                if (empty($number)) {
                    throw new RenderableException('Number not found', [404], 404);
                }
                $leadId = $request->input('lead_id');
                if (empty($number)) {
                    throw new RenderableException('Lead Id not found', [404], 404);
                }
                $response = $asterisk->click2CallCRM($number, $campaignId, $leadId, $extension, $userData, $crm_cli);
                if ($response == true) {
                    return  array(
                        'success' => 1,
                        'message' => 'Call connected successfully for number =' . $number,
                        'data' => $response,
                        'code' => 302
                    );
                } else {
                    throw new RenderableException('Call not connected for number =' . $number, [401], 401);
                }
            } catch (Exception $ex) {
                throw new RenderableException('Call not connected for number =' . $number, [401], 401);
            }
        }
    }


    public function hangUpCRM($request)
    {
        $extension = $request->input('extension');
        if (empty($extension)) {
            throw new RenderableException('Extension not found', [404], 404);
        }

        $number = $request->input('number');
        if (empty($number)) {
            throw new RenderableException('Number not found', [404], 404);
        }

        $leadId = $request->input('lead_id');
        if (empty($number)) {
            throw new RenderableException('Lead Id not found', [404], 404);
        }

        $data = User::where('extension', $extension)->orWhere('alt_extension', $extension)->orWhere('app_extension', $extension)->get()->first();

        if (!empty($data)) {
            $server = AsteriskServer::find($data->asterisk_server_id);
            $asteriskServerId = $server->id;
            $parentId = $data->parent_id;
            $campaignId = 1;
        } else {
            throw new RenderableException('Unauthorised Extension Found', [401], 401);
        }

        try {
            $asterisk = $this->getAsterisk($asteriskServerId, $extension, $parentId);
            $response = $asterisk->hangUp();
            if ($response == true) {
                $sql = "UPDATE cdr set disposition_id = :disposition_id WHERE lead_id = :lead_id";
                DB::connection('mysql_' . $parentId)->update($sql, array('lead_id' => $leadId, 'disposition_id' => '108'));
                /*return array(
                    'success' => true,
                    'message' => 'Hang up successful'
                );*/
                return  array(
                    'success' => 1,
                    'message' => 'Hang up successful for number =' . $number,
                    'data' => $response,
                    'code' => 303
                );
            } else {
                /*return array(
                    'success' => false,
                    'message' => 'Unable to hang up the phone'
                );*/

                throw new RenderableException('Unable to hang up the number =' . $number,  401);
            }
        } catch (\Throwable $e) {
            Log::error("Dialer.hangUpCRM", [
                "message" => $e->getMessage(),
                "code" => $e->getCode(),
                "file" => $e->getFile(),
                "line" => $e->getLine()
            ]);
            throw new RenderableException('Unable to hang up the number =' . $number,  401);
        }
    }

    /*CLose*/

    /*
     *Extension Login
     *@param object $request
     *@return array
     */
    public function extensionLogin($request)
    {
        try {
            //check extension from extension live table
            $extension = $request->auth->extension;
            $intWebPhoneSetting = DialerController::getWebPhonestatus($request->auth->id, $request->auth->parent_id);
            if ($intWebPhoneSetting == 1) {
                $extension = $request->auth->alt_extension;
            }

            /* new code implement*/

            $dataUser = User::where('id', $request->auth->id)->get()->first();

            $dialer_mode = $dataUser->dialer_mode;

            if ($dialer_mode == 3) {
                $extension = $dataUser->app_extension;
            } else
            if ($dialer_mode == 2) {
                $extension = $request->auth->alt_extension;
            } else
            if ($dialer_mode == 1) {
                $extension =  $request->auth->extension;
            }

            //echo $extension;die;

            /*close new code implement*/

            $getExtensionLive = $this->getExtensionLive($extension, $request->auth->parent_id);
            if (empty($getExtensionLive)) {
                $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $extension, $request->auth->parent_id);
                $asterisk->asteriskLogin($request->input('campaign_id'));
                $count = 1;
                while (true) {
                    $getExtensionLive = $this->getExtensionLive($extension, $request->auth->parent_id);
                    if (!empty($getExtensionLive)) {
                        $this->getLeadCountInTemp($request->input('campaign_id'), $request->auth->parent_id);
                        $modeType = $this->getHopperModeInCampaign($request->input('campaign_id'), $request->auth->parent_id);
                        $response = $this->addLeadToExtensionLive(
                            $request->input('campaign_id'),
                            $modeType['hopper_mode'],
                            $extension,
                            $request->auth->asterisk_server_id,
                            $request->auth->parent_id
                        );
                        return array(
                            'success' => $response["status"],
                            'message' => 'You are logged in successfully. ' . $response["message"]
                        );
                    } elseif ($count == 5) {
                        return array(
                            'success' => false,
                            'message' => 'Unable to log you in to system. Extenstion not reachable.'
                        );
                    } else {
                        sleep(5);
                    }
                    $count++;
                }
            } else {
                if ($getExtensionLive['lead_id']) {
                    return array(
                        'success' => true,
                        'message' => 'You are already in call. Lead Id: ' . $getExtensionLive['lead_id']
                    );
                }

                if ($getExtensionLive['status'] == 0 || $getExtensionLive['status'] == 3) {
                    $sql = "UPDATE extension_live SET status = :status, lead_id = null, campaign_id = :campaign_id WHERE extension = :extension";
                    DB::connection('mysql_' . $request->auth->parent_id)->update($sql, array('extension' => $extension, 'status' => '0', 'campaign_id' => $request->input('campaign_id')));
                    $this->getLeadCountInTemp($request->input('campaign_id'), $request->auth->parent_id);
                    $modeType = $this->getHopperModeInCampaign($request->input('campaign_id'), $request->auth->parent_id);
                    $response = $this->addLeadToExtensionLive(
                        $request->input('campaign_id'),
                        $modeType['hopper_mode'],
                        $extension,
                        $request->auth->asterisk_server_id,
                        $request->auth->parent_id
                    );
                    return array(
                        'success' => $response["status"],
                        'message' => 'You are logged in successfully. ' . $response["message"]
                    );
                } else {
                    return array(
                        'success' => false,
                        'message' => 'You are already in call'
                    );
                }
            }
        } catch (\Throwable $e) {
            Log::error("Dialer.extensionLogin", [
                "message" => $e->getMessage(),
                "code" => $e->getCode(),
                "file" => $e->getFile(),
                "line" => $e->getLine()
            ]);
            return array(
                'success' => false,
                'message' => $e->getMessage(),
                'data' => []
            );
        }
    }

    /*
     * Asterisk server detail
     * @return object
     */
    public function getAsterisk(int $serverId, int $extension, int $adminId): Asterisk
    {
        /** @var Asterisk $asterisk */
        $asterisk = Asterisk::findOrFail($serverId);
        $asterisk->setExtension($extension);
        $asterisk->setAdmin($adminId);
        return $asterisk;
    }

    /*
     * Extension live
     * @return array
     */
    public function getExtensionLive($extension, $admin)
    {
        if (!empty($extension) && is_numeric($extension) && !empty($admin) && is_numeric($admin)) {
            $extensionLive = DB::connection('mysql_' . $admin)->selectOne("SELECT * FROM extension_live WHERE extension = :extension", array('extension' => $extension));
            $extensionLive = (array)$extensionLive;
            return $extensionLive;
        }
    }

    /*
     *Call Number
     *@param object $request
     *@return array
     */
    public function callNumber($request)
    {
        try {
            if (
                !empty($request->input('campaign_id')) && is_numeric($request->input('campaign_id')) &&
                !empty($request->input('lead_id')) && is_numeric($request->input('lead_id')) &&
                !empty($request->input('number')) && is_numeric($request->input('number'))
            ) {
                $extension = $request->auth->extension;
                $intWebPhoneSetting = DialerController::getWebPhonestatus($request->auth->id, $request->auth->parent_id);
                if ($intWebPhoneSetting == 1) {
                    $extension = $request->auth->alt_extension;
                }

                /* new code implement*/

                $dataUser = User::where('id', $request->auth->id)->get()->first();

                $dialer_mode = $dataUser->dialer_mode;

                if ($dialer_mode == 3) {
                    $extension = $dataUser->app_extension;
                } else
            if ($dialer_mode == 2) {
                    $extension = $request->auth->alt_extension;
                } else
            if ($dialer_mode == 1) {
                    $extension =  $request->auth->extension;
                }

                //echo $extension;die;

                /*close new code implement*/

                $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $extension, $request->auth->parent_id);
                $response = $asterisk->click2Call($request->input('number'), $request->input('campaign_id'), $request->input('lead_id'));
                if ($response == true) {
                    return array(
                        'success' => 'true',
                        'message' => 'Number called'
                    );
                } else {
                    return array(
                        'success' => 'false',
                        'message' => 'Unable to call the number'
                    );
                }
            }
        } catch (Exception $e) {
            echo $e->getMessage();
        } catch (InvalidArgumentException $e) {
            echo $e->getMessage();
        }
    }

    /*
     *Hang Up
     *@param object $request
     *@return array
     */
    public function hangUp($request)
    {
        $extension = $request->auth->extension;
        $intWebPhoneSetting = DialerController::getWebPhonestatus($request->auth->id, $request->auth->parent_id);
        if ($intWebPhoneSetting == 1) {
            $extension = $request->auth->alt_extension;
        }

        /* new code implement*/

        $dataUser = User::where('id', $request->auth->id)->get()->first();

        $dialer_mode = $dataUser->dialer_mode;

        if ($dialer_mode == 3) {
            $extension = $dataUser->app_extension;
        } else
            if ($dialer_mode == 2) {
            $extension = $request->auth->alt_extension;
        } else
            if ($dialer_mode == 1) {
            $extension =  $request->auth->extension;
        }

        //echo $extension;die;

        /*close new code implement*/

        try {
            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $extension, $request->auth->parent_id);
            $response = $asterisk->hangUp();
            if ($response == true) {
                return array(
                    'success' => true,
                    'message' => 'Hang up successful'
                );
            } else {
                return array(
                    'success' => false,
                    'message' => 'Unable to hang up the phone'
                );
            }
        } catch (\Throwable $e) {
            Log::error("Dialer.hangUp", [
                "message" => $e->getMessage(),
                "code" => $e->getCode(),
                "file" => $e->getFile(),
                "line" => $e->getLine()
            ]);
            return array(
                'success' => false,
                'message' => 'Unable to hang up the phone. ' . $e->getMessage(),
                'data' => []
            );
        }
    }

    /*
     * Assigned lead to extenstion
     * Fetches lead information
     * @return boolean
     */
    function addLeadToExtensionLive(int $campaignId, int $hopperMode, int $extension, int $asteriskServerId, int $clientId)
    {

        $response = [
            "status" => false,
            "code" => "NO_LEADS",
            "message" => "No leads in hopper for campaign",
            "data" => []
        ];

        //check lead on temp table
        $db = $clientId;

        // hopper mode linear type
        if ($hopperMode == '1') {
            $lead = DB::connection('mysql_' . $db)->selectOne(
                "SELECT * FROM lead_temp WHERE campaign_id = :campaign_id ORDER BY lead_id ASC",
                ['campaign_id' => $campaignId]
            );
        }

        // hopper mode random type

        else
            if ($hopperMode == '2') {
            $lead = DB::connection('mysql_' . $db)->selectOne(
                "SELECT * FROM lead_temp WHERE campaign_id = :campaign_id and redial = '1'",
                ['campaign_id' => $campaignId]
            );

            if (empty($lead)) {
                $lead = DB::connection('mysql_' . $db)->selectOne(
                    "SELECT * FROM lead_temp WHERE campaign_id = :campaign_id ORDER BY RAND()",
                    ['campaign_id' => $campaignId]
                );
            }
        }


        $lead = (array)$lead;

        if (!empty($lead)) {
            DB::connection('mysql_' . $db)->delete(
                "DELETE FROM lead_temp WHERE campaign_id = :campaign_id AND lead_id = :lead_id",
                [
                    'campaign_id' => $campaignId,
                    'lead_id' => $lead['lead_id']
                ]
            );

            $campaignType = DB::connection('mysql_' . $db)->selectOne(
                "SELECT dial_mode FROM campaign WHERE id = :id",
                [
                    'id' => $campaignId
                ]
            );

            $dialMode = (array)$campaignType;
            if ($dialMode['dial_mode'] == 'super_power_dial') {
                $sql = "SELECT column_name FROM list_header  WHERE list_id = :list_id AND is_dialing = :is_dialing";
                $listHeader = DB::connection('mysql_' . $db)->selectOne($sql, ['list_id' => $lead['list_id'], 'is_dialing' => 1]);
                $listHeader = (array)$listHeader;

                $sql = "SELECT * FROM list_data  WHERE id = :id";
                $listData = DB::connection('mysql_' . $db)->selectOne($sql, ['id' => $lead['lead_id']]);
                $listData = (array)$listData;
                $number = $listData[$listHeader['column_name']];

                $numStr2 = (string)$number;

                $mobile = preg_replace('/[^0-9]/', '', $numStr2);
                $digitCount2 = strlen($mobile);
                // return array('status' => false, 'message' => $number.'  '.$mobile.' '.$digitCount2);
                // if (!empty($number)) {

                if ($digitCount2 == 10) {
                    $sql = "UPDATE extension_live SET lead_id = :lead_id, campaign_id = :campaign_id WHERE extension = :extension";
                    DB::connection('mysql_' . $db)->update(
                        $sql,
                        [
                            'extension' => $extension,
                            'lead_id' => $lead['lead_id'],
                            'campaign_id' => $campaignId
                        ]
                    );
                    $asterisk = $this->getAsterisk($asteriskServerId, $extension, $clientId);
                    $response = $asterisk->click2Call($number, $campaignId, $lead['lead_id']);
                    if ($response == true) {
                        $this->addToLeadReport('mysql_' . $db, $campaignId, $lead['list_id'], $lead['lead_id'], 0);
                        return array('status' => true, 'message' => "Call connected");
                    } else {
                        return array('status' => false, 'message' => "Unable to connect call");
                    }
                } else {

                    $addResponse = $this->addLeadToExtensionLive($campaignId, $hopperMode, $extension, $asteriskServerId, $clientId);
                    $response["dail_next_lead"] = $addResponse;
                    //return array('status' => false, 'message' => "Incorrect lead value");
                }
            } elseif ($dialMode['dial_mode'] == 'predictive_dial') {

                $sql = "SELECT column_name FROM list_header  WHERE list_id = :list_id AND is_dialing = :is_dialing";
                $listHeader = DB::connection('mysql_' . $db)->selectOne($sql, ['list_id' => $lead['list_id'], 'is_dialing' => 1]);
                $listHeader = (array)$listHeader;

                $sql = "SELECT * FROM list_data  WHERE id = :id";
                $listData = DB::connection('mysql_' . $db)->selectOne($sql, ['id' => $lead['lead_id']]);
                $listData = (array)$listData;
                $number = $listData[$listHeader['column_name']];

                if (!empty($number)) {
                    /* $sql = "UPDATE extension_live SET lead_id = :lead_id, campaign_id = :campaign_id WHERE extension = :extension";
                    DB::connection('mysql_' . $db)->update($sql,
                        [
                            'extension' => $extension,
                            'lead_id' => $lead['lead_id'],
                            'campaign_id' => $campaignId
                        ]
                    );*/

                    $asterisk = $this->getAsterisk($asteriskServerId, $extension, $clientId);
                    $response = $asterisk->predictiveDial($number, $campaignId, $lead['lead_id'], $clientId);
                    if ($response == true) {
                        $this->addToLeadReport('mysql_' . $db, $campaignId, $lead['list_id'], $lead['lead_id'], 0);
                        return array('status' => true, 'message' => "Call connected Predictive Dial Calls");
                    } else {
                        return array('status' => false, 'message' => "Unable to connect call Predictive Dial");
                    }
                } else {
                    return array('status' => false, 'message' => "Incorrect lead value Predictive dial");
                }
            } elseif ($dialMode['dial_mode'] == 'outbound_ai') {

                $sql = "SELECT column_name FROM list_header  WHERE list_id = :list_id AND is_dialing = :is_dialing";
                $listHeader = DB::connection('mysql_' . $db)->selectOne($sql, ['list_id' => $lead['list_id'], 'is_dialing' => 1]);
                $listHeader = (array)$listHeader;

                $sql = "SELECT * FROM list_data  WHERE id = :id";
                $listData = DB::connection('mysql_' . $db)->selectOne($sql, ['id' => $lead['lead_id']]);
                $listData = (array)$listData;
                $number = $listData[$listHeader['column_name']];

                if (!empty($number)) {
                    /* $sql = "UPDATE extension_live SET lead_id = :lead_id, campaign_id = :campaign_id WHERE extension = :extension";
                    DB::connection('mysql_' . $db)->update($sql,
                        [
                            'extension' => $extension,
                            'lead_id' => $lead['lead_id'],
                            'campaign_id' => $campaignId
                        ]
                    );*/

                    $asterisk = $this->getAsterisk($asteriskServerId, $extension, $clientId);
                    $response = $asterisk->outboundAIDial($number, $campaignId, $lead['lead_id'], $clientId);
                    if ($response == true) {
                        $this->addToLeadReport('mysql_' . $db, $campaignId, $lead['list_id'], $lead['lead_id'], 0);
                        return array('status' => true, 'message' => "Call connected Outbound AI Dial Calls");
                    } else {
                        return array('status' => false, 'message' => "Unable to connect call Outbound AI Dial");
                    }
                } else {
                    return array('status' => false, 'message' => "Incorrect lead value Outbound AI dial");
                }
            } else {

                $insertSql = "INSERT INTO extension_live (extension, status, campaign_id, lead_id)
                          VALUES (:extension, :status, :campaign_id, :lead_id)
                          ON DUPLICATE KEY UPDATE  status = :status_1, campaign_id = :campaign_id_1, lead_id = :lead_id_1";
                DB::connection('mysql_' . $db)->insert(
                    $insertSql,
                    array(
                        'extension' => $extension,
                        'status' => 0,
                        'campaign_id' => $campaignId,
                        'lead_id' => $lead['lead_id'],
                        'status_1' => 0,
                        'campaign_id_1' => $campaignId,
                        'lead_id_1' => $lead['lead_id']
                    )
                );
                $this->addToLeadReport('mysql_' . $db, $campaignId, $lead['list_id'], $lead['lead_id'], 0);
                return array('status' => true, 'message' => "Call connected");
            }
        }
        return $response;
    }

    /*
     * disposition Campaign
     * @return array
     */
    public function dispositionCampaign($request)
    {
        $sql = "SELECT id, title FROM disposition WHERE is_deleted = 0 ";
        $record = DB::connection('mysql_' . $request->auth->parent_id)->select($sql);
        $dataClient = (array)$record;
        if (!empty($dataClient)) {
            return array(
                'success' => 'true',
                'message' => 'Dispositions detail.',
                'data' => $dataClient
            );
        }
        return array(
            'success' => 'false',
            'message' => 'Dispositions not created.',
            'data' => array()
        );
    }

    public function dispositionByCampaignId(int $campaignId, int $clientId)
    {
        $sql = "SELECT d.id, d.title,d.enable_sms, d_type FROM campaign_disposition as cd INNER JOIN disposition as d ON cd.disposition_id = d.id  WHERE cd.is_deleted = :is_deleted AND cd.campaign_id = :campaign_id AND d.title!='' ";
        $record = DB::connection("mysql_$clientId")->select($sql, array('is_deleted' => 0, 'campaign_id' => $campaignId));
        $dataClient = (array)$record;
        $data = $dataClient;
        if (!empty($data)) {
            return array(
                'success' => 'true',
                'message' => 'Dispositions detail.',
                'data' => $data
            );
        }
        return array(
            'success' => 'false',
            'message' => 'Dispositions not created.',
            'data' => array()
        );
    }

    public function getLead(int $parentId, int $extension)
    {
        $data = array();
        $number = null;
        $connection = "mysql_$parentId";

        //Fetch current lead
        $sql = "SELECT * FROM extension_live  WHERE extension = :extension";
        $extensionLive = DB::connection($connection)->selectOne($sql, array('extension' => $extension));
        $extensionLive = (array)$extensionLive;
        if (!empty($extensionLive) && !empty($extensionLive['lead_id'])) {
            $lead = $extensionLive['lead_id'];
            $sql = "SELECT * FROM list_data  WHERE id = :id";
            $listData = DB::connection($connection)->selectOne($sql, array('id' => $lead));
            $listData = (array)$listData;
            $listId = $listData['list_id'];

            $listHeaders = ListHeader::on($connection)->where([
                ["is_visible", "=", 1],
                ["is_deleted", "=", 0],
                ["list_id", "=", $listId]
            ])->get()->all();

            foreach ($listHeaders as $header) {
                if ($header->is_dialing == 1) $number = $listData[$header->column_name];
                $title = null;
                if (!empty($header->label_id)) {
                    $label = \App\Model\Client\Label::on($connection)->find($header->label_id);
                    if ($label) $title = $label->title;
                }
                $data[$header->column_name] = [
                    "label" => $title,
                    "value" => $listData[$header->column_name],
                    "is_dialing" => $header->is_dialing,
                    "is_visible" => $header->is_visible,
                    "is_editable" => $header->is_editable,
                    "alternate_phone" => $header->alternate_phone
                ];
            }

            $number = preg_replace('/[^0-9]/', '', $number);

            return [
                'success' => true,
                'message' => 'lead detail.',
                'number' => $number,
                'lead_id' => $lead,
                'list_id' => $listId,
                'data' => $data
            ];
        }

        return [
            'success' => false,
            'message' => "Not on a call",
            'number' => null,
            'lead_id' => null,
            'data' => $data
        ];
    }

    /*
     * save disposition
     * @return array
     */
    public function saveDisposition($request)
    {
        $response = [
            "extension_update" => false,
            "cdr_update" => false
        ];

        $extension = $request->auth->extension;
        $intWebPhoneSetting = DialerController::getWebPhonestatus($request->auth->id, $request->auth->parent_id);
        if ($intWebPhoneSetting == 1) {
            $extension = $request->auth->alt_extension;
        }

        /* new code implement*/

        $dataUser = User::where('id', $request->auth->id)->get()->first();

        $dialer_mode = $dataUser->dialer_mode;

        if ($dialer_mode == 3) {
            $extension = $dataUser->app_extension;
        } else
            if ($dialer_mode == 2) {
            $extension = $request->auth->alt_extension;
        } else
            if ($dialer_mode == 1) {
            $extension =  $request->auth->extension;
        }

        //echo $extension;die;

        /*close new code implement*/

        $db = "mysql_" . $request->auth->parent_id;
        $campaignId = $request->input('campaign_id');
        $leadId = $request->input('lead_id');
        $dispositionId = $request->input('disposition_id');
        $pauseCalling = $request->input('pause_calling');
        $callBack = $request->input('call_back');
        $comment = $request->input('comment');
        $apiCall = $request->input('api_call');
        //Update extension_live table
        $status = ($pauseCalling == 1) ? 3 : 0;
        $sql = "";
        $profiler = new ExecutionProfiler();

        try {
            $extensionLive = ExtensionLive::on($db)->findOrFail($extension);
            $extensionLive->status = $status;
            $extensionLive->lead_id = null;
            $extensionLive->saveOrFail();
            $response["extension_update"] = true;
        } catch (\Exception $exception) {
            Log::error("Failed to update extension_live", [
                "message" => $exception->getMessage(),
                "file" => $exception->getFile(),
                "line" => $exception->getLine()
            ]);
        }
        $profiler->addInterval("extension_live_updated");

        //Cdr Detail
        try {
            $sql = "SELECT id, number FROM cdr WHERE lead_id = :lead_id AND campaign_id = :campaign_id AND extension = :extension ORDER BY id DESC LIMIT 1";
            $cdr = DB::connection($db)->selectOne($sql, array('lead_id' => $leadId, 'campaign_id' => $campaignId, 'extension' => $extension));
            $cdr = (array)$cdr;
            $response["cdr_update"] = $cdr;
        } catch (\Exception $exception) {
            Log::error("Failed to fetch cdr", [
                "sql" => $sql,
                "message" => $exception->getMessage()
            ]);
        }
        $profiler->addInterval("cdr_updated");


        // Disposition Detail
        try {
            $sql = "SELECT * FROM disposition WHERE id=:dispositionId";
            $dispositionDetail = DB::connection($db)->selectOne($sql, array('dispositionId' => $dispositionId));
            $dispositionDetail = (array)$dispositionDetail;
        } catch (\Exception $exception) {
            Log::error("Failed to fetch disposition", [
                "sql" => $sql,
                "message" => $exception->getMessage()
            ]);
        }
        $profiler->addInterval("disposition_updated");

        if (!empty($cdr)) {
            $number = $cdr['number'];
            $id = $cdr['id'];
        }

        //Update PowerDialCDR
        if (!empty($id)) {
            try {
                $sql = "UPDATE cdr set disposition_id = :disposition_id WHERE id = :id";
                DB::connection($db)->update($sql, array('id' => $id, 'disposition_id' => $dispositionId));
            } catch (\Exception $exception) {
                Log::error("Failed to update disposition", [
                    "sql" => $sql,
                    "message" => $exception->getMessage()
                ]);
            }
        } else {
            try {
                $sql = "UPDATE cdr set disposition_id = :disposition_id WHERE extension = :extension AND lead_id = :lead_id AND campaign_id = :campaign_id ORDER BY id DESC";
                DB::connection($db)->update($sql, array('lead_id' => $leadId, 'campaign_id' => $campaignId, 'extension' => $extension, 'disposition_id' => $dispositionId));
            } catch (\Exception $exception) {
                Log::error("Failed to update disposition", [
                    "sql" => $sql,
                    "message" => $exception->getMessage()
                ]);
            }
        }
        $profiler->addInterval("cdr_updated_2");

        //Update lead_report
        try {
            $sql = "UPDATE lead_report SET disposition_id = :disposition_id WHERE campaign_id = :campaign_id AND lead_id = :lead_id";
            DB::connection($db)->update($sql, array('campaign_id' => $campaignId, 'disposition_id' => $dispositionId, 'lead_id' => $leadId));
        } catch (\Exception $exception) {
            Log::error("Failed to update lead_report", [
                "sql" => $sql,
                "message" => $exception->getMessage()
            ]);
        }
        $profiler->addInterval("lead_report_updated");

        //Add comment
        if (!empty($comment) && !empty($id)) {
            try {
                $sql = "INSERT IGNORE INTO comment (extension, campaign_id, cdr_id, lead_id, comment) VALUE (:extension, :campaign_id, :cdr_id, :lead_id, :comment)";
                DB::connection($db)->insert($sql, array('extension' => $extension, 'campaign_id' => $campaignId, 'cdr_id' => $id, 'lead_id' => $leadId, 'comment' => $comment));
            } catch (\Exception $exception) {
                Log::error("Failed to add comment", [
                    "sql" => $sql,
                    "message" => $exception->getMessage()
                ]);
            }
            $profiler->addInterval("comment_added");
        }

        //Add callback time
        //$id=11;
        if (!empty($callBack) && !empty($id) && $dispositionDetail['d_type'] == 3) {
            try {
                $sql = "INSERT IGNORE INTO callback (extension, campaign_id, cdr_id, lead_id, callback_time) VALUE (:extension, :campaign_id, :cdr_id, :lead_id, :callback_time)";
                DB::connection($db)->insert($sql, array('extension' => $extension, 'campaign_id' => $campaignId, 'cdr_id' => $id, 'lead_id' => $leadId, 'callback_time' => $callBack));


                $schedule = new Schedule();
                $schedule->setConnection($db);
                $schedule->title = $request->input('full_name');
                $schedule->description = $request->input('callback_comment');
                $schedule->start_datetime = $callBack;
                $schedule->end_datetime = $callBack;
                $schedule->user_id = $request->auth->id;
                // $schedule->timezone = 'sssss';

                $schedule->save();
            } catch (\Exception $exception) {
                Log::error("Failed to add callback", [
                    "sql" => $sql,
                    "message" => $exception->getMessage()
                ]);
            }
            $profiler->addInterval("callback_added");
        }
        //update dnc
        $dncArray = array('1', '2', '5', '9', '3');
        //if(!empty($number) && in_array($dispositionId, $dncArray))


        if (!empty($number) && $dispositionDetail['d_type'] == 2) {
            $comment = "No Comments";
            // switch ($dispositionId){
            //     case '1':
            //         $comment = "Do not Call";
            //         break;
            //     case '2':
            //         $comment = "Wrong number";
            //         break;
            //     case '5':
            //         $comment = "Disconnected Number";
            //         break;
            //     case '9':
            //         $comment = "Disconnected or Wrong Number";
            //         break;
            //     default:
            //         $comment = "Sale Made";
            // }

            try {
                $sql = "INSERT INTO dnc (number, extension, comment) VALUE (:number, :extension, :comment)";
                DB::connection($db)->insert($sql, array('number' => $number, 'extension' => $extension, 'comment' => $comment));
            } catch (\Exception $exception) {
                Log::error("Failed to add dnc", [
                    "sql" => $sql,
                    "message" => $exception->getMessage()
                ]);
            }
            $profiler->addInterval("dnc_added");
        }

        //call Api
        if ($apiCall == '1') {
            try {
                $callApi = $this->apiData($extension, $request->auth->parent_id, $db, $campaignId, $leadId, $dispositionId, $number);
                if (!empty($callApi)) {
                    $res = $this->callAPI($callApi['method'], $callApi['url'], $callApi['data']);
                    //$this->database->setData('api_log', array('extension' => $extension, 'campaign_id' =>$campaignId, 'lead_id' => $leadId, 'type' => 'post', 'url' => addslashes(htmlentities($value['url'])) , 'data' => addslashes(htmlentities(json_encode($value['data']))), 'response' => addslashes(htmlentities($res))));
                }
            } catch (\Exception $exception) {
                Log::error("Failed to call API", [
                    "message" => $exception->getMessage()
                ]);
            }
            $profiler->addInterval("api_call");
        }
        if ($pauseCalling != 1) {
            try {
                $modeType = $this->getHopperModeInCampaign($campaignId, $request->auth->parent_id);
                $addResponse = $this->addLeadToExtensionLive(
                    $request->input('campaign_id'),
                    $modeType['hopper_mode'],
                    $extension,
                    $request->auth->asterisk_server_id,
                    $request->auth->parent_id
                );
                $response["dail_next_lead"] = $addResponse;
            } catch (\Exception $exception) {
                Log::error("Failed to to dial next lead", [
                    "message" => $exception->getMessage()
                ]);
            }
            $profiler->addInterval("dail_next_lead");

            /*if($addResponse != true)
            {
                return array(
                    'success' => 'false',
                    'message' => 'Disposition saved successfully, but Unable to dial next lead'
                );
            }*/
        }
        $profile = $profiler->calculate();
        $response["execution_time"] = $profile;
        Log::info("Dailer.saveDisposition.response", $response);
        return $response;
    }


    public function redialCall($request)
    {
        $response = [
            "extension_update" => false,
            "cdr_update" => false
        ];

        $extension = $request->auth->extension;
        $intWebPhoneSetting = DialerController::getWebPhonestatus($request->auth->id, $request->auth->parent_id);
        if ($intWebPhoneSetting == 1) {
            $extension = $request->auth->alt_extension;
        }

        /* new code implement*/

        $dataUser = User::where('id', $request->auth->id)->get()->first();

        $dialer_mode = $dataUser->dialer_mode;

        if ($dialer_mode == 3) {
            $extension = $dataUser->app_extension;
        } else
            if ($dialer_mode == 2) {
            $extension = $request->auth->alt_extension;
        } else
            if ($dialer_mode == 1) {
            $extension =  $request->auth->extension;
        }

        //echo $extension;die;

        /*close new code implement*/

        $db = "mysql_" . $request->auth->parent_id;
        $campaignId = $request->input('campaign_id');
        $leadId = $request->input('lead_id');
        $dispositionId = $request->input('disposition_id');
        $pauseCalling = $request->input('pause_calling');
        $callBack = $request->input('call_back');
        $comment = $request->input('comment');
        $listId = $request->input('listId');

        $apiCall = $request->input('api_call');
        //Update extension_live table
        $status = ($pauseCalling == 1) ? 3 : 0;
        $sql = "";
        $profiler = new ExecutionProfiler();

        $redial = 1;


        if ($redial == 1) {

            $this->addToLeadTempTableRedialCall($db, $campaignId, $listId, $leadId, 0);
        }

        try {
            $extensionLive = ExtensionLive::on($db)->findOrFail($extension);
            $extensionLive->status = $status;
            $extensionLive->lead_id = null;
            $extensionLive->saveOrFail();
            $response["extension_update"] = true;
        } catch (\Exception $exception) {
            Log::error("Failed to update extension_live", [
                "message" => $exception->getMessage(),
                "file" => $exception->getFile(),
                "line" => $exception->getLine()
            ]);
        }
        $profiler->addInterval("extension_live_updated");

        //Cdr Detail
        try {
            $sql = "SELECT id, number FROM cdr WHERE lead_id = :lead_id AND campaign_id = :campaign_id AND extension = :extension ORDER BY id DESC LIMIT 1";
            $cdr = DB::connection($db)->selectOne($sql, array('lead_id' => $leadId, 'campaign_id' => $campaignId, 'extension' => $extension));
            $cdr = (array)$cdr;
            $response["cdr_update"] = $cdr;
        } catch (\Exception $exception) {
            Log::error("Failed to fetch cdr", [
                "sql" => $sql,
                "message" => $exception->getMessage()
            ]);
        }
        $profiler->addInterval("cdr_updated");


        // Disposition Detail
        try {
            $sql = "SELECT * FROM disposition WHERE id=:dispositionId";
            $dispositionDetail = DB::connection($db)->selectOne($sql, array('dispositionId' => $dispositionId));
            $dispositionDetail = (array)$dispositionDetail;
        } catch (\Exception $exception) {
            Log::error("Failed to fetch disposition", [
                "sql" => $sql,
                "message" => $exception->getMessage()
            ]);
        }
        $profiler->addInterval("disposition_updated");

        if (!empty($cdr)) {
            $number = $cdr['number'];
            $id = $cdr['id'];
        }

        //Update PowerDialCDR
        if (!empty($id)) {
            try {
                $sql = "UPDATE cdr set disposition_id = :disposition_id WHERE id = :id";
                DB::connection($db)->update($sql, array('id' => $id, 'disposition_id' => $dispositionId));
            } catch (\Exception $exception) {
                Log::error("Failed to update disposition", [
                    "sql" => $sql,
                    "message" => $exception->getMessage()
                ]);
            }
        } else {
            try {
                $sql = "UPDATE cdr set disposition_id = :disposition_id WHERE extension = :extension AND lead_id = :lead_id AND campaign_id = :campaign_id ORDER BY id DESC";
                DB::connection($db)->update($sql, array('lead_id' => $leadId, 'campaign_id' => $campaignId, 'extension' => $extension, 'disposition_id' => $dispositionId));
            } catch (\Exception $exception) {
                Log::error("Failed to update disposition", [
                    "sql" => $sql,
                    "message" => $exception->getMessage()
                ]);
            }
        }
        $profiler->addInterval("cdr_updated_2");

        //Update lead_report
        try {
            $sql = "UPDATE lead_report SET disposition_id = :disposition_id WHERE campaign_id = :campaign_id AND lead_id = :lead_id";
            DB::connection($db)->update($sql, array('campaign_id' => $campaignId, 'disposition_id' => $dispositionId, 'lead_id' => $leadId));
        } catch (\Exception $exception) {
            Log::error("Failed to update lead_report", [
                "sql" => $sql,
                "message" => $exception->getMessage()
            ]);
        }
        $profiler->addInterval("lead_report_updated");

        //Add comment
        if (!empty($comment) && !empty($id)) {
            try {
                $sql = "INSERT IGNORE INTO comment (extension, campaign_id, cdr_id, lead_id, comment) VALUE (:extension, :campaign_id, :cdr_id, :lead_id, :comment)";
                DB::connection($db)->insert($sql, array('extension' => $extension, 'campaign_id' => $campaignId, 'cdr_id' => $id, 'lead_id' => $leadId, 'comment' => $comment));
            } catch (\Exception $exception) {
                Log::error("Failed to add comment", [
                    "sql" => $sql,
                    "message" => $exception->getMessage()
                ]);
            }
            $profiler->addInterval("comment_added");
        }

        //Add callback time
        if (!empty($callBack) && !empty($id) && $dispositionDetail['d_type'] == 3) {
            try {
                $sql = "INSERT IGNORE INTO callback (extension, campaign_id, cdr_id, lead_id, callback_time) VALUE (:extension, :campaign_id, :cdr_id, :lead_id, :callback_time)";
                DB::connection($db)->insert($sql, array('extension' => $extension, 'campaign_id' => $campaignId, 'cdr_id' => $id, 'lead_id' => $leadId, 'callback_time' => $callBack));
            } catch (\Exception $exception) {
                Log::error("Failed to add callback", [
                    "sql" => $sql,
                    "message" => $exception->getMessage()
                ]);
            }
            $profiler->addInterval("callback_added");
        }
        //update dnc
        $dncArray = array('1', '2', '5', '9', '3');
        //if(!empty($number) && in_array($dispositionId, $dncArray))


        if (!empty($number) && $dispositionDetail['d_type'] == 2) {
            $comment = "No Comments";
            // switch ($dispositionId){
            //     case '1':
            //         $comment = "Do not Call";
            //         break;
            //     case '2':
            //         $comment = "Wrong number";
            //         break;
            //     case '5':
            //         $comment = "Disconnected Number";
            //         break;
            //     case '9':
            //         $comment = "Disconnected or Wrong Number";
            //         break;
            //     default:
            //         $comment = "Sale Made";
            // }

            try {
                $sql = "INSERT INTO dnc (number, extension, comment) VALUE (:number, :extension, :comment)";
                DB::connection($db)->insert($sql, array('number' => $number, 'extension' => $extension, 'comment' => $comment));
            } catch (\Exception $exception) {
                Log::error("Failed to add dnc", [
                    "sql" => $sql,
                    "message" => $exception->getMessage()
                ]);
            }
            $profiler->addInterval("dnc_added");
        }

        //call Api
        if ($apiCall == '1') {
            try {
                $callApi = $this->apiData($extension, $request->auth->parent_id, $db, $campaignId, $leadId, $dispositionId, $number);
                if (!empty($callApi)) {
                    $res = $this->callAPI($callApi['method'], $callApi['url'], $callApi['data']);
                    //$this->database->setData('api_log', array('extension' => $extension, 'campaign_id' =>$campaignId, 'lead_id' => $leadId, 'type' => 'post', 'url' => addslashes(htmlentities($value['url'])) , 'data' => addslashes(htmlentities(json_encode($value['data']))), 'response' => addslashes(htmlentities($res))));
                }
            } catch (\Exception $exception) {
                Log::error("Failed to call API", [
                    "message" => $exception->getMessage()
                ]);
            }
            $profiler->addInterval("api_call");
        }
        if ($pauseCalling != 1) {
            try {
                $modeType = $this->getHopperModeInCampaign($campaignId, $request->auth->parent_id);
                $addResponse = $this->addLeadToExtensionLive(
                    $request->input('campaign_id'),
                    $modeType['hopper_mode'],
                    $extension,
                    $request->auth->asterisk_server_id,
                    $request->auth->parent_id
                );
                $response["dail_next_lead"] = $addResponse;
            } catch (\Exception $exception) {
                Log::error("Failed to to dial next lead", [
                    "message" => $exception->getMessage()
                ]);
            }
            $profiler->addInterval("dail_next_lead");

            /*if($addResponse != true)
            {
                return array(
                    'success' => 'false',
                    'message' => 'Disposition saved successfully, but Unable to dial next lead'
                );
            }*/
        }
        $profile = $profiler->calculate();
        $response["execution_time"] = $profile;
        Log::info("Dailer.saveDisposition.response", $response);
        return $response;
    }

    /*
     * Insert data in lead report
     * @return boolean
     */
    public function addToLeadReport($db, $campaignId, $listId, $leadId, $dispositionId)
    {
        $insertSql = "INSERT INTO lead_report (campaign_id, list_id, lead_id, disposition_id) VALUE (:campaign_id, :list_id, :lead_id, :disposition_id) ON DUPLICATE KEY UPDATE disposition_id = :disposition_id_1";
        return DB::connection($db)->insert(
            $insertSql,
            array(
                'campaign_id' => $campaignId,
                'list_id' => $listId,
                'lead_id' => $leadId,
                'disposition_id' => $dispositionId,
                'disposition_id_1' => $dispositionId
            )
        );
    }

    public function addToLeadTempTable($db, $campaignId, $listId, $leadId, $dispositionId)
    {
        $insertSql = "INSERT INTO lead_temp (campaign_id, list_id, lead_id) VALUE (:campaign_id, :list_id, :lead_id) ON DUPLICATE KEY UPDATE lead_id = :lead_id_1";
        return DB::connection($db)->insert(
            $insertSql,
            array(
                'campaign_id' => $campaignId,
                'list_id' => $listId,
                'lead_id' => $leadId,
                'lead_id_1' => $leadId
            )
        );
    }


    public function addToLeadTempTableRedialCall($db, $campaignId, $listId, $leadId, $dispositionId)
    {
        $redial = '1';
        $insertSql = "INSERT INTO lead_temp (campaign_id, list_id, lead_id, redial) VALUE (:campaign_id, :list_id, :lead_id, :redial) ON DUPLICATE KEY UPDATE lead_id = :lead_id_1";
        return DB::connection($db)->insert(
            $insertSql,
            array(
                'campaign_id' => $campaignId,
                'list_id' => $listId,
                'lead_id' => $leadId,
                'lead_id_1' => $leadId,
                'redial' => $redial
            )
        );
    }

    /*
     *DTMF
     *@param object $request
     *@return array
     */
    public function dtmf($request)
    {
        try {
            $extension = $request->auth->extension;
            $intWebPhoneSetting = DialerController::getWebPhonestatus($request->auth->id, $request->auth->parent_id);
            if ($intWebPhoneSetting == 1) {
                $extension = $request->auth->alt_extension;
            }

            /* new code implement*/

            $dataUser = User::where('id', $request->auth->id)->get()->first();

            $dialer_mode = $dataUser->dialer_mode;

            if ($dialer_mode == 3) {
                $extension = $dataUser->app_extension;
            } else
            if ($dialer_mode == 2) {
                $extension = $request->auth->alt_extension;
            } else
            if ($dialer_mode == 1) {
                $extension =  $request->auth->extension;
            }

            //echo $extension;die;

            /*close new code implement*/

            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $extension, $request->auth->parent_id);
            $response = $asterisk->dtmf($request->input('number'));
            if ($response['status'] == true) {
                return array(
                    'success' => 'true',
                    'message' => 'DTMF dialed successfully'
                );
            } else {
                return array(
                    'success' => 'false',
                    'message' => $response['message']
                );
            }
        } catch (Exception $e) {
            echo $e->getMessage();
        } catch (InvalidArgumentException $e) {
            echo $e->getMessage();
        }
    }

    /*
     *Voicemail Drop
     *@param object $request
     *@return array
     */
    public function voicemailDrop($request)
    {

        try {
            $extension = $request->auth->extension;
            $intWebPhoneSetting = DialerController::getWebPhonestatus($request->auth->id, $request->auth->parent_id);
            if ($intWebPhoneSetting == 1) {
                $extension = $request->auth->alt_extension;
            }

            /* new code implement*/

            $dataUser = User::where('id', $request->auth->id)->get()->first();

            $dialer_mode = $dataUser->dialer_mode;

            if ($dialer_mode == 3) {
                $extension = $dataUser->app_extension;
            } else
            if ($dialer_mode == 2) {
                $extension = $request->auth->alt_extension;
            } else
            if ($dialer_mode == 1) {
                $extension =  $request->auth->extension;
            }

            //echo $extension;die;

            /*close new code implement*/

            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $extension, $request->auth->parent_id);
            $response = $asterisk->voicemailDrop();
            if ($response['status'] == true) {
                return array(
                    'success' => 'true',
                    'message' => 'Voice mail dropped'
                );
            } else {
                return array(
                    'success' => 'false',
                    'message' => $response['message']
                );
            }
        } catch (Exception $e) {
            echo $e->getMessage();
        } catch (InvalidArgumentException $e) {
            echo $e->getMessage();
        }
    }

    public function apiData($extension, $adminId, $db, $campaignId, $leadId, $dispositionId, $number = '')
    {
        if (empty($number)) {
            $sql = "SELECT number FROM cdr WHERE extension = :extension AND lead_id = :lead AND campaign_id = :campaign order by id desc limit 0,1";
            $cdr = DB::connection($db)->selectOne($sql, array('extension' => $extension, 'lead' => $leadId, 'campaign' => $campaignId));
            $cdr = (array)$cdr;
            if (!empty($cdr)) {
                $number = $cdr['number'];
            }
        }
        $param = array(
            'extension' => $extension,
            'campaignId' => $campaignId,
            'leadId' => $leadId,
            'dispositionId' => $dispositionId,
            'dialed_number' => $number,
            'adminAccountNum' => $adminId
        );
        return $this->getApiData($param, $db);
    }

    /*

    changes related to two or more api url added and send to crm show both urls.

    public function getApiData($param = array(), $db)
    {
        $sql = "SELECT id, url, method FROM api WHERE is_deleted = :is_deleted AND campaign_id = :campaign";
        $api = DB::connection($db)->selectOne($sql, array('is_deleted' => 0, 'campaign' => $param['campaignId']));
        $api = (array)$api;
        if (!empty($api)) {
            $returnArray = array();
            $url = $api['url'];
            $method = $api['method'];
            $apiId = $api['id'];
            if ($param['dispositionId'] != 0) {
                $sql = "SELECT disposition_id FROM api_disposition WHERE api_id = :api_id AND disposition_id = :disposition_id";
                $apiDisposition = DB::connection($db)->selectOne($sql, array('api_id' => $apiId, 'disposition_id' => $param['dispositionId']));
                $apiDisposition = (array)$apiDisposition;
                if (empty($apiDisposition)) {
                    return;
                }
            }
            if (!empty($url)) {
                $data = array();
                $sql = "SELECT parameter, value, type FROM api_parameter WHERE api_id = :api_id";
                $apiLabelParam = DB::connection($db)->select($sql, array('api_id' => $apiId));
                foreach ( $apiLabelParam as $key1 => $value1 ) {

                    $data[$value1->parameter] = ($value1->type == "label") ? $this->leadColumnData($param['leadId'], $value1->value, $db) : $value1->value;
                }
                $param['api_id'] = $apiId;
                $res = $this->getCustomApiData($param, $data, $db);
                if (!empty($res) && is_array($res)) {
                    $returnData = array_merge($data, $res);
                } else {
                    $returnData = $data;
                }

                if (!empty($returnData)) {
                    $returnArray = array('method' => $method, 'url' => $url, 'data' => $returnData);
                }
            }
            return $returnArray;
        }
        return;
    }*/

    public function getApiData($param = array(), $db)
    {
        $sql = "SELECT id, url, method FROM api WHERE is_deleted = :is_deleted AND campaign_id = :campaign";
        $api = DB::connection($db)->select($sql, array('is_deleted' => 0, 'campaign' => $param['campaignId']));
        $api = (array)$api;
        if (!empty($api)) {
            $returnArray = array();
            foreach ($api as $item => $value) {
                $url[$item] = $value->url;
                $method[$item] = $value->method;
                $apiId = $value->id;

                if ($param['dispositionId'] != 0) {
                    $sql = "SELECT disposition_id FROM api_disposition WHERE api_id = :api_id AND disposition_id = :disposition_id";
                    $apiDisposition = DB::connection($db)->selectOne($sql, array('api_id' => $apiId, 'disposition_id' => $param['dispositionId']));
                    $apiDisposition = (array)$apiDisposition;
                    if (empty($apiDisposition)) {
                        return;
                    }
                }

                if (!empty($url)) {
                    $data = array();
                    $sql = "SELECT parameter, value, type FROM api_parameter WHERE api_id = :api_id";
                    $apiLabelParam = DB::connection($db)->select($sql, array('api_id' => $apiId));
                    foreach ($apiLabelParam as $key1 => $value1) {
                        $data[$value1->parameter] = ($value1->type == "label") ? $this->leadColumnData($param['leadId'], $value1->value, $db) : $value1->value;
                    }

                    $param['api_id'] = $apiId;
                    $res = $this->getCustomApiData($param, $method[$item], $data, $db);
                    if (!empty($res) && is_array($res)) {
                        $returnData[$item] = array_merge($data, $res);
                    } else {
                        $returnData[$item] = $data;
                    }

                    if (!empty($returnData)) {
                        $returnArray = array('param' => $param['api_id'], 'method' => $method, 'url' => $url, 'data' => $returnData);
                    }
                }
            }
            return $returnArray;
        }
        return;
    }

    public function leadColumnData($lead_id, $label_id, $db)
    {
        if (!empty($lead_id)) {
            $sql = "select * from list_data where id = :id";
            $leadDetail = DB::connection($db)->selectOne($sql, array('id' => $lead_id));
            $leadDetail = (array)$leadDetail;
            if (!empty($leadDetail)) {
                $listId = $leadDetail['list_id'];
                $sql = "select column_name from list_header where list_id = :list_id and label_id = :label_id";
                $column_name = DB::connection($db)->selectOne($sql, array('list_id' => $listId, 'label_id' => $label_id));
                $column_name = (array)$column_name;
                if (!empty($column_name)) {
                    $column = $column_name['column_name'];
                    if (!empty($leadDetail[$column])) {
                        return stripslashes(html_entity_decode($leadDetail[$column]));
                    } else {
                        return null;
                    }
                } else {
                    return null;
                }
            } else {
                return null;
            }
        } else {
            return null;
        }
    }

    public function getCustomApiData($param = array(), $method, $data = array(), $db)
    {
        $addData['phone'] = $param['extension'];
        $addData['phone_number'] = $param['dialed_number'];
        if ($method == 'get') {
            $addData['lead_id'] = $param['leadId'];
        }
        //$addData['leadId'] = $param['leadId'];
        $addData['SQLdate'] = date('Y-m-d H:i:s');
        $addData['campaign'] = 'test';
        $addData['server_ip'] = 'test';
        $addData['vendor_id'] = '';
        $addData['user'] = $param['extension'];
        if ($method == 'post') {
            $addData['sip_extension'] = $param['extension'];
            $addData['leadId'] = $param['leadId'];
        }

        $campaign = DB::connection($db)->selectOne("SELECT title FROM campaign WHERE id = :id", array('id' => $param['campaignId']));
        $campaign = (array)$campaign;
        if (!empty($campaign)) {
            $addData['campaign'] = $campaign['title'];
        }
        if (!empty($param['dispositionId']) && $param['dispositionId'] > 0) {
            $sql = "SELECT id, duration, call_recording FROM cdr WHERE extension = :extension AND lead_id = :lead_id AND campaign_id = :campaign_id AND disposition_id = :disposition order by id desc";
            $res = DB::connection($db)->selectOne($sql, array('extension' => $param['extension'], 'lead_id' => $param['leadId'], 'campaign_id' => $param['campaignId'], 'disposition' => $param['dispositionId']));
            $res = (array)$res;
            if (!empty($res)) {
                $addData['talk_time'] = $res['duration'];
                $addData['recording_filename'] = $res['call_recording'];
                $addData['leadID'] = $param['leadId'];
                $addData['server_ip'] = 'test123';
            }
            if (!empty($param['dispositionId']) && $param['dispositionId'] != 0) {
                $res = DB::connection($db)->selectOne("SELECT title as name FROM disposition WHERE id = :id", array('id' => $param['dispositionId']));
                $res = (array)$res;
                if (empty($res)) {
                    $res = DB::connection('master')->selectOne("SELECT title as name FROM disposition WHERE id = :id", array('id' => $param['dispositionId']));
                    $res = (array)$res;
                }
                if (!empty($res)) {
                    $addData['dispo'] = $res['name'];
                }
            }
        }
        return $addData;
    }

    function callAPI($method, $url, $data = false)
    {
        $curl = curl_init();

        switch ($method) {
            case "POST":
                curl_setopt($curl, CURLOPT_POST, 1);
                if ($data)
                    curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
                break;
            case "PUT":
                curl_setopt($curl, CURLOPT_PUT, 1);
                break;
            default:
                if ($data)
                    $url = sprintf("%s?%s", $url, http_build_query($data));
        }

        // Optional Authentication:
        //curl_setopt($curl, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
        //curl_setopt($curl, CURLOPT_USERPWD, "username:password");
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
        $result = curl_exec($curl);
        curl_close($curl);
        return $result;
    }

    public function logout($request)
    {
        $extension = $request->auth->extension;
        $intWebPhoneSetting = DialerController::getWebPhonestatus($request->auth->id, $request->auth->parent_id);
        if ($intWebPhoneSetting == 1) {
            $extension = $request->auth->alt_extension;
        }

        /* new code implement*/

        $dataUser = User::where('id', $request->auth->id)->get()->first();

        $dialer_mode = $dataUser->dialer_mode;

        if ($dialer_mode == 3) {
            $extension = $dataUser->app_extension;
        } else
            if ($dialer_mode == 2) {
            $extension = $request->auth->alt_extension;
        } else
            if ($dialer_mode == 1) {
            $extension =  $request->auth->extension;
        }

        //echo $extension;die;

        /*close new code implement*/

        $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $extension, $request->auth->parent_id);
        if ($request->logout_all == 1) {
            User::where('id', $request->auth->id)->update(['webphone' => false]);
            Cache::put("user.webphone.{$request->auth->id}.{$request->auth->parent_id}", 0);
        }
        return $asterisk->asteriskLogout($request->auth->parent_id, $extension);
    }

    public function listenCall($request)
    {

        try {
            $extension_auth = $request->auth->extension;
            $extension = $request->extension;

            if ($extension == $extension_auth) {
            } else {
                $intWebPhoneSetting = DialerController::getWebPhonestatus($request->auth->id, $request->auth->parent_id);
                if ($intWebPhoneSetting == 1) {
                    $extension = $request->extension;
                } else {
                    return array(
                        'success' => false,
                        'message' => 'Please enable the webphone first'
                    );
                }
            }

            $lineDetailArray = LineDetail::on('mysql_' . $request->auth->parent_id)->findOrFail($request->listen_id)->toArray();
            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $extension, $request->auth->parent_id);
            $response = $asterisk->listenCall($lineDetailArray, $extension);
            if ($response == true) {
                return array(
                    'success' => true,
                    'message' => 'Listen activity started'
                );
            } else {
                return array(
                    'success' => false,
                    'message' => 'Unable to listen activity'
                );
            }
        } catch (\Throwable $e) {
            Log::error("Dialer.hangUp", [
                "message" => $e->getMessage(),
                "code" => $e->getCode(),
                "file" => $e->getFile(),
                "line" => $e->getLine()
            ]);
            return array(
                'success' => false,
                'message' => 'Unable to hang up the phone. ' . $e->getMessage(),
                'data' => []
            );
        }
    }

    public function bargeCall($request)
    {

        try {
            $extension_auth = $request->auth->extension;
            $extension = $request->extension;

            if ($extension == $extension_auth) {
            } else {
                $intWebPhoneSetting = DialerController::getWebPhonestatus($request->auth->id, $request->auth->parent_id);
                if ($intWebPhoneSetting == 1) {
                    $extension = $request->extension;
                } else {
                    return array(
                        'success' => false,
                        'message' => 'Please enable the webphone first'
                    );
                }
            }

            $lineDetailArray = LineDetail::on('mysql_' . $request->auth->parent_id)->findOrFail($request->listen_id)->toArray();
            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $extension, $request->auth->parent_id);
            $response = $asterisk->bargeCall($lineDetailArray, $extension);
            if ($response == true) {
                return array(
                    'success' => true,
                    'message' => 'Barge Call activity started'
                );
            } else {
                return array(
                    'success' => false,
                    'message' => 'Unable to Barge Call activity'
                );
            }
        } catch (\Throwable $e) {
            Log::error("Dialer.hangUp", [
                "message" => $e->getMessage(),
                "code" => $e->getCode(),
                "file" => $e->getFile(),
                "line" => $e->getLine()
            ]);
            return array(
                'success' => false,
                'message' => 'Unable to bargeCall the phone. ' . $e->getMessage(),
                'data' => []
            );
        }
    }

    public function addNewLeadPd($request)
    {
        try {

            $lineDetailObj              = ListHeader::on('mysql_' . $request->auth->parent_id)->where(['list_id' => $request->list_id], ['is_dialing' => 1])->firstOrFail();
            $lineDetailArray            = $lineDetailObj->toArray();
            $is_dial_column             = $lineDetailArray['column_name'];

            $lineDetailAlterObj         = ListHeader::on('mysql_' . $request->auth->parent_id)->where(['list_id' => $request->list_id], ['alternate_phone' => 1])->firstOrFail();
            $lineDetailAlterArray       = $lineDetailAlterObj->toArray();
            $alternate_phone_column     = $lineDetailAlterArray['column_name'];

            $tasks = ListData::on('mysql_' . $request->auth->parent_id)->find($request->lead_id);
            $newTask = $tasks->replicate();
            $newTask->save();
            $newId = $newTask->id;
            ListData::on('mysql_' . $request->auth->parent_id)->where('id', $newId)->update([$is_dial_column => $request->nxt_call], ['alternate_phone' => 0], [$alternate_phone_column => '']);

            if ($newId) {
                return array(
                    'success' => true,
                    'message' => 'Created new lead'
                );
            } else {
                return array(
                    'success' => false,
                    'message' => 'Unable to create new lead'
                );
            }
        } catch (\Throwable $e) {
            Log::error("Dialer.addNewLeadPd", [
                "message" => $e->getMessage(),
                "code" => $e->getCode(),
                "file" => $e->getFile(),
                "line" => $e->getLine()
            ]);
            return array(
                'success' => false,
                'message' => 'Unable to create new lead. ' . $e->getMessage(),
                'data' => []
            );
        }
    }


    public function getHopperModeInCampaign(int $campaignId, int $parentId)
    {
        $hopperMode = DB::connection('mysql_' . $parentId)->selectOne(
            "SELECT * FROM campaign WHERE id = :id",
            array('id' => $campaignId)
        );
        return $hopperModeType = (array)$hopperMode;
    }

    public function deleteExt($request)
    {
        Log::info('reached', $request->all());
        try {
            $extension = $request->input('sip');
            $dataUser = User::where('extension', $extension)->orWhere('alt_extension', $extension)->get()->first();

            if (!empty($dataUser)) {
                $server = AsteriskServer::find($dataUser->asterisk_server_id);
                $asteriskServerId = $server->id;
                $parentId = $dataUser->parent_id;
                $alt_extension = $dataUser->alt_extension;
            } else {
                throw new RenderableException('Unauthorised Extension Found', [401], 401);
            }

            //  return $alt_extension;

            $asterisk = $this->getAsterisk($asteriskServerId, $extension, $parentId);
            $response = $asterisk->confbridge($alt_extension, $extension);
            if ($response == true) {
                $data['extension'] = $extension;
                $sql = "DELETE FROM extension_live where extension=:extension";
                $record =  DB::connection('mysql_' . $request->auth->parent_id)->select($sql, $data);
                Log::info('reached dlete ext', ['sql' => $sql]);
                $data = (array)$record;
                //return 1;
                if (empty($data)) {
                    return array(
                        'success' => 'true',
                        'message' => 'live extension deleted.',
                        'response' => $response
                    );
                }

                return array(
                    'success' => 'false',
                    'message' => 'live extension not deleted.'
                );
            } else {
                return array(
                    'success' => 'Live Extension Not Found',
                    'data' => $response
                );
            }
        } catch (Exception $e) {
            Log::log($e->getMessage());
        } catch (InvalidArgumentException $e) {
            Log::log($e->getMessage());
        }
    }


    public function directCallTransfer(int $campaignId, int $parentId)
    {
        return array(
            'success' => true,
            'message' => 'Direct Call Transfer run successfully'
        );
    }


    public function warmCallTransferOLD($request, int $parentId)
    {

        $callTransferData = array('lead_id' => $request->lead_id, 'forward_extension' => $request->forward_extension, 'user_extension' => $request->auth->alt_extension, 'number' => $request->customer_phone_number, 'campaign_id' => $request->campaign_id, 'parent_id' => $request->auth->parent_id);



        try {
            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $request->auth->alt_extension, $request->auth->parent_id);

            $response = $asterisk->getWarmCallTransfer($callTransferData);
            // $response = $asterisk->hangUp();
            if ($response == true) {
                return array(
                    'success' => true,
                    'message' => 'Warm Call Transfer on Extension is successful'
                );
            } else {
                return array(
                    'success' => false,
                    'message' => 'Unable to Run Warm Call Transfer'
                );
            }
        } catch (\Throwable $e) {
            Log::error("Dialer.hangUp", [
                "message" => $e->getMessage(),
                "code" => $e->getCode(),
                "file" => $e->getFile(),
                "line" => $e->getLine()
            ]);
            return array(
                'success' => false,
                'message' => 'Unable to Run Warm Call Transfer. ' . $e->getMessage(),
                'data' => []
            );
        }
        /*return array(
                    'success' => true,
                    'message' => 'Wall Call Transfer run successfully'
                );*/
    }

    public function warmCallTransfer($request, int $parentId)
    {
        $dataUser = DB::selectOne("SELECT * FROM users WHERE (extension = :extension OR alt_extension = :alt_extension OR app_extension = :app_extension)", ['extension' => $request->forward_extension, 'alt_extension' => $request->forward_extension, 'app_extension' => $request->forward_extension]);

        $dialer_mode = $dataUser->dialer_mode;

        if ($dialer_mode == 3) {
            $forward_extension = $dataUser->app_extension;
        } else
            if ($dialer_mode == 2) {
            $forward_extension = $dataUser->alt_extension;
        } else
            if ($dialer_mode == 1) {
            $forward_extension =  $dataUser->extension;
        }


        $callTransferData = array('domain' => $request->domain, 'lead_id' => $request->lead_id, 'ring_group' => $request->ring_group, 'forward_extension' => $forward_extension, 'user_extension' => $request->auth->alt_extension, 'number' => $request->customer_phone_number, 'parent_id' => $request->auth->parent_id, $request);

        //echo "
";print_r($callTransferData);die;




        try {
            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $request->auth->alt_extension, $request->auth->parent_id);

            if ($request->warm_call_transfer_type == 'extension') {
                $response = $asterisk->getWarmCallTransfer($callTransferData, $request);
                if ($response == true) {
                    return array(
                        'success' => true,
                        'message' => 'Warm Call Transfer C2C initiating on Extension is successful'
                    );
                } else {
                    return array(
                        'success' => false,
                        'message' => 'Unable to Run Warm Call Transfer C2C'
                    );
                }
            } else
            if ($request->warm_call_transfer_type == 'ring_group') {
                $response = $asterisk->getWarmCallTransferRingGroup($callTransferData, $request);
                if ($response == true) {
                    return array(
                        'success' => true,
                        'message' => 'Warm Call Transfer C2C initiating on Ring group is successful'
                    );
                } else {
                    return array(
                        'success' => false,
                        'message' => 'Unable to Run Warm Call Transfer C2C'
                    );
                }
            } else
            if ($request->warm_call_transfer_type == 'did') {
                $response = $asterisk->warmCallTransferDid($callTransferData, $request);
                if ($response == true) {
                    return array(
                        'success' => true,
                        'message' => 'Warm Call Transfer C2C initiating on Phone number is successful'
                    );
                } else {
                    return array(
                        'success' => false,
                        'message' => 'Unable to Run Warm Call Transfer C2C'
                    );
                }
            }
        } catch (\Throwable $e) {
            Log::error("Dialer.hangUp", [
                "message" => $e->getMessage(),
                "code" => $e->getCode(),
                "file" => $e->getFile(),
                "line" => $e->getLine()
            ]);
            return array(
                'success' => false,
                'message' => 'Unable to Run Warm Call Transfer C2C. ' . $e->getMessage(),
                'data' => []
            );
        }
        /*return array(
                    'success' => true,
                    'message' => 'Wall Call Transfer run successfully'
                );*/
    }


    function channelRedirect($request, $channel, $forward_extension)
    {
        try {
            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $request->auth->alt_extension, $request->auth->parent_id);

            $response = $asterisk->channelRedirectToAgentB($request, $channel, $forward_extension);


            if ($response['status'] == true) {
                return array(
                    'success' => true,
                    'message' => 'Redirect channel of A to Conference of B'
                );
            } else {
                return array(
                    'success' => false,
                    'message' => 'Unable to Redirect channel of A to Conference of B'
                );
            }
        } catch (Exception $ex) {
            throw new RenderableException('Redirect channel of A to Conference of B Failed', [401], 401);
        }
    }



    public function mergeCallWithTransfer($request, $channel)
    {
        try {
            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $request->auth->alt_extension, $request->auth->parent_id);

            $response = $asterisk->channelMergeWithNumber($request, $request->forward_extension, $channel);

            if ($response['status'] == true) {
                return array(
                    'success' => true,
                    'message' => 'Call Merge with Customer Phone Number'
                );
            } else {
                return array(
                    'success' => false,
                    'message' => 'Unable to Call Merge with Customer Phone Number'
                );
            }
        } catch (Exception $ex) {
            throw new RenderableException('Redirect channel of A to Conference of B Failed', [401], 401);
        }
    }



    public function leaveConferenceTransfer($request, $channel)
    {
        try {
            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $request->auth->alt_extension, $request->auth->parent_id);

            $response = $asterisk->leaveConferenceTransfer($request, $request->auth->alt_extension, $channel);

            if ($response['status'] == true) {
                return array(
                    'success' => true,
                    'message' => 'Conference Leave Successfully'
                );
            } else {
                return array(
                    'success' => false,
                    'message' => 'Unable to leave Conference '
                );
            }
        } catch (Exception $ex) {
            throw new RenderableException('Unable to leave Conference', [401], 401);
        }
    }



    //call trnasfer to did

    public function warmCallTransferDid($request, int $parentId)
    {



        $callTransferData = array('domain' => $request->domain, 'lead_id' => $request->lead_id, 'did_number' => $request->did_number, 'user_extension' => $request->auth->alt_extension, 'number' => $request->customer_phone_number, 'parent_id' => $request->auth->parent_id, $request);

        /* return array(
                        'success' => true,
                        'message' => 'Warm Call Transfer C2C initiating on Phone number is successful',
                        'data' => $callTransferData
                    );
*/



        try {
            $asterisk = $this->getAsterisk($request->auth->asterisk_server_id, $request->auth->alt_extension, $request->auth->parent_id);




            if ($request->warm_call_transfer_type == 'did') {
                $response = $asterisk->warmCallTransferDid($callTransferData, $request);
                if ($response == true) {
                    return array(
                        'success' => true,
                        'message' => 'Warm Call Transfer C2C initiating on Phone number is successful'
                    );
                } else {
                    return array(
                        'success' => false,
                        'message' => 'Unable to Run Warm Call Transfer C2C'
                    );
                }
            }
        } catch (\Throwable $e) {
            Log::error("Dialer.hangUp", [
                "message" => $e->getMessage(),
                "code" => $e->getCode(),
                "file" => $e->getFile(),
                "line" => $e->getLine()
            ]);
            return array(
                'success' => false,
                'message' => 'Unable to Run Warm Call Transfer C2C. ' . $e->getMessage(),
                'data' => []
            );
        }
        /*return array(
                    'success' => true,
                    'message' => 'Wall Call Transfer run successfully'
                );*/
    }
}