";print_r($insertString);die;
                $query = "INSERT INTO " . $this->table . " SET " . $insertString;
                $add = DB::connection('mysql_' . $request->auth->parent_id)->insert($query, $data);
                if ($add == true) {
                    $lastInsertId = DB::connection('mysql_' . $request->auth->parent_id)->selectOne("SELECT * FROM " . $this->table . " ORDER BY id DESC");

                    $campaignId = $lastInsertId->id;
                    if ($request->has('disposition_id') && is_array($request->input('disposition_id'))) {
                        foreach ($request->input('disposition_id') as $value) {
                            $sql = "INSERT INTO campaign_disposition (campaign_id, disposition_id) VALUE (:campaign_id, :disposition_id) ON DUPLICATE KEY UPDATE is_deleted = :is_deleted";
                            DB::connection('mysql_' . $request->auth->parent_id)->insert($sql, array('is_deleted' => 0, 'campaign_id' => $campaignId, 'disposition_id' => $value));
                        }
                    }

                    // add for new api

                    $this->copyApiByNewCampaign($request, $campaignId);

                    return array(
                        'success' => 'true',
                        'message' => 'Campaign added successfully.',
                        'data' => (array) $lastInsertId
                    );
                } else {
                    return array(
                        'success' => 'false',
                        'message' => 'Campaign are not added successfully, Due to some incorrect value.'
                    );
                }
            }

            return array(
                'success' => 'false',
                'message' => 'Campaign are not added successfully. Title is missing'
            );
        } catch (Exception $e) {
            Log::log($e->getMessage());
        } catch (InvalidArgumentException $e) {
            Log::log($e->getMessage());
        }
    }

    /*
     * Validate Campaign
     *
     */

    protected function validateCampaign($request)
    {
        $string = array();
        $data = array();
        if ($request->has('title') && !empty($request->input('title'))) {
            array_push($string, 'title = :title');
            $data['title'] = $request->input('title');
        }
        if ($request->has('description') && !empty($request->input('description'))) {
            array_push($string, 'description = :description');
            $data['description'] = $request->input('description');
        }
        if ($request->has('status') && is_numeric($request->input('status'))) {
            array_push($string, 'status = :status');
            $data['status'] = $request->input('status');
        }
        if ($request->has('caller_id') && !empty($request->input('caller_id')) && ($request->input('caller_id') == 'area_code' || $request->input('caller_id') == 'custom' || $request->input('caller_id') == 'area_code_random' || $request->input('caller_id') == 'area_code_3' || $request->input('caller_id') == 'area_code_4' || $request->input('caller_id') == 'area_code_5')) {
            array_push($string, 'caller_id = :caller_id');
            $data['caller_id'] = $request->input('caller_id');
        }
        if ($request->has('custom_caller_id') && is_numeric($request->input('custom_caller_id'))) {
            array_push($string, 'custom_caller_id = :custom_caller_id');
            $data['custom_caller_id'] = $request->input('custom_caller_id');
        }
        if ($request->has('time_based_calling') && is_numeric($request->input('time_based_calling'))) {
            array_push($string, 'time_based_calling = :time_based_calling');
            $data['time_based_calling'] = $request->input('time_based_calling');
        }
        if ($request->has('call_time_start') && !empty($request->input('call_time_start'))) {
            array_push($string, 'call_time_start = :call_time_start');
            $data['call_time_start'] = $request->input('call_time_start');
        }
        if ($request->has('call_time_end') && !empty($request->input('call_time_end'))) {
            array_push($string, 'call_time_end = :call_time_end');
            $data['call_time_end'] = $request->input('call_time_end');
        }
        if ($request->has('dial_mode') && !empty($request->input('dial_mode')) && ($request->input('dial_mode') == 'preview_and_dial' || $request->input('dial_mode') == 'power_dial' || $request->input('dial_mode') == 'super_power_dial' || $request->input('dial_mode') == 'predictive_dial') || $request->input('dial_mode') == 'outbound_ai') {
            array_push($string, 'dial_mode = :dial_mode');
            $data['dial_mode'] = $request->input('dial_mode');
        }
        if ($request->has('group_id') && is_numeric($request->input('group_id'))) {
            array_push($string, 'group_id = :group_id');
            $data['group_id'] = $request->input('group_id');
        }
        if ($request->has('max_lead_temp') && is_numeric($request->input('max_lead_temp')) && $request->input('max_lead_temp') < 1000) {
            array_push($string, 'max_lead_temp = :max_lead_temp');
            $data['max_lead_temp'] = $request->input('max_lead_temp');
        }
        if ($request->has('min_lead_temp') && !empty($request->input('min_lead_temp')) && $request->input('max_lead_temp') < 500) {
            array_push($string, 'min_lead_temp = :min_lead_temp');
            $data['min_lead_temp'] = $request->input('min_lead_temp');
        }
        // if ($request->has('api') && is_numeric($request->input('api'))) {
        //     array_push($string, 'api = :api');
        //     $data['api'] = $request->input('api');
        // }
        if ($request->has('api') && is_numeric($request->input('api'))) {
            $data['api'] = $request->input('api');
        } else {
            $data['api'] = 1; // Default value if 'api' is not in the request or invalid
        }

        array_push($string, 'api = :api');
        if ($request->has('is_deleted') && is_numeric($request->input('is_deleted'))) {
            array_push($string, 'is_deleted = :is_deleted');
            $data['is_deleted'] = $request->input('is_deleted');
        }
        if ($request->has('send_report') && is_numeric($request->input('send_report'))) {
            array_push($string, 'send_report = :send_report');
            $data['send_report'] = $request->input('send_report');
        }
        if ($request->has('send_crm')) {
            array_push($string, 'send_crm = :send_crm');
            $data['send_crm'] = $request->input('send_crm');
        }
        if ($request->has('email')) {
            array_push($string, 'email = :email');
            $data['email'] = $request->input('email');
        }
        if ($request->has('sms')) {
            array_push($string, 'sms = :sms');
            $data['sms'] = $request->input('sms');
        }

        if ($request->has('hopper_mode')) {
            array_push($string, 'hopper_mode = :hopper_mode');
            $data['hopper_mode'] = $request->input('hopper_mode');
        }

        if ($request->has('call_ratio')) {
            array_push($string, 'call_ratio = :call_ratio');
            $data['call_ratio'] = $request->input('call_ratio');
        }

        if ($request->has('duration')) {
            array_push($string, 'duration = :duration');
            $data['duration'] = $request->input('duration');
        }

        if ($request->has('automated_duration')) {
            array_push($string, 'automated_duration = :automated_duration');
            $data['automated_duration'] = $request->input('automated_duration');
        }

        if ($request->has('amd')) {
            array_push($string, 'amd = :amd');
            $data['amd'] = $request->input('amd');
        }
        if ($request->has('amd_drop_action')) {
            array_push($string, 'amd_drop_action = :amd_drop_action');
            $data['amd_drop_action'] = $request->input('amd_drop_action');
        }
        if ($request->has('voicedrop_option_user_id')) {
            array_push($string, 'voicedrop_option_user_id = :voicedrop_option_user_id');
            $data['voicedrop_option_user_id'] = $request->input('voicedrop_option_user_id');
        }

        if ($request->has('no_agent_available_action')) {
            array_push($string, 'no_agent_available_action = :no_agent_available_action');
            $data['no_agent_available_action'] = $request->input('no_agent_available_action');
        }

        if ($request->has('no_agent_dropdown_action')) {
            array_push($string, 'no_agent_dropdown_action = :no_agent_dropdown_action');
            $data['no_agent_dropdown_action'] = $request->input('no_agent_dropdown_action');
        }

        if ($request->has('redirect_to')) {
            array_push($string, 'redirect_to = :redirect_to');
            $data['redirect_to'] = $request->input('redirect_to');
        }

        if ($request->has('redirect_to_dropdown')) {
            array_push($string, 'redirect_to_dropdown = :redirect_to_dropdown');
            $data['redirect_to_dropdown'] = $request->input('redirect_to_dropdown');
        }

        if ($request->has('country_code')) {
            array_push($string, 'country_code = :country_code');
            $data['country_code'] = $request->input('country_code');
        }

        if ($request->has('voip_configuration_id')) {
            array_push($string, 'voip_configuration_id = :voip_configuration_id');
            $data['voip_configuration_id'] = $request->input('voip_configuration_id');
        }

        if ($request->has('call_transfer')) {
            array_push($string, 'call_transfer = :call_transfer');
            $data['call_transfer'] = $request->input('call_transfer');
        }
        if ($request->has('call_metric')) {
            array_push($string, 'call_metric = :call_metric');
            $data['call_metric'] = $request->input('call_metric');
        }
        return array('string' => $string, 'data' => $data);
    }

    /*
     * Fetch campaign for agent
     * @param object $request
     * @return array
     */

    public function getAgentCampaign($request)
    {
        try {
            if (!empty($request->input('id')) && $request->auth->role == '2') {
                $db = $request->auth->parent_id;
                $extension = $request->auth->extension;
                $extensionGroup = DB::connection('mysql_' . $db)->select(
                    "SELECT * FROM extension_group_map WHERE extension = :extension AND is_deleted = :is_deleted",
                    array('extension' => $extension, 'is_deleted' => 0)
                );
                if (!empty($extensionGroup)) {
                    $inStr = array();
                    $data['is_deleted'] = 0;
                    $count = 1;
                    foreach ($extensionGroup as $item => $value) {
                        array_push($inStr, ":group_" . $count);
                        $data["group_" . $count] = $value->group_id;
                        $count++;
                    }
                    $campaign = DB::connection('mysql_' . $db)->select(
                        "SELECT * FROM campaign WHERE group_id in (" . implode(' , ', $inStr) . ") AND is_deleted = :is_deleted",
                        $data
                    );
                    if (!empty($campaign)) {
                        return array(
                            'success' => 'true',
                            'message' => 'List of campaign for extension.',
                            'data' => $campaign
                        );
                    } else {
                        return array(
                            'success' => 'true',
                            'message' => 'Extension is not belong to any campaign.',
                            'data' => array()
                        );
                    }
                } else {
                    return array(
                        'success' => 'false',
                        'message' => 'Extension not belong to any group'
                    );
                }
            } else {
                return array(
                    'success' => 'false',
                    'message' => 'User does not have agent permission'
                );
            }
        } catch (Exception $e) {
            echo $e->getMessage();
        } catch (InvalidArgumentException $e) {
            echo $e->getMessage();
        }
    }

    function getCampaignCount($request)
    {
        try {
            $data['is_deleted'] = 0;
            $sql = "SELECT count(1) as rowCount FROM " . $this->table . " WHERE is_deleted = :is_deleted ";
            $record = DB::connection('mysql_' . $request->auth->parent_id)->selectOne($sql, $data);
            $data = (array) $record;
            return array(
                'success' => 'true',
                'message' => 'Extension is not belong to any campaign.',
                'data' => $data['rowCount']
            );
        } catch (Exception $e) {
            echo $e->getMessage();
        } catch (InvalidArgumentException $e) {
            echo $e->getMessage();
        }
    }

    function getCampaignAndList($request)
    {

        try {
            $data = array();
            $searchStr = array();
            if ($request->has('campaign_id') && is_numeric($request->input('campaign_id'))) {
                $data['campaign_id'] = $request->input('campaign_id');
                $data['is_deleted'] = $request->input('is_deleted');
            }

            $sql = "SELECT campaign_list.campaign_id,campaign_list.status,campaign_list.list_id,campaign_list.is_deleted,list.title as l_title,list.id,campaign.title,campaign.crm_title_url FROM campaign_list inner join list on campaign_list.list_id = list.id inner join campaign on campaign_list.campaign_id = campaign.id WHERE campaign_list.campaign_id = '" . $request->input('campaign_id') . "' and campaign_list.is_deleted ='" . $request->input('is_deleted') . "'";

            $record = DB::connection('mysql_' . $request->auth->parent_id)->select($sql);
            $data = (array) $record;

            foreach ($data as $key => $id) {

                $data1['campaign_id'] = $id->campaign_id;
                $data1['list_id'] = $id->list_id;

                $sql_count_lead_report = "SELECT count(1) as rowCountLearReport FROM lead_report WHERE campaign_id = :campaign_id  and list_id = :list_id";
                $record_count_lead = DB::connection('mysql_' . $request->auth->parent_id)->selectOne($sql_count_lead_report, $data1);
                $id->rowLeadReport = $record_count_lead->rowCountLearReport;

                $list_data['list_id'] = $id->list_id;


                $sql_count_list = "SELECT count(1) as rowCountList FROM list_data WHERE list_id=:list_id ";
                $record_count_list = DB::connection('mysql_' . $request->auth->parent_id)->select($sql_count_list, $list_data);

                //return $data = (array)$record_count_list;
                //$id->rowList = $count;
                $id->rowListData = $record_count_list[0]->rowCountList;
            }

            //return $data;
            if (!empty($data)) {
                return array(
                    'success' => 'true',
                    'message' => 'Campaign List detail.',
                    'data' => $data
                );
            }
            return array(
                'success' => 'false',
                'message' => 'Campaign List Found.',
                'data' => array()
            );
        } catch (Exception $e) {
            echo $e->getMessage();
        } catch (InvalidArgumentException $e) {
            echo $e->getMessage();
        }
    }

    function getDispositionAndList($request)
    {



        try {
            $data = array();
            $searchStr = array();
            if ($request->has('list_id') && is_numeric($request->input('list_id'))) {
                $data['list_id'] = $request->input('list_id');
            }

            $sql = "SELECT l.disposition_id as id, IF(l.disposition_id = 0 , 'Not Dialed', d.title) as name, COUNT(l.list_id) as record_count FROM lead_report as l
                LEFT JOIN disposition as d ON l.disposition_id = d.id WHERE l.list_id = :list_id group by l.disposition_id";
            $record = DB::connection('mysql_' . $request->auth->parent_id)->select($sql, $data);
            $data = (array) $record;







            //return $data;
            if (!empty($data)) {
                return array(
                    'success' => 'true',
                    'message' => 'Disposition List detail.',
                    'data' => $data
                );
            }
            return array(
                'success' => 'false',
                'message' => 'Disposition List Not Found.',
                'data' => array()
            );
        } catch (Exception $e) {
            echo $e->getMessage();
        } catch (InvalidArgumentException $e) {
            echo $e->getMessage();
        }
    }

    function deleteDispositionAndList($request)
    {



        try {
            $data = array();
            $searchStr = array();
            if ($request->has('list_id') && is_numeric($request->input('list_id'))) {
                $data['list_id'] = $request->input('list_id');
            }

            if ($request->has('campaign_id') && is_numeric($request->input('campaign_id'))) {
                $data['campaign_id'] = $request->input('campaign_id');
            }

            $disposition = $request->input('disposition');
            $select_id = $request->input('select_id');

            $count_deletedLeads = 0;
            foreach ($disposition as $dis => $dispositionId) {
                $userCount = $select_id[$dis];
                $data['disposition_id'] = $dispositionId;
                $sql = "SELECT lr.list_id, lr.lead_id, if(p.total is null, '0', p.total) as total
                    FROM lead_report as lr
                    LEFT JOIN (
                    SELECT lead_id, count(id) as total, campaign_id FROM cdr WHERE campaign_id = " . $request->input('campaign_id') . " group by lead_id
                    UNION
                    SELECT lead_id, count(id) as total, campaign_id FROM cdr WHERE campaign_id = " . $request->input('campaign_id') . " group by lead_id
                    ) as p
                    ON p.lead_id = lr.lead_id AND lr.campaign_id = p.campaign_id
                    WHERE lr.campaign_id = " . $request->input('campaign_id') . " AND lr.list_id = " . $request->input('list_id') . " AND lr.disposition_id = " . $dispositionId . "";

                $record = DB::connection('mysql_' . $request->auth->parent_id)->select($sql);
                //return $data = (array)$record;

                $deleteId = array();
                foreach ($record as $key => $value) {
                    if ($value->total <= $userCount) {
                        array_push($deleteId, $value->lead_id);
                    }
                }

                //return $deleteId;

                if (!empty($deleteId)) {
                    $deleteSql = "DELETE FROM lead_report WHERE lead_id in (" . implode(",", $deleteId) . ")";
                    DB::connection('mysql_' . $request->auth->parent_id)->update($deleteSql);
                }

                $count[$dispositionId] = count($deleteId);
                $count_deletedLeads = $count_deletedLeads + $count[$dispositionId];
                //Send Email
            }

            $recycle_data = [
                "action" => "Recycle Data",
                "listId" => $request->input('list_id'),
                "records" => $count_deletedLeads,
                //"deletedId" => $deleteId,
                "disposition_count" => $count,
                "disposition" => $disposition,
                "campaignId" => $request->input('campaign_id')
            ];
            // return $recycle_data;



            $campaignId = $request->input('campaign_id');
            dispatch(new RecycleDeletedNotificationJob($request->auth->parent_id, $campaignId, $recycle_data))->onConnection("database");
            //return $data;
            if (!empty($data)) {
                return array(
                    'success' => 'true',
                    'message' => 'Disposition List deleted successfully.',
                    'data' => $data
                );
            }
            return array(
                'success' => 'false',
                'message' => 'Disposition List Not Deleted Successfully.',
                'data' => array()
            );
        } catch (Exception $e) {
            echo $e->getMessage();
        } catch (InvalidArgumentException $e) {
            echo $e->getMessage();
        }
    }

    public function copyCampaign($request)
    {
        $campignStatus = '';
        $campaignId = $request->input('c_id');
        $userArray = Campaign::on('mysql_' . $request->auth->parent_id)->where('id', $campaignId)->first();
        if ($userArray['id']) {
            $id = Campaign::on('mysql_' . $request->auth->parent_id)->insertGetId(
                [
                    'title' => 'Copy ' . $userArray['title'],
                    'description' => $userArray['description'],
                    'status' => $userArray['status'],
                    'is_deleted' => $userArray['is_deleted'],
                    'caller_id' => $userArray['caller_id'],
                    'custom_caller_id' => $userArray['custom_caller_id'],
                    'time_based_calling' => $userArray['time_based_calling'],
                    'call_time_start' => $userArray['call_time_start'],
                    'call_time_end' => $userArray['call_time_end'],
                    'dial_mode' => $userArray['dial_mode'],
                    'group_id' => $userArray['group_id'],
                    'max_lead_temp' => $userArray['max_lead_temp'],
                    'min_lead_temp' => $userArray['min_lead_temp'],
                    'api' => $userArray['api'],
                    'send_report' => $userArray['send_report'],
                    'campaign' => $userArray['campaign'],
                    'send_crm' => $userArray['send_crm'],
                    'email' => $userArray['email'],
                    'sms' => $userArray['sms'],
                ]
            );

            //copy for API

            $sql = "SELECT * FROM api  WHERE is_default = :is_default";
            $record =  DB::connection('mysql_' . $request->auth->parent_id)->selectOne($sql, array('is_default' => '1'));
            $data = (array)$record;
            $request['api_id'] = $data['id'];

            $campaignId_new = $id;

            $this->copyApiByNewCampaign($request, $campaignId_new);

            //end API


            $now = date('Y-m-d h:i:s');
            $campaignDispositionArray = CampaignDisposition::on('mysql_' . $request->auth->parent_id)->where('campaign_id', $campaignId)->get();
            foreach ($campaignDispositionArray as $key => $val) {
                $user_Record[] = array('disposition_id' => $val->disposition_id, 'campaign_id' => $id, 'is_deleted' => 0, 'updated_at' => $now);
            }
            if (!empty($user_Record)) {
                $campignStatus = CampaignDisposition::on('mysql_' . $request->auth->parent_id)->insert($user_Record);
            }

            if ($campignStatus) {
                return array(
                    'success' => 'true',
                    'message' => 'Copy campaign successfully.',
                    'data' => $id
                );
            } else {
                return array(
                    'success' => 'false',
                    'message' => 'Copy campaign failed.',
                    'data' => array()
                );
            }
        }
    }

    function campaignById($request)
    {
        $userArray = Campaign::on('mysql_' . $request->auth->parent_id)->where('id', $request->campaign_id)->get();
        return $userArray;
    }


    //hubspot

    function getCampaignAndListHubspot($request)
    {

        try {
            $data = array();
            $searchStr = array();
            if ($request->has('campaign_id') && is_numeric($request->input('campaign_id'))) {
                $data['campaign_id'] = $request->input('campaign_id');
                $data['is_deleted'] = $request->input('is_deleted');
            }

            $sql = "SELECT campaign_list.campaign_id,campaign_list.status,campaign_list.list_id,campaign_list.is_deleted,list.title as l_title,list.id,campaign.title,campaign.crm_title_url,list.size as rowListData FROM hubspot_campaign_list as campaign_list inner join hubspot_lists as list on campaign_list.list_id = list.id inner join campaign on campaign_list.campaign_id = campaign.id WHERE campaign_list.campaign_id = '" . $request->input('campaign_id') . "' and campaign_list.is_deleted ='" . $request->input('is_deleted') . "'";

            $record = DB::connection('mysql_' . $request->auth->parent_id)->select($sql, $data);
            $data = (array) $record;

            foreach ($data as $key => $id) {

                $data1['campaign_id'] = $id->campaign_id;
                $data1['list_id'] = $id->list_id;

                $sql_count_lead_report = "SELECT count(1) as rowCountLearReport FROM lead_report WHERE campaign_id = :campaign_id  and list_id = :list_id";
                $record_count_lead = DB::connection('mysql_' . $request->auth->parent_id)->selectOne($sql_count_lead_report, $data1);
                $id->rowLeadReport = $record_count_lead->rowCountLearReport;

                $list_data['list_id'] = $id->list_id;


                /*$sql_count_list = "SELECT count(1) as rowCountList FROM list_data WHERE list_id=:list_id ";
                $record_count_list = DB::connection('mysql_' . $request->auth->parent_id)->select($sql_count_list, $list_data);

                //return $data = (array)$record_count_list;
                //$id->rowList = $count;
                $id->rowListData = $record_count_list[0]->rowCountList;*/
            }

            //return $data;
            if (!empty($data)) {
                return array(
                    'success' => 'true',
                    'message' => 'Campaign List detail.',
                    'data' => $data
                );
            }
            return array(
                'success' => 'false',
                'message' => 'Campaign List Found.',
                'data' => array()
            );
        } catch (Exception $e) {
            echo $e->getMessage();
        } catch (InvalidArgumentException $e) {
            echo $e->getMessage();
        }
    }

    //close hubspot
    function updateCampaignStatus($request)
    {
        $listId = $request->input('listId');
        $status = $request->input('status');

        // Clear pause_reason on any manual status change — this is a user-initiated action
        $saveRecord = Campaign::on('mysql_' . $request->auth->parent_id)
            ->where('id', $listId)
            ->update(['status' => $status, 'pause_reason' => null]);
        // Log::debug('Update SQL query: ', ['sql' => Campaign::on('mysql_' . $request->auth->parent_id)
        // ->where('id', $listId)
        // ->toSql()]);
        $saveRecordCampaignList = CampaignList::on('mysql_' . $request->auth->parent_id)
            ->where('campaign_id', $listId)
            ->update(array('status' => $status));

        // Log::debug('Received listId: ', ['listId' => $listId]);
        // Log::debug('Received status: ', ['status' => $status]);
        // Log::debug('Number of updated rows: ', ['saveRecord' => $saveRecord]);
        if ($saveRecord >= 0 && $saveRecordCampaignList >= 0) {
            return response()->json([
                'success' => 'true',
                'status' => 'true',
                'message' => 'Campaign status updated successfully'
            ]);
        } else {
            return response()->json([
                'success' => 'false',
                'status' => 'false',
                'message' => 'Campaign update failed'
            ]);
        }
    }
    function updateCampaignHopper($request)
    {
        $listId = $request->input('listId');
        $hopper_mode = $request->input('status');

        $saveRecord = Campaign::on('mysql_' . $request->auth->parent_id)
            ->where('id', $listId) // Use the actual listId received from the request
            ->update(array('hopper_mode' => $hopper_mode));
        Log::debug('Update SQL query: ', ['sql' => Campaign::on('mysql_' . $request->auth->parent_id)
            ->where('id', $listId)
            ->toSql()]);

        // Log::debug('Received listId: ', ['listId' => $listId]);
        // Log::debug('Received status: ', ['status' => $hopper_mode]);
        // Log::debug('Number of updated rows: ', ['saveRecord' => $saveRecord]);
        if ($saveRecord > 0) {
            return response()->json([
                'success' => 'true',
                'status' => 'true',
                'message' => 'Hopper mode  updated successfully'
            ]);
        } else {
            return response()->json([
                'success' => 'false',
                'status' => 'false',
                'message' => 'Hopper mode  failed'
            ]);
        }
    }
}