redis/mysql代理

Administrator

2023-08-15 68237432c42b70b8f27dc07c37f85414ee5234bf

redis/mysql代理

 code_attribute/big_money_num_manager.py

@@ -3,8 +3,8 @@
"""

# 大单管理
from db import redis_manager
from db.redis_manager import RedisUtils
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from utils import tool

__db = 0

 code_attribute/code_data_util.py

@@ -7,8 +7,8 @@
import time

from code_attribute import gpcode_manager
from db import mysql_data, redis_manager
from db.redis_manager import RedisUtils
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from utils import tool

_redisManager = redis_manager.RedisManager(0)

 code_attribute/code_nature_analyse.py

@@ -10,7 +10,7 @@

# 代码股性记录管理
from utils import tool
from db.redis_manager import RedisManager, RedisUtils
from db.redis_manager_delegate import RedisManager, RedisUtils


class CodeNatureRecordManager:

 code_attribute/code_volumn_manager.py

@@ -7,9 +7,9 @@
# yesterday 昨天的量
import json

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import global_util, tool
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from log_module.log import logger_day_volumn

__redis_manager = redis_manager.RedisManager(0)

 code_attribute/gpcode_first_screen_manager.py

@@ -5,9 +5,9 @@
# 设置首板未筛选的目标票
import json

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import tool
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from third_data import block_info

__redisManager = redis_manager.RedisManager(0)

 code_attribute/gpcode_manager.py

@@ -5,8 +5,8 @@
import time

import constant
from db import redis_manager
from db.redis_manager import RedisUtils
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from utils import tool
import decimal


 code_attribute/limit_up_time_manager.py

@@ -2,8 +2,8 @@
"""
涨停时间管理器
"""
from db import redis_manager
from db.redis_manager import RedisUtils
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from utils import global_util, tool



 config/settings.py

@@ -1,6 +1,6 @@
# 设置模块
from db import redis_manager
from db.redis_manager import RedisUtils
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils

__redis_manager = redis_manager.RedisManager(2)


 gui.py

@@ -9,12 +9,12 @@

import win32gui

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import data_export_util
import multiprocessing

from log_module import log, log_export
from db import mysql_data, redis_manager
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
import server
from config import settings
from ths.l2_code_operate import L2CodeOperate

 inited_data.py

@@ -9,7 +9,7 @@
# import gm.api as gmapi

from code_attribute import big_money_num_manager, global_data_loader, gpcode_manager, gpcode_first_screen_manager
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from ths import client_manager
import constant
from trade.trade_manager import AccountAvailableMoneyManager
@@ -18,7 +18,7 @@

import server

from db import redis_manager
from db import redis_manager_delegate as redis_manager
from user import authority
import decimal


 l2/cancel_buy_strategy.py

@@ -12,8 +12,8 @@
import constant
from code_attribute import big_money_num_manager, gpcode_manager
import l2_data_util
from db import redis_manager
from db.redis_manager import RedisUtils
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from utils import tool
from l2.safe_count_manager import BuyL2SafeCountManager
from l2.transaction_progress import TradeBuyQueue

 l2/code_price_manager.py

@@ -3,9 +3,9 @@
"""
import json

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import tool
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from log_module.log import logger_trade_queue_price_info



 l2/huaxin/huaxin_target_codes_manager.py

@@ -13,7 +13,7 @@
import constant
from code_attribute import global_data_loader, code_volumn_manager, first_target_code_data_processor
from code_attribute.code_data_util import ZYLTGBUtil
from db import redis_manager
from db import redis_manager_delegate as 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

 l2/l2_data_manager.py

