站点同步定时器

yiming
1 parent 72bbdd01
Showing 5 changed files with 228 additions and 104 deletions
bsthLineProfiles/src/main/java/com/ruoyi/project/monitor/job/task/RyTask.java
bsthLineProfiles/src/main/java/com/ruoyi/project/system/line/domain/BsthStation.java
bsthLineProfiles/src/main/java/com/ruoyi/project/system/line/mapper/BsthStationMapper.java
bsthLineProfiles/src/main/resources/mybatis/mybatis/system/BsthStationMapper.xml
bsthLineProfiles/src/main/resources/templates/system/line/map.html
@@ -6,9 +6,14 @@ import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
+import cn.hutool.http.HttpUtil;
+import com.alibaba.fastjson.JSONObject;
 import com.ruoyi.common.utils.security.ShiroUtils;
 import com.ruoyi.project.system.dept.service.DeptServiceImpl;
+import com.ruoyi.project.system.line.domain.BsthStation;
+import com.ruoyi.project.system.line.mapper.BsthStationMapper;
 import com.ruoyi.project.system.user.domain.User;
 import org.apache.shiro.util.ThreadContext;
 import org.apache.shiro.web.mgt.DefaultWebSecurityManager;
@@ -36,6 +41,9 @@ public class RyTask {
 	@Autowired
 	DeptServiceImpl deptService;
+	@Autowired
+	BsthStationMapper bsthStationMapper;
+
 	public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) {
 		System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
 	}
@@ -129,4 +137,25 @@ public class RyTask {
 		ThreadContext.bind(manager);
 		deptService.updateSysDept();
 	}
+
+	public void updateStation(){
+		List<BsthStation> bsthStations=bsthStationMapper.selectBsthStation();
+		Map<String,List<BsthStation>> m=bsthStations.stream().collect(Collectors.groupingBy(v->v.getStationCode()));
+		String url="https://180.167.126.126:18991/prod-api/service/interfact/getStation";
+		JSONArray jsonArray= JSONObject.parseObject(HttpUtil.get(url)).getJSONArray("data");
+		for (Object o : jsonArray) {
+			BsthStation b=JSONObject.parseObject(o.toString(), BsthStation.class);
+			List<BsthStation> bsthStationList=m.get(b.getStationCode());
+			if(bsthStationList==null){
+				bsthStationMapper.insertBsthStation(b);
+			}else {
+				BsthStation bsthStation=bsthStationList.get(0);
+				if(!b.equals(bsthStation)){
+					bsthStationMapper.updateBsthStation(b);
+				}
+			}
+
+		}
+	}
+
 }
@@ -3,6 +3,8 @@ package com.ruoyi.project.system.line.domain;
 import org.apache.commons.lang3.builder.ToStringBuilder;
 import org.apache.commons.lang3.builder.ToStringStyle;
