diff --git a/xhpc-modules/xhpc-log/src/main/java/com/xhpc/XhpcLogApplication.java b/xhpc-modules/xhpc-log/src/main/java/com/xhpc/XhpcLogApplication.java index 2275b657..1207b609 100644 --- a/xhpc-modules/xhpc-log/src/main/java/com/xhpc/XhpcLogApplication.java +++ b/xhpc-modules/xhpc-log/src/main/java/com/xhpc/XhpcLogApplication.java @@ -6,8 +6,10 @@ import org.mybatis.spring.annotation.MapperScan; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; +import org.springframework.scheduling.annotation.EnableScheduling; +@EnableScheduling @EnableCustomConfig @SpringBootApplication @EnableRyFeignClients diff --git a/xhpc-modules/xhpc-log/src/main/java/com/xhpc/log/mapper/XhpcDeviceMessageMapper.java b/xhpc-modules/xhpc-log/src/main/java/com/xhpc/log/mapper/XhpcDeviceMessageMapper.java index c9f267ad..c68605d3 100644 --- a/xhpc-modules/xhpc-log/src/main/java/com/xhpc/log/mapper/XhpcDeviceMessageMapper.java +++ b/xhpc-modules/xhpc-log/src/main/java/com/xhpc/log/mapper/XhpcDeviceMessageMapper.java @@ -24,4 +24,7 @@ public interface XhpcDeviceMessageMapper { List> getOrderMessageByParams(@Param("params")Map params); + + + int deleteMessageByDate(@Param("date")String date); } diff --git a/xhpc-modules/xhpc-log/src/main/java/com/xhpc/log/task/AutoClearDataTask.java b/xhpc-modules/xhpc-log/src/main/java/com/xhpc/log/task/AutoClearDataTask.java new file mode 100644 index 00000000..c8d16121 --- /dev/null +++ b/xhpc-modules/xhpc-log/src/main/java/com/xhpc/log/task/AutoClearDataTask.java @@ -0,0 +1,29 @@ +package com.xhpc.log.task; + + +import com.xhpc.common.util.DateUtil; +import com.xhpc.log.mapper.XhpcDeviceMessageMapper; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.Date; + +@Component +public class AutoClearDataTask { + + + @Resource + XhpcDeviceMessageMapper messageMapper; + + /** + * 清理一个月前的数据 + */ + @Scheduled(cron = "0 0 5 * * ?") + private void autoClearDeviceMessageData(){ + + String date = DateUtil.date2String(DateUtil.addDay(new Date(), -30), "yyyy-MM-dd"); + messageMapper.deleteMessageByDate(date); + + } +} diff --git a/xhpc-modules/xhpc-log/src/main/resources/mapper/XhpcDeviceMessageMapper.xml b/xhpc-modules/xhpc-log/src/main/resources/mapper/XhpcDeviceMessageMapper.xml index 7bb54eae..0c61affd 100644 --- a/xhpc-modules/xhpc-log/src/main/resources/mapper/XhpcDeviceMessageMapper.xml +++ b/xhpc-modules/xhpc-log/src/main/resources/mapper/XhpcDeviceMessageMapper.xml @@ -3,6 +3,12 @@ "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> + + + delete from xhpc_device_message where create_time create_time #{date} + + +