dddsample/external/reporting/src/main/java/com.reporting/CargoReport.java

@@ -1,140 +0,0 @@
-package com.reporting;
-
-import javax.xml.bind.annotation.XmlRootElement;
-import java.util.Date;
-import java.util.List;
-
-@XmlRootElement(name = "cargo")
-public class CargoReport {
-
-  String trackingId;
-  String receivedIn;
-  String finalDestination;
-  String arrivalDeadline;
-  String eta;
-  String currentStatus;
-  String currentVoyage;
-  String currentLocation;
-  String lastUpdatedOn;
-  List<Handling> handlings;
-
-  public String getTrackingId() {
-    return trackingId;
-  }
-
-  public void setTrackingId(String trackingId) {
-    this.trackingId = trackingId;
-  }
-
-  public String getReceivedIn() {
-    return receivedIn;
-  }
-
-  public void setReceivedIn(String receivedIn) {
-    this.receivedIn = receivedIn;
-  }
-
-  public String getFinalDestination() {
-    return finalDestination;
-  }
-
-  public void setFinalDestination(String finalDestination) {
-    this.finalDestination = finalDestination;
-  }
-
-  public String getArrivalDeadline() {
-    return arrivalDeadline;
-  }
-
-  public void setArrivalDeadline(String arrivalDeadline) {
-    this.arrivalDeadline = arrivalDeadline;
-  }
-
-  public String getEta() {
-    return eta;
-  }
-
-  public void setEta(String eta) {
-    this.eta = eta;
-  }
-
-  public String getCurrentStatus() {
-    return currentStatus;
-  }
-
-  public void setCurrentStatus(String currentStatus) {
-    this.currentStatus = currentStatus;
-  }
-
-  public String getCurrentVoyage() {
-    return currentVoyage;
-  }
-
-  public void setCurrentVoyage(String currentVoyage) {
-    this.currentVoyage = currentVoyage;
-  }
-
-  public String getCurrentLocation() {
-    return currentLocation;
-  }
-
-  public void setCurrentLocation(String currentLocation) {
-    this.currentLocation = currentLocation;
-  }
-
-  public List<Handling> getHandlings() {
-    return handlings;
-  }
-
-  public void setHandlings(List<Handling> handlings) {
-    this.handlings = handlings;
-  }
-
-  public String getLastUpdatedOn() {
-    return lastUpdatedOn;
-  }
-
-  public void setLastUpdatedOn(String lastUpdatedOn) {
-    this.lastUpdatedOn = lastUpdatedOn;
-  }
-
-  public static class Handling {
-    String type;
-    String location;
-    String voyage;
-    String completedOn;
-
-    public String getType() {
-      return type;
-    }
-
-    public void setType(String type) {
-      this.type = type;
-    }
-
-    public String getLocation() {
-      return location;
-    }
-
-    public void setLocation(String location) {
-      this.location = location;
-    }
-
-    public String getVoyage() {
-      return voyage;
-    }
-
-    public void setVoyage(String voyage) {
-      this.voyage = voyage;
-    }
-
-    public String getCompletedOn() {
-      return completedOn;
-    }
-
-    public void setCompletedOn(String completedOn) {
-      this.completedOn = completedOn;
-    }
-  }
-
-}

dddsample/external/reporting/src/main/java/com.reporting/CargoReportRowMapper.java

