GIF89;aGIF89;aGIF89;a

Team Anon Force

https://t.me/Professor6T9x

Professor6T9 Web SheLL

Linux host.videowhizz.saglus.com 3.10.0-1160.119.1.el7.x86_64 #1 SMP Tue Jun 4 14:43:51 UTC 2024 x86_64
Apache
67.43.5.91

File Name : Queue.php

<?php
defined('BASEPATH') OR exit('No direct script access allowed');

class Queue extends CI_Controller {

function __construct()
	{ 
	    parent::__construct();
		$this->load->model('Queue_Model');
	}
	public function index()
	{
		$queue_data = $this->Queue_Model->getQueueNewsletter();
		
	  $queue_size = sizeof($queue_data);
	  if($queue_size==0)
	   { return; }
	  $process_value = round(50000/$queue_size);
	  
	  foreach($queue_data as $valQueue)
	   {
			  $message_type = $valQueue->message_type;
			  $schedule_date = date('Y-m-d H:i:s',$valQueue->schedule_timestamp);
			  $message_id = $valQueue->id;
			  $subscriber_ids = $valQueue->subscriber_ids;
			  $last_process_id = $valQueue->last_process_id;
		
			  if($last_process_id)
			  $newarray = explode(','.$last_process_id.',',$subscriber_ids);
			  else 
			  $newarray[1] = $subscriber_ids;
			  
			  $contact_array = array_filter(explode(',',$newarray[1]));
			  $lastkey = end(array_keys($contact_array));
		
			  if($lastkey>$process_value)
			   {
				 $newContactarray = array_chunk($contact_array, $process_value)[0];
				 $newlast_procees_key = end(array_keys($newContactarray));
				 $this->Queue_Model->setlastProcessId($contact_array[$newlast_procees_key],'inprocess',$message_id);
			   } else {
				 $newContactarray = $contact_array;
				 $newlast_procees_key = $lastkey;
				 $this->Queue_Model->setlastProcessId($contact_array[$newlast_procees_key],'complete',$message_id);
			   }
			   
			   $batchinsertdata = '';
			   foreach($newContactarray as $key=>$val_contact)
				{
					 $batchinsertdata[] =  array(
									  'time' => $schedule_date ,
									  'message_id' => $message_id ,
									  'subscriber_id' => $val_contact
								   );
				}
				$this->Queue_Model->addEmailQueueBatch($batchinsertdata);
		}
	}
	public function resetQueue()
	{
	  $this->Queue_Model->resetQueue();
	  $this->Queue_Model->resetFinalQueue();
	}
}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	webgetmaildaddy/webgetmaildaddy	0755	2024-07-09 09:12:33
..	dir	-	webgetmaildaddy/webgetmaildaddy	0755	2024-07-09 09:31:34
Autoresponder.php	text/x-php	19.83 KB	webgetmaildaddy/webgetmaildaddy	0644	2023-02-20 01:25:36
Bounce.php	text/x-php	2.78 KB	webgetmaildaddy/webgetmaildaddy	0644	2024-07-09 09:12:33
Cron.php	text/x-php	1 KB	webgetmaildaddy/webgetmaildaddy	0644	2019-03-27 11:37:20
Final_queue.php	text/x-php	15.35 KB	webgetmaildaddy/webgetmaildaddy	0644	2024-07-09 05:45:33
Mail.php	text/x-php	4.18 KB	webgetmaildaddy/webgetmaildaddy	0644	2018-01-03 08:40:20
My_Thread.php	text/x-php	669 B	webgetmaildaddy/webgetmaildaddy	0644	2024-06-19 11:00:04
Queue.php	text/x-php	1.88 KB	webgetmaildaddy/webgetmaildaddy	0644	2024-06-20 06:38:23
Thread_queue.php	text/x-php	1.25 KB	webgetmaildaddy/webgetmaildaddy	0644	2018-03-13 07:09:44
Trackmail.php	text/x-php	2.28 KB	webgetmaildaddy/webgetmaildaddy	0644	2024-07-09 09:12:22
Welcome.php	text/x-php	1.9 KB	webgetmaildaddy/webgetmaildaddy	0644	2018-02-06 07:59:34

© Professor6T9