在春季合并一个模型类中的两个对象

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);}

另一方面，我有这个服务类，谁给我了客户类中的客户对象需要添加到我的模型类中，给出特定的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;
                });
    }

最后我的问题是如何将此对象添加到我的模型类中？因此，我可以在Postman中有类似的东西：

{
    "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
        }
    ]
}

更新： 获得相关客户的RestController如下：

@GetMapping("/getId/{Id}")
    public Mono<CuCoPerson> getRelationById(@PathVariable Integer id, @RequestHeader(value="Authorization") String GS_AUTH_TOKEN) {

        return webClientService.getCuCoPerson(id, GS_AUTH_TOKEN);
    }

Answer 1

您可以订阅人对象和getRelatedCustomers（）和do 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()));
        
}

您可以将consuster将其更改为 ressectcustomers在peopledocumentdto时，请在必要时。