报销接口编写

service/src/main/java/com/hzya/frame/grpU8/nxproof/gbizbsyrec/dao/IGbiZbsyrecDao.java

@@ -12,4 +12,7 @@ import com.hzya.frame.grpU8.nxproof.gbizbsyrec.entity.GbiZbsyrecEntity;
  * @Date: 2023/6/19 14:47
  */
 public interface IGbiZbsyrecDao extends IBaseDao<GbiZbsyrecEntity,String> {
+    Integer deleteData(GbiZbsyrecEntity oeryszb);
+
+    Integer saveData(GbiZbsyrecEntity oeryszb);
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/gbizbsyrec/dao/impl/GbiZbsyrecDaoImpl.java

@@ -1,5 +1,6 @@
 package com.hzya.frame.grpU8.nxproof.gbizbsyrec.dao.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.grpU8.nxproof.gbizbsyrec.dao.IGbiZbsyrecDao;
 import com.hzya.frame.grpU8.nxproof.gbizbsyrec.entity.GbiZbsyrecEntity;
@@ -14,4 +15,17 @@ import org.springframework.stereotype.Repository;
  */
 @Repository(value = "gbiZbsyrecDao")
 public class GbiZbsyrecDaoImpl extends MybatisGenericDao<GbiZbsyrecEntity,String> implements IGbiZbsyrecDao {
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer deleteData( GbiZbsyrecEntity entity) {
+        Integer o = super.delete(getSqlIdPrifx() + "GbiZbsyrecEntity_delete_mlid", entity);
+        return o;
+    }
+
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer saveData( GbiZbsyrecEntity entity) {
+        Integer o = super.insert(getSqlIdPrifx() + "GbiZbsyrecEntity_insert", entity);
+        return o;
+    }
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/oerdjjsfs/dao/IOerDjjsfsDao.java

@@ -12,4 +12,7 @@ import com.hzya.frame.grpU8.nxproof.oerdjjsfs.entity.OerDjjsfsEntity;
  * @Date: 2023/6/19 14:52
  */
 public interface IOerDjjsfsDao extends IBaseDao<OerDjjsfsEntity,String> {
+    Integer deleteData(OerDjjsfsEntity oerDjjsfsEntity);
+
+    Integer saveData(OerDjjsfsEntity oerdjjsfs);
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/oerdjjsfs/dao/impl/OerDjjsfsDaoImpl.java

@@ -1,6 +1,7 @@
 package com.hzya.frame.grpU8.nxproof.oerdjjsfs.dao.impl;
 
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.grpU8.nxproof.oerdjjsfs.dao.IOerDjjsfsDao;
 import com.hzya.frame.grpU8.nxproof.oerdjjsfs.entity.OerDjjsfsEntity;
@@ -15,4 +16,16 @@ import org.springframework.stereotype.Repository;
  */
 @Repository(value = "oerDjjsfsDao")
 public class OerDjjsfsDaoImpl extends MybatisGenericDao<OerDjjsfsEntity,String> implements IOerDjjsfsDao {
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer deleteData(OerDjjsfsEntity entity) {
+        Integer o = super.delete(getSqlIdPrifx() + "OerDjjsfsEntity_delete_delMlid", entity);
+        return o;
+    }
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer saveData(OerDjjsfsEntity entity) {
+        Integer o = super.insert(getSqlIdPrifx() + "OerDjjsfsEntity_insert", entity);
+        return o;
+    }
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/oerdjml/dao/IOerDjmlDao.java

@@ -45,4 +45,8 @@ public interface IOerDjmlDao extends IBaseDao<OerDjmlEntity,String> {
     Integer updateOerDjmlZt(OerDjmlEntity oerDjmlAllEntity);
 
     Integer updateGbiZbsyrecByDjid(GbiZbsyrecAllEntity gbiZbsyrecAllEntity);
+
+    Integer updateData(OerDjmlEntity oerdjml);
+
+    Integer saveData(OerDjmlEntity oerdjml);
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/oerdjml/dao/impl/OerDjmlDaoImpl.java

@@ -1,6 +1,7 @@
 package com.hzya.frame.grpU8.nxproof.oerdjml.dao.impl;
 
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.grpU8.nxproof.oerdjml.dao.IOerDjmlDao;
 import com.hzya.frame.grpU8.nxproof.oerdjml.entity.GbiZbsyrecAllEntity;
@@ -18,7 +19,7 @@ import java.util.List;
  */
 @Repository(value = "oerDjmlDao")
 public class OerDjmlDaoImpl extends MybatisGenericDao<OerDjmlEntity,String> implements IOerDjmlDao {
-
+    @DS("#oerDjmlEntity.dataSourceCode")
     @Override
     public String getMaxDjbgByGsdm(OerDjmlEntity oerDjmlEntity) {
         oerDjmlEntity = (OerDjmlEntity) super.selectOne("OerDjmlEntity_list_base_djbhMax",oerDjmlEntity);
@@ -28,7 +29,7 @@ public class OerDjmlDaoImpl extends MybatisGenericDao<OerDjmlEntity,String> impl
            return oerDjmlEntity.getDjbh();
         }
     }
-
+    @DS("#oerDjmlEntity.dataSourceCode")
     @Override
     public String getMaxMlIdByGsdm(OerDjmlEntity oerDjmlEntity) {
         oerDjmlEntity= (OerDjmlEntity) super.selectOne("OerDjmlEntity_list_base_mlidMax",oerDjmlEntity);
@@ -58,22 +59,35 @@ public class OerDjmlDaoImpl extends MybatisGenericDao<OerDjmlEntity,String> impl
             return oerDjmlEntity;
         }
     }
-
+    @DS("#entity.dataSourceCode")
     @Override
-    public List<OerDjmlEntity> queryOerDjml(OerDjmlEntity oerDjmlAllEntity) {
+    public List<OerDjmlEntity> queryOerDjml(OerDjmlEntity entity) {
-        List<OerDjmlEntity> o = (List<OerDjmlEntity>) super.selectList(getSqlIdPrifx() + "queryOerDjml", oerDjmlAllEntity);
+        List<OerDjmlEntity> o = (List<OerDjmlEntity>) super.selectList(getSqlIdPrifx() + "queryOerDjml", entity);
+        return o;
+    }
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer updateOerDjmlZt(OerDjmlEntity entity) {
+        Integer o = super.update(getSqlIdPrifx() + "updateOerDjmlZt", entity);
+        return o;
+    }
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer updateGbiZbsyrecByDjid(GbiZbsyrecAllEntity entity) {
+        Integer o = super.update(getSqlIdPrifx() + "updateGbiZbsyrecByDjid", entity);
         return o;
     }
 
+    @DS("#entity.dataSourceCode")
     @Override
-    public Integer updateOerDjmlZt(OerDjmlEntity oerDjmlAllEntity) {
+    public Integer updateData(OerDjmlEntity entity) {
-        Integer o = super.update(getSqlIdPrifx() + "updateOerDjmlZt", oerDjmlAllEntity);
+        Integer o = super.update(getSqlIdPrifx() + "OerDjmlEntity_update_data", entity);
         return o;
     }
-
+    @DS("#entity.dataSourceCode")
     @Override
-    public Integer updateGbiZbsyrecByDjid(GbiZbsyrecAllEntity gbiZbsyrecAllEntity) {
+    public Integer saveData(OerDjmlEntity entity) {
-        Integer o = super.update(getSqlIdPrifx() + "updateGbiZbsyrecByDjid", gbiZbsyrecAllEntity);
+        Integer o = super.insert(getSqlIdPrifx() + "OerDjmlEntity_insert", entity);
         return o;
     }
 

service/src/main/java/com/hzya/frame/grpU8/nxproof/oerdjml/entity/OerDjmlEntity.xml

@@ -230,472 +230,11 @@ GSDM,KJND,mlId
 
     <select id="queryOerDjml" resultType="com.hzya.frame.grpU8.nxproof.oerdjml.entity.OerDjmlEntity" parameterType = "com.hzya.frame.grpU8.nxproof.oerdjml.entity.OerDjmlEntity">
         select
-        MLID
+        mlId,
-        ,GSDM
+        DJBH
-        ,KJND
-        ,DJLXID
-        ,DQRQ
-        ,ZT
-        ,CRERDM
-        ,CRERMC
-        ,CRERDATE
-        ,FKDH
-        ,FKRID
-        ,FKR
-        ,FKRQ
-        ,IDPZH
-        ,PZRID
-        ,PZR
-        ,PZRQ
-        ,DJBH
-        ,DJDATE
-        ,JE
-        ,JEDX
-        ,WHJE
-        ,FJS
-        ,ZY
-        ,YJJE
-        ,THJE
-        ,BLJE
-        ,BMDM
-        ,BMMC
-        ,XMDM
-        ,XMMC
-        ,GRDM
-        ,GRMC
-        ,DWDM
-        ,DWMC
-        ,GNDM
-        ,GNMC
-        ,JJDM
-        ,JJMC
-        ,FZX6DM
-        ,FZX6MC
-        ,FZX7DM
-        ,FZX7MC
-        ,FZX8DM
-        ,FZX8MC
-        ,FZX9DM
-        ,FZX9MC
-        ,FZXADM
-        ,FZXAMC
-        ,KMDM
-        ,KMMC
-        ,HTBH
-        ,HTJH
-        ,SKR
-        ,YHZH
-        ,KHYH
-        ,CURSHJD
-        ,NEXTSHJD
-        ,FLOWCODE
-        ,SHRID
-        ,SHR
-        ,SHRQ
-        ,SFTH
-        ,THXX
-        ,JSFS
-        ,FQRID
-        ,FQR
-        ,FQRQ
-        ,WX00000051
-        ,WX00000052
-        ,WX00000053
-        ,WX00000054
-        ,WX00000055
-        ,WX00000056
-        ,WX00000057
-        ,WX00000058
-        ,WX00000059
-        ,XQ
-        ,WX00000060
-        ,SKZH
-        ,FKZH
-        ,JSDH
-        ,JSRID
-        ,JSR
-        ,JSRQ
-        ,WX00000061
-        ,WX00000062
-        ,LYBXSX
-        ,WX00000065
-        ,WX00000066
-        ,WX00000063
-        ,WX00000064
-        ,WX00000067
-        ,WX00000068
-        ,WX00000069
-        ,JFLXDM
-        ,JFLXMC
-        ,GZDM
-        ,GZMC
-        ,MXXMDM
-        ,MXXMMC
-        ,JXSE
-        ,POSRQ
-        ,POSDH
-        ,SFZH
-        ,PROVINCE
-        ,CITY
-        ,YH
-        ,YHHH
-        ,KHDQ
-        ,WYZFGUID
-        ,FKRNAME
-        ,FKRKHYH
-        ,FKRYHZH
-        ,TEL
-        ,CLF_CCR
-        ,WLYWGUID
-        ,YYBH
-        ,ZJXZDM
-        ,ZJXZMC
-        ,ZJLYDM
-        ,ZJLYMC
-        ,YSDWDM
-        ,YSDWMC
-        ,SFKGSDM
-        ,wlh
-        ,wlhDisplay
-        ,CLF_CCLB
-        ,KZZL1DM
-        ,KZZL1MC
-        ,KZZL2DM
-        ,KZZL2MC
-        ,KZZL3DM
-        ,KZZL3MC
-        ,KZZL4DM
-        ,KZZL4MC
-        ,KZZL5DM
-        ,KZZL5MC
-        ,KZZL6DM
-        ,KZZL6MC
-        ,KZZL7DM
-        ,KZZL7MC
-        ,ZCSXDM
-        ,ZCSXMC
-        ,FYBZ
-        ,TS
-        ,HDKSRQ
-        ,HDJSRQ
-        ,StartDate
-        ,EndDate
-        ,SFDD
-        ,FDDSM
-        ,ZWJB
-        ,JDDXDW
-        ,ZBXM
-        ,HYLB
-        ,PXMC
-        ,PXLB
-        ,ZYRS
-        ,FZRS
-        ,DD
-        ,HYMC
-        ,SmsSendFlag
-        ,BillMODS
-        ,DX_LWFDH
-        ,DX_CLSPDH
-        ,DX_HYJH
-        ,DX_ZCLX
-        ,ZFFSXX
-        ,CLF_QZF
-        ,CLF_BXF
-        ,CLF_QTF
-        ,CLF_JTF
-        ,CLF_CCTS
-        ,DYRID
-        ,DYR
-        ,DYRQ
-        ,DYCS
-        ,IDSFPD
-        ,YSKJKMDM
-        ,YSKJKMMC
-        ,DJGUID
-        ,SSRQ
-        ,SSRID
-        ,SSR
-        ,XMFLDM
-        ,XMFLMC
-        ,ZCBH
-        ,GWZJBXDBH
-        ,WBDJBH
-        ,FZX11DM
-        ,FZX11MC
-        ,FZX12DM
-        ,FZX12MC
-        ,FZX13DM
-        ,FZX13MC
-        ,FZX14DM
-        ,FZX14MC
-        ,FZX15DM
-        ,FZX15MC
-        ,FZX16DM
-        ,FZX16MC
-        ,FZX17DM
-        ,FZX17MC
-        ,FZX18DM
-        ,FZX18MC
-        ,FZX19DM
-        ,FZX19MC
-        ,FZX20DM
-        ,FZX20MC
-        ,FZX21DM
-        ,FZX21MC
-        ,FZX22DM
-        ,FZX22MC
-        ,FZX23DM
-        ,FZX23MC
-        ,FZX24DM
-        ,FZX24MC
-        ,FZX25DM
-        ,FZX25MC
-        ,FZX26DM
-        ,FZX26MC
-        ,FZX27DM
-        ,FZX27MC
-        ,FZX28DM
-        ,FZX28MC
-        ,FZX29DM
-        ,FZX29MC
-        ,FZX30DM
-        ,FZX30MC
-        ,TDUSER
-        ,TDDATE
         from OER_DJML
         <trim prefix="where" prefixOverrides="and">
-            <if test="mlid != null"> and MLID = #{mlid} </if>
-            <if test="gsdm != null and gsdm != ''"> and GSDM = #{gsdm} </if>
-            <if test="kjnd != null and kjnd != ''"> and KJND = #{kjnd} </if>
-            <if test="djlxid != null"> and DJLXID = #{djlxid} </if>
-            <if test="dqrq != null and dqrq != ''"> and DQRQ = #{dqrq} </if>
-            <if test="zt != null and zt != ''"> and ZT = #{zt} </if>
-            <if test="crerdm != null and crerdm != ''"> and CRERDM = #{crerdm} </if>
-            <if test="crermc != null and crermc != ''"> and CRERMC = #{crermc} </if>
-            <if test="crerdate != null and crerdate != ''"> and CRERDATE = #{crerdate} </if>
-            <if test="fkdh != null and fkdh != ''"> and FKDH = #{fkdh} </if>
-            <if test="fkrid != null"> and FKRID = #{fkrid} </if>
-            <if test="fkr != null and fkr != ''"> and FKR = #{fkr} </if>
-            <if test="fkrq != null and fkrq != ''"> and FKRQ = #{fkrq} </if>
-            <if test="idpzh != null and idpzh != ''"> and IDPZH = #{idpzh} </if>
-            <if test="pzrid != null"> and PZRID = #{pzrid} </if>
-            <if test="pzr != null and pzr != ''"> and PZR = #{pzr} </if>
-            <if test="pzrq != null and pzrq != ''"> and PZRQ = #{pzrq} </if>
             <if test="djbh != null and djbh != ''"> and DJBH = #{djbh} </if>
-            <if test="djdate != null and djdate != ''"> and DJDATE = #{djdate} </if>
-            <if test="je != null"> and JE = #{je} </if>
-            <if test="jedx != null and jedx != ''"> and JEDX = #{jedx} </if>
-            <if test="whje != null"> and WHJE = #{whje} </if>
-            <if test="fjs != null"> and FJS = #{fjs} </if>
-            <if test="zy != null and zy != ''"> and ZY = #{zy} </if>
-            <if test="yjje != null"> and YJJE = #{yjje} </if>
-            <if test="thje != null"> and THJE = #{thje} </if>
-            <if test="blje != null"> and BLJE = #{blje} </if>
-            <if test="bmdm != null and bmdm != ''"> and BMDM = #{bmdm} </if>
-            <if test="bmmc != null and bmmc != ''"> and BMMC = #{bmmc} </if>
-            <if test="xmdm != null and xmdm != ''"> and XMDM = #{xmdm} </if>
-            <if test="xmmc != null and xmmc != ''"> and XMMC = #{xmmc} </if>
-            <if test="grdm != null and grdm != ''"> and GRDM = #{grdm} </if>
-            <if test="grmc != null and grmc != ''"> and GRMC = #{grmc} </if>
-            <if test="dwdm != null and dwdm != ''"> and DWDM = #{dwdm} </if>
-            <if test="dwmc != null and dwmc != ''"> and DWMC = #{dwmc} </if>
-            <if test="gndm != null and gndm != ''"> and GNDM = #{gndm} </if>
-            <if test="gnmc != null and gnmc != ''"> and GNMC = #{gnmc} </if>
-            <if test="jjdm != null and jjdm != ''"> and JJDM = #{jjdm} </if>
-            <if test="jjmc != null and jjmc != ''"> and JJMC = #{jjmc} </if>
-            <if test="fzx6dm != null and fzx6dm != ''"> and FZX6DM = #{fzx6dm} </if>
-            <if test="fzx6mc != null and fzx6mc != ''"> and FZX6MC = #{fzx6mc} </if>
-            <if test="fzx7dm != null and fzx7dm != ''"> and FZX7DM = #{fzx7dm} </if>
-            <if test="fzx7mc != null and fzx7mc != ''"> and FZX7MC = #{fzx7mc} </if>
-            <if test="fzx8dm != null and fzx8dm != ''"> and FZX8DM = #{fzx8dm} </if>
-            <if test="fzx8mc != null and fzx8mc != ''"> and FZX8MC = #{fzx8mc} </if>
-            <if test="fzx9dm != null and fzx9dm != ''"> and FZX9DM = #{fzx9dm} </if>
-            <if test="fzx9mc != null and fzx9mc != ''"> and FZX9MC = #{fzx9mc} </if>
-            <if test="fzxadm != null and fzxadm != ''"> and FZXADM = #{fzxadm} </if>
-            <if test="fzxamc != null and fzxamc != ''"> and FZXAMC = #{fzxamc} </if>
-            <if test="kmdm != null and kmdm != ''"> and KMDM = #{kmdm} </if>
-            <if test="kmmc != null and kmmc != ''"> and KMMC = #{kmmc} </if>
-            <if test="htbh != null and htbh != ''"> and HTBH = #{htbh} </if>
-            <if test="htjh != null and htjh != ''"> and HTJH = #{htjh} </if>
-            <if test="skr != null and skr != ''"> and SKR = #{skr} </if>
-            <if test="yhzh != null and yhzh != ''"> and YHZH = #{yhzh} </if>
-            <if test="khyh != null and khyh != ''"> and KHYH = #{khyh} </if>
-            <if test="curshjd != null"> and CURSHJD = #{curshjd} </if>
-            <if test="nextshjd != null"> and NEXTSHJD = #{nextshjd} </if>
-            <if test="flowcode != null and flowcode != ''"> and FLOWCODE = #{flowcode} </if>
-            <if test="shrid != null and shrid != ''"> and SHRID = #{shrid} </if>
-            <if test="shr != null and shr != ''"> and SHR = #{shr} </if>
-            <if test="shrq != null and shrq != ''"> and SHRQ = #{shrq} </if>
-            <if test="sfth != null and sfth != ''"> and SFTH = #{sfth} </if>
-            <if test="thxx != null and thxx != ''"> and THXX = #{thxx} </if>
-            <if test="jsfs != null and jsfs != ''"> and JSFS = #{jsfs} </if>
-            <if test="fqrid != null"> and FQRID = #{fqrid} </if>
-            <if test="fqr != null and fqr != ''"> and FQR = #{fqr} </if>
-            <if test="fqrq != null and fqrq != ''"> and FQRQ = #{fqrq} </if>
-            <if test="wx00000051 != null and wx00000051 != ''"> and WX00000051 = #{wx00000051} </if>
-            <if test="wx00000052 != null and wx00000052 != ''"> and WX00000052 = #{wx00000052} </if>
-            <if test="wx00000053 != null and wx00000053 != ''"> and WX00000053 = #{wx00000053} </if>
-            <if test="wx00000054 != null and wx00000054 != ''"> and WX00000054 = #{wx00000054} </if>
-            <if test="wx00000055 != null and wx00000055 != ''"> and WX00000055 = #{wx00000055} </if>
-            <if test="wx00000056 != null"> and WX00000056 = #{wx00000056} </if>
-            <if test="wx00000057 != null and wx00000057 != ''"> and WX00000057 = #{wx00000057} </if>
-            <if test="wx00000058 != null and wx00000058 != ''"> and WX00000058 = #{wx00000058} </if>
-            <if test="wx00000059 != null"> and WX00000059 = #{wx00000059} </if>
-            <if test="xq != null and xq != ''"> and XQ = #{xq} </if>
-            <if test="wx00000060 != null and wx00000060 != ''"> and WX00000060 = #{wx00000060} </if>
-            <if test="skzh != null and skzh != ''"> and SKZH = #{skzh} </if>
-            <if test="fkzh != null and fkzh != ''"> and FKZH = #{fkzh} </if>
-            <if test="jsdh != null and jsdh != ''"> and JSDH = #{jsdh} </if>
-            <if test="jsrid != null"> and JSRID = #{jsrid} </if>
-            <if test="jsr != null and jsr != ''"> and JSR = #{jsr} </if>
-            <if test="jsrq != null and jsrq != ''"> and JSRQ = #{jsrq} </if>
-            <if test="wx00000061 != null and wx00000061 != ''"> and WX00000061 = #{wx00000061} </if>
-            <if test="wx00000062 != null and wx00000062 != ''"> and WX00000062 = #{wx00000062} </if>
-            <if test="lybxsx != null and lybxsx != ''"> and LYBXSX = #{lybxsx} </if>
-            <if test="wx00000065 != null"> and WX00000065 = #{wx00000065} </if>
-            <if test="wx00000066 != null"> and WX00000066 = #{wx00000066} </if>
-            <if test="wx00000063 != null"> and WX00000063 = #{wx00000063} </if>
-            <if test="wx00000064 != null"> and WX00000064 = #{wx00000064} </if>
-            <if test="wx00000067 != null and wx00000067 != ''"> and WX00000067 = #{wx00000067} </if>
-            <if test="wx00000068 != null"> and WX00000068 = #{wx00000068} </if>
-            <if test="wx00000069 != null and wx00000069 != ''"> and WX00000069 = #{wx00000069} </if>
-            <if test="jflxdm != null and jflxdm != ''"> and JFLXDM = #{jflxdm} </if>
-            <if test="jflxmc != null and jflxmc != ''"> and JFLXMC = #{jflxmc} </if>
-            <if test="gzdm != null"> and GZDM = #{gzdm} </if>
-            <if test="gzmc != null and gzmc != ''"> and GZMC = #{gzmc} </if>
-            <if test="mxxmdm != null and mxxmdm != ''"> and MXXMDM = #{mxxmdm} </if>
-            <if test="mxxmmc != null and mxxmmc != ''"> and MXXMMC = #{mxxmmc} </if>
-            <if test="jxse != null"> and JXSE = #{jxse} </if>
-            <if test="posrq != null and posrq != ''"> and POSRQ = #{posrq} </if>
-            <if test="posdh != null and posdh != ''"> and POSDH = #{posdh} </if>
-            <if test="sfzh != null and sfzh != ''"> and SFZH = #{sfzh} </if>
-            <if test="province != null and province != ''"> and PROVINCE = #{province} </if>
-            <if test="city != null and city != ''"> and CITY = #{city} </if>
-            <if test="yh != null and yh != ''"> and YH = #{yh} </if>
-            <if test="yhhh != null and yhhh != ''"> and YHHH = #{yhhh} </if>
-            <if test="khdq != null and khdq != ''"> and KHDQ = #{khdq} </if>
-            <if test="wyzfguid != null and wyzfguid != ''"> and WYZFGUID = #{wyzfguid} </if>
-            <if test="fkrname != null and fkrname != ''"> and FKRNAME = #{fkrname} </if>
-            <if test="fkrkhyh != null and fkrkhyh != ''"> and FKRKHYH = #{fkrkhyh} </if>
-            <if test="fkryhzh != null and fkryhzh != ''"> and FKRYHZH = #{fkryhzh} </if>
-            <if test="tel != null and tel != ''"> and TEL = #{tel} </if>
-            <if test="clfCcr != null and clfCcr != ''"> and CLF_CCR = #{clfCcr} </if>
-            <if test="wlywguid != null and wlywguid != ''"> and WLYWGUID = #{wlywguid} </if>
-            <if test="yybh != null and yybh != ''"> and YYBH = #{yybh} </if>
-            <if test="zjxzdm != null and zjxzdm != ''"> and ZJXZDM = #{zjxzdm} </if>
-            <if test="zjxzmc != null and zjxzmc != ''"> and ZJXZMC = #{zjxzmc} </if>
-            <if test="zjlydm != null and zjlydm != ''"> and ZJLYDM = #{zjlydm} </if>
-            <if test="zjlymc != null and zjlymc != ''"> and ZJLYMC = #{zjlymc} </if>
-            <if test="ysdwdm != null and ysdwdm != ''"> and YSDWDM = #{ysdwdm} </if>
-            <if test="ysdwmc != null and ysdwmc != ''"> and YSDWMC = #{ysdwmc} </if>
-            <if test="sfkgsdm != null and sfkgsdm != ''"> and SFKGSDM = #{sfkgsdm} </if>
-            <if test="wlh != null and wlh != ''"> and wlh = #{wlh} </if>
-            <if test="wlhdisplay != null and wlhdisplay != ''"> and wlhDisplay = #{wlhdisplay} </if>
-            <if test="clfCclb != null and clfCclb != ''"> and CLF_CCLB = #{clfCclb} </if>
-            <if test="kzzl1dm != null and kzzl1dm != ''"> and KZZL1DM = #{kzzl1dm} </if>
-            <if test="kzzl1mc != null and kzzl1mc != ''"> and KZZL1MC = #{kzzl1mc} </if>
-            <if test="kzzl2dm != null and kzzl2dm != ''"> and KZZL2DM = #{kzzl2dm} </if>
-            <if test="kzzl2mc != null and kzzl2mc != ''"> and KZZL2MC = #{kzzl2mc} </if>
-            <if test="kzzl3dm != null and kzzl3dm != ''"> and KZZL3DM = #{kzzl3dm} </if>
-            <if test="kzzl3mc != null and kzzl3mc != ''"> and KZZL3MC = #{kzzl3mc} </if>
-            <if test="kzzl4dm != null and kzzl4dm != ''"> and KZZL4DM = #{kzzl4dm} </if>
-            <if test="kzzl4mc != null and kzzl4mc != ''"> and KZZL4MC = #{kzzl4mc} </if>
-            <if test="kzzl5dm != null and kzzl5dm != ''"> and KZZL5DM = #{kzzl5dm} </if>
-            <if test="kzzl5mc != null and kzzl5mc != ''"> and KZZL5MC = #{kzzl5mc} </if>
-            <if test="kzzl6dm != null and kzzl6dm != ''"> and KZZL6DM = #{kzzl6dm} </if>
-            <if test="kzzl6mc != null and kzzl6mc != ''"> and KZZL6MC = #{kzzl6mc} </if>
-            <if test="kzzl7dm != null and kzzl7dm != ''"> and KZZL7DM = #{kzzl7dm} </if>
-            <if test="kzzl7mc != null and kzzl7mc != ''"> and KZZL7MC = #{kzzl7mc} </if>
-            <if test="zcsxdm != null and zcsxdm != ''"> and ZCSXDM = #{zcsxdm} </if>
-            <if test="zcsxmc != null and zcsxmc != ''"> and ZCSXMC = #{zcsxmc} </if>
-            <if test="fybz != null and fybz != ''"> and FYBZ = #{fybz} </if>
-            <if test="ts != null"> and TS = #{ts} </if>
-            <if test="hdksrq != null and hdksrq != ''"> and HDKSRQ = #{hdksrq} </if>
-            <if test="hdjsrq != null and hdjsrq != ''"> and HDJSRQ = #{hdjsrq} </if>
-            <if test="startdate != null and startdate != ''"> and StartDate = #{startdate} </if>
-            <if test="enddate != null and enddate != ''"> and EndDate = #{enddate} </if>
-            <if test="sfdd != null and sfdd != ''"> and SFDD = #{sfdd} </if>
-            <if test="fddsm != null and fddsm != ''"> and FDDSM = #{fddsm} </if>
-            <if test="zwjb != null and zwjb != ''"> and ZWJB = #{zwjb} </if>
-            <if test="jddxdw != null and jddxdw != ''"> and JDDXDW = #{jddxdw} </if>
-            <if test="zbxm != null and zbxm != ''"> and ZBXM = #{zbxm} </if>
-            <if test="hylb != null and hylb != ''"> and HYLB = #{hylb} </if>
-            <if test="pxmc != null and pxmc != ''"> and PXMC = #{pxmc} </if>
-            <if test="pxlb != null and pxlb != ''"> and PXLB = #{pxlb} </if>
-            <if test="zyrs != null"> and ZYRS = #{zyrs} </if>
-            <if test="fzrs != null"> and FZRS = #{fzrs} </if>
-            <if test="dd != null and dd != ''"> and DD = #{dd} </if>
-            <if test="hymc != null and hymc != ''"> and HYMC = #{hymc} </if>
-            <if test="smssendflag != null"> and SmsSendFlag = #{smssendflag} </if>
-            <if test="billmods != null and billmods != ''"> and BillMODS = #{billmods} </if>
-            <if test="dxLwfdh != null and dxLwfdh != ''"> and DX_LWFDH = #{dxLwfdh} </if>
-            <if test="dxClspdh != null and dxClspdh != ''"> and DX_CLSPDH = #{dxClspdh} </if>
-            <if test="dxHyjh != null and dxHyjh != ''"> and DX_HYJH = #{dxHyjh} </if>
-            <if test="dxZclx != null and dxZclx != ''"> and DX_ZCLX = #{dxZclx} </if>
-            <if test="zffsxx != null and zffsxx != ''"> and ZFFSXX = #{zffsxx} </if>
-            <if test="clfQzf != null"> and CLF_QZF = #{clfQzf} </if>
-            <if test="clfBxf != null"> and CLF_BXF = #{clfBxf} </if>
-            <if test="clfQtf != null"> and CLF_QTF = #{clfQtf} </if>
-            <if test="clfJtf != null"> and CLF_JTF = #{clfJtf} </if>
-            <if test="clfCcts != null"> and CLF_CCTS = #{clfCcts} </if>
-            <if test="dyrid != null and dyrid != ''"> and DYRID = #{dyrid} </if>
-            <if test="dyr != null and dyr != ''"> and DYR = #{dyr} </if>
-            <if test="dyrq != null and dyrq != ''"> and DYRQ = #{dyrq} </if>
-            <if test="dycs != null"> and DYCS = #{dycs} </if>
-            <if test="idsfpd != null and idsfpd != ''"> and IDSFPD = #{idsfpd} </if>
-            <if test="yskjkmdm != null and yskjkmdm != ''"> and YSKJKMDM = #{yskjkmdm} </if>
-            <if test="yskjkmmc != null and yskjkmmc != ''"> and YSKJKMMC = #{yskjkmmc} </if>
-            <if test="djguid != null and djguid != ''"> and DJGUID = #{djguid} </if>
-            <if test="ssrq != null and ssrq != ''"> and SSRQ = #{ssrq} </if>
-            <if test="ssrid != null and ssrid != ''"> and SSRID = #{ssrid} </if>
-            <if test="ssr != null and ssr != ''"> and SSR = #{ssr} </if>
-            <if test="xmfldm != null and xmfldm != ''"> and XMFLDM = #{xmfldm} </if>
-            <if test="xmflmc != null and xmflmc != ''"> and XMFLMC = #{xmflmc} </if>
-            <if test="zcbh != null and zcbh != ''"> and ZCBH = #{zcbh} </if>
-            <if test="gwzjbxdbh != null and gwzjbxdbh != ''"> and GWZJBXDBH = #{gwzjbxdbh} </if>
-            <if test="wbdjbh != null and wbdjbh != ''"> and WBDJBH = #{wbdjbh} </if>
-            <if test="fzx11dm != null and fzx11dm != ''"> and FZX11DM = #{fzx11dm} </if>
-            <if test="fzx11mc != null and fzx11mc != ''"> and FZX11MC = #{fzx11mc} </if>
-            <if test="fzx12dm != null and fzx12dm != ''"> and FZX12DM = #{fzx12dm} </if>
-            <if test="fzx12mc != null and fzx12mc != ''"> and FZX12MC = #{fzx12mc} </if>
-            <if test="fzx13dm != null and fzx13dm != ''"> and FZX13DM = #{fzx13dm} </if>
-            <if test="fzx13mc != null and fzx13mc != ''"> and FZX13MC = #{fzx13mc} </if>
-            <if test="fzx14dm != null and fzx14dm != ''"> and FZX14DM = #{fzx14dm} </if>
-            <if test="fzx14mc != null and fzx14mc != ''"> and FZX14MC = #{fzx14mc} </if>
-            <if test="fzx15dm != null and fzx15dm != ''"> and FZX15DM = #{fzx15dm} </if>
-            <if test="fzx15mc != null and fzx15mc != ''"> and FZX15MC = #{fzx15mc} </if>
-            <if test="fzx16dm != null and fzx16dm != ''"> and FZX16DM = #{fzx16dm} </if>
-            <if test="fzx16mc != null and fzx16mc != ''"> and FZX16MC = #{fzx16mc} </if>
-            <if test="fzx17dm != null and fzx17dm != ''"> and FZX17DM = #{fzx17dm} </if>
-            <if test="fzx17mc != null and fzx17mc != ''"> and FZX17MC = #{fzx17mc} </if>
-            <if test="fzx18dm != null and fzx18dm != ''"> and FZX18DM = #{fzx18dm} </if>
-            <if test="fzx18mc != null and fzx18mc != ''"> and FZX18MC = #{fzx18mc} </if>
-            <if test="fzx19dm != null and fzx19dm != ''"> and FZX19DM = #{fzx19dm} </if>
-            <if test="fzx19mc != null and fzx19mc != ''"> and FZX19MC = #{fzx19mc} </if>
-            <if test="fzx20dm != null and fzx20dm != ''"> and FZX20DM = #{fzx20dm} </if>
-            <if test="fzx20mc != null and fzx20mc != ''"> and FZX20MC = #{fzx20mc} </if>
-            <if test="fzx21dm != null and fzx21dm != ''"> and FZX21DM = #{fzx21dm} </if>
-            <if test="fzx21mc != null and fzx21mc != ''"> and FZX21MC = #{fzx21mc} </if>
-            <if test="fzx22dm != null and fzx22dm != ''"> and FZX22DM = #{fzx22dm} </if>
-            <if test="fzx22mc != null and fzx22mc != ''"> and FZX22MC = #{fzx22mc} </if>
-            <if test="fzx23dm != null and fzx23dm != ''"> and FZX23DM = #{fzx23dm} </if>
-            <if test="fzx23mc != null and fzx23mc != ''"> and FZX23MC = #{fzx23mc} </if>
-            <if test="fzx24dm != null and fzx24dm != ''"> and FZX24DM = #{fzx24dm} </if>
-            <if test="fzx24mc != null and fzx24mc != ''"> and FZX24MC = #{fzx24mc} </if>
-            <if test="fzx25dm != null and fzx25dm != ''"> and FZX25DM = #{fzx25dm} </if>
-            <if test="fzx25mc != null and fzx25mc != ''"> and FZX25MC = #{fzx25mc} </if>
-            <if test="fzx26dm != null and fzx26dm != ''"> and FZX26DM = #{fzx26dm} </if>
-            <if test="fzx26mc != null and fzx26mc != ''"> and FZX26MC = #{fzx26mc} </if>
-            <if test="fzx27dm != null and fzx27dm != ''"> and FZX27DM = #{fzx27dm} </if>
-            <if test="fzx27mc != null and fzx27mc != ''"> and FZX27MC = #{fzx27mc} </if>
-            <if test="fzx28dm != null and fzx28dm != ''"> and FZX28DM = #{fzx28dm} </if>
-            <if test="fzx28mc != null and fzx28mc != ''"> and FZX28MC = #{fzx28mc} </if>
-            <if test="fzx29dm != null and fzx29dm != ''"> and FZX29DM = #{fzx29dm} </if>
-            <if test="fzx29mc != null and fzx29mc != ''"> and FZX29MC = #{fzx29mc} </if>
-            <if test="fzx30dm != null and fzx30dm != ''"> and FZX30DM = #{fzx30dm} </if>
-            <if test="fzx30mc != null and fzx30mc != ''"> and FZX30MC = #{fzx30mc} </if>
-            <if test="tduser != null and tduser != ''"> and TDUSER = #{tduser} </if>
-            <if test="tddate != null and tddate != ''"> and TDDATE = #{tddate} </if>
         </trim>
     </select>
 

service/src/main/java/com/hzya/frame/grpU8/nxproof/oerdjml/service/impl/OerDjmlServiceImpl.java

@@ -367,7 +367,7 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
     private GbiZbsyrecEntity setOerYszbEntity(OerDjmlEntity entity,OerDjnrEntity djnrEntity) {
         GbiZbsyrecEntity   yszbEntity = new GbiZbsyrecEntity();
         BeanUtil.copyProperties(djnrEntity,yszbEntity);
-        yszbEntity.setModule(djnrEntity.getModule());
+        yszbEntity.setModule("OER");
         yszbEntity.setDjlx(djnrEntity.getDjlxId());
         yszbEntity.setDjId(djnrEntity.getMlId());
         yszbEntity.setDjflh(djnrEntity.getDjflh());
@@ -723,6 +723,10 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
         if (entity == null) {
             return BaseResult.getFailureMessageEntity("参数不允许为空");
         }
+        if (entity.getDataSourceCode() == null || "".equals(entity.getDataSourceCode())) {
+            return BaseResult.getFailureMessageEntity("数据源编码不允许为空");
+        }
+        String dataSourceCode = entity.getDataSourceCode();
         if (entity.getLclb() == null || "".equals(entity.getLclb())) {
             return BaseResult.getFailureMessageEntity("流程类别不允许为空");
         }
@@ -733,9 +737,10 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
             return BaseResult.getFailureMessageEntity("单据编号不允许为空");
         }
         if(ColEventTypeEnum.ONSTART.getType().equals(entity.getLclb())){//流程发起
-            return saveOrUpdateData(entity);
+            return saveOrUpdateData(dataSourceCode,entity);
         }else if(ColEventTypeEnum.ONCANCEL.getType().equals(entity.getLclb())){//流程撤销
             OerDjmlEntity oerDjmlAllEntity = new OerDjmlEntity();
+            oerDjmlAllEntity.setDataSourceCode(dataSourceCode);
             oerDjmlAllEntity.setDjbh(entity.getDjbh());
             List<OerDjmlEntity> oerDjmlAllEntities = iOerDjmlDao.queryOerDjml(oerDjmlAllEntity);
             if(oerDjmlAllEntities != null && oerDjmlAllEntities.size() == 1){
@@ -751,14 +756,15 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
                 gbiZbsyrecAllEntity.setKjnd(oerDjmlAllEntities.get(0).getKjnd());
                 gbiZbsyrecAllEntity.setDjflmx(Integer.valueOf(oerDjmlAllEntities.get(0).getMlId()));
                 gbiZbsyrecAllEntity.setModule("'OER'");
-
                 gbiZbsyrecAllEntity.setDjzt("0");
+                gbiZbsyrecAllEntity.setDataSourceCode(dataSourceCode);
                 iOerDjmlDao.updateGbiZbsyrecByDjid(gbiZbsyrecAllEntity);
             }else {
                 return BaseResult.getFailureMessageEntity("根据单据编号存在多条报销单");
             }
         }else if(ColEventTypeEnum.ONSTOP.getType().equals(entity.getLclb())){//流程终止
             OerDjmlEntity oerDjmlAllEntity = new OerDjmlEntity();
+            oerDjmlAllEntity.setDataSourceCode(dataSourceCode);
             oerDjmlAllEntity.setDjbh(entity.getDjbh());
             List<OerDjmlEntity> oerDjmlAllEntities = iOerDjmlDao.queryOerDjml(oerDjmlAllEntity);
             if(oerDjmlAllEntities != null && oerDjmlAllEntities.size() == 1){
@@ -774,14 +780,15 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
                 gbiZbsyrecAllEntity.setKjnd(oerDjmlAllEntities.get(0).getKjnd());
                 gbiZbsyrecAllEntity.setDjflmx(Integer.valueOf(oerDjmlAllEntities.get(0).getMlId()));
                 gbiZbsyrecAllEntity.setModule("'OER'");
-
                 gbiZbsyrecAllEntity.setDjzt("0");
+                gbiZbsyrecAllEntity.setDataSourceCode(dataSourceCode);
                 iOerDjmlDao.updateGbiZbsyrecByDjid(gbiZbsyrecAllEntity);
             }else {
                 return BaseResult.getFailureMessageEntity("根据单据编号存在多条报销单");
             }
         }else if(ColEventTypeEnum.ONPROCESSFINISHED.getType().equals(entity.getLclb())){//流程结束
             OerDjmlEntity oerDjmlAllEntity = new OerDjmlEntity();
+            oerDjmlAllEntity.setDataSourceCode(dataSourceCode);
             oerDjmlAllEntity.setDjbh(entity.getDjbh());
             List<OerDjmlEntity> oerDjmlAllEntities = iOerDjmlDao.queryOerDjml(oerDjmlAllEntity);
             if(oerDjmlAllEntities != null && oerDjmlAllEntities.size() == 1){
@@ -795,8 +802,7 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
         }else {
             return BaseResult.getFailureMessageEntity("流程类别错误");
         }
-
+        return BaseResult.getSuccessMessageEntity("处理成功");
-        return null;
     }
 
     /**
@@ -971,7 +977,7 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
      * @param entity
      * @return java.lang.Object
      **/
-    private Object saveOrUpdateData(OerDjmlEntity entity) {
+    private Object saveOrUpdateData(String dataSourceCode,OerDjmlEntity entity) {
         //获取主表数据
         logger.info("开始处理数据:------>");
         String gsdm = entity.getGsdm();
@@ -993,6 +999,7 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
         String maxMlId = null;
         if(entity.getDjbh() != null && !"".equals(entity.getDjbh())){
             OerDjmlEntity oerDjmlAllEntity = new OerDjmlEntity();
+            oerDjmlAllEntity.setDataSourceCode(dataSourceCode);
             oerDjmlAllEntity.setDjbh(entity.getDjbh());
             List<OerDjmlEntity> oerDjmlAllEntities = iOerDjmlDao.queryOerDjml(oerDjmlAllEntity);
             if(oerDjmlAllEntities != null && oerDjmlAllEntities.size() == 1){
@@ -1003,12 +1010,14 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
         }
 
         if(!flag){
-            logger.info("获取最大单据编号");
+            //logger.info("获取最大单据编号");
             OerDjmlEntity oerDjmlEntity = new OerDjmlEntity();
+            oerDjmlEntity.setDataSourceCode(dataSourceCode);
             oerDjmlEntity.setGsdm(gsdm);
             oerDjmlEntity.setDjdate(entity.getDjdate());
             oerDjmlEntity.setFph(nullConvert(entity.getFph()));
-            maxDjbh = iOerDjmlDao.getMaxDjbgByGsdm(oerDjmlEntity);
+            //maxDjbh = iOerDjmlDao.getMaxDjbgByGsdm(oerDjmlEntity);
+            maxDjbh = entity.getDjbh();
             logger.info("获取到最大单据编号:------>"+maxDjbh);
             //查询最大单据ID mlid
             maxMlId = iOerDjmlDao.getMaxMlIdByGsdm(oerDjmlEntity);
@@ -1019,66 +1028,76 @@ public class OerDjmlServiceImpl implements IOerDjmlService {
         OerDjmlEntity oerdjml = setMainData(entity,maxDjbh,maxMlId);
         logger.info("保存主表信息:------>");
         if(flag){
-            iOerDjmlDao.update("OerDjmlEntity_update_data",oerdjml);
+            oerdjml.setDataSourceCode(dataSourceCode);
+            iOerDjmlDao.updateData(oerdjml);
             //删除明细
             OerDjnrEntity oerDjnrEntity = new OerDjnrEntity();
             oerDjnrEntity.setMlId(maxMlId);
             oerDjnrEntity.setGsdm(entity.getGsdm());
             oerDjnrEntity.setKjnd(entity.getKjnd());
             oerDjnrEntity.setDjlxId(entity.getDjlxId());
-            iOerDjnrDao.delete("OerDjnrEntity_delete",oerDjnrEntity);
+            oerDjnrEntity.setDataSourceCode(dataSourceCode);
+            iOerDjnrDao.deleteData(oerDjnrEntity);
             //删除预算指标
             OerYszbEntity oerYszbEntity = new OerYszbEntity();
             oerYszbEntity.setGsdm(entity.getGsdm());
             oerYszbEntity.setKjnd(entity.getKjnd());
             oerYszbEntity.setMlId(maxMlId);
-            iOerYszbDao.delete("OerYszbEntity_delete",oerYszbEntity);
+            oerYszbEntity.setDataSourceCode(dataSourceCode);
-
+            iOerYszbDao.deleteData(oerYszbEntity);
             //删除预算指标记录
             GbiZbsyrecEntity oeryszb= new GbiZbsyrecEntity();
             oeryszb.setGsdm(entity.getGsdm());
             oeryszb.setKjnd(entity.getKjnd());
             oeryszb.setDjId(maxMlId);
-            iGbiZbsyrecDao.delete("GbiZbsyrecEntity_delete_mlid",oeryszb);
+            oeryszb.setDataSourceCode(dataSourceCode);
+            iGbiZbsyrecDao.deleteData(oeryszb);
             //删除单据结算方式
             OerDjjsfsEntity oerDjjsfsEntity = new OerDjjsfsEntity();
             oerDjjsfsEntity.setMlId(maxMlId);
             oerDjjsfsEntity.setGsdm(entity.getGsdm());
-            iOerDjjsfsDao.delete("OerDjjsfsEntity_delete_delMlid",oerDjjsfsEntity);
+            oerDjjsfsEntity.setDataSourceCode(dataSourceCode);
+            iOerDjjsfsDao.deleteData(oerDjjsfsEntity);
             //删除日志
             //删除节点
         }else {
-            iOerDjmlDao.save("OerDjmlEntity_insert",oerdjml);
+            oerdjml.setDataSourceCode(dataSourceCode);
+            iOerDjmlDao.saveData(oerdjml);
         }
 
         logger.info("组装单据报销明细开始:------>");
         List<OerDjnrEntity> oerDjnrEntityList = setOerDjnrEntity(entity,maxDjbh,maxMlId);
         logger.info("保存报销明细开始:------>");
         for(OerDjnrEntity djnrEntity : oerDjnrEntityList){
-            iOerDjnrDao.save("OerDjnrEntity_insert",djnrEntity);
+            djnrEntity.setDataSourceCode(dataSourceCode);
+            iOerDjnrDao.saveData(djnrEntity);
             logger.info("保存完报销明细后，根据明细数据生成预算指标数据:------>");
             OerYszbEntity yszbEntity = createOerYszbEntity(djnrEntity,maxMlId);
             logger.info("保存预算指标开始:------>");
-            iOerYszbDao.save("OerYszbEntity_insert",yszbEntity);
+            yszbEntity.setDataSourceCode(dataSourceCode);
+            iOerYszbDao.saveData(yszbEntity);
             logger.info("保存预算指标记录:------>");
             GbiZbsyrecEntity oeryszb= setOerYszbEntity(entity,djnrEntity);
-            iGbiZbsyrecDao.save("GbiZbsyrecEntity_insert",oeryszb);
+            oeryszb.setDataSourceCode(dataSourceCode);
+            iGbiZbsyrecDao.saveData(oeryszb);
         }
         logger.info("组装单据结算方式明细开始:------>");
         List<OerDjjsfsEntity> oerDjjsfsEntityList = setOerDjjsfsEntityList(entity,maxDjbh,maxMlId);
         logger.info("保存结算方式明细开始:------>");
         for(OerDjjsfsEntity oerdjjsfs :oerDjjsfsEntityList){
-            iOerDjjsfsDao.save("OerDjjsfsEntity_insert",oerdjjsfs);
+            oerdjjsfs.setDataSourceCode(dataSourceCode);
+            iOerDjjsfsDao.saveData(oerdjjsfs);
         }
         //保存日志表PubAuditLog
         List<PubAuditLogEntity> pubAuditLogEntityList = setPubAuditLog(entity, maxMlId);
         for (PubAuditLogEntity pubAuditLog : pubAuditLogEntityList) {
-            iPubAuditLogDao.save("PubAuditLogEntity_insert",pubAuditLog);
+            pubAuditLog.setDataSourceCode(dataSourceCode);
+            iPubAuditLogDao.saveData(pubAuditLog);
         }
         //保存节点PUB_OBJ_FLOW
         PubObjFlowEntity pubObjFlowEntity = setPubObjFlow(entity, maxMlId);
-        iPubObjFlowDao.save("PubObjFlowEntity_insert",pubObjFlowEntity);
+        pubObjFlowEntity.setDataSourceCode(dataSourceCode);
-
+        iPubObjFlowDao.saveData(pubObjFlowEntity);
         return BaseResult.getSuccessMessageEntity("保存报销单成功");
     }
 

service/src/main/java/com/hzya/frame/grpU8/nxproof/oerdjnr/dao/IOerDjnrDao.java

@@ -12,4 +12,7 @@ import com.hzya.frame.grpU8.nxproof.oerdjnr.entity.OerDjnrEntity;
  * @Date: 2023/6/19 14:57
  */
 public interface IOerDjnrDao extends IBaseDao<OerDjnrEntity,String> {
+    Integer deleteData(OerDjnrEntity oerDjnrEntity);
+
+    Integer saveData(OerDjnrEntity djnrEntity);
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/oerdjnr/dao/impl/OerDjnrDaoImpl.java

@@ -1,5 +1,6 @@
 package com.hzya.frame.grpU8.nxproof.oerdjnr.dao.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.grpU8.nxproof.oerdjnr.dao.IOerDjnrDao;
 import com.hzya.frame.grpU8.nxproof.oerdjnr.entity.OerDjnrEntity;
@@ -14,4 +15,17 @@ import org.springframework.stereotype.Repository;
  */
 @Repository(value = "oerDjnrDao")
 public class OerDjnrDaoImpl extends MybatisGenericDao<OerDjnrEntity,String> implements IOerDjnrDao {
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer deleteData(OerDjnrEntity entity) {
+        Integer o = super.delete(getSqlIdPrifx() + "OerDjnrEntity_delete", entity);
+        return o;
+    }
+
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer saveData(OerDjnrEntity entity) {
+        Integer o = super.insert(getSqlIdPrifx() + "OerDjnrEntity_insert", entity);
+        return o;
+    }
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/oeryszb/dao/IOerYszbDao.java

@@ -11,4 +11,7 @@ import com.hzya.frame.grpU8.nxproof.oeryszb.entity.OerYszbEntity;
  * @Date: 2023/6/19 14:59
  */
 public interface IOerYszbDao extends IBaseDao<OerYszbEntity,String> {
+    Integer deleteData(OerYszbEntity oerYszbEntity);
+
+    Integer saveData(OerYszbEntity yszbEntity);
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/oeryszb/dao/impl/OerYszbDaoImpl.java

@@ -1,6 +1,7 @@
 package com.hzya.frame.grpU8.nxproof.oeryszb.dao.impl;
 
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.grpU8.nxproof.oeryszb.dao.IOerYszbDao;
 import com.hzya.frame.grpU8.nxproof.oeryszb.entity.OerYszbEntity;
@@ -15,4 +16,17 @@ import org.springframework.stereotype.Repository;
  */
 @Repository(value = "oerYszbDao")
 public class OerYszbDaoImpl extends MybatisGenericDao<OerYszbEntity,String> implements IOerYszbDao {
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer deleteData(OerYszbEntity entity) {
+        Integer o = super.delete(getSqlIdPrifx() + "OerYszbEntity_delete", entity);
+        return o;
+    }
+
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer saveData(OerYszbEntity entity) {
+        Integer o = super.insert(getSqlIdPrifx() + "OerYszbEntity_insert", entity);
+        return o;
+    }
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/pubauditlog/dao/IPubAuditLogDao.java

@@ -11,4 +11,5 @@ import com.hzya.frame.grpU8.nxproof.pubauditlog.entity.PubAuditLogEntity;
  * @Date: 2023/6/19 14:59
  */
 public interface IPubAuditLogDao extends IBaseDao<PubAuditLogEntity,String> {
+    Integer saveData(PubAuditLogEntity pubAuditLog);
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/pubauditlog/dao/impl/PubAuditLogDaoImpl.java

@@ -1,6 +1,7 @@
 package com.hzya.frame.grpU8.nxproof.pubauditlog.dao.impl;
 
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.grpU8.nxproof.pubauditlog.dao.IPubAuditLogDao;
 import com.hzya.frame.grpU8.nxproof.pubauditlog.entity.PubAuditLogEntity;
@@ -15,4 +16,10 @@ import org.springframework.stereotype.Repository;
  */
 @Repository(value = "pubAuditLogDao")
 public class PubAuditLogDaoImpl extends MybatisGenericDao<PubAuditLogEntity,String> implements IPubAuditLogDao {
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer saveData(PubAuditLogEntity entity) {
+        Integer o = super.insert(getSqlIdPrifx() + "PubAuditLogEntity_insert", entity);
+        return o;
+    }
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/pubobjflow/dao/IPubObjFlowDao.java

@@ -12,4 +12,5 @@ import com.hzya.frame.grpU8.nxproof.pubobjflow.entity.PubObjFlowEntity;
  * @Date: 2023/6/19 14:59
  */
 public interface IPubObjFlowDao extends IBaseDao<PubObjFlowEntity,String> {
+    Integer saveData(PubObjFlowEntity pubObjFlowEntity);
 }

service/src/main/java/com/hzya/frame/grpU8/nxproof/pubobjflow/dao/impl/PubObjFlowDaoImpl.java

@@ -1,6 +1,7 @@
 package com.hzya.frame.grpU8.nxproof.pubobjflow.dao.impl;
 
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.grpU8.nxproof.pubobjflow.dao.IPubObjFlowDao;
 import com.hzya.frame.grpU8.nxproof.pubobjflow.entity.PubObjFlowEntity;
@@ -15,4 +16,10 @@ import org.springframework.stereotype.Repository;
  */
 @Repository(value = "pubObjFlowDao")
 public class PubObjFlowDaoImpl extends MybatisGenericDao<PubObjFlowEntity,String> implements IPubObjFlowDao {
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer saveData(PubObjFlowEntity entity) {
+        Integer o = super.insert(getSqlIdPrifx() + "PubObjFlowEntity_insert", entity);
+        return o;
+    }
 }