D-Net

import {Component, ViewChild, ElementRef} from '@angular/core';

import {Observable}       from 'rxjs/Observable';

import {Subject} from 'rxjs/Subject';

import {ActivatedRoute, Router} from '@angular/router';

import {OrganizationService} from '../../services/organization.service';

import {OrganizationInfo} from '../../utils/entities/organizationInfo';

import {ReportsService} from '../../services/reports.service';

import {FetchPublications} from '../../utils/fetchEntitiesClasses/fetchPublications.class';

import {FetchProjects} from '../../utils/fetchEntitiesClasses/fetchProjects.class';

import {FetchDataproviders} from '../../utils/fetchEntitiesClasses/fetchDataproviders.class';

import {SearchPublicationsService} from '../../services/searchPublications.service';

import {SearchDataprovidersService} from '../../services/searchDataproviders.service';

import {SearchProjectsService} from '../../services/searchProjects.service';

import { Meta} from '../../../angular2-meta';

import {OpenaireProperties, ErrorCodes} from '../../utils/properties/openaireProperties';

import {SearchingProjectsTabComponent} from '../landing-utils/searchingProjectsInTab.component';

import {RouterHelper} from '../../utils/routerHelper.class';

import {ModalLoading} from '../../utils/modal/loading.component';

import {AlertModal} from '../../utils/modal/alert';

import {PiwikService} from '../../utils/piwik/piwik.service';

import {StringUtils} from '../../utils/string-utils.class';

@Component({

    selector: 'organization',

    templateUrl: 'organization.component.html',

})

export class OrganizationComponent {

    public organizationInfo: OrganizationInfo;

    public organizationId: string;

    // Message variables

    public warningMessage = "";

    public errorMessage = "";

    public showLoading: boolean = true;

    // CSV variables

    public downloadURLAPI: string;

    public csvProjectParamsHead: string;

    public csvPublicationParamsHead: string;

    public csvParamsTail: string;

    // Active tab variable for responsiveness

    public activeTab: string = "Publications";

    // Variables for publications, projects, dataproviders tabs

    public fetchPublications: FetchPublications;

    public linkToSearchPublications: string = "";

    public fetchProjects: FetchProjects;

    public fetchDataproviders : FetchDataproviders;

    public linkToSearchDataproviders:string = "";

    //public projectFunders:string[] = [];

    // Variables for projects query (query results only if projects tab is clicked)

    public projectsClicked: boolean = false;

    @ViewChild (SearchingProjectsTabComponent) searchingProjectsTabComponent : SearchingProjectsTabComponent ;

    @ViewChild (ModalLoading) loading : ModalLoading ;

    // Alert box when CSV: Project Publications for a funder is requested

    @ViewChild('AlertModalApplyAll') alertApplyAll;

    // Alert box when something is wrong with CSV requests

    @ViewChild('AlertModalCsvError') alertCsvError;

    public routerHelper:RouterHelper = new RouterHelper();

    public errorCodes:ErrorCodes = new ErrorCodes();

    //private projectsNum: number = 0;

    //private fundersSet: Set<string>;

    //private emptyFundersSet: boolean = true;

    // Request results for content providers only the one time (first time tab is clicked)

    private reloadDataproviders: boolean = true;

    // Helper variables to specify funder in downloadPublicationsFile function

    private funder: string;

    private funderId: string;

    private funderCountPublications: number;

    sub: any;

    infoSub: any;

    piwiksub: any;

    downloadFileSub: any;

    downloadFilePiwikSub: any;

    countProjectsSub: any;

    countPublSub: any;

    downloadProjectPublSub: any;

    //private ngUnsubscribe: Subject<void> = new Subject<void>();

    constructor (private element: ElementRef,

                 private _organizationService: OrganizationService,

                 private _piwikService:PiwikService,

                 private  route: ActivatedRoute,

                 private _searchDataprovidersService: SearchDataprovidersService,

                 private _reportsService: ReportsService,

                 private _searchPublicationsService: SearchPublicationsService,

                 private _searchProjectsService: SearchProjectsService, private _meta: Meta,

                 private _router: Router) {

            this.fetchPublications = new FetchPublications(this._searchPublicationsService);

            this.fetchProjects = new FetchProjects(this._searchProjectsService);

            this.fetchDataproviders = new FetchDataproviders(this._searchDataprovidersService);

            this.updateUrl(OpenaireProperties.getBaseLink()+this._router.url);

    }

