From 27f360947d9a86f327b08df55677ec01d86e0efa Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=98=93=E7=84=B1?= Date: Fri, 14 Jun 2019 19:02:06 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E6=8E=A8=E9=80=81=E4=BC=98?= =?UTF-8?q?=E5=8C=96!?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../tasks/business/device/entity/TblTmpPushRemind.java | 2 +- src/main/java/com/ifish7/tasks/job/impl/RemindJobImpl.java | 7 ++++++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/ifish7/tasks/business/device/entity/TblTmpPushRemind.java b/src/main/java/com/ifish7/tasks/business/device/entity/TblTmpPushRemind.java index b85441e..e8fae72 100644 --- a/src/main/java/com/ifish7/tasks/business/device/entity/TblTmpPushRemind.java +++ b/src/main/java/com/ifish7/tasks/business/device/entity/TblTmpPushRemind.java @@ -26,7 +26,7 @@ public class TblTmpPushRemind { @TableId(value = "device_id", type = IdType.NONE) private Integer deviceId; - @TableId(value = "device_id", type = IdType.NONE) + @TableId(value = "user_id", type = IdType.NONE) private Integer userId; private String phoneNumber; diff --git a/src/main/java/com/ifish7/tasks/job/impl/RemindJobImpl.java b/src/main/java/com/ifish7/tasks/job/impl/RemindJobImpl.java index 68c0881..15851d5 100644 --- a/src/main/java/com/ifish7/tasks/job/impl/RemindJobImpl.java +++ b/src/main/java/com/ifish7/tasks/job/impl/RemindJobImpl.java @@ -3,6 +3,7 @@ package com.ifish7.tasks.job.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.ifish7.tasks.business.device.entity.TblDevice; import com.ifish7.tasks.business.device.entity.TblDeviceHeaterDetail; import com.ifish7.tasks.business.device.entity.TblDeviceUser; @@ -58,6 +59,7 @@ public class RemindJobImpl implements RemindJob { private final String pushContent = "【换水提醒】您的水族箱\"%s\"需要换水啦～您可以在水箱设置中更改提醒设置"; + @Scheduled(cron = "0 0 10 * * ?") @Override public void commDeviceChangeWater() { @@ -80,7 +82,10 @@ public class RemindJobImpl implements RemindJob { Instant instant = nextRemindDate.toInstant(); ZoneId zoneId = ZoneId.systemDefault(); tblTmpPushRemind.setRemindDate(instant.atZone(zoneId).toLocalDate()); - tmpPushRemindService.saveOrUpdate(tblTmpPushRemind); + boolean update = tmpPushRemindService.update(tblTmpPushRemind, new UpdateWrapper() + .eq("device_id", tblTmpPushRemind.getDeviceId()) + .eq("user_id", tblTmpPushRemind.getUserId())); + log.info("update : " + update); } }