from PyQt5.QtCore import QThread, pyqtSignal, QMutex, QWaitCondition

qmut_1 = QMutex() # 创建线程锁
qmut_2 = QMutex()
import time



class MyThread(QThread):
    conChange = pyqtSignal(int)#线程运行状态,0为取消，1为暂停，2为正常运行
    valueReturn = pyqtSignal(int)#返回进度条当前的值
    def __init__(self):
        super().__init__()

        self.isPause = False
        self.isCancel = False
        self.cond = QWaitCondition()
        self.mutex = QMutex()
        self.progress_value = 0 #进度条返回值，初始化为0


    def run(self):
        self.mutex.lock()  # 加锁

        # if self.isPause:
        #     self.cond.wait(self.mutex)
        #     self.valueChange.emit(1)
        # if self.isCancel:
        #     self.valueChange.emit(0)

        ####需要运行的线程



        ####需要运行的线程

        qmut_1.lock()  # 加锁
        values = [1, 2, 3, 4, 5]
        for i in values:
            print(i)
            time.sleep(0.5)  # 休眠
        qmut_1.unlock()  # 解锁
        # 操作完成后发射gold_finish信号，将金矿数量发射出去。

        # qmut_2.lock()  # 加锁
        values = ["a", "b", "c", "d", "e"]
        for i in values:
            print(i)
            time.sleep(0.5)
        # qmut_2.unlock()  # 解锁
        self._signal.emit()


        self.mutex.unlock()  # 解锁



    def pause(self):
        self.main_textBrowser.append("线程暂停")
        self.isPause = True

    def cancel(self):
        self.main_textBrowser.append("线程取消")
        self.isCancel = True

    def resume(self):
        self.main_textBrowser.append("线程恢复")
        self.isPause = False
        self.cond.wakeAll()


    def __del__(self):
        self.wait()


def output_info_thread(myMainWindow):
    t1=time.time()
    Opened = False
    while(True):
        if myMainWindow.img_opened==True:
            imgs_path = myMainWindow.img_name[0].replace("/","//")
            break
        elif myMainWindow.imgs_opened==True:
            imgs_path=[]
            for path in myMainWindow.imgs_name[0]:
                imgs_path.append(path.replace("/","//"))
            break
    Opened = True
    myMainWindow._signal.emit("当前线程：%s" %threading.current_thread().name)
    timeArray = time.localtime(t1)
    now=time.strftime("%Y_%m_%d", timeArray)
    try:
        if(Opened):
            s1 = "正在进行裂纹识别评估"
            myMainWindow._signal.emit(s1)
            kinds=prediction(imgs_path)
            s2='裂纹图片   裂纹类型   裂纹长度    裂纹面积    裂纹最大宽度    裂纹最小宽度   裂纹平均宽度'
            myMainWindow._signal.emit(s2)
            data= np.empty(shape=[0, 8])
            for i in range(len(kinds)):
                if len(kinds)==1:
                    name=imgs_path[::-1].split('//', 1)[0][::-1]
                else:
                    name=imgs_path[i][::-1].split('//', 1)[0][::-1]
                if kinds[i]=='无裂纹':
                    crack_info=[imgs_path[i],kinds[i],'','','','']
                elif len(kinds)==1:
                    crack_info=img_processing(imgs_path,kinds[i])
                else:
                    crack_info=img_processing(imgs_path[i],kinds[i])
                s=name+'   '+crack_info[0]+' '*5+crack_info[1]+' '*7+crack_info[2]+\
                ' '*11+crack_info[3]+' '*12+crack_info[4]+' '*12+crack_info[5]
                myMainWindow._signal.emit(s)
                new_crack_info=[name,crack_info[0],crack_info[1],crack_info[2],
                                crack_info[3],crack_info[4],crack_info[5],now]
                data=np.append(data, [new_crack_info], axis = 0)
            t2=time.time()
            database='crack_info'
            try:
                save_mysql(database,data)
                myMainWindow._signal.emit('数据已存入'+database+'数据库中')
            except:
                myMainWindow._signal.emit('数据存储失败，请检查数据库是否打开！')
            time_comsume=round(t2-t1,2)
            myMainWindow._signal.emit('共耗时： '+str(time_comsume)+' s')
            myMainWindow._signal.emit("****************处理完毕****************")
    except BaseException as e1:
        print(e1)
    except EnvironmentError as e2:
        print(e2)
    except (OSError,WindowsError,
            MemoryError,NameError,
            UnboundLocalError,ReferenceError,
            RuntimeError,NotImplementedError,
            UnicodeDecodeError,UnicodeEncodeError,
            UnicodeError,UnicodeTranslateError,
            RuntimeWarning,UserWarning) as e3:
        print(e3)