I am getting Batch Apex Too many SOQL queries: 201 when the class is scheduled for run in developer console.
Batch Apex:
global class Batch_EmailBlast implements Schedulable,Database.Batchable<sObject>, Database.Stateful {
String query;
public string emailBlastId;
public Email_Blast__c emailBlast;
public List<Case> listOfEmailsToBeSent;
public List<Case> listOfDuplicateCases;
public List<Account> listOfAccountsToBeUpdated;
public Map<Id,String> mapOfOrgCaseIdToError;
public Map<Id,String> mapOfDupCaseIdToError;
public boolean isError;
global Batch_EmailBlast() {
}
global Database.QueryLocator start(Database.BatchableContext BC) {
return Database.getQueryLocator([SELECT Id, Inquiry_Type__c, Product_type__c, Solution__c,Reason_For_Calling__c,Problem_Category__c, Duplicate_Case_Problem_Category__c,Duplicate_Case_Product_Type__c, Duplicate_Case_Reason_For_Calling__c, Duplicate_Case_Status__c,Web_Product_Business_Group__c, WebProductPLTypeName__c,Age_Hours__c,Language__c, Case_Status__c,Completed_Date__c, status__c, No_Of_Emails_Sent__c, No_Of_Duplicate_Cases__c FROM Email_Blast__c WHERE status__c =: Label.Email_Blast_Process_Status AND Criteria_Tested__c =:Label.Email_Blast_TestingStatus AND No_Of_Records_Satisfying_Criteria__c >:Decimal.valueOf(Label.Email_Blast_Case_Count_Limit)]);
}
global void execute(Database.BatchableContext BC, List<Email_Blast__c> scope)
{
set<String> setOfDuplicateCreiteria = new set<String>();
set<ID> setOfAccIds = new set<Id>();
//Get Duplicate cases and cases for which email to be sent
for(Email_Blast__c emailBlast : scope)
{
String businessGroup = emailBlast.Web_Product_Business_Group__c;
String webProductPLTypeName = emailBlast.WebProductPLTypeName__c;
Integer age = Integer.valueOf(emailBlast.Age_Hours__c);
List<String> languageList = new List<String>();
if(emailBlast.Language__c != null && emailBlast.Language__c.contains(';'))
{
List<String> allLangs = emailBlast.Language__c.split(';');
for(String iterString: allLangs)
{
languageList.add(iterString);
}
}
else
{
languageList.add(emailBlast.Language__c);
}
String status = emailBlast.Case_Status__c;
String caseQuery = 'Select Id, Inquiry_Type__c, Product_type__c, Solution__c, Reason_For_Calling__c, Email_Blast__c, '
+'Problem_Category__c,Status,Send_Mass_Email__c,Web_Product_Support_Product__c, Validation_Flag__c ,'
+'Account.PersonEmail,AccountId, Account.Mass_Email_Received__c, Account.Last_mass_email_Date__c from Case where '
+'Web_Product_Support_Product__r.Business_Group__c =: businessGroup AND '
+'WebProductPLTypeName__c =: webProductPLTypeName AND Case_Age_in_Hours__c >: age AND '
+'Language__c in: languageList AND Status=: status AND Account.Mass_Email_Received__c = false '
+'order by Id, Account.PersonEmail, Case_Age_in_Hours__c DESC ';
for(Case iterCase : Database.query(caseQuery))
{
listOfEmailsToBeSent = new List<Case>();
listOfDuplicateCases = new List<Case>();
mapOfOrgCaseIdToError = new Map<Id,String>();
mapOfDupCaseIdToError = new Map<Id,String>();
listOfAccountsToBeUpdated = new List<Account>();
String criteria = iterCase.Account.PersonEmail +'-'+iterCase.Web_Product_Support_Product__c;
if(!setOfDuplicateCreiteria.contains(criteria)){
setOfDuplicateCreiteria.add(iterCase.Account.PersonEmail +'-'+iterCase.Web_Product_Support_Product__c);
iterCase.Send_Mass_Email__c = true;
iterCase.Inquiry_Type__c = emailBlast.Inquiry_Type__c;
iterCase.Product_type__c = emailBlast.Product_type__c;
iterCase.Problem_Category__c = emailBlast.Problem_Category__c;
iterCase.Reason_For_Calling__c = emailBlast.Reason_For_Calling__c;
iterCase.Solution__c = emailBlast.Solution__c;
iterCase.Email_Blast__c = emailBlast.Id;
If(Test.isRunningTest() && ProcessEmailBlast.isError)
iterCase.Id = null;
listOfEmailsToBeSent.add(iterCase);
}
else{
iterCase.Status = emailBlast.Duplicate_Case_Status__c;
iterCase.Product_type__c = emailBlast.Duplicate_Case_Product_Type__c;
iterCase.Problem_Category__c = emailBlast.Duplicate_Case_Problem_Category__c;
iterCase.Reason_For_Calling__c = emailBlast.Duplicate_Case_Reason_For_Calling__c;
iterCase.Email_Blast__c = emailBlast.Id;
If(Test.isRunningTest() && ProcessEmailBlast.isError)
iterCase.Id = null;
listOfDuplicateCases.add(iterCase);
}
if(!listOfEmailsToBeSent.isEmpty()){
//update listOfEmailsToBeSent;
List<Database.SaveResult> updateResults = Database.update(listOfEmailsToBeSent, false);
for(Integer i=0;i<updateResults.size();i++){
if (updateResults.get(i).isSuccess()){
setOfAccIds.add(listOfEmailsToBeSent.get(i).AccountId);
}else if (!updateResults.get(i).isSuccess()){
// DML operation failed
Database.Error error = updateResults.get(i).getErrors().get(0);
String failedDML = error.getMessage();
mapOfOrgCaseIdToError.put(listOfEmailsToBeSent.get(i).Id,failedDML);//failed record from the list
system.debug('Failed ID'+listOfEmailsToBeSent.get(i).Id);
}
}
}
if(!listOfDuplicateCases.isEmpty()){
//update listOfDuplicateCases;
List<Database.SaveResult> updateResults = Database.update(listOfDuplicateCases, false);
for(Integer i=0;i<updateResults.size();i++)
{
if (updateResults.get(i).isSuccess()){
updateResults.get(i).getId();
}else if (!updateResults.get(i).isSuccess()){
// DML operation failed
Database.Error error = updateResults.get(i).getErrors().get(0);
String failedDML = error.getMessage();
mapOfDupCaseIdToError.put(listOfDuplicateCases.get(i).Id,failedDML);//failed record from the list
system.debug('Failed ID'+listOfDuplicateCases.get(i).Id);
}
}
}
for(Account iterAcc : [select Id, Mass_Email_Received__c, Last_mass_email_Date__c from Account where
Id in: setOfAccIds ])
{
iterAcc.Mass_Email_Received__c = true;
iterAcc.Last_mass_email_Date__c = Date.Today();
listOfAccountsToBeUpdated.add(iterAcc);
}
system.debug('listOfAccountsToBeUpdateddd '+listOfAccountsToBeUpdated);
try{
if(!listOfAccountsToBeUpdated.isEmpty())
{
update listOfAccountsToBeUpdated;
}
}
catch(Exception e){
SystemLoggerUtil.logError(e);
}
}
updateEmailBlast(emailBlast);
}
}
global void finish(Database.BatchableContext BC) {
}
global void execute(SchedulableContext scon) {
Database.executeBatch(new Batch_EmailBlast(),1000);
}
private void updateEmailBlast(Email_Blast__c emailBlast)
{
if(mapOfDupCaseIdToError.keySet().size() > 0){
String OrgCaseError = 'Case Id,Error Message\n';
for(Id iterCaseId : mapOfDupCaseIdToError.keySet()){
OrgCaseError += iterCaseId+','+mapOfDupCaseIdToError.get(iterCaseId)+'\n';
}
Attachment dupCaseAttchment = new Attachment();
dupCaseAttchment.Name = 'Duplicate Case Errors'+ dateTime.Now()+'.csv';
dupCaseAttchment.contentType = 'text/csv';
dupCaseAttchment.body = Blob.valueOf(OrgCaseError);
dupCaseAttchment.ParentId = emailBlast.Id;
insert dupCaseAttchment;
}
if(mapOfOrgCaseIdToError.keySet().size() > 0){
String OrgCaseError = 'Case Id,Error Message\n';
for(Id iterCaseId : mapOfOrgCaseIdToError.keySet()){
OrgCaseError += iterCaseId+','+mapOfOrgCaseIdToError.get(iterCaseId)+'\n';
}
Attachment orgCaseAttchment = new Attachment();
orgCaseAttchment.Name = 'Case Errors'+ dateTime.Now()+'.csv';
orgCaseAttchment.contentType = 'text/csv';
orgCaseAttchment.body = Blob.valueOf(OrgCaseError);
orgCaseAttchment.ParentId = emailBlast.Id;
insert orgCaseAttchment;
}
emailBlast.Completed_Date__c = DateTime.Now();
if(!mapOfDupCaseIdToError.values().isEmpty() || !mapOfOrgCaseIdToError.values().isEmpty()){
emailBlast.status__c = 'Partially Completed';
}
else
emailBlast.status__c = 'Completed';
emailBlast.No_Of_Emails_Sent__c = listOfEmailsToBeSent.size();
emailBlast.No_Of_Duplicate_Cases__c = listOfDuplicateCases.size();
update emailBlast;
}
}
Database.executeBatch(new MyBatch(), 1).