disk.py 3.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109
  1. #!/usr/bin/env python
  2. # -*- coding: utf-8 -*-
  3. import json
  4. from flask import Blueprint, render_template, url_for, request
  5. import requests
  6. from math import ceil
  7. import re
  8. __author__ = 'James Iter'
  9. __date__ = '2017/6/25'
  10. __contact__ = 'james.iter.cn@gmail.com'
  11. __copyright__ = '(c) 2017 by James Iter.'
  12. blueprint = Blueprint(
  13. 'v_disk',
  14. __name__,
  15. url_prefix='/disk'
  16. )
  17. blueprints = Blueprint(
  18. 'v_disks',
  19. __name__,
  20. url_prefix='/disks'
  21. )
  22. def show():
  23. args = list()
  24. page = int(request.args.get('page', 1))
  25. page_size = int(request.args.get('page_size', 10))
  26. keyword = request.args.get('keyword', None)
  27. resource_path = request.path
  28. if page is not None:
  29. args.append('page=' + page.__str__())
  30. if page_size is not None:
  31. args.append('page_size=' + page_size.__str__())
  32. if keyword is not None:
  33. args.append('keyword=' + keyword.__str__())
  34. host_url = request.host_url.rstrip('/')
  35. disks_url = host_url + url_for('api_disks.r_get_by_filter')
  36. if keyword is not None:
  37. disks_url = host_url + url_for('api_disks.r_content_search')
  38. if args.__len__() > 0:
  39. disks_url = disks_url + '?' + '&'.join(args)
  40. disks_ret = requests.get(url=disks_url)
  41. disks_ret = json.loads(disks_ret.content)
  42. last_page = int(ceil(disks_ret['paging']['total'] / float(page_size)))
  43. page_length = 5
  44. pages = list()
  45. if page < int(ceil(page_length / 2.0)):
  46. for i in range(1, page_length + 1):
  47. pages.append(i)
  48. if i == last_page:
  49. break
  50. elif last_page - page < page_length / 2:
  51. for i in range(last_page - page_length + 1, last_page + 1):
  52. if i < 1:
  53. continue
  54. pages.append(i)
  55. else:
  56. for i in range(page - page_length / 2, page + int(ceil(page_length / 2.0))):
  57. pages.append(i)
  58. if i == last_page:
  59. break
  60. return render_template('disk_show.html', disks_ret=disks_ret, resource_path=resource_path, page=page,
  61. page_size=page_size, keyword=keyword, pages=pages, last_page=last_page)
  62. def create():
  63. host_url = request.host_url.rstrip('/')
  64. if request.method == 'POST':
  65. size = request.form.get('size')
  66. quantity = request.form.get('quantity')
  67. remark = request.form.get('remark')
  68. payload = {
  69. "size": int(size),
  70. "quantity": int(quantity),
  71. "remark": remark
  72. }
  73. url = host_url + '/api/disk'
  74. headers = {'content-type': 'application/json'}
  75. r = requests.post(url, data=json.dumps(payload), headers=headers)
  76. j_r = json.loads(r.content)
  77. return render_template('success.html', go_back_url='/disks', timeout=10000, title='提交成功',
  78. message_title='创建实例的请求已被接受',
  79. message='您所提交的资源正在创建中。根据所提交资源的数量,需要等待几到十几秒钟。页面将在10秒钟后自动跳转到实例列表页面!')
  80. else:
  81. return render_template('disk_create.html')