2015-11-27 00:11:18 +03:00
|
|
|
import json
|
2016-04-02 00:42:22 +03:00
|
|
|
|
|
|
|
from SWSCloudCore import models
|
2015-11-27 00:11:18 +03:00
|
|
|
|
|
|
|
|
|
|
|
class ControllerManageTasks:
|
|
|
|
"""
|
|
|
|
|
|
|
|
"""
|
|
|
|
def __init__(self):
|
|
|
|
pass
|
|
|
|
|
2016-05-16 09:24:27 +03:00
|
|
|
def get(self, limit=100):
|
|
|
|
return models.Tasks.select().limit(limit)
|
2015-12-12 17:29:45 +03:00
|
|
|
|
2016-06-25 02:03:14 +03:00
|
|
|
def get_task(self, task_id):
|
|
|
|
"""
|
|
|
|
Get specified task
|
|
|
|
:param task_id:
|
|
|
|
:return:
|
|
|
|
"""
|
|
|
|
return models.Tasks.select().where(models.Tasks.id == task_id).get()
|
|
|
|
|
2015-11-27 00:11:18 +03:00
|
|
|
def get_by_server(self, server_id):
|
|
|
|
task = models.Tasks.select(models.Tasks.plain).\
|
|
|
|
where(models.Tasks.server_id == server_id).order_by(models.Tasks.created.desc()).limit(1)
|
|
|
|
return json.loads(task[0].plain)
|
|
|
|
|
|
|
|
def delete(self, task_id):
|
|
|
|
return models.Tasks.delete().where(models.Tasks.id == task_id).execute()
|
|
|
|
|
|
|
|
def check_exists_by_id(self, task_id):
|
|
|
|
if models.Tasks.select().where(models.Tasks.id == task_id).count() == 1:
|
|
|
|
return True
|
|
|
|
return False
|
|
|
|
|
|
|
|
def check_exists_by_server(self, server_id):
|
|
|
|
result = models.Tasks.select().where(models.Tasks.server_id == server_id).count()
|
|
|
|
# logging.debug("Function: check_exists_by_server(): %s" % result)
|
|
|
|
return result
|