@ -21,7 +21,7 @@ ConfPath g_conf_path;
SysConf g_sys_conf ; //系统配置参数
ModbusConf g_modbus_conf ; //modbus地址参数
PLCDevice * m_PLCDevice , * m_PLCTCP Device;
PLCDevice * m_PLC ;
bool g_plc_dialog_open ; //是否打开plc配置对话框
QDateTime g_ts_start ;
@ -67,7 +67,9 @@ SyncQueue<_UDPSendInfo>* UDP_Info_queue;
# endif
# ifdef __TCPSend
SyncQueue < _TCPSendInfo > * TCP_Info_queue ;
# endif
# ifdef __MQTTSend
SyncQueue < _MqttSendInfo > * MQTT_Info_queue ;
# endif
bool flag = false ;
SyncQueue < _XMLExportDataInfo > * export_XMLData_Info_queue ;
@ -114,53 +116,47 @@ Cigarette::Cigarette(QWidget* parent)
InitPtrMat ( ) ;
read_conf ( g_conf_path ) ;
if ( ! g_conf_path . config_path . isEmpty ( ) ) { //判断conf路径是否存在， ，
if ( ! g_conf_path . config_path . isEmpty ( ) ) {
// 如果非空
QDir * dirinfo = new QDir ( g_conf_path . config_path ) ;
if ( ! dirinfo - > exists ( ) ) {
// 如果文件夹信息不存在
delete dirinfo , dirinfo = nullptr ;
g_conf_path . config_path = DEFAULT_CONFPATH_PATH ;
g_conf_path . config_path = " D:/conf " ;
}
delete dirinfo , dirinfo = nullptr ;
}
else
{
# ifdef __DEBUGPATH
g_conf_path . config_path = " ../conf/conf.txt " ;
# else
g_conf_path . config_path = DEFAULT_CONFPATH_PATH ;
# endif
}
g_conf_path . config_path = " D:/conf " ;
bool update_rotate = false ;
if ( ! read_rotate_message ( ) ) { //读取旋转参数
if ( ! read_rotate_message ( ) ) {
update_rotate = true ;
}
QThread * hThread = new QThread ( ) ; //主线程
CLog * clogWorkThread = new CLog ( ) ; //日志线程
clogWorkThread - > moveToThread ( hThread ) ; //将日志线程依附到主线程（相当于父类）
connect ( this , & Cigarette : : destroyed , hThread , & QThread : : quit ) ; //Cigarette退出系统了， ；
connect ( hThread , & QThread : : finished , clogWorkThread , & CLog : : deleteLater ) ; //Qt类结束，
connect ( this , & Cigarette : : sengMsgToClog , clogWorkThread , & CLog : : recMegFromCigarette ) ; // sengMsgToClog 写日志的信号，
# ifdef LOG_RECORD
QThread * hThread = new QThread ( ) ;
CLog * clogWorkThread = new CLog ( ) ;
clogWorkThread - > moveToThread ( hThread ) ;
connect ( this , & Cigarette : : destroyed , hThread , & QThread : : quit ) ;
connect ( hThread , & QThread : : finished , clogWorkThread , & CLog : : deleteLater ) ;
connect ( this , & Cigarette : : sengMsgToClog , clogWorkThread , & CLog : : recMegFromCigarette ) ;
hThread - > start ( ) ;
emit sengMsgToClog ( " Application Start. " ) ;
//初始化队列
//保存队列
# endif
g_save_queue = new SyncQueue < std : : pair < std : : string , cv : : Mat > > ( Queue_Size ) ;
g_save_queue - > name = " save queue " ;
# ifdef __UDPSend
UDP_Info_queue = new SyncQueue < _UDPSendInfo > ( Queue_Size ) ;
UDP_Info_queue - > name = " UDP Info queue " ;
# endif
//TCP队列
# ifdef __TCPSend
TCP_Info_queue = new SyncQueue < _TCPSendInfo > ( Queue_Size ) ;
TCP_Info_queue - > name = " TCP Info queue " ;
# endif
//FTP数据队列
# ifdef __MQTTSend
MQTT_Info_queue = new SyncQueue < _MqttSendInfo > ( Queue_Size ) ;
MQTT_Info_queue - > name = " MQTT Info queue " ;
# endif
# ifdef __ExportData
export_XMLData_Info_queue = new SyncQueue < _XMLExportDataInfo > ( Queue_Size ) ;
export_XMLData_Info_queue - > name = " Export Data Info queue " ;
@ -168,7 +164,6 @@ Cigarette::Cigarette(QWidget* parent)
last_shift = 256 ;
work_camera_nums = 0 ;
//相机公共队列(合成图片)
# ifdef SYNC_CAMERA
g_image_sync_queue = new SyncQueue < std : : vector < std : : pair < int , cv : : Mat > > > ( Queue_Size ) ;
g_image_sync_queue - > name = format ( " sync_image " ) ;
@ -176,26 +171,20 @@ Cigarette::Cigarette(QWidget* parent)
for ( int i = 0 ; i < NumberOfSupportedCameras ; i + + )
{
# ifndef SYNC_CAMERA
//相机单独队列
g_image_queue [ i ] = new SyncQueue < std : : pair < int , cv : : Mat > > ( Queue_Size ) ;
g_image_queue [ i ] - > name = format ( " image_%d " , i ) ;
# endif
//结果队列
g_result_queue [ i ] = new ASyncQueue < bool > ( Queue_Size ) ;
g_result_queue [ i ] - > name = format ( " result_%d " , i ) ;
//结果延后队列
g_result_wait_queue [ i ] = new ASyncQueue < bool > ( Queue_Size ) ;
g_result_wait_queue [ i ] - > name = format ( " result_wait%d " , i ) ;
//两个结果队列
g_double_queue [ i ] = new ASyncQueue < bool > ( Queue_Size ) ;
g_double_queue [ i ] - > name = format ( " double_wait%d " , i ) ;
//拍照队列
g_shooted_queue [ i ] = new ASyncQueue < bool > ( Queue_Size ) ;
g_shooted_queue [ i ] - > name = format ( " shooted_%d " , i ) ;
//调试队列
g_debug_queue [ i ] = new SyncQueue < cv : : Mat > ( Queue_Size ) ;
g_debug_queue [ i ] - > name = format ( " debug_%d " , i ) ;
if ( update_rotate ) { //未读到旋转参数，进行初始化
if ( update_rotate ) {
rotationAngle [ i ] = cv : : ROTATE_90_COUNTERCLOCKWISE + 1 ;
isNeedRotate [ i ] = false ;
}
@ -213,7 +202,7 @@ Cigarette::Cigarette(QWidget* parent)
g_op_time = OP_TIME ;
g_op_pswd = read_op_pswd ( ) ;
g_working = false ; //调试标志
g_working = false ;
g_debug_mode = false ;
g_alarm_msg < < QStringLiteral ( " 无报警 " ) /// 0
@ -236,14 +225,14 @@ Cigarette::Cigarette(QWidget* parent)
for ( int i = 0 ; i < NumberOfSupportedCameras ; i + + )
{
g_display_label_conf [ i ] . g_max [ 0 ] = false ; //视图最大化
g_display_label_conf [ i ] . g_max [ 0 ] = false ;
g_display_label_conf [ i ] . g_max [ 1 ] = false ;
OpenWithUserID [ i ] = 0xff ; //没用
production_number [ i ] = 0 ; //检测个数
lcdNumber_total_mat [ i ] - > display ( production_number [ i ] ) ; //display 显示到界面
OpenWithUserID [ i ] = 0xff ;
production_number [ i ] = 0 ;
lcdNumber_total_mat [ i ] - > display ( production_number [ i ] ) ;
ok [ i ] = 0 ;
ng [ i ] = 0 ;
g_display_label_conf [ i ] . g_last_mat [ 0 ] = cv : : Mat : : zeros ( 20 , 20 , CV_8UC3 ) ; //放大后的图片
g_display_label_conf [ i ] . g_last_mat [ 0 ] = cv : : Mat : : zeros ( 20 , 20 , CV_8UC3 ) ;
g_display_label_conf [ i ] . g_last_mat [ 1 ] = cv : : Mat : : zeros ( 20 , 20 , CV_8UC3 ) ;
# ifdef DRAW_RECT
DrawRect_init ( i ) ;
@ -273,51 +262,45 @@ Cigarette::Cigarette(QWidget* parent)
g_modbus_conf . debug = 0 ;
g_modbus_conf . reset = 0 ;
g_modbus_conf . alarm = 0 ;
g_modbus_conf . heart = 0 ;
read_modbus_config ( g_modbus_conf ) ; //初始化modbus地址
//保存图片线程
saveThread . init ( ) ; //初始化
# ifdef __TCPSend
saveThread . init ( ) ;
# ifdef __ExportData
connect ( & sync_work_thread , & SyncWorkThread : : sendDataToCompress , & exportDataThread , & ExportDataThread : : GetDataFromSaveThread ) ;
# endif
connect ( & saveThread , & SaveThread : : sendDataToExport , & exportDataThread , & ExportDataThread : : GetDataFromSaveThread ) ;
# endif
saveThread . start_work ( ) ;
# ifdef __UDPSend
sThread . init ( UDP_Info_queue , g_sys_conf . MonitorIP , g_sys_conf . MonitorPort ) ;
sThread . start_work ( ) ;
rThread = new threadReceive ( ) ;
rThread - > init ( g_sys_conf . MonitorIP , g_sys_conf . MonitorPort ) ;
connect ( rThread , & threadReceive : : sendMsgToCigratte , this , & Cigarette : : recMsgFromUdp ) ;
rThread - > start_work ( ) ;
rThread . init ( g_sys_conf . MonitorIP , g_sys_conf . MonitorPort ) ;
connect ( & rThread , & threadReceive : : sendMsgToCigratte , this , & Cigarette : : recMsgFromUdp ) ;
rThread . start_work ( ) ;
# endif
//初始化TCP数据传输线程
# ifdef __TCPSend
std : : string serverIp = g_sys_conf . TcpIP ;
int serverPort = g_sys_conf . TcpPort ;
tcpSendThread . init ( TCP_Info_queue , serverIp , serverPort ) ;
tcpSendThread . start_work ( ) ;
std : : string ServerIp = g_sys_conf . TcpIP ;
int ServerPort = g_sys_conf . TcpPort ;
TcpSendThread . init ( TCP_Info_queue , ServerIp , ServerPort ) ;
TcpSendThread . start_work ( ) ;
# endif
# ifdef __MQTTSend
std : : string MqttServerIp = g_sys_conf . TcpIP ;
int MqttServerPort = g_sys_conf . TcpPort ;
MqttSendThread . init ( MQTT_Info_queue , MqttServerIp , MqttServerPort ) ;
MqttSendThread . start_work ( ) ;
# endif
//初始化FTP数据传输线程
# ifdef __ExportData
string ftpip = g_sys_conf . FtpIP ;
int ftpport = g_sys_conf . FtpPort ;
string ftpusername = g_sys_conf . FtpUserName ;
string ftpuserpwd = g_sys_conf . FtpUserPwd ;
exportDataThread . init ( ftpip , ftpport , ftpusername , ftpuserpwd ) ;
# ifdef __ExportData
exportDataThread . init ( ) ;
connect ( this , & Cigarette : : sendMsgToExportData , & exportDataThread , & ExportDataThread : : EDrecMsgFromCigarette ) ;
exportDataThread . start_work ( ) ;
//connect(this, &Cigarette::sendMsgToExportData, &exportDataThread, &ExportDataThread::EDrecMsgFromCigarette);
# endif
//初始化通讯PLC
m_PLCDevice = new PLCDevice ;
PLCDevice : : init_plc ( m_PLCDevice ) ;
m_PLCTCPDevice = new PLCDevice ;
PLCDevice : : init_plc_tcp ( m_PLCTCPDevice ) ;
if ( m_PLCDevice - > g_plc_ok )
{
printf ( " Connected to dev! \n " ) ;
@ -344,27 +327,26 @@ Cigarette::Cigarette(QWidget* parent)
}
std : : cout < < " Enumerate Cameras... " < < std : : endl ;
EnumerateCameras ( ( SingleCamInfoStruct * ) & SingleCamInfo , true , g_sys_conf ) ; //枚举相机
EnumerateCameras ( ( SingleCamInfoStruct * ) & SingleCamInfo , true , g_sys_conf ) ;
// 剔除值清0
int ret = m_PLCDevice - > write_bit_2_plc ( g_modbus_conf . shift , 1 ) ; //给PLC发送换班消息
# ifdef SYNC_CAMERA
CreatWorkThread ( 0 , 0 , this ) ; //创建相机公共工作线程
CreatWorkThread ( 0 , 0 , this ) ;
# endif
//创建相机工作线程
for ( int i = 0 ; i < NumberOfSupportedCameras ; i + + )
{
//读取模型文件
if ( SingleCamInfo [ i ] . Detect ) { //检测相机是否存在
work_camera_nums + + ; //相机数量
if ( SingleCamInfo [ i ] . Detect ) {
work_camera_nums + + ;
cam_status_mat [ i ] - > setStyleSheet ( tr ( " background-color: rgb(0, 170, 0); " ) ) ;
QString model_path , model_name ;
if ( g_sys_conf . model_path . isEmpty ( ) ) {
model_path = DEFAULT_MODEL_PATH ;
g_sys_conf . model_path = DEFAULT_MODEL_PATH ;
model_path = " D:/model " ;
g_sys_conf . model_path = " D:/model " ;
}
else
model_path = g_sys_conf . model_path ;
@ -382,15 +364,14 @@ Cigarette::Cigarette(QWidget* parent)
exit ( - 1 ) ;
}
# ifdef SYNC_CAMERA
//调试模式线程
debug_thread [ i ] . init ( g_debug_queue [ i ] , i ) ;
connect ( & debug_thread [ i ] , SIGNAL ( notify ( int , int , cv : : Mat ) ) , this , SLOT ( OnNotifyHub ( int , int , cv : : Mat ) ) ) ;
debug_thread [ i ] . start_work ( ) ;
# else
CreatWorkThread ( SingleCamInfo [ i ] . CamClass , i , this ) ; //创建相机单独工作线程
CreatWorkThread ( SingleCamInfo [ i ] . CamClass , i , this ) ;
# endif
}
else { //报警信息
else {
QDateTime ts_start = QDateTime : : currentDateTime ( ) ;
QTime time = QTime : : currentTime ( ) ;
QDateTime local ( ts_start ) ;
@ -459,40 +440,35 @@ Cigarette::Cigarette(QWidget* parent)
sThread . sendData ( " LockOk " , g_sys_conf . FeedbackPort ) ;
# endif
DisableDebugMode ( ) ;
//读取PLC信息等
m_pTimer = new QTimer ( this ) ;
connect ( m_pTimer , SIGNAL ( timeout ( ) ) , this , SLOT ( handleTimeout ( ) ) ) ; //SIGNAL(timeout())周期性， ；
connect ( m_pTimer , SIGNAL ( timeout ( ) ) , this , SLOT ( handleTimeout ( ) ) ) ;
m_pTimer - > start ( 1000 ) ;
m_delay = new QTimer ( this ) ; //换班防连击
connect ( m_delay , SIGNAL ( timeout ( ) ) , this , SLOT ( enable_shift ( ) ) ) ;
# ifdef __UDPSend
m_sendMsg_delay = new QTimer ( this ) ;
connect ( m_sendMsg_delay , SIGNAL ( timeout ( ) ) , this , SLOT ( sendLatestData ( ) ) ) ;
# endif
//SIGNAL信号函数与SLOT槽函数，
//无参信号对应无参槽函数
//检查操作员时间
m_op_delay = new QTimer ( this ) ;
connect ( m_op_delay , SIGNAL ( timeout ( ) ) , this , SLOT ( op_timeout ( ) ) ) ;
//检查管理员时间
m_admin_delay = new QTimer ( this ) ;
connect ( m_admin_delay , SIGNAL ( timeout ( ) ) , this , SLOT ( admin_timeout ( ) ) ) ;
//定时自动清理照片
# ifdef CLEAR_THREAD
clean_pTimer = new QTimer ( this ) ;
connect ( clean_pTimer , SIGNAL ( timeout ( ) ) , this , SLOT ( CleanThreadStartAuto ( ) ) ) ;
clean_pTimer - > start ( 3600000 ) ;
//报警标签双击消警
connect ( ui . label_alarm , SIGNAL ( QlabelDoubleClick ( ) ) , this , SLOT ( OnCancelAlarm ( ) ) ) ; //
clean_pTimer - > start ( 5000 ) ;
# endif
# ifdef __MQTTSend
mqtt_pTimer = new QTimer ( this ) ;
connect ( mqtt_pTimer , SIGNAL ( timeout ( ) ) , this , SLOT ( MqttMsgSend ( ) ) ) ;
mqtt_pTimer - > start ( 3600000 ) ;
# endif
//心跳检测
heartbeat_pTimer = new QTimer ( this ) ;
connect ( heartbeat_pTimer , SIGNAL ( timeout ( ) ) , this , SLOT ( heartbeat ( ) ) ) ;
heartbeat_pTimer - > start ( 5000 ) ;
connect ( ui . label_alarm , SIGNAL ( QlabelDoubleClick ( ) ) , this , SLOT ( OnCancelAlarm ( ) ) ) ; //报警标签双击消警
//无参对有参需要利用信号转发器QSignalMapper(this)
//信号转发器
image_lable_DBsignalMapper0 = new QSignalMapper ( this ) ;
image_lable_DBsignalMapper1 = new QSignalMapper ( this ) ;
image_lable_TPsignalMapper0 = new QSignalMapper ( this ) ;
@ -501,14 +477,11 @@ Cigarette::Cigarette(QWidget* parent)
pTimer_Cam_signalMapper = new QSignalMapper ( this ) ;
toolButton_cam_signalMapper = new QSignalMapper ( this ) ;
RotateReleased_signalMapper = new QSignalMapper ( this ) ;
for ( int i = 0 ; i < NumberOfSupportedCameras ; i + + )
{
//SIGNAL信号函数与SLOT槽函数，
{
m_pTimer_Cam_mat [ i ] = new QTimer ( this ) ;
connect ( m_pTimer_Cam_mat [ i ] , SIGNAL ( timeout ( ) ) , pTimer_Cam_signalMapper , SLOT ( map ( ) ) ) ;
pTimer_Cam_signalMapper - > setMapping ( m_pTimer_Cam_mat [ i ] , i ) ; //此句执行后map()=>mapped(int);相当于无参变有参
pTimer_Cam_signalMapper - > setMapping ( m_pTimer_Cam_mat [ i ] , i ) ;
connect ( display_lable_mat [ i ] [ 0 ] , SIGNAL ( QlabelDoubleClick ( ) ) , image_lable_DBsignalMapper0 , SLOT ( map ( ) ) ) ;
image_lable_DBsignalMapper0 - > setMapping ( display_lable_mat [ i ] [ 0 ] , i < < 4 | 0 ) ;
@ -532,8 +505,6 @@ Cigarette::Cigarette(QWidget* parent)
RotateReleased_signalMapper - > setMapping ( rotate_mat [ i ] , i ) ;
}
//SIGNAL信号函数与SLOT槽函数，
//有参对有参
connect ( toolButton_cam_signalMapper , SIGNAL ( mapped ( int ) ) , this , SLOT ( OnToolButtonCamReleasedHub ( int ) ) ) ;
//connect(pTimer_Cam_signalMapper, SIGNAL(mapped(int)), this, SLOT(OpenCamTimeoutHub(int)));
connect ( image_lable_DBsignalMapper0 , SIGNAL ( mapped ( int ) ) , this , SLOT ( OnDBClickHub ( int ) ) ) ;
@ -576,11 +547,9 @@ Cigarette::Cigarette(QWidget* parent)
}
if ( m_PLCDevice - > g_plc_ok ) {
BeforeWork ( g_sys_conf . shoot ) ; //预热
BeforeWork ( g_sys_conf . shoot ) ;
int ret = m_PLCDevice - > write_bit_2_plc ( g_modbus_conf . work , 1 ) ;
ui . label_title - > setStyleSheet ( tr ( " background-color: rgb(0, 170, 0); " ) ) ;
ui . label_title_2 - > setStyleSheet ( tr ( " background-color: rgb(0, 170, 0); " ) ) ;
ui . label_title_2 - > setText ( QStringLiteral ( " 运行中 " ) ) ;
# ifdef __UDPSend
sThread . sendData ( " Work " , g_sys_conf . FeedbackPort ) ;
# endif
@ -601,7 +570,7 @@ Cigarette::~Cigarette()
{
emit sengMsgToClog ( " Application exited. " ) ;
Exit ( ) ;
exit ( - 1 ) ;
//exit(-1);
}
void Cigarette : : start_work ( )
@ -648,8 +617,6 @@ void Cigarette::start_work()
ret = m_PLCDevice - > write_bit_2_plc ( g_modbus_conf . work , 1 ) ; */
//printf("write:\t%d\n", ret);
ui . label_title - > setStyleSheet ( tr ( " background-color: rgb(0, 170, 0); " ) ) ;
ui . label_title_2 - > setStyleSheet ( tr ( " background-color: rgb(0, 170, 0); " ) ) ;
ui . label_title_2 - > setText ( QStringLiteral ( " 运行中 " ) ) ;
# ifdef __UDPSend
sThread . sendData ( " Work " , g_sys_conf . FeedbackPort ) ;
# endif
@ -666,8 +633,6 @@ void Cigarette::start_work()
//开始按钮
void Cigarette : : on_btn_start_released ( )
{
uint16_t data [ 2 ] = { 1111 , 0 } ;
m_PLCTCPDevice - > write_2_plc ( 0 , 70 , data ) ; //条盒
emit sengMsgToClog ( " Start to work. " ) ;
if ( ! g_admin_mode )
{
@ -702,8 +667,6 @@ void Cigarette::pause_work()
int ret = m_PLCDevice - > write_bit_2_plc ( g_modbus_conf . work , 0 ) ;
//printf("write:\t%d\n", ret);
ui . label_title - > setStyleSheet ( tr ( " background-color: rgb(255, 255, 0); " ) ) ;
ui . label_title_2 - > setStyleSheet ( tr ( " background-color: rgb(255, 255, 0); " ) ) ;
ui . label_title_2 - > setText ( QStringLiteral ( " 未运行 " ) ) ;
# ifdef __UDPSend
sThread . sendData ( " NoWork " , g_sys_conf . FeedbackPort ) ;
# endif
@ -756,12 +719,15 @@ void Cigarette::Exit()
delete g_save_queue ;
# ifdef __UDPSend
sThread . stop ( ) ;
rThread - > stop ( ) ;
delete rThread ;
rThread . stop ( ) ;
# endif
# ifdef __TCPSend
tcpSendThread . stop ( ) ;
TcpSendThread . stop ( ) ;
# endif
# ifdef __MQTTSend
MqttSendThread . stop ( ) ;
# endif
# ifdef __ExportData
@ -774,10 +740,6 @@ void Cigarette::Exit()
m_PLCDevice - > disconnect_plc ( ) ;
delete m_PLCDevice ;
}
if ( m_PLCTCPDevice ) {
m_PLCTCPDevice - > disconnect_plc ( ) ;
delete m_PLCTCPDevice ;
}
qApp - > quit ( ) ;
this - > close ( ) ;
@ -1051,7 +1013,7 @@ void Cigarette::OnToolButtonCamReleasedHub(int Num)
QMessageBox : : information ( NULL , QStringLiteral ( " 权限检查 " ) , QStringLiteral ( " 请先点击解锁按钮，进入管理员模式 " ) , QMessageBox : : Ok ) ;
}
}
//重连相机
void Cigarette : : ReconnectCamHub ( int Num )
{
//close
@ -1064,6 +1026,7 @@ void Cigarette::ReconnectCamHub(int Num)
}
}
}
void Cigarette : : OpenCamTimeoutHub ( int Num ) //重新打开相机
{
//open
@ -1080,14 +1043,14 @@ void Cigarette::OnKey(QKeyEvent* event)
int Cnt = CurOpLabel & 0x0f ;
std : : lock_guard < std : : mutex > locker ( g_display_label_conf [ Num ] . lock ) ;
if ( event - > key ( ) = = Qt : : Key_Escape & & event - > isAutoRepeat ( ) = = false ) //画框Esc清除参数
if ( event - > key ( ) = = Qt : : Key_Escape & & event - > isAutoRepeat ( ) = = false )
{
if ( g_display_label_conf [ Num ] . RectVet [ Cnt ] . size ( ) )
{
g_display_label_conf [ Num ] . RectVet [ Cnt ] . pop_back ( ) ;
}
}
else if ( event - > key ( ) = = Qt : : Key_Return & & event - > isAutoRepeat ( ) = = false ) //画框回车保存参数
else if ( event - > key ( ) = = Qt : : Key_Return & & event - > isAutoRepeat ( ) = = false )
{
std : : fstream cfg_file ;
char buf [ 256 ] ;
@ -1593,13 +1556,7 @@ void Cigarette::admin_timeout()
}
}
//心跳检测
void Cigarette : : heartbeat ( )
{
int ret = m_PLCDevice - > write_bit_2_plc ( g_modbus_conf . heart , 1 ) ;
}
void Cigarette : : handleTimeout ( ) //获取时间， ； ；
void Cigarette : : handleTimeout ( )
{
QDateTime ts_start = QDateTime : : currentDateTime ( ) ;
QTime time = QTime : : currentTime ( ) ;
@ -1920,7 +1877,6 @@ void Cigarette::handleTimeout()//获取时间， ；
ui . label_alarm - > setStyleSheet ( tr ( " background-color: rgb(0, 170, 0); " ) ) ;
ui . label_alarm - > setText ( QStringLiteral ( " 无报警 " ) ) ;
}
# ifdef __UDPSend
QString str ;
str = QString ( " alarm " ) + ' _ ' + QString : : number ( alarm_info . alarm_code ) ;
@ -2106,8 +2062,8 @@ void Cigarette::on_pushButton_clear_released()//换班
g_op_time = OP_TIME ;
ui . pushButton_clear - > setEnabled ( false ) ;
m_delay - > setSingleShot ( true ) ; //执行一次
m_delay - > start ( 5000 ) ; //5秒
m_delay - > setSingleShot ( true ) ;
m_delay - > start ( 5000 ) ;
Sleep ( 500 ) ;
for ( int i = 0 ; i < NumberOfSupportedCameras ; i + + )
{
@ -2149,11 +2105,7 @@ void Cigarette::on_pushButton_clear_released()//换班
QString Cigarette : : read_pswd ( )
{
std : : fstream cfg_file ;
# ifdef __DEBUGPATH
cfg_file . open ( " pswd.txt " ) ;
# else
cfg_file . open ( " D:/Release/pswd.txt " ) ;
# endif
if ( ! cfg_file . is_open ( ) )
{
std : : cout < < " Error: Open config file pswd.txt " < < std : : endl ;
@ -2185,11 +2137,7 @@ QString Cigarette::read_pswd()
QString Cigarette : : read_op_pswd ( )
{
std : : fstream cfg_file ;
# ifdef __DEBUGPATH
cfg_file . open ( " pswd_op.txt " ) ;
# else
cfg_file . open ( " D:/Release/pswd_op.txt " ) ;
# endif
if ( ! cfg_file . is_open ( ) )
{
std : : cout < < " Error: Open config file pswd_op.txt " < < std : : endl ;
@ -2220,15 +2168,15 @@ QString Cigarette::read_op_pswd()
bool Cigarette : : read_conf ( ConfPath & conf_path ) {
std : : fstream conf_file ;
conf_file . open ( CONFPATH ) ;
if ( ! conf_file . is_open ( ) ) { //判断能否打开文件
if ( ! conf_file . is_open ( ) ) {
std : : cout < < " Error: Open conf path file " < < CONFPATH < < std : : endl ;
return false ;
}
while ( ! conf_file . eof ( ) ) { //从头读到尾，
while ( ! conf_file . eof ( ) ) {
char tmp [ 256 ] = " " ;
conf_file . getline ( tmp , 256 ) ;
std : : string line ( tmp ) ;
if ( line . length ( ) > 0 ) { //按行读取
if ( line . length ( ) > 0 ) {
size_t pos = line . find ( ' = ' ) ;
std : : string tmp_key = line . substr ( 0 , pos ) ;
if ( tmp_key = = " CONF_PATH " ) {
@ -2636,22 +2584,6 @@ bool Cigarette::read_sys_config(SysConf& conf, QString conf_path)
{
conf . TcpPort = atoi ( line . substr ( pos + 1 ) . c_str ( ) ) ;
}
else if ( tmp_key = = " FtpIP " )
{
conf . FtpIP = line . substr ( pos + 1 ) ;
}
else if ( tmp_key = = " FtpPort " )
{
conf . FtpPort = atoi ( line . substr ( pos + 1 ) . c_str ( ) ) ;
}
else if ( tmp_key = = " FtpUserName " )
{
conf . FtpUserName = line . substr ( pos + 1 ) ;
}
else if ( tmp_key = = " FtpUserPwd " )
{
conf . FtpUserPwd = line . substr ( pos + 1 ) ;
}
}
}
@ -2713,10 +2645,6 @@ bool Cigarette::read_modbus_config(ModbusConf& conf)
{
conf . alarm = atoi ( line . substr ( pos + 1 ) . c_str ( ) ) ;
}
else if ( tmp_key = = " HEART " )
{
conf . heart = atoi ( line . substr ( pos + 1 ) . c_str ( ) ) ;
}
}
}
cfg_file . close ( ) ;
@ -2911,7 +2839,7 @@ void Cigarette::init_plc_value()
void Cigarette : : CreatWorkThread ( int classid , int Num , Cigarette * classptr )
{
# ifdef SYNC_CAMERA
sync_work_thread . init ( g_image_sync_queue , g_result_queue , 0 ) ; // 默认使用第一个相机的数据
sync_work_thread . init ( g_image_sync_queue , g_result_queue [0 ] ) ;
connect ( & sync_work_thread , SIGNAL ( notify ( int , int , cv : : Mat ) ) , classptr , SLOT ( OnNotifyHub ( int , int , cv : : Mat ) ) ) ;
connect ( & sync_work_thread , SIGNAL ( display_timecost ( int , int ) ) , classptr , SLOT ( OnDisplayTimeCostHub ( int , int ) ) ) ;
connect ( & sync_work_thread , SIGNAL ( display_check_total ( int , long ) ) , classptr , SLOT ( OnDisplayCheckNumberHub ( int , long ) ) ) ;
@ -3217,11 +3145,11 @@ bool Cigarette::ControlCamOpenOrClose(int Num, bool OpenOrClose)
else if ( SingleCamInfo [ Num ] . CamClass = = HIKClassID )
{
qDebug ( ) < < " open for hik " ;
int nRet = MV_OK ; //海康内部定义MV_OK = 0x0000000;
int nRet = MV_OK ;
void * camhandle ;
nRet = MV_CC_CreateHandle ( & camhandle , HIKCamera : : stDeviceList . pDeviceInfo [ SingleCamInfo [ Num ] . unfiltered_num ] ) ;
HIKCamHandle [ Num ] = camhandle ;
nRet = MV_CC_OpenDevice ( camhandle ) ; //打开相机成功返回MV_OK
nRet = MV_CC_OpenDevice ( camhandle ) ;
if ( nRet )
{
MV_CC_CloseDevice ( camhandle ) ;
@ -3233,7 +3161,6 @@ bool Cigarette::ControlCamOpenOrClose(int Num, bool OpenOrClose)
}
if ( HIKCamera : : stDeviceList . pDeviceInfo [ SingleCamInfo [ Num ] . unfiltered_num ] - > nTLayerType = = MV_GIGE_DEVICE )
{
//配置网口相机
int nPacketSize = MV_CC_GetOptimalPacketSize ( camhandle ) ;
if ( nPacketSize > 0 )
{
@ -3327,7 +3254,7 @@ bool Cigarette::ControlCamOpenOrClose(int Num, bool OpenOrClose)
if ( ! g_debug_mode )
connect ( pHIKCaptureThread [ Num ] , SIGNAL ( updateStatistics ( const QString & , int ) ) , this , SLOT ( updateStatisticsHub ( const QString & , int ) ) ) ;
pThread [ Num ] - > start ( ) ;
if ( pThread [ Num ] - > isRunning ( ) ) //线程开始工作后打印消息
if ( pThread [ Num ] - > isRunning ( ) )
{
qDebug ( ) < < " hik pThread OK " ;
SingleCamInfo [ Num ] . IsOpen = true ;
@ -3341,7 +3268,6 @@ bool Cigarette::ControlCamOpenOrClose(int Num, bool OpenOrClose)
if ( SingleCamInfo [ Num ] . CamClass = = BalluffClassID )
{
qDebug ( ) < < " close for balluff " ;
//取消函数连接
disconnect ( pThread [ Num ] , SIGNAL ( started ( ) ) , pCaptureThread [ Num ] , SLOT ( process ( ) ) ) ;
//disconnect(pCaptureThread[Num], SIGNAL(error(QString)), this, SLOT(errorString(QString)));
disconnect ( pCaptureThread [ Num ] , SIGNAL ( finished ( ) ) , pThread [ Num ] , SLOT ( quit ( ) ) ) ;
@ -3439,7 +3365,7 @@ void Cigarette::EnumerateCameras(SingleCamInfoStruct* TempSingleCamInfoStruct, b
Pylon : : CInstantCameraArray cameras ( filtered ) ;
Pylon : : CTlFactory & tlFactory = Pylon : : CTlFactory : : GetInstance ( ) ;
for ( int i = 0 ; i < min ( filtered , NumberOf Identity Cameras) ; i + + )
for ( int i = 0 ; i < min ( filtered , NumberOf Supported Cameras) ; i + + )
{
SingleCamInfoStruct CamInfo ;
//cameras[i].Attach(tlFactory.CreateDevice(BaslerCamera::devices[i]));
@ -3470,7 +3396,7 @@ void Cigarette::EnumerateCameras(SingleCamInfoStruct* TempSingleCamInfoStruct, b
int hik_cnt = 0 ;
int unfiltered = 0 ;
unfiltered = HIKCamera : : Enumerate ( ) ;
for ( int i = 0 ; i < min ( unfiltered , NumberOf Identity Cameras) ; i + + )
for ( int i = 0 ; i < min ( unfiltered , NumberOf Supported Cameras) ; i + + )
{
MV_CC_DEVICE_INFO * pDeviceInfo = HIKCamera : : stDeviceList . pDeviceInfo [ i ] ;
std : : string manufacture ;
@ -3533,7 +3459,7 @@ void Cigarette::EnumerateCameras(SingleCamInfoStruct* TempSingleCamInfoStruct, b
int balluff_cnt = 0 ;
unfiltered = BalluffCamera : : Enumerate ( ) ;
for ( int i = 0 ; i < min ( unfiltered , NumberOf Identity Cameras) ; i + + )
for ( int i = 0 ; i < min ( unfiltered , NumberOf Supported Cameras) ; i + + )
{
Device * pDev = BalluffCamera : : devMgr [ i ] ;
if ( ! pDev - > isInUse ( ) ) {
@ -3634,7 +3560,7 @@ void Cigarette::EnableDebugMode()
}
g_debug_mode = true ;
}
//非调试模式
void Cigarette : : DisableDebugMode ( )
{
for ( int i = 0 ; i < NumberOfSupportedCameras ; i + + )
@ -3687,12 +3613,13 @@ void Cigarette::DisableDebugMode()
g_debug_mode = false ;
}
# ifdef CLEAR_THREAD
void Cigarette : : CleanThreadStart ( )
{
QThread * handleThread = new QThread ( ) ;
CleanWorkThread * cleanWorkThread = new CleanWorkThread ( ) ;
cleanWorkThread - > moveToThread ( handleThread ) ; //依附到handleThread线程
cleanWorkThread - > moveToThread ( handleThread ) ;
connect ( handleThread , & QThread : : started , cleanWorkThread , & CleanWorkThread : : startWork ) ;
connect ( cleanWorkThread , & CleanWorkThread : : workStart , cleanWorkThread , & CleanWorkThread : : setSel ) ;
@ -3715,81 +3642,57 @@ void Cigarette::CleanThreadStartAuto()
connect ( handleThread , & QThread : : finished , handleThread , & QThread : : deleteLater ) ;
handleThread - > start ( ) ;
}
# endif
void Cigarette : : record_output_statistic ( qint64 quantity , int Kick [ NumberOfSupportedCameras ] , int shift )
{
QString file_name , file_path ;
for ( int i = 0 ; i < NumberOfSupportedCameras ; i + + )
{
if ( SingleCamInfo [ i ] . IsOpen ) //&& quantity > 0
{
if ( SingleCamInfo [ i ] . IsOpen & & quantity > 0 ) {
std : : fstream cfg_file ;
file_name = QString ( STATISTIC_FILE ) . arg ( i ) ;
file_path = g_conf_path . config_path + " / " + file_name ;
char buf [ 256 ] ;
QDateTime date = QDateTime : : currentDateTime ( ) ;
string nowtime = date . toString ( " yyyy-MM-dd_HH:mm:ss " ) . toStdString ( ) . c_str ( ) ;
double ng_rate ;
if ( ng [ i ] > 0 )
{
ng_rate = double ( ng [ i ] ) / production_number [ i ] ;
}
else
{
ng_rate = 0 ;
}
if ( quantity > 0 )
{
sprintf ( buf , " %c 总产量:%010I64d 剔除率:%02.5f%% 合格率:%02.5f%% NG率:%02.5f%% \n " , ( shift = = 0 ) ? ' A ' : ( ( shift = = 1 ) ? ' B ' : ' C ' ) , quantity , ( ( double ) Kick [ i ] / quantity ) * 100 , ( 1.0 - ng_rate ) * 100 , ng_rate * 100 ) ;
}
else
{
sprintf ( buf , " %c 总产量:%010I64d 剔除率:%02.5f%% 合格率:%02.5f%% NG率:%02.5f%% \n " , ( shift = = 0 ) ? ' A ' : ( ( shift = = 1 ) ? ' B ' : ' C ' ) , quantity , 0.00 , 0.00 , 0.00 ) ;
}
std : : ifstream file ( file_path . toStdString ( ) ) ;
std : : ifstream file_ ( file_path . toStdString ( ) ) ;
std : : vector < std : : string > lines ; //用于存储文件的所有行
if ( file_ . good ( ) )
{
file_ . close ( ) ;
}
else
{
std : : ofstream outFile ( file_path . toStdString ( ) ) ;
std : : string fristNews = " ************************************************************************************** \n " + nowtime + " \n " + buf ;
outFile < < fristNews < < endl ;
outFile . close ( ) ;
}
if ( file . is_open ( ) )
{
std : : string line ;
while ( std : : getline ( file , line ) )
{
lines . push_back ( line ) ;
}
file . close ( ) ;
// 在第一行添加数据
std : : string newData = " ************************************************************************************** \n " + nowtime + " \n " + buf ;
if ( ! lines . empty ( ) )
{
lines . insert ( lines . begin ( ) , newData ) ; // 在vector的开始位置插入新数据
}
// 将修改后的数据写回文件
std : : ofstream outFile ( file_path . toStdString ( ) ) ;
if ( outFile . is_open ( ) )
{
for ( const auto & l : lines )
{
outFile < < l < < std : : endl ;
}
outFile . close ( ) ;
memset ( buf , 0 , 256 ) ;
sprintf ( buf , " %s " , file_path . toLocal8Bit ( ) . constData ( ) ) ;
cfg_file . open ( buf , std : : ios : : app ) ;
if ( cfg_file . good ( ) )
{
if ( last_shift = = 2 | | last_shift = = 256 ) {
memset ( buf , 0 , 256 ) ;
sprintf ( buf , " \n \n ************************************************************************************** \n " ) ;
cfg_file . write ( buf , strlen ( buf ) ) ;
//QDate date = QDate::currentDate();
QDateTime date = QDateTime : : currentDateTime ( ) ;
memset ( buf , 0 , 256 ) ;
sprintf ( buf , " %s: \n " , date . toString ( " yyyy-MM-dd_HH-mm-ss " ) . toStdString ( ) . c_str ( ) ) ;
cfg_file . write ( buf , strlen ( buf ) ) ;
}
memset ( buf , 0 , 256 ) ;
double ng_rate ;
if ( ng [ i ] > 0 )
ng_rate = double ( ng [ i ] ) / production_number [ i ] ;
else
ng_rate = 0 ;
sprintf ( buf , " %c 总产量:%010I64d 剔除率:%02.5f%% 合格率:%02.5f%% NG率:%02.5f%% \n " , ( shift = = 0 ) ? ' A ' : ( ( shift = = 1 ) ? ' B ' : ' C ' ) , quantity , ( ( double ) Kick [ i ] / quantity ) * 100 , ( 1.0 - ng_rate ) * 100 , ng_rate * 100 ) ;
cfg_file . write ( buf , strlen ( buf ) ) ;
memset ( buf , 0 , 256 ) ;
}
cfg_file . close ( ) ;
}
}
last_shift = shift ;
}
void Cigarette : : MqttMsgSend ( )
{
_MqttSendInfo MqttSendInfo ;
MQTT_Info_queue - > put ( MqttSendInfo ) ;
}
# ifdef __UDPSend
void Cigarette : : recMsgFromUdp ( QString data )
{
@ -3891,7 +3794,9 @@ void Cigarette::recMsgFromUdp(QString data)
else if ( data = = " CLEARNIMAGE " )
{
emit sengMsgToClog ( " Clean images. " ) ;
# ifdef CLEAR_THREAD
CleanThreadStart ( ) ;
# endif
}
else if ( data = = " DEBUGEN " )
{
Jinhuan