1 package org.onap.vid.job.impl;
3 import com.google.common.collect.ImmutableMap;
4 import org.onap.vid.job.Job;
5 import org.onap.vid.job.JobAdapter;
6 import org.onap.vid.job.JobType;
7 import org.onap.vid.model.JobModel;
8 import org.springframework.stereotype.Component;
11 import java.util.UUID;
14 public class JobAdapterImpl implements JobAdapter {
17 public JobModel toModel(Job job) {
18 JobModel jobModel = new JobModel();
19 jobModel.setUuid(job.getUuid());
20 jobModel.setStatus(job.getStatus());
21 jobModel.setTemplateId(job.getTemplateId());
26 public Job createServiceInstantiationJob(JobType jobType, AsyncJobRequest request, UUID templateId, String userId, String optimisticUniqueServiceInstanceName, Integer indexInBulk){
27 JobDaoImpl job = createJob(jobType, Job.JobStatus.PENDING , userId);
28 job.setSharedData(new JobSharedData(job.getUuid(), userId, request));
29 job.setTypeAndData(jobType, ImmutableMap.of(
30 "optimisticUniqueServiceInstanceName", optimisticUniqueServiceInstanceName
32 job.setTemplateId(templateId);
33 job.setIndexInBulk(indexInBulk);
38 public Job createChildJob(JobType jobType, Job.JobStatus jobStatus, AsyncJobRequest request, JobSharedData parentSharedData, Map<String, Object> jobData) {
39 JobDaoImpl job = createJob(jobType, jobStatus , parentSharedData.getUserId());
40 job.setSharedData(new JobSharedData(job.getUuid(), request, parentSharedData));
41 job.setTypeAndData(jobType, jobData);
45 protected JobDaoImpl createJob(JobType jobType, Job.JobStatus jobStatus, String userId) {
46 JobDaoImpl job = new JobDaoImpl();
47 job.setTypeAndData(jobType, null);
48 job.setStatus(jobStatus);
49 job.setUuid(UUID.randomUUID());
50 job.setUserId(userId);