Administrator
2024-05-06 ef26675d07cc0014a3fb7cdabffc45bb00394af3
bug修复
3个文件已修改
12 ■■■■■ 已修改文件
l2/cancel_buy_strategy.py 3 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
third_data/kpl_api.py 5 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
third_data/kpl_data_manager.py 4 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
l2/cancel_buy_strategy.py
@@ -7,7 +7,6 @@
# 计算范围到申报时间的那一秒
import json
import logging
import random
import time
import constant
@@ -18,10 +17,8 @@
from l2.code_price_manager import Buy1PriceManager
from l2.huaxin import l2_huaxin_util
from l2.l2_data_manager import OrderBeginPosInfo
from l2.l2_sell_manager import L2LimitUpSellManager
from l2.l2_transaction_data_manager import HuaXinBuyOrderManager, HuaXinSellOrderStatisticManager, BigOrderDealManager
from log_module import async_log_util
from trade.deal_big_money_manager import DealOrderNoManager
from trade.sell.sell_rule_manager import TradeRuleManager
from utils import tool
third_data/kpl_api.py
@@ -49,7 +49,6 @@
def __getLimitUpInfo(pidType, page, pageSize):
    data = f"Order=0&a=DailyLimitPerformance&st={pageSize}&apiv=w35&Type=4&c=HomeDingPan&PhoneOSNew=1&DeviceID=a38adabd-99ef-3116-8bb9-6d893c846e24&VerSion=5.13.0.0&Index={(page - 1) * pageSize}&PidType={pidType}&"
    result = __base_request("https://apphq.longhuvip.com/w1/api/index.php", data=data)
    print(result)
    return result
@@ -61,12 +60,10 @@
        for i in range(100):
            start_time = time.time()
            result = __getLimitUpInfo(pid_info[0], i + 1, 20)
            print("请求用时", time.time() - start_time)
            result = json.loads(result)
            datas = result["info"][0]
            results.extend(datas)
            day = result["info"][1]
            print(datas)
            if len(datas) < 20:
                break
        for r in results:
@@ -261,4 +258,4 @@
if __name__ == "__main__":
    print(set(__getConceptJXBK("002670")) - constant.KPL_INVALID_BLOCKS)
    print(getLimitUpInfoNew())
third_data/kpl_data_manager.py
@@ -9,7 +9,7 @@
import constant
from db.redis_manager_delegate import RedisUtils
from log_module import async_log_util
from log_module import async_log_util, log
from utils import tool
# 开盘啦历史涨停数据管理
@@ -436,6 +436,8 @@
    @classmethod
    def run_limit_up_task(cls):
        # 关闭log
        log.close_print()
        while True:
            try:
                if (tool.is_trade_time() and int(tool.get_now_time_str().replace(':', '')) > int("092530")):