dsp76 · September 20, 2024 16:32
diff --git a/mautic5_tasks.sh b/mautic5_tasks.sh
 #!/bin/bash

 # Set the working directory to the directory of the script
 cd "$(dirname "$0")"

 # Variables for the script
 phpinterpreter="php -d memory_limit=1G"
 pathtoconsole="../code/bin/console"
 lockfile="/tmp/cronjob.lock"

 # Directory for log files
 log_dir="./logs"  # Directory for logs, adjust as needed
 mkdir -p "$log_dir"  # Create the directory if it doesn't exist

 # Email sending settings
 emails_per_batch=14  # Number of emails per batch and rate limit (14 emails/sec)

 # Limits for other Mautic commands
 segments_update_limit=900
 campaigns_rebuild_limit=300
 broadcasts_send_limit=800
 import_limit=500

 # Loop control
 max_loops=40
 current_loop=0
 milliseconds_per_second=1000

 # Colors for output
 RED='\033[0;31m'
 GREEN='\033[0;32m'
 YELLOW='\033[0;33m'
 BLUE='\033[0;34m'
 NC='\033[0m' # No Color

 # Locking mechanism
 if [ -f "$lockfile" ]; then
    # Colored output in the console
    echo "${RED}Script is already running.${NC}"
    
    # No color codes in the log file
    echo "Script is already running." >> "$log_file"
    exit 1
 fi
 touch "$lockfile"
 trap 'rm -f "$lockfile"; exit' INT TERM EXIT

 # Log file for the current run
 log_file="$log_dir/$(date +'%Y%m%d_%H%M%S').log"

 # Function to execute Mautic commands
 execute_command() {
    local command="$1"
    
    # Colored output in the console (stdout)
    echo "${BLUE}Executing: $command${NC}"
    
    # Output without colors to the log file
    echo "Executing: $command" >> "$log_file"
    
    # Execute the command and capture both stdout and stderr
    output=$($phpinterpreter $pathtoconsole $command 2>&1)
    
    # Colored output in the console (stdout and stderr)
    if [ $? -eq 0 ]; then
        echo "${GREEN}$output${NC}"
    else
        echo "${RED}$output${NC}" >&2
    fi
    
    # Output without colors to the log file
    echo "$output" >> "$log_file"
    
    return $?  # Return the exit status of the command
 }

 # Calculate dynamic sleep time in microseconds
 calculate_sleep_time() {
    local duration=$1  # Duration in milliseconds
    local target_duration=$((milliseconds_per_second))  # Target duration in milliseconds for 14 emails per second
    local sleep_time=$(( (target_duration - duration) * 1000 ))  # Convert to microseconds
    echo "$sleep_time"
 }

 # Execute other commands before the email sending loop
 execute_command "mautic:segments:update --batch-limit=$segments_update_limit"
 execute_command "mautic:campaigns:rebuild --batch-limit=$campaigns_rebuild_limit"
 execute_command "mautic:campaigns:trigger"
 execute_command "mautic:broadcasts:send --batch=$broadcasts_send_limit"

 # Loop for sending emails
 while [ $current_loop -lt $max_loops ]
 do
    # Increment the loop counter
    current_loop=$((current_loop+1))

    # Capture start time in milliseconds
    start_time=$(date +%s%3N)
    
    # Execute the command to send emails
    output=$(execute_command "messenger:consume email --limit=$emails_per_batch")
    
    # Capture end time in milliseconds
    end_time=$(date +%s%3N)
    
    # Calculate the duration of the command in milliseconds
    duration=$((end_time - start_time))

    # Calculate the sleep time to maintain the rate limit
    sleep_time=$(calculate_sleep_time $duration)

    # Ensure the command was successful
    if [ $? -ne 0 ]; then
        echo "${RED}Error during email sending. Exiting loop.${NC}" >&2
        echo "Error during email sending. Exiting loop." >> "$log_file"
        break
    fi
    
    # If the number of sent emails is less than the batch limit, exit the loop
    sent_emails=$(echo "$output" | grep -oP '\b\d+(?= emails sent)' || echo 0)
    if [ "$sent_emails" -lt "$emails_per_batch" ]; then
        echo "${RED}Less than $emails_per_batch emails sent. Exiting loop.${NC}"
        echo "Less than $emails_per_batch emails sent. Exiting loop." >> "$log_file"
        break
    fi

    # Pause for the calculated sleep time
    if [ "$sleep_time" -gt 0 ]; then
        usleep "$sleep_time"
    fi
 done

 # Execute additional Mautic commands
 execute_command "mautic:unusedip:delete"
 execute_command "mautic:import --limit=$import_limit"
 execute_command "mautic:webhooks:process"
 execute_command "mautic:reports:scheduler"

 # Remove the lock file at the end
 rm -f "$lockfile"
	#!/bin/bash

	# Set the working directory to the directory of the script
	cd "$(dirname "$0")"

	# Variables for the script
	phpinterpreter="php -d memory_limit=1G"
	pathtoconsole="../code/bin/console"
	lockfile="/tmp/cronjob.lock"

	# Directory for log files
	log_dir="./logs" # Directory for logs, adjust as needed
	mkdir -p "$log_dir" # Create the directory if it doesn't exist

	# Email sending settings
	emails_per_batch=14 # Number of emails per batch and rate limit (14 emails/sec)

	# Limits for other Mautic commands
	segments_update_limit=900
	campaigns_rebuild_limit=300
	broadcasts_send_limit=800
	import_limit=500

	# Loop control
	max_loops=40
	current_loop=0
	milliseconds_per_second=1000

	# Colors for output
	RED='\033[0;31m'
	GREEN='\033[0;32m'
	YELLOW='\033[0;33m'
	BLUE='\033[0;34m'
	NC='\033[0m' # No Color

	# Locking mechanism
	if [ -f "$lockfile" ]; then
	# Colored output in the console
	echo "${RED}Script is already running.${NC}"

	# No color codes in the log file
	echo "Script is already running." >> "$log_file"
	exit 1
	fi
	touch "$lockfile"
	trap 'rm -f "$lockfile"; exit' INT TERM EXIT

	# Log file for the current run
	log_file="$log_dir/$(date +'%Y%m%d_%H%M%S').log"

	# Function to execute Mautic commands
	execute_command() {
	local command="$1"

	# Colored output in the console (stdout)
	echo "${BLUE}Executing: $command${NC}"

	# Output without colors to the log file
	echo "Executing: $command" >> "$log_file"

	# Execute the command and capture both stdout and stderr
	output=$($phpinterpreter $pathtoconsole $command 2>&1)

	# Colored output in the console (stdout and stderr)
	if [ $? -eq 0 ]; then
	echo "${GREEN}$output${NC}"
	else
	echo "${RED}$output${NC}" >&2
	fi

	# Output without colors to the log file
	echo "$output" >> "$log_file"

	return $? # Return the exit status of the command
	}

	# Calculate dynamic sleep time in microseconds
	calculate_sleep_time() {
	local duration=$1 # Duration in milliseconds
	local target_duration=$((milliseconds_per_second)) # Target duration in milliseconds for 14 emails per second
	local sleep_time=$(( (target_duration - duration) * 1000 )) # Convert to microseconds
	echo "$sleep_time"
	}

	# Execute other commands before the email sending loop
	execute_command "mautic:segments:update --batch-limit=$segments_update_limit"
	execute_command "mautic:campaigns:rebuild --batch-limit=$campaigns_rebuild_limit"
	execute_command "mautic:campaigns:trigger"
	execute_command "mautic:broadcasts:send --batch=$broadcasts_send_limit"

	# Loop for sending emails
	while [ $current_loop -lt $max_loops ]
	do
	# Increment the loop counter
	current_loop=$((current_loop+1))

	# Capture start time in milliseconds
	start_time=$(date +%s%3N)

	# Execute the command to send emails
	output=$(execute_command "messenger:consume email --limit=$emails_per_batch")

	# Capture end time in milliseconds
	end_time=$(date +%s%3N)

	# Calculate the duration of the command in milliseconds
	duration=$((end_time - start_time))

	# Calculate the sleep time to maintain the rate limit
	sleep_time=$(calculate_sleep_time $duration)

	# Ensure the command was successful
	if [ $? -ne 0 ]; then
	echo "${RED}Error during email sending. Exiting loop.${NC}" >&2
	echo "Error during email sending. Exiting loop." >> "$log_file"
	break
	fi

	# If the number of sent emails is less than the batch limit, exit the loop
	sent_emails=$(echo "$output" \| grep -oP '\b\d+(?= emails sent)' \|\| echo 0)
	if [ "$sent_emails" -lt "$emails_per_batch" ]; then
	echo "${RED}Less than $emails_per_batch emails sent. Exiting loop.${NC}"
	echo "Less than $emails_per_batch emails sent. Exiting loop." >> "$log_file"
	break
	fi

	# Pause for the calculated sleep time
	if [ "$sleep_time" -gt 0 ]; then
	usleep "$sleep_time"
	fi
	done

	# Execute additional Mautic commands
	execute_command "mautic:unusedip:delete"
	execute_command "mautic:import --limit=$import_limit"
	execute_command "mautic:webhooks:process"
	execute_command "mautic:reports:scheduler"

	# Remove the lock file at the end
	rm -f "$lockfile"