function simple_node_importer_update_rc_table_form_submit in Simple Node Importer 8

1 string reference to 'simple_node_importer_update_rc_table_form_submit'

simple_node_importer_form_alter in ./simple_node_importer.module

Implements hook_form_alter().

File

./simple_node_importer.module, line 321

Simple node importer module file.

Code

function simple_node_importer_update_rc_table_form_submit($form, FormStateInterface &$form_state) {
  $refKey = $form_state
    ->getValue('refkey');
  $sni_nid = $form_state
    ->getValue('sni_nid');
  if ($refKey) {
    $connection = Database::getConnection();
    $num_deleted = $connection
      ->delete('node_resolution')
      ->condition('reference', $refKey)
      ->execute();
    if ($num_deleted) {
      if ($sni_nid) {
        $connection = Database::getConnection();
        $connection
          ->query("SET SQL_MODE=''");
        $query_record = $connection
          ->select('node_resolution', 'nr');
        $query_record
          ->fields('nr', [
          'status',
        ]);
        $query_record
          ->condition('nr.sni_nid', $sni_nid);
        $query_record
          ->range(0, 1);
        $result = $query_record
          ->execute()
          ->fetchAll();
        foreach ($result as $row) {
          $status = unserialize($row->status);
        }
        $import_status = [
          'success' => $status['success'] + 1,
          'fail' => $status['fail'] - 1,
        ];

        // Update status.
        $connection
          ->update('node_resolution')
          ->fields([
          'status' => serialize($import_status),
        ])
          ->condition('sni_nid', $sni_nid)
          ->execute();
      }
      $msg = t("Resolution Center Updated");
      \Drupal::messenger()
        ->deleteByType('error');
      $form_state
        ->setRedirect('simple_node_importer.node_resolution_center');
      \Drupal::messenger()
        ->addStatus($msg);
    }
  }
}