import.php ➔ createProtocol() - Code Metrics - XoopsModules25x/xnewsletter - Measure and Improve Code Quality continuously with Scrutinizer

import.php ➔ createProtocol() A
last analyzed 2020-08-07 11:59 UTC

↳ Parent: Project
Complexity

Conditions	2
Paths	2
Size

Total Lines
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	2
nc	2
nop	3
dl	0
loc	10
rs	9.9332
c	0
b	0
f	0
<?php
/**
 * ****************************************************************************
 *  - A Project by Developers TEAM For Xoops - ( https://xoops.org )
 * ****************************************************************************
 *  XNEWSLETTER - MODULE FOR XOOPS
 *  Copyright (c) 2007 - 2012
 *  Goffy ( wedega.com )
 *
 *  You may not change or alter any portion of this comment or credits
 *  of supporting developers from this source code or any supporting
 *  source code which is considered copyrighted (c) material of the
 *  original comment or credit authors.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *  ---------------------------------------------------------------------------
 * @copyright  Goffy ( wedega.com )
 * @license    GPL 2.0
 * @package    xnewsletter
 * @author     Goffy ( [email protected] )
 *
 * ****************************************************************************
 */

use Xmf\Request;

$currentFile = basename(__FILE__);
require_once __DIR__ . '/admin_header.php';
xoops_cp_header();

// set template
$templateMain = 'xnewsletter_admin_import.tpl';

define('XNEWSLETTER_BASIC_LIMIT_IMPORT_CHECKED', 100);
define('XNEWSLETTER_BASIC_LIMIT_IMPORT_AT_ONCE', 10);

$op                 = Request::getString('op', 'default');
$plugin             = Request::getString('plugin', 'csv');
$cat_id             = Request::getInt('cat_id', 0, 'int');
$action_after_read  = Request::getInt('action_after_read', 1);
$start              = Request::getInt('start', 0);
$limitcheck         = Request::getInt('limitcheck', XNEWSLETTER_BASIC_LIMIT_IMPORT_CHECKED);
$skipcatsubscrexist = Request::getInt('skipcatsubscrexist', 1);
$check_import       = Request::getInt('check_import', 0);

$adminObject->displayNavigation($currentFile);

