chamilo
/
chamilo-lms
mirror of https://github.com/chamilo/chamilo-lms/tree/1.11.x
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Admin: User move stats, refactor code. BT#18119

Browse Source
pull/3694/head
Julio Montoya 6 years ago
parent cd7ea3dc80
commit 90f8a9f4ae
2 changed files with 593 additions and 568 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 580
      main/admin/user_move_stats.php
  2. 581
      main/inc/lib/tracking.lib.php

580
main/admin/user_move_stats.php
Unescape View File

@ -1,4 +1,5 @@
<?php
/* For licensing terms, see /license.txt */
/**
@ -6,89 +7,35 @@
*/
$cidReset = true;
require_once __DIR__.'/../inc/global.inc.php';
$this_section = SECTION_PLATFORM_ADMIN;
require_once api_get_path(SYS_CODE_PATH).'work/work.lib.php';
$this_section = SECTION_PLATFORM_ADMIN;
api_protect_admin_script();
$em = Database::getManager();
$interbreadcrumb[] = ["url" => '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 '<br / ><h3>'.get_lang($title).' </h3><hr />';
if (is_array($data)) {
foreach ($data as $id => $item) {
if ($table == 'TRACK_E_EXERCISES' || $table == 'TRACK_E_EXERCISES_IN_LP') {
echo "<br /><h3>".get_lang('Attempt')." #$id</h3>";
echo '<h3>';
echo get_lang('Exercise').' #'.$item['exe_exo_id'];
echo '</h3>';
if (!empty($item['orig_lp_id'])) {
echo '<h3>';
echo get_lang('LearningPath').' #'.$item['orig_lp_id'];
echo '</h3>';
}
//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 <br />";
}
}
} else {
echo "<br /><h3>".get_lang('Id')." #$id</h3>";
//process data
foreach ($item as $key => $value) {
echo "$key = $value <br />";
}
}
}
} 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 '<h2>'.get_lang('StatsMoved').'</h2>';
if (is_array($result_message)) {
foreach ($result_message as $table => $times) {
echo 'Table '.$table.' - '.$times.' records updated <br />';
}
}
} else {
echo '<h2>'.get_lang('UserInformationOfThisCourse').'</h2>';
echo '<br />';
echo '<table width="100%">';
echo '<tr>';
echo '<td width="50%" valign="top">';
if ($origin_session_id == 0) {
echo '<h4>'.get_lang('OriginCourse').'</h4>';
} else {
echo '<h4>'.get_lang('OriginSession').' #'.$origin_session_id.'</h4>';
}
compare_data($result_message);
echo '</td>';
echo '<td width="50%" valign="top">';
if ($new_session_id == 0) {
echo '<h4>'.get_lang('DestinyCourse').'</h4>';
} else {
echo '<h4>'.get_lang('DestinySession').' #'.$new_session_id.'</h4>';
}
compare_data($result_message_compare);
echo '</td>';
echo '</tr>';
echo '</table>';
}
// 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');
}

581
main/inc/lib/tracking.lib.php
Unescape View File

@ -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 '<h2>'.get_lang('StatsMoved').'</h2>';
if (is_array($result_message)) {
foreach ($result_message as $table => $times) {
echo 'Table '.$table.' - '.$times.' records updated <br />';
}
}
} else {
echo '<h2>'.get_lang('UserInformationOfThisCourse').'</h2>';
echo '<br />';
echo '<table class="table" width="100%">';
echo '<tr>';
echo '<td width="50%" valign="top">';
if ($origin_session_id == 0) {
echo '<h4>'.get_lang('OriginCourse').'</h4>';
} else {
echo '<h4>'.get_lang('OriginSession').' #'.$origin_session_id.'</h4>';
}
self::compareUserData($result_message);
echo '</td>';
echo '<td width="50%" valign="top">';
if ($new_session_id == 0) {
echo '<h4>'.get_lang('DestinyCourse').'</h4>';
} else {
echo '<h4>'.get_lang('DestinySession').' #'.$new_session_id.'</h4>';
}
self::compareUserData($result_message_compare);
echo '</td>';
echo '</tr>';
echo '</table>';
}
}
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 '<br / ><h3>'.get_lang($title).' </h3><hr />';
if (is_array($data)) {
foreach ($data as $id => $item) {
if ($table === 'TRACK_E_EXERCISES' || $table === 'TRACK_E_EXERCISES_IN_LP') {
echo "<br /><h3>".get_lang('Attempt')." #$id</h3>";
echo '<h3>';
echo get_lang('Exercise').' #'.$item['exe_exo_id'];
echo '</h3>';
if (!empty($item['orig_lp_id'])) {
echo '<h3>';
echo get_lang('LearningPath').' #'.$item['orig_lp_id'];
echo '</h3>';
}
// 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 <br />";
}
}
} else {
echo "<br /><h3>".get_lang('Id')." #$id</h3>";
// process data
foreach ($item as $key => $value) {
echo "$key = $value <br />";
}
}
}
} else {
echo get_lang('NoResults');
}
}
}
}
/**

Write Preview
Loading…
Cancel
Save