ldap_synchro.php 7.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190
  1. <?php //$id: $
  2. /*
  3. ==============================================================================
  4. Dokeos - elearning and course management software
  5. Copyright (c) 2008 Dokeos SPRL
  6. Copyright (c) 2007 Mustapha Alouani (supervised by Michel Moreau-Belliard)
  7. For a full list of contributors, see "credits.txt".
  8. The full license can be read in "license.txt".
  9. This program is free software; you can redistribute it and/or
  10. modify it under the terms of the GNU General Public License
  11. as published by the Free Software Foundation; either version 2
  12. of the License, or (at your option) any later version.
  13. See the GNU General Public License for more details.
  14. Contact: Dokeos, rue du Corbeau, 108, B-1030 Brussels, Belgium, info@dokeos.com
  15. ==============================================================================
  16. */
  17. /**
  18. ==============================================================================
  19. * @package dokeos.admin
  20. ==============================================================================
  21. */
  22. // name of the language file that needs to be included
  23. $language_file='admin';
  24. $cidReset=true;
  25. require('../inc/global.inc.php');
  26. $libpath = api_get_path(LIBRARY_PATH);
  27. require_once($libpath.'formvalidator/FormValidator.class.php');
  28. require_once($libpath.'usermanager.lib.php');
  29. require_once('../auth/ldap/authldap.php');
  30. $annee_base=date('Y');
  31. // setting the section (for the tabs)
  32. $this_section = SECTION_PLATFORM_ADMIN;
  33. //api_protect_admin_script(); // on vire la secu... qui n'a pas lieu d'etre ici (script de synchro)
  34. // setting breadcrumbs
  35. $interbreadcrumb[]=array('url' => 'index.php',"name" => get_lang('PlatformAdmin'));
  36. $interbreadcrumb[]=array('url' => api_get_self(),"name" => "Liste des sessions");
  37. // Database Table Definitions
  38. $tbl_session = Database::get_main_table(TABLE_MAIN_SESSION);
  39. $tbl_session_rel_class = Database::get_main_table(TABLE_MAIN_SESSION_CLASS);
  40. $tbl_session_rel_course = Database::get_main_table(TABLE_MAIN_SESSION_COURSE);
  41. $tbl_session_rel_course_rel_user = Database::get_main_table(TABLE_MAIN_SESSION_COURSE_USER);
  42. $tbl_course = Database::get_main_table(TABLE_MAIN_COURSE);
  43. $tbl_user = Database::get_main_table(TABLE_MAIN_USER);
  44. $tbl_session_rel_user = Database::get_main_table(TABLE_MAIN_SESSION_USER);
  45. $tbl_class = Database::get_main_table(TABLE_MAIN_CLASS);
  46. $tbl_class_user = Database::get_main_table(TABLE_MAIN_CLASS_USER);
  47. $tbl_session_rel_etape = "session_rel_etape";
  48. $message="";
  49. $result=api_sql_query("SELECT id, name FROM $tbl_session",__FILE__,__LINE__);
  50. $Sessions=api_store_result($result);
  51. $result=api_sql_query($sql,__FILE__,__LINE__);
  52. $users=api_store_result($result);
  53. foreach($Sessions as $session){
  54. $id_session = $session['id'];
  55. $name_session = $session['name'];
  56. $UserList=array();
  57. $UserUpdate=array();
  58. $UserAdd=array();
  59. // Parse des code etape de la session
  60. /*
  61. $sql = "SELECT id_session, code_etape, etape_description, code_ufr, annee
  62. FROM $tbl_session_rel_etape
  63. WHERE id_session='$id_session'
  64. ORDER BY code_ufr, code_etape";
  65. $result = api_sql_query($sql);
  66. */
  67. $ds = ldap_connect($ldap_host, $ldap_port) or die(get_lang('LDAPConnectionError'));
  68. ldap_set_version($ds);
  69. // Import des utilisateurs des etapes dans la session
  70. if ($ds)
  71. {
  72. $r = false;
  73. $res = ldap_handle_bind($ds, $r);
  74. $UserList=array();
  75. if($result !== false)
  76. {
  77. //while($row = Database::fetch_array($result))
  78. //{
  79. /*
  80. $annee = $row['annee'];
  81. $code_ufr = $row['code_ufr'];
  82. $etape = $row['code_etape'];
  83. */
  84. // LDAP Query
  85. // edupersonorgunitdn=ou=12CI1,ou=2006,ou=diploma,o=Paris1,dc=univ-paris1,dc=fr
  86. //etapescommented
  87. //$sr = @ ldap_search($ds, "ou=people,$LDAPbasedn", "edupersonorgunitdn=ou=$etape,ou=$annee,ou=diploma,$LDAPbasedn");
  88. $sr = @ ldap_search($ds, $ldap_basedn, '(uid=*)');
  89. $info = ldap_get_entries($ds, $sr);
  90. for ($key = 0; $key < $info["count"]; $key ++)
  91. {
  92. echo "<pre>";
  93. print_r($info[$key]);
  94. echo "</pre>";
  95. $lastname = iconv('utf-8', api_get_setting('platform_charset'), $info[$key]["sn"][0]);
  96. $firstname = iconv('utf-8', api_get_setting('platform_charset'), $info[$key]["givenname"][0]);
  97. $email = $info[$key]["mail"][0];
  98. // Get uid from dn
  99. $dn_array=ldap_explode_dn($info[$key]["dn"],1);
  100. $username = $dn_array[0]; // uid is first key
  101. $outab[] = $info[$key]["edupersonprimaryaffiliation"][0]; // Ici "student"
  102. $val = ldap_get_values_len($ds, $sr, "userPassword");
  103. $password = $val[0];
  104. // Pour faciliter la gestion on ajoute le code "etape-annee"
  105. $official_code=$etape."-".$annee;
  106. $auth_source="ldap";
  107. // Pas de date d'expiration d'etudiant (a recuperer par rapport au shadow expire LDAP)
  108. $expiration_date='0000-00-00 00:00:00';
  109. $active=1;
  110. // Ajout de l'utilisateur
  111. if (UserManager::is_username_available($username))
  112. {
  113. $user_id = UserManager::create_user($firstname,$lastname,$status,$email,$username,$password,$official_code,api_get_setting('platformLanguage'),$phone,$picture_uri,$auth_source,$expiration_date,$active);
  114. $UserAdd[]=$user_id;
  115. }
  116. else
  117. {
  118. $user = UserManager::get_user_info($username);
  119. $user_id=$user['user_id'];
  120. UserManager::update_user($user_id, $firstname, $lastname, $username, null, null, $email, $status, $official_code, $phone, $picture_uri, $expiration_date, $active);
  121. $UserUpdate[]=$user_id;
  122. }
  123. $UserList[]=$user_id;
  124. }
  125. //}
  126. }
  127. if (isset($included) && ($included))
  128. {
  129. $message .= "> $name_session: ".count($UserAdd)." ".get_lang('Added').' '.get_lang('And').' '.count($UserUpdate).' '.get_lang('Modified').'<br/>';
  130. }
  131. else
  132. {
  133. print "> $name_session: ".count($UserAdd).get_lang('Added').' '.get_lang('And').' '.count($UserUpdate).' '.get_lang('Modified')."\n";
  134. }
  135. // Une fois les utilisateurs importer dans la base des utilisateurs, on peux les affecter a� la session
  136. $result=api_sql_query("SELECT course_code FROM $tbl_session_rel_course " .
  137. "WHERE id_session='$id_session'",__FILE__,__LINE__);
  138. $CourseList=array();
  139. while($row=Database::fetch_array($result))
  140. {
  141. $CourseList[]=$row['course_code'];
  142. }
  143. foreach($CourseList as $enreg_course)
  144. {
  145. // On ajoute la relation entre l'utilisateur et le cours
  146. foreach($UserList as $enreg_user)
  147. {
  148. api_sql_query("INSERT IGNORE INTO $tbl_session_rel_course_rel_user(id_session,course_code,id_user) VALUES('$id_session','$enreg_course','$enreg_user')",__FILE__,__LINE__);
  149. }
  150. $sql = "SELECT COUNT(id_user) as nbUsers " .
  151. "FROM $tbl_session_rel_course_rel_user " .
  152. "WHERE id_session='$id_session' AND course_code='$enreg_course'";
  153. $rs = api_sql_query($sql, __FILE__, __LINE__);
  154. list($nbr_users) = Database::fetch_array($rs);
  155. $sql = "UPDATE $tbl_session_rel_course SET nbr_users=$nbr_users WHERE id_session='$id_session' AND course_code='$enreg_course'";
  156. api_sql_query($sql,__FILE__,__LINE__);
  157. }
  158. // On ajoute la relation entre l'utilisateur et la session
  159. foreach($UserList as $enreg_user){
  160. $sql = "INSERT IGNORE INTO $tbl_session_rel_user(id_session, id_user) " .
  161. "VALUES('$id_session','$enreg_user')";
  162. api_sql_query($sql,__FILE__,__LINE__);
  163. }
  164. $sql = "SELECT COUNT(id_user) as nbUsers " .
  165. "FROM $tbl_session_rel_user " .
  166. "WHERE id_session='$id_session'";
  167. $rs = api_sql_query($sql, __FILE__, __LINE__);
  168. list($nbr_users) = Database::fetch_array($rs);
  169. $sql = "UPDATE $tbl_session SET nbr_users=$nbr_users WHERE id='$id_session'";
  170. api_sql_query($sql,__FILE__,__LINE__);
  171. }
  172. }
  173. ?>