@@ -1,27 +0,0 @@
-package com.reporting;
-
-import org.springframework.jdbc.core.simple.ParameterizedRowMapper;
-
-import java.sql.ResultSet;
-import java.sql.SQLException;
-
-import static com.reporting.Constants.*;
-
-class CargoReportRowMapper implements ParameterizedRowMapper<CargoReport> {
-
-  @Override
-  public CargoReport mapRow(ResultSet rs, int rowNum) throws SQLException {
-    CargoReport cargoReport = new CargoReport();
-    cargoReport.setTrackingId(rs.getString("cargo_tracking_id"));
-    cargoReport.setArrivalDeadline(US_DATETIME.format(rs.getTimestamp("arrival_deadline")));
-    cargoReport.setCurrentLocation(rs.getString("current_location"));
-    cargoReport.setCurrentStatus(rs.getString("current_status"));
-    cargoReport.setCurrentVoyage(rs.getString("current_voyage_number"));
-    cargoReport.setEta(US_DATETIME.format(rs.getTimestamp("eta")));
-    cargoReport.setFinalDestination(rs.getString("destination"));
-    cargoReport.setLastUpdatedOn(US_DATETIME.format(rs.getTimestamp("last_updated_on")));
-    cargoReport.setReceivedIn(rs.getString("received_in"));
-    return cargoReport;
-  }
-
-}

dddsample/external/reporting/src/main/java/com.reporting/Constants.java

@@ -1,10 +0,0 @@
-package com.reporting;
-
-import java.text.DateFormat;
-import java.util.Locale;
-
-public interface Constants {
-
-  DateFormat US_DATETIME = DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.SHORT, Locale.US);
-
-}

dddsample/external/reporting/src/main/java/com.reporting/HandlingRowMapper.java

@@ -1,22 +0,0 @@
-package com.reporting;
-
-import org.springframework.jdbc.core.simple.ParameterizedRowMapper;
-
-import java.sql.ResultSet;
-import java.sql.SQLException;
-
-import static com.reporting.Constants.*;
-
-class HandlingRowMapper implements ParameterizedRowMapper<CargoReport.Handling> {
-
-  @Override
-  public CargoReport.Handling mapRow(ResultSet rs, int rowNum) throws SQLException {
-    CargoReport.Handling handling = new CargoReport.Handling();
-    handling.setCompletedOn(US_DATETIME.format(rs.getTimestamp("completed_on")));
-    handling.setLocation(rs.getString("location"));
-    handling.setType(rs.getString("type"));
-    handling.setVoyage(rs.getString("voyage_number"));
-    return handling;
-  }
-
-}

dddsample/external/reporting/src/main/java/com.reporting/PDFCargoReportProvider.java

@@ -1,43 +0,0 @@
-package com.reporting;
-
-import com.lowagie.text.*;
-import com.lowagie.text.pdf.PdfPTable;
-import static com.lowagie.text.FontFactory.*;
-
-import javax.ws.rs.ext.Provider;
-import javax.ws.rs.Produces;
-
-@Produces("application/pdf")
-@Provider
-public class PDFCargoReportProvider extends PDFMessageBodyWriter<CargoReport> {
-
-  @Override
-  protected Class<CargoReport> getSupportedClass() {
-    return CargoReport.class;
-  }
-
-  @Override
-  protected void buildDocument(CargoReport cargoReport, Document document) {
-    try {
-      document.add(new Paragraph("Cargo " + cargoReport.getTrackingId(), getFont(HELVETICA_BOLD, 18.0f)));
-      document.add(new Paragraph("Status: " + cargoReport.getCurrentStatus()));
-      document.add(new Paragraph("Location: " + cargoReport.getCurrentLocation()));
-      document.add(new Paragraph("Voyage: " + cargoReport.getCurrentVoyage()));
-      document.add(new Paragraph("Destination: " + cargoReport.getFinalDestination()));
-      document.add(new Paragraph("Arrival deadline: " + cargoReport.getArrivalDeadline()));
-      document.add(new Paragraph("ETA: " + cargoReport.getEta()));
-
-      document.add(new Paragraph("Handling history", getFont(HELVETICA_BOLD)));
-      PdfPTable table = new PdfPTable(4);
-      for (CargoReport.Handling handling : cargoReport.getHandlings()) {
-        table.addCell(handling.getType());
-        table.addCell(handling.getLocation());
-        table.addCell(handling.getVoyage());
-        table.addCell(handling.getCompletedOn());
-      }
-    } catch (DocumentException e) {
-      throw new RuntimeException(e);
-    }
-  }
-
-}

