定时删除同步任务、下载记录和第三方数据的30天之前数据

api-admin/src/main/java/com/glxp/sale/admin/controller/info/CompanyController.java

@@ -45,6 +45,8 @@ public class CompanyController {
     @Resource
     CustomerContactService customerContactService;
     @Resource
+
+
     private CompanyUpdateLogService companyUpdateLogService;
 
     @AuthRuleAnnotation("")

api-admin/src/main/java/com/glxp/sale/admin/dao/basic/BasicDownloadDao.java

@@ -16,6 +16,7 @@ public interface BasicDownloadDao {
     boolean insertDownloadStatus(BasicDownloadStatusEntity basicDownloadStatusEntity);
 
     boolean deleteById(@Param("id") String id);
+    boolean deleteByTime();
 
     boolean updateDownloadStatus(BasicDownloadStatusEntity basicDownloadStatusEntity);
 

api-admin/src/main/java/com/glxp/sale/admin/dao/basic/BasicExportDao.java

@@ -5,6 +5,7 @@ import com.glxp.sale.admin.req.basic.BasicExportStatusRequest;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.Date;
 import java.util.List;
 
 @Mapper
@@ -16,6 +17,7 @@ public interface BasicExportDao {
     boolean insertExportStatus(BasicExportStatusEntity ioOrderStatusEntity);
 
     boolean deleteById(@Param("id") String id);
+    boolean deleteByTime();
 
     boolean updateExportStatus(BasicExportStatusEntity warehouseEntity);
 

api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrCorpExportLogDao.java

@@ -18,4 +18,5 @@ public interface ThrCorpExportLogDao {
     boolean updateThrCorpExportLog(ThrCorpExportLogEntity thrCorpExportLogEntity);
 
     boolean deleteById(@Param("id") String id);
+    boolean deleteByTime();
 }

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();
 }

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();
+
 }

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();
+
 
 }

api-admin/src/main/java/com/glxp/sale/admin/dao/thrsys/ThrOrderDetailDao.java

@@ -26,4 +26,6 @@ public interface ThrOrderDetailDao {
 
     boolean deleteAll();
 
+    boolean deleteByTime();
+
 }

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();
 }

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();
 }

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();
+
 }

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();
 }

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);
 
 }

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();
 }

api-admin/src/main/java/com/glxp/sale/admin/service/basic/BasicDownloadService.java

@@ -15,6 +15,7 @@ public interface BasicDownloadService {
     boolean insertDownloadStatus(BasicDownloadStatusEntity basicDownloadStatusEntity);
 
     boolean deleteById(String id);
+    boolean deleteByTime();
 
     boolean updateDownloadStatus(BasicDownloadStatusEntity basicDownloadStatusEntity);
 }

api-admin/src/main/java/com/glxp/sale/admin/service/basic/BasicExportService.java

@@ -4,6 +4,7 @@ package com.glxp.sale.admin.service.basic;
 import com.glxp.sale.admin.entity.basic.BasicExportStatusEntity;
 import com.glxp.sale.admin.req.basic.BasicExportStatusRequest;
 
+import java.util.Date;
 import java.util.List;
 
 public interface BasicExportService {
@@ -17,5 +18,7 @@ public interface BasicExportService {
 
     boolean deleteById(String id);
 
+    boolean deleteByTime();
+
     boolean updateExportStatus(BasicExportStatusEntity warehouseEntity);
 }

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);

api-admin/src/main/java/com/glxp/sale/admin/service/basic/impl/BasicExportServiceImpl.java

@@ -10,6 +10,7 @@ import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import java.util.Collections;
+import java.util.Date;
 import java.util.List;
 
 @Service
@@ -52,6 +53,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);

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpExportLogService.java

@@ -19,5 +19,6 @@ public interface ThrCorpExportLogService {
     boolean updateThrCorpExportLog(ThrCorpExportLogEntity thrCorpExportLogEntity);
 
     boolean deleteById(String id);
+    boolean deleteByTime();
 
 }

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();
+
 }

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrCorpImportLogService.java

