基于springboot +thymeleaf 的小米商城管理系统.zip

package com.siro.mall.service.impl; import com.siro.mall.common.*; import com.siro.mall.dao.GoodsMapper; import com.siro.mall.dao.OrderItemMapper; import com.siro.mall.dao.OrderMapper; import com.siro.mall.dao.ShoppingCartItemMapper; import com.siro.mall.entity.Goods; import com.siro.mall.entity.Order; import com.siro.mall.entity.OrderItem; import com.siro.mall.service.OrderService; import com.siro.mall.utils.BeanUtil; import com.siro.mall.utils.NumberUtil; import com.siro.mall.utils.PageQueryUtil; import com.siro.mall.utils.PageResult; import com.siro.mall.vo.*; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import org.springframework.util.StringUtils; import javax.annotation.Resource; import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; import static java.util.stream.Collectors.groupingBy; /** * @author starsea * @date 2021-01-23 */ @Service public class OrderServiceImpl implements OrderService { @Resource private OrderMapper orderMapper; @Resource private OrderItemMapper orderItemMapper; @Resource private ShoppingCartItemMapper shoppingCartItemMapper; @Resource private GoodsMapper goodsMapper; @Override public PageResult getOrdersPage(PageQueryUtil pageUtil) { List<Order> orders = orderMapper.findOrderList(pageUtil); int total = orderMapper.getTotalOrders(pageUtil); PageResult pageResult = new PageResult(orders, total, pageUtil.getLimit(), pageUtil.getPage()); return pageResult; } @Override public String updateOrderInfo(Order MallOrder) { Order temp = orderMapper.selectByPrimaryKey(MallOrder.getOrderId()); //不为空且orderStatus>=0且状态为出库之前可以修改部分信息 if (temp != null && temp.getOrderStatus() >= 0 && temp.getOrderStatus() < 3) { temp.setTotalPrice(MallOrder.getTotalPrice()); temp.setUserAddress(MallOrder.getUserAddress()); temp.setUpdateTime(new Date()); if (orderMapper.updateByPrimaryKeySelective(temp) > 0) { return ServiceResultEnum.SUCCESS.getResult(); } return ServiceResultEnum.DB_ERROR.getResult(); } return ServiceResultEnum.DATA_NOT_EXIST.getResult(); } @Override public String checkDone(Long[] ids) { //查询所有的订单 判断状态 修改状态和更新时间 List<Order> orders = orderMapper.selectByPrimaryKeys(Arrays.asList(ids)); String errorOrderNos = ""; if (!CollectionUtils.isEmpty(orders)) { for (Order MallOrder : orders) { if (MallOrder.getIsDeleted() == 1) { errorOrderNos += MallOrder.getOrderNo() + " "; continue; } if (MallOrder.getOrderStatus() != 1) { errorOrderNos += MallOrder.getOrderNo() + " "; } } if (StringUtils.isEmpty(errorOrderNos)) { //订单状态正常 可以执行配货完成操作 修改订单状态和更新时间 if (orderMapper.checkDone(Arrays.asList(ids)) > 0) { return ServiceResultEnum.SUCCESS.getResult(); } else { return ServiceResultEnum.DB_ERROR.getResult(); } } else { //订单此时不可执行出库操作 if (errorOrderNos.length() > 0 && errorOrderNos.length() < 100) { return errorOrderNos + "订单的状态不是支付成功无法执行出库操作"; } else { return "你选择了太多状态不是支付成功的订单，无法执行配货完成操作"; } } } //未查询到数据 返回错误提示 return ServiceResultEnum.DATA_NOT_EXIST.getResult(); } @Override public String checkOut(Long[] ids) { //查询所有的订单 判断状态 修改状态和更新时间 List<Order> orders = orderMapper.selectByPrimaryKeys(Arrays.asList(ids)); String errorOrderNos = ""; if (!CollectionUtils.isEmpty(orders)) { for (Order MallOrder : orders) { if (MallOrder.getIsDeleted() == 1) { errorOrderNos += MallOrder.getOrderNo() + " "; continue; } if (MallOrder.getOrderStatus() != 1 && MallOrder.getOrderStatus() != 2) { errorOrderNos += MallOrder.getOrderNo() + " "; } } if (StringUtils.isEmpty(errorOrderNos)) { //订单状态正常 可以执行出库操作 修改订单状态和更新时间 if (orderMapper.checkOut(Arrays.asList(ids)) > 0) { return ServiceResultEnum.SUCCESS.getResult(); } else { return ServiceResultEnum.DB_ERROR.getResult(); } } else { //订单此时不可执行出库操作 if (errorOrderNos.length() > 0 && errorOrderNos.length() < 100) { return errorOrderNos + "订单的状态不是支付成功或配货完成无法执行出库操作"; } else { return "你选择了太多状态不是支付成功或配货完成的订单，无法执行出库操作"; } } } //未查询到数据 返回错误提示 return ServiceResultEnum.DATA_NOT_EXIST.getResult(); } @Override public String closeOrder(Long[] ids) { //查询所有的订单 判断状态 修改状态和更新时间 List<Order> orders = orderMapper.selectByPrimaryKeys(Arrays.asList(ids)); String errorOrderNos = ""; if (!CollectionUtils.isEmpty(orders)) { for (Order MallOrder : orders) { // isDeleted=1 一定为已关闭订单 if (MallOrder.getIsDeleted() == 1) { errorOrderNos += MallOrder.getOrderNo() + " "; continue; } //已关闭或者已完成无法关闭订单 if (MallOrder.getOrderStatus() == 4 || MallOrder.getOrderStatus() < 0) { errorOrderNos += MallOrder.getOrderNo() + " "; } } if (StringUtils.isEmpty(errorOrderNos)) { //订单状态正常 可以执行关闭操作 修改订单状态和更新时间 if (orderMapper.closeOrder(Arrays.asList(ids), MallOrderStatusEnum.ORDER_CLOSED_BY_JUDGE.getOrderStatus()) > 0) { return ServiceResultEnum.SUCCESS.getResult(); } else { return ServiceResultEnum.DB_ERROR.getResult(); } } else { //订单此时不可执行关闭操作 if (errorOrderNos.length() > 0 && errorOrderNos.length() < 100) { return errorOrderNos + "订单不能执行关闭操作"; } else { return "你选择的订单不能执行关闭操作"; } } } //未查询到数据 返回错误提示 return ServiceResultEnum.DATA_NOT_EXIST.getResult(); } @Override public String saveOrder(UserVO user, List<ShoppingCartItemVO> myShoppingCartItems) { List<Long> itemIdList = myShoppingCartItems.stream().map(ShoppingCartItemVO::getCartItemId).collect(Collectors.toList()); List<Long> goodsIds = myShoppingCartItems.stream().map(ShoppingCartItemVO::getGoodsId).collect(Collectors.toList()); List<Goods> MallGoods = goodsMapper.selectByPrimaryKeys(goodsIds); //检查是否包含已下架商品 List<Goods> goodsListNotSelling = MallGoods.stream() .filter(MallGoodsTemp -> MallGoodsTemp.getGoodsSe