JezK

Edit File: campaignsProcessor.php

<?php
/**
 * Class: Campaign Processor process single or all campaigns. to be called by the cron.php file
 * @author sweetheatmn
 *
 */

if (   time() > 1596240000){
	$wp_automatic_lcs = get_option('wp_automatic_license_active','');
	$wp_automatic_lcsc = get_option('wp_automatic_license','');
	
	if( wp_automatic_trim($wp_automatic_lcs) != 'active'  || ! stristr($wp_automatic_lcsc, '-') ){
		
		
	}
}

class CampaignProcessor{
	
	// Public vars
	public $db;
	public $prefix;
	public $wp_prefix;
	public $camp_general;
	 
	
	function __construct(){
		
		// Database initialization
		global $wpdb;
		$this->db = $wpdb;
		$this->prefix = $this->wp_prefix = $wpdb->prefix;
		
		echo 'Plugin started performance report before running the script: '. number_format(memory_get_peak_usage()/(1024*1024),2) .'MB of ram and DB queries count:'.get_num_queries() .' ';
		
		
	}
	
	/**
	 * Process all campaigns or single campaign
	 * @param string $cid specific campaign id
	 */
	function process_campaigns($cid = false) {
		
		 
		// DB prefix
		$prefix = $this->db->prefix;
		
	
		// Single or all check
		if (wp_automatic_trim( $cid ) == '') {
				
			// All campaings
			$last = get_option ( 'gm_last_processed', 0 );
		 		
			// get all the campaigns from the db lower than the last processed
			$query = "SELECT camp_id FROM {$this->wp_prefix}automatic_camps where camp_id < $last ORDER BY camp_id DESC";
			
 			
			$camps = $this->db->get_results ( $query );
 	
			// check if results returned with id less than the last processed or not if not using regular method
			$query = "SELECT camp_id FROM {$this->wp_prefix}automatic_camps WHERE camp_id >= $last ORDER BY camp_id DESC";
			$camps2 = $this->db->get_results ( $query );
				
			// merging 2 arrays
			$camps = array_merge ( $camps, $camps2 );
			
		} else {
		 	 
			// Single campaign process
			$query = "SELECT * FROM {$this->wp_prefix}automatic_camps where camp_id = $cid ORDER BY camp_id DESC";
			$camps = $this->db->get_results ( $query );
		 	
		}

// check if need to process camaigns or skip
		if (count ( $camps ) == 0) {
			
			 echo ' No valid campaigns were found to process ';
			return;
			
		}else{
			
			if(wp_automatic_trim($cid) == '') echo ' DB contains ('.count($camps).') campaigns ';
				
		}
	
		// now processing each fetched campaign
		$i = 0;
		$processed_campaigns_count = 0; // count the number of campaigns processed
		$wp_automatic_cron_campaigns_to_process = wp_automatic_trim( get_option('wp_automatic_cron_campaigns_to_process',1)); // get the number of campaigns to process before exiting the script

//if not is numeric or not > 1 set it to 1
		if(! is_numeric($wp_automatic_cron_campaigns_to_process) || $wp_automatic_cron_campaigns_to_process < 1 ) $wp_automatic_cron_campaigns_to_process = 1;

foreach ( $camps as $campaign ) {
			
			// reading post status
			$status = get_post_status ( $campaign->camp_id );
			$camp_post_type = get_post_type($campaign->camp_id);
			 
			//if not set $campaign->camp_options grab the whole record
			if(! isset($campaign->camp_options)){
				
				$query = "SELECT * FROM {$this->wp_prefix}automatic_camps  where camp_id = $campaign->camp_id";
				
				$campaign = $this->db->get_row ( $query );
				
			}
			
			
			// if published process and if is a campaign really
			if ($status == 'publish'  && $camp_post_type == 'wp_automatic') {

$camp_opt = unserialize ( $campaign->camp_options );
				
				if ($i != 0) echo ' ';
				
				// report campaign number
				 echo "Processing Campaign $campaign->camp_name { $campaign->camp_id }";
					
				// updating the last id processed
				update_option ( 'gm_last_processed', $campaign->camp_id );
				
				//check if deserve processing now or not
				if(wp_automatic_trim($cid) == false){
					 
					//read post every x minutes
					if( stristr($campaign->camp_general, 'a:') ) $campaign->camp_general=base64_encode($campaign->camp_general);
					$camp_general = unserialize (base64_decode( $campaign->camp_general) );
					@$camp_general=array_map('wp_automatic_stripslashes', $camp_general);
						
					if(! is_array($camp_general) || ! isset($camp_general['cg_update_every']) ){
						$camp_general = array('cg_update_every'=>60 ,'cg_update_unit'=> 1);
					}
					
					$this->camp_general = $camp_general;
 
					$post_every = $camp_general['cg_update_every'] * $camp_general['cg_update_unit'];
	
					 echo ' Campaign scheduled to process every '.$post_every . ' minutes ';
						
					//get last check time
					$last_update=get_post_meta($campaign->camp_id,'last_update',1);
					if(wp_automatic_trim($last_update) == '') $last_update =1388692276 ;
					// echo ' Last updated stamp '.$last_update;
						
					$difference = $this->get_time_difference($last_update, time());
						
					 echo ' & last processing was '.$difference. ' minutes ago ';
						
					if($difference > $post_every ){
						
						echo '<-- Campaign passed the update interval and is eligible to be processed, let\'s process it...';
						
	
						//process
						$eligible_for_posting = true ;
						if( in_array( 'OPT_CUSTOM_INTERVAL' , $camp_opt )){
							
							$eligible_for_posting = false ;
							
							$current = current_time('timestamp');
							echo ' Current time: ' . date("H:i", $current ) . " ($current)";

$t = sprintf("%02d", $camp_general['cg_custom_start']) . ":" . sprintf("%02d", $camp_general['cg_custom_start_minutes'] ) . ' ' . $camp_general['cg_custom_start_am_pm'] ;
						 
							$strtotime1 = strtotime($t);
							echo ' Start time: ' . date("H:i", $strtotime1 ) . " ($strtotime1)";
							 
							
							$t = sprintf("%02d", $camp_general['cg_custom_end']) . ":" . sprintf("%02d",$camp_general['cg_custom_end_minutes']) . ' ' . $camp_general['cg_custom_end_am_pm'];
							$strtotime = strtotime($t);
							echo ' End time: ' . date("H:i", $strtotime ). " ($strtotime)";
							
							if( $strtotime1 > $strtotime){
								
								echo ' Start > end';
								$threthod_1 = strtotime('11:59 pm');
								$threthod_2 = strtotime('12:00 am');
								
								echo ' TH1:' .$threthod_1;
								echo ' TH2:' . $threthod_2;
								
								if( ($current > $strtotime1 && $current < $threthod_1) || ($current > $threthod_2 && $current < $strtotime) ){
									echo ' > Valid time';
									$eligible_for_posting = true ;
								}
								
							}else{
								echo ' End > Start';
								
								if($current > $strtotime1 && $current < $strtotime ){ 
									echo ' > Valid time';
									$eligible_for_posting = true ;
								}else{
									
									echo ' > Not valid time';
									
								}
							}
							
							if($eligible_for_posting){
								update_post_meta($campaign->camp_id,'last_update',time());
								$this->processCampaign( $campaign ,'Cron' );

//increment processed campaigns count
								$processed_campaigns_count++;

//if processed campaigns count is equal to max campaigns per cron then exit cron
								if($processed_campaigns_count >= $wp_automatic_cron_campaigns_to_process){
									
									//report that processed campaigns reached max campaigns per cron and exit cron
									echo ' Processed '.$processed_campaigns_count.' campaigns and reached max campaigns per cron. Exit cron now and complete next cron.';

exit;
								}
								 
							}
						 
							
						}else{
							update_post_meta($campaign->camp_id,'last_update',time());
							$this->processCampaign( $campaign ,'Cron' );
							
							//increment processed campaigns count
							$processed_campaigns_count++;

//if processed campaigns count is equal to max campaigns per cron then exit cron
							if($processed_campaigns_count >= $wp_automatic_cron_campaigns_to_process){
								
								//report that processed campaigns reached max campaigns per cron and exit cron
								echo ' Processed '.$processed_campaigns_count.' campaigns and reached max campaigns per cron. Exit cron now and complete next cron.';

exit;
							}
							 
							 
						}
						
					}else{
						 echo '<-- Campaign still not passed '.$post_every . ' minutes';
					}
						
						
				}else{
					
					// No cron just single campaign process
					$this->processCampaign($campaign);
						
				}
				$i ++;
				
			} elseif (! $status) {
				
				/* commented starting from 3.51.2
				// deleting Camp record
				$query = "delete from {$this->wp_prefix}automatic_camps where camp_id= '$campaign->camp_id'";
				$this->db->query ( $query );
				// deleting matching records for keywords
				$query = "delete from {$this->wp_prefix}automatic_keywords where keyword_camp ='$campaign->camp_id'";
				$this->db->query ( $query );
				*/
				
			}else{
				 echo " Campaign #{$campaign->camp_id} is not published skipping... ";
				 
				 if(isset($_GET['id'])){
				 	
				 	echo ' Please Click on the publish botton on the right for the campaign to process normally. only published campaigns get processed. If you want to change the imported posts status, check the post status option below!<img src="https://deandev.com/files/publish_campaign.png"/>';
				 	
				 }
				 
			}
		}
		
		//cron job no campaigns processed log
		// log external cron
		if($cid == false){
			
			$now = date ( 'Y-m-d H:i:s' );
			$data = @addslashes ( $data );
			$type= 'No Campaigns processed';
			$data= 'Cron checked(' .$i . ') campaigns and did not find any eligible campaigns to process... will try next run ';
			
			$query = "INSERT INTO {$this->wp_prefix}automatic_log (action,date,data) values('$type','$now','$data')";
			
			// echome$query;
			$this->db->query ( $query );
			
		}
		
	}
	
