如何解决带有聚合查询的批处理顶点，效果很好，但是当我尝试为此批处理顶点测试类编写测试类时失败
**当我运行下面的测试类时，它在查询方法中返回空列表。我有任何不同的方法来为聚合批处理顶点编写测试类 **
全局类 Batch_Agent 实现 Database.Batchable {
global Iterable<AggregateResult> start(Database.BatchableContext BC){
string query='SELECT SUM(Expected_Agency_Commission__c) Sum_of_Agency_Commission,SUM(Monthly_Premium__c) Sum_of_Monthly_Permium,Sales_Agent__c FROM InsurancePolicy WHERE Is_Agency_commission_Paid__c=False and Effectuated__c=true and Submitted_Date__c >= 2021-02-02 and Submitted_Date__c <= 2021-05-01 and Sales_Agent__r.Sales_Agent_User__r.IsActive = true and Expected_Agency_Commission__c!= 0 and Expected_Agency_Commission__c!= null Group by Sales_Agent__c,Is_Agency_commission_Paid__c ';
return new AggregateResultIterable(query);
}
global void execute(Database.BatchableContext BC,List<Sobject> scope){
List<Sobject> policyLists = scope;
List<contact> agentContactList = new List<contact>();
List<Contact> conlist = [SELECT Id,Name,Seat_Cost__c,Tier__c FROM Contact WHERE Sales_Agent_User__r.IsActive = true and RecordType.name ='Sales Agent'];
List<Bonus_Amount__c> bonusList = [SELECT Id,Commission_Amount__c,Commission_End_Amount__c,Bonus_Percentage__c FROM Bonus_Amount__c ];
List<Agent_Commission__c> agentComList = new List<Agent_Commission__c>();
list<Id> salesAgentIds = new List<Id>();
for(Sobject policy:policyLists){
if(policy.Get('Sales_Agent__c')!=null){
Id conIds;
Decimal seatCost;
String agentTier;
Decimal comissionAmount;
Decimal bonusPercentage;
Agent_Commission__c agentComm = new Agent_Commission__c();
agentComm.Sum_of_Expected_Agency_Commission__c = (Decimal)policy.Get('Sum_of_Agency_Commission');
agentComm.Sum_of_Monthly_Permium__c = (Decimal)policy.Get('Sum_of_Monthly_Permium');
conIds = (Id)policy.Get('Sales_Agent__c');
for(contact con:conlist ){
if(con.Id==conIds){
seatCost=con.Seat_Cost__c;
agentTier=con.Tier__c;
}
}
agentComm.Commisionable_Amount__c = ((Decimal)policy.Get('Sum_of_Agency_Commission')-seatCost);
comissionAmount = agentComm.Commisionable_Amount__c ;
for(Bonus_Amount__c bnus:bonusList){
if(bnus.Name == agentTier){
if (comissionAmount < 0 ){
bonusPercentage = 0;
}
else if( comissionAmount >= bnus.Commission_Amount__c && comissionAmount < bnus.Commission_End_Amount__c){
bonusPercentage = bnus.Bonus_Percentage__c;
}
}
}
agentComm.Bonus_Percentage__c = bonusPercentage;
agentComm.Bonus_Amount__c = comissionAmount*bonusPercentage;
agentComm.Sales_Agent__c = (String)policy.Get('Sales_Agent__c');
salesAgentIds.add(agentComm.Sales_Agent__c);
agentComm.Name = String.valueOf(System.now());
agentComList.add(agentComm);
}
}
Insert agentComList;
List<InsurancePolicy> policyUpdates = [SELECT ID,test_Is_Agency_commission_Paid__c,Is_Agency_commission_Paid__c,Sales_Agent__c FROM InsurancePolicy
WHERE Is_Agency_commission_Paid__c= false and Sales_Agent__r.Sales_Agent_User__r.IsActive = true and
Expected_Agency_Commission__c!= 0 and Expected_Agency_Commission__c!= null and Effectuated__c=true and
Submitted_Date__c > 2021-01-01 and Sales_Agent__c in :salesAgentIDs ];
for(InsurancePolicy polupdate :policyUpdates ){
polupdate.Is_Agency_commission_Paid__c = false;
}
Update policyUpdates;
}
global void finish(Database.BatchableContext BC){
}
}
================================================ ===
@isTest(SeeAllData = FALSE) 公共类 lig_AgentCommissionTrigerHandlerTest {
private static Contact createContact(String lastName,Boolean withInsert ){
Contact newContact = new Contact(
LastName = lastName,recordTypeId = Schema.getGlobalDescribe().get('Contact').getDescribe().getRecordTypeInfosByName().get('Sales Agent').getRecordTypeId(),Seat_Cost__c = 22000,Tier__c = 'T1'
);
if(withInsert){
insert newContact;
}
return newContact;
}
private static Bonus_Amount__c createBonusList(Boolean withInsert){
Bonus_Amount__c newBonusAmount = new Bonus_Amount__c(
Name = 'T1',Commission_Amount__c = 2100,Commission_End_Amount__c = 3500,Bonus_Percentage__c = 0.03
);
if(withInsert){
insert newBonusAmount ;
}
return newBonusAmount ;
}
private static InsurancePolicy createInsurancePolicy(String name,Id nameInsuredId,Id saleAgentID,Integer agencycom,Integer mnthlyper,Boolean withInsert){
InsurancePolicy newPolicy = new InsurancePolicy(
NameInsuredId = nameInsuredId,Name = name,Sales_Agent__c = saleAgentID,Expected_Agency_Commission__c = 12345,Monthly_Premium__c = 231,Is_Agency_commission_Paid__c = False
//Effectuated__c = True
);
if(withInsert){
insert newPolicy;
}
return newPolicy;
}
@TestSetup
private static void createTestData() {
//create test account
//create test account
Account policyHolder = lig_TestDataFactory.createPersonAccount('Test','Account','test@account.com','1234567890','1234567980',TRUE);
Contact agentContact = lig_AgentCommissionTrigerHandlerTest.createContact('Test',TRUE);
Bonus_Amount__c bonusAmount = lig_AgentCommissionTrigerHandlerTest.createBonusList(TRUE);
List<InsurancePolicy> testPolicies = new List<InsurancePolicy>();
testPolicies.add(lig_AgentCommissionTrigerHandlerTest.createInsurancePolicy('Test Policy 1',policyHolder.Id,agentContact.Id,1234,212,FALSE));
testPolicies.add(lig_AgentCommissionTrigerHandlerTest.createInsurancePolicy('Test Policy 2',2311,123,FALSE));
insert testPolicies;
}
@isTest static void testCreateRenewalOppty()
{
List<Sobject> policies = [SELECT SUM(Expected_Agency_Commission__c) Sum_of_Agency_Commission,Sales_Agent__c FROM InsurancePolicy
WHERE Is_Agency_commission_Paid__c=False Group by Sales_Agent__c];
List<Bonus_Amount__c> bonusList = [SELECT Id,Bonus_Percentage__c FROM Bonus_Amount__c ];
list<Id> salesAgentIds = new List<Id>();
Test.startTest();
Batch_Agent baAgent = new Batch_Agent();
ID jobID = database.executebatch(baAgent,5);
Test.stopTest();
}
}
解决方法
它返回一个空列表，因为您创建的测试数据与查询过滤器不匹配：
SELECT SUM(Expected_Agency_Commission__c) Sum_of_Agency_Commission,SUM(Monthly_Premium__c) Sum_of_Monthly_Permium,Sales_Agent__c
FROM InsurancePolicy
WHERE Is_Agency_commission_Paid__c=False
and Effectuated__c=true
and Submitted_Date__c >= 2021-02-02
and Submitted_Date__c <= 2021-05-01
and Sales_Agent__r.Sales_Agent_User__r.IsActive = true
and Expected_Agency_Commission__c!= 0
and Expected_Agency_Commission__c!= null
Group by Sales_Agent__c,Is_Agency_commission_Paid__c
您的测试上下文 InsurancePolicy 记录必须匹配 所有 WHERE 过滤器。请注意，作为一个示例，您的测试数据工厂不会填充 Submitted_Date__c 字段。 （不清楚您为什么在查询中硬编码这些值）。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
