redis封装

Administrator

2023-08-02 a3c05bddc4c61d63b804ee541cf6dd01717ba94d

 trade/trade_juejin.py

@@ -9,7 +9,7 @@

import constant
from code_attribute import gpcode_manager
from db.redis_manager import RedisManager
from db.redis_manager import RedisManager, RedisUtils
from log_module.log import logger_juejin_trade
from utils import network_util, tool

@@ -34,7 +34,7 @@
    # 添加订单ID
    @classmethod
    def add_order_id(cls, code, account_id, order_id):
        cls.__get_redis().sadd(f"juejin_order_id-{code}", json.dumps((account_id, order_id)))
        RedisUtils.sadd(cls.__get_redis(),f"juejin_order_id-{code}", json.dumps((account_id, order_id)))
        cls.__get_redis().expire(f"juejin_order_id-{code}", tool.get_expire())

    # 删除订单ID
@@ -45,7 +45,7 @@
    # 查询所有的订单号
    @classmethod
    def list_order_ids(cls, code):
        return cls.__get_redis().smembers(f"juejin_order_id-{code}")
        return RedisUtils.smembers(cls.__get_redis(), f"juejin_order_id-{code}")


def init(context):