问题描述
在这个程序中，线程 main_target 在连续运行 1 小时后冻结。 我已经将此线程声明为守护进程，但仍然被杀死。
Project_name: AUTO PRN PROJECT
Author: Rakesh Ranjan Jena
Dept: ims
Company: BEST KOKI AUTOMOTIVE PVT. LTD.
Start Date:02.03.2021
Implement Date:
End Date:
DESCRIPTION:
This Project is for auto counting of OK NG Parts with Cycle time from each and every Machine.
This is IIoT Prject to Monitor Productivity of Machine and Process through Cycle time and OK,NG Count.
This Project is Applicable where PLC Communcication is Not Possible or PLC is OLDER or PLC is unable to send data to Server.
#IMPORTING LIBRARY
import threading
#GTK Library
import gi
gi.require_version('Gtk','3.0')
from gi.repository import Gtk,GObject,GLib,Gdk
#DATE and TIME Library
import datetime
from datetime import datetime
import time
import pytz
from datetime import timedelta
#DB API LIBRARY
import sqlite3
from sqlite3 import Error
#Rpi GPIO
import RPi.GPIO as GPIO
#URL LIBRARY
import urllib3
http = urllib3.PoolManager()
import log
from gi.repository import Gtk
app_path="/home/pi/autoprn/"
database = app_path+"autoprn.db"
GObject.threads_init()
class Handler:
def onDestroy(self,*args):
Gtk.main_quit()
# GLOBAL VARIABLES
try:
f = open(app_path+"device_id.data",'r',encoding = 'utf-8')
device_id=f.readline()
f.close()
except:
device_id=""
print("IO Error")
device_time_stamp=datetime.Now()
#variable Declaration For Timer Operation
start_count_signal=0
#GPIO Operation VARIABLES
OK=0
NG=0
CYCLE=0
model=""
remark=""
target=0
made=0
prev_idle_time=0
Now = datetime.Now(tz=pytz.timezone('Asia/Kolkata'))
device_time_stamp=(str(Now.strftime('%Y-%m-%d %H:%M:%s-%f')))
device_date=(str(Now.strftime('%Y-%m-%d')))
device_time=(str(Now.strftime('%H:%M:%s')))
#DB CONNECTION
def create_connection(db_file):
conn = None
try:
conn = sqlite3.connect(db_file)
except Error as e:
print(e)
return conn
#DB OPEERATIONS
def update_data_db():
global model
global OK
global NG
global device_time_stamp
global device_date
global device_time
global database
global CYCLE
#last_data_db_ok=0
#last_data_db_ng=0
#last_data_db_date=""
if not (model == None or model == ''):
try:
CYCLE=OK+NG
#log.writeLog("CYCLE:",CYCLE)
conn = create_connection(database)
command="SELECT * FROM data WHERE model='"+str(model)+"' AND date='"+str(device_date)+"'"
#print(command)
cursor = conn.execute(command)
data_1=cursor.fetchall()
if len(data_1)>0:
for row in data_1:
#last_data_db_date=str(row[1])
last_data_db_ok=int(row[5])
last_data_db_ng=int(row[6])
print(last_data_db_ok,last_data_db_ng)
if OK<last_data_db_ok or NG<last_data_db_ng:
#NEW DATA ADDED
OK+=last_data_db_ok
NG+=last_data_db_ng
print("Data Updated")
command="UPDATE data SET date='"+device_date+"',time='"+device_time+"',OK="+str(OK)+",NG="+str(NG)+",time_stamp='"+str(device_time_stamp)+"',CYCLE="+str(CYCLE)+",sync=0 WHERE model='"+str(model)+"' AND date='"+str(device_date)+"'"
#log.writeLog("UPDATE",command)
#print(command)
#conn.commit()
else:
OK=1
NG=0
print("Part Model found with name,New Addition: "+model)
command="INSERT INTO data(date,time,model,OK,NG,time_stamp,CYCLE,sync) VALUES ('"+device_date+"','"+device_time+"','"+str(model)+"',"+str(OK)+","+str(NG)+",'"+str(device_time_stamp)+"',"+str(CYCLE)+",0)"
#log.writeLog("INSERT",command)
#print(command)
conn.execute(command)
conn.commit()
except sqlite3.Error as er:
print("sql ERROR"+str(er))
#log.writeLog("Error",str(er))
finally:
conn.commit()
print("Data Updated")
conn.close()
def create_historian_data():
global prev_OK
global prev_NG
global model
global OK
global NG
global device_time_stamp
global device_date
global device_time
global database
global duration_in_s
global idle_time_in_sec
global remark
if not ((OK == prev_OK and NG == prev_NG) or (model == None or model == '')):
try:
conn = create_connection(database)
command="INSERT INTO historian(model,date,cycle_time,idle_time,remark) VALUES ('"+str(model)+"','"+str(device_date)+"','"+str(device_time)+"','"+str(duration_in_s)+"',"+str(idle_time_in_sec)+",'"+str(remark)+"')"
#print(command)
conn.execute(command)
conn.commit()
except sqlite3.Error as er:
print("sql ERROR"+str(er))
finally:
print("History Updated")
conn.close()
prev_OK=OK
prev_NG=NG
idle_time_in_sec=0
remark=""
else:
print("Same Data. IDLE Time Updated")
idle_time_in_sec+=duration_in_s
def main():
global database
global remark
remark="NEW COUNT"
database = app_path+"autoprn.db"
conn = create_connection(database)
builder = Gtk.Builder()
builder.add_from_file(app_path+"autoprn.glade")
builder.connect_signals(Handler())
#GET GUI Objects
date_label= builder.get_object("date_label")
shift_label= builder.get_object("shift_label")
model_Box= builder.get_object("model_Box")
count_btn= builder.get_object("count_btn")
OK_label= builder.get_object("OK_label")
NG_label= builder.get_object("NG_label")
#Sensor Labels
inp1_label= builder.get_object("inp1_label")
inp2_label= builder.get_object("inp2_label")
inp3_label= builder.get_object("inp3_label")
inp4_label= builder.get_object("inp4_label")
inp5_label= builder.get_object("inp5_label")
inp6_label= builder.get_object("inp6_label")
#OUTPUT Label
out1_label= builder.get_object("out1_label")
out2_label= builder.get_object("out2_label")
#Target and Completed Label
target_label= builder.get_object("target_label")
msg_label= builder.get_object("msg_label")
completed_label= builder.get_object("completed_label")
device_id_label= builder.get_object("device_id_label")
info_label= builder.get_object("info_label")
cycle_time_label= builder.get_object("cycle_time_label")
idle_time_label= builder.get_object("idle_time_label")
btn_man=builder.get_object("btn_man")
btn_machine=builder.get_object("btn_machine")
btn_material=builder.get_object("btn_material")
btn_method=builder.get_object("btn_method")
idle_time_disp=builder.get_object("idle_time_disp")
btn_shutdown=builder.get_object("shutdown_btn")
btn_restart=builder.get_object("restart_btn")
update_btn=builder.get_object("update_btn")
update_label=builder.get_object("update_label")
uc=builder.get_object("update_app")
pbar=builder.get_object("p_bar1")
"""
#4M DIALOG OBJECTS
dialog_4m=builder.get_object("dialog_4m")
dialog_idle_label=builder.get_object("dialog_idle_label")
btn_man1=builder.get_object("man_btn1")
btn_machien1=builder.get_object("machine_btn1")
btn_material1=builder.get_object("material_btn1")
btn_method1=builder.get_object("method_btn1")
dialog_cancel=builder.get_object("dialog_cancel")
dialog_save=builder.get_object("dialog_save")
#WIFI DIALOG OBJECTS
dialog_net_info=builder.get_object("network_conn_dialog")
net_info_label=builder.get_object("net_info")
network_dia_cancel=builder.get_object("network_dia_cancel")
#dialog.destroy()
#def dialog_4m_destroy():
#dialog_idle_label.set_text("Hello")
#dialog_4m.destroy()
#dialog_cancel.connect("clicked",dialog_4m.destroy)
#dialog_4m.fullscreen()
#dialog_4m.show_all()
#dialog_4m.run() """
#DeFinition Program to Shut Down Restart Device
def shutdown_device(self):
import os
try:
log.writeLog("Shut Down","Done")
#time.sleep(5)
os.system("sudo shutdown -h Now")
time.sleep(5)
except:
print("Shell Error!")
def restart_device(slef):
import os
try:
log.writeLog("Restart ","Done")
#time.sleep(5)
os.system("sudo shutdown -r Now")
time.sleep(5)
except:
print("Shell Error!")
#pbar.pulse()
def update_device(slef):
import app_update
update_label.set_text("")
try:
update_label.set_text("Please Wait..")
log.writeLog("Update ","Started")
#time.sleep(5)
#update_cmd="python3 "+app_path+"app_update.py"
#os.system(update_cmd)
win = app_update.prn_app_update()
win.on_start_stop()
win.show_all()
win.Gtk.main()
#GLib.idle_add(app_update.downloadFiles(app_update.source,app_update.destination))
#time.sleep(10)
update_label.set_text("Device Updated. Please Restart.")
except:
print("Shell Error!")
update_label.set_text("Device Updated. Please Restart.")
finally:
uc.destroy()
update_btn.connect("clicked",update_device)
btn_shutdown.connect("clicked",shutdown_device)
btn_restart.connect("clicked",restart_device)
def update_model_data():
try:
conn = sqlite3.connect(database)
command="SELECT part_name from model"
#print(command)
cursor = conn.execute(command)
for row in cursor:
model_Box.append_text(row[0])
except sqlite3.Error as er:
print("sql ERROR"+str(er))
finally:
print("Model Updated")
conn.close()
update_model_data()
device_id_label.set_text(str(device_id))
def update_local_time():
global device_time_stamp
global device_date
global device_time
Now = datetime.Now(tz=pytz.timezone('Asia/Kolkata'))
date_label.set_text(str(Now.strftime('%B %d,%Y %H:%M:%s')))
device_time_stamp=(str(Now.strftime('%Y-%m-%d %H:%M:%s-%f')))
device_date=(str(Now.strftime('%Y-%m-%d')))
device_time=(str(Now.strftime('%H:%M:%s')))
def record_alert(alert,desc):
global device_time_stamp
global device_date
global device_time
global model
global database
global prev_idle_time
global idle_time_in_sec
sync=0
try:
conn = create_connection(database)
command="SELECT * FROM alert WHERE alert_name='"+str(alert)+"' AND date='"+str(device_date)+"' AND description='"+str(desc)+"' AND model='"+str(model)+"'"
#print(command)
cursor = conn.execute(command)
data_1=cursor.fetchall()
if len(data_1)>0:
if (prev_idle_time-idle_time_in_sec)<=-300:
print("Alert Updated")
command="UPDATE alert SET time='"+device_time+"',sync=0 WHERE model='"+str(model)+"' AND date='"+str(device_date)+"'"
prev_idle_time=idle_time_in_sec
#print(command)
else:
command="INSERT INTO alert(date,alert_name,description,sync) VALUES ('"+str(device_date)+"','"+str(alert)+"','"+str(desc)+"',"+str(sync)+")"
#print(command)
conn.execute(command)
conn.commit()
except sqlite3.Error as er:
print("sql ERROR"+str(er))
finally:
print("Alert Raised!")
conn.close()
#print(device_time_stamp)
def update_data_model(self):
global model
global OK
global NG
OK=0
NG=0
model=model_Box.get_active_text()
#if start_count_signal==1:
info_label.set_text("Selected Part: " + str(model))
if model==None:
target_label.set_text(str('NA'))
start_count_signal=0
else:
target_label.set_text(str(getTarget()))
start_count_signal=1
print(start_count_signal)
count_btn.connect("clicked",update_data_model)
#GET AND SET TARGET
def getTarget():
global database
global model
global device_date
global target
target_data=0
try:
conn = create_connection(database)
command="SELECT target FROM model WHERE part_name='"+str(model)+"' AND date='"+str(device_date)+"'"
#print(command)
cursor = conn.execute(command)
data2=cursor.fetchall()
for row in data2:
target_data=row[0]
except sqlite3.Error as er:
print("sql ERROR"+str(er))
finally:
print("Got a Target..")
conn.close()
target=target_data
return target_data
#DeFinition to Set OK and NG =o if Model is undeified. Print UIUX and Database
def update_data():
global OK
global NG
global model
global in1
global in3
global idle_time_in_sec
global remark
global device_id
global target
global made
global prev_idle_time
m1=""
m2=""
m3=""
m4=""
if model==None or model=="":
OK=0
NG=0
OK_label.set_text(str(OK))
NG_label.set_text(str(NG))
completed_label.set_text(str(OK))
inp1_label.set_text(str(in1))
inp2_label.set_text(str(in3))
print("Device iD:"+ device_id)
production=target-OK
if OK>target:
production=production*(-1)
msg="Production Exceeded By:"+str(production)
msg_label.set_text(msg)
if OK != made:
record_alert("Production Exceeded",str(msg))
made=OK
elif OK==target and OK>0 and target>0:
msg="Target Achieved,Pending :"+str(production)
msg_label.set_text(msg)
elif OK<target:
msg="In Progress,Pending :"+str(production)
msg_label.set_text(msg)
else:
msg_label.set_text("")
if (prev_idle_time-idle_time_in_sec)<=-300:
remark=""
idle_time_disp.set_text(str(int(idle_time_in_sec)))
#print("IDLE TIME REACHED")
if btn_man.get_active() == True:
m1="MAN,"
if btn_machine.get_active() == True:
m2="MCHINE,"
if btn_material.get_active() == True:
m3="MATERIAL,"
if btn_method.get_active() == True:
m4="METHOD,"
remark=m1+m2+m3+m4
if remark=="" or remark==None:
remark="UNPLANNED WITHOUT ANY REASON"
record_alert("IDLE TIME",remark)
#print("Hello WORLD 1")
def update_cycle_time():
global dle_time_in_sec
global duration_in_s
idle_time_label.set_text(str(idle_time_in_sec))
cycle_time_label.set_text(str(duration_in_s))
def main_target():
global prev_OK
global prev_NG
global OK
global NG
global idle_time_in_sec
global duration_in_s
global in1
global in3
prev_OK=0
prev_NG=0
idle_time_in_sec=0
duration_in_s=0
input_pin1=16
input_pin2=12
input_pin3=26
output_pin1=20
output_pin2=21
GPIO.setwarnings(False)
GPIO.setmode(GPIO.BCM)
GPIO.setup(input_pin1,GPIO.IN)
GPIO.setup(input_pin2,GPIO.IN)
GPIO.setup(input_pin3,GPIO.IN)
GPIO.setup(output_pin1,GPIO.OUT)
GPIO.setup(output_pin2,GPIO.OUT)
while True:
duration_in_sec=0
idle_count_flag=0
idle_time_start=datetime.Now()
#sensor and Pin Configuration Variables,I/O Pin Varibles
d1=0
d0=0
in1=GPIO.input(input_pin1)
in2=GPIO.input(input_pin2)
in3=GPIO.input(input_pin3)
#Momnitor Sensor Value Loop
while in1==0:
#start Cycle Time Count
if idle_count_flag==0:
idle_count_flag=1
first_time = datetime.Now()
print("OK Loop")
in1=GPIO.input(input_pin1)
in3=GPIO.input(input_pin3)
if in1==1:
OK+=1
if in3==0:
d0+=1
if in3==1:
if d0>=1:
NG+=1
d0=0
print("d0:"+str(d0))
print(OK,NG)
while in3==0:
if idle_count_flag==0:
idle_count_flag=1
first_time = datetime.Now()
print("In NG Loop")
in3=GPIO.input(input_pin3)
in1=GPIO.input(input_pin1)
if in3==1:
NG+=1
if in1==0:
d1+=1
if in1==1:
if d1>=1:
OK+=1
d1=0
print("d1:"+str(d1))
print(OK,NG)
print(model,NG)
#if model !=None and model==!=""
print(in1,in3)
print(prev_OK,prev_NG)
#time.sleep(1)
#GLib.idle_add()
later_time = datetime.Now()
if idle_count_flag==0:
difference=0
duration_in_sec=0
difference = later_time-idle_time_start
duration_in_sec = float(difference.total_seconds())*10
idle_time_in_sec += round(duration_in_sec,4)
#idle_time_in_sec=idle_time_in_sec
print("Idle Time"+str(idle_time_in_sec))
else:
difference = later_time - first_time
duration_in_s = float(difference.total_seconds())
print("Cycle Time"+ str(duration_in_s))
create_historian_data()
update_data_db()
#idle_time_in_sec=0
GLib.idle_add(update_cycle_time)
#GLib.idle_add(update_data)
GObject.timeout_add(100,update_data)
#GLib.idle_add(update_local_time)
#GLib.idle_add(update_data_db)
GLib.timeout_add(10,update_local_time)
#difference = later_time - first_time
time.sleep(0.01)
GPIO.cleanup()
thread = threading.Thread(target=main_target)
thread.daemon = True
thread.start()
#update Date and Time
window = builder.get_object("window1")
window.fullscreen()
window.show_all()
window.connect("deenter code herestroy",Gtk.main_quit)
#GObject.timeout_add(100,print("Hello"))
Gtk.main()
if __name__ == '__main__':
main()
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）