dddsample/external/reporting/src/main/java/com.reporting/PDFMessageBodyWriter.java

@@ -1,48 +0,0 @@
-package com.reporting;
-
-import com.lowagie.text.Document;
-import com.lowagie.text.DocumentException;
-import com.lowagie.text.pdf.PdfWriter;
-
-import javax.ws.rs.ext.MessageBodyWriter;
-import javax.ws.rs.core.MediaType;
-import javax.ws.rs.core.MultivaluedMap;
-import java.lang.reflect.Type;
-import java.lang.annotation.Annotation;
-import java.io.ByteArrayOutputStream;
-import java.io.OutputStream;
-import java.io.IOException;
-
-public abstract class PDFMessageBodyWriter<T> implements MessageBodyWriter<T> {
-
-  public long getSize(T t, Class<?> type, Type genericType, Annotation[] annotations, MediaType mt) {
-    ByteArrayOutputStream baos = new ByteArrayOutputStream();
-    writeDocumentToStream(t, baos);
-    return baos.toByteArray().length;
-  }
-
-  public boolean isWriteable(Class<?> type, Type genericType, Annotation[] annotations, MediaType mt) {
-    return getSupportedClass().isAssignableFrom(type);
-  }
-
-  public void writeTo(T t, Class<?> clazz, Type type, Annotation[] a, MediaType mt, MultivaluedMap<String, Object> headers, OutputStream os) throws IOException {
-    writeDocumentToStream(t, os);
-  }
-
-  protected void writeDocumentToStream(T t, OutputStream os) {
-    Document document = new Document();
-    try {
-      PdfWriter.getInstance(document, os);
-    } catch (DocumentException e) {
-      throw new RuntimeException(e);
-    }
-    document.open();
-    buildDocument(t, document);
-    document.close();
-  }
-
-  protected abstract void buildDocument(T t, Document document);
-
-  protected abstract Class<T> getSupportedClass();
-
-}

dddsample/external/reporting/src/main/java/com.reporting/PDFVoyageReportProvider.java

@@ -1,28 +0,0 @@
-package com.reporting;
-
-import com.lowagie.text.Document;
-import com.lowagie.text.DocumentException;
-import com.lowagie.text.Paragraph;
-
-import javax.ws.rs.Produces;
-import javax.ws.rs.ext.Provider;
-
-@Produces("application/pdf")
-@Provider
-public class PDFVoyageReportProvider extends PDFMessageBodyWriter<VoyageReport> {
-
-  @Override
-  protected Class<VoyageReport> getSupportedClass() {
-    return VoyageReport.class;
-  }
-
-  @Override
-  protected void buildDocument(VoyageReport voyageReport, Document document) {
-    try {
-      document.add(new Paragraph("Voyage " + voyageReport.getVoyageNumber()));
-    } catch (DocumentException e) {
-      throw new RuntimeException(e);
-    }
-  }
-
-}

dddsample/external/reporting/src/main/java/com.reporting/ReportingService.java

