import time, datetime
import json
import traceback

from apscheduler.schedulers.blocking import BlockingScheduler
import pandas as pd

from ZlwlAlgosCommon.utils.ProUtils import *
from ZlwlAlgosCommon.service.iotp.IotpAlgoService import IotpAlgoService

cur_env = 'prd' # 设置运行环境
app_path = "/home/shouxueqi/projects/zlwl-algos/" # 设置相对路径
log_base_path = f"{os.path.dirname(os.path.abspath(__file__))}/log" # 设置日志路径
app_name = "schedule" # 应用名, 建议与topic的后缀相同

sysUtils = SysUtils(cur_env, app_path)

mysqlUtils = MysqlUtils()
mysql_iotp_params = sysUtils.get_cf_param('mysql-iotp')
mysql_iotp_engine, mysql_iotp_Session= mysqlUtils.get_mysql_engine(mysql_iotp_params)


mysql_kw_params = sysUtils.get_cf_param('mysql-algo')
mysql_kw_engine, mysql_kw_Session= mysqlUtils.get_mysql_engine(mysql_kw_params)

redis_params = sysUtils.get_cf_param('redis')
redisUtils = RedisUtils()
rc = redisUtils.get_redis_conncect(redis_params)

kafka_params = sysUtils.get_cf_param('kafka')
kafkaUtils = KafkaUtils()
kafka_producer = kafkaUtils.get_kafka_producer(kafka_params, client_id="test")

logger_main = sysUtils.get_logger(app_name, log_base_path)



# # mysql
mysql_algo_params = sysUtils.get_cf_param('mysql-algo')
mysqlUtils = MysqlUtils()
mysql_algo_engine, mysql_algo_Session= mysqlUtils.get_mysql_engine(mysql_algo_params)
mysql_algo_conn = mysql_algo_engine.connect()
df_snpk_list = pd.read_sql("select sn, imei,pack_model,device_cell_type,scrap_status from t_device where organ_code='001001'", mysql_algo_conn)
df_snpk_list=df_snpk_list[df_snpk_list['scrap_status']<4]
df_snpk_list=df_snpk_list.rename(columns={'pack_model':'pack_code'})
print(len(df_snpk_list))

fault_info_ing=pd.read_sql("select * from algo_all_fault_info_ing", mysql_algo_conn)
print(len(fault_info_ing))
x=list(set(fault_info_ing['sn']))
print(len(x))
# fault_info_ing_after=pd.merge(fault_info_ing,df_snpk_list,on=['sn'],how='inner')
# print(len(fault_info_ing_after))
#     # main()
# task_day_1_sxq_test = task_day_1_1_sxq_test
# group_id_task_day_1_sxq_test = group_task_day_1_sxq_test