001package jmri.jmrit.operations.trains; 002 003import java.io.File; 004import java.io.IOException; 005import java.util.List; 006import java.util.Locale; 007 008import org.apache.commons.text.StringEscapeUtils; 009import org.slf4j.Logger; 010import org.slf4j.LoggerFactory; 011 012import com.fasterxml.jackson.databind.ObjectMapper; 013import com.fasterxml.jackson.databind.SerializationFeature; 014import com.fasterxml.jackson.databind.node.ArrayNode; 015import com.fasterxml.jackson.databind.node.ObjectNode; 016 017import jmri.InstanceManager; 018import jmri.jmrit.operations.locations.Track; 019import jmri.jmrit.operations.rollingstock.cars.Car; 020import jmri.jmrit.operations.rollingstock.engines.Engine; 021import jmri.jmrit.operations.routes.RouteLocation; 022import jmri.jmrit.operations.setup.Setup; 023import jmri.server.json.JSON; 024import jmri.server.json.operations.JsonOperations; 025import jmri.server.json.operations.JsonUtil; 026 027/** 028 * A minimal manifest in JSON. 029 * 030 * This manifest is intended to be read by machines for building manifests in 031 * other, human-readable outputs. This manifest is retained at build time so 032 * that manifests can be endlessly recreated in other formats, even if the 033 * operations database state has changed. It is expected that the parsers for 034 * this manifest will be capable of querying operations for more specific 035 * information while transforming this manifest into other formats. 036 * 037 * @author Randall Wood 038 * @author Daniel Boudreau 1/26/2015 Load all cars including utility cars into 039 * the JSON file, and tidied up the code a bit. 040 * 041 */ 042public class JsonManifest extends TrainCommon { 043 044 protected final Locale locale = Locale.getDefault(); 045 protected final Train train; 046 private final ObjectMapper mapper = new ObjectMapper(); 047 private final JsonUtil utilities = new JsonUtil(mapper); 048 049 private final static Logger log = LoggerFactory.getLogger(JsonManifest.class); 050 051 public JsonManifest(Train train) { 052 this.train = train; 053 this.mapper.enable(SerializationFeature.INDENT_OUTPUT); 054 } 055 056 public File getFile() { 057 return InstanceManager.getDefault(TrainManagerXml.class).getManifestFile(this.train.getName(), JSON.JSON); 058 } 059 060 public void build() throws IOException { 061 ObjectNode root = this.mapper.createObjectNode(); 062 if (!this.train.getRailroadName().equals(Train.NONE)) { 063 root.put(JSON.RAILROAD, StringEscapeUtils.escapeHtml4(this.train.getRailroadName())); 064 } else { 065 root.put(JSON.RAILROAD, StringEscapeUtils.escapeHtml4(Setup.getRailroadName())); 066 } 067 root.put(JSON.USERNAME, StringEscapeUtils.escapeHtml4(this.train.getName())); 068 root.put(JSON.DESCRIPTION, StringEscapeUtils.escapeHtml4(this.train.getDescription())); 069 root.set(JsonOperations.LOCATIONS, this.getLocations()); 070 if (!this.train.getManifestLogoPathName().equals(Train.NONE)) { 071 // The operationsServlet will need to change this to a usable URL 072 root.put(JSON.IMAGE, this.train.getManifestLogoPathName()); 073 } 074 root.put(JsonOperations.DATE, TrainCommon.getISO8601Date(true)); // Validity 075 this.mapper.writeValue(InstanceManager.getDefault(TrainManagerXml.class).createManifestFile(this.train.getName(), JSON.JSON), root); 076 } 077 078 public ArrayNode getLocations() { 079 // get engine and car lists 080 List<Engine> engineList = engineManager.getByTrainBlockingList(train); 081 List<Car> carList = carManager.getByTrainDestinationList(train); 082 ArrayNode locations = this.mapper.createArrayNode(); 083 List<RouteLocation> route = train.getRoute().getLocationsBySequenceList(); 084 for (RouteLocation routeLocation : route) { 085 String locationName = routeLocation.getSplitName(); 086 ObjectNode jsonLocation = this.mapper.createObjectNode(); 087 ObjectNode jsonCars = this.mapper.createObjectNode(); 088 jsonLocation.put(JSON.USERNAME, StringEscapeUtils.escapeHtml4(locationName)); 089 jsonLocation.put(JSON.NAME, routeLocation.getId()); 090 if (routeLocation != train.getTrainDepartsRouteLocation()) { 091 jsonLocation.put(JSON.ARRIVAL_TIME, train.getExpectedArrivalTime(routeLocation)); 092 } 093 if (routeLocation == train.getTrainDepartsRouteLocation()) { 094 jsonLocation.put(JSON.DEPARTURE_TIME, train.getDepartureTime()); 095 } else if (!routeLocation.getDepartureTime().equals(RouteLocation.NONE)) { 096 jsonLocation.put(JSON.DEPARTURE_TIME, routeLocation.getDepartureTime()); 097 } else { 098 jsonLocation.put(JSON.EXPECTED_DEPARTURE, train.getExpectedDepartureTime(routeLocation)); 099 } 100 // add location comment and id 101 ObjectNode locationNode = this.mapper.createObjectNode(); 102 locationNode.put(JSON.COMMENT, 103 StringEscapeUtils.escapeHtml4(routeLocation.getLocation().getCommentWithColor())); 104 locationNode.put(JSON.NAME, routeLocation.getLocation().getId()); 105 jsonLocation.set(JsonOperations.LOCATION, locationNode); 106 jsonLocation.put(JSON.COMMENT, StringEscapeUtils.escapeHtml4(routeLocation.getCommentWithColor())); 107 // engine change or helper service? 108 if (train.getSecondLegOptions() != Train.NO_CABOOSE_OR_FRED) { 109 ArrayNode options = this.mapper.createArrayNode(); 110 if (routeLocation == train.getSecondLegStartRouteLocation()) { 111 if ((train.getSecondLegOptions() & Train.HELPER_ENGINES) == Train.HELPER_ENGINES) { 112 options.add(JSON.ADD_HELPERS); 113 } else if ((train.getSecondLegOptions() & Train.REMOVE_CABOOSE) == Train.REMOVE_CABOOSE 114 || (train.getSecondLegOptions() & Train.ADD_CABOOSE) == Train.ADD_CABOOSE) { 115 options.add(JSON.CHANGE_CABOOSE); 116 } else if ((train.getSecondLegOptions() & Train.CHANGE_ENGINES) == Train.CHANGE_ENGINES) { 117 options.add(JSON.CHANGE_ENGINES); 118 } 119 } 120 if (routeLocation == train.getSecondLegEndRouteLocation()) { 121 options.add(JSON.REMOVE_HELPERS); 122 } 123 jsonLocation.set(JSON.OPTIONS, options); 124 } 125 if (train.getThirdLegOptions() != Train.NO_CABOOSE_OR_FRED) { 126 ArrayNode options = this.mapper.createArrayNode(); 127 if (routeLocation == train.getThirdLegStartRouteLocation()) { 128 if ((train.getThirdLegOptions() & Train.HELPER_ENGINES) == Train.HELPER_ENGINES) { 129 options.add(JSON.ADD_HELPERS); 130 } else if ((train.getThirdLegOptions() & Train.REMOVE_CABOOSE) == Train.REMOVE_CABOOSE 131 || (train.getThirdLegOptions() & Train.ADD_CABOOSE) == Train.ADD_CABOOSE) { 132 options.add(JSON.CHANGE_CABOOSE); 133 } else if ((train.getThirdLegOptions() & Train.CHANGE_ENGINES) == Train.CHANGE_ENGINES) { 134 options.add(JSON.CHANGE_ENGINES); 135 } 136 } 137 if (routeLocation == train.getThirdLegEndRouteLocation()) { 138 options.add(JSON.ADD_HELPERS); 139 } 140 jsonLocation.set(JSON.OPTIONS, options); 141 } 142 143 ObjectNode engines = this.mapper.createObjectNode(); 144 engines.set(JSON.ADD, pickupEngines(engineList, routeLocation)); 145 engines.set(JSON.REMOVE, dropEngines(engineList, routeLocation)); 146 jsonLocation.set(JSON.ENGINES, engines); 147 148 // block cars by destination 149 // caboose or FRED is placed at end of the train 150 // passenger cars are already blocked in the car list 151 // passenger cars with negative block numbers are placed at 152 // the front of the train, positive numbers at the end of 153 // the train. 154 ArrayNode pickups = this.mapper.createArrayNode(); 155 for (RouteLocation destination : route) { 156 for (Car car : carList) { 157 if (isNextCar(car, routeLocation, destination)) { 158 pickups.add(this.utilities.getCar(car, locale)); 159 } 160 } 161 } 162 jsonCars.set(JSON.ADD, pickups); 163 // car set outs 164 ArrayNode setouts = this.mapper.createArrayNode(); 165 for (Car car : carList) { 166 if (car.getRouteDestination() == routeLocation) { 167 setouts.add(this.utilities.getCar(car, locale)); 168 } 169 } 170 jsonCars.set(JSON.REMOVE, setouts); 171 172 jsonLocation.set(JsonOperations.TRACK, this.getTrackComments(routeLocation, carList)); 173 174 if (routeLocation != train.getTrainTerminatesRouteLocation()) { 175 jsonLocation.put(JSON.TRAIN_DIRECTION, routeLocation.getTrainDirection()); 176 ObjectNode length = this.mapper.createObjectNode(); 177 length.put(JSON.LENGTH, train.getTrainLength(routeLocation)); 178 length.put(JSON.UNIT, Setup.getLengthUnit()); 179 jsonLocation.set(JSON.LENGTH, length); 180 jsonLocation.put(JsonOperations.WEIGHT, train.getTrainWeight(routeLocation)); 181 int cars = train.getNumberCarsInTrain(routeLocation); 182 int emptyCars = train.getNumberEmptyCarsInTrain(routeLocation); 183 jsonCars.put(JSON.TOTAL, cars); 184 jsonCars.put(JSON.LOADS, cars - emptyCars); 185 jsonCars.put(JSON.EMPTIES, emptyCars); 186 } else { 187 log.debug("Train terminates in {}", locationName); 188 jsonLocation.put("TrainTerminatesIn", StringEscapeUtils.escapeHtml4(locationName)); 189 } 190 jsonLocation.set(JsonOperations.CARS, jsonCars); 191 locations.add(jsonLocation); 192 } 193 return locations; 194 } 195 196 protected ArrayNode dropEngines(List<Engine> engines, RouteLocation routeLocation) { 197 ArrayNode node = this.mapper.createArrayNode(); 198 for (Engine engine : engines) { 199 if (engine.getRouteDestination() != null && engine.getRouteDestination().equals(routeLocation)) { 200 node.add(this.utilities.getEngine(engine, locale)); 201 } 202 } 203 return node; 204 } 205 206 protected ArrayNode pickupEngines(List<Engine> engines, RouteLocation routeLocation) { 207 ArrayNode node = this.mapper.createArrayNode(); 208 for (Engine engine : engines) { 209 if (engine.getRouteLocation() != null && engine.getRouteLocation().equals(routeLocation)) { 210 node.add(this.utilities.getEngine(engine, locale)); 211 } 212 } 213 return node; 214 } 215 216 // TODO: migrate comments into actual setout/pickup track location spaces 217 private ObjectNode getTrackComments(RouteLocation routeLocation, List<Car> cars) { 218 ObjectNode comments = this.mapper.createObjectNode(); 219 if (routeLocation.getLocation() != null) { 220 List<Track> tracks = routeLocation.getLocation().getTracksByNameList(null); 221 for (Track track : tracks) { 222 ObjectNode jsonTrack = this.mapper.createObjectNode(); 223 jsonTrack.put(JSON.ADD, StringEscapeUtils.escapeHtml4(track.getCommentPickupWithColor())); 224 jsonTrack.put(JSON.REMOVE, StringEscapeUtils.escapeHtml4(track.getCommentSetoutWithColor())); 225 jsonTrack.put(JSON.ADD_AND_REMOVE, StringEscapeUtils.escapeHtml4(track.getCommentBothWithColor())); 226 jsonTrack.put(JSON.COMMENT, StringEscapeUtils.escapeHtml4(track.getComment())); 227 comments.set(track.getId(), jsonTrack); 228 } 229 } 230 return comments; 231 } 232}