心泉疗愈
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2025-02-28 dd663d0ac783755d889e270eee57ee58630c88c8 
 xinquan-modules/xinquan-user/src/main/java/com/xinquan/user/controller/client/ClientAppUserController.java


@@ -16,6 +16,8 @@


import com.xinquan.common.core.utils.page.CollUtils;


import com.xinquan.common.core.utils.page.PageDTO;


import com.xinquan.common.core.web.domain.BaseModel;


import com.xinquan.common.log.annotation.Log;


import com.xinquan.common.log.enums.BusinessType;


import com.xinquan.common.redis.service.RedisService;


import com.xinquan.common.security.service.TokenService;


import com.xinquan.common.security.utils.SecurityUtils;


@@ -23,6 +25,7 @@


import com.xinquan.course.api.domain.CourseCategory;


import com.xinquan.course.api.domain.CourseDTO;


import com.xinquan.course.api.domain.OrderCourseVO;


import com.xinquan.meditation.api.domain.Meditation;


import com.xinquan.order.api.feign.RemoteOrderService;


import com.xinquan.system.api.RemoteBannerService;


import com.xinquan.system.api.RemoteUserService;


@@ -62,6 +65,7 @@


import java.time.temporal.TemporalAdjusters;


import java.util.*;


import java.util.stream.Collectors;


import java.util.stream.Stream;




import io.swagger.models.auth.In;


import lombok.RequiredArgsConstructor;


