From f615ec5c9239327740948501627545f8e78e2a9e Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期二, 18 三月 2025 09:07:26 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShareController.java | 55 +++++++++++++++++++++++++++++++++++-------------------- 1 files changed, 35 insertions(+), 20 deletions(-) diff --git a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShareController.java b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShareController.java index d128ada..231e8f9 100644 --- a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShareController.java +++ b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShareController.java @@ -152,12 +152,11 @@ if(sysUser.getRoleType() == 2){ share.setObjectId(sysUser.getObjectId().longValue()); } -// if (sysUser.getRoleType() == 1){ -// share.setAuditStatus(ShareAuditStatus.SUCCESS.getCode()); -// }else{ -// share.setAuditStatus(ShareAuditStatus.WAIT.getCode()); -// } - share.setAuditStatus(ShareAuditStatus.WAIT.getCode()); + if (sysUser.getRoleType() == 1){ + share.setAuditStatus(ShareAuditStatus.SUCCESS.getCode()); + }else{ + share.setAuditStatus(ShareAuditStatus.WAIT.getCode()); + } share.setDelFlag(0); shareService.save(share); return R.ok(); @@ -256,6 +255,16 @@ userIds.addAll(userList.stream().map(AppUser::getId).collect(Collectors.toList())); } + List<Share> list = shareService.list(); + if (CollectionUtils.isEmpty(list)){ + return R.ok(Page.of(pageNum, pageSize)); + } + List<Long> objectIds = list.stream().map(Share::getObjectId).distinct().collect(Collectors.toList()); + List<AppUser> appUsers = appUserClient.listByIds(objectIds); + List<Long> appUserIds = appUsers.stream().filter(item -> !item.getDelFlag()).map(AppUser::getId).collect(Collectors.toList()); + if (CollectionUtils.isEmpty(userIds)){ + userIds = appUserIds; + } Page<Share> page = shareService.lambdaQuery() @@ -265,7 +274,6 @@ .eq(auditStatus != null, Share::getAuditStatus, auditStatus) .in(!CollectionUtils.isEmpty(userIds),Share::getObjectId, userIds) .eq(Share::getDelFlag, 0) - .orderByAsc(Share::getAuditStatus) .orderByDesc(Share::getCreateTime) .page(Page.of(pageNum, pageSize)); for (Share record : page.getRecords()) { @@ -307,7 +315,8 @@ @ApiOperation(value = "获取小程序分享数据", tags = {"小程序-分享"}) @GetMapping("/auth/getAppletShare") public R<Share> getAppletShare(){ - Share one = shareService.getOne(new LambdaQueryWrapper<Share>().eq(Share::getDelFlag, 0).eq(Share::getAppletShare, 1).eq(Share::getAuditStatus, 1).last(" limit 0, 1")); + Share one = shareService.getOne(new LambdaQueryWrapper<Share>().eq(Share::getDelFlag, 0).eq(Share::getAppletShare, 1) + .eq(Share::getAuditStatus, 1).last(" limit 0, 1")); //添加每日分享积分 String token = SecurityUtils.getToken(ServletUtils.getRequest()); if(StringUtils.isNotEmpty(token)){ @@ -315,7 +324,8 @@ Boolean data = userPointClient.judgmentDailyShare(userid).getData(); if(!data){ AppUser appUser = appUserClient.getAppUserById(userid); - PointSetting pointSetting = pointSettingService.getOne(new LambdaQueryWrapper<PointSetting>().eq(PointSetting::getId, appUser.getVipId()).eq(PointSetting::getDelFlag, 0)); + PointSetting pointSetting = pointSettingService.getOne(new LambdaQueryWrapper<PointSetting>() + .eq(PointSetting::getId, appUser.getVipId()).eq(PointSetting::getDelFlag, 0)); if(null != pointSetting){ Integer everySharePoint = pointSetting.getEverySharePoint(); Integer lavePoint = appUser.getLavePoint(); @@ -327,23 +337,28 @@ appUser.setTotalPoint(appUser.getTotalPoint() + everySharePoint); appUserClient.editAppUserById(appUser); //添加积分流水 - if(everySharePoint > 0){ - UserPoint userPoint = new UserPoint(); - userPoint.setAppUserId(userid); - userPoint.setType(4); - userPoint.setHistoricalPoint(lavePoint); - userPoint.setVariablePoint(everySharePoint); - userPoint.setBalance(appUser.getLavePoint()); - userPoint.setCreateTime(LocalDateTime.now()); - userPoint.setAppUserId(appUser.getId()); - userPointClient.saveUserPoint(userPoint); - } + UserPoint userPoint = new UserPoint(); + userPoint.setAppUserId(userid); + userPoint.setType(4); + userPoint.setHistoricalPoint(lavePoint); + userPoint.setVariablePoint(everySharePoint); + userPoint.setBalance(appUser.getLavePoint()); + userPoint.setCreateTime(LocalDateTime.now()); + userPoint.setAppUserId(appUser.getId()); + userPointClient.saveUserPoint(userPoint); } } } return R.ok(one); } + + //appUserShare/ + @GetMapping("/saveAppUserShare") + public R<Share> saveAppUserShare() { + return getAppletShare(); + } + } -- Gitblit v1.7.1