Browse Source

优化了省数据编目

dev
vincent 10 hours ago
parent
commit
ead1c00002
  1. 8
      script/sql/vincent/V1.10.1-数据编目-达梦.sql
  2. 4
      script/sql/vincent/V1.10.1_20261013_tgk.sql
  3. 2
      zdxt-modules/zdxt-enforcement-code/src/main/java/com/zdxt/enforcementcode/service/impl/XzjcInfoShareServiceImpl.java
  4. 6
      zdxt-modules/zdxt-enforcement-code/src/main/resources/mapper/enforcementcode/XzjcInfoShareGxkMapper.xml

8
script/sql/vincent/V1.10.1-数据编目-达梦.sql

@ -1,4 +1,4 @@
CREATE TABLE SZ_SFJ_ZFJDM_XZJC_INFO ( CREATE TABLE SZ_SFJ_ZFJDM_XZZF_INFO (
ID BIGINT NOT NULL IDENTITY(1,1) COMMENT '主键,自增ID', ID BIGINT NOT NULL IDENTITY(1,1) COMMENT '主键,自增ID',
YWID VARCHAR(64) NOT NULL COMMENT '业务ID', YWID VARCHAR(64) NOT NULL COMMENT '业务ID',
BJQQYMC VARCHAR(128) DEFAULT NULL COMMENT '被检查企业名称', BJQQYMC VARCHAR(128) DEFAULT NULL COMMENT '被检查企业名称',
@ -36,7 +36,7 @@ CREATE TABLE SZ_SFJ_ZFJDM_XZJC_INFO (
) COMMENT='深圳市涉企行政执法扫码入企登记信息'; ) COMMENT='深圳市涉企行政执法扫码入企登记信息';
-- 索引 -- 索引
CREATE INDEX IDX_BJQY_CREDIT ON SZ_SFJ_ZFJDM_XZJC_INFO(BJQQYTYSHXYDM); CREATE INDEX IDX_BJQY_CREDIT ON SZ_SFJ_ZFJDM_XZZF_INFO(BJQQYTYSHXYDM);
CREATE INDEX IDX_RQSJ ON SZ_SFJ_ZFJDM_XZJC_INFO(RQSJ); CREATE INDEX IDX_RQSJ ON SZ_SFJ_ZFJDM_XZZF_INFO(RQSJ);
-- YWID 唯一:同一业务ID只保留一行(先查后写的防重兜底) -- YWID 唯一:同一业务ID只保留一行(先查后写的防重兜底)
CREATE UNIQUE INDEX UK_YWID ON SZ_SFJ_ZFJDM_XZJC_INFO(YWID); CREATE UNIQUE INDEX UK_YWID ON SZ_SFJ_ZFJDM_XZZF_INFO(YWID);

4
script/sql/vincent/V1.10.1_20261013_tgk.sql

@ -58,9 +58,9 @@ VALUES ('省数据编码-行政执法扫码入企登记信息共享(局)',
DROP TABLE IF EXISTS `SZ_SFJ_ZFJDM_XZJC_INFO`; DROP TABLE IF EXISTS `SZ_SFJ_ZFJDM_XZZF_INFO`;
CREATE TABLE `SZ_SFJ_ZFJDM_XZJC_INFO` ( CREATE TABLE `SZ_SFJ_ZFJDM_XZZF_INFO` (
`ID` bigint NOT NULL AUTO_INCREMENT COMMENT '主键,自增ID', `ID` bigint NOT NULL AUTO_INCREMENT COMMENT '主键,自增ID',
`YWID` varchar(64) NOT NULL COMMENT '业务ID', `YWID` varchar(64) NOT NULL COMMENT '业务ID',
`BJQQYMC` varchar(128) DEFAULT NULL COMMENT '被检查企业名称', `BJQQYMC` varchar(128) DEFAULT NULL COMMENT '被检查企业名称',

2
zdxt-modules/zdxt-enforcement-code/src/main/java/com/zdxt/enforcementcode/service/impl/XzjcInfoShareServiceImpl.java

@ -18,7 +18,7 @@ import java.util.concurrent.TimeUnit;
/** /**
* 行政检查信息共享同步服务实现 * 行政检查信息共享同步服务实现
* <p>源表:zfjd_tgk.SZSFJ_ZFJDM_XZJC_INFO(TBZT='0');目标表:zfjd_gxk.SZ_SFJ_ZFJDM_XZJC_INFO</p> * <p>源表:zfjd_tgk.SZSFJ_ZFJDM_XZJC_INFO(TBZT='0');目标表:zfjd_gxk.SZ_SFJ_ZFJDM_XZZF_INFO</p>
* <p>写入成功的行回写源表 TBZT='1';单行失败跳过不标记,下次任务重试</p> * <p>写入成功的行回写源表 TBZT='1';单行失败跳过不标记,下次任务重试</p>
* *
* @author zdxt * @author zdxt

6
zdxt-modules/zdxt-enforcement-code/src/main/resources/mapper/enforcementcode/XzjcInfoShareGxkMapper.xml

@ -7,7 +7,7 @@
<!-- 已存在业务ID查询:I/U 判定依据 --> <!-- 已存在业务ID查询:I/U 判定依据 -->
<select id="selectExistingYwids" resultType="java.lang.String"> <select id="selectExistingYwids" resultType="java.lang.String">
SELECT YWID SELECT YWID
FROM SZ_SFJ_ZFJDM_XZJC_INFO FROM SZ_SFJ_ZFJDM_XZZF_INFO
WHERE YWID IN WHERE YWID IN
<foreach collection="list" item="id" open="(" separator="," close=")"> <foreach collection="list" item="id" open="(" separator="," close=")">
#{id} #{id}
@ -16,7 +16,7 @@
<!-- 插入新行(不存在该 YWID -> I);ADD_TIME 由数据库默认值维护 --> <!-- 插入新行(不存在该 YWID -> I);ADD_TIME 由数据库默认值维护 -->
<insert id="insertOne"> <insert id="insertOne">
INSERT INTO SZ_SFJ_ZFJDM_XZJC_INFO INSERT INTO SZ_SFJ_ZFJDM_XZZF_INFO
(YWID, BJQQYMC, BJQQYTYSHXYDM, SSQYBM, SSQYMC, JCSX, RQSJ, ZFYJ, JCLB, JCYY, (YWID, BJQQYMC, BJQQYTYSHXYDM, SSQYBM, SSQYMC, JCSX, RQSJ, ZFYJ, JCLB, JCYY,
SFLHJC, LHJCBH, SFWTJC, WTJCBMMC, SFSM, WSMYY, QTYXXQ, SFLHJC, LHJCBH, SFWTJC, WTJCBMMC, SFSM, WSMYY, QTYXXQ,
ZFRYXM, XZZFZH, QTZFRYXM, QTXZZFZH, ZFDWID, ZFDWMC, ZFBMMC, SFSC, YWCJSJ, YWXGSJ, ZFRYXM, XZZFZH, QTZFRYXM, QTXZZFZH, ZFDWID, ZFDWMC, ZFBMMC, SFSC, YWCJSJ, YWXGSJ,
@ -32,7 +32,7 @@
<!-- 按业务ID更新已存在行(存在该 YWID -> U);CD_BATCH/CD_OPERATION 刷新为最新批次通知再次拉取 --> <!-- 按业务ID更新已存在行(存在该 YWID -> U);CD_BATCH/CD_OPERATION 刷新为最新批次通知再次拉取 -->
<update id="updateByYwid"> <update id="updateByYwid">
UPDATE SZ_SFJ_ZFJDM_XZJC_INFO UPDATE SZ_SFJ_ZFJDM_XZZF_INFO
SET BJQQYMC = #{item.bjqqymc}, SET BJQQYMC = #{item.bjqqymc},
BJQQYTYSHXYDM = #{item.bjqqytyshxydm}, BJQQYTYSHXYDM = #{item.bjqqytyshxydm},
SSQYBM = #{item.ssqybm}, SSQYBM = #{item.ssqybm},

Loading…
Cancel
Save