清算新增表、mapper、bo、vo等

isc-common-core/src/main/java/com/brilliance/isc/bo/Crd.java

+package com.brilliance.isc.bo;
+
+import com.brilliance.isc.common.vo.AbstractCommonVo;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.Data;
+
+import java.util.Date;
+
+import static com.brilliance.mda.runtime.mda.Constants.NULLDATE;
+import static com.brilliance.mda.runtime.mda.Constants.NULLSTR;
+
+
+/**
+ * TABLE:crd:
+ */
+@Data
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class Crd extends AbstractCommonVo {
+
+
+    //Internal Unique ID of Import L/C (max = 8)
+    private String inr = NULLSTR;
+
+    //Reference (max = 16)
+    private String ownref = NULLSTR;
+
+    //Externally Displayed Name to Identify the Contract (max = 40)
+    private String nam = NULLSTR;
+
+    //Responsible User (max = 8)
+    private String ownusr = NULLSTR;
+
+    //Date of Creation Opening or Registry
+    @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
+    private Date credat = NULLDATE;
+
+    //Date L/C Opened/Issued
+    @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
+
+    private Date opndat = NULLDATE;
+
+    //Date L/C Closed
+    @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
+
+    private Date clsdat = NULLDATE;
+
+    //Object Type of Associated Contract Optional  (max =6)
+    private String rcvobjtyp = NULLSTR;
+
+    //Object INR of Associated Contract Optional (max =8)
+    private String rcvobjinr = NULLSTR;
+
+    //Clearing Type  (max =1)
+    private String clrtyp = NULLSTR;
+
+    //Transaction Type  (max =1)
+    private String trntyp = NULLSTR;
+
+    //Receiver BIC  (max =12)
+    private String rcvbic = NULLSTR;
+
+    //Message ReferenceTag21  (max =16)
+    private String msgref = NULLSTR;
+
+    //Account in MessageTag59  (max =21)
+    private String msgact = NULLSTR;
+
+    //Message Type  (max =3)
+    private String msgtyp = NULLSTR;
+
+    //Message InrSMH  (max =8)
+    private String msginr = NULLSTR;
+
+    //Bound Message Type  (max =8)
+    private String bndtyp = NULLSTR;
+
+    //Bound Message INRSMH   (max =8)
+    private String bndinr = NULLSTR;
+
+    //Status  (max =1)
+    private String sta = NULLSTR;
+
+    //Error Message  (max =40)
+    private String errmsg = NULLSTR;
+
+    //Customer Type  (max =1)
+    private String custyp = NULLSTR;
+
+    //BRANCHINR (max =8)
+    private String branchinr = NULLSTR;
+
+    //BRANCH CODE KEYINR  (max =8)
+    private String bchkeyinr = NULLSTR;
+
+    //Receiver Branch Inr  (max =8)
+    private String rcvbchinr = NULLSTR;
+
+    //Version Counter  (max =4)
+    private String ver = NULLSTR;
+
+    //Inr for SPT  (max =8)
+    private String sptinr = NULLSTR;
+
+    //Entity holding Contract   (max =8)
+    private String etyextkey = NULLSTR;
+
+
+}
\ No newline at end of file

isc-common-core/src/main/java/com/brilliance/isc/bo/Rou.java

+package com.brilliance.isc.bo;
+
+import com.brilliance.isc.common.vo.AbstractCommonVo;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.Data;
+
+import static com.brilliance.mda.runtime.mda.Constants.NULLSTR;
+
+
+/**
+ * TABLE:rou:ROU - Routing
+ */
+@Data
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class Rou extends AbstractCommonVo {
+
+    //Internal Unique ID of ROU Routing
+    private String inr = NULLSTR;
+
+    //Priority Detail Level
+    private int pri;
+
+    //Work Group (max=6)
+    private String usg = NULLSTR;
+
+    //Product Type (max=2)
+    private String bussec = NULLSTR;
+
+    //State Code (max=2)
+    private String stacod = NULLSTR;
+
+    //Country (max=2)
+    private String cty = NULLSTR;
+
+    //Currency  (max=3)
+    private String cur = NULLSTR;
+
+    //Entity owning routing entry  (max=8)
+    private String etyextkey = NULLSTR;
+
+    //Work Group  (max=6)
+    private String grp = NULLSTR;
+
+    //Branch Code  (max=6)
+    private String bchcod = NULLSTR;
+
+    //TRNGRP   (max=6)
+    private String trngrp = NULLSTR;
+
+
+}
\ No newline at end of file

