按JSON数组的唯一ID分组

Question

块引号

[
    {
        "ID": "1234",
        "CustomerName": "KUMAR",
        "BranchName": "HARBOUR",
        "SchemeName": "GOLD",
        "MobileNumber": "123456789",
        "CustomerType": "PRIMARY",
        "DedupeFound" : "NO"
        
    },
    {
        "ID": "1234",
        "CustomerName": "SEAN",
        "BranchName": "HARBOUR",
        "SchemeName": "GOLD",
        "MobileNumber": "123456789",
        "CustomerType": "SECONDARY",
        "DedupeFound" : "YES"
    },
    {
        "ID": "5678",
        "CustomerName": "MARK",
        "BranchName": "CANTONMENT",
        "SchemeName": "DIAMOND",
        "MobileNumber": "123456789",
        "CustomerType": "PRIMARY",
        "DedupeFound" : "NO"
    },
    {
        "ID": "5678",
        "CustomerName": "STEVE",
        "BranchName": "CANTONMENT",
        "SchemeName": "DIAMOND",
        "MobileNumber": "123456789",
        "CustomerType": "SECONDARY",
        "DedupeFound" : "YES"
    }
]

null

[
    {
        "ID": "1234",
        "CustomerName": "KUMAR",           // Only Primary Customer Details for the 
        "BranchName": "HARBOUR",           //  ID Tag to be displayed here
        "SchemeName": "GOLD",
        "MobileNumber": "123456789"
        "DedupeDetails": [
            {
                "CustomerType": "PRIMARY"
                "CustomerName": "KUMAR",
                "DedupeFound" : "NO"
            },
            {
                "CustomerType": "SECONDARY"
                "CustomerName": "SEAN",
                "DedupeFound" : "YES"
            }
        ]
    },
    {
        "ID": "5678",
        "CustomerName": "MARK",
        "BranchName": "CANTONMENT",
        "SchemeName": "DIAMOND",
        "MobileNumber": "123456789"
        "DedupeDetails": [
            {
                "CustomerType": "PRIMARY"
                "CustomerName": "MARK",
                "DedupeFound" : "NO"
            },
            {
                "CustomerType": "SECONDARY"
                "CustomerName": "STEVE",
                "DedupeFound" : "YES"
            }
        ]
    }
]

爪哇

package com.mycompany.Login;

import java.util.List;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.sql.Timestamp;
import java.io.File;
import java.io.PrintWriter;
import java.sql.Time;
import com.mycompany.Login.*;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.mycompany.Dedupe.DedupeRoot.DedupeRes;




public class LoginMapping implements Processor{
    public void process(Exchange ex)throws Exception{ 
    
        try {   
        
           
            String responseString = {Input mentioned in post};          
            ObjectMapper mapper = new ObjectMapper();
            mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);         
            List<DedupeRes> dedupe = Arrays.asList(mapper.readValue(responseString, DedupeRes[].class));  
            int total = dedupe.size();          
            if (total > 0)
            {               
                for (int i = 0; i < total; i++) {                   
                    
                }               
            }
    
     ex.getIn().setBody(responseString);
        }       
        catch(Exception e) {
            ex.getIn().setHeader("ExpMsg", "Undefined");
            throw e;
        }   
    
}
}

Answer 1

完整的代码实现，尝试一下。

public class T {

    private static final ObjectMapper mapper = new ObjectMapper();

    static {
        mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
    }

