package cn.lili.controller.goods;
|
|
import cn.lili.common.aop.annotation.DemoSite;
|
import cn.lili.common.aop.annotation.PreventDuplicateSubmissions;
|
import cn.lili.common.enums.ResultCode;
|
import cn.lili.common.enums.ResultUtil;
|
import cn.lili.common.exception.ServiceException;
|
import cn.lili.common.utils.StringUtils;
|
import cn.lili.common.vo.ResultMessage;
|
import cn.lili.modules.goods.entity.dos.Goods;
|
import cn.lili.modules.goods.entity.dos.GoodsSku;
|
import cn.lili.modules.goods.entity.dto.GoodsSearchParams;
|
import cn.lili.modules.goods.entity.enums.GoodsAuthEnum;
|
import cn.lili.modules.goods.entity.enums.GoodsStatusEnum;
|
import cn.lili.modules.goods.entity.vos.GoodsVO;
|
import cn.lili.modules.goods.service.GoodsService;
|
import cn.lili.modules.goods.service.GoodsSkuService;
|
import cn.lili.utils.COSUtil;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.validation.constraints.NotEmpty;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
import java.util.stream.Stream;
|
|
/**
|
* 管理端,商品管理接口
|
*
|
* @author pikachu
|
* @since 2020-02-23 15:18:56
|
*/
|
@RestController
|
@Api(tags = "管理端,商品管理接口")
|
@RequestMapping("/manager/goods/goods")
|
public class GoodsManagerController {
|
/**
|
* 商品
|
*/
|
@Autowired
|
private GoodsService goodsService;
|
/**
|
* 规格商品
|
*/
|
@Autowired
|
private GoodsSkuService goodsSkuService;
|
|
@Autowired
|
private COSUtil cosUtil;
|
|
@ApiOperation(value = "分页获取")
|
@GetMapping(value = "/list")
|
public ResultMessage<IPage<Goods>> getByPage(GoodsSearchParams goodsSearchParams) {
|
return ResultUtil.data(goodsService.queryByParams(goodsSearchParams));
|
}
|
|
@ApiOperation(value = "分页获取商品列表")
|
@GetMapping(value = "/sku/list")
|
public ResultMessage<IPage<GoodsSku>> getSkuByPage(GoodsSearchParams goodsSearchParams) {
|
return ResultUtil.data(goodsSkuService.getGoodsSkuByPage(goodsSearchParams));
|
}
|
|
@ApiOperation(value = "分页获取待审核商品")
|
@GetMapping(value = "/auth/list")
|
public ResultMessage<IPage<Goods>> getAuthPage(GoodsSearchParams goodsSearchParams) {
|
goodsSearchParams.setAuthFlag(GoodsAuthEnum.TOBEAUDITED.name());
|
IPage<Goods> page = goodsService.queryByParams(goodsSearchParams);
|
page.getRecords().forEach(item -> {
|
String original = item.getOriginal();
|
String goodsVideo = item.getGoodsVideo();
|
if (StringUtils.isNotBlank(original)&&!original.contains("http")) {
|
item.setOriginal(cosUtil.getPreviewUrl(original));
|
}
|
if (StringUtils.isNotBlank(goodsVideo)&&!goodsVideo.contains("http")) {
|
item.setGoodsVideo(cosUtil.getPreviewUrl(goodsVideo));
|
}
|
});
|
return ResultUtil.data(page);
|
}
|
|
@PreventDuplicateSubmissions
|
@ApiOperation(value = "管理员下架商品", notes = "管理员下架商品时使用")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "goodsId", value = "商品ID", required = true, paramType = "query", allowMultiple = true),
|
@ApiImplicitParam(name = "reason", value = "下架理由", required = true, paramType = "query")
|
})
|
@DemoSite
|
@PutMapping(value = "/{goodsId}/under")
|
public ResultMessage<Object> underGoods(@PathVariable String goodsId, @NotEmpty(message = "下架原因不能为空") @RequestParam String reason) {
|
List<String> goodsIds = Arrays.asList(goodsId.split(","));
|
if (Boolean.TRUE.equals(goodsService.managerUpdateGoodsMarketAble(goodsIds, GoodsStatusEnum.DOWN, reason))) {
|
return ResultUtil.success();
|
}
|
throw new ServiceException(ResultCode.GOODS_UNDER_ERROR);
|
}
|
|
@PreventDuplicateSubmissions
|
@ApiOperation(value = "管理员审核商品", notes = "管理员审核商品")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "goodsIds", value = "商品ID", required = true, paramType = "path", allowMultiple = true, dataType = "int"),
|
@ApiImplicitParam(name = "authFlag", value = "审核结果", required = true, paramType = "query", dataType = "string")
|
})
|
@PutMapping(value = "{goodsIds}/auth")
|
public ResultMessage<Object> auth(@PathVariable List<String> goodsIds, @RequestParam String authFlag) {
|
//校验商品是否存在
|
if (goodsService.auditGoods(goodsIds, GoodsAuthEnum.valueOf(authFlag))) {
|
return ResultUtil.success();
|
}
|
throw new ServiceException(ResultCode.GOODS_AUTH_ERROR);
|
}
|
|
|
@PreventDuplicateSubmissions
|
@ApiOperation(value = "管理员上架商品", notes = "管理员上架商品时使用")
|
@PutMapping(value = "/{goodsId}/up")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "goodsId", value = "商品ID", required = true, allowMultiple = true)
|
})
|
public ResultMessage<Object> unpGoods(@PathVariable List<String> goodsId) {
|
if (Boolean.TRUE.equals(goodsService.updateGoodsMarketAble(goodsId, GoodsStatusEnum.UPPER, ""))) {
|
return ResultUtil.success();
|
}
|
throw new ServiceException(ResultCode.GOODS_UPPER_ERROR);
|
}
|
|
|
@ApiOperation(value = "通过id获取商品详情")
|
@GetMapping(value = "/get/{id}")
|
public ResultMessage<GoodsVO> get(@PathVariable String id) {
|
GoodsVO goods = goodsService.getGoodsVO(id);
|
return ResultUtil.data(goods);
|
}
|
|
}
|
