package com.matrix.system.shopXcx.api.action;
|
|
import com.matrix.core.constance.SystemErrorCode;
|
import com.matrix.core.constance.SystemMessageCode;
|
import com.matrix.core.exception.GlobleException;
|
import com.matrix.core.pojo.AjaxResult;
|
import com.matrix.core.tools.StringUtils;
|
import com.matrix.biz.bean.BizUser;
|
import com.matrix.component.redis.RedisUserLoginUtils;
|
import com.matrix.system.common.constance.AppConstance;
|
|
import com.matrix.system.shopXcx.bean.ShopShoppingCart;
|
import com.matrix.system.shopXcx.bean.ShopSku;
|
import com.matrix.system.shopXcx.dao.ShopShoppingCartDao;
|
import com.matrix.system.shopXcx.dao.ShopSkuDao;
|
import com.matrix.system.shopXcx.api.service.ShoppingCartService;
|
import com.matrix.system.shopXcx.api.service.WxShopCouponService;
|
import com.matrix.system.shopXcx.api.vo.ShopCartBillVo;
|
import com.matrix.system.shopXcx.api.vo.ShopCartVo;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @author jiangyouyao
|
* @description 购物车
|
* @date 2019-06-12 19:15
|
*/
|
@CrossOrigin(origins = "*", maxAge = 3600)
|
@Controller
|
@RequestMapping(value = "wxapi/ShoppingCart")
|
public class WxShoppingCartAction {
|
@Autowired
|
private ShopShoppingCartDao shoppingCartDao;
|
@Autowired
|
private RedisUserLoginUtils redisUserLoginUtils;
|
|
@Autowired
|
WxShopCouponService shopCouponService;
|
|
@Autowired
|
ShoppingCartService shoppingCartService;
|
|
@Autowired
|
ShopSkuDao skuDao;
|
|
|
/**
|
* 根据ID删除购物车
|
*
|
* @param
|
* @return
|
*/
|
@PostMapping("/deleteByCartId/{cartId}")
|
@ResponseBody
|
public AjaxResult deleteByCartId(@PathVariable("cartId") Integer cartId) {
|
int i = shoppingCartDao.deleteById(cartId);
|
if (i == 0) {
|
return new AjaxResult(AjaxResult.STATUS_FAIL, "删除失败");
|
}
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, "删除成功");
|
}
|
|
/**
|
* 根据用户ID查询购物车 没有分页
|
*
|
* @param
|
* @return
|
*/
|
@PostMapping("/findShoppingCart")
|
@ResponseBody
|
public AjaxResult getShoppingCartByUserId(@RequestBody ShopShoppingCart shoppingCart) {
|
List<ShopCartVo> cartList = shoppingCartService.findUserCartList(shoppingCart.getShopId());
|
AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, cartList, cartList.size());
|
ShopCartBillVo shopCartBill = shoppingCartService.buildShopCartBillVo(cartList);
|
result.putInMap("billTotal", shopCartBill.getBillTotal().stripTrailingZeros().toPlainString());
|
result.putInMap("selectCount", shopCartBill.getSelectCount());
|
result.putInMap("cartCount", shopCartBill.getCartCount());
|
result.putInMap("billCouponTotal", shopCartBill.getBillCouponTotal().stripTrailingZeros().toPlainString());
|
result.putInMap("srcTotal", shopCartBill.getSrcTotal().stripTrailingZeros().toPlainString());
|
return result;
|
}
|
|
/**
|
* 批量删除
|
*/
|
@PostMapping(value = "/delShoppingCart/{keys}")
|
public
|
@ResponseBody
|
AjaxResult del(@PathVariable("keys") String keys) {
|
List<String> ids = StringUtils.strToCollToString(keys, ",");
|
int i = shoppingCartDao.deleteByIds(ids);
|
if (i > 0) {
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, SystemMessageCode.DELETE_SUCCES, i);
|
} else {
|
throw new GlobleException(SystemErrorCode.DATA_DELETE_FAIL);
|
}
|
}
|
|
@PostMapping(value = "/getUserCartCount/{shopId}")
|
public
|
@ResponseBody
|
AjaxResult getUserCartCount(@PathVariable("shopId") Long shopId) {
|
BizUser loginUser = redisUserLoginUtils.getLoginUser(BizUser.class);
|
Integer userCartCount = shoppingCartDao.selectUserCartCount(shopId, loginUser.getOpenId());
|
if (userCartCount == null) {
|
userCartCount = 0;
|
}
|
AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, "请求成功");
|
result.putInMap("userCartCount", userCartCount);
|
return result;
|
}
|
|
/**
|
* 接收保存购物车数据
|
*/
|
@PostMapping(value = "/saveShoppingCart")
|
public
|
@ResponseBody
|
AjaxResult saveShoppingCart(@RequestBody ShopShoppingCart shoppingCart) {
|
|
//查询到sku设置对应的产品id
|
ShopSku sku= skuDao.selectById(shoppingCart.getCartSkuId());
|
if(sku==null){
|
return new AjaxResult(AjaxResult.STATUS_FAIL,"无效的产品id");
|
}
|
|
shoppingCart.setCartProductId(sku.getpId());
|
|
BizUser loginUser = redisUserLoginUtils.getLoginUser(BizUser.class);
|
shoppingCart.setCreateBy(loginUser.getOpenId());
|
shoppingCart.setUpdateBy(loginUser.getOpenId());
|
shoppingCart.setCartUserId(loginUser.getOpenId());
|
ShopShoppingCart shoppCartLimt = shoppingCartDao.selectBuyLimit(shoppingCart.getCartProductId(),
|
shoppingCart.getCartSkuId());
|
// Integer buyLimitNum = 0;
|
Integer stock = 0;
|
if (null != shoppCartLimt) {
|
// buyLimitNum = shoppCart.getBuyLimit();
|
stock = shoppCartLimt.getStock();
|
}
|
// 如果加入购物车的数量超出商品限购数量则不让其加入
|
/*
|
* if(shoppingCart.getCartNumber() > buyLimitNum){ return new
|
* AjaxResult(AjaxResult.STATUS_FAIL, "该产品加入购物车的数量超出商品限购数量"); }
|
*/
|
// 如果加入购物车的数量超出商品库存数量则不让其加入
|
if (shoppingCart.getCartNumber() > stock) {
|
return new AjaxResult(AjaxResult.STATUS_FAIL, "您来晚了商品已经卖完了");
|
}
|
|
// 如果同一个用户添加相同规格的产品，只做数量上的增加
|
Integer cartProductId = shoppingCart.getCartProductId();
|
Integer cartSkuId = shoppingCart.getCartSkuId();
|
Integer cartNumber = shoppingCart.getCartNumber();
|
ShopShoppingCart shopShoppingCart = new ShopShoppingCart();
|
shopShoppingCart.setCartProductId(cartProductId);
|
shopShoppingCart.setCartSkuId(cartSkuId);
|
shopShoppingCart.setCartUserId(loginUser.getOpenId());
|
shopShoppingCart.setShopId(shoppingCart.getShopId());
|
List<ShopShoppingCart> shopShoppingCarts = shoppingCartDao.selectByModel(shopShoppingCart);
|
int i = 0;
|
if (CollectionUtils.isNotEmpty(shopShoppingCarts)) {
|
Map<String, Object> modifyMap = new HashMap<>();
|
for (ShopShoppingCart shopCart : shopShoppingCarts) {
|
Integer cartNumber1 = shopCart.getCartNumber();
|
Integer total = cartNumber + cartNumber1;
|
// 再次判断加入购物车的数量是否超出商品限购数量
|
/*
|
* if(total > buyLimitNum ){ return new
|
* AjaxResult(AjaxResult.STATUS_FAIL, "该产品加入购物车的数量超出商品限购数量"); }
|
*/
|
if (total > stock) {
|
return new AjaxResult(AjaxResult.STATUS_FAIL, "该产品加入购物车的数量超出商品库存数量");
|
} else {
|
modifyMap.put("cartNumber", total);
|
modifyMap.put("isSelected", 1);
|
modifyMap.put("cartId", shopCart.getCartId());
|
shoppingCartDao.updateByMap(modifyMap);
|
i = i + 1;
|
}
|
}
|
} else {
|
shoppingCart.setIsSelected(1);
|
i = shoppingCartDao.insert(shoppingCart);
|
}
|
|
if (i == 0) {
|
return new AjaxResult(AjaxResult.STATUS_FAIL, "保存失败");
|
}
|
int userCartCount = shoppingCartDao.selectUserCartCount(shoppingCart.getShopId(),
|
loginUser.getOpenId());
|
AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, "保存成功");
|
result.putInMap("userCartCount", userCartCount);
|
return result;
|
}
|
|
/**
|
* 根据ID增减购物车
|
*
|
* @param
|
* @return
|
*/
|
@PostMapping("/updateCarNumberByCartId")
|
@ResponseBody
|
public AjaxResult updateCarNumberByCartId(@RequestBody ShopShoppingCart shoppingCart) {
|
ShopShoppingCart shopRefundRecord = shoppingCartDao.selectById(shoppingCart.getCartId());
|
|
ShopShoppingCart shoppCart = shoppingCartDao.selectBuyLimit(shopRefundRecord.getCartProductId(),
|
shopRefundRecord.getCartSkuId());
|
Integer stock = 0;
|
if (null != shoppCart) {
|
stock = shoppCart.getStock();
|
}
|
|
Map<String, Object> modifyMap = new HashMap<>();
|
if (null != shoppingCart.getIncreaseAndDecrease()
|
&& AppConstance.IS_INCREASE.equals(shoppingCart.getIncreaseAndDecrease())) {
|
modifyMap.put("cartNumber", shopRefundRecord.getCartNumber() + 1);
|
modifyMap.put("cartId", shoppingCart.getCartId());
|
// 如果加入购物车的数量超出商品库存数量则不让其加入
|
if (shopRefundRecord.getCartNumber() + 1 > stock) {
|
return new AjaxResult(AjaxResult.STATUS_FAIL, "您来晚了商品已经卖完了");
|
}
|
shoppingCartDao.updateByMap(modifyMap);
|
}
|
if (null != shoppingCart.getIncreaseAndDecrease()
|
&& AppConstance.IS_DECREASE.equals(shoppingCart.getIncreaseAndDecrease())) {
|
|
if ((shopRefundRecord.getCartNumber() - 1) > 0) {
|
modifyMap.put("cartNumber", shopRefundRecord.getCartNumber() - 1);
|
modifyMap.put("cartId", shoppingCart.getCartId());
|
shoppingCartDao.updateByMap(modifyMap);
|
}
|
|
}
|
if (null != shoppingCart.getModifyCartNumber()) {
|
modifyMap.put("cartNumber", shoppingCart.getModifyCartNumber());
|
modifyMap.put("cartId", shoppingCart.getCartId());
|
// 如果加入购物车的数量超出商品库存数量则不让其加入
|
if (shoppingCart.getModifyCartNumber() > stock) {
|
return new AjaxResult(AjaxResult.STATUS_FAIL, "您来晚了商品已经卖完了");
|
}
|
shoppingCartDao.updateByMap(modifyMap);
|
}
|
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, "修改成功");
|
}
|
|
/**
|
* 修改购物车产品选中状态
|
*
|
* @param
|
* @return
|
*/
|
@RequestMapping("/updateCartSelected")
|
@ResponseBody
|
public AjaxResult updateCartSelected(@RequestBody ShopShoppingCart shoppingCart) {
|
Map<String, Object> modifyMap = new HashMap<>();
|
modifyMap.put("isSelected", shoppingCart.getIsSelected());
|
modifyMap.put("cartId", shoppingCart.getCartId());
|
shoppingCartDao.updateByMap(modifyMap);
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, "修改成功");
|
}
|
|
/**
|
* 修改购物车产品选中状态
|
*
|
* @param
|
* @return
|
*/
|
@RequestMapping("/updateCartAllSelected/{shopId}/{isSelected}")
|
@ResponseBody
|
public AjaxResult updateCartAllSelected(@PathVariable("isSelected") Integer isSelected,
|
@PathVariable("shopId") Long shopId) {
|
Map<String, Object> modifyMap = new HashMap<>();
|
BizUser user = redisUserLoginUtils.getLoginUser(BizUser.class);
|
shoppingCartDao.updateAllSelected(user.getOpenId(),shopId, isSelected);
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, "修改成功");
|
}
|
}
|
