Skip to content

Commit

Permalink
Counting only when new value is applied
Browse files Browse the repository at this point in the history
  • Loading branch information
lassetyr committed Nov 14, 2023
1 parent 3d32135 commit c8dc8e7
Showing 1 changed file with 16 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -53,21 +53,24 @@ public void process(Siri siri) {
List<EstimatedVehicleJourney> estimatedVehicleJourneies = estimatedJourneyVersionFrame.getEstimatedVehicleJourneies();
for (EstimatedVehicleJourney estimatedVehicleJourney : estimatedVehicleJourneies) {

int counter = 0;
int updatedOrderIndex = 0;
int ruleAppliedCounter = 0;
final EstimatedVehicleJourney.RecordedCalls recordedCallsObj = estimatedVehicleJourney.getRecordedCalls();
if (recordedCallsObj != null) {
final List<RecordedCall> recordedCalls = recordedCallsObj.getRecordedCalls();
for (RecordedCall call : recordedCalls) {
if (call.getOrder() == null) {
counter++;
updatedOrderIndex++;
if (call.getVisitNumber() != null) {
call.setOrder(call.getVisitNumber());
counter = call.getVisitNumber().intValue();
updatedOrderIndex = call.getVisitNumber().intValue();
ruleAppliedCounter++;
} else {
call.setOrder(BigInteger.valueOf(counter));
call.setOrder(BigInteger.valueOf(updatedOrderIndex));
ruleAppliedCounter++;
}
} else {
counter = call.getOrder().intValue();
updatedOrderIndex = call.getOrder().intValue();
}
}
}
Expand All @@ -77,24 +80,26 @@ public void process(Siri siri) {
final List<EstimatedCall> estimatedCalls = estimatedCallsObj.getEstimatedCalls();
for (EstimatedCall call : estimatedCalls) {
if (call.getOrder() == null) {
counter++;
updatedOrderIndex++;
if (call.getVisitNumber() != null) {
call.setOrder(call.getVisitNumber());
counter = call.getVisitNumber().intValue();
updatedOrderIndex = call.getVisitNumber().intValue();
ruleAppliedCounter++;
} else {
call.setOrder(BigInteger.valueOf(counter));
call.setOrder(BigInteger.valueOf(updatedOrderIndex));
ruleAppliedCounter++;
}
} else {
counter = call.getOrder().intValue();
updatedOrderIndex = call.getOrder().intValue();
}
}
}
if (counter > 0) {
if (ruleAppliedCounter > 0) {
getMetricsService().registerDataMapping(
SiriDataType.ESTIMATED_TIMETABLE,
datasetId,
ADD_ORDER_TO_CALLS,
counter
ruleAppliedCounter
);
}
}
Expand Down

0 comments on commit c8dc8e7

Please sign in to comment.