xyzshop/plot/refill/ChSpeedCalc.py

from .ChannelCalc import ChannelCalc, detail_paths
from .algorithm import calc_chspeed
from .DataStream import EChPosmap as pos_map
from .ChannelReader import ChannelReader
import time as time
import json
import redis

import logging
logger = logging.getLogger('ChSpeedCalc')

class ChSpeedCalc(ChannelCalc):
    def _calc_handler(self, rclient):
        logger.debug('_calc_handler')

        reader = self._reader()
        end_time = int(time.time() - 86400)
        period = 300
        days, start_time, end_time = self.calc_time(reader, end_time - period, end_time)

        day_stamp = days[0]
        tuple_pathes = reader.many_tuple_path(days, card_types=set([4, 5, 6]))
        gen = detail_paths(reader, tuple_pathes, days)

        mamounts = dict()
        for _name, _card_type, _spec, _data in gen:
            speed = calc_chspeed(_data, pos_map, start_time - day_stamp, end_time - day_stamp)
            logger.debug("_name")



        return 0.1