Merge branch 'master' into FJ_Contrat_Sans_Avenant (e453d696) · Commits · open-source / OSE

admin/actions/test.php

+6 −4

Changes for admin/actions/test.php: 6 added lines, 4 removed lines.
Original line number	Diff line number	Diff line
		<?php

		require_once dirname(__DIR__) . '/migration/v18Plafonds.php';
		/*
		require_once dirname(__DIR__) . '/migration/v18Divers.php';

		$mm = new MigrationManager($oa, new \BddAdmin\Ddl\Ddl(), []);
		$v18 = new v18Plafonds($mm);
		$v18 = new v18Divers($mm);

		$v18->checkDoublons();*/

		$v18->migrationParamsStatut();
		No newline at end of file
		phpinfo();
		No newline at end of file

admin/actions/update-bdd.php

+4 −0

Changes for admin/actions/update-bdd.php: 4 added lines, 0 removed lines.
Original line number	Diff line number	Diff line
		@@ -23,6 +23,10 @@ foreach ($ref as $ddlClass => $objects) {
		}
		}

		if (($_SERVER['IGNORE_MV_EXT_SERVICE'] ?? "false") == "true") {
		$filters['materialized-view']['excludes'][] = 'MV_EXT_SERVICE';
		}

		$tablesDep = [
		Ddl::INDEX,
		Ddl::PRIMARY_CONSTRAINT,

admin/migration/v18Divers.php

+229 −1

Changes for admin/migration/v18Divers.php: 229 added lines, 1 removed line.
Original line number	Diff line number	Diff line
		@@ -16,7 +16,7 @@ class v18Divers extends AbstractMigration

		public function utile(): bool
		{
		return $this->manager->hasNew('table', 'PLAFOND_PERIMETRE');
		return true;
		}


		@@ -31,6 +31,28 @@ class v18Divers extends AbstractMigration
		$c->printDie('Attention : vous devez d\'abord mettre à jour en version 17.3 AVANT de mettre à jour en version 18');
		}

		try {
		$bdd->exec("alter trigger F_INTERVENANT disable");
		} catch (\Exception $e) {
		}

		try {
		$bdd->exec("alter trigger F_INTERVENANT_S disable");
		} catch (\Exception $e) {
		}

		try {
		$c->msg('Coupure forcée de la synchronisation sur la table INTERVENANT');
		$bdd->exec("UPDATE IMPORT_TABLES SET SYNC_ENABLED = 0 WHERE TABLE_NAME = 'INTERVENANT'");
		} catch (\Exception $e) {
		// rien à faire : la contrainte a déjà du être supprimée
		}


		if (!$this->checkDoublons()) {
		$c->printDie('Attention : des doublons ont été trouvés dans vos intervenants. Merci de purger d\'abord votre base de données, puis de relancer ensuite la procédure de mise à jour.');
		}

		try {
		$c->msg('Coupure forcée de la synchronisation sur la table INTERVENANT');
		$bdd->exec("UPDATE IMPORT_TABLES SET SYNC_ENABLED = 0 WHERE TABLE_NAME = 'INTERVENANT'");
		@@ -93,4 +115,210 @@ class v18Divers extends AbstractMigration
		$c->end();
		}



		public function checkDoublons(): bool
		{
		$bdd = $this->manager->getBdd();
		$c = $this->manager->getOseAdmin()->getConsole();

		$uc = \BddAdmin\Ddl\Ddl::UNIQUE_CONSTRAINT;

		$res = [];
		if ($this->manager->hasNew($uc, 'INTERVENANT_CODE_UN')) {
		$lres = $this->checkDoublonsCode();
		foreach ($lres as $r) {
		$res[] = $r;
		}
		}

		if ($this->manager->hasNew($uc, 'INTERVENANT_SOURCE_UN')) {
		$lres = $this->checkDoublonsSourceCode();
		foreach ($lres as $r) {
		$res[] = $r;
		}
		}

		$data = [];
		$sqls = [];
		$autoSqls = [];
		foreach ($res as $i) {
		if ($i['HISTO_DESTRUCTION']) {
		$autoSqls[$i['USQL']] = $i['USQL'];
		} else {
		if (isset($i['CODE'])) {
		$cl = 'Code';
		$cv = $i['CODE'];
		} elseif (isset($i['SOURCE_CODE'])) {
		$cl = 'Code Source';
		$cv = $i['SOURCE_CODE'];
		} elseif (isset($i['UTILISATEUR_CODE'])) {
		$cl = 'Code Utilisateur';
		$cv = $i['UTILISATEUR_CODE'];
		} else {
		$cl = 'Code inconnu';
		$cv = null;
		}

		$data[$i['USQL']] = [
		'Année' => $i['ANNEE_ID'],
		$cl => $cv,
		'STATUT' => $i['STATUT'],
		'Nom usuel' => $i['NOM_USUEL'],
		'Prénom' => $i['PRENOM'],
		];
		$sqls[$i['USQL']] = $i['USQL'];
		}
		}

		foreach ($autoSqls as $sql) {
		$bdd->exec($sql);
		}

		if (!empty($data)) {
		$c->printArray($data);
		$c->println('Des intervenants ayant deux fois le même statut, le même source_code ou le même utilisateur_code pour la même année ont été trouvés.');
		$c->println('Afin de régler ce problème, vous devrez historiser les fiches concernées en exécutant vous-mêmes en BDD les requêtes suivantes :');
		$c->println('');
		$c->println(implode("\n", $sqls));
		$c->println('');
		$c->println('Une fois le traitement effectué, vous pourrez reprendre la mise à jour via la commande ./bin/ose update-bdd.');

		return false;
		} else {
		return true;
		}
		}



		private function checkDoublonsCode(): array
		{
		$bdd = $this->manager->getBdd();
		$c = $this->manager->getOseAdmin()->getConsole();

		$statutTable = $this->manager->hasTable('STATUT') ? 'STATUT' : 'STATUT_INTERVENANT';

		$sql = "
		SELECT
		i.*,
		i.nom_usuel nom,
		i.prenom prenom,
		si.libelle statut,
		CASE WHEN i.histo_destruction IS NOT NULL THEN
		'UPDATE INTERVENANT SET HISTO_DESTRUCTION = HISTO_DESTRUCTION + interval ''1'' second WHERE ID = ' \|\| i.id
		ELSE
		'UPDATE INTERVENANT SET HISTO_DESTRUCTION = sysdate, HISTO_DESTRUCTEUR_ID = ose_parametre.get_ose_user WHERE ID = ' \|\| i.id \|\| ';'
		END usql
		FROM
		(
		SELECT
		i.*,
		min(nbdeps) OVER (PARTITION BY code, annee_id, statut_id, histo_destruction) minnbdeps,
		max(nbdeps) OVER (PARTITION BY code, annee_id, statut_id, histo_destruction) maxnbdeps,
		ROW_NUMBER() OVER (PARTITION BY code, annee_id, statut_id, histo_destruction ORDER BY id) ordre
		FROM
		(
		SELECT
		code, annee_id, statut_id, histo_destruction
		,id,prenom,nom_usuel,
		(
		(SELECT count(*) FROM SERVICE_REFERENTIEL WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM VALIDATION WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM AGREMENT WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM CONTRAT WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM HISTO_INTERVENANT_SERVICE WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM AFFECTATION_RECHERCHE WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM PIECE_JOINTE WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM SERVICE WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM MODIFICATION_SERVICE_DU WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM INDIC_MODIF_DOSSIER WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM INTERVENANT_PAR_DEFAUT WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM INTERVENANT_DOSSIER WHERE intervenant_id = i.id)
		) nbdeps,
		COUNT(*) OVER (PARTITION BY code, annee_id, statut_id, histo_destruction) nbr
		FROM
		intervenant i
		) i
		WHERE
		nbr > 1
		) i
		JOIN $statutTable si ON si.id = i.statut_id
		WHERE
		CASE
		WHEN nbdeps < maxnbdeps AND nbdeps = minnbdeps THEN 1
		WHEN i.ordre > 1 THEN 1
		ELSE 0
		END = 1
		";

		return $bdd->select($sql);
		}



		private function checkDoublonsSourceCode(): array
		{
		$bdd = $this->manager->getBdd();
		$c = $this->manager->getOseAdmin()->getConsole();

		// $statutTable = $this->manager->hasTable('STATUT') ? 'STATUT' : 'STATUT_INTERVENANT';
		$statutTable = 'STATUT_INTERVENANT';

		$sql = "
		SELECT
		i.*,
		i.nom_usuel nom,
		i.prenom prenom,
		si.libelle statut,
		CASE WHEN i.histo_destruction IS NOT NULL THEN
		'UPDATE INTERVENANT SET HISTO_DESTRUCTION = HISTO_DESTRUCTION + interval ''1'' second WHERE ID = ' \|\| i.id
		ELSE
		'UPDATE INTERVENANT SET HISTO_DESTRUCTION = sysdate, HISTO_DESTRUCTEUR_ID = ose_parametre.get_ose_user WHERE ID = ' \|\| i.id \|\| ';'
		END usql
		FROM
		(
		SELECT
		i.*,
		min(nbdeps) OVER (PARTITION BY source_code, annee_id, statut_id, histo_destruction) minnbdeps,
		max(nbdeps) OVER (PARTITION BY source_code, annee_id, statut_id, histo_destruction) maxnbdeps,
		ROW_NUMBER() OVER (PARTITION BY source_code, annee_id, statut_id, histo_destruction ORDER BY id) ordre
		FROM
		(
		SELECT
		source_code, annee_id, statut_id, histo_destruction
		,id,prenom,nom_usuel,
		(
		(SELECT count(*) FROM SERVICE_REFERENTIEL WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM VALIDATION WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM AGREMENT WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM CONTRAT WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM HISTO_INTERVENANT_SERVICE WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM AFFECTATION_RECHERCHE WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM PIECE_JOINTE WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM SERVICE WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM MODIFICATION_SERVICE_DU WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM INDIC_MODIF_DOSSIER WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM INTERVENANT_PAR_DEFAUT WHERE intervenant_id = i.id)
		+ (SELECT count(*) FROM INTERVENANT_DOSSIER WHERE intervenant_id = i.id)
		) nbdeps,
		COUNT(*) OVER (PARTITION BY source_code, annee_id, statut_id, histo_destruction) nbr
		FROM
		intervenant i
		) i
		WHERE
		nbr > 1
		) i
		JOIN $statutTable si ON si.id = i.statut_id
		WHERE
		CASE
		WHEN nbdeps < maxnbdeps AND nbdeps = minnbdeps THEN 1
		WHEN i.ordre > 1 THEN 1
		ELSE 0
		END = 1
		";

		return $bdd->select($sql);
		}

		}
		No newline at end of file

