newsletter_send.php

Go to the documentation of this file.

<?php

class Newsletter_Send extends Newsletter_Selection
{
    protected $_aMailErrors = array();

    public function render()
    {
        oxAdminDetails::render();

        // calculating
        $iUserCount = $this->getUserCount();

        $iStart = (int) oxConfig::getParameter( "iStart" );

        $oNewsletter = oxNew( "oxNewsLetter" );
        $oNewsletter->load( $this->getEditObjectId() );
        $oNewsletterGroups = $oNewsletter->getGroups();

        // send emails....
        $oDB = oxDb::getDb( oxDB::FETCH_MODE_ASSOC );
        $sQGroups = " ( oxobject2group.oxgroupsid in ( ";
        $blSep = false;
        foreach ( $oNewsletterGroups as $sInGroup ) {
            $sSearchKey = $sInGroup->oxgroups__oxid->value;
            if ( $blSep ) {
                $sQGroups .= ",";
            }
            $sQGroups .= $oDB->quote( $sSearchKey );
            $blSep = true;
        }
        $sQGroups .= ") )";

        // no group selected
        if ( !$blSep ) {
            $sQGroups = " oxobject2group.oxobjectid is null ";
        }

        $myConfig  = $this->getConfig();

        $iSendCnt = 0;
        $iMaxCnt  = (int) $myConfig->getConfigParam( 'iCntofMails' );
        $sShopId  = $myConfig->getShopId();

        $sQ = "select oxnewssubscribed.oxuserid, oxnewssubscribed.oxemail, oxnewssubscribed.oxsal,
               oxnewssubscribed.oxfname, oxnewssubscribed.oxlname, oxnewssubscribed.oxemailfailed
               from oxnewssubscribed left join oxobject2group on
               oxobject2group.oxobjectid = oxnewssubscribed.oxuserid where
               ( oxobject2group.oxshopid = '{$sShopId}' or oxobject2group.oxshopid is null ) and
               $sQGroups and oxnewssubscribed.oxdboptin = 1 and oxnewssubscribed.oxshopid = '{$sShopId}'
               group by oxnewssubscribed.oxemail";

        $oRs = $oDB->selectLimit( $sQ, 100, $iStart );
        $blContinue = ( $oRs != false && $oRs->recordCount() > 0 );

        if ( $blContinue ) {
            $blLoadAction = $myConfig->getConfigParam( 'bl_perfLoadAktion' );
            while ( !$oRs->EOF && $iSendCnt < $iMaxCnt ) {

                if ( $oRs->fields['oxemailfailed'] != "1" ) {
                    $sUserId = $oRs->fields['oxuserid'];
                    $iSendCnt++;

                    // must check if such user is in DB
                    if ( !$oDB->getOne( "select oxid from oxuser where oxid = ".$oDB->quote( $sUserId ), false, false ) ) {
                        $sUserId = null;
                    }

                    // #559
                    if ( !isset( $sUserId ) || !$sUserId ) {
                         // there is no user object so we fake one
                        $oUser = oxNew( "oxuser" );
                        $oUser->oxuser__oxusername = new oxField( $oRs->fields['oxemail'] );
                        $oUser->oxuser__oxsal      = new oxField( $oRs->fields['oxsal'] );
                        $oUser->oxuser__oxfname    = new oxField( $oRs->fields['oxfname'] );
                        $oUser->oxuser__oxlname    = new oxField( $oRs->fields['oxlname'] );
                        $oNewsletter->prepare( $oUser, $blLoadAction );
                    } else {
                        $oNewsletter->prepare( $sUserId, $blLoadAction );
                    }

                    if ( $oNewsletter->send( $iSendCnt ) ) {
                         // add user history
                        $oRemark = oxNew( "oxremark" );
                        $oRemark->oxremark__oxtext     = new oxField( $oNewsletter->getPlainText() );
                        $oRemark->oxremark__oxparentid = new oxField( $sUserId );
                        $oRemark->oxremark__oxshopid   = new oxField( $sShopId );
                        $oRemark->oxremark__oxtype     = new oxField( "n" );
                        $oRemark->save();
                    } else {
                        $this->_aMailErrors[] = "problem sending to : ".$oRs->fields['oxemail'];
                    }
                }

                $oRs->moveNext();
                $iStart++;
            }
        }

        $iSend = $iSendCnt + ( ceil( $iStart / $iMaxCnt ) - 1 ) * $iMaxCnt;
        $iSend = $iSend > $iUserCount ? $iUserCount : $iSend;

        $this->_aViewData["iStart"] = $iStart;
        $this->_aViewData["iSend"]  = $iSend;

        // end ?
        if ( $blContinue ) {
            return "newsletter_send.tpl";
        } else {
            $this->resetUserCount();
            return "newsletter_done.tpl";
        }
    }

    public function getUserCount()
    {
        $iCnt = oxSession::getVar( "iUserCount" );
        if ( $iCnt === null ) {
            $iCnt = parent::getUserCount();
            oxSession::setVar( "iUserCount", $iCnt );
        }
        return $iCnt;
    }

    public function resetUserCount()
    {
        oxSession::deleteVar( "iUserCount" );
        $this->_iUserCount = null;
    }

    public function getMailErrors()
    {
        return $this->_aMailErrors;
    }

    protected function _setupNavigation( $sNode )
    {
        $sNode = 'newsletter_list';

        $myAdminNavig = $this->getNavigation();

        // active tab
        $iActTab = 3;

        // tabs
        $this->_aViewData['editnavi'] = $myAdminNavig->getTabs( $sNode, $iActTab );

        // active tab
        $this->_aViewData['actlocation'] = $myAdminNavig->getActiveTab( $sNode, $iActTab );

        // default tab
        $this->_aViewData['default_edit'] = $myAdminNavig->getActiveTab( $sNode, $this->_iDefEdit );

        // passign active tab number
        $this->_aViewData['actedit'] = $iActTab;
    }

    public function getListSorting()
    {
    }
}