switch ($op) {
    case 'show_formcheck':
        $adminObject->addItemButton(_AM_XNEWSLETTER_IMPORT_PLUGINS_AVAIL, $currentFile, 'list');
        $GLOBALS['xoopsTpl']->assign('buttons', $adminObject->renderButton('left'));

        $importCriteria = new \CriteriaCompo();
        $importCriteria->setSort('import_id');
        $importCriteria->setOrder('ASC');
        $importsCount = $helper->getHandler('Import')->getCount($importCriteria);

        $importCriteria->setStart($start);
        $importCriteria->setLimit($limitcheck);
        $importObjs = $helper->getHandler('Import')->getAll($importCriteria);

        if ($importsCount > 0) {
            require_once XOOPS_ROOT_PATH . '/class/xoopsformloader.php';

            $action    = $_SERVER['REQUEST_URI'];
            $unique_id = uniqid(mt_rand(), true);
            $form      = '<br>';
            $form      .= "<form name=\"form_import_{$unique_id}\" id=\"form_import_{$unique_id}\" action=\"{$currentFile}\" method=\"post\" enctype=\"multipart/form-data\">";

            $showlimit = str_replace('%s', $start + 1, _AM_XNEWSLETTER_IMPORT_SHOW);
            if ($limitcheck < $importsCount) {
                $showlimit = str_replace('%l', $limitcheck, $showlimit);
            } else {
                $showlimit = str_replace('%l', $importsCount, $showlimit);
            }
            $showlimit = str_replace('%n', $importsCount, $showlimit);

            $form .= "
            <table width='100%' cellspacing='1' class='outer'>
            <tr>
                <td align='left' colspan='8'>" . $showlimit . '</td>
            </tr>';

            $class = 'odd';
            $form  .= '
            <tr>
                <th>&nbsp;</th>
                <th>' . _AM_XNEWSLETTER_SUBSCR_EMAIL . '</th>
                <th>' . _AM_XNEWSLETTER_SUBSCR_SEX . '</th>
                <th>' . _AM_XNEWSLETTER_SUBSCR_FIRSTNAME . '</th>
                <th>' . _AM_XNEWSLETTER_SUBSCR_LASTNAME . '</th>
                <th>' . _AM_XNEWSLETTER_IMPORT_EMAIL_EXIST . '</th>
                <th>' . _AM_XNEWSLETTER_IMPORT_CATSUBSCR_EXIST . '</th>
                <th>' . _AM_XNEWSLETTER_CAT_NAME . '</th>
            </tr>';

            $class   = 'odd';
            $counter = 0;

            //get data for dropdown with cats
            $catCriteria = new \CriteriaCompo();
            $catCriteria->setSort('cat_id ASC, cat_name');
            $catCriteria->setOrder('ASC');
            $catObjs = $helper->getHandler('Cat')->getAll($catCriteria);

            foreach ($importObjs as $i => $importObj) {
                ++$counter;
                $form  .= "<tr class='{$class}'>";
                $class = ('even' === $class) ? 'odd' : 'even';
                $form  .= '<td>' . $counter;
                $form  .= "<input type='hidden' name='import_id_{$counter}' title='import_id_{$counter}' id='import_id_{$counter}' value='" . $importObj->getVar('import_id') . "'>";
                $form  .= '</td>';
                $form  .= '<td>';
                $form  .= "<input type='text' disabled=disabled name='email_{$counter}' title='" . _AM_XNEWSLETTER_SUBSCR_EMAIL . "' id='email_{$counter}' value='" . $importObj->getVar('import_email') . "'>";
                $form  .= '</td>';

                $form .= '<td>';
                $sex  = $importObj->getVar('import_sex');
                $form .= "<select size='1' name='sex_{$counter}' id='sex_{$counter}' title='" . _AM_XNEWSLETTER_SUBSCR_SEX . "' ";
                $form .= "value='" . $sex . "'>";
                $form .= "<option value=''";
                if (_AM_XNEWSLETTER_SUBSCR_SEX_EMPTY == $sex) {
                    $form .= ' selected';
                }
                $form .= '>' . _AM_XNEWSLETTER_SUBSCR_SEX_EMPTY . '</option>';
                $form .= "<option value='" . _AM_XNEWSLETTER_SUBSCR_SEX_FEMALE . "'";
                if (_AM_XNEWSLETTER_SUBSCR_SEX_FEMALE == $sex) {
                    $form .= ' selected';
                }
                $form .= '>' . _AM_XNEWSLETTER_SUBSCR_SEX_FEMALE . '</option>';
                $form .= "<option value='" . _AM_XNEWSLETTER_SUBSCR_SEX_MALE . "'";
                if (_AM_XNEWSLETTER_SUBSCR_SEX_MALE == $sex) {
                    $form .= ' selected';
                }
                $form .= '>' . _AM_XNEWSLETTER_SUBSCR_SEX_MALE . '</option>';
                $form .= "<option value='" . _AM_XNEWSLETTER_SUBSCR_SEX_COMP . "'";
                if (_AM_XNEWSLETTER_SUBSCR_SEX_COMP == $sex) {
                    $form .= ' selected';
                }
                $form .= '>' . _AM_XNEWSLETTER_SUBSCR_SEX_COMP . '</option>';
                $form .= "<option value='" . _AM_XNEWSLETTER_SUBSCR_SEX_FAMILY . "'";
                if (_AM_XNEWSLETTER_SUBSCR_SEX_FAMILY == $sex) {
                    $form .= ' selected';
                }
                $form .= '>' . _AM_XNEWSLETTER_SUBSCR_SEX_FAMILY . '</option>';
                $form .= "</select>\n";
                $form .= '</td>';

                $form      .= '<td>';
                $form      .= "<input type='text' name='firstname_{$counter}' title='" . _AM_XNEWSLETTER_SUBSCR_FIRSTNAME . "' id='firstname_{$counter}' value='" . $importObj->getVar('import_firstname') . "'>";
                $form      .= '</td>';
                $form      .= '<td>';
                $form      .= "<input type='text' name='lastname_{$counter}' title='" . _AM_XNEWSLETTER_SUBSCR_LASTNAME . "' id='lastname_{$counter}' value='" . $importObj->getVar('import_lastname') . "'>";
                $form      .= '</td>';
                $form      .= '<td>';
                $subscr_id = $importObj->getVar('import_subscr_id');
                $form      .= "<input type='hidden' name='subscr_id_{$counter}' title='subscr_id' id='subscr_id_{$counter}' value='" . $subscr_id . "'>";
                if ($subscr_id > 0) {
                    $form .= "<img src='" . XNEWSLETTER_ICONS_URL . "/xn_ok.png' alt='" . _AM_XNEWSLETTER_IMPORT_EMAIL_EXIST . "' title='" . _AM_XNEWSLETTER_IMPORT_EMAIL_EXIST . "'>";
                }
                $form         .= '</td>';
                $form         .= '<td>';
                $catsubscr_id = $importObj->getVar('import_catsubscr_id');
                $form         .= "<input type='hidden' name='catsubscr_id_{$counter}' title='catsubscr_id' id='catsubscr_id_{$counter}' value='" . $catsubscr_id . "'>";
                if ($catsubscr_id > 0) {
                    $form .= "<img src='" . XNEWSLETTER_ICONS_URL . "/xn_ok.png' alt='" . _AM_XNEWSLETTER_IMPORT_CATSUBSCR_EXIST . "' title='" . _AM_XNEWSLETTER_IMPORT_CATSUBSCR_EXIST . "'>";
                }
                $form        .= '</td>';
                $form        .= '</td>';
                $form        .= '<td>';
                $curr_cat_id = $importObj->getVar('import_cat_id');
                $form        .= "<select size='1' name='cat_id_{$counter}' id=\"cat_id_{$counter}' title='cat' ";
                $form        .= "value='" . $curr_cat_id . "'>";
                $cat_select  = "<option value='0'";
                $cat_select  .= '>' . _AM_XNEWSLETTER_IMPORT_NOIMPORT . '</option>';
                foreach ($catObjs as $cat_id => $catObj) {
                    $cat_select .= "<option value='" . $cat_id . "'";
                    if ($curr_cat_id == $cat_id) {
                        $cat_select .= ' selected';
                    }
                    $cat_select .= '>' . $catObj->getVar('cat_name') . '</option>';
                }

                $form .= $cat_select;
                $form .= "</select>\n";

                $form .= '</td>';
                $form .= '</tr>';
            }
            $form  .= "<tr class='{$class}'>";
            $class = ('even' === $class) ? 'odd' : 'even';
            $form  .= "<td colspan='8'>";
            $form  .= "<input type='hidden' name='counter' title='counter' id='counter' value='{$counter}'>";
            $form  .= "<input type='hidden' name='limitcheck' title='limitcheck' id='limitcheck' value='" . $limitcheck . "'>";
            $form  .= "<input type='hidden' name='op' title='op' id='op' value='apply_import_form'>";
            $form  .= "<input type='submit' class='formButton' name='submit' id='submit' value='" . _AM_XNEWSLETTER_IMPORT_EXEC . "' title='" . _AM_XNEWSLETTER_IMPORT_EXEC . "'>";
            $form  .= '</td></tr>';

            $form .= '</table></form>';
            $GLOBALS['xoopsTpl']->assign('form', $form);
        }
        break;
    case 'apply_import_form':
        //update xnewsletter with settings form_import
        $counter = Request::getInt('counter', 0);

        for ($i = 1; $i < ($counter + 1); ++$i) {
            $import_id        = Request::getString("import_id_{$i}", 'default');
            $subscr_firstname = Request::getString("firstname_{$i}", '');
            $subscr_lastname  = Request::getString("lastname_{$i}", '');
            $subscr_sex       = Request::getString("sex_{$i}", '');
            $cat_id           = Request::getInt("cat_id_{$i}", 0);

            if ($cat_id > 0) {
                if (0 == $subscr_id) {
                    //update sex, firstname, lastname
                    $sql    = "UPDATE {$xoopsDB->prefix('xnewsletter_import')}";
                    $sql    .= " SET `import_sex`='{$subscr_sex}', `import_firstname`='{$subscr_firstname}', `import_lastname`='{$subscr_lastname}'";
                    $sql    .= " WHERE `import_id`={$import_id}";
                    $result = $xoopsDB->queryF($sql);
                }
            }
            //update cat_id and import_status
            $sql    = "UPDATE {$xoopsDB->prefix('xnewsletter_import')}";
            $sql    .= " SET `import_cat_id`='{$cat_id}', `import_status`=1";
            $sql    .= " WHERE `import_id`={$import_id}";
            $result = $xoopsDB->queryF($sql);
        }

        redirect_header("?op=exec_import_final&check_import=1&limitcheck={$limitcheck}", 0, '');
        break;
    case 'exec_import_final':
        //execute final import of all data from xnewsletter_import, where import_status = true
        //delete data from xnewsletter_import, when imported (successful or not)
        $adminObject->addItemButton(_AM_XNEWSLETTER_IMPORT_PLUGINS_AVAIL, $currentFile, 'list');
        $GLOBALS['xoopsTpl']->assign('buttons', $adminObject->renderButton('left'));

        $ip        = xoops_getenv('REMOTE_ADDR');
        $submitter = $xoopsUser->uid();

        $importCriteria = new \CriteriaCompo();
        $importCriteria->add(new \Criteria('import_status', true));
        $numrows_total = $helper->getHandler('Import')->getCount();
        $numrows_act   = $helper->getHandler('Import')->getCount($importCriteria);
        if ($numrows_act > 0) {
            $sql     = 'SELECT *';
            $sql     .= " FROM {$xoopsDB->prefix('xnewsletter_import')}";
            $sql     .= ' WHERE ((import_status)=1)';
            $sql     .= ' ORDER BY `import_id` ASC';
            $counter = 0;
            if (!$users_import = $xoopsDB->queryF($sql)) {
                die('MySQL-Error: ' . $GLOBALS['xoopsDB']->error());
            }
            while (null !== ($user_import = mysqli_fetch_assoc($users_import))) {
                $import_id        = $user_import['import_id'];
                $subscr_email     = $user_import['import_email'];
                $subscr_firstname = $user_import['import_firstname'];
                $subscr_lastname  = $user_import['import_lastname'];
                $subscr_sex       = $user_import['import_sex'];
                $cat_id           = $user_import['import_cat_id'];
                $subscr_id        = $user_import['import_subscr_id'];
                $catsubscr_id     = $user_import['import_catsubscr_id'];
                $subscribe        = 0;

                if (0 == $cat_id) {
                    createProtocol(str_replace('%e', $subscr_email, _AM_XNEWSLETTER_IMPORT_RESULT_SKIP), true, $submitter);
                } else {
                    //register email
                    if (0 == $subscr_id) {
                        $subscr_uid = 0;
                        $sql        = 'SELECT `uid`';
                        $sql        .= " FROM {$xoopsDB->prefix('users')}";
                        $sql        .= " WHERE (`email`='{$subscr_email}') LIMIT 1";
                        $user       = $xoopsDB->queryF($sql);
                        if ($user) {
                            $row_user   = $xoopsDB->fetchBoth($user);
                            $subscr_uid = $row_user[0];
                        }
                        unset($row_user);
                        unset($user);

                        $sql = 'INSERT';
                        $sql .= " INTO `{$xoopsDB->prefix('xnewsletter_subscr')}`";
                        $sql .= ' (`subscr_email`, `subscr_firstname`, `subscr_lastname`, `subscr_uid`, `subscr_sex`, `subscr_submitter`, `subscr_created`, `subscr_ip`, `subscr_activated`, `subscr_actoptions`)';
                        $sql .= " VALUES ('{$subscr_email}', '{$subscr_firstname}', '{$subscr_lastname}', " . $subscr_uid . ", '{$subscr_sex}', {$submitter}, " . time() . ",'{$ip}', 1, '')";
                        if (!$xoopsDB->queryF($sql)) {
                            createProtocol(str_replace('%e', $subscr_email, _AM_XNEWSLETTER_IMPORT_RESULT_FAILED), false, $submitter);
                        } else {
                            //register email successful
                            $resulttext = $subscr_email . ': ' . _AM_XNEWSLETTER_IMPORT_RESULT_REG_OK . ' | ';
                            $subscr_id  = $xoopsDB->getInsertId();
                            $subscribe  = 1;
                        }
                    } else {
                        //email already registered
                        $resulttext = $subscr_email . ': ' . _AM_XNEWSLETTER_IMPORT_EMAIL_EXIST . ' | ';
                        $subscribe  = 1;
                    }
                    if (1 == $subscribe) {
                        if (0 == $catsubscr_id) {
                            //add subscription of this email
                            $sql = 'INSERT';
                            $sql .= " INTO `{$xoopsDB->prefix('xnewsletter_catsubscr')}`";
                            $sql .= ' (`catsubscr_catid`, `catsubscr_subscrid`, `catsubscr_submitter`, `catsubscr_created`)';
                            $sql .= " VALUES ({$cat_id}, {$subscr_id}, {$submitter}," . time() . ')';
                            if ($xoopsDB->queryF($sql)) {
                                createProtocol($resulttext . _AM_XNEWSLETTER_IMPORT_RESULT_SUBSCR_OK, true, $submitter);
                                //handle mailinglists
                                $cat_mailinglist = 0;
                                $sql             = 'SELECT `cat_mailinglist`';
                                $sql             .= " FROM {$xoopsDB->prefix('xnewsletter_cat')}";
                                $sql             .= " WHERE (`cat_id`={$cat_id}) LIMIT 1";
                                $cat_mls         = $xoopsDB->queryF($sql);
                                if ($cat_mls) {
                                    $cat_ml          = $xoopsDB->fetchBoth($cat_mls);
                                    $cat_mailinglist = $cat_ml[0];
                                }
                                unset($cat_ml);
                                unset($cat_mls);

                                if ($cat_mailinglist > 0) {
                                    require_once XOOPS_ROOT_PATH . '/modules/xnewsletter/include/mailinglist.php';
                                    subscribingMLHandler(_XNEWSLETTER_MAILINGLIST_SUBSCRIBE, $subscr_id, $cat_mailinglist);
                                }
                            } else {
                                createProtocol(str_replace('%e', $subscr_email, _AM_XNEWSLETTER_IMPORT_RESULT_FAILED), false, $submitter);
                            }
                        } else {
                            createProtocol($resulttext . _AM_XNEWSLETTER_IMPORT_CATSUBSCR_EXIST, true, $submitter);
                        }
                    }
                }
                $sql_del = 'DELETE';
                $sql_del .= " FROM {$xoopsDB->prefix('xnewsletter_import')}";
                $sql_del .= " WHERE `import_id`={$import_id}";
                $result  = $xoopsDB->queryF($sql_del);
            }

            $resulttext = str_replace('%p', $numrows_act, _AM_XNEWSLETTER_IMPORT_FINISHED);
            $resulttext = str_replace('%t', $numrows_total, $resulttext);
            $GLOBALS['xoopsTpl']->assign('resulttext', XNEWSLETTER_IMG_OK . $resulttext);

            $numrows_pend = $helper->getHandler('Import')->getCount();
            if ($numrows_pend > 0) {
                $form_continue = "<form id='form_continue' enctype='multipart/form-data' method='post' action='{$currentFile}' name='form_continue'>";
                $form_continue .= "<input id='submit' class='formButton' type='submit' title='" . _AM_XNEWSLETTER_IMPORT_CONTINUE . "' value='" . _AM_XNEWSLETTER_IMPORT_CONTINUE . "' name='submit'>";
                $form_continue .= '<input id="limitcheck" type="hidden" value="' . $limitcheck . '" name="limitcheck">';
                if (1 == $check_import) {
                    //show next form for check settings
                    $form_continue .= '<input id="op" type="hidden" value="show_formcheck" name="op">';
                } else {
                    // set import_status = 1 for next package
                    $sql_update = 'UPDATE ' . $xoopsDB->prefix('xnewsletter_import') . ' SET `import_status`=1 ORDER BY import_id LIMIT ' . $limitcheck;
                    $xoopsDB->queryF($sql_update);
                    //execute import for the next package
                    $form_continue .= '<input id="op" type="hidden" value="exec_import_final" name="op">';
                }
                $form_continue .= '<input id="action_after_read" type="hidden" value="' . $action_after_read . '" name="action_after_read">';
                $form_continue .= '<input id="limitcheck" type="hidden" value="' . $limitcheck . '" name="limitcheck">';
                $form_continue .= '<input id="plugin" type="hidden" value="' . $plugin . '" name="plugin">';
                $form_continue .= '<input id="check_import" type="hidden" value="' . $check_import . '" name="check_import">';
                $form_continue .= '</form>';
                $GLOBALS['xoopsTpl']->assign('form', $form_continue);
            }
        } else {
            $GLOBALS['xoopsTpl']->assign('error', _AM_XNEWSLETTER_IMPORT_NODATA);
        }
        break;
    case 'searchdata':
        //delete all existing data, import data into xnewsletter_import with plugin
        //set cat_id as preselected, update information about existing registration/subscriptions
        //if ($action_after_read==1) execute import else show form for check before executing import

        $pluginFile = XNEWSLETTER_ROOT_PATH . "/plugins/{$plugin}.php";
        if (!file_exists($pluginFile)) {

            $GLOBALS['xoopsTpl']->assign('error', str_replace('%p', $plugin, _AM_XNEWSLETTER_IMPORT_ERROR_NO_PLUGIN));
            break;
        }
        require_once $pluginFile;

        $function = 'xnewsletter_plugin_getdata_' . $plugin;
        if (!function_exists($function)) {
            $error = "Error: require_once function 'xnewsletter_plugin_getdata_{$plugin}' doesn't exist<br>";
            $error .= str_replace('%f', $plugin, _AM_XNEWSLETTER_IMPORT_ERROR_NO_FUNCTION);
            $GLOBALS['xoopsTpl']->assign('error', $error);
            break;
        }

        //delete all existing data
        $sql    = 'TRUNCATE TABLE ' . $xoopsDB->prefix('xnewsletter_import');
        $result = $xoopsDB->queryF($sql);

        //import data into xnewsletter_import with plugin
        if ('csv' === $plugin) {
            $csv_file      = $_FILES['csv_file']['tmp_name'];
            $csv_header    = Request::getInt('csv_header', 0);
            $csv_delimiter = Request::getString('csv_delimiter', ',');
            //$numData = $function($cat_id, $action_after_read, $limitcheck, $skipcatsubscrexist, $csv_file, $csv_delimiter, $csv_header);
            $numData = call_user_func($function, $cat_id, $action_after_read, $limitcheck, $skipcatsubscrexist, $csv_file, $csv_delimiter, $csv_header);
        } else {
            if ('xoopsuser' === $plugin) {
                $arr_groups = $_POST['xoopsuser_group'];
                //$numData = $function($cat_id, $action_after_read, $limitcheck, $skipcatsubscrexist, $arr_groups);
                $numData = call_user_func($function, $cat_id, $action_after_read, $limitcheck, $skipcatsubscrexist, $arr_groups);
            } else {
                //$numData = $function($cat_id, $action_after_read, $limitcheck, $skipcatsubscrexist);
                $numData = call_user_func($function, $cat_id, $action_after_read, $limitcheck, $skipcatsubscrexist);
            }
        }

        if ($numData > 0) {
            if (0 == $action_after_read) {
                //execute import without check
                redirect_header("{$currentFile}?op=exec_import_final&action_after_read=0&limitcheck={$limitcheck}", 0, '');
            } else {
                //show form for check before executing import
                redirect_header("{$currentFile}?op=show_formcheck&action_after_read=1&plugin={$plugin}&limitcheck={$limitcheck}", 0, '');
            }
        } else {
            redirect_header($currentFile, 3, _AM_XNEWSLETTER_IMPORT_NODATA);
        }
        break;
    case 'form_additional':
        //show form for additional settings
        $adminObject->addItemButton(_AM_XNEWSLETTER_IMPORT_PLUGINS_AVAIL, $currentFile, 'list');
        $GLOBALS['xoopsTpl']->assign('buttons', $adminObject->renderButton('left'));

        $pluginFile = XNEWSLETTER_ROOT_PATH . "/plugins/{$plugin}.php";
        if (!file_exists($pluginFile)) {

            $GLOBALS['xoopsTpl']->assign('error', str_replace('%p', $plugin, _AM_XNEWSLETTER_IMPORT_ERROR_NO_PLUGIN));
            break;
        }
        require_once $pluginFile;

        $function = "xnewsletter_plugin_getform_{$plugin}";
        if (!function_exists($function)) {
            $GLOBALS['xoopsTpl']->assign('error', str_replace('%f', $plugin, _AM_XNEWSLETTER_IMPORT_ERROR_NO_FUNCTION));
            break;
        }
        //$form = $function( $cat_id, $action_after_read, $limitcheck, $skipcatsubscrexist );
        $form = call_user_func($function, $cat_id, $action_after_read, $limitcheck, $skipcatsubscrexist);
        $GLOBALS['xoopsTpl']->assign('form', $form->render());
        break;
    case 'default':
    default:
        //show basic search form
        $importObj = $helper->getHandler('Import')->create();
        $form      = $importObj->getSearchForm($plugin, $action_after_read, $limitcheck);
        $GLOBALS['xoopsTpl']->assign('form', $form->render());
        break;
}
require_once __DIR__ . '/admin_footer.php';

/**
 * @param $prot_text
 * @param $success
 * @param $submitter
 */
function createProtocol($prot_text, $success, $submitter)
{
    global $xoopsDB;
    $sql = "INSERT INTO `{$xoopsDB->prefix('xnewsletter_protocol')}`";
    $sql .= ' (`protocol_letter_id`, `protocol_subscriber_id`, `protocol_status`, `protocol_success`, `protocol_submitter`, `protocol_created`)';
    $sql .= " VALUES (0,0,'{$prot_text}', {$success}, {$submitter}, " . time() . ')';
    if (!$xoopsDB->queryF($sql)) {
        die('MySQL-Error: ' . $GLOBALS['xoopsDB']->error());
    }
}

XoopsModules25x / xnewsletter

import.php ➔ createProtocol() A last analyzed 2020-08-07 11:59 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

import.php ➔ createProtocol() A
last analyzed 2020-08-07 11:59 UTC