@@ -122,6 +126,109 @@


    private RemoteUserService remoteUserService;


    @Resource


    private NoticeRecordService noticeRecordService;


    @Resource


    private AppUserBlackService appUserBlackService;




    /**


     * 远程调用 查询当前登陆人拉黑列表


     * @param appUserId


     */


    @PostMapping("/getUserBlackList/{appUserId}")


    public R<List<Long>> getUserBlackList(@PathVariable("appUserId") Long appUserId){


        List<Long> collect = appUserBlackService.lambdaQuery().eq(AppUserBlack::getAppUserId, appUserId).list()


                .stream().map(AppUserBlack::getBlackId).collect(Collectors.toList());


        return R.ok(collect);


    }


    @PostMapping("/blackUser")


    @ApiOperation(value = "取消拉黑功能", tags = "IOS拉黑列表--用于上架")


    @ApiImplicitParams({


            @ApiImplicitParam(value = "被拉黑用户id", name = "appUserId", required = true, dataType = "Long"),


    })


    public R blackUser(Long appUserId) {


        LoginUser loginUser = tokenService.getLoginUser();


        if (loginUser==null){


            return R.tokenError("登录失效");


        }


        AppUserBlack one = appUserBlackService.lambdaQuery().eq(AppUserBlack::getAppUserId, loginUser.getAppUserId())


                .eq(AppUserBlack::getBlackId, appUserId).one();


        if (one==null){


            // 拉黑


            AppUserBlack appUserBlack = new AppUserBlack();


            appUserBlack.setAppUserId(loginUser.getAppUserId());


            appUserBlack.setBlackId(appUserId);


            appUserBlackService.save(appUserBlack);


        }else {


            // 取消拉黑


            appUserBlackService.removeById(one.getId());


        }


        return R.ok();


    }


    @GetMapping("/blackList")


    @ApiOperation(value = "IOS拉黑列表", tags = "IOS拉黑列表--用于上架")


    @ApiImplicitParams({


            @ApiImplicitParam(value = "分页参数，当前页码", name = "pageCurr", required = true, dataType = "Integer"),


            @ApiImplicitParam(value = "分页参数，每页数量", name = "pageSize", required = true, dataType = "Integer")


    })


    public R<PageDTO<AppUser>> blackList(Integer pageCurr, Integer pageSize) {


        LoginUser loginUser = tokenService.getLoginUser();


        if (loginUser==null){


            return R.tokenError("登录失效");


        }


        List<Long> collect = appUserBlackService.lambdaQuery().eq(AppUserBlack::getAppUserId, loginUser.getAppUserId()).list()


                .stream().map(AppUserBlack::getBlackId).collect(Collectors.toList());


        if (collect.isEmpty()){


            collect.add(-1L);


        }


        Page<AppUser> page = appUserService.lambdaQuery().in(AppUser::getId, collect).page(new Page<>(pageCurr, pageSize));


        if (CollUtils.isEmpty(page.getRecords())){


            PageDTO<AppUser> empty = PageDTO.empty(page);


            return R.ok(empty);


        }


        return R.ok(PageDTO.of(page, AppUser.class));


    }




    @PostMapping("/subVipExpireTime/{appUserId}/{type}")


    public void subVipExpireTime(@PathVariable("appUserId") Long appUserId,@PathVariable("type") Integer type){


        AppUser byId = appUserService.getById(appUserId);


        switch (type){


            case 1:


                LocalDateTime localDateTime = byId.getVipExpireTime().minusDays(30);


                byId.setVipExpireTime(localDateTime);


                break;


            case 2:


                LocalDateTime localDateTime1 = byId.getVipExpireTime().minusDays(90);


                byId.setVipExpireTime(localDateTime1);


                break;


            case 3:


                LocalDateTime localDateTime2 = byId.getVipExpireTime().minusDays(365);


                byId.setVipExpireTime(localDateTime2);


                break;


        }


        appUserService.updateById(byId);


    }


    @ApiOperation(value = "会员临期", tags = "会员临期")


    @PostMapping("/testVip")


    public void testVip() {


        LocalDateTime now = LocalDateTime.now();


        List<AppUser> list = appUserService.lambdaQuery().ne(AppUser::getUserStatus, 3).list();


        for (AppUser appUser : list) {


            if (appUser.getVipExpireTime()!=null && appUser.getVipExpireTime().isAfter(now)){


                // 计算两个now和time的天数差


                long between = ChronoUnit.DAYS.between(now,appUser.getVipExpireTime());


                if (between<=7 &&between>=0){


                    NoticeRecord noticeRecord = new NoticeRecord();


                    noticeRecord.setAppUserId(appUser.getId());


                    noticeRecord.setReadStatus(1);


                    noticeRecord.setNoticeType(1);


                    noticeRecord.setTitle("【会员临期通知】");


                    noticeRecord.setContent("尊敬的泉疗愈会员你好,你的会员即将在"


                            +appUser.getVipExpireTime().toLocalDate()+"到期,到期后将不再享受会员权益,请及时续费");


                    noticeRecordService.save(noticeRecord);


                }


            }




        }


    }


    @GetMapping("/deleteBalance/{id}/{amount}")


    public R deleteBalance(@PathVariable("id")String id,@PathVariable("amount")String amount) {


        AppUser byId = appUserService.getById(id);


@@ -148,7 +255,7 @@


                    noticeRecord.setReadStatus(1);


                    noticeRecord.setNoticeType(1);


                    noticeRecord.setTitle("【会员临期通知】");


                    noticeRecord.setContent("尊敬的心泉疗愈会员你好,你的会员即将在"


                    noticeRecord.setContent("尊敬的泉疗愈会员你好,你的会员即将在"


                            +appUser.getVipExpireTime().toLocalDate()+"到期,到期后将不再享受会员权益,请及时续费");


                    noticeRecordService.save(noticeRecord);


                }


@@ -313,6 +420,7 @@


        StringBuilder stringBuilder = new StringBuilder();


        List<AppUser> list = appUserService.lambdaQuery()


                .eq(BaseModel::getDelFlag, 0)


                .isNotNull(AppUser::getCellPhone)


                .ne(AppUser::getUserStatus, 3).list();


        stringBuilder.append(list.size()).append(",");


        List<AppUser> memberList = list.stream().filter(appUser ->


@@ -423,14 +531,19 @@


    private TokenService tokenService;


    @PostMapping("/freezing")


    @ApiOperation(value = "冻结用户", tags = "管理后台-用户管理")




    @Log(title = "【用户管理】冻结用户", businessType = BusinessType.UPDATE)


    public R freezingDetail(@RequestBody UserFreezingDTO dto) {


        AppUser byId = appUserService.getById(dto.getUid());


        byId.setFreezingTime(LocalDateTime.now());


        byId.setFreezingReason(dto.getFreezingReason());


        byId.setUserStatus(2);


        byId.setFreezingOperator(tokenService.getLoginUser().getUserid()+"");


        Long userid = tokenService.getLoginUser().getUserid();


        SysUser data = remoteUserService.getSysUserById(userid + "").getData();


        byId.setFreezingOperator(data.getNickName()+"("+data.getUserName()+")");


        appUserService.updateById(byId);


        String cacheList = redisService.getCacheObject(byId.getId() + "");


        redisService.deleteObject(cacheList);




        return R.ok();


    }


    @GetMapping("/detail")


@@ -471,6 +584,7 @@


    }


    @GetMapping("/unFreezing")


    @ApiOperation(value = "解冻用户", tags = "管理后台-用户管理")


    @Log(title = "【用户管理】解冻用户", businessType = BusinessType.UPDATE)


    public R unFreezing(String uid) {


        AppUser byId = appUserService.getById(uid);


        byId.setUserStatus(1);


@@ -499,6 +613,8 @@


            @ApiImplicitParam(name = "energyValue", value = "能量值", dataType = "int", required = true),


            @ApiImplicitParam(name = "reason", value = "备注", dataType = "String", required = true)


    })


    @Log(title = "【用户管理】能量值修改", businessType = BusinessType.UPDATE)




    public R setTotalEnergyValue(String uid,Integer energyValue,String reason) {


        AppUser byId = appUserService.getById(uid);


        if (energyValue<0){


@@ -507,7 +623,6 @@


            }


        }


        byId.setTotalEnergyValue(byId.getTotalEnergyValue()+energyValue);


        byId.setEnergyValue(byId.getEnergyValue()+energyValue);


        appUserService.updateById(byId);


        AppUserEnergyRecord appUserEnergyRecord = new AppUserEnergyRecord();


        appUserEnergyRecord.setAppUserId(byId.getId());


