首末站同步定时器

yiming
1 parent 1244cf37
Showing 6 changed files with 156 additions and 2 deletions
bsthLineProfiles/src/main/java/com/ruoyi/project/monitor/job/task/RyTask.java
bsthLineProfiles/src/main/java/com/ruoyi/project/system/line/domain/BsthSite.java
bsthLineProfiles/src/main/java/com/ruoyi/project/system/line/domain/BsthTLineKFK.java
bsthLineProfiles/src/main/java/com/ruoyi/project/system/line/mapper/BsthSiteMapper.java
bsthLineProfiles/src/main/resources/application.yml
bsthLineProfiles/src/main/resources/mybatis/mybatis/system/BsthSiteMapper.xml
@@ -12,7 +12,9 @@ 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.BsthSite;
 import com.ruoyi.project.system.line.domain.BsthStation;
+import com.ruoyi.project.system.line.mapper.BsthSiteMapper;
 import com.ruoyi.project.system.line.mapper.BsthStationMapper;
 import com.ruoyi.project.system.user.domain.User;
 import org.apache.shiro.util.ThreadContext;
@@ -44,6 +46,9 @@ public class RyTask {
 	@Autowired
 	BsthStationMapper bsthStationMapper;
+	@Autowired
+	BsthSiteMapper bsthSiteMapper;
+
 	public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) {
 		System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
 	}
@@ -157,5 +162,28 @@ public class RyTask {
 		}
 	}
+	public void updateSite(){
+		List<BsthSite> bsthSites=bsthSiteMapper.selectBsthSite();
+		Map<String,List<BsthSite>> m=bsthSites.stream().collect(Collectors.groupingBy(v->(String.valueOf(v.getId()))));
+		String url="http://180.166.5.82:19006/site/Site_list";
+		JSONArray jsonArray=JSONObject.parseArray(HttpUtil.post(url,new HashMap<>()));
+ 		for (Object o : jsonArray) {
+			BsthSite b=JSONObject.parseObject(o.toString(), BsthSite.class);
+			List<BsthSite> bsthSiteList=m.get(String.valueOf(b.getId()));
+			if(bsthSiteList==null){
+				bsthSiteMapper.insertBsthSite(b);
+			}else {
+				BsthSite bsthSite=bsthSiteList.get(0);
+				if(!b.equals(bsthSite)){
+					bsthSiteMapper.updateBsthSite(b);
+				}
+			}
+		}
+	}
+
+	public static void main(String[] args) {
+		RyTask ryTask=new RyTask();
+		ryTask.updateSite();
+	}
 }
+package com.ruoyi.project.system.line.domain;
+
+
+import java.util.Objects;
+
+public class BsthSite
+{
+    private static final long serialVersionUID = 1L;
+
+
+    private long id;
+
+    private String ddname;
+
+    private String name;
+
+    public long getId() {
+        return id;
+    }
+
+    public void setId(long id) {
+        this.id = id;
+    }
+
+    public String getDdname() {
+        return ddname;
+    }
+
+    public void setDdname(String ddname) {
+        this.ddname = ddname;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        BsthSite bsthSite = (BsthSite) o;
+        return Objects.equals(id, bsthSite.id) && Objects.equals(ddname, bsthSite.ddname) && Objects.equals(name, bsthSite.name);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(id, ddname, name);
+    }
+
+    @Override
+    public String toString() {
+        return "BsthSite{" +
+                "id='" + id + '\'' +
+                ", ddname='" + ddname + '\'' +
+                ", name='" + name + '\'' +
+                '}';
+    }
+}
@@ -190,6 +190,9 @@ public class BsthTLineKFK
     /** 类型 */
     private String operationType;
+    /** 线路编码 */
+    private String lineCode;
+
     public BsthTLineKFK(){
@@ -670,4 +673,12 @@ public class BsthTLineKFK
     public void setId(Long id) {
         this.id = id;
     }
+
+    public String getLineCode() {
+        return lineCode;
+    }
+
+    public void setLineCode(String lineCode) {
+        this.lineCode = lineCode;
+    }
 }
+package com.ruoyi.project.system.line.mapper;
+
+
+import com.ruoyi.project.system.line.domain.BsthSite;
+import org.apache.ibatis.annotations.Mapper;
+import java.util.List;
+
+@Mapper
+public interface BsthSiteMapper
+{
+
+
+    List<BsthSite> selectBsthSite();
+
+    void updateBsthSite(BsthSite bsthSite);
+
+    void insertBsthSite(BsthSite bsthSite);
+
+}
@@ -100,7 +100,7 @@ spring:
     # 令牌密钥
     secret: abcdefghijklmnopqrstuvwxyz
     # 令牌有效期（默认30分钟）
-    expireTime: 30
+    expireTime: 360
   kafka:
     bootstrap-servers: 47.106.82.232:9092
@@ -157,7 +157,7 @@ shiro:
     cipherKey: zSyK5Kp6PZAAjlT+eeNMlg==
   session:
     # Session超时时间，-1代表永不过期（默认30分钟）
-    expireTime: 30
+    expireTime: 360
     # 同步session到数据库的周期（默认1分钟）
     dbSyncPeriod: 1
     # 相隔多久检查一次session的有效性，默认就是10分钟
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.ruoyi.project.system.line.mapper.BsthSiteMapper">
+
+	<select id="selectBsthSite" resultType="com.ruoyi.project.system.line.domain.BsthSite">
+		select id,ddname,name from bsth_t_site
+	</select>
+
+	<update id="updateBsthSite" parameterType="com.ruoyi.project.system.line.domain.BsthSite">
+		update bsth_t_site
+		<trim prefix="SET" suffixOverrides=",">
+			<if test="ddname != null">ddname = #{ddname},</if>
+			<if test="name != null">name = #{name},</if>
+		</trim>
+		where id = #{id}
+	</update>
+
+	<insert id="insertBsthSite" parameterType="com.ruoyi.project.system.line.domain.BsthSite">
+		insert into bsth_t_site
+		<trim prefix="(" suffix=")" suffixOverrides=",">
+			<if test="id != null and id != ''">id,</if>
+			<if test="ddname != null and ddname != ''">ddname,</if>
+			<if test="name != null and name != ''">name,</if>
+		</trim>
+		<trim prefix="values (" suffix=")" suffixOverrides=",">
+			<if test="id != null and id != ''">#{id},</if>
+			<if test="ddname != null and ddname != ''">#{ddname},</if>
+			<if test="name != null and name != ''">#{name},</if>
+		</trim>
+	</insert>
+
+</mapper>
 \ No newline at end of file