后台管理系统源码，基于ssm开发

package com.tulingxueyuan.mall.modules.oms.service.impl; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.date.DateField; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import cn.hutool.core.io.FileUtil; import cn.hutool.core.util.ArrayUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.tulingxueyuan.mall.common.api.ResultCode; import com.tulingxueyuan.mall.common.exception.ApiException; import com.tulingxueyuan.mall.common.service.RedisService; import com.tulingxueyuan.mall.component.TradePayProp; import com.tulingxueyuan.mall.dto.*; import com.tulingxueyuan.mall.modules.oms.mapper.OmsCartItemMapper; import com.tulingxueyuan.mall.modules.oms.mapper.OmsOrderMapper; import com.tulingxueyuan.mall.modules.oms.model.OmsCartItem; import com.tulingxueyuan.mall.modules.oms.model.OmsOrder; import com.tulingxueyuan.mall.modules.oms.model.OmsOrderItem; import com.tulingxueyuan.mall.modules.oms.model.OmsOrderSetting; import com.tulingxueyuan.mall.modules.oms.service.OmsCartItemService; import com.tulingxueyuan.mall.modules.oms.service.OmsOrderItemService; import com.tulingxueyuan.mall.modules.oms.service.OmsOrderService; import com.tulingxueyuan.mall.modules.oms.service.OmsOrderSettingService; import com.tulingxueyuan.mall.modules.pms.model.PmsProduct; import com.tulingxueyuan.mall.modules.pms.model.PmsSkuStock; import com.tulingxueyuan.mall.modules.pms.service.PmsProductService; import com.tulingxueyuan.mall.modules.pms.service.PmsSkuStockService; import com.tulingxueyuan.mall.modules.ums.model.UmsMember; import com.tulingxueyuan.mall.modules.ums.model.UmsMemberReceiveAddress; import com.tulingxueyuan.mall.modules.ums.service.UmsMemberReceiveAddressService; import com.tulingxueyuan.mall.modules.ums.service.UmsMemberService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; /** * <p> * 订单表 服务实现类 * </p> * * @author SunMiao * @since 2022-10-02 */ @Service @Slf4j public class OmsOrderServiceImpl extends ServiceImpl<OmsOrderMapper, OmsOrder> implements OmsOrderService { @Autowired OmsCartItemService cartItemService; @Autowired PmsProductService productService; @Autowired UmsMemberReceiveAddressService addressService; @Autowired UmsMemberService memberService; @Autowired OmsCartItemMapper cartItemMapper; @Autowired PmsSkuStockService skuStockService; @Autowired OmsOrderItemService orderItemService; @Autowired RedisService redisService; @Value("${redis.key.prefix.orderId}") private String REDIS_KEY_PREFIX_ORDER_ID; @Autowired OmsOrderSettingService orderSettingService; @Autowired TradePayProp tradePayProp; @Autowired OmsOrderService orderService; /** * 初始化确认订单的商品和收获地址信息 * @param ids * @return */ @Override public ConfirmOrderDTO generateConfirmOrder(List<Long> ids) { if(CollectionUtil.isEmpty(ids)){ throw new ApiException(ResultCode.VALIDATE_FAILED); } ConfirmOrderDTO confirmOrderDTO = new ConfirmOrderDTO(); // 1.商品 List<OmsCartItem> omsCartItemList = cartItemService.listByIds(ids); confirmOrderDTO.setCartList(omsCartItemList); // 2.计算价格 calcCatAmount(confirmOrderDTO); // 3.收货地址 UmsMember currentMember = memberService.getCurrentMember(); QueryWrapper<UmsMemberReceiveAddress> queryWrapper = new QueryWrapper<>(); queryWrapper.lambda().eq(UmsMemberReceiveAddress::getMemberId,currentMember.getId()); List<UmsMemberReceiveAddress> list = addressService.list(queryWrapper); confirmOrderDTO.setAddressList(list); return confirmOrderDTO; } /** * 计算价格 * @param confirmOrderDTO */ public void calcCatAmount(ConfirmOrderDTO confirmOrderDTO){ // 计算商品数量 Integer productTotal=0; // 总价 BigDecimal priceTotal=new BigDecimal(0); // 运费 BigDecimal freightAmount=new BigDecimal(0); for (OmsCartItem omsCartItem : cartItemService.getCarList()) { // 商品总件数 productTotal += omsCartItem.getQuantity(); // 总价 priceTotal = priceTotal.add(omsCartItem.getPrice().multiply(new BigDecimal(omsCartItem.getQuantity()))); PmsProduct product = productService.getById(omsCartItem.getProductId()); String serviceIds = product.getServiceIds(); String[] serviceIdsArray = serviceIds.split(","); if (serviceIdsArray.length>0){ // 判断是否包邮 if (!ArrayUtil.containsAny(serviceIdsArray,3)){ freightAmount = freightAmount.add(new BigDecimal(10)); } } } confirmOrderDTO.setProductTotal(productTotal); confirmOrderDTO.setPriceTotal(priceTotal); confirmOrderDTO.setFreightAmount(freightAmount); confirmOrderDTO.setPayAmount(priceTotal.subtract(freightAmount)); } /** * 下单 * 1. 判断库存（如果没有库存直接提示） * 没有库存id 只有购物车id，根据购物车id查询所有购物车信息 * 2.保存订单主表oms_order信息 订单号 * 3.保存订单详情表oms_order_item(购物车转移） * 4.锁定库存（如果用户超过10分钟没有支付-恢复库存） * 5.删除对应购物车 * 先不考虑并发 * @param paramDTO * @return */ @Override @Transactional // 事务，保持数据一致性 public OmsOrder generateOrder(OrderParamDTO paramDTO) { // 根据购物车id 查询真实库存 UmsMember currentMember = memberService.getCurrentMember(); QueryWrapper<OmsCartItem> queryWrapper = new QueryWrapper<>(); // 防止用户篡改 queryWrapper.lambda() .eq(OmsCartItem::getMemberId,currentMember.getId()) .in(OmsCartItem::getId,paramDTO.getItemIds()); // 根据购物车id查询所有购物车信息 List<CartItemStockDTO> cartItemStockByIds = cartItemMapper.getCartItemStockByIds(queryWrapper); // 1. 判断库存（如果没有库存直接提示） // 获取库存不足的名称 如果productName为空说明库存未超出 String productName = hasStock(cartItemStockByIds); if(StrUtil.isNotEmpty(productName)){ throw new ApiException("您的手速过慢，"+productName+"已被别人买走"); } // 如果有库存就进行下单操作： //2.保存订单主表oms_order信息 订单号 OmsOrder omsOrder = newOrder(paramDTO, currentMember, cartItemStockByIds); this.save(omsOrder); // 3.保存订单详情表oms_order_item( 购物车转移） List<OmsOrderItem> list=newOrderItems(omsOrder,cartItemStockByIds); orderItemService.saveBatch(list); // 4.锁定库存 lockStock(cartItemStockByIds); // 5.删除对应购物车 removeCartItem(cartItemStockByIds); return omsOrder; } /** * 读取下单成功后的订单详情 * @param id * @return */ @Override public OrderDet