test/hikyuu2
1
0
Fork 0
mirror of https://gitee.com/fasiondog/hikyuu.git synced 2024-11-30 02:48:57 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

通达信导入的时候没有导入历史财务数据

Browse Source
This commit is contained in:
Jet 2024-05-21 19:32:18 +08:00
parent a17c822d79
commit 4c0e461ab9
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hikyuu/gui/data/ImportHistoryFinanceTask.py
View File

@ -124,6 +124,11 @@ class ImportHistoryFinanceTask:
if __name__ == "__main__":
from multiprocessing import Queue
from configparser import ConfigParser
this_dir = os.path.expanduser('~') + '/.hikyuu'
import_config = ConfigParser()
import_config.read(this_dir + '/importdata-gui.ini', encoding='utf-8')
task = ImportHistoryFinanceTask(None, None, None, "c:\\stock")
task()
print("over!")

5
hikyuu/gui/data/UseTdxImportToH5Thread.py
View File

@ -28,6 +28,7 @@ from multiprocessing import Queue, Process
from PyQt5.QtCore import QThread, pyqtSignal
from hikyuu.gui.data.ImportTdxToH5Task import ImportTdxToH5Task
from hikyuu.gui.data.ImportWeightToSqliteTask import ImportWeightToSqliteTask
from hikyuu.gui.data.ImportHistoryFinanceTask import ImportHistoryFinanceTask
from hikyuu.data.common_sqlite3 import create_database
from hikyuu.data.tdx_to_h5 import tdx_import_stock_name_from_file
@ -68,6 +69,8 @@ class UseTdxImportToH5Thread(QThread):
self.tasks = []
if self.config.getboolean('weight', 'enable', fallback=False):
self.tasks.append(ImportWeightToSqliteTask(self.log_queue, self.queue, self.config, dest_dir))
if self.config.getboolean('finance', 'enable', fallback=True):
self.tasks.append(ImportHistoryFinanceTask(self.log_queue, self.queue, self.config, dest_dir))
if self.config.getboolean('ktype', 'day', fallback=False):
self.tasks.append(
ImportTdxToH5Task(self.log_queue, self.queue, config, 'SH', 'DAY', self.quotations, src_dir, dest_dir)
@ -149,5 +152,7 @@ class UseTdxImportToH5Thread(QThread):
hdf5_import_progress[market][ktype] = progress
current_progress = (hdf5_import_progress['SH'][ktype] + hdf5_import_progress['SZ'][ktype]) // 2
self.send_message(['IMPORT_KDATA', ktype, current_progress])
elif taskname == 'IMPORT_KDATA':
self.send_message([taskname, progress])
else:
self.logger.error("Unknow task: {}".format(taskname))