@@ -1,129 +0,0 @@
-package com.reporting;
-
-import static com.reporting.Constants.US_DATETIME;
-import org.springframework.dao.EmptyResultDataAccessException;
-import org.springframework.jdbc.core.JdbcTemplate;
-import org.springframework.jdbc.core.RowCallbackHandler;
-import org.springframework.jdbc.core.simple.ParameterizedRowMapper;
-import org.springframework.transaction.annotation.Transactional;
-
-import javax.sql.DataSource;
-import javax.ws.rs.GET;
-import javax.ws.rs.Path;
-import javax.ws.rs.PathParam;
-import javax.ws.rs.Produces;
-import javax.ws.rs.core.Response;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.text.ParseException;
-import java.util.ArrayList;
-import java.util.List;
-
-@Produces({"application/json", "application/pdf"})
-@Path("/report")
-public class ReportingService {
-
-  private JdbcTemplate jdbc;
-  private HandlingRowMapper handlingRowMapper;
-  private CargoReportRowMapper cargoReportRowMapper;
-  private VoyageReportRowMapper rowMapper;
-
-  public ReportingService(DataSource dataSource) {
-    this.jdbc = new JdbcTemplate(dataSource);
-    this.handlingRowMapper = new HandlingRowMapper();
-    this.cargoReportRowMapper = new CargoReportRowMapper();
-    this.rowMapper = new VoyageReportRowMapper();
-  }
-
-  @GET
-  @Path("/cargo/{trackingId}")
-  @Transactional
-  public Response getCargoReport(@PathParam("trackingId") String trackingId) throws ParseException {
-    CargoReport cargoReport = loadCargoReport(trackingId);
-    if (cargoReport == null) return null;
-
-    cargoReport.setHandlings(loadHandlings(trackingId));
-
-    return Response.ok(cargoReport).
-      lastModified(US_DATETIME.parse(cargoReport.getLastUpdatedOn())).
-      build();
-  }
-
-  @GET
-  @Path("/voyage/{voyageNumber}")
-  @Transactional
-  public Response getVoyageReport(@PathParam("voyageNumber") String voyageNumber) throws ParseException {
-    VoyageReport voyageReport = loadVoyageReport(voyageNumber);
-    if (voyageReport == null) return null;
-
-    voyageReport.setOnboardCargos(loadOnboardCargos(voyageNumber));
-
-    return Response.ok(voyageReport).
-      lastModified(US_DATETIME.parse(voyageReport.getLastUpdatedOn())).
-      build();
-  }
-
-  // --- Private methods ---
-
-  private CargoReport loadCargoReport(String trackingId) {
-    try {
-      String[] args = {trackingId};
-      String sql = "select * from cargo where cargo_tracking_id = ?";
-      return (CargoReport) jdbc.queryForObject(sql, args, cargoReportRowMapper);
-    } catch (EmptyResultDataAccessException e) {
-      return null;
-    }
-  }
-
-  private List<CargoReport.Handling> loadHandlings(String trackingId) {
-    final List<CargoReport.Handling> handlings = new ArrayList<CargoReport.Handling>();
-    RowCallbackHandler handler = new RowCallbackHandler() {
-      @Override
-      public void processRow(ResultSet rs) throws SQLException {
-        handlings.add(handlingRowMapper.mapRow(rs, rs.getRow()));
-      }
-    };
-    String[] args = {trackingId};
-    String sql = "select * from handling where cargo_tracking_id = ?";
-    jdbc.query(sql, args, handler);
-    return handlings;
-  }
-
-  private List<VoyageReport.Cargo> loadOnboardCargos(String voyageNumber) {
-    final List<VoyageReport.Cargo> cargos = new ArrayList<VoyageReport.Cargo>();
-    final ParameterizedRowMapper<VoyageReport.Cargo> rowMapper = new ParameterizedRowMapper<VoyageReport.Cargo>() {
-      @Override
-      public VoyageReport.Cargo mapRow(ResultSet rs, int rowNum) throws SQLException {
-        VoyageReport.Cargo cargo = new VoyageReport.Cargo();
-        cargo.setTrackingId(rs.getString("cargo_tracking_id"));
-        cargo.setFinalDestination(rs.getString("destination"));
-        return cargo;
-      }
-    };
-    String[] args = {voyageNumber};
-    String sql = "select cargo_tracking_id, destination from cargo where current_voyage_number = ?";
-    jdbc.query(sql, args, new RowCallbackHandler() {
-      @Override
-      public void processRow(ResultSet rs) throws SQLException {
-        cargos.add(rowMapper.mapRow(rs, rs.getRow()));
-      }
-    });
-
-    return cargos;
-  }
-
-  private VoyageReport loadVoyageReport(String voyageNumber) {
-    String[] args = {voyageNumber};
-    String sql = "select * from voyage where voyage_number = ?";
-    try {
-      return (VoyageReport) jdbc.queryForObject(sql, args, rowMapper);
-    } catch (EmptyResultDataAccessException e) {
-      return null;
-    }
-  }
-
-  ReportingService() {
-    // Needed by CGLIB
-  }
-
-}

