接处警逻辑补充

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
  */

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();
+        }
+
+
+    }
+
 }

src/main/resources/mapper/JcjCjxxViewMapperMysql.xml

@@ -445,4 +445,11 @@
         where CJBH = #{CJBH}
     </update>
 
+
+    <select id="selectRecordOrderByRksj" parameterType="java.lang.String" resultMap="BaseResultMap">
+        select *
+        from jcj_cjxx_view order by ws_rksj desc limit 1;
+    </select>
+
+
 </mapper>

src/main/resources/mapper/JcjCjxxViewMapperOracle.xml

@@ -122,4 +122,8 @@
                 WHERE t2.rn <![CDATA[ >= ]]> ${rowStart}
         </select>
 
+
+        <select id="getRealTimeRecording" parameterType="java.util.Map" resultMap="BaseResultMap">
+                SELECT * FROM SYX_JWPT.JCJ_CJXX_VIEW where WS_RKSJ >#{maxTime}
+        </select>
 </mapper>

src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml

@@ -544,4 +544,11 @@
         where JJBH = #{JJBH}
     </update>
 
+
+
+    <select id="selectRecordOrderByRksj" parameterType="java.lang.String" resultMap="BaseResultMap">
+        select *
+        from jcj_jjxx_view order by ws_rksj desc limit 1;
+    </select>
+
 </mapper>

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<![CDATA[ <= ]]> ${rowEnd}) t2
         WHERE t2.rn <![CDATA[ >= ]]> ${rowStart}
     </select>
+
+    <select id="getRealTimeRecording" parameterType="java.util.Map" resultMap="JjxxResultMap">
+        SELECT * FROM SYX_JWPT.JCJ_JJXX_VIEW where WS_RKSJ >#{maxTime}
+    </select>
 </mapper>