blob: fe6ebc7ee72cf4e8844785db297421d9786b4483 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
import {Injectable} from '@angular/core';
import {Observable} from 'rxjs';
import {ServiceInfoModel} from './serviceInfo.model';
import {HttpClient, HttpHeaders} from '@angular/common/http';
import { of } from 'rxjs';
import { map } from 'rxjs/operators';
import {Constants} from '../../utils/constants';
import {forkJoin} from "rxjs/observable/forkJoin";
import * as _ from 'lodash';
import {AuditStatus} from "./AuditStatus.model";
@Injectable()
export class ServiceInfoService {
constructor(private _http: HttpClient) {
}
getServicesJobInfo(filterByUser : boolean, showSpinner: boolean = true): Observable<ServiceInfoModel[]> {
let pathQuery = Constants.Path.SERVICES_JOB_INFO_PATH;
let headers = new HttpHeaders({'x-show-spinner': showSpinner.toString()});
return this._http.get<ServiceInfoModel[]>(pathQuery, { headers: headers }).map(res => res );
}
deleteJob(jobId: string): Observable<any> {
let pathQuery = Constants.Path.SERVICES_JOB_INFO_PATH + '/job/' + jobId;
return this._http.delete<any>(pathQuery).map(res => res);
}
hideJob(jobId: string): Observable<any> {
let pathQuery = Constants.Path.SERVICES_JOB_INFO_PATH + '/hide/' + jobId;
return this._http.post<any>(pathQuery, null).map(res => res);
}
getJobAuditStatus(jobData: ServiceInfoModel) : Observable<Object[]>{
let pathQueryBySource: string = Constants.Path.SERVICES_JOB_INFO_PATH + Constants.Path.SERVICES_JOB_AUDIT_PATH + '/' + jobData.jobId + '?source=';
let pathQueryVID: string = pathQueryBySource + 'VID';
let pathQueryMSO: string;
// just call it
if(jobData.aLaCarte) {
let requestParams: string[] = [];
pathQueryMSO = Constants.Path.SERVICES_JOB_INFO_PATH + Constants.Path.SERVICES_JOB_AUDIT_PATH + '/' + jobData.jobId + '/mso';
if (!_.isEmpty(jobData.requestId)) {
requestParams[requestParams.length] = 'requestId=' + jobData.requestId;
}
if (!_.isEmpty(jobData.serviceInstanceId)) {
requestParams[requestParams.length] = 'serviceInstanceId=' + jobData.serviceInstanceId;
}
if (requestParams.length > 0) {
pathQueryMSO += '?' + requestParams.join('&');
}
}
else {
pathQueryMSO = pathQueryBySource + 'MSO';
}
let vidObs = this._http.get(pathQueryVID);
let msoObs = this._http.get(pathQueryMSO);
return forkJoin([vidObs, msoObs]);
}
getInstanceAuditStatus(instanceId: string, type :string) : Observable<AuditStatus[]>{
let pathQuery: string = Constants.Path.SERVICES_JOB_INFO_PATH + Constants.Path.SERVICES_JOB_AUDIT_PATH + '/' + type + '/' + instanceId + '/mso';
return this._http.get<any>(pathQuery).map(res => res);
}
getAuditStatusForRetry(trackById: string) : Observable<AuditStatus>{
let pathQuery: string = Constants.Path.AUDIT_STATUS_FOR_RETRY_PATH + '/' + trackById ;
return this._http.get<any>(pathQuery).map(res => res);
}
}
|