@@ -3,8 +3,8 @@
"""
import json

from db import redis_manager
from db.redis_manager import RedisUtils
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from utils import tool
from utils.tool import CodeDataCacheUtil


 l2/l2_data_manager_new.py

@@ -5,12 +5,12 @@
from code_attribute import big_money_num_manager, code_volumn_manager, code_data_util, industry_codes_sort, \
    limit_up_time_manager, global_data_loader, gpcode_manager
import constant
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from l2.huaxin import l2_huaxin_util, huaxin_delegate_postion_manager
from third_data import kpl_data_manager, block_info
from utils import global_util, ths_industry_util, tool
import l2_data_util
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from third_data.code_plate_key_manager import CodePlateKeyBuyManager
from trade import trade_manager, trade_queue_manager, l2_trade_factor, l2_trade_util, \
    trade_result_manager, first_code_score_manager, current_price_process_manager

 l2/l2_data_util.py

@@ -13,10 +13,10 @@

import constant
from code_attribute import gpcode_manager
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from l2 import l2_data_log, l2_data_source_util
from log_module import log, log_export
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from utils import tool

_redisManager = redis_manager.RedisManager(1)

 l2/safe_count_manager.py

@@ -4,10 +4,10 @@
# 下单L2的安全笔数管理
import json

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from l2 import l2_data_source_util
from trade import l2_trade_factor
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from utils import tool
from l2.l2_data_util import L2DataUtil


 l2/transaction_progress.py

@@ -7,8 +7,8 @@
import json

import constant
from db import redis_manager
from db.redis_manager import RedisUtils
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from utils import tool
import l2.l2_data_util
from log_module.log import logger_l2_trade_buy_queue, logger_l2_trade_buy_progress

 l2_data_util.py

@@ -7,7 +7,7 @@
import json
import time

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils.tool import async_call

from l2 import l2_data_manager

 main.py

@@ -4,7 +4,7 @@

import multiprocessing

from db import redis_manager
from db import redis_manager_delegate as redis_manager
from log_module.log import logger_l2_process_time

from server import *

 output/kp_client_msg_manager.py

@@ -7,9 +7,7 @@
import time

from code_attribute import gpcode_manager
from log_module import log, log_export
from db.redis_manager import RedisManager, RedisUtils
from log_module.log import logger_kp_msg
from log_module import log_export
from utils import middle_api_protocol, tool

CLIENT_IDS = ["zjb", "hxh"]

 output/limit_up_data_filter.py

@@ -5,9 +5,9 @@
# 判断是龙几，判断是否涨停，判断是否炸板，加载分数

from code_attribute import code_volumn_manager, limit_up_time_manager, gpcode_manager
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import tool
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from third_data.kpl_data_manager import KPLDataManager
from third_data.kpl_util import KPLDataType
from trade import first_code_score_manager

 test/l2_trade_test.py

@@ -9,10 +9,10 @@
from unittest import mock

from code_attribute import big_money_num_manager, gpcode_manager
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from log_module import log, log_export
from utils import tool
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from l2 import l2_log, l2_data_manager, transaction_progress
from l2.safe_count_manager import BuyL2SafeCountManager
from l2.transaction_progress import TradeBuyQueue

 third_data/code_plate_key_manager.py

@@ -6,11 +6,11 @@
import json

import constant
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from third_data import kpl_block_util
from utils import global_util, tool
from log_module import log
from db import redis_manager
from db import redis_manager_delegate as redis_manager

from log_module.log import logger_kpl_limit_up, logger_kpl_block_can_buy, logger_kpl_debug
from third_data.kpl_util import KPLPlatManager

 third_data/history_k_data_util.py

@@ -8,9 +8,9 @@
import requests

import constant
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import tool, middle_api_protocol
from db import redis_manager
from db import redis_manager_delegate as redis_manager
# import gm.api as gmapi



 third_data/kpl_data_manager.py

@@ -6,11 +6,11 @@
import requests

import constant
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import tool

# 开盘啦历史涨停数据管理
from db import mysql_data, redis_manager
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
from log_module.log import logger_kpl_limit_up_reason_change
from third_data import kpl_util, kpl_api
from third_data.code_plate_key_manager import LimitUpCodesPlateKeyManager, CodesHisReasonAndBlocksManager

 third_data/kpl_util.py

@@ -1,7 +1,7 @@
import enum
import json

from db import mysql_data
from db import mysql_data_delegate as mysql_data


def parse_kpl_datas(results):

 ths/client_manager.py

@@ -1,9 +1,9 @@
# 客户端管理器
import json

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from user import authority
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from utils import import_util

ths_util = import_util.import_lib("ths.ths_util")

 ths/l2_code_operate.py

@@ -7,7 +7,7 @@
import logging
import threading

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from ths import client_manager
from code_attribute import gpcode_manager
from l2 import l2_data_manager
@@ -16,7 +16,7 @@
import server
from utils import tool
import time
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from log_module.log import logger_code_operate

__reset_code_dict = {}

 ths/l2_listen_pos_health_manager.py

@@ -2,10 +2,9 @@
同花顺l2监听位置健康度管理
"""
# 不健康
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import tool
from db import redis_manager

