NxTIC/build/api/module/input.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);

			/* [1] 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 = intval($subject['subject_id']);

			// Contiendra la valeur de l'id maximum
			$maxId  = $offset;


			/* [2] On initialise nos variables (lightdb + autres)
			=========================================================*/
			/* (1) Fichiers de sortie */
			$file = [
				"subject" => "",
				"relations" => []
			];

			/* (2) Bases de données */
			$subjectdb = new lightdb('subject');
			$contactdb = new lightdb('contact');


			/* [3] Données du sujet
			=========================================================*/
			$subject_set = $subjectdb->fetch($subject_id);

			/* (1) Si le sujet n'existe pas -> ERROR */
			if( $subject_set === false )
				return ['ModuleError'=>ManagerError::UnreachableResource];

			/* (2) Initialisation des contacts si vide */
			if( !isset($subject_set['contacts']) )
				$subject_set['contacts'] = [];

			/* (3) Initialisation des relations si vide */
			if( !isset($subject_set['relations']) )
				$subject_set['relations'] = [];

			/* (4) Ajout de l'enquête */
			if( !in_array('phone', $subject_set['subject']['surveys']) )
				$subject_set['subject']['surveys'][] = 'phone';

			/* (5) On récupère les noms des contacts */
			$contactsById   = []; // idContact  -> nomContact

			foreach($subject_set['contacts'] as $contactId){
				$contactId = intval($contactId);
				$contactData = $contactdb->fetch( $contactId );

				$contactsById[$contactId] = $contactData['name'];
			}


			/* [4] On saisit les fiches + les contacts des fiches
			=========================================================*/
			$contactsDone = [
				"existing" => [], // Contacts exportés déja enregistrés
				"username" => []  // Nouveaux contacts déja enregistrés
			];
			$finalid = []; // id_contact -> id_final_contact (existant ou nouveau)

			foreach($fiches as $f=>$ficheData){

				/* (1) On récupère les données du contact associé */
				if( !isset($contacts[$ficheData['contact']]) )
					continue;


				$contact = $contacts[ $ficheData['contact'] ];

				/* (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 = $contactsById[ intval($contact['existing']) ];

					$existingData = $dbcontact->fetch( intval($contact['existing']) );

					$finalid[ intval($contact['uid']) ] = $newId;

					// S'il a déja une fiche ou qu'on a déja fait une fiche, on quitte
					if( is_array($existingData) && isset($existingData['studies2']) || in_array($contact['existing'], $contactsDone['existing']) )
						continue;

				/* (3) Si nouveau contact */
				}else{

					$newId = (int) ($offset+$contact['uid']);
					$uname = $contact['username'];

					$finalid[ intval($contact['uid']) ] = $newId;

					// 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;

				/* (5) On enregistre les données du contact */
				$contactdb->insert($newId, [
					'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 ajoute le contact dans la liste des contacts du sujet (si pas déja)
				if( !in_array($newId, $subject_set['contacts']) )
					$subject_set['contacts'][] = $newId;

				// On enregistre la relation avec EGO
				$subject_set['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'];
			}


			/* [5] On enregistre les mini + les contacts des mini
			=========================================================*/
			foreach($mini as $miniData){

				/* (1) On récupère les données du contact associé */
				if( !isset($contacts[$miniData['contact']]) )
					continue;

				$contact = $contacts[ $miniData['contact'] ];

				/* (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 = $contactsById[ intval($contact['existing']) ];

					$existingData = $dbcontact->fetch( intval($contact['existing']) );

					$finalid[ intval($contact['uid']) ] = $newId;

					// S'il a déja une fiche ou qu'on a déja fait une fiche (ou mini), on quitte
					if( is_array($existingData) && isset($existingData['studies2']) || in_array($contact['existing'], $contactsDone['existing']) )
						continue;

				/* (3) Si nouveau contact */
				}else{

					$newId = (int) ($offset+$contact['uid']);
					$uname = $contact['username'];

					$finalid[ intval($contact['uid']) ] = $newId;

					// 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
				$contactdb->insert($newId, [
					'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 ajoute le contact dans la liste des contacts du sujet (si pas déja)
				if( !in_array($newId, $subject_set['contacts']) )
					$subject_set['contacts'][] = $newId;

				// On enregistre la relation avec EGO
				$subject_set['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'];

			}


			/* [6] On enregistre les relations de la MATRICE
			=========================================================*/
			var_dump('finalid\'s', $finalid);
			$clen = count($finalid);

			/* (1) On récupére les ids des contacts */
			$cIdList = [];
			foreach($finalid as $lastid=>$newid){
				$id = (int) $lastid;

				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

						// Si relation alter-alter
						$relationXY = isset($matrice[$y]) && in_array($x, $matrice[$y])
								|| (  isset($matrice[$x]) && in_array($y, $matrice[$x]) );

						$subject_set['relations'][] = [
							'idA'  => $finalid[$x],
							'idB'  => $finalid[$y],
							'type' => $relationXY ? 1 : 0 // 0->aucune relation     1->relation alter alter
						];

					}
			}


			/* [6] On les données du sujet
			=========================================================*/
			$subjectdb->delete($subject_id);
			$subjectdb->insert($subject_id, $subject_set);


			/* [7] Ferme les bases de données
			=========================================================*/
			$subjectdb->close();
			$contactdb->close();


			/* [7] On met à jour le nouvel ID unique
			=========================================================*/
			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);


			/* [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);

			/* [1] 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 = intval($subject['subject_id']);

			// Contiendra la valeur de l'id maximum
			$maxId  = $offset;


			/* [2] On initialise nos variables (lightdb + autres)
			=========================================================*/
			/* (1) Fichiers de sortie */
			$file = [
				"subject" => "",
				"relations" => []
			];

			/* (2) Bases de données */
			$subjectdb = new lightdb('subject');
			$contactdb = new lightdb('contact');


			/* [3] Données du sujet
			=========================================================*/
			$subject_set = $subjectdb->fetch($subject_id);

			/* (1) Si le sujet n'existe pas -> ERROR */
			if( $subject_set === false )
				return ['ModuleError'=>ManagerError::UnreachableResource];

			/* (2) Initialisation des contacts si vide */
			if( !isset($subject_set['contacts']) )
				$subject_set['contacts'] = [];

			/* (3) Initialisation des relations si vide */
			if( !isset($subject_set['relations']) )
				$subject_set['relations'] = [];

			/* (4) Ajout de l'enquête */
			if( !in_array('facebook', $subject_set['surveys']) )
				$subject_set['surveys'][] = 'facebook';

			/* (5) On récupère les noms des contacts */
			$contactsById   = []; // idContact  -> nomContact

			foreach($subject_set['contacts'] as $contactId){
				$contactId = intval($contactId);
				$contactData = $contactdb->fetch( $contactId );

				$contactsById[$contactId] = $contactData['name'];
			}


			/* [4] On saisit les fiches + les contacts des fiches
			=========================================================*/
			$contactsDone = [
				"existing" => [], // Contacts exportés déja enregistrés
				"username" => []  // Nouveaux contacts déja enregistrés
			];
			$finalid = []; // id_contact -> id_final_contact (existant ou nouveau)

			foreach($fiches as $f=>$ficheData){
				/* (1) On récupère les données du contact associé */
				if( !isset($contacts[$ficheData['contact']]) )
					break;

				$contact = $contacts[ $ficheData['contact'] ];

				/* (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 = $contactsById[ intval($contact['existing']) ];

					$existingData = $dbcontact->fetch( intval($contact['existing']) );

					$finalid[ intval($contact['uid']) ] = $newId;

					// S'il a déja une fiche ou qu'on a déja fait une fiche, on quitte
					if( is_array($existingData) && isset($existingData['studies2']) || in_array($contact['existing'], $contactsDone['existing']) )
						break;

				/* (3) Si nouveau contact */
				}else{

					$newId = (int) ($offset+$contact['uid']);
					$uname = $contact['username'];

					$finalid[ intval($contact['uid']) ] = $newId;

					// 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;

				/* (5) On enregistre les données du contact */
				$contactdb->insert($newId, [
					'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 ajoute le contact dans la liste des contacts du sujet (si pas déja)
				if( !in_array($newId, $subject_set['contacts']) )
					$subject_set['contacts'][] = $newId;

				// On enregistre la relation avec EGO
				$subject_set['relations'][] = [
					'idA'  => $subject_id,
					'idB'  => $newId,
					'type' => ($f<20) ? 6 : 7 // 6->historique     7->messenger
				];


				/* (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 mini + les contacts des mini
			=========================================================*/
			foreach($mini as $miniData){
				/* (1) On récupère les données du contact associé */
				if( !isset($contacts[$miniData['contact']]) )
					break;

				$contact = $contacts[ $miniData['contact'] ];

				/* (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 = $contactsById[ intval($contact['existing']) ];

					$existingData = $dbcontact->fetch( intval($contact['existing']) );

					$finalid[ intval($contact['uid']) ] = $newId;

					// S'il a déja une fiche ou qu'on a déja fait une fiche (ou mini), on quitte
					if( is_array($existingData) && isset($existingData['studies2']) || in_array($contact['existing'], $contactsDone['existing']) )
						break;

				/* (3) Si nouveau contact */
				}else{

					$newId = (int) ($offset+$contact['uid']);
					$uname = $contact['username'];

					$finalid[ intval($contact['uid']) ] = $newId;

					// 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
				$contactdb->insert($newId, [
					'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 ajoute le contact dans la liste des contacts du sujet (si pas déja)
				if( !in_array($newId, $subject_set['contacts']) )
					$subject_set['contacts'][] = $newId;

				// On enregistre la relation avec EGO
				$subject_set['relations'][] = [
					'idA'  => $subject_id,
					'idB'  => $newId,
					'type' => 3 // relation facebook 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'];

			}


			/* [6] On enregistre les relations de la MATRICE
			=========================================================*/
			$clen = count($finalid);

			/* (1) On récupére les ids des contacts */
			$cIdList = [];
			foreach($finalid as $lastid=>$newid){
				$id = (int) $lastid;

				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

						// Si relation alter-alter
						$relationXY = isset($matrice[$y]) && in_array($x, $matrice[$y])
								|| (  isset($matrice[$x]) && in_array($y, $matrice[$x]) );

						$subject_set['relations'][] = [
							'idA'  => $finalid[$x],
							'idB'  => $finalid[$y],
							'type' => $relationXY ? 1 : 0 // 0->aucune relation     1->relation alter alter
						];

					}
			}


			/* [6] On les données du sujet
			=========================================================*/
			$subjectdb->insert($subject_id, $subject_set);


			/* [7] On enregistre les données des contacts
			=========================================================*/
			/* (1) On enregistre chaque contact */
			foreach($file['contacts'] as $c=>$contactData)
				$contactdb->insert($contactData['id'], $contactData);


			/* [7] On met à jour le nouvel ID unique
			=========================================================*/
			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);


			/* [9] Gestion du retour
			=========================================================*/
			return [
				'ModuleError' => ManagerError::Success,
				'subject_id'  => $subject_id
			];
		}



	}


?>