Index: grails-app/services/com/lemans/ds/solr/SolrQueryService.groovy =================================================================== diff -u -r45bc95cd7736b158e8ef1f6390dd07086d4d5ecd -r27219613cc0b77214268b8604917ed50a2feb8de --- grails-app/services/com/lemans/ds/solr/SolrQueryService.groovy (.../SolrQueryService.groovy) (revision 45bc95cd7736b158e8ef1f6390dd07086d4d5ecd) +++ grails-app/services/com/lemans/ds/solr/SolrQueryService.groovy (.../SolrQueryService.groovy) (revision 27219613cc0b77214268b8604917ed50a2feb8de) @@ -49,6 +49,7 @@ queueCountsForPartsWithoutFitment(payload, pool), queueCountsForPartsWithTentativeFitment(payload, pool), queueCountsForPartImagesToReview(payload, pool), + queueCountsForPartNeedMDChangeFlag(payload, pool), queueCountsForPartsNotStarted(payload, pool), queueCountsForPartsSomeInProgress(payload, pool), @@ -390,6 +391,20 @@ }, executor) } + private CompletableFuture queueCountsForPartNeedMDChangeFlag(QueuePayload payload, Executor executor) { + CompletableFuture.supplyAsync(new Supplier() { + @Override + Map get() { + QueuePayload queuePayload = copyWithQueueType(payload, QueueType.PARTS_NEED_MARKETING_DESCR_CHANGE) + SolrQuery query = new SolrQuery() + .addFilterQuery('(hasPartNeedMDChangeFlag:true)') + .addFilterQuery('(categoryId:[* TO *])') + QueryResponse queryResponse = dsQueueSolrClient.query(buildFacetQuery(query, queuePayload)) + buildResponse(queryResponse, queuePayload) + } + }, executor) + } + private CompletableFuture queueCountsForPartsNotStarted(QueuePayload payload, Executor executor) { CompletableFuture.supplyAsync(new Supplier() { @Override