isc-common-core/src/main/java/com/brilliance/isc/bo/model/Cracbs.java

+package com.brilliance.isc.bo.model;
+
+import com.brilliance.isc.bo.Cbb;
+import com.brilliance.isc.common.vo.AbstractCommonVo;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.Data;
+
+/**
+ * @program: isc-core
+ * @ClassName: Cracbs
+ * @description: 清算cbs模块
+ * @author: huangshunlin
+ * @create: 2024-10-16 20:41
+ */
+@Data
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class Cracbs extends AbstractCommonVo {
+
+    private Cbb max;
+
+    @Override
+    public void reset() {
+        super.reset();
+        if (max == null) {
+            max = new Cbb();
+        }
+        max.reset();
+    }
+
+}

isc-common-core/src/main/java/com/brilliance/isc/bo/model/Crdgrp.java

+package com.brilliance.isc.bo.model;
+
+import com.brilliance.isc.bo.Crd;
+import com.brilliance.isc.common.vo.AbstractCommonVo;
+import com.brilliance.isc.common.vo.PtsptaVo;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.Data;
+
+/**
+ * @program: isc-core
+ * @ClassName: Crdgrp
+ * @description: 清算grp模块
+ * @author: huangshunlin
+ * @create: 2024-10-16 20:38
+ */
+@Data
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class Crdgrp extends AbstractCommonVo {
+
+    private Crd rec;
+
+    private Cracbs cbs;
+
+    private PtsptaVo snd;
+
+    private PtsptaVo rcv;
+
+    private PtsptaVo trf;
+
+    private PtsptaVo apl;
+
+    private PtsptaVo acc;
+
+    @Override
+    public void reset() {
+        if (rec == null) {
+            rec = new Crd();
+        }
+
+        if (cbs == null) {
+            cbs = new Cracbs();
+        }
+        cbs.reset();
+
+        if (snd == null) {
+            snd = new PtsptaVo();
+        }
+        snd.reset();
+
+        if (rcv == null) {
+            rcv = new PtsptaVo();
+        }
+        rcv.reset();
+
+        if (trf == null) {
+            trf = new PtsptaVo();
+        }
+        trf.reset();
+
+        if (apl == null) {
+            apl = new PtsptaVo();
+        }
+        apl.reset();
+
+        if (acc == null) {
+            acc = new PtsptaVo();
+        }
+        acc.reset();
+
+    }
+}

isc-common-core/src/main/java/com/brilliance/isc/bo/model/Crtmod.java

+package com.brilliance.isc.bo.model;
+
+import com.brilliance.isc.bo.Spt;
+import com.brilliance.isc.common.vo.AbstractCommonVo;
+import com.brilliance.mda.runtime.mda.IStream;
+import com.brilliance.mda.runtime.mda.impl.StreamImpl;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.Data;
+
+import static com.brilliance.mda.runtime.mda.Constants.NULLSTR;
+
+/**
+ * @program: isc-core
+ * @ClassName: Crtmod
+ * @description: 清算crtmod
+ * @author: huangshunlin
+ * @create: 2024-10-17 18:24
+ */
+@Data
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class Crtmod extends AbstractCommonVo {
+    //Parameter Stream
+    private IStream parstm = new StreamImpl();
+    //Inr of SMH
+    private String smhinr = NULLSTR;
+
+    private Crdgrp crdgrp;
+
+//    private Sysobj crdobj;
+
+//    private Crdlod crdlod;
+
+    private Spt crtspt;
+
+    //    private Crtdoc crtdoc;
+    @Override
+    public void reset() {
+        if (crdgrp == null) {
+            crdgrp = new Crdgrp();
+        }
+        crdgrp.reset();
+
+        if (crtspt == null) {
+            crtspt = new Spt();
+        }
+    }
+}

isc-common-core/src/main/java/com/brilliance/isc/mda/dao/CrdMapper.java

