From 96106c312fbc512057859d5be3caa5836a9fb6f0 Mon Sep 17 00:00:00 2001 From: x_z Date: Wed, 14 Dec 2022 15:10:53 +0800 Subject: [PATCH] =?UTF-8?q?1.=E6=B7=BB=E5=8A=A0=E5=AE=9A=E6=97=B6=E5=88=A0?= =?UTF-8?q?=E9=99=A4=E5=8E=86=E5=8F=B2=E6=95=B0=E6=8D=AE=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../api/admin/dao/basic/BasicDownloadDao.java | 1 + .../api/admin/dao/basic/BasicExportDao.java | 3 +- .../admin/dao/thrsys/ThrCorpExportLogDao.java | 2 + .../dao/thrsys/ThrCorpImportDetailDao.java | 2 + .../admin/dao/thrsys/ThrCorpImportLogDao.java | 1 + .../api/admin/dao/thrsys/ThrImportLogDao.java | 2 + .../admin/dao/thrsys/ThrOrderDetailDao.java | 2 + .../dao/thrsys/ThrOrderExportLogDao.java | 2 + .../dao/thrsys/ThrOrderImportDetailDao.java | 2 + .../dao/thrsys/ThrOrderImportLogDao.java | 2 + .../dao/thrsys/ThrProductsExportLogDao.java | 2 + .../thrsys/ThrProductsImportDetailDao.java | 1 + .../dao/thrsys/ThrProductsImportLogDao.java | 3 + .../service/basic/BasicDownloadService.java | 2 + .../service/basic/BasicExportService.java | 5 +- .../basic/impl/BasicDownloadServiceImpl.java | 7 ++ .../basic/impl/BasicExportServiceImpl.java | 9 +- .../thrsys/ThrCorpExportLogService.java | 2 +- .../thrsys/ThrCorpImportDetailService.java | 2 +- .../thrsys/ThrCorpImportLogService.java | 1 + .../service/thrsys/ThrImportLogService.java | 2 + .../service/thrsys/ThrOrderDetailService.java | 1 + .../thrsys/ThrOrderExportLogService.java | 2 + .../thrsys/ThrOrderImportDetailService.java | 2 + .../thrsys/ThrOrderImportLogService.java | 1 + .../thrsys/ThrProductsExportLogService.java | 1 + .../ThrProductsImportDetailService.java | 1 + .../thrsys/ThrProductsImportLogService.java | 2 + .../impl/ThrCorpExportLogServiceImpl.java | 8 ++ .../impl/ThrCorpImportDetailServiceImpl.java | 7 ++ .../impl/ThrCorpImportLogServiceImpl.java | 7 ++ .../thrsys/impl/ThrImportLogServiceImpl.java | 7 ++ .../impl/ThrOrderDetailServiceImpl.java | 8 +- .../impl/ThrOrderExportLogServiceImpl.java | 7 ++ .../impl/ThrOrderImportDetailServiceImpl.java | 7 ++ .../impl/ThrOrderImportLogServiceImpl.java | 8 +- .../impl/ThrProductsExportLogServiceImpl.java | 7 ++ .../ThrProductsImportDetailServiceImpl.java | 7 ++ .../impl/ThrProductsImportLogServiceImpl.java | 7 ++ .../glxp/api/admin/thread/CleanDataTask.java | 95 +++++++++++++++++++ .../mybatis/mapper/basic/BasicDownloadDao.xml | 4 + .../mybatis/mapper/basic/BasicExportDao.xml | 4 + .../mapper/thrsys/ThrCorpExportLogDao.xml | 4 + .../mapper/thrsys/ThrCorpImportDetailDao.xml | 4 + .../mapper/thrsys/ThrCorpImportLogDao.xml | 4 + .../mybatis/mapper/thrsys/ThrImportLogDao.xml | 4 + .../mapper/thrsys/ThrOrderDetailDao.xml | 4 + .../mapper/thrsys/ThrOrderExportLogDao.xml | 4 + .../mapper/thrsys/ThrOrderImportDetailDao.xml | 4 + .../mapper/thrsys/ThrOrderImportLogDao.xml | 4 + .../mapper/thrsys/ThrProductsExportLogDao.xml | 4 + .../thrsys/ThrProductsImportDetailDao.xml | 4 + .../mapper/thrsys/ThrProductsImportLogDao.xml | 4 + .../main/resources/schemas/schema_v2.1.sql | 8 ++ 54 files changed, 290 insertions(+), 10 deletions(-) create mode 100644 api-admin/src/main/java/com/glxp/api/admin/thread/CleanDataTask.java diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/basic/BasicDownloadDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/basic/BasicDownloadDao.java index d0a5f56d..5233f5c7 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/basic/BasicDownloadDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/basic/BasicDownloadDao.java @@ -20,4 +20,5 @@ public interface BasicDownloadDao { boolean updateDownloadStatus(BasicDownloadStatusEntity basicDownloadStatusEntity); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/basic/BasicExportDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/basic/BasicExportDao.java index 60d6db0e..774bc9c4 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/basic/BasicExportDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/basic/BasicExportDao.java @@ -1,9 +1,7 @@ package com.glxp.api.admin.dao.basic; import com.glxp.api.admin.entity.basic.BasicExportStatusEntity; -import com.glxp.api.admin.entity.inout.IOOrderStatusEntity; import com.glxp.api.admin.req.basic.BasicExportStatusRequest; -import com.glxp.api.admin.req.inout.OrderStatusFilterRequest; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; @@ -22,4 +20,5 @@ public interface BasicExportDao { boolean updateExportStatus(BasicExportStatusEntity warehouseEntity); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpExportLogDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpExportLogDao.java index 28462cd6..a9c36b68 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpExportLogDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpExportLogDao.java @@ -20,4 +20,6 @@ public interface ThrCorpExportLogDao { boolean deleteById(@Param("id") String id); String selectFilePathById(@Param("id") String id); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpImportDetailDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpImportDetailDao.java index dd9a12b0..a5f1209e 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpImportDetailDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpImportDetailDao.java @@ -20,4 +20,6 @@ public interface ThrCorpImportDetailDao { boolean deleteById(@Param("id") String id); boolean deleteByGenkey(@Param("genKey") String genKey); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpImportLogDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpImportLogDao.java index 873205d6..7c39085a 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpImportLogDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrCorpImportLogDao.java @@ -18,4 +18,5 @@ public interface ThrCorpImportLogDao { boolean deleteById(@Param("id") String id); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrImportLogDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrImportLogDao.java index 277335f7..9341b1cc 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrImportLogDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrImportLogDao.java @@ -19,4 +19,6 @@ public interface ThrImportLogDao { boolean deleteById(@Param("id") String id); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderDetailDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderDetailDao.java index c15b610f..e81d06cf 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderDetailDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderDetailDao.java @@ -26,4 +26,6 @@ public interface ThrOrderDetailDao { boolean deleteAll(); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderExportLogDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderExportLogDao.java index 8c0d9b1e..15a95242 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderExportLogDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderExportLogDao.java @@ -17,4 +17,6 @@ public interface ThrOrderExportLogDao { boolean updateThrOrderExportLog(ThrOrderExportLogEntity thrOrderExportLogEntity); boolean deleteById(@Param("id") String id); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderImportDetailDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderImportDetailDao.java index 60b6f2de..cc252590 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderImportDetailDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderImportDetailDao.java @@ -21,4 +21,6 @@ public interface ThrOrderImportDetailDao { boolean deleteById(@Param("id") String id); boolean deleteByGenkey(@Param("genKey") String genKey); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderImportLogDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderImportLogDao.java index 04c5abd5..9da9f614 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderImportLogDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrOrderImportLogDao.java @@ -18,4 +18,6 @@ public interface ThrOrderImportLogDao { boolean deleteById(@Param("id") String id); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsExportLogDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsExportLogDao.java index 90e5d508..a0738f31 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsExportLogDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsExportLogDao.java @@ -25,4 +25,6 @@ public interface ThrProductsExportLogDao { * @return */ String selectFilePathById(@Param("id") String id); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsImportDetailDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsImportDetailDao.java index af6380eb..91fd4fda 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsImportDetailDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsImportDetailDao.java @@ -23,4 +23,5 @@ public interface ThrProductsImportDetailDao { boolean deleteByGenkey(@Param("genKey") String genKey); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsImportLogDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsImportLogDao.java index e32cbcc9..be0288b6 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsImportLogDao.java +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/thrsys/ThrProductsImportLogDao.java @@ -16,4 +16,7 @@ public interface ThrProductsImportLogDao { boolean updateImportLog(ThrProductsImportLogEntity thrProductsImportLogEntity); boolean deleteById(@Param("id") String id); + + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/basic/BasicDownloadService.java b/api-admin/src/main/java/com/glxp/api/admin/service/basic/BasicDownloadService.java index 287b1e3a..4dc8d020 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/basic/BasicDownloadService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/basic/BasicDownloadService.java @@ -16,4 +16,6 @@ public interface BasicDownloadService { boolean deleteById(String id); boolean updateDownloadStatus(BasicDownloadStatusEntity basicDownloadStatusEntity); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/basic/BasicExportService.java b/api-admin/src/main/java/com/glxp/api/admin/service/basic/BasicExportService.java index 5bfacd72..b9d6cb96 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/basic/BasicExportService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/basic/BasicExportService.java @@ -2,8 +2,6 @@ package com.glxp.api.admin.service.basic; import com.glxp.api.admin.entity.basic.BasicExportStatusEntity; import com.glxp.api.admin.req.basic.BasicExportStatusRequest; -import com.glxp.api.admin.req.inout.OrderStatusFilterRequest; -import org.apache.ibatis.annotations.Param; import java.util.List; @@ -18,4 +16,7 @@ public interface BasicExportService { boolean deleteById(String id); boolean updateExportStatus(BasicExportStatusEntity warehouseEntity); + + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/basic/impl/BasicDownloadServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/basic/impl/BasicDownloadServiceImpl.java index 01ee543f..e77c7b6f 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/basic/impl/BasicDownloadServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/basic/impl/BasicDownloadServiceImpl.java @@ -7,12 +7,14 @@ import com.glxp.api.admin.entity.basic.BasicDownloadStatusEntity; import com.glxp.api.admin.req.basic.BasicDownloadRequest; import com.glxp.api.admin.service.basic.BasicDownloadService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class BasicDownloadServiceImpl implements BasicDownloadService { @Resource @@ -56,4 +58,9 @@ public class BasicDownloadServiceImpl implements BasicDownloadService { public boolean updateDownloadStatus(BasicDownloadStatusEntity basicDownloadStatusEntity) { return basicDownloadDao.updateDownloadStatus(basicDownloadStatusEntity); } + + @Override + public boolean deleteByTime() { + return basicDownloadDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/basic/impl/BasicExportServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/basic/impl/BasicExportServiceImpl.java index 012841da..d78e2a67 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/basic/impl/BasicExportServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/basic/impl/BasicExportServiceImpl.java @@ -4,17 +4,17 @@ import cn.hutool.core.collection.CollUtil; import com.github.pagehelper.PageHelper; import com.glxp.api.admin.dao.basic.BasicExportDao; import com.glxp.api.admin.entity.basic.BasicExportStatusEntity; -import com.glxp.api.admin.entity.inout.IOOrderStatusEntity; import com.glxp.api.admin.req.basic.BasicExportStatusRequest; -import com.glxp.api.admin.req.inout.OrderStatusFilterRequest; import com.glxp.api.admin.service.basic.BasicExportService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class BasicExportServiceImpl implements BasicExportService { @Resource @@ -58,4 +58,9 @@ public class BasicExportServiceImpl implements BasicExportService { public boolean updateExportStatus(BasicExportStatusEntity basicExportStatusEntity) { return basicExportDao.updateExportStatus(basicExportStatusEntity); } + + @Override + public boolean deleteByTime() { + return basicExportDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpExportLogService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpExportLogService.java index 6bab1325..7cae4e9b 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpExportLogService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpExportLogService.java @@ -1,7 +1,6 @@ package com.glxp.api.admin.service.thrsys; import com.glxp.api.admin.entity.thrsys.ThrCorpExportLogEntity; -import com.glxp.api.admin.entity.thrsys.ThrCorpImportLogEntity; import com.glxp.api.admin.req.basic.FilterUdiEpLogRequest; import java.util.List; @@ -20,4 +19,5 @@ public interface ThrCorpExportLogService { boolean deleteById(String id); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpImportDetailService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpImportDetailService.java index ad557dcc..95e36186 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpImportDetailService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpImportDetailService.java @@ -2,7 +2,6 @@ package com.glxp.api.admin.service.thrsys; import com.glxp.api.admin.entity.thrsys.ThrCorpImportDetailEntity; import com.glxp.api.admin.req.basic.FilterUdiIpLogRequest; -import org.apache.ibatis.annotations.Param; import org.springframework.stereotype.Service; import java.util.List; @@ -22,4 +21,5 @@ public interface ThrCorpImportDetailService { boolean deleteByGenkey( String genKey); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpImportLogService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpImportLogService.java index 3cb510d5..cb6cf31a 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpImportLogService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrCorpImportLogService.java @@ -17,4 +17,5 @@ public interface ThrCorpImportLogService { boolean deleteById(String id); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrImportLogService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrImportLogService.java index 23988cd2..05082327 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrImportLogService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrImportLogService.java @@ -17,4 +17,6 @@ public interface ThrImportLogService { boolean deleteById(String id); ThrImportLogEntity selectByGenKey(String genKey); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderDetailService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderDetailService.java index af25b7b2..401070c6 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderDetailService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderDetailService.java @@ -22,4 +22,5 @@ public interface ThrOrderDetailService { boolean deleteAll(); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderExportLogService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderExportLogService.java index 64180d7a..b60cf943 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderExportLogService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderExportLogService.java @@ -16,4 +16,6 @@ public interface ThrOrderExportLogService { boolean updateThrOrderExportLog(ThrOrderExportLogEntity thrOrderExportLogEntity); boolean deleteById(String id); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderImportDetailService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderImportDetailService.java index 8c79c10f..c998a495 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderImportDetailService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderImportDetailService.java @@ -18,4 +18,6 @@ public interface ThrOrderImportDetailService { boolean deleteById(String id); boolean deleteByGenkey(String genKey); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderImportLogService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderImportLogService.java index ad67abb3..4c790da6 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderImportLogService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrOrderImportLogService.java @@ -16,4 +16,5 @@ public interface ThrOrderImportLogService { boolean deleteById(String id); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsExportLogService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsExportLogService.java index 5011baea..d4facdd9 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsExportLogService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsExportLogService.java @@ -17,4 +17,5 @@ public interface ThrProductsExportLogService { boolean deleteById(String id); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsImportDetailService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsImportDetailService.java index 230ac442..8db62bb0 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsImportDetailService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsImportDetailService.java @@ -18,4 +18,5 @@ public interface ThrProductsImportDetailService { boolean deleteByGenkey(String genKey); + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsImportLogService.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsImportLogService.java index 1157d28e..f6260413 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsImportLogService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/ThrProductsImportLogService.java @@ -15,4 +15,6 @@ public interface ThrProductsImportLogService { boolean deleteById(String id); ThrProductsImportLogEntity selectByGenKey(String genKey); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpExportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpExportLogServiceImpl.java index d037714f..2cffb529 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpExportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpExportLogServiceImpl.java @@ -8,13 +8,16 @@ import com.glxp.api.admin.entity.thrsys.ThrCorpExportLogEntity; import com.glxp.api.admin.req.basic.FilterUdiEpLogRequest; import com.glxp.api.admin.service.thrsys.ThrCorpExportLogService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrCorpExportLogServiceImpl implements ThrCorpExportLogService { + @Resource ThrCorpExportLogDao thrCorpExportLogDao; @@ -61,4 +64,9 @@ public class ThrCorpExportLogServiceImpl implements ThrCorpExportLogService { } return thrCorpExportLogDao.deleteById(id); } + + @Override + public boolean deleteByTime() { + return thrCorpExportLogDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpImportDetailServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpImportDetailServiceImpl.java index 6a25f41d..89aa3032 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpImportDetailServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpImportDetailServiceImpl.java @@ -6,12 +6,14 @@ import com.glxp.api.admin.entity.thrsys.ThrCorpImportDetailEntity; import com.glxp.api.admin.req.basic.FilterUdiIpLogRequest; import com.glxp.api.admin.service.thrsys.ThrCorpImportDetailService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrCorpImportDetailServiceImpl implements ThrCorpImportDetailService { @Resource @@ -54,4 +56,9 @@ public class ThrCorpImportDetailServiceImpl implements ThrCorpImportDetailServic public boolean deleteByGenkey(String genKey) { return thrCorpImportDetailDao.deleteByGenkey(genKey); } + + @Override + public boolean deleteByTime() { + return thrCorpImportDetailDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpImportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpImportLogServiceImpl.java index 84f35797..bd84ffe0 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpImportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrCorpImportLogServiceImpl.java @@ -6,12 +6,14 @@ import com.glxp.api.admin.entity.thrsys.ThrCorpImportLogEntity; import com.glxp.api.admin.req.basic.FilterUdiIpLogRequest; import com.glxp.api.admin.service.thrsys.ThrCorpImportLogService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrCorpImportLogServiceImpl implements ThrCorpImportLogService { @Resource ThrCorpImportLogDao thrCorpImportLogDao; @@ -55,4 +57,9 @@ public class ThrCorpImportLogServiceImpl implements ThrCorpImportLogService { public boolean deleteById(String id) { return thrCorpImportLogDao.deleteById(id); } + + @Override + public boolean deleteByTime() { + return thrCorpImportLogDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrImportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrImportLogServiceImpl.java index cb8be72a..2894493a 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrImportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrImportLogServiceImpl.java @@ -6,12 +6,14 @@ import com.glxp.api.admin.entity.thrsys.ThrImportLogEntity; import com.glxp.api.admin.req.basic.FilterUdiIpLogRequest; import com.glxp.api.admin.service.thrsys.ThrImportLogService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrImportLogServiceImpl implements ThrImportLogService { @Resource @@ -55,4 +57,9 @@ public class ThrImportLogServiceImpl implements ThrImportLogService { } return null; } + + @Override + public boolean deleteByTime() { + return thrImportLogDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderDetailServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderDetailServiceImpl.java index cc428160..4f00a76f 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderDetailServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderDetailServiceImpl.java @@ -2,17 +2,18 @@ package com.glxp.api.admin.service.thrsys.impl; import com.github.pagehelper.PageHelper; import com.glxp.api.admin.dao.thrsys.ThrOrderDetailDao; -import com.glxp.api.admin.entity.thrsys.ThrInvProductsEntity; import com.glxp.api.admin.entity.thrsys.ThrOrderDetailEntity; import com.glxp.api.admin.req.thrsys.FilterThrOrderDetailRequest; import com.glxp.api.admin.service.thrsys.ThrOrderDetailService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrOrderDetailServiceImpl implements ThrOrderDetailService { @Resource @@ -60,4 +61,9 @@ public class ThrOrderDetailServiceImpl implements ThrOrderDetailService { public boolean deleteAll() { return thrOrderDetailDao.deleteAll(); } + + @Override + public boolean deleteByTime() { + return thrOrderDetailDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderExportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderExportLogServiceImpl.java index bbd7d455..4a07327d 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderExportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderExportLogServiceImpl.java @@ -6,12 +6,14 @@ import com.glxp.api.admin.entity.thrsys.ThrOrderExportLogEntity; import com.glxp.api.admin.req.basic.FilterUdiEpLogRequest; import com.glxp.api.admin.service.thrsys.ThrOrderExportLogService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrOrderExportLogServiceImpl implements ThrOrderExportLogService { @Resource @@ -55,4 +57,9 @@ public class ThrOrderExportLogServiceImpl implements ThrOrderExportLogService { public boolean deleteById(String id) { return thrOrderExportLogDao.deleteById(id); } + + @Override + public boolean deleteByTime() { + return thrOrderExportLogDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderImportDetailServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderImportDetailServiceImpl.java index 30920cd2..0011cea0 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderImportDetailServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderImportDetailServiceImpl.java @@ -6,12 +6,14 @@ import com.glxp.api.admin.entity.thrsys.ThrOrderImportDetailEntity; import com.glxp.api.admin.req.basic.FilterUdiIpLogRequest; import com.glxp.api.admin.service.thrsys.ThrOrderImportDetailService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrOrderImportDetailServiceImpl implements ThrOrderImportDetailService { @Resource @@ -54,4 +56,9 @@ public class ThrOrderImportDetailServiceImpl implements ThrOrderImportDetailServ public boolean deleteByGenkey(String genKey) { return thrOrderImportDetailDao.deleteByGenkey(genKey); } + + @Override + public boolean deleteByTime() { + return thrOrderImportDetailDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderImportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderImportLogServiceImpl.java index 16a55bac..546d3b16 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderImportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrOrderImportLogServiceImpl.java @@ -2,11 +2,11 @@ package com.glxp.api.admin.service.thrsys.impl; import com.github.pagehelper.PageHelper; import com.glxp.api.admin.dao.thrsys.ThrOrderImportLogDao; -import com.glxp.api.admin.entity.basic.CorpImportLogEntity; import com.glxp.api.admin.entity.thrsys.ThrOrderImportLogEntity; import com.glxp.api.admin.req.basic.FilterUdiIpLogRequest; import com.glxp.api.admin.service.thrsys.ThrOrderImportLogService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; @@ -14,6 +14,7 @@ import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrOrderImportLogServiceImpl implements ThrOrderImportLogService { @Resource ThrOrderImportLogDao thrOrderImportLogDao; @@ -57,4 +58,9 @@ public class ThrOrderImportLogServiceImpl implements ThrOrderImportLogService { public boolean deleteById(String id) { return thrOrderImportLogDao.deleteById(id); } + + @Override + public boolean deleteByTime() { + return thrOrderImportLogDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsExportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsExportLogServiceImpl.java index b10c8e77..17041d4e 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsExportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsExportLogServiceImpl.java @@ -8,12 +8,14 @@ import com.glxp.api.admin.entity.thrsys.ThrProductsExportLogEntity; import com.glxp.api.admin.req.basic.FilterUdiEpLogRequest; import com.glxp.api.admin.service.thrsys.ThrProductsExportLogService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrProductsExportLogServiceImpl implements ThrProductsExportLogService { @Resource ThrProductsExportLogDao thrProductsExportLogDao; @@ -61,4 +63,9 @@ public class ThrProductsExportLogServiceImpl implements ThrProductsExportLogServ } return thrProductsExportLogDao.deleteById(id); } + + @Override + public boolean deleteByTime() { + return thrProductsExportLogDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsImportDetailServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsImportDetailServiceImpl.java index 9a9fb98c..9ca49460 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsImportDetailServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsImportDetailServiceImpl.java @@ -6,12 +6,14 @@ import com.glxp.api.admin.entity.thrsys.ThrProductsImportDetailEntity; import com.glxp.api.admin.req.basic.FilterUdiIpLogRequest; import com.glxp.api.admin.service.thrsys.ThrProductsImportDetailService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrProductsImportDetailServiceImpl implements ThrProductsImportDetailService { @Resource @@ -54,4 +56,9 @@ public class ThrProductsImportDetailServiceImpl implements ThrProductsImportDeta public boolean deleteByGenkey(String genKey) { return thrProductsImportDetailDao.deleteByGenkey(genKey); } + + @Override + public boolean deleteByTime() { + return thrProductsImportDetailDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsImportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsImportLogServiceImpl.java index afa49ec9..cbcde42b 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsImportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/api/admin/service/thrsys/impl/ThrProductsImportLogServiceImpl.java @@ -6,12 +6,14 @@ import com.glxp.api.admin.entity.thrsys.ThrProductsImportLogEntity; import com.glxp.api.admin.req.basic.FilterUdiIpLogRequest; import com.glxp.api.admin.service.thrsys.ThrProductsImportLogService; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Collections; import java.util.List; @Service +@Transactional(rollbackFor = Exception.class) public class ThrProductsImportLogServiceImpl implements ThrProductsImportLogService { @Resource ThrProductsImportLogDao thrProductsImportLogDao; @@ -54,4 +56,9 @@ public class ThrProductsImportLogServiceImpl implements ThrProductsImportLogServ } return null; } + + @Override + public boolean deleteByTime() { + return thrProductsImportLogDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/api/admin/thread/CleanDataTask.java b/api-admin/src/main/java/com/glxp/api/admin/thread/CleanDataTask.java new file mode 100644 index 00000000..1ce8b48c --- /dev/null +++ b/api-admin/src/main/java/com/glxp/api/admin/thread/CleanDataTask.java @@ -0,0 +1,95 @@ +package com.glxp.api.admin.thread; + +import com.glxp.api.admin.dao.schedule.ScheduledDao; +import com.glxp.api.admin.entity.info.ScheduledEntity; +import com.glxp.api.admin.req.info.ScheduledRequest; +import com.glxp.api.admin.service.basic.BasicDownloadService; +import com.glxp.api.admin.service.basic.BasicExportService; +import com.glxp.api.admin.service.thrsys.*; +import lombok.extern.slf4j.Slf4j; +import org.springframework.scheduling.annotation.EnableScheduling; +import org.springframework.scheduling.annotation.SchedulingConfigurer; +import org.springframework.scheduling.config.ScheduledTaskRegistrar; +import org.springframework.scheduling.support.CronTrigger; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; + +/** + * 删除数据 + */ +@Slf4j +@Component +@EnableScheduling +public class CleanDataTask implements SchedulingConfigurer { + + @Resource + private ScheduledDao scheduledDao; + @Resource + private BasicExportService basicExportService; + @Resource + private BasicDownloadService basicDownloadService; + @Resource + private ThrCorpExportLogService thrCorpExportLogService; + @Resource + private ThrCorpImportDetailService thrCorpImportDetailService; + @Resource + private ThrCorpImportLogService thrCorpImportLogService; + @Resource + private ThrImportLogService thrImportLogService; + @Resource + private ThrOrderDetailService thrOrderDetailService; + @Resource + private ThrOrderExportLogService thrOrderExportLogService; + @Resource + private ThrOrderImportDetailService thrOrderImportDetailService; + @Resource + private ThrOrderImportLogService thrOrderImportLogService; + @Resource + private ThrProductsImportLogService thrProductsImportLogService; + @Resource + private ThrProductsExportLogService thrProductsExportLogService; + @Resource + private ThrProductsImportDetailService thrProductsImportDetailService; + + @Override + public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { + taskRegistrar.addTriggerTask(() -> process(), + triggerContext -> { + ScheduledRequest scheduledRequest = new ScheduledRequest(); + scheduledRequest.setCronName("ScheduledDeletion"); + ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest); + String cron = scheduledEntity.getCron(); + if (cron.isEmpty()) { + log.error("cron is null"); + } + return new CronTrigger(cron).nextExecutionTime(triggerContext); + }); + } + + private void process() { + log.info("开始清理 30 天前的历史数据"); + //删除同步任务 + log.info("开始删除同步任务历史记录"); + basicExportService.deleteByTime(); + //删除下载记录 + log.info("开始删除下载记录"); + basicDownloadService.deleteByTime(); + //删除第三方数据 + log.info("开始删除第三方数据"); + thrCorpExportLogService.deleteByTime(); + thrCorpImportDetailService.deleteByTime(); + thrCorpImportLogService.deleteByTime(); + thrImportLogService.deleteByTime(); + thrOrderDetailService.deleteByTime(); + thrOrderExportLogService.deleteByTime(); + thrOrderImportDetailService.deleteByTime(); + thrOrderImportLogService.deleteByTime(); + thrProductsImportLogService.deleteByTime(); + thrProductsExportLogService.deleteByTime(); + thrProductsImportDetailService.deleteByTime(); + log.info("历史数据清理完成"); + } + + +} diff --git a/api-admin/src/main/resources/mybatis/mapper/basic/BasicDownloadDao.xml b/api-admin/src/main/resources/mybatis/mapper/basic/BasicDownloadDao.xml index 4c66913a..e666d6e2 100644 --- a/api-admin/src/main/resources/mybatis/mapper/basic/BasicDownloadDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/basic/BasicDownloadDao.xml @@ -69,4 +69,8 @@ WHERE id = #{id} + + Delete From basic_download_status + where date(startTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/basic/BasicExportDao.xml b/api-admin/src/main/resources/mybatis/mapper/basic/BasicExportDao.xml index 77df727b..5770f17b 100644 --- a/api-admin/src/main/resources/mybatis/mapper/basic/BasicExportDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/basic/BasicExportDao.xml @@ -67,4 +67,8 @@ WHERE id = #{id} + + Delete From basic_export_status + where date(startTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpExportLogDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpExportLogDao.xml index 4e45e881..72113a4b 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpExportLogDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpExportLogDao.xml @@ -53,4 +53,8 @@ WHERE genKey = #{genKey} + + Delete From thr_corp_export_log + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportDetailDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportDetailDao.xml index 597678f0..df3fd773 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportDetailDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportDetailDao.xml @@ -89,4 +89,8 @@ WHERE id = #{id} + + Delete From thr_corp_import_detail + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportLogDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportLogDao.xml index 85afe623..20beb4b1 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportLogDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportLogDao.xml @@ -55,4 +55,8 @@ WHERE genKey = #{genKey} + + Delete From thr_corp_import_log + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrImportLogDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrImportLogDao.xml index 66b8bc69..9f090471 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrImportLogDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrImportLogDao.xml @@ -59,4 +59,8 @@ WHERE genKey = #{genKey} + + Delete From thr_import_log + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderDetailDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderDetailDao.xml index 525bce26..9a3c80ac 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderDetailDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderDetailDao.xml @@ -126,4 +126,8 @@ FROM thr_order_detail + + Delete From thr_order_detail + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderExportLogDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderExportLogDao.xml index 41c06c0a..955ca015 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderExportLogDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderExportLogDao.xml @@ -50,4 +50,8 @@ WHERE genKey = #{genKey} + + Delete From thr_order_export_log + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportDetailDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportDetailDao.xml index a3331b2f..6a4e4f8b 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportDetailDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportDetailDao.xml @@ -90,4 +90,8 @@ WHERE id = #{id} + + Delete From thr_order_import_log + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportLogDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportLogDao.xml index d06df015..f0be8009 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportLogDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportLogDao.xml @@ -54,4 +54,8 @@ WHERE genKey = #{genKey} + + Delete From thr_order_import_log + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsExportLogDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsExportLogDao.xml index 2213c2e0..fc74a051 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsExportLogDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsExportLogDao.xml @@ -53,4 +53,8 @@ WHERE genKey = #{genKey} + + Delete From thr_products_export_log + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportDetailDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportDetailDao.xml index e73a9eaa..70ad98bf 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportDetailDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportDetailDao.xml @@ -102,4 +102,8 @@ WHERE id = #{id} + + Delete From thr_products_import_detail + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportLogDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportLogDao.xml index 7a30ae16..09997ca1 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportLogDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportLogDao.xml @@ -54,4 +54,8 @@ WHERE genKey = #{genKey} + + Delete From thr_porducts_import_log + where date(updateTime) <= date(DATE_SUB(NOW(),INTERVAL 30 day)) + \ No newline at end of file diff --git a/api-admin/src/main/resources/schemas/schema_v2.1.sql b/api-admin/src/main/resources/schemas/schema_v2.1.sql index 8070d1bd..873aa2dd 100644 --- a/api-admin/src/main/resources/schemas/schema_v2.1.sql +++ b/api-admin/src/main/resources/schemas/schema_v2.1.sql @@ -7,5 +7,13 @@ CALL Pro_Temp_ColumnWork ('io_order','wzUploadResult','varchar(255) ', 1); CALL Pro_Temp_ColumnWork ('stock_order','noInvOut','tinyint', 1); +-- 新增数据 +INSERT ignore INTO sys_scheduled(id, cronName, cron, customerId, remark) +VALUES + (16, 'ScheduledDeletion', '0 0 2 1/1 * ? ', NULL, '删除30天数据'); + +INSERT ignore INTO system_param_config ( id, parentId, paramName, paramKey, paramValue, paramStatus, paramType, paramExplain ) +VALUES + ( 20009, 0, '删除30天数据', 'ScheduledDeletion', '1', 1, 0, '1:是，0：否' ); -- 创建表时必须 create table if not exists 表名 \ No newline at end of file