diff --git a/main/admin/user_move_stats.php b/main/admin/user_move_stats.php index 1bb857abf7..fc85582253 100755 --- a/main/admin/user_move_stats.php +++ b/main/admin/user_move_stats.php @@ -1,4 +1,5 @@ 'index.php', "name" => get_lang('PlatformAdmin')]; +$interbreadcrumb[] = ['url' => 'index.php', 'name' => get_lang('PlatformAdmin')]; $debug = 0; -function compare_data($result_message) -{ - foreach ($result_message as $table => $data) { - $title = $table; - if ($table == 'TRACK_E_EXERCISES') { - $title = get_lang('Exercises'); - } elseif ($table == 'TRACK_E_EXERCISES_IN_LP') { - $title = get_lang('ExercisesInLp'); - } elseif ($table == 'LP_VIEW') { - $title = get_lang('LearningPaths'); - } - echo '

'.get_lang($title).'

'; - - if (is_array($data)) { - foreach ($data as $id => $item) { - if ($table == 'TRACK_E_EXERCISES' || $table == 'TRACK_E_EXERCISES_IN_LP') { - echo "

".get_lang('Attempt')." #$id

"; - echo '

'; - echo get_lang('Exercise').' #'.$item['exe_exo_id']; - echo '

'; - if (!empty($item['orig_lp_id'])) { - echo '

'; - echo get_lang('LearningPath').' #'.$item['orig_lp_id']; - echo '

'; - } - //Process data - $array = [ - 'exe_date' => get_lang('Date'), - 'exe_result' => get_lang('Score'), - 'exe_weighting' => get_lang('Weighting'), - ]; - foreach ($item as $key => $value) { - if (in_array($key, array_keys($array))) { - $key = $array[$key]; - echo "$key = $value
"; - } - } - } else { - echo "

".get_lang('Id')." #$id

"; - //process data - foreach ($item as $key => $value) { - echo "$key = $value
"; - } - } - } - } else { - echo get_lang('NoResults'); - } - } -} - if (isset($_REQUEST['load_ajax'])) { //Checking the variable $_SESSION['combination'] that has all the // information of the selected course (instead of using a lots of // hidden variables ... ) if (isset($_SESSION['combination']) && !empty($_SESSION['combination'])) { $combinations = $_SESSION['combination']; - $combination_result = $combinations[$_REQUEST['unique_id']]; + $combination_result = isset($combinations[$_REQUEST['unique_id']]) ? $combinations[$_REQUEST['unique_id']] : []; if (empty($combination_result)) { echo get_lang('ThereWasAnError'); } else { $origin_course_code = $combination_result['course_code']; $origin_session_id = (int) $combination_result['session_id']; $new_session_id = (int) $_REQUEST['session_id']; - $session = $em->find('ChamiloCoreBundle:Session', $new_session_id); - //if (!isset($_REQUEST['view_stat'])) { if ($origin_session_id == $new_session_id) { echo get_lang('CantMoveToTheSameSession'); exit; } - //} $user_id = (int) $_REQUEST['user_id']; - $new_course_list = SessionManager::get_course_list_by_session_id($new_session_id); $course_founded = false; @@ -100,7 +47,6 @@ if (isset($_REQUEST['load_ajax'])) { $result_message = []; $result_message_compare = []; - $update_database = true; if (isset($_REQUEST['view_stat']) && $_REQUEST['view_stat'] == 1) { $update_database = false; @@ -108,7 +54,6 @@ if (isset($_REQUEST['load_ajax'])) { //Check if the same course exist in the session destination if ($course_founded) { - //Check if the user is registered in the session otherwise we will add it $result = SessionManager::get_users_by_session($new_session_id); if (empty($result) || !in_array($user_id, array_keys($result))) { if ($debug) { @@ -122,513 +67,16 @@ if (isset($_REQUEST['load_ajax'])) { ); } - // Begin with the import process $course_info = api_get_course_info($origin_course_code); - $course_id = $course_info['real_id']; - - $TABLETRACK_EXERCICES = Database::get_main_table(TABLE_STATISTIC_TRACK_E_EXERCISES); - $TBL_TRACK_ATTEMPT = Database::get_main_table(TABLE_STATISTIC_TRACK_E_ATTEMPT); - $TBL_TRACK_E_COURSE_ACCESS = Database::get_main_table(TABLE_STATISTIC_TRACK_E_COURSE_ACCESS); - $TBL_TRACK_E_LAST_ACCESS = Database::get_main_table(TABLE_STATISTIC_TRACK_E_LASTACCESS); - - $TBL_LP_VIEW = Database::get_course_table(TABLE_LP_VIEW); - $TBL_NOTEBOOK = Database::get_course_table(TABLE_NOTEBOOK); - $TBL_STUDENT_PUBLICATION = Database::get_course_table(TABLE_STUDENT_PUBLICATION); - $TBL_STUDENT_PUBLICATION_ASSIGNMENT = Database::get_course_table(TABLE_STUDENT_PUBLICATION_ASSIGNMENT); - $TBL_ITEM_PROPERTY = Database::get_course_table(TABLE_ITEM_PROPERTY); - - $TBL_DROPBOX_FILE = Database::get_course_table(TABLE_DROPBOX_FILE); - $TBL_DROPBOX_POST = Database::get_course_table(TABLE_DROPBOX_POST); - $TBL_AGENDA = Database::get_course_table(TABLE_AGENDA); - - //1. track_e_exercises - //ORIGINAL COURSE - - $sql = "SELECT * FROM $TABLETRACK_EXERCICES - WHERE c_id = $course_id AND session_id = $origin_session_id AND exe_user_id = $user_id "; - $res = Database::query($sql); - $list = []; - while ($row = Database::fetch_array($res, 'ASSOC')) { - $list[$row['exe_id']] = $row; - } - - if (!empty($list)) { - foreach ($list as $exe_id => $data) { - if ($update_database) { - $sql = "UPDATE $TABLETRACK_EXERCICES SET session_id = '$new_session_id' WHERE exe_id = $exe_id"; - $res = Database::query($sql); - $result_message[$TABLETRACK_EXERCICES]++; - } else { - if (!empty($data['orig_lp_id']) && !empty($data['orig_lp_item_id'])) { - $result_message['TRACK_E_EXERCISES'][$exe_id] = $data; - } else { - $result_message['TRACK_E_EXERCISES_IN_LP'][$exe_id] = $data; - } - } - } - } - - // DESTINY COURSE - if (!$update_database) { - $sql = "SELECT * FROM $TABLETRACK_EXERCICES - WHERE - c_id = $course_id AND - session_id = $new_session_id AND - exe_user_id = $user_id "; - $res = Database::query($sql); - $list = []; - while ($row = Database::fetch_array($res, 'ASSOC')) { - $list[$row['exe_id']] = $row; - } - - if (!empty($list)) { - foreach ($list as $exe_id => $data) { - if ($update_database) { - $sql = "UPDATE $TABLETRACK_EXERCICES - SET session_id = '$new_session_id' - WHERE exe_id = $exe_id"; - $res = Database::query($sql); - $result_message[$TABLETRACK_EXERCICES]++; - } else { - if (!empty($data['orig_lp_id']) && !empty($data['orig_lp_item_id'])) { - $result_message_compare['TRACK_E_EXERCISES'][$exe_id] = $data; - } else { - $result_message_compare['TRACK_E_EXERCISES_IN_LP'][$exe_id] = $data; - } - } - } - } - } - - //2.track_e_attempt, track_e_attempt_recording, track_e_downloads - //Nothing to do because there are not relationship with a session - - //3. track_e_course_access - $sql = "SELECT * FROM $TBL_TRACK_E_COURSE_ACCESS - WHERE c_id = $course_id AND session_id = $origin_session_id AND user_id = $user_id "; - $res = Database::query($sql); - $list = []; - while ($row = Database::fetch_array($res, 'ASSOC')) { - $list[$row['course_access_id']] = $row; - } - - if (!empty($list)) { - foreach ($list as $id => $data) { - if ($update_database) { - $sql = "UPDATE $TBL_TRACK_E_COURSE_ACCESS - SET session_id = $new_session_id - WHERE course_access_id = $id"; - if ($debug) { - echo $sql; - } - $res = Database::query($sql); - $result_message[$TBL_TRACK_E_COURSE_ACCESS]++; - } - } - } - - //4. track_e_lastaccess - $sql = "SELECT access_id FROM $TBL_TRACK_E_LAST_ACCESS - WHERE c_id = $course_id - AND access_session_id = $origin_session_id - AND access_user_id = $user_id "; - $res = Database::query($sql); - $list = []; - while ($row = Database::fetch_array($res, 'ASSOC')) { - $list[] = $row['access_id']; - } - - if (!empty($list)) { - foreach ($list as $id) { - if ($update_database) { - $sql = "UPDATE $TBL_TRACK_E_LAST_ACCESS - SET access_session_id = $new_session_id - WHERE access_id = $id"; - if ($debug) { - echo $sql; - } - $res = Database::query($sql); - //if ($debug) var_dump($res); - $result_message[$TBL_TRACK_E_LAST_ACCESS]++; - } - } - } - - //5. lp_item_view - //CHECK ORIGIN - $sql = "SELECT * FROM $TBL_LP_VIEW - WHERE user_id = $user_id AND session_id = $origin_session_id AND c_id = $course_id "; - $res = Database::query($sql); - - // Getting the list of LPs in the new session - $lp_list = new LearnpathList($user_id, $course_info, $new_session_id); - $flat_list = $lp_list->get_flat_list(); - - $list = []; - while ($row = Database::fetch_array($res, 'ASSOC')) { - // Checking if the LP exist in the new session - //if (in_array($row['lp_id'], array_keys($flat_list))) { - $list[$row['id']] = $row; - //} - } - - if (!empty($list)) { - foreach ($list as $id => $data) { - if ($update_database) { - $sql = "UPDATE $TBL_LP_VIEW - SET session_id = $new_session_id - WHERE c_id = $course_id AND id = $id "; - if ($debug) { - var_dump($sql); - } - $res = Database::query($sql); - if ($debug) { - var_dump($res); - } - $result_message[$TBL_LP_VIEW]++; - } else { - //Getting all information of that lp_item_id - $score = Tracking::get_avg_student_score( - $user_id, - $origin_course_code, - [$data['lp_id']], - $origin_session_id - ); - $progress = Tracking::get_avg_student_progress( - $user_id, - $origin_course_code, - [$data['lp_id']], - $origin_session_id - ); - $result_message['LP_VIEW'][$data['lp_id']] = [ - 'score' => $score, - 'progress' => $progress, - ]; - } - } - } - - //CHECk DESTINY - if (!$update_database) { - $sql = "SELECT * FROM $TBL_LP_VIEW WHERE user_id = $user_id AND session_id = $new_session_id AND c_id = $course_id"; - $res = Database::query($sql); - - // Getting the list of LPs in the new session - $lp_list = new LearnpathList($user_id, $course_info, $new_session_id); - $flat_list = $lp_list->get_flat_list(); - - $list = []; - while ($row = Database::fetch_array($res, 'ASSOC')) { - //Checking if the LP exist in the new session - //if (in_array($row['lp_id'], array_keys($flat_list))) { - $list[$row['id']] = $row; - //} - } - - if (!empty($list)) { - foreach ($list as $id => $data) { - //Getting all information of that lp_item_id - $score = Tracking::get_avg_student_score( - $user_id, - $origin_course_code, - [$data['lp_id']], - $new_session_id - ); - $progress = Tracking::get_avg_student_progress( - $user_id, - $origin_course_code, - [$data['lp_id']], - $new_session_id - ); - $result_message_compare['LP_VIEW'][$data['lp_id']] = [ - 'score' => $score, - 'progress' => $progress, - ]; - } - } - } - - //6. Agenda - //calendar_event_attachment no problems no session_id - $sql = "SELECT ref FROM $TBL_ITEM_PROPERTY - WHERE tool = 'calendar_event' AND insert_user_id = $user_id AND c_id = $course_id "; - $res = Database::query($sql); - while ($row = Database::fetch_array($res, 'ASSOC')) { - $id = $row['ref']; - if ($update_database) { - $sql = "UPDATE $TBL_AGENDA SET session_id = $new_session_id WHERE c_id = $course_id AND id = $id "; - if ($debug) { - var_dump($sql); - } - $res_update = Database::query($sql); - if ($debug) { - var_dump($res_update); - } - $result_message['agenda']++; - } - } - - //7. Forum ?? So much problems when trying to import data - //8. Student publication - Works - $sql = "SELECT ref FROM $TBL_ITEM_PROPERTY - WHERE tool = 'work' AND insert_user_id = $user_id AND c_id = $course_id"; - if ($debug) { - echo $sql; - } - $res = Database::query($sql); - while ($row = Database::fetch_array($res, 'ASSOC')) { - $id = $row['ref']; - $sql = "SELECT * FROM $TBL_STUDENT_PUBLICATION WHERE id = $id AND session_id = $origin_session_id AND c_id = $course_id"; - if ($debug) { - var_dump($sql); - } - $sub_res = Database::query($sql); - if (Database::num_rows($sub_res) > 0) { - $data = Database::fetch_array($sub_res, 'ASSOC'); - if ($debug) { - var_dump($data); - } - $parent_id = $data['parent_id']; - if (isset($data['parent_id']) && !empty($data['parent_id'])) { - $sql = "SELECT * FROM $TBL_STUDENT_PUBLICATION - WHERE id = $parent_id AND c_id = $course_id"; - $select_res = Database::query($sql); - $parent_data = Database::fetch_array( - $select_res, - 'ASSOC' - ); - if ($debug) { - var_dump($parent_data); - } - - $sys_course_path = api_get_path(SYS_COURSE_PATH); - $course_dir = $sys_course_path.$course_info['path']; - $base_work_dir = $course_dir.'/work'; - require_once api_get_path(SYS_CODE_PATH).'work/work.lib.php'; - - // Creating the parent folder in the session if does not exists already - //@todo ugly fix - $search_this = "folder_moved_from_session_id_$origin_session_id"; - $search_this2 = $parent_data['url']; - $sql = "SELECT * FROM $TBL_STUDENT_PUBLICATION - WHERE description like '%$search_this%' AND url LIKE '%$search_this2%' AND session_id = $new_session_id AND c_id = $course_id - ORDER BY id desc LIMIT 1"; - if ($debug) { - echo $sql; - } - $sub_res = Database::query($sql); - $num_rows = Database::num_rows($sub_res); - - if ($num_rows > 0) { - $new_result = Database::fetch_array($sub_res, 'ASSOC'); - $created_dir = $new_result['url']; - $new_parent_id = $new_result['id']; - } else { - if ($update_database) { - $dir_name = substr($parent_data['url'], 1); - $created_dir = create_unexisting_work_directory($base_work_dir, $dir_name); - $created_dir = '/'.$created_dir; - $now = new DateTime(api_get_utc_datetime(), new DateTimeZone('UTC')); - //Creating directory - $publication = new \Chamilo\CourseBundle\Entity\CStudentPublication(); - $publication - ->setUrl($created_dir) - ->setCId($course_id) - ->setTitle($parent_data['title']) - ->setDescription( - $parent_data['description']."folder_moved_from_session_id_$origin_session_id" - ) - ->setActive(false) - ->setAccepted(true) - ->setFiletype('folder') - ->setSentDate($now) - ->setQualification($parent_data['qualification']) - ->setParentId(0) - ->setQualificatorId(0) - ->setSession($session); - - $id = $publication->getIid(); - //Folder created - api_item_property_update($course_info, 'work', $id, 'DirectoryCreated', api_get_user_id()); - $new_parent_id = $id; - $result_message[$TBL_STUDENT_PUBLICATION.' - new folder created called: '.$created_dir]++; - } - } - - //Creating student_publication_assignment if exists - $sql = "SELECT * FROM $TBL_STUDENT_PUBLICATION_ASSIGNMENT WHERE publication_id = $parent_id AND c_id = $course_id"; - if ($debug) { - var_dump($sql); - } - $rest_select = Database::query($sql); - if (Database::num_rows($rest_select) > 0) { - if ($update_database) { - $assignment_data = Database::fetch_array($rest_select, 'ASSOC'); - $sql_add_publication = "INSERT INTO ".$TBL_STUDENT_PUBLICATION_ASSIGNMENT." SET - c_id = '$course_id', - expires_on = '".$assignment_data['expires_on']."', - ends_on = '".$assignment_data['ends_on']."', - add_to_calendar = '".$assignment_data['add_to_calendar']."', - enable_qualification = '".$assignment_data['enable_qualification']."', - publication_id = '".$new_parent_id."'"; - if ($debug) { - echo $sql_add_publication; - } - $rest_select = Database::query($sql_add_publication); - $id = Database::insert_id(); - - $sql_update = "UPDATE ".$TBL_STUDENT_PUBLICATION." SET ". - "has_properties = '".$id."', - view_properties = '1' - WHERE id = ".$new_parent_id; - if ($debug) { - echo $sql_update; - } - $rest_update = Database::query($sql_update); - if ($debug) { - var_dump($sql_update); - } - $result_message[$TBL_STUDENT_PUBLICATION_ASSIGNMENT]++; - } - } - - $doc_url = $data['url']; - $new_url = str_replace($parent_data['url'], $created_dir, $doc_url); - - if ($update_database) { - //Creating a new work - $data['sent_date'] = new DateTime($data['sent_date'], new DateTimeZone('UTC')); - - $publication = new \Chamilo\CourseBundle\Entity\CStudentPublication(); - $publication - ->setUrl($new_url) - ->setCId($course_id) - ->setTitle($data['title']) - ->setDescription($data['description'].' file moved') - ->setActive($data['active']) - ->setAccepted($data['accepted']) - ->setPostGroupId($data['post_group_id']) - ->setSentDate($data['sent_date']) - ->setParentId($new_parent_id) - ->setSession($session); - - $em->persist($publication); - $em->flush(); - - $id = $publication->getIid(); - api_item_property_update($course_info, 'work', $id, 'DocumentAdded', $user_id); - $result_message[$TBL_STUDENT_PUBLICATION]++; - - $full_file_name = $course_dir.'/'.$doc_url; - $new_file = $course_dir.'/'.$new_url; - - if (file_exists($full_file_name)) { - //deleting old assignment - $result = copy($full_file_name, $new_file); - if ($result) { - unlink($full_file_name); - $sql = "DELETE FROM $TBL_STUDENT_PUBLICATION WHERE id= ".$data['id']; - if ($debug) { - var_dump($sql); - } - $result_delete = Database::query($sql); - api_item_property_update($course_info, 'work', $data['id'], 'DocumentDeleted', api_get_user_id()); - } - } - } - } - } - } - - //9. Survey Pending - //10. Dropbox - not neccesary to move categories (no presence of session_id) - $sql = "SELECT id FROM $TBL_DROPBOX_FILE - WHERE uploader_id = $user_id AND session_id = $origin_session_id AND c_id = $course_id"; - if ($debug) { - var_dump($sql); - } - $res = Database::query($sql); - while ($row = Database::fetch_array($res, 'ASSOC')) { - $id = $row['id']; - if ($update_database) { - $sql = "UPDATE $TBL_DROPBOX_FILE SET session_id = $new_session_id WHERE c_id = $course_id AND id = $id"; - if ($debug) { - var_dump($sql); - } - $res = Database::query($sql); - if ($debug) { - var_dump($res); - } - - $sql = "UPDATE $TBL_DROPBOX_POST SET session_id = $new_session_id WHERE file_id = $id"; - if ($debug) { - var_dump($sql); - } - $res = Database::query($sql); - if ($debug) { - var_dump($res); - } - $result_message[$TBL_DROPBOX_FILE]++; - } - } - - //11. Notebook - - $sql = "SELECT notebook_id FROM $TBL_NOTEBOOK - WHERE user_id = $user_id AND session_id = $origin_session_id AND course = '$origin_course_code' AND c_id = $course_id"; - if ($debug) { - var_dump($sql); - } - $res = Database::query($sql); - while ($row = Database::fetch_array($res, 'ASSOC')) { - $id = $row['notebook_id']; - if ($update_database) { - $sql = "UPDATE $TBL_NOTEBOOK - SET session_id = $new_session_id - WHERE c_id = $course_id AND notebook_id = $id"; - if ($debug) { - var_dump($sql); - } - $res = Database::query($sql); - if ($debug) { - var_dump($res); - } - } - } - - if ($update_database) { - echo '

'.get_lang('StatsMoved').'

'; - if (is_array($result_message)) { - foreach ($result_message as $table => $times) { - echo 'Table '.$table.' - '.$times.' records updated
'; - } - } - } else { - echo '

'.get_lang('UserInformationOfThisCourse').'

'; - - echo '
'; - echo ''; - echo ''; - echo ''; - echo ''; - echo ''; - echo '
'; - - if ($origin_session_id == 0) { - echo '

'.get_lang('OriginCourse').'

'; - } else { - echo '

'.get_lang('OriginSession').' #'.$origin_session_id.'

'; - } - compare_data($result_message); - echo '		'; - if ($new_session_id == 0) { - echo '

'.get_lang('DestinyCourse').'

'; - } else { - echo '

'.get_lang('DestinySession').' #'.$new_session_id.'

'; - } - compare_data($result_message_compare); - echo '
'; - } + // Check if the user is registered in the session otherwise we will add it + Tracking::processUserDataMove( + $user_id, + $course_info, + $origin_session_id, + $new_session_id, + $update_database, + $debug + ); } else { echo get_lang('CourseDoesNotExistInThisSession'); } diff --git a/main/inc/lib/tracking.lib.php b/main/inc/lib/tracking.lib.php index e7472f1e1d..3c00bda830 100755 --- a/main/inc/lib/tracking.lib.php +++ b/main/inc/lib/tracking.lib.php @@ -7048,13 +7048,590 @@ class Tracking $userId = (int) $userId; $sql = "SELECT COUNT(DISTINCT (DATE(login_course_date))) AS c - FROM $tblTrackCourseAccess - WHERE c_id = $courseId $sessionCondition AND user_id = $userId"; + FROM $tblTrackCourseAccess + WHERE c_id = $courseId $sessionCondition AND user_id = $userId"; $result = Database::fetch_assoc(Database::query($sql)); return (int) $result['c']; } + + public static function processUserDataMove($user_id, $course_info, $origin_session_id, $new_session_id, $update_database, $debug = false) + { + // Begin with the import process + $origin_course_code = $course_info['code']; + $course_id = $course_info['real_id']; + $user_id = (int) $user_id; + $origin_session_id = (int) $origin_session_id; + $new_session_id = (int) $new_session_id; + + $session = api_get_session_entity($new_session_id); + $em = Database::getManager(); + + $TABLETRACK_EXERCICES = Database::get_main_table(TABLE_STATISTIC_TRACK_E_EXERCISES); + $TBL_TRACK_ATTEMPT = Database::get_main_table(TABLE_STATISTIC_TRACK_E_ATTEMPT); + $TBL_TRACK_E_COURSE_ACCESS = Database::get_main_table(TABLE_STATISTIC_TRACK_E_COURSE_ACCESS); + $TBL_TRACK_E_LAST_ACCESS = Database::get_main_table(TABLE_STATISTIC_TRACK_E_LASTACCESS); + + $TBL_LP_VIEW = Database::get_course_table(TABLE_LP_VIEW); + $TBL_NOTEBOOK = Database::get_course_table(TABLE_NOTEBOOK); + $TBL_STUDENT_PUBLICATION = Database::get_course_table(TABLE_STUDENT_PUBLICATION); + $TBL_STUDENT_PUBLICATION_ASSIGNMENT = Database::get_course_table(TABLE_STUDENT_PUBLICATION_ASSIGNMENT); + $TBL_ITEM_PROPERTY = Database::get_course_table(TABLE_ITEM_PROPERTY); + + $TBL_DROPBOX_FILE = Database::get_course_table(TABLE_DROPBOX_FILE); + $TBL_DROPBOX_POST = Database::get_course_table(TABLE_DROPBOX_POST); + $TBL_AGENDA = Database::get_course_table(TABLE_AGENDA); + + //1. track_e_exercises + //ORIGINAL COURSE + $sql = "SELECT * FROM $TABLETRACK_EXERCICES + WHERE c_id = $course_id AND session_id = $origin_session_id AND exe_user_id = $user_id "; + $res = Database::query($sql); + $list = []; + while ($row = Database::fetch_array($res, 'ASSOC')) { + $list[$row['exe_id']] = $row; + } + + $result_message = []; + if (!empty($list)) { + foreach ($list as $exe_id => $data) { + if ($update_database) { + $sql = "UPDATE $TABLETRACK_EXERCICES SET session_id = '$new_session_id' WHERE exe_id = $exe_id"; + Database::query($sql); + $result_message['TABLETRACK_EXERCICES']++; + } else { + if (!empty($data['orig_lp_id']) && !empty($data['orig_lp_item_id'])) { + $result_message['TRACK_E_EXERCISES'][$exe_id] = $data; + } else { + $result_message['TRACK_E_EXERCISES_IN_LP'][$exe_id] = $data; + } + } + } + } + + // DESTINY COURSE + if (!$update_database) { + $sql = "SELECT * FROM $TABLETRACK_EXERCICES + WHERE + c_id = $course_id AND + session_id = $new_session_id AND + exe_user_id = $user_id "; + $res = Database::query($sql); + $list = []; + while ($row = Database::fetch_array($res, 'ASSOC')) { + $list[$row['exe_id']] = $row; + } + + if (!empty($list)) { + foreach ($list as $exe_id => $data) { + if ($update_database) { + $sql = "UPDATE $TABLETRACK_EXERCICES + SET session_id = '$new_session_id' + WHERE exe_id = $exe_id"; + Database::query($sql); + $result_message[$TABLETRACK_EXERCICES]++; + } else { + if (!empty($data['orig_lp_id']) && !empty($data['orig_lp_item_id'])) { + $result_message_compare['TRACK_E_EXERCISES'][$exe_id] = $data; + } else { + $result_message_compare['TRACK_E_EXERCISES_IN_LP'][$exe_id] = $data; + } + } + } + } + } + + // 2.track_e_attempt, track_e_attempt_recording, track_e_downloads + // Nothing to do because there are not relationship with a session + // 3. track_e_course_access + $sql = "SELECT * FROM $TBL_TRACK_E_COURSE_ACCESS + WHERE c_id = $course_id AND session_id = $origin_session_id AND user_id = $user_id "; + $res = Database::query($sql); + $list = []; + while ($row = Database::fetch_array($res, 'ASSOC')) { + $list[$row['course_access_id']] = $row; + } + + if (!empty($list)) { + foreach ($list as $id => $data) { + if ($update_database) { + $sql = "UPDATE $TBL_TRACK_E_COURSE_ACCESS + SET session_id = $new_session_id + WHERE course_access_id = $id"; + if ($debug) { + echo $sql; + } + Database::query($sql); + $result_message[$TBL_TRACK_E_COURSE_ACCESS]++; + } + } + } + + //4. track_e_lastaccess + $sql = "SELECT access_id FROM $TBL_TRACK_E_LAST_ACCESS + WHERE + c_id = $course_id AND + access_session_id = $origin_session_id AND + access_user_id = $user_id "; + $res = Database::query($sql); + $list = []; + while ($row = Database::fetch_array($res, 'ASSOC')) { + $list[] = $row['access_id']; + } + + if (!empty($list)) { + foreach ($list as $id) { + if ($update_database) { + $sql = "UPDATE $TBL_TRACK_E_LAST_ACCESS + SET access_session_id = $new_session_id + WHERE access_id = $id"; + if ($debug) { + echo $sql; + } + Database::query($sql); + //if ($debug) var_dump($res); + $result_message[$TBL_TRACK_E_LAST_ACCESS]++; + } + } + } + + // 5. lp_item_view + // CHECK ORIGIN + $sql = "SELECT * FROM $TBL_LP_VIEW + WHERE user_id = $user_id AND session_id = $origin_session_id AND c_id = $course_id "; + $res = Database::query($sql); + + // Getting the list of LPs in the new session + $lp_list = new LearnpathList($user_id, $course_info, $new_session_id); + $flat_list = $lp_list->get_flat_list(); + + $list = []; + while ($row = Database::fetch_array($res, 'ASSOC')) { + // Checking if the LP exist in the new session + //if (in_array($row['lp_id'], array_keys($flat_list))) { + $list[$row['id']] = $row; + //} + } + + if (!empty($list)) { + foreach ($list as $id => $data) { + if ($update_database) { + $sql = "UPDATE $TBL_LP_VIEW + SET session_id = $new_session_id + WHERE c_id = $course_id AND id = $id "; + if ($debug) { + var_dump($sql); + } + $res = Database::query($sql); + if ($debug) { + var_dump($res); + } + $result_message[$TBL_LP_VIEW]++; + } else { + //Getting all information of that lp_item_id + $score = Tracking::get_avg_student_score( + $user_id, + $origin_course_code, + [$data['lp_id']], + $origin_session_id + ); + $progress = Tracking::get_avg_student_progress( + $user_id, + $origin_course_code, + [$data['lp_id']], + $origin_session_id + ); + $result_message['LP_VIEW'][$data['lp_id']] = [ + 'score' => $score, + 'progress' => $progress, + ]; + } + } + } + + // CHECk DESTINY + if (!$update_database) { + $sql = "SELECT * FROM $TBL_LP_VIEW WHERE user_id = $user_id AND session_id = $new_session_id AND c_id = $course_id"; + $res = Database::query($sql); + + // Getting the list of LPs in the new session + $lp_list = new LearnpathList($user_id, $course_info, $new_session_id); + $flat_list = $lp_list->get_flat_list(); + + $list = []; + while ($row = Database::fetch_array($res, 'ASSOC')) { + //Checking if the LP exist in the new session + //if (in_array($row['lp_id'], array_keys($flat_list))) { + $list[$row['id']] = $row; + //} + } + + if (!empty($list)) { + foreach ($list as $id => $data) { + //Getting all information of that lp_item_id + $score = Tracking::get_avg_student_score( + $user_id, + $origin_course_code, + [$data['lp_id']], + $new_session_id + ); + $progress = Tracking::get_avg_student_progress( + $user_id, + $origin_course_code, + [$data['lp_id']], + $new_session_id + ); + $result_message_compare['LP_VIEW'][$data['lp_id']] = [ + 'score' => $score, + 'progress' => $progress, + ]; + } + } + } + + //6. Agenda + //calendar_event_attachment no problems no session_id + $sql = "SELECT ref FROM $TBL_ITEM_PROPERTY + WHERE tool = 'calendar_event' AND insert_user_id = $user_id AND c_id = $course_id "; + $res = Database::query($sql); + while ($row = Database::fetch_array($res, 'ASSOC')) { + $id = $row['ref']; + if ($update_database) { + $sql = "UPDATE $TBL_AGENDA SET session_id = $new_session_id WHERE c_id = $course_id AND id = $id "; + if ($debug) { + var_dump($sql); + } + $res_update = Database::query($sql); + if ($debug) { + var_dump($res_update); + } + $result_message['agenda']++; + } + } + + //7. Forum ?? So much problems when trying to import data + //8. Student publication - Works + $sql = "SELECT ref FROM $TBL_ITEM_PROPERTY + WHERE tool = 'work' AND insert_user_id = $user_id AND c_id = $course_id"; + if ($debug) { + echo $sql; + } + $res = Database::query($sql); + while ($row = Database::fetch_array($res, 'ASSOC')) { + $id = $row['ref']; + $sql = "SELECT * FROM $TBL_STUDENT_PUBLICATION + WHERE id = $id AND session_id = $origin_session_id AND c_id = $course_id"; + if ($debug) { + var_dump($sql); + } + $sub_res = Database::query($sql); + if (Database::num_rows($sub_res) > 0) { + $data = Database::fetch_array($sub_res, 'ASSOC'); + if ($debug) { + var_dump($data); + } + $parent_id = $data['parent_id']; + if (isset($data['parent_id']) && !empty($data['parent_id'])) { + $sql = "SELECT * FROM $TBL_STUDENT_PUBLICATION + WHERE id = $parent_id AND c_id = $course_id"; + $select_res = Database::query($sql); + $parent_data = Database::fetch_array( + $select_res, + 'ASSOC' + ); + if ($debug) { + var_dump($parent_data); + } + + $sys_course_path = api_get_path(SYS_COURSE_PATH); + $course_dir = $sys_course_path.$course_info['path']; + $base_work_dir = $course_dir.'/work'; + + // Creating the parent folder in the session if does not exists already + //@todo ugly fix + $search_this = "folder_moved_from_session_id_$origin_session_id"; + $search_this2 = $parent_data['url']; + $sql = "SELECT * FROM $TBL_STUDENT_PUBLICATION + WHERE description like '%$search_this%' AND url LIKE '%$search_this2%' AND session_id = $new_session_id AND c_id = $course_id + ORDER BY id desc LIMIT 1"; + if ($debug) { + echo $sql; + } + $sub_res = Database::query($sql); + $num_rows = Database::num_rows($sub_res); + + if ($num_rows > 0) { + $new_result = Database::fetch_array($sub_res, 'ASSOC'); + $created_dir = $new_result['url']; + $new_parent_id = $new_result['id']; + } else { + if ($update_database) { + $dir_name = substr($parent_data['url'], 1); + $created_dir = create_unexisting_work_directory($base_work_dir, $dir_name); + $created_dir = '/'.$created_dir; + $now = new DateTime(api_get_utc_datetime(), new DateTimeZone('UTC')); + //Creating directory + $publication = new \Chamilo\CourseBundle\Entity\CStudentPublication(); + $publication + ->setUrl($created_dir) + ->setCId($course_id) + ->setTitle($parent_data['title']) + ->setDescription( + $parent_data['description']."folder_moved_from_session_id_$origin_session_id" + ) + ->setActive(false) + ->setAccepted(true) + ->setFiletype('folder') + ->setSentDate($now) + ->setQualification($parent_data['qualification']) + ->setParentId(0) + ->setQualificatorId(0) + ->setSession($session); + + $id = $publication->getIid(); + //Folder created + api_item_property_update($course_info, 'work', $id, 'DirectoryCreated', api_get_user_id()); + $new_parent_id = $id; + $result_message[$TBL_STUDENT_PUBLICATION.' - new folder created called: '.$created_dir]++; + } + } + + //Creating student_publication_assignment if exists + $sql = "SELECT * FROM $TBL_STUDENT_PUBLICATION_ASSIGNMENT + WHERE publication_id = $parent_id AND c_id = $course_id"; + if ($debug) { + var_dump($sql); + } + $rest_select = Database::query($sql); + if (Database::num_rows($rest_select) > 0) { + if ($update_database) { + $assignment_data = Database::fetch_array($rest_select, 'ASSOC'); + $sql_add_publication = "INSERT INTO ".$TBL_STUDENT_PUBLICATION_ASSIGNMENT." SET + c_id = '$course_id', + expires_on = '".$assignment_data['expires_on']."', + ends_on = '".$assignment_data['ends_on']."', + add_to_calendar = '".$assignment_data['add_to_calendar']."', + enable_qualification = '".$assignment_data['enable_qualification']."', + publication_id = '".$new_parent_id."'"; + if ($debug) { + echo $sql_add_publication; + } + Database::query($sql_add_publication); + $id = Database::insert_id(); + + $sql_update = "UPDATE ".$TBL_STUDENT_PUBLICATION." SET ". + "has_properties = '".$id."', + view_properties = '1' + WHERE id = ".$new_parent_id; + if ($debug) { + echo $sql_update; + } + Database::query($sql_update); + if ($debug) { + var_dump($sql_update); + } + $result_message[$TBL_STUDENT_PUBLICATION_ASSIGNMENT]++; + } + } + + $doc_url = $data['url']; + $new_url = str_replace($parent_data['url'], $created_dir, $doc_url); + + if ($update_database) { + //Creating a new work + $data['sent_date'] = new DateTime($data['sent_date'], new DateTimeZone('UTC')); + + $publication = new \Chamilo\CourseBundle\Entity\CStudentPublication(); + $publication + ->setUrl($new_url) + ->setCId($course_id) + ->setTitle($data['title']) + ->setDescription($data['description'].' file moved') + ->setActive($data['active']) + ->setAccepted($data['accepted']) + ->setPostGroupId($data['post_group_id']) + ->setSentDate($data['sent_date']) + ->setParentId($new_parent_id) + ->setSession($session); + + $em->persist($publication); + $em->flush(); + + $id = $publication->getIid(); + api_item_property_update($course_info, 'work', $id, 'DocumentAdded', $user_id); + $result_message[$TBL_STUDENT_PUBLICATION]++; + $full_file_name = $course_dir.'/'.$doc_url; + $new_file = $course_dir.'/'.$new_url; + + if (file_exists($full_file_name)) { + // deleting old assignment + $result = copy($full_file_name, $new_file); + if ($result) { + unlink($full_file_name); + $sql = "DELETE FROM $TBL_STUDENT_PUBLICATION WHERE id= ".$data['id']; + if ($debug) { + var_dump($sql); + } + Database::query($sql); + api_item_property_update( + $course_info, + 'work', + $data['id'], + 'DocumentDeleted', + api_get_user_id() + ); + } + } + } + } + } + } + + //9. Survey Pending + //10. Dropbox - not neccesary to move categories (no presence of session_id) + $sql = "SELECT id FROM $TBL_DROPBOX_FILE + WHERE uploader_id = $user_id AND session_id = $origin_session_id AND c_id = $course_id"; + if ($debug) { + var_dump($sql); + } + $res = Database::query($sql); + while ($row = Database::fetch_array($res, 'ASSOC')) { + $id = $row['id']; + if ($update_database) { + $sql = "UPDATE $TBL_DROPBOX_FILE SET session_id = $new_session_id WHERE c_id = $course_id AND id = $id"; + if ($debug) { + var_dump($sql); + } + $res = Database::query($sql); + if ($debug) { + var_dump($res); + } + + $sql = "UPDATE $TBL_DROPBOX_POST SET session_id = $new_session_id WHERE file_id = $id"; + if ($debug) { + var_dump($sql); + } + $res = Database::query($sql); + if ($debug) { + var_dump($res); + } + $result_message[$TBL_DROPBOX_FILE]++; + } + } + + // 11. Notebook + /*$sql = "SELECT notebook_id FROM $TBL_NOTEBOOK + WHERE + user_id = $user_id AND + session_id = $origin_session_id AND + course = '$origin_course_code' AND + c_id = $course_id"; + if ($debug) { + var_dump($sql); + } + $res = Database::query($sql); + while ($row = Database::fetch_array($res, 'ASSOC')) { + $id = $row['notebook_id']; + if ($update_database) { + $sql = "UPDATE $TBL_NOTEBOOK + SET session_id = $new_session_id + WHERE c_id = $course_id AND notebook_id = $id"; + if ($debug) { + var_dump($sql); + } + $res = Database::query($sql); + if ($debug) { + var_dump($res); + } + } + }*/ + + if ($update_database) { + echo '

'.get_lang('StatsMoved').'

'; + if (is_array($result_message)) { + foreach ($result_message as $table => $times) { + echo 'Table '.$table.' - '.$times.' records updated
'; + } + } + } else { + echo '

'.get_lang('UserInformationOfThisCourse').'

'; + + echo '
'; + echo ''; + echo ''; + echo ''; + echo ''; + echo ''; + echo '
'; + + if ($origin_session_id == 0) { + echo '

'.get_lang('OriginCourse').'

'; + } else { + echo '

'.get_lang('OriginSession').' #'.$origin_session_id.'

'; + } + self::compareUserData($result_message); + echo '		'; + if ($new_session_id == 0) { + echo '

'.get_lang('DestinyCourse').'

'; + } else { + echo '

'.get_lang('DestinySession').' #'.$new_session_id.'

'; + } + self::compareUserData($result_message_compare); + echo '
'; + } + } + + public static function compareUserData($result_message) + { + foreach ($result_message as $table => $data) { + $title = $table; + if ($table === 'TRACK_E_EXERCISES') { + $title = get_lang('Exercises'); + } elseif ($table === 'TRACK_E_EXERCISES_IN_LP') { + $title = get_lang('ExercisesInLp'); + } elseif ($table === 'LP_VIEW') { + $title = get_lang('LearningPaths'); + } + echo '

'.get_lang($title).'

'; + + if (is_array($data)) { + foreach ($data as $id => $item) { + if ($table === 'TRACK_E_EXERCISES' || $table === 'TRACK_E_EXERCISES_IN_LP') { + echo "

".get_lang('Attempt')." #$id

"; + echo '

'; + echo get_lang('Exercise').' #'.$item['exe_exo_id']; + echo '

'; + if (!empty($item['orig_lp_id'])) { + echo '

'; + echo get_lang('LearningPath').' #'.$item['orig_lp_id']; + echo '

'; + } + // Process data. + $array = [ + 'exe_date' => get_lang('Date'), + 'exe_result' => get_lang('Score'), + 'exe_weighting' => get_lang('Weighting'), + ]; + foreach ($item as $key => $value) { + if (in_array($key, array_keys($array))) { + $key = $array[$key]; + echo "$key = $value
"; + } + } + } else { + echo "

".get_lang('Id')." #$id

"; + // process data + foreach ($item as $key => $value) { + echo "$key = $value
"; + } + } + } + } else { + echo get_lang('NoResults'); + } + } + } } /**