zhuibobo
/
EnforcementCode-2.0
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

优化了省数据编目

dev
vincent 18 hours ago
parent
446fbf4eaf
commit
61c7f7b4b2
6 changed files with 100 additions and 54 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 127
      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/quartz/job/XzjcInfoShareJob.java
  4. 2
      zdxt-modules/zdxt-enforcement-code/src/main/java/com/zdxt/enforcementcode/service/impl/XzjcInfoShareServiceImpl.java
  5. 6
      zdxt-modules/zdxt-enforcement-code/src/main/resources/mapper/enforcementcode/XzjcInfoShareGxkMapper.xml
  6. 13
      zdxt-web-server/zdxt-admin-web-server/src/main/resources/application-prod.yml

127
script/sql/vincent/V1.10.1-数据编目-达梦.sql
View File

@ -1,42 +1,87 @@
CREATE TABLE SZ_SFJ_ZFJDM_XZZF_INFO (
ID BIGINT NOT NULL IDENTITY(1,1) COMMENT '主键，自增ID',
YWID VARCHAR(64) NOT NULL COMMENT '业务ID',
BJQQYMC VARCHAR(128) DEFAULT NULL COMMENT '被检查企业名称',
BJQQYTYSHXYDM VARCHAR(32) DEFAULT NULL COMMENT '被检查企业统一社会信用代码',
SSQYBM VARCHAR(64) DEFAULT NULL COMMENT '所属区域编码',
SSQYMC VARCHAR(64) DEFAULT NULL COMMENT '所属区域名称',
JCSX VARCHAR(512) DEFAULT NULL COMMENT '检查事项',
RQSJ DATETIME DEFAULT NULL COMMENT '入企时间',
ZFYJ VARCHAR(512) DEFAULT NULL COMMENT '执法依据',
JCLB VARCHAR(2) DEFAULT NULL COMMENT '检查类别：1行政检查|2行政处罚|3行政许可|4行政强制|5行政征收|6行政给付|7行政确认|8行政登记|9行政裁决|10文书送达',
JCYY VARCHAR(2) DEFAULT NULL COMMENT '检查原因：01日常检查|02投诉举报|03上级交办|04部门移送|05重点领域治理部署|06专项行动|09其它',
SFLHJC TINYINT DEFAULT NULL COMMENT '是否联合检查：0否，1是',
LHJCBH VARCHAR(50) DEFAULT NULL COMMENT '联合检查编号',
SFWTJC TINYINT DEFAULT NULL COMMENT '是否委托检查：0否，1是',
WTJCBMMC VARCHAR(128) DEFAULT NULL COMMENT '委托检查部门名称',
SFSM TINYINT DEFAULT NULL COMMENT '是否扫码：0是，1否',
WSMYY VARCHAR(256) DEFAULT NULL COMMENT '未扫码原因：0其他|1企业原因|2系统原因|3扫码未能显示企业信息|9补录',
QTYXXQ VARCHAR(512) DEFAULT NULL COMMENT '其他原因详情',
ZFRYXM VARCHAR(64) DEFAULT NULL COMMENT '执法人员姓名',
XZZFZH VARCHAR(64) DEFAULT NULL COMMENT '行政执法证号',
QTZFRYXM VARCHAR(64) DEFAULT NULL COMMENT '其他执法人员姓名',
QTXZZFZH VARCHAR(64) DEFAULT NULL COMMENT '其他行政执法证号',
ZFDWID VARCHAR(64) DEFAULT NULL COMMENT '执法单位ID',
ZFDWMC VARCHAR(64) DEFAULT NULL COMMENT '执法单位名称',
ZFBMMC VARCHAR(64) DEFAULT NULL COMMENT '执法部门名称',
SFSC TINYINT DEFAULT 0 COMMENT '是否删除：0否，1是',
YWCJSJ DATETIME DEFAULT NULL COMMENT '业务创建时间',
YWXGSJ DATETIME DEFAULT NULL COMMENT '业务修改时间',
ADD_TIME DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
CD_TIME DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
CD_OPERATION VARCHAR(4) DEFAULT NULL COMMENT '增量标识：I|插入，U|更新，D|删除',
CD_BATCH VARCHAR(32) DEFAULT NULL COMMENT '批次号',
REMARK VARCHAR(256) DEFAULT NULL COMMENT '备注',
PRIMARY KEY (ID)
) COMMENT='深圳市涉企行政执法扫码入企登记信息';
-- 索引
CREATE INDEX IDX_BJQY_CREDIT ON SZ_SFJ_ZFJDM_XZZF_INFO(BJQQYTYSHXYDM);
CREATE INDEX IDX_RQSJ ON SZ_SFJ_ZFJDM_XZZF_INFO(RQSJ);
-- YWID 唯一:同一业务ID只保留一行(先查后写的防重兜底)
CREATE UNIQUE INDEX UK_YWID ON SZ_SFJ_ZFJDM_XZZF_INFO(YWID);
CREATE TABLE SZSFJ_ZFJDM_XZZFSMRQDJXX (
ID BIGINT NOT NULL IDENTITY(1,1),
YWID VARCHAR(64) NOT NULL,
BJQQYMC VARCHAR(128) DEFAULT NULL,
BJQQYTYSHXYDM VARCHAR(32) DEFAULT NULL,
SSQYBM VARCHAR(64) DEFAULT NULL,
SSQYMC VARCHAR(64) DEFAULT NULL,
JCSX VARCHAR(512) DEFAULT NULL,
RQSJ DATETIME DEFAULT NULL,
ZFYJ VARCHAR(512) DEFAULT NULL,
JCLB VARCHAR(2) DEFAULT NULL,
JCYY VARCHAR(2) DEFAULT NULL,
SFLHJC TINYINT DEFAULT NULL,
LHJCBH VARCHAR(50) DEFAULT NULL,
SFWTJC TINYINT DEFAULT NULL,
WTJCBMMC VARCHAR(128) DEFAULT NULL,
SFSM TINYINT DEFAULT NULL,
WSMYY VARCHAR(256) DEFAULT NULL,
QTYXXQ VARCHAR(512) DEFAULT NULL,
ZFRYXM VARCHAR(64) DEFAULT NULL,
XZZFZH VARCHAR(64) DEFAULT NULL,
QTZFRYXM VARCHAR(64) DEFAULT NULL,
QTXZZFZH VARCHAR(64) DEFAULT NULL,
ZFDWID VARCHAR(64) DEFAULT NULL,
ZFDWMC VARCHAR(64) DEFAULT NULL,
ZFBMMC VARCHAR(64) DEFAULT NULL,
SFSC TINYINT DEFAULT 0,
YWCJSJ DATETIME DEFAULT NULL,
YWXGSJ DATETIME DEFAULT NULL,
ADD_TIME DATETIME DEFAULT CURRENT_TIMESTAMP,
CD_TIME DATETIME DEFAULT CURRENT_TIMESTAMP,
CD_OPERATION VARCHAR(4) DEFAULT NULL,
CD_BATCH VARCHAR(32) DEFAULT NULL,
REMARK VARCHAR(256) DEFAULT NULL,
PRIMARY KEY (ID),
CONSTRAINT UK_YWID UNIQUE (YWID)
);
-- 表注释(达梦不支持建表内联 COMMENT,必须单独声明)
COMMENT ON TABLE SZSFJ_ZFJDM_XZZFSMRQDJXX IS '深圳市涉企行政执法扫码入企登记信息';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.ID IS '主键，自增ID';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.YWID IS '业务ID';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.BJQQYMC IS '被检查企业名称';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.BJQQYTYSHXYDM IS '被检查企业统一社会信用代码';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.SSQYBM IS '所属区域编码';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.SSQYMC IS '所属区域名称';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.JCSX IS '检查事项';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.RQSJ IS '入企时间';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.ZFYJ IS '执法依据';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.JCLB IS '检查类别：1行政检查|2行政处罚|3行政许可|4行政强制|5行政征收|6行政给付|7行政确认|8行政登记|9行政裁决|10文书送达';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.JCYY IS '检查原因：01日常检查|02投诉举报|03上级交办|04部门移送|05重点领域治理部署|06专项行动|09其它';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.SFLHJC IS '是否联合检查：0否，1是';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.LHJCBH IS '联合检查编号';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.SFWTJC IS '是否委托检查：0否，1是';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.WTJCBMMC IS '委托检查部门名称';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.SFSM IS '是否扫码：0是，1否';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.WSMYY IS '未扫码原因：0其他|1企业原因|2系统原因|3扫码未能显示企业信息|9补录';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.QTYXXQ IS '其他原因详情';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.ZFRYXM IS '执法人员姓名';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.XZZFZH IS '行政执法证号';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.QTZFRYXM IS '其他执法人员姓名';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.QTXZZFZH IS '其他行政执法证号';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.ZFDWID IS '执法单位ID';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.ZFDWMC IS '执法单位名称';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.ZFBMMC IS '执法部门名称';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.SFSC IS '是否删除：0否，1是';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.YWCJSJ IS '业务创建时间';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.YWXGSJ IS '业务修改时间';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.ADD_TIME IS '创建时间';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.CD_TIME IS '修改时间';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.CD_OPERATION IS '增量标识：I|插入，U|更新，D|删除';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.CD_BATCH IS '批次号';
COMMENT ON COLUMN SZSFJ_ZFJDM_XZZFSMRQDJXX.REMARK IS '备注';
-- 普通索引(达梦不支持建表内联 KEY,需单独创建)
CREATE INDEX IDX_BJQY_CREDIT ON SZSFJ_ZFJDM_XZZFSMRQDJXX (BJQQYTYSHXYDM);
CREATE INDEX IDX_RQSJ ON SZSFJ_ZFJDM_XZZFSMRQDJXX (RQSJ);
-- 达梦不支持 ON UPDATE CURRENT_TIMESTAMP,用行级触发器实现 CD_TIME 自动更新
-- (Mapper 的 updateByYwid 已显式 SET CD_TIME = CURRENT_TIMESTAMP,此触发器为数据库层兜底)
CREATE OR REPLACE TRIGGER TRI_XZZF_INFO_CD_TIME
BEFORE UPDATE ON SZSFJ_ZFJDM_XZZFSMRQDJXX
FOR EACH ROW
BEGIN
:NEW.CD_TIME := CURRENT_TIMESTAMP;
END;

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

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

