Added: support to sync pos return netsuite internal id in OMS. (175-sync-pos-return-from-ns-to-oms)

src/FileCabinet/SuiteScripts/POSReturn/HC_MR_ExportedPOSReturnCSV.js

@@ -0,0 +1,227 @@
+/**
+ * @NApiVersion 2.1
+ * @NScriptType MapReduceScript
+ */
+define(['N/file', 'N/record', 'N/search', 'N/sftp', 'N/format', 'N/error'],
+    (file, record, search, sftp, format, error) => {
+        function uplaodPOSReturnCSVFileOnSFTP (posReturnFileObj, fileName) {
+            //Get Custom Record Type SFTP details
+            var customRecordSFTPSearch = search.create({
+                type: 'customrecord_ns_sftp_configuration',
+                columns: [
+                    'custrecord_ns_sftp_server',
+                    'custrecord_ns_sftp_userid',
+                    'custrecord_ns_sftp_port_no',
+                    'custrecord_ns_sftp_host_key',
+                    'custrecord_ns_sftp_guid',
+                    'custrecord_ns_sftp_default_file_dir'
+                ]
+
+            });
+            var sftpSearchResults = customRecordSFTPSearch.run().getRange({
+                start: 0,
+                end: 1
+            });
+
+            var sftpSearchResult = sftpSearchResults[0];
+
+            var sftpUrl = sftpSearchResult.getValue({
+                name: 'custrecord_ns_sftp_server'
+            });
+
+            var sftpUserName = sftpSearchResult.getValue({
+                name: 'custrecord_ns_sftp_userid'
+            });
+
+            var sftpPort = sftpSearchResult.getValue({
+                name: 'custrecord_ns_sftp_port_no'
+            });
+
+            var hostKey = sftpSearchResult.getValue({
+                name: 'custrecord_ns_sftp_host_key'
+            });
+
+            var sftpKeyId = sftpSearchResult.getValue({
+                name: 'custrecord_ns_sftp_guid'
+            });
+
+            var sftpDirectory = sftpSearchResult.getValue({
+                name: 'custrecord_ns_sftp_default_file_dir'
+            });
+
+            sftpDirectory = sftpDirectory + 'pos-return';
+            sftpPort = parseInt(sftpPort);
+
+            var connection = sftp.createConnection({
+                username: sftpUserName,
+                secret: sftpKeyId,
+                url: sftpUrl,
+                port: sftpPort,
+                directory: sftpDirectory,
+                hostKey: hostKey
+            });
+            log.debug("Connection established successfully with SFTP server!");
+
+            if (posReturnFileObj.size > connection.MAX_FILE_SIZE) {
+                throw error.create({
+                name:"FILE_IS_TOO_BIG",
+                message:"The file you are trying to upload is too big"
+                });
+            }
+            connection.upload({
+                directory: '/import/returnidentification/',
+                file: posReturnFileObj
+            });
+            log.debug("POS Return CSV File Uploaded Successfully to SFTP server with file" + fileName);
+
+        }
+
+        const getInputData = (inputContext) => {
+            var now = format.format({value : new Date(), type: format.Type.DATETIME});
+
+            var nowDateParts = now.split(' ');
+
+            var datePart = nowDateParts[0];
+            var timePart = nowDateParts[1];
+            var ampmPart = nowDateParts[2];
+
+            // Remove the seconds from the time part
+            var timeWithoutSeconds = timePart.split(':').slice(0, 2).join(':');
+
+            var dateStringWithoutSeconds = datePart + ' ' + timeWithoutSeconds + ' ' + ampmPart;
+
+            // get last pos return export runtime
+            var customRecordSearch = search.create({
+                type: 'customrecord_hc_last_runtime_export',
+                columns: ['custrecord_pos_return_ex_date']
+            });
+
+            var searchResults = customRecordSearch.run().getRange({
+               start: 0,
+               end: 1
+            });
+
+            var searchResult = searchResults[0];
+            var lastExportDate = searchResult.getValue({
+                name: 'custrecord_pos_return_ex_date'
+            });
+
+            var lastExportDateParts = lastExportDate.split(' ');
+            var lastExportDatePart = lastExportDateParts[0];
+            var lastExportTimePart = lastExportDateParts[1];
+            var ampmExportPart = lastExportDateParts[2];
+
+            // Remove the seconds from the time part
+            var lastExportTimeWithoutSeconds = lastExportTimePart.split(':').slice(0, 2).join(':');
+
+            var lastExportDateString = lastExportDatePart + ' ' + lastExportTimeWithoutSeconds + ' ' + ampmExportPart;
+
+            // Get pos return search query
+            var posReturnSearch = search.load({ id: 'customsearch_hc_exp_pos_return' });
+
+            // Copy the filters from posReturnSearch into defaultFilters.
+            var defaultFilters = posReturnSearch.filters;
+
+            // Push the customFilters into defaultFilters.
+
+            defaultFilters.push(search.createFilter({
+                name: "datecreated",
+                operator: search.Operator.WITHIN,
+                values: lastExportDateString, dateStringWithoutSeconds
+            }));
+            // Copy the modified defaultFilters
+            posReturnSearch.filters = defaultFilters;
+
+            return posReturnSearch;
+        }        
+
+        const map = (mapContext) => {
+            var contextValues = JSON.parse(mapContext.value);
+
+            var hcReturnId = contextValues.values.custbody_hc_pos_return_id;
+            var internalId = contextValues.values.internalid.value;
+
+            var posReturnData = {
+                "returnId": hcReturnId,
+                'returnIdentificationTypeId': "NETSUITE_RTN_ID",
+                'idValue': internalId
+            };
+
+            mapContext.write({
+                key: contextValues.id,
+                value: posReturnData
+            });
+
+        }
+
+        const reduce = (reduceContext) => {
+            var contextValues = JSON.parse(reduceContext.values);
+            var soId = reduceContext.key; 
+            var content = contextValues.returnId + ',' + contextValues.returnIdentificationTypeId + ',' + contextValues.idValue + '\n';
+
+            reduceContext.write(soId, content);
+        }
+
+        const summarize = (summaryContext) => {
+            try {
+                var fileLines = 'returnId,returnIdentificationTypeId,idValue\n';
+                var totalRecordsExported = 0;
+
+                summaryContext.output.iterator().each(function(key, value) {
+                    fileLines += value;
+                    totalRecordsExported = totalRecordsExported + 1;
+                    return true;
+                });
+
+                log.debug("====totalRecordsExported=="+totalRecordsExported);
+
+                if (totalRecordsExported > 0) {
+                    var fileName =  summaryContext.dateCreated + '-POSReturnExport.csv';
+                    var posReturnFileObj = file.create({
+                        name: fileName,
+                        fileType: file.Type.CSV,
+                        contents: fileLines
+                    });
+
+                    // call function to upload csv file on SFTP server
+                    uplaodPOSReturnCSVFileOnSFTP(posReturnFileObj, fileName);                    
+
+                    var currentDate = format.format({value : summaryContext.dateCreated, type: format.Type.DATETIME});
+
+                    //Get Custom Record Type internal id
+                    var customRecordHCExSearch = search.create({
+                        type: 'customrecord_hc_last_runtime_export',
+                        columns: ['internalid']
+                    });
+                    var searchResults = customRecordHCExSearch.run().getRange({
+                        start: 0,
+                        end: 1
+                    });
+
+                    var searchResult = searchResults[0];
+                    var lastRuntimeExportInternalId = searchResult.getValue({
+                        name: 'internalid'
+                    });
+
+                    // save last pos return export date
+                    record.submitFields({
+                        type: 'customrecord_hc_last_runtime_export',
+                        id: lastRuntimeExportInternalId,
+                        values: {
+                            custrecord_pos_return_ex_date : currentDate
+                        }
+                    });
+                }
+            } catch (e) {
+                log.error({
+                title: 'Error in exporting and uploading pos return csv files',
+                details: e,
+                });
+                throw error.create({
+                name:"Error in exporting and uploading pos return csv files",
+                message: e
+                });
+            }            
+        }
+        return {getInputData, map, reduce, summarize}
+    });