+package com.brilliance.isc.mda.dao;
+
+import com.brilliance.isc.bo.Crd;
+import com.brilliance.isc.bo.Fxd;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface CrdMapper {
+
+    int insert(Crd record);
+
+    int insertSelective(Crd record);
+
+    int updateByPrimaryKeySelective(Crd record);
+
+    int updateByPrimaryKey(Crd record);
+
+    int deleteByPrimaryKey(Crd record);
+
+    int deleteByIds(Collection<Object> collection);
+
+    Crd selectByPrimaryKey(Crd record);
+
+    int dyncDelete(Map<String, Object> dyncMap);
+
+    int dyncUpdate(Map<String, Object> dyncMap);
+
+    List<Crd> dyncRead(Map<String, Object> dyncMap);
+
+    Crd selectByInr(@Param("inr") String inr);
+
+    Crd selectByOwnref(String ownref);
+}
\ No newline at end of file

isc-common-core/src/main/java/com/brilliance/isc/mda/dao/RouMapper.java

+package com.brilliance.isc.mda.dao;
+
+import com.brilliance.isc.bo.Rou;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface RouMapper {
+
+    int insert(Rou record);
+
+    int insertSelective(Rou record);
+
+    int updateByPrimaryKeySelective(Rou record);
+
+    int updateByPrimaryKey(Rou record);
+
+    int deleteByPrimaryKey(Rou record);
+
+    int deleteByIds(Collection<Object> collection);
+
+    Rou selectByPrimaryKey(Rou record);
+
+    int dyncDelete(Map<String, Object> dyncMap);
+
+    int dyncUpdate(Map<String, Object> dyncMap);
+
+    List<Rou> dyncRead(Map<String, Object> dyncMap);
+
+    Rou selectByBussec(@Param("bussec") String  bussec);
+
+}
\ No newline at end of file

isc-common-core/src/main/java/com/brilliance/isc/vo/funds/CrdBizAmdInfoVo.java

+package com.brilliance.isc.vo.funds;
+
+import com.brilliance.isc.common.vo.BizAmdInfoVo;
+import lombok.Data;
+
+/**
+ * @program: isc-core
+ * @ClassName: CrdBizAmdInfoVo
+ * @description: crd 修改业务数据
+ * @author: huangshunlin
+ * @create: 2024-10-17 20:40
+ */
+@Data
+public class CrdBizAmdInfoVo extends BizAmdInfoVo {
+}

isc-common-core/src/main/java/com/brilliance/isc/vo/funds/CrdBizInfoVo.java

+package com.brilliance.isc.vo.funds;
+
+import com.brilliance.isc.common.vo.BizInfoVo;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * @program: isc-core
+ * @ClassName: CrdBizInfoVo
+ * @description: crd业务数据
+ * @author: huangshunlin
+ * @create: 2024-10-17 20:34
+ */
+@Data
+public class CrdBizInfoVo extends BizInfoVo {
+
+    //crtp.forare
+    private String forare;
+    //crdgrp.rec.opndat
+    private Date opndat;
+
+    //crdgrp.rec.rcvbchinr
+    private String rcvbchinr;
+
+    //crdgrp.rec.custyp
+    private String custyp;
+
+    //rcvact.inr
+    private String rcvactInr;
+
+}

