| | |
| | | time_str = datetime.datetime.now().strftime("%H:%M:%S") |
| | | redis.setex("trade-success-latest-time", tool.get_expire(), time_str) |
| | | for data in datas: |
| | | _time = data["time"] |
| | | # 过滤错误数据 |
| | | if _time == "00:00:00": |
| | | continue |
| | | data["_id"] = data["trade_num"] |
| | | data["day"] = day |
| | | data["create_time"] = int(round(t.time() * 1000)) |
| | |
| | | return None |
| | | for data in datas: |
| | | code = data["code"] |
| | | _time = data["time"] |
| | | if _time == "00:00:00": |
| | | continue |
| | | if code is not None: |
| | | set_trade_state(code, TRADE_STATE_BUY_SUCCESS) |
| | | forbidden_trade(code) |