| | |
|---|
| | | import l2_code_operate |
|---|
| | | from code_data_util import ZYLTGBUtil |
|---|
| | | |
|---|
| | | from log import logger_l2_error, logger_device, logger_trade_delegate |
|---|
| | | from trade_queue_manager import THSBuy1VolumnManager |
|---|
| | | from log import logger_l2_error, logger_device, logger_trade_delegate, logger_buy_1_volumn_record |
|---|
| | | from trade_queue_manager import THSBuy1VolumnManager, Buy1PriceManager |
|---|
| | | |
|---|
| | | |
|---|
| | | class MyTCPServer(socketserver.TCPServer): |
|---|
| | |
|---|
| | | l2_data_error_dict = {} |
|---|
| | | last_trade_delegate_data = None |
|---|
| | | buy1_volumn_manager = THSBuy1VolumnManager() |
|---|
| | | latest_buy1_volumn_dict={} |
|---|
| | | buy1_price_manager = Buy1PriceManager() |
|---|
| | | |
|---|
| | | def setup(self): |
|---|
| | | super().setup() # 可以不调用父类的setup()方法，父类的setup方法什么都没做 |
|---|
| | |
|---|
| | | global_data_loader.load_name_codes() |
|---|
| | | code = global_util.name_codes.get(code_name) |
|---|
| | | if code is not None: |
|---|
| | | # 记录日志 |
|---|
| | | if self.latest_buy1_volumn_dict.get(code) != "{}-{}".format(volumn,price): |
|---|
| | | # 记录数据 |
|---|
| | | logger_buy_1_volumn_record.info("{}-{}",code,data) |
|---|
| | | self.latest_buy1_volumn_dict[code] = "{}-{}".format(volumn,price) |
|---|
| | | # 保存买1价格 |
|---|
| | | self.buy1_price_manager.save(code,price) |
|---|
| | | # 校正时间 |
|---|
| | | seconds = tool.get_time_as_second(time_) |
|---|
| | | if seconds % 3 > 0: |
|---|
| | | seconds = seconds - seconds % 3 |
|---|
| | | time_ = tool.time_seconds_format(seconds) |
|---|
| | | time_ = tool.compute_buy1_real_time(time_) |
|---|
| | | # 保存数据 |
|---|
| | | need_sync, need_cancel, cancel_msg = self.buy1_volumn_manager.save(code, time_, volumn, |
|---|
| | | price) |
|---|