2
zdxt-modules/zdxt-enforcement-code/src/main/java/com/zdxt/enforcementcode/quartz/job/XzjcInfoShareJob.java
View File

@ -8,7 +8,7 @@ import org.springframework.stereotype.Component;
/**
* 共享库同步到提供库（局级）
* 行政检查信息共享同步定时任务
* <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.SZSFJ_ZFJDM_XZZFSMRQDJXX</p>
* <p>默认 cron: 0 30 2 * * ?(每天凌晨 2:30,晚于 2:00 的 tgk 写入任务)</p>
*
* @author zdxt

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

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

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

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

13
zdxt-web-server/zdxt-admin-web-server/src/main/resources/application-prod.yml
View File

@ -50,22 +50,23 @@ spring:
url: jdbc:mysql:loadbalance://10.134.89.36:15144,10.134.89.37:15144,10.134.89.38:15144,10.134.89.39:15144/zfjd_ef20_prod?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: zfjd
password: szsf@zfjd
# 推管库(行政检查信息同步目标库)
tgk:
# 一期数据库
v1:
lazy: true
type: ${spring.datasource.type}
driverClassName: com.mysql.cj.jdbc.Driver
url: jdbc:mysql:loadbalance://10.134.89.36:15144,10.134.89.37:15144,10.134.89.38:15144,10.134.89.39:15144/zfjd_tgk?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
url: jdbc:mysql:loadbalance://10.134.89.36:15144,10.134.89.37:15144,10.134.89.38:15144,10.134.89.39:15144/zfjd?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: zfjd
password: szsf@zfjd
v1:
# 提供库（内部）
tgk:
lazy: true
type: ${spring.datasource.type}
driverClassName: com.mysql.cj.jdbc.Driver
url: jdbc:mysql:loadbalance://10.134.89.36:15144,10.134.89.37:15144,10.134.89.38:15144,10.134.89.39:15144/zfjd?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
url: jdbc:mysql:loadbalance://10.134.89.36:15144,10.134.89.37:15144,10.134.89.38:15144,10.134.89.39:15144/zfjd_tgk?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: zfjd
password: szsf@zfjd
# 共享库(达梦,行政检查信息 tgk -> gxk 同步目标库)
# 省数据编目，同步到局数据库
gxk:
lazy: true
type: ${spring.datasource.type}

Write Preview
Loading…
Cancel
Save