from db import redis_manager_delegate as redis_manager
UN_HEALTHY = 0
UN_KNOWN = 1
HEALTHY = 2

 ths/ths_util.py

@@ -8,8 +8,8 @@
import win32con
import win32gui

from db import redis_manager
from db.redis_manager import RedisUtils
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from utils import tool
from trade import trade_gui


 trade/bidding_money_manager.py

@@ -3,9 +3,9 @@
"""
import json

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import tool
from db import redis_manager
from db import redis_manager_delegate as redis_manager

__redisManager = redis_manager.RedisManager(2)


 trade/deal_big_money_manager.py

@@ -3,9 +3,9 @@
"""
import json

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import tool
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from l2 import l2_data_util, l2_data_source_util



 trade/huaxin/huaxin_trade_record_manager.py

@@ -6,9 +6,9 @@
import datetime
import json

from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import tool
from db import mysql_data, redis_manager
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
from third_data.history_k_data_util import HistoryKDatasUtils



 trade/huaxin/trade_api_server.py

@@ -10,8 +10,8 @@

import inited_data
from code_attribute import gpcode_manager
from db import redis_manager, mysql_data
from db.redis_manager import RedisUtils
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from l2 import l2_data_manager_new
from l2.huaxin import huaxin_target_codes_manager
from third_data import block_info

 trade/huaxin/trade_server.py

@@ -18,8 +18,8 @@
import inited_data
import outside_api_command_manager
from code_attribute import gpcode_manager
from db import redis_manager, mysql_data
from db.redis_manager import RedisUtils
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from huaxin.client_network import SendResponseSkManager
from l2 import l2_data_manager_new, l2_log, code_price_manager, l2_data_util, l2_data_manager, transaction_progress
from l2.cancel_buy_strategy import HourCancelBigNumComputer, LCancelBigNumComputer, DCancelBigNumComputer

 trade/l2_trade_util.py

@@ -1,6 +1,6 @@
# 是否在禁止交易代码中
from db import redis_manager
from db.redis_manager import RedisUtils
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from utils import tool

__redis_manager = redis_manager.RedisManager(2)

 trade/trade_data_manager.py

@@ -7,10 +7,10 @@

# 交易撤销数据管理器
import constant
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from utils import global_util, tool
import l2_data_util
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from log_module.log import logger_trade



 trade/trade_gui.py

@@ -12,10 +12,10 @@
import win32con

from code_attribute import gpcode_manager
from db.redis_manager import RedisUtils
from db.redis_manager_delegate import RedisUtils
from ocr import ocr_util
from trade import l2_trade_util
from db import redis_manager
from db import redis_manager_delegate as redis_manager
from log_module.log import *
from utils.tool import async_call
from utils import win32_util, capture_util, tool

 trade/trade_huaxin.py

@@ -5,7 +5,7 @@
import time

import constant
from db.redis_manager import RedisManager, RedisUtils
from db.redis_manager_delegate import RedisManager, RedisUtils
from log_module.log import logger_juejin_trade, hx_logger_trade_debug
from trade.huaxin import huaxin_trade_api
from utils import tool, huaxin_util

 trade/trade_juejin.py

@@ -10,7 +10,7 @@

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


 trade/trade_manager.py

@@ -10,8 +10,8 @@
import dask

from code_attribute import gpcode_manager
from db import mysql_data, redis_manager
from db.redis_manager import RedisUtils
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from output import kp_client_msg_manager
from trade import trade_data_manager, l2_trade_util, trade_juejin, trade_huaxin


 trade/trade_queue_manager.py

@@ -3,8 +3,8 @@
import json

from code_attribute import gpcode_manager
from db import redis_manager
from db.redis_manager import RedisUtils
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from utils import tool
from trade import trade_manager


 user/authority.py

@@ -2,7 +2,7 @@
用户验证
"""

from db import mysql_data
from db import mysql_data_delegate as mysql_data


# 新增用户

 utils/ths_industry_util.py

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

from code_attribute import global_data_loader
from utils import global_util, tool
from db import mysql_data
from db import mysql_data_delegate as mysql_data

# 获取行业映射