@@ -85,11 +85,12 @@ public Queue<TypedMessageBuilder<byte[]>> handleResultSet(ResultSet resultSet) t
85
85
86
86
final String key = resultSet .getString ("IsOnDatedVehicleJourneyId" ) + resultSet .getString ("JourneyPatternSequenceNumber" );
87
87
final long dvjId = common .getIsOnDatedVehicleJourneyId ();
88
- final long jppId = common .getIsTargetedAtJourneyPatternPointGid ();
88
+ final long scheduledJppId = common .getIsTimetabledAtJourneyPatternPointGid ();
89
+ final long targetedJppId = common .getIsTargetedAtJourneyPatternPointGid ();
89
90
90
- Optional <PubtransTableProtos .DOITripInfo > maybeTripInfo = getTripInfo (dvjId , jppId );
91
+ Optional <PubtransTableProtos .DOITripInfo > maybeTripInfo = getTripInfo (dvjId , scheduledJppId , targetedJppId );
91
92
if (!maybeTripInfo .isPresent ()) {
92
- log .warn ("Could not find valid DOITripInfo from Redis for dvjId {}, jppId {}. Ignoring this update " , dvjId , jppId );
93
+ log .warn ("Could not find valid DOITripInfo from Redis for dvjId {}, timetabledJppId {}, targetedJppId {} . Ignoring this update " , dvjId , scheduledJppId , targetedJppId );
93
94
}
94
95
else {
95
96
final byte [] data = createPayload (resultSet , common , maybeTripInfo .get ());
@@ -156,14 +157,18 @@ private Optional<Map<String, String>> getTripInfoFields(long dvjId) {
156
157
}
157
158
}
158
159
159
- protected Optional <PubtransTableProtos .DOITripInfo > getTripInfo (long dvjId , long jppId ) {
160
+ protected Optional <PubtransTableProtos .DOITripInfo > getTripInfo (long dvjId , long scheduledJppId , long targetedJppId ) {
160
161
try {
161
- Optional <String > maybeStopId = getStopId (jppId );
162
+ Optional <String > maybeScheduledStopId = getStopId (scheduledJppId );
163
+ Optional <String > maybeTargetedStopId = getStopId (targetedJppId );
162
164
Optional <Map <String , String >> maybeTripInfoMap = getTripInfoFields (dvjId );
163
165
164
- if (maybeStopId .isPresent () && maybeTripInfoMap .isPresent ()) {
166
+ if (maybeScheduledStopId .isPresent () && maybeTripInfoMap .isPresent ()) {
165
167
PubtransTableProtos .DOITripInfo .Builder builder = PubtransTableProtos .DOITripInfo .newBuilder ();
166
- builder .setStopId (maybeStopId .get ());
168
+
169
+ builder .setStopId (maybeScheduledStopId .get ());
170
+ maybeTargetedStopId .ifPresent (builder ::setTargetedStopId );
171
+
167
172
maybeTripInfoMap .ifPresent (map -> {
168
173
if (map .containsKey (TransitdataProperties .KEY_DIRECTION ))
169
174
builder .setDirectionId (Integer .parseInt (map .get (TransitdataProperties .KEY_DIRECTION )));
@@ -178,7 +183,7 @@ protected Optional<PubtransTableProtos.DOITripInfo> getTripInfo(long dvjId, long
178
183
return Optional .of (builder .build ());
179
184
}
180
185
else {
181
- log .error ("Failed to get data from Redis for dvjId {}, jppId {}" , dvjId , jppId );
186
+ log .error ("Failed to get data from Redis for dvjId {}, timetabledJppId {}" , dvjId , scheduledJppId );
182
187
return Optional .empty ();
183
188
}
184
189
}
0 commit comments