diff --git a/mcwl-admin/src/main/java/com/mcwl/web/controller/communityCenter/ChatController.java b/mcwl-admin/src/main/java/com/mcwl/web/controller/communityCenter/ChatController.java index a960b17..ee0f2de 100644 --- a/mcwl-admin/src/main/java/com/mcwl/web/controller/communityCenter/ChatController.java +++ b/mcwl-admin/src/main/java/com/mcwl/web/controller/communityCenter/ChatController.java @@ -1,28 +1,29 @@ package com.mcwl.web.controller.communityCenter; +import com.mcwl.communityCenter.service.AIService; import com.mcwl.communityCenter.webSocket.ChatWebSocket; import lombok.RequiredArgsConstructor; +import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import reactor.core.publisher.Flux; @RequiredArgsConstructor @RestController @RequestMapping("/chat") public class ChatController { - private final ChatWebSocket chatWebSocket; + private final AIService aiService; /** - * 切换用户模式 - * @param sessionId - * @throws Exception + * ai */ -// @GetMapping("/switchUserMode") -// public void switchUserMode(String sessionId) throws Exception { -// chatWebSocket.switchUserMode(sessionId); -// } + @GetMapping("/ai") + public Flux switchUserMode(String msg) throws Exception { + return aiService.getDeepSeekResponseStream(msg); + } diff --git a/mcwl-admin/src/main/java/com/mcwl/web/controller/memberCenter/MemberController.java b/mcwl-admin/src/main/java/com/mcwl/web/controller/memberCenter/MemberController.java index bde9e44..f790b75 100644 --- a/mcwl-admin/src/main/java/com/mcwl/web/controller/memberCenter/MemberController.java +++ b/mcwl-admin/src/main/java/com/mcwl/web/controller/memberCenter/MemberController.java @@ -4,6 +4,8 @@ import cn.hutool.core.bean.BeanUtil; import com.mcwl.common.core.domain.AjaxResult; import com.mcwl.common.core.domain.R; import com.mcwl.common.core.domain.entity.SysUser; +import com.mcwl.common.core.page.PageDomain; +import com.mcwl.common.core.page.TableDataInfo; import com.mcwl.common.utils.SecurityUtils; import com.mcwl.memberCenter.domain.*; import com.mcwl.memberCenter.domain.vo.MemberConsumeVO; @@ -82,33 +84,23 @@ public class MemberController { /** * 获取积分消费记录 * - * @return 积分消费记录 + * @return 获取积分消费记录 */ - @GetMapping("getPoints") + @GetMapping("getConsumePoints") @ApiOperation(value = "获取积分消费记录") - public R> getPoints() { - Long userId = SecurityUtils.getUserId(); + public TableDataInfo getConsumePoints(@Valid @RequestBody PageDomain pageDomain) { - // 会员消费记录 - List memberConsumeList = memberConsumeService - .lambdaQuery() - .eq(MemberConsume::getUserId, userId) - .list(); - - return R.ok(BeanUtil.copyToList(memberConsumeList, MemberConsumeVO.class)); + return memberConsumeService.getConsumePoints(pageDomain); } /** - * 获取积分记录 + * 获取积分充值记录 */ @GetMapping("getRechargePoints") - @ApiOperation(value = "获取积分记录") - public R> getRechargePoints() { - Long userId = SecurityUtils.getUserId(); + @ApiOperation(value = "获取积分充值记录") + public TableDataInfo getRechargePoints(@Valid @RequestBody PageDomain pageDomain) { - List rechargeRecordList = memberService.getRechargePoints(userId); - - return R.ok(rechargeRecordList); + return memberService.getRechargePoints(pageDomain); } diff --git a/mcwl-admin/src/main/java/com/mcwl/web/controller/personalCenter/PersonalCenterController.java b/mcwl-admin/src/main/java/com/mcwl/web/controller/personalCenter/PersonalCenterController.java index 79a9ced..b906be4 100644 --- a/mcwl-admin/src/main/java/com/mcwl/web/controller/personalCenter/PersonalCenterController.java +++ b/mcwl-admin/src/main/java/com/mcwl/web/controller/personalCenter/PersonalCenterController.java @@ -1,12 +1,16 @@ package com.mcwl.web.controller.personalCenter; +import cn.hutool.core.bean.BeanUtil; import com.mcwl.common.core.domain.R; import com.mcwl.common.core.domain.entity.SysUser; import com.mcwl.common.core.page.PageDomain; import com.mcwl.common.core.page.TableDataInfo; import com.mcwl.common.utils.SecurityUtils; import com.mcwl.memberCenter.domain.Member; +import com.mcwl.memberCenter.domain.MemberConsume; +import com.mcwl.memberCenter.domain.vo.MemberConsumeVO; +import com.mcwl.memberCenter.domain.vo.RechargeRecordVO; import com.mcwl.memberCenter.service.MemberService; import com.mcwl.myInvitation.service.ConsumeService; import com.mcwl.pay.service.OrderTradeService; @@ -20,6 +24,7 @@ import org.springframework.web.bind.annotation.*; import javax.validation.Valid; import java.util.HashMap; +import java.util.List; import java.util.Map; import java.util.Objects; diff --git a/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/MemberConsumeService.java b/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/MemberConsumeService.java index 79d564f..824eb1d 100644 --- a/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/MemberConsumeService.java +++ b/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/MemberConsumeService.java @@ -1,10 +1,14 @@ package com.mcwl.memberCenter.service; import com.baomidou.mybatisplus.extension.service.IService; +import com.mcwl.common.core.page.PageDomain; +import com.mcwl.common.core.page.TableDataInfo; import com.mcwl.memberCenter.domain.MemberConsume; +import javax.validation.Valid; + public interface MemberConsumeService extends IService { - + TableDataInfo getConsumePoints(PageDomain pageDomain); } diff --git a/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/MemberService.java b/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/MemberService.java index 6dd51fd..01bc342 100644 --- a/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/MemberService.java +++ b/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/MemberService.java @@ -1,6 +1,8 @@ package com.mcwl.memberCenter.service; import com.baomidou.mybatisplus.extension.service.IService; +import com.mcwl.common.core.page.PageDomain; +import com.mcwl.common.core.page.TableDataInfo; import com.mcwl.memberCenter.domain.Member; import com.mcwl.memberCenter.domain.vo.RechargeRecordVO; @@ -47,5 +49,5 @@ public interface MemberService extends IService { Double calculatePayment(Double unitPrice, Long promotionId); - List getRechargePoints(Long userId); + TableDataInfo getRechargePoints(PageDomain pageDomain); } diff --git a/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/impl/MemberConsumeServiceImpl.java b/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/impl/MemberConsumeServiceImpl.java index aad3310..c87e377 100644 --- a/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/impl/MemberConsumeServiceImpl.java +++ b/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/impl/MemberConsumeServiceImpl.java @@ -1,16 +1,56 @@ package com.mcwl.memberCenter.service.impl; +import cn.hutool.core.bean.BeanUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.mcwl.common.constant.HttpStatus; +import com.mcwl.common.core.page.PageDomain; +import com.mcwl.common.core.page.TableDataInfo; +import com.mcwl.common.utils.SecurityUtils; import com.mcwl.memberCenter.domain.MemberConsume; +import com.mcwl.memberCenter.domain.vo.MemberConsumeVO; import com.mcwl.memberCenter.mapper.MemberConsumeMapper; import com.mcwl.memberCenter.service.MemberConsumeService; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; +import java.util.ArrayList; +import java.util.List; + @Service @RequiredArgsConstructor public class MemberConsumeServiceImpl extends ServiceImpl implements MemberConsumeService { + private final MemberConsumeMapper memberConsumeMapper; + @Override + public TableDataInfo getConsumePoints(PageDomain pageDomain) { + Page page = new Page<>(pageDomain.getPageNum(), pageDomain.getPageSize()); + + Long userId = SecurityUtils.getUserId(); + + LambdaQueryWrapper lqw = new LambdaQueryWrapper<>(); + lqw.eq(MemberConsume::getUserId, userId); + + memberConsumeMapper.selectPage(page, lqw); + + List memberConsumeList = page.getRecords(); + List memberConsumeVOList = new ArrayList<>(); + for (MemberConsume memberConsume : memberConsumeList) { + MemberConsumeVO memberConsumeVO = new MemberConsumeVO(); + BeanUtil.copyProperties(memberConsume, memberConsumeVO); + memberConsumeVOList.add(memberConsumeVO); + } + + TableDataInfo rspData = new TableDataInfo(); + rspData.setCode(HttpStatus.SUCCESS); + rspData.setMsg("查询成功"); + rspData.setRows(memberConsumeVOList); + rspData.setTotal(page.getTotal()); + + return rspData; + } } diff --git a/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/impl/MemberServiceImpl.java b/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/impl/MemberServiceImpl.java index a8ecc6e..3fd0fe8 100644 --- a/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/impl/MemberServiceImpl.java +++ b/mcwl-memberCenter/src/main/java/com/mcwl/memberCenter/service/impl/MemberServiceImpl.java @@ -3,10 +3,15 @@ package com.mcwl.memberCenter.service.impl; import cn.hutool.core.bean.BeanUtil; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.mcwl.common.constant.HttpStatus; import com.mcwl.common.core.domain.AjaxResult; import com.mcwl.common.core.domain.entity.SysUser; +import com.mcwl.common.core.page.PageDomain; +import com.mcwl.common.core.page.TableDataInfo; import com.mcwl.common.exception.ServiceException; +import com.mcwl.common.utils.DateUtils; import com.mcwl.common.utils.SecurityUtils; import com.mcwl.memberCenter.domain.*; import com.mcwl.memberCenter.domain.vo.RechargeRecordVO; @@ -283,22 +288,30 @@ public class MemberServiceImpl extends ServiceImpl impleme @Override - public List getRechargePoints(Long userId) { - if (Objects.isNull(userId)) { - return Collections.emptyList(); - } - List rechargeRecordList = rechargeRecordService.lambdaQuery() - .eq(RechargeRecord::getUserId, userId) - .list(); + public TableDataInfo getRechargePoints(PageDomain pageDomain) { + + Page page = new Page<>(pageDomain.getPageNum(), pageDomain.getPageSize()); + + rechargeRecordService.page(page, new LambdaQueryWrapper() + .eq(RechargeRecord::getUserId, SecurityUtils.getUserId())); + + List rechargeRecordList = page.getRecords(); List rechargeRecordVOList = new ArrayList<>(); for (RechargeRecord rechargeRecord : rechargeRecordList) { - RechargeRecordVO rechargeRecordVO = BeanUtil.copyProperties(rechargeRecord, RechargeRecordVO.class); + RechargeRecordVO rechargeRecordVO = new RechargeRecordVO(); + BeanUtil.copyProperties(rechargeRecord, rechargeRecordVO); rechargeRecordVO.setRechargeTime(rechargeRecord.getCreateTime()); rechargeRecordVOList.add(rechargeRecordVO); } - return rechargeRecordVOList; + TableDataInfo rspData = new TableDataInfo(); + rspData.setCode(HttpStatus.SUCCESS); + rspData.setMsg("查询成功"); + rspData.setRows(rechargeRecordVOList); + rspData.setTotal(page.getTotal()); + + return rspData; } }