买撤策略修改；加入报警功能

Administrator

2022-10-12 be73e2b78857adaf006063275726b69c4c60f0d7

 ths_util.py

@@ -8,7 +8,11 @@
import win32con
import win32gui

import redis_manager
import tool
import trade_gui

__redisManager = redis_manager.RedisManager(2)


def __click(hwnd):
@@ -171,6 +175,27 @@
    raise Exception("专业版下单打开失败")


def set_ths_dead_state(client_id, dead):
    redis = __redisManager.getRedis()
    key = "ths_state_dead_count-{}".format(client_id)
    if not dead:
        redis.setex(key, tool.get_expire(), 0)
    else:
        redis.incrby(key, 1)
        redis.expire(key, tool.get_expire())


# 同花顺是否卡死
def is_ths_dead(client_id):
    key = "ths_state_dead_count-{}".format(client_id)
    redis = __redisManager.getRedis()
    val = redis.get(key)
    if val is not None and int(val) >= 5:
        return True
    else:
        return False


if __name__ == "__main__":
    open_trade_gui()