增加些实时参数的缓存

Administrator

2023-07-31 b9dcb0b8ef3501395d4a2624c2adcf09d725e09c

 l2/huaxin/huaxin_target_codes_manager.py

@@ -8,6 +8,7 @@
from code_attribute.code_data_util import ZYLTGBUtil
from db import redis_manager
from third_data import kpl_data_manager, kpl_api
from trade import current_price_process_manager
from utils import tool, global_util, socket_util

redisManager = redis_manager.RedisManager(0)
@@ -89,23 +90,8 @@
            fitem = {"code": code, "price": d[1], "volume": d[3] // (10000*100), "volumeUnit": 1, "time": "00:00:00",
                     "zyltgb": zyltgb // 10000, "zyltgbUnit": 1}
            flist.append(fitem)
        fdata = {"type": 22, "data": flist}
        print("首板代码数量", len(flist))

        addr, port = "127.0.0.1", 9001
        sk = socket.socket()  # 生成socket，连接server
        sk.connect((addr, port))
        try:
            sk.sendall(socket_util.load_header(json.dumps(fdata).encode('utf-8')))
        finally:
            sk.close()

        sk = socket.socket()  # 生成socket，连接server
        sk.connect((addr, port))
        try:
            sk.sendall(socket_util.load_header(json.dumps({"type": 40, "data": []}).encode('utf-8')))
        finally:
            sk.close()
        current_price_process_manager.accept_prices(flist)


if __name__ == "__main__":