237 lines
8.8 KiB
Python
237 lines
8.8 KiB
Python
|
# import socket
|
|||
|
|
# import threading
|
|||
|
|
# import aacecontrol
|
|||
|
|
# import ctypes,win32con,win32gui,sys,json
|
|||
|
|
# import logging
|
|||
|
|
# # import file_script
|
|||
|
|
|
|||
|
|
|
|||
|
|
# IpAddress = '127.0.0.1'
|
|||
|
|
# FilePath = 'D:\\MegaSoft\\Scripts'
|
|||
|
|
# Port = 2016
|
|||
|
|
# # device = md.MultiWinDevice("multiWin")
|
|||
|
|
# device = aacecontrol.AppService()
|
|||
|
|
# # 定义互斥量名称
|
|||
|
|
# mutex_name = "aaca_mutex"
|
|||
|
|
|
|||
|
|
|
|||
|
|
# def handle_client(client_socket,addr):
|
|||
|
|
# device.loginformation(f'监听{addr}的数据')
|
|||
|
|
# while True:
|
|||
|
|
# try:
|
|||
|
|
# # 接收客户端发送的数据
|
|||
|
|
# data = client_socket.recv(2048)
|
|||
|
|
# if not data:
|
|||
|
|
# device.loginformation(f'{addr}-接收到空数据')
|
|||
|
|
# break
|
|||
|
|
# # # 处理接收到的数据
|
|||
|
|
# # device.loginformation(f"Received from {client_socket.getpeername()}: {data.decode('utf-8')}")
|
|||
|
|
# datadecode = data.decode('utf-8')
|
|||
|
|
# command = datadecode.partition(':')[0] # 只分割一次
|
|||
|
|
# paras = datadecode.partition(':')[2]
|
|||
|
|
# result = -1
|
|||
|
|
|
|||
|
|
# if 'makeGraph' in command:
|
|||
|
|
# command = 'makeGraph'
|
|||
|
|
# device.loginformation(f'---收到制图指令 {datadecode}---')
|
|||
|
|
# result = device.click_create_table(paras)
|
|||
|
|
# elif 'operate' in command:
|
|||
|
|
# command = 'operate'
|
|||
|
|
# device.loginformation(f'---收到创建任务指令 {datadecode}---')
|
|||
|
|
# result = device.start(paras)
|
|||
|
|
# elif 'createTask' in command:
|
|||
|
|
# command = 'createTask'
|
|||
|
|
# device.loginformation(f'---收到制图创建任务命令 {datadecode}---')
|
|||
|
|
# result = device.create(paras)
|
|||
|
|
# elif 'start' in command:
|
|||
|
|
# command = 'start'
|
|||
|
|
# device.loginformation(f'---收到启动命令 {datadecode}---')
|
|||
|
|
# result = device.run(paras)
|
|||
|
|
# elif 'status' in command:
|
|||
|
|
# device.loginformation(f'---收到查询状态命令 {datadecode}---')
|
|||
|
|
# result = 2
|
|||
|
|
# if device.is_finished():
|
|||
|
|
# result = 1
|
|||
|
|
# else:
|
|||
|
|
# command = '未知命令'
|
|||
|
|
# device.loginformation('---未知命令---')
|
|||
|
|
|
|||
|
|
# reponse_txt = command + ':' + str(result) + '\n'
|
|||
|
|
# client_socket.send(reponse_txt.encode('utf-8'))
|
|||
|
|
# device.loginformation(f'---返回-{reponse_txt}---')
|
|||
|
|
# except:
|
|||
|
|
# device.loginformation(f'{addr}-接收数据异常')
|
|||
|
|
# client_socket.close()
|
|||
|
|
# return
|
|||
|
|
# # 关闭连接
|
|||
|
|
# device.loginformation(f'{addr}-连接断开')
|
|||
|
|
# client_socket.close()
|
|||
|
|
|
|||
|
|
# def start_server():
|
|||
|
|
# server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|||
|
|
# server.bind((IpAddress, Port))
|
|||
|
|
# server.listen(20)
|
|||
|
|
# device.loginformation(f"Server listening on port {IpAddress}:{Port}...")
|
|||
|
|
# try:
|
|||
|
|
# while True:
|
|||
|
|
# client_socket, addr = server.accept()
|
|||
|
|
# device.loginformation(f"Accepted connection from {addr}")
|
|||
|
|
# # 启动一个新线程来处理客户端请求
|
|||
|
|
# client_handler = threading.Thread(target=handle_client, args=(client_socket,addr))
|
|||
|
|
# client_handler.start()
|
|||
|
|
# except:
|
|||
|
|
# print('服务结束了。。。')
|
|||
|
|
# finally:
|
|||
|
|
# ctypes.windll.kernel32.CloseHandle(mutex)
|
|||
|
|
|
|||
|
|
# def message_box(title, message, type=win32con.MB_OK):
|
|||
|
|
# """
|
|||
|
|
# 弹出一个消息框
|
|||
|
|
# :param title: 消息框的标题
|
|||
|
|
# :param message: 消息框显示的消息
|
|||
|
|
# :param type: 消息框的类型，例如MB_OK, MB_ICONERROR等
|
|||
|
|
# :return: 用户点击的消息框按钮的标识符
|
|||
|
|
# """
|
|||
|
|
# return win32gui.MessageBox(None, message, title, type)
|
|||
|
|
|
|||
|
|
# if __name__ == "__main__":
|
|||
|
|
# # 定义互斥锁名称，可以是任意字符串
|
|||
|
|
# mutex = ctypes.windll.kernel32.CreateMutexW(None, False, mutex_name)
|
|||
|
|
# # 检查互斥量是否已经存在
|
|||
|
|
# if ctypes.windll.kernel32.GetLastError() == 183: # ERROR_ALREADY_EXISTS
|
|||
|
|
# message_box("提醒", "脚本正在运行中，请点击确定关闭。", win32con.MB_ICONWARNING)
|
|||
|
|
# sys.exit(0)
|
|||
|
|
|
|||
|
|
# ctypes.windll.kernel32.SetThreadExecutionState(0x80000002) # 确保桌面不息屏
|
|||
|
|
|
|||
|
|
# server_thread = threading.Thread(target=start_server)
|
|||
|
|
# server_thread.start()
|
|||
|
|
|
|||
|
|
# # w = file_script.Watcher(FilePath)
|
|||
|
|
# # file_thread = threading.Thread(target=w.run)
|
|||
|
|
# # file_thread.start()
|
|||
|
|
|
|||
|
|
|
|||
|
|
import ctypes
|
|||
|
|
import socket
|
|||
|
|
import sys
|
|||
|
|
import threading
|
|||
|
|
import win32con
|
|||
|
|
import win32gui
|
|||
|
|
from file_script import Watcher
|
|||
|
|
import aacecontrol
|
|||
|
|
|
|||
|
|
|
|||
|
|
IpAddress = '127.0.0.1'
|
|||
|
|
FilePath = 'D:\\MegaSoft\\Scripts'
|
|||
|
|
Port = 2016
|
|||
|
|
device = aacecontrol.AppService()
|
|||
|
|
# 定义互斥量名称
|
|||
|
|
mutex_name = "aaca_mutex"
|
|||
|
|
|
|||
|
|
def handle_client(client, addr):
|
|||
|
|
while True:
|
|||
|
|
try:
|
|||
|
|
data = client.recv(2048)
|
|||
|
|
if not data:
|
|||
|
|
device.loginformation("接收数据异常")
|
|||
|
|
break
|
|||
|
|
datadecode = data.decode('utf-8')
|
|||
|
|
device.loginformation(f"接收到---{client.getpeername()}---数据---{datadecode}")
|
|||
|
|
result = -1
|
|||
|
|
command = datadecode.partition(':')[0] # 只分割一次
|
|||
|
|
paras = datadecode.partition(':')[2] # 返回包含分隔符
|
|||
|
|
|
|||
|
|
# if 'makeGraph' in command:
|
|||
|
|
# command = 'makeGraph'
|
|||
|
|
# device.loginformation(f'---收到制图指令 {datadecode}---')
|
|||
|
|
# result = device.click_create_table(paras)
|
|||
|
|
# elif 'operate' in command:
|
|||
|
|
# command = 'operate'
|
|||
|
|
# device.loginformation(f'---收到创建任务指令 {datadecode}---')
|
|||
|
|
# result = device.start(paras)
|
|||
|
|
if 'createTask' in command:
|
|||
|
|
command = 'createTask'
|
|||
|
|
device.loginformation(f'收到创建任务并执行命令 {datadecode}')
|
|||
|
|
result = device.createThenStart(paras)
|
|||
|
|
# elif 'start' in command:
|
|||
|
|
# command = 'start'
|
|||
|
|
# device.loginformation(f'---收到启动命令 {datadecode}---')
|
|||
|
|
# result = device.run(paras)
|
|||
|
|
elif 'status' in command:
|
|||
|
|
device.loginformation(f'收到查询状态命令 {datadecode}')
|
|||
|
|
result = 2
|
|||
|
|
if device.is_finished():
|
|||
|
|
result = 0
|
|||
|
|
else:
|
|||
|
|
command = '未知命令'
|
|||
|
|
device.loginformation('未知命令')
|
|||
|
|
|
|||
|
|
response_txt = command + ':' + str(result) + '\n'
|
|||
|
|
device.loginformation(f'返回:{command}:{str(result)}')
|
|||
|
|
client.send(response_txt.encode('utf-8'))
|
|||
|
|
except:
|
|||
|
|
device.loginformation(f'{addr}通讯异常')
|
|||
|
|
break
|
|||
|
|
# 关闭连接
|
|||
|
|
device.loginformation(f'关闭{addr}连接')
|
|||
|
|
client.close()
|
|||
|
|
|
|||
|
|
def message_box(title, message, type=win32con.MB_OK):
|
|||
|
|
"""
|
|||
|
|
弹出一个消息框
|
|||
|
|
:param title: 消息框的标题
|
|||
|
|
:param message: 消息框显示的消息
|
|||
|
|
:param type: 消息框的类型，例如MB_OK, MB_ICONERROR等
|
|||
|
|
:return: 用户点击的消息框按钮的标识符
|
|||
|
|
"""
|
|||
|
|
return win32gui.MessageBox(None, message, title, type)
|
|||
|
|
|
|||
|
|
|
|||
|
|
class TCPThread(threading.Thread):
|
|||
|
|
def run(self):
|
|||
|
|
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|||
|
|
server.bind((IpAddress, Port))
|
|||
|
|
server.listen(20)
|
|||
|
|
device.loginformation(f"服务端---{IpAddress}---{Port}---启动")
|
|||
|
|
connected_clients = 0
|
|||
|
|
try:
|
|||
|
|
while True:
|
|||
|
|
client, addr = server.accept()
|
|||
|
|
connected_clients = connected_clients + 1
|
|||
|
|
device.loginformation(f"客户端---{addr}---已连接,已连接客户端数量：{connected_clients}")
|
|||
|
|
client_handle = threading.Thread(target=handle_client, args=(client,addr))
|
|||
|
|
client_handle.start()
|
|||
|
|
except Exception as e:
|
|||
|
|
device.loginformation(f"{str(e)}服务端正在关闭...")
|
|||
|
|
server.close()
|
|||
|
|
device.loginformation("服务端已关闭")
|
|||
|
|
finally:
|
|||
|
|
# 释放互斥量
|
|||
|
|
ctypes.windll.kernel32.CloseHandle(mutex)
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
if __name__ == "__main__":
|
|||
|
|
# 定义互斥锁名称，可以是任意字符串
|
|||
|
|
mutex = ctypes.windll.kernel32.CreateMutexW(None, False, mutex_name)
|
|||
|
|
# 检查互斥量是否已经存在
|
|||
|
|
if ctypes.windll.kernel32.GetLastError() == 183: # ERROR_ALREADY_EXISTS
|
|||
|
|
message_box("提醒", "脚本正在运行中，请点击确定关闭。", win32con.MB_ICONWARNING)
|
|||
|
|
sys.exit(0)
|
|||
|
|
|
|||
|
|
ctypes.windll.kernel32.SetThreadExecutionState(0x80000002)
|
|||
|
|
|
|||
|
|
tcp_thread = TCPThread()
|
|||
|
|
tcp_thread.start()
|
|||
|
|
|
|||
|
|
# 创建线程
|
|||
|
|
watcher = Watcher(FilePath)
|
|||
|
|
watcher_thread = threading.Thread(target=watcher.run)
|
|||
|
|
watcher_thread.start()
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|