vincent
4 days ago
10 changed files with 180 additions and 154 deletions
@ -1,46 +1,18 @@ |
|||
CREATE TABLE `SZSFJ_ZFJDM_XZJC_INFO` ( |
|||
`ID` bigint NOT NULL AUTO_INCREMENT COMMENT '主键，自增ID', |
|||
`YWID` varchar(64) NOT NULL COMMENT '业务ID', |
|||
`BJQYMC` varchar(128) DEFAULT NULL COMMENT '被检查企业名称', |
|||
`BJQYTYSHXYDM` varchar(32) 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补录', |
|||
`QTYYXXQ` 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 '其他行政执法证号', |
|||
`ZFDWMC` varchar(64) DEFAULT NULL COMMENT '执法单位名称', |
|||
`ZFBMMC` varchar(64) DEFAULT NULL COMMENT '执法部门名称', |
|||
`YWCJSJ` datetime DEFAULT NULL COMMENT '业务创建时间', |
|||
`YWXGSJ` datetime DEFAULT NULL COMMENT '业务修改时间', |
|||
`CJSJ` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', |
|||
`XGSJ` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', |
|||
PRIMARY KEY (`ID`), |
|||
UNIQUE KEY `uk_ywid` (`YWID`), |
|||
KEY `idx_bjqy_credit` (`BJQYTYSHXYDM`), |
|||
KEY `idx_rqsj` (`RQSJ`) |
|||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='行政检查信息表'; |
|||
|
|||
-- 定时任务:每天凌晨2点同步 enforcement_registration 增量数据到 SZSFJ_ZFJDM_XZJC_INFO |
|||
INSERT INTO sys_job (job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, status, create_by, |
|||
create_time, remark) |
|||
VALUES ('行政检查信息增量同步', |
|||
INSERT INTO sys_job (job_name, job_group, invoke_target, cron_expression, |
|||
misfire_policy, concurrent, status, create_by, create_time, remark) |
|||
VALUES ('省数据编目-行政检查信息同步到前置库', |
|||
'DEFAULT', |
|||
'xzjcInfoSyncJob.execute()', |
|||
'0 0 2 * * ?', |
|||
'3', |
|||
'1', |
|||
'0', |
|||
'admin', |
|||
NOW(), |
|||
'3', -- misfire: 放弃错过的执行 |
|||
'1', -- concurrent: 禁止并发 |
|||
'0', -- status: 正常 |
|||
'admin', NOW(), |
|||
'每天凌晨2点将enforcement_registration增量数据同步到SZSFJ_ZFJDM_XZJC_INFO表(市司法局数据共享)'); |
|||
|
|||
ALTER TABLE enforcement_registration |
|||
MODIFY COLUMN update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间'; |
|||
|
|||
|
|||
update enforcement_registration set update_time = create_time where update_time is null; |
|||
|
|||
@ -0,0 +1,34 @@ |
|||
DROP TABLE IF EXISTS `SZSFJ_ZFJDM_XZJC_INFO`; |
|||
CREATE TABLE `SZSFJ_ZFJDM_XZJC_INFO` ( |
|||
`ID` bigint NOT NULL AUTO_INCREMENT COMMENT '主键，自增ID', |
|||
`YWID` varchar(64) NOT NULL COMMENT '业务ID', |
|||
`BJQYMC` varchar(128) DEFAULT NULL COMMENT '被检查企业名称', |
|||
`BJQYTYSHXYDM` varchar(32) 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补录', |
|||
`QTYYXXQ` 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 '其他行政执法证号', |
|||
`ZFDWMC` varchar(64) DEFAULT NULL COMMENT '执法单位名称', |
|||
`ZFBMMC` varchar(64) DEFAULT NULL COMMENT '执法部门名称', |
|||
`YWCJSJ` datetime DEFAULT NULL COMMENT '业务创建时间', |
|||
`YWXGSJ` datetime DEFAULT NULL COMMENT '业务修改时间', |
|||
`CJSJ` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', |
|||
`XGSJ` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', |
|||
`ZLBS` varchar(2) DEFAULT '0' COMMENT '增量标识，0|未同步，1|已同步', |
|||
PRIMARY KEY (`ID`), |
|||
UNIQUE KEY `uk_ywid` (`YWID`), |
|||
KEY `idx_bjqy_credit` (`BJQYTYSHXYDM`), |
|||
KEY `idx_rqsj` (`RQSJ`) |
|||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='行政检查信息表'; |
|||
@ -0,0 +1,34 @@ |
|||
package com.zdxt.enforcementcode.mapper; |
|||
|
|||
import com.baomidou.dynamic.datasource.annotation.DS; |
|||
import com.zdxt.enforcementcode.domain.bo.XzjcInfoSyncBo; |
|||
import org.apache.ibatis.annotations.Param; |
|||
|
|||
import java.util.Date; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* 行政检查信息同步 Mapper 接口(zfjd_tgk 推管库) |
|||
* <p>增量同步 enforcement_registration -> zfjd_tgk.SZSFJ_ZFJDM_XZJC_INFO(市司法局数据共享表)</p> |
|||
* <p>仅承载目标表操作(水位查询/批量写入);源表分页读取见 {@link XzjcInfoSyncMapper}</p> |
|||
* |
|||
* @author zdxt |
|||
*/ |
|||
@DS("tgk") |
|||
public interface XzjcInfoSyncTgkMapper { |
|||
|
|||
/** |
|||
* 查询增量水位:目标表已同步数据的最大业务修改时间(MAX(YWXGSJ)) |
|||
* |
|||
* @return 水位时间;目标表为空时返回 null |
|||
*/ |
|||
Date selectWatermark(); |
|||
|
|||
/** |
|||
* 批量 upsert 目标表(基于 uk_ywid 唯一键 INSERT ... ON DUPLICATE KEY UPDATE,幂等) |
|||
* |
|||
* @param list 写入行集合 |
|||
* @return 影响行数(MySQL upsert 语义,不代表真实写入条数) |
|||
*/ |
|||
int upsertBatch(@Param("list") List<XzjcInfoSyncBo> list); |
|||
} |
|||
@ -0,0 +1,53 @@ |
|||
<?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.zdxt.enforcementcode.mapper.XzjcInfoSyncTgkMapper"> |
|||
|
|||
<!-- 增量水位:目标表已同步数据的最大业务修改时间;表为空时返回 NULL --> |
|||
<select id="selectWatermark" resultType="java.util.Date"> |
|||
SELECT MAX(YWXGSJ) |
|||
FROM SZSFJ_ZFJDM_XZJC_INFO |
|||
</select> |
|||
|
|||
<!-- 批量 upsert(uk_ywid 冲突时更新);注:affected 返回值(插入 1/更新 2)不代表真实行数 --> |
|||
<!-- ZLBS 增量标识:每次写入(插入/更新)均置 '0'-未同步,由推管方拉取后置 1 --> |
|||
<insert id="upsertBatch"> |
|||
INSERT INTO SZSFJ_ZFJDM_XZJC_INFO |
|||
(YWID, BJQYMC, BJQYTYSHXYDM, JCSX, RQSJ, ZFYJ, JCLB, JCYY, |
|||
SFLHJC, LHJCBH, SFWTJC, WTJCBMMC, SFSM, WSMYY, QTYYXXQ, |
|||
ZFRYXM, XZZFZH, QTZFRYXM, QTXZZFZH, ZFDWMC, ZFBMMC, YWCJSJ, YWXGSJ, ZLBS) |
|||
VALUES |
|||
<foreach collection="list" item="item" separator=","> |
|||
(#{item.ywid}, #{item.bjqymc}, #{item.bjqytyshxydm}, #{item.jcsx}, #{item.rqsj}, |
|||
#{item.zfyj}, #{item.jclb}, #{item.jcyy}, #{item.sflhjc}, #{item.lhjcbh}, |
|||
#{item.sfwtjc}, #{item.wtjcbmmc}, #{item.sfsm}, #{item.wsmyy}, #{item.qtyyxxq}, |
|||
#{item.zfryxm}, #{item.xzzfzh}, #{item.qtzfryxm}, #{item.qtxzzfzh}, |
|||
#{item.zfdwmc}, #{item.zfbmmc}, #{item.ywcjsj}, #{item.ywxgsj}, '0') |
|||
</foreach> |
|||
ON DUPLICATE KEY UPDATE |
|||
BJQYMC = VALUES(BJQYMC), |
|||
BJQYTYSHXYDM = VALUES(BJQYTYSHXYDM), |
|||
JCSX = VALUES(JCSX), |
|||
RQSJ = VALUES(RQSJ), |
|||
ZFYJ = VALUES(ZFYJ), |
|||
JCLB = VALUES(JCLB), |
|||
JCYY = VALUES(JCYY), |
|||
SFLHJC = VALUES(SFLHJC), |
|||
LHJCBH = VALUES(LHJCBH), |
|||
SFWTJC = VALUES(SFWTJC), |
|||
WTJCBMMC = VALUES(WTJCBMMC), |
|||
SFSM = VALUES(SFSM), |
|||
WSMYY = VALUES(WSMYY), |
|||
QTYYXXQ = VALUES(QTYYXXQ), |
|||
ZFRYXM = VALUES(ZFRYXM), |
|||
XZZFZH = VALUES(XZZFZH), |
|||
QTZFRYXM = VALUES(QTZFRYXM), |
|||
QTXZZFZH = VALUES(QTXZZFZH), |
|||
ZFDWMC = VALUES(ZFDWMC), |
|||
ZFBMMC = VALUES(ZFBMMC), |
|||
YWCJSJ = VALUES(YWCJSJ), |
|||
YWXGSJ = VALUES(YWXGSJ), |
|||
ZLBS = '0' |
|||
</insert> |
|||
</mapper> |
|||
Loading…
Reference in new issue