From 9a5d2bce56af2ae03104c0c2b5da5fbccdde86f2 Mon Sep 17 00:00:00 2001
From: panshuling321 <panshuling321@163.com>
Date: Tue, 28 Dec 2021 17:23:15 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=AE=9A=E6=97=B6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=EF=BC=8C=E6=AF=8F=E5=A4=A9=E5=87=8C=E6=99=A8=E4=BA=94?=
 =?UTF-8?q?=E7=82=B9=E6=B8=85=E7=90=8690=E5=A4=A9=E5=89=8D=E7=9A=84?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/xhpc/mapper/XhpcMessageMapper.java    |  4 +++
 .../com/xhpc/pp/server/MessageCLeanTask.java  | 29 +++++++++++++++++++
 .../resources/mapper/XhpcMessageMapper.xml    |  5 ++++
 3 files changed, 38 insertions(+)
 create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/MessageCLeanTask.java

diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/mapper/XhpcMessageMapper.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/mapper/XhpcMessageMapper.java
index a19c7938..0537b6c9 100644
--- a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/mapper/XhpcMessageMapper.java
+++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/mapper/XhpcMessageMapper.java
@@ -13,4 +13,8 @@ import org.apache.ibatis.annotations.Mapper;
 public interface XhpcMessageMapper {
 
     int insertItemsBy(XhpcMessage xhpcMessage);
+
+//    void deleteByLastThreeMonth(String expireDate);
+
+    void deleteByLastThreeMonth(String expireDate);
 }
diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/MessageCLeanTask.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/MessageCLeanTask.java
new file mode 100644
index 00000000..9110b6ef
--- /dev/null
+++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/MessageCLeanTask.java
@@ -0,0 +1,29 @@
+package com.xhpc.pp.server;
+
+
+import cn.hutool.core.convert.Convert;
+import com.xhpc.common.util.DateUtil;
+import com.xhpc.mapper.XhpcMessageMapper;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.Date;
+
+@Component
+public class MessageCLeanTask {
+
+    @Resource
+    XhpcMessageMapper messageMapper;
+
+    /**
+     * 每天定时清理message表三个月前的数据
+     */
+    @Scheduled(cron = "0 0 05 1/1 * ?")
+    private void run(){
+
+        String expireDate = DateUtil.date2String(DateUtil.addDay(new Date(), -90), DateUtil.DATE_FORMAT_DATE_TIME) ;
+        messageMapper.deleteByLastThreeMonth(expireDate);
+
+    }
+}
diff --git a/xhpc-modules/xhpc-power-pile/src/main/resources/mapper/XhpcMessageMapper.xml b/xhpc-modules/xhpc-power-pile/src/main/resources/mapper/XhpcMessageMapper.xml
index 5bb1d30e..10048eb6 100644
--- a/xhpc-modules/xhpc-power-pile/src/main/resources/mapper/XhpcMessageMapper.xml
+++ b/xhpc-modules/xhpc-power-pile/src/main/resources/mapper/XhpcMessageMapper.xml
@@ -36,4 +36,9 @@
         sysdate()
         )
     </insert>
+
+    <delete id="deleteByLastThreeMonth">
+        delete from xhpc_message
+        where create_time <![CDATA[ <= ]]> #{expireDate};
+    </delete>
 </mapper>