| | |
|---|
| | | while True: |
|---|
| | | cls.set_read_queue_valid() |
|---|
| | | try: |
|---|
| | | data = redis.lpop("code_operate_queue") |
|---|
| | | data =RedisUtils.lpop(redis,"code_operate_queue") |
|---|
| | | # print("读取操作队列", data, redis.llen("code_operate_queue")) |
|---|
| | | if data is not None: |
|---|
| | | data = json.loads(data) |
|---|
| | |
|---|
| | | if int(tool.get_now_time_str().replace(":", "")) < int("092510"): |
|---|
| | | return |
|---|
| | | redis = self.redis_manager_.getRedis() |
|---|
| | | redis.rpush("code_operate_queue", |
|---|
| | | RedisUtils.rpush(redis, "code_operate_queue", |
|---|
| | | json.dumps({"type": type, "msg": msg, "code": code, "client": client, "pos": pos, |
|---|
| | | "create_time": round(time.time() * 1000)})) |
|---|
| | | |
|---|
| | |
|---|
| | | "data": {"index": int(pos), "code": code, "min_price": float(min_price), |
|---|
| | | "max_price": float(max_price)}} |
|---|
| | | redis = self.redis_manager_.getRedis() |
|---|
| | | redis.rpush("code_operate_queue", json.dumps( |
|---|
| | | RedisUtils.rpush(redis, "code_operate_queue", json.dumps( |
|---|
| | | {"type": 3, "code": code, "client": client_id, "data": data, "create_time": round(time.time() * 1000)})) |
|---|
| | | |
|---|
| | | # 移除监控 |
|---|
| | |
|---|
| | | @classmethod |
|---|
| | | def is_read_queue_valid(cls): |
|---|
| | | redis = cls.getRedis() |
|---|
| | | return redis.get("operate_queue_read_state") is not None |
|---|
| | | return RedisUtils.get(redis, "operate_queue_read_state") is not None |
|---|
| | | |
|---|
| | | |
|---|
| | | # 通过l2代码校验代码位 |
|---|
