代码结构修改

Administrator

2024-11-27 c3359e9c48cb01d627d7197c3f1d528b7efb195e

 utils/kpl_data_db_util.py

@@ -12,7 +12,7 @@
        @param code: 代码
        @return: 最近的涨停板块信息
        """
        sql = f"SELECT r.`_code`, r.`_day`, r.`_hot_block_name`, r.`_blocks` FROM `kpl_limit_up_record` r WHERE r.`_day`>'{min_day}' and r.`_day` <'{max_day}'"
        sql = f"SELECT r.`_code`, r.`_day`, r.`_hot_block_name`, r.`_blocks` FROM `kpl_limit_up_record` r WHERE r.`_day`>='{min_day}' and r.`_day` <'{max_day}'"

        if code:
            sql += f" AND _code='{code}'"
@@ -21,6 +21,14 @@
        results = mysqldb.select_all(sql)
        return results

    @classmethod
    def get_latest_block_infos_by_day(cls, day=tool.get_now_date_str()):
        sql = f"SELECT * FROM `kpl_limit_up_record` r WHERE r.`_day`='{day}'"
        mysqldb = Mysqldb()
        results = mysqldb.select_all(sql)
        return results



if __name__ == '__main__':
    # 删除不是交易日期的数据