From e7c78f306418b196b4885952aea0b5255458a61e Mon Sep 17 00:00:00 2001
From: hanrenchun <hanrenchun>
Date: Wed, 29 Nov 2023 15:32:59 +0800
Subject: [PATCH] =?UTF-8?q?=E5=87=BA=E8=AD=A6=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 config/application.properties                 |   9 +-
 .../domain/JcjCjxxViewOracle.java             | 535 ++++++++++++++++++
 .../mapper/JcjCjxxViewOracleMapper.java       |  27 +
 .../service/JcjCjxxViewOracleService.java     |  18 +
 .../impl/JcjCjxxViewOracleServiceImpl.java    |  40 ++
 .../impl/TJksbglOracleServiceImpl.java        |   6 -
 .../ssf/mysqloracletest/task/JcjCjxxTask.java | 114 ++++
 .../mysqloracletest/utils/ConfigParam.java    |   1 +
 .../mapper/JcjCjxxViewMapperOracle.xml        | 125 ++++
 .../resources/mapper/VSySyrkMysqlMapper.xml   |   4 +-
 10 files changed, 867 insertions(+), 12 deletions(-)
 create mode 100644 src/main/java/com/ssf/mysqloracletest/domain/JcjCjxxViewOracle.java
 create mode 100644 src/main/java/com/ssf/mysqloracletest/mapper/JcjCjxxViewOracleMapper.java
 create mode 100644 src/main/java/com/ssf/mysqloracletest/service/JcjCjxxViewOracleService.java
 create mode 100644 src/main/java/com/ssf/mysqloracletest/service/impl/JcjCjxxViewOracleServiceImpl.java
 create mode 100644 src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java
 create mode 100644 src/main/resources/mapper/JcjCjxxViewMapperOracle.xml

diff --git a/config/application.properties b/config/application.properties
index 9cd1765..0c798ca 100644
--- a/config/application.properties
+++ b/config/application.properties
@@ -1,11 +1,12 @@
-#ʵ�е�ַ���봦������
+#ʵ�е�ַ���봦����
 sydzSwitch=false
-#���β�ѯ������
+#���β�ѯ������
 oncesCounts=10000
 
 syfwSwitch=false
-syrkSwitch=false
-jksbSwitch=true
+syrkSwitch=true
+jksbSwitch=false
+cjxxSwitch=false
 
 
 