@@ -534,6 +649,8 @@


            @ApiImplicitParam(name = "vipType", value = "会员类型 1非 2月 3季 4年", dataType = "Integer", required = true),


            @ApiImplicitParam(name = "vipExpireTime", value = "会员到期时间 yyyy-MM-dd HH:mm", dataType = "String", required = true),


    })


    @Log(title = "【用户管理】设置会员", businessType = BusinessType.UPDATE)




    public R setVip(String uid, Integer vipType,String vipExpireTime) {


        // 将其转化为LocalDateTime格式


        LocalDateTime parse = LocalDateTime.parse(vipExpireTime, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));


@@ -608,8 +725,8 @@


        String endTime = null;


        if (org.springframework.util.StringUtils.hasLength(dto.getTime())){


            String[] split = dto.getTime().split(" - ");


            startTime = split[0]+"00:00:00";


            endTime = split[1]+"23:59:59";


            startTime = split[0]+" 00:00:00";


            endTime = split[1]+" 23:59:59";


        }


        String userId = dto.getUid();


        LambdaQueryWrapper<AppUser> appUserWalletRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();


@@ -618,6 +735,7 @@


        appUserWalletRecordLambdaQueryWrapper.like(org.springframework.util.StringUtils.hasLength(dto.getCellPhone()),AppUser::getCellPhone,dto.getCellPhone());


        appUserWalletRecordLambdaQueryWrapper.like(org.springframework.util.StringUtils.hasLength(dto.getNickName()),AppUser::getNickname,dto.getNickName());


        appUserWalletRecordLambdaQueryWrapper.orderByDesc(BaseModel::getCreateTime);


        appUserWalletRecordLambdaQueryWrapper.isNotNull(AppUser::getCellPhone);


        List<AppUser> page = appUserService


                .list(appUserWalletRecordLambdaQueryWrapper);


        List<UserInfoExport> userInfoExports = new ArrayList<>();


@@ -675,15 +793,15 @@


        String endTime = null;


        if (org.springframework.util.StringUtils.hasLength(courseDTO.getVipExpireTime())){


            String[] split = courseDTO.getVipExpireTime().split(" - ");


            startTime = split[0]+"00:00:00";


            endTime = split[1]+"23:59:59";


            startTime = split[0]+" 00:00:00";


            endTime = split[1]+" 23:59:59";


        }


        String startTime1 = null;


        String endTime1 = null;


        if (org.springframework.util.StringUtils.hasLength(courseDTO.getRegisterTime())){


            String[] split = courseDTO.getRegisterTime().split(" - ");


            startTime1 = split[0]+"00:00:00";


            endTime1 = split[1]+"23:59:59";


            startTime1 = split[0]+" 00:00:00";


            endTime1 = split[1]+" 23:59:59";


        }


        List<Long> longs = new ArrayList<>();


        LambdaQueryWrapper<AppUser> courseLambdaQueryWrapper = new LambdaQueryWrapper<>();


