扫入板块修改/不保存非交易时间的开盘啦涨停队列

Administrator

2024-11-06 a53ab43591e80223e736261a3cd6fbebb7ae4e55

 utils/kpl_data_db_util.py

@@ -1,4 +1,5 @@
from db.mysql_data_delegate import Mysqldb
from third_data.history_k_data_util import HistoryKDatasUtils
from utils import tool


@@ -19,3 +20,23 @@
        mysqldb = Mysqldb()
        results = mysqldb.select_all(sql)
        return results


if __name__ == '__main__':
    # 删除不是交易日期的数据
    days = HistoryKDatasUtils.get_latest_trading_date(300)
    for day in days:
        pass
    print(days)
    mysqldb = Mysqldb()
    results = mysqldb.select_all(f"SELECT _id, _day from kpl_limit_up_record r where r._day>='{days[-1]}'")
    ids = []
    for result in results:
        if result[1] not in days:
            ids.append(result[0])
            # print("删除：", result)
            if len(ids) > 10:
                sql = f"delete from kpl_limit_up_record where " + ' or '.join([f"_id='{x}'" for x in ids])
                mysqldb.execute(sql)
                ids.clear()
    pass