From e15ddfa800ddf87becbd8ea3e462ebd59fbd82b1 Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Tue, 31 Aug 2021 13:08:20 +0800
Subject: [PATCH] screen-manage 更新日志操作
---
screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java | 37 ++++++++++++++++++++++++-------------
1 files changed, 24 insertions(+), 13 deletions(-)
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java
index 797334b..8f5f0b5 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java
@@ -7,7 +7,6 @@
import com.moral.api.mapper.HistoryHourlyMapper;
import com.moral.api.mapper.HistoryMinutelyMapper;
import com.moral.api.service.HistoryHourlyService;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.moral.api.service.SensorService;
import com.moral.constant.Constants;
import com.moral.constant.RedisConstants;
@@ -39,7 +38,7 @@
* @since 2021-06-28
*/
@Service
-public class HistoryHourlyServiceImpl extends ServiceImpl<HistoryHourlyMapper, HistoryHourly> implements HistoryHourlyService {
+public class HistoryHourlyServiceImpl implements HistoryHourlyService {
@Autowired
private HistoryHourlyMapper historyHourlyMapper;
@@ -54,6 +53,11 @@
private SensorService sensorService;
@Override
+ public void createTable(String timeUnits) {
+ historyHourlyMapper.createTable(timeUnits);
+ }
+
+ @Override
public void insertHistoryHourly() {
//������������������yyyy-MM-dd HH:mm
String format = DateUtils.yyyy_MM_dd_HH_EN;
@@ -64,16 +68,18 @@
Date now = new Date();
String time = DateUtils.dateToDateString(now, format) + ":00:00";
- QueryWrapper<HistoryHourly> queryWrapper = new QueryWrapper<>();
- queryWrapper.eq("time", time);
//������������������������������������������������macs������������������������������
- Integer count = historyHourlyMapper.selectCount(queryWrapper);
- if (macs.size() > count) {
+ Map<String, Object> prop = new HashMap<>();
+ prop.put("timeUnits", DateUtils.getDateStringOfMon(0, DateUtils.yyyyMM_EN));
+ prop.put("time", time);
+ Integer count = historyHourlyMapper.selectCountByTime(prop);
+
+ if (macs.size() <= count) {
+ return;
+ } else {
macs.removeIf(mac -> {
- queryWrapper.clear();
- queryWrapper.eq("time", time);
- queryWrapper.eq("mac", mac);
- Integer num = historyHourlyMapper.selectCount(queryWrapper);
+ prop.put("mac", mac);
+ Integer num = historyHourlyMapper.selectCountByTime(prop);
return num != 0;
});
}
@@ -163,7 +169,7 @@
Map<String, Object> dataValue = JSONObject.parseObject((String) v.get("value"), Map.class);
Object sensorValue = dataValue.get(sensorCode);
//������������������������
- Object flag = dataValue.get(sensorCode + Constants.MARKER_BIT_KEY);
+ Object flag = dataValue.get(sensorCode + "-" + Constants.MARKER_BIT_KEY);
if (!Constants.MARKER_BIT_TRUE.equals(flag)) {
return null;
}
@@ -199,9 +205,9 @@
jsonMap.put(sensorCode, sciCal);
//���������
if (size.get() >= 45) {
- jsonMap.put(sensorCode + Constants.MARKER_BIT_KEY, Constants.MARKER_BIT_TRUE);
+ jsonMap.put(sensorCode + "-" + Constants.MARKER_BIT_KEY, Constants.MARKER_BIT_TRUE);
} else {
- jsonMap.put(sensorCode + Constants.MARKER_BIT_KEY, Constants.MARKER_BIT_FALSE);
+ jsonMap.put(sensorCode + "-" + Constants.MARKER_BIT_KEY, Constants.MARKER_BIT_FALSE);
}
}
});
@@ -213,4 +219,9 @@
//���������������
historyHourlyMapper.insertHistoryHourly(insertData);
}
+
+ @Override
+ public List<Map<String, Object>> selectDailyData(Map<String, Object> params) {
+ return historyHourlyMapper.selectDailyData(params);
+ }
}
--
Gitblit v1.8.0