package cn.lili.modules.order.order.serviceimpl;
|
|
import cn.hutool.core.date.DateTime;
|
import cn.hutool.core.text.CharSequenceUtil;
|
import cn.lili.base.Result;
|
import cn.lili.common.enums.ResultCode;
|
import cn.lili.common.exception.ServiceException;
|
import cn.lili.common.utils.StringUtils;
|
import cn.lili.modules.goods.entity.dos.GoodsSku;
|
import cn.lili.modules.goods.service.GoodsSkuService;
|
import cn.lili.modules.lmk.domain.vo.GoodsCustomizeTemplateVO;
|
import cn.lili.modules.lmk.service.GoodsCustomizeTemplateService;
|
import cn.lili.modules.order.order.entity.dos.OrderItem;
|
import cn.lili.modules.order.order.entity.dto.OrderItemOperationDTO;
|
import cn.lili.modules.order.order.entity.enums.*;
|
import cn.lili.modules.order.order.mapper.OrderItemMapper;
|
import cn.lili.modules.order.order.service.OrderItemService;
|
import cn.lili.utils.COSUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* 子订单业务层实现
|
*
|
* @author Chopper
|
* @since 2020/11/17 7:38 下午
|
*/
|
@Service
|
@RequiredArgsConstructor
|
public class OrderItemServiceImpl extends ServiceImpl<OrderItemMapper, OrderItem> implements OrderItemService {
|
private final GoodsCustomizeTemplateService goodsCustomizeTemplateService;
|
private final GoodsSkuService skuService;
|
private final COSUtil cosUtil;
|
|
@Override
|
public void updateCommentStatus(String orderItemSn, CommentStatusEnum commentStatusEnum) {
|
LambdaUpdateWrapper<OrderItem> lambdaUpdateWrapper = Wrappers.lambdaUpdate();
|
lambdaUpdateWrapper.set(OrderItem::getCommentStatus, commentStatusEnum.name());
|
lambdaUpdateWrapper.eq(OrderItem::getSn, orderItemSn);
|
this.update(lambdaUpdateWrapper);
|
}
|
|
@Override
|
public void updateAfterSaleStatus(String orderItemSn, OrderItemAfterSaleStatusEnum orderItemAfterSaleStatusEnum) {
|
LambdaUpdateWrapper<OrderItem> lambdaUpdateWrapper = Wrappers.lambdaUpdate();
|
lambdaUpdateWrapper.set(OrderItem::getAfterSaleStatus, orderItemAfterSaleStatusEnum.name());
|
lambdaUpdateWrapper.eq(OrderItem::getSn, orderItemSn);
|
this.update(lambdaUpdateWrapper);
|
}
|
|
@Override
|
public void updateByAfterSale(OrderItem orderItem) {
|
LambdaUpdateWrapper<OrderItem> lambdaUpdateWrapper = new LambdaUpdateWrapper<OrderItem>()
|
.eq(OrderItem::getSn, orderItem.getSn())
|
.set(OrderItem::getIsRefund, orderItem.getIsRefund())
|
.set(OrderItem::getRefundPrice, orderItem.getRefundPrice());
|
this.update(lambdaUpdateWrapper);
|
}
|
|
/**
|
* 更新订单可投诉状态
|
*
|
* @param orderSn 订单sn
|
* @param skuId 商品skuId
|
* @param complainId 订单交易投诉ID
|
* @param complainStatusEnum 修改状态
|
*/
|
@Override
|
public void updateOrderItemsComplainStatus(String orderSn, String skuId, String complainId, OrderComplaintStatusEnum complainStatusEnum) {
|
LambdaQueryWrapper<OrderItem> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(OrderItem::getOrderSn, orderSn).eq(OrderItem::getSkuId, skuId);
|
OrderItem orderItem = getOne(queryWrapper);
|
if (orderItem == null) {
|
throw new ServiceException(ResultCode.ORDER_ITEM_NOT_EXIST);
|
}
|
orderItem.setComplainId(complainId);
|
orderItem.setComplainStatus(complainStatusEnum.name());
|
updateById(orderItem);
|
}
|
|
@Override
|
public OrderItem getBySn(String sn) {
|
LambdaQueryWrapper<OrderItem> lambdaQueryWrapper = Wrappers.lambdaQuery();
|
lambdaQueryWrapper.eq(OrderItem::getSn, sn);
|
return this.getOne(lambdaQueryWrapper);
|
}
|
|
@Override
|
public List<OrderItem> getByOrderSn(String orderSn) {
|
LambdaQueryWrapper<OrderItem> lambdaQueryWrapper = Wrappers.lambdaQuery();
|
lambdaQueryWrapper.eq(OrderItem::getOrderSn, orderSn);
|
//查询每个 skuId对应的商品 是否是定制商品 ，是则查询出模板信息
|
List<OrderItem> list = this.list(lambdaQueryWrapper);
|
|
for (OrderItem orderItem : list) {
|
GoodsSku goodsSku = new LambdaQueryChainWrapper<>(skuService.getBaseMapper())
|
.eq(GoodsSku::getId, orderItem.getSkuId())
|
.eq(GoodsSku::getDeleteFlag, Boolean.FALSE)
|
.one();
|
if (goodsSku != null && CustomizeFlagEnum.CUSTOMIZE.name().equals(goodsSku.getCustomizeFlag())) {
|
if (goodsSku.getCustomizeTemplateId() != null){
|
GoodsCustomizeTemplateVO goodsCustomizeTemplateVO = goodsCustomizeTemplateService.detailById(goodsSku.getCustomizeTemplateId());
|
goodsCustomizeTemplateVO.getListImages().forEach(item ->{
|
if (StringUtils.isNotBlank(item.getImgUrl()) && !item.getImgUrl().contains("http")){
|
item.setImgUrl(cosUtil.getPreviewUrl(item.getImgUrl()));
|
}
|
});
|
|
orderItem.setGoodsCustomizeTemplateVO(goodsCustomizeTemplateVO);
|
|
}
|
}
|
|
}
|
return list;
|
}
|
|
@Override
|
public OrderItem getByOrderSnAndSkuId(String orderSn, String skuId) {
|
return this.getOne(new LambdaQueryWrapper<OrderItem>()
|
.eq(OrderItem::getOrderSn, orderSn)
|
.eq(OrderItem::getSkuId, skuId));
|
}
|
|
@Override
|
public List<OrderItem> waitOperationOrderItem(OrderItemOperationDTO dto) {
|
QueryWrapper queryWrapper = new QueryWrapper();
|
queryWrapper.le("o.complete_time", dto.getReceiveTime());
|
queryWrapper.eq(CharSequenceUtil.isNotEmpty(dto.getCommentStatus()), "oi.comment_status", dto.getCommentStatus());
|
queryWrapper.eq(CharSequenceUtil.isNotEmpty(dto.getAfterSaleStatus()), "oi.after_sale_status", dto.getAfterSaleStatus());
|
queryWrapper.eq(CharSequenceUtil.isNotEmpty(dto.getComplainStatus()), "oi.complain_status", dto.getComplainStatus());
|
return this.baseMapper.waitOperationOrderItem(queryWrapper);
|
}
|
|
|
@Override
|
public void expiredAfterSaleStatus(DateTime expiredTime) {
|
this.baseMapper.expiredAfterSaleStatus(expiredTime);
|
this.baseMapper.expiredAfterSaleStatusExecuteByAfterSale(expiredTime);
|
}
|
}
|
