# -*- coding: utf-8 -*-
# Author : Charley
# Python : 3.10.8
# Date   : 2025/9/29 13:56
from loguru import logger

from mysql_pool import MySQLConnectionPool

sql_pool = MySQLConnectionPool(log=logger)

# data_list =  []
# for i in range(10000001,10700001):
#     data_list.append({"cert_id": i})
#
# print(len(data_list))
# sql_pool.insert_many("pcg_task", data_list)


"""
数据去重
"""

sql_cert_list = sql_pool.select_all("select cert_id from pcg_record")

sql_cert_list = [i[0] for i in sql_cert_list]

for i in sql_cert_list:
    # 更新task表中的state为1
    sql_pool.update_one_or_dict("pcg_task", {"state": 1}, {"cert_id": i})

logger.success("------------------- 更新完成 -------------------")