| | |
| | | |
| | | from utils import global_util, tool |
| | | from db import redis_manager |
| | | from logs_.log import logger_day_volumn |
| | | from log_module.log import logger_day_volumn |
| | | |
| | | __redis_manager = redis_manager.RedisManager(0) |
| | | |
| | |
| | | from utils import data_export_util |
| | | import multiprocessing |
| | | |
| | | from logs_ import log |
| | | from log_module import log |
| | | from db import mysql_data, redis_manager |
| | | import server |
| | | from config import settings |
| | |
| | | from third_data.history_k_data_util import HistoryKDatasUtils |
| | | from trade import l2_trade_util, trade_manager |
| | | from l2.cancel_buy_strategy import L2LimitUpSellStatisticUtil, LCancelBigNumComputer |
| | | from logs_.log import logger_juejin_tick, logger_system |
| | | from log_module.log import logger_juejin_tick, logger_system |
| | | from trade.trade_data_manager import CodeActualPriceProcessor |
| | | from trade.trade_queue_manager import JueJinBuy1VolumnManager |
| | | |
| | |
| | | from trade import trade_data_manager, trade_queue_manager, l2_trade_factor |
| | | from l2 import l2_log, l2_data_log, l2_data_source_util |
| | | from l2.l2_data_util import L2DataUtil, local_today_num_operate_map, local_today_datas |
| | | from logs_.log import logger_buy_1_volumn, logger_l2_h_cancel, logger_l2_s_cancel |
| | | from log_module.log import logger_buy_1_volumn, logger_l2_h_cancel, logger_l2_s_cancel |
| | | |
| | | |
| | | class SecondCancelBigNumComputer: |
| | |
| | | |
| | | from utils import tool |
| | | from db import redis_manager |
| | | from logs_.log import logger_trade_queue_price_info |
| | | from log_module.log import logger_trade_queue_price_info |
| | | |
| | | |
| | | class Buy1PriceManager: |
| | |
| | | # l2数据的日志 |
| | | import time |
| | | |
| | | from logs_ import log |
| | | from log_module import log |
| | | from l2 import l2_log |
| | | |
| | | |
| | |
| | | |
| | | from db import redis_manager |
| | | from utils import tool |
| | | from logs_.log import logger_l2_trade_buy |
| | | from log_module.log import logger_l2_trade_buy |
| | | |
| | | _redisManager = redis_manager.RedisManager(1) |
| | | |
| | |
| | | from l2.l2_data_util import local_today_datas, L2DataUtil, local_today_num_operate_map, local_today_buyno_map, \ |
| | | local_latest_datas |
| | | import l2.l2_data_util |
| | | from logs_.log import logger_l2_trade_buy, logger_l2_process, \ |
| | | from log_module.log import logger_l2_trade_buy, logger_l2_process, \ |
| | | logger_place_order_score, logger_l2_error |
| | | |
| | | # TODO l2数据管理 |
| | |
| | | import constant |
| | | from code_attribute import gpcode_manager |
| | | from l2 import l2_data_log, l2_data_source_util |
| | | from logs_ import log |
| | | from log_module import log |
| | | from db import redis_manager |
| | | from utils import tool |
| | | |
| | |
| | | from logs_.log import logger_l2_trade_cancel, logger_l2_trade_buy, logger_trade_record, logger_l2_trade |
| | | from log_module.log import logger_l2_trade_cancel, logger_l2_trade_buy, logger_trade_record, logger_l2_trade |
| | | |
| | | threadIds = {} |
| | | |
| | |
| | | from db import redis_manager |
| | | from utils import tool |
| | | import l2.l2_data_util |
| | | from logs_.log import logger_l2_trade_buy_queue, logger_l2_trade_buy_progress |
| | | from log_module.log import logger_l2_trade_buy_queue, logger_l2_trade_buy_progress |
| | | |
| | | |
| | | class TradeBuyQueue: |
| | |
| | | |
| | | from trade.huaxin import trade_server |
| | | from third_data import data_server |
| | | from logs_ import log |
| | | import log_module |
| | | |
| | | from server import * |
| | | import l2.l2_data_util |
| | |
| | | |
| | | |
| | | if __name__ == '__main__': |
| | | log.logger_l2_process_time.info("测试123") |
| | | log_module.log.logger_l2_process_time.info("测试123") |
| | | serverProcess = multiprocessing.Process(target=createServer) |
| | | serverProcess.start() |
| | | # 将tradeServer作为主进程 |
| | |
| | | from code_attribute import code_volumn_manager, limit_up_time_manager, global_data_loader, gpcode_manager |
| | | import constant |
| | | from utils import global_util, tool |
| | | from logs_ import log |
| | | from log_module import log |
| | | from l2 import l2_data_manager, l2_data_util, transaction_progress, l2_data_manager_new, code_price_manager |
| | | from l2.cancel_buy_strategy import HourCancelBigNumComputer |
| | | import l2.l2_data_manager_new |
| | |
| | | import time |
| | | |
| | | from code_attribute import gpcode_manager |
| | | from logs_ import log |
| | | from log_module import log |
| | | from db.redis_manager import RedisManager |
| | | from logs_.log import logger_kp_msg |
| | | from log_module.log import logger_kp_msg |
| | | |
| | | CLIENT_IDS = ["zjb", "hxh"] |
| | | |
| | |
| | | from code_attribute.code_data_util import ZYLTGBUtil |
| | | import l2.transaction_progress |
| | | |
| | | from logs_.log import logger_l2_error, logger_device, logger_trade_delegate, logger_buy_1_volumn_record, \ |
| | | from log_module.log import logger_l2_error, logger_device, logger_trade_delegate, logger_buy_1_volumn_record, \ |
| | | logger_l2_trade_queue, logger_l2_latest_data, logger_l2_trade_buy_queue, logger_first_code_record, logger_debug |
| | | from trade.huaxin import huaxin_trade_record_manager |
| | | from trade.trade_manager import TradeTargetCodeModeManager |
| | |
| | | from unittest import mock |
| | | |
| | | from code_attribute import big_money_num_manager, gpcode_manager |
| | | from logs_ import log |
| | | from log_module import log |
| | | from utils import tool |
| | | from db import redis_manager |
| | | from l2 import l2_log, l2_data_manager, transaction_progress |
| | |
| | | |
| | | import constant |
| | | from utils import global_util, tool |
| | | from logs_ import log |
| | | from log_module import log |
| | | from db import redis_manager |
| | | |
| | | from logs_.log import logger_kpl_limit_up, logger_kpl_block_can_buy |
| | | from log_module.log import logger_kpl_limit_up, logger_kpl_block_can_buy |
| | | from third_data.kpl_util import KPLPlatManager |
| | | from trade import trade_manager |
| | | |
| | |
| | | |
| | | from utils import global_util, tool |
| | | from code_attribute import gpcode_manager |
| | | from logs_ import log, log_analyse |
| | | from log_module import log, log_analyse |
| | | from l2 import code_price_manager, l2_data_util |
| | | from l2.cancel_buy_strategy import HourCancelBigNumComputer |
| | | from output.limit_up_data_filter import IgnoreCodeManager |
| | |
| | | |
| | | # 开盘啦历史涨停数据管理 |
| | | from db import mysql_data, redis_manager |
| | | from logs_.log import logger_kpl_limit_up_reason_change |
| | | 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 |
| | | |
| | |
| | | from utils import tool |
| | | import time |
| | | from db import redis_manager |
| | | from logs_.log import logger_code_operate |
| | | from log_module.log import logger_code_operate |
| | | |
| | | __reset_code_dict = {} |
| | | __set_operate_code_state_dict = {} |
| | |
| | | from l2 import l2_data_manager_new, l2_data_log |
| | | from l2.huaxin import l2_huaxin_util, huaxin_target_codes_manager |
| | | from l2.l2_data_util import local_today_datas |
| | | from logs_.log import logger_l2_error |
| | | from log_module.log import logger_l2_error |
| | | from trade.huaxin.huaxin_log import logger_l2_orderdetail, logger_l2_transaction, logger_l2_upload, \ |
| | | logger_contact_debug, logger_trade_callback, logger_trade_debug |
| | | |
| | |
| | | import constant |
| | | from utils import tool |
| | | from db.redis_manager import RedisManager |
| | | from logs_.log import logger_huaxin_trade |
| | | from log_module.log import logger_huaxin_trade |
| | | |
| | | |
| | | class TradeOrderIdManager: |
| | |
| | | from utils import global_util, tool |
| | | import l2_data_util |
| | | from db import redis_manager |
| | | from logs_.log import logger_trade |
| | | from log_module.log import logger_trade |
| | | |
| | | |
| | | class TradeCancelDataManager: |
| | |
| | | from ocr import ocr_util |
| | | from trade import l2_trade_util |
| | | from db import redis_manager |
| | | from logs_.log import * |
| | | from log_module.log import * |
| | | from utils.tool import async_call |
| | | from utils import win32_util, capture_util |
| | | |
| | |
| | | |
| | | import constant |
| | | from db.redis_manager import RedisManager |
| | | from logs_.log import logger_juejin_trade |
| | | from log_module.log import logger_juejin_trade |
| | | from trade.huaxin import huaxin_trade_api |
| | | from utils import tool |
| | | |
| | |
| | | import constant |
| | | from code_attribute import gpcode_manager |
| | | from db.redis_manager import RedisManager |
| | | from logs_.log import logger_juejin_trade |
| | | from log_module.log import logger_juejin_trade |
| | | from utils import network_util, tool |
| | | |
| | | __context_dict = {} |
| | |
| | | import time as t |
| | | from l2 import l2_data_manager, l2_data_log |
| | | |
| | | from logs_.log import * |
| | | from log_module.log import * |
| | | from utils import import_util |
| | | |
| | | trade_gui = import_util.import_lib("trade.trade_gui") |
| | |
| | | LCancelBigNumComputer |
| | | from l2.l2_data_util import local_today_datas, local_today_num_operate_map |
| | | from l2.safe_count_manager import BuyL2SafeCountManager |
| | | from logs_.log import logger_l2_error |
| | | from log_module.log import logger_l2_error |
| | | from trade import trade_data_manager |
| | | from trade.trade_queue_manager import THSBuy1VolumnManager |
| | | |
| | |
| | | import constant |
| | | from code_attribute import gpcode_manager |
| | | import l2.l2_data_util |
| | | from logs_ import log |
| | | from log_module import log |
| | | from l2 import l2_data_source_util |
| | | from trade import deal_big_money_manager |
| | | |
| | |
| | | # 数据处理 |
| | | import json |
| | | from db import redis_manager |
| | | from logs_.log import logger_l2_error |
| | | from log_module.log import logger_l2_error |
| | | |
| | | __redisManager = redis_manager.RedisManager(0) |
| | | |