Browse Source

数据更新

alan 1 year ago
parent
commit
f4aa00ac3f

+ 3 - 1
src/main/java/com/zhili/dashboard/mapper/AlarmMsgMapper.java

@@ -131,7 +131,7 @@ public interface AlarmMsgMapper extends BaseMapper<AlarmMsg> {
     Long getInterval();
 
     /**
-     * 累计信息统计  
+     * 累计信息统计
      * @return java.util.Map<java.lang.String,java.lang.Object>
      */
     @MapKey("id")
@@ -160,4 +160,6 @@ public interface AlarmMsgMapper extends BaseMapper<AlarmMsg> {
      */
     @MapKey("id")
     List<Map<String, Object>> getBatteryMap(@Param("province") String province);
+
+    void updateAlarmMsg();
 }

+ 2 - 0
src/main/java/com/zhili/dashboard/mapper/AlarmMsgWarnMapper.java

@@ -83,4 +83,6 @@ public interface AlarmMsgWarnMapper extends BaseMapper<AlarmMsgWarn> {
      * @return java.lang.Long
      */
     Long execUpdateStatus();
+
+    void updateAlarmMsgWarn();
 }

+ 2 - 0
src/main/java/com/zhili/dashboard/mapper/DistributionMapMapper.java

@@ -38,4 +38,6 @@ public interface DistributionMapMapper extends BaseMapper<DistributionMap> {
      */
     @MapKey("id")
     List<Map<String, Object>> getOnLine(@Param("dateStr") String dateStr, @Param("hourStr") String hourStr);
+
+    void updateDistributionMap();
 }

+ 11 - 0
src/main/java/com/zhili/dashboard/scheduler/JobScheduler.java

@@ -22,6 +22,17 @@ public class JobScheduler {
     IDeviceDurationService deviceDurationService;
     @Resource
     IStatisticsService statisticsService;
+
+
+    /**
+     * 同步电池信息
+     * 10min一次
+     */
+    @Async
+    @Scheduled(cron = "0 0 0 * * ?")
+    public void updateAlarmMsg() {
+        alarmMsgService.updateAlarmMsg();
+    }
     /**
      * 同步电池信息
      * 10min一次

+ 2 - 0
src/main/java/com/zhili/dashboard/service/IAlarmMsgService.java

@@ -169,4 +169,6 @@ public interface IAlarmMsgService extends IService<AlarmMsg> {
      * @return java.util.List<BaseCycleChartVo>
      */
     List<BaseCycleChartVo> getCmdOverview();
+
+    void updateAlarmMsg();
 }

+ 8 - 1
src/main/java/com/zhili/dashboard/service/impl/AlarmMsgServiceImpl.java

@@ -1556,4 +1556,11 @@ public class AlarmMsgServiceImpl extends ServiceImpl<AlarmMsgMapper, AlarmMsg> i
 
         return voList;
     }
-}
+
+    @Override
+    public void updateAlarmMsg() {
+        alarmMsgMapper.updateAlarmMsg();
+        alarmMsgWarnMapper.updateAlarmMsgWarn();
+        distributionMapMapper.updateDistributionMap();
+    }
+}

+ 7 - 1
src/main/resources/mapper/AlarmMsgMapper.xml

@@ -13,6 +13,12 @@
         <result property="item" column="item"/>
         <result property="quantity" column="quantity"/>
     </resultMap>
+    <update id="updateAlarmMsg">
+        UPDATE t_alarm_msg t
+        SET t.create_time = DATE_ADD( t.create_time, INTERVAL 1 DAY ),
+            t.fault_time = DATE_ADD( t.fault_time, INTERVAL 1 DAY ),
+            t.finish_time = DATE_ADD( t.finish_time, INTERVAL 1 DAY )
+    </update>
 
     <select id="getAlarmLevelPie" resultMap="HzCarModel">
         SELECT fault_level, count(1) as quantity
@@ -228,4 +234,4 @@
         and am.fault_status = 0
 
     </select>
-</mapper>
+</mapper>

+ 6 - 0
src/main/resources/mapper/AlarmMsgWarnMapper.xml

@@ -111,4 +111,10 @@
          and t.fault_time &lt;= DATE_ADD(now(), INTERVAL -1 DAY)
         and t.fault_status=0
     </update>
+    <update id="updateAlarmMsgWarn">
+        UPDATE t_alarm_msg_warn t
+        SET t.create_time = DATE_ADD( t.create_time, INTERVAL 1 DAY ),
+            t.fault_time = DATE_ADD( t.fault_time, INTERVAL 1 DAY ),
+            t.finish_time = DATE_ADD( t.finish_time, INTERVAL 1 DAY )
+    </update>
 </mapper>

+ 6 - 1
src/main/resources/mapper/DistributionMapMapper.xml

@@ -3,6 +3,11 @@
         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.zhili.dashboard.mapper.DistributionMapMapper">
+    <update id="updateDistributionMap">
+        -- 更新大屏数据库
+        UPDATE tb_distribution_map t
+        SET t.statis_date = REPLACE(DATE_ADD(t.statis_date,INTERVAL 1 DAY),'-','')
+    </update>
 
     <select id="getDeviceStatusList" resultType="Map">
         select sum(car_num) * 20000 as quantity, statis_hours as num, stat_flg as item,statis_date
@@ -22,4 +27,4 @@
           and statis_hours = #{hourStr}
     </select>
 
-</mapper>
+</mapper>