diff --git a/src/main/java/com/ssf/mysqloracletest/domain/JcjJjxxViewMysql.java b/src/main/java/com/ssf/mysqloracletest/domain/JcjJjxxViewMysql.java new file mode 100644 index 0000000..8ae7370 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/domain/JcjJjxxViewMysql.java @@ -0,0 +1,657 @@ +package com.ssf.mysqloracletest.domain; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import java.io.Serializable; +import lombok.Data; + +/** + * + * @TableName jcj_jjxx_view + */ +@TableName(value ="jcj_jjxx_view") +@Data +public class JcjJjxxViewMysql implements Serializable { + /** + * + */ + private String jjbh; + + /** + * + */ + private String jjdbh; + + /** + * + */ + private String pjdbh; + + /** + * + */ + private String gljjdbh; + + /** + * + */ + private String jjlyh; + + /** + * + */ + private String pjlyh; + + /** + * + */ + private String ldgbh; + + /** + * + */ + private String jjyxm; + + /** + * + */ + private String pjyxm; + + /** + * + */ + private String lhlbdm; + + /** + * + */ + private String bjdhsj; + + /** + * + */ + private String bjdh; + + /** + * + */ + private String bjdhhm; + + /** + * + */ + private String bjdhdz; + + /** + * + */ + private String thsc; + + /** + * + */ + private String bjr; + + /** + * + */ + private String bjrxb; + + /** + * + */ + private String lxdh; + + /** + * + */ + private String bjxs; + + /** + * + */ + private String bjlx; + + /** + * + */ + private String sfdd; + + /** + * + */ + private String bjnr; + + /** + * + */ + private String bcjjnr; + + /** + * + */ + private String sjcph; + + /** + * + */ + private String cllx; + + /** + * + */ + private String syqx; + + /** + * + */ + private String clqx; + + /** + * + */ + private String hzdj; + + /** + * + */ + private String sfzddw; + + /** + * + */ + private String zddwbm; + + /** + * + */ + private String jzlb; + + /** + * + */ + private String jzjg; + + /** + * + */ + private String qhcs; + + /** + * + */ + private String bzwqk; + + /** + * + */ + private String blqk; + + /** + * + */ + private String sfbw; + + /** + * + */ + private String rswxz; + + /** + * + */ + private String yfwxwz; + + /** + * + */ + private String ywbzxl; + + /** + * + */ + private String yfty; + + /** + * + */ + private String ywbkry; + + /** + * + */ + private String gisX; + + /** + * + */ + private String gisY; + + /** + * + */ + private String sfzxxs; + + /** + * + */ + private String bjtdyy; + + /** + * + */ + private String pjsj; + + /** + * + */ + private String bjcjyj; + + /** + * + */ + private String ejddsj; + + /** + * + */ + private String ejjssj; + + /** + * + */ + private String ejxfsj; + + /** + * + */ + private String ejjsr; + + /** + * + */ + private String ejjsrxm; + + /** + * + */ + private String ejjsdw; + + /** + * + */ + private String ejjsdwmc; + + /** + * + */ + private String sjddsj; + + /** + * + */ + private String sjjssj; + + /** + * + */ + private String sjjsr; + + /** + * + */ + private String sjjsrxm; + + /** + * + */ + private String sjjsd; + + /** + * + */ + private String sjjsdwmc; + + /** + * + */ + private String cjbs; + + /** + * + */ + 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 jjrqsj; + + /** + * + */ + private String jjdw; + + /** + * + */ + private String jjdwmc; + + /** + * + */ + private String jjr; + + /** + * + */ + private String jjrxm; + + /** + * + */ + private String yjdw; + + /** + * + */ + private String yjsj; + + /** + * + */ + private String yjsm; + + /** + * + */ + private String yjr; + + /** + * + */ + private String jjxzqh; + + /** + * + */ + private String jjgxdw; + + /** + * + */ + private String fkyq; + + /** + * + */ + private String sfyfdx; + + /** + * + */ + private String jjdxnr; + + /** + * + */ + private String jjdxsj; + + /** + * + */ + private String sbsj; + + /** + * + */ + private String sbnr; + + /** + * + */ + private String cdclbm; + + /** + * + */ + private String jjlx; + + /** + * + */ + private String zdyjr; + + /** + * + */ + private String zdyjdw; + + /** + * + */ + private String zdyjsj; + + /** + * + */ + private String zdyjsm; + + /** + * + */ + private String sfbddh; + + /** + * + */ + private String sfpj; + + /** + * + */ + private String sffk; + + /** + * + */ + private String bjrxbmc; + + /** + * + */ + private String bjxsmc; + + /** + * + */ + private String bjlxmc; + + /** + * + */ + private String cllxmc; + + /** + * + */ + private String hzdjmc; + + /** + * + */ + private String sfzddwmc; + + /** + * + */ + private String jzlbmc; + + /** + * + */ + private String jzjgmc; + + /** + * + */ + private String qhcsmc; + + /** + * + */ + private String yfwxwzmc; + + /** + * + */ + private String ywbzxlmc; + + /** + * + */ + private String yftymc; + + /** + * + */ + private String ywbkrymc; + + /** + * + */ + private String sfzxxsmc; + + /** + * + */ + private String sjjsdmc; + + /** + * + */ + private String cjbsmc; + + /** + * + */ + private String yjdwmc; + + /** + * + */ + private String jjxzqhmc; + + /** + * + */ + private String jjgxdwmc; + + /** + * + */ + private String zdyjrxm; + + /** + * + */ + private String zdyjdwmc; + + /** + * + */ + private String sfbddhmc; + + /** + * + */ + private String sfpjmc; + + /** + * + */ + private String sffkmc; + + /** + * + */ + private String lhlbdmmc; + + /** + * + */ + private String wsRksj; + + /** + * + */ + private String wsXgsj; + + /** + * + */ + private String wsYxx; + + /** + * + */ + private String rywksj; + + /** + * + */ + private String jdzb; + + /** + * + */ + private String wdzb; + + @TableField(exist = false) + private static final long serialVersionUID = 1L; +} \ No newline at end of file diff --git a/src/main/java/com/ssf/mysqloracletest/domain/JcjJjxxViewOracle.java b/src/main/java/com/ssf/mysqloracletest/domain/JcjJjxxViewOracle.java new file mode 100644 index 0000000..49285ad --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/domain/JcjJjxxViewOracle.java @@ -0,0 +1,658 @@ +package com.ssf.mysqloracletest.domain; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serializable; + +/** + * + * @TableName jcj_jjxx_view + */ +@TableName(value ="jcj_jjxx_view") +@Data +public class JcjJjxxViewOracle implements Serializable { + /** + * + */ + private String jjbh; + + /** + * + */ + private String jjdbh; + + /** + * + */ + private String pjdbh; + + /** + * + */ + private String gljjdbh; + + /** + * + */ + private String jjlyh; + + /** + * + */ + private String pjlyh; + + /** + * + */ + private String ldgbh; + + /** + * + */ + private String jjyxm; + + /** + * + */ + private String pjyxm; + + /** + * + */ + private String lhlbdm; + + /** + * + */ + private String bjdhsj; + + /** + * + */ + private String bjdh; + + /** + * + */ + private String bjdhhm; + + /** + * + */ + private String bjdhdz; + + /** + * + */ + private String thsc; + + /** + * + */ + private String bjr; + + /** + * + */ + private String bjrxb; + + /** + * + */ + private String lxdh; + + /** + * + */ + private String bjxs; + + /** + * + */ + private String bjlx; + + /** + * + */ + private String sfdd; + + /** + * + */ + private String bjnr; + + /** + * + */ + private String bcjjnr; + + /** + * + */ + private String sjcph; + + /** + * + */ + private String cllx; + + /** + * + */ + private String syqx; + + /** + * + */ + private String clqx; + + /** + * + */ + private String hzdj; + + /** + * + */ + private String sfzddw; + + /** + * + */ + private String zddwbm; + + /** + * + */ + private String jzlb; + + /** + * + */ + private String jzjg; + + /** + * + */ + private String qhcs; + + /** + * + */ + private String bzwqk; + + /** + * + */ + private String blqk; + + /** + * + */ + private String sfbw; + + /** + * + */ + private String rswxz; + + /** + * + */ + private String yfwxwz; + + /** + * + */ + private String ywbzxl; + + /** + * + */ + private String yfty; + + /** + * + */ + private String ywbkry; + + /** + * + */ + private String gisX; + + /** + * + */ + private String gisY; + + /** + * + */ + private String sfzxxs; + + /** + * + */ + private String bjtdyy; + + /** + * + */ + private String pjsj; + + /** + * + */ + private String bjcjyj; + + /** + * + */ + private String ejddsj; + + /** + * + */ + private String ejjssj; + + /** + * + */ + private String ejxfsj; + + /** + * + */ + private String ejjsr; + + /** + * + */ + private String ejjsrxm; + + /** + * + */ + private String ejjsdw; + + /** + * + */ + private String ejjsdwmc; + + /** + * + */ + private String sjddsj; + + /** + * + */ + private String sjjssj; + + /** + * + */ + private String sjjsr; + + /** + * + */ + private String sjjsrxm; + + /** + * + */ + private String sjjsd; + + /** + * + */ + private String sjjsdwmc; + + /** + * + */ + private String cjbs; + + /** + * + */ + 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 jjrqsj; + + /** + * + */ + private String jjdw; + + /** + * + */ + private String jjdwmc; + + /** + * + */ + private String jjr; + + /** + * + */ + private String jjrxm; + + /** + * + */ + private String yjdw; + + /** + * + */ + private String yjsj; + + /** + * + */ + private String yjsm; + + /** + * + */ + private String yjr; + + /** + * + */ + private String jjxzqh; + + /** + * + */ + private String jjgxdw; + + /** + * + */ + private String fkyq; + + /** + * + */ + private String sfyfdx; + + /** + * + */ + private String jjdxnr; + + /** + * + */ + private String jjdxsj; + + /** + * + */ + private String sbsj; + + /** + * + */ + private String sbnr; + + /** + * + */ + private String cdclbm; + + /** + * + */ + private String jjlx; + + /** + * + */ + private String zdyjr; + + /** + * + */ + private String zdyjdw; + + /** + * + */ + private String zdyjsj; + + /** + * + */ + private String zdyjsm; + + /** + * + */ + private String sfbddh; + + /** + * + */ + private String sfpj; + + /** + * + */ + private String sffk; + + /** + * + */ + private String bjrxbmc; + + /** + * + */ + private String bjxsmc; + + /** + * + */ + private String bjlxmc; + + /** + * + */ + private String cllxmc; + + /** + * + */ + private String hzdjmc; + + /** + * + */ + private String sfzddwmc; + + /** + * + */ + private String jzlbmc; + + /** + * + */ + private String jzjgmc; + + /** + * + */ + private String qhcsmc; + + /** + * + */ + private String yfwxwzmc; + + /** + * + */ + private String ywbzxlmc; + + /** + * + */ + private String yftymc; + + /** + * + */ + private String ywbkrymc; + + /** + * + */ + private String sfzxxsmc; + + /** + * + */ + private String sjjsdmc; + + /** + * + */ + private String cjbsmc; + + /** + * + */ + private String yjdwmc; + + /** + * + */ + private String jjxzqhmc; + + /** + * + */ + private String jjgxdwmc; + + /** + * + */ + private String zdyjrxm; + + /** + * + */ + private String zdyjdwmc; + + /** + * + */ + private String sfbddhmc; + + /** + * + */ + private String sfpjmc; + + /** + * + */ + private String sffkmc; + + /** + * + */ + private String lhlbdmmc; + + /** + * + */ + private String wsRksj; + + /** + * + */ + private String wsXgsj; + + /** + * + */ + private String wsYxx; + + /** + * + */ + private String rywksj; + + /** + * + */ + private String jdzb; + + /** + * + */ + private String wdzb; + + @TableField(exist = false) + private static final long serialVersionUID = 1L; +} \ No newline at end of file diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/JcjJjxxViewMysqlMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/JcjJjxxViewMysqlMapper.java new file mode 100644 index 0000000..bc202fb --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/mapper/JcjJjxxViewMysqlMapper.java @@ -0,0 +1,26 @@ +package com.ssf.mysqloracletest.mapper; + +import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.ssf.mysqloracletest.domain.VSySydzMysql; +import org.apache.ibatis.annotations.Mapper; + +/** + * @author 10503 + * @description 针对表【jcj_jjxx_view】的数据库操作Mapper + * @createDate 2023-11-29 16:13:53 + * @Entity com.ssf.mysqloracletest.domain.JcjJjxxView + */ +@Mapper +public interface JcjJjxxViewMysqlMapper { + + public JcjJjxxViewMysql selectJcjJxxById(String id); + + public int insertJjxx(JcjJjxxViewMysql bean); + + public int updateJjxxById(JcjJjxxViewMysql bean); +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/JcjJjxxViewOracleMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/JcjJjxxViewOracleMapper.java new file mode 100644 index 0000000..fb508d3 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/mapper/JcjJjxxViewOracleMapper.java @@ -0,0 +1,27 @@ +package com.ssf.mysqloracletest.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql; +import com.ssf.mysqloracletest.domain.JcjJjxxViewOracle; +import com.ssf.mysqloracletest.domain.TJksbglOracle; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; +import java.util.Map; + +/** +* @author 10503 +* @description 针对表【jcj_jjxx_view】的数据库操作Mapper +* @createDate 2023-11-29 16:13:53 +* @Entity com.ssf.mysqloracletest.domain.JcjJjxxView +*/ +@Mapper +public interface JcjJjxxViewOracleMapper { + public int countJjxx(); + + public List getJjxxList(Map map); +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/service/JcjJjxxViewMysqlService.java b/src/main/java/com/ssf/mysqloracletest/service/JcjJjxxViewMysqlService.java new file mode 100644 index 0000000..20a8467 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/JcjJjxxViewMysqlService.java @@ -0,0 +1,18 @@ +package com.ssf.mysqloracletest.service; + +import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql; +import com.baomidou.mybatisplus.extension.service.IService; + +/** +* @author 10503 +* @description 针对表【jcj_jjxx_view】的数据库操作Service +* @createDate 2023-11-29 16:13:53 +*/ +public interface JcjJjxxViewMysqlService { + public JcjJjxxViewMysql selectJcjJxxById(String id); + + public int insertJjxx(JcjJjxxViewMysql jjxx); + + public int updateJjxxById(JcjJjxxViewMysql jjxx); + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/JcjJjxxViewOracleService.java b/src/main/java/com/ssf/mysqloracletest/service/JcjJjxxViewOracleService.java new file mode 100644 index 0000000..e402723 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/JcjJjxxViewOracleService.java @@ -0,0 +1,21 @@ +package com.ssf.mysqloracletest.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql; +import com.ssf.mysqloracletest.domain.JcjJjxxViewOracle; +import com.ssf.mysqloracletest.domain.TJksbglOracle; + +import java.util.List; +import java.util.Map; + +/** +* @author 10503 +* @description 针对表【jcj_jjxx_view】的数据库操作Service +* @createDate 2023-11-29 16:13:53 +*/ +public interface JcjJjxxViewOracleService{ + + public int countJjxx(); + + public List getJjxxList(Map map); +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/JcjJjxxViewMysqlServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/JcjJjxxViewMysqlServiceImpl.java new file mode 100644 index 0000000..e3866db --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/JcjJjxxViewMysqlServiceImpl.java @@ -0,0 +1,41 @@ +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.JcjJjxxViewMysql; +import com.ssf.mysqloracletest.service.JcjJjxxViewMysqlService; +import com.ssf.mysqloracletest.mapper.JcjJjxxViewMysqlMapper; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + +/** +* @author 10503 +* @description 针对表【jcj_jjxx_view】的数据库操作Service实现 +* @createDate 2023-11-29 16:13:53 +*/ +@Service +@DS("mysql") +@RequiredArgsConstructor +public class JcjJjxxViewMysqlServiceImpl implements JcjJjxxViewMysqlService { + private final JcjJjxxViewMysqlMapper jcxxMapper; + + + @Override + public JcjJjxxViewMysql selectJcjJxxById(String id) { + return jcxxMapper.selectJcjJxxById(id); + } + + @Override + public int insertJjxx(JcjJjxxViewMysql jjxx) { + return jcxxMapper.insertJjxx(jjxx); + } + + @Override + public int updateJjxxById(JcjJjxxViewMysql jjxx) { + return jcxxMapper.updateJjxxById(jjxx); + } +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/JcjJjxxViewOracleServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/JcjJjxxViewOracleServiceImpl.java new file mode 100644 index 0000000..8f4720a --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/JcjJjxxViewOracleServiceImpl.java @@ -0,0 +1,38 @@ +package com.ssf.mysqloracletest.service.impl; + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.ssf.mysqloracletest.domain.JcjJjxxViewOracle; +import com.ssf.mysqloracletest.mapper.JcjJjxxViewOracleMapper; +import com.ssf.mysqloracletest.service.JcjJjxxViewOracleService; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Map; + +/** + * @author 10503 + * @description 针对表【jcj_jjxx_view】的数据库操作Service实现 + * @createDate 2023-11-29 16:13:53 + */ +@Service +@DS("oracleSydz") +public class JcjJjxxViewOracleServiceImpl implements JcjJjxxViewOracleService { + @Resource + private JcjJjxxViewOracleMapper oracleMapper; + + + @Override + public int countJjxx() { + return oracleMapper.countJjxx(); + } + + @Override + public List getJjxxList(Map map) { + return oracleMapper.getJjxxList(map); + } +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/task/JjxxTask.java b/src/main/java/com/ssf/mysqloracletest/task/JjxxTask.java new file mode 100644 index 0000000..6570ee4 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/task/JjxxTask.java @@ -0,0 +1,114 @@ +package com.ssf.mysqloracletest.task; + +import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql; +import com.ssf.mysqloracletest.domain.JcjJjxxViewOracle; +import com.ssf.mysqloracletest.service.JcjJjxxViewMysqlService; +import com.ssf.mysqloracletest.service.JcjJjxxViewOracleService; +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 JjxxTask { + + private static final Logger logger = LoggerFactory.getLogger(JjxxTask.class); + + @Resource + private JcjJjxxViewMysqlService JjxxMysqlService; + + @Resource + private JcjJjxxViewOracleService JjxxOracleService; + + final int oncesCounts = NumKit.checkInt(ConfigParam.oncesCounts) == 0 ? 1000 : NumKit.checkInt(ConfigParam.oncesCounts); + + private boolean JjxxTag = false; + + /** + * 连云港 对接海康平台获取人员基础数据 + * // + */ + @Scheduled(initialDelay = 100, fixedDelay = 3000) + public void transjksb() { + + if (JjxxTag) { + return; + } + + if (!"true".equals(ConfigParam.JjxxSwitch)) { + return; + } + + + try { + int countJjxx = JjxxOracleService.countJjxx(); + logger.info("countJjxx:" + countJjxx); + + if (countJjxx > 0) { + + JjxxTag = true; + + int count = countJjxx / oncesCounts; + CountDownLatch latch = new CountDownLatch(count); + ExecutorService JjxxPool = Executors.newFixedThreadPool(50); + + for (int i = 0; i <= count; i++) { + Map JjxxMap = new HashMap(); + JjxxMap.put("rowStart", i * oncesCounts); + JjxxMap.put("rowEnd", (i + 1) * oncesCounts); + JjxxPool.submit(() -> { + try { + List Jjxxs = JjxxOracleService.getJjxxList(JjxxMap); + for (JcjJjxxViewOracle Jjxx : Jjxxs) { + JcjJjxxViewMysql sBean = new JcjJjxxViewMysql(); + BeanUtils.copyProperties(Jjxxs, sBean); + //确定一个数据是否唯一 + JcjJjxxViewMysql checkjksb = JjxxMysqlService.selectJcjJxxById(Jjxx.getJjbh()); + if (checkjksb == null) { + JjxxMysqlService.insertJjxx(sBean); + logger.info("Jjxx-" + Jjxx.getJjbh() + ":插入成功"); + } else { + JjxxMysqlService.updateJjxxById(sBean); + logger.info("Jjxx-" + Jjxx.getJjbh() + ":更新成功"); + } + } + } catch (Exception e) { + logger.info("Jjxxs:" + StringKit.getTrace(e)); + } + latch.countDown(); + }); + logger.info("JjxxMap数据总量:" + countJjxx + "," + "当前处理下标:" + JjxxMap.get("rowStart") + "/" + JjxxMap.get("rowEnd")); + } + + try { + // Wait for all threads to complete + latch.await(); + } catch (InterruptedException e) { + e.printStackTrace(); + } + // 关闭线程池 + JjxxPool.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..b6ca1df 100644 --- a/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java +++ b/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java @@ -16,4 +16,5 @@ public class ConfigParam { public static String jksbSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("jksbSwitch")); + public static String JjxxSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("JjxxSwitch")); } diff --git a/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml b/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml new file mode 100644 index 0000000..a7e8b5a --- /dev/null +++ b/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml @@ -0,0 +1,546 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into jcj_jjxx_view + + jjbh, + jjdbh, + pjdbh, + gljjdbh, + jjlyh, + pjlyh, + ldgbh, + jjyxm, + pjyxm, + lhlbdm, + bjdhsj, + bjdh, + bjdhhm, + bjdhdz, + thsc, + bjr, + bjrxb, + lxdh, + bjxs, + bjlx, + sfdd, + bjnr, + bcjjnr, + sjcph, + cllx, + syqx, + clqx, + hzdj, + sfzddw, + zddwbm, + jzlb, + jzjg, + qhcs, + bzwqk, + blqk, + sfbw, + rswxz, + yfwxwz, + ywbzxl, + yfty, + ywbkry, + gisX, + gisY, + sfzxxs, + bjtdyy, + pjsj, + bjcjyj, + ejddsj, + ejjssj, + ejxfsj, + ejjsr, + ejjsrxm, + ejjsdw, + ejjsdwmc, + sjddsj, + sjjssj, + sjjsr, + sjjsrxm, + sjjsd, + sjjsdwmc, + cjbs, + djdw, + djr, + djsj, + xgr, + xgsj, + xgdw, + djrxm, + djdwmc, + xgrxm, + xgdwmc, + jjrqsj, + jjdw, + jjdwmc, + jjr, + jjrxm, + yjdw, + yjsj, + yjsm, + yjr, + jjxzqh, + jjgxdw, + fkyq, + sfyfdx, + jjdxnr, + jjdxsj, + sbsj, + sbnr, + cdclbm, + jjlx, + zdyjr, + zdyjdw, + zdyjsj, + zdyjsm, + sfbddh, + sfpj, + sffk, + bjrxbmc, + bjxsmc, + bjlxmc, + cllxmc, + hzdjmc, + hzdjmc, + jzlbmc, + jzjgmc, + qhcsmc, + yfwxwzmc, + ywbzxlmc, + yftymc, + ywbkrymc, + sfzxxsmc, + sjjsdmc, + cjbsmc, + yjdwmc, + jjxzqhmc, + jjgxdwmc, + zdyjrxm, + zdyjdwmc, + sfbddhmc, + sfpjmc, + sffkmc, + lhlbdmmc, + wsRksj, + wsXgsj, + wsYxx, + rywksj, + jdzb, + wdzb, + + + #{jjbh}, + #{jjdbh}, + #{pjdbh}, + #{gljjdbh}, + #{jjlyh}, + #{pjlyh}, + #{ldgbh}, + #{jjyxm}, + #{pjyxm}, + #{lhlbdm}, + #{bjdhsj}, + #{bjdh}, + #{bjdhhm}, + #{bjdhdz}, + #{thsc}, + #{bjr}, + #{bjrxb}, + #{lxdh}, + #{bjxs}, + #{bjlx}, + #{sfdd}, + #{bjnr}, + #{bcjjnr}, + #{sjcph}, + #{cllx}, + #{syqx}, + #{clqx}, + #{hzdj}, + #{sfzddw}, + #{zddwbm}, + #{jzlb}, + #{jzjg}, + #{qhcs}, + #{bzwqk}, + #{blqk}, + #{sfbw}, + #{rswxz}, + #{yfwxwz}, + #{ywbzxl}, + #{yfty}, + #{ywbkry}, + #{gisX}, + #{gisY}, + #{sfzxxs}, + #{bjtdyy}, + #{pjsj}, + #{bjcjyj}, + #{ejddsj}, + #{ejjssj}, + #{ejxfsj}, + #{ejjsr}, + #{ejjsrxm}, + #{ejjsdw}, + #{ejjsdwmc}, + #{sjddsj}, + #{sjjssj}, + #{sjjsr}, + #{sjjsrxm}, + #{sjjsd}, + #{sjjsdwmc}, + #{cjbs}, + #{djdw}, + #{djr}, + #{djsj}, + #{xgr}, + #{xgsj}, + #{xgdw}, + #{djrxm}, + #{djdwmc}, + #{xgrxm}, + #{xgdwmc}, + #{jjrqsj}, + #{jjdw}, + #{jjdwmc}, + #{jjr}, + #{jjrxm}, + #{yjdw}, + #{yjsj}, + #{yjsm}, + #{yjr}, + #{jjxzqh}, + #{jjgxdw}, + #{fkyq}, + #{sfyfdx}, + #{jjdxnr}, + #{jjdxsj}, + #{sbsj}, + #{sbnr}, + #{cdclbm}, + #{jjlx}, + #{zdyjr}, + #{zdyjdw}, + #{zdyjsj}, + #{zdyjsm}, + #{sfbddh}, + #{sfpj}, + #{sffk}, + #{bjrxbmc}, + #{bjxsmc}, + #{bjlxmc}, + #{cllxmc}, + #{hzdjmc}, + #{hzdjmc}, + #{jzlbmc}, + #{jzjgmc}, + #{qhcsmc}, + #{yfwxwzmc}, + #{ywbzxlmc}, + #{yftymc}, + #{ywbkrymc}, + #{sfzxxsmc}, + #{sjjsdmc}, + #{cjbsmc}, + #{yjdwmc}, + #{jjxzqhmc}, + #{jjgxdwmc}, + #{zdyjrxm}, + #{zdyjdwmc}, + #{sfbddhmc}, + #{sfpjmc}, + #{sffkmc}, + #{lhlbdmmc}, + #{wsRksj}, + #{wsXgsj}, + #{wsYxx}, + #{rywksj}, + #{jdzb}, + #{wdzb}, + + + + + + update jcj_jjxx_view + + jjbh=#{jjbh}, + jjdbh=#{jjdbh}, + pjdbh=#{pjdbh}, + gljjdbh=#{gljjdbh}, + jjlyh=#{jjlyh}, + pjlyh=#{pjlyh}, + ldgbh=#{ldgbh}, + jjyxm=#{jjyxm}, + pjyxm=#{pjyxm}, + lhlbdm=#{lhlbdm}, + bjdhsj=#{bjdhsj}, + bjdh=#{bjdh}, + bjdhhm=#{bjdhhm}, + bjdhdz=#{bjdhdz}, + thsc=#{thsc}, + bjr=#{bjr}, + bjrxb=#{bjrxb}, + lxdh=#{lxdh}, + bjxs=#{bjxs}, + bjlx=#{bjlx}, + sfdd=#{sfdd}, + bjnr=#{bjnr}, + bcjjnr=#{bcjjnr}, + sjcph=#{sjcph}, + cllx=#{cllx}, + syqx=#{syqx}, + clqx=#{clqx}, + hzdj=#{hzdj}, + sfzddw=#{sfzddw}, + zddwbm=#{zddwbm}, + jzlb=#{jzlb}, + jzjg=#{jzjg}, + qhcs=#{qhcs}, + bzwqk=#{bzwqk}, + blqk=#{blqk}, + sfbw=#{sfbw}, + rswxz=#{rswxz}, + yfwxwz=#{yfwxwz}, + ywbzxl=#{ywbzxl}, + yfty=#{yfty}, + ywbkry=#{ywbkry}, + gisX=#{gisX}, + gisY=#{gisY}, + sfzxxs=#{sfzxxs}, + bjtdyy=#{bjtdyy}, + pjsj=#{pjsj}, + bjcjyj=#{bjcjyj}, + ejddsj=#{ejddsj}, + ejjssj=#{ejjssj}, + ejxfsj=#{ejxfsj}, + ejjsr=#{ejjsr}, + ejjsrxm=#{ejjsrxm}, + ejjsdw=#{ejjsdw}, + ejjsdwmc=#{ejjsdwmc}, + sjddsj=#{sjddsj}, + sjjssj=#{sjjssj}, + sjjsr=#{sjjsr}, + sjjsrxm=#{sjjsrxm}, + sjjsd=#{sjjsd}, + sjjsdwmc=#{sjjsdwmc}, + cjbs=#{cjbs}, + djdw=#{djdw}, + djr=#{djr}, + djsj=#{djsj}, + xgr=#{xgr}, + xgsj=#{xgsj}, + xgdw=#{xgdw}, + djrxm=#{djrxm}, + djdwmc=#{djdwmc}, + xgrxm=#{xgrxm}, + xgdwmc=#{xgdwmc}, + jjrqsj=#{jjrqsj}, + jjdw=#{jjdw}, + jjdwmc=#{jjdwmc}, + jjr=#{jjr}, + jjrxm=#{jjrxm}, + yjdw=#{yjdw}, + yjsj=#{yjsj}, + yjsm=#{yjsm}, + yjr=#{yjr}, + jjxzqh=#{jjxzqh}, + jjgxdw=#{jjgxdw}, + fkyq=#{fkyq}, + sfyfdx=#{sfyfdx}, + jjdxnr=#{jjdxnr}, + jjdxsj=#{jjdxsj}, + sbsj=#{sbsj}, + sbnr=#{sbnr}, + cdclbm=#{cdclbm}, + jjlx=#{jjlx}, + zdyjr=#{zdyjr}, + zdyjdw=#{zdyjdw}, + zdyjsj=#{zdyjsj}, + zdyjsm=#{zdyjsm}, + sfbddh=#{sfbddh}, + sfpj=#{sfpj}, + sffk=#{sffk}, + bjrxbmc=#{bjrxbmc}, + bjxsmc=#{bjxsmc}, + bjlxmc=#{bjlxmc}, + cllxmc=#{cllxmc}, + hzdjmc=#{hzdjmc}, + hzdjmc=#{hzdjmc}, + jzlbmc=#{jzlbmc}, + jzjgmc=#{jzjgmc}, + qhcsmc=#{qhcsmc}, + yfwxwzmc=#{yfwxwzmc}, + ywbzxlmc=#{ywbzxlmc}, + yftymc=#{yftymc}, + ywbkrymc=#{ywbkrymc}, + sfzxxsmc=#{sfzxxsmc}, + sjjsdmc=#{sjjsdmc}, + cjbsmc=#{cjbsmc}, + yjdwmc=#{yjdwmc}, + jjxzqhmc=#{jjxzqhmc}, + jjgxdwmc=#{jjgxdwmc}, + zdyjrxm=#{zdyjrxm}, + zdyjdwmc=#{zdyjdwmc}, + sfbddhmc=#{sfbddhmc}, + sfpjmc=#{sfpjmc}, + sffkmc=#{sffkmc}, + lhlbdmmc=#{lhlbdmmc}, + wsRksj=#{wsRksj}, + wsXgsj=#{wsXgsj}, + wsYxx=#{wsYxx}, + rywksj=#{rywksj}, + jdzb=#{jdzb}, + wdzb=#{wdzb}, + + where jjbh = #{jjbh} + + + diff --git a/src/main/resources/mapper/JcjJjxxViewOracleMapper.xml b/src/main/resources/mapper/JcjJjxxViewOracleMapper.xml new file mode 100644 index 0000000..78a557b --- /dev/null +++ b/src/main/resources/mapper/JcjJjxxViewOracleMapper.xml @@ -0,0 +1,148 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/src/main/resources/mapper/TJksbglMysqlMapper.xml b/src/main/resources/mapper/TJksbglMysqlMapper.xml index e639800..4577107 100644 --- a/src/main/resources/mapper/TJksbglMysqlMapper.xml +++ b/src/main/resources/mapper/TJksbglMysqlMapper.xml @@ -71,7 +71,7 @@ sfjsbryj=#{sfjsbryj}, sfzzrkyj=#{sfzzrkyj}, - where SBMC = #{SBMC} + where sbbh = #{sbbh} diff --git a/src/main/resources/mapper/VSySyfwMysqlMapper.xml b/src/main/resources/mapper/VSySyfwMysqlMapper.xml index 599cd4b..0363c6e 100644 --- a/src/main/resources/mapper/VSySyfwMysqlMapper.xml +++ b/src/main/resources/mapper/VSySyfwMysqlMapper.xml @@ -154,73 +154,73 @@ - #{ZJLID}, - #{YSXTJRZJ}, - #{XXSC_PDBZ}, - #{DAH}, - #{JCWH}, - #{FWID}, - #{FWLX}, - #{FWDZ}, - #{FWXZ}, - #{FWLB}, - #{FWJG}, - #{FJS}, - #{MJ}, - #{CZYT}, - #{DJRQ}, - #{XM}, - #{SFZH}, - #{XB}, - #{HJDQX}, - #{HJDXZ}, - #{XZDQX}, - #{XZDXZ}, - #{DWMC}, - #{DWXZ}, - #{LXDH}, - #{LRRID}, - #{LRR}, - #{LRSJ}, - #{XGRID}, - #{XGRXM}, - #{XGSJ}, - #{TBBS}, - #{TBSJ}, - #{MEMO}, - #{BZ}, - #{DQRQ}, - #{SJFWID}, - #{DYHCODE}, - #{PCSDM}, - #{JWQID}, - #{SSYS}, - #{SNO}, - #{ZXRQ}, - #{ZXYY}, - #{LKBZDZID}, - #{LKBZDZMC}, - #{FWZT}, - #{CZFWBM}, - #{CZFWQM}, - #{TBMEMO}, - #{SFCZ}, - #{JZLX}, - #{FWDJ}, + #{zjlid}, + #{ysxtjrzj}, + #{xxscPdbz}, + #{dah}, + #{jcwh}, + #{fwid}, + #{fwlx}, + #{fwdz}, + #{fwxz}, + #{fwlb}, + #{fwjg}, + #{fjs}, + #{mj}, + #{czyt}, + #{djrq}, + #{xm}, + #{sfzh}, + #{xb}, + #{hjdqx}, + #{hjdxz}, + #{xzdqx}, + #{xzdxz}, + #{dwmc}, + #{dwxz}, + #{lxdh}, + #{lrrid}, + #{lrr}, + #{lrsj}, + #{xgrid}, + #{xgrxm}, + #{xgsj}, + #{tbbs}, + #{tbsj}, + #{memo}, + #{bz}, + #{dqrq}, + #{sjfwid}, + #{dyhcode}, + #{pcsdm}, + #{jwqid}, + #{ssys}, + #{sno}, + #{zxrq}, + #{zxyy}, + #{lkbzdzid}, + #{lkbzdzmc}, + #{fwzt}, + #{czfwbm}, + #{czfwqm}, + #{tbmemo}, + #{sfcz}, + #{jzlx}, + #{fwdj}, #{zdfw}, - #{ZDRY}, - #{SFQZ}, - #{ZJLX}, - #{ZFLX}, - #{CWS}, - #{CZRZJLX}, - #{CZRZJHM}, - #{CZRXM}, - #{CZRLXDH}, + #{zdry}, + #{sfqz}, + #{zjlx}, + #{zflx}, + #{cws}, + #{czrzjlx}, + #{czrzjhm}, + #{czrxm}, + #{czrlxdh}, - #{CDC_JYM}, - #{YSBZK_RKSJ}, - #{YSBZK_GXSJ}, + #{cdcJym}, + #{ysbzkRksj}, + #{ysbzkGxsj},