NxTIC/build/api/module/input.php

787 lines
23 KiB
PHP

<?php
namespace api\module;
use \manager\sessionManager;
use \database\core\DatabaseDriver;
use \manager\ManagerError;
use \api\core\ModuleRequest;
use \database\core\Repo;
use \lightdb\core\lightdb;
class input{
/* TRAITE LES DONNÉES D'UN FORMULAIRE DE TYPE TÉLÉPHONIQUE
*
* @subject<Array> Tableau contenant les données du sujet
* @contacts<Array> Tableau contenant les données des contacts
* @mini<Array> Tableau contenant les données des mini fiches relation
* @fiches<Array> Tableau contenant les données des fiches relation
*
* @return subject_id<int> Retourne l'id sujet de l'enquête
*
*/
public static function phone($params){
extract($params);
/* [0] On récupère l'id unique actuel
=========================================================*/
$funiq = fopen( __BUILD__.'/lightdb/storage/uniqid', 'r+' );
flock($funiq, LOCK_EX); // On verrouille le fichier
$uniqid = fgets( $funiq );
if( !is_numeric($uniqid) )
$uniqid = 0;
// Décalage à appliquer à tous les ids
$offset = intval($uniqid) + 1;
// on enregistre l'id du sujet
$subject_id = $subject['subject_id'];
// Contiendra la valeur de l'id maximum
$maxId = $offset;
// /* [1] On récupère les logs s'ils existent
// =========================================================*/
// // Contiendra le contenu du fichier
$file = [
"subject" => "",
"contacts" => [],
"relations" => []
];
// $file = [ 'logs' => [] ];
//
//
// /* (1) On définit les 2 fichiers utiles */
// $tmpfile = __BUILD__.'/tmp/phone_'.$subject['tmp_id'].'.json';
//
// /* (2) Si on a déja crée le fichier avec le journal d'appel dedans, on le récupère */
// $storage_already = is_string($subject['tmp_id']) && strlen($subject['tmp_id']) == 40 && file_exists($tmpfile);
//
//
// /* (3) Si on a déja crée le fichier, on essaie de récupérer son contenu */
// if( $storage_already ){
// $file = json_decode( file_get_contents($tmpfile), true );
//
// // erreur
// if( $file == null )
// return [ 'ModuleRequest' => ManagerError::ParsingFailed ];
//
// // On incrémente tous les ids de l'offset
// foreach($file['logs'] as $i=>$log){
// $file['logs'][$i]['id'] = $offset + $log['id'];
//
// if( $log['id'] > $maxId )
// $maxId = (int) $log['id'];
// }
// }
/* [2] On enregistre les données du sujet
=========================================================*/
/* (1) On crée le sujet */
$file['subject'] = [ 'id' => $subject_id ];
/* (2) On récupère ses contacts facebook */
// {2.1} On récupère les données du sujet //
$lfacebook = new lightdb('facebook_db');
$lfacebook = $lfacebook->fetch($subject_id);
// {2.2} si n'existe pas, on a un tableau vide //
if( $lfacebook === false )
$lfacebook = [ 'contacts' => [] ];
if( !isset($lfacebook['contacts']) )
$lfacebook['contacts'] = [];
/* (3) On récupère ses contacts lab-surveys */
// {3.1} On récupère les données du sujet //
$lsurvey = new lightdb('survey_db');
$lsurvey = $lsurvey->fetch($subject_id);
// {3.2} si n'existe pas, on a un tableau vide //
if( $lsurvey === false )
$lsurvey = [ 'contacts' => [] ];
if( !isset($lsurvey['contacts']) )
$lsurvey['contacts'] = [];
/* (4) On récupère uniquement la liste des contacts avec le type de fiche qu'ils ont */
// {4.1} Contiendra les contacts exportés //
$exported = [
'fiche' => [],
'mini' => []
];
// {4.2} Contiendra les username des contacts exportés //
$exportedU = [];
// {4.3} On récupère les contacts facebook //
foreach($lfacebook['contacts'] as $c=>$data){
if( isset($data['studies2']) ){
$exported['fiche'][] = $data['id'];
$exportedU[$data['id']] = $data['name'];
}else
// S'il n'est pas déja dans les fiches
if( !in_array($data['id'], $exported['fiche']) ){
$exported['mini'][] = $data['id'];
$exportedU[$data['id']] = $data['name'];
}
}
// {4.4} On récupère les contacts lab-surveys //
foreach($lsurvey['contacts'] as $c=>$data){
if( isset($data['studies2']) )
// On ajoute le contact s'il n'y est pas déja
if( !in_array($data['id'], $exported['fiche']) ){
$exported['fiche'][] = $data['id'];
$exportedU['fiche'][] = $data['username'];
}
else
// On ajoute le contact s'il n'y est pas déja (ni dans mini ni dans fiche)
if( !in_array($data['id'], $exported['mini']) && !in_array($data['id'], $exported['fiche']) ){
$exported['mini'][] = $data['id'];
$exportedU['mini'][] = $data['username'];
}
}
/* [3] On enregistre les contacts des FICHES
=========================================================*/
$contactsDone = [
"existing" => [], // Contacts exportés déja enregistrés
"username" => [] // Nouveaux contacts déja enregistrés
];
foreach($fiches as $f=>$ficheData){
/* (1) On récupère les données du contact associé */
if( !isset($contacts[$ficheData['uid']]) )
break;
$contact = $contacts[ $ficheData['uid'] ];
/* (2) Si le contact a été importé d'une autre enquête */
if( isset($contact['existing']) && is_numeric($contact['existing']) ){
$newId = (int) $contact['existing'];
$uname = $exportedU[intval($contact['existing'])];
// {2.1} S'il a déja une fiche ou qu'on a déja fait une fiche, on quitte //
if( in_array(intval($contact['existing']), $exported['fiche']) || in_array($contact['existing'], $contactsDone['existing']) )
break;
/* (3) Si nouveau contact */
}else{
$newId = (int) ($offset+$ficheData['uid']);
$uname = $contact['username'];
// {3.1} S'il a déja été saisi, on quitte //
if( in_array($contact['username'], $contactsDone['username']) )
break;
}
/* (4) Update du @maxId */
if( $newId > $maxId )
$maxId = (int) $newId;
// On remplit les données qui iront dans le fichier pour ce contact
$file['contacts'][] = [
'id' => $newId,
'name' => $uname,
'sexe' => $ficheData['sexe'],
'age' => $ficheData['age'],
'studies2' => $ficheData['studies'],
'reltype' => ($ficheData['reltype']==10) ? $ficheData['reltypeSpecial'] : $ficheData['reltype'], // si 'autre' -> valeur, sinon le code
'dist' => $ficheData['loc'],
'job' => $ficheData['job'],
'famsit' => $ficheData['famsit'],
'city' => $ficheData['city'],
'cp' => $ficheData['cp'],
'quartier' => $ficheData['quartier'],
'duration' => $ficheData['duration'],
'context' => $ficheData['context'],
'contextExtra' => $ficheData['contextSpecial'],
'freq' => $ficheData['freq'],
'connect' => $ficheData['connect'],
'connectExtra' => $ficheData['connectSpecial']
];
// On enregistre la relation avec EGO
$file['relations'][] = [
'idA' => $subject_id,
'idB' => $newId,
'type' => ($f<20) ? 4 : 5 // 4->appels 5->sms
];
/* (x) Si le contact a été importé d'une autre enquête */
if( isset($contact['existing']) && is_numeric($contact['existing']) )
$contactsDone['existing'][] = $contact['existing'];
/* (x+1) Si nouveau contact */
else
$contactsDone['username'][] = $contact['username'];
}
/* [4] On enregistre les contacts des MINI
=========================================================*/
foreach($mini as $miniData){
/* (1) On récupère les données du contact associé */
if( !isset($contacts[$miniData['uid']]) )
break;
$contact = $contacts[ $miniData['uid'] ];
/* (2) Si le contact a été importé d'une autre enquête */
if( isset($contact['existing']) && is_numeric($contact['existing']) ){
$newId = (int) $contact['existing'];
$uname = $exportedU[intval($contact['existing'])];
// {2.1} S'il a déja une fiche ou qu'on a déja fait une fiche (ou mini), on quitte //
if( in_array(intval($contact['existing']), $exported['fiche']) || in_array($contact['existing'], $contactsDone['existing']) )
break;
/* (3) Si nouveau contact */
}else{
$newId = (int) ($offset+$miniData['uid']);
$uname = $contact['username'];
// {3.1} S'il a déja été saisi, on quitte //
if( in_array($contact['username'], $contactsDone['username']) )
break;
}
/* (4) Update du @maxId */
if( $newId > $maxId )
$maxId = (int) $newId;
// On remplit les données qui iront dans le fichier pour ce contact
$file['contacts'][] = [
'id' => $newId,
'name' => $uname,
'sexe' => $miniData['sexe'],
'age' => $miniData['age'],
'studies1' => $miniData['studies'],
'reltype' => ($miniData['reltype']==10) ? $miniData['reltypeSpecial'] : $miniData['reltype'], // si 'autre' -> valeur, sinon le code
'dist' => $miniData['loc']
];
// On enregistre la relation avec EGO
$file['relations'][] = [
'idA' => $subject_id,
'idB' => $newId,
'type' => 2 // relation cellulaire mineure
];
/* (x) Si le contact a été importé d'une autre enquête */
if( isset($contact['existing']) && is_numeric($contact['existing']) )
$contactsDone['existing'][] = $contact['existing'];
/* (x+1) Si nouveau contact */
else
$contactsDone['username'][] = $contact['username'];
}
/* [5] On enregistre les relations de la MATRICE
=========================================================*/
$clen = count($file['contacts']);
/* (1) On récupére les ids des contacts */
$cIdList = [];
foreach($file['contacts'] as $c=>$contact){
$id = $contact['id'] - $offset;
if( !in_array($id, $cIdList) )
$cIdList[$id] = null;
}
ksort($cIdList);
/* (2) On remplit les relations */
foreach($cIdList as $y=>$yNull){
foreach($cIdList as $x=>$xNull)
if( $x < $y ){ // On affiche que sous la diagonale
$idY = $file['contacts'][$y]['id'] - $offset;
$idX = $file['contacts'][$x]['id'] - $offset;
// Si relation alter-alter
$relationXY = isset($matrice[$y]) && in_array($x, $matrice[$y])
|| ( isset($matrice[$x]) && in_array($y, $matrice[$x]) );
array_push($file['relations'], [
'idA' => $offset + $x,
'idB' => $offset + $y,
'type' => $relationXY ? 1 : 0 // 0->aucune relation 1->relation alter alter
]);
}
}
/* [6] On enregistre tout dans 'lightdb'
=========================================================*/
$db = new lightdb('phone_db');
$db->insert( $subject_id, $file );
$db->close();
/* [7] On met à jour le nouvel ID unique
=========================================================*/
// $maxId += $offset;
rewind($funiq); // On revient au début du fichier
fwrite($funiq, $maxId); // On écrit la nouvelle valeur (forcément plus grande)
flock($funiq, LOCK_UN); // On débloque le verrou
fclose($funiq);
// /* [8] On supprime le fichier temporaire si existe
// =========================================================*/
// if( file_exists($tmpfile) )
// unlink($tmpfile);
/* [9] Gestion du retour
=========================================================*/
return [
'ModuleError' => ManagerError::Success,
'subject_id' => $subject_id
];
}
/* TRAITE LES DONNÉES D'UN FORMULAIRE DE TYPE FACEBOOK
*
* @subject<Array> Tableau contenant les données du sujet
* @contacts<Array> Tableau contenant les données des contacts
* @mini<Array> Tableau contenant les données des mini fiches relation
* @fiches<Array> Tableau contenant les données des fiches relation
*
* @return subject_id<int> Retourne l'id sujet de l'enquête
*
*/
public static function facebook($params){
extract($params);
/* [0] On récupère l'id unique actuel
=========================================================*/
$funiq = fopen( __BUILD__.'/lightdb/storage/uniqid', 'r+' );
flock($funiq, LOCK_EX); // On verrouille le fichier
$uniqid = fgets( $funiq );
if( !is_numeric($uniqid) )
$uniqid = 0;
// Décalage à appliquer à tous les ids
$offset = intval($uniqid) + 1;
// on enregistre l'id du sujet
$subject_id = $subject['subject_id'];
// Contiendra la valeur de l'id maximum
$maxId = $offset;
// /* [1] On récupère les logs s'ils existent
// =========================================================*/
// // Contiendra le contenu du fichier
$file = [
"subject" => "",
"contacts" => [],
"relations" => []
];
// $file = [ 'logs' => [] ];
//
//
// /* (1) On définit les 2 fichiers utiles */
// $tmpfile = __BUILD__.'/tmp/phone_'.$subject['tmp_id'].'.json';
//
// /* (2) Si on a déja crée le fichier avec le journal d'appel dedans, on le récupère */
// $storage_already = is_string($subject['tmp_id']) && strlen($subject['tmp_id']) == 40 && file_exists($tmpfile);
//
//
// /* (3) Si on a déja crée le fichier, on essaie de récupérer son contenu */
// if( $storage_already ){
// $file = json_decode( file_get_contents($tmpfile), true );
//
// // erreur
// if( $file == null )
// return [ 'ModuleRequest' => ManagerError::ParsingFailed ];
//
// // On incrémente tous les ids de l'offset
// foreach($file['logs'] as $i=>$log){
// $file['logs'][$i]['id'] = $offset + $log['id'];
//
// if( $log['id'] > $maxId )
// $maxId = (int) $log['id'];
// }
// }
/* [2] On enregistre les données du sujet
=========================================================*/
/* (1) On crée le sujet */
$file['subject'] = [ 'id' => $subject_id ];
/* (2) On récupère ses contacts phone */
// {2.1} On récupère les données du sujet //
$lphone = new lightdb('phone_db');
$lphone = $lphone->fetch($subject_id);
// {2.2} si n'existe pas, on a un tableau vide //
if( $lphone === false )
$lphone = [ 'contacts' => [] ];
if( !isset($lphone['contacts']) )
$lphone['contacts'] = [];
/* (3) On récupère ses contacts lab-surveys */
// {3.1} On récupère les données du sujet //
$lsurvey = new lightdb('survey_db');
$lsurvey = $lsurvey->fetch($subject_id);
// {3.2} si n'existe pas, on a un tableau vide //
if( $lsurvey === false )
$lsurvey = [ 'contacts' => [] ];
if( !isset($lsurvey['contacts']) )
$lsurvey['contacts'] = [];
/* (4) On récupère uniquement la liste des contacts avec le type de fiche qu'ils ont */
// {4.1} Contiendra les contacts exportés //
$exported = [
'fiche' => [],
'mini' => []
];
// {4.2} Contiendra les username des contacts exportés //
$exportedU = [];
// {4.3} On récupère les contacts facebook //
foreach($lphone['contacts'] as $c=>$data){
if( isset($data['studies2']) ){
$exported['fiche'][] = $data['id'];
$exportedU[$data['id']] = $data['name'];
}else
// S'il n'est pas déja dans les fiches
if( !in_array($data['id'], $exported['fiche']) ){
$exported['mini'][] = $data['id'];
$exportedU[$data['id']] = $data['name'];
}
}
// {4.4} On récupère les contacts lab-surveys //
foreach($lsurvey['contacts'] as $c=>$data){
if( isset($data['studies2']) )
// On ajoute le contact s'il n'y est pas déja
if( !in_array($data['id'], $exported['fiche']) ){
$exported['fiche'][] = $data['id'];
$exportedU['fiche'][] = $data['username'];
}
else
// On ajoute le contact s'il n'y est pas déja (ni dans mini ni dans fiche)
if( !in_array($data['id'], $exported['mini']) && !in_array($data['id'], $exported['fiche']) ){
$exported['mini'][] = $data['id'];
$exportedU['mini'][] = $data['username'];
}
}
/* [3] On enregistre les contacts des FICHES
=========================================================*/
$contactsDone = [
"existing" => [], // Contacts exportés déja enregistrés
"username" => [] // Nouveaux contacts déja enregistrés
];
foreach($fiches as $f=>$ficheData){
/* (1) On récupère les données du contact associé */
if( !isset($contacts[$ficheData['uid']]) )
continue;
$contact = $contacts[ $ficheData['uid'] ];
/* (2) Si le contact a été importé d'une autre enquête */
if( isset($contact['existing']) && is_numeric($contact['existing']) ){
$newId = (int) $contact['existing'];
$uname = $exportedU[intval($contact['existing'])];
// {2.1} S'il a déja une fiche ou qu'on a déja fait une fiche, on quitte //
if( in_array(intval($contact['existing']), $exported['fiche']) || in_array($contact['existing'], $contactsDone['existing']) )
continue;
/* (3) Si nouveau contact */
}else{
$newId = (int) ($offset+$ficheData['uid']);
$uname = $contact['username'];
// {3.1} S'il a déja été saisi, on quitte //
if( in_array($contact['username'], $contactsDone['username']) )
continue;
}
/* (4) Update du @maxId */
if( $newId > $maxId )
$maxId = (int) $newId;
// On remplit les données qui iront dans le fichier pour ce contact
$file['contacts'][] = [
'id' => $newId,
'name' => $uname,
'sexe' => $ficheData['sexe'],
'age' => $ficheData['age'],
'studies2' => $ficheData['studies'],
'reltype' => ($ficheData['reltype']==10) ? $ficheData['reltypeSpecial'] : $ficheData['reltype'], // si 'autre' -> valeur, sinon le code
'dist' => $ficheData['loc'],
'job' => $ficheData['job'],
'famsit' => $ficheData['famsit'],
'city' => $ficheData['city'],
'cp' => $ficheData['cp'],
'quartier' => $ficheData['quartier'],
'duration' => $ficheData['duration'],
'context' => $ficheData['context'],
'contextExtra' => $ficheData['contextSpecial'],
'freq' => $ficheData['freq'],
'connect' => $ficheData['connect'],
'connectExtra' => $ficheData['connectSpecial']
];
// On enregistre la relation avec EGO
$file['relations'][] = [
'idA' => $subject_id,
'idB' => $newId,
'type' => ($f<20) ? 4 : 5 // 4->appels 5->sms
];
/* (x) Si le contact a été importé d'une autre enquête */
if( isset($contact['existing']) && is_numeric($contact['existing']) )
$contactsDone['existing'][] = $contact['existing'];
/* (x+1) Si nouveau contact */
else
$contactsDone['username'][] = $contact['username'];
}
/* [4] On enregistre les contacts des MINI
=========================================================*/
foreach($mini as $miniData){
/* (1) On récupère les données du contact associé */
if( !isset($contacts[$miniData['uid']]) )
continue;
$contact = $contacts[ $miniData['uid'] ];
/* (2) Si le contact a été importé d'une autre enquête */
if( isset($contact['existing']) && is_numeric($contact['existing']) ){
$newId = (int) $contact['existing'];
$uname = $exportedU[intval($contact['existing'])];
// {2.1} S'il a déja une fiche ou qu'on a déja fait une fiche (ou mini), on quitte //
if( in_array(intval($contact['existing']), $exported['fiche']) || in_array($contact['existing'], $contactsDone['existing']) )
continue;
/* (3) Si nouveau contact */
}else{
$newId = (int) ($offset+$miniData['uid']);
$uname = $contact['username'];
// {3.1} S'il a déja été saisi, on quitte //
if( in_array($contact['username'], $contactsDone['username']) )
continue;
}
/* (4) Update du @maxId */
if( $newId > $maxId )
$maxId = (int) $newId;
// On remplit les données qui iront dans le fichier pour ce contact
$file['contacts'][] = [
'id' => $newId,
'name' => $uname,
'sexe' => $miniData['sexe'],
'age' => $miniData['age'],
'studies1' => $miniData['studies'],
'reltype' => ($miniData['reltype']==10) ? $miniData['reltypeSpecial'] : $miniData['reltype'], // si 'autre' -> valeur, sinon le code
'dist' => $miniData['loc']
];
// On enregistre la relation avec EGO
$file['relations'][] = [
'idA' => $subject_id,
'idB' => $newId,
'type' => 2 // relation cellulaire mineure
];
/* (x) Si le contact a été importé d'une autre enquête */
if( isset($contact['existing']) && is_numeric($contact['existing']) )
$contactsDone['existing'][] = $contact['existing'];
/* (x+1) Si nouveau contact */
else
$contactsDone['username'][] = $contact['username'];
}
/* [5] On enregistre les relations de la MATRICE
=========================================================*/
$clen = count($file['contacts']);
// var_dump($file['contacts']);
/* (1) On récupére les ids des contacts */
$cIdList = [];
foreach($file['contacts'] as $c=>$contact){
$id = (int) $c;
if( !in_array($id, $cIdList) )
$cIdList[$id] = null;
}
ksort($cIdList);
/* (2) On remplit les relations */
foreach($cIdList as $y=>$yNull){
foreach($cIdList as $x=>$xNull)
if( $x < $y ){ // On affiche que sous la diagonale
$idY = $file['contacts'][$y]['id'] - $offset;
$idX = $file['contacts'][$x]['id'] - $offset;
// Si relation alter-alter
$relationXY = isset($matrice[$y]) && in_array($x, $matrice[$y])
|| ( isset($matrice[$x]) && in_array($y, $matrice[$x]) );
$file['relations'][] = [
'idA' => $offset + $x,
'idB' => $offset + $y,
'type' => $relationXY ? 1 : 0 // 0->aucune relation 1->relation alter alter
];
}
}
/* [6] On enregistre tout dans 'lightdb'
=========================================================*/
$db = new lightdb('facebook_db');
$db->insert( $subject_id, $file );
$db->close();
/* [7] On met à jour le nouvel ID unique
=========================================================*/
// $maxId += $offset;
rewind($funiq); // On revient au début du fichier
fwrite($funiq, $maxId); // On écrit la nouvelle valeur (forcément plus grande)
flock($funiq, LOCK_UN); // On débloque le verrou
fclose($funiq);
// /* [8] On supprime le fichier temporaire si existe
// =========================================================*/
// if( file_exists($tmpfile) )
// unlink($tmpfile);
/* [9] Gestion du retour
=========================================================*/
return [
'ModuleError' => ManagerError::Success,
'subject_id' => $subject_id
];
}
}
?>