"copy station!"

youxiw2000
1 parent be0beb26
Showing 3 changed files with 95 additions and 18 deletions
src/main/java/com/bsth/entity/Station.java
src/main/java/com/bsth/repository/StationRepository.java
src/main/java/com/bsth/service/impl/LineVersionsServiceImpl.java
@@ -4,6 +4,8 @@ import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import javax.persistence.Column;
 import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
 import javax.persistence.Id;
 import javax.persistence.Table;
@@ -31,7 +33,7 @@ import java.util.Date;
 public class Station {
 	@Id
-	/*@GeneratedValue(strategy = GenerationType.IDENTITY)*/
+//	@GeneratedValue(strategy = GenerationType.IDENTITY)
 	private Integer id;
 	// 站点编码
@@ -47,6 +47,8 @@ public interface StationRepository extends BaseRepository&lt;Station, Integer&gt; {
 			, nativeQuery=true)
 	List<Object[]> findStationName(Integer dir , String stationName);
+	@Query("select s from Station s where s.id = ?1")
+	Station findByIdReturnMojo(Integer id);
 	/**
 	 * @Description :TODO(站点保存)
 	 * 
 package com.bsth.service.impl;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.bsth.common.ResponseCode;
@@ -8,28 +23,17 @@ import com.bsth.entity.LineVersions;
 import com.bsth.entity.LsSectionRoute;
 import com.bsth.entity.LsStationRoute;
 import com.bsth.entity.SectionRoute;
+import com.bsth.entity.Station;
 import com.bsth.entity.StationRoute;
 import com.bsth.repository.LineRepository;
 import com.bsth.repository.LineVersionsRepository;
 import com.bsth.repository.LsSectionRouteRepository;
 import com.bsth.repository.LsStationRouteRepository;
+import com.bsth.repository.StationRepository;
 import com.bsth.service.LineVersionsService;
 import com.bsth.service.SectionRouteService;
 import com.bsth.service.StationRouteService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.jdbc.core.BatchPreparedStatementSetter;
-import org.springframework.jdbc.core.JdbcTemplate;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
-import java.sql.PreparedStatement;
-import java.sql.SQLException;
-import java.text.ParseException;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import com.bsth.util.GetUIDAndCode;
 /**
  * 
@@ -59,6 +63,10 @@ public class LineVersionsServiceImpl extends BaseServiceImpl&lt;LineVersions, Integ
     @Autowired
     StationRouteService stationRouteService;
+
+    @Autowired
+    StationRepository stationRepository;
+    
     @Autowired
     com.bsth.repository.SectionRouteRepository  sectionRouteRepository ;
@@ -231,7 +239,11 @@ public class LineVersionsServiceImpl extends BaseServiceImpl&lt;LineVersions, Integ
 	/**
 	 * 线路版本添加
 	 */
+	/**
+	 *
+	 */
 	@Override
+	@Transactional
 	public Map<String, Object> add(Map<String, Object> map) {
 		SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 		Map<String, Object> resultMap = new HashMap<>();
@@ -296,16 +308,49 @@ public class LineVersionsServiceImpl extends BaseServiceImpl&lt;LineVersions, Integ
 				List<LsStationRoute> stationList = lsStationRouteRepository.findupdated(Integer.valueOf(map.get("lineId").toString()),map.get("lineCode").toString(),hisVersion);
 				for(int i =0;i<stationList.size();i++) {
+					
+
+					Station newStation = stationRepository.findByIdReturnMojo(stationList.get(i).getStation().getId());
+					Station oldStation = new Station();
+					long stationCode = GetUIDAndCode.getStationId();
+					oldStation.setStationCod(String.valueOf(stationCode));
+					oldStation.setId((int)stationCode);
+//					oldStation.setStationCod(newStation.getStationCod());
+					
+					oldStation.setAddr(newStation.getAddr());
+					oldStation.setbJwpoints(newStation.getbJwpoints());
+					oldStation.setbPolygonGrid(newStation.getbPolygonGrid());
+					oldStation.setCreateDate(new Date());
+					oldStation.setDbType(newStation.getDbType());
+					oldStation.setDescriptions(newStation.getDescriptions());
+					oldStation.setDestroy(newStation.getDestroy());
+					oldStation.setgLaty(newStation.getgLaty());
+					oldStation.setgLonx(newStation.getgLonx());
+					oldStation.setbPolygonGrid(newStation.getbPolygonGrid());
+					oldStation.setIsHarbourStation(newStation.getIsHarbourStation());
+					oldStation.setIsHaveLed(newStation.getIsHaveLed());
+					oldStation.setIsHaveShelter(newStation.getIsHaveShelter());
+					oldStation.setRadius(newStation.getRadius());
+					oldStation.setRoadCoding(newStation.getRoadCoding());
+					oldStation.setShapesType(newStation.getShapesType());
+					oldStation.setStationName(newStation.getStationName());
+					oldStation.setX(newStation.getX());
+					oldStation.setY(newStation.getY());
+					
+					
+					stationRepository.save(oldStation);
+					
+					
 					LsStationRoute oldData = stationList.get(i);
 					LsStationRoute newData = new LsStationRoute();
-
+					
 					newData.setLine(oldData.getLine());
-					newData.setStation(oldData.getStation());
+					newData.setStation(oldStation);
 					newData.setStationName(oldData.getStationName());
 					newData.setStationRouteCode(oldData.getStationRouteCode());
 					newData.setLineCode(oldData.getLineCode());
-					newData.setStationCode(oldData.getStationCode());
+					newData.setStationCode(String.valueOf(stationCode));
 					newData.setStationMark(oldData.getStationMark());
 					newData.setOutStationNmber(oldData.getOutStationNmber());
 					newData.setDirections(oldData.getDirections());
@@ -322,6 +367,34 @@ public class LineVersionsServiceImpl extends BaseServiceImpl&lt;LineVersions, Integ
 					lsStationRouteRepository.save(newData);
 				}
+				
+//				for(int i =0;i<stationList.size();i++) {
+//					LsStationRoute oldData = stationList.get(i);
+//					
+//					LsStationRoute newData = new LsStationRoute();
+//
+//					newData.setLine(oldData.getLine());
+//					newData.setStation(oldData.getStation());
+//					newData.setStationName(oldData.getStationName());
+//					newData.setStationRouteCode(oldData.getStationRouteCode());
+//					newData.setLineCode(oldData.getLineCode());
+//					newData.setStationCode(oldData.getStationCode());
+//					newData.setStationMark(oldData.getStationMark());
+//					newData.setOutStationNmber(oldData.getOutStationNmber());
+//					newData.setDirections(oldData.getDirections());
+//					newData.setDistances(oldData.getDistances());
+//					newData.setToTime(oldData.getToTime());
+//					newData.setFirstTime(oldData.getFirstTime());
+//					newData.setEndTime(oldData.getEndTime());
+//					newData.setEndTime(oldData.getEndTime());
+//					newData.setDescriptions(oldData.getDescriptions());
+//					newData.setIndustryCode(oldData.getIndustryCode());
+//					newData.setDestroy(0);
+//					newData.setVersions(versions);
+//					
+//					lsStationRouteRepository.save(newData);
+//				}
+				
 			}
 			resultMap.put("status", ResponseCode.SUCCESS);
 		} catch (ParseException e) {