添加必要的数据日志

admin

3 天以前 0b0d0e790fec8c7edfdbcab5c31d625e0c2eadd6

 strategy/kpl_data_manager.py

@@ -1,5 +1,6 @@
from log_module import log_export, async_log_util
from log_module.log import logger_stock_of_markets_plate, logger_debug, logger_kpl_market_sift_plate
from log_module.log import logger_stock_of_markets_plate, logger_debug, logger_kpl_market_sift_plate, \
    logger_stock_of_markets_plate_simple
from utils import tool


@@ -71,11 +72,18 @@
    def add_log(self, in_plates_info, plate_codes_info):
        oringin_data = (tool.get_now_time_str(), in_plates_info, plate_codes_info)
        async_log_util.info(logger_stock_of_markets_plate, f"{(oringin_data[1], oringin_data[2])}")
        plate_codes_simple_info = {plate: [(s[1], s[0], s[6], s[9], s[4], s[2], s[40]) for s in oringin_data[2][plate]] for plate in oringin_data[2]}
        async_log_util.info(logger_stock_of_markets_plate_simple, f"{(oringin_data[1], plate_codes_simple_info)}")

    def get_filter_log_datas(self):
        return self.__filter_log_datas


if __name__ == '__main__':
    KPLMarketsSiftPlateLogManager().load_data()
    # KPLMarketsSiftPlateLogManager().load_data()
    # KPLMarketStockHeatLogManager()
    with open("D:/text.txt", encoding='utf-8', mode='r') as f:
        line = f.readline()
        res = eval(line)
        KPLMarketStockHeatLogManager().add_log(res[0], res[1])
        print(res)