diff --git a/src/main/java/com/ssf/mysqloracletest/domain/JcjCjxxViewMysql.java b/src/main/java/com/ssf/mysqloracletest/domain/JcjCjxxViewMysql.java index 3eb4ea7..1759e35 100644 --- a/src/main/java/com/ssf/mysqloracletest/domain/JcjCjxxViewMysql.java +++ b/src/main/java/com/ssf/mysqloracletest/domain/JcjCjxxViewMysql.java @@ -1,14 +1,9 @@ package com.ssf.mysqloracletest.domain; -import com.baomidou.mybatisplus.annotation.IdType; -import com.baomidou.mybatisplus.annotation.TableField; -import com.baomidou.mybatisplus.annotation.TableId; -import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; import java.io.Serializable; -import lombok.Data; - /** * @TableName jcj_cjxx_view */ diff --git a/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java b/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java index f6129a0..42c3d50 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java +++ b/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java @@ -126,8 +126,6 @@ public class JcjCjxxTask { } catch (Exception e) { logger.info(StringKit.getTrace(e)); } - - } private static String getFolderPath(String picpath) { String floderPath; @@ -144,4 +142,32 @@ public class JcjCjxxTask { } + + /** + * + * 功能描述: 接入出警信息实时数据 + * + * @param: + * @return: + * @auther: cyfeng + * @date: 2023/12/2 14:31 + */ + @Scheduled(initialDelay = 100, fixedDelay = 3000) + public void transcjxxNow() { + + try { + + //1 去mysql查出当前最大时间 + + //2 用得到的最大时间去oracle 查询大于这个时间的记录 + + //3 解析入库 + + }catch (Exception e){ + e.printStackTrace(); + } + + + } + } diff --git a/src/main/resources/mapper/JcjCjxxViewMapperMysql.xml b/src/main/resources/mapper/JcjCjxxViewMapperMysql.xml index 7e53780..624da59 100644 --- a/src/main/resources/mapper/JcjCjxxViewMapperMysql.xml +++ b/src/main/resources/mapper/JcjCjxxViewMapperMysql.xml @@ -445,4 +445,11 @@ where CJBH = #{CJBH} + + + + diff --git a/src/main/resources/mapper/JcjCjxxViewMapperOracle.xml b/src/main/resources/mapper/JcjCjxxViewMapperOracle.xml index 072e95a..75ea502 100644 --- a/src/main/resources/mapper/JcjCjxxViewMapperOracle.xml +++ b/src/main/resources/mapper/JcjCjxxViewMapperOracle.xml @@ -122,4 +122,8 @@ WHERE t2.rn = ]]> ${rowStart} + + diff --git a/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml b/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml index 8cbbc78..18a7f5f 100644 --- a/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml +++ b/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml @@ -544,4 +544,11 @@ where JJBH = #{JJBH} + + + + diff --git a/src/main/resources/mapper/JcjJjxxViewOracleMapper.xml b/src/main/resources/mapper/JcjJjxxViewOracleMapper.xml index da228af..b3cad5b 100644 --- a/src/main/resources/mapper/JcjJjxxViewOracleMapper.xml +++ b/src/main/resources/mapper/JcjJjxxViewOracleMapper.xml @@ -145,4 +145,8 @@ FROM (SELECT ROWNUM rn, t1.* FROM (SELECT * FROM SYX_JWPT.JCJ_JJXX_VIEW) t1 WHERE ROWNUM ${rowEnd}) t2 WHERE t2.rn = ]]> ${rowStart} + +