5e28f2d65a608671e51a14ef1d85f8cca9459398
[usecase-ui.git] /
1 import { Component, OnInit, Input, Output, EventEmitter, ViewChild } from '@angular/core';
2 import { NzMessageService } from 'ng-zorro-antd';
3 import { SlicingTaskServices } from '../../../../../core/services/slicingTaskServices';
4
5 @Component({
6   selector: 'app-slicing-task-model',
7   templateUrl: './slicing-task-model.component.html',
8   styleUrls: ['./slicing-task-model.component.less']
9 })
10 export class SlicingTaskModelComponent implements OnInit {
11   @Input() showDetail: boolean;
12   @Input() moduleTitle: string;
13   @Input() taskId: string;
14   @Output() cancel = new EventEmitter<object>();
15   @ViewChild('notification') notification1: any;
16
17   constructor(private http: SlicingTaskServices, private message: NzMessageService) { }
18
19   // 配置审核详情
20   checkDetail: any[] = [{}];
21   //业务需求信息
22   businessRequirement: any[] = [];
23   //匹配NST信息 
24   NSTinfo: object[] = [{}];
25   // 共享切片实例
26   selectedServiceId: string;
27   selectedServiceName: string;
28   slicingInstances: any;
29   // 子网实例
30   slicingSubnet: any[] = [
31     {
32       title: 'An',
33       context: 'an',
34       slicingId: '',
35       slicingName: '',
36       total: 0,
37       currentPage: '1',
38       pageSize: '10',
39       isLoading: false,
40       flag: false,
41       instances: []
42     },
43     {
44       title: 'Tn',
45       context: 'tn',
46       slicingId: '',
47       slicingName: '',
48       total: 0,
49       currentPage: '1',
50       pageSize: '10',
51       isLoading: false,
52       flag: false,
53       instances: []
54     },
55     {
56       title: 'Cn',
57       context: 'cn',
58       slicingId: '',
59       slicingName: '',
60       total: 0,
61       currentPage: '1',
62       pageSize: '10',
63       isLoading: false,
64       flag: false,
65       instances: []
66     }
67   ]
68   isDisabled: boolean = true;
69   // 子网参数
70   isShowParams: boolean;
71   paramsTitle: string;
72   params: any;
73   // 获取数据loading
74   isSpinning: boolean = false;
75   loading: boolean = false;
76
77
78   ngOnInit() { }
79
80   ngOnChanges() {
81     if (this.showDetail) {
82       this.isSpinning = true;
83       this.getautidInfo();
84     } else {
85       this.isDisabled = true;
86     }
87   }
88
89   getautidInfo(): void {
90     this.http.getAuditInfo(this.taskId).subscribe( res => {
91       const { result_header: { result_code, result_message } } = res;
92       this.isSpinning = false;
93       if (+result_code === 200) {
94         const {
95           task_id,
96           task_name,
97           create_time,
98           processing_status,
99           business_demand_info,
100           nst_info,
101           nsi_nssi_info,
102           business_demand_info: { service_snssai, coverage_area_ta_list }
103         } = res.result_body;
104         const {
105           suggest_nsi_id,
106           suggest_nsi_name,
107           an_suggest_nssi_id,
108           an_suggest_nssi_name,
109           tn_suggest_nssi_id,
110           tn_suggest_nssi_name,
111           cn_suggest_nssi_id,
112           cn_suggest_nssi_name,
113           an_latency,
114           an_5qi,
115           an_script_name,
116           an_coverage_area_ta_list,
117           tn_latency,
118           tn_bandwidth,
119           tn_script_name,
120           cn_service_snssai,
121           cn_resource_sharing_level,
122           cn_ue_mobility_level,
123           cn_latency,
124           cn_max_number_of_ues,
125           cn_activity_factor,
126           cn_exp_data_rate_dl,
127           cn_exp_data_rate_ul,
128           cn_area_traffic_cap_dl,
129           cn_area_traffic_cap_ul,
130           cn_script_name
131         } = nsi_nssi_info;
132         // 处理配置审核详情数据
133         this.checkDetail = [{ task_id, task_name, create_time, processing_status, service_snssai }];
134         // 业务需求信息数据
135         business_demand_info.area = coverage_area_ta_list.map(item => {
136           item = item.split(';').join(' - ')
137           return item
138         })
139         // 前端模拟数据
140         let areaList = ["Haidian District;Beijing;Beijing", "Xicheng District;Beijing;Beijing", "Changping District;Beijing;Beijing"].map(item => {
141           item = item.split(';').join(' - ')
142           return item
143         })
144         this.businessRequirement = [{ ...business_demand_info, area: areaList }];
145         // 匹配NST信息
146         this.NSTinfo = [nst_info];
147         // 共享切片实例
148         this.selectedServiceId = suggest_nsi_id;
149         this.selectedServiceName = suggest_nsi_name;
150         if (!this.selectedServiceId || !this.selectedServiceName) {
151           this.isDisabled = false;
152         }
153         this.slicingInstances = {
154           currentPage: '1',
155           pageSize: '10',
156           isLoading: false,
157           total: 0,
158           flag: false,
159           list: [{
160             service_instance_id: this.selectedServiceId,
161             service_instance_name: this.selectedServiceName
162           }]
163         }
164         // 子网实例
165         let subnetData = { an_suggest_nssi_id, an_suggest_nssi_name, tn_suggest_nssi_id, tn_suggest_nssi_name, cn_suggest_nssi_id, cn_suggest_nssi_name };
166         this.subnetDataFormatting(subnetData, 0);
167         // 前端模拟数据
168         let area = ["Beijing;Beijing;Haidian District", "Beijing;Beijing;Xicheng District", "Beijing;Beijing;Changping District"]
169         // this.slicingSubnet[0].params = { an_latency, an_5qi, an_coverage_area_ta_list } 
170         this.slicingSubnet[0].params = { an_latency, an_5qi, an_script_name, an_coverage_area_ta_list: area }
171         this.slicingSubnet[1].params = { tn_latency, tn_bandwidth, tn_script_name };
172         this.slicingSubnet[2].params = {
173           cn_service_snssai,
174           cn_resource_sharing_level,
175           cn_ue_mobility_level,
176           cn_latency,
177           cn_max_number_of_ues,
178           cn_activity_factor,
179           cn_exp_data_rate_dl,
180           cn_exp_data_rate_ul,
181           cn_area_traffic_cap_dl,
182           cn_area_traffic_cap_ul,
183           cn_script_name
184         };
185       } else {
186         this.message.error(result_message || 'Failed to get data')
187       }
188     }, ({ status, statusText }) => {
189       this.message.error(status + ' (' + statusText + ')');
190       this.isSpinning = false;
191     })
192   }
193
194   openSlicingInstance(bool: boolean): void {
195     const { total, currentPage, pageSize } = this.slicingInstances;
196     if (bool && !total) {
197       this.slicingInstances.list = [];
198       this.getSlicingInstances(currentPage, pageSize)
199     }
200   }
201
202   getNextPageData(): void {
203     const { total, currentPage, pageSize } = this.slicingInstances;
204     if (total - (+currentPage * +pageSize) > 0) {
205       if (this.slicingInstances.flag) return;
206       this.slicingInstances.flag = true
207       this.getSlicingInstances(currentPage, pageSize)
208       this.slicingInstances.currentPage = (+this.slicingInstances.currentPage + 1).toString();
209     }
210   }
211
212   getSlicingInstances(pageNo: string, pageSize: string): void {
213     this.slicingInstances.isLoading = true;
214     this.http.getSlicingInstance(pageNo, pageSize).subscribe(res => {
215       const { result_header: { result_code, result_message }, result_body } = res;
216       setTimeout(() => {
217         if (+result_code === 200) {
218           const { nsi_service_instances, record_number } = result_body;
219           this.slicingInstances.total = record_number;
220           this.slicingInstances.list.push(...nsi_service_instances);
221         } else {
222           this.message.error(result_message || 'Failed to get slicing instance ID')
223         }
224         this.slicingInstances.isLoading = false;
225         this.slicingInstances.flag = false;
226       }, 2000)
227     }, ({ status, statusText }) => {
228       this.message.error(status + ' (' + statusText + ')');
229       this.slicingInstances.isLoading = false;
230       this.slicingInstances.flag = false;
231     })
232   }
233
234
235   slicingInstanceChange(): void {
236     this.isDisabled = true;
237     this.selectedServiceName = '';
238     // 获取切片子网实例数据
239     this.http.getSlicingSubnetInstance(this.selectedServiceId).subscribe(res => {
240       const { result_header: { result_code, result_message }, result_body, record_number} = res;
241       if (+result_code === 200) {
242         this.subnetDataFormatting(result_body, record_number)
243       } else {
244         this.subnetDataFormatting({}, 1);
245         this.message.error(result_message || 'Failed to get slicing subnet instance ID')
246       }
247     }, ({ status, statusText }) => {
248       this.message.error(status + ' (' + statusText + ')');
249     })
250     this.slicingInstances.list.forEach(item => {
251       if (item.service_instance_id === this.selectedServiceId) {
252         this.selectedServiceName = item.service_instance_name;
253       }
254     })
255   }
256
257   subnetDataFormatting ( subnetData?: any, total?: number): void{
258     const { an_suggest_nssi_id, an_suggest_nssi_name, tn_suggest_nssi_id, tn_suggest_nssi_name, cn_suggest_nssi_id, cn_suggest_nssi_name } = subnetData;
259     this.slicingSubnet[0].slicingId = an_suggest_nssi_id;
260     this.slicingSubnet[0].slicingName = an_suggest_nssi_name;
261     this.slicingSubnet[0].total = total;
262     this.slicingSubnet[0].currentPage = '1';
263     this.slicingSubnet[0].instances = [{
264       service_instance_id: an_suggest_nssi_id,
265       service_instance_name: an_suggest_nssi_name
266     }];
267
268     this.slicingSubnet[1].slicingId = tn_suggest_nssi_id;
269     this.slicingSubnet[1].slicingName = tn_suggest_nssi_name;
270     this.slicingSubnet[1].total = total;
271     this.slicingSubnet[1].currentPage = '1';
272     this.slicingSubnet[1].instances = [{
273       service_instance_id: tn_suggest_nssi_id,
274       service_instance_name: tn_suggest_nssi_name
275     }];
276
277     this.slicingSubnet[2].slicingId = cn_suggest_nssi_id;
278     this.slicingSubnet[2].slicingName = cn_suggest_nssi_name;
279     this.slicingSubnet[2].total = total;
280     this.slicingSubnet[2].currentPage = '1';
281     this.slicingSubnet[2].instances = [{
282       service_instance_id: cn_suggest_nssi_id,
283       service_instance_name: cn_suggest_nssi_name
284     }];
285   }
286
287   resetSlicingInstance(): void {
288     this.selectedServiceId = '';
289     this.selectedServiceName = '';
290     this.slicingSubnet.map(item => {
291       item.slicingId = '';
292       item.slicingName = '';
293     })
294     this.isDisabled = false;
295   }
296
297   openSubnetInstances(bool: boolean, instance: any): void {
298     if (bool && !instance.total) {
299       instance.instances = []
300       this.getSubnetInstances(instance)
301     }
302   }
303
304   getNextPageSubnet(instance: any): void {
305     const { total, currentPage, pageSize } = instance;
306     if (total - (+currentPage * +pageSize) > 0) {
307       if (instance.flag) return;
308       instance.flag = true;
309       this.getSubnetInstances(instance);
310       let count = +instance.currentPage;
311       instance.currentPage = (++count).toString();
312     }
313   }
314
315   getSubnetInstances(instance: any): void {
316     instance.isLoading = true;
317     const { context, currentPage, pageSize } = instance;
318     this.http.getSubnetInContext(context, currentPage, pageSize).subscribe(res => {
319       const { result_header: { result_code, result_message }, result_body } = res;
320       if (+result_code === 200) {
321         const { nssi_service_instances, record_number } = result_body;
322         this.slicingSubnet.map(item => {
323           if (item.context === context) {
324             item.total = record_number;
325             item.instances.push(...nssi_service_instances);
326           }
327         })
328       } else {
329         this.message.error(result_message || 'Failed to get slicing subnet instance ID');
330       }
331       instance.isLoading = false;
332       instance.flag = false;
333     }, ({ status, statusText }) => {
334       this.message.error(status + ' (' + statusText + ')');
335       instance.isLoading = false;
336       instance.flag = false;
337     })
338   }
339
340   slicingSubnetChange(instance: any): void {
341     instance.slicingName = ''
342     instance.instances.forEach(item => {
343       if (instance.slicingId === item.service_instance_id) {
344         instance.slicingName = item.service_instance_name;
345       }
346     })
347   }
348
349   restSubnetInstance(instance: any): void {
350     instance.slicingId = '';
351     instance.slicingName = '';
352   }
353
354   showParamsModel(item: any): void {
355     this.isShowParams = true;
356     this.paramsTitle = item.title;
357     this.params = item.params
358   }
359
360   changeParams(params: any): void {
361     const index = this.paramsTitle === 'An' ? 0 : (this.paramsTitle === 'Tn' ? 1 : 2);
362     this.slicingSubnet[index].params = params
363   }
364
365   handleCancel(bool: boolean = false) {
366     this.showDetail = false;
367     this.cancel.emit({ showDetail: this.showDetail, bool });
368   }
369   handleOk() {
370     this.loading = true;
371     const { selectedServiceId, selectedServiceName, slicingSubnet, checkDetail, businessRequirement, NSTinfo } = this;
372     const nsi_nssi_info: object = {
373       suggest_nsi_id: selectedServiceId,
374       suggest_nsi_name: selectedServiceName,
375       an_suggest_nssi_id: slicingSubnet[0].slicingId,
376       an_suggest_nssi_name: slicingSubnet[0].slicingName,
377       ...slicingSubnet[0].params,
378       tn_suggest_nssi_id: slicingSubnet[1].slicingId,
379       tn_suggest_nssi_name: slicingSubnet[1].slicingName,
380       ...slicingSubnet[1].params,
381       cn_suggest_nssi_id: slicingSubnet[2].slicingId,
382       cn_suggest_nssi_name: slicingSubnet[2].slicingName,
383       ...slicingSubnet[2].params,
384     }
385     delete businessRequirement[0].area
386     let reqBody = { ...checkDetail[0], business_demand_info: businessRequirement[0], nst_info: NSTinfo[0], nsi_nssi_info };
387     delete reqBody.service_snssai;
388     this.http.submitSlicing(reqBody).subscribe(res => {
389       const { result_header: { result_code } } = res;
390       if (+result_code === 200) {
391         this.notification1.notificationSuccess('Task', 'Sumbit', this.taskId)
392       } else {
393         this.notification1.notificationFailed('Task', 'Sumbit', this.taskId)
394       }
395       this.loading = false;
396       this.handleCancel(true);
397     }, ({ status, statusText }) => {
398       this.message.error(status + ' (' + statusText + ')');
399       this.loading = false;
400     })
401   }
402 }