diff --git a/config/application.properties b/config/application.properties index 02021ef..ae33526 100644 --- a/config/application.properties +++ b/config/application.properties @@ -3,4 +3,6 @@ sydzSwitch=false #βѯ oncesCounts=10000 -syfwSwitch=true +syfwSwitch=false + +jksbSwitch=true diff --git a/src/main/java/com/ssf/mysqloracletest/domain/TJksbglMysql.java b/src/main/java/com/ssf/mysqloracletest/domain/TJksbglMysql.java new file mode 100644 index 0000000..98cac62 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/domain/TJksbglMysql.java @@ -0,0 +1,327 @@ +package com.ssf.mysqloracletest.domain; + +import com.baomidou.mybatisplus.annotation.TableField; + +import java.io.Serializable; +import lombok.Data; + +/** + * + * @TableName t_jksbgl + */ + +@Data +public class TJksbglMysql { + /** + * + */ + private String id; + + /** + * 设备名称 + */ + private String sbmc; + + /** + * 设备编号 + */ + private String sbbh; + + /** + * ip地址 + */ + private String ipdz; + + /** + * + */ + private String macdz; + + /** + * + */ + private String sbdk; + + /** + * + */ + private String jkdwlx; + + /** + * + */ + private String sblx; + + /** + * + */ + private String sbxs; + + /** + * + */ + private String gnlx; + + /** + * + */ + private String ywbq; + + /** + * + */ + private String jcc; + + /** + * + */ + private String sbjd; + + /** + * + */ + private String sbwd; + + /** + * + */ + private String azdz; + + /** + * + */ + private String cjfx; + + /** + * + */ + private String sbzt; + + /** + * + */ + private String ssgajg; + + /** + * + */ + private String jrfs; + + /** + * + */ + private String wlbs; + + /** + * + */ + private String sbcs; + + /** + * + */ + private String azsj; + + /** + * + */ + private String ssbmhy; + + /** + * + */ + private String dwlx; + + /** + * + */ + private String djrxm; + + /** + * + */ + private String djrsfzh; + + /** + * + */ + private String djrdwdm; + + /** + * + */ + private String djrdwmc; + + /** + * + */ + private String djsj; + + /** + * + */ + private String jrsjl; + + /** + * + */ + private String zrsjl; + + /** + * + */ + private String j30tsjl; + + /** + * + */ + private String j30tjl; + + /** + * + */ + private String zxzpsj; + + /** + * + */ + private String zxrksj; + + /** + * + */ + private String j7tsjl; + + /** + * + */ + private String sfzdryj; + + /** + * + */ + private String glytbh; + + /** + * + */ + private String glksbh; + + /** + * + */ + private String sfsdryj; + + /** + * + */ + private String sbid; + + /** + * + */ + private String sbjc; + + /** + * + */ + private String gldl; + + /** + * + */ + private String dllx; + + /** + * + */ + private String cjqy; + + /** + * + */ + private String cjfxlx; + + /** + * + */ + private String sbsybh; + + /** + * + */ + private String sbbabh; + + /** + * + */ + private String sbbazt; + + /** + * + */ + private String sbbzmc; + + /** + * + */ + private String lkldmc; + + /** + * + */ + private String lklddm; + + /** + * + */ + private String glxmmc; + + /** + * + */ + private String glxmid; + + /** + * + */ + private String jczq; + + /** + * + */ + private String jckk; + + /** + * + */ + private String zpfx; + + /** + * + */ + private String gldw; + + /** + * + */ + private String lxr; + + /** + * + */ + private String lxdh; + + /** + * + */ + private String sfjsbryj; + + /** + * + */ + private String sfzzrkyj; + +// @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/TJksbglOracle.java b/src/main/java/com/ssf/mysqloracletest/domain/TJksbglOracle.java new file mode 100644 index 0000000..6c1a1b0 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/domain/TJksbglOracle.java @@ -0,0 +1,327 @@ +package com.ssf.mysqloracletest.domain; + +import com.baomidou.mybatisplus.annotation.TableField; +import lombok.Data; + +import java.io.Serializable; + +/** + * + * @TableName t_jksbgl + */ + +@Data +public class TJksbglOracle { + /** + * + */ + private String id; + + /** + * 设备名称 + */ + private String sbmc; + + /** + * 设备编号 + */ + private String sbbh; + + /** + * ip地址 + */ + private String ipdz; + + /** + * + */ + private String macdz; + + /** + * + */ + private String sbdk; + + /** + * + */ + private String jkdwlx; + + /** + * + */ + private String sblx; + + /** + * + */ + private String sbxs; + + /** + * + */ + private String gnlx; + + /** + * + */ + private String ywbq; + + /** + * + */ + private String jcc; + + /** + * + */ + private String sbjd; + + /** + * + */ + private String sbwd; + + /** + * + */ + private String azdz; + + /** + * + */ + private String cjfx; + + /** + * + */ + private String sbzt; + + /** + * + */ + private String ssgajg; + + /** + * + */ + private String jrfs; + + /** + * + */ + private String wlbs; + + /** + * + */ + private String sbcs; + + /** + * + */ + private String azsj; + + /** + * + */ + private String ssbmhy; + + /** + * + */ + private String dwlx; + + /** + * + */ + private String djrxm; + + /** + * + */ + private String djrsfzh; + + /** + * + */ + private String djrdwdm; + + /** + * + */ + private String djrdwmc; + + /** + * + */ + private String djsj; + + /** + * + */ + private String jrsjl; + + /** + * + */ + private String zrsjl; + + /** + * + */ + private String j30tsjl; + + /** + * + */ + private String j30tjl; + + /** + * + */ + private String zxzpsj; + + /** + * + */ + private String zxrksj; + + /** + * + */ + private String j7tsjl; + + /** + * + */ + private String sfzdryj; + + /** + * + */ + private String glytbh; + + /** + * + */ + private String glksbh; + + /** + * + */ + private String sfsdryj; + + /** + * + */ + private String sbid; + + /** + * + */ + private String sbjc; + + /** + * + */ + private String gldl; + + /** + * + */ + private String dllx; + + /** + * + */ + private String cjqy; + + /** + * + */ + private String cjfxlx; + + /** + * + */ + private String sbsybh; + + /** + * + */ + private String sbbabh; + + /** + * + */ + private String sbbazt; + + /** + * + */ + private String sbbzmc; + + /** + * + */ + private String lkldmc; + + /** + * + */ + private String lklddm; + + /** + * + */ + private String glxmmc; + + /** + * + */ + private String glxmid; + + /** + * + */ + private String jczq; + + /** + * + */ + private String jckk; + + /** + * + */ + private String zpfx; + + /** + * + */ + private String gldw; + + /** + * + */ + private String lxr; + + /** + * + */ + private String lxdh; + + /** + * + */ + private String sfjsbryj; + + /** + * + */ + private String sfzzrkyj; + +// @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/TJksbglMysqlMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/TJksbglMysqlMapper.java new file mode 100644 index 0000000..2dc79d9 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/mapper/TJksbglMysqlMapper.java @@ -0,0 +1,25 @@ +package com.ssf.mysqloracletest.mapper; + +import com.ssf.mysqloracletest.domain.TJksbglMysql; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.ssf.mysqloracletest.domain.TJksbglMysql; +import org.apache.ibatis.annotations.Mapper; + +/** +* @author 10503 +* @description 针对表【t_jksbgl】的数据库操作Mapper +* @createDate 2023-11-28 21:07:14 +* @Entity com.ssf.mysqloracletest.domain.TJksbgl +*/ +@Mapper +public interface TJksbglMysqlMapper { + public TJksbglMysql selectTJksbglById(String id); + + public int insertTJksbgl(TJksbglMysql bean); + + public int updateTJksbglById(TJksbglMysql bean); +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/TJksbglOracleMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/TJksbglOracleMapper.java new file mode 100644 index 0000000..3ebe05f --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/mapper/TJksbglOracleMapper.java @@ -0,0 +1,27 @@ +package com.ssf.mysqloracletest.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.ssf.mysqloracletest.domain.TJksbglMysql; +import com.ssf.mysqloracletest.domain.TJksbglOracle; +import com.ssf.mysqloracletest.domain.VSySydzOracle; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; +import java.util.Map; + +/** +* @author 10503 +* @description 针对表【t_jksbgl】的数据库操作Mapper +* @createDate 2023-11-28 21:07:14 +* @Entity com.ssf.mysqloracletest.domain.TJksbgl +*/ +@Mapper +public interface TJksbglOracleMapper { + public int countJKsb(); + + public List getJKsbList(Map map); +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/service/TJksbglMysqlService.java b/src/main/java/com/ssf/mysqloracletest/service/TJksbglMysqlService.java new file mode 100644 index 0000000..2d455a7 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/TJksbglMysqlService.java @@ -0,0 +1,19 @@ +package com.ssf.mysqloracletest.service; + +import com.ssf.mysqloracletest.domain.TJksbglMysql; +import com.baomidou.mybatisplus.extension.service.IService; +import com.ssf.mysqloracletest.domain.VSySydzMysql; + +/** +* @author 10503 +* @description 针对表【t_jksbgl】的数据库操作Service +* @createDate 2023-11-28 21:07:14 +*/ +public interface TJksbglMysqlService { + + public TJksbglMysql selectTJksbglById(String id); + + public int insertTJksbgl(TJksbglMysql sydz); + + public int updateTJksbglById(TJksbglMysql sydz); +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/TJksbglOracleService.java b/src/main/java/com/ssf/mysqloracletest/service/TJksbglOracleService.java new file mode 100644 index 0000000..2fd8e06 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/TJksbglOracleService.java @@ -0,0 +1,20 @@ +package com.ssf.mysqloracletest.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ssf.mysqloracletest.domain.TJksbglMysql; +import com.ssf.mysqloracletest.domain.TJksbglOracle; +import com.ssf.mysqloracletest.domain.VSySydzOracle; + +import java.util.List; +import java.util.Map; + +/** +* @author 10503 +* @description 针对表【t_jksbgl】的数据库操作Service +* @createDate 2023-11-28 21:07:14 +*/ +public interface TJksbglOracleService { + public int countJKsb(); + + public List getJKsbList(Map map); +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/TJksbglMysqlServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/TJksbglMysqlServiceImpl.java new file mode 100644 index 0000000..17da148 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/TJksbglMysqlServiceImpl.java @@ -0,0 +1,37 @@ +package com.ssf.mysqloracletest.service.impl; + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.ssf.mysqloracletest.domain.TJksbglMysql; +import com.ssf.mysqloracletest.domain.VSySydzMysql; +import com.ssf.mysqloracletest.mapper.TJksbglMysqlMapper; +import com.ssf.mysqloracletest.mapper.VSySydzMysqlMapper; +import com.ssf.mysqloracletest.service.TJksbglMysqlService; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +@Service +@DS("mysql") +@RequiredArgsConstructor +public class TJksbglMysqlServiceImpl implements TJksbglMysqlService { + private final TJksbglMysqlMapper tjksbglMysqlMapper; + + @Override + public TJksbglMysql selectTJksbglById(String id) { + return tjksbglMysqlMapper.selectTJksbglById(id); + } + + @Override + public int insertTJksbgl(TJksbglMysql bean) { + return tjksbglMysqlMapper.insertTJksbgl(bean); + } + + @Override + public int updateTJksbglById(TJksbglMysql bean) { + return tjksbglMysqlMapper.updateTJksbglById(bean); + } +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/TJksbglOracleServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/TJksbglOracleServiceImpl.java new file mode 100644 index 0000000..ceb3402 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/TJksbglOracleServiceImpl.java @@ -0,0 +1,43 @@ +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; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Map; + +/** +* @author 10503 +* @description 针对表【t_jksbgl】的数据库操作Service实现 +* @createDate 2023-11-28 21:07:14 +*/ +@Service +@DS("oracleSydz") +public class TJksbglOracleServiceImpl implements TJksbglOracleService { + @Resource + private TJksbglOracleMapper oracleMapper; + + @Override + public int countJKsb(){ + return oracleMapper.countJKsb(); + } + + @Override + public List getJKsbList(Map map) { + return oracleMapper.getJKsbList(map); + } +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/task/TjksbglTask.java b/src/main/java/com/ssf/mysqloracletest/task/TjksbglTask.java new file mode 100644 index 0000000..1682113 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/task/TjksbglTask.java @@ -0,0 +1,114 @@ +package com.ssf.mysqloracletest.task; + +import com.ssf.mysqloracletest.domain.TJksbglMysql; +import com.ssf.mysqloracletest.domain.TJksbglOracle; +import com.ssf.mysqloracletest.service.TJksbglMysqlService; +import com.ssf.mysqloracletest.service.TJksbglOracleService; +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 TjksbglTask { + + private static final Logger logger = LoggerFactory.getLogger(TjksbglTask.class); + + @Resource + private TJksbglMysqlService jksbMysqlService; + + @Resource + private TJksbglOracleService jksbOracleService; + + final int oncesCounts = NumKit.checkInt(ConfigParam.oncesCounts) == 0 ? 1000 : NumKit.checkInt(ConfigParam.oncesCounts); + + private boolean jksbTag = false; + + /** + * 连云港 对接海康平台获取人员基础数据 + * // + */ + @Scheduled(initialDelay = 100, fixedDelay = 3000) + public void transjksb() { + + if (jksbTag) { + return; + } + + if (!"true".equals(ConfigParam.jksbSwitch)) { + return; + } + + + try { + int countjksb = jksbOracleService.countJKsb(); + logger.info("countjksb:" + countjksb); + + if (countjksb > 0) { + + jksbTag = true; + + int count = countjksb / oncesCounts; + CountDownLatch latch = new CountDownLatch(count); + ExecutorService jksbPool = Executors.newFixedThreadPool(50); + + for (int i = 0; i <= count; i++) { + Map jksbMap = new HashMap(); + jksbMap.put("rowStart", i * oncesCounts); + jksbMap.put("rowEnd", (i + 1) * oncesCounts); + jksbPool.submit(() -> { + try { + List jksbs = jksbOracleService.getJKsbList(jksbMap); + for (TJksbglOracle jksb : jksbs) { + TJksbglMysql sBean = new TJksbglMysql(); + BeanUtils.copyProperties(jksb, sBean); + //确定一个数据是否唯一 + TJksbglMysql checkjksb = jksbMysqlService.selectTJksbglById(jksb.getId()); + if (checkjksb == null) { + jksbMysqlService.insertTJksbgl(sBean); + logger.info("jksb-" + jksb.getId() + ":插入成功"); + } else { + jksbMysqlService.updateTJksbglById(sBean); + logger.info("jksb-" + jksb.getId() + ":更新成功"); + } + } + } catch (Exception e) { + logger.info("jksbs:" + e.getMessage()); + } + latch.countDown(); + }); + logger.info("jksbMap数据总量:" + countjksb + "," + "当前处理下标:" + jksbMap.get("rowStart") + "/" + jksbMap.get("rowEnd")); + } + + try { + // Wait for all threads to complete + latch.await(); + } catch (InterruptedException e) { + e.printStackTrace(); + } + // 关闭线程池 + jksbPool.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 4d2bc20..9e57cc6 100644 --- a/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java +++ b/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java @@ -12,4 +12,5 @@ public class ConfigParam { public static String oncesCounts = StringKit.toString(PropertiesUtil.queryPropertiesByKey("oncesCounts")); public static String syfwSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("syfwSwitch")); + public static String jksbSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("jksbSwitch")); } diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 3bab4d6..97731e8 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -1 +1 @@ -server: port: 5678 spring: datasource: dynamic: primary: mysql #设置默认的数据源或者数据源组,默认值即为master strict: false #设置严格模式,默认false不启动. 启动后再为匹配到指定数据源时候回抛出异常,不启动会使用默认数据源. datasource: oracleSydz: url: jdbc:oracle:thin:@50.146.63.219:1588/sygadsj driver-class-name: oracle.jdbc.driver.OracleDriver username: za_sjdj password: 'za_sjdj0324' mysql: url: jdbc:mysql://121.41.91.94:12036/yhzafk?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT driver-class-name: com.mysql.cj.jdbc.Driver username: root password: '!QAZ1qaz' mybatis-plus: mapper-locations: - classpath:mapper/*.xml \ No newline at end of file +server: port: 5678 spring: datasource: dynamic: primary: mysql #设置默认的数据源或者数据源组,默认值即为master strict: false #设置严格模式,默认false不启动. 启动后再为匹配到指定数据源时候回抛出异常,不启动会使用默认数据源. datasource: oracleSydz: url: jdbc:oracle:thin:@50.146.63.219:1588/sygadsj driver-class-name: oracle.jdbc.driver.OracleDriver username: za_sjdj password: 'za_sjdj0324' mysql: url: jdbc:mysql://localhost:55306/yhzafk?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT driver-class-name: com.mysql.cj.jdbc.Driver username: root password: '!QAZ1qaz' mybatis-plus: mapper-locations: - classpath:mapper/*.xml \ No newline at end of file diff --git a/src/main/resources/mapper/TJksbglMysqlMapper.xml b/src/main/resources/mapper/TJksbglMysqlMapper.xml new file mode 100644 index 0000000..3f04d1e --- /dev/null +++ b/src/main/resources/mapper/TJksbglMysqlMapper.xml @@ -0,0 +1,279 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into t_jksbgl + + ID, + SBMC, + SBBH, + IPDZ, + MACDZ, + SBDK, + JKDWLX, + SBLX, + SBXS, + GNLX, + YWBQ, + JCC, + SBJD, + SBWD, + AZDZ, + CJFX, + SBZT, + SSGAJG, + JRFS, + WLBS, + SBCS, + AZSJ, + SSBMHY, + DWLX, + DJRXM, + DJRSFZH, + DJRDWDM, + DJRDWMC, + DJSJ, + JRSJL, + ZRSJL, + J30TSJL, + J30TJL, + ZXZPSJ, + ZXRKSJ, + J7TSJL, + SFZDRYJ, + GLYTBH, + GLKSBH, + SFSDRYJ, + SBID, + SBJC, + GLDL, + DLLX, + CJQY, + CJFXLX, + SBSYBH, + SBBABH, + SBBAZT, + SBBZMC, + LKLDMC, + LKLDDM, + GLXMMC, + GLXMID, + JCZQ, + JCKK, + ZPFX, + GLDW, + LXR, + LXDH, + SFJSBRYJ, + SFZZRKYJ, + + + + #{ID}, + #{SBMC}, + #{SBBH}, + #{IPDZ}, + #{MACDZ}, + #{SBDK}, + #{JKDWLX}, + #{SBLX}, + #{SBXS}, + #{GNLX}, + #{YWBQ}, + #{JCC}, + #{SBJD}, + #{SBWD}, + #{AZDZ}, + #{CJFX}, + #{SBZT}, + #{SSGAJG}, + #{JRFS}, + #{WLBS}, + #{SBCS}, + #{AZSJ}, + #{SSBMHY}, + #{DWLX}, + #{DJRXM}, + #{DJRSFZH}, + #{DJRDWDM}, + #{DJRDWMC}, + #{DJSJ}, + #{JRSJL}, + #{ZRSJL}, + #{J30TSJL}, + #{J30TJL}, + #{ZXZPSJ}, + #{ZXRKSJ}, + #{J7TSJL}, + #{SFZDRYJ}, + #{GLYTBH}, + #{GLKSBH}, + #{SFSDRYJ}, + #{SBID}, + #{SBJC}, + #{GLDL}, + #{DLLX}, + #{CJQY}, + #{CJFXLX}, + #{SBSYBH}, + #{SBBABH}, + #{SBBAZT}, + #{SBBZMC}, + #{LKLDMC}, + #{LKLDDM}, + #{GLXMMC}, + #{GLXMID}, + #{JCZQ}, + #{JCKK}, + #{ZPFX}, + #{GLDW}, + #{LXR}, + #{LXDH}, + #{SFJSBRYJ}, + #{SFZZRKYJ}, + + + + + update t_jksbgl + + ID=#{ID}, + SBMC=#{SBMC}, + SBBH=#{SBBH}, + IPDZ=#{IPDZ}, + MACDZ=#{MACDZ}, + SBDK=#{SBDK}, + JKDWLX=#{JKDWLX}, + SBLX=#{SBLX}, + SBXS=#{SBXS}, + GNLX=#{GNLX}, + YWBQ=#{YWBQ}, + JCC=#{JCC}, + SBJD=#{SBJD}, + SBWD=#{SBWD}, + AZDZ=#{AZDZ}, + CJFX=#{CJFX}, + SBZT=#{SBZT}, + SSGAJG=#{SSGAJG}, + JRFS=#{JRFS}, + WLBS=#{WLBS}, + SBCS=#{SBCS}, + AZSJ=#{AZSJ}, + SSBMHY=#{SSBMHY}, + DWLX=#{DWLX}, + DJRXM=#{DJRXM}, + DJRSFZH=#{DJRSFZH}, + DJRDWDM=#{DJRDWDM}, + DJRDWMC=#{DJRDWMC}, + DJSJ=#{DJSJ}, + JRSJL=#{JRSJL}, + ZRSJL=#{ZRSJL}, + J30TSJL=#{J30TSJL}, + J30TJL=#{J30TJL}, + ZXZPSJ=#{ZXZPSJ}, + ZXRKSJ=#{ZXRKSJ}, + J7TSJL=#{J7TSJL}, + SFZDRYJ=#{SFZDRYJ}, + GLYTBH=#{GLYTBH}, + GLKSBH=#{GLKSBH}, + SFSDRYJ=#{SFSDRYJ}, + SBID=#{SBID}, + SBJC=#{SBJC}, + GLDL=#{GLDL}, + DLLX=#{DLLX}, + CJQY=#{CJQY}, + CJFXLX=#{CJFXLX}, + SBSYBH=#{SBSYBH}, + SBBABH=#{SBBABH}, + SBBAZT=#{SBBAZT}, + SBBZMC=#{SBBZMC}, + LKLDMC=#{LKLDMC}, + LKLDDM=#{LKLDDM}, + GLXMMC=#{GLXMMC}, + GLXMID=#{GLXMID}, + JCZQ=#{JCZQ}, + JCKK=#{JCKK}, + ZPFX=#{ZPFX}, + GLDW=#{GLDW}, + LXR=#{LXR}, + LXDH=#{LXDH}, + SFJSBRYJ=#{SFJSBRYJ}, + SFZZRKYH=#{SFZZRKYJ}, + + where SBMC = #{SBMC} + + diff --git a/src/main/resources/mapper/TJksbglOracleMapper.xml b/src/main/resources/mapper/TJksbglOracleMapper.xml new file mode 100644 index 0000000..beebd75 --- /dev/null +++ b/src/main/resources/mapper/TJksbglOracleMapper.xml @@ -0,0 +1,82 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/src/main/resources/mapper/VSySydzOracleMapper.xml b/src/main/resources/mapper/VSySydzOracleMapper.xml index 78f1aef..e60ac4e 100644 --- a/src/main/resources/mapper/VSySydzOracleMapper.xml +++ b/src/main/resources/mapper/VSySydzOracleMapper.xml @@ -18,6 +18,7 @@ +