import pymysql,json,time
def get_countOrder_status(counting_order):
try:
#定时1min查询数据库,检查入库任务状态是否为“DONE”完成
status = ''
while True:
db = pymysql.connect(host=ip,port=port,user=user,passwd=pwd,db=wes_database,charset='utf8') #打开数据库连接
cursor = db.cursor() # 使用cursor()方法获取操作游标
# SQL 查询语句
sql = ('''SELECt status FROM `wes`.`counting_order` WHERe `counting_no` LIKE (%s) LIMIT 0,1000''')%counting_order
cursor.execute(sql)
db.commit() # 提交到数据库执行
result = cursor.fetchone()
#print(result)
status = result[0]
print("托盘的盘点状态为 "+status)
if status=='FINISH':
break
db.close() # 关闭数据库连接
time.sleep(10)
except BaseException as e:
print("error:",e)