From 811b4ea864044cbe057e1fcf2841bba648987e66 Mon Sep 17 00:00:00 2001 From: Angel <1050374295@qq.com> Date: Tue, 28 Nov 2023 19:54:00 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9E=E6=9C=89=E6=88=BF=E5=B1=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- config/application.properties | 2 + .../mysqloracletest/domain/VSySyfwMysql.java | 151 +++++++++ .../mysqloracletest/domain/VSySyfwOracle.java | 138 ++++++++ .../mapper/VSySyfwMysqlMapper.java | 22 ++ .../mapper/VSySyfwOracleMapper.java | 14 + .../service/VSySyfwMysqlService.java | 19 ++ .../service/VSySyfwOracleService.java | 13 + .../impl/VSySydzOracleServiceImpl.java | 1 + .../service/impl/VSySyfwMysqlServiceImpl.java | 41 +++ .../impl/VSySyfwOracleServiceImpl.java | 29 ++ .../ssf/mysqloracletest/task/VSySydzTask.java | 2 +- .../ssf/mysqloracletest/task/VSySyfwTask.java | 118 +++++++ .../mysqloracletest/utils/ConfigParam.java | 2 + .../resources/mapper/VSySydzMysqlMapper.xml | 3 +- .../resources/mapper/VSySydzOracleMapper.xml | 11 +- .../resources/mapper/VSySyfwMysqlMapper.xml | 313 ++++++++++++++++++ .../resources/mapper/VSySyfwOracleMapper.xml | 85 +++++ 17 files changed, 957 insertions(+), 7 deletions(-) create mode 100644 src/main/java/com/ssf/mysqloracletest/domain/VSySyfwMysql.java create mode 100644 src/main/java/com/ssf/mysqloracletest/domain/VSySyfwOracle.java create mode 100644 src/main/java/com/ssf/mysqloracletest/mapper/VSySyfwMysqlMapper.java create mode 100644 src/main/java/com/ssf/mysqloracletest/mapper/VSySyfwOracleMapper.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/VSySyfwMysqlService.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/VSySyfwOracleService.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/impl/VSySyfwMysqlServiceImpl.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/impl/VSySyfwOracleServiceImpl.java create mode 100644 src/main/java/com/ssf/mysqloracletest/task/VSySyfwTask.java create mode 100644 src/main/resources/mapper/VSySyfwMysqlMapper.xml create mode 100644 src/main/resources/mapper/VSySyfwOracleMapper.xml diff --git a/config/application.properties b/config/application.properties index c7ce1c1..02021ef 100644 --- a/config/application.properties +++ b/config/application.properties @@ -2,3 +2,5 @@ sydzSwitch=false #单次查询数据量 oncesCounts=10000 + +syfwSwitch=true diff --git a/src/main/java/com/ssf/mysqloracletest/domain/VSySyfwMysql.java b/src/main/java/com/ssf/mysqloracletest/domain/VSySyfwMysql.java new file mode 100644 index 0000000..2734f6c --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/domain/VSySyfwMysql.java @@ -0,0 +1,151 @@ +package com.ssf.mysqloracletest.domain; + + +import com.baomidou.mybatisplus.extension.activerecord.Model; +import lombok.Data; + +/** + * (VSySyfw)琛ㄥ疄浣撶被 + * + * @author makejava + * @since 2023-11-28 16:03:26 + */ + +@Data +public class VSySyfwMysql { + + private String zjlid; + + private String ysxtjrzj; + // + private String xxscPdbz; + + private String dah; + + private String jcwh; + + private String fwid; + + private String fwlx; + + private String fwdz; + + private String fwxz; + + private String fwlb; + + private String fwjg; + + private String fjs; + + private String mj; + + private String czyt; + + private String djrq; + //濮撳悕 + private String xm; + + private String sfzh; + + private String xb; + + private String hjdqx; + + private String hjdxz; + + private String xzdqx; + + private String xzdxz; + + private String dwmc; + + private String dwxz; + + private String lxdh; + + private String lrrid; + + private String lrr; + + private String lrsj; + + private String xgrid; + + private String xgrxm; + + private String xgsj; + + private String tbbs; + + private String tbsj; + + private String memo; + + private String bz; + + private String dqrq; + + private String sjfwid; + + private String dyhcode; + + private String pcsdm; + + private String jwqid; + + private String ssys; + + private String sno; + + private String zxrq; + + private String zxyy; + + private String lkbzdzid; + + private String lkbzdzmc; + + private String fwzt; + + private String czfwbm; + + private String czfwqm; + + private String tbmemo; + + private String sfcz; + + private String jzlx; + + private String fwdj; + + private String zdfw; + + private String zdry; + + private String sfqz; + + private String zjlx; + + private String zflx; + + private String cws; + + private String czrzjlx; + + private String czrzjhm; + + private String czrxm; + + private String czrlxdh; + + private String cdcJym; + + private String ysbzkRksj; + + private String ysbzkGxsj; + + +} + diff --git a/src/main/java/com/ssf/mysqloracletest/domain/VSySyfwOracle.java b/src/main/java/com/ssf/mysqloracletest/domain/VSySyfwOracle.java new file mode 100644 index 0000000..54b8b97 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/domain/VSySyfwOracle.java @@ -0,0 +1,138 @@ +package com.ssf.mysqloracletest.domain; + +import lombok.Data; + +@Data +public class VSySyfwOracle { + private String zjlid; + + private String ysxtjrzj; + + private String xxscPdbz; + + private String dah; + + private String jcwh; + + private String fwid; + + private String fwlx; + + private String fwdz; + + private String fwxz; + + private String fwlb; + + private String fwjg; + + private String fjs; + + private String mj; + + private String czyt; + + private String djrq; + + private String xm; + + private String sfzh; + + private String xb; + + private String hjdqx; + + private String hjdxz; + + private String xzdqx; + + private String xzdxz; + + private String dwmc; + + private String dwxz; + + private String lxdh; + + private String lrrid; + + private String lrr; + + private String lrsj; + + private String xgrid; + + private String xgrxm; + + private String xgsj; + + private String tbbs; + + private String tbsj; + + private String memo; + + private String bz; + + private String dqrq; + + private String sjfwid; + + private String dyhcode; + + private String pcsdm; + + private String jwqid; + + private String ssys; + + private String sno; + + private String zxrq; + + private String zxyy; + + private String lkbzdzid; + + private String lkbzdzmc; + + private String fwzt; + + private String czfwbm; + + private String czfwqm; + + private String tbmemo; + + private String sfcz; + + private String jzlx; + + private String fwdj; + + private String zdfw; + + private String zdry; + + private String sfqz; + + private String zjlx; + + private String zflx; + + private String cws; + + private String czrzjlx; + + private String czrzjhm; + + private String czrxm; + + private String czrlxdh; + + private String cdcJym; + + private String ysbzkRksj; + + private String ysbzkGxsj; +} diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/VSySyfwMysqlMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/VSySyfwMysqlMapper.java new file mode 100644 index 0000000..4c6e05b --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/mapper/VSySyfwMysqlMapper.java @@ -0,0 +1,22 @@ +package com.ssf.mysqloracletest.mapper; + +import com.ssf.mysqloracletest.domain.VSySyfwMysql; +import org.apache.ibatis.annotations.Mapper; + + +/** + * (VSySyfw)琛ㄦ暟鎹簱璁块棶灞 + * + * @author makejava + * @since 2023-11-28 16:03:25 + */ +@Mapper +public interface VSySyfwMysqlMapper { + + public VSySyfwMysql selectVSySyfwById(String id); + + public int insertVSySyfw(VSySyfwMysql bean); + + public int updateVSySyfwById(VSySyfwMysql bean); +} + diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/VSySyfwOracleMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/VSySyfwOracleMapper.java new file mode 100644 index 0000000..49ae7f8 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/mapper/VSySyfwOracleMapper.java @@ -0,0 +1,14 @@ +package com.ssf.mysqloracletest.mapper; + +import com.ssf.mysqloracletest.domain.VSySyfwOracle; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; +import java.util.Map; + +@Mapper +public interface VSySyfwOracleMapper { + public int countSyfw(); + + public List getSyfwList(Map map); +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/VSySyfwMysqlService.java b/src/main/java/com/ssf/mysqloracletest/service/VSySyfwMysqlService.java new file mode 100644 index 0000000..2667fe6 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/VSySyfwMysqlService.java @@ -0,0 +1,19 @@ +package com.ssf.mysqloracletest.service; + + +import com.ssf.mysqloracletest.domain.VSySyfwMysql; + +/** + * (VSySyfw)琛ㄦ湇鍔℃帴鍙 + * + * @author makejava + * @since 2023-11-28 16:03:26 + */ +public interface VSySyfwMysqlService { + public VSySyfwMysql selectVSySyfwById(String id); + + public int insertVSySyfw(VSySyfwMysql syfw); + + public int updateVSySyfwById(VSySyfwMysql syfw); +} + diff --git a/src/main/java/com/ssf/mysqloracletest/service/VSySyfwOracleService.java b/src/main/java/com/ssf/mysqloracletest/service/VSySyfwOracleService.java new file mode 100644 index 0000000..f73d980 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/VSySyfwOracleService.java @@ -0,0 +1,13 @@ +package com.ssf.mysqloracletest.service; + +import com.ssf.mysqloracletest.domain.VSySyfwOracle; + +import java.util.List; +import java.util.Map; + + +public interface VSySyfwOracleService { + public int countSyfw(); + + public List getSyfwList(Map map); +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/VSySydzOracleServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/VSySydzOracleServiceImpl.java index 0567149..56b4e94 100644 --- a/src/main/java/com/ssf/mysqloracletest/service/impl/VSySydzOracleServiceImpl.java +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/VSySydzOracleServiceImpl.java @@ -4,6 +4,7 @@ import com.baomidou.dynamic.datasource.annotation.DS; import com.ssf.mysqloracletest.domain.VSySydzOracle; import com.ssf.mysqloracletest.mapper.VSySydzOracleMapper; import com.ssf.mysqloracletest.service.VSySydzOracleService; +import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; import javax.annotation.Resource; diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/VSySyfwMysqlServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/VSySyfwMysqlServiceImpl.java new file mode 100644 index 0000000..ebe84a8 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/VSySyfwMysqlServiceImpl.java @@ -0,0 +1,41 @@ +package com.ssf.mysqloracletest.service.impl; + + + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.ssf.mysqloracletest.domain.VSySyfwMysql; +import com.ssf.mysqloracletest.mapper.VSySyfwMysqlMapper; +import com.ssf.mysqloracletest.mapper.VSySyfwMysqlMapper; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; +import com.ssf.mysqloracletest.service.VSySyfwMysqlService; + +/** + * (VSySyfw)琛ㄦ湇鍔″疄鐜扮被 + * + * @author makejava + * @since 2023-11-28 16:03:26 + */ +@Service +@DS("mysql") +@RequiredArgsConstructor +public class VSySyfwMysqlServiceImpl implements VSySyfwMysqlService { + + private final VSySyfwMysqlMapper sySyfwMysqlMapper; + + @Override + public VSySyfwMysql selectVSySyfwById(String id) { + return sySyfwMysqlMapper.selectVSySyfwById(id); + } + + @Override + public int insertVSySyfw(VSySyfwMysql syfw) { + return 0; + } + + @Override + public int updateVSySyfwById(VSySyfwMysql syfw) { + return 0; + } +} + diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/VSySyfwOracleServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/VSySyfwOracleServiceImpl.java new file mode 100644 index 0000000..6a896cf --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/VSySyfwOracleServiceImpl.java @@ -0,0 +1,29 @@ +package com.ssf.mysqloracletest.service.impl; + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.ssf.mysqloracletest.domain.VSySyfwOracle; +import com.ssf.mysqloracletest.mapper.VSySyfwOracleMapper; +import com.ssf.mysqloracletest.service.VSySyfwOracleService; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Map; + +@Service +@DS("oracleSydz") +public class VSySyfwOracleServiceImpl implements VSySyfwOracleService { + + @Resource + private VSySyfwOracleMapper oracleMapper; + + @Override + public int countSyfw() { + return oracleMapper.countSyfw(); + } + + @Override + public List getSyfwList(Map map) { + return oracleMapper.getSyfwList(map); + } +} diff --git a/src/main/java/com/ssf/mysqloracletest/task/VSySydzTask.java b/src/main/java/com/ssf/mysqloracletest/task/VSySydzTask.java index f51c129..8727290 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/VSySydzTask.java +++ b/src/main/java/com/ssf/mysqloracletest/task/VSySydzTask.java @@ -22,7 +22,7 @@ import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /** - * 鐏屼簯 鐢ㄦ埛鏁版嵁鎺ュ叆 + * 鐢ㄦ埛鏁版嵁鎺ュ叆 */ @Component public class VSySydzTask { diff --git a/src/main/java/com/ssf/mysqloracletest/task/VSySyfwTask.java b/src/main/java/com/ssf/mysqloracletest/task/VSySyfwTask.java new file mode 100644 index 0000000..1f0f6f3 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/task/VSySyfwTask.java @@ -0,0 +1,118 @@ +package com.ssf.mysqloracletest.task; + +import com.ssf.mysqloracletest.domain.VSySydzMysql; +import com.ssf.mysqloracletest.domain.VSySydzOracle; +import com.ssf.mysqloracletest.domain.VSySyfwMysql; +import com.ssf.mysqloracletest.domain.VSySyfwOracle; +import com.ssf.mysqloracletest.service.VSySydzMysqlService; +import com.ssf.mysqloracletest.service.VSySydzOracleService; +import com.ssf.mysqloracletest.service.VSySyfwMysqlService; +import com.ssf.mysqloracletest.service.VSySyfwOracleService; +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 VSySyfwTask { + + private static final Logger logger = LoggerFactory.getLogger(VSySyfwTask.class); + + @Resource + private VSySyfwMysqlService syfwMysqlService; + + @Resource + private VSySyfwOracleService syfwOracleService; + + final int oncesCounts = NumKit.checkInt(ConfigParam.oncesCounts) == 0 ? 1000 : NumKit.checkInt(ConfigParam.oncesCounts); + + private boolean syfwTag = false; + + /** + * 杩炰簯娓 瀵规帴娴峰悍骞冲彴鑾峰彇浜哄憳鍩虹鏁版嵁 + * // + */ + @Scheduled(initialDelay = 100, fixedDelay = 3000) + public void transSyfw() { + + if (syfwTag) { + return; + } + + if (!"true".equals(ConfigParam.syfwSwitch)) { + return; + } + + + try { + int countSyfw = syfwOracleService.countSyfw(); + logger.info("countsyfw:" + countSyfw); + + if (countSyfw > 0) { + + syfwTag = true; + + int count = countSyfw / oncesCounts; + CountDownLatch latch = new CountDownLatch(count); + ExecutorService syfwPool = Executors.newFixedThreadPool(50); + + for (int i = 0; i <= count; i++) { + Map syfwMap = new HashMap(); + syfwMap.put("rowStart", i * oncesCounts); + syfwMap.put("rowEnd", (i + 1) * oncesCounts); + syfwPool.submit(() -> { + try { + List syfws = syfwOracleService.getSyfwList(syfwMap); + for (VSySyfwOracle syfw : syfws) { + VSySyfwMysql sBean = new VSySyfwMysql(); + BeanUtils.copyProperties(syfw, sBean); + //纭畾涓涓暟鎹槸鍚﹀敮涓 + VSySyfwMysql checkSyfw = syfwMysqlService.selectVSySyfwById(syfw.getZjlid()); + if (checkSyfw == null) { + syfwMysqlService.insertVSySyfw(sBean); + logger.info("syfw-" + syfw.getZjlid() + ":鎻掑叆鎴愬姛"); + } else { + syfwMysqlService.updateVSySyfwById(sBean); + logger.info("syfw-" + syfw.getZjlid() + ":鏇存柊鎴愬姛"); + } + } + } catch (Exception e) { + logger.info("syfws:" + e.getMessage()); + } + latch.countDown(); + }); + logger.info("syfwMap鏁版嵁鎬婚噺:" + countSyfw + "," + "褰撳墠澶勭悊涓嬫爣:" + syfwMap.get("rowStart") + "/" + syfwMap.get("rowEnd")); + } + + try { + // Wait for all threads to complete + latch.await(); + } catch (InterruptedException e) { + e.printStackTrace(); + } + // 鍏抽棴绾跨▼姹 + syfwPool.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 4710305..4d2bc20 100644 --- a/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java +++ b/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java @@ -10,4 +10,6 @@ public class ConfigParam { public static String seq = File.separator; public static String sydzSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("sydzSwitch")); public static String oncesCounts = StringKit.toString(PropertiesUtil.queryPropertiesByKey("oncesCounts")); + + public static String syfwSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("syfwSwitch")); } diff --git a/src/main/resources/mapper/VSySydzMysqlMapper.xml b/src/main/resources/mapper/VSySydzMysqlMapper.xml index e5b960a..f64b042 100644 --- a/src/main/resources/mapper/VSySydzMysqlMapper.xml +++ b/src/main/resources/mapper/VSySydzMysqlMapper.xml @@ -13,13 +13,12 @@ - + diff --git a/src/main/resources/mapper/VSySydzOracleMapper.xml b/src/main/resources/mapper/VSySydzOracleMapper.xml index 67b1aea..78f1aef 100644 --- a/src/main/resources/mapper/VSySydzOracleMapper.xml +++ b/src/main/resources/mapper/VSySydzOracleMapper.xml @@ -2,8 +2,9 @@ + select count(*) + from SYX_JWYSJ.V_SY_SYDZ + @@ -18,7 +19,9 @@ + SELECT t2.* + FROM (SELECT ROWNUM rn, t1.* FROM (SELECT * FROM SYX_JWYSJ.V_SY_SYDZ) t1 WHERE ROWNUM ${rowEnd}) t2 + WHERE t2.rn = ]]> ${rowStart} + \ No newline at end of file diff --git a/src/main/resources/mapper/VSySyfwMysqlMapper.xml b/src/main/resources/mapper/VSySyfwMysqlMapper.xml new file mode 100644 index 0000000..2051c0e --- /dev/null +++ b/src/main/resources/mapper/VSySyfwMysqlMapper.xml @@ -0,0 +1,313 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into v_sy_syfw + + 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, + ZDFW, + ZDRY, + SFQZ, + ZJLX, + ZFLX, + CWS, + CZRZJLX, + CZRZJHM, + CZRXM, + CZRLXDH, + + CDC_JYM, + YSBZK_RKSJ, + YSBZK_GXSJ, + + + + #{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}, + #{ZDFW}, + #{ZDRY}, + #{SFQZ}, + #{ZJLX}, + #{ZFLX}, + #{CWS}, + #{CZRZJLX}, + #{CZRZJHM}, + #{CZRXM}, + #{CZRLXDH}, + + #{CDC_JYM}, + #{YSBZK_RKSJ}, + #{YSBZK_GXSJ}, + + + + + update v_sy_sydz + + zjlid = #{ZJLID}, + ysxtjrzj=#{YSXTJRZJ}, + xxscPdbz=#{XXSC_PDBZ}, + dah=#{DAH}, + jcwh=#{JCWH}, + + fwid=#{FWID}, + fwlx=#{FWLX}, + fwdz=#{FWDZ}, + fwxz=#{FWXZ}, + fwlb=#{FWLB}, + + fwjg=#{FWJG}, + fjs=#{FJS}, + mj=#{MJ}, + czyt=#{CZYT}, + djrq=#{DJRQ}, + + xm=#{XM}, + sfzh=#{SFZH}, + xb=#{XB}, + hjdqx=#{HJDQX}, + hjdxz=#{HJDXZ}, + + xzdqx=#{XZDQX}, + xzdxz=#{XZDXZ}, + dwmc=#{DWMC}, + dwxz=#{DWXZ}, + lxdh=#{LXDH}, + + lrrid=#{LRRID}, + lrr=#{LRR}, + lrsj=#{LRSJ}, + xgrid=#{XGRID}, + xgrxm=#{XGRXM}, + + xgsj=#{XGSJ}, + tbbs=#{TBBS}, + tbsj=#{TBSJ}, + memo=#{MEMO}, + bz=#{BZ}, + + dqrq=#{DQRQ}, + sjfwid=#{SJFWID}, + dyhcode=#{DYHCODE}, + pcsdm=#{PCSDM}, + jwqid=#{JWQID}, + + ssys=#{SSYS}, + sno=#{SNO}, + zxrq=#{ZXRQ}, + zxyy=#{ZXYY}, + lkbzdzid=#{LKBZDZID}, + + lkbzdzmc=#{LKBZDZMC}, + fwzt=#{FWZT}, + czfwbm=#{CZFWBM}, + czfwqm=#{CZFWQM}, + tbmemo=#{TBMEMO}, + + sfcz=#{SFCZ}, + jzlx=#{JZLX}, + fwdj=#{FWDJ}, + zdfw=#{ZDFW}, + zdry=#{ZDRY}, + + sfqz=#{SFQZ}, + zjlx=#{ZJLX}, + zflx=#{ZFLX}, + cws=#{CWS}, + czrzjlx=#{CZRZJLX}, + + czrzjhm=#{CZRZJHM}, + czrxm=#{CZRXM}, + czrlxdh=#{CZRLXDH}, + cdcJym=#{CDC_JYM}, + ysbzkRksj=#{YSBZK_RKSJ}, + + ysbzkGxsj=#{YSBZK_GXSJ}, + + where DZDXMC = #{DZDXMC} + + + \ No newline at end of file diff --git a/src/main/resources/mapper/VSySyfwOracleMapper.xml b/src/main/resources/mapper/VSySyfwOracleMapper.xml new file mode 100644 index 0000000..0ccbc3e --- /dev/null +++ b/src/main/resources/mapper/VSySyfwOracleMapper.xml @@ -0,0 +1,85 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file