package com.webmanage.controller;
|
|
import com.webmanage.common.Result;
|
import com.webmanage.dto.CartItemDTO;
|
import com.webmanage.dto.CartQueryDTO;
|
import com.webmanage.service.CartService;
|
import com.webmanage.vo.CartVO;
|
import com.webmanage.vo.CartItemVO;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import io.swagger.annotations.ApiParam;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import javax.validation.Valid;
|
import javax.validation.constraints.Min;
|
import javax.validation.constraints.NotNull;
|
import java.util.List;
|
|
/**
|
* 购物车管理Controller
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("/api/cart")
|
@Api(tags = "购物车管理")
|
@Validated
|
public class CartController {
|
|
@Resource
|
private CartService cartService;
|
|
@PostMapping("/add")
|
@ApiOperation("添加商品到购物车")
|
public Result<Object> addToCart(@Valid @RequestBody CartItemDTO cartItemDTO,
|
@RequestParam @NotNull String userId,
|
@RequestParam String unitId) {
|
try {
|
boolean result = cartService.addToCart(userId, unitId, cartItemDTO);
|
if (result) {
|
return Result.success("添加商品到购物车成功");
|
} else {
|
return Result.error("添加商品到购物车失败");
|
}
|
} catch (Exception e) {
|
log.error("添加商品到购物车失败", e);
|
return Result.error("添加商品到购物车失败：" + e.getMessage());
|
}
|
}
|
|
@DeleteMapping("/remove")
|
@ApiOperation("从购物车移除商品")
|
public Result<Object> removeFromCart(@RequestParam @NotNull String userId,
|
@RequestParam String unitId,
|
@RequestParam @NotNull String productId,
|
@RequestParam @NotNull Long pricingId) {
|
try {
|
boolean result = cartService.removeFromCart(userId, unitId, productId, pricingId);
|
if (result) {
|
return Result.success("从购物车移除商品成功");
|
} else {
|
return Result.error("从购物车移除商品失败");
|
}
|
} catch (Exception e) {
|
log.error("从购物车移除商品失败", e);
|
return Result.error("从购物车移除商品失败：" + e.getMessage());
|
}
|
}
|
|
@PutMapping("/update")
|
@ApiOperation("更新购物车商品数量")
|
public Result<Object> updateCartItemQuantity(@RequestParam @NotNull String userId,
|
@RequestParam String unitId,
|
@RequestParam @NotNull String productId,
|
@RequestParam @NotNull Long pricingId,
|
@RequestParam @NotNull @Min(1) Integer quantity) {
|
try {
|
boolean result = cartService.updateCartItemQuantity(userId, unitId, productId, pricingId, quantity);
|
if (result) {
|
return Result.success("更新购物车商品数量成功");
|
} else {
|
return Result.error("更新购物车商品数量失败");
|
}
|
} catch (Exception e) {
|
log.error("更新购物车商品数量失败", e);
|
return Result.error("更新购物车商品数量失败：" + e.getMessage());
|
}
|
}
|
|
|
@PutMapping("/update/duration")
|
@ApiOperation("更新购物车商品数量")
|
public Result<Object> updateCartItemDuration(@RequestParam @NotNull String userId,
|
@RequestParam String unitId,
|
@RequestParam @NotNull String productId,
|
@RequestParam @NotNull Long pricingId,
|
@RequestParam @NotNull @Min(1) Integer duration) {
|
try {
|
boolean result = cartService.updateCartItemDuration(userId, unitId, productId, pricingId, duration);
|
if (result) {
|
return Result.success("更新购物车商品数量成功");
|
} else {
|
return Result.error("更新购物车商品数量失败");
|
}
|
} catch (Exception e) {
|
log.error("更新购物车商品数量失败", e);
|
return Result.error("更新购物车商品数量失败：" + e.getMessage());
|
}
|
}
|
|
@DeleteMapping("/clear")
|
@ApiOperation("清空购物车")
|
public Result<Object> clearCart(@RequestParam @NotNull String userId,
|
@RequestParam String unitId,
|
@RequestParam @NotNull String productId) {
|
try {
|
boolean result = cartService.clearCart(userId, unitId, productId);
|
if (result) {
|
return Result.success("清空购物车成功");
|
} else {
|
return Result.error("清空购物车失败");
|
}
|
} catch (Exception e) {
|
log.error("清空购物车失败", e);
|
return Result.error("清空购物车失败：" + e.getMessage());
|
}
|
}
|
|
@GetMapping("/info")
|
@ApiOperation("获取购物车信息")
|
public Result<Object> getCart(@RequestParam @NotNull String userId,
|
@RequestParam String unitId,
|
@RequestParam @NotNull String productId ) {
|
try {
|
CartVO cart = cartService.getCart(userId, unitId, productId);
|
return Result.success(cart);
|
} catch (Exception e) {
|
log.error("获取购物车信息失败", e);
|
return Result.error("获取购物车信息失败：" + e.getMessage());
|
}
|
}
|
|
@GetMapping("/items")
|
@ApiOperation("获取购物车商品列表")
|
public Result<Object> getCartItems(@RequestParam @NotNull String userId,
|
@RequestParam String unitId,
|
@RequestParam @NotNull String productId) {
|
try {
|
List<CartItemVO> items = cartService.getCartItems(userId, unitId, productId);
|
return Result.success(items);
|
} catch (Exception e) {
|
log.error("获取购物车商品列表失败", e);
|
return Result.error("获取购物车商品列表失败：" + e.getMessage());
|
}
|
}
|
|
@DeleteMapping("/batch-remove")
|
@ApiOperation("批量删除购物车商品")
|
public Result<Object> batchRemoveFromCart(@RequestParam @NotNull String userId,
|
@RequestParam String unitId,
|
@RequestParam @NotNull String productId,
|
@RequestBody List<Long> pricingIds) {
|
try {
|
boolean result = cartService.batchRemoveFromCart(userId, unitId, productId, pricingIds);
|
if (result) {
|
return Result.success("批量删除购物车商品成功");
|
} else {
|
return Result.error("批量删除购物车商品失败");
|
}
|
} catch (Exception e) {
|
log.error("批量删除购物车商品失败", e);
|
return Result.error("批量删除购物车商品失败：" + e.getMessage());
|
}
|
}
|
|
@GetMapping("/count")
|
@ApiOperation("获取购物车商品数量")
|
public Result<Object> getCartItemCount(@RequestParam @NotNull String userId,
|
@RequestParam String unitId,
|
@RequestParam @NotNull String productId ) {
|
try {
|
Integer count = cartService.getCartItemCount(userId, unitId, productId);
|
return Result.success(count);
|
} catch (Exception e) {
|
log.error("获取购物车商品数量失败", e);
|
return Result.error("获取购物车商品数量失败：" + e.getMessage());
|
}
|
}
|
|
@PostMapping("/sync-to-db")
|
@ApiOperation("同步Redis购物车数据到数据库")
|
public Result<Object> syncCartToDatabase(@RequestParam @NotNull String userId,
|
@RequestParam @NotNull String unitId,
|
@RequestParam @NotNull String productId ) {
|
try {
|
boolean result = cartService.syncCartToDatabase(userId, unitId, productId);
|
if (result) {
|
return Result.success("同步购物车数据到数据库成功");
|
} else {
|
return Result.error("同步购物车数据到数据库失败");
|
}
|
} catch (Exception e) {
|
log.error("同步购物车数据到数据库失败", e);
|
return Result.error("同步购物车数据到数据库失败：" + e.getMessage());
|
}
|
}
|
@PostMapping("/load-from-db")
|
@ApiOperation("从数据库加载购物车数据到Redis")
|
public Result<Object> loadCartFromDatabase(@RequestParam @NotNull String userId,
|
@RequestParam @NotNull String unitId,
|
@RequestParam @NotNull String productId ) {
|
try {
|
boolean result = cartService.loadCartFromDatabase(userId, unitId,productId);
|
if (result) {
|
return Result.success("从数据库加载购物车数据成功");
|
} else {
|
return Result.error("从数据库加载购物车数据失败");
|
}
|
} catch (Exception e) {
|
log.error("从数据库加载购物车数据失败", e);
|
return Result.error("从数据库加载购物车数据失败：" + e.getMessage());
|
}
|
}
|
|
@GetMapping("/consistency")
|
@ApiOperation("检查购物车数据一致性")
|
public Result<Object> checkCartConsistency(@RequestParam @NotNull String userId,
|
@RequestParam @NotNull String unitId,
|
@RequestParam @NotNull String productId) {
|
try {
|
boolean isConsistent = cartService.checkCartConsistency(userId, unitId, productId);
|
if (isConsistent) {
|
return Result.success("购物车数据一致");
|
} else {
|
return Result.error("购物车数据不一致");
|
}
|
} catch (Exception e) {
|
log.error("检查购物车数据一致性失败", e);
|
return Result.error("检查购物车数据一致性失败：" + e.getMessage());
|
}
|
}
|
}
|
