| | |
| | | data["day"] = day |
| | | data["create_time"] = int(round(t.time() * 1000)) |
| | | count = mongo_data.count("ths-trade-delegate-record", {"_id": data["_id"]}) |
| | | if count < 1: |
| | | if count is None or count < 1: |
| | | mongo_data.save_one("ths-trade-delegate-record", data) |
| | | # 保存最新的委托数据 |
| | | redis = __redis_manager.getRedis() |
| | |
| | | |
| | | # 取消委托成功 |
| | | def __cancel_success(code): |
| | | TradeBuyDataManager.remove_buy_capture_time(code) |
| | | TradeBuyDataManager.remove_buy_position_info(code) |
| | | # 下单成功,加入固定代码库 |
| | | l2_data_manager.remove_from_l2_fixed_codes(code) |
| | | logger_trade.info("{}撤单成功".format(code)) |