xyzshop/plot/refill/ChannelCalc.py

from .CalcBase import CalcBase
from .DataStream import EChPosmap as pos_map, span_days
from .ChannelReader import ChannelReader

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


def detail_pathes(reader: ChannelReader, tuple_pathes: dict, days: list):
    count = len(days)
    for name, tup in tuple_pathes.items():
        for _card_type, _spec in tup:
            detail_datas = reader.init_data(count)
            for i, day in enumerate(days):
                data = reader.read(day, name, _card_type, _spec)
                if data is not None:
                    column_pos = i * 86400
                    view = detail_datas[:, column_pos:column_pos + 86400]
                    view += data
            yield name, _card_type, _spec, detail_datas


class ChannelCalc(CalcBase):
    def _reader(self):
        return ChannelReader()
    pass