| | |
|---|
| | | # 自动加想策略 |
|---|
| | | threading.Thread(target=lambda: auto_add_want_buy_strategy.run(), daemon=True).start() |
|---|
| | | |
|---|
| | | # 加载开盘啦今日历史涨停数据 |
|---|
| | | kpl_data_manager.KPLLimitUpDataRecordManager.load_total_datas() |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_read, trade_ipc_addr): |
|---|
| | | """ |
|---|
| | |
|---|
| | | @classmethod |
|---|
| | | def load_total_datas(cls): |
|---|
| | | cls.total_datas = KPLLimitUpDataRecordManager.list_all(tool.get_now_date_str()) |
|---|
| | | LimitUpDataConstant.set_history_limit_up_datas(cls.total_datas) |
|---|
| | | cls.__LimitUpCodesPlateKeyManager.set_today_total_limit_up( |
|---|
| | | [(r[3], r[2], r[6].split("、") if r[6] else []) for r in cls.total_datas]) |
|---|
| | | for d in cls.total_datas: |
|---|