    ngOnInit() {

        console.info('organization init');

        this.sub =  this.route.queryParams.subscribe(params => {

            this.organizationInfo=null;

            this.updateTitle("Organization");

            this.updateDescription("Organization, country, projects,  search, repositories, open access");

            this.projectsClicked = false;

            this.organizationId = params['organizationId'];

            console.info("Id is :"+this.organizationId);

            if(this.organizationId){

                this.getOrganizationInfo();

            }else{

                this.showLoading = false;

                this.warningMessage="No valid organization id";

            }

            if (typeof document !== 'undefined') {

               this.element.nativeElement.scrollIntoView();

            }

            this.csvParamsTail = '" and relorganizationid exact "'+this.organizationId+'" ))';

        });

        this.downloadURLAPI = OpenaireProperties.getCsvAPIURL();

        this.csvProjectParamsHead = 'format=csv&type=projects&page=0&query=( (oaftype exact project)and (funder exact "';

        //this.csvPublicationParamsHead = 'format=csv-special&type=publications&page=0&query=((((oaftype exact result) and (resulttypeid exact publication)) and (funderid exact ';

    }

    ngOnDestroy() {

      this.sub.unsubscribe();

      if(this.piwiksub){

        this.piwiksub.unsubscribe();

      }

      if(this.infoSub) {

        this.infoSub.unsubscribe();

      }

      if(this.downloadFileSub) {

        this.downloadFileSub.unsubscribe();

      }

      if(this.downloadFilePiwikSub) {

        this.downloadFilePiwikSub.unsubscribe();

      }

      if(this.countProjectsSub) {

        this.countProjectsSub.unsubscribe();

      }

      if(this.countPublSub) {

        this.countPublSub.unsubscribe();

      }

      if(this.downloadProjectPublSub) {

        this.downloadProjectPublSub.unsubscribe();

      }

      /*

      this.ngUnsubscribe.next();

      this.ngUnsubscribe.complete();

      */

    }

    private getOrganizationInfo ()  {

        this.warningMessage = '';

        this.errorMessage=""

        this.showLoading = true;

        this.infoSub = this._organizationService.getOrganizationInfo(this.organizationId).subscribe(

            data => {

                if(data == null) {

                    this.showLoading = false;

                    this.errorMessage = 'No organization found';

                } else {

                    this.organizationInfo = data;

                    this.updateTitle(this.organizationInfo.title.name);

                    this.updateDescription("Organization, country, projects,  search, repositories, open access"+this.organizationInfo.title.name);

                    if(OpenaireProperties.isPiwikTrackEnabled() && (typeof document !== 'undefined')){

                      this.piwiksub = this._piwikService.trackView(this.organizationInfo.title.name).subscribe();

                    }

                    var refineFields:string [] = ["funder"];

                    this.searchPublications();

                     this.fetchProjects.getResultsForOrganizations(this.organizationId, "", 1, 0,refineFields);

                    this.fetchDataproviders.getNumForEntity("organization", this.organizationId);

                    this.showLoading = false;

                    /*let projectsNum = 0;

                    if(this.organizationInfo.projects != undefined) {

                         this.fundersSet = new Set<string>();

                        this.organizationInfo.projects.forEach(function (value, key, map) {

                            projectsNum += value.length;

                            this.fundersSet.add(key);

                        }.bind(this));

                    }

                    this.projectsNum = projectsNum;*/

                }

            },

            err => {

                console.log(err)

                this.errorMessage = 'No organization found';

                this.showLoading = false;

            }

        );

    }

/*

    private getMetrics() {

        console.info("getOrganizationMetrics: component");

        this._organizationService.getMetrics(this.organizationId).subscribe(

         data => {

             this.metrics = data;

         },

         err => {

           console.log(err);

         }

       );

    }

*/

/*

    private handleClick(funder: string) {

         if(this.emptyFundersSet) {

             this.fundersSet.clear();

             this.emptyFundersSet = false;

         }

         if(this.fundersSet.has(funder)) {

             this.fundersSet.delete(funder);

             if(this.fundersSet.size == 0) {

                 this.organizationInfo.projects.forEach(function (value, key, map) {

                     this.fundersSet.add(key);

                 }.bind(this));

                 this.emptyFundersSet = true;

             }

             console.info(funder+" funder deleted");

         } else {

             this.fundersSet.add(funder);

             console.info(funder+" funder added");

         }

     }

*/

