问如何解析带有ZPM段的DFT_P03报文

EN

@Override
public Message processMessage(Message t, Map map) throws ReceivingApplicationException, HL7Exception 
{
    String encodedMessage = new DefaultHapiContext().getPipeParser().encode(t);

    logEntryService.logDebug(LogEntry.CONNECTIVITY, "Received message:\n" + encodedMessage + "\n\n");

    try 
    {
        InboundMessage inboundMessage = new InboundMessage();
        inboundMessage.setMessageTime(new Date());
        inboundMessage.setMessageType("Usage");

        DFT_P03 usageMessage = (DFT_P03) t;
        Segment ZPMSegment = (Segment)usageMessage.get("ZPM");

        inboundMessage.setMessage(usageMessage.toString());
        Facility facility = facilityService.findByCode(usageMessage.getMSH().getReceivingFacility().getNamespaceID().getValue());
        inboundMessage.setTargetFacility(facility);
        String controlID = usageMessage.getMSH().getMessageControlID().encode();
        controlID = controlID.substring(controlID.indexOf("^") + 1, controlID.length());
        inboundMessage.setControlId(controlID);

        Message response;

        try
        {
            inboundMessageService.save(inboundMessage);
            response = t.generateACK();
            logEntryService.logDebug(LogEntry.CONNECTIVITY, "Message ACKed");
        }
        catch (Exception ex)
        {
            response = t.generateACK(AcknowledgmentCode.AE, new HL7Exception(ex));
            logEntryService.logDebug(LogEntry.CONNECTIVITY, "Message NACKed");
        }

        return response;
    } 
    catch (IOException e) 
    {
        logEntryService.logDebug(LogEntry.CONNECTIVITY, "Message rejected");

        throw new HL7Exception(e);
    }
}

public class DFT_P03_Custom extends DFT_P03
{
    public DFT_P03_Custom() throws HL7Exception
    {
        this(new DefaultModelClassFactory());
    }

    public DFT_P03_Custom(ModelClassFactory factory) throws HL7Exception
    {
        super(factory);
        String[] segmentNames = getNames();
        int indexOfPid = Arrays.asList(segmentNames).indexOf("FT1");
        int index = indexOfPid + 1;
        Class<ZPM> type = ZPM.class;
        boolean required = true;
        boolean repeating = false;
        this.add(type, required, repeating, index);
    }

    public ZPM getZPM()
    {
        return getTyped("ZPM", ZPM.class);
    }
}