车载上报停靠站查询表在21上

zlz
1 parent a59c6716
Showing 1 changed file with 15 additions and 15 deletions
src/main/java/com/bsth/service/traffic/impl/VehicleInoutStopServiceImpl.java
@@ -4,6 +4,7 @@ import com.bsth.entity.traffic.VehicleInoutStop;
 import com.bsth.service.impl.BaseServiceImpl;
 import com.bsth.service.traffic.VehicleInoutStopService;
 import com.bsth.util.DateUtils;
+import com.bsth.util.db.DBUtils_MS;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Service;
@@ -51,17 +52,16 @@ public class VehicleInoutStopServiceImpl extends BaseServiceImpl&lt;VehicleInoutSto
 		String order = " order by report_date asc"+ " LIMIT "+page*size+","+size;
 		int dayNum = DateUtils.calcDaynumberInYear(reportDate_start.substring(0,8)) -1;
 		if(!lineId.equals("")){
-			sql.append(" and l.id = ").append(lineId);
+			sql.append(" and line_id = ").append(lineId);
 		}
 		if(!insideCode.equals("")){
-			sql.append(" and c.inside_code = ").append("'").append(insideCode.toUpperCase()).append("'");
+			sql.append(" and inside_code = ").append("'").append(insideCode.toUpperCase()).append("'");
 		}
 		if(!carPlate.equals("")){
-			sql.append(" and c.car_plate = ").append("'").append("沪").append(carPlate.substring(0,1)).append("-")
-					.append(carPlate.substring(1)).append("'");
+			sql.append(" and car_plate = ").append("'").append(carPlate).append("'");
 		}
 		sql.append(" and FROM_UNIXTIME(REPORT_DATE/1000,'%Y%m%d%H') between '").append(reportDate_start).
-				append("' and '").append(reportDate_end).append("'").append(" and r.day_year = ").append(dayNum);
+				append("' and '").append(reportDate_end).append("'").append(" and day_year = ").append(dayNum);
 		if(flag.equals("count")){
 			return sql.toString();
 		}else{
@@ -75,13 +75,13 @@ public class VehicleInoutStopServiceImpl extends BaseServiceImpl&lt;VehicleInoutSto
 	 * @return
 	 */
 	public List<Map<String, Object>> getVehicleInoutStopByParam(Map<String,Object> map){
-		String sql = "SELECT c.branche_company,c.company,l.name,l.shanghai_linecode,inside_code,equipment_code,car_plate," +
-				"if( r.service_state= 0,'营运','停运') as service_state ," +
-				"if( r.up_down= 0,'上行','下行') as up_down ," +
-				"if( r.in_out_stop= 0,'站内','站外') as in_out_stop , " +
-				"r.stop,r.report_date FROM bsth_c_shreal r LEFT JOIN bsth_c_cars c on r.cars = c.id " +
-				"LEFT JOIN bsth_c_line l on r.line = l.id" + packageParam(map,"") ;
-		List<Map<String, Object>> result = jdbcTemplate.queryForList(sql);
+		JdbcTemplate jdbcTemp = new JdbcTemplate(DBUtils_MS.getDataSource());
+		String sql = "SELECT branche_company,company,name,shanghai_linecode,inside_code,equipment_code,car_plate," +
+				"if( service_state= 0,'营运','停运') as service_state ," +
+				"if( up_down= 0,'上行','下行') as up_down ," +
+				"if( in_out_stop= 0,'站内','站外') as in_out_stop , " +
+				"stop,report_date FROM bsth_c_shreal " + packageParam(map,"") ;
+		List<Map<String, Object>> result = jdbcTemp.queryForList(sql);
 		return result;
 	}
@@ -91,9 +91,9 @@ public class VehicleInoutStopServiceImpl extends BaseServiceImpl&lt;VehicleInoutSto
 	 * @return
 	 */
 	public long getVehicleInoutStopCountByParam(Map<String,Object> map){
-		String sql = "SELECT count(1) COUNT FROM bsth_c_shreal r LEFT JOIN bsth_c_cars c on r.cars = c.id " +
-				"LEFT JOIN bsth_c_line l on r.line = l.id" + packageParam(map,"count");
-		long result = Long.valueOf(jdbcTemplate.queryForMap(sql).get("COUNT")+"");
+		JdbcTemplate jdbcTemp = new JdbcTemplate(DBUtils_MS.getDataSource());
+		String sql = "SELECT count(1) COUNT FROM bsth_c_shreal" + packageParam(map,"count");
+		long result = Long.valueOf(jdbcTemp.queryForMap(sql).get("COUNT")+"");
 		return result;
 	}
 }