import datetime import json import os import re import time import uuid class Problem(object): def __init__(self, problem_path, solution_path): self.path = problem_path self.name = '' self.size = (0, 0) self.block_num = 0 self.blocks = dict() self.problem = '' self.status = 'Ready' self.solutions = dict() self.solution_path = solution_path self._load_problem(problem_path) @property def size_str(self): return f'{self.size[0]}X{self.size[1]}' def _load_problem(self, path): with open(path, 'r') as fp: q_text = fp.read() q_lines = q_text.splitlines() board_size = [0, 0] block_num = 0 blocks = dict() def intplus(v): if v.isdecimal(): return int(v) else: return v li = 0 while li < len(q_lines): _l = q_lines[li] if "SIZE" in _l: board_size_str = _l.strip().split()[1] board_size = [int(v) for v in board_size_str.split('X')] if 'BLOCK_NUM' in _l: block_num = int(_l.strip().split()[1]) if 'BLOCK#' in _l: p = r'BLOCK#([0-9]+) +([0-9]+)X([0-9]+)' m = re.match(p, _l.strip()) bi = int(m.group(1)) bw = int(m.group(2)) bh = int(m.group(3)) blocks[bi] = { 'index': bi, 'w': bw, 'h': bh, 'cells': list() } for _h in range(bh): li += 1 _l = q_lines[li].strip() blocks[bi]['cells'].append([intplus(v.strip()) for v in _l.split(',')]) li += 1 name = os.path.splitext(os.path.basename(path))[0] self.size = board_size self.block_num = block_num self.blocks = blocks self.name = name self.problem = q_text self.status = 'Ready' def get_dict(self): return { 'name': self.name, 'size': self.size, 'size_str': self.size_str, 'block_num': self.block_num, 'problem': self.problem, 'status': self.status } def get_d3json(self): return { 'block': self.blocks, 'w': self.size[0], 'h': self.size[1], 'n': self.block_num } def put_solution(self, data): solution = Solution(data) solution_id = solution.get_id() print(f'I: Put a solution: {solution_id}') self.solutions[solution_id] = solution # Save solution solution.save(self.solution_path) def get_solutions(self): return self.solutions def get_solution(self, solution_id): if solution_id in self.solutions: return self.solutions[solution_id] else: return None class Solution(object): def __init__(self, data): self.problem = data['problem'] self.request_id = data['request_id'] self.worker = data['worker'] self.elapsed_time = data['elapsed_time'] self.solution = data['solution'] self.timestamp = time.time() self._id = str(uuid.uuid4()) def get_id(self): return self._id def get_dict(self): return { 'id': self._id, 'timestamp': self.timestamp, 'request_id': self.request_id, 'worker': self.worker, 'elapsed_time': self.elapsed_time, 'problem': self.problem, 'solution': self.solution } def get_d3json(self): board_size = [0, 0] block_num = 0 _lines = self.solution.splitlines() li = 0 bw, bh = 0, 0 bmap = list() bposition = dict() while li < len(_lines): _l = _lines[li].strip() if 'SIZE' in _l: board_size_str = _l.strip().split()[1] board_solution_size = [int(v) for v in board_size_str.split('X')] bw = board_solution_size[0] bh = board_solution_size[1] for _h in range(bh): li += 1 _l = _lines[li].strip() bmap.append([int(v.strip()) for v in _l.split(',')]) if 'BLOCK' in _l: p = r'BLOCK#([0-9]+) +@\(([0-9]+), *([0-9]+)\)' m = re.match(p, _l.strip()) bi = int(m.group(1)) bx = int(m.group(2)) by = int(m.group(3)) bposition[bi] = { 'index': bi, 'x': bx, 'y': by, } li += 1 return { 'w': bw, 'h': bh, 'map': bmap, 'block': bposition } def save(self, basedir): outdir = f"{basedir}/{self.problem}" if not os.path.exists(outdir): os.mkdir(outdir) outpath = f"{outdir}/{self.request_id}-{self.worker}.json".replace(":", ".") with open(outpath, 'w') as fp: json.dump(self.get_dict(), fp, indent=4) @property def timestamp_str(self): dt = datetime.datetime.fromtimestamp( self.timestamp, datetime.timezone(datetime.timedelta(hours=9))) return dt.strftime('%H:%M:%S.%f')