diff --git a/src/main/java/com/ssf/mysqloracletest/domain/JcjCjxxViewOracle.java b/src/main/java/com/ssf/mysqloracletest/domain/JcjCjxxViewOracle.java
new file mode 100644
index 0000000..f596a50
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/domain/JcjCjxxViewOracle.java
@@ -0,0 +1,535 @@
+package com.ssf.mysqloracletest.domain;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 
+ * @TableName jcj_cjxx_view
+ */
+@TableName(value ="jcj_cjxx_view")
+@Data
+public class JcjCjxxViewOracle implements Serializable {
+    /**
+     * 
+     */
+    private String cjbh;
+
+    /**
+     * 
+     */
+    private String jjbh;
+
+    /**
+     * 
+     */
+    private String jjdbh;
+
+    /**
+     * 
+     */
+    private String pjdbh;
+
+    /**
+     * 
+     */
+    private String fklyh;
+
+    /**
+     * 
+     */
+    private String cjlb;
+
+    /**
+     * 
+     */
+    private String cjsj;
+
+    /**
+     * 
+     */
+    private String ddxcsj;
+
+    /**
+     * 
+     */
+    private String cjxzqh;
+
+    /**
+     * 
+     */
+    private String cjjlx;
+
+    /**
+     * 
+     */
+    private String cjmlph;
+
+    /**
+     * 
+     */
+    private String cjmphz;
+
+    /**
+     * 
+     */
+    private String cjxz;
+
+    /**
+     * 
+     */
+    private String sfcs;
+
+    /**
+     * 
+     */
+    private String fsyy;
+
+    /**
+     * 
+     */
+    private String tqqk;
+
+    /**
+     * 
+     */
+    private String jqsx;
+
+    /**
+     * 
+     */
+    private String cjr;
+
+    /**
+     * 
+     */
+    private String cjrhzxs;
+
+    /**
+     * 
+     */
+    private String cjrlxfs;
+
+    /**
+     * 
+     */
+    private String sfxq;
+
+    /**
+     * 
+     */
+    private String sfsjsx;
+
+    /**
+     * 
+     */
+    private String sfsjxx;
+
+    /**
+     * 
+     */
+    private String cljgnr;
+
+    /**
+     * 
+     */
+    private String bccljg;
+
+    /**
+     * 
+     */
+    private String ssxxqk;
+
+    /**
+     * 
+     */
+    private String cjfksj;
+
+    /**
+     * 
+     */
+    private String spsj;
+
+    /**
+     * 
+     */
+    private String zbld;
+
+    /**
+     * 
+     */
+    private String zbldxm;
+
+    /**
+     * 
+     */
+    private String ldclsj;
+
+    /**
+     * 
+     */
+    private String cjjg;
+
+    /**
+     * 
+     */
+    private String cjysjsdw;
+
+    /**
+     * 
+     */
+    private String cjysjsr;
+
+    /**
+     * 
+     */
+    private String cjysjssj;
+
+    /**
+     * 
+     */
+    private String cdjl;
+
+    /**
+     * 
+     */
+    private String cdjdc;
+
+    /**
+     * 
+     */
+    private String cdcz;
+
+    /**
+     * 
+     */
+    private String jjfns;
+
+    /**
+     * 
+     */
+    private String jjets;
+
+    /**
+     * 
+     */
+    private String jjrzs;
+
+    /**
+     * 
+     */
+    private String jzqz;
+
+    /**
+     * 
+     */
+    private String jzsy;
+
+    /**
+     * 
+     */
+    private String rysss;
+
+    /**
+     * 
+     */
+    private String rysws;
+
+    /**
+     * 
+     */
+    private String lzscrs;
+
+    /**
+     * 
+     */
+    private String phxxaj;
+
+    /**
+     * 
+     */
+    private String phxsaj;
+
+    /**
+     * 
+     */
+    private String phzaaj;
+
+    /**
+     * 
+     */
+    private String tprf;
+
+    /**
+     * 
+     */
+    private String zhzacy;
+
+    /**
+     * 
+     */
+    private String zjjjss;
+
+    /**
+     * 
+     */
+    private String whss;
+
+    /**
+     * 
+     */
+    private String ajslr;
+
+    /**
+     * 
+     */
+    private String ajsldw;
+
+    /**
+     * 
+     */
+    private String glajbh;
+
+    /**
+     * 
+     */
+    private String glajzt;
+
+    /**
+     * 
+     */
+    private String gisX;
+
+    /**
+     * 
+     */
+    private String gisY;
+
+    /**
+     * 
+     */
+    private String djdw;
+
+    /**
+     * 
+     */
+    private String djr;
+
+    /**
+     * 
+     */
+    private String djsj;
+
+    /**
+     * 
+     */
+    private String xgr;
+
+    /**
+     * 
+     */
+    private String xgsj;
+
+    /**
+     * 
+     */
+    private String xgdw;
+
+    /**
+     * 
+     */
+    private String djrxm;
+
+    /**
+     * 
+     */
+    private String djdwmc;
+
+    /**
+     * 
+     */
+    private String xgrxm;
+
+    /**
+     * 
+     */
+    private String xgdwmc;
+
+    /**
+     * 
+     */
+    private String cjdw;
+
+    /**
+     * 
+     */
+    private String cjdwmc;
+
+    /**
+     * 
+     */
+    private String cjxxdd;
+
+    /**
+     * 
+     */
+    private String zblddw;
+
+    /**
+     * 
+     */
+    private String zblddwmc;
+
+    /**
+     * 
+     */
+    private String spxgsj;
+
+    /**
+     * 
+     */
+    private String yzb;
+
+    /**
+     * 
+     */
+    private String xzb;
+
+    /**
+     * 
+     */
+    private String bzsj;
+
+    /**
+     * 
+     */
+    private String bzdw;
+
+    /**
+     * 
+     */
+    private String bzr;
+
+    /**
+     * 
+     */
+    private String bzrxm;
+
+    /**
+     * 
+     */
+    private String bzdwmc;
+
+    /**
+     * 
+     */
+    private String gxsj;
+
+    /**
+     * 
+     */
+    private String gxrxm;
+
+    /**
+     * 
+     */
+    private String gxr;
+
+    /**
+     * 
+     */
+    private String gxdwmc;
+
+    /**
+     * 
+     */
+    private String gxdw;
+
+    /**
+     * 
+     */
+    private String cjlbmc;
+
+    /**
+     * 
+     */
+    private String cjxzqhmc;
+
+    /**
+     * 
+     */
+    private String cjjlxmc;
+
+    /**
+     * 
+     */
+    private String cjmphzmc;
+
+    /**
+     * 
+     */
+    private String sfcsmc;
+
+    /**
+     * 
+     */
+    private String fsyymc;
+
+    /**
+     * 
+     */
+    private String tqqkmc;
+
+    /**
+     * 
+     */
+    private String sfxqmc;
+
+    /**
+     * 
+     */
+    private String cjjgmc;
+
+    /**
+     * 
+     */
+    private String ajslrmc;
+
+    /**
+     * 
+     */
+    private String ajsldwmc;
+
+    /**
+     * 
+     */
+    private String glajztmc;
+
+    /**
+     * 
+     */
+    private String wsRksj;
+
+    /**
+     * 
+     */
+    private String wsXgsj;
+
+    /**
+     * 
+     */
+    private String wsYxx;
+
+    /**
+     * 
+     */
+    private String jqsxmc;
+
+    /**
+     * 
+     */
+    private String rywksj;
+
+}
\ No newline at end of file
diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/JcjCjxxViewOracleMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/JcjCjxxViewOracleMapper.java
new file mode 100644
index 0000000..2cd93e7
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/mapper/JcjCjxxViewOracleMapper.java
@@ -0,0 +1,27 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ssf.mysqloracletest.domain.JcjCjxxViewOracle;
+import org.apache.ibatis.annotations.Mapper;
+import java.util.List;
+import java.util.Map;
+
+/**
+* @author 28758
+* @description 针对表【jcj_cjxx_view】的数据库操作Mapper
+* @createDate 2023-11-29 09:28:09
+* @Entity com.ssf.mysqloracletest.domain.JcjCjxxView
+ * 
+*/
+
+@Mapper
+public interface JcjCjxxViewOracleMapper extends BaseMapper<JcjCjxxViewOracle> {
+
+    public int countCjxx();
+
+    public List<JcjCjxxViewOracle> getCjxxList(Map map);
+}
+
+
+
+
diff --git a/src/main/java/com/ssf/mysqloracletest/service/JcjCjxxViewOracleService.java b/src/main/java/com/ssf/mysqloracletest/service/JcjCjxxViewOracleService.java
new file mode 100644
index 0000000..47f4b0c
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/service/JcjCjxxViewOracleService.java
@@ -0,0 +1,18 @@
+package com.ssf.mysqloracletest.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ssf.mysqloracletest.domain.JcjCjxxViewOracle;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+* @author 28758
+* @description 针对表【jcj_cjxx_view】的数据库操作Service
+* @createDate 2023-11-29 09:28:09
+*/
+public interface JcjCjxxViewOracleService extends IService<JcjCjxxViewOracle> {
+    public int countCjxx();
+
+    public List<JcjCjxxViewOracle> getCjxxList(Map map);
+}
diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/JcjCjxxViewOracleServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/JcjCjxxViewOracleServiceImpl.java
new file mode 100644
index 0000000..b9c056b
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/service/impl/JcjCjxxViewOracleServiceImpl.java
@@ -0,0 +1,40 @@
+package com.ssf.mysqloracletest.service.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ssf.mysqloracletest.domain.JcjCjxxViewOracle;
+import com.ssf.mysqloracletest.mapper.JcjCjxxViewOracleMapper;
+import com.ssf.mysqloracletest.service.JcjCjxxViewOracleService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+
+/**
+* @author 28758
+* @description 针对表【jcj_cjxx_view】的数据库操作Service实现
+* @createDate 2023-11-29 09:28:09
+*/
+@Service
+@DS("oracleSydz")
+public class JcjCjxxViewOracleServiceImpl extends ServiceImpl<JcjCjxxViewOracleMapper, JcjCjxxViewOracle>
+    implements JcjCjxxViewOracleService {
+    @Resource
+    private JcjCjxxViewOracleMapper oracleMapper;
+
+    @Override
+    public int countCjxx(){
+        return oracleMapper.countCjxx();
+    }
+
+    @Override
+    public List<JcjCjxxViewOracle> getCjxxList(Map map) {
+        return oracleMapper.getCjxxList(map);
+    }
+
+}
+
+
+
+
diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/TJksbglOracleServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/TJksbglOracleServiceImpl.java
index ceb3402..6295211 100644
--- a/src/main/java/com/ssf/mysqloracletest/service/impl/TJksbglOracleServiceImpl.java
+++ b/src/main/java/com/ssf/mysqloracletest/service/impl/TJksbglOracleServiceImpl.java
@@ -1,14 +1,8 @@
 package com.ssf.mysqloracletest.service.impl;
 
 import com.baomidou.dynamic.datasource.annotation.DS;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ssf.mysqloracletest.domain.TJksbglMysql;
 import com.ssf.mysqloracletest.domain.TJksbglOracle;
