From aef21540e147d618bfe55ca17864c77b06ffebed Mon Sep 17 00:00:00 2001 From: gongbiao Date: Wed, 8 Aug 2018 19:52:02 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9F=AD=E4=BF=A1=E7=9B=B8=E5=85=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../simple/service/impl/WxMsgServiceImpl.java | 20 ++++++++++++++++--- 1 file changed, 17 insertions(+), 3 deletions(-) diff --git a/mallinkService/src/main/java/com/simple/service/impl/WxMsgServiceImpl.java b/mallinkService/src/main/java/com/simple/service/impl/WxMsgServiceImpl.java index 4766fa303..b7332a295 100644 --- a/mallinkService/src/main/java/com/simple/service/impl/WxMsgServiceImpl.java +++ b/mallinkService/src/main/java/com/simple/service/impl/WxMsgServiceImpl.java @@ -17,9 +17,11 @@ import com.simple.utils.HttpUtil; import com.simple.utils.RsaUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; -import org.springframework.web.multipart.MultipartFile; import java.util.*; +import java.util.concurrent.Executors; +import java.util.concurrent.ScheduledExecutorService; +import java.util.concurrent.TimeUnit; @Service public class WxMsgServiceImpl implements WxMsgService { @@ -54,7 +56,7 @@ public class WxMsgServiceImpl implements WxMsgService { } //是否立即发送 - if (wxMsg.getIsright() == 0) { + if (wxMsg.getIsright() == 1) { wxMsg.setStatus(1); sendmsg(wxMsg); } else { @@ -73,7 +75,7 @@ public class WxMsgServiceImpl implements WxMsgService { } //是否立即发送 - if (wxMsg.getIsright() == 0) { + if (wxMsg.getIsright() == 1) { wxMsg.setStatus(1); sendmsg(wxMsg); } else { @@ -81,6 +83,8 @@ public class WxMsgServiceImpl implements WxMsgService { wxMsg.setStatus(0); wxMsgMapper.updateByPrimaryKeySelective(wxMsg); return new ResultData(Result.SUCCESS, "短信会在预设时间发送"); + + } } @@ -170,4 +174,14 @@ public class WxMsgServiceImpl implements WxMsgService { } + public static void main(String args[]){ + + ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor(); + service.scheduleAtFixedRate(()->System.out.println("task ScheduledExecutorService "+new Date()), 0, 1, TimeUnit.SECONDS); + + } + + + + }