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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
/*******************************************************************************
* Copyright (c) 2015 Boeing.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Boeing - initial API and implementation
*******************************************************************************/
package org.eclipse.osee.ats.core.client.task;
import java.util.Collection;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.Response.Status;
import org.eclipse.osee.ats.api.data.AtsArtifactTypes;
import org.eclipse.osee.ats.api.data.AtsRelationTypes;
import org.eclipse.osee.ats.api.task.AbstractAtsTaskService;
import org.eclipse.osee.ats.api.task.AtsTaskEndpointApi;
import org.eclipse.osee.ats.api.task.JaxAtsTask;
import org.eclipse.osee.ats.api.task.JaxAtsTasks;
import org.eclipse.osee.ats.api.task.NewTaskData;
import org.eclipse.osee.ats.api.task.NewTaskDatas;
import org.eclipse.osee.ats.api.user.IAtsUser;
import org.eclipse.osee.ats.api.util.IAtsChangeSet;
import org.eclipse.osee.ats.api.workflow.IAtsTask;
import org.eclipse.osee.ats.api.workflow.IAtsTeamWorkflow;
import org.eclipse.osee.ats.core.client.IAtsClient;
import org.eclipse.osee.ats.core.client.internal.AtsClientService;
import org.eclipse.osee.ats.core.client.team.TeamWorkFlowArtifact;
import org.eclipse.osee.ats.core.client.util.AtsTaskCache;
import org.eclipse.osee.ats.core.util.AtsUtilCore;
import org.eclipse.osee.framework.core.enums.DeletionFlag;
import org.eclipse.osee.framework.core.model.event.DefaultBasicGuidArtifact;
import org.eclipse.osee.framework.core.model.event.DefaultBasicUuidRelation;
import org.eclipse.osee.framework.jdk.core.type.OseeCoreException;
import org.eclipse.osee.framework.skynet.core.artifact.Artifact;
import org.eclipse.osee.framework.skynet.core.artifact.search.ArtifactQuery;
import org.eclipse.osee.framework.skynet.core.event.OseeEventManager;
import org.eclipse.osee.framework.skynet.core.event.model.ArtifactEvent;
import org.eclipse.osee.framework.skynet.core.event.model.EventBasicGuidArtifact;
import org.eclipse.osee.framework.skynet.core.event.model.EventBasicGuidRelation;
import org.eclipse.osee.framework.skynet.core.event.model.EventModType;
import org.eclipse.osee.framework.skynet.core.relation.RelationEventType;
import org.eclipse.osee.framework.skynet.core.relation.RelationLink;
/**
* @author Donald G. Dunne
*/
public class AtsTaskService extends AbstractAtsTaskService {
private final IAtsClient atsClient;
public AtsTaskService(IAtsClient atsClient) {
super(atsClient.getServices());
this.atsClient = atsClient;
}
@Override
public Collection<IAtsTask> createTasks(NewTaskDatas newTaskDatas) {
AtsTaskEndpointApi taskEp = AtsClientService.getTaskEp();
Response response = taskEp.create(newTaskDatas);
if (response.getStatus() != Status.OK.getStatusCode()) {
throw new OseeCoreException("Error creating task [%s] [%s]", newTaskDatas, response.toString());
}
List<IAtsTask> tasks = new LinkedList<>();
ArtifactEvent artifactEvent = new ArtifactEvent(AtsUtilCore.getAtsBranch());
for (NewTaskData newTaskData : newTaskDatas.getTaskDatas()) {
processForEvents(newTaskData, response, tasks, artifactEvent);
}
OseeEventManager.kickPersistEvent(getClass(), artifactEvent);
return tasks;
}
private void processForEvents(NewTaskData newTaskData, Response response, List<IAtsTask> tasks, ArtifactEvent artifactEvent2) {
Artifact teamWf = atsClient.getArtifact(newTaskData.getTeamWfUuid());
JaxAtsTasks jaxTasks = response.readEntity(JaxAtsTasks.class);
ArtifactEvent artifactEvent = new ArtifactEvent(AtsUtilCore.getAtsBranch());
List<Long> artUuids = new LinkedList<>();
teamWf.reloadAttributesAndRelations();
AtsTaskCache.decache((TeamWorkFlowArtifact) teamWf);
for (JaxAtsTask task : jaxTasks.getTasks()) {
String guid = ArtifactQuery.getGuidFromUuid(task.getUuid(), AtsUtilCore.getAtsBranch());
artifactEvent.getArtifacts().add(new EventBasicGuidArtifact(EventModType.Added, AtsUtilCore.getAtsBranch(),
AtsArtifactTypes.Task.getGuid(), guid));
artUuids.add(task.getUuid());
RelationLink relation = getRelation(teamWf, task);
relation = getRelation(teamWf, task);
if (relation != null) {
Artifact taskArt = atsClient.getArtifact(task.getUuid());
DefaultBasicUuidRelation guidRelation = new DefaultBasicUuidRelation(AtsUtilCore.getAtsBranch().getUuid(),
AtsRelationTypes.TeamWfToTask_Task.getGuid(), relation.getId(), relation.getGammaId(),
getBasicGuidArtifact(teamWf), getBasicGuidArtifact(taskArt));
artifactEvent.getRelations().add(new EventBasicGuidRelation(RelationEventType.Added,
newTaskData.getTeamWfUuid().intValue(), new Long(task.getUuid()).intValue(), guidRelation));
}
}
for (Long uuid : artUuids) {
tasks.add(AtsClientService.get().getWorkItemFactory().getTask(AtsClientService.get().getArtifact(uuid)));
}
}
public static DefaultBasicGuidArtifact getBasicGuidArtifact(Artifact artifact) {
return new DefaultBasicGuidArtifact(artifact.getBranch(), artifact.getArtTypeGuid(), artifact.getGuid());
}
private RelationLink getRelation(Artifact teamWf, JaxAtsTask task) {
for (RelationLink relation : teamWf.getRelationsAll(DeletionFlag.EXCLUDE_DELETED)) {
if (relation.getBArtifactId() == (int) task.getUuid()) {
return relation;
}
}
return null;
}
@Override
public Collection<IAtsTask> createTasks(IAtsTeamWorkflow teamWf, List<String> titles, List<IAtsUser> assignees, Date createdDate, IAtsUser createdBy, String relatedToState, String taskWorkDef, Map<String, List<String>> attributes, IAtsChangeSet changes) {
throw new UnsupportedOperationException("Not Supported on Client");
}
@Override
public Collection<IAtsTask> createTasks(NewTaskData newTaskData, IAtsChangeSet changes) {
throw new UnsupportedOperationException("Not Supported on Client");
}
}
|
