<?php
 if(isset($_POST['edit_activity'])){
   $req_fields = array('activity-task','activity-assg','activity-due','activity-done');
   if(empty($errors)){
     $p_prj    = $project['id'];
     $p_task   = remove_junk(real_escape($_POST['activity-task']));
     $p_assg   = remove_junk(real_escape($_POST['activity-assg']));
     $p_due    = remove_junk(real_escape($_POST['activity-due']));
     $p_done  = remove_junk(real_escape($_POST['activity-done']));
     $query = "UPDATE activities SET (";
	 $append = 0;
	 if ($p_task <> $org['task_id']) {
        $query .="  task_id = {$p_task}";
		$append = 1;
	 }
	 if ($p_assg <> $org['assigned_id']) {
		if ($append) : $query .= ", ";  $append = 0; endif;
        $query .="assigned_id = {$p_assg}";
		$append = 1; 
	 }
	 if ($p_due <> $org['due_date']) {
		if ($append) : $query .= ", ";  $append = 0; endif;
        $query .="due_date = {$p_due}";
		$append = 1; 
	 }
	 if ($p_done <> $org['completed']) {
		if ($append) : $query .= ", ";  $append = 0; endif;
        $query .="completed = {$p_done}";
		$append = 1; 
	 }
     $query .=") WHERE id = {$activity['id']};";
       $session->msg('d', $query);
    $result = mysqli_query($con, $query);
     if($result){
       $session->msg('s',"Activity updated ");
       redirect('edit_project.php?id=' . $project['id'], false);
     } else {
       $session->msg('d',' Sorry failed to update!');
       redirect('edit_project.php?id=' . $project['id'], false);
     }
   } else{
     $session->msg("d", $errors);
      redirect('edit_project.php?id=' . $project['id'],false);
   }
 }

?>