-import com.ssf.mysqloracletest.domain.VSySydzOracle;
-import com.ssf.mysqloracletest.mapper.TJksbglMysqlMapper;
 import com.ssf.mysqloracletest.mapper.TJksbglOracleMapper;
-import com.ssf.mysqloracletest.mapper.VSySydzOracleMapper;
-import com.ssf.mysqloracletest.service.TJksbglMysqlService;
 import com.ssf.mysqloracletest.service.TJksbglOracleService;
 import org.springframework.stereotype.Service;
 
diff --git a/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java b/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java
new file mode 100644
index 0000000..59d830d
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java
@@ -0,0 +1,114 @@
+package com.ssf.mysqloracletest.task;
+
+import com.ssf.mysqloracletest.domain.JcjCjxxViewMysql;
+import com.ssf.mysqloracletest.domain.JcjCjxxViewOracle;
+import com.ssf.mysqloracletest.service.JcjCjxxViewMysqlService;
+import com.ssf.mysqloracletest.service.JcjCjxxViewOracleService;
+import com.ssf.mysqloracletest.utils.ConfigParam;
+import com.ssf.mysqloracletest.utils.NumKit;
+import com.ssf.mysqloracletest.utils.StringKit;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeanUtils;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ *  用户数据接入
+ */
+@Component
+public class JcjCjxxTask {
+
+    private static final Logger logger = LoggerFactory.getLogger(JcjCjxxTask.class);
+
+    @Resource
+    private JcjCjxxViewMysqlService cjxxMysqlService;
+
+    @Resource
+    private JcjCjxxViewOracleService cjxxOracleService;
+
+    final int oncesCounts = NumKit.checkInt(ConfigParam.oncesCounts) == 0 ? 1000 : NumKit.checkInt(ConfigParam.oncesCounts);
+
+    private boolean cjxxTag = false;
+
+    /**
+     * 连云港 对接海康平台获取人员基础数据
+     * //
+     */
+    @Scheduled(initialDelay = 100, fixedDelay = 3000)
+    public void transcjxx() {
+
+        if (cjxxTag) {
+            return;
+        }
+
+        if (!"true".equals(ConfigParam.cjxxSwitch)) {
+            return;
+        }
+
+
+        try {
+            int countcjxx = cjxxOracleService.countCjxx();
+            logger.info("countcjxx:" + countcjxx);
+
+            if (countcjxx > 0) {
+
+                cjxxTag = true;
+
+                int count = countcjxx / oncesCounts;
+                CountDownLatch latch = new CountDownLatch(count);
+                ExecutorService cjxxPool = Executors.newFixedThreadPool(50);
+
+                for (int i = 0; i <= count; i++) {
+                    Map cjxxMap = new HashMap();
+                    cjxxMap.put("rowStart", i * oncesCounts);
+                    cjxxMap.put("rowEnd", (i + 1) * oncesCounts);
+                    cjxxPool.submit(() -> {
+                        try {
+                            List<JcjCjxxViewOracle> cjxxs = cjxxOracleService.getCjxxList(cjxxMap);
+                            for (JcjCjxxViewOracle cjxx : cjxxs) {
+                                JcjCjxxViewMysql sBean = new JcjCjxxViewMysql();
+                                BeanUtils.copyProperties(cjxx, sBean);
+                                //确定一个数据是否唯一
+                                JcjCjxxViewMysql checkcjxx = cjxxMysqlService.selectCjxxById(cjxx.getCjbh());
+                                if (checkcjxx == null) {
+                                    cjxxMysqlService.insertCjxx(sBean);
+                                    logger.info("cjxx-" + cjxx.getCjbh() + ":插入成功");
+                                } else {
+                                    cjxxMysqlService.updateCjxxById(sBean);
+                                    logger.info("cjxx-" + cjxx.getCjbh() + ":更新成功");
+                                }
+                            }
+                        } catch (Exception e) {
+                            logger.info("cjxxs:" + e.getMessage());
+                        }
+                        latch.countDown();
+                    });
+                    logger.info("cjxxMap数据总量:" + countcjxx + "," + "当前处理下标:" + cjxxMap.get("rowStart") + "/" + cjxxMap.get("rowEnd"));
+                }
+
+                try {
+                    // Wait for all threads to complete
+                    latch.await();
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+                // 关闭线程池
+                cjxxPool.shutdown();
+            }
+
+        } catch (Exception e) {
+            logger.info(StringKit.getTrace(e));
+        }
+    }
+
+
+}
diff --git a/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java b/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java
index d03059c..a8389ee 100644
--- a/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java
+++ b/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java
@@ -15,5 +15,6 @@ public class ConfigParam {
     public static String syrkSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("syrkSwitch"));
 
     public static String jksbSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("jksbSwitch"));
