|
|
@@ -429,38 +429,38 @@ public class MarketingCampaignServiceImpl
|
|
|
c.setStatus(expected);
|
|
|
changed.add(c);
|
|
|
}
|
|
|
- // 每种目标状态执行一次批量 UPDATE
|
|
|
- for (Map.Entry<Integer, List<Long>> entry : idsByStatus.entrySet()) {
|
|
|
- List<Long> ids = entry.getValue();
|
|
|
- if (CollectionUtils.isEmpty(ids)) {
|
|
|
- continue;
|
|
|
- }
|
|
|
- this.lambdaUpdate()
|
|
|
- .in(MarketingCampaignEntity::getId, ids)
|
|
|
- .set(MarketingCampaignEntity::getStatus, entry.getKey())
|
|
|
- .update();
|
|
|
- }
|
|
|
- // 按目标状态拆分列表并打印:哪些改为开始、哪些改为结束
|
|
|
- List<Long> started = changed.stream()
|
|
|
- .filter(e -> STATUS_RUNNING == e.getStatus())
|
|
|
- .map(MarketingCampaignEntity::getId)
|
|
|
- .collect(Collectors.toList());
|
|
|
- List<Long> ended = changed.stream()
|
|
|
- .filter(e -> STATUS_COMPLETED == e.getStatus())
|
|
|
- .map(MarketingCampaignEntity::getId)
|
|
|
- .collect(Collectors.toList());
|
|
|
- log.info("营销活动开始/结束状态同步完成:改为开始(运行中)={}, 改为结束(完成)={}", started, ended);
|
|
|
- MarketEmailsCustomerVO startVO = new MarketEmailsCustomerVO();
|
|
|
- startVO.setMarketingCampaignIdList(started);
|
|
|
- //修改状态为待发送
|
|
|
- startVO.setStatus(-1);
|
|
|
- marketEmailsService.updateCustomerEmailStatus(startVO);
|
|
|
-
|
|
|
- MarketEmailsCustomerVO endVO = new MarketEmailsCustomerVO();
|
|
|
- endVO.setMarketingCampaignIdList(ended);
|
|
|
- //修改状态为待发送
|
|
|
- endVO.setStatus(-3);
|
|
|
- marketEmailsService.updateCustomerEmailStatus(endVO);
|
|
|
+// // 每种目标状态执行一次批量 UPDATE
|
|
|
+// for (Map.Entry<Integer, List<Long>> entry : idsByStatus.entrySet()) {
|
|
|
+// List<Long> ids = entry.getValue();
|
|
|
+// if (CollectionUtils.isEmpty(ids)) {
|
|
|
+// continue;
|
|
|
+// }
|
|
|
+// this.lambdaUpdate()
|
|
|
+// .in(MarketingCampaignEntity::getId, ids)
|
|
|
+// .set(MarketingCampaignEntity::getStatus, entry.getKey())
|
|
|
+// .update();
|
|
|
+// }
|
|
|
+// // 按目标状态拆分列表并打印:哪些改为开始、哪些改为结束
|
|
|
+// List<Long> started = changed.stream()
|
|
|
+// .filter(e -> STATUS_RUNNING == e.getStatus())
|
|
|
+// .map(MarketingCampaignEntity::getId)
|
|
|
+// .collect(Collectors.toList());
|
|
|
+// List<Long> ended = changed.stream()
|
|
|
+// .filter(e -> STATUS_COMPLETED == e.getStatus())
|
|
|
+// .map(MarketingCampaignEntity::getId)
|
|
|
+// .collect(Collectors.toList());
|
|
|
+// log.info("营销活动开始/结束状态同步完成:改为开始(运行中)={}, 改为结束(完成)={}", started, ended);
|
|
|
+// MarketEmailsCustomerVO startVO = new MarketEmailsCustomerVO();
|
|
|
+// startVO.setMarketingCampaignIdList(started);
|
|
|
+// //修改状态为待发送
|
|
|
+// startVO.setStatus(-1);
|
|
|
+// marketEmailsService.updateCustomerEmailStatus(startVO);
|
|
|
+//
|
|
|
+// MarketEmailsCustomerVO endVO = new MarketEmailsCustomerVO();
|
|
|
+// endVO.setMarketingCampaignIdList(ended);
|
|
|
+// //修改状态为待发送
|
|
|
+// endVO.setStatus(-3);
|
|
|
+// marketEmailsService.updateCustomerEmailStatus(endVO);
|
|
|
}
|
|
|
|
|
|
/**
|