|
@@ -157,6 +157,38 @@ public class MusicGroupPaymentCalenderServiceImpl extends BaseServiceImpl<Long,
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public boolean autoUpdateMusicGroupPaymentCalenderStatus() {
|
|
|
+ //获取当天创建且未缴费的数据,并推送
|
|
|
+ List<MusicGroupPaymentCalenderDetail> details = musicGroupPaymentCalenderDetailDao.queryNoPaymentCanPushList();
|
|
|
+ if(details != null && details.size() > 0){
|
|
|
+ Set<String> musicGroupIds = details.stream().map(e -> e.getMusicGroupId()).collect(Collectors.toSet());
|
|
|
+ Map<String, String> musicGroupNameMap = MapUtil.convertMybatisMap(musicGroupDao.queryMusicGroupNameMap(musicGroupIds));
|
|
|
+ for (MusicGroupPaymentCalenderDetail detail:details) {
|
|
|
+ Map<Integer, String> push = new HashMap<>(1);
|
|
|
+ push.put(detail.getUserId(), detail.getUserId() + "");
|
|
|
+// MusicGroup musicGroup = musicGroupDao.get(detail.getMusicGroupId());
|
|
|
+ String baseUrl = sysConfigDao.findConfigValue(SysConfigService.BASE_API_URL);
|
|
|
+ String memo = "4?" + baseUrl + "/#/renew?musicGroupId=" + detail.getMusicGroupId();
|
|
|
+ // 发送续费通知
|
|
|
+ sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.STUDENT_PUSH_WAIT_RENEW_MESSAGE, push,
|
|
|
+ null, 0, memo, "STUDENT", musicGroupNameMap.get(detail.getMusicGroupId()));
|
|
|
+ }
|
|
|
+ /*Map<Integer,String> listMap = MapUtil.convertMybatisMap(musicGroupPaymentCalenderDetailDao.queryPaymentPushMap());
|
|
|
+ Set<Integer> studentIds = details.stream().map(e -> e.getUserId()).collect(Collectors.toSet());
|
|
|
+ String musicGroupId = details.get(0).getMusicGroupId();
|
|
|
+ if (studentIds.size() > 0) {
|
|
|
+ Map<Integer, String> push = new HashMap<>();
|
|
|
+ for (Integer userId : studentIds) {
|
|
|
+ push.put(userId, userId + "");
|
|
|
+ }
|
|
|
+ MusicGroup musicGroup = musicGroupDao.get(musicGroupId);
|
|
|
+ String baseUrl = sysConfigDao.findConfigValue(SysConfigService.BASE_API_URL);
|
|
|
+ String memo = "4?" + baseUrl + "/#/renew?musicGroupId=" + musicGroup.getId();
|
|
|
+ // 发送续费通知
|
|
|
+ sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.STUDENT_PUSH_WAIT_RENEW_MESSAGE, push,
|
|
|
+ null, 0, memo, "STUDENT", musicGroup.getName());
|
|
|
+ }*/
|
|
|
+ }
|
|
|
+
|
|
|
Date date = new Date();
|
|
|
List<PaymentStatusEnum> statusList = new ArrayList<PaymentStatusEnum>();
|
|
|
statusList.add(PaymentStatusEnum.NO);
|
|
@@ -372,4 +404,45 @@ public class MusicGroupPaymentCalenderServiceImpl extends BaseServiceImpl<Long,
|
|
|
});
|
|
|
return pageInfo;
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void paymentPush(Long id, String userIds) {
|
|
|
+ //推送所有
|
|
|
+ if(StringUtils.isEmpty(userIds)){
|
|
|
+ List<MusicGroupPaymentCalenderDetail> details = musicGroupPaymentCalenderDetailDao.queryCanPushList(id);
|
|
|
+ if(details == null || details.size() == 0){
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ String musicGroupId = details.get(0).getMusicGroupId();
|
|
|
+ Set<Integer> studentIds = details.stream().map(e -> e.getUserId()).collect(Collectors.toSet());
|
|
|
+ //推送消息
|
|
|
+ if (studentIds.size() > 0) {
|
|
|
+ Map<Integer, String> push = new HashMap<>();
|
|
|
+ for (Integer userId : studentIds) {
|
|
|
+ push.put(userId, userId + "");
|
|
|
+ }
|
|
|
+ MusicGroup musicGroup = musicGroupDao.get(musicGroupId);
|
|
|
+ String baseUrl = sysConfigDao.findConfigValue(SysConfigService.BASE_API_URL);
|
|
|
+ String memo = "4?" + baseUrl + "/#/renew?musicGroupId=" + musicGroupId;
|
|
|
+ // 发送续费通知
|
|
|
+ sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.STUDENT_PUSH_WAIT_RENEW_MESSAGE, push, null, 0, memo,"STUDENT",musicGroup.getName());
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ //获取课推送列表
|
|
|
+ //批量推送
|
|
|
+ MusicGroupPaymentCalender calender = musicGroupPaymentCalenderDao.get(id);
|
|
|
+ Set<String> studentIds = new HashSet<>(Arrays.asList(userIds.split(",")));
|
|
|
+ if (studentIds.size() > 0) {
|
|
|
+ Map<Integer, String> push = new HashMap<>();
|
|
|
+ for (String userId : studentIds) {
|
|
|
+ push.put(Integer.parseInt(userId), userId + "");
|
|
|
+ }
|
|
|
+ MusicGroup musicGroup = musicGroupDao.get(calender.getMusicGroupId());
|
|
|
+ String baseUrl = sysConfigDao.findConfigValue(SysConfigService.BASE_API_URL);
|
|
|
+ String memo = "4?" + baseUrl + "/#/renew?musicGroupId=" + calender.getMusicGroupId();
|
|
|
+ // 发送续费通知
|
|
|
+ sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.STUDENT_PUSH_WAIT_RENEW_MESSAGE, push, null, 0, memo,"STUDENT",musicGroup.getName());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|