"""
|
常用工具
|
"""
|
import decimal
|
import random
|
import time
|
import time as t
|
import datetime
|
from threading import Thread
|
|
import constant
|
|
|
def async_call(fn):
|
def wrapper(*args, **kwargs):
|
Thread(target=fn, args=args, kwargs=kwargs).start()
|
|
return wrapper
|
|
|
def get_expire():
|
now = int(t.time())
|
end = int(t.time()) + 60 * 60 * 24
|
local_time = t.strftime("%Y-%m-%d", t.localtime(end))
|
end = int(t.mktime(t.strptime(local_time, "%Y-%m-%d")))
|
expire = end - now
|
# 加随机数，防止一起销毁数据
|
expire += random.randint(0, 60 * 60)
|
return expire
|
|
|
def get_now_date():
|
date = datetime.datetime.now()
|
return date
|
|
|
# 转为价格，四舍五入保留2位小数
|
def to_price(_decimal):
|
return _decimal.quantize(decimal.Decimal("0.00"), decimal.ROUND_HALF_UP)
|
|
|
# 是否为交易时间
|
def is_trade_time():
|
# 测试
|
if constant.TEST:
|
return True
|
|
relative_timestamp = t.time() % (24 * 60 * 60) + 8 * 60 * 60
|
start1 = 60 * 60 * 9 + 24 * 60;
|
end1 = 60 * 60 * 11 + 35 * 60;
|
start2 = 60 * 60 * 12 + 50 * 60;
|
end2 = 60 * 60 * 15 + 5 * 60;
|
if start1 < relative_timestamp < end1 or start2 < relative_timestamp < end2:
|
return True
|
else:
|
return False
|
|
|
def is_set_code_time():
|
# 测试
|
if constant.TEST:
|
return True
|
|
relative_timestamp = t.time() % (24 * 60 * 60) + 8 * 60 * 60
|
start1 = 60 * 60 * 9 + 14 * 60;
|
end1 = 60 * 60 * 11 + 35 * 60;
|
start2 = 60 * 60 * 12 + 50 * 60;
|
end2 = 60 * 60 * 15 + 5 * 60;
|
if start1 < relative_timestamp < end1 or start2 < relative_timestamp < end2:
|
return True
|
else:
|
return False
|
|
def run_time():
|
def decorator(func):
|
def infunc(*args, **kwargs):
|
start = round(time.time() * 1000)
|
result = func(args, **kwargs)
|
print("执行时间", round(time.time() * 1000) - start)
|
return result
|
|
return infunc
|
|
return decorator
|
|
|
def get_time_as_second(time_str):
|
ts = time_str.split(":")
|
return int(ts[0]) * 3600 + int(ts[1]) * 60 + int(ts[2])
|
|
|
# 将秒数格式化为时间
|
def time_seconds_format(seconds):
|
h = seconds // 3600
|
m = seconds % 3600 // 60
|
s = seconds % 60
|
return "{0:0>2}:{1:0>2}:{2:0>2}".format(h, m, s)
|
|
|
# 交易時間的差值
|
# 如11:29:59 与 13:00:00只相差1s
|
def trade_time_sub(time_str_1, time_str_2):
|
split_time = get_time_as_second("11:30:00")
|
time_1 = get_time_as_second(time_str_1)
|
time_2 = get_time_as_second(time_str_2)
|
if time_1 < split_time < time_2:
|
time_2 = time_2 - 90 * 60
|
|
return time_1 - time_2
|
|
|
if __name__ == "__main__":
|
print(trade_time_sub("11:29:59", "13:00:00"))
|
print(trade_time_sub("11:29:59", "14:00:00"))
|
print(trade_time_sub("10:29:59", "11:29:59"))
|
print(trade_time_sub("13:29:59", "14:29:59"))
|
