xyzshop/test/TestBigData.php

<?php


use PHPUnit\Framework\TestCase;

define('APP_ID', 'test');
define('BASE_ROOT_PATH', str_replace('/test', '', dirname(__FILE__)));

require_once(BASE_ROOT_PATH . '/global.php');
require_once(BASE_CORE_PATH . '/lrlz.php');
require_once(BASE_ROOT_PATH . '/fooder.php');
require_once(BASE_HELPER_PATH . '/refill/RefillFactory.php');



class TestBigData extends TestCase
{
    public static function setUpBeforeClass(): void
    {
        Base::run_util();
    }

    public function testParserRatios()
    {
        # 'commit-succ': 0, 'commit-fail': 1, 'notify-succ': 2, 'notify-fail': 3
        $json = "{\"time\": 1624256280, \"ratios\": {\"feinimoshu_hf-100-5-1\": [0, 0, 0, 0], \"feinimoshu_hf-200-5-1\": [0, 0, 0, 0], \"gftd-100-2-5\": [0, 0, 7, 1], \"gftd-1000-2-5\": [0, 0, 0, 1], \"gftd-200-2-5\": [0, 0, 9, 0], \"gftd-500-2-5\": [0, 0, 1, 0], \"gftdsinop-100-2-5\": [8, 0, 0, 0], \"gftdsinop-1000-2-5\": [1, 0, 0, 0], \"gftdsinop-200-2-5\": [7, 0, 0, 0], \"gftdsinop-500-2-5\": [1, 0, 0, 0], \"lingzh-100-4-1\": [0, 0, 0, 0], \"lingzh-200-4-1\": [0, 0, 0, 0], \"lingzh-30-4-1\": [0, 0, 0, 0], \"lingzh-50-4-1\": [0, 0, 0, 0], \"lingzh-100-5-1\": [0, 0, 0, 0], \"lingzh-200-5-1\": [0, 0, 0, 0], \"lingzh-30-5-1\": [18, 0, 1, 18], \"lingzh-50-5-1\": [24, 0, 1, 23], \"lingzh-100-6-1\": [0, 0, 0, 0], \"lingzh-300-6-1\": [0, 0, 0, 0], \"lingzh-100-4-5\": [5, 0, 4, 0], \"lingzh-200-4-5\": [1, 0, 0, 0], \"lingzh-100-5-5\": [2, 0, 4, 0], \"lingzh-200-5-5\": [0, 0, 0, 0], \"lingzh-100-6-5\": [0, 0, 0, 0], \"lingzh-200-6-5\": [0, 0, 0, 0], \"lingzhoil-100-2-1\": [7, 0, 1, 2], \"lingzhoil-1000-2-1\": [0, 0, 0, 0], \"lingzhoil-200-2-1\": [5, 0, 0, 3], \"lingzhoil-500-2-1\": [0, 0, 0, 0], \"moxj-100-5-1\": [0, 0, 0, 0], \"moxj-200-5-1\": [0, 0, 0, 0], \"moxj-30-5-1\": [49, 5, 2, 48], \"moxj-50-5-1\": [49, 0, 6, 41], \"qianqian-100-4-1\": [5, 0, 2, 4], \"qianqian-200-4-1\": [0, 0, 0, 0], \"qianqian-30-4-1\": [67, 0, 2, 65], \"qianqian-50-4-1\": [0, 0, 0, 0], \"qianqian-100-5-1\": [0, 0, 0, 0], \"qianqian-200-5-1\": [0, 0, 0, 0], \"qianqian-30-5-1\": [16, 0, 0, 17], \"qianqian-50-5-1\": [2, 0, 0, 3], \"qianqian-100-6-1\": [0, 0, 0, 0], \"weiyiwt-100-4-1\": [2, 0, 0, 2], \"weiyiwt-200-4-1\": [0, 0, 0, 0], \"weiyiwt-30-4-1\": [0, 0, 0, 0], \"weiyiwt-50-4-1\": [0, 0, 0, 0], \"weiyiwt-100-6-1\": [6, 0, 1, 7], \"weiyiwt-200-6-1\": [1, 0, 0, 1], \"weiyiwt-30-6-1\": [4, 0, 2, 4], \"weiyiwt-50-6-1\": [3, 0, 1, 3], \"yinteng-100-6-1\": [0, 0, 0, 0], \"yunling-100-4-1\": [0, 0, 0, 0], \"yunling-200-4-1\": [0, 0, 0, 0], \"yunling-30-4-1\": [0, 0, 0, 0], \"yunling-50-4-1\": [0, 0, 0, 0], \"yunling-100-5-1\": [0, 0, 0, 0], \"yunling-200-5-1\": [0, 0, 0, 0], \"yunling-30-5-1\": [373, 0, 14, 348], \"yunling-50-5-1\": [67, 0, 2, 78], \"yunling-100-6-1\": [0, 0, 0, 0], \"yunlingfs-100-4-1\": [0, 0, 0, 0], \"yunlingfs-200-4-1\": [0, 0, 0, 0], \"yunlingfs-30-4-1\": [10, 0, 0, 7], \"yunlingfs-50-4-1\": [0, 0, 0, 0], \"yunsuoyao-100-5-1\": [0, 0, 0, 0], \"yunsuoyao-200-5-1\": [0, 0, 0, 0], \"zanzanquick-100-5-1\": [0, 0, 0, 1], \"zanzanquick-200-5-1\": [0, 0, 0, 0]}}";
        $val = json_decode($json,true);
        $ratios = $val['ratios'];
        refill\RefillFactory::instance()->UpdateRatio($ratios);
    }

    public function testCache()
    {
        $ins = Cache::getInstance('cacheredis');
        $val = $ins->get_org('channel_ratios');
        Log::record("subscribe_message channel_ratios val={$val}",Log::DEBUG);
        if(empty($val));
        $val = json_decode($val,true);
        if(empty($val));
        $ratios = $val['ratios'];
        if(empty($ratios));

    }
}