     //private getProjectsData(key: string): any {

         //return this.projectsData;

     //}

     private searchPublications() {

       this.fetchPublications.getResultsForEntity("organization", this.organizationId, 1, 10);

       this.linkToSearchPublications = OpenaireProperties.getLinkToAdvancedSearchPublications();// + "?project=" + this.projectId+"&pr=and";

       if(this.fetchPublications.searchUtils.totalResults > 0) {

         //this.activeTab = "Publications";

       } else {

         //this.projectsClicked = true;

       }

     }

     private searchDataproviders() {

       this.fetchDataproviders.getResultsForEntity("organization", this.organizationId, 1, 10);

       this.linkToSearchDataproviders = OpenaireProperties.getLinkToAdvancedSearchDataProviders();

       if(this.fetchDataproviders.searchUtils.totalResults > 0) {

         this.reloadDataproviders = false;

         //this.activeTab = "Content Providers";

       } else {

       }

     }

     public searchDataprovidersInit() {

         if(this.reloadDataproviders && this.fetchDataproviders.searchUtils.totalResults > 0) {

             this.searchDataproviders();

         }

     }

     public downloadFile(url:string){

       console.log("Downloading file: "+ url);

       this.openLoading();

       this.setMessageLoading("Downloading CSV file");

       this.downloadFileSub = this._reportsService.downloadCSVFile(url).subscribe(

           data => {

               this.closeLoading();

               window.open(window.URL.createObjectURL(data));

                if(OpenaireProperties.isPiwikTrackEnabled() && (typeof document !== 'undefined')){

                  this.downloadFilePiwikSub = this._piwikService.trackDownload(url).subscribe();

                }

           },

           err => {

             console.log("Error downloading the file.");

             this.closeLoading();

             this.confirmOpenCsvError();

           },

           () => console.log('Completed file download.'));

     }

