Ver Fonte

增加指定账号发送

xueyiming há 7 meses atrás
pai
commit
530d0427df

+ 3 - 0
we-com-server/src/main/java/com/tzld/piaoquan/wecom/job/WeComMessageDataJob.java

@@ -229,6 +229,9 @@ public class WeComMessageDataJob {
     @XxlJob("pushSendMessageJob")
     @XxlJob("pushSendMessageJob")
     public ReturnT<String> pushSendMessage(String param) {
     public ReturnT<String> pushSendMessage(String param) {
         List<SendMessage> groupList = sendMessageMapper.getGroupList(DateUtil.getThatDayDate(), 0);
         List<SendMessage> groupList = sendMessageMapper.getGroupList(DateUtil.getThatDayDate(), 0);
+        if (StringUtils.isNotEmpty(param)) {
+            groupList = groupList.stream().filter(e -> e.getStaffId() == Long.parseLong(param)).collect(Collectors.toList());
+        }
         for (SendMessage sendMessage : groupList) {
         for (SendMessage sendMessage : groupList) {
             sendMessage.setIsSend(0);
             sendMessage.setIsSend(0);
             sendMessage.setCreateTime(DateUtil.getThatDayDate());
             sendMessage.setCreateTime(DateUtil.getThatDayDate());