CORE-POS/IS4C

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

    Copyright 2011 Whole Foods Co-op

    This file is part of CORE-POS.

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

    CORE-POS 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

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


/* --COMMENTS - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -

    * 22Sep2012 Eric Lee Annotate, esp re cURL.
    *           http://curl.haxx.se/
    *           http://ca.php.net/manual/en/function.curl-setopt.php
    *           See www-data's crontab for where error reports go, e.g.
    *            30 1 * * * cd /var/www/IS4C/fannie/cron && php ./nightly.lanesync.php >> /var/www/IS4C/fannie/logs/dayend.log

*/

/* HELP

   nightly.lanesync.php

   Send the following tables to all lanes:
    products, custdata, memberCards, employees, departments, custReceiptMessage, CustomerNotifications
   Optionally also send:
    productUser

   Uses curl to call Fannie's web-based sync routines

*/

include(dirname(__FILE__) . '/../config.php');
if (!class_exists('FannieAPI')) {
    include(__DIR__ . '/../classlib2.0/FannieAPI.php');
}
if (!function_exists('cron_msg')) {
    include(__DIR__ . '/../src/cron_msg.php');
}
if (!isset($FANNIE_LANES) || !is_array($FANNIE_LANES)) {
    $FANNIE_LANES = array();
}

set_time_limit(0);

$dbc = FannieDB::get($FANNIE_TRANS_DB);
foreach($FANNIE_LANES as $f){
    try {
        $dbc->addConnection($f['host'],$f['type'],$f['trans'],$f['user'],$f['pw']);
    } catch (Exception $ex) {
        echo cron_msg('Cannot connect to '.$f['host']);
        continue;
    }
    if ($dbc->connections[$f['trans']] === False){
        echo cron_msg('Cannot connect to '.$f['host']);
        continue;
    }

    // valutec tables are deprecated and may no longer
    // exist on the lane
    if (!$dbc->table_exists('valutecRequest', $f['trans'])) {
        continue;
    }

    $try = $dbc->transfer($f['trans'],'SELECT * FROM valutecRequest',
            $FANNIE_TRANS_DB,'INSERT INTO valutecRequest');
    if ($try !== False){
        $dbc->query('TRUNCATE TABLE valutecRequest',$f['trans']);
    }

    $try = $dbc->transfer($f['trans'],'SELECT * FROM valutecRequestMod',
            $FANNIE_TRANS_DB,'INSERT INTO valutecRequestMod');
    if ($try !== False){
        $dbc->query('TRUNCATE TABLE valutecRequestMod',$f['trans']);
    }

    $try = $dbc->transfer($f['trans'],'SELECT * FROM valutecResponse',
            $FANNIE_TRANS_DB,'INSERT INTO valutecResponse');
    if ($try !== False){
        $dbc->query('TRUNCATE TABLE valutecResponse',$f['trans']);
    }
}

$url = "http://".php_uname('n').$FANNIE_URL."sync/TableSyncPage.php";

/* curl_init():
 *  Initializes a new session and returns a cURL handle for use with
 * the curl_setopt(), curl_exec(), and curl_close() functions.
*/
$products = curl_init($url."?tablename=products&othertable=");
/* CURLOPT_RETURNTRANSFER:
 * TRUE to return the transfer as a string of the return value of
 * curl_exec() instead of outputting it out directly.
*/
curl_setopt($products, CURLOPT_RETURNTRANSFER, True);
// r1 is apparently never used.
$r1 = curl_exec($products);
// r1 contains a copy of the web page. logging makes a bit of a mess
//echo "Result of tablesync of products: >{$r1}<";
curl_close($products);

// Other tables are done the same way, except as noted.

$custdata = curl_init($url."?tablename=custdata&othertable=");
curl_setopt($custdata, CURLOPT_RETURNTRANSFER, True);
$r1 = curl_exec($custdata);
curl_close($custdata);

// Note use of othertable.
$memcards = curl_init($url."?tablename=&othertable=memberCards");
curl_setopt($memcards, CURLOPT_RETURNTRANSFER, True);
$r1 = curl_exec($memcards);
curl_close($memcards);

// 15May13 EL This table doesn't seem to exist on lanes.
$crm = curl_init($url."?tablename=&othertable=custReceiptMessage");
curl_setopt($crm, CURLOPT_RETURNTRANSFER, True);
$r1 = curl_exec($crm);
curl_close($crm);

$crm = curl_init($url."?tablename=&othertable=CustomerNotifications");
curl_setopt($crm, CURLOPT_RETURNTRANSFER, True);
$r1 = curl_exec($crm);
curl_close($crm);

$employees = curl_init($url."?tablename=employees&othertable=");
curl_setopt($employees, CURLOPT_RETURNTRANSFER, True);
$r1 = curl_exec($employees);
curl_close($employees);

$departments = curl_init($url."?tablename=departments&othertable=");
curl_setopt($departments, CURLOPT_RETURNTRANSFER, True);
$r1 = curl_exec($departments);
curl_close($departments);

if ( isset($FANNIE_COMPOSE_LONG_PRODUCT_DESCRIPTION) && $FANNIE_COMPOSE_LONG_PRODUCT_DESCRIPTION == True ) {
    $productUser = curl_init($url."?tablename=productUser&othertable=");
    curl_setopt($productUser, CURLOPT_RETURNTRANSFER, True);
    $r1 = curl_exec($productUser);
    curl_close($productUser);
}