+    public static String cjxxSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("cjxxSwitch"));
 
 }
diff --git a/src/main/resources/mapper/JcjCjxxViewMapperOracle.xml b/src/main/resources/mapper/JcjCjxxViewMapperOracle.xml
new file mode 100644
index 0000000..9839239
--- /dev/null
+++ b/src/main/resources/mapper/JcjCjxxViewMapperOracle.xml
@@ -0,0 +1,125 @@
+<?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.ssf.mysqloracletest.mapper.JcjCjxxViewOracleMapper">
+
+        <select id="countCjxx" resultType="int">
+                select count(*)
+                from SYX_JWPT.JCJ_CJXX_VIEW
+        </select>
+
+    <resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.JcjCjxxViewOracle">
+            <result property="cjbh" column="CJBH" jdbcType="VARCHAR"/>
+            <result property="jjbh" column="JJBH" jdbcType="VARCHAR"/>
+            <result property="jjdbh" column="JJDBH" jdbcType="VARCHAR"/>
+            <result property="pjdbh" column="PJDBH" jdbcType="VARCHAR"/>
+            <result property="fklyh" column="FKLYH" jdbcType="VARCHAR"/>
+            <result property="cjlb" column="CJLB" jdbcType="VARCHAR"/>
+            <result property="cjsj" column="CJSJ" jdbcType="VARCHAR"/>
+            <result property="ddxcsj" column="DDXCSJ" jdbcType="VARCHAR"/>
+            <result property="cjxzqh" column="CJXZQH" jdbcType="VARCHAR"/>
+            <result property="cjjlx" column="CJJLX" jdbcType="VARCHAR"/>
+            <result property="cjmlph" column="CJMLPH" jdbcType="VARCHAR"/>
+            <result property="cjmphz" column="CJMPHZ" jdbcType="VARCHAR"/>
+            <result property="cjxz" column="CJXZ" jdbcType="VARCHAR"/>
+            <result property="sfcs" column="SFCS" jdbcType="VARCHAR"/>
+            <result property="fsyy" column="FSYY" jdbcType="VARCHAR"/>
+            <result property="tqqk" column="TQQK" jdbcType="VARCHAR"/>
+            <result property="jqsx" column="JQSX" jdbcType="VARCHAR"/>
+            <result property="cjr" column="CJR" jdbcType="VARCHAR"/>
+            <result property="cjrhzxs" column="CJRHZXS" jdbcType="VARCHAR"/>
+            <result property="cjrlxfs" column="CJRLXFS" jdbcType="VARCHAR"/>
+            <result property="sfxq" column="SFXQ" jdbcType="VARCHAR"/>
+            <result property="sfsjsx" column="SFSJSX" jdbcType="VARCHAR"/>
+            <result property="sfsjxx" column="SFSJXX" jdbcType="VARCHAR"/>
+            <result property="cljgnr" column="CLJGNR" jdbcType="VARCHAR"/>
+            <result property="bccljg" column="BCCLJG" jdbcType="VARCHAR"/>
+            <result property="ssxxqk" column="SSXXQK" jdbcType="VARCHAR"/>
+            <result property="cjfksj" column="CJFKSJ" jdbcType="VARCHAR"/>
+            <result property="spsj" column="SPSJ" jdbcType="VARCHAR"/>
+            <result property="zbld" column="ZBLD" jdbcType="VARCHAR"/>
+            <result property="zbldxm" column="ZBLDXM" jdbcType="VARCHAR"/>
+            <result property="ldclsj" column="LDCLSJ" jdbcType="VARCHAR"/>
+            <result property="cjjg" column="CJJG" jdbcType="VARCHAR"/>
+            <result property="cjysjsdw" column="CJYSJSDW" jdbcType="VARCHAR"/>
+            <result property="cjysjsr" column="CJYSJSR" jdbcType="VARCHAR"/>
+            <result property="cjysjssj" column="CJYSJSSJ" jdbcType="VARCHAR"/>
+            <result property="cdjl" column="CDJL" jdbcType="VARCHAR"/>
+            <result property="cdjdc" column="CDJDC" jdbcType="VARCHAR"/>
+            <result property="cdcz" column="CDCZ" jdbcType="VARCHAR"/>
+            <result property="jjfns" column="JJFNS" jdbcType="VARCHAR"/>
+            <result property="jjets" column="JJETS" jdbcType="VARCHAR"/>
+            <result property="jjrzs" column="JJRZS" jdbcType="VARCHAR"/>
+            <result property="jzqz" column="JZQZ" jdbcType="VARCHAR"/>
+            <result property="jzsy" column="JZSY" jdbcType="VARCHAR"/>
+            <result property="rysss" column="RYSSS" jdbcType="VARCHAR"/>
+            <result property="rysws" column="RYSWS" jdbcType="VARCHAR"/>
+            <result property="lzscrs" column="LZSCRS" jdbcType="VARCHAR"/>
+            <result property="phxxaj" column="PHXXAJ" jdbcType="VARCHAR"/>
+            <result property="phxsaj" column="PHXSAJ" jdbcType="VARCHAR"/>
+            <result property="phzaaj" column="PHZAAJ" jdbcType="VARCHAR"/>
+            <result property="tprf" column="TPRF" jdbcType="VARCHAR"/>
+            <result property="zhzacy" column="ZHZACY" jdbcType="VARCHAR"/>
+            <result property="zjjjss" column="ZJJJSS" jdbcType="VARCHAR"/>
+            <result property="whss" column="WHSS" jdbcType="VARCHAR"/>
+            <result property="ajslr" column="AJSLR" jdbcType="VARCHAR"/>
+            <result property="ajsldw" column="AJSLDW" jdbcType="VARCHAR"/>
+            <result property="glajbh" column="GLAJBH" jdbcType="VARCHAR"/>
+            <result property="glajzt" column="GLAJZT" jdbcType="VARCHAR"/>
+            <result property="gisX" column="GIS_X" jdbcType="VARCHAR"/>
+            <result property="gisY" column="GIS_Y" jdbcType="VARCHAR"/>
+            <result property="djdw" column="DJDW" jdbcType="VARCHAR"/>
+            <result property="djr" column="DJR" jdbcType="VARCHAR"/>
+            <result property="djsj" column="DJSJ" jdbcType="VARCHAR"/>
+            <result property="xgr" column="XGR" jdbcType="VARCHAR"/>
+            <result property="xgsj" column="XGSJ" jdbcType="VARCHAR"/>
+            <result property="xgdw" column="XGDW" jdbcType="VARCHAR"/>
+            <result property="djrxm" column="DJRXM" jdbcType="VARCHAR"/>
+            <result property="djdwmc" column="DJDWMC" jdbcType="VARCHAR"/>
+            <result property="xgrxm" column="XGRXM" jdbcType="VARCHAR"/>
+            <result property="xgdwmc" column="XGDWMC" jdbcType="VARCHAR"/>
+            <result property="cjdw" column="CJDW" jdbcType="VARCHAR"/>
+            <result property="cjdwmc" column="CJDWMC" jdbcType="VARCHAR"/>
+            <result property="cjxxdd" column="CJXXDD" jdbcType="VARCHAR"/>
+            <result property="zblddw" column="ZBLDDW" jdbcType="VARCHAR"/>
+            <result property="zblddwmc" column="ZBLDDWMC" jdbcType="VARCHAR"/>
+            <result property="spxgsj" column="SPXGSJ" jdbcType="VARCHAR"/>
+            <result property="yzb" column="YZB" jdbcType="VARCHAR"/>
+            <result property="xzb" column="XZB" jdbcType="VARCHAR"/>
+            <result property="bzsj" column="BZSJ" jdbcType="VARCHAR"/>
+            <result property="bzdw" column="BZDW" jdbcType="VARCHAR"/>
+            <result property="bzr" column="BZR" jdbcType="VARCHAR"/>
+            <result property="bzrxm" column="BZRXM" jdbcType="VARCHAR"/>
+            <result property="bzdwmc" column="BZDWMC" jdbcType="VARCHAR"/>
+            <result property="gxsj" column="GXSJ" jdbcType="VARCHAR"/>
+            <result property="gxrxm" column="GXRXM" jdbcType="VARCHAR"/>
+            <result property="gxr" column="GXR" jdbcType="VARCHAR"/>
+            <result property="gxdwmc" column="GXDWMC" jdbcType="VARCHAR"/>
+            <result property="gxdw" column="GXDW" jdbcType="VARCHAR"/>
+            <result property="cjlbmc" column="CJLBMC" jdbcType="VARCHAR"/>
+            <result property="cjxzqhmc" column="CJXZQHMC" jdbcType="VARCHAR"/>
+            <result property="cjjlxmc" column="CJJLXMC" jdbcType="VARCHAR"/>
+            <result property="cjmphzmc" column="CJMPHZMC" jdbcType="VARCHAR"/>
+            <result property="sfcsmc" column="SFCSMC" jdbcType="VARCHAR"/>
+            <result property="fsyymc" column="FSYYMC" jdbcType="VARCHAR"/>
+            <result property="tqqkmc" column="TQQKMC" jdbcType="VARCHAR"/>
+            <result property="sfxqmc" column="SFXQMC" jdbcType="VARCHAR"/>
+            <result property="cjjgmc" column="CJJGMC" jdbcType="VARCHAR"/>
+            <result property="ajslrmc" column="AJSLRMC" jdbcType="VARCHAR"/>
+            <result property="ajsldwmc" column="AJSLDWMC" jdbcType="VARCHAR"/>
+            <result property="glajztmc" column="GLAJZTMC" jdbcType="VARCHAR"/>
+            <result property="wsRksj" column="WS_RKSJ" jdbcType="VARCHAR"/>
+            <result property="wsXgsj" column="WS_XGSJ" jdbcType="VARCHAR"/>
+            <result property="wsYxx" column="WS_YXX" jdbcType="VARCHAR"/>
+            <result property="jqsxmc" column="JQSXMC" jdbcType="VARCHAR"/>
+            <result property="rywksj" column="RYWKSJ" jdbcType="VARCHAR"/>
+    </resultMap>
+
+        <select id="getCjxxList" parameterType="java.util.Map" resultMap="BaseResultMap">
+                SELECT t2.*
+                FROM (SELECT ROWNUM rn, t1.* FROM (SELECT * FROM SYX_JWPT.JCJ_CJXX_VIEW) t1 WHERE ROWNUM<![CDATA[ <= ]]> ${rowEnd}) t2
+                WHERE t2.rn <![CDATA[ >= ]]> ${rowStart}
+        </select>
+
+</mapper>
diff --git a/src/main/resources/mapper/VSySyrkMysqlMapper.xml b/src/main/resources/mapper/VSySyrkMysqlMapper.xml
index ef7b48d..8872b2b 100644
--- a/src/main/resources/mapper/VSySyrkMysqlMapper.xml
+++ b/src/main/resources/mapper/VSySyrkMysqlMapper.xml
@@ -50,7 +50,7 @@
 
         <select id="selectVSySyrkById" parameterType="java.lang.String" resultMap="BaseResultMap">
                 select * from v_sy_syrk
-                where ID = #{id}  limit 1
+                where ID = #{ID}  limit 1
         </select>
 
         <insert id="insertVSySyrk" parameterType="com.ssf.mysqloracletest.domain.VSySyrkMysql" useGeneratedKeys="true"
@@ -177,7 +177,7 @@
                         <if test="YSBZK_RKSJ != null   and YSBZK_RKSJ != '' ">YSBZK_RKSJ=#{YSBZK_RKSJ},</if>
                         <if test="YSBZK_GXSJ != null   and YSBZK_GXSJ != '' ">YSBZK_GXSJ=#{YSBZK_GXSJ},</if>
                 </trim>
-                where ID = #{id}
+                where ID = #{ID}
         </update>
 
 </mapper>