import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
/**
 * This method actually writes the xml to disk.
 * @param payload
 * @param path
 * @return
 */
@Override
protected void exportXmlFile(ByteArrayPayload payload, String path) throws IOException {
	File file = new File(path);
    if (file.exists() && !file.delete()) {
        throw new IOException("Cannot overwrite " + path + ". Perhaps the file is locked?");
    }

    // create data stream
    InputStream is = payload.getPayloadStream();
    int len = (int) payload.getLength();

    // read from data stream
    try {
        mSecureStorage.writeFile(path, is);
    } catch (Exception e) {
        throw new IOException(e);
    }

}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
public IDataPayload createSerializedPayload	(FormInstance model, IDataReference ref) throws IOException {
	init();
	rootRef = FormInstance.unpackReference(ref);
	if(this.serializer == null) {
		this.setAnswerDataSerializer(new XFormAnswerDataSerializer());
	}
	model.accept(this);
	if(theXmlDoc != null) {
		//TODO: Did this strip necessary data?
		byte[] form = XFormSerializer.getUtfBytes(theXmlDoc);
		if(dataPointers.size() == 0) {
			return new ByteArrayPayload(form, null, IDataPayload.PAYLOAD_TYPE_XML);
		}
		MultiMessagePayload payload = new MultiMessagePayload();
		payload.addPayload(new ByteArrayPayload(form, "xml_submission_file", IDataPayload.PAYLOAD_TYPE_XML));
          for (IDataPointer pointer : dataPointers) {
			payload.addPayload(new DataPointerPayload(pointer));
		}
		return payload;
	}
	else {
		return null;
	}
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
@Override
public IDataPayload createSerializedPayload(FormInstance model, XPathReference ref) throws IOException {
    init();
    rootRef = FormInstance.unpackReference(ref);
    if (this.serializer == null) {
        this.setAnswerDataSerializer(new XFormAnswerDataSerializer());
    }
    model.accept(this);
    if (theXmlDoc != null) {
        //TODO: Did this strip necessary data?
        byte[] form = XFormSerializer.getUtfBytesFromDocument(theXmlDoc);
        if (dataPointers.size() == 0) {
            return new ByteArrayPayload(form, null, IDataPayload.PAYLOAD_TYPE_XML);
        }
        MultiMessagePayload payload = new MultiMessagePayload();
        payload.addPayload(new ByteArrayPayload(form, "xml_submission_file", IDataPayload.PAYLOAD_TYPE_XML));
        Enumeration en = dataPointers.elements();
        while (en.hasMoreElements()) {
            IDataPointer pointer = (IDataPointer)en.nextElement();
            payload.addPayload(new DataPointerPayload(pointer));
        }
        return payload;
    } else {
        return null;
    }
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
/**
 * Blocking write of the instance data to a temp file. Used to safeguard data
 * during intent launches for, e.g., taking photos.
 *
 * @param tempPath
 * @return
 */
public static String blockingExportTempData() {
    FormController formController = Collect.getInstance().getFormController();

    long start = System.currentTimeMillis();
    File temp = savepointFile(formController.getInstancePath());
    ByteArrayPayload payload;
    try {
    	payload = formController.getFilledInFormXml();
        // write out xml
        if ( exportXmlFile(payload, temp.getAbsolutePath()) ) {
        	return temp.getAbsolutePath();
        }
        return null;
    } catch (IOException e) {
        Log.e(t, "Error creating serialized payload");
        e.printStackTrace();
        return null;
    } finally {
    	long end = System.currentTimeMillis();
    	Log.i(t, "Savepoint ms: " + Long.toString(end - start));
    }
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
@Override
protected String doInBackground(Void... params) {
    synchronized (lock) {
        if (priority < lastPriorityUsed) {
            Log.w(t, "Savepoint thread (p=" + priority + ") was cancelled (a) because another one is waiting (p=" + lastPriorityUsed + ")");
            return null;
        }

        long start = System.currentTimeMillis();

        try {
            FormController formController = Collect.getInstance().getFormController();
            File temp = SaveToDiskTask.savepointFile(formController.getInstancePath());
            ByteArrayPayload payload = formController.getFilledInFormXml();

            if (priority < lastPriorityUsed) {
                Log.w(t, "Savepoint thread (p=" + priority + ") was cancelled (b) because another one is waiting (p=" + lastPriorityUsed + ")");
                return null;
            }

            // write out xml
            SaveToDiskTask.exportXmlFile(payload, temp.getAbsolutePath());

            long end = System.currentTimeMillis();
            Log.i(t, "Savepoint ms: " + Long.toString(end - start) + " to " + temp);

            return null;
        } catch (Exception e) {
            String msg = e.getMessage();
            Log.e(t, msg, e);
            return msg;
        }
    }
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
/**
 * Constructs the XML payload for a filled-in form instance. This payload
 * enables a filled-in form to be re-opened and edited.
 *
 * @return
 * @throws IOException
 */
public ByteArrayPayload getFilledInFormXml() throws IOException {
    // assume no binary data inside the model.
    FormInstance datamodel = getInstance();
    XFormSerializingVisitor serializer = new XFormSerializingVisitor();
    ByteArrayPayload payload =
    		(ByteArrayPayload) serializer.createSerializedPayload(datamodel);

    return payload;
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
/**
 * Extract the portion of the form that should be uploaded to the server.
 *
 * @return
 * @throws IOException
 */
public ByteArrayPayload getSubmissionXml() throws IOException {
    FormInstance instance = getInstance();
    XFormSerializingVisitor serializer = new XFormSerializingVisitor();
    ByteArrayPayload payload =
            (ByteArrayPayload) serializer.createSerializedPayload(instance,
                                               getSubmissionDataReference());
    return payload;
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
@Override
protected void exportXmlFile(ByteArrayPayload payload, String path) throws IOException {
    SecureFile file = new SecureFile(path);
    if (file.exists() && !file.delete()) {
        throw new IOException("Cannot overwrite " + path + ". Perhaps the file is locked?");
    }

    try {
        mSecureStorage.writeFile(path, payload.getPayloadStream());
    } catch (Exception e) {
        throw new IOException(e);
    }
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
public IDataPayload createSerializedPayload(FormInstance model, IDataReference ref)
		throws IOException {
	init();
	rootRef = FormInstance.unpackReference(ref);
	if (this.serializer == null) {
		this.setAnswerDataSerializer(new XFormAnswerDataSerializer());
	}
	model.accept(this);
	if (theSmsStr != null) {
		byte[] form = theSmsStr.getBytes("UTF-8");
		return new ByteArrayPayload(form, null, IDataPayload.PAYLOAD_TYPE_SMS);
	} else {
		return null;
	}
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
public IDataPayload createSerializedPayload(FormInstance model, XPathReference ref)
        throws IOException {
    init();
    rootRef = FormInstance.unpackReference(ref);
    if (this.serializer == null) {
        this.setAnswerDataSerializer(new XFormAnswerDataSerializer());
    }
    model.accept(this);
    if (theSmsStr != null) {
        byte[] form = theSmsStr.getBytes("UTF-16");
        return new ByteArrayPayload(form, null, IDataPayload.PAYLOAD_TYPE_SMS);
    } else {
        return null;
    }
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
private void writeXmlToStream(ByteArrayPayload payload, OutputStream output) throws IOException {
    try {
        InputStream is = payload.getPayloadStream();
        StreamsUtil.writeFromInputToOutput(is, output);
    } finally {
        output.close();
    }
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
/**
 * Extract the portion of the form that should be uploaded to the server.
 */
public ByteArrayPayload getSubmissionXml() throws IOException {
    FormInstance instance = getInstance();
    XFormSerializingVisitor serializer = new XFormSerializingVisitor();

    return (ByteArrayPayload)serializer.createSerializedPayload(instance,
            getSubmissionDataReference());
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
/**
 * Constructs the XML payload for a filled-in form instance. This payload
 * enables a filled-in form to be re-opened and edited.
 * 
 * @return
 * @throws IOException
 */
public ByteArrayPayload getFilledInFormXml() throws IOException {
    // assume no binary data inside the model.
    FormInstance datamodel = getInstance();
    XFormSerializingVisitor serializer = new XFormSerializingVisitor();
    ByteArrayPayload payload =
    		(ByteArrayPayload) serializer.createSerializedPayload(datamodel);

    return payload;
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
/**
 * Extract the portion of the form that should be uploaded to the server.
 * 
 * @return
 * @throws IOException
 */
public ByteArrayPayload getSubmissionXml() throws IOException {
    FormInstance instance = getInstance();
    XFormSerializingVisitor serializer = new XFormSerializingVisitor();
    ByteArrayPayload payload = 
            (ByteArrayPayload) serializer.createSerializedPayload(instance,
                                               getSubmissionDataReference());
    return payload;
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
/**
     * This method actually writes the xml to disk.
     * @param payload
     * @param path
     * @return
     */
    static void exportXmlFile(ByteArrayPayload payload, String path) throws IOException {
        File file = new File(path);
        if (file.exists() && !file.delete()) {
            throw new IOException("Cannot overwrite " + path + ". Perhaps the file is locked?");
        }

        // create data stream
        InputStream is = payload.getPayloadStream();
        int len = (int) payload.getLength();

        // read from data stream
        byte[] data = new byte[len];
//        try {
            int read = is.read(data, 0, len);
            if (read > 0) {
                // write xml file
                RandomAccessFile randomAccessFile = null;
                try {
                    // String filename = path + File.separator +
                    // path.substring(path.lastIndexOf(File.separator) + 1) + ".xml";
                    randomAccessFile = new RandomAccessFile(file, "rws");
                    randomAccessFile.write(data);
                } finally {
                    if (randomAccessFile != null) {
                        try {
                            randomAccessFile.close();
                        } catch (IOException e) {
                            Log.e(t, "Error closing RandomAccessFile: " + path, e);
                        }
                    }
                }
            }
//        } catch (IOException e) {
//            Log.e(t, "Error reading from payload data stream");
//            e.printStackTrace();
//            return false;
//        }
//
//        return false;
    }
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
public static ByteArrayPayload dispatch (FormInstance dm) {
	return (ByteArrayPayload)xfFact.serializeInstance(dm);
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
public IDataPayload visit(ByteArrayPayload payload) {
    return visitIndividual(payload);
}
 

import org.javarosa.core.services.transport.payload.ByteArrayPayload; //导入依赖的package包/类
/**
 * @param str
 * @param destinationURL
 */
public SimpleHttpTransportMessage(byte[] content, String url) {
    this();
    this.url = url;
    this.content = new ByteArrayPayload(content);
}