admin/migration/v18Indicateurs.php

+0 −2

Changes for admin/migration/v18Indicateurs.php: 0 added lines, 2 removed lines.
Original line number	Diff line number	Diff line
		@@ -16,8 +16,6 @@ class v18Indicateurs extends AbstractMigration

		public function utile(): bool
		{
		return true;

		return $this->manager->hasNew('table', 'TYPE_INDICATEUR');
		}

admin/migration/v18Plafonds.php

+6 −1

Changes for admin/migration/v18Plafonds.php: 6 added lines, 1 removed line.
Original line number	Diff line number	Diff line
		@@ -16,7 +16,12 @@ class v18Plafonds extends AbstractMigration

		public function utile(): bool
		{
		return $this->manager->hasNew('table', 'PLAFOND_PERIMETRE') \|\| $this->manager->hasTable('SAVE_V18_PLAFOND');
		return $this->manager->hasNew('table', 'PLAFOND_PERIMETRE')
		&& $this->manager->tableRealExists('SAVE_V18_PLAFOND')
		&& $this->manager->tableRealExists('SAVE_V18_STRUCTURE')
		&& $this->manager->tableRealExists('SAVE_V18_PLAFOND_APP')
		&& $this->manager->tableRealExists('SAVE_V18_REFERENTIEL')
		&& $this->manager->tableRealExists('SAVE_V18_STATUT');
		}