xyzshop/helper/fcode/send_manager.php

<?php
/**
 * Created by PhpStorm.
 * User: stanley-king
 * Date: 2017/5/11
 * Time: 上午11:56
 */

namespace fcode;

require_once (BASE_ROOT_PATH . '/helper/message/msgutil.php');
require_once (BASE_ROOT_PATH . '/helper/special_helper.php');


use StatesHelper;
use Log;
use special_manager;

class send_manager
{
    public static $stInstance;
    private $mGoodsBlock;
    private $mAmountGoods;

    private function __construct()
    {
    }

    static public function instance()
    {
        if(self::$stInstance == null) {
            self::$stInstance = new send_manager();
        }
        if(StatesHelper::fetch_state('fcode')) {
            Log::record("fcode reinit data.",Log::DEBUG);
            self::$stInstance->init();
        }

        return self::$stInstance;
    }

    private function init()
    {
        $this->mAmountGoods = [];
        $this->mGoodsBlock  = [];

        global $config;
        $fcodes_id = $config['paysuccess_fcodes']['fcodes_id'];
        $blocks = special_manager::instance()->special($fcodes_id,$goods_ids);

        foreach ($blocks as $block)
        {
            $item_type  = $block['item_type'];
            $item_title = $block['item_title'];
            $amount = intval($item_title);
            if($item_type == 'home1' && $amount > 0)
            {
                $items = $block['items'];
                if(empty($items)) continue;

                $item = $items[0];
                $batch_code = $item['title'];
                if(!empty($batch_code)) {
                    $this->add($amount,$item,$block);
                }
            }
        }

        krsort($this->mAmountGoods);
    }

    private function add($amount,$item,$block)
    {
        $goods_id = intval($item['data']);
        if($goods_id <= 0) return;

        if(array_key_exists($amount,$this->mAmountGoods) == false) {
            $this->mAmountGoods[$amount] = [];
        }
        $this->mAmountGoods[$amount][] = $goods_id;
        $this->mGoodsBlock[$goods_id] = $block;
    }

    public function fetch($amount)
    {
        $amount = intval($amount);
        if($amount <= 0) return false;

        $gids = [];
        foreach ($this->mAmountGoods as $key => $goods_ids)
        {
            if(empty($goods_ids)) continue;

            if($key <= $amount)
            {
                foreach ($goods_ids as $gid) {
                    $gids[] = $gid;
                }
            }
        }
        if(empty($gids)) {
            return false;
        }

        $result = $this->validate_one($gids);
        return $result;
    }

    private function validate_one($gids)
    {
        $mod_goods  = Model('goods');
        $goods_list = $mod_goods->getGoodsOnlineList(array('goods_id' => array('in', $gids),'goods_storage' => array('gt',0),'is_fcode' => 1));
        if(empty($goods_list)) return false;

        $all_goods = [];
        foreach ($goods_list as $goods) {
            $gid = intval($goods['goods_id']);
            $all_goods[$gid] = $goods;
        }


        foreach ($gids as $gid)
        {
            if(array_key_exists($gid,$all_goods))
            {
                $goods = $all_goods[$gid];
                $commonid = $goods['goods_commonid'];

                $block = $this->mGoodsBlock[$gid];
                $batch_code = $block['items'][0]['title'];

                $oper = new operator($commonid,$batch_code);
                //todo 测试完成之后需要关闭掉
                //if($oper->grabed()) continue;
                $fcode = $oper->grab();
                if($fcode != false) {
                    return ['fcode' => $fcode,'banner' => $block];
                }
            }
        }

        return false;
    }
}