| | |
| | | import multiprocessing |
| | | |
| | | import log |
| | | import mysql_data |
| | | import redis_manager |
| | | from db import mysql_data, redis_manager |
| | | import server |
| | | import settings |
| | | from juejin import JueJinManager |
| | |
| | | from ocr import ocr_server |
| | | |
| | | from server import * |
| | | import l2.l2_data_util |
| | | |
| | | # 读取server进程的消息 |
| | | from trade.trade_data_manager import CodeActualPriceProcessor |
| | |
| | | continue |
| | | l2_data_manager.clear_l2_data(code) |
| | | # 删除level2的数据 |
| | | if l2_data_manager.local_today_datas and code in l2_data_manager.local_today_datas: |
| | | l2_data_manager.local_today_datas.pop(code) |
| | | if l2_data_manager.local_latest_datas and code in l2_data_manager.local_latest_datas: |
| | | l2_data_manager.local_latest_datas.pop(code) |
| | | if l2.l2_data_util.local_today_datas and code in l2.l2_data_util.local_today_datas: |
| | | l2.l2_data_util.local_today_datas.pop(code) |
| | | if l2.l2_data_util.local_latest_datas and code in l2.l2_data_util.local_latest_datas: |
| | | l2.l2_data_util.local_latest_datas.pop(code) |
| | | |
| | | time.sleep(0.1) |
| | | |
| | |
| | | table_limit_up.show() |
| | | |
| | | # 获取数据 |
| | | time_str, datas = gpcode_manager.get_limit_up_list(); |
| | | time_str, datas = gpcode_manager.get_limit_up_list() |
| | | limit_up_datas_time.set(time_str) |
| | | # 删除所有的行 |
| | | # table_limit_up.model.deleteRows() |
| | |
| | | showwarning('警告', e) |
| | | |
| | | def export_l2_data(code): |
| | | if code not in l2_data_manager.local_today_datas: |
| | | l2_data_manager.load_l2_data(code) |
| | | datas = l2_data_manager.local_today_datas[code] |
| | | if code not in l2.l2_data_util.local_today_datas: |
| | | l2.l2_data_util.load_l2_data(code) |
| | | datas = l2.l2_data_util.local_today_datas[code] |
| | | try: |
| | | path = data_export_util.export_l2_data(code, datas) |
| | | showinfo("提示", "导出成功,路径为:" + path) |