From 111652d23733d04e379c2454c8b39171596a6b50 Mon Sep 17 00:00:00 2001 From: 无关风月 <443237572@qq.com> Date: 星期六, 09 十一月 2024 14:28:51 +0800 Subject: [PATCH] 代码提交 --- xinquan-modules/xinquan-meditation/src/main/java/com/xinquan/meditation/controller/client/ClientMeditationQuestionController.java | 56 +++++++++++++++++++++++++++++++++++++++++--------------- 1 files changed, 41 insertions(+), 15 deletions(-) diff --git a/xinquan-modules/xinquan-meditation/src/main/java/com/xinquan/meditation/controller/client/ClientMeditationQuestionController.java b/xinquan-modules/xinquan-meditation/src/main/java/com/xinquan/meditation/controller/client/ClientMeditationQuestionController.java index 8dc4c3e..cb0513b 100644 --- a/xinquan-modules/xinquan-meditation/src/main/java/com/xinquan/meditation/controller/client/ClientMeditationQuestionController.java +++ b/xinquan-modules/xinquan-meditation/src/main/java/com/xinquan/meditation/controller/client/ClientMeditationQuestionController.java @@ -17,14 +17,12 @@ import com.xinquan.meditation.domain.export.QuestionExport; import com.xinquan.meditation.service.MeditationCategoryService; import com.xinquan.meditation.service.MeditationQuestionService; -import com.xinquan.meditation.service.MeditationQuestionService; import com.xinquan.meditation.service.MeditationService; -import com.xinquan.system.api.RemoteUserService; import com.xinquan.system.api.domain.AppUser; -import com.xinquan.system.api.domain.MeditationQuestion; +import com.xinquan.meditation.api.domain.MeditationQuestion; import com.xinquan.meditation.api.domain.vo.NoticeDetailVO; +import com.xinquan.system.api.domain.NoticeRecord; import com.xinquan.system.api.model.LoginUser; -import com.xinquan.user.api.domain.dto.OrderListDTO; import com.xinquan.user.api.feign.RemoteAppUserService; import io.swagger.annotations.ApiOperation; import org.apache.poi.ss.usermodel.Workbook; @@ -39,9 +37,7 @@ import java.net.URLEncoder; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.List; +import java.util.*; import java.util.stream.Collectors; /** @@ -66,6 +62,12 @@ @Autowired private TokenService tokenService; + @GetMapping("/getMeditationQuestion/{id}") + public R<MeditationQuestion> getMeditationQuestion(@PathVariable("id") String id){ + MeditationQuestion byId = meditationQuestionService.getById(id); + return R.ok(byId); + } + /** * 远程调用 查询待回复内容数量 * @return @@ -122,9 +124,9 @@ } meditationLambdaQueryWrapper.in(MeditationQuestion::getAppUserId,data); } - if (StringUtils.hasLength(dto.getName())){ + if (StringUtils.hasLength(dto.getMeditationName())){ List<Long> collect = meditationService.lambdaQuery() - .like(Meditation::getMeditationTitle, dto.getName()) + .like(Meditation::getMeditationTitle, dto.getMeditationName()) .list().stream().map(Meditation::getId).collect(Collectors.toList()); if (collect.isEmpty()){ collect.add(-1L); @@ -196,9 +198,9 @@ meditationLambdaQueryWrapper.eq(dto.getShowFlag()!=null,MeditationQuestion::getShowFlag, dto.getShowFlag()); if (dto.getIsReplay()!=null){ if (dto.getIsReplay() == 1){ - meditationLambdaQueryWrapper.isNotNull(MeditationQuestion::getReplyTime); + meditationLambdaQueryWrapper.isNotNull(MeditationQuestion::getReplyContent); }else{ - meditationLambdaQueryWrapper.isNull(MeditationQuestion::getReplyTime); + meditationLambdaQueryWrapper.isNull(MeditationQuestion::getReplyContent); } } if (StringUtils.hasLength(dto.getUserName())){ @@ -208,15 +210,17 @@ } meditationLambdaQueryWrapper.in(MeditationQuestion::getAppUserId,data); } - if (StringUtils.hasLength(dto.getName())){ + if (StringUtils.hasLength(dto.getMeditationName())){ List<Long> collect = meditationService.lambdaQuery() - .like(Meditation::getMeditationTitle, dto.getName()) + .like(Meditation::getMeditationTitle, dto.getMeditationName()) .list().stream().map(Meditation::getId).collect(Collectors.toList()); if (collect.isEmpty()){ collect.add(-1L); } meditationLambdaQueryWrapper.in(MeditationQuestion::getMeditationId,collect); } + meditationLambdaQueryWrapper.orderBy(true, true, MeditationQuestion::getReplyContent); // "reply_content IS NULL" 确保 null 排前面 + meditationLambdaQueryWrapper.orderByDesc(MeditationQuestion::getCreateTime); Page<MeditationQuestion> page = meditationQuestionService.page(new Page<>(dto.getPageCurr(), dto.getPageSize()), meditationLambdaQueryWrapper); if (CollUtils.isEmpty(page.getRecords())) { @@ -231,15 +235,21 @@ record.setCellPhone(data.getCellPhone()); } Meditation byId = meditationService.getById(record.getMeditationId()); + if (byId!=null){ record.setChargeType(byId.getChargeType()); + MeditationCategory byId1 = meditationCategoryService.getById(byId.getCateId()); + if (byId1!=null){ + record.setMeditationCategoryName(byId1.getCategoryName()); + } record.setMeditationName(byId.getMeditationTitle()); if (byId.getChargeType()!=null &&byId.getChargeType() == 3){ record.setMoney(byId.getGeneralPrice()); } } - } +// List<MeditationQuestion> records = page.getRecords(); +// page.setRecords(records); return R.ok(PageDTO.of(page, MeditationQuestion.class)); } @PostMapping("/addMeditationQuestion") @@ -275,19 +285,35 @@ if (byId1!=null){ byId.setMeditationName(byId1.getMeditationTitle()); byId.setChargeType(byId1.getChargeType()); + byId.setCoverUrl(byId1.getCoverUrl().split(",")[0]); } MeditationCategory byId2 = meditationCategoryService.getById(byId1.getCateId()); if (byId2!=null){ byId.setMeditationCategoryName(byId2.getCategoryName()); } - return R.ok(); + return R.ok(byId); } @PostMapping("/updateMeditationQuestion") @ApiOperation(value = "修改提问管理", tags = "管理后台-提问管理") public R updateMeditationQuestion(@RequestBody MeditationQuestion homeBackgroundMusic) { + Long id = homeBackgroundMusic.getId(); + MeditationQuestion byId = meditationQuestionService.getById(id); homeBackgroundMusic.setUpdateBy(SecurityUtils.getUsername()); homeBackgroundMusic.setUpdateTime(LocalDateTime.now()); + if (homeBackgroundMusic.getType() == 1){ + homeBackgroundMusic.setReplyTime(LocalDateTime.now()); + // 给用户添加一条系统消息 + NoticeRecord noticeRecord = new NoticeRecord(); + noticeRecord.setAppUserId(byId.getAppUserId()); + noticeRecord.setMeditationQuestionId(homeBackgroundMusic.getId()); + noticeRecord.setReadStatus(1); + noticeRecord.setNoticeType(2); + noticeRecord.setMeditationId(byId.getMeditationId()); + noticeRecord.setTitle("平台回复通知"); + noticeRecord.setContent(homeBackgroundMusic.getReplyContent()); + remoteAppUserService.addNoticeReplay(noticeRecord); + } return R.ok(meditationQuestionService.updateById(homeBackgroundMusic)); } @PostMapping("/deleteMeditationQuestion") -- Gitblit v1.7.1