List< AlarmErrorStatus> jobs = new ArrayList< AlarmErrorStatus>();
String sfdcQuery ="SELECT CreatedDate,Id,XX_Base__Account__c,XX_Base__Contact__c,XX_Base__Execution_Steps__c,XX_Base__External_Key__c,XX_Base__Log_Level__c,XX_Base__Log_Message__c,XX_Base__Log_Type__c,XX_Base__Org_ID__c,XX_Base__Process_Name__c,XX_Base__Status__c,XX_Base__Step_in_Process__c,XX_Base__Summary_Advanced_Log__c,XX_Base__Total_Records_Errored__c,XX_Base__Total_Records_Processed__c,XX_Base__Total_Records_Succeeded__c,XX_Base__User_ID__c FROM XX_Base__Advanced_Log__c WHERE XX_Base__Summary_Advanced_Log__c = '" + jobId + "'";
QueryResult systemerrorQueryResult=connection.query(sfdcQuery);
for (SObject fieldObject : systemerrorQueryResult.getRecords()) {
AlarmErrorStatus alarm = new AlarmErrorStatus(); //java object
alarm.setAlarmJobId(jobId);
alarm.setCreatedDate(dateConverts.sfdcToJava((String) fieldObject.getField("CreatedDate")));
alarm.setUserName((String) fieldObject.getField("XX_Base__User_ID__c"));
alarm.setErrorCode((String) fieldObject.getField("Id"));
alarm.setErrorMessage((String) fieldObject.getField("XX_Base__Log_Message__c"));
alarm.setErrorStatus((String) fieldObject.getField("XX_Base__Status__c"));
alarm.setErrorReason("");
alarm.setErrorSR("");
alarm.setAccount((String) fieldObject.getField("XX_Base__Account__c"));
alarm.setContact((String) fieldObject.getField("XX_Base__Contact__c"));
alarm.setExecutionSteps((String) fieldObject.getField("XX_Base__Execution_Steps__c"));
alarm.setExternalKey((String) fieldObject.getField("XX_Base__External_Key__c"));
alarm.setType((String) fieldObject.getField("XX_Base__Log_Type__c"));
alarm.setOrgId((String) fieldObject.getField("XX_Base__Org_ID__c"));
alarm.setProcessName((String) fieldObject.getField("XX_Base__Process_Name__c"));
alarm.setStepInProcess((String) fieldObject.getField("XX_Base__Step_in_Process__c"));
alarm.setTotalRecordsErrored((String) fieldObject.getField("XX_Base__Total_Records_Errored__c"));
alarm.setTotalRecordsSucceded((String) fieldObject.getField("XX_Base__Total_Records_Succeeded__c"));
monitorLogger.info("Error Id:" + (String) fieldObject.getField("Id"));
jobs.add(alarm);
}
return jobs;
String sfdcQuery ="SELECT CreatedDate,Id,XX_Base__Account__c,XX_Base__Contact__c,XX_Base__Execution_Steps__c,XX_Base__External_Key__c,XX_Base__Log_Level__c,XX_Base__Log_Message__c,XX_Base__Log_Type__c,XX_Base__Org_ID__c,XX_Base__Process_Name__c,XX_Base__Status__c,XX_Base__Step_in_Process__c,XX_Base__Summary_Advanced_Log__c,XX_Base__Total_Records_Errored__c,XX_Base__Total_Records_Processed__c,XX_Base__Total_Records_Succeeded__c,XX_Base__User_ID__c FROM XX_Base__Advanced_Log__c WHERE XX_Base__Summary_Advanced_Log__c = '" + jobId + "'";
QueryResult systemerrorQueryResult=connection.query(sfdcQuery);
for (SObject fieldObject : systemerrorQueryResult.getRecords()) {
AlarmErrorStatus alarm = new AlarmErrorStatus(); //java object
alarm.setAlarmJobId(jobId);
alarm.setCreatedDate(dateConverts.sfdcToJava((String) fieldObject.getField("CreatedDate")));
alarm.setUserName((String) fieldObject.getField("XX_Base__User_ID__c"));
alarm.setErrorCode((String) fieldObject.getField("Id"));
alarm.setErrorMessage((String) fieldObject.getField("XX_Base__Log_Message__c"));
alarm.setErrorStatus((String) fieldObject.getField("XX_Base__Status__c"));
alarm.setErrorReason("");
alarm.setErrorSR("");
alarm.setAccount((String) fieldObject.getField("XX_Base__Account__c"));
alarm.setContact((String) fieldObject.getField("XX_Base__Contact__c"));
alarm.setExecutionSteps((String) fieldObject.getField("XX_Base__Execution_Steps__c"));
alarm.setExternalKey((String) fieldObject.getField("XX_Base__External_Key__c"));
alarm.setType((String) fieldObject.getField("XX_Base__Log_Type__c"));
alarm.setOrgId((String) fieldObject.getField("XX_Base__Org_ID__c"));
alarm.setProcessName((String) fieldObject.getField("XX_Base__Process_Name__c"));
alarm.setStepInProcess((String) fieldObject.getField("XX_Base__Step_in_Process__c"));
alarm.setTotalRecordsErrored((String) fieldObject.getField("XX_Base__Total_Records_Errored__c"));
alarm.setTotalRecordsSucceded((String) fieldObject.getField("XX_Base__Total_Records_Succeeded__c"));
monitorLogger.info("Error Id:" + (String) fieldObject.getField("Id"));
jobs.add(alarm);
}
return jobs;
No comments:
Post a Comment