kuaileorder/queue/deal/sync_historical_orders.php

<?php

/**
 * 同步历史订单
 */
include_once dirname(dirname(__FILE__)).'/base/dealBase.php';

class syncHistoricalOrders extends dealBase {

    public function setPara() {
        $this->processnum = $GLOBALS['DAEMON_NUMLIMIT'][DAEMON_SYNC_HISTORICAL_ORDERS];
//         $this->is_while = false;
    }

    public function deal() {
        $obj = new mOrder();
        $rdobj = $obj->initRedis();
        $jsondata = $rdobj->rpop(_RQ_SYNC_HISTORICAL_ORDERS);
        if ($jsondata === false) exit();

        $data = json_decode($jsondata, true);

        $start_date = $data['start_date'];
        $name = $data['name'];

        $sobj = new mShop();
        $shopinfo = $sobj->getShopByName($name);
        if (empty($shopinfo)) return false;

        $pobj = new mPdd();
        for ($page=1;;$page++) {
            $trades = $pobj->getPddOrderList($name, $start_date.' 00:00:00', $start_date.' 23:59:59', ORDER_STATUS_FULL, REFUND_STATUS_FULL, $page, 100);
            if (!$trades) break;
            if (empty($trades['order_list'])) break;

            $obj->addOrders($trades['order_list'], $shopinfo['id'], $shopinfo['uid']);

            if ($trades['has_next'] != true) break;


        }

    }

}

new syncHistoricalOrders();