From fafae77d59bc333a11c6b43e8f8606e190341e4a Mon Sep 17 00:00:00 2001 From: 无关风月 <443237572@qq.com> Date: 星期二, 10 六月 2025 16:53:13 +0800 Subject: [PATCH] 部分代码 --- ruoyi-service/ruoyi-goods/src/main/java/com/ruoyi/goods/controller/TGoodsController.java | 306 ++++++++++++++++++++++++++++++++++++++------------ 1 files changed, 230 insertions(+), 76 deletions(-) diff --git a/ruoyi-service/ruoyi-goods/src/main/java/com/ruoyi/goods/controller/TGoodsController.java b/ruoyi-service/ruoyi-goods/src/main/java/com/ruoyi/goods/controller/TGoodsController.java index 325b9b5..c87a3ae 100644 --- a/ruoyi-service/ruoyi-goods/src/main/java/com/ruoyi/goods/controller/TGoodsController.java +++ b/ruoyi-service/ruoyi-goods/src/main/java/com/ruoyi/goods/controller/TGoodsController.java @@ -1,8 +1,8 @@ package com.ruoyi.goods.controller; +import java.util.Date; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ruoyi.common.core.constant.Constants; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.exception.GlobalException; @@ -18,6 +18,7 @@ import com.ruoyi.goods.vo.TOrderVO; import com.ruoyi.study.api.domain.TUser; import com.ruoyi.study.api.feignClient.StudyClient; +import com.ruoyi.study.api.vo.UserPersonalCenterVO; import com.ruoyi.system.api.model.LoginUserParent; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; @@ -59,7 +60,38 @@ private IRegionService regionService; @Resource private TokenService tokenService; - + @PostMapping("/testAddData") + @ApiOperation(value = "测试分片", tags = {"测试分片"}) + public R<Object> testAddData() { + TOrder tOrder = new TOrder(); + tOrder.setOrderNumber(""); + tOrder.setUserId(63); + tOrder.setInsertTime(new Date()); + tOrder.setGoodsId(0); + tOrder.setCount(0); + tOrder.setState(0); + tOrder.setExpress(""); + tOrder.setExpressNumber(""); + tOrder.setExpressTime(new Date()); + tOrder.setIntegral(0); + tOrder.setCompleteTime(new Date()); + tOrder.setConsigneeName(""); + tOrder.setImg(""); + tOrder.setName(""); + tOrder.setType(""); + tOrder.setConsigneePhone(""); + tOrder.setConsigneeAddress(""); + tOrder.setProvince(""); + tOrder.setCity(""); + tOrder.setRemark(""); + tOrder.setDisabled(false); + tOrder.setCreateBy(""); + tOrder.setCreateTime(new Date()); + tOrder.setUpdateBy(""); + tOrder.setUpdateTime(new Date()); + orderService.save(tOrder); + return R.ok(); + } @PostMapping("/listType") @ApiOperation(value = "列表查询", tags = {"后台-商品类型管理"}) public R<PageInfo<TGoodsType>> listType(@RequestBody GoodsTypeQuery query) { @@ -81,20 +113,26 @@ if (tokenService.getLoginUser1() == null) { return R.tokenError("登录失效"); } - List<String> type = goodQuery.getType(); String keywords = goodQuery.getKeywords(); // 初始化条件构造器 QueryWrapper<TGoods> wrapper = new QueryWrapper<>(); - wrapper = keywords != null && "".equals(keywords.trim()) ? wrapper.like("name", keywords) : wrapper; + wrapper = keywords != null && !"".equals(keywords.trim()) ? wrapper.like("name", keywords) : wrapper; // 类型匹配 todo if (goodQuery.getType() != null && goodQuery.getType().size() > 0) { - StringBuilder temp = new StringBuilder(""); - for (String s : goodQuery.getType()) { - wrapper.or().apply("FIND_IN_SET('" + s + "', typeIds)"); // 将每个类型 ID 应用于 FIND_IN_SET 函数 + for (int i = 0; i < goodQuery.getType().size(); i++) { +// if (i == 0){ +// wrapper.apply("FIND_IN_SET('" + goodQuery.getType().get(i) + "', typeIds)"); // 将每个类型 ID 应用于 FIND_IN_SET 函数 +// }else{ + wrapper.or().apply("FIND_IN_SET('" + goodQuery.getType().get(i) + "', typeIds)"); // 将每个类型 ID 应用于 FIND_IN_SET 函数 +// } } } wrapper.eq("isDelete", 0); + // sort排序 + wrapper.orderByAsc("CASE WHEN sort IS NULL THEN 1 ELSE 0 END") + .orderByAsc("sort") + .orderByDesc("createTime"); return R.ok(goodsService.page(new PageInfo<>(goodQuery.getPageNumber(), goodQuery.getPageSize()), wrapper)); } @@ -108,15 +146,21 @@ // 初始化条件构造器 QueryWrapper<TGoods> wrapper = new QueryWrapper<>(); wrapper = keywords != null && !"".equals(keywords.trim()) ? wrapper.like("name", keywords) : wrapper; - // 类型匹配 todo - if (goodQuery.getType() != null && !goodQuery.getType().isEmpty()) { - for (String s : goodQuery.getType()) { - // 将每个类型 ID 应用于 FIND_IN_SET 函数 - wrapper.or().apply("FIND_IN_SET('" + s + "', typeIds)"); + if (goodQuery.getType() != null && goodQuery.getType().size() > 0) { + for (int i = 0; i < goodQuery.getType().size(); i++) { + if (i == 0){ + wrapper.apply("FIND_IN_SET('" + goodQuery.getType().get(i) + "', typeIds)"); // 将每个类型 ID 应用于 FIND_IN_SET 函数 + }else{ + wrapper.or().apply("FIND_IN_SET('" + goodQuery.getType().get(i) + "', typeIds)"); // 将每个类型 ID 应用于 FIND_IN_SET 函数 + } } } wrapper.eq("isDelete", 0); + // sort排序 + wrapper.orderByAsc("CASE WHEN sort IS NULL THEN 1 ELSE 0 END") + .orderByDesc("sort") + .orderByDesc("createTime"); return R.ok(goodsService.page(new PageInfo<>(goodQuery.getPageNumber(), goodQuery.getPageSize()), wrapper)); } @@ -137,6 +181,15 @@ @PostMapping("/deleteGoodsType/{id}") @ApiOperation(value = "删除", tags = {"后台-商品类型管理"}) public R deleteGoodsType(@PathVariable("id") Integer id) { + // 初始化条件构造器 + QueryWrapper<TGoods> wrapper = new QueryWrapper<>(); + // 类型匹配 todo + wrapper.or().apply("FIND_IN_SET('" + id + "', typeIds)"); // 将每个类型 ID 应用于 FIND_IN_SET 函数 + wrapper.eq("isDelete", 0); + List<TGoods> list = goodsService.list(wrapper); + if (!list.isEmpty()) { + return R.fail("当前商品分类被使用,无法删除!"); + } TGoodsType byId = goodsTypeService.getById(id); byId.setIsDelete(1); goodsTypeService.removeById(byId); @@ -153,9 +206,27 @@ wrapper.orderByDesc("id"); List<TGoods> list = goodsService.list(wrapper); for (TGoods tGoods : list) { - long goodsId = orderService.count(new QueryWrapper<TOrder>().eq("goodsId", tGoods.getId())); - tGoods.setInventory(goodsId); + Long temp = 0L; + List<TOrder> list1 = orderService.list(new QueryWrapper<TOrder>().eq("goodsId", tGoods.getId())); + for (TOrder tOrder : list1) { + temp += tOrder.getCount(); + } + tGoods.setInventory(temp); + // 剩余兑换数量 + Integer residueNumber = null; + if (null != tGoods.getTotal()) { + // 计算剩余兑换数量 + List<TOrder> orderList = orderService.lambdaQuery().eq(TOrder::getGoodsId, tGoods) + .eq(TOrder::getDisabled, 0).list(); + Integer item = 0; + for (TOrder order : orderList) { + item += order.getCount(); + } + residueNumber = tGoods.getTotal() - item; + tGoods.setSurplus(residueNumber); + } } + PageInfo<TGoods> res = new PageInfo<>(query.getPageNumber(), query.getPageSize()); res.setRecords(list); return R.ok(res); @@ -164,9 +235,9 @@ @PostMapping("/addGoods") @ApiOperation(value = "添加", tags = {"后台-商品管理"}) public R addGoods(@RequestBody TGoods dto) { - if (dto.getTotal()!=null){ + if (dto.getTotal() != null) { dto.setSurplus(dto.getTotal()); - }else{ + } else { dto.setSurplus(0); } goodsService.save(dto); @@ -184,12 +255,22 @@ @PostMapping("/updateGoods") @ApiOperation(value = "修改", tags = {"后台-商品管理"}) public R updateGoods(@RequestBody TGoods dto) { - if (dto.getTotal()!=null){ - dto.setSurplus(dto.getTotal()); - }else{ - dto.setSurplus(0); + TGoods byId = goodsService.getById(dto.getId()); + if (byId.getTotal()!=null && dto.getTotal()!=null &&!Objects.equals(byId.getTotal(), dto.getTotal())){ + // 如果修改了商品总数 那么需要再判断当前商品已被购买了多少 + List<TOrder> list = orderService.list(new QueryWrapper<TOrder>() + .eq("goodsId", dto.getId())); + Integer temp = 0; + for (TOrder tOrder : list) { + temp += tOrder.getCount(); + } + if (dto.getTotal()<temp){ + return R.fail("商品总数不能小于当前商品已兑换数量,"+"当前商品已兑换数量为:"+temp); + } } goodsService.updateById(dto); + goodsService.updateOne(dto); + return R.ok("修改成功"); } @@ -217,10 +298,15 @@ */ @GetMapping("/exchangeRecord") @ApiOperation(value = "学习端-兑换记录", tags = {"学习端-商城"}) - public R<List<ExchangeRecordVO>> exchangeRecord() { - List<ExchangeRecordVO> exchangeRecord = orderService.exchangeRecord(tokenService.getLoginUserStudy().getUserid()); + public R<PageInfo<ExchangeRecordVO>> exchangeRecord(Integer pageNumber,Integer pageSize) { + PageInfo<ExchangeRecordVO> res = new PageInfo<>(pageNumber, pageSize); + LoginUserParent loginUserStudy = tokenService.getLoginUserStudy(); + if (null == loginUserStudy) { + return R.tokenError("登录失效!"); + } + List<ExchangeRecordVO> exchangeRecord = orderService.exchangeRecord(res,tokenService.getLoginUserStudy().getUserid()); for (ExchangeRecordVO record : exchangeRecord) { - TGoods goods = goodsService.getById(record.getGoodsId()); + TGoods goods = goodsService.getById1(record.getGoodsId()); List<String> typeList; if (null != goods) { List<TGoodsType> goodsTypes = goodsTypeService.lambdaQuery().in(TGoodsType::getId, Arrays.stream(goods.getTypeIds().split(",")).collect(Collectors.toList())) @@ -231,38 +317,34 @@ } record.setGoodsType(typeList); } - return R.ok(exchangeRecord); + res.setRecords(exchangeRecord); + res.setTotal(exchangeRecord.size()); + return R.ok(res); } @GetMapping("/exchangeRecordParent") @ApiOperation(value = "家长端-兑换记录", tags = {"家长端-兑换记录"}) - public R<Page<TOrder>> exchangeRecordParent(Integer pageNumber, Integer pageSize) { + public R<PageInfo<ExchangeRecordVO>> exchangeRecordParent(Integer pageNumber,Integer pageSize) { + PageInfo<ExchangeRecordVO> res = new PageInfo<>(pageNumber, pageSize); if (tokenService.getLoginUser1() == null) { return R.tokenError("登录失效"); } - Page<TOrder> page = orderService.page(new Page<>(pageNumber, pageSize), new QueryWrapper<TOrder>().eq("userId", tokenService.getLoginUser1().getUserid()) - .orderByDesc("createTime")); - List<TOrder> records = page.getRecords(); - for (TOrder tOrder : records) { - TGoods byId = goodsService.getById(tOrder.getGoodsId()); - tOrder.setName(byId.getName()); - tOrder.setImg(byId.getCoverImg()); - StringBuilder stringBuilder = new StringBuilder(); - if (StringUtils.hasLength(byId.getTypeIds())) { - String[] split = byId.getTypeIds().split(","); - for (String s : split) { - TGoodsType byId1 = goodsTypeService.getById(s); - if (byId1 != null) { - stringBuilder.append(byId1.getName()).append("|"); - } - } - // 去除最后一个字符 - stringBuilder.deleteCharAt(stringBuilder.length() - 1); - tOrder.setType(stringBuilder.toString()); + List<ExchangeRecordVO> exchangeRecord = orderService.exchangeRecord(res,tokenService.getLoginUser1().getUserid()); + for (ExchangeRecordVO record : exchangeRecord) { + TGoods goods = goodsService.getById1(record.getGoodsId()); + List<String> typeList; + if (null != goods) { + List<TGoodsType> goodsTypes = goodsTypeService.lambdaQuery().in(TGoodsType::getId, Arrays.stream(goods.getTypeIds().split(",")).collect(Collectors.toList())) + .eq(TGoodsType::getIsDelete, 0).list(); + typeList = goodsTypes.stream().map(TGoodsType::getName).collect(Collectors.toList()); + } else { + typeList = new ArrayList<>(); } + record.setGoodsType(typeList); } - - return R.ok(page); + res.setRecords(exchangeRecord); + res.setTotal(exchangeRecord.size()); + return R.ok(res); } /** @@ -274,12 +356,14 @@ @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "id", dataType = "String", required = true) }) - public R<Boolean> confirm(@RequestParam Integer id) { + public R<Boolean> confirm(@RequestParam String id) { if (tokenService.getLoginUser1() == null) { return R.tokenError("登录失效"); } TOrder byId = orderService.getById(id); + byId.setUserId(null); byId.setState(3); + byId.setCompleteTime(new Date()); return R.ok(orderService.updateById(byId)); } @@ -292,11 +376,12 @@ @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "id", dataType = "String", required = true) }) - public R<Boolean> confirmStudy(@RequestParam Integer id) { + public R<Boolean> confirmStudy(@RequestParam String id) { if (tokenService.getLoginUserStudy() == null) { return R.tokenError("登录失效"); } TOrder byId = orderService.getById(id); + byId.setUserId(null); byId.setState(3); byId.setCompleteTime(new Date()); return R.ok(orderService.updateById(byId)); @@ -545,17 +630,24 @@ @ApiImplicitParam(value = "订单id", name = "orderId", dataType = "String", required = true), @ApiImplicitParam(value = "地址信息id", name = "recipientId", dataType = "String", required = true) }) - public R updateOrderAddressParent(@RequestParam Integer orderId, @RequestParam Integer recipientId) { + public R updateOrderAddressParent(@RequestParam String orderId, @RequestParam Integer recipientId) { if (tokenService.getLoginUser1() == null) { return R.tokenError("登录失效"); } - Recipient userId = recipientService.getById(recipientId); - TOrder byId = orderService.getById(orderId); - byId.setConsigneeName(userId.getRecipient()); - byId.setConsigneePhone(userId.getRecipientPhone()); - byId.setConsigneeAddress(userId.getAddress()); - orderService.updateById(byId); - return R.ok("修改成功"); + Recipient recipient = recipientService.getById(recipientId); + TOrder order = orderService.getById(orderId); + if (null == order) { + throw new GlobalException("订单不存在!"); + } + if (!Constants.ONE.equals(order.getState())) { + throw new GlobalException("订单已发货,无法修改收货地址!"); + } + order.setUserId(null); + order.setConsigneeName(recipient.getRecipient()); + order.setConsigneePhone(recipient.getRecipientPhone()); + order.setConsigneeAddress(recipient.getProvince()+recipient.getCity()+recipient.getAddress()); + orderService.updateById(order); + return R.ok(); } @GetMapping("/updateOrderAddress") @@ -565,7 +657,7 @@ @ApiImplicitParam(value = "订单id", name = "orderId", dataType = "String", required = true), @ApiImplicitParam(value = "地址信息id", name = "recipientId", dataType = "String", required = true) }) - public R updateOrderAddress(@RequestParam Integer orderId, @RequestParam Integer recipientId) { + public R updateOrderAddress(@RequestParam String orderId, @RequestParam Integer recipientId) { if (tokenService.getLoginUserStudy() == null) { return R.tokenError("登录失效"); } @@ -577,9 +669,10 @@ if (!Constants.ONE.equals(order.getState())) { throw new GlobalException("订单已发货,无法修改收货地址!"); } - order.setConsigneeName(recipient.getAddress()); + order.setUserId(null); + order.setConsigneeName(recipient.getRecipient()); order.setConsigneePhone(recipient.getRecipientPhone()); - order.setConsigneeAddress(recipient.getAddress()); + order.setConsigneeAddress(recipient.getProvince()+recipient.getCity()+recipient.getAddress()); orderService.updateById(order); return R.ok(); } @@ -602,7 +695,24 @@ @ApiOperation(value = "可兑换商品推荐", tags = {"学习端-商城"}) @ApiOperationSupport(order = 38) public R<List<TGoodsVO>> goodRecommend() { - return R.ok(goodsService.goodRecommend(tokenService.getLoginUserStudy().getUserid())); + LoginUserParent loginUserStudy = tokenService.getLoginUserStudy(); + if (null == loginUserStudy) { + return R.tokenError("登录失效!"); + } + UserPersonalCenterVO data = studyClient.userInfo().getData(); + List<TGoodsVO> tGoodsVOS = goodsService.goodRecommend(loginUserStudy.getUserid()); + List<TGoodsVO> res = new ArrayList<>(); + int temp = 0; + for (TGoodsVO re : tGoodsVOS) { + if (temp>=3){ + break; + } + if (data.getUser().getIntegral()>=re.getIntegral()){ + res.add(re); + temp++; + } + } + return R.ok(res); } /** @@ -642,8 +752,23 @@ if (null != goods.getBasicCount()) { number += goods.getBasicCount(); } - number += orderService.getGoodBuyNumber(goods.getId()); - return R.ok(new GoodDetailVO(goods, goodsTypes, number)); + List<TOrder> list = orderService.list(new QueryWrapper<TOrder>().eq("goodsId", goods.getId())); + for (TOrder tOrder : list) { + number+=tOrder.getCount(); + } + // 剩余兑换数量 + Integer residueNumber = null; + if (null != goods.getTotal()) { + // 计算剩余兑换数量 + List<TOrder> orderList = orderService.lambdaQuery().eq(TOrder::getGoodsId, goodId) + .eq(TOrder::getDisabled, 0).list(); + Integer item = 0; + for (TOrder order : orderList) { + item += order.getCount(); + } + residueNumber = goods.getTotal() - item; + } + return R.ok(new GoodDetailVO(goods, goodsTypes, number, residueNumber)); } /** @@ -653,7 +778,6 @@ */ @GetMapping("/goodDetailParent") @ApiOperation(value = "商品详情", tags = {"家长端-商城"}) - @ApiOperationSupport(order = 24) @ApiImplicitParams({ @ApiImplicitParam(value = "商品id", name = "goodId", dataType = "String", required = true) }) @@ -669,8 +793,27 @@ // 商品分类详情 List<TGoodsType> goodsTypes = goodsTypeService.lambdaQuery().in(TGoodsType::getId, Arrays.asList(goods.getTypeIds().split(","))).list(); // 已兑换人数 - int number = goods.getBasicCount() + orderService.getGoodBuyNumber(goods.getId()); - return R.ok(new GoodDetailVO(goods, goodsTypes, number)); + int number = 0; + if (null != goods.getBasicCount()) { + number += goods.getBasicCount(); + } + List<TOrder> list = orderService.list(new QueryWrapper<TOrder>().eq("goodsId", goods.getId())); + for (TOrder tOrder : list) { + number+=tOrder.getCount(); + } + // 剩余兑换数量 + Integer residueNumber = null; + if (null != goods.getTotal()) { + // 计算剩余兑换数量 + List<TOrder> orderList = orderService.lambdaQuery().eq(TOrder::getGoodsId, goodId) + .eq(TOrder::getDisabled, 0).list(); + Integer item = 0; + for (TOrder order : orderList) { + item += order.getCount(); + } + residueNumber = goods.getTotal() - item; + } + return R.ok(new GoodDetailVO(goods, goodsTypes, number, residueNumber)); } /** @@ -690,6 +833,13 @@ .eq(Recipient::getUserId, tokenService.getLoginUserStudy().getUserid()) .eq(Recipient::getIsDefault, 1) .eq(Recipient::getDisabled, 0).one(); + if (null == recipient) { + recipient = recipientService.lambdaQuery() + .eq(Recipient::getUserId, tokenService.getLoginUserStudy().getUserid()) + .eq(Recipient::getDisabled, 0) + .orderByDesc(Recipient::getCreateTime) + .last("limit 1").one(); + } GoodDetailVO goodDetailVO = goodsService.redeemNow(goodId, recipient); LocalDateTime currentDateTime = LocalDateTime.now(); // 格式化日期和时间信息 @@ -726,12 +876,11 @@ .eq(Recipient::getIsDefault, 1).one(); if (recipient == null) { // 随便取一条地址数据 - List<Recipient> list = recipientService.lambdaQuery() + recipient = recipientService.lambdaQuery() .eq(Recipient::getUserId, tokenService.getLoginUser1().getUserid()) - .eq(Recipient::getIsDefault, 1).list(); - if (!list.isEmpty()) { - recipient = list.get(0); - } + .orderByDesc(Recipient::getCreateTime) + .eq(Recipient::getDisabled, 0).last("limit 1") + .one(); } GoodDetailVO goodDetailVO = goodsService.redeemNow(goodId, recipient); LocalDateTime currentDateTime = LocalDateTime.now(); @@ -781,15 +930,18 @@ @PostMapping("/getOrderInfo/{id}") @ApiOperation(value = "查看详情", tags = {"后台-订单管理"}) @ApiOperationSupport(order = 11) - public R<TOrderVO> getOrderInfo(@PathVariable("id") Integer id) { + public R<TOrderVO> getOrderInfo(@PathVariable("id") String id) { TOrder byId = orderService.getById(id); - TGoods byId2 = goodsService.getById(byId.getGoodsId()); + TGoods byId2 = goodsService.getById1(byId.getGoodsId()); TOrderVO tGoodsVO = new TOrderVO(); - tGoodsVO.setName(byId2.getName()); BeanUtils.copyProperties(byId, tGoodsVO); + tGoodsVO.setName(byId2.getName()); TUser byId1 = studyClient.getUserById(byId.getUserId()).getData(); tGoodsVO.setUserName(byId1.getName()); tGoodsVO.setPhone(byId1.getPhone()); + if (byId.getProvince() != null && byId.getCity() != null) { + tGoodsVO.setConsigneeAddress(byId.getProvince() + byId.getCity() + tGoodsVO.getConsigneeAddress()); + } return R.ok(tGoodsVO); } @@ -798,6 +950,7 @@ @ApiOperationSupport(order = 12) public R getGoodsInfo1(@RequestBody OrderDTO dto) { TOrder byId = orderService.getById(dto.getId()); + byId.setUserId(null); byId.setState(2); byId.setExpress(dto.getExpress()); byId.setExpressNumber(dto.getExpressNumber()); @@ -810,11 +963,14 @@ @ApiOperation(value = "列表查询", tags = {"后台-订单管理"}) @ApiOperationSupport(order = 13) public R<PageInfo<TOrderVO>> listAll1(@RequestBody OrderQuery query) throws ParseException { - SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); if (query.getEndTime() != null) { Date parse = format.parse(query.getStartTime()); Date parse1 = format.parse(query.getEndTime()); + parse1.setHours(23); + parse1.setMinutes(59); + parse1.setSeconds(59); query.setStartTime1(parse); query.setEndTime1(parse1); } @@ -844,8 +1000,6 @@ list1.add(tOrderVO); } } - - } PageInfo<TOrderVO> res = new PageInfo<>(query.getPageNumber(), query.getPageSize()); res.setRecords(list1); -- Gitblit v1.7.1