Redis数据同步队列修改/增加辨识度代码同步接口

Administrator

2024-11-29 8c3563969827850b9826ee1428f9deb1b6cb0081

Redis数据同步队列修改/增加辨识度代码同步接口

 api/outside_api_command_callback.py

@@ -46,6 +46,7 @@
from trade import trade_manager, l2_trade_util, trade_data_manager, trade_constant
import l2_data_util as l2_data_util_old
from trade.buy_money_count_setting import BuyMoneyAndCountSetting, RadicalBuyBlockCodeCountManager
from trade.buy_radical import block_special_codes_manager

from trade.huaxin import huaxin_trade_api, huaxin_trade_data_update, \
    huaxin_trade_record_manager, huaxin_trade_order_processor, huaxin_sell_util
@@ -1367,6 +1368,15 @@
                self.send_response({"code": 0, "data": list(codes), "msg": f""},
                                   client_id,
                                   request_id)

            elif ctype == "async_radical_buy_special_codes":
                # 同步扫入买的辨识度代码
                count = block_special_codes_manager.update_block_special_codes()
                self.send_response({"code": 0, "msg": f"更新成功数量：{count}"},
                                   client_id,
                                   request_id)


        except Exception as e:
            logging.exception(e)
            logger_debug.exception(e)

 db/redis_manager_delegate.py

@@ -40,11 +40,10 @@
    # 本机执行redis
    __LOCAL_REQUEST = True

    __async_task_queue = queue.Queue(maxsize=4096)
    __async_task_queue = queue.Queue(maxsize=10240)

    @classmethod
    def exec(cls, method_name, key, lamada_method):
        __start_time = time.time()
        try:
            return lamada_method()
        finally:
@@ -272,23 +271,6 @@
                    results = cls.__batch__request(dataList)
                    last_upload_time = time.time()
                    dataList.clear()
                    # try:
                    #     db = data[0]
                    #     method_name = data[1]
                    #     args = data[2]
                    #     _redis = RedisManager(db).getRedisNoPool()
                    #     method = getattr(RedisUtils, method_name)
                    #     if type(args) == tuple:
                    #         args = list(args)
                    #         args.insert(0, _redis)
                    #         args = tuple(args)
                    #         result = method(*args)
                    #     else:
                    #         args = tuple([_redis, args])
                    #         result = method(*args)
                    # except Exception as e2:
                    #     logging.exception(e2)
                    #     logging.error(data)
            except Exception as e1:
                logging.exception(e1)
                pass

 servers/huaxin_trade_server.py

@@ -249,11 +249,6 @@
                            code_name_map[d["sec_id"]] = d["sec_name"]
                        # 保存代码名称
                        CodesNameManager().add_code_names(code_name_map)

                        # 更新辨识度代码
                        threading.Thread(target=block_special_codes_manager.update_block_special_codes,
                                         daemon=True).start()

                        sk.sendall(
                            socket_util.load_header(json.dumps({"code": 0, "data": fdatas}).encode(encoding='utf-8')))


 trade/buy_radical/block_special_codes_manager.py

@@ -192,6 +192,7 @@
    for d in datas:
        print(d)
    BlockSpecialCodesManager().set_block_codes_list(datas)
    return len(datas)

if __name__ == "__main__":
    # print(datas)