Skip to content

Commit 32a72ec

Browse files
committed
Fix qmt last ticks missed issue
1 parent e1301f0 commit 32a72ec

File tree

1 file changed

+11
-5
lines changed

1 file changed

+11
-5
lines changed

src/zvt/broker/qmt/qmt_quote.py

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -370,23 +370,29 @@ def record_stock_quote(subscribe=False):
370370
import time
371371

372372
first_time = True
373+
last_time = False
373374
while True:
374375
if not first_time and Stock.in_trading_time() and not Stock.in_real_trading_time():
375-
logger.info(f"Sleeping time......")
376+
logger.info("Sleeping time......")
376377
time.sleep(60 * 1)
377378
continue
378379

380+
if not Stock.in_trading_time():
381+
logger.info("Not in trading time......")
382+
time.sleep(60 * 1)
383+
last_time = True
384+
379385
datas = xtdata.get_full_tick(code_list=qmt_stocks)
380386
on_data_func(datas=datas)
381387

382388
time.sleep(3)
383-
current_timestamp = now_pd_timestamp()
384-
if not Stock.in_trading_time():
389+
first_time = False
390+
391+
if last_time:
392+
current_timestamp = now_pd_timestamp()
385393
logger.info(f"record tick finished at: {current_timestamp}")
386394
break
387395

388-
first_time = False
389-
390396

391397
if __name__ == "__main__":
392398
from apscheduler.schedulers.background import BackgroundScheduler

0 commit comments

Comments
 (0)