From 4450dd41e8d5828e5da4d277c86e54551a6b6c15 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Thu, 16 Dec 2021 09:06:28 +0800 Subject: [PATCH] 设备新增,修改是工艺字段可以为多个,修改mapper,sql --- screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java | 13 ++++++++++++- 1 files changed, 12 insertions(+), 1 deletions(-) diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java index 2a0e2c1..12aa978 100644 --- a/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java +++ b/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java @@ -86,7 +86,7 @@ } HistoryAqi historyAqi = new HistoryAqi(); historyAqi.setGuid(guid); - historyAqi.setTime(time); + historyAqi.setTime(DateUtils.addHours(time, -1)); //��������������� historyAqi.setValue(JSONObject.toJSONString(map)); historyAqiMapper.insert(historyAqi); @@ -126,4 +126,15 @@ redisTemplate.opsForHash().put(RedisConstants.AQI_DATA, guid, value); } } + + @Override + public HistoryAqi getHistoryApiByTimeAndGuid(String guid, String time) { + QueryWrapper<HistoryAqi> wrapper_historyAqi = new QueryWrapper<>(); + wrapper_historyAqi.eq("guid", guid).eq("time", time); + HistoryAqi historyAqi = new HistoryAqi(); + if (historyAqiMapper.selectCount(wrapper_historyAqi) == 1) { + historyAqi = historyAqiMapper.selectOne(wrapper_historyAqi); + } + return historyAqi; + } } -- Gitblit v1.8.0