@@ -693,7 +811,8 @@


                .eq(Objects.nonNull(courseDTO.getGender()), AppUser::getGender, courseDTO.getGender())


                .eq(Objects.nonNull(courseDTO.getUserStatus()), AppUser::getUserStatus, courseDTO.getUserStatus())


                .between(Objects.nonNull(startTime),AppUser::getVipExpireTime,startTime,endTime)


                .between(Objects.nonNull(startTime1),AppUser::getRegisterTime,startTime1,endTime1)


                .between(Objects.nonNull(startTime1),AppUser::getRegisterTime,startTime1,endTime1);


        courseLambdaQueryWrapper.isNotNull(AppUser::getCellPhone)


                .orderByDesc(AppUser::getRegisterTime);


        if (org.springframework.util.StringUtils.hasLength(courseDTO.getVipType())){


            String[] split = courseDTO.getVipType().split(",");


@@ -718,23 +837,11 @@


            List<AppUser> list = appUserService.lambdaQuery().list();


            List<AppUser> appUsers = new ArrayList<>();


            for (AppUser appUser : list) {


                List<AppUserTree> list1 = appUserTreeService.lambdaQuery().eq(AppUserTree::getAppUserId, appUser.getId())


                        .list();


                // 查询用户等级最高的那颗树苗


                AppUserTree tree = list1.stream().max((o1, o2) -> {


                    if (o1.getTreeLevelType() > o2.getTreeLevelType()) {


                        return 1;


                    } else if (o1.getTreeLevelType() < o2.getTreeLevelType()) {


                        return -1;


                    } else {


                        return 0;


                    }


                }).orElse(null);


                AppUserTree list1 = appUserTreeService.lambdaQuery().eq(AppUserTree::getAppUserId, appUser.getId())


                        .eq(AppUserTree::getSowAgain,2)


                        .one();


                // 查询疗愈等级 名称 图标


                int level = 1;


                if (tree != null){


                    level = tree.getTreeLevelType();


                }


                int level = list1.getTreeLevelType();


                if (list2.contains(level+"")){


                    appUsers.add(appUser);


                }


@@ -745,6 +852,7 @@


            }


            courseLambdaQueryWrapper.in(AppUser::getId, collect);


        }


        courseLambdaQueryWrapper.isNotNull(AppUser::getCellPhone);


        List<AppUser> page = appUserService.list(courseLambdaQueryWrapper);


        List<UserExport> userExports = new ArrayList<>();


        for (AppUser record : page) {


@@ -757,23 +865,11 @@


            }else{


                record.setIsVip(1);


            }


            List<AppUserTree> list1 = appUserTreeService.lambdaQuery().eq(AppUserTree::getAppUserId, record.getId())


                    .list();


            // 查询用户等级最高的那颗树苗


            AppUserTree tree = list1.stream().max((o1, o2) -> {


                if (o1.getTreeLevelType() > o2.getTreeLevelType()) {


                    return 1;


                } else if (o1.getTreeLevelType() < o2.getTreeLevelType()) {


                    return -1;


                } else {


                    return 0;


                }


            }).orElse(null);


            AppUserTree list1 = appUserTreeService.lambdaQuery().eq(AppUserTree::getAppUserId, record.getId())


                    .eq(AppUserTree::getSowAgain,2)


                    .one();


            // 查询疗愈等级 名称 图标


            int level = 1;


            if (tree != null){


                level = tree.getTreeLevelType();


            }


            int level = list1.getTreeLevelType();


            // 根据等级查询疗愈名称和图标


            UserLevelSetting data = remoteBannerService.getIconNameByLevel(level).getData();


            record.setLevel(level);


