add - 机台日志定时清除

ruoyi-traceability/src/main/java/com/ruoyi/traceability/Task/DeleteMachineLog.java

@@ -0,0 +1,45 @@
+package com.ruoyi.traceability.Task;
+
+import com.alibaba.fastjson.JSONArray;
+import com.ruoyi.common.core.text.Convert;
+import com.ruoyi.common.json.JSONObject;
+import com.ruoyi.traceability.domain.ProLogrecord;
+import com.ruoyi.traceability.service.IProLogrecordService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+/**
+ * 定时清除机台日志-清除两天前的数据
+ */
+@Component("DeleteMachineLog")
+public class DeleteMachineLog {
+
+    @Autowired
+    private IProLogrecordService proLogrecordService;
+
+    public void RunTask(){
+        try {
+            Calendar calendar = Calendar.getInstance();
+            calendar.add(Calendar.DATE,-2);
+
+            List<ProLogrecord> logrecords = proLogrecordService.selectProLogrecordList(new ProLogrecord());
+
+            List<ProLogrecord> collect = logrecords.stream().filter(x -> x.getRecordTime().before(calendar.getTime())).collect(Collectors.toList());
+
+            if(collect != null && collect.size() > 0){
+                Optional<ProLogrecord> max = collect.stream().max(Comparator.comparingLong(ProLogrecord::getId));
+                ProLogrecord proLogrecord = max.get();
+                proLogrecordService.deleteProLogrecordById(proLogrecord.getId(),true);
+            }
+        }catch (Exception ex){
+            System.out.println("定时任务执行异常:"+ex.getMessage());
+        }
+
+
+    }
+}

ruoyi-traceability/src/main/java/com/ruoyi/traceability/mapper/ProLogrecordMapper.java

@@ -1,6 +1,8 @@
 package com.ruoyi.traceability.mapper;
 
 import java.util.List;
+
+import com.ruoyi.common.annotation.Log;
 import com.ruoyi.traceability.domain.ProLogrecord;
 
 /**
@@ -58,4 +60,6 @@ public interface ProLogrecordMapper
      * @return 结果
      */
     public int deleteProLogrecordByIds(String[] ids);
+
+    public int deleteProLogrecordByEndId(Long id);
 }

ruoyi-traceability/src/main/java/com/ruoyi/traceability/service/IProLogrecordService.java

@@ -57,5 +57,6 @@ public interface IProLogrecordService
      * @param id 机台日志主键
      * @return 结果
      */
-    public int deleteProLogrecordById(Long id);
+    public int deleteProLogrecordById(Long id,boolean beforeFlag);
+    
 }

ruoyi-traceability/src/main/java/com/ruoyi/traceability/service/impl/ProLogrecordServiceImpl.java

@@ -1,12 +1,13 @@
 package com.ruoyi.traceability.service.impl;
 
 import java.util.List;
+
+import com.ruoyi.common.core.text.Convert;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.ruoyi.traceability.mapper.ProLogrecordMapper;
 import com.ruoyi.traceability.domain.ProLogrecord;
 import com.ruoyi.traceability.service.IProLogrecordService;
-import com.ruoyi.common.core.text.Convert;
 
 /**
  * 机台日志Service业务层处理
@@ -87,8 +88,11 @@ public class ProLogrecordServiceImpl implements IProLogrecordService
      * @return 结果
      */
     @Override
-    public int deleteProLogrecordById(Long id)
+    public int deleteProLogrecordById(Long id,boolean beforeFlag)
     {
+        if(beforeFlag){
+            return proLogrecordMapper.deleteProLogrecordByEndId(id);
+        }
         return proLogrecordMapper.deleteProLogrecordById(id);
     }
 }

ruoyi-traceability/src/main/resources/mapper/traceability/ProLogrecordMapper.xml

@@ -68,4 +68,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         </foreach>
     </delete>
 
+    <delete id="deleteProLogrecordByEndId" parameterType="Long">
+        delete from pro_logrecord where id &lt; #{id}
+    </delete>
 </mapper>