| | |
|---|
| | | from strategy.strategy_variable_factory import DataLoader |
|---|
| | | from third_data.history_k_data_manager import TradeDateManager |
|---|
| | | from third_data.kpl_block_manager import KPLCodeJXBlocksManager |
|---|
| | | from trade import trade_record_log_util |
|---|
| | | from utils import socket_util, middle_api_protocol, tool |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | day = tool.get_now_date_str() |
|---|
| | | fdata["history_data"]["kpl_code_jx_blocks_count"] = env_info.get_kpl_code_jx_blocks(day) |
|---|
| | | |
|---|
| | | |
|---|
| | | return {"code": 0, "data": fdata, "msg": "测试结果"} |
|---|
| | | |
|---|
| | | def __on_update_leading_limit_up_datas(self): |
|---|
| | |
|---|
| | | codes |= set([x.decode() for x in codes_sz]) |
|---|
| | | KPLCodeJXBlocksManager(day, codes).start_download_blocks() |
|---|
| | | # 如果在16:00之前采用当前日期 |
|---|
| | | |
|---|
| | | day = tool.get_now_date_str() |
|---|
| | | threading.Thread(target=lambda: update(), daemon=True).start() |
|---|
| | | return {"code": 0} |
|---|
| | |
|---|
| | | elif ctype == 'init_datas': |
|---|
| | | # 初始化数据 |
|---|
| | | result_json = self.__on_init_data() |
|---|
| | | elif ctype == 'get_place_order_records': |
|---|
| | | # 获取下单记录 |
|---|
| | | datas = trade_record_log_util.get_trade_records(trade_record_log_util.TYPE_PLACE_ORDER) |
|---|
| | | result_json = {"code": 0, "data": datas} |
|---|
| | | |
|---|
| | | self.send_response(result_json, client_id, request_id) |
|---|