@@ -813,6 +909,13 @@


            userExport.setUserStatus(record.getUserStatus()+"");


            List<AppUserQuestion> list = appUserQuestionService.lambdaQuery()


                    .eq(AppUserQuestion::getAppUserId, record.getId()).list();


                userExport.setType1("");


                userExport.setType2("");


                userExport.setType3("");


                userExport.setType4("");


                userExport.setType5("");


                userExport.setType6("");


                userExport.setType6("");


            for (AppUserQuestion appUserQuestion : list) {


                switch (appUserQuestion.getType()){


                    case 1:


@@ -835,17 +938,15 @@


                        break;


                }


            }


            List<Integer> collect = appUserTagService.lambdaQuery()


                    .eq(AppUserTag::getAppUserId, record.getId()).list().stream()


                    .map(AppUserTag::getTagId)


                    .collect(Collectors.toList());


            if (collect.isEmpty()){


                collect.add(-1);


            List<String> collect = new ArrayList<>();


            if (org.springframework.util.StringUtils.hasLength(record.getTagId())) {


                collect = tagService.lambdaQuery()


                        .in(Tag::getId, Arrays.stream(record.getTagId().split(",")).map(Long::parseLong).collect(Collectors.toList())).list().stream()


                                .map(Tag::getTagName).collect(Collectors.toList());


            }


            List<Tag> list2 = tagService.lambdaQuery().in(Tag::getId, collect).list();


            StringBuilder stringBuilder = new StringBuilder();


            for (Tag tag : list2) {


                stringBuilder.append(tag.getTagName()).append(";");


            for (String tag : collect) {


                stringBuilder.append(tag).append(";");


            }


            userExport.setType7(stringBuilder+"");


            userExport.setSanskritFlag(record.getSanskritFlag()+"");


@@ -884,15 +985,15 @@


        String endTime = null;


        if (org.springframework.util.StringUtils.hasLength(courseDTO.getVipExpireTime())){


            String[] split = courseDTO.getVipExpireTime().split(" - ");


            startTime = split[0]+"00:00:00";


            endTime = split[1]+"23:59:59";


            startTime = split[0]+" 00:00:00";


            endTime = split[1]+" 23:59:59";


        }


        String startTime1 = null;


        String endTime1 = null;


        if (org.springframework.util.StringUtils.hasLength(courseDTO.getRegisterTime())){


            String[] split = courseDTO.getRegisterTime().split(" - ");


            startTime1 = split[0]+"00:00:00";


            endTime1 = split[1]+"23:59:59";


            startTime1 = split[0]+" 00:00:00";


            endTime1 = split[1]+" 23:59:59";


        }


        List<Long> longs = new ArrayList<>();


        LambdaQueryWrapper<AppUser> courseLambdaQueryWrapper = new LambdaQueryWrapper<>();


@@ -1064,7 +1165,7 @@


            String key = keyPrefix + cellPhone;


            String code = redisService.getCacheObject(key);


            // 万能验证码


            if (captcha.equals("123456") || (com.xinquan.common.core.utils.StringUtils.isNotBlank(code) && code.equals(


            if (captcha.equals("220125") || (com.xinquan.common.core.utils.StringUtils.isNotBlank(code) && code.equals(


                    captcha))) {


                redisService.deleteObject(key);


                return true;


@@ -1191,7 +1292,7 @@


        page.sort((o1, o2) -> o2.getMoney().compareTo(o1.getMoney()));




        List<AppUser> testing = testing(page.size(), pageCurr, pageSize, page);


        objectPage.setTotal(testing.size());


        objectPage.setTotal(page.size());


        objectPage.setRecords(testing);


        return R.ok(PageDTO.of(objectPage, InviteRankListVO.class));


    }


@@ -1284,6 +1385,23 @@


        objectPage.setRecords(testing);


        objectPage.setTotal(res.size());


        return R.ok(PageDTO.of(objectPage, InviteRankListVO.class)) ;


    }


    @PostMapping("/inviteRankListShareInfo")


    @ApiOperation(value = "爱心助力榜单详情-分页", tags = {"H5分享"})


    @ApiImplicitParams({


            @ApiImplicitParam(value = "id", name = "id", required = true, dataType = "Long"),


            @ApiImplicitParam(value = "分页参数，当前页码", name = "pageCurr", required = true, dataType = "Integer"),


            @ApiImplicitParam(value = "分页参数，每页数量", name = "pageSize", required = true, dataType = "Integer")


    })


    public R<PageDTO<InviteRankListVO>> inviteRankListShareInfo(


            @RequestParam(value = "id") Long id,


            @RequestParam(value = "pageCurr", defaultValue = "1") Integer pageCurr,


            @RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize) {


        LambdaQueryWrapper<AppUser> appUserLambdaQueryWrapper = new LambdaQueryWrapper<>();


        appUserLambdaQueryWrapper.eq(AppUser::getInviteUserId,id);


        appUserLambdaQueryWrapper.ne(AppUser::getUserStatus,3);


        Page<AppUser> page = appUserService.page(new Page<>(pageCurr, pageSize), appUserLambdaQueryWrapper);


        return R.ok(PageDTO.of(page, InviteRankListVO.class)) ;


    }


    @PostMapping("/getUserInfo")


    @ApiOperation(value = "获取用户信息", tags = {"个人中心"})


@@ -1579,9 +1697,17 @@


    @PostMapping("/getUserByPhone")


    @ApiOperation(value = "根据用户手机号查询用户信息")


    public R<AppUserDetailVO> getCurrentUser(String phone) {


        LoginUser loginUser = tokenService.getLoginUser();


        if (loginUser==null){


            return R.tokenError("登录失效");


        }




        AppUser one = appUserService.lambdaQuery().eq(AppUser::getCellPhone, phone)


                .ne(AppUser::getUserStatus,3).one();


        if (one!=null){


            if (one.getId().equals(loginUser.getUserid())){


                return R.giveError("不能赠送给自己");


            }


            AppUserDetailVO appUserDetailVO = new AppUserDetailVO();


            appUserDetailVO.setId(one.getId());


            appUserDetailVO.setCellPhone(one.getCellPhone());