     private downloadPublicationsFile(funder: string, funderId:string, count:number){

       console.log("Downloading publications file");

       this.openLoading();

       this.setMessageLoading("Downloading CSV file");

       let response: string[] = [];

       let totalResponse: string = "";

       let projects = [];

       let counter: number = count;

       let title: boolean = false;

       this.countProjectsSub = this._searchProjectsService.getProjectsForOrganizations(this.organizationId,' and (funder exact "'+ funderId + '" ) ',1,count,[]).subscribe(

           data =>

               {

                 projects = data[1];

                  for(let index=0; index < projects.length; index++) {

                      this.countPublSub = this._searchPublicationsService.numOfEntityPublications(projects[index].id, "project").subscribe(

                          data =>

                              {

                                  // let index: number = this.organizationInfo.projects.get(funder).indexOf(project);

                                  let url: string;

                                  if(index == 0 || !title) {

                                      url = this.downloadURLAPI+"projects/"+projects[index].id+"/publications?format=csv-special&size="+data;

                                  } else {

                                      url = this.downloadURLAPI+"projects/"+projects[index].id+"/publications?format=csv-special-notitle&size="+data;

                                  }

                                  if(data == 0) {   // if no publications for this project

                                      counter--;

                                      response[index] = "";

                                      if(counter == 0) {

                                          for(let i=0; i<count; i++) {

                                              if(response[i] != "") {

                                                  totalResponse += response[i];

                                              }

                                          }

                                          this.closeLoading();

                                          window.open(window.URL.createObjectURL(new Blob([totalResponse], { type: 'text/csv' })));

                                          // if(OpenaireProperties.isPiwikTrackEnabled() && (typeof document !== 'undefined')){

                                          //   this._piwikService.trackDownload(url).subscribe();

                                          // }

                                      }

                                  } else {

                                      title = true;

                                      this.downloadProjectPublSub = this._reportsService.getCSVResponse(url).subscribe(

                                          data =>

                                              {

                                                  counter--;

                                                  response[index] = data;

                                                  if(counter == 0) {

                                                      for(let i=0; i<count; i++) {

                                                          if(response[i] != "") {

                                                              totalResponse += response[i];

                                                          }

                                                      }

                                                      this.closeLoading();

                                                      window.open(window.URL.createObjectURL(new Blob([totalResponse], { type: 'text/csv' })));

                                                      // if(OpenaireProperties.isPiwikTrackEnabled() && (typeof document !== 'undefined')){

                                                      //   this._piwikService.trackDownload(url).subscribe();

                                                      // }

                                                  }

                                              },

                                          err => {

                                            console.log("Error downloading the file.");

                                            this.closeLoading();

                                            this.confirmOpenCsvError();

                                          },

                                          () => console.log('Completed file download.')

                                      );

                                  }

                              },

                          err => console.log("Error getting number of publications for project."));

                  }//);

               },

           err => {

            console.log("Error getting projects project.");

            this.closeLoading();

            this.confirmOpenCsvError();

          }

        );

      //  let counter: number = this.organizationInfo.projects.get(funder).length;

       //

      //  for(let project of this.organizationInfo.projects.get(funder)) {

      //       this._searchPublicationsService.numOfEntityPublications(project.id, "projects/").subscribe(

      //           data =>

      //               {

      //                   let index: number = this.organizationInfo.projects.get(funder).indexOf(project);

       //

      //                   let url: string;

      //                   if(index == 0) {

      //                       url = this.downloadURLAPI+"projects/"+project.id+"/publications?format=csv-special&size="+data;

      //                   } else {

      //                       url = this.downloadURLAPI+"projects/"+project.id+"/publications?format=csv-special-notitle&size="+data;

      //                   }

       //

      //                   this._reportsService.getCSVResponse(url).subscribe(

      //                       data =>

      //                           {

      //                               counter--;

       //

      //                               response[index] = data;

       //

      //                               if(counter == 0) {

      //                                   for(let i=0; i<this.organizationInfo.projects.get(funder).length; i++) {

      //                                       totalResponse += response[i]+"\n";

      //                                   }

      //                                   window.open(window.URL.createObjectURL(new Blob([totalResponse], { type: 'text/csv' })));

      //                               }

      //                           },

      //                       error => console.log("Error downloading the file."),

      //                       () => console.log('Completed file download.'));

      //               },

      //           error => console.log("Error getting number of publications for project."));

        // }//);

    }

    private updateDescription(description:string){

      this._meta.updateMeta("description", description);

      this._meta.updateProperty("og:description", description);

    }

    private updateTitle(title:string){

      var _prefix ="OpenAIRE | ";

      var _title = _prefix + ((title.length> 50 ) ?title.substring(0,50):title);

      this._meta.setTitle(_title );

      this._meta.updateProperty("og:title",_title);

    }

    private updateUrl(url:string){

      this._meta.updateProperty("og:url", url);

    }

    private openLoading(){

      if(this.loading){

        this.loading.open();

      }

    }

    private closeLoading(){

      if(this.loading){

        this.loading.close();

      }

    }

    private setMessageLoading(message: string){

      if(this.loading){

        this.loading.message = message;

      }

    }

    public confirmOpenApplyAll(funder: string, funderId:string, funderCountPublications:number){

      this.alertApplyAll.cancelButton = true;

      this.alertApplyAll.okButton = true;

      this.alertApplyAll.alertTitle = "CSV FILE";

      this.alertApplyAll.message = "Do you wish to download a CSV file? Note that this process may take a while.";

      this.alertApplyAll.okButtonText = "Yes";

      this.alertApplyAll.cancelButtonText = "No";

      this.alertApplyAll.open();

      this.funder = funder;

      this.funderId = funderId;

      this.funderCountPublications = funderCountPublications;

    }

    public confirmCloseApplyAll(data){

         this.downloadPublicationsFile(this.funder, this.funderId, this.funderCountPublications);

    }

    public confirmOpenCsvError(){

      this.alertCsvError.cancelButton = false;

      this.alertCsvError.okButton = true;

      this.alertCsvError.alertTitle = "ERROR DOWNLOADING CSV FILE";

      this.alertCsvError.message = "There was an error in csv downloading. Please try again later.";

      this.alertCsvError.okButtonText = "OK";

      this.alertCsvError.open();

    }

    encodeURI(input: string): string {

      return StringUtils.URIEncode(input);

    }

}