更新定时删除任务

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

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

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

@@ -19,6 +19,8 @@ public interface BasicExportDao {
 
     boolean deleteById(@Param("id") String id);
 
+    boolean deleteByTime();
+
     boolean updateExportStatus(BasicExportStatusEntity warehouseEntity);
 
 

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

@@ -19,5 +19,7 @@ public interface ThrCorpExportLogDao {
 
     boolean deleteById(@Param("id") String id);
 
+    boolean deleteByTime();
+
     String selectFilePathById(@Param("id") String id);
 }

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

api-admin/src/main/java/com/glxp/api/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/api/admin/dao/thrsys/ThrImportLogDao.java

@@ -18,5 +18,7 @@ public interface ThrImportLogDao {
 
     boolean deleteById(@Param("id") String id);
 
+    boolean deleteByTime();
+
 
 }

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

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

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

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

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

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

api-admin/src/main/java/com/glxp/api/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/api/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/api/admin/service/basic/BasicDownloadService.java

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

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

@@ -17,5 +17,7 @@ public interface BasicExportService {
 
     boolean deleteById(String id);
 
+    boolean deleteByTime();
+
     boolean updateExportStatus(BasicExportStatusEntity warehouseEntity);
 }

api-admin/src/main/java/com/glxp/api/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/api/admin/service/basic/impl/BasicExportServiceImpl.java

@@ -54,6 +54,10 @@ 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/api/admin/service/thrsys/ThrCorpExportLogService.java

@@ -20,4 +20,6 @@ public interface ThrCorpExportLogService {
 
     boolean deleteById(String id);
 
+    boolean deleteByTime();
+
 }

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

@@ -22,4 +22,6 @@ public interface ThrCorpImportDetailService {
 
     boolean deleteByGenkey( String genKey);
 
+    boolean deleteByTime();
+
 }

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

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

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

@@ -16,5 +16,7 @@ public interface ThrImportLogService {
 
     boolean deleteById(String id);
 
+    boolean deleteByTime();
+
     ThrImportLogEntity selectByGenKey(String genKey);
 }

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

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

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

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

@@ -17,5 +17,7 @@ public interface ThrOrderImportDetailService {
 
     boolean deleteById(String id);
 
+    boolean deleteByTime();
+
     boolean deleteByGenkey(String genKey);
 }

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

@@ -16,4 +16,6 @@ public interface ThrOrderImportLogService {
 
     boolean deleteById(String id);
 
+    boolean deleteByTime();
+
 }

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

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

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

@@ -16,6 +16,8 @@ public interface ThrProductsImportDetailService {
 
     boolean deleteById(String id);
 
+    boolean deleteByTime();
+
     boolean deleteByGenkey(String genKey);
 
 }

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

@@ -14,5 +14,7 @@ public interface ThrProductsImportLogService {
 
     boolean deleteById(String id);
 
+    boolean deleteByTime();
+
     ThrProductsImportLogEntity selectByGenKey(String genKey);
 }

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

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

api-admin/src/main/java/com/glxp/api/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/api/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();
+    }
+
 }

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

@@ -45,6 +45,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/api/admin/service/thrsys/impl/ThrOrderDetailServiceImpl.java

@@ -60,4 +60,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/api/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/api/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/api/admin/service/thrsys/impl/ThrOrderImportLogServiceImpl.java

@@ -57,4 +57,10 @@ 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/api/admin/service/thrsys/impl/ThrProductsExportLogServiceImpl.java

@@ -61,4 +61,9 @@ public class ThrProductsExportLogServiceImpl implements ThrProductsExportLogServ
         }
         return thrProductsExportLogDao.deleteById(id);
     }
+
+    @Override
+    public boolean deleteByTime() {
+        return thrProductsExportLogDao.deleteByTime();
+    }
 }

api-admin/src/main/java/com/glxp/api/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/api/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/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("历史数据清理完成");
+    }
+
+
+}

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

@@ -1,8 +1,8 @@
 server.port=9991
 spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
-spring.datasource.jdbc-url=jdbc:mysql://192.168.0.66:3364/udiwms?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/udiwms?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
 spring.datasource.username=root
-spring.datasource.password=Glxp@6066
+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

@@ -68,5 +68,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

@@ -71,4 +71,9 @@
         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

@@ -53,4 +53,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

@@ -55,4 +55,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

@@ -126,4 +126,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

@@ -90,4 +90,10 @@
         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

@@ -53,4 +53,10 @@
         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

@@ -102,4 +102,9 @@
         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

@@ -54,4 +54,10 @@
         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>

api-admin/src/main/resources/schemas/schema_v2.1.sql

@@ -4,6 +4,14 @@ CALL Pro_Temp_ColumnWork ('basic_export_status','receiveStatus','varchar(255) ',
 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 表名