    public static <T> List<T> parseObjectList(String json, Class<T> clazz) {
        try {
            return mapper.readValue(
                    json,
                    TypeFactory.defaultInstance().constructParametricType(ArrayList.class, clazz)
            );
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    public static <T> String toJsonString(T t) {
        try {
            return mapper.writeValueAsString(t);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    public static void main(String[] args) {
        try {
            String responseString = "[{\"ID\":\"1234\",\"CustomerName\":\"KUMAR\",\"BranchName\":\"HARBOUR\",\"SchemeName\":\"GOLD\",\"MobileNumber\":\"123456789\",\"CustomerType\":\"PRIMARY\",\"DedupeFound\":\"NO\"},{\"ID\":\"1234\",\"CustomerName\":\"SEAN\",\"BranchName\":\"HARBOUR\",\"SchemeName\":\"GOLD\",\"MobileNumber\":\"123456789\",\"CustomerType\":\"SECONDARY\",\"DedupeFound\":\"YES\"},{\"ID\":\"5678\",\"CustomerName\":\"MARK\",\"BranchName\":\"CANTONMENT\",\"SchemeName\":\"DIAMOND\",\"MobileNumber\":\"123456789\",\"CustomerType\":\"PRIMARY\",\"DedupeFound\":\"NO\"},{\"ID\":\"5678\",\"CustomerName\":\"STEVE\",\"BranchName\":\"CANTONMENT\",\"SchemeName\":\"DIAMOND\",\"MobileNumber\":\"123456789\",\"CustomerType\":\"SECONDARY\",\"DedupeFound\":\"YES\"}]";
            List<DedupeRes> list = parseObjectList(responseString, DedupeRes.class);
            if (list != null && !list.isEmpty()) {
                Map<String, List<DedupeRes>> map = list.stream().collect(Collectors.groupingBy(DedupeRes::getID));
                List<Res> resList = new ArrayList<>();
                map.forEach((k, v) -> resList.add(listToRes(v)));
                responseString = toJsonString(resList);
                System.out.println(responseString);
            }
        } catch (Exception e) {
            // xx
            e.printStackTrace();
        }
    }

    private static Res listToRes(List<DedupeRes> list) {
        Res res = new Res();
        res.setDedupeDetails(new ArrayList<>());
        for (DedupeRes dedupeRes : list) {
            if (Objects.equals("PRIMARY", dedupeRes.getCustomerType())) {
                // if you used spring -> BeanUtils.copyProperties(dedupeRes, res);
                res.setID(dedupeRes.getID());
                res.setBranchName(dedupeRes.getBranchName());
                res.setCustomerName(dedupeRes.getCustomerName());
                res.setMobileNumber(dedupeRes.getMobileNumber());
                res.setSchemeName(dedupeRes.getSchemeName());
            }
            DedupeDetails details = new DedupeDetails();
            //
            BeanUtils.copyProperties(dedupeRes, details);
            res.getDedupeDetails().add(details);
        }
        return res;
    }

    @Data
    private static class DedupeRes {
        @JsonProperty("ID")
        private String ID;
        @JsonProperty("CustomerName")
        private String CustomerName;
        @JsonProperty("BranchName")
        private String BranchName;
        @JsonProperty("SchemeName")
        private String SchemeName;
        @JsonProperty("MobileNumber")
        private String MobileNumber;
        @JsonProperty("CustomerType")
        private String CustomerType;
        @JsonProperty("DedupeFound")
        private String DedupeFound;
    }

    @Data
    private static class Res {
        @JsonProperty("ID")
        private String ID;
        @JsonProperty("CustomerName")
        private String CustomerName;
        @JsonProperty("BranchName")
        private String BranchName;
        @JsonProperty("SchemeName")
        private String SchemeName;
        @JsonProperty("MobileNumber")
        private String MobileNumber;
        @JsonProperty("dedupeDetails")
        private List<DedupeDetails> dedupeDetails;
    }

    @Data
    private static class DedupeDetails {
        @JsonProperty("CustomerType")
        private String CustomerType;
        @JsonProperty("CustomerName")
        private String CustomerName;
        @JsonProperty("DedupeFound")
        private String DedupeFound;
    }
}

康苏尔。

[{"ID":"1234","CustomerName":"KUMAR","BranchName":"HARBOUR","SchemeName":"GOLD","MobileNumber":"123456789","dedupeDetails":[{"CustomerType":"PRIMARY","CustomerName":"KUMAR","DedupeFound":"NO"},{"CustomerType":"SECONDARY","CustomerName":"SEAN","DedupeFound":"YES"}]},{"ID":"5678","CustomerName":"MARK","BranchName":"CANTONMENT","SchemeName":"DIAMOND","MobileNumber":"123456789","dedupeDetails":[{"CustomerType":"PRIMARY","CustomerName":"MARK","DedupeFound":"NO"},{"CustomerType":"SECONDARY","CustomerName":"STEVE","DedupeFound":"YES"}]}]