CORE-POS/IS4C

<?php
/*******************************************************************************

    Copyright 2016 Whole Foods Co-op

    This file is part of IT CORE.

    IT CORE is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation; either version 2 of the License, or
    (at your option) any later version.

    IT CORE 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.

    You should have received a copy of the GNU General Public License
    in the file license.txt along with IT CORE; if not, write to the Free Software
    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

*********************************************************************************/

/**
*/
class SatelliteRedisRecv extends FannieTask
{
    public $name = 'Satellite Store Redis Receive';

    public $log_start_stop = false;

    public $default_schedule = array(
        'min' => '4,9,14,19,24,29,34,39,44,49,54,57',
        'hour' => '7-22',
        'day' => '*',
        'month' => '*',
        'weekday' => '*',
    );
    
    public function run()
    {
        if ($this->isLocked()) {
            return false;
        }
        $this->lock();

        $conf = $this->config->get('PLUGIN_SETTINGS');
        $redis_host = $conf['SatelliteRedis'];

        $dbc = FannieDB::get($this->config->get('TRANS_DB'));
        if (!$dbc->isConnected()) {
            echo "No connection";
            $this->unlock();
            return false;
        }

        try {
            $redis = new Predis\Client($redis_host);

            $this->getTrans($dbc, $redis, new DTransactionsModel(null));
            $this->getTrans($dbc, $redis, new PaycardTransactionsModel(null));
            $this->getTrans($dbc, $redis, new CapturedSignatureModel(null), array('capturedSignatureID'));
        } catch (Exception $ex) {
        }

        $this->unlock();
    }

    private function getTrans($dbc, $redis, $model, $skip_columns=array())
    {
        try {
            $cols = array_keys($model->getColumns());
            $cols = array_filter($cols, function($i) use ($skip_columns) { return !in_array($i, $skip_columns); });

            $names = '';
            $vals = '';
            foreach ($cols as $col) {
                $names .= $dbc->identifierEscape($col) . ',';
                $vals .= '?,';
            }
            $insQ = 'INSERT INTO ' . $model->getName() . '
                (' . substr($names, 0, strlen($names)-1) . ') 
                VALUES 
                (' . substr($vals, 0, strlen($vals)-1) . ')';
            $insP = $dbc->prepare($insQ);

            while (($json = $redis->rpop($model->getName())) !== null) {
                $row = json_decode($json, true);
                $args = array();
                foreach ($cols as $col) {
                    if (substr($row[$col], 0, 7) == 'base64:') {
                        $decoded = base64_decode(substr($row[$col], 7));
                        if ($decoded) {
                            $row[$col] = $decoded;
                        }
                    }
                    $args[] = $row[$col];
                }
                $dbc->execute($insP, $args);
            }
        } catch (Exception $ex) {
            // connection to redis failed. 
            // no cleanup required
        }
    }
}