Files
OSJ/classes/migration/upgrade/v3_4_0/I7129_IssueEntityDAORefactor.php
CHIEFSOFT\ameye df3a033196 first commit
2024-06-08 17:09:23 -04:00

111 lines
3.6 KiB
PHP

<?php
/**
* @file classes/migration/upgrade/v3_4_0/I7129_IssueEntityDAORefactor.php
*
* Copyright (c) 2014-2021 Simon Fraser University
* Copyright (c) 2000-2021 John Willinsky
* Distributed under the GNU GPL v3. For full terms see the file docs/COPYING.
*
* @class I7129_IssueEntityDAORefactor
*
* @brief Convert issue DAO to use new repository pattern
*/
namespace APP\migration\upgrade\v3_4_0;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Schema;
class I7129_IssueEntityDAORefactor extends \PKP\migration\Migration
{
/**
* Run the migration.
*/
public function up(): void
{
// Remove deprecated setting_type requirement
Schema::table('issue_settings', function (Blueprint $table) {
$table->string('setting_type', 6)->nullable()->change();
});
// Move current issue status from Issue to Journal
Schema::table('journals', function (Blueprint $table) {
$table->bigInteger('current_issue_id')->nullable()->default(null);
$table->foreign('current_issue_id')->references('issue_id')->on('issues')->onDelete('set null');
$table->index(['current_issue_id'], 'journals_current_issue_id');
});
$this->transferCurrentStatusToJournal();
Schema::table('issues', function (Blueprint $table) {
$table->dropColumn('current');
});
}
/**
* Reverse the downgrades
*/
public function down(): void
{
// Restore deprecated setting_type requirement
Schema::table('issue_settings', function (Blueprint $table) {
$table->string('setting_type', 6)->change();
});
// Move current issue status back to Issue from Journal
Schema::table('issues', function (Blueprint $table) {
$table->smallInteger('current')->default(0);
});
$this->transferCurrentStatusToIssue();
Schema::table('journals', function (Blueprint $table) {
$table->dropForeign('journals_current_issue_id_foreign');
$table->dropColumn('current_issue_id');
});
}
/**
* Transfers current issue status from Issue to Journal for each journal
*/
private function transferCurrentStatusToJournal()
{
$contexts = DB::table('journals', 'j')
->select('j.journal_id')
->get();
foreach ($contexts as $context) {
$currentIssue = DB::table('issues', 'i')
->select('i.issue_id')
->where('i.journal_id', '=', $context->journal_id)
->where('i.current', '=', 1)
->get()
->first();
if ($currentIssue !== null) {
DB::table('journals', 'j')
->where('j.journal_id', '=', $context->journal_id)
->update(['current_issue_id' => $currentIssue->issue_id]);
}
}
}
// Transfer current issue status from Journal to Issue for each journal
private function transferCurrentStatusToIssue()
{
$contexts = DB::table('journals', 'j')
->select('j.current_issue_id')
->get();
foreach ($contexts as $context) {
if ($context->current_issue_id != null) {
DB::table('issues', 'i')
->where('i.issue_id', '=', $context->current_issue_id)
->update(['i.current' => 1]);
}
}
}
}
if (!PKP_STRICT_MODE) {
class_alias('\APP\migration\upgrade\v3_4_0\I7129_IssueEntityDAORefactor', '\I7129_IssueEntityDAORefactor');
}