淘宝超市卡TopAPI接入实战：Spring Boot + Lombok完整实现指南

<dependencies>
    <!-- Spring Boot Starter -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    
    <!-- Lombok -->
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    
    <!-- 淘宝Top SDK -->
    <dependency>
        <groupId>com.taobao.top</groupId>
        <artifactId>top-api-sdk</artifactId>
        <version>2.0.0</version>
    </dependency>
    
    <!-- 测试 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

controller       - 接收HTTP请求
service          - 业务逻辑处理
config           - 配置类
dto              - 数据传输对象
exception        - 自定义异常

// 配置淘宝客户端
@Configuration
public class TopApiConfig {
    @Bean
    public TaobaoClient taobaoClient(
        @Value("${top.api.url}") String url,
        @Value("${top.api.appkey}") String appKey,
        @Value("${top.api.appsecret}") String appSecret) {
        return new DefaultTaobaoClient(url, appKey, appSecret);
    }
}

// 服务接口
public interface SupermarketCardService {
    TradeInfoResponse getTradeInfo(TradeInfoRequest request);
    void buyCard(BuyCardRequest request);
    FetchCardResponse fetchCard(FetchCardRequest request);
    void bindCard(BindCardRequest request);
}

@Override
public TradeInfoResponse getTradeInfo(TradeInfoRequest request) {
    TradeFullinfoGetRequest req = new TradeFullinfoGetRequest();
    req.setTid(request.getTid());
    
    try {
        TradeFullinfoGetResponse response = taobaoClient.execute(req);
        if (response.isSuccess()) {
            TradeInfoResponse result = new TradeInfoResponse();
            result.setVirtualUserId(response.getBuyerNick()); // 假设虚拟ID是买家昵称
            result.setTradeStatus(response.getStatus());
            return result;
        } else {
            log.error("获取交易信息失败: {}", response.getSubMsg());
            throw new ApiException(response.getSubCode(), response.getSubMsg());
        }
    } catch (ApiException e) {
        log.error("调用淘宝API异常", e);
        throw new RuntimeException("调用淘宝API异常", e);
    }
}

@Data
public class BuyCardRequest {
    @NotBlank(message = "虚拟用户ID不能为空")
    private String virtualUserId;
    
    @Min(value = 1, message = "面值必须大于0")
    private Long parValue;
    
    private boolean needBindUser = false;
}

@PostMapping("/buy")
public ResponseEntity<?> buyCard(@Valid @RequestBody BuyCardRequest request) {
    supermarketCardService.buyCard(request);
    return ResponseEntity.ok().build();
}

@Override
public FetchCardResponse fetchCard(FetchCardRequest request) {
    TmallPurchaseCardFetchRequest req = new TmallPurchaseCardFetchRequest();
    req.setPurchaseOrderId(request.getPurchaseOrderId());
    
    try {
        TmallPurchaseCardFetchResponse response = taobaoClient.execute(req);
        if (response.isSuccess()) {
            FetchCardResponse result = new FetchCardResponse();
            result.setCardNo(response.getCardNo());
            result.setEncryptedPwd(response.getEncryptedPwd());
            
            // 使用RSA私钥解密
            if (StringUtils.isNotBlank(response.getEncryptedPwd())) {
                result.setDecryptPwd(rsaDecrypt(response.getEncryptedPwd()));
            }
            
            return result;
        } else {
            throw new ApiException(response.getSubCode(), response.getSubMsg());
        }
    } catch (Exception e) {
        throw new RuntimeException("获取卡密失败", e);
    }
}

@PostMapping("/bind")
public ResponseEntity<?> bindCard(@Valid @RequestBody BindCardRequest request) {
    supermarketCardService.bindCard(request);
    return ResponseEntity.ok().build();
}

// 实现类
@Override
public void bindCard(BindCardRequest request) {
    TmallPurchaseCardBindRequest req = new TmallPurchaseCardBindRequest();
    req.setCardNo(request.getCardNo());
    req.setVirtualUserId(request.getVirtualUserId());
    
    try {
        TmallPurchaseCardBindResponse response = taobaoClient.execute(req);
        if (!response.isSuccess()) {
            throw new ApiException(response.getSubCode(), response.getSubMsg());
        }
    } catch (ApiException e) {
        throw new RuntimeException("绑定超市卡失败", e);
    }
}

@Configuration
public class RsaConfig {
    
    @Value("${rsa.private-key}")
    private String privateKey;
    
    @Bean
    public RSA rsa() {
        return new RSA(privateKey, null);
    }
    
    public String rsaDecrypt(String encryptedText) {
        try {
            return new String(rsa().decrypt(encryptedText, KeyType.PrivateKey));
        } catch (Exception e) {
            throw new RuntimeException("RSA解密失败", e);
        }
    }
}

@RestControllerAdvice
public class GlobalExceptionHandler {
    
    @ExceptionHandler(ApiException.class)
    public ResponseEntity<ErrorResponse> handleApiException(ApiException e) {
        ErrorResponse response = new ErrorResponse(
            "API_ERROR", 
            "淘宝API调用失败: " + e.getMessage()
        );
        return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(response);
    }
    
    @Data
    @AllArgsConstructor
    public static class ErrorResponse {
        private String code;
        private String message;
    }
}

@SpringBootTest
@Slf4j
class SupermarketCardIntegrationTest {

    @Autowired
    private SupermarketCardService service;
    
    @Test
    @Order(1)
    void testGetTradeInfo() {
        TradeInfoRequest request = new TradeInfoRequest();
        request.setTid(123456789L);
        
        TradeInfoResponse response = service.getTradeInfo(request);
        assertNotNull(response.getVirtualUserId());
        log.info("获取虚拟用户ID成功: {}", response.getVirtualUserId());
    }
    
    @Test
    @Order(2)
    void testBuyCard() {
        BuyCardRequest request = new BuyCardRequest();
        request.setVirtualUserId("test_user_001");
        request.setParValue(2L);
        
        assertDoesNotThrow(() -> service.buyCard(request));
        log.info("购买超市卡成功");
    }
    
    @Test
    @Order(3)
    void testFetchCard() {
        FetchCardRequest request = new FetchCardRequest();
        request.setPurchaseOrderId(987654321L);
        
        FetchCardResponse response = service.fetchCard(request);
        assertNotNull(response.getCardNo());
        log.info("获取卡密成功，卡号: {}", response.getCardNo());
    }
    
    @Test
    @Order(4)
    void testBindCard() {
        BindCardRequest request = new BindCardRequest();
        request.setVirtualUserId("test_user_001");
        request.setCardNo("1234567890");
        
        assertDoesNotThrow(() -> service.bindCard(request));
        log.info("绑定超市卡成功");
    }
}

# 测试商品
test.card.par-value=2

# 测试用户
test.user.virtual-id=test_user_001

# 测试环境
top.api.url=http://pre-gw.api.taobao.com/top/router/rest

# 生产环境
top.api.url=http://gw.api.taobao.com/router/rest