FEAT #11691 TIME 5 migration res_version_attachment

migration/19.12/1912.sql

@@ -479,6 +479,7 @@ ALTER TABLE listinstance DROP COLUMN IF EXISTS listinstance_type;
 ALTER TABLE listinstance DROP COLUMN IF EXISTS visible;
 ALTER TABLE listinstance_history_details DROP COLUMN IF EXISTS added_by_entity;
 ALTER TABLE usergroup_content DROP COLUMN IF EXISTS primary_group;
+ALTER TABLE emails ALTER COLUMN document type jsonb;
 
 /* M2M */
 DO $$ BEGIN

migration/19.12/migrate.sh

@@ -18,4 +18,5 @@ php ./migrateWorkingDays.php
 php ./migrateExtensions.php
 php ./migrateM2MConfiguration.php
 php ./removeNatureFromPrint.php
-php ./migrateCustomValues.php
+php ./migrateCustomValues.php
\ No newline at end of file
+php ./migrateVersionAttachments.php
\ No newline at end of file

migration/19.12/migrateVersionAttachments.php

+<?php
+
+require '../../vendor/autoload.php';
+
+chdir('../..');
+
+$customs =  scandir('custom');
+
+foreach ($customs as $custom) {
+    if ($custom == 'custom.xml' || $custom == '.' || $custom == '..') {
+        continue;
+    }
+
+    \SrcCore\models\DatabasePDO::reset();
+    new \SrcCore\models\DatabasePDO(['customId' => $custom]);
+
+    \SrcCore\models\DatabaseModel::delete([
+        'table' => 'res_attachments',
+        'where' => ['relation > 1']
+    ]);
+
+    $migrated = 0;
+    $attachmentsInfo = \SrcCore\models\DatabaseModel::select([
+        'select'   => ['res_id', 'title', 'subject', 'description', 'type_id', 'format', 'typist', 'creation_date', 'fulltext_result', 'author', 'identifier', 'source', 'relation', 'doc_date', 'docserver_id', 'path', 'filename', 'offset_doc', 'fingerprint', 'filesize', 'status', 'destination', 'validation_date', 'effective_date', 'origin', 'priority', 'initiator', 'dest_user', 'res_id_master', 'attachment_type', 'dest_contact_id', 'dest_address_id', 'updated_by', 'is_multicontacts', 'in_signature_book', 'signatory_user_serial_id', 'in_send_attach', 'external_id', 'attachment_id_master'],
+        'table'    => ['res_version_attachments']
+    ]);
+
+    foreach ($attachmentsInfo as $attachmentInfo) {
+        $oldResId = $attachmentInfo['res_id'];
+        unset($attachmentInfo['res_id']);
+        $attachmentInfo['origin_id'] = $attachmentInfo['attachment_id_master'];
+        unset($attachmentInfo['attachment_id_master']);
+        $attachmentInfo['in_signature_book'] = empty($attachmentInfo['in_signature_book']) ?  'false' : 'true';
+        $attachmentInfo['in_send_attach']    = empty($attachmentInfo['in_send_attach']) ?  'false' : 'true';
+        $attachmentInfo['format']            = empty($attachmentInfo['format']) ?  pathinfo($attachmentInfo['filename'], PATHINFO_EXTENSION) : $attachmentInfo['format'];
+
+        $newResId = \Attachment\models\AttachmentModel::create($attachmentInfo);
+
+        migrateAdrVersionAttachments(['oldResId' => $oldResId, 'newResId' => $newResId]);
+        migrateHistoryVersion(['oldResId' => $oldResId, 'newResId' => $newResId]);
+        migrateEmailsVersion(['oldResId' => $oldResId, 'newResId' => $newResId]);
+        migrateMessageExchangeVersion(['oldResId' => $oldResId, 'newResId' => $newResId]);
+        migrateShippingVersion(['oldResId' => $oldResId, 'newResId' => $newResId]);
+
+        $migrated++;
+    }
+
+    printf("Migration version attachement (CUSTOM {$custom}) : " . $migrated . " Version(s) trouvée(s) et migrée(s).\n");
+}
+
+function migrateAdrVersionAttachments($args = [])
+{
+    $adrInfos = \SrcCore\models\DatabaseModel::select(['select' => ['*'], 'table' => ['adr_attachments_version'], 'where' => ['res_id = ?'], 'data' => [$args['oldResId']]]);
+    foreach ($adrInfos as $value) {
+        unset($value['id']);
+        $value['res_id'] = $args['newResId'];
+        \SrcCore\models\DatabaseModel::insert([
+            'table'         => 'adr_attachments',
+            'columnsValues' => $value
+        ]);
+    }
+}
+
+function migrateHistoryVersion($args = [])
+{
+    \SrcCore\models\DatabaseModel::update([
+        'set'   => ['table_name' => 'res_attachments', 'record_id' => $args['newResId']],
+        'postSet' => ['info' => "REPLACE(info, '{$args['oldResId']} (res_version_attachments)', '{$args['newResId']} (res_attachments)')"],
+        'table' => 'history',
+        'where' => ['table_name = ?', 'record_id = ?'],
+        'data'  => ['res_version_attachments', $args['oldResId']]
+    ]);
+}
+
+function migrateEmailsVersion($args = [])
+{
+    $emails = \SrcCore\models\DatabaseModel::select([
+        'select' => ['id', 'document'],
+        'table' => ['emails'],
+        'where' => ['document->\'attachments\' @> ?'],
+        'data' => ['[{"id":'.$args['oldResId'].', "isVersion":true}]']
+    ]);
+
+    foreach ($emails as $email) {
+        $email = json_decode($email['document'], true);
+        foreach ($email['document']['attachment'] as $key => $attachment) {
+            if ($attachment['id'] == $args['oldResId'] && $attachment['isVersion']) {
+                $email['document']['attachment'][$key]['id'] = $args['newResId'];
+                $email['document']['attachment'][$key]['isVersion'] = false;
+                break;
+            }
+        }
+        \SrcCore\models\DatabaseModel::update([
+            'set'   => ['document' => json_encode($email['document'])],
+            'table' => 'emails',
+            'where' => ['id = ?'],
+            'data'  => [$email['id']]
+        ]);
+    }
+}
+
+function migrateMessageExchangeVersion($args = [])
+{
+    \SrcCore\models\DatabaseModel::update([
+        'set'   => ['res_id' => $args['newResId'], 'tablename' => 'res_attachments'],
+        'table' => 'unit_identifier',
+        'where' => ['res_id = ?', 'tablename = ?'],
+        'data'  => [$args['oldResId'], 'res_version_attachments']
+    ]);
+}
+
+function migrateShippingVersion($args = [])
+{
+    \SrcCore\models\DatabaseModel::update([
+        'set'   => ['attachment_id' => $args['newResId'], 'is_version' => 'false'],
+        'table' => 'shippings',
+        'where' => ['attachment_id = ?', 'is_version = ?'],
+        'data'  => [$args['oldResId'], 'true']
+    ]);
+}

modules/sendmail/Controllers/ReadMessageExchangeController.php

@@ -74,7 +74,6 @@ class ReadMessageExchangeController
         $aDataForm['object']      = $messageExchangeData->DataObjectPackage->DescriptiveMetadata->ArchiveUnit[0]->Content->Title[0];
 
         $aDataForm['attachments']         = [];
-        $aDataForm['attachments_version'] = [];
         $aDataForm['notes']               = [];
         foreach ($unitIdentifierData as $value) {
             if ($value->tablename == 'notes') {