@@ -17,4 +17,5 @@ public interface ThrCorpImportLogService {
 
     boolean deleteById(String id);
 
+    boolean deleteByTime();
 }

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);
 }

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderDetailService.java

@@ -23,4 +23,5 @@ public interface ThrOrderDetailService {
 
     boolean deleteAll();
 
+    boolean deleteByTime();
 }

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();
 }

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderImportDetailService.java

@@ -17,6 +17,7 @@ public interface ThrOrderImportDetailService {
     boolean insertOrderImportDetails(List<ThrOrderImportDetailEntity> thrOrderImportDetailEntities);
 
     boolean deleteById(String id);
+    boolean deleteByTime();
 
     boolean deleteByGenkey(String genKey);
 }

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrOrderImportLogService.java

@@ -16,5 +16,6 @@ public interface ThrOrderImportLogService {
     boolean updateImportLog(ThrOrderImportLogEntity thrOrderImportLogEntity);
 
     boolean deleteById(String id);
+    boolean deleteByTime();
 
 }

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();
+
 }

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/ThrProductsImportDetailService.java

@@ -17,6 +17,7 @@ public interface ThrProductsImportDetailService {
     boolean insertProductsDetailImports(List<ThrProductsImportDetailEntity> thrOrderImportDetailEntities);
 
     boolean deleteById(String id);
+    boolean deleteByTime();
 
     boolean deleteByGenkey(String genKey);
 

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);
 }

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpExportLogServiceImpl.java

@@ -54,4 +54,9 @@ public class ThrCorpExportLogServiceImpl implements ThrCorpExportLogService {
     public boolean deleteById(String id) {
         return thrCorpExportLogDao.deleteById(id);
     }
+
+    @Override
+    public boolean deleteByTime() {
+        return thrCorpExportLogDao.deleteByTime();
+    }
 }

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();
+    }
 }

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrCorpImportLogServiceImpl.java

@@ -55,4 +55,9 @@ public class ThrCorpImportLogServiceImpl implements ThrCorpImportLogService {
     public boolean deleteById(String id) {
         return thrCorpImportLogDao.deleteById(id);
     }
+
+    @Override
+    public boolean deleteByTime() {
+        return thrCorpImportLogDao.deleteByTime();
+    }
 }

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();

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();
+    }
 }

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderExportLogServiceImpl.java

@@ -55,4 +55,9 @@ public class ThrOrderExportLogServiceImpl implements ThrOrderExportLogService {
     public boolean deleteById(String id) {
         return thrOrderExportLogDao.deleteById(id);
     }
+
+    @Override
+    public boolean deleteByTime() {
+        return thrOrderExportLogDao.deleteByTime();
+    }
 }

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderImportDetailServiceImpl.java

@@ -50,6 +50,11 @@ 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);

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrOrderImportLogServiceImpl.java

@@ -56,4 +56,9 @@ public class ThrOrderImportLogServiceImpl implements ThrOrderImportLogService {
     public boolean deleteById(String id) {
         return thrOrderImportLogDao.deleteById(id);
     }
+
+    @Override
+    public boolean deleteByTime() {
+        return thrOrderImportLogDao.deleteByTime();
+    }
 }

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();
+    }
 }

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsImportDetailServiceImpl.java

@@ -50,6 +50,11 @@ public class ThrProductsImportDetailServiceImpl implements ThrProductsImportDeta
         return thrProductsImportDetailDao.deleteById(id);
     }
 
