Projet

Général

Profil

Télécharger (6,78 ko) Statistiques
| Branche: | Tag: | Révision:

root/lib/epcis-0.5.0/epcis-interop-test/src/test/java/org/fosstrak/epcis/repository/test/CaptureTest.java @ 2e0a7cb1

/*
* Copyright (C) 2007 ETH Zurich
*
* This file is part of Fosstrak (www.fosstrak.org).
*
* Fosstrak is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software Foundation.
*
* Fosstrak is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with Fosstrak; if not, write to the Free
* Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
* Boston, MA 02110-1301 USA
*/

package org.fosstrak.epcis.repository.test;

import java.io.FileInputStream;

import org.dbunit.dataset.ITable;
import org.dbunit.operation.DatabaseOperation;
import org.fosstrak.epcis.captureclient.CaptureClient;
import org.fosstrak.epcis.utils.FosstrakDatabaseHelper;

/**
* Tests the capture operation by sending a set of EPCIS capture requests to the
* repository using the {@link CaptureClient}.
*
* @author Marco Steybe
*/
public class CaptureTest extends FosstrakInteropTestCase {

/**
* The XML files from which the EPCIS capture events are taken.
*/
private static final String COMMISSION_CASES_XML = "src/test/resources/events/1_case_commissioning_events.xml";
private static final String COMMISSION_PALLETS_XML = "src/test/resources/events/2_pallet_commissioning_events.xml";
private static final String PACK_CASES_XML = "src/test/resources/events/3_pack_cases_events.xml";
private static final String REICEIVE_PALLET_XML = "src/test/resources/events/4_receive_pallets_events.xml";
private static final String PICK_ORDER_XML = "src/test/resources/events/5_pick_order_events.xml";
private static final String SHIP_ORDER_XML = "src/test/resources/events/6_ship_order_events.xml";
private static final String RECEIVE_ORDER_XML = "src/test/resources/events/7_receive_order_events.xml";
private static final String STORE_INVENTORY_XML = "src/test/resources/events/8_store_inventory_events.xml";

private CaptureClient client = new CaptureClient();

@Override
protected DatabaseOperation getSetUpOperation() throws Exception {
return DatabaseOperation.DELETE_ALL;
}

private void runCaptureTest(String pathToXml) throws Exception {
long t1 = System.currentTimeMillis();
int response = client.capture(new FileInputStream(pathToXml));
assertEquals(200, response);
System.out.println("events successfully captured in " + (System.currentTimeMillis() - t1) + "ms");
}

/**
* Capture events test 1.
*/
public void testCommissionCases() throws Exception {
String epcToCheck = "urn:epc:id:sgtin:0614141.107340.1";
ITable table = FosstrakDatabaseHelper.getObjectEventByEpc(getConnection(), epcToCheck);
assertEquals(0, table.getRowCount());

runCaptureTest(COMMISSION_CASES_XML);

table = FosstrakDatabaseHelper.getObjectEventByEpc(getConnection(), epcToCheck);
assertEquals(1, table.getRowCount());
}

/**
* Capture events test 2.
*/
public void testCommissionPallets() throws Exception {
String epcToCheck = "urn:epc:id:sscc:0614141.0000000001";
ITable table = FosstrakDatabaseHelper.getObjectEventByEpc(getConnection(), epcToCheck);
assertEquals(0, table.getRowCount());

runCaptureTest(COMMISSION_PALLETS_XML);

table = FosstrakDatabaseHelper.getObjectEventByEpc(getConnection(), epcToCheck);
assertEquals(1, table.getRowCount());
}

/**
* Capture events test 3.
*/
public void testPackCases() throws Exception {
String epcToCheck = "urn:epc:id:sgtin:0614141.107340.1";
ITable table = FosstrakDatabaseHelper.getAggregationEventByChildEpc(getConnection(), epcToCheck);
assertEquals(0, table.getRowCount());

runCaptureTest(PACK_CASES_XML);

table = FosstrakDatabaseHelper.getAggregationEventByChildEpc(getConnection(), epcToCheck);
assertEquals(1, table.getRowCount());
}

/**
* Capture events test 4.
*/
public void testReceivePallets() throws Exception {
String epcToCheck = "urn:epc:id:sscc:0614142.0000000010";
ITable table = FosstrakDatabaseHelper.getObjectEventByEpc(getConnection(), epcToCheck);
assertEquals(0, table.getRowCount());

runCaptureTest(REICEIVE_PALLET_XML);

table = FosstrakDatabaseHelper.getObjectEventByEpc(getConnection(), epcToCheck);
assertEquals(1, table.getRowCount());
}

/**
* Capture events test 5.
*/
public void testPickOrder() throws Exception {
String epcToCheck = "urn:epc:id:sgtin:0614141.107341.1";
ITable table = FosstrakDatabaseHelper.getObjectEventByEpc(getConnection(), epcToCheck);
assertEquals(0, table.getRowCount());

runCaptureTest(PICK_ORDER_XML);

table = FosstrakDatabaseHelper.getObjectEventByEpc(getConnection(), epcToCheck);
assertEquals(1, table.getRowCount());
}

/**
* Capture events test 6.
*/
public void testShipOrder() throws Exception {
String epcToCheck = "urn:epc:id:sgtin:0614141.107343.1";
ITable table = FosstrakDatabaseHelper.getTransactionEventByEpc(getConnection(), epcToCheck);
assertEquals(0, table.getRowCount());

runCaptureTest(SHIP_ORDER_XML);

table = FosstrakDatabaseHelper.getTransactionEventByEpc(getConnection(), epcToCheck);
assertEquals(1, table.getRowCount());
}

/**
* Capture events test 7.
*/
public void testReceiveOrder() throws Exception {
String epcToCheck = "urn:epc:id:sgtin:0614142.107349.10";
ITable table = FosstrakDatabaseHelper.getTransactionEventByEpc(getConnection(), epcToCheck);
assertEquals(0, table.getRowCount());

runCaptureTest(RECEIVE_ORDER_XML);

table = FosstrakDatabaseHelper.getTransactionEventByEpc(getConnection(), epcToCheck);
assertEquals(1, table.getRowCount());
}

/**
* Capture events test 8.
*/
public void testStoreInventory() throws Exception {
String epcToCheck = "urn:epc:idpat:sgtin:0614141.107340.*";
ITable table = FosstrakDatabaseHelper.getQuantityEventByEpcClass(getConnection(), epcToCheck);
assertEquals(0, table.getRowCount());

runCaptureTest(STORE_INVENTORY_XML);

table = FosstrakDatabaseHelper.getQuantityEventByEpcClass(getConnection(), epcToCheck);
assertEquals(1, table.getRowCount());
}
}
(7-7/24)