import modbus_tk
import modbus_tk.defines as cst
from modbus_tk import modbus_tcp, hooks
import logging
import struct
import threading
import time
# from protocol.ModBus.ByteOrder import *
import threading

class SearchSlaveThread(threading.Thread):
    def __init__(self, callback, master):
        super().__init__()
        self.stopEvent = threading.Event()
        self.callback = callback
        self.master = master

    def run(self):
        for address in range(1, 126):
            if not self.stopEvent.is_set():
                self.callback(address, self.master.judgeSlave(address))

            
    def stop(self):
        self.stopEvent.set()




class DPV1Master():
    resetData = struct.unpack('>hhhh', b'\x00\x00\x00\x00\x00\x00\x00\x00')
    def __init__(self, host, port):
        try:
            self.master = modbus_tcp.TcpMaster(host = host, port = port)
            self.master.set_timeout(5.0)
        except Exception as e:
            self.master = None
        # hooks.install_hook("modbus_tcp.TcpMaster.after_recv", afterRecv)
        # hooks.install_hook("modbus_tcp.TcpMaster.after_send", afterSend)
    

    def writeMultipleRegister(self, slaveId, address, outputValue):
        if not self.master:
            return 'error'
        try:
            self.master.execute(slaveId, cst.WRITE_MULTIPLE_REGISTERS, starting_address = address, output_value=outputValue)
        except Exception as e:
            return 'error'


    def readHoldingRegisters(self, slaveId, startAddress, varNums):
        if not self.master:
            return 'error'
        try:
            value = self.master.execute(slaveId, cst.READ_HOLDING_REGISTERS, startAddress, varNums)
            return value
        except:
            return '读取错误'
    
    def areAllZeros(self, tup):
        return all(x == 0 for x in tup)

    
    def searchSlave(self, callback = None):
        self.searchSlaveThread = SearchSlaveThread(callback = callback, master = self)
        self.searchSlaveThread.start()
    
    def closeThread(self):
        self.searchSlaveThread.stop()

    def readParm(self, address, slot, index, length, callback = None):
        hexAddress = address.to_bytes(1, byteorder='little')
        slotByte = slot.to_bytes(1, byteorder='little')
        indexByte = index.to_bytes(1, byteorder='little')
        readByteStream = b'\x01' + hexAddress + slotByte + indexByte + b'\xF0\x00'
        searchDate = struct.unpack('>hhh', readByteStream)
        self.writeMultipleRegister(1, 750, searchDate)
        time.sleep(0.3)
        value = self.readHoldingRegisters(1, 750, -(-length // 2)) #  -(-length // 2)向上取整
        value = struct.pack('>{}b'.format(-(-length // 2)), value)[:length]
        self.writeMultipleRegister(1, 750, self.resetData)
        time.sleep(0.1)
        if callable(callback):
            callback(value)
            return
        return value

    def judgeSlave(self, address):
        hexAddress = address.to_bytes(1, byteorder='little')
        searchByteStream = b'\x01' + hexAddress + b'\x01\x00\xF0\x00'
        searchDate = struct.unpack('>hhh', searchByteStream)
        self.writeMultipleRegister(1, 750, searchDate)
        time.sleep(0.3)
        dir = self.readHoldingRegisters(1, 750, 6)
        self.writeMultipleRegister(1, 750, self.resetData)
        time.sleep(0.1)
        if not self.areAllZeros(dir) and dir != 'error':
            return True
        else:
            return False


    # def readInputRegisters(self, slaveId, startAddress, varNums, order = 'ABCD'):
    #     try:
    #         if order == 'int':
    #             valueByte = self.master.execute(slaveId, cst.READ_INPUT_REGISTERS, startAddress, varNums)[0]
    #         else:
    #             value = self.master.execute(slaveId, cst.READ_INPUT_REGISTERS, startAddress, 2)
    #             if order == 'ABCD': # 大端模式
    #                 valueByte = ABCDToFloat(value)
    #             elif order == 'DCBA': # 小端模式
    #                 valueByte = DCBAToFloat(value)
    #             elif order == 'BADC':
    #                 valueByte = BADCToFloat(value)
    #             elif order == 'CDAB':
    #                 valueByte = CDABToFloat(value)
    #         return valueByte
    #     except Exception as e:
    #         return 'error'

    # def readCoils(self, slaveId, startAddress, varNums, order = 'ABCD'):
    #     try:
    #         value = self.master.execute(slaveId, cst.READ_COILS, startAddress, varNums)
    #         return value[0]
    #     except Exception as e:
    #         return 'error'
    # def readInputCoils(self, slaveId, startAddress, varNums):
    #     print(slaveId, startAddress, varNums)
    #     try:
    #         value = self.master.execute(slaveId, cst.READ_DISCRETE_INPUTS, startAddress, varNums)
    #         return value[0]
    #     except:
    #         return 'error'
    #




        # print(cst.READ_HOLDING_REGISTERS, cst.READ_COILS, cst.WRITE_SINGLE_REGISTER, cst.WRITE_SINGLE_COIL)
        # self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 0, output_value=[1, 2, 3, 4, 5])
        # self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, starting_address=5, output_value=[3.0], data_format='>f')
        # self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, starting_address=6, output_value=[4.0], data_format='>f')
        # self.master.execute(2, cst.WRITE_SINGLE_COIL, 2, output_value=1)
        # self.master.execute(2, cst.WRITE_MULTIPLE_COILS, 0, output_value=[1, 1, 0, 1, 1, 0, 1, 1])
        # logger.info(master.execute(1, cst.READ_HOLDING_REGISTERS, 0, 2, data_format='f'))

        # Read and write floats

        # send some queries
        # logger.info(master.execute(1, cst.READ_HOLDING_REGISTERS, 100, 12))





if __name__ == "__main__":
    tcpMaster = DPV1Master('192.168.3.10', 502)
    tcpMaster.searchMaster()
    # tcpMaster.readHoldingRegisters(1, 6, 2)
    # tcpMaster.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, starting_address=0, output_value=[1,2,3,4,5])
    #
    # master = modbus_tcp.TcpMaster(host="localhost", port=502)
    # values = [6]
    # master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, starting_address=0, output_value=values)