Skip to content

Commit

Permalink
修复任务搜索和分页
Browse files Browse the repository at this point in the history
  • Loading branch information
shenshuo committed Jun 12, 2019
1 parent f5d6953 commit c578b5a
Showing 1 changed file with 9 additions and 2 deletions.
11 changes: 9 additions & 2 deletions cron/applications.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,13 +31,19 @@ def job_from(**jobargs):

class CronJobs(BaseHandler):
def get(self, *args, **kwargs):
page_size = self.get_argument('page', default=1, strip=True)
limit = self.get_argument('limit', default=15, strip=True)
job_id = self.get_argument('job_id', default=None, strip=True)

limit_start = (int(page_size) - 1) * int(limit)
limit_end = int(page_size) * int(limit)
info_list = []
try:
if not job_id:
ret_list = scheduler.get_jobs()
else:
ret_list = [scheduler.get_job(job_id)]
limit_start = 0
for ret in ret_list:
fields = ret.trigger.fields
cron = {}
Expand All @@ -53,9 +59,10 @@ def get(self, *args, **kwargs):
"day") + " " + cron.get("month") + " " + cron.get("day_of_week")
}
info_list.append(info)
return self.write(dict(code=0, msg='获取成功', data=info_list))

return self.write(dict(code=0, msg='获取成功', data=info_list[limit_start:limit_end], count=len(info_list)))
except Exception as e:
return self.write(dict(code=-1, msg=str(e)))
return self.write(dict(code=-1, msg="错误 " + str(e)))

def post(self, *args, **kwargs):
data = json.loads(self.request.body.decode("utf-8"))
Expand Down

0 comments on commit c578b5a

Please sign in to comment.