From bc8074c56893eac3eb5002dcefeacd644d827a29 Mon Sep 17 00:00:00 2001 From: zhanghua <314079846@qq.com> Date: 星期日, 21 一月 2024 20:54:27 +0800 Subject: [PATCH] 优化 --- ycl-platform/src/main/java/com/ycl/timer/SendMsg.java | 36 ++++ ycl-platform/src/main/java/com/ycl/service/message/IMessageService.java | 1 ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/ViolationsServiceImpl.java | 15 + ycl-platform/src/main/java/com/ycl/common/util/DateUtil.java | 384 +++++++++++++++++++++--------------------- ycl-platform/src/main/java/com/ycl/entity/caseHandler/DispatchInfo.java | 2 ycl-platform/src/main/java/com/ycl/service/message/impl/MessageServiceImpl.java | 65 ++++-- 6 files changed, 289 insertions(+), 214 deletions(-) diff --git a/ycl-platform/src/main/java/com/ycl/common/util/DateUtil.java b/ycl-platform/src/main/java/com/ycl/common/util/DateUtil.java index db296c7..c392d05 100644 --- a/ycl-platform/src/main/java/com/ycl/common/util/DateUtil.java +++ b/ycl-platform/src/main/java/com/ycl/common/util/DateUtil.java @@ -12,219 +12,223 @@ public class DateUtil { - /** - * 鑾峰彇涓ゆ棩鏈熶箣闂撮棿闅旂殑澶╂暟 - * - * @param smdate - * 杈冨皬鐨勬椂闂� - * @param bdate - * 杈冨ぇ鐨勬椂闂� - * @return 鐩稿樊澶╂暟 - */ - public static int daysBetween(Date smdate, Date bdate) { - long between_days = 0; - try { - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); - smdate = sdf.parse(sdf.format(smdate)); - bdate = sdf.parse(sdf.format(bdate)); - Calendar cal = Calendar.getInstance(); - cal.setTime(smdate); - long time1 = cal.getTimeInMillis(); - cal.setTime(bdate); - long time2 = cal.getTimeInMillis(); - between_days = (time2 - time1) / (1000 * 3600 * 24); - } catch (ParseException e) { - e.printStackTrace(); - } + /** + * 鑾峰彇涓ゆ棩鏈熶箣闂撮棿闅旂殑澶╂暟 + * + * @param smdate 杈冨皬鐨勬椂闂� + * @param bdate 杈冨ぇ鐨勬椂闂� + * @return 鐩稿樊澶╂暟 + */ + public static int daysBetween(Date smdate, Date bdate) { + long between_days = 0; + try { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + smdate = sdf.parse(sdf.format(smdate)); + bdate = sdf.parse(sdf.format(bdate)); + Calendar cal = Calendar.getInstance(); + cal.setTime(smdate); + long time1 = cal.getTimeInMillis(); + cal.setTime(bdate); + long time2 = cal.getTimeInMillis(); + between_days = (time2 - time1) / (1000 * 3600 * 24); + } catch (ParseException e) { + e.printStackTrace(); + } - return Integer.parseInt(String.valueOf(between_days)); - } + return Integer.parseInt(String.valueOf(between_days)); + } - public static boolean isBetween(Date date, Date startDate, Date endDate) { - - try { + public static boolean isBetween(Date date, Date startDate, Date endDate) { - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - startDate = sdf.parse(sdf.format(startDate)); - endDate = sdf.parse(sdf.format(endDate)); - date = sdf.parse(sdf.format(date)); + try { - Calendar cal = Calendar.getInstance(); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + startDate = sdf.parse(sdf.format(startDate)); + endDate = sdf.parse(sdf.format(endDate)); + date = sdf.parse(sdf.format(date)); - cal.setTime(date); - long time0 = cal.getTimeInMillis(); - cal.setTime(startDate); - long time1 = cal.getTimeInMillis(); - cal.setTime(endDate); - long time2 = cal.getTimeInMillis(); + Calendar cal = Calendar.getInstance(); - if (time0 > time1 && time0 <= time2) - return true; + cal.setTime(date); + long time0 = cal.getTimeInMillis(); + cal.setTime(startDate); + long time1 = cal.getTimeInMillis(); + cal.setTime(endDate); + long time2 = cal.getTimeInMillis(); - } catch (ParseException e) { - e.printStackTrace(); - } - return false; + if (time0 > time1 && time0 <= time2) + return true; - } + } catch (ParseException e) { + e.printStackTrace(); + } + return false; - public static long DifferMillis(Date sDate, Date eDate) { - try { - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - sDate = sdf.parse(sdf.format(sDate)); - eDate = sdf.parse(sdf.format(eDate)); - Calendar cal = Calendar.getInstance(); - cal.setTime(sDate); - long time1 = cal.getTimeInMillis(); - cal.setTime(eDate); - long time2 = cal.getTimeInMillis(); - return Math.abs(time1 - time2); - } catch (ParseException e) { - e.printStackTrace(); - } + } - return -1L; - } + public static long DifferMillis(Date sDate, Date eDate) { + try { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + sDate = sdf.parse(sdf.format(sDate)); + eDate = sdf.parse(sdf.format(eDate)); + Calendar cal = Calendar.getInstance(); + cal.setTime(sDate); + long time1 = cal.getTimeInMillis(); + cal.setTime(eDate); + long time2 = cal.getTimeInMillis(); + return Math.abs(time1 - time2); + } catch (ParseException e) { + e.printStackTrace(); + } - public static long DifferSeconds(Date sDate, Date eDate) { + return -1L; + } - return DifferMillis(sDate, eDate) / 1000; - } + public static long DifferSeconds(Date sDate, Date eDate) { - /** - * 鐩稿樊鍒嗛挓鏁� - * - * @param sDate - * @param eDate - * @return - */ - public static long DifferMinutes(Date sDate, Date eDate) { + return DifferMillis(sDate, eDate) / 1000; + } - return Long.parseLong(String.valueOf(DifferMillis(sDate, eDate) - / (1000 * 60))); - } + /** + * 鐩稿樊鍒嗛挓鏁� + * + * @param sDate + * @param eDate + * @return + */ + public static long DifferMinutes(Date sDate, Date eDate) { - public static String getNowDate(String format) { - return new SimpleDateFormat(format).format(new Date()); - } + return Long.parseLong(String.valueOf(DifferMillis(sDate, eDate) + / (1000 * 60))); + } - public static String getDateString(Date date, String format) { - return new SimpleDateFormat(format).format(date); - } + public static String getNowDate(String format) { + return new SimpleDateFormat(format).format(new Date()); + } - public static Date parse(String date, String format) { + public static String getDateString(Date date, String format) { + return new SimpleDateFormat(format).format(date); + } - try { - return new SimpleDateFormat(format).parse(date); - } catch (ParseException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - return null; - } + public static Date parse(String date, String format) { - public static boolean nowTimeBetween(String beginTimeStr, String endTimeStr) - throws ParseException { - SimpleDateFormat dateFormat = new SimpleDateFormat("hh:mm:ss"); - Long beginTime = dateFormat.parse(beginTimeStr).getTime(); - Long endTime = dateFormat.parse(endTimeStr).getTime(); - Long nowTime = dateFormat.parse(dateFormat.format(new Date())) - .getTime(); - if (nowTime >= beginTime && nowTime <= endTime) { - return true; - } - return false; - } + try { + return new SimpleDateFormat(format).parse(date); + } catch (ParseException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + return null; + } - @SuppressWarnings("static-access") - public static Date addDate(Date date, int days) { - Calendar calendar = new GregorianCalendar(); - calendar.setTime(date); - calendar.add(calendar.DATE, days);// 鎶婃棩鏈熷線鍚庡鍔犱竴澶�.鏁存暟寰�鍚庢帹,璐熸暟寰�鍓嶇Щ鍔� - return calendar.getTime(); // 杩欎釜鏃堕棿灏辨槸鏃ユ湡寰�鍚庢帹涓�澶╃殑缁撴灉 - } + public static boolean nowTimeBetween(String beginTimeStr, String endTimeStr) + throws ParseException { + SimpleDateFormat dateFormat = new SimpleDateFormat("hh:mm:ss"); + Long beginTime = dateFormat.parse(beginTimeStr).getTime(); + Long endTime = dateFormat.parse(endTimeStr).getTime(); + Long nowTime = dateFormat.parse(dateFormat.format(new Date())) + .getTime(); + if (nowTime >= beginTime && nowTime <= endTime) { + return true; + } + return false; + } - @SuppressWarnings("static-access") - public static Date addHour(Date date, int hour) { - Calendar calendar = new GregorianCalendar(); - calendar.setTime(date); - calendar.add(calendar.HOUR, hour);// 鎶婃棩鏈熷線鍚庡鍔犱竴澶�.鏁存暟寰�鍚庢帹,璐熸暟寰�鍓嶇Щ鍔� - return calendar.getTime(); // 杩欎釜鏃堕棿灏辨槸鏃ユ湡寰�鍚庢帹涓�澶╃殑缁撴灉 - } + @SuppressWarnings("static-access") + public static Date addDate(Date date, int days) { + Calendar calendar = new GregorianCalendar(); + calendar.setTime(date); + calendar.add(calendar.DATE, days);// 鎶婃棩鏈熷線鍚庡鍔犱竴澶�.鏁存暟寰�鍚庢帹,璐熸暟寰�鍓嶇Щ鍔� + return calendar.getTime(); // 杩欎釜鏃堕棿灏辨槸鏃ユ湡寰�鍚庢帹涓�澶╃殑缁撴灉 + } - @SuppressWarnings("static-access") - public static Date addMinute(Date date, int minute) { - Calendar calendar = new GregorianCalendar(); - calendar.setTime(date); - calendar.add(calendar.MINUTE, minute);// 鎶婃棩鏈熷線鍚庡鍔犱竴澶�.鏁存暟寰�鍚庢帹,璐熸暟寰�鍓嶇Щ鍔� - return calendar.getTime(); // 杩欎釜鏃堕棿灏辨槸鏃ユ湡寰�鍚庢帹涓�澶╃殑缁撴灉 - } + @SuppressWarnings("static-access") + public static Date addHour(Date date, int hour) { + Calendar calendar = new GregorianCalendar(); + calendar.setTime(date); + calendar.add(calendar.HOUR, hour);// 鎶婃棩鏈熷線鍚庡鍔犱竴澶�.鏁存暟寰�鍚庢帹,璐熸暟寰�鍓嶇Щ鍔� + return calendar.getTime(); // 杩欎釜鏃堕棿灏辨槸鏃ユ湡寰�鍚庢帹涓�澶╃殑缁撴灉 + } - @SuppressWarnings("static-access") - public static Date addSecond(Date date, int second) { - Calendar calendar = new GregorianCalendar(); - calendar.setTime(date); - calendar.add(calendar.SECOND, second);// 鎶婃棩鏈熷線鍚庡鍔犱竴澶�.鏁存暟寰�鍚庢帹,璐熸暟寰�鍓嶇Щ鍔� - return calendar.getTime(); // 杩欎釜鏃堕棿灏辨槸鏃ユ湡寰�鍚庢帹涓�澶╃殑缁撴灉 - } + @SuppressWarnings("static-access") + public static Date addMinute(Date date, int minute) { + Calendar calendar = new GregorianCalendar(); + calendar.setTime(date); + calendar.add(calendar.MINUTE, minute);// 鎶婃棩鏈熷線鍚庡鍔犱竴澶�.鏁存暟寰�鍚庢帹,璐熸暟寰�鍓嶇Щ鍔� + return calendar.getTime(); // 杩欎釜鏃堕棿灏辨槸鏃ユ湡寰�鍚庢帹涓�澶╃殑缁撴灉 + } - /** - * 缁熻涓や釜鏃堕棿鐨勬椂闂村樊 - * two-one - * 鐩稿樊鍑犵鍑犳绉� - */ - public static String getDistanceDateTime(Date one, Date two) { - long day = 0;//澶╂暟宸� - long hour = 0;//灏忔椂鏁板樊 - long min = 0;//鍒嗛挓鏁板樊 - long second=0;//绉掓暟宸� - long diff=0 ;//姣宸� - String result = ""; - final Calendar c = Calendar.getInstance(); - c.setTimeZone(TimeZone.getTimeZone("GMT+8:00")); - c.setTime(one); - long time1 = one.getTime(); - long time2 = two.getTime(); - diff = time2 - time1; - day = diff / (24 * 60 * 60 * 1000); - hour = (diff / (60 * 60 * 1000) - day * 24); - min = ((diff / (60 * 1000)) - day * 24 * 60 - hour * 60); - second = diff/1000; - // System.out.println("day="+day+" hour="+hour+" min="+min+" ss="+second%60+" SSS="+diff%1000); - String daystr = day%30+"澶�"; - String hourStr = hour%24+"灏忔椂"; - String minStr = min%60+"鍒�"; - String secondStr = second%60+"绉�"; - if (day!=0){ - result = result + daystr; - } - if (hour!=0){ - result = result + hourStr; - } - if (min!=0){ - result = result + minStr; - } - if (second!=0){ - result = result + secondStr; - } - return result; - } - public static Date fromLocalDateTime(LocalDateTime ldt){ - ZoneId zoneId = ZoneId.systemDefault(); - ZonedDateTime zdt = ldt.atZone(zoneId); - Date date = Date.from(zdt.toInstant()); - return date ; - } - public static void main(String[] args) throws ParseException { + @SuppressWarnings("static-access") + public static Date addSecond(Date date, int second) { + Calendar calendar = new GregorianCalendar(); + calendar.setTime(date); + calendar.add(calendar.SECOND, second);// 鎶婃棩鏈熷線鍚庡鍔犱竴澶�.鏁存暟寰�鍚庢帹,璐熸暟寰�鍓嶇Щ鍔� + return calendar.getTime(); // 杩欎釜鏃堕棿灏辨槸鏃ユ湡寰�鍚庢帹涓�澶╃殑缁撴灉 + } - Calendar calendar = Calendar.getInstance(); - calendar.add(Calendar.DATE,-1); - calendar.add(Calendar.HOUR,-6); - calendar.add(Calendar.MINUTE,-5); - calendar.add(Calendar.SECOND,-4); - calendar.add(Calendar.MILLISECOND, -30); - Date date = calendar.getTime(); - Date today = new Date(); - // System.out.println(getDistanceDateTime(date,today)); - } + /** + * 缁熻涓や釜鏃堕棿鐨勬椂闂村樊 + * two-one + * 鐩稿樊鍑犵鍑犳绉� + */ + public static String getDistanceDateTime(Date one, Date two) { + long day = 0;//澶╂暟宸� + long hour = 0;//灏忔椂鏁板樊 + long min = 0;//鍒嗛挓鏁板樊 + long second = 0;//绉掓暟宸� + long diff = 0;//姣宸� + String result = ""; + final Calendar c = Calendar.getInstance(); + c.setTimeZone(TimeZone.getTimeZone("GMT+8:00")); + c.setTime(one); + long time1 = one.getTime(); + long time2 = two.getTime(); + diff = time2 - time1; + day = diff / (24 * 60 * 60 * 1000); + hour = (diff / (60 * 60 * 1000) - day * 24); + min = ((diff / (60 * 1000)) - day * 24 * 60 - hour * 60); + second = diff / 1000; + // System.out.println("day="+day+" hour="+hour+" min="+min+" ss="+second%60+" SSS="+diff%1000); + String daystr = day % 30 + "澶�"; + String hourStr = hour % 24 + "灏忔椂"; + String minStr = min % 60 + "鍒�"; + String secondStr = second % 60 + "绉�"; + if (day != 0) { + result = result + daystr; + } + if (hour != 0) { + result = result + hourStr; + } + if (min != 0) { + if (day == 0) { + result = result + minStr; + } + } + if (second != 0) { + if (day == 0 && hour == 0) { + result = result + secondStr; + } + } + return result; + } + + public static Date fromLocalDateTime(LocalDateTime ldt) { + ZoneId zoneId = ZoneId.systemDefault(); + ZonedDateTime zdt = ldt.atZone(zoneId); + Date date = Date.from(zdt.toInstant()); + return date; + } + + public static void main(String[] args) throws ParseException { + + Calendar calendar = Calendar.getInstance(); + calendar.add(Calendar.DATE, -1); + calendar.add(Calendar.HOUR, -6); + calendar.add(Calendar.MINUTE, -5); + calendar.add(Calendar.SECOND, -4); + calendar.add(Calendar.MILLISECOND, -30); + Date date = calendar.getTime(); + Date today = new Date(); + // System.out.println(getDistanceDateTime(date,today)); + } } \ No newline at end of file diff --git a/ycl-platform/src/main/java/com/ycl/entity/caseHandler/DispatchInfo.java b/ycl-platform/src/main/java/com/ycl/entity/caseHandler/DispatchInfo.java index de1900b..29c6df0 100644 --- a/ycl-platform/src/main/java/com/ycl/entity/caseHandler/DispatchInfo.java +++ b/ycl-platform/src/main/java/com/ycl/entity/caseHandler/DispatchInfo.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -106,6 +107,7 @@ * 鍒涘缓鏃堕棿 */ @TableField("create_time") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") @ApiModelProperty(value = "鍒涘缓鏃堕棿") private Date createTime; diff --git a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/ViolationsServiceImpl.java b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/ViolationsServiceImpl.java index 5a16078..b97fd39 100644 --- a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/ViolationsServiceImpl.java +++ b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/ViolationsServiceImpl.java @@ -1,6 +1,8 @@ package com.ycl.service.caseHandler.impl; +import cn.hutool.core.bean.BeanUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.BeanUtils; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ycl.common.util.UtilNumber; import com.ycl.dto.video.HKAlarmParam; @@ -124,6 +126,12 @@ imageResources.setBelongToId(baseCase.getId()); imageResources.setUrl(videoAlarmReport.getPicData()); imageResources.setCreateTime(LocalDateTime.now()); + + ImageResources imageResources1 = new ImageResources(); + BeanUtil.copyProperties(imageResources,imageResources1); + imageResources1.setType("01"); + + imageResourcesService.save(imageResources1); imageResourcesService.save(imageResources); } catch (Exception ex) { System.out.println("娴峰悍鎺ㄩ�佷繚瀛樺紓甯革細" + ex.getMessage()); @@ -191,8 +199,13 @@ imageResources.setBelongToId(baseCase.getId()); imageResources.setUrl(imgs[i]); imageResources.setCreateTime(LocalDateTime.now()); - imageResourcesService.save(imageResources); + ImageResources imageResources1 = new ImageResources(); + BeanUtil.copyProperties(imageResources,imageResources1); + imageResources1.setType("01"); + + imageResourcesService.save(imageResources1); + imageResourcesService.save(imageResources); } } catch (Exception ex) { diff --git a/ycl-platform/src/main/java/com/ycl/service/message/IMessageService.java b/ycl-platform/src/main/java/com/ycl/service/message/IMessageService.java index 3b21fe6..db77747 100644 --- a/ycl-platform/src/main/java/com/ycl/service/message/IMessageService.java +++ b/ycl-platform/src/main/java/com/ycl/service/message/IMessageService.java @@ -18,6 +18,7 @@ */ public interface IMessageService extends IService<Message> { + void sendSMS(Message message); void sendMessage(Message message); Page<MessageVO> list(MessageParam messageParam); diff --git a/ycl-platform/src/main/java/com/ycl/service/message/impl/MessageServiceImpl.java b/ycl-platform/src/main/java/com/ycl/service/message/impl/MessageServiceImpl.java index b6a1a7e..31d76d6 100644 --- a/ycl-platform/src/main/java/com/ycl/service/message/impl/MessageServiceImpl.java +++ b/ycl-platform/src/main/java/com/ycl/service/message/impl/MessageServiceImpl.java @@ -82,18 +82,37 @@ RestTemplate restTemplate; @Override + @SneakyThrows + @Transactional(rollbackFor = Exception.class) + public void sendSMS(Message message) { + Integer messageStatus = sendMessages(message); + + if (messageStatus == 2) { + message.setStatus(2); + message.setRespondResult("鍙戦�佹垚鍔�"); + } + if (messageStatus == 3) { + message.setStatus(3); + message.setRespondResult("鍙戦�佸け璐�"); + } + message.setUpdateTime(new Date()); + message.setSendTime(new Date()); + messageMapper.updateById(message); + } + + @Override @Transactional(rollbackFor = Exception.class) public void sendMessage(Message message) { - Message savedMessage = messageMapper.selectOne(new LambdaQueryWrapper<Message>() - .eq(Message::getTargetTo, message.getTargetTo()) - .eq(Message::getTargetFrom, message.getTargetFrom()) - .eq(Message::getBody, message.getBody()) - .eq(Message::getStatus, 1) - .eq(Message::getHead, message.getHead())); - if (savedMessage != null) { - messageMapper.deleteById(savedMessage); - } +// Message savedMessage = messageMapper.selectOne(new LambdaQueryWrapper<Message>() +// .eq(Message::getTargetTo, message.getTargetTo()) +// .eq(Message::getTargetFrom, message.getTargetFrom()) +// .eq(Message::getBody, message.getBody()) +// .eq(Message::getStatus, 1) +// .eq(Message::getHead, message.getHead())); +// if (savedMessage != null) { +// messageMapper.deleteById(savedMessage); +// } ArrayList<Message> ids = new ArrayList<>(); message.setTargetFrom(umsAdminMapper.selectById(message.getCreateUser()).getUsername()); @@ -114,20 +133,20 @@ ids.add(sendMessage); } } - switch (message.getChannelCode()) { - //閭欢鍙戦�� - case ChannelCode.SMS: - sendSMS(message, ids); - break; - //鐭俊鍙戦�� - case ChannelCode.MAIL: - sendMail(message); - break; - case ChannelCode.INNER: - break; - default: - throw new ApiException("鏈尮閰嶅埌璇ョ被鍨�"); - } +// switch (message.getChannelCode()) { +// //鐭俊鍙戦�� +// case ChannelCode.SMS: +// sendSMS(message, ids); +// break; +// //閭欢鍙戦�� +// case ChannelCode.MAIL: +// sendMail(message); +// break; +// case ChannelCode.INNER: +// break; +// default: +// throw new ApiException("鏈尮閰嶅埌璇ョ被鍨�"); +// } } @SneakyThrows diff --git a/ycl-platform/src/main/java/com/ycl/timer/SendMsg.java b/ycl-platform/src/main/java/com/ycl/timer/SendMsg.java new file mode 100644 index 0000000..1abb3d7 --- /dev/null +++ b/ycl-platform/src/main/java/com/ycl/timer/SendMsg.java @@ -0,0 +1,36 @@ +package com.ycl.timer; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.ycl.service.message.IMessageService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; +import com.ycl.entity.message.Message; + +import java.util.List; + +@Slf4j +@Component +public class SendMsg { + @Value("${spring.profiles.active}") + private String env; + + @Autowired + IMessageService messageService; + + @Scheduled(cron = "0 0/2 * * * ?") + public void runAction() { + if ("online".equals(env)) { + + List<Message> messages = messageService.list(new LambdaQueryWrapper<Message>() + .eq(Message::getStatus, 0)); + + for (Message msg : messages) { + messageService.sendSMS(msg); + } + } + } + +} -- Gitblit v1.8.0