migration.custom.class.php 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298
  1. <?php
  2. /**
  3. * This file contains the MigrationCustom class, which defines methods to
  4. * alter the data from the original database when importing it to the Chamilo
  5. * database
  6. */
  7. /**
  8. * The custom migration class allows you to define rules to process data
  9. * during the migration
  10. */
  11. class MigrationCustom {
  12. /**
  13. * The only required method is the 'none' method, which will not trigger
  14. * any process at all
  15. * @param mixed Data
  16. * @param mixed Unaltered data
  17. */
  18. public function none($data) {
  19. return $data;
  20. }
  21. public function join_horario($data, &$omigrate, $row_data) {
  22. return $row_data['chrHoraInicial'].' '.$row_data['chrHoraFinal'];
  23. }
  24. /**
  25. * Transform the uid identifiers from MSSQL to a string
  26. * @param string Field name
  27. * @return string SQL select string to include in the final select
  28. */
  29. public function sql_alter_unhash_50($field) {
  30. $as_field = explode('.', $field);
  31. if (isset($as_field[1])) {
  32. $as_field = $as_field[1];
  33. } else {
  34. $as_field = $field;
  35. }
  36. return " cast( $field as varchar(50)) as $as_field ";
  37. }
  38. /**
  39. * Log data from the original users table
  40. */
  41. public function log_original_user_unique_id($data, &$omigrate, $row_data) {
  42. $omigrate['users_alumno'][$row_data['uidIdAlumno']] = $row_data;
  43. return $data;
  44. }
  45. public function clean_utf8($value) {
  46. return utf8_encode($value);
  47. }
  48. public function clean_session_name($value, &$omigrate, $row_data) {
  49. return self::clean_utf8($row_data['session_name']);
  50. }
  51. public function log_original_persona_unique_id($data, &$omigrate, $row_data) {
  52. if (isset($omigrate['users_persona'][$row_data['uidIdPersona']])) {
  53. $omigrate['users_persona'][$row_data['uidIdPersona']][] = $omigrate['users_persona'][$row_data['uidIdPersona']];
  54. $omigrate['users_persona'][$row_data['uidIdPersona']][] = $row_data;
  55. //error_log(print_r($row_data, 1));
  56. //error_log(print_r($omigrate['users_persona'][$row_data['uidIdPersona']], 1));
  57. error_log('WHAT??');
  58. } else {
  59. $omigrate['users_persona'][$row_data['uidIdPersona']] = $row_data;
  60. }
  61. return $data;
  62. }
  63. public function log_original_teacher_unique_id($data, &$omigrate, $row_data) {
  64. $omigrate['users_empleado'][$row_data['uidIdEmpleado']] = $row_data;
  65. return $row_data['uidIdEmpleado'];
  66. }
  67. /**
  68. * Log data from the original users table
  69. */
  70. public function log_original_course_unique_id($data, &$omigrate) {
  71. $omigrate['courses'][$data] = 0;
  72. return $data;
  73. }
  74. /**
  75. * Log data from the original users table
  76. */
  77. public function log_original_session_unique_id($data, &$omigrate, $row_data) {
  78. $omigrate['sessions'][$row_data['uidIdPrograma']] = $row_data;
  79. return $data;
  80. }
  81. public function get_real_course_code($data, &$omigrate, $row_data) {
  82. if (!isset($omigrate['courses'][$data])) {
  83. error_log("Course not found in data_list array");
  84. error_log(print_r($data, 1));
  85. //exit;
  86. }
  87. return $omigrate['courses'][$data]['code'];
  88. }
  89. function get_session_id_by_programa_id($data, &$omigrate, $row_data) {
  90. /*error_log(print_r($data, 1));
  91. error_log(print_r($row_data, 1));
  92. error_log($omigrate['sessions'][$data]);*/
  93. if (!isset($omigrate['sessions'][$data])) {
  94. error_log(print_r($omigrate['sessions'], 1));
  95. error_log("Sessions not found in data_list array ");
  96. exit;
  97. }
  98. return $omigrate['sessions'][$data];
  99. }
  100. public function get_user_id($data, &$omigrate, $row_data) {
  101. //error_log('get_real_teacher_id');
  102. //error_log(print_r($data, 1));
  103. //error_log(print_r($omigrate['users_empleado'], 1));
  104. //error_log('get_real_teacher_id');
  105. //error_log($data);
  106. if (empty($omigrate['users_alumno'][$data])) {
  107. //error_log('not set');
  108. return 1;
  109. } else {
  110. $persona_id = $omigrate['users_alumno'][$data]['uidIdPersona'];
  111. if (!empty($persona_id)) {
  112. return $omigrate['users_persona'][$persona_id]['user_id'];
  113. }
  114. }
  115. return $omigrate['users_alumno'][$data]['user_id'];
  116. }
  117. public function get_real_teacher_id($data, &$omigrate, $row_data) {
  118. $default_teacher_id = 1;
  119. //error_log('get_real_teacher_id');
  120. //error_log(print_r($data, 1));
  121. //error_log(print_r($omigrate['users_empleado'], 1));
  122. //error_log('get_real_teacher_id');
  123. //error_log($data);
  124. if (empty($data)) {
  125. //error_log('No teacher provided');
  126. return $default_teacher_id;
  127. }
  128. if (!isset($omigrate['users_empleado'][$data])) {
  129. //error_log(' Teacher not found big problem! ');
  130. //echo $data;
  131. //print_r($omigrate['users_empleado'][$data]);
  132. //echo $data;exit;
  133. return $default_teacher_id;
  134. } else {
  135. //error_log('Teacher found: '.$omigrate['users_empleado'][$data]['extra']['user_id']);
  136. return isset($omigrate['users_empleado'][$data]['extra']) ? $omigrate['users_empleado'][$data]['extra']['user_id'] : $default_teacher_id;
  137. }
  138. }
  139. public function create_user($data, $omigrate) {
  140. //error_log(print_r($data, 1));
  141. if (empty($data['uidIdPersona'])) {
  142. error_log('User does not have a uidIdPersona');
  143. error_log(print_r($data, 1));
  144. exit;
  145. }
  146. //Is a teacher
  147. if (isset($omigrate['users_empleado'][$data['uidIdEmpleado']])) {
  148. //error_log(print_r($omigrate['users_empleado'][$data['uidIdPersona']], 1));
  149. //error_log(print_r($data, 1));
  150. //error_log('teacher');
  151. //$data['username'] = UserManager::create_unique_username($data['firstname'], $data['lastname']);
  152. $data['status'] = COURSEMANAGER;
  153. }
  154. //Is a student
  155. if (isset($omigrate['users_alumno'][$data['uidIdAlumno']])) {
  156. $data['status'] = STUDENT;
  157. }
  158. if (!isset($data['username']) || empty($data['username'])) {
  159. $data['firstname'] = (string) trim($data['firstname']);
  160. $data['lastname'] = (string) trim($data['lastname']);
  161. if (empty($data['firstname']) && empty($data['lastname'])) {
  162. $wanted_user_name = UserManager::purify_username($data['uidIdPersona']);
  163. //$wanted_user_name = UserManager::create_unique_username(null, null);
  164. } else {
  165. $wanted_user_name = UserManager::create_username($data['firstname'], $data['lastname']);
  166. }
  167. $extra_data = UserManager::get_extra_user_data_by_value('uidIdPersona', $data['uidIdPersona']);
  168. if ($extra_data) {
  169. $user_info = api_get_user_info($extra_data[0]);
  170. //print_r($extra_data);
  171. //error_log("User_already_added - {$user_info['user_id']} - {$user_info['username']} - {$user_info['firstname']} - {$user_info['lastname']}");
  172. return $user_info;
  173. }
  174. if (UserManager::is_username_available($wanted_user_name)) {
  175. $data['username'] = $wanted_user_name;
  176. error_log("username available $wanted_user_name");
  177. } else {
  178. //the user already exists?
  179. $user_info = UserManager::get_user_info_simple($wanted_user_name);
  180. $user_persona = UserManager::get_extra_user_data_by_field($user_info['user_id'], 'uidIdPersona');
  181. if (isset($user_persona['uidIdPersona']) && $data['uidIdPersona'] == $user_persona['uidIdPersona']) {
  182. error_log("Skip user already added: {$user_info['username']}");
  183. return $user_info;
  184. } else {
  185. error_log("homonym - wanted_username: $wanted_user_name - uidIdPersona: {$user_persona['uidIdPersona']} - username: {$user_info['username']}");
  186. print_r($data);
  187. //The user has the same firstname and lastname but it has another uiIdPersona could by an homonym
  188. $data['username'] = UserManager::create_unique_username($data['firstname'], $data['lastname']);
  189. error_log("homonym username created ". $data['username']);
  190. }
  191. }
  192. if (empty($data['username'])) {
  193. //Last chance to have a nice username
  194. if (empty($data['firstname']) && empty($data['lastname'])) {
  195. $data['username'] = UserManager::create_unique_username(uniqid());
  196. error_log("username empty 1". $data['username']);
  197. } else {
  198. $data['username'] = UserManager::create_unique_username($data['firstname'], $data['lastname']);
  199. error_log("username empty 2". $data['username']);
  200. }
  201. }
  202. } else {
  203. if (UserManager::is_username_available($data['username'])) {
  204. //error_log("username available {$data['username']} ");
  205. } else {
  206. //the user already exists?
  207. $user_info = UserManager::get_user_info_simple($data['username']);
  208. $user_persona = UserManager::get_extra_user_data_by_field($user_info['user_id'], 'uidIdPersona');
  209. if (isset($user_persona['uidIdPersona']) && (string)$data['uidIdPersona'] == (string)$user_persona['uidIdPersona']) {
  210. //error_log("2 Skip user already added: {$user_info['username']}");
  211. return $user_info;
  212. } else {
  213. //print_r($user_persona);
  214. //error_log("2 homonym - wanted_username: {$data['username']} - uidIdPersona: {$user_persona['uidIdPersona']} - username: {$user_info['username']}");
  215. //print_r($data);
  216. //The user has the same firstname and lastname but it has another uiIdPersona could by an homonym
  217. $data['username'] = UserManager::create_unique_username($data['firstname'], $data['lastname']);
  218. //error_log("2 homonym username created ". $data['username']);
  219. }
  220. }
  221. }
  222. if (empty($data['username'])) {
  223. error_log('No Username provided');
  224. error_log(print_r($data, 1));
  225. exit;
  226. }
  227. unset($data['uidIdPersona']);
  228. unset($data['uidIdAlumno']);
  229. unset($data['uidIdEmpleado']);
  230. global $api_failureList;
  231. $api_failureList = array();
  232. //error_log(print_r($data, 1));
  233. $user_info = UserManager::add($data);
  234. if (!$user_info) {
  235. echo 'error';
  236. }
  237. return $user_info;
  238. }
  239. public function create_course($data) {
  240. //Fixes wrong wanted codes
  241. $data['wanted_code'] = str_replace(array('-', '_'), '000', $data['wanted_code']);
  242. return CourseManager::create_course($data);
  243. }
  244. public function create_session($data) {
  245. $session_id = SessionManager::add($data);
  246. if (!$session_id) {
  247. print_r($data);
  248. exit;
  249. }
  250. return $session_id;
  251. }
  252. public function add_user_to_session($data, $data_list) {
  253. error_log('add_user_to_session');
  254. if (!empty($data['session_id']) && !empty($data['user_id'])) {
  255. SessionManager::suscribe_users_to_session($data['session_id'], array($data['user_id']));
  256. } else {
  257. error_log('missing data');
  258. error_log(print_r($data, 1));
  259. exit;
  260. }
  261. }
  262. }