|
|
@@ -11,8 +11,43 @@ from datetime import datetime
|
|
|
import win32gui
|
|
|
import win32con
|
|
|
import win32api
|
|
|
-import tkinter as tk
|
|
|
from PIL import Image, ImageTk
|
|
|
+from tkcalendar import DateEntry # 需要安装: pip install tkcalendar
|
|
|
+
|
|
|
+def sendTask(payload):
|
|
|
+ # 生成8-12分钟的随机延迟（转换为毫秒）
|
|
|
+ # delay_minutes = random.randint(1, 2)
|
|
|
+ delay_minutes = 0
|
|
|
+ delay_seconds = delay_minutes * 60
|
|
|
+ delay_ms = delay_seconds * 1000
|
|
|
+
|
|
|
+ # 计算生效时间（当前时间 + 延迟毫秒数）
|
|
|
+ effective_time = int((time.time() * 1000) + delay_ms)
|
|
|
+
|
|
|
+ # 构建包含延迟信息的任务内容
|
|
|
+ task_payload = {
|
|
|
+ "plate": payload,
|
|
|
+ "effectiveTime": effective_time # 添加生效时间字段
|
|
|
+ }
|
|
|
+
|
|
|
+ # 使用去重发布接口（避免重复任务）
|
|
|
+ url = f"https://task.port.run/publish/carNext/600"
|
|
|
+
|
|
|
+ print(f"发送车牌号: {payload} 到服务器...")
|
|
|
+ print(f"延迟 {delay_minutes} 分钟后执行（生效时间: {time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(effective_time/1000))}）")
|
|
|
+
|
|
|
+ headers = {
|
|
|
+ "Content-Type": "application/json",
|
|
|
+ "Accept": "*/*",
|
|
|
+ "Accept-Encoding": "gzip, deflate, br",
|
|
|
+ "User-Agent": "PostmanRuntime-ApipostRuntime/1.1.0",
|
|
|
+ "Connection": "keep-alive"
|
|
|
+ }
|
|
|
+
|
|
|
+ response = requests.request("POST", url, json=task_payload, headers=headers)
|
|
|
+
|
|
|
+ print(response.text)
|
|
|
+ return response
|
|
|
|
|
|
def drag_in_emulator(manager_path, emu_index, x, y1, y2, duration=400):
|
|
|
"""
|
|
|
@@ -43,6 +78,7 @@ def drag_in_emulator(manager_path, emu_index, x, y1, y2, duration=400):
|
|
|
result = subprocess.run(cmd, shell=True, capture_output=True, text=True)
|
|
|
|
|
|
return result.returncode == 0
|
|
|
+
|
|
|
def input_text_to_emulator(manager_path, emu_index, text):
|
|
|
"""向模拟器输入文本"""
|
|
|
# 获取adb端口
|
|
|
@@ -129,7 +165,26 @@ def get_emulator_pixel_color(manager_path, emu_index, x, y):
|
|
|
import os
|
|
|
if os.path.exists(temp_file):
|
|
|
os.remove(temp_file)
|
|
|
-
|
|
|
+def split_and_random_select(input_string):
|
|
|
+ """
|
|
|
+ 将字符串按@分割，然后随机返回其中一个元素
|
|
|
+
|
|
|
+ 参数:
|
|
|
+ input_string: 类似 "32@33@41" 的字符串
|
|
|
+
|
|
|
+ 返回:
|
|
|
+ 随机选中的元素
|
|
|
+ """
|
|
|
+ # 按@分割字符串
|
|
|
+ elements = input_string.split('@')
|
|
|
+
|
|
|
+ # 从分割后的数组中随机选择一个元素
|
|
|
+ if elements: # 确保数组不为空
|
|
|
+ random_element = random.choice(elements)
|
|
|
+ return random_element
|
|
|
+ else:
|
|
|
+ return None
|
|
|
+
|
|
|
def show_image_at_position(image_path, x, y, width=250, height=250):
|
|
|
"""
|
|
|
在指定位置创建窗口显示图片并激活
|
|
|
@@ -162,6 +217,7 @@ def show_image_at_position(image_path, x, y, width=250, height=250):
|
|
|
return window
|
|
|
|
|
|
def click_screen(x, y):
|
|
|
+ print(f"点击屏幕坐标: ({x}, {y})")
|
|
|
"""
|
|
|
在屏幕坐标(x, y)处点击鼠标左键
|
|
|
"""
|
|
|
@@ -278,13 +334,22 @@ class SimpleMuMuManager:
|
|
|
def __init__(self, root):
|
|
|
self.root = root
|
|
|
self.root.title("MuMu模拟器管理工具")
|
|
|
- self.root.geometry("650x450")
|
|
|
+ self.root.geometry("700x600") # 增加高度以容纳新控件
|
|
|
|
|
|
# 配置文件
|
|
|
self.config_file = "mumu_config.json"
|
|
|
self.mumu_manager_path = None
|
|
|
self.emulators = []
|
|
|
|
|
|
+ # 任务调度控制
|
|
|
+ self.is_running = False
|
|
|
+ self.task_thread = None
|
|
|
+ self.stop_event = threading.Event()
|
|
|
+
|
|
|
+ # 最后发货时间设置
|
|
|
+ self.last_delivery_time = None # 存储最后发货时间
|
|
|
+ self.delivery_time_enabled = False # 是否启用最后发货时间限制
|
|
|
+
|
|
|
# 创建界面
|
|
|
self.create_widgets()
|
|
|
|
|
|
@@ -335,28 +400,294 @@ class SimpleMuMuManager:
|
|
|
self.receive_combo = ttk.Combobox(receive_frame, textvariable=self.receive_var, width=35, state="readonly")
|
|
|
self.receive_combo.grid(row=0, column=0)
|
|
|
|
|
|
+ # 最后发货时间设置区域
|
|
|
+ time_frame = ttk.LabelFrame(main_frame, text="最后发货时间设置", padding="10")
|
|
|
+ time_frame.grid(row=2, column=0, sticky=(tk.W, tk.E), pady=10)
|
|
|
+
|
|
|
+ # 启用/禁用复选框
|
|
|
+ self.time_enabled_var = tk.BooleanVar(value=False)
|
|
|
+ enable_check = ttk.Checkbutton(
|
|
|
+ time_frame,
|
|
|
+ text="启用最后发货时间限制",
|
|
|
+ variable=self.time_enabled_var,
|
|
|
+ command=self.on_time_enable_changed
|
|
|
+ )
|
|
|
+ enable_check.grid(row=0, column=0, columnspan=4, sticky=tk.W, pady=5)
|
|
|
+
|
|
|
+ # 日期选择
|
|
|
+ ttk.Label(time_frame, text="截止日期:").grid(row=1, column=0, padx=5, pady=5, sticky=tk.W)
|
|
|
+ self.date_picker = DateEntry(
|
|
|
+ time_frame,
|
|
|
+ width=12,
|
|
|
+ background='darkblue',
|
|
|
+ foreground='white',
|
|
|
+ borderwidth=2,
|
|
|
+ date_pattern='yyyy-mm-dd'
|
|
|
+ )
|
|
|
+ self.date_picker.grid(row=1, column=1, padx=5, pady=5)
|
|
|
+
|
|
|
+ # 时间选择（时:分）
|
|
|
+ ttk.Label(time_frame, text="截止时间:").grid(row=1, column=2, padx=5, pady=5, sticky=tk.W)
|
|
|
+
|
|
|
+ time_select_frame = ttk.Frame(time_frame)
|
|
|
+ time_select_frame.grid(row=1, column=3, padx=5, pady=5, sticky=tk.W)
|
|
|
+
|
|
|
+ self.hour_var = tk.StringVar(value="23")
|
|
|
+ self.minute_var = tk.StringVar(value="59")
|
|
|
+
|
|
|
+ hour_combo = ttk.Combobox(time_select_frame, textvariable=self.hour_var, width=5,
|
|
|
+ values=[f"{i:02d}" for i in range(24)], state="readonly")
|
|
|
+ hour_combo.grid(row=0, column=0)
|
|
|
+ ttk.Label(time_select_frame, text=":").grid(row=0, column=1)
|
|
|
+ minute_combo = ttk.Combobox(time_select_frame, textvariable=self.minute_var, width=5,
|
|
|
+ values=[f"{i:02d}" for i in range(60)], state="readonly")
|
|
|
+ minute_combo.grid(row=0, column=2)
|
|
|
+
|
|
|
+ # 显示当前设置的状态标签
|
|
|
+ self.time_status_label = ttk.Label(time_frame, text="未启用时间限制", foreground="gray")
|
|
|
+ self.time_status_label.grid(row=2, column=0, columnspan=4, sticky=tk.W, pady=5)
|
|
|
+
|
|
|
+ # 控制按钮区域
|
|
|
+ control_frame = ttk.Frame(main_frame)
|
|
|
+ control_frame.grid(row=3, column=0, pady=10)
|
|
|
+
|
|
|
+ self.start_btn = ttk.Button(control_frame, text="开始运行", command=self.start_task_scheduler, width=15)
|
|
|
+ self.start_btn.grid(row=0, column=0, padx=10)
|
|
|
+
|
|
|
+ self.stop_btn = ttk.Button(control_frame, text="结束运行", command=self.stop_task_scheduler, width=15, state="disabled")
|
|
|
+ self.stop_btn.grid(row=0, column=1, padx=10)
|
|
|
+
|
|
|
+ # 状态显示
|
|
|
+ status_frame = ttk.Frame(main_frame)
|
|
|
+ status_frame.grid(row=4, column=0, pady=5)
|
|
|
+
|
|
|
+ self.status_label = ttk.Label(status_frame, text="状态: ● 已停止", foreground="red")
|
|
|
+ self.status_label.grid(row=0, column=0)
|
|
|
+
|
|
|
# 日志区域
|
|
|
log_frame = ttk.LabelFrame(main_frame, text="日志", padding="10")
|
|
|
- log_frame.grid(row=2, column=0, sticky=(tk.W, tk.E, tk.N, tk.S), pady=10)
|
|
|
+ log_frame.grid(row=5, column=0, sticky=(tk.W, tk.E, tk.N, tk.S), pady=10)
|
|
|
|
|
|
self.log_text = scrolledtext.ScrolledText(log_frame, width=75, height=15, wrap=tk.WORD)
|
|
|
self.log_text.grid(row=0, column=0)
|
|
|
|
|
|
- # 测试按钮
|
|
|
- # test_btn = ttk.Button(main_frame, text="测试发货", command=self.test_click, width=20)
|
|
|
- # test_btn.grid(row=3, column=0, pady=1)
|
|
|
-
|
|
|
- test_btn2 = ttk.Button(main_frame, text="测试收货", command=self.test_click2, width=20)
|
|
|
- test_btn2.grid(row=3, column=0, pady=1)
|
|
|
-
|
|
|
# 配置权重
|
|
|
self.root.columnconfigure(0, weight=1)
|
|
|
self.root.rowconfigure(0, weight=1)
|
|
|
main_frame.columnconfigure(0, weight=1)
|
|
|
- main_frame.rowconfigure(2, weight=1)
|
|
|
+ main_frame.rowconfigure(5, weight=1)
|
|
|
log_frame.columnconfigure(0, weight=1)
|
|
|
log_frame.rowconfigure(0, weight=1)
|
|
|
|
|
|
+ def on_time_enable_changed(self):
|
|
|
+ """时间限制启用/禁用状态改变时的处理"""
|
|
|
+ self.delivery_time_enabled = self.time_enabled_var.get()
|
|
|
+
|
|
|
+ # 启用/禁用日期时间选择器
|
|
|
+ state = "normal" if self.delivery_time_enabled else "disabled"
|
|
|
+ self.date_picker.config(state=state)
|
|
|
+ self.hour_var.set("23" if self.delivery_time_enabled else "")
|
|
|
+ self.minute_var.set("59" if self.delivery_time_enabled else "")
|
|
|
+
|
|
|
+ if self.delivery_time_enabled:
|
|
|
+ # 更新最后发货时间
|
|
|
+ self.update_last_delivery_time()
|
|
|
+ self.time_status_label.config(
|
|
|
+ text=f"最后发货时间: {self.last_delivery_time.strftime('%Y-%m-%d %H:%M:%S') if self.last_delivery_time else '未设置'}",
|
|
|
+ foreground="green"
|
|
|
+ )
|
|
|
+ self.log_message(f"已启用最后发货时间限制: {self.last_delivery_time}", "INFO")
|
|
|
+ else:
|
|
|
+ self.last_delivery_time = None
|
|
|
+ self.time_status_label.config(text="未启用时间限制", foreground="gray")
|
|
|
+ self.log_message("已禁用最后发货时间限制", "INFO")
|
|
|
+
|
|
|
+ def update_last_delivery_time(self):
|
|
|
+ """根据选择的日期时间更新最后发货时间"""
|
|
|
+ if not self.delivery_time_enabled:
|
|
|
+ return
|
|
|
+
|
|
|
+ try:
|
|
|
+ date_str = self.date_picker.get()
|
|
|
+ hour = int(self.hour_var.get())
|
|
|
+ minute = int(self.minute_var.get())
|
|
|
+
|
|
|
+ # 组合日期时间
|
|
|
+ self.last_delivery_time = datetime.strptime(f"{date_str} {hour:02d}:{minute:02d}:00", "%Y-%m-%d %H:%M:%S")
|
|
|
+
|
|
|
+ # 如果设置的时间已经过了，给出警告
|
|
|
+ if self.last_delivery_time <= datetime.now():
|
|
|
+ self.log_message(f"警告: 设置的最后发货时间 {self.last_delivery_time} 已经过去，将立即停止发货任务", "WARNING")
|
|
|
+ self.time_status_label.config(foreground="orange")
|
|
|
+ else:
|
|
|
+ self.time_status_label.config(foreground="green")
|
|
|
+
|
|
|
+ except Exception as e:
|
|
|
+ self.log_message(f"解析时间失败: {e}", "ERROR")
|
|
|
+ self.last_delivery_time = None
|
|
|
+
|
|
|
+ def is_delivery_allowed(self):
|
|
|
+ """检查是否允许执行发货任务"""
|
|
|
+ if not self.delivery_time_enabled:
|
|
|
+ return True
|
|
|
+
|
|
|
+ if self.last_delivery_time is None:
|
|
|
+ self.update_last_delivery_time()
|
|
|
+
|
|
|
+ current_time = datetime.now()
|
|
|
+ allowed = current_time <= self.last_delivery_time
|
|
|
+
|
|
|
+ if not allowed:
|
|
|
+ self.log_message(f"当前时间 {current_time.strftime('%Y-%m-%d %H:%M:%S')} 已超过最后发货时间 {self.last_delivery_time.strftime('%Y-%m-%d %H:%M:%S')}，跳过发货任务", "WARNING")
|
|
|
+
|
|
|
+ return allowed
|
|
|
+
|
|
|
+ def start_task_scheduler(self):
|
|
|
+ """启动任务调度器"""
|
|
|
+ # 检查是否选择了模拟器
|
|
|
+ if not self.send_var.get():
|
|
|
+ self.log_message("请先选择发货手机模拟器", "ERROR")
|
|
|
+ messagebox.showwarning("警告", "请先选择发货手机模拟器")
|
|
|
+ return
|
|
|
+
|
|
|
+ if not self.receive_var.get():
|
|
|
+ self.log_message("请先选择收货手机模拟器", "ERROR")
|
|
|
+ messagebox.showwarning("警告", "请先选择收货手机模拟器")
|
|
|
+ return
|
|
|
+
|
|
|
+ if self.is_running:
|
|
|
+ self.log_message("任务调度器已在运行中", "WARNING")
|
|
|
+ return
|
|
|
+
|
|
|
+ # 检查MuMuManager路径
|
|
|
+ if not self.mumu_manager_path or not os.path.exists(self.mumu_manager_path):
|
|
|
+ self.log_message("请先设置正确的 MuMuManager.exe 路径", "ERROR")
|
|
|
+ messagebox.showwarning("警告", "请先设置 MuMuManager.exe 路径")
|
|
|
+ return
|
|
|
+
|
|
|
+ # 如果启用了时间限制，更新时间
|
|
|
+ if self.delivery_time_enabled:
|
|
|
+ self.update_last_delivery_time()
|
|
|
+ if self.last_delivery_time and self.last_delivery_time <= datetime.now():
|
|
|
+ result = messagebox.askyesno(
|
|
|
+ "确认",
|
|
|
+ f"最后发货时间 {self.last_delivery_time} 已经过去，将不会执行任何发货任务。是否继续？"
|
|
|
+ )
|
|
|
+ if not result:
|
|
|
+ return
|
|
|
+
|
|
|
+ self.is_running = True
|
|
|
+ self.stop_event.clear()
|
|
|
+
|
|
|
+ # 启动任务线程
|
|
|
+ self.task_thread = threading.Thread(target=self.task_scheduler_loop, daemon=True)
|
|
|
+ self.task_thread.start()
|
|
|
+
|
|
|
+ # 更新UI
|
|
|
+ self.start_btn.config(state="disabled")
|
|
|
+ self.stop_btn.config(state="normal")
|
|
|
+ self.status_label.config(text="状态: ● 运行中", foreground="green")
|
|
|
+
|
|
|
+ time_info = f"最后发货时间: {self.last_delivery_time}" if self.delivery_time_enabled else "无时间限制"
|
|
|
+ self.log_message(f"任务调度器已启动，每10秒检测一次任务。{time_info}", "INFO")
|
|
|
+
|
|
|
+ def stop_task_scheduler(self):
|
|
|
+ """停止任务调度器"""
|
|
|
+ if not self.is_running:
|
|
|
+ return
|
|
|
+
|
|
|
+ self.is_running = False
|
|
|
+ self.stop_event.set()
|
|
|
+
|
|
|
+ # 等待线程结束
|
|
|
+ if self.task_thread and self.task_thread.is_alive():
|
|
|
+ self.task_thread.join(timeout=3)
|
|
|
+
|
|
|
+ # 更新UI
|
|
|
+ self.start_btn.config(state="normal")
|
|
|
+ self.stop_btn.config(state="disabled")
|
|
|
+ self.status_label.config(text="状态: ● 已停止", foreground="red")
|
|
|
+ self.log_message("任务调度器已停止", "INFO")
|
|
|
+
|
|
|
+ def task_scheduler_loop(self):
|
|
|
+ """任务调度循环"""
|
|
|
+ while self.is_running and not self.stop_event.is_set():
|
|
|
+ try:
|
|
|
+ self.log_message("开始检测任务...", "INFO")
|
|
|
+
|
|
|
+ # 检查发货任务（根据时间限制决定）
|
|
|
+ delivery_allowed = self.is_delivery_allowed()
|
|
|
+
|
|
|
+ if delivery_allowed:
|
|
|
+ # 如果允许发货，先检查发货任务
|
|
|
+ has_task = self.check_and_execute_task("https://task.port.run/acquire/bdxkjzc", "发货")
|
|
|
+
|
|
|
+ # 如果没有发货任务，检查收货任务
|
|
|
+ if not has_task:
|
|
|
+ has_task = self.check_and_execute_task("https://task.port.run/acquire/bdxkjxc", "收货")
|
|
|
+ else:
|
|
|
+ # 不允许发货，只检查收货任务
|
|
|
+ self.log_message("已超过最后发货时间，仅处理收货任务", "INFO")
|
|
|
+ has_task = self.check_and_execute_task("https://task.port.run/acquire/bdxkjxc", "收货")
|
|
|
+
|
|
|
+ if not has_task:
|
|
|
+ self.log_message("暂无可用任务，10秒后继续检测", "INFO")
|
|
|
+
|
|
|
+ # 等待10秒后继续检测
|
|
|
+ time.sleep(3)
|
|
|
+
|
|
|
+ except Exception as e:
|
|
|
+ self.log_message(f"任务调度循环出错: {e}", "ERROR")
|
|
|
+ time.sleep(5)
|
|
|
+
|
|
|
+ def check_and_execute_task(self, url, task_type):
|
|
|
+ """
|
|
|
+ 检查并执行任务
|
|
|
+ Returns:
|
|
|
+ bool: 是否执行了任务
|
|
|
+ """
|
|
|
+ try:
|
|
|
+ # 发送请求获取任务
|
|
|
+ response = requests.get(url, timeout=10)
|
|
|
+ response.raise_for_status()
|
|
|
+
|
|
|
+ repData = response.json()
|
|
|
+
|
|
|
+ # 检查是否有任务
|
|
|
+ if "task" in repData and "content" in repData['task']:
|
|
|
+ content = repData['task']["content"]
|
|
|
+ self.log_message(f"获取到{task_type}任务: {content.get('tableData', ['N/A'])[2] if 'tableData' in content else '未知'}", "INFO")
|
|
|
+
|
|
|
+ # 执行任务
|
|
|
+ if task_type == "发货":
|
|
|
+ send_selection = self.send_var.get()
|
|
|
+ emu_index = self.get_emulator_index(send_selection)
|
|
|
+ if emu_index:
|
|
|
+ self.perform_click(emu_index, send_selection.split(" (")[0], content)
|
|
|
+ return True
|
|
|
+ else:
|
|
|
+ self.log_message(f"无法获取发货模拟器索引", "ERROR")
|
|
|
+ return False
|
|
|
+ else: # 收货任务
|
|
|
+ receive_selection = self.receive_var.get()
|
|
|
+ emu_index = self.get_emulator_index(receive_selection)
|
|
|
+ if emu_index:
|
|
|
+ self.perform_click2(emu_index, receive_selection.split(" (")[0], content)
|
|
|
+ return True
|
|
|
+ else:
|
|
|
+ self.log_message(f"无法获取收货模拟器索引", "ERROR")
|
|
|
+ return False
|
|
|
+ else:
|
|
|
+ self.log_message(f"暂无{task_type}任务", "INFO")
|
|
|
+ return False
|
|
|
+
|
|
|
+ except requests.RequestException as e:
|
|
|
+ self.log_message(f"请求{task_type}任务失败: {e}", "ERROR")
|
|
|
+ return False
|
|
|
+ except Exception as e:
|
|
|
+ self.log_message(f"处理{task_type}任务时出错: {e}", "ERROR")
|
|
|
+ return False
|
|
|
+
|
|
|
def browse_mumu_manager(self):
|
|
|
"""浏览选择MuMuManager.exe"""
|
|
|
file_path = filedialog.askopenfilename(
|
|
|
@@ -380,7 +711,11 @@ class SimpleMuMuManager:
|
|
|
|
|
|
def save_config(self):
|
|
|
"""保存配置"""
|
|
|
- config = {'mumu_manager_path': self.mumu_manager_path}
|
|
|
+ config = {
|
|
|
+ 'mumu_manager_path': self.mumu_manager_path,
|
|
|
+ 'delivery_time_enabled': self.delivery_time_enabled,
|
|
|
+ 'last_delivery_time': self.last_delivery_time.strftime("%Y-%m-%d %H:%M:%S") if self.last_delivery_time else None
|
|
|
+ }
|
|
|
try:
|
|
|
with open(self.config_file, 'w', encoding='utf-8') as f:
|
|
|
json.dump(config, f, indent=4)
|
|
|
@@ -400,6 +735,29 @@ class SimpleMuMuManager:
|
|
|
self.log_message(f"已加载配置: {path}")
|
|
|
elif path:
|
|
|
self.log_message(f"配置路径不存在: {path}", "WARNING")
|
|
|
+
|
|
|
+ # 加载时间限制配置
|
|
|
+ enabled = config.get('delivery_time_enabled', False)
|
|
|
+ self.time_enabled_var.set(enabled)
|
|
|
+ self.delivery_time_enabled = enabled
|
|
|
+
|
|
|
+ last_time_str = config.get('last_delivery_time')
|
|
|
+ if last_time_str and enabled:
|
|
|
+ try:
|
|
|
+ self.last_delivery_time = datetime.strptime(last_time_str, "%Y-%m-%d %H:%M:%S")
|
|
|
+ # 设置日期选择器
|
|
|
+ date_str = self.last_delivery_time.strftime("%Y-%m-%d")
|
|
|
+ self.date_picker.set_date(date_str)
|
|
|
+ self.hour_var.set(f"{self.last_delivery_time.hour:02d}")
|
|
|
+ self.minute_var.set(f"{self.last_delivery_time.minute:02d}")
|
|
|
+ self.on_time_enable_changed()
|
|
|
+ self.log_message(f"已加载最后发货时间设置: {last_time_str}", "INFO")
|
|
|
+ except Exception as e:
|
|
|
+ self.log_message(f"加载最后发货时间失败: {e}", "WARNING")
|
|
|
+
|
|
|
+ # 根据配置更新UI状态
|
|
|
+ self.on_time_enable_changed()
|
|
|
+
|
|
|
except Exception as e:
|
|
|
self.log_message(f"加载配置失败: {e}", "ERROR")
|
|
|
|
|
|
@@ -407,9 +765,14 @@ class SimpleMuMuManager:
|
|
|
"""添加日志"""
|
|
|
timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
|
|
|
log_entry = f"[{timestamp}] [{level}] {message}\n"
|
|
|
+
|
|
|
+ # 在主线程中更新UI
|
|
|
+ self.root.after(0, lambda: self._append_log(log_entry))
|
|
|
+
|
|
|
+ def _append_log(self, log_entry):
|
|
|
+ """实际添加日志到文本框"""
|
|
|
self.log_text.insert(tk.END, log_entry)
|
|
|
self.log_text.see(tk.END)
|
|
|
- self.root.update()
|
|
|
|
|
|
def refresh_emulators(self):
|
|
|
"""刷新模拟器列表"""
|
|
|
@@ -457,86 +820,10 @@ class SimpleMuMuManager:
|
|
|
return match.group(1)
|
|
|
return None
|
|
|
|
|
|
- def test_click(self):
|
|
|
- url = "https://task.port.run/acquire/bdxkjzc"
|
|
|
-
|
|
|
- payload = ""
|
|
|
- headers = {
|
|
|
- "Content-Type": "application/json",
|
|
|
- "Accept": "*/*",
|
|
|
- "Accept-Encoding": "gzip, deflate, br",
|
|
|
- "User-Agent": "PostmanRuntime-ApipostRuntime/1.1.0",
|
|
|
- "Connection": "keep-alive"
|
|
|
- }
|
|
|
-
|
|
|
- response = requests.request("GET", url, data=payload, headers=headers)
|
|
|
-
|
|
|
- print(response.text)
|
|
|
- repData = json.loads(response.text)
|
|
|
- if ("task" in repData and "content" in repData['task']):
|
|
|
- """测试点击"""
|
|
|
- send_selection = self.send_var.get()
|
|
|
-
|
|
|
- if not send_selection:
|
|
|
- self.log_message("请选择发货手机模拟器", "ERROR")
|
|
|
- messagebox.showwarning("警告", "请选择发货手机模拟器")
|
|
|
- return
|
|
|
-
|
|
|
- emu_index = self.get_emulator_index(send_selection)
|
|
|
- if not emu_index:
|
|
|
- self.log_message("无法获取模拟器索引", "ERROR")
|
|
|
- return
|
|
|
-
|
|
|
- # 在新线程中执行点击
|
|
|
- thread = threading.Thread(target=self.perform_click, args=(emu_index, send_selection.split(" (")[0], repData['task']["content"]))
|
|
|
- thread.daemon = True
|
|
|
- thread.start()
|
|
|
- else:
|
|
|
- self.log_message("未获取到有效任务数据", "ERROR")
|
|
|
- messagebox.showerror("错误", "未获取到有效任务数据")
|
|
|
-
|
|
|
- def test_click2(self):
|
|
|
- url = "https://task.port.run/acquire/bdxkjxc"
|
|
|
-
|
|
|
- payload = ""
|
|
|
- headers = {
|
|
|
- "Content-Type": "application/json",
|
|
|
- "Accept": "*/*",
|
|
|
- "Accept-Encoding": "gzip, deflate, br",
|
|
|
- "User-Agent": "PostmanRuntime-ApipostRuntime/1.1.0",
|
|
|
- "Connection": "keep-alive"
|
|
|
- }
|
|
|
-
|
|
|
- response = requests.request("GET", url, data=payload, headers=headers)
|
|
|
-
|
|
|
- print(response.text)
|
|
|
- repData = json.loads(response.text)
|
|
|
- if ("task" in repData and "content" in repData['task']):
|
|
|
- """测试点击"""
|
|
|
- receive_selection = self.receive_var.get()
|
|
|
-
|
|
|
- if not receive_selection:
|
|
|
- self.log_message("请选择收货手机模拟器", "ERROR")
|
|
|
- messagebox.showwarning("警告", "请选择收货手机模拟器")
|
|
|
- return
|
|
|
-
|
|
|
- emu_index = self.get_emulator_index(receive_selection)
|
|
|
- if not emu_index:
|
|
|
- self.log_message("无法获取模拟器索引", "ERROR")
|
|
|
- return
|
|
|
-
|
|
|
- # 在新线程中执行点击
|
|
|
- thread = threading.Thread(target=self.perform_click2, args=(emu_index, receive_selection.split(" (")[0], repData['task']["content"]))
|
|
|
- thread.daemon = True
|
|
|
- thread.start()
|
|
|
- else:
|
|
|
- self.log_message("未获取到有效任务数据", "ERROR")
|
|
|
- messagebox.showerror("错误", "未获取到有效任务数据")
|
|
|
-
|
|
|
def perform_click(self, emu_index, window_title, content):
|
|
|
"""执行点击操作"""
|
|
|
x, y = 508, 252
|
|
|
- self.log_message(f"开始在模拟器 {emu_index} 上点击位置 ({x}, {y})")
|
|
|
+ self.log_message(f"开始在模拟器 {emu_index} 上执行发货任务")
|
|
|
|
|
|
try:
|
|
|
manager = MuMuEmulatorManager(self.mumu_manager_path)
|
|
|
@@ -552,28 +839,29 @@ class SimpleMuMuManager:
|
|
|
self.log_message(f"✅ 点击成功！模拟器 {emu_index} 位置 ({x}, {y})")
|
|
|
rectX, rectY = activate_window_and_get_position(window_title)
|
|
|
time.sleep(2) # 短暂等待窗口激活
|
|
|
- click_screen(rectX + 339, rectY + 576)
|
|
|
+ click_screen(rectX + 241, rectY + 411)
|
|
|
time.sleep(1)
|
|
|
- showImageBox = show_image_at_position("C:\\Users\\mail\\Downloads\\chepai\\" + content["tableData"][2] + ".png", rectX + 273, rectY + 549 )
|
|
|
+ showImageBox = show_image_at_position(".\\chepai\\" + content["tableData"][2] + ".png", rectX + 144, rectY + 355)
|
|
|
# 开始检测是否扫描
|
|
|
color1 = get_emulator_pixel_color(self.mumu_manager_path, emu_index, 523, 1114)
|
|
|
- while color1 != "#007AFF": # 假设白色表示未扫描
|
|
|
+ while color1 != "#007AFF" and self.is_running:
|
|
|
self.log_message(f"当前颜色: {color1}, 等待扫描完成...")
|
|
|
time.sleep(1)
|
|
|
color1 = get_emulator_pixel_color(self.mumu_manager_path, emu_index, 523, 1114)
|
|
|
# 关闭窗口
|
|
|
showImageBox.destroy()
|
|
|
self.log_message(f"关闭二维码窗口!")
|
|
|
- click_screen(rectX + 323, rectY + 718)
|
|
|
+ manager.tap(emu_index, 323, 718, self.log_message)
|
|
|
time.sleep(1)
|
|
|
drag_in_emulator(self.mumu_manager_path, emu_index, 430, 1046, 980, 400)
|
|
|
time.sleep(0.5)
|
|
|
- click_screen(rectX + 650, rectY + 743)
|
|
|
+ manager.tap(emu_index, 650, 743, self.log_message)
|
|
|
time.sleep(1)
|
|
|
- click_screen(rectX + 358, rectY + 1112)
|
|
|
+ manager.tap(emu_index, 358, 1112, self.log_message)
|
|
|
time.sleep(1)
|
|
|
- click_screen(rectX + 419, rectY + 760)
|
|
|
-
|
|
|
+ manager.tap(emu_index, 419, 765, self.log_message)
|
|
|
+ self.log_message(f"✅ 发货任务执行完成")
|
|
|
+ sendTask(content["tableData"][2])
|
|
|
else:
|
|
|
self.log_message(f"❌ 点击失败", "ERROR")
|
|
|
|
|
|
@@ -583,7 +871,7 @@ class SimpleMuMuManager:
|
|
|
def perform_click2(self, emu_index, window_title, content):
|
|
|
"""执行点击操作"""
|
|
|
x, y = 508, 252
|
|
|
- self.log_message(f"开始在模拟器 {emu_index} 上点击位置 ({x}, {y})")
|
|
|
+ self.log_message(f"开始在模拟器 {emu_index} 上执行收货任务")
|
|
|
|
|
|
try:
|
|
|
manager = MuMuEmulatorManager(self.mumu_manager_path)
|
|
|
@@ -599,12 +887,12 @@ class SimpleMuMuManager:
|
|
|
self.log_message(f"✅ 点击成功！模拟器 {emu_index} 位置 ({x}, {y})")
|
|
|
rectX, rectY = activate_window_and_get_position(window_title)
|
|
|
time.sleep(2) # 短暂等待窗口激活
|
|
|
- click_screen(rectX + 339, rectY + 576)
|
|
|
+ click_screen(rectX + 241, rectY + 411)
|
|
|
time.sleep(1)
|
|
|
- showImageBox = show_image_at_position("C:\\Users\\mail\\Downloads\\chepai\\" + content["tableData"][2] + ".png", rectX + 273, rectY + 549 )
|
|
|
+ showImageBox = show_image_at_position(".\\chepai\\" + content["tableData"][2] + ".png", rectX + 144, rectY + 355)
|
|
|
# 开始检测是否扫描
|
|
|
color1 = get_emulator_pixel_color(self.mumu_manager_path, emu_index, 530, 1200)
|
|
|
- while color1 != "#007AFF": # 假设白色表示未扫描
|
|
|
+ while color1 != "#007AFF" and self.is_running:
|
|
|
self.log_message(f"当前颜色: {color1}, 等待扫描完成...")
|
|
|
time.sleep(1)
|
|
|
color1 = get_emulator_pixel_color(self.mumu_manager_path, emu_index, 530, 1200)
|
|
|
@@ -617,18 +905,19 @@ class SimpleMuMuManager:
|
|
|
time.sleep(1)
|
|
|
manager.tap(emu_index, 347, 918, self.log_message)
|
|
|
time.sleep(1)
|
|
|
- input_text_to_emulator(self.mumu_manager_path, emu_index, random.randint(35, 36))
|
|
|
- time.sleep(1)
|
|
|
+ input_text_to_emulator(self.mumu_manager_path, emu_index, split_and_random_select(content["tdds"]))
|
|
|
time.sleep(1)
|
|
|
manager.tap(emu_index, 530, 1200, self.log_message)
|
|
|
time.sleep(1)
|
|
|
manager.tap(emu_index, 419, 765, self.log_message)
|
|
|
-
|
|
|
+ self.log_message(f"✅ 收货任务执行完成")
|
|
|
+ sendTask(content["tableData"][2])
|
|
|
else:
|
|
|
self.log_message(f"❌ 点击失败", "ERROR")
|
|
|
|
|
|
except Exception as e:
|
|
|
self.log_message(f"❌ 执行出错: {e}", "ERROR")
|
|
|
+
|
|
|
def main():
|
|
|
root = tk.Tk()
|
|
|
app = SimpleMuMuManager(root)
|
PUGE