| | |
|---|
| | | # 交易管理器 |
|---|
| | | import datetime |
|---|
| | | import json |
|---|
| | | import threading |
|---|
| | | import time |
|---|
| | | |
|---|
| | | import dask |
|---|
| | |
|---|
| | | |
|---|
| | | # 设置交易状态 |
|---|
| | | def set_trade_state(self, code, state): |
|---|
| | | logger_trade.info("set_trade_state {}-{}".format(code, state)) |
|---|
| | | async_log_util.info(logger_trade, "set_trade_state {}-{}".format(code, state)) |
|---|
| | | tool.CodeDataCacheUtil.set_cache(self.__trade_state_cache, code, state) |
|---|
| | | RedisUtils.setex_async(self.__db, "trade-state-{}".format(code), tool.get_expire(), state) |
|---|
| | | |
|---|
| | |
|---|
| | | guiTrade.cancel_buy(code) |
|---|
| | | async_log_util.info(logger_trade, "{}撤单方法结束".format(code)) |
|---|
| | | __cancel_success(code) |
|---|
| | | # 再次撤单 |
|---|
| | | if constant.TRADE_WAY == constant.TRADE_WAY_HUAXIN: |
|---|
| | | threading.Thread(target=lambda: trade_huaxin.cancel_order(code, msg="再次撤单"), daemon=True).start() |
|---|
| | | # 不需要再次撤单了 |
|---|
| | | # try: |
|---|
| | | # cancel_buy_again(code) |
|---|
