SpringCloud+MybatisPlus+XXL-JOB+redis+Vue前后端分离、分布式、微服务架构Java商城系统

package com.medusa.gruul.order.service.impl; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.TimeInterval; import cn.hutool.core.util.NumberUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.http.HttpStatus; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.IdWorker; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.medusa.gruul.account.api.entity.MiniAccountAddress; import com.medusa.gruul.account.api.enums.BlacklistEnum; import com.medusa.gruul.account.api.feign.RemoteMiniAccountService; import com.medusa.gruul.account.api.model.*; import com.medusa.gruul.afs.api.entity.AfsOrder; import com.medusa.gruul.afs.api.enums.AfsOrderStatusEnum; import com.medusa.gruul.common.core.constant.TimeConstants; import com.medusa.gruul.common.core.exception.ServiceException; import com.medusa.gruul.common.core.util.*; import com.medusa.gruul.common.data.tenant.ShopContextHolder; import com.medusa.gruul.common.data.tenant.TenantContextHolder; import com.medusa.gruul.common.dto.CurShopInfoDto; import com.medusa.gruul.common.dto.CurUserDto; import com.medusa.gruul.goods.api.constant.GoodsSkuStockRedisKey; import com.medusa.gruul.goods.api.entity.SkuStock; import com.medusa.gruul.goods.api.feign.RemoteGoodsService; import com.medusa.gruul.goods.api.model.vo.manager.ItemVo; import com.medusa.gruul.goods.api.param.OperateStockDto; import com.medusa.gruul.logistics.api.feign.RemoteLogisticsFeginService; import com.medusa.gruul.logistics.model.dto.manager.CountCostDto; import com.medusa.gruul.logistics.model.dto.manager.LogisticsFreightDto; import com.medusa.gruul.order.api.constant.OrderCode; import com.medusa.gruul.order.api.constant.OrderConstant; import com.medusa.gruul.order.api.constant.OrderFailedRedisKey; import com.medusa.gruul.order.api.constant.OrderQueueEnum; import com.medusa.gruul.order.api.entity.*; import com.medusa.gruul.order.api.enums.DeliverTypeEnum; import com.medusa.gruul.order.api.enums.OrderStatusEnum; import com.medusa.gruul.order.api.enums.OrderTypeEnum; import com.medusa.gruul.order.api.enums.PayTypeEnum; import com.medusa.gruul.order.api.model.*; import com.medusa.gruul.order.mapper.*; import com.medusa.gruul.order.model.*; import com.medusa.gruul.order.mq.Sender; import com.medusa.gruul.order.service.IMiniOrderService; import com.medusa.gruul.order.service.IOrderShareSettingService; import com.medusa.gruul.payment.api.feign.RemotePaymentService; import com.medusa.gruul.payment.api.model.dto.PayRequestDto; import com.medusa.gruul.payment.api.model.dto.PayResultDto; import com.medusa.gruul.payment.api.model.dto.RefundNotifyResultDto; import com.medusa.gruul.platform.api.feign.RemoteMiniInfoService; import com.medusa.gruul.platform.api.model.dto.ShopConfigDto; import com.medusa.gruul.platform.api.model.vo.PayInfoVo; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.math.BigDecimal; import java.time.LocalDateTime; import java.util.*; import java.util.stream.Collectors; /** * <p> * 订单表 服务实现类 * </p> * * @author alan * @since 2019 -09-02 */ @Slf4j @Service public class MiniOrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements IMiniOrderService { @Resource private RemoteGoodsService remoteGoodsService; @Resource private RemotePaymentService remotePaymentService; @Resource private RemoteMiniAccountService remoteMiniAccountService; @Resource private RemoteLogisticsFeginService remoteLogisticsFeginService; @Resource private IOrderShareSettingService orderShareSettingService; @Resource private OrderDeliveryMapper orderDeliveryMapper; @Resource private OrderSettingMapper orderSettingMapper; @Resource private OrderItemMapper orderItemMapper; @Resource private OrderEvaluateMapper orderEvaluateMapper; @Resource private OrderProductEvaluateMapper productEvaluateMapper; @Resource private Sender sender; @Resource private RemoteMiniInfoService remoteMiniInfoService; @Resource private AfsOrderMapper afsOrderMapper; /** * 根据用户选择的商品返回结算页需要的数据 * * @param dto * @return com.medusa.gruul.order.model.ConfirmOrderVo * @author alan * @date 2020/7/26 14:19 */ @Override public ConfirmOrderVo getConfirmOrder(ConfirmOrderDto dto) { TimeInterval timer = DateUtil.timer(); CurUserDto curUserDto = CurUserUtil.getHttpCurUser(); if (ObjectUtil.isNull(curUserDto)) { throw new ServiceException(SystemCode.UNAUTHORIZED); } log.info("当前用户信息:" + curUserDto.toString()); ConfirmOrderVo result = new ConfirmOrderVo(); GoodsSkuStockRedisKey redisStock = new GoodsSkuStockRedisKey(); //查询商品库存情况 List<ItemVo> itemVoList = remoteGoodsService.findItemVoByIds(dto.getItemSkuIds()); if (CollUtil.isEmpty(itemVoList)) { throw new ServiceException(OrderCode.DATA_HAS_BEEN_UPDATED); } Map<Long, ItemVo> itemVoMap = itemVoList.stream().collect(Collectors.toMap(ItemVo::getProductSkuId, v -> v)); for (ItemDto item : dto.getItems()) { ItemVo itemVo = itemVoMap.get(item.getSkuId()); itemVo.setProductQuantity(item.getNumber()); String stock = redisStock.get(item.getSkuId().toString()); if (ObjectUtil.isNull(stock)) { throw new ServiceException(OrderCode.THIRD_PARTY_SERVICE_EXCEPTION); } if (Integer.parseInt(stock) > item.getNumber()) { //库存状态：0->有库存 itemVo.setStatus(0); } else { //库存状态：1->无库存 itemVo.setStatus(1); } } result.setItemVoList(itemVoList); log.info(ObjectUtil.isNotNull(itemVoList) ? itemVoList.toString() : ""); log.info("查询商品耗时{}ms", timer.intervalRestart()); //查询用户持有的积分、收货地址 AccountInfoDto accountInfoDto = remoteMiniAccountService.accountInfo(curUserDto.getUserId(), Arrays.asList(2, 3, 5)); result.setMiniAccountAddress(accountInfoDto.getMiniAccountAddress()); log.info(ObjectUtil.isNotNull(accountInfoDto) ? accountInfoDto.toString() : ""); log.info("查询用户耗时{}ms", timer.intervalRestart()); //Todo 查询用户的会员情况 //Todo 查询积分使用规则 //Todo 查询满减活动信息 //Todo 查询单个客户优惠劵信息 return result; } /** * 获取运费的参数包装类，将参数包装成需要的格式 * * @param miniAccountAddress * @param deliverType * @param itemDtoList * @return com.medusa.gruul.shipping.model.dto.CountCostDto * @author alan * @date 2020/7/26 14:32 */ private CountCostDto getFreightAmount(MiniAccountAddress miniAccountAddress, DeliverTypeEnum deliverType, List<ItemDto> itemDtoList) { //查询运费 log.info("miniAccountAddress is {}", JSONUtil.toJsonStr(miniAccountAddress)); log.info("deliverType is {}", deliverType.getDesc()); CountCostDto countCostDto; GetCostDto getCostDto = new GetC