代码提交

无关风月

2024-11-09 fef8e1050da603344ed8bda819d390c2c16551ea

 xinquan-modules/xinquan-user/src/main/java/com/xinquan/user/utils/TaskUtil.java

@@ -102,8 +102,58 @@
                        +appUser.getVipExpireTime().toLocalDate()+"到期,到期后将不再享受会员权益,请及时续费");
                        noticeRecordService.save(noticeRecord);
                    }

                }
                AppUserTree one = appUserTreeService.lambdaQuery().eq(AppUserTree::getAppUserId, appUser.getId())
                        .eq(AppUserTree::getSowAgain, 2).one();
                if(one.getTaskOne()==2||one.getTaskTwo()==2){
                    NoticeRecord noticeRecord = new NoticeRecord();
                    noticeRecord.setAppUserId(appUser.getId());
                    noticeRecord.setReadStatus(1);
                    noticeRecord.setNoticeType(1);
                    noticeRecord.setTitle("【冥想通知】");
                    noticeRecord.setContent("你今天的冥想任务还未完成，完成冥想后可获得能量值奖励，快去冥想吧！");
                    noticeRecordService.save(noticeRecord);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    @Scheduled(cron = "0 0 21 * * ?")
    public void taskNineDay() {
        try {
            LocalDateTime now = LocalDateTime.now();
            List<AppUser> list = appUserService.lambdaQuery().ne(AppUser::getUserStatus, 3).list();
            for (AppUser appUser : list) {
                AppUserTree one = appUserTreeService.lambdaQuery().eq(AppUserTree::getAppUserId, appUser.getId())
                        .eq(AppUserTree::getSowAgain, 2).one();
                if(one.getTaskOne()==2||one.getTaskTwo()==2){
                    NoticeRecord noticeRecord = new NoticeRecord();
                    noticeRecord.setAppUserId(appUser.getId());
                    noticeRecord.setReadStatus(1);
                    noticeRecord.setNoticeType(1);
                    noticeRecord.setTitle("【冥想通知】");
                    noticeRecord.setContent("你今天的冥想任务还未完成，完成冥想后可获得能量值奖励，快去冥想吧！");
                    noticeRecordService.save(noticeRecord);
                }
                if (appUser.getSignTime()==null){
                    NoticeRecord noticeRecord = new NoticeRecord();
                    noticeRecord.setAppUserId(appUser.getId());
                    noticeRecord.setReadStatus(1);
                    noticeRecord.setNoticeType(1);
                    noticeRecord.setTitle("【签到通知】");
                    noticeRecord.setContent("你今天还未签到，及时签到可获得能量值奖励，快去签到吧！");
                    noticeRecordService.save(noticeRecord);
                }else if (!appUser.getSignTime().toLocalDate().equals(LocalDateTime.now().toLocalDate())){
                    NoticeRecord noticeRecord = new NoticeRecord();
                    noticeRecord.setAppUserId(appUser.getId());
                    noticeRecord.setReadStatus(1);
                    noticeRecord.setNoticeType(1);
                    noticeRecord.setTitle("【签到通知】");
                    noticeRecord.setContent("你今天还未签到，及时签到可获得能量值奖励，快去签到吧！");
                    noticeRecordService.save(noticeRecord);
                }

            }
        } catch (Exception e) {
            e.printStackTrace();