REQUIREMENT
Needs to create CSV file of the saved search result and send the results to the client using a scheduled script.
SOLUTION
We will use the task module to convert the saved search results to the CSV file and send the CSV file as email attachment using map reduce script.
/**
* @NApiVersion 2.1
* @NScriptType MapReduceScript
*/
define(["N/email", "N/search", "N/file", "N/runtime", "N/task"]
/**
* @param{email} email
* @param{search} search
* @param{file} file
* @param{runtime} runtime
* @param{task} task
*/, (email, search, file, runtime, task) => {
/**
* Defines the function that is executed at the beginning of the map/reduce process and generates the input data.
* @param {Object} inputContext
* @param {boolean} inputContext.isRestarted - Indicates whether the current invocation of this function is the first
* invocation (if true, the current invocation is not the first invocation and this function has been restarted)
* @param {Object} inputContext.ObjectRef - Object that references the input data
* @typedef {Object} ObjectRef
* @property {string|number} ObjectRef.id - Internal ID of the record instance that contains the input data
* @property {string} ObjectRef.type - Type of the record instance that contains the input data
* @returns {Array|Object|Search|ObjectRef|File|Query} The input data to use in the map/reduce process
* @since 2015.2
*/
const getInputData = (inputContext) => {
try {
let searchId = runtime
.getCurrentScript()
.getParameter("custscript_jj_search_id1");
let arr = [];
if (checkForParameter(searchId)) {
arr.push(searchId);
}
return arr;
} catch (err) {
log.error("error@getInputData", err);
return [];
}
};
/**
* Defines the function that is executed when the reduce entry point is triggered. This entry point is triggered
* automatically when the associated map stage is complete. This function is applied to each group in the provided context.
* @param {Object} reduceContext - Data collection containing the groups to process in the reduce stage. This parameter is
* provided automatically based on the results of the map stage.
* @param {Iterator} reduceContext.errors - Serialized errors that were thrown during previous attempts to execute the
* reduce function on the current group
* @param {number} reduceContext.executionNo - Number of times the reduce function has been executed on the current group
* @param {boolean} reduceContext.isRestarted - Indicates whether the current invocation of this function is the first
* invocation (if true, the current invocation is not the first invocation and this function has been restarted)
* @param {string} reduceContext.key - Key to be processed during the reduce stage
* @param {List<String>} reduceContext.values - All values associated with a unique key that was passed to the reduce stage
* for processing
* @since 2015.2
*/
const reduce = (reduceContext) => {
try {
let savedSearchIdToSend = JSON.parse(reduceContext.values);
let searchTask = task.create({
taskType: task.TaskType.SEARCH,
});
if (checkForParameter(savedSearchIdToSend)) {
searchTask.savedSearchId = savedSearchIdToSend;
let searchTitle = fetchSearchName(savedSearchIdToSend);
if (!checkForParameter(searchTitle)) {
searchTitle = "Saved Search ";
}
let name = searchTitle + "_" + Math.floor(Date.now() / 1000) + ".csv";
let emailContent = "Attached are the results of your search";
searchTask.filePath =
"SuiteScripts/Jobin and Jismi IT Services/HGPLA-362 Scheduled Script to send search results/" +
name;
let searchTaskId = searchTask.submit();
if (checkForParameter(searchTaskId)) {
let searchTaskStatus = task.checkStatus({
taskId: searchTaskId,
}).status;
let currentStatus;
do {
currentStatus = task.checkStatus({
taskId: searchTaskId,
}).status;
} while (currentStatus != "COMPLETE");
let fetchFile = fileSearch(name);
log.debug("fetchFile", fetchFile);
if (checkForParameter(fetchFile)) {
let fileLoad = file.load({
id: Number(fetchFile),
});
try {
email.send({
author: -5,
recipients: [emailaddress],
subject: "Search: " + searchTitle,
body: emailContent,
attachments: [fileLoad],
});
} catch (err) {
log.error("error@email sending", err);
return [];
}
file.delete({
id: Number(fetchFile),
});
}
}
}
} catch (err) {
log.error("error@reduce", err);
return [];
}
};
/**
* Defines the function that is executed when the summarize entry point is triggered. This entry point is triggered
* automatically when the associated reduce stage is complete. This function is applied to the entire result set.
* @param {Object} summaryContext - Statistics about the execution of a map/reduce script
* @param {number} summaryContext.concurrency - Maximum concurrency number when executing parallel tasks for the map/reduce
* script
* @param {Date} summaryContext.dateCreated - The date and time when the map/reduce script began running
* @param {boolean} summaryContext.isRestarted - Indicates whether the current invocation of this function is the first
* invocation (if true, the current invocation is not the first invocation and this function has been restarted)
* @param {Iterator} summaryContext.output - Serialized keys and values that were saved as output during the reduce stage
* @param {number} summaryContext.seconds - Total seconds elapsed when running the map/reduce script
* @param {number} summaryContext.usage - Total number of governance usage units consumed when running the map/reduce
* script
* @param {number} summaryContext.yields - Total number of yields when running the map/reduce script
* @param {Object} summaryContext.inputSummary - Statistics about the input stage
* @param {Object} summaryContext.mapSummary - Statistics about the map stage
* @param {Object} summaryContext.reduceSummary - Statistics about the reduce stage
* @since 2015.2
*/
const summarize = (summaryContext) => {
try {
} catch (err) {
log.error("error@summarize", err);
}
};
const checkForParameter = function checkForParameter(parameter) {
if (
parameter !== "" &&
parameter !== null &&
parameter !== undefined &&
parameter !== false &&
parameter !== "null" &&
parameter !== "undefined" &&
parameter !== " " &&
parameter !== "false"
) {
return true;
}
};
function fetchSearchName(searchId) {
try {
let savedsearchSearchObj = search.create({
type: "savedsearch",
filters: [["internalid", "anyof", searchId]],
columns: [search.createColumn({ name: "title", label: "Title" })],
});
let searchResults = savedsearchSearchObj
.run()
.getRange({ start: 0, end: 1 });
log.audit("searchResults name", searchResults);
return searchResults[0].getValue({ name: "title", label: "Title" });
} catch (err) {}
}
function fileSearch(fileName) {
try {
let folderSearchObj = search.create({
type: "folder",
filters: [
["internalid", "anyof", "163500"],
"AND",
["file.name", "is", fileName],
],
columns: [
search.createColumn({
name: "internalid",
join: "file",
label: "Internal ID",
}),
],
});
let searchResults = folderSearchObj.run().getRange({ start: 0, end: 1 });
return searchResults[0].getValue({
name: "internalid",
join: "file",
label: "Internal ID",
});
} catch (err) {
log.error("error@fileSearch", fileSearch);
}
}
return { getInputData, reduce, summarize };
});