✅ 新增BFI服务层单元测试覆盖客户/应付/应收/票务/资金接口
This commit is contained in:
刘泉佳
+592
@@ -0,0 +1,592 @@
|
||||
/*
|
||||
* BladeX Commercial License Agreement
|
||||
* Copyright (c) 2018-2099, https://bladex.cn. All rights reserved.
|
||||
* <p>
|
||||
* Use of this software is governed by the Commercial License Agreement
|
||||
* obtained after purchasing a license from BladeX.
|
||||
* <p>
|
||||
* 1. This software is for development use only under a valid license
|
||||
* from BladeX.
|
||||
* <p>
|
||||
* 2. Redistribution of this software's source code to any third party
|
||||
* without a commercial license is strictly prohibited.
|
||||
* <p>
|
||||
* 3. Licensees may copyright their own code but cannot use segments
|
||||
* from this software for such purposes. Copyright of this software
|
||||
* remains with BladeX.
|
||||
* <p>
|
||||
* Using this software signifies agreement to this License, and the software
|
||||
* must not be used for illegal purposes.
|
||||
* <p>
|
||||
* THIS SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY. The author is
|
||||
* not liable for any claims arising from secondary or illegal development.
|
||||
* <p>
|
||||
* Author: Chill Zhuang (bladejava@qq.com)
|
||||
*/
|
||||
package org.springblade.thirdparty.bfi.service;
|
||||
|
||||
import cn.hutool.json.JSONObject;
|
||||
import cn.hutool.json.JSONUtil;
|
||||
import feign.Request;
|
||||
import feign.Response;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.junit.jupiter.api.extension.ExtendWith;
|
||||
import org.mockito.ArgumentCaptor;
|
||||
import org.mockito.InjectMocks;
|
||||
import org.mockito.Mock;
|
||||
import org.mockito.junit.jupiter.MockitoExtension;
|
||||
import org.springblade.core.redis.cache.BladeRedis;
|
||||
import org.springblade.thirdparty.bfi.config.BfiProperties;
|
||||
import org.springblade.thirdparty.bfi.exception.BfiException;
|
||||
import org.springblade.thirdparty.bfi.feign.IBfiClient;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiApBillQueryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiApBillSaveDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiApBillSaveEntryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiArBillQueryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiArBillSaveDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiArBillSaveEntryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiClaimAnnounceQueryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiClaimPushDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiClaimPushEntryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiCustomerQueryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiCustomerSaveDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiCustomerGroupEntryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiInvoiceApplyOpenApiQueryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiInvoiceApplyQueryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiInvoiceApplySaveDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiInvoiceApplySaveEntryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiInvoiceAssignBodyDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiInvoiceAssignItemDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiInvoiceAssignRefDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiInvoicePoolQueryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiReceivedInvoiceQueryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiReceivedInvoiceSaveDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiReceivedInvoiceSaveEntryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiRecBillQueryDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.dto.BfiTokenDTO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiApBillVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiArBillVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiBillSaveResultVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiClaimAnnounceVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiCustomerVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiInvoiceApplyVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiInvoicePoolVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiOpenApiResultVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiPageVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiReceivedInvoiceVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiRecBillVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiResultVO;
|
||||
import org.springblade.thirdparty.bfi.pojo.vo.BfiTokenVO;
|
||||
import org.springframework.data.redis.core.ValueOperations;
|
||||
|
||||
import org.springblade.thirdparty.bfi.service.impl.BfiServiceImpl;
|
||||
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.util.Base64;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
import static org.junit.jupiter.api.Assertions.assertNotNull;
|
||||
import static org.junit.jupiter.api.Assertions.assertThrows;
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
import static org.mockito.ArgumentMatchers.any;
|
||||
import static org.mockito.ArgumentMatchers.anyString;
|
||||
import static org.mockito.ArgumentMatchers.eq;
|
||||
import static org.mockito.Mockito.lenient;
|
||||
import static org.mockito.Mockito.never;
|
||||
import static org.mockito.Mockito.verify;
|
||||
import static org.mockito.Mockito.verifyNoInteractions;
|
||||
import static org.mockito.Mockito.when;
|
||||
|
||||
/**
|
||||
* 业财融合（BFI）服务实现单元测试
|
||||
*
|
||||
* @author Chill
|
||||
*/
|
||||
@ExtendWith(MockitoExtension.class)
|
||||
class BfiServiceImplTest {
|
||||
|
||||
@Mock
|
||||
private BfiProperties properties;
|
||||
|
||||
@Mock
|
||||
private IBfiClient client;
|
||||
|
||||
@Mock
|
||||
private BladeRedis bladeRedis;
|
||||
|
||||
@Mock
|
||||
private ValueOperations<String, Object> valueOperations;
|
||||
|
||||
@InjectMocks
|
||||
private BfiServiceImpl service;
|
||||
|
||||
@BeforeEach
|
||||
void setUp() {
|
||||
lenient().when(properties.getClientId()).thenReturn("test-client");
|
||||
lenient().when(properties.getClientSecret()).thenReturn("test-secret");
|
||||
lenient().when(properties.getUsername()).thenReturn("test-user");
|
||||
lenient().when(properties.getAccountId()).thenReturn("test-account");
|
||||
lenient().when(properties.getLanguage()).thenReturn("zh_CN");
|
||||
lenient().when(bladeRedis.getValueOps()).thenReturn(valueOperations);
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建成功响应
|
||||
*/
|
||||
private <T> BfiResultVO<T> success(T data) {
|
||||
BfiResultVO<T> result = new BfiResultVO<>();
|
||||
result.setStatus(true);
|
||||
result.setErrorCode("0");
|
||||
result.setData(data);
|
||||
return result;
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建保存结果
|
||||
*/
|
||||
private BfiBillSaveResultVO saveResult(int successCount) {
|
||||
BfiBillSaveResultVO result = new BfiBillSaveResultVO();
|
||||
result.setSuccessCount(String.valueOf(successCount));
|
||||
result.setFailCount("0");
|
||||
return result;
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建令牌数据
|
||||
*/
|
||||
private BfiTokenVO tokenVO() {
|
||||
BfiTokenVO tokenVO = new BfiTokenVO();
|
||||
tokenVO.setAccessToken("token-1");
|
||||
tokenVO.setExpiresIn(600_000L);
|
||||
return tokenVO;
|
||||
}
|
||||
|
||||
/**
|
||||
* 模拟缓存未命中并通过 getToken 获取令牌
|
||||
*/
|
||||
private void mockAccessToken() {
|
||||
when(bladeRedis.get("blade:third:bfi:token")).thenReturn(null);
|
||||
when(client.getToken(any(BfiTokenDTO.class))).thenReturn(success(tokenVO()));
|
||||
}
|
||||
|
||||
@Test
|
||||
void getTokenShouldCacheAndReturnToken() {
|
||||
when(client.getToken(any(BfiTokenDTO.class))).thenReturn(success(tokenVO()));
|
||||
BfiTokenVO tokenVO = service.getToken();
|
||||
assertEquals("token-1", tokenVO.getAccessToken());
|
||||
ArgumentCaptor<BfiTokenDTO> captor = ArgumentCaptor.forClass(BfiTokenDTO.class);
|
||||
verify(client).getToken(captor.capture());
|
||||
assertEquals("test-client", captor.getValue().getClientId());
|
||||
assertNotNull(captor.getValue().getNonce());
|
||||
assertNotNull(captor.getValue().getTimestamp());
|
||||
verify(valueOperations).setIfAbsent(eq("blade:third:bfi:token"), eq("token-1"), any());
|
||||
}
|
||||
|
||||
@Test
|
||||
void getTokenShouldThrowWhenDataEmpty() {
|
||||
when(client.getToken(any(BfiTokenDTO.class))).thenReturn(success(new BfiTokenVO()));
|
||||
assertThrows(BfiException.class, () -> service.getToken());
|
||||
}
|
||||
|
||||
@Test
|
||||
void getAccessTokenShouldReturnCachedValue() {
|
||||
when(bladeRedis.get("blade:third:bfi:token")).thenReturn("cached-token");
|
||||
assertEquals("cached-token", service.getAccessToken());
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void getAccessTokenShouldFetchWhenCacheMiss() {
|
||||
mockAccessToken();
|
||||
assertEquals("token-1", service.getAccessToken());
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryCustomerShouldReturnPage() {
|
||||
mockAccessToken();
|
||||
BfiPageVO<BfiCustomerVO> page = new BfiPageVO<>();
|
||||
when(client.customerQuery(eq("token-1"), eq(1), eq(10), any(), any(), any(), any(), any(), any(), any(), any()))
|
||||
.thenReturn(success(page));
|
||||
BfiCustomerQueryDTO param = new BfiCustomerQueryDTO();
|
||||
param.setPageNo(1);
|
||||
param.setPageSize(10);
|
||||
assertEquals(page, service.queryCustomer(param));
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryCustomerShouldThrowWhenPageEmpty() {
|
||||
assertThrows(BfiException.class, () -> service.queryCustomer(new BfiCustomerQueryDTO()));
|
||||
}
|
||||
|
||||
@Test
|
||||
void saveCustomerShouldValidateRequiredFields() {
|
||||
BfiCustomerSaveDTO noName = new BfiCustomerSaveDTO();
|
||||
assertThrows(BfiException.class, () -> service.saveCustomer(noName));
|
||||
|
||||
BfiCustomerSaveDTO noCreditCode = new BfiCustomerSaveDTO();
|
||||
noCreditCode.setName("客户A");
|
||||
noCreditCode.setEntryGroupstandard(List.of(new BfiCustomerGroupEntryDTO()));
|
||||
assertThrows(BfiException.class, () -> service.saveCustomer(noCreditCode));
|
||||
|
||||
BfiCustomerSaveDTO noGroup = new BfiCustomerSaveDTO();
|
||||
noGroup.setName("客户A");
|
||||
noGroup.setSocietycreditcode("91450000MA5Q1G1M59");
|
||||
assertThrows(BfiException.class, () -> service.saveCustomer(noGroup));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void saveCustomerShouldWrapData() {
|
||||
mockAccessToken();
|
||||
when(client.customerSave(anyString(), any())).thenReturn(success(saveResult(1)));
|
||||
BfiCustomerSaveDTO param = new BfiCustomerSaveDTO();
|
||||
param.setName("客户A");
|
||||
param.setSocietycreditcode("91450000MA5Q1G1M59");
|
||||
param.setEntryGroupstandard(List.of(new BfiCustomerGroupEntryDTO()));
|
||||
BfiBillSaveResultVO result = service.saveCustomer(param);
|
||||
assertEquals("1", result.getSuccessCount());
|
||||
ArgumentCaptor<org.springblade.thirdparty.bfi.pojo.dto.BfiCustomerSaveBodyDTO> captor =
|
||||
ArgumentCaptor.forClass(org.springblade.thirdparty.bfi.pojo.dto.BfiCustomerSaveBodyDTO.class);
|
||||
verify(client).customerSave(eq("token-1"), captor.capture());
|
||||
assertEquals(param, captor.getValue().getData().get(0));
|
||||
}
|
||||
|
||||
@Test
|
||||
void saveApBillShouldValidateRequiredFields() {
|
||||
BfiApBillSaveDTO noSrc = new BfiApBillSaveDTO();
|
||||
assertThrows(BfiException.class, () -> service.saveApBill(noSrc));
|
||||
|
||||
BfiApBillSaveDTO noEntry = new BfiApBillSaveDTO();
|
||||
noEntry.setAwrpSrcSys("WCCK");
|
||||
noEntry.setAwrpSrcCode("AP-1");
|
||||
assertThrows(BfiException.class, () -> service.saveApBill(noEntry));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void saveApBillShouldWrapData() {
|
||||
mockAccessToken();
|
||||
when(client.apBillSave(anyString(), any())).thenReturn(success(saveResult(1)));
|
||||
BfiApBillSaveDTO param = new BfiApBillSaveDTO();
|
||||
param.setAwrpSrcSys("WCCK");
|
||||
param.setAwrpSrcCode("AP-1");
|
||||
param.setDetailentry(List.of(new BfiApBillSaveEntryDTO()));
|
||||
assertEquals("1", service.saveApBill(param).getSuccessCount());
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryApBillShouldReturnPage() {
|
||||
mockAccessToken();
|
||||
BfiPageVO<BfiApBillVO> page = new BfiPageVO<>();
|
||||
when(client.apBillQuery(eq("token-1"), eq(1), eq(10), any(), any(), any(), any(), any(), any()))
|
||||
.thenReturn(success(page));
|
||||
BfiApBillQueryDTO param = new BfiApBillQueryDTO();
|
||||
param.setPageNo(1);
|
||||
param.setPageSize(10);
|
||||
assertEquals(page, service.queryApBill(param));
|
||||
}
|
||||
|
||||
@Test
|
||||
void saveArBillShouldValidateRequiredFields() {
|
||||
BfiArBillSaveDTO noSrc = new BfiArBillSaveDTO();
|
||||
assertThrows(BfiException.class, () -> service.saveArBill(noSrc));
|
||||
|
||||
BfiArBillSaveDTO noEntry = new BfiArBillSaveDTO();
|
||||
noEntry.setAwrpSrcSys("WCCK");
|
||||
noEntry.setAwrpSrcCode("AR-1");
|
||||
assertThrows(BfiException.class, () -> service.saveArBill(noEntry));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void saveArBillShouldWrapData() {
|
||||
mockAccessToken();
|
||||
when(client.arBillSave(anyString(), any())).thenReturn(success(saveResult(1)));
|
||||
BfiArBillSaveDTO param = new BfiArBillSaveDTO();
|
||||
param.setAwrpSrcSys("WCCK");
|
||||
param.setAwrpSrcCode("AR-1");
|
||||
param.setEntry(List.of(new BfiArBillSaveEntryDTO()));
|
||||
assertEquals("1", service.saveArBill(param).getSuccessCount());
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryArBillShouldReturnPage() {
|
||||
mockAccessToken();
|
||||
BfiPageVO<BfiArBillVO> page = new BfiPageVO<>();
|
||||
when(client.arBillQuery(eq("token-1"), eq(1), eq(10), any(), any(), any(), any(), any(), any()))
|
||||
.thenReturn(success(page));
|
||||
BfiArBillQueryDTO param = new BfiArBillQueryDTO();
|
||||
param.setPageNo(1);
|
||||
param.setPageSize(10);
|
||||
assertEquals(page, service.queryArBill(param));
|
||||
}
|
||||
|
||||
@Test
|
||||
void invoiceAssignShouldValidateAndWrapBody() {
|
||||
assertThrows(BfiException.class, () -> service.invoiceAssign(null, List.of()));
|
||||
assertThrows(BfiException.class, () -> service.invoiceAssign("assign", List.of()));
|
||||
|
||||
mockAccessToken();
|
||||
when(client.invoiceAssign(anyString(), any())).thenReturn(success(saveResult(1)));
|
||||
BfiInvoiceAssignRefDTO invoice = new BfiInvoiceAssignRefDTO();
|
||||
invoice.setAwrpSrcCode("INV-1");
|
||||
invoice.setAwrpSrcSys("WCCK");
|
||||
BfiInvoiceAssignRefDTO apBill = new BfiInvoiceAssignRefDTO();
|
||||
apBill.setAwrpSrcCode("AP-1");
|
||||
apBill.setAwrpSrcSys("WCCK");
|
||||
BfiInvoiceAssignItemDTO item = new BfiInvoiceAssignItemDTO();
|
||||
item.setApInvoice(List.of(invoice));
|
||||
item.setApFinapbill(List.of(apBill));
|
||||
assertEquals("1", service.invoiceAssign("assign", List.of(item)).getSuccessCount());
|
||||
ArgumentCaptor<BfiInvoiceAssignBodyDTO> captor = ArgumentCaptor.forClass(BfiInvoiceAssignBodyDTO.class);
|
||||
verify(client).invoiceAssign(eq("token-1"), captor.capture());
|
||||
assertEquals("assign", captor.getValue().getOp());
|
||||
}
|
||||
|
||||
@Test
|
||||
void saveInvoiceApplyShouldValidateRequiredFields() {
|
||||
BfiInvoiceApplySaveDTO noBillNo = new BfiInvoiceApplySaveDTO();
|
||||
assertThrows(BfiException.class, () -> service.saveInvoiceApply(noBillNo));
|
||||
|
||||
BfiInvoiceApplySaveDTO noItem = new BfiInvoiceApplySaveDTO();
|
||||
noItem.setBillno("KPSQ-1");
|
||||
noItem.setOrgidNumber("01.00");
|
||||
assertThrows(BfiException.class, () -> service.saveInvoiceApply(noItem));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void saveInvoiceApplyShouldWrapData() {
|
||||
mockAccessToken();
|
||||
when(client.invoiceApplySave(anyString(), any())).thenReturn(success(saveResult(1)));
|
||||
BfiInvoiceApplySaveDTO param = new BfiInvoiceApplySaveDTO();
|
||||
param.setBillno("KPSQ-1");
|
||||
param.setOrgidNumber("01.00");
|
||||
param.setSimOriginalBillItem(List.of(new BfiInvoiceApplySaveEntryDTO()));
|
||||
assertEquals("1", service.saveInvoiceApply(param).getSuccessCount());
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryInvoiceApplyShouldReturnPage() {
|
||||
mockAccessToken();
|
||||
BfiPageVO<BfiInvoiceApplyVO> page = new BfiPageVO<>();
|
||||
when(client.invoiceApplyQuery(eq("token-1"), eq(1), eq(10), any(), any(), any(), any()))
|
||||
.thenReturn(success(page));
|
||||
BfiInvoiceApplyQueryDTO param = new BfiInvoiceApplyQueryDTO();
|
||||
param.setPageNo(1);
|
||||
param.setPageSize(10);
|
||||
assertEquals(page, service.queryInvoiceApply(param));
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryInvoiceApplyInvoiceShouldEncodeBase64Data() {
|
||||
mockAccessToken();
|
||||
BfiOpenApiResultVO<List<Object>> openApiResult = new BfiOpenApiResultVO<>();
|
||||
openApiResult.setSuccess(true);
|
||||
openApiResult.setErrorCode("S0000");
|
||||
openApiResult.setData(List.of());
|
||||
when(client.invoiceApplyOpenApi(anyString(), any())).thenReturn(openApiResult);
|
||||
BfiInvoiceApplyOpenApiQueryDTO param = new BfiInvoiceApplyOpenApiQueryDTO();
|
||||
param.setSerialNo("KPSQ-1,KPSQ-2");
|
||||
param.setSellerTaxpayerId("91450000MA5Q1G1M59");
|
||||
service.queryInvoiceApplyInvoice(param);
|
||||
ArgumentCaptor<org.springblade.thirdparty.bfi.pojo.dto.BfiInvoiceApplyOpenApiBodyDTO> captor =
|
||||
ArgumentCaptor.forClass(org.springblade.thirdparty.bfi.pojo.dto.BfiInvoiceApplyOpenApiBodyDTO.class);
|
||||
verify(client).invoiceApplyOpenApi(eq("token-1"), captor.capture());
|
||||
assertEquals("BILL.INVOICE.QUERY", captor.getValue().getInterfaceCode());
|
||||
assertEquals("test-client", captor.getValue().getBusinessSystemCode());
|
||||
String decoded = new String(Base64.getDecoder().decode(captor.getValue().getData()), StandardCharsets.UTF_8);
|
||||
JSONObject json = JSONUtil.parseObj(decoded);
|
||||
assertEquals("KPSQ-1,KPSQ-2", json.getStr("serialNo"));
|
||||
assertEquals("91450000MA5Q1G1M59", json.getStr("sellerTaxpayerId"));
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryInvoiceApplyInvoiceShouldThrowWhenParamsBlank() {
|
||||
assertThrows(BfiException.class, () -> service.queryInvoiceApplyInvoice(new BfiInvoiceApplyOpenApiQueryDTO()));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void saveReceivedInvoiceShouldValidateRequiredFields() {
|
||||
BfiReceivedInvoiceSaveDTO noSrc = new BfiReceivedInvoiceSaveDTO();
|
||||
assertThrows(BfiException.class, () -> service.saveReceivedInvoice(noSrc));
|
||||
|
||||
BfiReceivedInvoiceSaveDTO noEntry = new BfiReceivedInvoiceSaveDTO();
|
||||
noEntry.setAwrpSrcSys("WCCK");
|
||||
noEntry.setAwrpSrcCode("INV-1");
|
||||
assertThrows(BfiException.class, () -> service.saveReceivedInvoice(noEntry));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void saveReceivedInvoiceShouldWrapData() {
|
||||
mockAccessToken();
|
||||
when(client.receivedInvoiceSave(anyString(), any())).thenReturn(success(saveResult(1)));
|
||||
BfiReceivedInvoiceSaveDTO param = new BfiReceivedInvoiceSaveDTO();
|
||||
param.setAwrpSrcSys("WCCK");
|
||||
param.setAwrpSrcCode("INV-1");
|
||||
param.setEntry(List.of(new BfiReceivedInvoiceSaveEntryDTO()));
|
||||
assertEquals("1", service.saveReceivedInvoice(param).getSuccessCount());
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryReceivedInvoiceShouldValidateModifyTime() {
|
||||
assertThrows(BfiException.class, () -> service.queryReceivedInvoice(new BfiReceivedInvoiceQueryDTO()));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryReceivedInvoiceShouldReturnPage() {
|
||||
mockAccessToken();
|
||||
BfiPageVO<BfiReceivedInvoiceVO> page = new BfiPageVO<>();
|
||||
when(client.receivedInvoiceQuery(anyString(), any(BfiReceivedInvoiceQueryDTO.class))).thenReturn(success(page));
|
||||
BfiReceivedInvoiceQueryDTO param = new BfiReceivedInvoiceQueryDTO();
|
||||
param.setModifytime("2026-09-08 10:36:29");
|
||||
param.setModifytimeE("2026-09-08 10:39:36");
|
||||
assertEquals(page, service.queryReceivedInvoice(param));
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryRecBillShouldValidateRequiredFields() {
|
||||
assertThrows(BfiException.class, () -> service.queryRecBill(new BfiRecBillQueryDTO()));
|
||||
|
||||
BfiRecBillQueryDTO noDate = new BfiRecBillQueryDTO();
|
||||
noDate.setPageNo(1);
|
||||
noDate.setPageSize(10);
|
||||
assertThrows(BfiException.class, () -> service.queryRecBill(noDate));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryRecBillShouldReturnPage() {
|
||||
mockAccessToken();
|
||||
BfiPageVO<BfiRecBillVO> page = new BfiPageVO<>();
|
||||
when(client.recBillQuery(eq("token-1"), eq(1), eq(10), any(), any(), any(), any()))
|
||||
.thenReturn(success(page));
|
||||
BfiRecBillQueryDTO param = new BfiRecBillQueryDTO();
|
||||
param.setPageNo(1);
|
||||
param.setPageSize(10);
|
||||
param.setBeginBizdate("2026-08-08");
|
||||
param.setEndBizdate("2026-09-08");
|
||||
assertEquals(page, service.queryRecBill(param));
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryClaimAnnounceShouldValidateParams() {
|
||||
assertThrows(BfiException.class, () -> service.queryClaimAnnounce(null, 1, 10));
|
||||
assertThrows(BfiException.class, () -> service.queryClaimAnnounce("张三", null, 10));
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryClaimAnnounceShouldReturnPage() {
|
||||
mockAccessToken();
|
||||
BfiPageVO<BfiClaimAnnounceVO> page = new BfiPageVO<>();
|
||||
when(client.claimAnnounceQuery("token-1", "张三", 1, 10)).thenReturn(success(page));
|
||||
assertEquals(page, service.queryClaimAnnounce("张三", 1, 10));
|
||||
}
|
||||
|
||||
@Test
|
||||
void pushClaimResultShouldValidateRequiredFields() {
|
||||
assertThrows(BfiException.class, () -> service.pushClaimResult(null));
|
||||
|
||||
BfiClaimPushDTO noBillId = new BfiClaimPushDTO();
|
||||
assertThrows(BfiException.class, () -> service.pushClaimResult(noBillId));
|
||||
|
||||
BfiClaimPushDTO noEntry = new BfiClaimPushDTO();
|
||||
noEntry.setBillid(1L);
|
||||
noEntry.setAwrpSrcSys("WCCK");
|
||||
noEntry.setAwrpSrcCode("RL-1");
|
||||
assertThrows(BfiException.class, () -> service.pushClaimResult(noEntry));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void pushClaimResultShouldWrapData() {
|
||||
mockAccessToken();
|
||||
when(client.claimBillPush(anyString(), any())).thenReturn(success(saveResult(1)));
|
||||
BfiClaimPushDTO param = new BfiClaimPushDTO();
|
||||
param.setBillid(2398805822369971200L);
|
||||
param.setAwrpSrcSys("WCCK");
|
||||
param.setAwrpSrcCode("RL-1");
|
||||
param.setEntryentity(List.of(new BfiClaimPushEntryDTO()));
|
||||
assertEquals("1", service.pushClaimResult(param).getSuccessCount());
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryInvoicePoolShouldValidateQueryParam() {
|
||||
assertThrows(BfiException.class, () -> service.queryInvoicePool(new BfiInvoicePoolQueryDTO()));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void queryInvoicePoolShouldReturnRows() {
|
||||
mockAccessToken();
|
||||
BfiInvoicePoolVO invoice = new BfiInvoicePoolVO();
|
||||
when(client.invoicePoolQuery(anyString(), any(BfiInvoicePoolQueryDTO.class)))
|
||||
.thenReturn(success(List.of(invoice)));
|
||||
BfiInvoicePoolQueryDTO param = new BfiInvoicePoolQueryDTO();
|
||||
param.setQueryParam(Map.of("invoiceNo", "25532000000044538098"));
|
||||
List<BfiInvoicePoolVO> rows = service.queryInvoicePool(param);
|
||||
assertEquals(1, rows.size());
|
||||
}
|
||||
|
||||
@Test
|
||||
void downloadInvoiceShouldValidatePath() {
|
||||
assertThrows(BfiException.class, () -> service.downloadInvoice(null));
|
||||
verifyNoInteractions(client);
|
||||
}
|
||||
|
||||
@Test
|
||||
void downloadInvoiceShouldThrowWhenStatusNotOk() {
|
||||
mockAccessToken();
|
||||
Response response = downloadResponse(500, "Internal Error");
|
||||
when(client.invoiceDownload(anyString(), any())).thenReturn(response);
|
||||
assertThrows(BfiException.class, () -> service.downloadInvoice("234e244b2c803400"));
|
||||
response.close();
|
||||
}
|
||||
|
||||
@Test
|
||||
void downloadInvoiceShouldReturnResponse() {
|
||||
mockAccessToken();
|
||||
Response response = downloadResponse(200, "OK");
|
||||
when(client.invoiceDownload(anyString(), any())).thenReturn(response);
|
||||
assertEquals(response, service.downloadInvoice("234e244b2c803400"));
|
||||
response.close();
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建下载响应
|
||||
*/
|
||||
private Response downloadResponse(int status, String reason) {
|
||||
Request request = Request.create(Request.HttpMethod.POST, "/ierp/kapi/v2/awrp/bosext/attachment/download",
|
||||
Map.of(), null, StandardCharsets.UTF_8);
|
||||
return Response.builder().status(status).reason(reason).request(request).build();
|
||||
}
|
||||
|
||||
@Test
|
||||
void commonCallShouldThrowWhenRemoteFailed() {
|
||||
mockAccessToken();
|
||||
BfiResultVO<BfiPageVO<BfiCustomerVO>> failed = new BfiResultVO<>();
|
||||
failed.setStatus(false);
|
||||
failed.setErrorCode("400");
|
||||
failed.setMessage("操作失败");
|
||||
when(client.customerQuery(any(), any(), any(), any(), any(), any(), any(), any(), any(), any(), any()))
|
||||
.thenReturn(failed);
|
||||
BfiCustomerQueryDTO param = new BfiCustomerQueryDTO();
|
||||
param.setPageNo(1);
|
||||
param.setPageSize(10);
|
||||
BfiException exception = assertThrows(BfiException.class, () -> service.queryCustomer(param));
|
||||
assertTrue(exception.getMessage().contains("操作失败"));
|
||||
}
|
||||
|
||||
@Test
|
||||
void getAccessTokenShouldNotCallRemoteWhenCached() {
|
||||
when(bladeRedis.get("blade:third:bfi:token")).thenReturn("cached-token");
|
||||
service.getAccessToken();
|
||||
verify(client, never()).getToken(any());
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user