materio-d8/cleanflaglist.script

<?php

//
// This example demonstrates how to write a drush
// script.  These scripts are run with the php-script command.
//
use Drush\Drush;

$this->output()->writeln("Flagging collection cleaning");
$this->output()->writeln("options : [delete-all | delete-nullname | delete-missing | delete-dups]");

// $this->output()->writeln("Hello world!");
$this->output()->writeln("The extra options/arguments to this command were:");
$this->output()->writeln(print_r($extra, true));

$delete_all = fasle;
$delete_nullname = false;
$delete_missing = false;
$delete_dups = false;

if ($extra[0] === "delete-all") {
  $delete_all = true;
}

if ($extra[0] === "delete-missing") {
  $delete_missing = true;
}

if ($extra[0] === "delete-nullname") {
  $delete_nullname = true;
}

if ($extra[0] === "delete-dups") {
  $delete_dups = true;
}


$database = \Drupal::database();

// remove flagging collection with null name
$this->output()->writeln("");
$this->output()->writeln("Flagging collection With NULL name cleaning");
$fcfd_query = $database->select('flagging_collection_field_data', 'fcfd')
  ->isNull('fcfd.name')
  ->fields('fcfd', ['id', 'relatedflag']);

$fcfd_result = $fcfd_query->execute();
$this->output()->writeln($fcfd_query->countQuery()->execute()->fetchField() . " flagging_collection with null name");

foreach ($fcfd_result as $fc) {
  // $this->output()->writeln($fc->id . " flagging_collection with null name");
  // $this->output()->writeln(print_r($fc, true));

  // get flag list items
  $flifd_query = $database->select('flag_list_item_field_data', 'flifd')
  ->condition('flifd.flag_list', $fc->id)
  ->fields('flifd', ['id', 'baseflag', 'flag_list']);

  $flifd_result = $flifd_query->execute();
  $this->output()->writeln($flifd_query->countQuery()->execute()->fetchField() . " items for fc " . $fc->id . ' with baseflag ' . $fc->relatedflag);
  // $this->output()->writeln(print_r($flifd_result->fetchAssoc(), true) . " items");

  delete_flagingcollection($fc, $database, $delete_all ? true : $delete_nullname);
}


// searching for missing related flags
$this->output()->writeln("");
$this->output()->writeln("Missing related flag Flagging collection cleaning");
$fcfd_query = $database->select('flagging_collection_field_data', 'fcfd')
  ->fields('fcfd', ['id', 'relatedflag']);

$fcfd_result = $fcfd_query->execute();
$this->output()->writeln($fcfd_query->countQuery()->execute()->fetchField() . " flagging_collections");

$fc_missing_relatedflag = 0;
foreach ($fcfd_result as $fc) {
  $flag_query = $database->select('config', 'c')
    ->condition('c.name', 'flag.flag.' . $fc->relatedflag)
    ->fields('c', ['name']);
  $conf_result = $flag_query->execute();
  $count = $flag_query->countQuery()->execute()->fetchField();
  if(!$count){
    $this->output()->writeln(' flagging_collection' . $fc->id . ' has ' . $count . " relatedflag");
    $fc_missing_relatedflag ++;
    delete_flagingcollection($fc, $database, $delete_all ? true : $delete_missing);
  }
}
$this->output()->writeln($fc_missing_relatedflag .' flagging_collection with missing related_flag');

// searching for duplicates relatedflags
$this->output()->writeln("");
$this->output()->writeln("Duplicate relatedflag flagging_collection cleaning");
$dup_query = $database->select('flagging_collection_field_data', 'fcfd')
  ->fields('fcfd', ['relatedflag'])
  ->groupBy('fcfd.relatedflag')
  ->having('COUNT(*) > 1');
$dup_query->addExpression('COUNT(*)', 'count');

// $results = $query->execute()->fetchAll();

$dup_result = $dup_query->execute();
$this->output()->writeln($dup_query->countQuery()->execute()->fetchField() . " duplicate related flags");

foreach ($dup_result as $dup){
  // $this->output()->writeln($dup->relatedflag . " is dup");
  $fcfd_query = $database->select('flagging_collection_field_data', 'fcfd')
    ->condition('fcfd.relatedflag', $dup->relatedflag)
    ->fields('fcfd', ['id', 'relatedflag']);
  $fcfd_result = $fcfd_query->execute();
  $count = $fcfd_query->countQuery()->execute()->fetchField();
  
  $this->output()->writeln($dup->relatedflag . ' relatedflag has ' . $count . ' flagging collection');
  
  foreach ($fcfd_result as $fc) {
    delete_flagingcollection($fc, $database, $delete_all ? true : $delete_dups);
  }

}








// MAIN DELETE FUNCTION
function delete_flagingcollection($fc, $database, $delete){
  if($delete){
    // $this is not working in function
    // $this->output()->writeln("Deleting flagging collection " . $fc->id);
    // get flag list items
    $flifd_query = $database->select('flag_list_item_field_data', 'flifd')
    ->condition('flifd.flag_list', $fc->id)
    ->fields('flifd', ['id', 'baseflag', 'flag_list']);

    $flifd_result = $flifd_query->execute();

    foreach ($flifd_result as $item) {
      // delete items
      $database->delete('flag_list_item')
      ->condition('id', $item->id)
      ->execute();
      $database->delete('flag_list_item_field_data')
        ->condition('id', $item->id)
        ->execute();
    }

    # delete the flag_collection
    $database->delete('flagging_collection')
    ->condition('id', $fc->id)
    ->execute();
    $database->delete('flagging_collection_revision')
      ->condition('id', $fc->id)
      ->execute();
    $database->delete('flagging_collection_field_revision')
      ->condition('id', $fc->id)
      ->execute();

    # delete related flag
    // $flag_query = $database->select('config', 'c')
    //   ->condition('c.name', 'flag.flag.' . $fc->relatedflag)
    //   ->fields('c', ['name']);
    // $conf_result = $flag_query->execute();
    // $this->output()->writeln(print_r($conf_result->fetchAssoc(), true));

    $database->delete('config')
    ->condition('name', 'flag.flag.' . $fc->relatedflag)
    ->execute();

    $database->delete('config')
    ->condition('name', 'system.action.flag_action.'.$fc->relatedflag.'_flag')
    ->execute();

    $database->delete('config')
    ->condition('name', 'system.action.flag_action.'.$fc->relatedflag.'_unflag')
    ->execute();
    

    $database->delete('flagging_collection_field_data')
      ->condition('id', $fc->id)
      ->execute();

  } else {
    // $this is not working in function
    // $this->output()->writeln("In order to actually delete fault flagging collection data please use delete option");
  }

}