基于Java的天津大学程序设计高级实践大作业设计源码

package com.neusoft.service.impl; import com.neusoft.feign.PointsFeignClient; import com.neusoft.feign.WalletFeignClient; import com.neusoft.mapper.CartMapper; import com.neusoft.mapper.OrderDetailetMapper; import com.neusoft.mapper.OrdersMapper; import com.neusoft.mapper.WalletOrderMapper; import com.neusoft.po.Cart; import com.neusoft.po.OrderDetailet; import com.neusoft.po.Orders; import com.neusoft.po.Wallet; import com.neusoft.service.OrdersService; import com.neusoft.util.CommonUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; import java.util.List; @Service public class OrdersServiceImpl implements OrdersService { @Autowired private CartMapper cartMapper; @Autowired private OrdersMapper ordersMapper; @Autowired private OrderDetailetMapper orderDetailetMapper; @Autowired private WalletOrderMapper walletOrderMapper; @Autowired private WalletFeignClient walletFeignClient; @Autowired private PointsFeignClient pointsFeignClient; @Override @Transactional public int createOrders(Orders orders) {//只需一行注释就可实现事务管理 @Transactional //1、查询当前用户购物车中当前商家的所有食品 Cart cart = new Cart();//封装一下 cart.setUserId(orders.getUserId()); cart.setBusinessId(orders.getBusinessId()); List<Cart> cartList = cartMapper.listCart(cart); //2、创建订单（返回生成的订单编号） orders.setOrderDate(CommonUtil.getCurrentDate()); ordersMapper.saveOrders(orders); int orderId = orders.getOrderId();//返回的是获取的主键 //3、批量添加订单明细 List<OrderDetailet> list = new ArrayList<>(); for (Cart c : cartList) { OrderDetailet od = new OrderDetailet(); od.setOrderId(orderId); od.setFoodId(c.getFoodId()); od.setQuantity(c.getQuantity()); list.add(od); } orderDetailetMapper.saveOrderDetailetBatch(list); //4、从购物车表中删除相关食品信息 cartMapper.removeCart(cart); return orderId; } @Override public Orders getOrdersById(Integer orderId) { return ordersMapper.getOrdersById(orderId); } @Override public List<Orders> listOrdersByUserId(String userId) { return ordersMapper.listOrdersByUserId(userId); } @Override @Transactional//任何一个数据库操作失败，那么所有的数据库操作都会被回滚， public int updateOrders(Integer orderId, Integer walletId) { Orders orders=ordersMapper.getOrdersById(orderId); if(walletId==-1){// 未使用钱包， int result=ordersMapper.updateOrderState(orderId) *pointsFeignClient.addPoints(orders.getUserId(),(int)(orders.getOrderTotal().doubleValue()),"订单消费").getResult(); return result; } Wallet wallet= walletFeignClient.findWalletById(walletId).getResult(); double balance=wallet.getBalance(); double total=ordersMapper.getOrdersById(orderId).getOrderTotal(); if(wallet.getBalance()<total) {//余额不足 wallet.setBalance(0.0); int result = walletFeignClient.updateBalance(wallet.getId(),wallet.getBalance()).getResult() *walletOrderMapper.saveWalletOrder(orderId, walletId, balance) *ordersMapper.updateOrderState(orderId) *pointsFeignClient.addPoints(orders.getUserId(),(int)(orders.getOrderTotal()-balance),"订单消费").getResult(); return result; }else{//余额充足 wallet.setBalance(balance-total); int result = walletFeignClient.updateBalance(wallet.getId(),wallet.getBalance()).getResult() *walletOrderMapper.saveWalletOrder(orderId, walletId, total) *ordersMapper.updateOrderState(orderId); return result; } } }