dddsample/external/reporting/src/main/java/com.reporting/VoyageReport.java

@@ -1,95 +0,0 @@
-package com.reporting;
-
-import javax.xml.bind.annotation.XmlRootElement;
-import java.util.List;
-import java.util.ArrayList;
-
-@XmlRootElement(name = "voyage")
-public class VoyageReport {
-
-  private String voyageNumber;
-  private String nextStop;
-  private String etaNextStop;
-  private String currentStatus;
-  private int delayedByMinutes;
-  private String lastUpdatedOn;
-  private List<Cargo> onboardCargos = new ArrayList<Cargo>();
-
-  public String getVoyageNumber() {
-    return voyageNumber;
-  }
-
-  public void setVoyageNumber(String voyageNumber) {
-    this.voyageNumber = voyageNumber;
-  }
-
-  public String getNextStop() {
-    return nextStop;
-  }
-
-  public void setNextStop(String nextStop) {
-    this.nextStop = nextStop;
-  }
-
-  public String getEtaNextStop() {
-    return etaNextStop;
-  }
-
-  public void setEtaNextStop(String etaNextStop) {
-    this.etaNextStop = etaNextStop;
-  }
-
-  public String getCurrentStatus() {
-    return currentStatus;
-  }
-
-  public void setCurrentStatus(String currentStatus) {
-    this.currentStatus = currentStatus;
-  }
-
-  public int getDelayedByMinutes() {
-    return delayedByMinutes;
-  }
-
-  public void setDelayedByMinutes(int delayedByMinutes) {
-    this.delayedByMinutes = delayedByMinutes;
-  }
-
-  public String getLastUpdatedOn() {
-    return lastUpdatedOn;
-  }
-
-  public void setLastUpdatedOn(String lastUpdatedOn) {
-    this.lastUpdatedOn = lastUpdatedOn;
-  }
-
-  public List<Cargo> getOnboardCargos() {
-    return onboardCargos;
-  }
-
-  public void setOnboardCargos(List<Cargo> onboardCargos) {
-    this.onboardCargos = onboardCargos;
-  }
-
-  public static class Cargo {
-    String trackingId;
-    String finalDestination;
-
-    public String getTrackingId() {
-      return trackingId;
-    }
-
-    public void setTrackingId(String trackingId) {
-      this.trackingId = trackingId;
-    }
-
-    public String getFinalDestination() {
-      return finalDestination;
-    }
-
-    public void setFinalDestination(String finalDestination) {
-      this.finalDestination = finalDestination;
-    }
-  }
-
-}

dddsample/external/reporting/src/main/java/com.reporting/VoyageReportRowMapper.java

@@ -1,22 +0,0 @@
-package com.reporting;
-
-import org.springframework.jdbc.core.simple.ParameterizedRowMapper;
-
-import java.sql.ResultSet;
-import java.sql.SQLException;
-
-import static com.reporting.Constants.*;
-
-class VoyageReportRowMapper implements ParameterizedRowMapper<VoyageReport> {
-  @Override
-  public VoyageReport mapRow(ResultSet rs, int rowNum) throws SQLException {
-    VoyageReport voyageReport = new VoyageReport();
-    voyageReport.setVoyageNumber(rs.getString("voyage_number"));
-    voyageReport.setCurrentStatus(rs.getString("current_status"));
-    voyageReport.setDelayedByMinutes(rs.getInt("delayed_by_min"));
-    voyageReport.setEtaNextStop(US_DATETIME.format(rs.getTimestamp("eta_next_stop")));
-    voyageReport.setLastUpdatedOn(US_DATETIME.format(rs.getTimestamp("last_updated_on")));
-    voyageReport.setNextStop(rs.getString("next_stop"));
-    return voyageReport;
-  }
-}