From 06d806d9c2c2b0c903b30b005ba0d74eaa389be0 Mon Sep 17 00:00:00 2001 From: yangjun <1173114630@qq.com> Date: Mon, 30 Oct 2023 22:51:58 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../SyncTdmjzgdqzt.java | 70 +++++++++++++++++++ .../kc/grab/exports/entity/Tdmjzgdqzt.java | 33 +++++++++ .../grab/exports/mapper/TdmjzgdqztMapper.java | 15 ++++ .../exports/mapper/xml/TdmjzgdqztMapper.xml | 5 ++ .../exports/service/ITdmjzgdqztService.java | 15 ++++ .../service/impl/TdmjzgdqztServiceImpl.java | 23 ++++++ .../kc/grab/imports/entity/Xxhbjzgdqzt.java | 44 ++++++++++++ .../imports/mapper/XxhbjzgdqztMapper.java | 15 ++++ .../imports/service/IXxhbxjzgdqztService.java | 32 +++++++++ .../service/impl/XxhbjzgdqztServiceImpl.java | 40 +++++++++++ 10 files changed, 292 insertions(+) create mode 100644 jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncTdmjzgdqzt.java create mode 100644 jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/entity/Tdmjzgdqzt.java create mode 100644 jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/mapper/TdmjzgdqztMapper.java create mode 100644 jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/mapper/xml/TdmjzgdqztMapper.xml create mode 100644 jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/service/ITdmjzgdqztService.java create mode 100644 jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/service/impl/TdmjzgdqztServiceImpl.java create mode 100644 jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/entity/Xxhbjzgdqzt.java create mode 100644 jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/mapper/XxhbjzgdqztMapper.java create mode 100644 jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/service/IXxhbxjzgdqztService.java create mode 100644 jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/service/impl/XxhbjzgdqztServiceImpl.java diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncTdmjzgdqzt.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncTdmjzgdqzt.java new file mode 100644 index 00000000..5e0324fd --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncTdmjzgdqzt.java @@ -0,0 +1,70 @@ +package org.jeecg.modules.kc.grab.SynchronizationService; + +import cn.hutool.core.bean.BeanUtil; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.compress.utils.Lists; +import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync; +import org.jeecg.modules.kc.grab.exports.entity.TBks; +import org.jeecg.modules.kc.grab.exports.entity.Tdmjzgdqzt; +import org.jeecg.modules.kc.grab.exports.service.ITBksService; +import org.jeecg.modules.kc.grab.exports.service.ITdmjzgdqztService; +import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks; +import org.jeecg.modules.kc.grab.imports.entity.Xxhbjzgdqzt; +import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog; +import org.jeecg.modules.kc.grab.imports.service.IXxhbbksService; +import org.jeecg.modules.kc.grab.imports.service.IXxhbxjzgdqztService; +import org.quartz.JobExecutionContext; +import org.springframework.beans.factory.annotation.Autowired; + +import java.util.List; +import java.util.Map; + +@Slf4j +public class SyncTdmjzgdqzt extends BaseSync { + + @Autowired + private ITdmjzgdqztService tdmjzgdqztService; + + @Autowired + private IXxhbxjzgdqztService xxhbxjzgdqztService; + + /** + * 若参数变量名修改 QuartzJobController中也需对应修改 + */ + + @Override + public void execute(JobExecutionContext jobExecutionContext) { + start(); + run(getParamMap()); + end(); + } + + + /** + * 有参定时任务实现 + * @param param + */ + public void run(Map param){ + //查询数据 + List inDataList = tdmjzgdqztService.list(); + List outDataList = Lists.newArrayList(); + + //清洗数据 + inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbjzgdqzt.class))); + + //保存到胃 + try { + xxhbxjzgdqztService.syncList(outDataList); + }catch (Exception e){ + e.printStackTrace(); + } + } + + /** + * 无参定时任务实现 + */ + public void run(){ + run(null); + } + +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/entity/Tdmjzgdqzt.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/entity/Tdmjzgdqzt.java new file mode 100644 index 00000000..41599fe9 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/entity/Tdmjzgdqzt.java @@ -0,0 +1,33 @@ +package org.jeecg.modules.kc.grab.exports.entity; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; +import org.jeecgframework.poi.excel.annotation.Excel; +import org.springframework.format.annotation.DateTimeFormat; + +/** + * @Description: T_BKS-抓取 + * @Author: jeecg-boot + * @Date: 2023-04-10 + * @Version: V1.0 + */ +@Data +@TableName("T_DM_JZGDQZT") +@EqualsAndHashCode(callSuper = false) +@Accessors(chain = true) +@ApiModel(value="T_DM_JZGDQZT对象", description="T_DM_JZGDQZT-抓取") +public class Tdmjzgdqzt { + + /**xh*/ + @ApiModelProperty(value = "dm") + private String dm; + /**xm*/ + @ApiModelProperty(value = "mc") + private String mc; + +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/mapper/TdmjzgdqztMapper.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/mapper/TdmjzgdqztMapper.java new file mode 100644 index 00000000..00c252a7 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/mapper/TdmjzgdqztMapper.java @@ -0,0 +1,15 @@ +package org.jeecg.modules.kc.grab.exports.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.jeecg.modules.kc.grab.exports.entity.TBks; +import org.jeecg.modules.kc.grab.exports.entity.Tdmjzgdqzt; + +/** + * @Description: T_BKS-抓取 + * @Author: jeecg-boot + * @Date: 2023-04-10 + * @Version: V1.0 + */ +public interface TdmjzgdqztMapper extends BaseMapper { + +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/mapper/xml/TdmjzgdqztMapper.xml b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/mapper/xml/TdmjzgdqztMapper.xml new file mode 100644 index 00000000..acb40f57 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/mapper/xml/TdmjzgdqztMapper.xml @@ -0,0 +1,5 @@ + + + + + \ No newline at end of file diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/service/ITdmjzgdqztService.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/service/ITdmjzgdqztService.java new file mode 100644 index 00000000..2d7ee624 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/service/ITdmjzgdqztService.java @@ -0,0 +1,15 @@ +package org.jeecg.modules.kc.grab.exports.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import org.jeecg.modules.kc.grab.exports.entity.TBks; +import org.jeecg.modules.kc.grab.exports.entity.Tdmjzgdqzt; + +/** + * @Description: T_BKS-抓取 + * @Author: jeecg-boot + * @Date: 2023-04-10 + * @Version: V1.0 + */ +public interface ITdmjzgdqztService extends IService { + +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/service/impl/TdmjzgdqztServiceImpl.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/service/impl/TdmjzgdqztServiceImpl.java new file mode 100644 index 00000000..baa51bb4 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/exports/service/impl/TdmjzgdqztServiceImpl.java @@ -0,0 +1,23 @@ +package org.jeecg.modules.kc.grab.exports.service.impl; + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.jeecg.modules.kc.grab.exports.entity.TBks; +import org.jeecg.modules.kc.grab.exports.entity.Tdmjzgdqzt; +import org.jeecg.modules.kc.grab.exports.mapper.TBksMapper; +import org.jeecg.modules.kc.grab.exports.mapper.TdmjzgdqztMapper; +import org.jeecg.modules.kc.grab.exports.service.ITBksService; +import org.jeecg.modules.kc.grab.exports.service.ITdmjzgdqztService; +import org.springframework.stereotype.Service; + +/** + * @Description: T_BKS-抓取 + * @Author: jeecg-boot + * @Date: 2023-04-10 + * @Version: V1.0 + */ +@DS("multi-oracle") +@Service +public class TdmjzgdqztServiceImpl extends ServiceImpl implements ITdmjzgdqztService { + +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/entity/Xxhbjzgdqzt.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/entity/Xxhbjzgdqzt.java new file mode 100644 index 00000000..d4b81d1e --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/entity/Xxhbjzgdqzt.java @@ -0,0 +1,44 @@ +package org.jeecg.modules.kc.grab.imports.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; +import org.jeecgframework.poi.excel.annotation.Excel; +import org.springframework.format.annotation.DateTimeFormat; + +import java.io.Serializable; + +/** + * @Description: 同步数据表（bks） + * @Author: jeecg-boot + * @Date: 2023-04-10 + * @Version: V1.0 + */ +@Data +@TableName("xxhbjzgdqzt") +@Accessors(chain = true) +@EqualsAndHashCode(callSuper = false) +@ApiModel(value="xxhbjzgdqzt", description="同步数据表（jzgdqzt）") +public class Xxhbjzgdqzt implements Serializable { + private static final long serialVersionUID = 1L; + + /**id*/ + @TableId(type = IdType.ASSIGN_ID) + @ApiModelProperty(value = "id") + private String id; + /**学号*/ + @Excel(name = "学号", width = 15) + @ApiModelProperty(value = "学号") + private String dm; + /**姓名*/ + @Excel(name = "姓名", width = 15) + @ApiModelProperty(value = "姓名") + private String mc; +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/mapper/XxhbjzgdqztMapper.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/mapper/XxhbjzgdqztMapper.java new file mode 100644 index 00000000..dc628754 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/mapper/XxhbjzgdqztMapper.java @@ -0,0 +1,15 @@ +package org.jeecg.modules.kc.grab.imports.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks; +import org.jeecg.modules.kc.grab.imports.entity.Xxhbjzgdqzt; + +/** + * @Description: 同步数据表（bks） + * @Author: jeecg-boot + * @Date: 2023-04-10 + * @Version: V1.0 + */ +public interface XxhbjzgdqztMapper extends BaseMapper { + +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/service/IXxhbxjzgdqztService.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/service/IXxhbxjzgdqztService.java new file mode 100644 index 00000000..e4dc4dbc --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/service/IXxhbxjzgdqztService.java @@ -0,0 +1,32 @@ +package org.jeecg.modules.kc.grab.imports.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks; +import org.jeecg.modules.kc.grab.imports.entity.Xxhbjzgdqzt; + +import java.util.Collection; + +/** + * @Description: 同步数据表（bks） + * @Author: jeecg-boot + * @Date: 2023-04-10 + * @Version: V1.0 + */ +public interface IXxhbxjzgdqztService extends IService { + + /** + * 同步数据 + * @param entityList + * @return + */ + boolean syncList(Collection entityList); + + /** + * + * @param entityList + * @param isDelete + * @return + */ + boolean syncList(Collection entityList, boolean isDelete); + +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/service/impl/XxhbjzgdqztServiceImpl.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/service/impl/XxhbjzgdqztServiceImpl.java new file mode 100644 index 00000000..72d8dc62 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/imports/service/impl/XxhbjzgdqztServiceImpl.java @@ -0,0 +1,40 @@ +package org.jeecg.modules.kc.grab.imports.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks; +import org.jeecg.modules.kc.grab.imports.entity.Xxhbjzgdqzt; +import org.jeecg.modules.kc.grab.imports.mapper.XxhbbksMapper; +import org.jeecg.modules.kc.grab.imports.mapper.XxhbjzgdqztMapper; +import org.jeecg.modules.kc.grab.imports.service.IXxhbbksService; +import org.jeecg.modules.kc.grab.imports.service.IXxhbxjzgdqztService; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.util.Collection; + +/** + * @Description: 同步数据表（bks） + * @Author: jeecg-boot + * @Date: 2023-04-10 + * @Version: V1.0 + */ +@Service +public class XxhbjzgdqztServiceImpl extends ServiceImpl implements IXxhbxjzgdqztService { + + @Override + @Transactional(rollbackFor = {Exception.class}) + public boolean syncList(Collection entityList) { + return syncList(entityList, true); + } + + @Override + @Transactional(rollbackFor = {Exception.class}) + public boolean syncList(Collection entityList, boolean isDelete) { + QueryWrapper dqw = new QueryWrapper(); + if(isDelete){ + baseMapper.delete(dqw); + } + return this.saveBatch(entityList, 1000); + } +}