L2数据处理完善

Administrator

2022-09-30 394e24aaba9b28c6427444d47aab6505c735fb7e

 data_process.py

@@ -15,6 +15,7 @@
# 统计今日卖出
# 统计今日买入
import tool
from code_data_util import ZYLTGBUtil

__redisManager = redis_manager.RedisManager(0)

@@ -154,6 +155,7 @@

# 保存自由流通市值
def saveZYLTSZ(datasList):
    redis = __redisManager.getRedis()
    _list = []
    for data in datasList:
        # 保存
@@ -161,6 +163,8 @@
                 "update_time": int(round(t.time() * 1000))}
        if float(data["zyltgb"]) > 0:
            _list.append(_dict)
            # 保存10天
            ZYLTGBUtil.save(data["code"],data["zyltgb"],data["zyltgb_unit"])
    mongo_data.save("ths-zylt", _list)


@@ -189,7 +193,7 @@
    val = redis.get("client-active-{}".format(client_id))
    if val is None:
        return None
    val=json.loads(val)
    val = json.loads(val)
    return val[0]