From ca563ca462f144a6aa6bb2cdfa059c2fa120865f Mon Sep 17 00:00:00 2001 From: shih <510524130@qq.com> Date: Mon, 27 Apr 2026 14:31:18 +0800 Subject: [PATCH] =?UTF-8?q?gr=5Fbi=5Ffs=5Fbusiness=5Fsum,=20gr=5Fbi=5Ffs?= =?UTF-8?q?=5Fsum,=20gr=5Fbi=5Fps=5Fsaleprod=20=E6=95=B0=E6=8D=AE=E5=90=8C?= =?UTF-8?q?=E6=AD=A5=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../config/job/GenerateFsBusinessSumJob.java | 29 ++++ .../config/job/GenerateFsSumJob.java | 29 ++++ .../config/job/GeneratePsSaleprodJob.java | 29 ++++ .../framework/entity/GrBiFsBusinessSum.java | 84 +++++++++ .../core/framework/entity/GrBiFsSum.java | 58 +++++++ .../core/framework/entity/GrBiPsSaleprod.java | 163 ++++++++++++++++++ .../mapper/GrBiFsBusinessSumMapper.java | 24 +++ .../framework/mapper/GrBiFsSumMapper.java | 24 +++ .../mapper/GrBiPsSaleprodMapper.java | 24 +++ .../service/IGrBiFsBusinessSumService.java | 9 + .../framework/service/IGrBiFsSumService.java | 9 + .../service/IGrBiPsSaleprodService.java | 9 + .../impl/GrBiFsBusinessSumServiceImpl.java | 38 ++++ .../service/impl/GrBiFsSumServiceImpl.java | 38 ++++ .../impl/GrBiPsSaleprodServiceImpl.java | 38 ++++ 15 files changed, 605 insertions(+) create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GenerateFsBusinessSumJob.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GenerateFsSumJob.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GeneratePsSaleprodJob.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiFsBusinessSum.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiFsSum.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiPsSaleprod.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiFsBusinessSumMapper.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiFsSumMapper.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiPsSaleprodMapper.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiFsBusinessSumService.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiFsSumService.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiPsSaleprodService.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsBusinessSumServiceImpl.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsSumServiceImpl.java create mode 100644 lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiPsSaleprodServiceImpl.java diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GenerateFsBusinessSumJob.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GenerateFsBusinessSumJob.java new file mode 100644 index 0000000..058eb5a --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GenerateFsBusinessSumJob.java @@ -0,0 +1,29 @@ +package com.lideeyunji.core.framework.config.job; + +import com.lideeyunji.core.framework.service.IGrBiFsBusinessSumService; +import com.lideeyunji.tool.framework.common.constant.lideeYunJiBaseConstant; +import com.lideeyunji.tool.framework.quartz.core.handler.JobHandler; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; + +/** + * + * oracle gr_bi_fs_business_sum -> mysql gr_bi_fs_business_sum + */ +@Slf4j +@Component("generateFsBusinessSumJob") +public class GenerateFsBusinessSumJob implements JobHandler { + + @Resource + private IGrBiFsBusinessSumService giBiFsBusinessSumService; + + @Override + public String execute(String param) throws Exception { + log.info("*********** 开始同步gr_bi_fs_business_sum ************"); + giBiFsBusinessSumService.GenerateFsBusinessSum(lideeYunJiBaseConstant.DS_ERP_BI_DATA); + log.info("*********** 同步gr_bi_fs_business_sum完成 ************"); + return "*********** 同步gr_bi_fs_business_sum完成 ************"; + } +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GenerateFsSumJob.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GenerateFsSumJob.java new file mode 100644 index 0000000..bc05bcd --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GenerateFsSumJob.java @@ -0,0 +1,29 @@ +package com.lideeyunji.core.framework.config.job; + +import com.lideeyunji.core.framework.service.IGrBiFsSumService; +import com.lideeyunji.tool.framework.common.constant.lideeYunJiBaseConstant; +import com.lideeyunji.tool.framework.quartz.core.handler.JobHandler; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; + +/** + * + * oracle gr_bi_fs_sum -> mysql gr_bi_fs_sum + */ +@Slf4j +@Component("generateFsSumJob") +public class GenerateFsSumJob implements JobHandler { + + @Resource + private IGrBiFsSumService grBiFsSumService; + + @Override + public String execute(String param) throws Exception { + log.info("*********** 开始同步gr_bi_fs_sum ************"); + grBiFsSumService.generateFsSum(lideeYunJiBaseConstant.DS_ERP_BI_DATA); + log.info("*********** 同步gr_bi_fs_sum完成 ************"); + return "*********** 同步gr_bi_fs_sum完成 ************"; + } +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GeneratePsSaleprodJob.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GeneratePsSaleprodJob.java new file mode 100644 index 0000000..e412ba6 --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/config/job/GeneratePsSaleprodJob.java @@ -0,0 +1,29 @@ +package com.lideeyunji.core.framework.config.job; + +import com.lideeyunji.core.framework.service.IGrBiPsSaleprodService; +import com.lideeyunji.tool.framework.common.constant.lideeYunJiBaseConstant; +import com.lideeyunji.tool.framework.quartz.core.handler.JobHandler; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; + +/** + * + * oracle gr_bi_ps_saleprod -> mysql gr_bi_ps_saleprod + */ +@Slf4j +@Component("generatePsSaleprodJob") +public class GeneratePsSaleprodJob implements JobHandler { + + @Resource + private IGrBiPsSaleprodService grBiPsSaleprodService; + + @Override + public String execute(String param) throws Exception { + log.info("*********** 开始同步gr_bi_ps_saleprod ************"); + grBiPsSaleprodService.generatePsSaleprod(lideeYunJiBaseConstant.DS_ERP_BI_DATA); + log.info("*********** 同步gr_bi_ps_saleprod完成 ************"); + return "*********** 同步gr_bi_ps_saleprod完成 ************"; + } +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiFsBusinessSum.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiFsBusinessSum.java new file mode 100644 index 0000000..d0445d7 --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiFsBusinessSum.java @@ -0,0 +1,84 @@ +package com.lideeyunji.core.framework.entity; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; +import java.io.Serializable; + +@TableName("gr_bi_fs_business_sum") +@Data +public class GrBiFsBusinessSum implements Serializable { + private static final long serialVersionUID = 1L; + + @TableField(value = "ID") + private Integer id; + + @TableField(value = "USEYEAR") + private Integer useyear; + + @TableField(value = "USEMONTH") + private Integer usemonth; + + @TableField(value = "THISPSRATE") + private Double thispsrate; + + @TableField(value = "LASTPSRATE") + private Double lastpsrate; + + @TableField(value = "THISQTYRATE") + private Double thisqtyrate; + + @TableField(value = "LASTQTYRATE") + private Double lastqtyrate; + + @TableField(value = "THISCYCLE") + private Double thiscycle; + + @TableField(value = "LASTCYCLE") + private Double lastcycle; + + @TableField(value = "MONTHPROFITRATE") + private Double monthprofitrate; + + @TableField(value = "THISPROFITRATE") + private Double thisprofitrate; + + @TableField(value = "LASTPROFITRATE") + private Double lastprofitrate; + + @TableField(value = "MONTHINCOME") + private Double monthincome; + + @TableField(value = "THISINCOME") + private Double thisincome; + + @TableField(value = "LASTINCOME") + private Double lastincome; + + @TableField(value = "MONTHPROFIT") + private Double monthprofit; + + @TableField(value = "THISPROFIT") + private Double thisprofit; + + @TableField(value = "LASTPROFIT") + private Double lastprofit; + + @TableField(value = "THISASSETS") + private Double thisassets; + + @TableField(value = "LASTASSETS") + private Double lastassets; + + @TableField(value = "THISLIAB") + private Double thisliab; + + @TableField(value = "LASTLIAB") + private Double lastliab; + + @TableField(value = "THISDEBTRATIO") + private Double thisdebtratio; + + @TableField(value = "LASTDEBTRATIO") + private Double lastdebtratio; +} \ No newline at end of file diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiFsSum.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiFsSum.java new file mode 100644 index 0000000..89a9b46 --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiFsSum.java @@ -0,0 +1,58 @@ +package com.lideeyunji.core.framework.entity; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serializable; + +@TableName("gr_bi_fs_sum") +@Data +public class GrBiFsSum implements Serializable { + private static final long serialVersionUID = 1L; + + @TableField(value = "ID") + private String id; + + @TableField(value = "USEYEAR") + private String useyear; + + @TableField(value = "USEMONTH") + private String usemonth; + + @TableField(value = "DEFAULTFLAG") + private String defaultflag; + + @TableField(value = "MONTHSAMONEY") + private String monthsamoney; + + @TableField(value = "THISSAMONEY") + private String thissamoney; + + @TableField(value = "LASTSAMONEY") + private String lastsamoney; + + @TableField(value = "YOYSAMONEY") + private String yoysamoney; + + @TableField(value = "MONTHPROFIT") + private String monthprofit; + + @TableField(value = "THISPROFIT") + private String thisprofit; + + @TableField(value = "LASTPROFIT") + private String lastprofit; + + @TableField(value = "YOYPROFIT") + private String yoyprofit; + + @TableField(value = "THISREMMONEY") + private String thisremmoney; + + @TableField(value = "THISPSRATE") + private String thispsrate; + + @TableField(value = "THISQTYRATE") + private String thisqtyrate; +} \ No newline at end of file diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiPsSaleprod.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiPsSaleprod.java new file mode 100644 index 0000000..1f8a6dc --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/entity/GrBiPsSaleprod.java @@ -0,0 +1,163 @@ +package com.lideeyunji.core.framework.entity; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serializable; + +@TableName("gr_bi_ps_saleprod") +@Data +public class GrBiPsSaleprod implements Serializable { + private static final long serialVersionUID = 1L; + + @TableField(value = "USEYEAR") + private String useyear; + + @TableField(value = "USEMONTH") + private String usemonth; + + @TableField(value = "GOODSID") + private String goodsid; + + @TableField(value = "GOODSNAME") + private String goodsname; + + @TableField(value = "GOODSTYPE") + private String goodstype; + + @TableField(value = "GOODSUNIT") + private String goodsunit; + + @TableField(value = "GOODSCLASSID") + private String goodsclassid; + + @TableField(value = "GOODSCLASSNAME") + private String goodsclassname; + + @TableField(value = "MONTHSAQTY") + private String monthsaqty; + + @TableField(value = "THISSAQTY") + private String thissaqty; + + @TableField(value = "LASTSAQTY") + private String lastsaqty; + + @TableField(value = "THISPRQTY") + private String thisprqty; + + @TableField(value = "LASTPRQTY") + private String lastprqty; + + @TableField(value = "THISPSRATE") + private String thispsrate; + + @TableField(value = "LASTPSRATE") + private String lastpsrate; + + @TableField(value = "THISREMQTY") + private String thisremqty; + + @TableField(value = "LASTREMQTY") + private String lastremqty; + + @TableField(value = "THISQTYRATE") + private String thisqtyrate; + + @TableField(value = "LASTQTYRATE") + private String lastqtyrate; + + @TableField(value = "MONTHSAMONEY") + private String monthsamoney; + + @TableField(value = "THISSAMONEY") + private String thissamoney; + + @TableField(value = "LASTSAMONEY") + private String lastsamoney; + + @TableField(value = "MONTHPROFIT") + private String monthprofit; + + @TableField(value = "THISPROFIT") + private String thisprofit; + + @TableField(value = "LASTPROFIT") + private String lastprofit; + + @TableField(value = "MONTHCOST") + private String monthcost; + + @TableField(value = "THISCOST") + private String thiscost; + + @TableField(value = "LASTCOST") + private String lastcost; + + @TableField(value = "ID") + private String id; + + @TableField(value = "MONTHPRQTY") + private String monthprqty; + + @TableField(value = "MONTHPRMONEY") + private String monthprmoney; + + @TableField(value = "THISPRMONEY") + private String thisprmoney; + + @TableField(value = "LASTPRMONEY") + private String lastprmoney; + + @TableField(value = "MONTHPRCOST") + private String monthprcost; + + @TableField(value = "THISPRCOST") + private String thisprcost; + + @TableField(value = "LASTPRCOST") + private String lastprcost; + + @TableField(value = "THISREMMONEY") + private String thisremmoney; + + @TableField(value = "LASTREMMONEY") + private String lastremmoney; + + @TableField(value = "MONTHPROFITRATE") + private String monthprofitrate; + + @TableField(value = "THISPROFITRATE") + private String thisprofitrate; + + @TableField(value = "LASTPROFITRATE") + private String lastprofitrate; + + @TableField(value = "MONTHSAMONEYSHARE") + private String monthsamoneyshare; + + @TableField(value = "THISSAMONEYSHARE") + private String thissamoneyshare; + + @TableField(value = "LASTSAMONEYSHARE") + private String lastsamoneyshare; + + @TableField(value = "MONTHPROFITSHARE") + private String monthprofitshare; + + @TableField(value = "THISPROFITSHARE") + private String thisprofitshare; + + @TableField(value = "LASTPROFITSHARE") + private String lastprofitshare; + + @TableField(value = "SAMONEYGROWTH") + private String samoneygrowth; + + @TableField(value = "PROFITGROWTH") + private String profitgrowth; + + @TableField(value = "PROFITCHANGE") + private String profitchange; +} \ No newline at end of file diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiFsBusinessSumMapper.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiFsBusinessSumMapper.java new file mode 100644 index 0000000..3a3ddaf --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiFsBusinessSumMapper.java @@ -0,0 +1,24 @@ +package com.lideeyunji.core.framework.mapper; + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.lideeyunji.core.framework.entity.GrBiFsBusinessSum; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +public interface GrBiFsBusinessSumMapper extends BaseMapper { + + + + @DS(value = "#dataSourceType") + default List getBusinessSumList(@Param("dataSourceType") String dataSourceType){ + return this.selectList(new QueryWrapper<>()); + } + + @DS(value = "#dataSourceType") + default int deleteOldBusinessSum(@Param("dataSourceType") String dataSourceType){ + return this.delete(new QueryWrapper<>()); + } +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiFsSumMapper.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiFsSumMapper.java new file mode 100644 index 0000000..f107c3d --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiFsSumMapper.java @@ -0,0 +1,24 @@ +package com.lideeyunji.core.framework.mapper; + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.lideeyunji.core.framework.entity.GrBiFsSum; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +public interface GrBiFsSumMapper extends BaseMapper { + + + + @DS(value = "#dataSourceType") + default List getFsSumList(@Param("dataSourceType") String dataSourceType){ + return this.selectList(new QueryWrapper<>()); + } + + @DS(value = "#dataSourceType") + default int deleteOldFsSum(@Param("dataSourceType") String dataSourceType){ + return this.delete(new QueryWrapper<>()); + } +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiPsSaleprodMapper.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiPsSaleprodMapper.java new file mode 100644 index 0000000..6e3f48d --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/mapper/GrBiPsSaleprodMapper.java @@ -0,0 +1,24 @@ +package com.lideeyunji.core.framework.mapper; + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.lideeyunji.core.framework.entity.GrBiPsSaleprod; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +public interface GrBiPsSaleprodMapper extends BaseMapper { + + + + @DS(value = "#dataSourceType") + default List getPsSaleprodList(@Param("dataSourceType") String dataSourceType){ + return this.selectList(new QueryWrapper<>()); + } + + @DS(value = "#dataSourceType") + default int deleteOldPsSaleprod(@Param("dataSourceType") String dataSourceType){ + return this.delete(new QueryWrapper<>()); + } +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiFsBusinessSumService.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiFsBusinessSumService.java new file mode 100644 index 0000000..abaa954 --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiFsBusinessSumService.java @@ -0,0 +1,9 @@ +package com.lideeyunji.core.framework.service; + +import org.apache.ibatis.annotations.Param; + + +public interface IGrBiFsBusinessSumService { + + void GenerateFsBusinessSum(@Param("dataSourceType") String dataSourceType); +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiFsSumService.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiFsSumService.java new file mode 100644 index 0000000..a13fe72 --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiFsSumService.java @@ -0,0 +1,9 @@ +package com.lideeyunji.core.framework.service; + +import org.apache.ibatis.annotations.Param; + + +public interface IGrBiFsSumService { + + void generateFsSum(@Param("dataSourceType") String dataSourceType); +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiPsSaleprodService.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiPsSaleprodService.java new file mode 100644 index 0000000..5fb8ef8 --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/IGrBiPsSaleprodService.java @@ -0,0 +1,9 @@ +package com.lideeyunji.core.framework.service; + +import org.apache.ibatis.annotations.Param; + + +public interface IGrBiPsSaleprodService { + + void generatePsSaleprod(@Param("dataSourceType") String dataSourceType); +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsBusinessSumServiceImpl.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsBusinessSumServiceImpl.java new file mode 100644 index 0000000..b57903c --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsBusinessSumServiceImpl.java @@ -0,0 +1,38 @@ +package com.lideeyunji.core.framework.service.impl; + +import cn.hutool.core.collection.CollUtil; +import com.baomidou.dynamic.datasource.annotation.DS; +import com.baomidou.dynamic.datasource.annotation.DSTransactional; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.lideeyunji.core.framework.entity.GrBiFsBusinessSum; +import com.lideeyunji.core.framework.mapper.GrBiFsBusinessSumMapper; +import com.lideeyunji.core.framework.service.IGrBiFsBusinessSumService; +import com.lideeyunji.tool.framework.common.constant.lideeYunJiBaseConstant; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Slf4j +@Service +public class GrBiFsBusinessSumServiceImpl extends ServiceImpl implements IGrBiFsBusinessSumService { + + @Override + @DSTransactional + @DS(value = "#dataSourceType") + public void GenerateFsBusinessSum(String dataSourceType) { + // 获取数据 + List grBiSaSetdtlList = this.baseMapper.getBusinessSumList(lideeYunJiBaseConstant.DS_ORACLE_GRYYBI); + if (CollUtil.isEmpty(grBiSaSetdtlList)) { + return; + } + //保存数据 + int reNum = this.baseMapper.deleteOldBusinessSum(lideeYunJiBaseConstant.DS_ERP_BI_DATA); + log.info("删除数量：{}", reNum); + //使用 saveBatch 批量插入 + boolean success = this.saveBatch(grBiSaSetdtlList, 500); + if (!success) { + throw new RuntimeException("批量新增异常"); + } + } +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsSumServiceImpl.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsSumServiceImpl.java new file mode 100644 index 0000000..7abfa77 --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsSumServiceImpl.java @@ -0,0 +1,38 @@ +package com.lideeyunji.core.framework.service.impl; + +import cn.hutool.core.collection.CollUtil; +import com.baomidou.dynamic.datasource.annotation.DS; +import com.baomidou.dynamic.datasource.annotation.DSTransactional; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.lideeyunji.core.framework.entity.GrBiFsSum; +import com.lideeyunji.core.framework.mapper.GrBiFsSumMapper; +import com.lideeyunji.core.framework.service.IGrBiFsSumService; +import com.lideeyunji.tool.framework.common.constant.lideeYunJiBaseConstant; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Slf4j +@Service +public class GrBiFsSumServiceImpl extends ServiceImpl implements IGrBiFsSumService { + + @Override + @DSTransactional + @DS(value = "#dataSourceType") + public void generateFsSum(String dataSourceType) { + // 获取数据 + List grBiSaSetdtlList = this.baseMapper.getFsSumList(lideeYunJiBaseConstant.DS_ORACLE_GRYYBI); + if (CollUtil.isEmpty(grBiSaSetdtlList)) { + return; + } + //保存数据 + int reNum = this.baseMapper.deleteOldFsSum(lideeYunJiBaseConstant.DS_ERP_BI_DATA); + log.info("删除数量：{}", reNum); + //使用 saveBatch 批量插入 + boolean success = this.saveBatch(grBiSaSetdtlList, 500); + if (!success) { + throw new RuntimeException("批量新增异常"); + } + } +} diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiPsSaleprodServiceImpl.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiPsSaleprodServiceImpl.java new file mode 100644 index 0000000..7dc19b8 --- /dev/null +++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiPsSaleprodServiceImpl.java @@ -0,0 +1,38 @@ +package com.lideeyunji.core.framework.service.impl; + +import cn.hutool.core.collection.CollUtil; +import com.baomidou.dynamic.datasource.annotation.DS; +import com.baomidou.dynamic.datasource.annotation.DSTransactional; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.lideeyunji.core.framework.entity.GrBiPsSaleprod; +import com.lideeyunji.core.framework.mapper.GrBiPsSaleprodMapper; +import com.lideeyunji.core.framework.service.IGrBiPsSaleprodService; +import com.lideeyunji.tool.framework.common.constant.lideeYunJiBaseConstant; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import java.util.List; + +@Slf4j +@Service +public class GrBiPsSaleprodServiceImpl extends ServiceImpl implements IGrBiPsSaleprodService { + + @Override + @DSTransactional + @DS(value = "#dataSourceType") + public void generatePsSaleprod(String dataSourceType) { + // 获取数据 + List grBiSaSetdtlList = this.baseMapper.getPsSaleprodList(lideeYunJiBaseConstant.DS_ORACLE_GRYYBI); + if (CollUtil.isEmpty(grBiSaSetdtlList)) { + return; + } + //保存数据 + int reNum = this.baseMapper.deleteOldPsSaleprod(lideeYunJiBaseConstant.DS_ERP_BI_DATA); + log.info("删除数量：{}", reNum); + //使用 saveBatch 批量插入 + boolean success = this.saveBatch(grBiSaSetdtlList, 500); + if (!success) { + throw new RuntimeException("批量新增异常"); + } + } +}