+import java.util.Objects;
+
 /**
  * 站点信息 过程或现状的站级信息都引用此站点信息对象 bsth_t_station
  * 
@@ -63,53 +65,49 @@ public class BsthStation
     private String hasMetro;
     private String remark;
+    /** 街道 */
+    private String streetTown;
-    public void setId(Long id) 
-    {
-        this.id = id;
-    }
-
-    public Long getId() 
-    {
+    public Long getId() {
         return id;
     }
-    public void setStandardStationCode(String standardStationCode) 
-    {
-        this.standardStationCode = standardStationCode;
+
+    public void setId(Long id) {
+        this.id = id;
     }
-    public String getStandardStationCode() 
-    {
+    public String getStandardStationCode() {
         return standardStationCode;
     }
-    public void setStationCode(String stationCode) 
-    {
-        this.stationCode = stationCode;
+
+    public void setStandardStationCode(String standardStationCode) {
+        this.standardStationCode = standardStationCode;
     }
-    public String getStationCode() 
-    {
+    public String getStationCode() {
         return stationCode;
     }
-    public void setStationName(String stationName) 
-    {
-        this.stationName = stationName;
+
+    public void setStationCode(String stationCode) {
+        this.stationCode = stationCode;
     }
-    public String getStationName() 
-    {
+    public String getStationName() {
         return stationName;
     }
-    public void setStationAddress(String stationAddress) 
-    {
-        this.stationAddress = stationAddress;
+
+    public void setStationName(String stationName) {
+        this.stationName = stationName;
     }
-    public String getStationAddress() 
-    {
+    public String getStationAddress() {
         return stationAddress;
     }
+    public void setStationAddress(String stationAddress) {
+        this.stationAddress = stationAddress;
+    }
+
     public String getBoardType() {
         return boardType;
     }
@@ -118,126 +116,145 @@ public class BsthStation
         this.boardType = boardType;
     }
-    public void setStationType(String stationType)
-    {
+    public String getStationType() {
+        return stationType;
+    }
+
+    public void setStationType(String stationType) {
         this.stationType = stationType;
     }
-    public String getStationType() 
-    {
-        return stationType;
+    public String getAnnular() {
+        return annular;
     }
-    public void setAnnular(String annular) 
-    {
+
+    public void setAnnular(String annular) {
         this.annular = annular;
     }
-    public String getAnnular() 
-    {
-        return annular;
+    public String getArea() {
+        return area;
     }
-    public void setArea(String area) 
-    {
+
+    public void setArea(String area) {
         this.area = area;
     }
-    public String getArea() 
-    {
-        return area;
+    public String getRoadName() {
+        return roadName;
     }
-    public void setRoadName(String roadName) 
-    {
+
+    public void setRoadName(String roadName) {
         this.roadName = roadName;
     }
-    public String getRoadName() 
-    {
-        return roadName;
+    public Double getLonBd() {
+        return lonBd;
     }
-    public void setLonBd(Double lonBd) 
-    {
+
+    public void setLonBd(Double lonBd) {
         this.lonBd = lonBd;
     }
-    public Double getLonBd() 
-    {
-        return lonBd;
+    public Double getLatBd() {
+        return latBd;
     }
-    public void setLatBd(Double latBd) 
-    {
+
+    public void setLatBd(Double latBd) {
         this.latBd = latBd;
     }
-    public Double getLatBd() 
-    {
-        return latBd;
+    public Double getLonGps() {
+        return lonGps;
     }
-    public void setLonGps(Double lonGps) 
-    {
+
+    public void setLonGps(Double lonGps) {
         this.lonGps = lonGps;
     }
-    public Double getLonGps() 
-    {
-        return lonGps;
+    public Double getLatGps() {
+        return latGps;
     }
-    public void setLatGps(Double latGps) 
-    {
+
+    public void setLatGps(Double latGps) {
         this.latGps = latGps;
     }
-    public Double getLatGps() 
-    {
-        return latGps;
+    public String getDistrict() {
+        return district;
     }
-    public void setDistrict(String district) 
-    {
+
+    public void setDistrict(String district) {
         this.district = district;
     }
-    public String getDistrict() 
-    {
-        return district;
+    public String getLineList() {
+        return lineList;
     }
-    public void setLineList(String lineList) 
-    {
+
+    public void setLineList(String lineList) {
         this.lineList = lineList;
     }
-    public String getLineList() 
-    {
-        return lineList;
+    public String getHasMetro() {
+        return hasMetro;
     }
-    public void setHasMetro(String hasMetro) 
-    {
+
+    public void setHasMetro(String hasMetro) {
         this.hasMetro = hasMetro;
     }
-    public String getHasMetro() 
-    {
-        return hasMetro;
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    public String getStreetTown() {
+        return streetTown;
     }
+    public void setStreetTown(String streetTown) {
+        this.streetTown = streetTown;
+    }
     @Override
     public String toString() {
-        return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
-            .append("id", getId())
-            .append("standardStationCode", getStandardStationCode())
-            .append("stationCode", getStationCode())
-            .append("stationName", getStationName())
-            .append("stationAddress", getStationAddress())
-            .append("stationType", getStationType())
-            .append("annular", getAnnular())
-            .append("area", getArea())
-            .append("roadName", getRoadName())
-            .append("lonBd", getLonBd())
-            .append("latBd", getLatBd())
-            .append("lonGps", getLonGps())
-            .append("latGps", getLatGps())
-            .append("district", getDistrict())
-            .append("lineList", getLineList())
-            .append("hasMetro", getHasMetro())
-            .toString();
+        return "BsthStation{" +
+                "id=" + id +
+                ", standardStationCode='" + standardStationCode + '\'' +
+                ", stationCode='" + stationCode + '\'' +
+                ", stationName='" + stationName + '\'' +
+                ", stationAddress='" + stationAddress + '\'' +
+                ", boardType='" + boardType + '\'' +
+                ", stationType='" + stationType + '\'' +
+                ", annular='" + annular + '\'' +
+                ", area='" + area + '\'' +
+                ", roadName='" + roadName + '\'' +
+                ", lonBd=" + lonBd +
+                ", latBd=" + latBd +
+                ", lonGps=" + lonGps +
+                ", latGps=" + latGps +
+                ", district='" + district + '\'' +
+                ", lineList='" + lineList + '\'' +
+                ", hasMetro='" + hasMetro + '\'' +
+                ", remark='" + remark + '\'' +
+                ", streetTown='" + streetTown + '\'' +
+                '}';
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        BsthStation that = (BsthStation) o;
+        return Objects.equals(standardStationCode, that.standardStationCode) && Objects.equals(stationCode, that.stationCode) && Objects.equals(stationName, that.stationName) && Objects.equals(stationAddress, that.stationAddress) && Objects.equals(boardType, that.boardType) && Objects.equals(stationType, that.stationType) && Objects.equals(annular, that.annular) && Objects.equals(area, that.area) && Objects.equals(roadName, that.roadName) && Objects.equals(lonBd, that.lonBd) && Objects.equals(latBd, that.latBd) && Objects.equals(lonGps, that.lonGps) && Objects.equals(latGps, that.latGps) && Objects.equals(district, that.district) && Objects.equals(lineList, that.lineList) && Objects.equals(hasMetro, that.hasMetro) && Objects.equals(remark, that.remark) && Objects.equals(streetTown, that.streetTown);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(standardStationCode, stationCode, stationName, stationAddress, boardType, stationType, annular, area, roadName, lonBd, latBd, lonGps, latGps, district, lineList, hasMetro, remark, streetTown);
     }
 }
@@ -10,4 +10,11 @@ import java.util.List;
 public interface BsthStationMapper 
 {
     List<BsthStation> selectBsthStationListByLoc(@Param("lng")String lng, @Param("lat")String lat, @Param("dis")String dis);
+
+    List<BsthStation> selectBsthStation();
+
+    void updateBsthStation(BsthStation bsthStation);
+
+    void insertBsthStation(BsthStation bsthStation);
+
 }
@@ -37,5 +37,76 @@ PUBLIC &quot;-//mybatis.org//DTD Mapper 3.0//EN&quot;
 		) &lt; ${dis}
 	</select>
+	<select id="selectBsthStation" resultMap="BsthStationResult">
+		select id, standard_station_code, station_code, station_name, station_address, station_type, board_type, annular, area, road_name, lon_bd, lat_bd, lon_gps, lat_gps, district, line_list, has_metro, remark from bsth_t_station
+	</select>
+
+	<update id="updateBsthStation" parameterType="com.ruoyi.project.system.line.domain.BsthStation">
+		update bsth_t_station
+		<trim prefix="SET" suffixOverrides=",">
+			<if test="standardStationCode != null">standard_station_code = #{standardStationCode},</if>
+			<if test="stationName != null">station_name = #{stationName},</if>
+			<if test="stationAddress != null">station_address = #{stationAddress},</if>
+			<if test="stationType != null">station_type = #{stationType},</if>
+			<if test="boardType != null">board_type = #{boardType},</if>
+			<if test="annular != null">annular = #{annular},</if>
+			<if test="area != null">area = #{area},</if>
+			<if test="roadName != null">road_name = #{roadName},</if>
+			<if test="lonBd != null">lon_bd = #{lonBd},</if>
+			<if test="latBd != null">lat_bd = #{latBd},</if>
+			<if test="lonGps != null">lon_gps = #{lonGps},</if>
+			<if test="latGps != null">lat_gps = #{latGps},</if>
+			<if test="district != null">district = #{district},</if>
+			<if test="lineList != null">line_list = #{lineList},</if>
+			<if test="hasMetro != null">has_metro = #{hasMetro},</if>
+			<if test="remark != null">remark = #{remark},</if>
+			<if test="streetTown != null">street_town = #{streetTown},</if>
+		</trim>
+		where station_code = #{stationCode}
+	</update>
+
+	<insert id="insertBsthStation" parameterType="com.ruoyi.project.system.line.domain.BsthStation">
+		insert into bsth_t_station
+		<trim prefix="(" suffix=")" suffixOverrides=",">
+			<if test="standardStationCode != null and standardStationCode != ''">standard_station_code,</if>
+			<if test="stationCode != null and stationCode != ''">station_code,</if>
+			<if test="stationName != null and stationName != ''">station_name,</if>
+			<if test="stationAddress != null and stationAddress != ''">station_address,</if>
+			<if test="stationType != null and stationType != ''">station_type,</if>
+			<if test="boardType != null and boardType != ''">board_type,</if>
+			<if test="annular != null and annular != ''">annular,</if>
+			<if test="area != null and area != ''">area,</if>
+			<if test="roadName != null and roadName != ''">road_name,</if>
+			<if test="lonBd != null and lonBd != ''">lon_bd,</if>
+			<if test="latBd != null and latBd != ''">lat_bd,</if>
+			<if test="lonGps != null and lonGps != ''">lon_gps,</if>
+			<if test="latGps != null and latGps != ''">lat_gps,</if>
+			<if test="district != null and district != ''">district,</if>
+			<if test="lineList != null and lineList != ''">line_list,</if>
+			<if test="hasMetro != null and hasMetro != ''">has_metro,</if>
+			<if test="remark != null and remark != ''">remark,</if>
+			<if test="streetTown != null and streetTown != ''">street_town,</if>
+		</trim>
+		<trim prefix="values (" suffix=")" suffixOverrides=",">
+			<if test="standardStationCode != null and standardStationCode != ''">#{standardStationCode},</if>
+			<if test="stationCode != null and stationCode != ''">#{stationCode},</if>
+			<if test="stationName != null and stationName != ''">#{stationName},</if>
+			<if test="stationAddress != null and stationAddress != ''">#{stationAddress},</if>
+			<if test="stationType != null and stationType != ''">#{stationType},</if>
+			<if test="boardType != null and boardType != ''">#{boardType},</if>
+			<if test="annular != null and annular != ''">#{annular},</if>
+			<if test="area != null and area != ''">#{area},</if>
+			<if test="roadName != null and roadName != ''">#{roadName},</if>
+			<if test="lonBd != null and lonBd != ''">#{lonBd},</if>
+			<if test="latBd != null and latBd != ''">#{latBd},</if>
+			<if test="lonGps != null and lonGps != ''">#{lonGps},</if>
+			<if test="latGps != null and latGps != ''">#{latGps},</if>
+			<if test="district != null and district != ''">#{district},</if>
+			<if test="lineList != null and lineList != ''">#{lineList},</if>
+			<if test="hasMetro != null and hasMetro != ''">#{hasMetro},</if>
+			<if test="remark != null and remark != ''">#{remark},</if>
+			<if test="streetTown != null and streetTown != ''">#{streetTown},</if>
+		</trim>
+	</insert>
 </mapper>
 \ No newline at end of file
@@ -68,7 +68,7 @@ body, html, #container {
 		<ul class="nav nav-tabs" role="tablist">
 			<li role="presentation" class="active"><a onclick="show('station','road','line','area')" role="tab" data-toggle="tab">地点查询</a></li>
 			<li role="presentation"><a onclick="show('road','station','line','area')" role="tab" data-toggle="tab">道路查询</a></li>
-			<li role="presentation"><a onclick="show('line','road','station','area')" role="tab" data-toggle="tab">途径线路</a></li>
+			<li role="presentation"><a onclick="show('line','road','station','area')" role="tab" data-toggle="tab">途经线路</a></li>
 			<li role="presentation"><a onclick="show('area','road','station','line')" role="tab" data-toggle="tab">区域查询</a></li>
 		</ul>
@@ -249,7 +249,7 @@ body, html, #container {
 		function a(lng,lat,distance){
 			$.get("../line/getStation?lng="
 					+lng + "&lat=" + lat + "&dis="
-					+ distance / 1000, function(data) {
+					+ distance*2/ 1000, function(data) {
 				if (data.code == "0") {
 					var bus=new Array();
 					for ( var i in data.data) {
@@ -299,7 +299,7 @@ body, html, #container {
 					document.getElementById('bus').innerHTML=str;
 					document.getElementById('count').innerHTML='共'+data.data.length+'个站点 &nbsp;&nbsp;&nbsp; 共'+bus.length+'条线路';
 					// 绘制圆
-					var circle = new BMapGL.Circle(new BMapGL.Point(lng,lat), distance/2, {
+					var circle = new BMapGL.Circle(new BMapGL.Point(lng,lat), distance, {
 						strokeColor: 'blue',
 						strokeWeight: 2,
 						strokeOpacity: 0.5
@@ -313,7 +313,7 @@ body, html, #container {
 		function b(lng,lat,distance,roadName){
 			$.get("../line/getStation?lng="
 					+lng + "&lat=" + lat + "&dis="
-					+ distance / 1000, function(data) {
+					+ distance*2/ 1000, function(data) {
 				if (data.code == "0") {
 					var bus=new Array();
 					var c=0;