newsletter_send.php

Go to the documentation of this file.

<?php

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

    public function render()
    {
        $myConfig  = $this->getConfig();
        parent::render();

        $iStart = oxConfig::getParameter( "iStart");
        $iUser  = oxConfig::getParameter( "user");
        $sID      = oxConfig::getParameter( "id");

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

        // #493A - fetching cached newsletter info
        $oCachedNewsletter = oxSession::getVar("_oNewsletter");
        if ( isset($oCachedNewsletter)) {
            //checking if cached session id is the same as current user session id
            if ($oCachedNewsletter->sID != $sID)
                oxSession::deleteVar("_oNewsletter");
            else {
                // setting cached values
                $iStart = $oCachedNewsletter->iStart;
                $iUser  = $oCachedNewsletter->iUser;
                $sID    = $oCachedNewsletter->sID;
            }
        } else {
            // setting initial values
            $oCachedNewsletter = new oxStdClass();
            $oCachedNewsletter->iStart = $iStart;
            $oCachedNewsletter->iUser  = $iUser;
            $oCachedNewsletter->sID    = $sID;
        }

        // send emails....
        $oDB = oxDb::getDb();
        $sSelectGroups =  " ( oxobject2group.oxgroupsid in ( ";
        $blSep = false;
        foreach ( $oNewsletterGroups as $sInGroup) {
            $sSearchKey = $sInGroup->oxgroups__oxid->value;
            if ( $blSep)
                $sSelectGroups .= ",";
            $sSelectGroups .= $oDB->quote( $sSearchKey );
            $blSep = true;
        }
        $sSelectGroups .= ") )";
        // no group selected
        if ( !$blSep)
            $sSelectGroups = " oxobject2group.oxobjectid is null ";

        $sSelect = "select oxnewssubscribed.oxuserid, oxnewssubscribed.oxemail, oxnewssubscribed.oxsal, oxnewssubscribed.oxfname, oxnewssubscribed.oxlname from oxnewssubscribed left join oxobject2group on oxobject2group.oxobjectid = oxnewssubscribed.oxuserid where ( oxobject2group.oxshopid = '".$myConfig->getShopID()."' or oxobject2group.oxshopid is null ) and $sSelectGroups and oxnewssubscribed.oxdboptin = 1 and (not (oxnewssubscribed.oxemailfailed = '1')) and (not(oxnewssubscribed.oxemailfailed = \"1\")) group by oxnewssubscribed.oxemail";

        $rs = $oDB->selectLimit( $sSelect, $myConfig->getConfigParam( 'iCntofMails' ), $iStart);

        ini_set("session.gc_maxlifetime", 36000);

        if ($rs != false && $rs->recordCount() > 0) {
            while (!$rs->EOF) {
                $sUserID = $rs->fields[0];

                // must check if such user is in DB
                if( !$oDB->getOne("select oxid from oxuser where oxid = '$sUserID'"))
                    $sUserID = null;

                // #559
                if ( !isset( $sUserID) || !$sUserID) {
                     // there is no user object so we fake one
                    $oUser = oxNew( "oxuser" );
                    $oUser->oxuser__oxusername = new oxField($rs->fields[1]);
                    $oUser->oxuser__oxsal      = new oxField($rs->fields[2]);
                    $oUser->oxuser__oxfname    = new oxField($rs->fields[3]);
                    $oUser->oxuser__oxlname    = new oxField($rs->fields[4]);
                    $oNewsletter->prepare( $oUser, $myConfig->getConfigParam( 'bl_perfLoadAktion' ) );
                }
                else
                    $oNewsletter->prepare( $sUserID, $myConfig->getConfigParam( 'bl_perfLoadAktion' ) );

                if ( $oNewsletter->send() ) {
                     // add user history
                    $oRemark = oxNew( "oxremark" );
                    $oRemark->oxremark__oxtext     = new oxField($oNewsletter->sPlainText);
                    $oRemark->oxremark__oxparentid = new oxField($sUserID);
                    $sShopID = oxSession::getVar( "actshop");
                    $sShopID = oxSession::setVar( "keepalive", "yes");
                    $oRemark->oxremark__oxshopid   = new oxField($sShopID);
                    $oRemark->save();
                } else {
                    $this->_aMailErrors[] = "problem sending to : ".$rs->fields[1]."<br>";
                }


                   $rs->moveNext();
            }
        }

        // adavance mail pointer and set parameter
        $iStart += $myConfig->getConfigParam( 'iCntofMails' );

        // #493A - setting new values
        $oCachedNewsletter->iStart = $iStart;
        $oCachedNewsletter->iUser  = $iUser;
        $oCachedNewsletter->sID    = $sID;

        $this->_aViewData["iStart"]     =  $iStart;
        $this->_aViewData["user"]     =  $iUser;
        $this->_aViewData["id"]         =  $sID;


        // end ?
        if ( $iStart < $iUser) {
               $sPage = "newsletter_send.tpl";
            // #493A - saving changes
            oxSession::setVar("_oNewsletter", $oCachedNewsletter);
        } else {
           $sPage = "newsletter_done.tpl";
            // #493A - deleting cache variable
            oxSession::deleteVar("_oNewsletter");
        }

        return $sPage;
    }

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

    /*
     * Overrides parent method to pass referred id
     *
     * @param string $sId class name
     */
    protected function _setupNavigation( $sId )
    {
        parent::_setupNavigation( 'newsletter_list' );
    }
}

---