Haider Ali

/**
 * @NApiVersion 2.1
 * @NScriptType MapReduceScript
 * @NModuleScope SameAccount
 */
define(['N/record', 'N/search', 'N/runtime', 'N/email'],
  (record, search, runtime, email) => {
    
    const getInputData = () => {
      return search.create({
        type: search.Type.SALES_ORDER,
        filters: [
          ['mainline', 'is', 'T'],
          'AND',
          ['status', 'anyof', 'SalesOrd:B'],
          'AND',
          ['custbody_sync_status', 'is', 'PENDING']
        ],
        columns: ['entity', 'total', 'trandate']
      });
    };

    const map = (context) => {
      const searchResult = JSON.parse(context.value);
      const orderId = searchResult.id;
      
      // Process order and emit for reduce
      context.write({
        key: searchResult.values.entity.value,
        value: { orderId, total: searchResult.values.total }
      });
    };

    const reduce = (context) => {
      const customerId = context.key;
      const orders = context.values.map(v => JSON.parse(v));
      
      // Aggregate customer orders
      const totalValue = orders.reduce((sum, o) => sum + parseFloat(o.total), 0);
      
      log.audit('Customer Summary', { customerId, totalValue, orderCount: orders.length });
    };

    return { getInputData, map, reduce };
  });

/**
 * @NApiVersion 2.1
 * @NScriptType Restlet
 */
define(['N/record', 'N/search', 'N/error'],
  (record, search, error) => {
    
    const post = (requestBody) => {
      try {
        const { action, payload } = requestBody;
        
        switch(action) {
          case 'CREATE_ORDER':
            return createSalesOrder(payload);
          case 'UPDATE_INVENTORY':
            return updateInventoryLevels(payload);
          default:
            throw error.create({
              name: 'INVALID_ACTION',
              message: `Unknown action: ${action}`
            });
        }
      } catch (e) {
        log.error('RESTlet Error', e);
        return { success: false, error: e.message };
      }
    };

    const createSalesOrder = (data) => {
      const salesOrder = record.create({
        type: record.Type.SALES_ORDER,
        isDynamic: true
      });
      
      salesOrder.setValue({ fieldId: 'entity', value: data.customerId });
      salesOrder.setValue({ fieldId: 'memo', value: data.externalRef });
      
      data.items.forEach(item => {
        salesOrder.selectNewLine({ sublistId: 'item' });
        salesOrder.setCurrentSublistValue({
          sublistId: 'item',
          fieldId: 'item',
          value: item.itemId
        });
        salesOrder.setCurrentSublistValue({
          sublistId: 'item',
          fieldId: 'quantity',
          value: item.qty
        });
        salesOrder.commitLine({ sublistId: 'item' });
      });
      
      const orderId = salesOrder.save();
      return { success: true, orderId };
    };

    return { post };
  });