1 files changed, 140 insertions, 0 deletions
diff --git a/so-admin-cockpit-monitoring-workflow/so-admin-cockpit-monitoring-workflow-ui/src/main/frontend/src/app/home/home.component.ts b/so-admin-cockpit-monitoring-workflow/so-admin-cockpit-monitoring-workflow-ui/src/main/frontend/src/app/home/home.component.ts
new file mode 100644
index 0000000..01e6899
--- /dev/null
+++ b/so-admin-cockpit-monitoring-workflow/so-admin-cockpit-monitoring-workflow-ui/src/main/frontend/src/app/home/home.component.ts
@@ -0,0 +1,140 @@
+/**
+============LICENSE_START=======================================================
+ Copyright (C) 2018 Ericsson. All rights reserved.
+================================================================================
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+ limitations under the License.
+
+SPDX-License-Identifier: Apache-2.0
+============LICENSE_END=========================================================
+
+@authors: ronan.kenny@ericsson.com, waqas.ikram@ericsson.com, andrei.barcovschi@ericsson.com
+*/
+
+import { Component, OnInit, ViewChild, ElementRef, Input, ViewEncapsulation } from '@angular/core';
+import { DataService } from '../data.service';
+import { ActivatedRoute, Router } from "@angular/router";
+import { BpmnInfraRequest } from '../model/bpmnInfraRequest.model';
+import { ProcessInstanceId } from '../model/processInstanceId.model';
+import { ToastrNotificationService } from '../toastr-notification-service.service';
+import { MatSelectModule } from '@angular/material/select';
+import { FormsModule, FormControl } from '@angular/forms';
+import { SearchData } from '../model/searchData.model';
+import { MatDatepickerModule } from '@angular/material/datepicker';
+import { SearchRequest } from '../model/SearchRequest.model';
+import { NgxSpinnerService } from 'ngx-spinner';
+import { MatFormFieldModule, MatInputModule, MatPaginator, MatSort, MatTableDataSource } from '@angular/material';
+import { Constants } from './home.constant';
+
+@Component({
+  selector: 'app-home',
+  templateUrl: './home.component.html',
+  styleUrls: ['./home.component.scss'],
+  encapsulation: ViewEncapsulation.None
+})
+
+export class HomeComponent {
+
+  totalVal = 0;
+  completeVal = 0;
+  inProgressVal = 0;
+  failedVal = 0;
+  pendingVal = 0;
+  unlockedVal = 0;
+  percentageComplete = 0;
+  percentageFailed = 0;
+  percentageInProg = 0;
+  percentagePending = 0;
+  percentageUnlocked = 0;
+
+  options = Constants.OPTIONS;
+  statusOptions = Constants.STATUS_OPTIONS;
+  hourOptions = Constants.HOUR_OPTIONS;
+  minuteOptions = Constants.MINUTE_OPTIONS;
+  displayedColumns = Constants.DISPLAYED_COLUMNS;
+  pageSizeOptions = Constants.DEFAULT_PAGE_SIZE_OPTIONS;
+
+  searchData: SearchData;
+  startingDate: Date;
+  processData: MatTableDataSource<BpmnInfraRequest>;
+
+  @ViewChild(MatPaginator) paginator: MatPaginator;
+  @ViewChild(MatSort) sort: MatSort;
+
+  constructor(private route: ActivatedRoute, private data: DataService,
+    private router: Router, private popup: ToastrNotificationService,
+    private spinner: NgxSpinnerService) {
+    this.searchData = new SearchData();
+  }
+
+  makeCall() {
+    this.spinner.show();
+
+    var search = this.searchData.getSearchRequest().subscribe((result: SearchRequest) => {
+
+      this.data.getBpmnInfraRequest(result.getFilters(), result.getStartTimeInMilliseconds(), result.getEndTimeInMilliseconds())
+        .subscribe((data: BpmnInfraRequest[]) => {
+          this.spinner.hide();
+          var processData: BpmnInfraRequest[] = data;
+          this.processData = new MatTableDataSource<BpmnInfraRequest>(processData);
+          this.processData.sort = this.sort;
+          this.processData.paginator = this.paginator;
+          this.processData.paginator.firstPage();
+
+          this.popup.info("Number of records found: " + data.length)
+
+          // Calculate Statistics for Service Statistics tab
+          this.completeVal = processData.filter(i => i.requestStatus === "COMPLETE").length;
+          this.inProgressVal = processData.filter(i => i.requestStatus === "IN_PROGRESS").length;
+          this.failedVal = processData.filter(i => i.requestStatus === "FAILED").length;
+          this.pendingVal = processData.filter(i => i.requestStatus === "PENDING").length;
+          this.unlockedVal = processData.filter(i => i.requestStatus === "UNLOCKED").length;
+          this.totalVal = processData.length;
+
+          // Calculate percentages to 2 decimal places and compare to 0 to avoid NaN error
+          if (this.totalVal != 0) {
+            this.percentageComplete = Math.round(((this.completeVal / this.totalVal) * 100) * 100) / 100;
+            this.percentageFailed = Math.round(((this.failedVal / this.totalVal) * 100) * 100) / 100;
+            this.percentageInProg = Math.round(((this.inProgressVal / this.totalVal) * 100) * 100) / 100;
+            this.percentagePending = Math.round(((this.pendingVal / this.totalVal) * 100) * 100) / 100;
+            this.percentageUnlocked = Math.round(((this.unlockedVal / this.totalVal) * 100) * 100) / 100;
+          }
+          console.log("COMPLETE: " + this.completeVal);
+          console.log("FAILED: " + this.failedVal);
+        }, error => {
+          console.log(error);
+          this.popup.error("Unable to perform search Error code:" + error.status);
+          this.spinner.hide();
+        });
+    }, error => {
+      console.log("Data validation error " + error);
+      this.popup.error(error);
+      this.spinner.hide();
+    });
+  }
+
+  getProcessInstanceId(requestId: string) {
+    this.spinner.show();
+
+    var response = this.data.getProcessInstanceId(requestId).subscribe((data) => {
+      if (data.status == 200) {
+        this.spinner.hide();
+        var processInstanceId = (data.body as ProcessInstanceId).processInstanceId;
+        this.router.navigate(['/details/' + processInstanceId]);
+      } else {
+        this.popup.error('No process instance id found: ' + requestId);
+        this.spinner.hide();
+        console.log('No process instance id found: ' + requestId);
+      }
+    });
+  }
+}