From abf170ece45b403f3d4e350fb1f1498772618795 Mon Sep 17 00:00:00 2001 From: wangwei <1610949092@qq.com> Date: Thu, 15 Dec 2022 15:01:32 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E5=AE=9A=E6=97=B6=E5=88=A0?= =?UTF-8?q?=E9=99=A4=E5=90=8C=E6=AD=A5=E4=BB=BB=E5=8A=A1=E3=80=81=E4=B8=8B?= =?UTF-8?q?=E8=BD=BD=E8=AE=B0=E5=BD=95=E5=92=8C=E7=AC=AC=E4=B8=89=E6=96=B9?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E7=9A=8430=E5=A4=A9=E4=B9=8B=E5=89=8D?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=92=8Csql?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../admin/dao/basic/BasicDownloadDao.java | 2 + .../sale/admin/dao/basic/BasicExportDao.java | 2 + .../admin/dao/thrsys/ThrCorpExportLogDao.java | 2 + .../dao/thrsys/ThrCorpImportDetailDao.java | 2 + .../admin/dao/thrsys/ThrCorpImportLogDao.java | 2 + .../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 | 2 + .../dao/thrsys/ThrProductsImportLogDao.java | 2 + .../service/basic/BasicDownloadService.java | 2 + .../service/basic/BasicExportService.java | 2 + .../basic/impl/BasicDownloadServiceImpl.java | 5 + .../basic/impl/BasicExportServiceImpl.java | 5 + .../thrsys/ThrCorpExportLogService.java | 2 + .../thrsys/ThrCorpImportDetailService.java | 2 + .../thrsys/ThrCorpImportLogService.java | 2 + .../service/thrsys/ThrImportLogService.java | 2 + .../service/thrsys/ThrOrderDetailService.java | 2 + .../thrsys/ThrOrderExportLogService.java | 2 + .../thrsys/ThrOrderImportDetailService.java | 2 + .../thrsys/ThrOrderImportLogService.java | 2 + .../thrsys/ThrProductsExportLogService.java | 2 + .../ThrProductsImportDetailService.java | 2 + .../thrsys/ThrProductsImportLogService.java | 2 + .../impl/ThrCorpExportLogServiceImpl.java | 6 ++ .../impl/ThrCorpImportDetailServiceImpl.java | 5 + .../impl/ThrCorpImportLogServiceImpl.java | 6 ++ .../thrsys/impl/ThrImportLogServiceImpl.java | 5 + .../impl/ThrOrderDetailServiceImpl.java | 5 + .../impl/ThrOrderExportLogServiceImpl.java | 6 ++ .../impl/ThrOrderImportDetailServiceImpl.java | 4 + .../impl/ThrOrderImportLogServiceImpl.java | 6 ++ .../impl/ThrProductsExportLogServiceImpl.java | 5 + .../ThrProductsImportDetailServiceImpl.java | 4 + .../impl/ThrProductsImportLogServiceImpl.java | 4 + .../glxp/sale/admin/thread/CleanDataTask.java | 96 +++++++++++++++++++ .../mybatis/mapper/basic/BasicDownloadDao.xml | 5 + .../mybatis/mapper/basic/BasicExportDao.xml | 5 + .../mapper/thrsys/ThrCorpExportLogDao.xml | 4 + .../mapper/thrsys/ThrCorpImportDetailDao.xml | 5 + .../mapper/thrsys/ThrCorpImportLogDao.xml | 5 + .../mybatis/mapper/thrsys/ThrImportLogDao.xml | 6 ++ .../mapper/thrsys/ThrOrderDetailDao.xml | 5 + .../mapper/thrsys/ThrOrderExportLogDao.xml | 7 ++ .../mapper/thrsys/ThrOrderImportDetailDao.xml | 5 + .../mapper/thrsys/ThrOrderImportLogDao.xml | 5 + .../mapper/thrsys/ThrProductsExportLogDao.xml | 5 + .../thrsys/ThrProductsImportDetailDao.xml | 5 + .../mapper/thrsys/ThrProductsImportLogDao.xml | 5 + .../main/resources/schemas/schema_v2.1.sql | 7 ++ 54 files changed, 288 insertions(+) create mode 100644 api-admin/src/main/java/com/glxp/sale/admin/thread/CleanDataTask.java diff --git a/api-admin/src/main/java/com/glxp/sale/admin/dao/basic/BasicDownloadDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/basic/BasicDownloadDao.java index 7966e7a..e517ccc 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/basic/BasicDownloadDao.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/dao/basic/BasicDownloadDao.java @@ -17,6 +17,8 @@ public interface BasicDownloadDao { boolean deleteById(@Param("id") String id); + boolean deleteByTime(); + boolean updateDownloadStatus(BasicDownloadStatusEntity basicDownloadStatusEntity); diff --git a/api-admin/src/main/java/com/glxp/sale/admin/dao/basic/BasicExportDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/basic/BasicExportDao.java index 053c91f..4b9242e 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/basic/BasicExportDao.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/dao/basic/BasicExportDao.java @@ -17,6 +17,8 @@ public interface BasicExportDao { boolean deleteById(@Param("id") String id); + boolean deleteByTime(); + boolean updateExportStatus(BasicExportStatusEntity warehouseEntity); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpExportLogDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpExportLogDao.java index a835d1d..79034ea 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpExportLogDao.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpExportLogDao.java @@ -18,4 +18,6 @@ public interface ThrCorpExportLogDao { boolean updateThrCorpExportLog(ThrCorpExportLogEntity thrCorpExportLogEntity); boolean deleteById(@Param("id") String id); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpImportDetailDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpImportDetailDao.java index e5481be..5313022 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpImportDetailDao.java +++ b/api-admin/src/main/java/com/glxp/sale/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/sale/admin/dao/thrsys/ThrCorpImportLogDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpImportLogDao.java index f824e8a..d42176e 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpImportLogDao.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpImportLogDao.java @@ -18,4 +18,6 @@ public interface ThrCorpImportLogDao { boolean deleteById(@Param("id") String id); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrImportLogDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrImportLogDao.java index d6bc4b3..5d60fda 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrImportLogDao.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrImportLogDao.java @@ -19,5 +19,7 @@ public interface ThrImportLogDao { boolean deleteById(@Param("id") String id); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrOrderDetailDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrOrderDetailDao.java index 175d79e..1fccc02 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrOrderDetailDao.java +++ b/api-admin/src/main/java/com/glxp/sale/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/sale/admin/dao/thrsys/ThrOrderExportLogDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrOrderExportLogDao.java index 8dcf594..bd79c05 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrOrderExportLogDao.java +++ b/api-admin/src/main/java/com/glxp/sale/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/sale/admin/dao/thrsys/ThrOrderImportDetailDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrOrderImportDetailDao.java index 63bb19e..12cad40 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrOrderImportDetailDao.java +++ b/api-admin/src/main/java/com/glxp/sale/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/sale/admin/dao/thrsys/ThrOrderImportLogDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrOrderImportLogDao.java index 98a1fd5..4a2571c 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrOrderImportLogDao.java +++ b/api-admin/src/main/java/com/glxp/sale/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/sale/admin/dao/thrsys/ThrProductsExportLogDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsExportLogDao.java index 63a9781..3104a1e 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsExportLogDao.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsExportLogDao.java @@ -17,4 +17,6 @@ public interface ThrProductsExportLogDao { boolean updateThrProductsExportLog(ThrProductsExportLogEntity thrProductsExportLogEntity); boolean deleteById(@Param("id") String id); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsImportDetailDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsImportDetailDao.java index 3f2ccee..3e7a6e6 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsImportDetailDao.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsImportDetailDao.java @@ -21,6 +21,8 @@ public interface ThrProductsImportDetailDao { boolean deleteById(@Param("id") String id); + boolean deleteByTime(); + boolean deleteByGenkey(@Param("genKey") String genKey); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsImportLogDao.java b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsImportLogDao.java index e973b96..50417e1 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsImportLogDao.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrProductsImportLogDao.java @@ -16,4 +16,6 @@ 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/sale/admin/service/basic/BasicDownloadService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/basic/BasicDownloadService.java index b9c9d67..2baf5d1 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/basic/BasicDownloadService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/basic/BasicDownloadService.java @@ -16,5 +16,7 @@ public interface BasicDownloadService { boolean deleteById(String id); + boolean deleteByTime(); + boolean updateDownloadStatus(BasicDownloadStatusEntity basicDownloadStatusEntity); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/basic/BasicExportService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/basic/BasicExportService.java index a89cf70..9830616 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/basic/BasicExportService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/basic/BasicExportService.java @@ -17,5 +17,7 @@ public interface BasicExportService { boolean deleteById(String id); + boolean deleteByTime(); + boolean updateExportStatus(BasicExportStatusEntity warehouseEntity); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/basic/impl/BasicDownloadServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/basic/impl/BasicDownloadServiceImpl.java index 437afc3..03ff097 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/basic/impl/BasicDownloadServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/basic/impl/BasicDownloadServiceImpl.java @@ -52,6 +52,11 @@ public class BasicDownloadServiceImpl implements BasicDownloadService { return basicDownloadDao.deleteById(id); } + + @Override + public boolean deleteByTime() { + return basicDownloadDao.deleteByTime(); + } @Override public boolean updateDownloadStatus(BasicDownloadStatusEntity basicDownloadStatusEntity) { return basicDownloadDao.updateDownloadStatus(basicDownloadStatusEntity); diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/basic/impl/BasicExportServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/basic/impl/BasicExportServiceImpl.java index 1a98249..656256c 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/basic/impl/BasicExportServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/basic/impl/BasicExportServiceImpl.java @@ -52,6 +52,11 @@ public class BasicExportServiceImpl implements BasicExportService { return basicExportDao.deleteById(id); } + @Override + public boolean deleteByTime() { + return basicExportDao.deleteByTime(); + } + @Override public boolean updateExportStatus(BasicExportStatusEntity basicExportStatusEntity) { return basicExportDao.updateExportStatus(basicExportStatusEntity); diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpExportLogService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpExportLogService.java index 3301334..4b3b7d0 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpExportLogService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpExportLogService.java @@ -20,4 +20,6 @@ public interface ThrCorpExportLogService { boolean deleteById(String id); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpImportDetailService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpImportDetailService.java index 6f3fca0..cab0697 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpImportDetailService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpImportDetailService.java @@ -21,4 +21,6 @@ public interface ThrCorpImportDetailService { boolean deleteByGenkey( String genKey); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpImportLogService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpImportLogService.java index e599ed6..e412997 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpImportLogService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpImportLogService.java @@ -17,4 +17,6 @@ public interface ThrCorpImportLogService { boolean deleteById(String id); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrImportLogService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrImportLogService.java index 64075e3..fc59d08 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrImportLogService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrImportLogService.java @@ -17,5 +17,7 @@ public interface ThrImportLogService { boolean deleteById(String id); + boolean deleteByTime(); + ThrImportLogEntity selectByGenKey(String genKey); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderDetailService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderDetailService.java index cc23188..ff6ba0b 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderDetailService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderDetailService.java @@ -23,4 +23,6 @@ public interface ThrOrderDetailService { boolean deleteAll(); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderExportLogService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderExportLogService.java index 4e75961..36c8e3c 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderExportLogService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderExportLogService.java @@ -17,4 +17,6 @@ public interface ThrOrderExportLogService { boolean updateThrOrderExportLog(ThrOrderExportLogEntity thrOrderExportLogEntity); boolean deleteById(String id); + + boolean deleteByTime(); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderImportDetailService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderImportDetailService.java index 7ffb4e4..3f1095d 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderImportDetailService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderImportDetailService.java @@ -18,5 +18,7 @@ public interface ThrOrderImportDetailService { boolean deleteById(String id); + boolean deleteByTime(); + boolean deleteByGenkey(String genKey); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderImportLogService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderImportLogService.java index 8abce42..8baabf0 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderImportLogService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderImportLogService.java @@ -17,4 +17,6 @@ public interface ThrOrderImportLogService { boolean deleteById(String id); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsExportLogService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsExportLogService.java index a5b61c6..0f1e791 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsExportLogService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsExportLogService.java @@ -18,4 +18,6 @@ public interface ThrProductsExportLogService { boolean deleteById(String id); + boolean deleteByTime(); + } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsImportDetailService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsImportDetailService.java index 80a7148..105a333 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsImportDetailService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsImportDetailService.java @@ -18,6 +18,8 @@ public interface ThrProductsImportDetailService { boolean deleteById(String id); + boolean deleteByTime(); + boolean deleteByGenkey(String genKey); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsImportLogService.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsImportLogService.java index b54ce8b..c2df740 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsImportLogService.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsImportLogService.java @@ -15,5 +15,7 @@ public interface ThrProductsImportLogService { boolean deleteById(String id); + boolean deleteByTime(); + ThrProductsImportLogEntity selectByGenKey(String genKey); } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpExportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpExportLogServiceImpl.java index da882b4..a018c1a 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpExportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpExportLogServiceImpl.java @@ -54,4 +54,10 @@ public class ThrCorpExportLogServiceImpl implements ThrCorpExportLogService { public boolean deleteById(String id) { return thrCorpExportLogDao.deleteById(id); } + + @Override + public boolean deleteByTime() { + return thrCorpExportLogDao.deleteByTime(); + } + } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpImportDetailServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpImportDetailServiceImpl.java index cb8114b..82d8166 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpImportDetailServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpImportDetailServiceImpl.java @@ -54,4 +54,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/sale/admin/service/thrsys/impl/ThrCorpImportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpImportLogServiceImpl.java index 037b5c6..485bf3e 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpImportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpImportLogServiceImpl.java @@ -55,4 +55,10 @@ 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/sale/admin/service/thrsys/impl/ThrImportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrImportLogServiceImpl.java index e35d2e6..347c6e6 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrImportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrImportLogServiceImpl.java @@ -47,6 +47,11 @@ public class ThrImportLogServiceImpl implements ThrImportLogService { return thrImportLogDao.deleteById(id); } + @Override + public boolean deleteByTime() { + return thrImportLogDao.deleteByTime(); + } + @Override public ThrImportLogEntity selectByGenKey(String genKey) { FilterUdiIpLogRequest filterUdiIpLogRequest = new FilterUdiIpLogRequest(); diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderDetailServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderDetailServiceImpl.java index 1a6ddb0..436883d 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderDetailServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderDetailServiceImpl.java @@ -59,4 +59,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/sale/admin/service/thrsys/impl/ThrOrderExportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderExportLogServiceImpl.java index 5037670..34f9a4b 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderExportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderExportLogServiceImpl.java @@ -55,4 +55,10 @@ 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/sale/admin/service/thrsys/impl/ThrOrderImportDetailServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderImportDetailServiceImpl.java index b4b2383..3024766 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderImportDetailServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderImportDetailServiceImpl.java @@ -50,6 +50,10 @@ public class ThrOrderImportDetailServiceImpl implements ThrOrderImportDetailServ return thrOrderImportDetailDao.deleteById(id); } + @Override + public boolean deleteByTime() { + return thrOrderImportDetailDao.deleteByTime(); + } @Override public boolean deleteByGenkey(String genKey) { return thrOrderImportDetailDao.deleteByGenkey(genKey); diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderImportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderImportLogServiceImpl.java index 63f4a8e..a38911d 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderImportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderImportLogServiceImpl.java @@ -56,4 +56,10 @@ 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/sale/admin/service/thrsys/impl/ThrProductsExportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsExportLogServiceImpl.java index 54ef7dc..1c8b51a 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsExportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsExportLogServiceImpl.java @@ -54,4 +54,9 @@ public class ThrProductsExportLogServiceImpl implements ThrProductsExportLogServ public boolean deleteById(String id) { return thrProductsExportLogDao.deleteById(id); } + + @Override + public boolean deleteByTime() { + return thrProductsExportLogDao.deleteByTime(); + } } diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsImportDetailServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsImportDetailServiceImpl.java index afe2a87..f9d858a 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsImportDetailServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsImportDetailServiceImpl.java @@ -50,6 +50,10 @@ public class ThrProductsImportDetailServiceImpl implements ThrProductsImportDeta return thrProductsImportDetailDao.deleteById(id); } + public boolean deleteByTime() { + return thrProductsImportDetailDao.deleteByTime(); + } + @Override public boolean deleteByGenkey(String genKey) { return thrProductsImportDetailDao.deleteByGenkey(genKey); diff --git a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsImportLogServiceImpl.java b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsImportLogServiceImpl.java index 2c00690..cee9e4c 100644 --- a/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsImportLogServiceImpl.java +++ b/api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsImportLogServiceImpl.java @@ -44,6 +44,10 @@ public class ThrProductsImportLogServiceImpl implements ThrProductsImportLogServ return thrProductsImportLogDao.deleteById(id); } + @Override + public boolean deleteByTime() { + return thrProductsImportLogDao.deleteByTime(); + } @Override public ThrProductsImportLogEntity selectByGenKey(String genKey) { FilterUdiIpLogRequest filterUdiIpLogRequest = new FilterUdiIpLogRequest(); diff --git a/api-admin/src/main/java/com/glxp/sale/admin/thread/CleanDataTask.java b/api-admin/src/main/java/com/glxp/sale/admin/thread/CleanDataTask.java new file mode 100644 index 0000000..cf12ad0 --- /dev/null +++ b/api-admin/src/main/java/com/glxp/sale/admin/thread/CleanDataTask.java @@ -0,0 +1,96 @@ +package com.glxp.sale.admin.thread; + + +import com.glxp.sale.admin.dao.info.ScheduledDao; +import com.glxp.sale.admin.entity.info.ScheduledEntity; +import com.glxp.sale.admin.req.udid.ScheduledRequest; +import com.glxp.sale.admin.service.basic.BasicDownloadService; +import com.glxp.sale.admin.service.basic.BasicExportService; +import com.glxp.sale.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 3ec7d52..a6f76cd 100644 --- a/api-admin/src/main/resources/mybatis/mapper/basic/BasicDownloadDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/basic/BasicDownloadDao.xml @@ -68,4 +68,9 @@ 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 53d1627..c459bfe 100644 --- a/api-admin/src/main/resources/mybatis/mapper/basic/BasicExportDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/basic/BasicExportDao.xml @@ -74,4 +74,9 @@ 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 6a5e9a2..3ae9728 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpExportLogDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpExportLogDao.xml @@ -49,5 +49,9 @@ 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 42171d2..543b057 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,9 @@ 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 475d0c4..b43ee33 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportLogDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportLogDao.xml @@ -54,4 +54,9 @@ 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 78f3658..8a2708c 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,10 @@ 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 e078341..5eeeb2d 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderDetailDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderDetailDao.xml @@ -127,4 +127,9 @@ 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 3427c7b..2263e0d 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,11 @@ 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 f65c787..43ab7f4 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportDetailDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportDetailDao.xml @@ -91,4 +91,9 @@ WHERE id = #{id} + + Delete From thr_order_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/ThrOrderImportLogDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportLogDao.xml index 13e322b..2bc2076 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,9 @@ 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 1c10725..3e6ee46 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsExportLogDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsExportLogDao.xml @@ -50,4 +50,9 @@ 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 5b19019..9278e68 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportDetailDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportDetailDao.xml @@ -100,4 +100,9 @@ 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 72b0dbd..d046327 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,9 @@ 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 587b80f..21e097e 100644 --- a/api-admin/src/main/resources/schemas/schema_v2.1.sql +++ b/api-admin/src/main/resources/schemas/schema_v2.1.sql @@ -5,5 +5,12 @@ CALL Pro_Temp_ColumnWork ('io_order','wzUploadStatus','varchar(255) ', 1); CALL Pro_Temp_ColumnWork ('io_order','wzUploadResult','varchar(255) ', 1); +INSERT ignore INTO 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