查询车辆某时刻营运状态与最近到离站接口加字段：车牌号、终点站名。

娄高锋
1 parent f6997c4b
Showing 2 changed files with 13 additions and 4 deletions
src/main/java/com/bsth/repository/ScheduleRealInfoRepository.java
src/main/java/com/bsth/server_rs/bigdata/BigdataService.java
@@ -93,8 +93,8 @@ public interface ScheduleRealInfoRepository extends PagingAndSortingRepository&lt;S
 	@Query(value = " select bc_type from bsth_c_s_sp_info where id = ?1 ", nativeQuery = true)
     List<String> findoOriginalType(Long spId);
-	@Query(value = " select equipment_code from bsth_c_cars where inside_code = ?1 ", nativeQuery = true)
-    List<String> findDeviceId(String nbbm);
+	@Query(value = " select equipment_code, car_plate from bsth_c_cars where inside_code = ?1 ", nativeQuery = true)
+    List<Object[]> findDeviceId(String nbbm);
 	@Query(value = " select station_name, b_jwpoints from bsth_c_station where station_cod = ?1 ", nativeQuery = true)
     List<Object[]> findStationName(String stationCode);
@@ -2220,6 +2220,9 @@ public class BigdataService {
 		String inOut = "";
 		String bLongitude = "";
 		String bLatitude = "";
+		String qdzName = "";
+		String zdzName = "";
+		String pzh = "";
 		List<ScheduleRealInfo> findByDateAndNbbm = scheduleRealInfoRepository.findByDateAndNbbm(dateStr, nbbm);
@@ -2270,12 +2273,15 @@ public class BigdataService {
 			lineName = temp.getXlName();
 			lineCode = temp.getXlBm();
 			dir = temp.getXlDir();
+			qdzName = temp.getQdzName();
+			zdzName = temp.getZdzName();
 		}
 		String deviceId = "";
-		List<String> findDeviceId = scheduleRealInfoRepository.findDeviceId(nbbm);
+		List<Object[]> findDeviceId = scheduleRealInfoRepository.findDeviceId(nbbm);
 		if(findDeviceId != null && findDeviceId.size() > 0){
-			deviceId = findDeviceId.get(0);
+			deviceId = findDeviceId.get(0)[0].toString();
+			pzh = findDeviceId.get(0)[1].toString();
 		}
 		Connection conn = null;
@@ -2343,6 +2349,9 @@ public class BigdataService {
 			resJson.put("inOut", inOut);
 			resJson.put("bLongitude", bLongitude);
 			resJson.put("bLatitude", bLatitude);
+			resJson.put("startStationName", qdzName);
+			resJson.put("endStationName", zdzName);
+			resJson.put("carPlate", pzh);
 		}catch(Exception e){
 			logger.error("", e);