在Spring中将两个对象合并到一个模型类中

Question

我从Rabbitmq中的队列收到了这条json消息：

{
    "type": "NEW",
    "operation": "NEW",
    "id": 1,
    "entity": "DOCUMENT",
    "entityType": "NIE",
    "documents": {
        "id": 1,
        "additionals": {
            "issuing_authority": "Spain",
            "country_doc": "ES",
            "place_of_birth": "",
            "valid_from": "1995-08-09",
            "valid_to": "0001-01-01"
        },
        "code": "X12345",
        "typeDocument": "NIE"
    }
}

然后我需要映射到这个模型类：

public class PeopleDocumentDTO {

    private String processType;
    private String operation;
    private String entity;
    private String entityType;
    private Long id;
    private Document document;

    @Getter
    @Setter
    class Customer {
        private String systemId;
        private String customerId;
    }
    private List<Customer> customers;
}

为此，我在@RabbitListener类中执行了此操作：

@RabbitListener(queues = "${event.queue}")
    public void receivedMessage(Message message) throws JsonProcessingException {

        String json = "";

        json = new String(message.getBody(), StandardCharsets.UTF_8);
        System.out.println(json);

        logger.info("Received message: {}", json);

        ObjectMapper objectMapper = new ObjectMapper();
        PeopleDocumentDTO dto = objectMapper.readValue(json, PeopleDocumentDTO.class);}

另一方面，我有一个服务类，它在customer类中为我提供customer对象，该对象需要添加到我的模型类中，并提供一个特定的id，如下所示：

public Mono<Person> getPerson(Integer id, String GS_AUTH_TOKEN) {
        WebClient webClient = WebClient.create();

        return webClient.get()
                .uri(GET_RELATION_BY_ID + id)
                .header("Accept", "application/json")
                .header("Authorization", GS_AUTH_TOKEN)
                .retrieve()
                .bodyToMono(Person.class)
                .map(person -> {
                    List<CustomerRelation> matches = person.getRelatedCustomers()
                            .stream()
                            .filter(relation -> relation.getSystemId().equals(400) || relation.getSystemId().equals(300) || relation.getSystemId().equals(410))
                            .filter(relation -> relation.getCustomerId().contains("F"))
                            .collect(Collectors.toList());
                    person.setRelatedCustomers(matches);
                    return person;
                });
    }

最后，我的问题是如何将这个对象添加到模型类中？所以我可以在《邮递员》中看到这样的内容：

{
    "type": "NEW",
    "operation": "NEW",
    "id": 1,
    "entity": "DOCUMENT",
    "entityType": "NIE",
    "documents": {
        "id": 1,
        "additionals": {
            "issuing_authority": "Spain",
            "country_doc": "ES",
            "place_of_birth": "",
            "valid_from": "1995-08-09",
            "valid_to": "0001-01-01"
        },
        "code": "X12345",
        "typeDocument": "NIE"
    },
    "id": 1,
    "relatedCustomers": [
        {
            "customerId": "xxx",
            "systemId": 999
        }
    ]
}

Answer 1

您可以订阅Person对象和getRelatedCustomers（）并执行dto。setCustomers（）

@RabbitListener(queues = "${event.queue}")
public void receivedMessage(Message message) throws JsonProcessingException {

        String json = "";

        json = new String(message.getBody(), StandardCharsets.UTF_8);
        System.out.println(json);

        logger.info("Received message: {}", json);

        ObjectMapper objectMapper = new ObjectMapper();
        PeopleDocumentDTO dto = objectMapper.readValue(json, PeopleDocumentDTO.class);
        
        personServie.getPerson("id", "authToken").subscribe(person -> dto.setCustomers(person.getRelatedCustomers()));
        
}

如有必要，您可以将PeopleDocumentDTO中的客户更改为related客户。