add

yj

2024-12-05 b9900893177c78fc559223521fe839aa21000017

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
package com.iotechn.unimall.admin.api.vip;
 
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.dobbinsoft.fw.core.exception.AdminServiceException;
import com.dobbinsoft.fw.core.exception.ServiceException;
import com.dobbinsoft.fw.pay.model.request.MatrixPayRefundRequest;
import com.dobbinsoft.fw.pay.model.result.MatrixPayRefundResult;
import com.dobbinsoft.fw.pay.service.pay.MatrixPayService;
import com.dobbinsoft.fw.support.component.LockComponent;
import com.dobbinsoft.fw.support.model.Page;
import com.dobbinsoft.fw.support.properties.FwWxAppProperties;
import com.iotechn.unimall.biz.service.vip.VipOrderBizService;
import com.iotechn.unimall.data.constant.LockConst;
import com.iotechn.unimall.data.domain.VipOrderDO;
import com.iotechn.unimall.data.enums.VipOrderStatusType;
import com.iotechn.unimall.data.exception.ExceptionDefinition;
import com.iotechn.unimall.data.mapper.VipOrderMapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.Date;
 
@Service
public class AdminVipOrderServiceImpl implements AdminVipOrderService {
 
    private static final Logger logger = LoggerFactory.getLogger(AdminVipOrderServiceImpl.class);
 
    @Autowired
    private VipOrderMapper vipOrderMapper;
    @Autowired
    private VipOrderBizService vipOrderBizService;
    @Autowired
    private LockComponent lockComponent;
    @Autowired
    private FwWxAppProperties fwWxAppProperties;
    @Autowired
    private MatrixPayService matrixPayService;
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public String refund(Long id, Long adminId) throws ServiceException {
        VipOrderDO vipOrderDO = vipOrderMapper.selectById(id);
        if (vipOrderDO.getStatus().intValue() != VipOrderStatusType.WAIT_REFUND.getCode()) {
            throw new AdminServiceException(ExceptionDefinition.VIP_ORDER_STATUS_ERROR);
        }
        if (vipOrderDO.getGmtPay().getTime() + 1000l * 60 * 60 * 24 * 7 <= new Date().getTime()) {
            throw new AdminServiceException(ExceptionDefinition.VIP_ORDER_REFUND_TIME_EXPIRED);
        }
        vipOrderBizService.changeOrderParentStatus(id, VipOrderStatusType.WAIT_REFUND.getCode(), VipOrderStatusType.REFUND_OVER.getCode());
        String lockKey = LockConst.VIP_ORDER_REFUND_LOCK + id;
        if (lockComponent.tryLock(lockKey, 30)) {
            try {
                //2.2.2 向支付平台发送退款请求
                MatrixPayRefundRequest matrixPayRefundRequest = new MatrixPayRefundRequest();
                matrixPayRefundRequest.setAppid(fwWxAppProperties.getMiniAppId());
                matrixPayRefundRequest.setOutTradeNo(vipOrderDO.getOrderNo());
                matrixPayRefundRequest.setOutRefundNo("refund_VIP_" + vipOrderDO.getOrderNo());
                matrixPayRefundRequest.setTotalFee(vipOrderDO.getPrice());
                matrixPayRefundRequest.setRefundFee(vipOrderDO.getPrice());
                MatrixPayRefundResult matrixPayRefundResult = matrixPayService.refund(matrixPayRefundRequest);
                if (!matrixPayRefundResult.getReturnCode().equals("SUCCESS")) {
                    logger.warn("[退款] 失败 : " + matrixPayRefundResult.getReturnMsg());
                    throw new AdminServiceException(matrixPayRefundResult.getReturnMsg(),
                            ExceptionDefinition.THIRD_PART_SERVICE_EXCEPTION.getCode());
                }
                if (!matrixPayRefundResult.getResultCode().equals("SUCCESS")) {
                    logger.warn("[退款] 失败 : " + matrixPayRefundResult.getReturnMsg());
                    throw new AdminServiceException(matrixPayRefundResult.getReturnMsg(),
                            ExceptionDefinition.THIRD_PART_SERVICE_EXCEPTION.getCode());
                }
                return "ok";
 
            } catch (ServiceException e) {
                throw e;
            } catch (Exception e) {
                logger.error("[退款] 异常", e);
                throw new AdminServiceException(ExceptionDefinition.ADMIN_UNKNOWN_EXCEPTION);
            } finally {
                lockComponent.release(lockKey);
            }
        } else {
            throw new AdminServiceException(ExceptionDefinition.SYSTEM_BUSY);
        }
    }
 
    @Override
    public Page<VipOrderDO> list(String orderNo, Integer status, String phone, Long templateId, Integer pageNo, Integer limit, Long adminId) throws ServiceException {
        QueryWrapper<VipOrderDO> wrapper = new QueryWrapper<>();
        if (orderNo != null) {
            wrapper.eq("order_no", orderNo);
        }
        if (status != null) {
            wrapper.eq("status", status);
        }
        if (phone != null) {
            wrapper.eq("phone", phone);
        }
        if (templateId != null) {
            wrapper.eq("template_id", templateId);
        }
        wrapper.orderByDesc("id");
        return vipOrderMapper.selectPage(Page.div(pageNo, limit, VipOrderDO.class), wrapper);
    }
}