isc-common-core/src/main/resources/mapper/roumapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.brilliance.isc.mda.dao.RouMapper">
+
+    <resultMap id="BaseResultMap" type="com.brilliance.isc.bo.Rou">
+        <result property="inr" column="inr" jdbcType="VARCHAR"/>
+        <result property="pri" column="pri" jdbcType="INTEGER"/>
+        <result property="usg" column="usg" jdbcType="VARCHAR"/>
+        <result property="bussec" column="bussec" jdbcType="VARCHAR"/>
+        <result property="stacod" column="stacod" jdbcType="VARCHAR"/>
+        <result property="cty" column="cty" jdbcType="VARCHAR"/>
+        <result property="cur" column="cur" jdbcType="VARCHAR"/>
+        <result property="etyextkey" column="etyextkey" jdbcType="VARCHAR"/>
+        <result property="grp" column="grp" jdbcType="VARCHAR"/>
+        <result property="bchcod" column="bchcod" jdbcType="VARCHAR"/>
+        <result property="trngrp" column="trngrp" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        inr,pri,usg,bussec,stacod,cty,cur,etyextkey,grp,bchcod,trngrp
+    </sql>
+
+    <select id="selectByPrimaryKey" resultMap="BaseResultMap">
+        select
+            <include refid="Base_Column_List" />
+        from rou
+        where inr = #{inr,jdbcType=VARCHAR}
+    </select>
+
+    <delete id="deleteByPrimaryKey">
+        delete from rou
+        where inr = #{inr,jdbcType=VARCHAR}
+    </delete>
+
+    <insert id="insert">
+        insert into rou (<include refid="Base_Column_List" />)
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            #{inr,jdbcType=VARCHAR},
+            #{pri,jdbcType=INTEGER},
+            #{usg,jdbcType=VARCHAR},
+            #{bussec,jdbcType=VARCHAR},
+            #{stacod,jdbcType=VARCHAR},
+            #{cty,jdbcType=VARCHAR},
+            #{cur,jdbcType=VARCHAR},
+            #{etyextkey,jdbcType=VARCHAR},
+            #{grp,jdbcType=VARCHAR},
+            #{bchcod,jdbcType=VARCHAR},
+            #{trngrp,jdbcType=VARCHAR},
+        </trim>
+    </insert>
+
+    <insert id="insertSelective">
+        insert into rou
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="inr != null">inr,</if>
+            <if test="pri != null">pri,</if>
+            <if test="usg != null">usg,</if>
+            <if test="bussec != null">bussec,</if>
+            <if test="stacod != null">stacod,</if>
+            <if test="cty != null">cty,</if>
+            <if test="cur != null">cur,</if>
+            <if test="etyextkey != null">etyextkey,</if>
+            <if test="grp != null">grp,</if>
+            <if test="bchcod != null">bchcod,</if>
+            <if test="trngrp != null">trngrp,</if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="inr != null">#{inr,jdbcType=VARCHAR}, </if>
+            <if test="pri != null">#{pri,jdbcType=INTEGER}, </if>
+            <if test="usg != null">#{usg,jdbcType=VARCHAR}, </if>
+            <if test="bussec != null">#{bussec,jdbcType=VARCHAR}, </if>
+            <if test="stacod != null">#{stacod,jdbcType=VARCHAR}, </if>
+            <if test="cty != null">#{cty,jdbcType=VARCHAR}, </if>
+            <if test="cur != null">#{cur,jdbcType=VARCHAR}, </if>
+            <if test="etyextkey != null">#{etyextkey,jdbcType=VARCHAR}, </if>
+            <if test="grp != null">#{grp,jdbcType=VARCHAR}, </if>
+            <if test="bchcod != null">#{bchcod,jdbcType=VARCHAR}, </if>
+            <if test="trngrp != null">#{trngrp,jdbcType=VARCHAR}, </if>
+        </trim>
+    </insert>
+
+    <update id="updateByPrimaryKeySelective">
+        update rou
+        <set>
+            <if test="pri != null">pri = #{pri,jdbcType=INTEGER},</if>
+            <if test="usg != null">usg = #{usg,jdbcType=VARCHAR},</if>
+            <if test="bussec != null">bussec = #{bussec,jdbcType=VARCHAR},</if>
+            <if test="stacod != null">stacod = #{stacod,jdbcType=VARCHAR},</if>
+            <if test="cty != null">cty = #{cty,jdbcType=VARCHAR},</if>
+            <if test="cur != null">cur = #{cur,jdbcType=VARCHAR},</if>
+            <if test="etyextkey != null">etyextkey = #{etyextkey,jdbcType=VARCHAR},</if>
+            <if test="grp != null">grp = #{grp,jdbcType=VARCHAR},</if>
+            <if test="bchcod != null">bchcod = #{bchcod,jdbcType=VARCHAR},</if>
+            <if test="trngrp != null">trngrp = #{trngrp,jdbcType=VARCHAR},</if>
+        </set>
+        where inr = #{inr,jdbcType=VARCHAR}
+    </update>
+
+    <update id="updateByPrimaryKey">
+        update rou
+        <set>
+            pri = #{pri,jdbcType=INTEGER},
+            usg = #{usg,jdbcType=VARCHAR},
+            bussec = #{bussec,jdbcType=VARCHAR},
+            stacod = #{stacod,jdbcType=VARCHAR},
+            cty = #{cty,jdbcType=VARCHAR},
+            cur = #{cur,jdbcType=VARCHAR},
+            etyextkey = #{etyextkey,jdbcType=VARCHAR},
+            grp = #{grp,jdbcType=VARCHAR},
+            bchcod = #{bchcod,jdbcType=VARCHAR},
+            trngrp = #{trngrp,jdbcType=VARCHAR},
+        </set>
+        where inr = #{inr,jdbcType=VARCHAR}
+    </update>
+
+    <delete id="deleteByIds">
+        delete from act where inr in
+        <foreach item="item" index="index" collection="collection" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </delete>
+
+    <update id="dyncUpdate">
+        update rou
+        <set>
+            <if test="module.pri != null">pri = #{module.pri,jdbcType=INTEGER},</if>
+            <if test="module.usg != null">usg = #{module.usg,jdbcType=VARCHAR},</if>
+            <if test="module.bussec != null">bussec = #{module.bussec,jdbcType=VARCHAR},</if>
+            <if test="module.stacod != null">stacod = #{module.stacod,jdbcType=VARCHAR},</if>
+            <if test="module.cty != null">cty = #{module.cty,jdbcType=VARCHAR},</if>
+            <if test="module.cur != null">cur = #{module.cur,jdbcType=VARCHAR},</if>
+            <if test="module.etyextkey != null">etyextkey = #{module.etyextkey,jdbcType=VARCHAR},</if>
+            <if test="module.grp != null">grp = #{module.grp,jdbcType=VARCHAR},</if>
+            <if test="module.bchcod != null">bchcod = #{module.bchcod,jdbcType=VARCHAR},</if>
+            <if test="module.trngrp != null">trngrp = #{module.trngrp,jdbcType=VARCHAR},</if>
+        </set>
+        ${conditions}
+    </update>
+
+    <delete id="dyncDelete">
+        ${sql}
+    </delete>
+
+    <select id="dyncRead" resultMap="BaseResultMap">
+        ${sql}
+    </select>
+
+    <select id="selectByBussec" resultMap="BaseResultMap">
+        select
+        <include refid="Base_Column_List" />
+        from rou
+        where bussec = #{bussec}
+    </select>
+</mapper>
+
+

