import pymysql
import socket
# 获取本机计算机名称
hostname = socket.gethostname()
# 获取本机ip
ip = socket.gethostbyname(hostname)
#print(ip)
ip_list = ['58.1.5.14','58.1.5.25','58.1.5.26','58.1.5.27','58.1.5.29','58.1.5.35']
# 设置任务编号
task_no = ""
if ip in ip_list:
#连接数据库
db = pymysql.connect(host='58.1.5.8', user='isa', password='123456', database='isa', port=13306, charset='utf8')
#使用cursor()方法创建一个游标对象
cursor = db.cursor()
#使用execute()方法执行SQL语句
sql = f"SELECT AGENT_NO,USER_NAME FROM T_CDA_AGENT WHERE AGENT_IP='{ip}'"
cursor.execute(sql)
#使用fetall()获取全部数据
data = cursor.fetchall()
# 设置数据库中T_RPA_JOB表中CURR_ROBOT_NO 值
curr_robot_no = ""
for i in data:
if i:
curr_robot_no = f"{i[1]}@{i[0]}"
#打印获取到的数据
print(curr_robot_no)
if curr_robot_no:
#使用cursor()方法创建一个游标对象
cursor = db.cursor()
#使用execute()方法执行SQL语句
sql = f"SELECT JOB_NO FROM T_RPA_JOB WHERE CURR_ROBOT_NO='{curr_robot_no}' AND STATUS='running'"
#print(sql)
cursor.execute(sql)
#使用fetall()获取全部数据
data = cursor.fetchall()
if data:
for i in data:
task_no = i[0]
else:
task_no = f"当前ip{ip}的机器人没有启动运行流程"
else:
task_no = f"当前ip{ip}的机器人不在机器人队列中"
#print(task_no)
#关闭游标和数据库的连接
cursor.close()
db.close()
else:
task_no = f"当前ip{ip}不是机器人运行IP"
#print(task_no)
return task_no