From 76ed8721a723e548999a9efc5d79f95bfcbe74df Mon Sep 17 00:00:00 2001 From: wujingtao Date: Mon, 29 Nov 2021 09:47:50 +0800 Subject: [PATCH 1/3] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E6=B6=88=E6=81=AF=20=E9=95=BF=E6=97=B6=E9=97=B4=E6=9C=AA?= =?UTF-8?q?=E5=8F=91=E9=80=81=E7=9A=84=E8=BF=9B=E8=A1=8C=E6=B8=85=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/hchbox/job/ConfirmReceiptJob.java | 2 +- .../hchbox/job/DeleteExpiredMessageJob.java | 36 +++++++++++++++ .../hchbox/job/ObtainInfoExportDelJob.java | 44 +++++++++---------- .../java/com/hchbox/job/ObtainInfoJob.java | 44 +++++++++---------- .../module/controller/TestController.java | 44 ------------------- .../module/controller/WwRemindController.java | 1 + .../dao/AutoWaitForMessageRepository.java | 11 +++++ .../hchbox/module/entity/AutoWaitMessage.java | 12 ++++- .../module/service/TimerTaskService.java | 7 ++- .../service/impl/TimerTaskServiceImpl.java | 23 ++++++++-- 10 files changed, 130 insertions(+), 94 deletions(-) create mode 100644 service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/DeleteExpiredMessageJob.java delete mode 100644 service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/TestController.java diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ConfirmReceiptJob.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ConfirmReceiptJob.java index ebef5aa..9d495c3 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ConfirmReceiptJob.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ConfirmReceiptJob.java @@ -20,7 +20,7 @@ import javax.annotation.Resource; */ @Slf4j @ElasticSimpleJob( - jobName = "ConfirmReceiptJob", cron = "0 0/1 * * * ?", shardingTotalCount = 1, overwrite = true, jobEvent = false) + jobName = "ConfirmReceiptJob", cron = "0 0/30 * * * ?", shardingTotalCount = 1, overwrite = true, jobEvent = false) @Component public class ConfirmReceiptJob implements SimpleJob { diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/DeleteExpiredMessageJob.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/DeleteExpiredMessageJob.java new file mode 100644 index 0000000..a6688d1 --- /dev/null +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/DeleteExpiredMessageJob.java @@ -0,0 +1,36 @@ +package com.hchbox.job; + +import com.dangdang.ddframe.job.api.ShardingContext; +import com.dangdang.ddframe.job.api.simple.SimpleJob; +import com.example.autoconfig.ElasticSimpleJob; +import com.hchbox.module.service.TimerTaskService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; +import javax.annotation.Resource; + +/** + * @author wjt + * @date 2021/11/26 + */ +@Slf4j +@ElasticSimpleJob( + jobName = "DeleteExpiredMessageJob", cron = "0 0 0/1 * * ?", shardingTotalCount = 1, overwrite = true, jobEvent = false) +@Component +public class DeleteExpiredMessageJob implements SimpleJob { + @Resource + private TimerTaskService timerTaskService; + + private static DeleteExpiredMessageJob deleteExpiredMessageJob; + + @PostConstruct + public void init() { + deleteExpiredMessageJob = this; + } + + @Override + public void execute(ShardingContext shardingContext) { + deleteExpiredMessageJob.timerTaskService.deleteNotSendMessage(); + } +} diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ObtainInfoExportDelJob.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ObtainInfoExportDelJob.java index 95deb5a..0919f07 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ObtainInfoExportDelJob.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ObtainInfoExportDelJob.java @@ -16,26 +16,26 @@ import javax.annotation.Resource; * @date 2021/10/15 * 导出一个月数据并删除数据 */ -@Slf4j -@ElasticSimpleJob( - //0 0 5 1 1/1 ? * -------每月1日5点 - jobName = "ObtainInfoExportDelJob", cron = "0 0 5 1 1/1 ? *", shardingTotalCount = 1, overwrite = true, jobEvent = false) -@Component -public class ObtainInfoExportDelJob implements SimpleJob { - - @Resource - private ObtainInfoService obtainInfoService; - - private static ObtainInfoExportDelJob obtainInfoExportDelJob; - - @PostConstruct - public void init() { - obtainInfoExportDelJob = this; - } - - @Override - public void execute(ShardingContext shardingContext) { - log.info("===============ObtainInfoExportDelJob备份数据到本地开始,{}================", DateUtil.date()); +//@Slf4j +//@ElasticSimpleJob( +// //0 0 5 1 1/1 ? * -------每月1日5点 +// jobName = "ObtainInfoExportDelJob", cron = "0 0 5 1 1/1 ? *", shardingTotalCount = 1, overwrite = true, jobEvent = false) +//@Component +//public class ObtainInfoExportDelJob implements SimpleJob { +// +// @Resource +// private ObtainInfoService obtainInfoService; +// +// private static ObtainInfoExportDelJob obtainInfoExportDelJob; +// +// @PostConstruct +// public void init() { +// obtainInfoExportDelJob = this; +// } +// +// @Override +// public void execute(ShardingContext shardingContext) { +// log.info("===============ObtainInfoExportDelJob备份数据到本地开始,{}================", DateUtil.date()); // obtainInfoExportDelJob.obtainInfoService.selectExportDel(); - } -} +// } +//} diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ObtainInfoJob.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ObtainInfoJob.java index 3b20ed5..3a4fcca 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ObtainInfoJob.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/job/ObtainInfoJob.java @@ -15,26 +15,26 @@ import javax.annotation.Resource; * @date 2021/10/14 * 获取淘宝信息 */ -@Slf4j -@ElasticSimpleJob( - //每天一点执行：0 0 1 * * ? - jobName = "ObtainInfoJob", cron = "0 0 1 * * ?", shardingTotalCount = 1, overwrite = true, jobEvent = false) -@Component -public class ObtainInfoJob implements SimpleJob { - - @Resource - private ObtainInfoService obtainInfoService; - - private static ObtainInfoJob obtainInfoJob; - - @PostConstruct - public void init() { - obtainInfoJob = this; - } - - @Override - public void execute(ShardingContext shardingContext) { - log.info("===============ObtainInfoJob同步前一天数据开始,{}================", DateUtil.date()); +//@Slf4j +//@ElasticSimpleJob( +// //每天一点执行：0 0 1 * * ? +// jobName = "ObtainInfoJob", cron = "0 0 1 * * ?", shardingTotalCount = 1, overwrite = true, jobEvent = false) +//@Component +//public class ObtainInfoJob implements SimpleJob { +// +// @Resource +// private ObtainInfoService obtainInfoService; +// +// private static ObtainInfoJob obtainInfoJob; +// +// @PostConstruct +// public void init() { +// obtainInfoJob = this; +// } +// +// @Override +// public void execute(ShardingContext shardingContext) { +// log.info("===============ObtainInfoJob同步前一天数据开始,{}================", DateUtil.date()); // obtainInfoJob.obtainInfoService.selectAllSave(); - } -} +// } +//} diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/TestController.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/TestController.java deleted file mode 100644 index c65ee66..0000000 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/TestController.java +++ /dev/null @@ -1,44 +0,0 @@ -package com.hchbox.module.controller; - -import com.google.gson.Gson; -import lombok.extern.slf4j.Slf4j; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; - -import javax.servlet.http.HttpServletRequest; -import java.util.Enumeration; -import java.util.HashMap; -import java.util.Map; - -/** - * @author Enzo - * @date : 2021/6/17 - */ -@Slf4j -@RestController -@RequestMapping("/wwsend") -public class TestController { - - @GetMapping("/test") - public String test(HttpServletRequest request) { - log.info("请求路径：" + request.getRequestURL().toString()); - log.info("请求ip：" + request.getRemoteAddr()); - Enumeration pNames = request.getParameterNames(); - Map map = new HashMap(16); - while (pNames.hasMoreElements()) { - String key = pNames.nextElement().toString(); - String result = request.getParameter(key); - map.put(key, result); - } - log.info("请求参数：" + new Gson().toJson(map)); - return request.getParameter("TAO_MI_TOKEN"); - } - - - @GetMapping("/helloWorld") - public String test(){ - return "Hello World Wwsend"; - } - -} diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java index 9f6329c..1e2abf8 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java @@ -67,6 +67,7 @@ public class WwRemindController { long parentId = sellerAccount.getParentId(); sellerNick = sellerAccountService.findSellerAccountById(parentId).getNickname(); } + log.info("===========sellerNick:{} 查询消息======", sellerNick); return new CommonResult<>().success(delayRemindService.selectDelayRemind(sellerNick)); } diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoWaitForMessageRepository.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoWaitForMessageRepository.java index 7510ca8..5580ea0 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoWaitForMessageRepository.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoWaitForMessageRepository.java @@ -1,8 +1,10 @@ package com.hchbox.module.dao; +import cn.hutool.core.date.DateTime; import com.hchbox.module.entity.AutoWaitMessage; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.JpaSpecificationExecutor; +import org.springframework.data.jpa.repository.Query; import org.springframework.stereotype.Repository; import java.util.List; @@ -20,4 +22,13 @@ public interface AutoWaitForMessageRepository extends JpaRepository findAllBySender(String sellerNick); + + /** + * 查询过期消息 + * + * @param creatTime + * @return + */ + @Query(value = "select a.id from AutoWaitMessage as a where a.createTime < ?1") + List findIdByCreatTime(DateTime creatTime); } diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/entity/AutoWaitMessage.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/entity/AutoWaitMessage.java index ab7c7ca..545c0b6 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/entity/AutoWaitMessage.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/entity/AutoWaitMessage.java @@ -2,9 +2,12 @@ package com.hchbox.module.entity; import io.swagger.annotations.ApiModelProperty; import lombok.Data; +import org.hibernate.annotations.CreationTimestamp; +import org.springframework.data.jpa.domain.support.AuditingEntityListener; import javax.persistence.*; import java.io.Serializable; +import java.util.Date; /** * @author wujingtao @@ -13,10 +16,13 @@ import java.io.Serializable; @Data @Entity @Table(name = "auto_wait_for_message") +@EntityListeners(AuditingEntityListener.class) public class AutoWaitMessage implements Serializable { @Id - @Column(name = "task_id") + @Column(name = "id") @ApiModelProperty(value = "id") + private Long id; + @ApiModelProperty(value = "taskId") private Long taskId; @ApiModelProperty("发送人") private String sender; @@ -26,4 +32,8 @@ public class AutoWaitMessage implements Serializable { private String sendMessage; @ApiModelProperty("接收人") private String buyer; + @CreationTimestamp + @ApiModelProperty("创建时间") + @Column(name = "create_time") + private Date createTime; } diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/TimerTaskService.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/TimerTaskService.java index 92e6e5b..7d4031a 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/TimerTaskService.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/TimerTaskService.java @@ -12,5 +12,10 @@ public interface TimerTaskService { * @param settingType * @param tradeStatus */ - void sendMessage(Integer settingType,String tradeStatus); + void sendMessage(Integer settingType, String tradeStatus); + + /** + * 定时删除过期的消息 + */ + void deleteNotSendMessage(); } diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/impl/TimerTaskServiceImpl.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/impl/TimerTaskServiceImpl.java index d9baf5d..3ddc856 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/impl/TimerTaskServiceImpl.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/impl/TimerTaskServiceImpl.java @@ -20,6 +20,7 @@ import org.springframework.util.CollectionUtils; import javax.annotation.Resource; import java.time.LocalTime; import java.util.ArrayList; +import java.util.Date; import java.util.List; @@ -116,9 +117,10 @@ public class TimerTaskServiceImpl implements TimerTaskService { return; } //创建发送信息 - createAutoTaskMessageInfo(templateStr, as, subNickList, info, autoTaskMessage.getId()); + long id = createAutoTaskMessageInfo(templateStr, as, subNickList, info, autoTaskMessage.getId()); //创建待发送列表 AutoWaitMessage autoWaitForMessage = new AutoWaitMessage(); + autoWaitForMessage.setId(id); autoWaitForMessage.setTaskId(autoTaskMessage.getId()); autoWaitForMessage.setTaskName(autoTaskMessage.getTaskName()); autoWaitForMessage.setSender(info.getSellerNick()); @@ -150,7 +152,7 @@ public class TimerTaskServiceImpl implements TimerTaskService { } } - private void createAutoTaskMessageInfo(String templateStr, AppSetting appSetting, List subNickList, TopTrade trade, Long taskId) { + private Long createAutoTaskMessageInfo(String templateStr, AppSetting appSetting, List subNickList, TopTrade trade, Long taskId) { AutoTaskMessageInfo autoTaskMessageInfo = new AutoTaskMessageInfo(); autoTaskMessageInfo.setTaskId(taskId); autoTaskMessageInfo.setMessageNick(subNickList.get(DefaultNumberConstants.ZERO_NUMBER)); @@ -163,7 +165,7 @@ public class TimerTaskServiceImpl implements TimerTaskService { String content = RemindTemplates.prepareMsg(templateStr, trade); // 模板替换 autoTaskMessageInfo.setInfo(content); - autoTaskMessageInfoJpa.save(autoTaskMessageInfo); + return autoTaskMessageInfoJpa.save(autoTaskMessageInfo).getId(); } private AutoTaskMessage createAutoTaskMessage(AppSetting setting, String template) { @@ -199,4 +201,19 @@ public class TimerTaskServiceImpl implements TimerTaskService { } return list; } + + @Override + @Transactional(rollbackFor = Exception.class) + public void deleteNotSendMessage() { + //超过三小时未发送的消息 就被清除 + DateTime newDate3 = DateUtil.offsetHour(DateUtil.date(), -3); + List idList = autoWaitForMessageRepository.findIdByCreatTime(newDate3); + if (CollUtil.isEmpty(idList)) { + return; + } + for (Long id : idList) { + autoWaitForMessageRepository.deleteById(id); + autoTaskMessageInfoJpa.deleteById(id); + } + } } From db48940346a05c419ce59575e44694755297106f Mon Sep 17 00:00:00 2001 From: wujingtao Date: Tue, 30 Nov 2021 18:31:32 +0800 Subject: [PATCH 2/3] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E9=80=BB=E8=BE=91=EF=BC=8C=E9=99=90=E5=88=B6?= =?UTF-8?q?=E6=AF=8F=E6=AC=A1=E6=9F=A5=E8=AF=A2=E6=9D=A1=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../module/controller/WwRemindController.java | 6 ---- .../dao/AutoWaitForMessageRepository.java | 4 ++- .../module/service/DelayRemindService.java | 7 ++-- .../service/impl/DelayRemindServiceImpl.java | 34 +++++++++++++++---- .../src/main/resources/application.yml | 3 ++ 5 files changed, 36 insertions(+), 18 deletions(-) diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java index 1e2abf8..390460d 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java @@ -70,10 +70,4 @@ public class WwRemindController { log.info("===========sellerNick:{} 查询消息======", sellerNick); return new CommonResult<>().success(delayRemindService.selectDelayRemind(sellerNick)); } - - @GetMapping("/test") - @ApiOperation("接受消息") - public String test() { - return "测试成功"; - } } diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoWaitForMessageRepository.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoWaitForMessageRepository.java index 5580ea0..4681d11 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoWaitForMessageRepository.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoWaitForMessageRepository.java @@ -19,9 +19,11 @@ public interface AutoWaitForMessageRepository extends JpaRepository findAllBySender(String sellerNick); + @Query(value = "select * from auto_wait_for_message where sender = ?1 limit 0 , ?2", nativeQuery = true) + List findAllBySender(String sellerNick, Integer num); /** * 查询过期消息 diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/DelayRemindService.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/DelayRemindService.java index e7fd1a8..f12c625 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/DelayRemindService.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/DelayRemindService.java @@ -1,8 +1,5 @@ package com.hchbox.module.service; - -import com.hchbox.module.entity.AutoWaitMessage; - -import java.util.List; +import java.util.Map; /** * @author wujingtao @@ -15,5 +12,5 @@ public interface DelayRemindService { * @param sellerNick * @return */ - List selectDelayRemind(String sellerNick); + Map selectDelayRemind(String sellerNick); } diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/impl/DelayRemindServiceImpl.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/impl/DelayRemindServiceImpl.java index 03c7a65..3caf0f4 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/impl/DelayRemindServiceImpl.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/service/impl/DelayRemindServiceImpl.java @@ -5,34 +5,56 @@ import com.hchbox.exception.TaoMiCommException; import com.hchbox.module.dao.AutoWaitForMessageRepository; import com.hchbox.module.entity.AutoWaitMessage; import com.hchbox.module.service.DelayRemindService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import javax.annotation.Resource; -import java.util.ArrayList; +import java.util.HashMap; import java.util.List; +import java.util.Map; /** * @author wujingtao * @date 2021/09/29 */ @Service +@Slf4j public class DelayRemindServiceImpl implements DelayRemindService { @Resource private AutoWaitForMessageRepository autoWaitForMessageRepository; + @Value("${timing.task.maxNum}") + private int maxNum; + /** + * 前段定时来查询消息，每次最多查询2000条，false表示还未查完，true表示已经查完了 + * + * @param sellerNick + * @return + */ @Override - public List selectDelayRemind(String sellerNick) { + public Map selectDelayRemind(String sellerNick) { + HashMap map = new HashMap<>(16); List list; try { - list = autoWaitForMessageRepository.findAllBySender(sellerNick); + list = autoWaitForMessageRepository.findAllBySender(sellerNick, maxNum); + map.put("data", list); if (CollectionUtil.isNotEmpty(list)) { - for (AutoWaitMessage info : list) { - autoWaitForMessageRepository.deleteById(info.getTaskId()); + if (list.size() >= maxNum) { + map.put("isOver", false); + } else { + map.put("isOver", true); } + autoWaitForMessageRepository.deleteInBatch(list); + } else { + map.put("isOver", true); } + } catch (Exception e) { + log.error("操作定时任务消息失败.{}", e.getMessage()); throw new TaoMiCommException("请求发送消息失败"); } - return list; + log.info("查询出來的消息条数：{}", list.size()); + return map; } } diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/resources/application.yml b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/resources/application.yml index 49cffd9..9ecf81b 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/resources/application.yml +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/resources/application.yml @@ -47,6 +47,9 @@ hystrix: snowflake: workerId: 9 datacenterId: 9 +timing: + task: + maxNum: 2000 hchbox: mi: appKey: 23042177 From a74fe60c71b5404a646697e66e4587e5ad8478ab Mon Sep 17 00:00:00 2001 From: wujingtao Date: Tue, 7 Dec 2021 14:42:37 +0800 Subject: [PATCH 3/3] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=8F=91=E9=80=81?= =?UTF-8?q?=E4=BF=A1=E6=81=AF=E4=BF=9D=E5=AD=98=E8=AE=B0=E5=BD=95=E7=9A=84?= =?UTF-8?q?=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/hchbox/module/controller/WwRemindController.java | 4 ++++ .../com/hchbox/module/dao/AutoTaskMessageRepository.java | 7 ++++--- .../hchbox/module/service/impl/TimerTaskServiceImpl.java | 7 +++++-- 3 files changed, 13 insertions(+), 5 deletions(-) diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java index 390460d..529f1d4 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/controller/WwRemindController.java @@ -3,6 +3,7 @@ package com.hchbox.module.controller; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; +import cn.hutool.core.util.StrUtil; import com.hchbox.constant.AuthConstants; import com.hchbox.constant.DefaultNumberConstants; import com.hchbox.dto.BathSendMessageDTO; @@ -56,6 +57,9 @@ public class WwRemindController { @ApiOperation("接受消息") public CommonResult wwDelayRemindController(HttpServletRequest request) { String token = request.getParameter("TAO_MI_TOKEN"); + if (StrUtil.isBlank(token)) { + return new CommonResult<>().error("查詢消息時店鋪token不能為空"); + } SellerAccount sellerAccount = sellerAccountService.findSellerAccountByAccessToken(token); String sellerNick; if (ObjectUtil.isEmpty(sellerAccount)) { diff --git a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoTaskMessageRepository.java b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoTaskMessageRepository.java index 3cfd0eb..e9d45e2 100644 --- a/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoTaskMessageRepository.java +++ b/service/trade-service-wwsend/trade-service-wwsend-task/src/main/java/com/hchbox/module/dao/AutoTaskMessageRepository.java @@ -17,13 +17,14 @@ public interface AutoTaskMessageRepository extends JpaRepository subNickList = sellerAccountRepository.findByParentId(sellerAccount.getId()); + List subNickList = Arrays.asList(as.getSendAccountIds().split(StrUtil.COMMA)); +// List subNickList = sellerAccountRepository.findByParentId(sellerAccount.getId()); if (CollectionUtils.isEmpty(subNickList)) { continue; } @@ -170,7 +173,7 @@ public class TimerTaskServiceImpl implements TimerTaskService { private AutoTaskMessage createAutoTaskMessage(AppSetting setting, String template) { DateTime date = DateUtil.date(); - AutoTaskMessage message = autoTaskMessageRepository.findAutoTaskMessageTypeBetweenTime(setting.getType(), DateUtil.beginOfDay(date), DateUtil.endOfDay(date)); + AutoTaskMessage message = autoTaskMessageRepository.findAutoTaskMessageTypeBetweenTime(setting.getType(), DateUtil.beginOfDay(date), DateUtil.endOfDay(date), setting.getSellerNick()); if (message != null) { return message; }