+    @Override
+    public boolean deleteByTime() {
+        return thrProductsImportDetailDao.deleteByTime();
+    }
+
     @Override
     public boolean deleteByGenkey(String genKey) {
         return thrProductsImportDetailDao.deleteByGenkey(genKey);

api-admin/src/main/java/com/glxp/sale/admin/service/thrsys/impl/ThrProductsImportLogServiceImpl.java

@@ -44,6 +44,11 @@ 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();

api-admin/src/main/resources/application-dev.properties

@@ -1,9 +1,9 @@
 # \u751F\u4EA7\u73AF\u5883
-server.port=9906
+server.port=9996
 spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
-spring.datasource.jdbc-url=jdbc:mysql://192.168.0.55:3306/spms?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
+spring.datasource.jdbc-url=jdbc:mysql://127.0.0.1:3306/spms?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
 spring.datasource.username=root
-spring.datasource.password=123456
+spring.datasource.password=root
 spring.datasource.hikari.connection-timeout=60000
 spring.datasource.hikari.maximum-pool-size=60
 spring.datasource.hikari.minimum-idle=10

api-admin/src/main/resources/mybatis/mapper/basic/BasicDownloadDao.xml

@@ -67,5 +67,9 @@
         FROM basic_download_status
         WHERE id = #{id}
     </delete>
+    <delete id="deleteByTime">
+        Delete From basic_download_status
+        where date(startTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
 
 </mapper>

api-admin/src/main/resources/mybatis/mapper/basic/BasicExportDao.xml

@@ -74,5 +74,9 @@
         FROM basic_export_status
         WHERE id = #{id}
     </delete>
+    <delete id="deleteByTime" >
+        Delete From basic_export_status
+         where date(startTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
 
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpExportLogDao.xml

@@ -50,4 +50,9 @@
         WHERE genKey = #{genKey}
     </update>
 
+    <delete id="deleteByTime">
+        Delete From thr_corp_export_log
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
+
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportDetailDao.xml

@@ -89,4 +89,9 @@
         WHERE id = #{id}
     </update>
 
+    <delete id="deleteByTime">
+        Delete From thr_corp_import_detail
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
+
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrCorpImportLogDao.xml

@@ -54,4 +54,9 @@
         WHERE genKey = #{genKey}
     </update>
 
+    <delete id="deleteByTime">
+        Delete From thr_corp_import_log
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
+
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrImportLogDao.xml

@@ -59,4 +59,9 @@
         WHERE genKey = #{genKey}
     </update>
 
+    <delete id="deleteByTime">
+        Delete From thr_import_log
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
+
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderDetailDao.xml

@@ -127,4 +127,9 @@
         FROM thr_order_detail
     </delete>
 
+    <delete id="deleteByTime">
+        Delete From thr_order_detail
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
+
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderExportLogDao.xml

@@ -50,4 +50,10 @@
         WHERE genKey = #{genKey}
     </update>
 
+    <delete id="deleteByTime">
+        Delete From thr_order_export_log
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+
+    </delete>
+
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportDetailDao.xml

@@ -91,4 +91,9 @@
         WHERE id = #{id}
     </update>
 
+    <delete id="deleteByTime">
+        Delete From thr_order_import_detail
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
+
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrOrderImportLogDao.xml

@@ -54,4 +54,9 @@
         WHERE genKey = #{genKey}
     </update>
 
+    <delete id="deleteByTime">
+        Delete From thr_order_import_log
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
+
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsExportLogDao.xml

@@ -50,4 +50,9 @@
         WHERE genKey = #{genKey}
     </update>
 
+    <delete id="deleteByTime">
+        Delete From thr_products_export_log
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
+
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportDetailDao.xml

@@ -99,5 +99,9 @@
         </trim>
         WHERE id = #{id}
     </update>
+    <delete id="deleteByTime">
+        Delete From thr_products_import_detail
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
 
 </mapper>

api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsImportLogDao.xml

@@ -53,5 +53,9 @@
         </set>
         WHERE genKey = #{genKey}
     </update>
+    <delete id="deleteByTime">
+        Delete From thr_porducts_import_log
+        where date(updateTime) &lt;= date(DATE_SUB(NOW(),INTERVAL 30 day))
+    </delete>
 
 </mapper>