|
|
@@ -29,200 +29,30 @@ blueprints = Blueprint(
|
|
|
|
|
|
|
|
|
def show():
|
|
|
- args = list()
|
|
|
+ url = url_for('api_disks.r_show', _external=True)
|
|
|
+ if request.args.__len__() >= 1:
|
|
|
+ args = list()
|
|
|
|
|
|
- page = request.args.get('page', 1)
|
|
|
- if page == '':
|
|
|
- page = 1
|
|
|
- page = int(page)
|
|
|
+ for k, v in request.args.items():
|
|
|
+ args.append('='.join([k, v]))
|
|
|
|
|
|
- page_size = int(request.args.get('page_size', 10))
|
|
|
- keyword = request.args.get('keyword', None)
|
|
|
- show_area = request.args.get('show_area', 'unmount')
|
|
|
- guest_uuid = request.args.get('guest_uuid', None)
|
|
|
- sequence = request.args.get('sequence', None)
|
|
|
- order_by = request.args.get('order_by', None)
|
|
|
- order = request.args.get('order', None)
|
|
|
- filters = list()
|
|
|
- resource_path = request.path
|
|
|
+ url += '?' + '&'.join(args)
|
|
|
|
|
|
- if page is not None:
|
|
|
- args.append('page=' + page.__str__())
|
|
|
+ ret = requests.get(url=url, cookies=request.cookies)
|
|
|
+ ret = json.loads(ret.content)
|
|
|
|
|
|
- if page_size is not None:
|
|
|
- args.append('page_size=' + page_size.__str__())
|
|
|
-
|
|
|
- if keyword is not None:
|
|
|
- args.append('keyword=' + keyword.__str__())
|
|
|
-
|
|
|
- if guest_uuid is not None:
|
|
|
- filters.append('guest_uuid:in:' + guest_uuid.__str__())
|
|
|
- show_area = 'all'
|
|
|
-
|
|
|
- if sequence is not None:
|
|
|
- filters.append('sequence:in:' + sequence.__str__())
|
|
|
- show_area = 'all'
|
|
|
-
|
|
|
- if show_area in ['unmount', 'data_disk', 'all']:
|
|
|
- if show_area == 'unmount':
|
|
|
- filters.append('sequence:eq:-1')
|
|
|
-
|
|
|
- elif show_area == 'data_disk':
|
|
|
- filters.append('sequence:gt:0')
|
|
|
-
|
|
|
- else:
|
|
|
- pass
|
|
|
-
|
|
|
- else:
|
|
|
- # 与前端页面相照应，首次打开时，默认只显示未挂载的磁盘
|
|
|
- filters.append('sequence:eq:-1')
|
|
|
-
|
|
|
- if order_by is not None:
|
|
|
- args.append('order_by=' + order_by)
|
|
|
-
|
|
|
- if order is not None:
|
|
|
- args.append('order=' + order)
|
|
|
-
|
|
|
- if filters.__len__() > 0:
|
|
|
- args.append('filter=' + ','.join(filters))
|
|
|
-
|
|
|
- host_url = request.host_url.rstrip('/')
|
|
|
-
|
|
|
- hosts_url = host_url + url_for('api_hosts.r_get_by_filter')
|
|
|
- disks_url = host_url + url_for('api_disks.r_get_by_filter')
|
|
|
- config_url = host_url + url_for('api_config.r_get')
|
|
|
-
|
|
|
- if keyword is not None:
|
|
|
- disks_url = host_url + url_for('api_disks.r_content_search')
|
|
|
- # 关键字检索，不支持显示域过滤
|
|
|
- show_area = 'all'
|
|
|
-
|
|
|
- hosts_ret = requests.get(url=hosts_url, cookies=request.cookies)
|
|
|
- hosts_ret = json.loads(hosts_ret.content)
|
|
|
-
|
|
|
- hosts_mapping_by_node_id = dict()
|
|
|
- for host in hosts_ret['data']:
|
|
|
- hosts_mapping_by_node_id[int(host['node_id'])] = host
|
|
|
-
|
|
|
- if args.__len__() > 0:
|
|
|
- disks_url = disks_url + '?' + '&'.join(args)
|
|
|
-
|
|
|
- disks_ret = requests.get(url=disks_url, cookies=request.cookies)
|
|
|
- disks_ret = json.loads(disks_ret.content)
|
|
|
-
|
|
|
- guests_uuid = list()
|
|
|
- disks_uuid = list()
|
|
|
-
|
|
|
- for disk in disks_ret['data']:
|
|
|
- disks_uuid.append(disk['uuid'])
|
|
|
-
|
|
|
- if disk['guest_uuid'].__len__() == 36:
|
|
|
- guests_uuid.append(disk['guest_uuid'])
|
|
|
-
|
|
|
- if guests_uuid.__len__() > 0:
|
|
|
- guests_url = host_url + url_for('api_guests.r_get_by_filter', filter='uuid:in:' + ','.join(guests_uuid))
|
|
|
- guests_ret = requests.get(url=guests_url, cookies=request.cookies)
|
|
|
- guests_ret = json.loads(guests_ret.content)
|
|
|
-
|
|
|
- guests_uuid_mapping = dict()
|
|
|
- for guest in guests_ret['data']:
|
|
|
- guests_uuid_mapping[guest['uuid']] = guest
|
|
|
-
|
|
|
- for i, disk in enumerate(disks_ret['data']):
|
|
|
- if disk['guest_uuid'].__len__() == 36:
|
|
|
- disks_ret['data'][i]['guest'] = guests_uuid_mapping[disk['guest_uuid']]
|
|
|
-
|
|
|
- if disks_uuid.__len__() > 0:
|
|
|
- snapshots_id_mapping_by_disks_uuid_url = host_url + url_for('api_snapshots.r_get_snapshots_by_disks_uuid',
|
|
|
- disks_uuid=','.join(disks_uuid))
|
|
|
- snapshots_id_mapping_by_disks_uuid_ret = requests.get(url=snapshots_id_mapping_by_disks_uuid_url,
|
|
|
- cookies=request.cookies)
|
|
|
- snapshots_id_mapping_by_disks_uuid_ret = json.loads(snapshots_id_mapping_by_disks_uuid_ret.content)
|
|
|
-
|
|
|
- snapshots_id_mapping_by_disk_uuid = dict()
|
|
|
-
|
|
|
- for snapshot_id_mapping_by_disk_uuid in snapshots_id_mapping_by_disks_uuid_ret['data']:
|
|
|
-
|
|
|
- disk_uuid = snapshot_id_mapping_by_disk_uuid['disk_uuid']
|
|
|
- snapshot_id = snapshot_id_mapping_by_disk_uuid['snapshot_id']
|
|
|
-
|
|
|
- if disk_uuid not in snapshots_id_mapping_by_disk_uuid:
|
|
|
- snapshots_id_mapping_by_disk_uuid[disk_uuid] = list()
|
|
|
-
|
|
|
- snapshots_id_mapping_by_disk_uuid[disk_uuid].append(snapshot_id)
|
|
|
-
|
|
|
- for i, disk in enumerate(disks_ret['data']):
|
|
|
- if disk['uuid'] in snapshots_id_mapping_by_disk_uuid:
|
|
|
- disks_ret['data'][i]['snapshot'] = snapshots_id_mapping_by_disk_uuid[disk['uuid']]
|
|
|
-
|
|
|
- config_ret = requests.get(url=config_url, cookies=request.cookies)
|
|
|
- config_ret = json.loads(config_ret.content)
|
|
|
-
|
|
|
- show_on_host = False
|
|
|
- if config_ret['data']['storage_mode'] == StorageMode.local.value:
|
|
|
- show_on_host = True
|
|
|
-
|
|
|
- last_page = int(ceil(disks_ret['paging']['total'] / float(page_size)))
|
|
|
- page_length = 5
|
|
|
- pages = list()
|
|
|
- if page < int(ceil(page_length / 2.0)):
|
|
|
- for i in range(1, page_length + 1):
|
|
|
- pages.append(i)
|
|
|
- if i == last_page or last_page == 0:
|
|
|
- break
|
|
|
-
|
|
|
- elif last_page - page < page_length / 2:
|
|
|
- for i in range(last_page - page_length + 1, last_page + 1):
|
|
|
- if i < 1:
|
|
|
- continue
|
|
|
- pages.append(i)
|
|
|
-
|
|
|
- else:
|
|
|
- for i in range(page - page_length / 2, page + int(ceil(page_length / 2.0))):
|
|
|
- pages.append(i)
|
|
|
- if i == last_page or last_page == 0:
|
|
|
- break
|
|
|
-
|
|
|
- return render_template('disks_show.html', disks_ret=disks_ret, resource_path=resource_path,
|
|
|
- hosts_mapping_by_node_id=hosts_mapping_by_node_id,
|
|
|
- page=page, page_size=page_size, keyword=keyword, pages=pages, order_by=order_by, order=order,
|
|
|
- last_page=last_page, show_area=show_area, config_ret=config_ret, show_on_host=show_on_host)
|
|
|
+ return render_template('disks_show.html', disks=ret['data']['disks'],
|
|
|
+ resource_path=request.path,
|
|
|
+ hosts_mapping_by_node_id=ret['data']['hosts_mapping_by_node_id'],
|
|
|
+ page=ret['data']['page'], page_size=ret['data']['page_size'], keyword=ret['data']['keyword'],
|
|
|
+ pages=ret['data']['pages'], order_by=ret['data']['order_by'], order=ret['data']['order'],
|
|
|
+ last_page=ret['data']['last_page'], paging=ret['data']['paging'],
|
|
|
+ show_area=ret['data']['show_area'], config=ret['data']['config'],
|
|
|
+ show_on_host=ret['data']['show_on_host'])
|
|
|
|
|
|
|
|
|
def create():
|
|
|
- host_url = request.host_url.rstrip('/')
|
|
|
-
|
|
|
- if request.method == 'POST':
|
|
|
- size = request.form.get('size')
|
|
|
- quantity = request.form.get('quantity')
|
|
|
- remark = request.form.get('remark')
|
|
|
- node_id = request.form.get('node_id')
|
|
|
-
|
|
|
- payload = {
|
|
|
- "size": int(size),
|
|
|
- "quantity": int(quantity),
|
|
|
- "remark": remark,
|
|
|
- "node_id": node_id
|
|
|
- }
|
|
|
-
|
|
|
- url = host_url + '/api/disk'
|
|
|
- headers = {'content-type': 'application/json'}
|
|
|
- r = requests.post(url, data=json.dumps(payload), headers=headers, cookies=request.cookies)
|
|
|
- j_r = json.loads(r.content)
|
|
|
- return render_template('success.html', go_back_url='/disks', timeout=10000, title='提交成功',
|
|
|
- message_title='创建实例的请求已被接受',
|
|
|
- message='您所提交的资源正在创建中。根据所提交资源的数量，需要等待几到十几秒钟。页面将在10秒钟后自动跳转到实例列表页面！')
|
|
|
-
|
|
|
- else:
|
|
|
- config_url = host_url + url_for('api_config.r_get')
|
|
|
- config_ret = requests.get(url=config_url, cookies=request.cookies)
|
|
|
- config_ret = json.loads(config_ret.content)
|
|
|
-
|
|
|
- show_on_host = False
|
|
|
- if config_ret['data']['storage_mode'] == StorageMode.local.value:
|
|
|
- show_on_host = True
|
|
|
-
|
|
|
- return render_template('disk_create.html', show_on_host=show_on_host)
|
|
|
+ return render_template('disk_create.html')
|
|
|
|
|
|
|
|
|
def detail(uuid):
|
James Iter