fix:增加并发测试方法

main
wb1496 2026-03-25 10:54:12 +08:00
parent 4aaa638f4a
commit 8a117d36df
1 changed files with 39 additions and 2 deletions

View File

@ -60,14 +60,51 @@ class PayServiceTest {
} }
@Test @Test
void detailQuery() { void AsyncTest(){
for(int i=0;i<10;i++){
new MyThread().start();
}
try{
Thread.sleep(3000000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
class MyThread extends Thread{
@Override
public void run(){
for(int i=0;i<1000000;i++){
asyncDetailQuery();
}
}
}
public void asyncDetailQuery(){
OfflineRechargeDetailQueryRequest request = new OfflineRechargeDetailQueryRequest(); OfflineRechargeDetailQueryRequest request = new OfflineRechargeDetailQueryRequest();
request.setChannelNo("0000"); request.setChannelNo("1021");
request.setAppNo("01"); request.setAppNo("01");
request.setSerialNo(Nonce.ofNonce()); request.setSerialNo(Nonce.ofNonce());
request.setTransDate(DateTimes.ofNowDate()); request.setTransDate(DateTimes.ofNowDate());
request.setTransTradeTime(DateTimes.ofNow()); request.setTransTradeTime(DateTimes.ofNow());
request.setAccountNo("1021231114000014");
request.setTradeDateStart(DateTimes.ofNowDate());
request.setTradeDateEnd(DateTimes.ofNowDate());
OfflineRechargeDetailQueryResponse response = payService.detailQuery(request);
Assertions.assertNotNull(response);
}
@Test
void detailQuery() {
OfflineRechargeDetailQueryRequest request = new OfflineRechargeDetailQueryRequest();
request.setChannelNo("1021");
request.setAppNo("01");
request.setSerialNo(Nonce.ofNonce());
request.setTransDate(DateTimes.ofNowDate());
request.setTransTradeTime(DateTimes.ofNow());
request.setAccountNo("1021231114000014");
request.setTradeDateStart(DateTimes.ofNowDate());
request.setTradeDateEnd(DateTimes.ofNowDate());
OfflineRechargeDetailQueryResponse response = payService.detailQuery(request); OfflineRechargeDetailQueryResponse response = payService.detailQuery(request);
Assertions.assertNotNull(response); Assertions.assertNotNull(response);
} }