From f10ef4933c6decda69308c1cf6e4d0449856ba1f Mon Sep 17 00:00:00 2001 From: zhibing.pu <393733352@qq.com> Date: 星期三, 21 八月 2024 18:07:33 +0800 Subject: [PATCH] 新增加websocket --- ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TGoodsController.java | 60 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 57 insertions(+), 3 deletions(-) diff --git a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TGoodsController.java b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TGoodsController.java index 29dd21b..357c25a 100644 --- a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TGoodsController.java +++ b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TGoodsController.java @@ -1,12 +1,18 @@ package com.ruoyi.other.controller; +import com.ruoyi.account.api.feignClient.AppUserClient; +import com.ruoyi.account.api.model.TAppUser; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.web.domain.AjaxResult; +import com.ruoyi.common.core.web.page.BasePage; import com.ruoyi.common.core.web.page.PageInfo; +import com.ruoyi.common.security.service.TokenService; +import com.ruoyi.order.api.feignClient.OrderClient; import com.ruoyi.other.api.domain.TActivity; import com.ruoyi.other.api.domain.TGoods; import com.ruoyi.other.api.dto.AdvertisingDTO; +import com.ruoyi.order.api.vo.ExchangeDto; import com.ruoyi.other.api.dto.GoodsDTO; import com.ruoyi.other.service.TActivityService; import com.ruoyi.other.service.TAdvertisingService; @@ -14,6 +20,9 @@ import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import java.util.Arrays; /** * <p> @@ -30,6 +39,12 @@ private TGoodsService goodsService; @Autowired private TActivityService activityService; + @Resource + private TokenService tokenService; + @Resource + private AppUserClient appUserClient; + @Resource + private OrderClient orderClient; @@ -45,8 +60,8 @@ @GetMapping("/delete") @ApiOperation(tags = {"管理后台-商品管理"},value = "商品删除") - public AjaxResult delete(Integer id) { - goodsService.removeById(id); + public AjaxResult delete(String ids) { + goodsService.removeBatchByIds(Arrays.asList(ids.split(","))); return AjaxResult.success(); } @@ -62,7 +77,7 @@ @GetMapping("/getInfo") - @ApiOperation(tags = {"管理后台-商品管理"},value = "商品查看详情") + @ApiOperation(tags = {"管理后台-商品管理","小程序-兑换商城"},value = "商品查看详情") public AjaxResult<TGoods> getInfo(Integer id) { return AjaxResult.ok(goodsService.getById(id)); } @@ -74,6 +89,45 @@ public AjaxResult<PageInfo<TGoods>> pageList(@RequestBody GoodsDTO dto) { return AjaxResult.ok(goodsService.pageList(dto)); } + + + @ApiOperation(tags = {"小程序-兑换商城"},value = "商品列表分页查询") + @PostMapping(value = "/app/pageList") + public AjaxResult<PageInfo<TGoods>> apppageList(BasePage basePage) { + return AjaxResult.ok(goodsService.pageList1(basePage)); + } + + @ApiOperation(tags = {"小程序-兑换商城"},value = "兑换商品") + @PostMapping(value = "/app/shop") + public AjaxResult<PageInfo<TGoods>> shop(@RequestBody ExchangeDto exchangeDto) { + //查询当前商品信息 + TGoods good = goodsService.getById(exchangeDto.getGoodId()); + + //检查当前用户积分是否够 + Long userId = tokenService.getLoginUserApplet().getUserId(); + TAppUser user = appUserClient.getUserById(userId).getData(); + if (user.getPoints()<good.getRedeemPoints()){ + return AjaxResult.error("当前用户积分不足"); + } + //检查当前用户是否到达兑换上限 + Long count = orderClient.getExchangeById(exchangeDto.getGoodId(), userId).getData(); + if (good.getLimitExchangeTimes()!=-1&&count>=good.getLimitExchangeTimes()){ + return AjaxResult.error("当前用户已到达兑换上限"); + } + //生成积分兑换成功的订单 + orderClient.exchangeCreate(exchangeDto); + + //如果是优惠卷,赠送优惠卷给用户 + + + + + //生成消耗积分的记录 + return AjaxResult.success(); + + + } + /** * 根据id获取商品信息 -- Gitblit v1.7.1