基于Spring Boot为主线的技术栈，采用RESTful风格架构的微信点餐系统.zip

package cn.imlxy.service.impl; import cn.imlxy.converter.OrderMaster2OrderDTOConverter; import cn.imlxy.dao.OrderDetailDao; import cn.imlxy.dao.OrderMasterDao; import cn.imlxy.dto.CartDTO; import cn.imlxy.dto.OrderDTO; import cn.imlxy.entity.OrderDetail; import cn.imlxy.entity.OrderMaster; import cn.imlxy.entity.ProductInfo; import cn.imlxy.enums.OrderStatusEnum; import cn.imlxy.enums.PayStatusEnum; import cn.imlxy.enums.ResultEnum; import cn.imlxy.exception.SellException; import cn.imlxy.service.*; import cn.imlxy.utils.KeyUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Page; import org.springframework.data.domain.PageImpl; import org.springframework.data.domain.Pageable; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import javax.persistence.Transient; import java.math.BigDecimal; import java.math.BigInteger; import java.util.ArrayList; import java.util.List; import java.util.stream.Collectors; /** * @ClassName : OrderServiceImpl * @Description : 订单 * @Author : LiuXinyu * @Site : www.imlxy.cn * @Date: 2020-05-11 21:46 */ @Service @Slf4j public class OrderServiceImpl implements OrderService { @Autowired private ProductService productService; @Autowired private OrderDetailDao orderDetailDao; @Autowired private OrderMasterDao orderMasterDao; @Autowired private PayService payService; @Autowired private PushMessageService pushMessageService; @Autowired private WebSocket webSocket; @Override @Transactional public OrderDTO create(OrderDTO orderDTO) { String orderId = KeyUtil.genUniqueKey(); BigDecimal orderAmount = new BigDecimal(BigInteger.ZERO); //1、查询商品（数量、价格） for (OrderDetail orderDetail : orderDTO.getOrderDetailList()) { ProductInfo productInfo = productService.findOne(orderDetail.getProductId()); if (productInfo == null) { throw new SellException(ResultEnum.PRODUCT_NOT_EXIT); // throw new ResponseBankException(); } //2、计算订单总价 orderAmount=productInfo.getProductPrice() .multiply(new BigDecimal(orderDetail.getProductQuantity())) .add(orderAmount); //订单详情入库 orderDetail.setDetailId(KeyUtil.genUniqueKey()); orderDetail.setOrderId(orderId); BeanUtils.copyProperties(productInfo, orderDetail); orderDetailDao.save(orderDetail); } //3、写入订单数据库（orderMaster和orderDetail） OrderMaster orderMaster = new OrderMaster(); orderDTO.setOrderId(orderId); BeanUtils.copyProperties(orderDTO, orderMaster); orderMaster.setOrderAmount(orderAmount); orderMaster.setOrderStatus(OrderStatusEnum.NEW.getCode()); orderMaster.setPayStatus(PayStatusEnum.WAIT.getCode()); orderMasterDao.save(orderMaster); //4、扣库存 List<CartDTO> cartDTOList = orderDTO.getOrderDetailList() .stream().map(e -> new CartDTO(e.getProductId(), e.getProductQuantity())) .collect(Collectors.toList()); productService.decreaseStock(cartDTOList); //发送websocket消息 webSocket.sendMessage(orderDTO.getOrderId()); return orderDTO; } @Override public OrderDTO findOne(String orderId) { OrderMaster orderMaster = orderMasterDao.findOne(orderId); if (orderMaster == null) { throw new SellException(ResultEnum.ORDER_NOT_EXIST); } List<OrderDetail> orderDetailList = orderDetailDao.findByOrOrderId(orderId); if (CollectionUtils.isEmpty(orderDetailList)) { throw new SellException(ResultEnum.ORDERDETAIL_NOT_EXIST); } OrderDTO orderDTO = new OrderDTO(); BeanUtils.copyProperties(orderMaster, orderDTO); orderDTO.setOrderDetailList(orderDetailList); return orderDTO; } @Override public Page<OrderDTO> findList(String buyerOpenid, Pageable pageable) { Page<OrderMaster> orderMasterPage = orderMasterDao.findByBuyerOpenid(buyerOpenid, pageable); //List<T> getContent(); //将所有数据返回为List List<OrderDTO> orderDTOList = OrderMaster2OrderDTOConverter.convert(orderMasterPage.getContent()); return new PageImpl<OrderDTO>(orderDTOList, pageable, orderMasterPage.getTotalElements()); } @Override @Transactional public OrderDTO cancel(OrderDTO orderDTO) { OrderMaster orderMaster=new OrderMaster(); // BeanUtils.copyProperties(orderDTO,orderMaster); //判断订单状态 if(!orderDTO.getOrderStatus().equals(OrderStatusEnum.NEW.getCode())){ log.error("【取消订单】订单状态不正确, orderId={},orderStatus={}",orderDTO.getOrderId(),orderDTO.getOrderStatus()); throw new SellException(ResultEnum.ORDER_STATUS_ERROR); } //修改订单状态 orderDTO.setOrderStatus(OrderStatusEnum.CANCLE.getCode()); BeanUtils.copyProperties(orderDTO,orderMaster); OrderMaster updateResult=orderMasterDao.save(orderMaster); if(updateResult==null){ log.error("【取消订单】更新失败,orderMaster={}",orderMaster); throw new SellException(ResultEnum.ORDER_UPDATE_FAIL); } //返还库存 if(CollectionUtils.isEmpty(orderDTO.getOrderDetailList())){ log.error("【取消订单】订单中无商品详情，orderDTO={}",orderDTO); throw new SellException(ResultEnum.ORDER_DETAIL_EMPTY); } List<CartDTO> cartDTOList=orderDTO.getOrderDetailList().stream() .map(e->new CartDTO(e.getProductId(),e.getProductQuantity())) .collect(Collectors.toList()); productService.increaseStock(cartDTOList); //如果已支付，需要退款 if (orderDTO.getPayStatus().equals(PayStatusEnum.SUCCESS.getCode())) { payService.refund(orderDTO); } return orderDTO; } @Override @Transactional public OrderDTO finish(OrderDTO orderDTO) { //判断订单状态 if (orderDTO.getOrderStatus().equals(OrderStatusEnum.FINISHED.getCode())) { log.error("【完结订单】订单状态不正确,orderId={},orderStatus={}", orderDTO.getOrderId(), orderDTO.getOrderStatus()); throw new SellException(ResultEnum.ORDER_STATUS_ERROR); } //修改订单状态 orderDTO.setOrderStatus(OrderStatusEnum.FINISHED.getCode()); OrderMaster orderMaster = new OrderMaster(); BeanUtils.copyProperties(orderDTO, orderMaster); OrderMaster updateResult = orderMasterDao.save(orderMaster); if (updateResult == null) { log.error("【完结订单】 更新失败,orderMaster={}", orderMaster); throw new SellException(ResultEnum.ORDER_UPDATE_FAIL); } //推送微信模板消息 pushMessageService.orderStatus(orderDTO); return orderDTO; } @Override @Transactional public OrderDTO paid(OrderDTO orderDTO) { //判断订单状态 if (!orderDTO.getOrderStatus().equals(OrderStatusEnum.NEW.getCode())) { log.error("【订单支付成功】订单状态不正确, orderId={},orderStatus={}",orderDTO.getOrderId(),orderDTO.getOrderStatus()); throw new SellException(ResultEnum.ORDER_STATUS_ERROR); } //判断支付状态 if (!orderDTO.getPayStatus().equals(PayStatusEnum.WAIT.getCode())) { log.error("【订单支付完成】订单状态不正确，orderDTO={}", orde