from datetime import datetime, timezone
import logging
logger = logging.getLogger(__name__)class AutoRunTask:def __init__(self):self.map_name = "" self.counting_succeed = Trueself.total_round = 0self.finished_round = 0self.succeed_round = 0#read only, set when task startself.startedAt = datetime.now(timezone.utc).isoformat(timespec="milliseconds").replace("+00:00", "Z")self.completedAt = Noneclass GlobalState:def __init__(self):self.current_account = Noneself.fish_target_area_start_x = 0self.fish_target_area_end_x = 0self.fish_cusor_start_x_time = Noneself.fish_cusor_speed = 0self.current_task = Noneself.task_history = []def start_run_task(self, map_name, total_round, counting_succeed=True):task = AutoRunTask()task.map_name = map_nametask.total_round = total_roundtask.counting_succeed = counting_succeedif self.current_task is not None:self.task_history.append(self.current_task)self.current_task = tasklogger.critical(f'Starting [{self.current_account}],total:{total_round},isfinish:{counting_succeed}')# def refresh_run_task(self, succeed):
# if self.current_task is None:
# logger.warning("No current task to refresh")
# return True
#
# logger.error(f'[{self.current_account}],round:{self.current_task.finished_round},success:{self.current_task.succeed_round},total:{self.current_task.total_round}')
#
# self.current_task.finished_round += 1
# if succeed:
# self.current_task.succeed_round += 1
#
# if self.current_task.finished_round >= self.current_task.total_round:
# if self.current_task.counting_succeed:
# if self.current_task.succeed_round < self.current_task.total_round:
# self.current_task.completedAt = datetime.now(timezone.utc).isoformat(timespec="milliseconds").replace("+00:00", "Z")
# logger.critical(f'Autorun task completed for account:{self.current_account}, total rounds: {self.current_task.total_round}, successful rounds: {self.current_task.succeed_round}')
# else:
# self.current_task.completedAt = datetime.now(timezone.utc).isoformat(timespec="milliseconds").replace("+00:00", "Z")
# logger.critical(f'Autorun task completed for account:{self.current_account}, total rounds: {self.current_task.total_round}, successful rounds: {self.current_task.succeed_round}')
# return True
#
# return Falsedef refresh_run_task(self, succeed):if self.current_task is None:logger.warning("No current task to refresh")return Truetask = self.current_taskif task.completedAt is not None:return Truetask.finished_round += 1if succeed:task.succeed_round += 1logger.info(f'[{self.current_account}],'f'round:{task.finished_round},'f'success:{task.succeed_round},'f'total:{task.total_round}')rounds_finished = task.finished_round >= task.total_roundall_succeeded = task.succeed_round >= task.total_roundis_completed = rounds_finished and (all_succeeded if task.counting_succeed else True)if is_completed:task.completedAt = datetime.now(timezone.utc).isoformat(timespec="milliseconds").replace("+00:00", "Z")logger.critical(f'Autorun task completed for account:{self.current_account}, 'f'total rounds: {task.total_round}, 'f'successful rounds: {task.succeed_round}')return is_completed def check_run_task(self):if self.current_task is None:logger.error("No current task to check")return Falselogger.error(f'[{self.current_account}],round:{self.current_task.finished_round},success:{self.current_task.succeed_round},total:{self.current_task.total_round}')global_state = GlobalState()
