Revision 29454
Added by Nikon Gasparis almost 10 years ago
| OpenDoarRepositoryFactoryDmsImpl.java | ||
|---|---|---|
| 98 | 98 |
|
| 99 | 99 |
repo.setDateOfCollection(date); |
| 100 | 100 |
repo.setAggregator("OPENAIRE");
|
| 101 |
if (dmService.getService().addDatasource(repo)) |
|
| 102 |
logger.debug("inserted successfully");
|
|
| 103 |
else |
|
| 104 |
logger.error("error while inserting");
|
|
| 101 |
try {
|
|
| 102 |
|
|
| 103 |
if (dmService.getService().addDatasource(repo)) |
|
| 104 |
logger.debug("inserted successfully");
|
|
| 105 |
else |
|
| 106 |
logger.error("error while inserting");
|
|
| 107 |
} catch (DatasourceManagerServiceException e) {
|
|
| 108 |
logger.error("error while inserting" + e);
|
|
| 109 |
} |
|
| 105 | 110 |
|
| 106 | 111 |
} |
| 107 | 112 |
logger.debug("Inserting Interfaces" );
|
| ... | ... | |
| 166 | 171 |
|
| 167 | 172 |
try {
|
| 168 | 173 |
logger.debug("getting repos by country from dms with key: " + collectedFrom);
|
| 169 |
repoList = (List<Repository>) cacheProvider.getCache().get(collectedFrom).getValue(); |
|
| 174 |
repoList = (List<Repository>) cacheProvider.getCache().get(collectedFrom).getObjectValue();
|
|
| 170 | 175 |
|
| 171 | 176 |
for (Repository repo : repoList) {
|
| 172 | 177 |
List<Map<String, String>> repos ; |
| ... | ... | |
| 226 | 231 |
List<Repository> retRepos = new ArrayList<Repository>(); |
| 227 | 232 |
try {
|
| 228 | 233 |
logger.debug("getting repositories registered by user: " + user_mail + " from dms");
|
| 229 |
for (Repository rep : ((List<Repository>) cacheProvider.getCache().get("opendoar").getValue())) {
|
|
| 234 |
for (Repository rep : ((List<Repository>) cacheProvider.getCache().get("opendoar").getObjectValue())) {
|
|
| 230 | 235 |
if (rep.getRegisteredBy().equalsIgnoreCase(user_mail) || rep.getContactEmail().equalsIgnoreCase(user_mail)) {
|
| 231 | 236 |
repo = new Repository(); |
| 232 | 237 |
repo.setId(rep.getId()); |
| ... | ... | |
| 234 | 239 |
retRepos.add(repo); |
| 235 | 240 |
} |
| 236 | 241 |
} |
| 237 |
for (Repository rep : ((List<Repository>) cacheProvider.getCache().get("re3data").getValue())) {
|
|
| 242 |
for (Repository rep : ((List<Repository>) cacheProvider.getCache().get("re3data").getObjectValue())) {
|
|
| 238 | 243 |
if (rep.getRegisteredBy().equalsIgnoreCase(user_mail) || rep.getContactEmail().equalsIgnoreCase(user_mail)) {
|
| 239 | 244 |
repo = new Repository(); |
| 240 | 245 |
repo.setId(rep.getId()); |
| ... | ... | |
| 242 | 247 |
retRepos.add(repo); |
| 243 | 248 |
} |
| 244 | 249 |
} |
| 245 |
for (Repository rep : ((List<Repository>) cacheProvider.getCache().get("jour_aggr").getValue())) {
|
|
| 250 |
for (Repository rep : ((List<Repository>) cacheProvider.getCache().get("jour_aggr").getObjectValue())) {
|
|
| 246 | 251 |
if (rep.getRegisteredBy().equalsIgnoreCase(user_mail) || rep.getContactEmail().equalsIgnoreCase(user_mail)) {
|
| 247 | 252 |
repo = new Repository(); |
| 248 | 253 |
repo.setId(rep.getId()); |
Also available in: Unified diff
*extended information on registration mails
*fixed a bug where namespace prefix for aggregator was 11 rather than 12 characters
*new properties to enable/disable registration of publication files
*new property to set deploy environment
*guidelines are displaying according to the chosen deploy environment
*support for CRIS rules
*support for CRIS compatibility tests