You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
This file contains ambiguous Unicode characters that may be confused with others in your current locale. If your use case is intentional and legitimate, you can safely ignore this warning. Use the Escape button to highlight these characters.
from Util . PgUtil import *
# 系统用户ID
SYSTEM_USER_ID = ' 16380C30-B1EA-4BFF-B5E6-4F3928CE36F3 '
# 普通用户ID
NORMAL_USER_ID = ' ca3e280e-12f0-33ff-c92e-4d56724b0fa1 '
USERS = [ SYSTEM_USER_ID , NORMAL_USER_ID ]
for USER in USERS :
# 当前处理哪个用户的文件
user_id = USER
# 获取所有生成的文件， ，
sql = " select t1.id,t1.task_id,t2.model_id from t_hy_task_files as t1 inner join t_hy_task as t2 on t1.task_id=t2.task_id where t2.user_id= ' %s ' " % (
user_id )
results = execute_query ( sql )
for row in results :
# 获取这个model_id+这个用户最小的任务编号是多少，然后把当前的数据修改为那个任务编号
sql = " select task_id from t_hy_task where model_id= %s and user_id= ' %s ' limit 1 " % ( row [ 2 ] , user_id )
res = execute_query ( sql )
if res :
task_id = res [ 0 ] [ 0 ]
sql = " update t_hy_task_files set task_id= %s where id= %s " % ( task_id , row [ 0 ] )
execute_modify ( sql )
print ( " 成功修改了一个数据 " )
# 删除表中没有生成过文件的任务
sql = " delete from t_hy_task where task_id not in (select task_id from t_hy_task_files) "
execute_modify ( sql )
# 清理完毕
print ( " 清理完毕 " )
