";print_r($campaign);die;

            //get leads from lead_temp table
            $getLead = $this->getTempLead($campaignId);

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


            //find how many new records need to added to temp table.
            $tempLeadCount = count($getLead);
            //echo "
";print_r($tempLeadCount);die;

            $hopperCount = [
                "valid" => $tempLeadCount,
                "invalid" => 0
            ];

            $minimumLead = $campaign['min_lead_temp'];
            $maximumLead = $campaign['max_lead_temp'];

            #if hopper is not maintaining count
            if ($tempLeadCount < $minimumLead) {
                $addRecord = $maximumLead - $tempLeadCount;
            } else {
                $addRecord = 0;
            }
            
            $startTime = $campaign['call_time_start'];
            $endTime = $campaign['call_time_end'];
            //echo "
";print_r($endTime);die;

            //check campaign time based calling
            if ($campaign['time_based_calling'] == '1' && $addRecord > 0) {
                //validate campaign start time
                if (!empty($startTime) && !empty($endTime) && strtotime($startTime) < strtotime($endTime)) {
                    #Loop through all the existing leads in hopper
                    #Check if they can still be dialed. Remove if cannot be dialed
                    foreach ( $getLead as $key => $value ) {
                        $validateLead = $this->validateLead($value, $startTime, $endTime);
                        //echo "
";print_r($validateLead);die;
                        if (!$validateLead["isValid"]) {
                            //remove lead from temp table if it is not belong to campaign time and reduce the count by 1 of total number of records
                            $removeLead = $this->removeLead($value->lead_id, $campaign['id']);
                            $hopperCount["valid"]--;
                            $hopperCount["invalid"]++;
                            $addRecord++;
                        }
                    }

                    if ($addRecord > 0) {
                    
                        $response = $this->addLeadToTempTimeBasedCalling($campaign['id'], $addRecord, $startTime, $endTime, '');
                        $response["min_lead_temp"] = $minimumLead;
                        $response["max_lead_temp"] = $maximumLead;
                        $hopperCount["valid"] = $hopperCount["valid"] + $response["added"];
                        $response["hopperCount"] = $hopperCount;
                        $this->sendLowLeadEmail("time_based_loading", $id, $campaign['id'], $response);
                        $response["success"] = true;
                        return $response;
                    }
                }
            } elseif ($campaign['time_based_calling'] == '0' && $addRecord > 0) {
                $response = $this->addLeadToTempNonTimeBasedCalling($campaign['id'], $addRecord, '');
                $response["min_lead_temp"] = $minimumLead;
                $response["max_lead_temp"] = $maximumLead;
                $hopperCount["valid"] = $hopperCount["valid"] + $response["added"];
                $response["hopperCount"] = $hopperCount;
                $this->sendLowLeadEmail("normal_loading", $id, $campaign['id'], $response);
                $response["success"] = true;
                return $response;
            }

            return [
                "success" => true,
                "limit" => 0,
                "added" => 0,
                "lists" => []
            ];
        } catch (\Throwable $e) {
            Log::error("Cron.addLeadTemp.error", [
                "message" => $e->getMessage(),
                "line" => $e->getLine(),
                "file" => $e->getFile()
            ]);
            return [
                "success" => false,
                "message" => $e->getMessage(),
                "limit" => null,
                "added" => null,
                "lists" => []
            ];
        }
    }

    public function sendLowLeadEmail(string $source, int $clientId, int $campaignId, array $response)
    {
        $sendEmail = false;
        if ($response["hopperCount"]["valid"] < 5) {
            Log::info("sendLowLeadEmail($clientId, $campaignId)", $response);
            #send email
            $subscription = SystemNotification::on("mysql_$clientId")->findOrFail("campaign_low_lead");
            if (empty($subscription->last_sent)) {
                $sendEmail = true;
            } else {
                $last_sent = new DateTime($subscription->last_sent);
                $diff = $last_sent->diff(new DateTime());
                Log::info("sendLowLeadEmail last sent diff in mins: " . $diff->i);
                if ($diff->i > 15) {
                    $sendEmail = true;
                }
            }
            if ($sendEmail) {
                dispatch(new LowLeadNotificationJob($clientId, $campaignId, $response))->onConnection("database");
            }
        }
        return $sendEmail;
    }

    /*
     * get lead in temp
     */
    public function getTempLead($campaignId)
    {
        $leadTemp = DB::connection($this->database)->select("SELECT campaign_id,list_id,lead_id FROM ringless_lead_temp WHERE campaign_id = :campaign_id", array('campaign_id' => $campaignId));
        $leadTemp = (array)$leadTemp;
        return $leadTemp;
    }

    /*
     * add Lead to lead_temp table for non time based calling campaign
     */
    public function addLeadToTempTimeBasedCalling($campaignId, $limit, $startTime = null, $endTime = null, $hopper_mode= null)
    {
        $response = [
            "limit" => $limit,
            "added" => 0,
            "lists" => []
        ];
        $campaignList = $this->getList($campaignId);
        //echo "
";print_r($campaignList);die;
        //echo "
";print_r($campaignList);die;
        $countCampaignList = count($campaignList);
        //echo "
";print_r($countCampaignList);die;

        //if($hopper_mode == '1' || ($hopper_mode == '2' && $countCampaignList == '1'))
        if(!empty($campaignList))
        {
            foreach ( $campaignList as $key => $list )
            {


                $lead = $this->getLead($list->id, $campaignId, $limit, $startTime, $endTime);
                $record = count($lead);
                $response["lists"][$list->id] = [
                    "records" => $record,
                    "valid" => 0,
                    "duplicates" => 0
                ];

               

                if ($record > 0)
                {
                    $getLead = $this->getTempLead($campaignId);
                    $lead_tempcount = count($getLead);
                    $lead_data =array();
                    foreach ( $lead as $leadKey => $value )
                    {
                        if($lead_tempcount <= 299)
                        {
                            $check_list = DB::connection($this->database)->selectOne("SELECT * FROM ringless_list WHERE campaign_id  = :campaign_id and id=:list_id and status=:status", array('campaign_id' => $campaignId,'list_id'=>$list->id,'status'=>'1'));

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

                            if(!empty($check_list))
                            {
                                $lead_data[$leadKey]['lead_id'] = $value;
                                $lead_data[$leadKey]['list_id'] = $list->id;
                                $lead_data[$leadKey]['campaign_id'] = $campaignId;
                                $response["lists"][$list->id]["valid"]++;
                                $response["added"]++;
                                ++$lead_tempcount ;
                            }
                        }

                    }

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

                    DB::connection($this->database)->table('ringless_lead_temp')->insert($lead_data);
                    $duplicates = $this->removeDuplicateRecord();
                    $response["lists"][$list->id]["duplicates"] = $duplicates;
                    $response["added"] = $response["added"] - $duplicates;
                }
            }
        }

        

        return $response;
    }

    /*
 * Remove lead from temp table
 */
    public function removeLead($leadId, $campaignId)
    {
        DB::connection($this->database)->delete("DELETE FROM ringless_lead_temp WHERE lead_id = :lead_id AND campaign_id = :campaign_id", array('lead_id' => $leadId, 'campaign_id' => $campaignId));
    }

    /*
     * get lead detail
     */
    public function getLeadDetail($id)
    {
        $leadDetail = DB::connection($this->database)->selectOne("SELECT * FROM ringless_list_data WHERE id = :id", array('id' => $id));
        $leadDetail = (array)$leadDetail;
        return $leadDetail;
    }

    /*
     * validate time based calling lead
     */
    public function validateLead($lead, $startTime, $endTime)
    {
        echo "S";die;
        $return = [
            "isValid" => false,
            "isDeleted" => false,
            "hasDialingColumn" => false,
            "leadDialable" => []
        ];
        if (is_array($lead)) {
            $detail = $lead;
        } elseif (is_numeric($lead)) {
            $detail = $this->getLeadDetail($lead);
            echo "
";print_r($detail);die;
        }
        //echo "
";print_r($detail);die;

        if (!empty($detail)) {
            $return["isDeleted"] = true;
            $list = $detail['list_id'];
            $dialingColumn = $this->getDialingColumn($list);
            //echo "
";print_r($dialingColumn);die;
            if (!empty($dialingColumn)) {
                $return["hasDialingColumn"] = true;
                $dialNumber = $detail[$dialingColumn];
                if (!empty($dialNumber)) {
                    $dialable = $this->isLeadDialable($dialNumber, $startTime, $endTime);
                    $return["leadDialable"] = $dialable;
                    $return["isValid"] = $dialable["dialable"];
                }
            }
        }
        return $return;
    }

    /*
     * get dialing column for list
     */
    public function isLeadDialable($number, $startTime, $endTime)
    {
        $return = [
            "dialable" => 0,
            "areacodeTimeZone" => 0,
            "dialingTime" => 0
        ];
        $numberAreacode = substr(trim($number), 0, 3);
        $timeZone = $this->getTimezone($numberAreacode);
        if (empty($timeZone)) {
            $return["dialable"] = 1;
            $return["dialingTime"] = 1;
        } else {
            if (!empty($timeZone['timezone'])) {
                $return["areacodeTimeZone"] = 1;
                $time = new DateTime();
                $time->setTimeZone(new DateTimeZone(timezone_name_from_abbr($timeZone['timezone'])));
                $currentTime = $time->format('H:i:s');
                if (strtotime($startTime) < strtotime($currentTime) && strtotime($endTime) > strtotime($currentTime)) {
                    $return["dialingTime"] = 1;
                    $return["dialable"] = 1;
                }
            }
        }
        return $return;
    }

    /*
     * get timezone from number
     */
    public function getTimezone($numberAreacode)
    {
        $timeZone = DB::connection('master')->selectOne("SELECT timezone FROM timezone WHERE areacode = :areacode", array('areacode' => $numberAreacode));
        $timeZone = (array)$timeZone;
        return $timeZone;
    }

    /*
     * get list associated to campaign
     */
    public function getList($campaignId)
    {
        $campaignList = DB::connection($this->database)->select("SELECT * FROM ringless_list WHERE campaign_id = :campaign_id  ORDER BY id ASC", array('campaign_id' => $campaignId));
        //Log::info('reached list',['campaignList'=>$campaignList]);
        //echo "
";print_r($campaignList);die;

        $campaignList = (array)$campaignList;
        return $campaignList;
    }

    /*
     * Fetch lead from laed data table
     * @return array
     */
    public function getLead($list_id, $campaign_id, $limit = 100, $startTime = null, $endTime = null)
    {
        $response = [];
        $dialingColumn = $this->getDialingColumn($list_id);
        if (!empty($dialingColumn)) {
            $listData = DB::connection($this->database)->select("SELECT id,list_id, option_1, option_2, option_3, option_4, option_5, option_6, option_7, option_8, option_9, option_10, option_11, option_12, option_13, option_14, option_15, option_16, option_17, option_18, option_19, option_20, option_21, option_22, option_23, option_24, option_25, option_26, option_27, option_28, option_29, option_30 FROM ringless_list_data WHERE list_id = :list_id", array('list_id' => $list_id));
            $data = (array)$listData;

            //echo "
";print_r($data);die;  // 41-50  cpu
            
            foreach ( $data as $key => $value ) {
                
                $number = $value->$dialingColumn;
                #do the time check of start and end time passed
                if ($startTime && $endTime && strtotime($startTime) < strtotime($endTime)) {
                    $check = $this->isLeadDialable($number, $startTime, $endTime);

                    #if not in dialing time skip
                    if (!$check["dialable"]) continue;
                }

                #If lead already in hopper skip
                $checkTemp = DB::connection($this->database)->selectOne("SELECT lead_id FROM ringless_lead_temp WHERE list_id = :list_id AND campaign_id = :campaign_id AND lead_id = :lead_id", array('list_id' => $list_id, 'campaign_id' => $campaign_id, 'lead_id' => $value->id));
                $checkTemp = (array)$checkTemp;
                if (!empty($checkTemp)) continue;

                #skip is lead present in lead_report
                $checkRecord = DB::connection($this->database)->selectOne("SELECT lead_id FROM ringless_lead_report WHERE campaign_id = :campaign_id AND lead_id = :lead_id", array('campaign_id' => $campaign_id, 'lead_id' => $value->id));
                $checkRecord = (array)$checkRecord;
                if (!empty($checkRecord)) continue;

                /*#Skip if lead present in DNC
                $checkNumber = DB::connection($this->database)->selectOne("SELECT `number`,`extension`,`comment`,`updated_at` FROM dnc WHERE number = :number", array('number' => $number));
                $checkNumber = (array)$checkNumber;
                if (!empty($checkNumber)) continue;*/

                /*$checkExcludeNumber = DB::connection($this->database)->selectOne("SELECT `number`,`campaign_id`,`first_name`,`last_name`,`company_name`,`updated_at` FROM exclude_number WHERE number = :number AND campaign_id = :campaign_id", array('number' => $number, 'campaign_id' => $campaign_id));
                $checkExcludeNumber = (array)$checkExcludeNumber;
                if (empty($checkExcludeNumber)) {
                    array_push($response, $value->id);
                }*/

                 array_push($response, $value->id);


                #if found required number of leads return back
                if (count($response) >= $limit) return $response;

                
            }
        }
        return $response;
    }


   

    /*
     * get dialing column for list
     */
    public function getDialingColumn($list_id)
    {
        $dialingColumn = DB::connection($this->database)->selectOne("SELECT column_name FROM ringless_list_header WHERE list_id = :list_id AND is_dialling = :is_dialling", array('list_id' => $list_id, 'is_dialling' => '1'));
        $dialingColumn = (array)$dialingColumn;
        return $dialingColumn['column_name'];
    }

    public function removeDuplicateRecord()
    {
        //commented because delete created record
        //$sql = "DELETE t1 FROM lead_temp t1 INNER JOIN lead_temp t2 WHERE t1.lead_id = t2.lead_id";
        //DB::connection($this->database)->delete($sql, array());
        return 0;
    }

    public function addLeadToTempNonTimeBasedCalling($campaignId, $limit, $hopper_mode)
    {
        $response = [
            "limit" => $limit,
            "added" => 0,
            "lists" => []
        ];
        $campaignList = $this->getList($campaignId);
        $countCampaignList = count($campaignList);
        //echo "
";print_r($campaignList);die;

        //if($hopper_mode == '1' || ($hopper_mode == '2' && $countCampaignList == '1'))
        if(!empty($campaignList))
        {
            foreach ( $campaignList as $key => $list )
            {
                $lead = $this->getLead($list->id, $campaignId, $limit);

                //echo "
";print_r($lead);die;
/*
                 $response = [
            "limit" => $limit,
            "campaignId" => $campaignId,
            "lists" => $list->list_id
        ];*/


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

                //echo "
";print_r($lead);die;
                $record = count($lead);
                $response["lists"][$list->id] = [
                    "records" => $record,
                    "valid" => 0,
                    "duplicates" => 0
                ];

                if ($record > 0)
                {
                    $getLead = $this->getTempLead($campaignId);
                    $lead_tempcount = count($getLead);
                    $lead_data =array();
                    foreach ( $lead as $leadKey => $value )
                    {
                        if($lead_tempcount < 300)
                        {
                            $check_list = DB::connection($this->database)->selectOne("SELECT * FROM ringless_list WHERE campaign_id  = :campaign_id and id=:id and status=:status", array('campaign_id' => $campaignId,'id'=>$list->id,'status'=>'1'));

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

                            if(!empty($check_list))
                            {
                                $lead_data[$leadKey]['lead_id'] = $value;
                                $lead_data[$leadKey]['list_id'] = $list->id;
                                $lead_data[$leadKey]['campaign_id'] = $campaignId;
                                $response["lists"][$list->id]["valid"]++;
                                $response["added"]++;
                                ++$lead_tempcount ;
                            }
                        }

                    }
                    DB::connection($this->database)->table('ringless_lead_temp')->insert($lead_data);

                    //echo "
";print_r($lead_data//);die;
                    //$duplicates = $this->removeDuplicateRecord();
                    $duplicates = 0;//

                    $response["lists"][$list->id]["duplicates"] = $duplicates;
                    $response["added"] = $response["added"] - $duplicates;
                }

                
            }
        }
       

        return $response;
    }



}