| | |
|---|
| | | def save_trade_success_data(datas): |
|---|
| | | day = datetime.datetime.now().strftime("%Y%m%d") |
|---|
| | | redis = __redis_manager.getRedis() |
|---|
| | | time_str = datetime.datetime.now().strftime("%H:%M:%S") |
|---|
| | | time_str = tool.get_now_time_str() |
|---|
| | | redis.setex("trade-success-latest-time", tool.get_expire(), time_str) |
|---|
| | | mysqldb = mysql_data.Mysqldb() |
|---|
| | | # 合并同一合同编号 |
|---|
| | |
|---|
| | | # 保存交易委托数据 |
|---|
| | | def save_trade_delegate_data(datas): |
|---|
| | | day = datetime.datetime.now().strftime("%Y%m%d") |
|---|
| | | time_str = datetime.datetime.now().strftime("%H:%M:%S") |
|---|
| | | time_str = tool.get_now_time_str() |
|---|
| | | mysqldb = mysql_data.Mysqldb() |
|---|
| | | for data in datas: |
|---|
| | | data["_id"] = "{}-{}-{}".format(day, data["code"], data["time"]) |
|---|
| | |
|---|
| | | # 再次撤单，防止没有撤掉 |
|---|
| | | @tool.async_call |
|---|
| | | def cancel_buy_again(code): |
|---|
| | | time.sleep(0.1) |
|---|
| | | time.sleep(0.02) |
|---|
| | | for i in range(0, 5): |
|---|
| | | # 如果时 |
|---|
| | | trade_state = get_trade_state(code) |
|---|
