WIndows_Listener.py

import ctypes
from ctypes import wintypes
import threading
from MQTT import Send_MQTT_Discovery, Update_State_data

# 定义常量
EVENT_SYSTEM_FOREGROUND = 0x0003
WINEVENT_OUTOFCONTEXT = 0x0000
WINEVENT_SKIPOWNPROCESS = 0x0002
WINEVENT_FLAGS = WINEVENT_OUTOFCONTEXT | WINEVENT_SKIPOWNPROCESS

# 加载必要的 DLL
user32 = ctypes.WinDLL('user32', use_last_error=True)
kernel32 = ctypes.WinDLL('kernel32', use_last_error=True)

# 定义回调函数类型
WinEventProcType = ctypes.WINFUNCTYPE(
    None,
    ctypes.c_void_p,  # hWinEventHook
    ctypes.c_uint,    # event
    ctypes.c_void_p,  # hwnd
    ctypes.c_long,    # idObject
    ctypes.c_long,    # idChild
    ctypes.c_uint,    # dwEventThread
    ctypes.c_uint     # dwmsEventTime
)

def discovery():
    info = Send_MQTT_Discovery(None,None,"前台应用","ForegroundWindow","sensor")
    # print(info)


# 定义回调函数
def win_event_proc(hWinEventHook, event, hwnd, idObject, idChild, dwEventThread, dwmsEventTime):
    # 使用 GetForegroundWindow 获取当前前台窗口
    current_hwnd = user32.GetForegroundWindow()
    if current_hwnd:
        # 获取窗口标题
        length = user32.GetWindowTextLengthW(current_hwnd)
        buffer = ctypes.create_unicode_buffer(length + 1)
        user32.GetWindowTextW(current_hwnd, buffer, length + 1)
        window_title = buffer.value

        # 获取窗口类名
        class_buffer = ctypes.create_unicode_buffer(256)
        user32.GetClassNameW(current_hwnd, class_buffer, 256)
        class_name = class_buffer.value

        print(f"前台窗口变化到 HWND={current_hwnd}, 标题='{window_title}', 类名='{class_name}'")
        title = str(window_title)
        if(title != ''):
            Update_State_data(title, "ForegroundWindow", "sensor")

# 将 Python 函数转换为 C 回调函数
WinEventProc = WinEventProcType(win_event_proc)

# 设置事件钩子
def window_listener(stop_event):
    discovery()
    global hook
    hook = user32.SetWinEventHook(
        EVENT_SYSTEM_FOREGROUND,  # eventMin
        EVENT_SYSTEM_FOREGROUND,  # eventMax
        0,                        # hmodWinEventProc, HMODULE.NULL
        WinEventProc,             # pfnWinEventProc
        0,                        # idProcess, 0 表示所有进程
        0,                        # idThread, 0 表示所有线程
        WINEVENT_FLAGS            # dwFlags
    )

    if not hook:
        raise ctypes.WinError(ctypes.get_last_error())

    print("正在监听前台窗口变化")
    # 消息循环
    msg = wintypes.MSG()

    while not stop_event.is_set():  # 监听直到 stop_event 被设置
        bRet = user32.GetMessageW(ctypes.byref(msg), 0, 0, 0)
        if bRet == 0:
            pass
        elif bRet == -1:
            raise ctypes.WinError(ctypes.get_last_error())
        else:
            user32.TranslateMessage(ctypes.byref(msg))
            user32.DispatchMessageW(ctypes.byref(msg))

def start_window_listener():
    stop_event = threading.Event()  # 创建一个事件来控制停止
    listener_thread = threading.Thread(target=window_listener, args=(stop_event,))
    listener_thread.daemon = True  # 设置为守护线程，程序退出时会自动结束
    listener_thread.start()
    return stop_event

if __name__ == "__main__":
    stop_event = start_window_listener()

    # 运行一段时间后，你可以通过 stop_event 来停止监听
    # 比如，在其他地方调用 stop_event.set() 来停止监听
    # 假设我们等待 10 秒后停止监听
    import time
    time.sleep(10)
    stop_event.set()
    print("停止监听前台窗口变化")