Валидация объектов + транзакции

<?php
class modWebTransactionProcessor extends modObjectProcessor
{
    public function process()
    {
        $startTransaction = false;
        #

        /**
         * transaction start
         */
        if (!$this->modx->pdo->inTransaction())
        {
            $this->modx->beginTransaction();
            $startTransaction = true;
        }
        /**
         * here we call parent::process for the current instance
         */
        $response = $this->_parentprocess();
        #

        /**
         * if we have errors
         */
        $errors = $this->modx->error->getErrors(true);
        if (!count($errors))
        {
            if ($startTransaction)
            {
                $this->modx->commit();
            }
            return $response;
        }
        # else

        /**
         *  if transaction was initialized at current processor instance
         */
        if ($startTransaction)
        {
            $this->modx->rollBack();
        }
        #

        /**
         * msg
         */
        $msg = $response['message'];
        if ($response['errors'])
        {
            $msg = $msg ? $msg : $this->modx->lexicon('error');
        }
        #
        return $this->failure($msg);
    }
}
return 'modWebTransactionProcessor';

if ($this->getOption(xPDO::OPT_VALIDATE_ON_SAVE)) {
    if (!$this->validate()) {
        $msgs = $this->_validator->getMessages();
        $this->xpdo->log(xPDO::LOG_LEVEL_ERROR, print_r($msgs,1));
        foreach($msgs as $msg){
            if(!$this->xpdo->error->hasError()){
                $this->xpdo->error->addField($msg['field'],$msg['message']);
            }else{
                foreach($this->xpdo->error->getErrors(true) as $error){
                    if($error['id'] !== $msg['field'] or $error['msg'] !== $msg['message']){
                        $this->xpdo->error->addField($msg['field'],$msg['message']);

                    }
                }
            }
        }
        return false;
    }
}