D-Net

import {Component, EventEmitter, OnDestroy, OnInit, Output} from '@angular/core';

import {DialogService} from 'primeng/dynamicdialog';

import {FileTableDialogComponent} from './file-table-dialog/file-table-dialog.component';

import {takeUntil} from 'rxjs/operators';

import {interval, Observable, Subject, Subscription} from 'rxjs';

import {InvoiceDownloadSchedulerService} from '../../../../shared/services/invoice-download-scheduler.service';

import {DownloadProcessTemp} from '../../../../shared/models/download-process-temp.interafce';

import {SchedulerCriteriaInterface} from '../../../../shared/models/scheduler-criteria.interface';

import { RealTimeExecution } from 'src/app/shared/models/real-time-execution.interface';

import { AuthService } from 'src/app/shared/services/auth.service';

import { NotificationsHandlingService } from 'src/app/shared/services/notifications-handling/notifications-handling.service';

import { USER_RIGHTS } from 'src/app/shared/enums/USER_RIGHTS.enum';

@Component({

  selector: 'app-file-download-real-time-monitor',

  templateUrl: './file-download-real-time-monitor.component.html',

  styleUrls: ['./file-download-real-time-monitor.component.scss']

})

export class FileDownloadRealTimeMonitorComponent implements OnInit, OnDestroy {

  @Output() executionInfo: EventEmitter<RealTimeExecution> = new EventEmitter<RealTimeExecution>(true);

  downloadProcessTemp: DownloadProcessTemp[] = [];

  loading = true;

  totalRecords: any;

  status : string = '';

  destroyed$ = new Subject();

  tableValues: DownloadProcessTemp[] = [];

  private subscription: Subscription;

  private criteria: SchedulerCriteriaInterface;

  private currentPage: number;

  private source: Observable<number>;

  constructor(private dialogService: DialogService, private fileService: InvoiceDownloadSchedulerService, private auth: AuthService, private notificationService: NotificationsHandlingService) {

  }

  ngOnInit(): void {

    this.currentPage = 1;

    this.fileService.getAllByUserId(this.auth.userDetails.id).subscribe(documentsDownloaded => {

      this.downloadProcessTemp = documentsDownloaded;

      documentsDownloaded.sort((first, second) => {

        return (first.status > second.status) ? 1 : -1;

      });

      console.log(documentsDownloaded);

      this.tableValues = documentsDownloaded;

      console.log(Math.min(documentsDownloaded.length, 10));

      console.log(this.tableValues);

      this.addInfoForExecutionInfo(this.tableValues);

    });

    this.source = interval(2000);

    this.subscription = this.source.subscribe(() => {

      this.downloadData();

    });

  }

  showResultsTable(downloadProcessTemp: DownloadProcessTemp): void {

    this.dialogService.open(FileTableDialogComponent, {

      data: [downloadProcessTemp]

    });

  }

  reschedule(downloadProcessTemp: DownloadProcessTemp): void {

    this.fileService.reschedule(String(downloadProcessTemp.iPowerClientCode)).subscribe(result => {

      this.notificationService.showRescheduleSuccess();

    });

    this.downloadData();

  }

  doNothing(downloadProcessTemp: any): void {

  }

  highPriority(downloadProcessTemp: DownloadProcessTemp): void {

    this.fileService.highPriority(String(downloadProcessTemp.iPowerClientCode)).subscribe(result => {

      this.notificationService.showHighPrioritySuccess();

    });

    this.downloadData();

  }

  searchByCriteria(criteria: SchedulerCriteriaInterface): void {

    this.criteria = criteria;

    console.log('criteria', criteria);

    const downloadProcessTemps: DownloadProcessTemp[] = [];

    this.downloadProcessTemp.forEach(x => {

      console.log(x.iPowerClientCode , criteria);

      console.log((criteria.status !== undefined && criteria.status !== null ? criteria.status === x.status : true)

        && (criteria.iPowerClientCode !== undefined && criteria.iPowerClientCode !== null &&

        criteria.iPowerClientCode.trim() !== '' ? criteria.iPowerClientCode === x.iPowerClientCode : true));

      console.log(x.iPowerClientCode, x.status);

      if ((criteria.status !== undefined && criteria.status !== null ? criteria.status === x.status : true)

        && (criteria.iPowerClientCode !== undefined && criteria.iPowerClientCode !== null &&

        criteria.iPowerClientCode.trim() !== '' ? criteria.iPowerClientCode === x.iPowerClientCode : true)) {

        console.log(x);

        downloadProcessTemps.push(x);

      }

    });

    console.log(Math.min(downloadProcessTemps.length, 10 * this.currentPage));

    this.tableValues = downloadProcessTemps;

    this.addInfoForExecutionInfo(this.tableValues);

  }

  ngOnDestroy(): void {

    this.destroyed$.next();

    this.destroyed$.complete();

    this.subscription.unsubscribe();

  }

  private downloadData(): void {

    this.fileService.getAllByUserId(this.auth.userDetails.id).subscribe(documentsDownloaded => {

      this.downloadProcessTemp = documentsDownloaded;

      console.log(this.downloadProcessTemp);

      documentsDownloaded.sort((first, second) => {

        return (first.status > second.status) ? 1 : -1;

      });

      if (this.criteria) {

        this.searchByCriteria(this.criteria);

      } else {

        this.tableValues = documentsDownloaded.slice(0, Math.min(documentsDownloaded.length, 10 * this.currentPage));

      }

    });

  }

  onPageChange(event: any): void {

    // TODO implement method that changes the pages

    console.log(event);

    this.currentPage = event.first / event.rows;

    this.downloadData();

  }

  addInfoForExecutionInfo(value: DownloadProcessTemp[]) {

    let sum = 0;

    value.forEach((element) => {

      sum = sum + element.results;

      if(element.status == 'Working' && element.status != undefined){

        this.status = element.iPowerClientName;

      }

  });

  console.log(sum);

  if(this.status != undefined){

    this.executionInfo.emit({ receivedFiles: sum ,status: this.status });

  }

  }

  canRescheculeUA() : boolean {

    return this.auth.userRights.find(rdc => USER_RIGHTS.A04.isGrantedToUser(rdc.rights)) != null;

  }

}