Spaces:
No application file
No application file
File size: 2,726 Bytes
d2897cd |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
<?php
declare(strict_types=1);
namespace Mautic\Migrations;
use Doctrine\DBAL\Schema\Schema;
use Mautic\CoreBundle\Doctrine\AbstractMauticMigration;
final class Version20231110103625 extends AbstractMauticMigration
{
protected static string $tableName = 'roles';
public function up(Schema $schema): void
{
$sql = sprintf('SELECT id, readable_permissions FROM %s WHERE is_admin != 1', $this->getPrefixedTableName());
$results = $this->connection->executeQuery($sql)->fetchAllAssociative();
$updatedRecords = 0;
$addPermissions = [];
foreach ($results as $row) {
$permissionsArray = unserialize($row['readable_permissions']);
// Add permissions if not exists
$permissionsToAdd = ['lead:export', 'form:export', 'report:export'];
foreach ($permissionsToAdd as $permission) {
if (!isset($permissionsArray[$permission])) {
$permissionsArray[$permission] = ['enable'];
$addPermissions[$row['id']][$permission] = 1024;
}
}
$permissionsString = serialize($permissionsArray);
$updateSql = sprintf('UPDATE %s SET readable_permissions = :permissions WHERE id = :id', $this->getPrefixedTableName());
$stmt = $this->connection->prepare($updateSql);
$stmt->bindValue('permissions', $permissionsString, \PDO::PARAM_STR);
$stmt->bindValue('id', $row['id'], \PDO::PARAM_INT);
$updatedRecords += $stmt->executeStatement();
foreach ($addPermissions as $roleId => $permissionsToAdd) {
foreach ($permissionsToAdd as $permissionToAdd => $bitwise) {
$sql = sprintf('INSERT IGNORE INTO %s (role_id, bundle, name, bitwise) VALUES (:role_id, :bundle, :name, :bitwise)', $this->prefix.'permissions');
$stmt = $this->connection->prepare($sql);
$permissionArray = explode(':', $permissionToAdd);
$stmt->bindValue('role_id', $row['id'], \PDO::PARAM_INT);
$stmt->bindValue('bundle', $permissionArray[0], \PDO::PARAM_STR);
$stmt->bindValue('name', $permissionArray[1], \PDO::PARAM_STR);
$stmt->bindValue('bitwise', $bitwise, \PDO::PARAM_INT);
$stmt->executeStatement();
}
}
}
$this->write(sprintf('<comment>%s record(s) have been updated successfully.</comment>', $updatedRecords));
}
private function getPrefixedTableName(): string
{
return $this->prefix.self::$tableName;
}
}
|