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
141
|
package org.openecomp.core.tools.Commands;
import com.amdocs.zusammen.datatypes.Id;
import com.amdocs.zusammen.datatypes.SessionContext;
import com.amdocs.zusammen.plugin.statestore.cassandra.dao.impl.VersionCassandraDao;
import com.google.common.collect.Sets;
import org.openecomp.core.tools.store.ElementHandler;
import org.openecomp.core.tools.store.VersionInfoCassandraLoader;
import org.openecomp.core.tools.store.VspGeneralLoader;
import org.openecomp.core.zusammen.impl.CassandraConnectionInitializer;
import org.openecomp.core.zusammen.plugin.dao.types.ElementEntity;
import org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductConstants;
import org.openecomp.sdc.versioning.dao.types.Version;
import org.openecomp.sdc.versioning.dao.types.VersionInfoEntity;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import static org.openecomp.core.tools.store.VspGeneralLoader.buildKey;
public class ResetOldVersion {
public static final String OLD_VERSION = "oldVersion";
private static Map<String, List<String>> itemVersionMap = new HashMap<>();
private static Map<String, List<String>> itemChangeRefMap = new HashMap<>();
private static int count = 0;
public static void reset(SessionContext context, String oldVersion, String emptyOldVersion) {
CassandraConnectionInitializer.setCassandraConnectionPropertiesToSystem();
loadItemVersionInfo(context);
Map<String, ElementEntity> generalElementMap =
VspGeneralLoader.load(context,
itemVersionMap, itemChangeRefMap);
generalElementMap.values().forEach(elementEntity -> updateOldVersionFlag(elementEntity,
oldVersion, Boolean.TRUE.toString().equals(emptyOldVersion)));
itemVersionMap.entrySet().forEach(entry -> updateElements(context, generalElementMap, entry));
itemChangeRefMap.entrySet().forEach(entry -> updateElements(context, generalElementMap, entry));
System.out.println("number of element updated:" + count);
}
private static void updateElements(SessionContext context, Map<String,
ElementEntity> generalElementMap, Map.Entry<String, List<String>> entry) {
entry.getValue().stream().filter
(changeRef -> generalElementMap
.containsKey(buildKey(context, entry, changeRef))).
forEach(changeref -> ElementHandler.update(context, entry.getKey(), changeref, changeref,
generalElementMap.get(buildKey(context, entry, changeref))));
}
private static void updateOldVersionFlag(ElementEntity elementEntity, String oldVersion,
boolean emptyOldVersion) {
if (!emptyOldVersion) {
elementEntity.getInfo().addProperty(OLD_VERSION, oldVersion);
count++;
} else if (elementEntity.getInfo().getProperty(OLD_VERSION) == null
|| "".equals(elementEntity.getInfo().getProperty(OLD_VERSION))) {
elementEntity.getInfo().addProperty(OLD_VERSION, oldVersion);
count++;
}
}
private static void loadItemVersionInfo(SessionContext context) {
List<String> items = new ArrayList<>();
System.setProperty("cassandra.dox.keystore", "dox");
VersionInfoCassandraLoader versionInfoCassandraLoader = new VersionInfoCassandraLoader();
Collection<VersionInfoEntity> versions = versionInfoCassandraLoader.list();
versions.stream().filter(versionInfoEntity -> versionInfoEntity.getEntityType()
.equals(VendorSoftwareProductConstants.VENDOR_SOFTWARE_PRODUCT_VERSIONABLE_TYPE)).forEach
(versionInfoEntity -> {
handleVersionInfoEntity(items, versionInfoEntity);
});
System.setProperty("cassandra.dox.keystore", "zusammen_dox");
VersionCassandraDao versionCassandraDao = new VersionCassandraDao();
items.forEach(itemId -> versionCassandraDao.list(context, context.getUser().getUserName(),
new Id(itemId)).forEach(itemVersion -> addItemVersion(itemId, itemVersion.getId())));
}
private static void handleVersionInfoEntity(List<String> items, VersionInfoEntity versionInfoEntity) {
items.add(versionInfoEntity.getEntityId());
Set<Version> viewableVersions;
if (versionInfoEntity.getViewableVersions() != null
&& !versionInfoEntity.getViewableVersions().isEmpty()) {
viewableVersions = versionInfoEntity.getViewableVersions();
} else {
viewableVersions = Sets.newHashSet(versionInfoEntity.getActiveVersion());
}
addItemChangeRef(versionInfoEntity.getEntityId(), maxChangeRef(viewableVersions));
}
private static Id maxChangeRef(Set<Version> viewableVersions) {
return new Id(viewableVersions.stream().max((o1, o2) -> o1.getMajor() > o2.getMajor()
?1:o1.getMajor
() == o2.getMajor() ? (o1.getMinor() > o2.getMinor() ? 1: o1.getMinor() == o2.getMinor()
? 0 : -1) : -1).get().toString());
}
private static void addItemChangeRef(String itemId, Id changeRef) {
addItemVersion(itemChangeRefMap, itemId, changeRef);
}
private static void addItemVersion(String itemId, Id versionId) {
addItemVersion(itemVersionMap, itemId, versionId);
}
private static void addItemVersion(Map<String, List<String>> itemVersions, String itemId, Id id) {
if (!itemVersions.containsKey(itemId)) {
itemVersions.put(itemId, new ArrayList<>());
}
itemVersions.get(itemId).add(id.getValue());
}
}
|
