Skip to content

Commit

Permalink
traffic-event-roadworks-bz: add subcode type to category
Browse files Browse the repository at this point in the history
  • Loading branch information
@dulvui
dulvui committed Oct 5, 2023
1 parent b3af492 commit a3395fb
Showing 1 changed file with 32 additions and 18 deletions.
50 changes: 32 additions & 18 deletions ...adworks-bz/src/main/java/it/bz/noi/trafficeventroadworkbz/MainTrafficEventRoadworkBZ.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -37,31 +37,37 @@ public class MainTrafficEventRoadworkBZ {
public void execute() {
LOG.info("MainTrafficEventRoadworks execute");
try {
List<TrafficEventRoadworkBZModel> trafficEventRoadworkList = trafficEventRoadworkBZConnector.getTrafficEventRoadworksModelList();
List<TrafficEventRoadworkBZModel> trafficEventRoadworkList = trafficEventRoadworkBZConnector
.getTrafficEventRoadworksModelList();
LOG.info("got {} traffic events", trafficEventRoadworkList.size());
List<EventDto> eventDtoList = new ArrayList<>();

for (TrafficEventRoadworkBZModel trafficEventRoadwork : trafficEventRoadworkList) {
EventDto eventDto = new EventDto();

Map<String, Object> uuidFields = getUuidFields(trafficEventRoadwork);
Map<String, Object> uuidFields = getUuidFields(trafficEventRoadwork);
eventDto.setUuid(uuidFields);
eventDto.setEventSeriesUuid(uuidFields);
eventDto.setCategory(trafficEventRoadwork.getTycodeIt() + " | " + trafficEventRoadwork.getTycodeDe());
eventDto.setEventSeriesUuid(uuidFields);
eventDto.setCategory(String.format("%s %s | %s %s", trafficEventRoadwork.getTycodeIt(),
trafficEventRoadwork.getSubTycodeIt(), trafficEventRoadwork.getTycodeDe(),
trafficEventRoadwork.getSubTycodeDe()));
eventDto.setOrigin(configuration.getOrigin());
eventDto.setName(Long.toString(trafficEventRoadwork.getMessageId()));
eventDto.setDescription(trafficEventRoadwork.getDescriptionIt() + " | " + trafficEventRoadwork.getDescriptionDe());
eventDto.setName(Long.toString(trafficEventRoadwork.getMessageId()));
eventDto.setDescription(
trafficEventRoadwork.getDescriptionIt() + " | " + trafficEventRoadwork.getDescriptionDe());

if(trafficEventRoadwork.getX() != null && trafficEventRoadwork.getY() != null) {
if (trafficEventRoadwork.getX() != null && trafficEventRoadwork.getY() != null) {
GeometryFactory geometryFactory = new GeometryFactory(new PrecisionModel(), 4326);
Coordinate coordinate = new Coordinate(trafficEventRoadwork.getX(), trafficEventRoadwork.getY());
Point point = geometryFactory.createPoint(coordinate);
eventDto.setWktGeometry(point.toText());
}

eventDto.setEventStart(trafficEventRoadwork.getBeginDateAsEpochMillis());
if(trafficEventRoadwork.getEndDate() != null)
eventDto.setEventEnd(trafficEventRoadwork.getEndDateAsEpochMillis() + 1); // +1 because we exclude the upper bound --> [lower,upper)
if (trafficEventRoadwork.getEndDate() != null)
eventDto.setEventEnd(trafficEventRoadwork.getEndDateAsEpochMillis() + 1); // +1 because we exclude
// the upper bound -->
// [lower,upper)

eventDto.getMetaData().put("json_featuretype", trafficEventRoadwork.getJson_featuretype());
eventDto.getMetaData().put("publisherDateTime", trafficEventRoadwork.getPublisherDateTime());
Expand All @@ -85,14 +91,21 @@ public void execute() {
eventDto.getMetaData().put("messageStreetId", trafficEventRoadwork.getMessageStreetId());
eventDto.getMetaData().put("messageStreetWapDescDe", trafficEventRoadwork.getMessageStreetWapDescDe());
eventDto.getMetaData().put("messageStreetWapDescIt", trafficEventRoadwork.getMessageStreetWapDescIt());
eventDto.getMetaData().put("messageStreetInternetDescDe", trafficEventRoadwork.getMessageStreetInternetDescDe());
eventDto.getMetaData().put("messageStreetInternetDescIt", trafficEventRoadwork.getMessageStreetInternetDescIt());
eventDto.getMetaData().put("messageStreetInternetDescDe",
trafficEventRoadwork.getMessageStreetInternetDescDe());
eventDto.getMetaData().put("messageStreetInternetDescIt",
trafficEventRoadwork.getMessageStreetInternetDescIt());
eventDto.getMetaData().put("messageStreetNr", trafficEventRoadwork.getMessageStreetNr());
eventDto.getMetaData().put("messageStreetHierarchie", trafficEventRoadwork.getMessageStreetHierarchie());
// Don't save message type, because it causes duplicate entries. More info here https://github.com/noi-techpark/bdp-commons/issues/599
// eventDto.getMetaData().put("messageTypeId", trafficEventRoadwork.getMessageTypeId());
// eventDto.getMetaData().put("messageTypeDescDe", trafficEventRoadwork.getMessageTypeDescDe());
// eventDto.getMetaData().put("messageTypeDescIt", trafficEventRoadwork.getMessageTypeDescIt());
eventDto.getMetaData().put("messageStreetHierarchie",
trafficEventRoadwork.getMessageStreetHierarchie());
// Don't save message type, because it causes duplicate entries. More info here
// https://github.com/noi-techpark/bdp-commons/issues/599
// eventDto.getMetaData().put("messageTypeId",
// trafficEventRoadwork.getMessageTypeId());
// eventDto.getMetaData().put("messageTypeDescDe",
// trafficEventRoadwork.getMessageTypeDescDe());
// eventDto.getMetaData().put("messageTypeDescIt",
// trafficEventRoadwork.getMessageTypeDescIt());

eventDtoList.add(eventDto);
}
Expand All @@ -107,12 +120,13 @@ private Map<String, Object> getUuidFields(TrafficEventRoadworkBZModel trafficEve
HashMap<String, Object> uuidMap = new HashMap<>();
uuidMap.put("beginDate", trafficEventRoadwork.getBeginDate());
uuidMap.put("endDate", trafficEventRoadwork.getEndDate());
// Don't save message type, because it causes duplicate entries. More info here https://github.com/noi-techpark/bdp-commons/issues/599
// Don't save message type, because it causes duplicate entries. More info here
// https://github.com/noi-techpark/bdp-commons/issues/599
// uuidMap.put("messageId", trafficEventRoadwork.getMessageId());
// uuidMap.put("messageTypeId", trafficEventRoadwork.getMessageTypeId());
uuidMap.put("X", trafficEventRoadwork.getX());
uuidMap.put("Y", trafficEventRoadwork.getY());
return uuidMap;
return uuidMap;
}

}

0 comments on commit a3395fb

Please sign in to comment.