[3bf09ba] | 1 | <?php |
---|
[15acccd] | 2 | // Fichero con funciones para trabajar con el webservice |
---|
[3bf09ba] | 3 | include_once("../../includes/restfunctions.php"); |
---|
[15acccd] | 4 | |
---|
| 5 | /** |
---|
| 6 | En este punto disponemos de tres variables indicando las ips, las macs y las ids de los |
---|
| 7 | ordenadores, este script obtiene cual es el repositorio |
---|
| 8 | $cadenaid |
---|
| 9 | $cadenaip |
---|
| 10 | $cadenamac |
---|
| 11 | |
---|
| 12 | */ |
---|
| 13 | // Capturamos todas las ids |
---|
| 14 | $macs = explode(";",$cadenamac); |
---|
| 15 | // Recorremos las ids y vemos cual es la ip del repositorio |
---|
| 16 | $repos = array(); |
---|
| 17 | $reposAndMacs = array(); |
---|
| 18 | foreach($macs as $mac){ |
---|
| 19 | $cmd->texto="SELECT repo.ip, repo.apikey FROM ordenadores o,repositorios repo WHERE o.mac=\"".$mac."\" AND o.idrepositorio=repo.idrepositorio"; |
---|
| 20 | $rs=new Recordset; |
---|
| 21 | $rs->Comando=&$cmd; |
---|
| 22 | if (!$rs->Abrir()) |
---|
| 23 | return; // Error al abrir recordset |
---|
| 24 | while (!$rs->EOF){ |
---|
| 25 | $repo = $rs->campos["ip"]; |
---|
| 26 | if(!existREPO($repo, $repos)){ |
---|
| 27 | $repos[count($repos)]=$repo; |
---|
| 28 | } |
---|
| 29 | // Una vez creado el repo se asigna la mac del pc a su lista |
---|
| 30 | if(empty($reposAndMacs[$repo])){ |
---|
| 31 | $reposAndMacs[$repo] = array(); |
---|
| 32 | $reposAndMacs[$repo]["apikey"] = $rs->campos["apikey"]; |
---|
| 33 | } |
---|
| 34 | // Modificar la mac añadiendo ":" cada dos caracteres |
---|
| 35 | $tmp = substr_replace($mac, ":", 2, 0); |
---|
| 36 | $tmp = substr_replace($tmp, ":", 5, 0); |
---|
| 37 | $tmp = substr_replace($tmp, ":", 8, 0); |
---|
| 38 | $tmp = substr_replace($tmp, ":", 11, 0); |
---|
| 39 | $tmp = substr_replace($tmp, ":", 14, 0); |
---|
| 40 | |
---|
| 41 | $reposAndMacs[$repo][count($reposAndMacs[$repo])] = $tmp; |
---|
| 42 | $rs->Siguiente(); |
---|
| 43 | } |
---|
| 44 | $rs->Cerrar(); |
---|
| 45 | } |
---|
| 46 | // En este punto tenemos un array con todos los repos y cada uno de ellos con una lista de todas las macs que deben arrancar |
---|
| 47 | // Recorremos cada uno de ellos |
---|
| 48 | foreach($reposAndMacs as $repo => $macs){ |
---|
| 49 | // En el array de $macs tenemos la clave "apikey" |
---|
| 50 | if($macs["apikey"] !== ""){ |
---|
| 51 | $apiKeyRepo = $macs["apikey"]; |
---|
| 52 | unset($macs["apikey"]); |
---|
[3bf09ba] | 53 | // Componer datos de conexión para el repositorio. |
---|
| 54 | $urls[$repo]['url'] = "https://$repo/opengnsys/rest/repository/poweron"; |
---|
| 55 | $urls[$repo]['header'] = array('Authorization: '. $apiKeyRepo); |
---|
| 56 | $urls[$repo]['post'] = '{"macs": ["' . implode('","', $macs) . '"]}'; |
---|
[15acccd] | 57 | } |
---|
| 58 | else{ |
---|
[3bf09ba] | 59 | $avisoRepo = true; |
---|
[15acccd] | 60 | } |
---|
| 61 | } |
---|
[3bf09ba] | 62 | // Enviar petición múltiple a los repositorios afectados. |
---|
| 63 | if (isset($urls)) { |
---|
| 64 | $result = multiRequest($urls); |
---|
| 65 | // Comprobar respuesta. |
---|
| 66 | foreach ($result as $repo => $res) { |
---|
| 67 | if ($res['code'] != 200) { |
---|
| 68 | $avisoRepo = true; |
---|
| 69 | } |
---|
| 70 | } |
---|
| 71 | } |
---|
| 72 | |
---|
[15acccd] | 73 | |
---|
| 74 | function existREPO($repo, $repos){ |
---|
| 75 | $found=false; |
---|
| 76 | $index = 0; |
---|
| 77 | while(!$found && $index < count($repos)){ |
---|
| 78 | $r = $repos[$index]; |
---|
| 79 | if($r == $repo) |
---|
| 80 | $found=true; |
---|
| 81 | } |
---|
| 82 | return $found; |
---|
| 83 | } |
---|
| 84 | |
---|
[b6ec162] | 85 | |
---|