Skip to content
Snippets Groups Projects
Commit d15d2051 authored by Felix Reichenbach's avatar Felix Reichenbach
Browse files

OZG-7515 change parent ids back to strings

parent 818d2e9a
No related branches found
No related tags found
1 merge request!11Ozg 7515 migrate patch item command
...@@ -54,19 +54,19 @@ public class M014_AddItemNameBescheidToPatchAttachedItemCommand { // NOSONAR ...@@ -54,19 +54,19 @@ public class M014_AddItemNameBescheidToPatchAttachedItemCommand { // NOSONAR
updateDocuments(mongoOperations, parentIds); updateDocuments(mongoOperations, parentIds);
} }
List<ObjectId> getSendBescheidCommandIds(MongoOperations mongoOperations) { List<String> getSendBescheidCommandIds(MongoOperations mongoOperations) {
var commands = mongoOperations.find(Query.query(Criteria.where(ORDER_FIELD).is(SEND_BESCHEID_ORDER)), Document.class, var commands = mongoOperations.find(Query.query(Criteria.where(ORDER_FIELD).is(SEND_BESCHEID_ORDER)), Document.class,
COMMAND_COLLECTION_NAME); COMMAND_COLLECTION_NAME);
return commands.stream().map(command -> command.getObjectId(ID_FIELD)).toList(); return commands.stream().map(command -> command.getObjectId(ID_FIELD)).map(ObjectId::toString).toList();
} }
void updateDocuments(MongoOperations mongoOperations, List<ObjectId> parentIds) { void updateDocuments(MongoOperations mongoOperations, List<String> parentIds) {
var query = buildQuery(parentIds); var query = buildQuery(parentIds);
var update = new Update().set(ITEM_NAME_FILED, BESCHEID_ITEM_NAME); var update = new Update().set(ITEM_NAME_FILED, BESCHEID_ITEM_NAME);
mongoOperations.updateMulti(query, update, COMMAND_COLLECTION_NAME); mongoOperations.updateMulti(query, update, COMMAND_COLLECTION_NAME);
} }
Query buildQuery(List<ObjectId> parentIds) { Query buildQuery(List<String> parentIds) {
return new Query().addCriteria(new Criteria().andOperator( return new Query().addCriteria(new Criteria().andOperator(
Criteria.where(PARENT_ID_FIELD).in(parentIds), Criteria.where(PARENT_ID_FIELD).in(parentIds),
Criteria.where(ORDER_FIELD).is(PATCH_ATTACHED_ITEM_ORDER), Criteria.where(ORDER_FIELD).is(PATCH_ATTACHED_ITEM_ORDER),
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment