<?php
if ( ! defined( 'ABSPATH' ) ) {
  exit; // Exit if accessed directly
}

global $wppmfunction, $current_user,$wpdb;
$from_name     = get_option('wppm_en_from_name');
$from_email    = get_option('wppm_en_from_email');
$ignore_emails = get_option('wppm_en_ignore_emails');
$task_id = absint(sanitize_text_field($task_id));
$task_data = $wppmfunction->get_task($task_id);
$project_id = absint($task_data['project']);
$project_users = $wpdb->get_results($wpdb->prepare("SELECT user_id FROM {$wpdb->prefix}wppm_project_users WHERE proj_id = %d AND role_id = 1",$project_id));
$p_users = $wpdb->get_var($wpdb->prepare("SELECT users FROM {$wpdb->prefix}wppm_project WHERE id = %d",$project_id));
$p_users_array = array();
if(isset($p_users)){
  $p_users_array = explode(',',$p_users);
}
$task_users = $task_data['users'];
$task_users = explode(',',$task_users);
$flag= false;
if ( !$from_name || !$from_email ) {
  return;
}
$wppm_email_notificatins = get_option('wppm_email_notification');
$wppm_default_email_notification_to_current_user = get_option('wppm_default_email_notification_to_current_user');
foreach ($wppm_email_notificatins as $key=>$val) :
  if($val['type']=='new_task'){
    $subject  = $wppmfunction->replace_task_macro(stripslashes($val['subject']), $task_id);
    $body  = $wppmfunction->replace_task_macro(stripslashes($val['body']),$task_id);
    $recipients = $val['recipients'];
    $email_addresses = array();
    if(!empty($recipients)){
      foreach ($recipients as $recipient) {
          if(is_numeric($recipient)){
            if($recipient == 1 && !empty($project_users)){
              foreach($project_users as $proj_user){
                $proj_user = (array) $proj_user;
                if(in_array($proj_user['user_id'],$p_users_array)){
                  $proj_userdata = get_userdata($proj_user['user_id']);
                  $email_addresses[] = $proj_userdata->user_email;
                }
              }
            }
            if($recipient == 1 && !empty($task_users)) {
                foreach($task_users as $user){
                  if(!empty($user)){
                    $user = absint($user);
                    $project_user_data = $wpdb->get_row($wpdb->prepare("SELECT * FROM {$wpdb->prefix}wppm_project_users WHERE proj_id = %d AND user_id = %d",$project_id,$user));
                    $userdata = get_userdata($user);
                    if((!empty($project_user_data)) && $project_user_data->role_id == 1){
                      $email_addresses[] = $userdata->user_email;
                    }
                  }
                }
            }
            elseif($recipient == 2 && !empty($task_users)){
                foreach($task_users as $user){
                  if(!empty($user)){
                    $user = absint($user);
                    $project_user_data = $wpdb->get_row($wpdb->prepare("SELECT * FROM {$wpdb->prefix}wppm_project_users WHERE proj_id = %d AND user_id = %d",$project_id,$user));
                    $userdata = get_userdata($user);
                    if((!empty($project_user_data)) && $project_user_data->role_id == 2){
                      $email_addresses[] = $userdata->user_email;
                    }
                  }
                } 
            }
          }else{
            switch ($recipient) {
              case 'project_creator':
              //$email_addresses = array_merge($email_addresses,$wppmfunction->get_project_creator_email($project_id));
              if ( ! empty($wppmfunction->get_project_creator_email($project_id)) ) {
                  $email_addresses = array_merge(
                      (array) $email_addresses,
                      (array) $wppmfunction->get_project_creator_email($project_id)
                  );
              }
              break;
              case 'task_creator':
              //$email_addresses = array_merge($email_addresses,$wppmfunction->get_task_creator_email($task_id));
              if ( ! empty($wppmfunction->get_task_creator_email($task_id)) ) {
                  $email_addresses = array_merge(
                      (array) $email_addresses,
                      (array) $wppmfunction->get_task_creator_email($task_id)
                  );
              }
              break;
            }
          }
      }
    }   
    $email_addresses = array_unique($email_addresses);
    $email_addresses = array_diff($email_addresses,$ignore_emails);
    if(empty($wppm_default_email_notification_to_current_user)){
      $email_addresses = array_diff($email_addresses,array($current_user->user_email));
    }
    $email_addresses = apply_filters('wppm_en_task_users_email_addresses',$email_addresses,$val,$task_id);
    $email_addresses = array_values($email_addresses);
    $to =  isset($email_addresses[0])? $email_addresses[0] : '';
    if($to){
      unset($email_addresses[0]);
    } else {
      continue; // no email address found to send. So go to next foreach iteration.
    }
    $bcc = implode(',',$email_addresses);
    $headers  = "From: {$from_name} <{$from_email}>\r\n";
    $email_addresses = explode(',',$bcc);
    foreach ($email_addresses as $email_address) {
      $headers .= "BCC: {$email_address}\r\n";
    }
    $headers .= "Content-Type: text/html; charset=UTF-8 \r\n";
    wp_mail($to, $subject, $body, $headers);
    do_action('wppm_after_submit_task_created_mail',$task_id,$val);
  }
endforeach;