|
|
@ -1,5 +1,6 @@ |
|
|
package com.qniao.dam.query.order.impl; |
|
|
package com.qniao.dam.query.order.impl; |
|
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil; |
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
import com.qniao.dam.api.query.order.user.request.UserPageOrderByOperatorQueryParam; |
|
|
import com.qniao.dam.api.query.order.user.request.UserPageOrderByOperatorQueryParam; |
|
|
@ -10,6 +11,8 @@ import com.qniao.dam.api.query.order.user.response.UserPageOrderItemByOperatorVo |
|
|
import com.qniao.dam.application.service.right.RightApplicationService; |
|
|
import com.qniao.dam.application.service.right.RightApplicationService; |
|
|
import com.qniao.dam.domain.aggregate.order.entity.Order; |
|
|
import com.qniao.dam.domain.aggregate.order.entity.Order; |
|
|
import com.qniao.dam.domain.aggregate.order.entity.OrderItem; |
|
|
import com.qniao.dam.domain.aggregate.order.entity.OrderItem; |
|
|
|
|
|
import com.qniao.dam.domain.aggregate.paymentorder.entity.PaymentOrder; |
|
|
|
|
|
import com.qniao.dam.domain.aggregate.paymentorder.valobj.PaymentOrderVoucherImage; |
|
|
import com.qniao.dam.domain.aggregate.productspec.entity.ProductSpec; |
|
|
import com.qniao.dam.domain.aggregate.productspec.entity.ProductSpec; |
|
|
import com.qniao.dam.domain.aggregate.productspec.repository.ProductSpecRepository; |
|
|
import com.qniao.dam.domain.aggregate.productspec.repository.ProductSpecRepository; |
|
|
import com.qniao.dam.domain.aggregate.productspec.valueobj.ProductSpecTerm; |
|
|
import com.qniao.dam.domain.aggregate.productspec.valueobj.ProductSpecTerm; |
|
|
@ -24,6 +27,7 @@ import com.qniao.dam.domian.aggregate.right.constant.RightTypeEnum; |
|
|
import com.qniao.dam.infrastructure.persistent.dao.domain.OrderDao; |
|
|
import com.qniao.dam.infrastructure.persistent.dao.domain.OrderDao; |
|
|
import com.qniao.dam.infrastructure.persistent.dao.view.OrderViewDao; |
|
|
import com.qniao.dam.infrastructure.persistent.dao.view.OrderViewDao; |
|
|
import com.qniao.dam.query.order.OrderQueryService; |
|
|
import com.qniao.dam.query.order.OrderQueryService; |
|
|
|
|
|
import com.qniao.dam.query.paymentorder.PaymentOrderQueryService; |
|
|
import com.qniao.dam.query.product.ProductQueryService; |
|
|
import com.qniao.dam.query.product.ProductQueryService; |
|
|
import com.qniao.dam.query.right.RightQueryService; |
|
|
import com.qniao.dam.query.right.RightQueryService; |
|
|
import com.qniao.domain.QnPage; |
|
|
import com.qniao.domain.QnPage; |
|
|
@ -48,9 +52,9 @@ public class OrderQueryServiceImpl implements OrderQueryService { |
|
|
@Resource |
|
|
@Resource |
|
|
private RightApplicationService rightApplicationService; |
|
|
private RightApplicationService rightApplicationService; |
|
|
@Resource |
|
|
@Resource |
|
|
private ProductSpecRepository productSpecRepository; |
|
|
|
|
|
@Resource |
|
|
|
|
|
private ProductQueryService productQueryService; |
|
|
private ProductQueryService productQueryService; |
|
|
|
|
|
@Resource |
|
|
|
|
|
private PaymentOrderQueryService paymentOrderQueryService; |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public IPage<UserPageOrderByOperatorVo> pageOrderByOperator(PageUtil pageUtil, UserPageOrderByOperatorQueryParam queryParam) { |
|
|
public IPage<UserPageOrderByOperatorVo> pageOrderByOperator(PageUtil pageUtil, UserPageOrderByOperatorQueryParam queryParam) { |
|
|
@ -59,7 +63,16 @@ public class OrderQueryServiceImpl implements OrderQueryService { |
|
|
List<Long> orderIdList = page.getRecords().stream().map(UserPageOrderByOperatorVo::getOrderId).collect(Collectors.toList()); |
|
|
List<Long> orderIdList = page.getRecords().stream().map(UserPageOrderByOperatorVo::getOrderId).collect(Collectors.toList()); |
|
|
List<UserPageOrderItemByOperatorVo> allOrderItemList = orderViewDao.listOrderItemByOperatorByOrderIds(orderIdList); |
|
|
List<UserPageOrderItemByOperatorVo> allOrderItemList = orderViewDao.listOrderItemByOperatorByOrderIds(orderIdList); |
|
|
Map<Long, List<UserPageOrderItemByOperatorVo>> allOrderItemMap = allOrderItemList.stream().collect(Collectors.groupingBy(UserPageOrderItemByOperatorVo::getOrderId)); |
|
|
Map<Long, List<UserPageOrderItemByOperatorVo>> allOrderItemMap = allOrderItemList.stream().collect(Collectors.groupingBy(UserPageOrderItemByOperatorVo::getOrderId)); |
|
|
page.getRecords().forEach(record -> record.setOrderItemList(allOrderItemMap.get(record.getOrderId()))); |
|
|
|
|
|
|
|
|
//付款凭证 |
|
|
|
|
|
List<Long> paymentOrderIdList = page.getRecords().stream().map(UserPageOrderByOperatorVo::getPaymentOrderId).collect(Collectors.toList()); |
|
|
|
|
|
Map<Long, List<PaymentOrderVoucherImage>> allVoucherImageMap = paymentOrderQueryService.mapVoucherImage(paymentOrderIdList); |
|
|
|
|
|
page.getRecords().forEach(record -> { |
|
|
|
|
|
record.setOrderItemList(allOrderItemMap.get(record.getOrderId())); |
|
|
|
|
|
List<PaymentOrderVoucherImage> voucherImageList = allVoucherImageMap.get(record.getPaymentOrderId()); |
|
|
|
|
|
if (CollUtil.isNotEmpty(voucherImageList)) { |
|
|
|
|
|
record.setVoucherImageList(voucherImageList.stream().map(PaymentOrderVoucherImage::getUrl).collect(Collectors.toList())); |
|
|
|
|
|
} |
|
|
|
|
|
}); |
|
|
} |
|
|
} |
|
|
return page; |
|
|
return page; |
|
|
} |
|
|
} |
|
|
@ -97,8 +110,8 @@ public class OrderQueryServiceImpl implements OrderQueryService { |
|
|
@Override |
|
|
@Override |
|
|
public List<Order> listHis(Long userId, OrderBelongingEnum orderBelonging, OrderStatusEnum status) { |
|
|
public List<Order> listHis(Long userId, OrderBelongingEnum orderBelonging, OrderStatusEnum status) { |
|
|
return orderDao.selectList(new LambdaQueryWrapper<Order>() |
|
|
return orderDao.selectList(new LambdaQueryWrapper<Order>() |
|
|
.eq(Order::getUserId,userId) |
|
|
|
|
|
.eq(Order::getOrderBelonging,orderBelonging) |
|
|
|
|
|
.eq(Order::getStatus,status)); |
|
|
|
|
|
|
|
|
.eq(Order::getUserId, userId) |
|
|
|
|
|
.eq(Order::getOrderBelonging, orderBelonging) |
|
|
|
|
|
.eq(Order::getStatus, status)); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |