package cn.iocoder.yudao.module.trade.controller.admin.aftersale;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.module.member.api.user.MemberUserApi;
|
import cn.iocoder.yudao.module.member.api.user.dto.MemberUserRespDTO;
|
import cn.iocoder.yudao.module.pay.api.notify.dto.PayRefundNotifyReqDTO;
|
import cn.iocoder.yudao.module.trade.controller.admin.aftersale.vo.*;
|
import cn.iocoder.yudao.module.trade.convert.aftersale.AfterSaleConvert;
|
import cn.iocoder.yudao.module.trade.dal.dataobject.aftersale.AfterSaleDO;
|
import cn.iocoder.yudao.module.trade.dal.dataobject.aftersale.AfterSaleLogDO;
|
import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderDO;
|
import cn.iocoder.yudao.module.trade.dal.dataobject.order.TradeOrderItemDO;
|
import cn.iocoder.yudao.module.trade.service.aftersale.AfterSaleLogService;
|
import cn.iocoder.yudao.module.trade.service.aftersale.AfterSaleService;
|
import cn.iocoder.yudao.module.trade.service.order.TradeOrderQueryService;
|
import cn.iocoder.yudao.module.trade.service.order.TradeOrderUpdateService;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Parameter;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.security.access.prepost.PreAuthorize;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import jakarta.annotation.Resource;
|
import jakarta.annotation.security.PermitAll;
|
import jakarta.validation.Valid;
|
import java.util.List;
|
import java.util.Map;
|
|
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
|
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
|
import static cn.iocoder.yudao.framework.common.util.servlet.ServletUtils.getClientIP;
|
import static cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils.getLoginUserId;
|
|
@Tag(name = "管理后台 - 售后订单")
|
@RestController
|
@RequestMapping("/trade/after-sale")
|
@Validated
|
@Slf4j
|
public class AfterSaleController {
|
|
@Resource
|
private AfterSaleService afterSaleService;
|
@Resource
|
private TradeOrderQueryService tradeOrderQueryService;
|
@Resource
|
private TradeOrderUpdateService tradeOrderUpdateService;
|
@Resource
|
private AfterSaleLogService afterSaleLogService;
|
@Resource
|
private MemberUserApi memberUserApi;
|
|
@GetMapping("/page")
|
@Operation(summary = "获得售后订单分页")
|
@PreAuthorize("@ss.hasPermission('trade:after-sale:query')")
|
public CommonResult<PageResult<AfterSaleRespPageItemVO>> getAfterSalePage(@Valid AfterSalePageReqVO pageVO) {
|
// 查询售后
|
PageResult<AfterSaleDO> pageResult = afterSaleService.getAfterSalePage(pageVO);
|
if (CollUtil.isEmpty(pageResult.getList())) {
|
return success(PageResult.empty());
|
}
|
|
// 查询会员
|
Map<Long, MemberUserRespDTO> memberUsers = memberUserApi.getUserMap(
|
convertSet(pageResult.getList(), AfterSaleDO::getUserId));
|
return success(AfterSaleConvert.INSTANCE.convertPage(pageResult, memberUsers));
|
}
|
|
@GetMapping("/get-detail")
|
@Operation(summary = "获得售后订单详情")
|
@Parameter(name = "id", description = "售后编号", required = true, example = "1")
|
@PreAuthorize("@ss.hasPermission('trade:after-sale:query')")
|
public CommonResult<AfterSaleDetailRespVO> getOrderDetail(@RequestParam("id") Long id) {
|
// 查询订单
|
AfterSaleDO afterSale = afterSaleService.getAfterSale(id);
|
if (afterSale == null) {
|
return success(null);
|
}
|
|
// 查询订单
|
TradeOrderDO order = tradeOrderQueryService.getOrder(afterSale.getOrderId());
|
// 查询订单项
|
TradeOrderItemDO orderItem = tradeOrderQueryService.getOrderItem(afterSale.getOrderItemId());
|
// 拼接数据
|
MemberUserRespDTO user = memberUserApi.getUser(afterSale.getUserId());
|
List<AfterSaleLogDO> logs = afterSaleLogService.getAfterSaleLogList(afterSale.getId());
|
return success(AfterSaleConvert.INSTANCE.convert(afterSale, order, orderItem, user, logs));
|
}
|
|
@PutMapping("/agree")
|
@Operation(summary = "同意售后")
|
@Parameter(name = "id", description = "售后编号", required = true, example = "1")
|
@PreAuthorize("@ss.hasPermission('trade:after-sale:agree')")
|
public CommonResult<Boolean> agreeAfterSale(@RequestParam("id") Long id) {
|
afterSaleService.agreeAfterSale(getLoginUserId(), id);
|
return success(true);
|
}
|
|
@PutMapping("/disagree")
|
@Operation(summary = "拒绝售后")
|
@PreAuthorize("@ss.hasPermission('trade:after-sale:disagree')")
|
public CommonResult<Boolean> disagreeAfterSale(@RequestBody AfterSaleDisagreeReqVO confirmReqVO) {
|
afterSaleService.disagreeAfterSale(getLoginUserId(), confirmReqVO);
|
return success(true);
|
}
|
|
@PutMapping("/receive")
|
@Operation(summary = "确认收货")
|
@Parameter(name = "id", description = "售后编号", required = true, example = "1")
|
@PreAuthorize("@ss.hasPermission('trade:after-sale:receive')")
|
public CommonResult<Boolean> receiveAfterSale(@RequestParam("id") Long id) {
|
afterSaleService.receiveAfterSale(getLoginUserId(), id);
|
return success(true);
|
}
|
|
@PutMapping("/refuse")
|
@Operation(summary = "拒绝收货")
|
@Parameter(name = "id", description = "售后编号", required = true, example = "1")
|
@PreAuthorize("@ss.hasPermission('trade:after-sale:receive')")
|
public CommonResult<Boolean> refuseAfterSale(AfterSaleRefuseReqVO refuseReqVO) {
|
afterSaleService.refuseAfterSale(getLoginUserId(), refuseReqVO);
|
return success(true);
|
}
|
|
@PutMapping("/refund")
|
@Operation(summary = "确认退款")
|
@Parameter(name = "id", description = "售后编号", required = true, example = "1")
|
@PreAuthorize("@ss.hasPermission('trade:after-sale:refund')")
|
public CommonResult<Boolean> refundAfterSale(@RequestParam("id") Long id) {
|
afterSaleService.refundAfterSale(getLoginUserId(), getClientIP(), id);
|
return success(true);
|
}
|
|
@PostMapping("/update-refunded")
|
@Operation(summary = "更新售后订单为已退款") // 由 pay-module 支付服务，进行回调，可见 PayNotifyJob
|
@PermitAll // 无需登录，安全由 AfterSaleService 内部校验实现
|
public CommonResult<Boolean> updateAfterSaleRefunded(@RequestBody PayRefundNotifyReqDTO notifyReqDTO) {
|
log.info("[updateAfterRefund][notifyReqDTO({})]", notifyReqDTO);
|
if (StrUtil.startWithAny(notifyReqDTO.getMerchantRefundId(), "order-")) {
|
Long orderId = Long.parseLong(StrUtil.subAfter(notifyReqDTO.getMerchantRefundId(), "order-", true));
|
tradeOrderUpdateService.updatePaidOrderRefunded(orderId, notifyReqDTO.getPayRefundId());
|
} else {
|
afterSaleService.updateAfterSaleRefunded(
|
Long.parseLong(notifyReqDTO.getMerchantRefundId()),
|
Long.parseLong(notifyReqDTO.getMerchantOrderId()),
|
notifyReqDTO.getPayRefundId());
|
}
|
return success(true);
|
}
|
|
}
|
