Ver código fonte

每天8:00清空电厂大屏实时数据表

wangggziwen 3 anos atrás
pai
commit
d30353d680

+ 8 - 0
src/main/java/io/renren/modules/aspen/controller/TElecdashboardRealtimeController.java

@@ -37,4 +37,12 @@ public class TElecdashboardRealtimeController {
         tElecdashboardRealtimeService.insertTElecdashboardRealtime(tElecdashboardRealtimeEntity);
     }
 
+    /**
+     * 每天8:00清空电厂大屏实时数据表
+     */
+//    @Scheduled(cron = "0 0 8 * * ?")
+    public void clearTElecdashboardRealtimeEveryHour() {
+        tElecdashboardRealtimeService.deleteTElecdashboardRealtime();
+    }
+
 }

+ 1 - 0
src/main/java/io/renren/modules/aspen/dao/TElecdashboardRealtimeDao.java

@@ -16,4 +16,5 @@ public interface TElecdashboardRealtimeDao extends BaseMapper<TElecdashboardReal
 
     public void insertTElecdashboardRealtime(TElecdashboardRealtimeEntity elecDashboardDataRealTime);
 
+    public void deleteTElecdashboardRealtime();
 }

+ 2 - 0
src/main/java/io/renren/modules/aspen/service/TElecdashboardRealtimeService.java

@@ -14,4 +14,6 @@ public interface TElecdashboardRealtimeService extends IService<TElecdashboardRe
 
     public void insertTElecdashboardRealtime(TElecdashboardRealtimeEntity elecDashboardDataRealTime);
 
+    public void deleteTElecdashboardRealtime();
+
 }

+ 5 - 0
src/main/java/io/renren/modules/aspen/service/impl/TElecdashboardRealtimeServiceImpl.java

@@ -28,4 +28,9 @@ public class TElecdashboardRealtimeServiceImpl
         tElecdashboardRealtimeDao.insertTElecdashboardRealtime(elecDashboardDataRealTime);
     }
 
+    @Override
+    public void deleteTElecdashboardRealtime() {
+        tElecdashboardRealtimeDao.deleteTElecdashboardRealtime();
+    }
+
 }

+ 8 - 1
src/main/resources/mapper/aspen/TElecdashboardRealtimeDao.xml

@@ -7,7 +7,7 @@
         <selectKey keyProperty="id" resultType="long" order="BEFORE">
             SELECT SEQ_T_ELECDASHBOARD_REALTIME.NEXTVAL as id FROM DUAL
         </selectKey>
-        insert into T_ELECDASHBOARD_REALTIME
+        insert into t_elecdashboard_realtime
         <trim prefix="(" suffix=")" suffixOverrides=",">
             <if test="id != null">id,</if>
             <if test="pullDate != null">pull_date,</if>
@@ -456,4 +456,11 @@
         </trim>
     </insert>
 
+    <!-- 清空电厂大屏实时数据表 -->
+    <!-- 保留日期最靠前的一条实时数据,其余过期数据全部物理删除,释放空间 -->
+    <delete id="deleteTElecdashboardRealtime">
+        delete * from t_elecdashboard_realtime
+        where pull_date != ( select max(pull_date) from t_elecdashboard_realtime)
+    </delete>
+
 </mapper>