package com.ruoyi.order.mapper;
|
|
import org.junit.jupiter.api.Test;
|
|
import java.io.BufferedReader;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.InputStreamReader;
|
import java.nio.charset.StandardCharsets;
|
import java.util.stream.Collectors;
|
|
import static org.junit.jupiter.api.Assertions.assertFalse;
|
import static org.junit.jupiter.api.Assertions.assertNotNull;
|
import static org.junit.jupiter.api.Assertions.assertTrue;
|
|
class ChargingOrderShareIncomeMapperTest {
|
|
@Test
|
void usesNetShareRecordAmountsWithoutDeductingOrderRefundAgain() throws IOException {
|
String mapper = resource("mapper/order/TChargingOrderMapper.xml");
|
String detailQuery = select(mapper, "chargingOrderShareIncomeByOrderIds");
|
String channelQuery = select(mapper, "chargingOrderShareIncomeByPayChannel");
|
String summaryQuery = select(mapper, "chargingOrderShareIncomeSummaryByOrderIds");
|
|
assertTrue(detailQuery.contains("sum(IFNULL(s.share_amount, 0)) as partnerIncome"));
|
assertTrue(detailQuery.contains("sum(IFNULL(s.channel_pay_amount, 0) - IFNULL(s.share_amount, 0)) as platformIncome"));
|
assertTrue(channelQuery.contains("sum(IFNULL(s.share_amount, 0)) as shareAmount"));
|
assertTrue(summaryQuery.contains("sum(IFNULL(s.share_amount, 0)) as partnerIncomeTotal"));
|
assertTrue(summaryQuery.contains("sum(IFNULL(s.channel_pay_amount, 0) - IFNULL(s.share_amount, 0)) as platformIncomeTotal"));
|
|
assertFalse(detailQuery.contains("third_refund_amount"));
|
assertFalse(channelQuery.contains("third_refund_amount"));
|
assertFalse(summaryQuery.contains("third_refund_amount"));
|
}
|
|
private String select(String mapper, String id) {
|
int start = mapper.indexOf("<select id=\"" + id + "\"");
|
int end = mapper.indexOf("</select>", start);
|
assertTrue(start >= 0 && end > start);
|
return mapper.substring(start, end);
|
}
|
|
private String resource(String path) throws IOException {
|
InputStream input = getClass().getClassLoader().getResourceAsStream(path);
|
assertNotNull(input);
|
try (BufferedReader reader = new BufferedReader(new InputStreamReader(input, StandardCharsets.UTF_8))) {
|
return reader.lines().collect(Collectors.joining("\n"));
|
}
|
}
|
}
|
