yii\console\controllers\MessageController::saveMessagesToDb()

Complexity

Conditions	31
Paths	> 20000

Size

Total Lines	144
Code Lines	90

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	90
CRAP Score	31

Importance

Changes	1
Bugs	0	Features	0

<?php
    protected function saveMessagesToDb($messages, $db, $sourceMessageTable, $messageTable, $removeUnused, $languages, $markUnused)
    {
        $this->stdout("UPDATING DB\n\n");
        
        $this->stdout("SOURCE MESSAGE TABLE\n\n");
        
        $currentMessages = [];
        $rows = (new Query())->select(['id', 'category', 'message'])->from($sourceMessageTable)->all($db);
        foreach ($rows as $row) {
            $currentMessages[$row['category']][$row['id']] = $row['message'];
        }
        
        $new = [];
        $obsolete = [];
        
        foreach ($messages as $category => $msgs) {
            $msgs = array_unique($msgs);

            if (isset($currentMessages[$category])) {
                $new[$category] = array_diff($msgs, $currentMessages[$category]);
                // obsolete msgs per category
                $obsolete += array_diff($currentMessages[$category], $msgs);
            } else {
                $new[$category] = $msgs;
            }
        }
        
        // obsolete categories
        foreach (array_diff(array_keys($currentMessages), array_keys($messages)) as $category) {
            $obsolete += $currentMessages[$category];
        }
        
        if (!$removeUnused) {
            foreach ($obsolete as $pk => $msg) {
                // skip already marked unused
                if (strncmp($msg, '@@', 2) === 0 && substr($msg, -2) === '@@') {
                    unset($obsolete[$pk]);
                }
            }
        }        
        
        $this->stdout('Inserting new messages...');
        $insertCount = 0;

        foreach ($new as $category => $msgs) {
            foreach ($msgs as $msg) {
                $insertCount++;
                $db->schema->insert($sourceMessageTable, ['category' => $category, 'message' => $msg]);
            }
        }
        
        $this->stdout($insertCount ? "{$insertCount} saved.\n" : "Nothing to save.\n");
        
        $this->stdout($removeUnused ? 'Deleting obsoleted messages...' : 'Updating obsoleted messages...');
        
        if (empty($obsolete)) {
            $this->stdout("Nothing obsoleted...skipped.\n");
        }
        
        if ($obsolete && $removeUnused) {
            $affected=$db->createCommand()
               ->delete($sourceMessageTable, ['in', 'id', array_keys($obsolete)])
               ->execute();
            $this->stdout("{$affected} deleted.\n");
        } elseif ($obsolete && $markUnused) {
            $marked=0;
            $rows = (new Query())
                ->select(['id', 'message'])
                ->from($sourceMessageTable)
                ->where(['in', 'id', array_keys($obsolete)])
                ->all($db);

            foreach ($rows as $row) {
                $marked++;
                $db->createCommand()->update(
                    $sourceMessageTable,
                    ['message' => '@@' . $row['message'] . '@@'],
                    ['id' => $row['id']]
                )->execute();
            }
            $this->stdout("{$marked} updated.\n");
        } elseif ($obsolete) {
            $this->stdout("kept untouched.\n");
        }
         
        $this->stdout("\n\nMESSAGE TABLE\n\n");
        
        // get fresh message id list
        $freshMessagesIds = [];
        $rows = (new Query())->select(['id'])->from($sourceMessageTable)->all($db);
        foreach ($rows as $row) {
            $freshMessagesIds[] = $row['id'];
        }
            
        $this->stdout("Generating missing rows...");
        $generatedMissingRows=[];
        
        foreach ($languages as $language) {
          $count=0;
          
          // get list of ids of translations for this language
          $msgRowsIds = [];
          $msgRows = (new Query())->select(['id'])->from($messageTable)->where([
              'language'=>$language,
          ])->all($db);
          foreach ($msgRows as $row) {
              $msgRowsIds[] = $row['id'];
          }
          
          // insert missing
          foreach ($freshMessagesIds as $id) {
            if (!in_array($id, $msgRowsIds)) {
              $db->createCommand()
                 ->insert($messageTable, ['id' => $id, 'language' => $language])
                 ->execute();
              $count++;
            }
          }
          if ($count) {
            $generatedMissingRows[]="{$count} for {$language}";
          }
        }
        
        $this->stdout($generatedMissingRows ? implode(", ", $generatedMissingRows).".\n" : "Nothing to do.\n");
        
        $this->stdout("Dropping unused languages...");
        $droppedLanguages=[];
        
        $currentLanguages = [];
        $rows = (new Query())->select(['language'])->from($messageTable)->groupBy('language')->all($db);
        foreach ($rows as $row) {
            $currentLanguages[] = $row['language'];
        }
        
        foreach ($currentLanguages as $currentLanguage) {
          if (!in_array($currentLanguage, $languages)) {
            $deleted=$db->createCommand()->delete($messageTable, "language=:language", [
                'language'=>$currentLanguage,
            ])->execute();
            $droppedLanguages[]="removed {$deleted} rows for $currentLanguage";
          }
        }
        
        $this->stdout($droppedLanguages ? implode(", ", $droppedLanguages).".\n" : "Nothing to do.\n");
    }