| | |
|---|
| | | import com.ruoyi.common.core.constant.SecurityConstants; |
|---|
| | | import com.ruoyi.common.core.enums.GroupStatusEnum; |
|---|
| | | import com.ruoyi.common.core.enums.ListingStatusEnum; |
|---|
| | | import com.ruoyi.common.core.enums.PaymentMethodEnum; |
|---|
| | | import com.ruoyi.common.core.enums.OrderStatusEnum; |
|---|
| | | import com.ruoyi.common.core.enums.StartStatusEnum; |
|---|
| | | import com.ruoyi.common.core.exception.ServiceException; |
|---|
| | | import com.ruoyi.common.core.utils.StringUtils; |
|---|
| | |
|---|
| | | import com.ruoyi.system.api.domain.GoodsSku; |
|---|
| | | import com.ruoyi.system.api.domain.Order; |
|---|
| | | import com.ruoyi.system.api.domain.dto.ListStatusDTO; |
|---|
| | | import com.ruoyi.system.api.domain.dto.OrderUpdDTO; |
|---|
| | | import com.ruoyi.system.api.domain.dto.RefundDTO; |
|---|
| | | import com.ruoyi.system.api.feignClient.OrderClient; |
|---|
| | | import java.time.LocalDateTime; |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.concurrent.ConcurrentHashMap; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | import lombok.RequiredArgsConstructor; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | |
|---|
| | | //查询关联订单 |
|---|
| | | List<Order> orderList = orderClient.getOrderByGroupPurchaseId(id, |
|---|
| | | SecurityConstants.INNER).getData(); |
|---|
| | | for (Order order : orderList) { |
|---|
| | | if (PaymentMethodEnum.ALIPAY.equals(order.getPaymentMethod())) { |
|---|
| | | //TODO 退款 |
|---|
| | | } |
|---|
| | | if (PaymentMethodEnum.WECHAT.equals(order.getPaymentMethod())) { |
|---|
| | | //TODO 退款 |
|---|
| | | } |
|---|
| | | |
|---|
| | | List<RefundDTO> refundDTOList = orderList.stream().map(order -> { |
|---|
| | | RefundDTO refundDTO = new RefundDTO(); |
|---|
| | | refundDTO.setOrderNo(order.getOrderNo()); |
|---|
| | | refundDTO.setAmount(order.getTotalAmount()); |
|---|
| | | return refundDTO; |
|---|
| | | }).collect(Collectors.toList()); |
|---|
| | | Map<String, Object> data = orderClient.refund(refundDTOList, |
|---|
| | | SecurityConstants.INNER).getData(); |
|---|
| | | if (StringUtils.isNotEmpty(data)) { |
|---|
| | | // 处理退款返回结果 |
|---|
| | | List<String> successfulOrders = new ArrayList<>(); |
|---|
| | | List<String> failedOrders = new ArrayList<>(); |
|---|
| | | |
|---|
| | | data.forEach((key, value) -> { |
|---|
| | | if ((boolean) value) { |
|---|
| | | successfulOrders.add(key); |
|---|
| | | } else { |
|---|
| | | failedOrders.add(key); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | // 处理退款结果 |
|---|
| | | List<Order> updateOrderList = orderList.stream() |
|---|
| | | .filter(order -> successfulOrders.contains(order.getOrderNo())) |
|---|
| | | .peek(order -> { |
|---|
| | | order.setOrderStatus(OrderStatusEnum.CANCELED); |
|---|
| | | }).collect(Collectors.toList()); |
|---|
| | | List<OrderUpdDTO> orderUpdDTOS = BeanUtils.copyList(updateOrderList, |
|---|
| | | OrderUpdDTO.class); |
|---|
| | | orderClient.updateOrderList(orderUpdDTOS, SecurityConstants.INNER); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | this.lambdaUpdate() |
|---|