src/FileCabinet/SuiteScripts/SFTP/HC_SC_CreateSFTPDirectory.js

@@ -428,6 +428,16 @@ define(['N/sftp', 'N/error', 'N/search'], function (sftp, error, search) {
         connection.makeDirectory({
             path: 'salesorder/import/oms-fulfillment-nifi/archive'
         });
+
+        connection.makeDirectory({
+            path: 'pos-return/import'
+        });
+        connection.makeDirectory({
+            path: 'pos-return/import/returnidentification'
+        });
+        connection.makeDirectory({
+            path: 'pos-return/import/returnidentification/archive'
+        });
 
       } catch (e) {
         log.error({

src/Objects/CustomRecord/customrecord_hc_last_runtime_export.xml

@@ -65,5 +65,12 @@
       <label>Customer Deposit Export Date</label>
       <storevalue>T</storevalue>
     </customrecordcustomfield>
+    <customrecordcustomfield scriptid="custrecord_pos_return_ex_date">
+      <accesslevel>2</accesslevel>
+      <displaytype>NORMAL</displaytype>
+      <fieldtype>DATETIMETZ</fieldtype>
+      <label>POS Return Export Date</label>
+      <storevalue>T</storevalue>
+    </customrecordcustomfield>
   </customrecordcustomfields>
 </customrecordtype>

src/Objects/POSReturn/customscript_exp_pos_return.xml

@@ -0,0 +1,29 @@
+<mapreducescript scriptid="customscript_exp_pos_return">
+  <description></description>
+  <isinactive>F</isinactive>
+  <name>HC_MR_ExportedPOSReturnCSV</name>
+  <notifyadmins>F</notifyadmins>
+  <notifyemails></notifyemails>
+  <notifyowner>T</notifyowner>
+  <scriptfile>[/SuiteScripts/SalesOrder/HC_MR_ExportedPOSReturnCSV.js]</scriptfile>
+  <scriptdeployments>
+    <scriptdeployment scriptid="customdeploy_exp_pos_return">
+      <buffersize>1</buffersize>
+      <concurrencylimit>1</concurrencylimit>
+      <isdeployed>T</isdeployed>
+      <loglevel>DEBUG</loglevel>
+      <queueallstagesatonce>T</queueallstagesatonce>
+      <status>SCHEDULED</status>
+      <title>HC_MR_ExportedPOSReturnCSV</title>
+      <yieldaftermins>60</yieldaftermins>
+      <recurrence>
+        <daily>
+          <everyxdays>1</everyxdays>
+          <repeat>PT15M</repeat>
+          <startdate>2023-08-22</startdate>
+          <starttime>05:00:00Z</starttime>
+        </daily>
+      </recurrence>
+    </scriptdeployment>
+  </scriptdeployments>
+</mapreducescript>

src/Objects/POSReturn/customsearch_hc_exp_pos_return.xml

@@ -0,0 +1,4 @@
+<!-- This XML must be system-generated. Do not edit it manually. !-->
+<savedsearch scriptid="customsearch_hc_exp_pos_return">
+  <definition>6961fec0aba62754ee610912dffdfa8693faf3b1306af6f555017fe0b4cc2f43@[email protected]@H4sIAAAAAAAA/+1dbW+jOhb+fqX7H6L08zblPa3SXBFwGrYEIiAz0/2CMglzJ3fTpErozHR+/RpjmlfSYAzJIksjTQPm2D74Oefx8cFu/fXreVb7ESxX08X8vs5d39RrwXy8mEznf9/Xh173X836X+0//2jNV6vF+M4NltPRbPo7mNhf/wnGobaYh6PpPFjWoJj56g6Vuq9/D8OXu0bj58+f1/MgXL1Ow+B6vHhurMbfg+fRqoGK1Wuv08l9XbyRRFm58d0Od+eOfgQTNxgtx9/vxq+rcPG8Qj/872M/+PXivyxW/jIIX5fzO04RZF6SeOlGbkr1dQ9urrl6LZw+B6tw9PwCe7RVro378Tx6eYGN3nqqDVsYNXcWTP4OlrC9y+A6rh7+h7u9vI6fvI4b2Uc/Wo1NoUkVk+DbdD4Nofh2Ky6tb1yZBKvxcvoSLmD5ZQDrmnhvL0FtPButVvf1uLzzfr3edoHqaD0fWJ7z1Gqsn2i3foxmr8Gq3foU/V/7Ng1m6EYipJtcqMf37uuP4MkfqNqj+gDqtUbGB13NMQaeb+j1qK2/f9/XV+ESjhWovaPvq9VA1WSorWsAU/d10FWHpudbah+2dhK8BPMJHJ9vj8Hbfd1cjEezQH9X5R3Wkmd4Jri62WtiT6uBXy+LZVgb2G7NydWwpKqnAdirx1uO5qvROHrTBOJN9cEfDDumob0L/rpYzILRvN7+NpqtAkKZpuF6dCUObAcqmrLQvqr1DAvQFeqAvmHpwKEr1e3Zn6FarUfKanVAFzgO0It4Ze+yC3l5a/GFvMa1+K7t9IuS7QAXmhyXrvhPBvjsqy4UHim+GNkPjjroFSV6w+RTkTy0oJ49x9A8QE9yX/3iO/ZnN5tjQ+3RDVftmMDXHcM0fd3+bNHrL/IY2hCOLkt78h3VA9hxZG5lz9CB3zVMDziwpfYgaie9kRp5+MTjeuCL58ctj+vbc3Oupzqe+9nweoRDQP2kGiZSOhxhXUBxHCDxD6bdUU0f6AZlvGnuJ7oCwRcNmJTNmd6lPH5BH74tv+vY/b2RkE+kO+z8G2geZakdW3+iLFKz+33IwGlIjV4RNH4PDyDyOKoJaPsEV+sBfWiWIhy+wX5fdQxA2We6wIpUP/CeivHJceNV04Q0Dg7CaG7TocxY4ioMSzOH0HAjb3qYMIbLV9I6etB6eranmpTVk7R6ABzDhi8CvgzPUS1X1TzDpuh1Yoh1huajbw8gyPSsjnH9PJofI3IIp7iO2ichAp0hdHew85T7Zw88o2/8B/ptyIs9gnYhNNiWPxzokEAUMJNRh9BTRq/YoOeLIkYRyYXEZ3/+vhn6UV8nU3gjuOPe657Ow3r75r3ORhLpaGwGT75NZ2GwhFfDvfgJmAXPwTzcCqDEVMZtNcKt4EnS/EhWu/UyWsLnEmHaYjYL0GS+XlsG34Jl1Mz7+vV1A/1Db5IwnAPHKByxPeDCcZHQrJzRnZjLIoZp9AEcNJptUeZVEQXY4G477JBKFZZN2WPZFBsYw9nxNVMdulDFnuoN19Zw/H20rLctUrnWsO+boOvFY8NNAwOBVMg2epTF4onIweDc18nybjR/u5u/zmbHImRoJkTcAGjph6ZK4i/6tm7AvxySZ1UPcrfOcMMKJx1TrSe7S9qbg8FEF5iQHH9gBZOLWYyg/0k1h2DPFMZmisQI5jR8cXsoBLc3IhX5hjdq0N7Ajr0EErURet4d0VdOOFdfw+977xNfP/BCE82vr7z/se2fmLdi3op5K6reSkOrV/ooHG1gGj12pQ1dLwom+D3NH9hRBNcbOha0Mlfpt/ZQn1qyMp7PcCEM0GSdqvuLwpDFOz9maZmlZZb2suYFEPjAsVTT0KNlIuuBWcpLtpTr6+8RmdXr8/No+dbNFqGJY8lPu5Gaxq600Y/RdDb6OgviK0hVJ1eya6XW1aSIjbNYslWCfTx6ZeeZZm22IK//iAe1aaguOaQNK4E06ciPsji+bFspjlQWHADRqttHSUWbSrwSSUxBMqRJKpTyVEiwyBybzKGFYvxEz5KbW/yoDxynAL+so6W2zlMyiBuH5t5VguX/3ZzmALj5MsEtlw1uhYG7THCvr2y780kQQqefzbnrwEPpEMy5J84dvYQ8wfxz+/Zm2fC/ZfBnvr1gVPZVwzINiyYoS/XJ3E3ZqOQ4BksGy4JhGSVSRdFYirAUSoUlXzosBQZLBsuCYam6dpcyLMVSYVl6fIpjASoGy6JhObBdz7Ae4kRkitiUSsVm6eEljsWXGDYLZ7LqF+q4lEvFZelxH44FfhguC8cl3UisUiYk+dKDPjwL+jBIFg1Ja9jvRIl81EDZLBWUpYd8eBbyYaAsHJRqn6afvC0VkqWHe3gW7mGQLDwKq2n20PJo5hEQpzITgaT0SA/PIj0MloWnEoC+TROTpSb38KVHeXgW5WGYLNxV9ml7ylKze4TSAz0CC/QwVBKi8oSEemWdQK+kJswTx1IP4bXUtB8hV0SGqMZcU1yGV4bXo3i9XeP1NhWvxDGdQ3gtNR9IKH0mKrCZKMNrcXjlbq42/k5FLHm85xBkS00TEnJNG4m+ac1FwhlkGWSPf2OqOUD1gI62BwFfBsByje7T1Qf30782PVicJtxLzT4SS19VFdmqKoN7gR6a2/DQXLqHJo7+HoJsqdlJYq41UKIac9F4BlkG2eOQ5Tcgy6dDljg0fAiypeYuiaWv/ohs9YdBtkDIChuQFdIhSxwdPgTZUnObpFwLNUQ15qLiDLIMsschK25AVkyHLHGA+NBWDaXmPUnl747G0hEZZAuErLQBWSkdssQB4kOQLTUtSsq1XENUYy4qziDLIHs82ux03Vg1vqvZDrhKvZMeYd4pSBPc5e5nWHp2lcyyqxi4Cwa36jou3lz9KvXOcXBvFKQJ7lJTseTSU7FklorFwF3kOvHA9Tu65rtPlobRiU5AR8dmXp1Y7si68bHHaJqBUjO85NIzvGSW4cXMQIFmwOr7anfg62DgGzqwPHQCx9UH99Nhf7A4TbiXmh0ml54dprDsMAb3ouHuAWegPtlDbxfn7zc+APh7OZrILjURTCmdzyuMzzNkF4ts07YHh84W2b11FN1bJWniu9SsMaX800UYUWf4Lhbfj6bqWGoqT9+7fRTne6VpYr3UdDOldJbeZCydYb1ArPe0VF++e+voOWGF+fJSc9OapX+00WQfbZzpqLDtw8FWi2UIUf76PD/9QFPb8XzNNod96zwHhW00IKcVeQRP8Xg80ylh5vsbzH9MGDoPG7gasHTDevholB0bIVtjAmJ4GcIy05cpfKOnH0hrQq1Ag68ZAwPSn43zaHfl4XN39eDbdD6NVAovzVerxfhusnEpuYJf0jRq6M61t1qINLRreOq11+nkgD3CLfUMzwRXkG5EhW7q7dZuwbjL7c3iSW/+G7xFh0pH/7XCaFDMRlFzYdtg35bwYjxi2sHcj1Zm8a/kak+rgV8vUNm1ge3WHHSE37pQA4tobAtu7DevsauIVNWor5NphD2sEvFGEmXlxnc73F1y646LNcHV12g+BZvqUIcvWgM0jnVPZMFRZPqRt7X7wHHpGc69OkB/YNpPABRZx0B1PKvYbji2WWgXPkHbYtPsQUzikiq2m58Y22Mm6+SBHx9+jQTtGYaD9+52tx6/csK5+hp+j9HBw3YdfK7dQn07sHN5fD1GRBsLw32CPUkRdnoPD5Fe3EHq5+ZGQgWogUOCoXVDfxmTY+fpvpdpTeDTyFbgWcH77+S49WRwJT9b89FzcEw2ut9qHG7c6Qo91Y3sHqeNDGu6G9meA63diJjdjUTcBLG9AjwFUe+luPdS9t5LFei9HPdezt57uQK9V+LeK9l7r1Sg9824983svW9WoPe3ce9vs/f+tgK95/DcgTsyeUjrP0cwe7g8BSRTBo5AAVwVFMBjBfAECuCroAABK0AgUIBQBQVg4scRMD+uCtSPw9yPIyB/XBXYH4fpH0fA/7gqEEAOM0COgAJyVeCAHCaBHAEL5KpAAznMAzkCIshVgQnymAnyBEyQrwIT5DET5AmYIF8FJshjJsgTMEG+CkyQx0yQJ2CCfBWYII+ZIE/ABPkqMEEeM0GegAnyVWCCPGaCPAET5KvABHnMBHkCJshXgQnymAnyBEyQrwIT5DET5AmYIF8FJihgJigQMEGhCkxQwExQIGCCwoUxwXxLq9snqCCd8KevnSoU10qV866NCpgaCgTUUKgCNRQwNRQIqKFwYdQwHya2TylBOpFOx8QtRUzcnhkTmCsKBFxRqAJXFBKbSMAVhQvjivkwsXsSCNJK83RUREuJ1GARCTsrLhKzQEAghSoQSBGPAJGAQIoXRiBzpqYRHreBtMdlyFJLOYeDGqbSKjhrvhqOV4oE8UqxCvFKEZNSkYCUihdGSnP6n51zLpBWxAz+h6Ppf7gz4wIHMUWCIKZYhSCmiImpSEBMxQsjpjlxsXOYBNKKkgEXPE1c8GfGBY5sigSRTbEKkU0RE1ORgJiKF0ZMc+Ji58QGlPl9kwEXAk1cCOfFhYQdpkQQ7pQuLNxJpgBsGSUCIildGJHMiYudYxGQVjJ8LROlA9LDhXhmXCQKIAh5ShcW8iRTQPJNDMlHMRdGJHPiYufsAaQVOQMuJJq4kM6MCxz2lAjCntKFhT3JFICJpERAJKULI5I541sZNvhHGrvNENPa2/mfXjRrT/Q58STjcKlMEC6VLyxcSqYATEBlAgIqXxgBpYCnE/fURxrLsBq/v9k+XTxtiT4rnvCETiYIi8oXFhYlUwAmrjIBcZUvjLjmXX+hs4090maGVf6P9renuC5zvKKz4jD5qJzkq/ILC8OSKQATZZmAKMsXRpRz4pBwH3mkvQx5BGkbzNPDW0oFZ8UZDuvKBGFd+cLCukQKUDCBVggItHJhBJocZ3bfAXAyo2/uwX6Vegdr7MQcg0MSKKHqsGhKeKJhtU7ZDh/pMgsX390nn7KB2pAcazLe10xfa4zqYEr2TduQfyZbqGDurxBwf6UK3F/B3F8h4P5Ktbh/pi3vkc6yMPz9vfCpYnhH9jn5hYJ5vELA45Uq8Hgl2R+KZIOoyvH47NvMI91lZPEH9p+niq8D8s+KMczhFQIOr1SBwzcxh28ScPhmZTh89u3dkc6yZArv7/tOD1f7ss+JqSZO62gSpHU0Lyytg0wBmAw3Cchw81xkePcS2i0bX3SD5XQ0m/4OJvbXf4JxqC3m4Wg6D5btP//4H9p1EPI99wAA</definition>
+</savedsearch>

src/deploy.xml

@@ -64,6 +64,7 @@
 
         <path>~/FileCabinet/SuiteScripts/SalesOrder/HC_SC_CreateCustomerDepositAndRefund.js</path>
         <path>~/FileCabinet/SuiteScripts/SalesOrder/HC_MR_ExportedOMSFulfilledBackOrdCSV.js</path>
+        <path>~/FileCabinet/SuiteScripts/SalesOrder/HC_MR_ExportedPOSReturnCSV.js</path>
     </files>
     <objects>
         <!--Custom Record-->
@@ -173,6 +174,7 @@
         <path>~/Objects/SalesOrder/customscript_create_cd_and_cr.xml</path>
         <path>~/Objects/SalesOrder/customscript_export_cust_deposit.xml</path>
         <path>~/Objects/SalesOrder/customscript_exp_oms_fulfilled_so.xml</path>
+        <path>~/Objects/SalesOrder/customscript_exp_pos_return.xml</path>
 
         <!--Saved Search-->
         <path>~/Objects/CashSale/customsearch_hc_export_cashsales.xml</path>
@@ -195,6 +197,7 @@
         <path>~/Objects/Product/customsearch_hc_exp_kit_component.xml</path>
         <path>~/Objects/SalesOrder/customsearch_hc_exp_customer_deposit.xml</path>
         <path>~/Objects/SalesOrder/customsearch_hc_exp_oms_shipped_orders.xml</path>
+        <path>~/Objects/SalesOrder/customsearch_hc_exp_pos_return.xml</path>
     </objects>
     <translationimports>
         <path>~/Translations/*</path>