isc-common-service/src/main/java/com/brilliance/isc/common/sysmod/SysmodService.java

@@ -167,4 +167,5 @@ public interface SysmodService {
 
     String getClientPath(String objtyp, BizInfoVo bizInfoVo);
 
+    void getTrnUSG(Argument<String> grp);
 }

isc-common-service/src/main/java/com/brilliance/isc/common/sysmod/impl/SysmodServiceImpl.java

@@ -131,6 +131,9 @@ public class SysmodServiceImpl implements SysmodService {
     @Resource
     private OffcfgMapper offcfgMapper;
 
+    @Resource
+    private RouMapper rouMapper;
+
     public String internalSetObjNam(Object recObj, BaseTransactionVo baseTransactionVo) {
         String objTyp = Utils.recGetObj(recObj);
         String ref = Utils.getFieldValue(recObj, "ownref");
@@ -1820,4 +1823,33 @@ public class SysmodServiceImpl implements SysmodService {
         return path;
     }
 
+
+    /**
+     * source:sysmod.0289.script
+     */
+    public void getTrnUSG(Argument<String> grp) {
+        //--------根据ROU表的设置给SPT,TRN表中的OWNGRP组赋值-----
+        // sec = 业务类型
+        // BCHKEY = 业务经办行
+        // BRANCH = 业务所属行
+        // GRP = 业务分配的所属组
+        // USR = 业务分配的柜员
+        grp.value = "";
+        //清算交易没办法分组,CL和光票
+        String sec = NULLSTR;
+        String transName = SettleContext.getTransName();
+        if (MdaUtils.compareTo(transName, "CLIOPN") == 0 || MdaUtils.compareTo(transName, "CLOOPN") == 0
+                || MdaUtils.compareTo(transName, "CPTMAN") == 0 || MdaUtils.compareTo(transName, "CPTBCK") == 0) {
+            grp.value = "CL";
+        } else {
+            sec = Strings.mid(transName, 1, 2);
+            if (!MdaUtils.isEmpty(sec)) {
+                Rou rou = rouMapper.selectByBussec(sec);
+                if (Objects.nonNull(rou)) {
+                    grp.value = rou.getGrp();
+                }
+            }
+        }
+
+    }
 }