Разбор массивов с Джексоном - PullRequest
0 голосов
/ 29 апреля 2018

Я хотел бы проанализировать следующий Json, используя Джексона, но я совсем не уверен, как мне построить сущность.

   [
      CHAN_ID, 
      [
        [
          SYMBOL, 
          STATUS, 
          AMOUNT, 
          BASE_PRICE, 
          MARGIN_FUNDING, 
          MARGIN_FUNDING_TYPE,
          PL,
          PL_PERC,
          PRICE_LIQ,
          LEVERAGE,
           ...
        ], 
        ...
      ]
    ]

Это то, что я имею до сих пор:

@Getter
@Setter
@EqualsAndHashCode
@ToString
@NoArgsConstructor
public class Position {

        @JsonProperty("SYMBOL")
        private String symbol;
        @JsonProperty("STATUS")
        private String status;
        @JsonProperty("AMOUNT")
        private Decimal amount;
        @JsonProperty("BASE_PRICE")
        private Decimal basePrice;
        @JsonProperty("MARGIN_FUNDING")
        private Integer marginFunding;
        @JsonProperty("MARGIN_FUNDING_TYPE")
        private Decimal marginFundingType;
        @JsonProperty("PL")
        private Decimal profitLoss;
        @JsonProperty("PL_PERC")
        private Decimal profitLossPercentage;
        @JsonProperty("PRICE_LIQ")
        private Decimal liquidationPrice;
        @JsonProperty("LEVERAGE")
        private Decimal leverage;
    }

Эта вещь, которую я пытаюсь проанализировать, похоже, имеет массив Position, но также до того, как у него есть этот CHAN_ID, я должен создать какой-то класс-обертку для этого?

@Getter
@Setter
@EqualsAndHashCode
@ToString
@NoArgsConstructor
public class Positions {

    @JsonProperty("CHAN_ID")
    private String channelId;

    @JsonProperty("positions")
    private List<Position> positions;

}

Как вы думаете, это правильно? Также не обращайте внимания на эти аннотации в верхней части классов, это просто Lombok. В настоящее время эта реализация выдает мне следующую ошибку при попытке анализа:

com.fasterxml.jackson.databind.exc.MismatchedInputException: невозможно десериализовать экземпляр model.Positions из токена START_ARRAY в [Источник: (String) "['ps', [['aa', 'bb', 123.45, 123.45, 567, 123.45, 123.45, 123.45, 123.45, 123.45]]] "; строка: 1, столбец: 1]

Чтобы проверить это, я просто использую ObjectMapper:

public static void main(String[] args) throws IOException {
        ObjectMapper objectMapper = new ObjectMapper();
        try {
            Positions positions = objectMapper.readValue("['ps', [ [ 'aa', 'bb', 123.45, 123.45, 567, 123.45, 123.45, 123.45, 123.45, 123.45]] ]", Positions.class);
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

1 Ответ

0 голосов
/ 29 апреля 2018

Поскольку входной JSON структурирован как вложенные массивы, связывание с @JsonProperty не имеет большого смысла, поскольку ни один из этих ключей свойств не присутствует во входном JSON. Здесь они имеют смысл, только если вы хотите впоследствии преобразовать десериализованные данные в JSON с парами свойство-значение.

Чтобы правильно прочитать эту структуру JSON, вам потребуется реализовать собственный десериализатор, потому что в этом случае свойства не могут быть сопоставлены с их значениями автоматически. Десериализатор может быть реализацией Джексона JsonDeserializer или StdDeserializer. Например, приведенная ниже реализация работает:

import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.deser.std.StdDeserializer;

import java.io.IOException;
import java.util.List;
import java.util.stream.Collectors;

public class PositionsDeserializer extends StdDeserializer<Positions> {

  public PositionsDeserializer() {
    super(Positions.class);
  }

  @Override
  public Positions deserialize(JsonParser p, DeserializationContext ctxt) throws IOException {
    Object[] positionsProps = p.readValueAs(Object[].class);
    if (positionsProps != null && positionsProps.length > 0) {
      String chanId = (String) positionsProps[0];
      List<Position> positionsList =
          ((List<List<?>>) positionsProps[1]).stream()
              .map(this::deserializePosition)
              .collect(Collectors.toList());
      Positions positions = new Positions();
      positions.setChannelId(chanId);
      positions.setPositions(positionsList);
      return positions;
    }
    // decide whether you want to return null, throw an exception or other outcome: depends on the constraints of your data
    return null;
  }

  private Position deserializePosition(List<?> props) {
    if (props != null && !props.isEmpty()) {
      final Position position = new Position();
      position.setSymbol((String) props.get(0));
      position.setStatus((String) props.get(1));
      position.setAmount((Double) props.get(2));
      position.setBasePrice((Double) props.get(3));
      position.setMarginFunding((Integer) props.get(4));
      position.setMarginFundingType((Double) props.get(5));
      position.setProfitLoss((Double) props.get(6));
      position.setProfitLossPercentage((Double) props.get(7));
      position.setLiquidationPrice((Double) props.get(8));
      position.setLeverage((Double) props.get(9));
      return position;
    }
    // decide whether you want to return null, throw an exception or other outcome: depends on the constraints of your data
    return null;
  }

}

Чтобы использовать этот десериализатор, он должен быть зарегистрирован в ObjectMapper:

private ObjectMapper initObjectMapper() {
  ObjectMapper objectMapper = new ObjectMapper();
  SimpleModule module = new SimpleModule();
  module.addDeserializer(Positions.class, new PositionsDeserializer());
  objectMapper.registerModule(module);
  return objectMapper;
}

@Test
public void deserializePositions() throws IOException {
  String json = "[ \"ps\", [ [ \"aa\", \"bb\", 123.45, 123.45, 567, 123.45, 123.45, 123.45, 123.45, 123.45 ] ] ]";

  Positions positions = initObjectMapper().readValue(json, Positions.class);

  System.out.println(positions);
}

Предложения

Если у вас есть возможность выбрать / изменить структуру входного JSON, я бы порекомендовал сократить вложение и ввести более обычное отображение KV. Например, для представления Positions:

{
  "CHAN_ID": "string",
  "positions": [
    // Use the arrays here: [ "aa", "bb", 123.45, 123.45, 567, 123.45, 123.45, 123.45, 123.45, 123.45 ], 
    // OR transform the array into KV mapping: { "SYMBOL": "string", ... }, ...
  ]
}

Такой подход позволит:

  • уменьшить риск ошибок, вызванных магическими числами, связанными с индексами массивов для значений;

  • упрощают десериализацию: автоматически читайте Positions и используйте специальный десериализатор только для Position, если структура массива сохраняется.

Кроме того, я не знаю, что означает тип Decimal в исходном коде, поэтому я заменил его на Double.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...