	/**
	 * Function processCampaign: process a single campaign
	 * @param database record $camp
	 */
	function processCampaign($campaign,$userOrCron = 'User'){
		
		//camp general
		if( stristr($campaign->camp_general, 'a:') ) $campaign->camp_general=base64_encode($campaign->camp_general);
		$camp_general = unserialize (base64_decode( $campaign->camp_general) );
		@$camp_general=array_map('wp_automatic_stripslashes', $camp_general);
		$camp_opt = unserialize ( $campaign->camp_options );
		
		// Update last run
		update_post_meta($campaign->camp_id,'last_update',time());
		
	 
		// Campaign type check
		$camp_type = $campaign->camp_type;

if($camp_type == 'Feeds'){
			
			require_once 'core.feeds.php';
			$WpAutomatic = new WpAutomaticFeeds();
			
			
		}elseif($camp_type == 'Amazon'){
			
			$wp_automatic_options = get_option('wp_automatic_options',array());
			$wp_amazonpin_abk = get_option('wp_amazonpin_abk','');
			
			if(  in_array( 'OPT_AMAZON_NOAPI', $wp_automatic_options) || wp_automatic_trim($wp_amazonpin_abk) == '' ){
				require_once 'core.amazon.less.php';
			}else{
				require_once 'core.amazon.php';
			}
			$WpAutomatic = new WpAutomaticAmazon();
			
			//amazon location option
			if(  (in_array( 'OPT_AMAZON_NOAPI', $wp_automatic_options) || wp_automatic_trim($wp_amazonpin_abk) == '' )  && ! in_array( 'OPT_AMAZON_LOC', $wp_automatic_options) ){
				$WpAutomatic->isAmazonLocationSimulated = true;
			}
			
		}elseif($camp_type == 'Clickbank'){
			
			require_once 'core.clickbank.php';
			$WpAutomatic = new WpAutomaticClickbank();
		}elseif($camp_type == 'Facebook'){
			
			require_once 'core.facebook.php';
			$WpAutomatic = new WpAutomaticFacebook();
		}elseif($camp_type == 'Youtube'){
			
			require_once 'core.youtube.php';
			$WpAutomatic = new WpAutomaticYoutube();
		}elseif($camp_type == 'SoundCloud'){
			
			require_once 'core.soundcloud.php';
			$WpAutomatic = new WpAutomaticSoundCloud();
		}elseif($camp_type == 'Pinterest'){
			
			require_once 'core.pinterest.php';
			$WpAutomatic = new WpAutomaticPinterest();
		
		}elseif($camp_type == 'Vimeo'){
			
			require_once 'core.vimeo.php';
			$WpAutomatic = new WpAutomaticVimeo();
		
		}elseif($camp_type == 'Twitter'){
			
			require_once 'core.twitter.php';
			$WpAutomatic = new WpAutomaticTwitter();
		
		}elseif($camp_type == 'Instagram'){
			
			require_once 'core.instagram.php';
			$WpAutomatic = new WpAutomaticInstagram();
		
		}elseif($camp_type == 'TikTok'){
			
			require_once 'core.tiktok.php';
			$WpAutomatic = new WpAutomatictiktok();
			
		}elseif($camp_type == 'eBay'){
			
			require_once 'core.ebay.php';
			$WpAutomatic = new WpAutomaticeBay();
			
		}elseif($camp_type == 'Flicker'){
			
			require_once 'core.flicker.php';
			$WpAutomatic = new WpAutomaticFlicker(); 
			
		}elseif($camp_type == 'Craigslist'){
				
			require_once 'core.craigslist.php';
			$WpAutomatic = new WpAutomaticCraigslist();
			
		}elseif($camp_type == 'Itunes'){
		
			require_once 'core.itunes.php';
			$WpAutomatic = new WpAutomaticItunes();
		
		}elseif($camp_type == 'Envato'){
		
			require_once 'core.envato.php';
			$WpAutomatic = new WpAutomaticEnvato();
			
		}elseif($camp_type == 'DailyMotion'){
		
			require_once 'core.dailymotion.php';
			$WpAutomatic = new WpAutomaticDailyMotion();
			
		}elseif($camp_type == 'Reddit'){
		
			require_once 'core.reddit.php';
			$WpAutomatic = new WpAutomaticReddit();

}elseif($camp_type == 'telegram'){
		
			require_once 'core.telegram.php';
			$WpAutomatic = new WpAutomaticTelegram();	
			
		}elseif($camp_type == 'Walmart'){
		
			require_once 'core.walmart.php';
			$WpAutomatic = new WpAutomaticWalmart();
		
		}elseif($camp_type == 'Single'){
				
				require_once 'core.single.php';
				$WpAutomatic = new WpAutomaticSingle();
				
		}elseif($camp_type == 'Careerjet'){
			
			require_once 'core.careerjet.php';
			$WpAutomatic = new WpAutomaticCareerjet();
			
		}elseif($camp_type == 'Aliexpress'){
			
			require_once 'core.aliexpress.php';
			$WpAutomatic = new WpAutomaticaliexpress();

}elseif($camp_type == 'gpt3'){
			
			require_once 'core.gpt3.php';
			$WpAutomatic = new WpAutomaticgpt3();	
			
		}elseif( $camp_type == 'Multi' ){
			
			require 'core.multi.php';
			
			if(! class_exists('WpAutomaticFeeds')) return false;
			
			$WpAutomatic = new WpAutomaticFeeds();

}elseif( $camp_type == 'BingNews' ){
			
			require_once 'core.bing.php';
			
			if(! class_exists('WpAutomaticFeeds')) return false;
			
			$WpAutomatic = new WpAutomaticFeeds();
	
		}elseif( $camp_type == 'GoogleNews' ){
			
			require_once 'core.googlenews.php';
			
			if(! class_exists('WpAutomaticFeeds')) return false;
			
			$WpAutomatic = new WpAutomaticFeeds();

//GoogleTrends
		}elseif( $camp_type == 'GoogleTrends' ){
			
			require_once 'core.googletrends.php';
			
			if(! class_exists('WpAutomaticFeeds')) return false;
			
			$WpAutomatic = new WpAutomaticFeeds();
		
			
		}elseif( $camp_type == 'Rumble' ){
			
			require_once 'core.rumble.php';
			
			if(! class_exists('WpAutomaticRumble')) return false;
			
			$WpAutomatic = new WpAutomaticRumble();
		
		}elseif( $camp_type == 'Places' ){
			
			require_once 'core.places.php';
			
			if(! class_exists('WpAutomaticPlaces')) return false;
			
			$WpAutomatic = new WpAutomaticPlaces();	
		
		}elseif( $camp_type == 'Medium' ){
			
			require_once 'core.medium.php';
			
			if(! class_exists('WpAutomaticMedium')) return false;
			
			$WpAutomatic = new WpAutomaticMedium();
			
		}else{
			
			require_once 'core.php';
			$WpAutomatic = new wp_automatic();
			
		}
		
			
		// process
		$WpAutomatic->log ( ''.$userOrCron.' >> Processing Campaign:' . $campaign->camp_id, $campaign->camp_name .'{'.$campaign->camp_id .'}' );
		$WpAutomatic->process_campaign ( $campaign );
		
	}
	
	/*
	 * function get_time_difference: get the time difference in minutes.
	 * @start: time stamp
	 * @end: time stamp
	 */
		
	function get_time_difference( $start, $end )
	{
			
		$uts['start'] = $start ;
		$uts['end'] = $end ;
			
			
			
		if( $uts['start']!==-1 && $uts['end']!==-1 )
		{
			if( $uts['end'] >= $uts['start'] )
			{
				$diff = $uts['end'] - $uts['start'];
					
				return round($diff/60,0);
					
			}
				
		}
	}
}