NetSuite Connector

  
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

  
<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking"
        xmlns:dw="http://www.mulesoft.org/schema/mule/ee/dw" xmlns:netsuite="http://www.mulesoft.org/schema/mule/netsuite"
        xmlns:json="http://www.mulesoft.org/schema/mule/json" xmlns:http="http://www.mulesoft.org/schema/mule/http"
        xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
        xmlns:spring="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://www.mulesoft.org/schema/mule/netsuite http://www.mulesoft.org/schema/mule/netsuite/current/mule-netsuite.xsd
http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/schema/mule/ee/tracking/current/mule-tracking-ee.xsd">

        <!-- Configs -->
        <netsuite:config-login-authentication
            name="NetSuite__Login_Authentication" email="${netsuite.email}"
                password="${netsuite.password}" account="${netsuite.account}" roleId="${netsuite.roleId}"
                applicationId="${netsuite.applicationId}" doc:name="NetSuite: Login Authentication" />

        <http:listener-config name="HTTP_Listener_Configuration"
                    host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration" />

        <!-- Add List Flow -->
        <flow name="asyncAddList">
                <http:listener config-ref="HTTP_Listener_Configuration" path="/asyncAddList" doc:name="HTTP" />
                <logger message="Process Started ..." level="INFO" doc:name="Logger" />

                <netsuite:async-add-list config-ref="NetSuite__Login_Authentication"
                        recordType="__customRecordType__customrecordcustomaccount__22"
                        doc:name="Async Add List">                                
                        <netsuite:records-attributes>
                            <!-- Attribute 1 -->            
                                <netsuite:records-attribute>                                                        
                                        <netsuite:inner-records-attribute
                                                key="externalId">addListExt1</netsuite:inner-records-attribute>                                                        
                                        <netsuite:inner-records-attribute
                                                key="name">addListName1</netsuite:inner-records-attribute>                                                    
                                </netsuite:records-attribute>
                                <!-- Attribute 2 -->  
                                <netsuite:records-attribute>                                                        
                                        <netsuite:inner-records-attribute
                                                key="externalId">addListExt2</netsuite:inner-records-attribute>                                                        
                                        <netsuite:inner-records-attribute
                                                key="name">addListName2</netsuite:inner-records-attribute>                                                    
                                </netsuite:records-attribute>                                        
                        </netsuite:records-attributes>                            
                </netsuite:async-add-list>
                <set-variable variableName="jobId" value="#[payload.getJobId()]"
                        doc:name="Set Variable: jobId" />
                <!-- Call sub-flow 'Check Async' -->
                <flow-ref name="check_async_status" doc:name="Check Async Status" />
        </flow>

        <!-- Check Async Sub-flow -->
        <sub-flow name="check_async_status">
                <logger message="===== Checking status for jobId: #[flowVars.jobId] =====" level="INFO" doc:name="Logger" />

                <until-successful maxRetries="180"
                        failureExpression="#[payload.getStatus() == com.netsuite.webservices.platform.core.types.AsyncStatusType.PENDING
                        || payload.getStatus() == com.netsuite.webservices.platform.core.types.AsyncStatusType.PROCESSING]"
                        synchronous="true" doc:name="Until Successful" millisBetweenRetries="10000">
                        <processor-chain doc:name="Processor Chain">
                                <netsuite:check-async-status config-ref="NetSuite__Login_Authentication" jobId="#[flowVars.jobId]" doc:name="Check Async Status" />                                            
                                <logger message="Status is: #[payload.getStatus()]" level="INFO" doc:name="Status" />                                        
                        </processor-chain>                            
                </until-successful>

                <choice doc:name="Choice">                                
                        <when expression="#[payload.getStatus() == com.netsuite.webservices.platform.core.types.AsyncStatusType.FINISHED]">                                            
                                <logger message="Records have been added successfully." level="INFO" doc:name="FINISHED" />
                        </when>                                
                        <otherwise>                                            
                                <logger message="An error has been encountered for jobId: #[flowVars.jobId] Navigate to Setup &gt; Integration &gt; Web Services Process Status on your sandbox for more information."
                                        level="ERROR" doc:name="FAILED / FINISHED_WITH_ERRORS" />                                        
                        </otherwise>                            
                </choice>
        </sub-flow>
         
        <!-- Get Result Sub-flow -->
        <sub-flow name="get_async_result" >                    
                <http:listener config-ref="HTTP_Listener_Configuration"
                    path="/getAsyncResult" doc:name="HTTP" />                    
                <set-variable variableName="jobId"
                        value="#[message.inboundProperties.'http.query.params'.jobId]"
                        doc:name="Set Variable: jobId" />                    
                <logger message="===== Results for jobId: #[flowVars.jobId] ====="
                    level="INFO" doc:name="Logger" />                    
                <netsuite:get-async-result config-ref="NetSuite__Login_Authentication"
                        jobId="#[flowVars.jobId]" doc:name="Get Async Result" />                    
                <set-payload value="#[payload.getWriteResponseList().getWriteResponse()]"
                        doc:name="Get Response List" />

                <foreach doc:name="For Each">                                
                        <logger message="Custom record with externalId:
                                #[payload.getBaseRef().getExternalId()] and typeId:
                                #[payload.getBaseRef().getTypeId()] ... Deleting it!"
                                    level="INFO" doc:name="Result Info" />
     
                        <netsuite:delete config-ref="Netsuite" doc:name="Delete">                                            
                                <netsuite:base-ref type="CUSTOM_RECORD_REF"
                                    externalId="#[payload.getBaseRef().getExternalId()]">                                                        
                                        <netsuite:specific-fields>                                                                    
                                                <netsuite:specific-field key="typeId">#[payload.getBaseRef().getTypeId()]</netsuite:specific-field>                                                                
                                        </netsuite:specific-fields>                                                    
                                </netsuite:base-ref>                                        
                        </netsuite:delete>
                            
                </foreach>
                    
                <logger message="Process Complete" level="INFO" doc:name="Logger" />
        </sub-flow>
</mule>

  
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

  
<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:netsuite="http://www.mulesoft.org/schema/mule/netsuite"
        xmlns:json="http://www.mulesoft.org/schema/mule/json"
        xmlns:http="http://www.mulesoft.org/schema/mule/http"
        xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
        xmlns:spring="http://www.springframework.org/schema/beans" version="EE-3.8.0"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/netsuite http://www.mulesoft.org/schema/mule/netsuite/current/mule-netsuite.xsd
http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd">

<http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/>

<netsuite:config-login-authentication name="NetSuite__Login_Authentication" email="${netsuite.email}" password="${netsuite.password}" account="${netsuite.account}" roleId="${netsuite.roleId}" applicationId="${netsuite.applicationId}" doc:name="NetSuite: Login Authentication"/>

<flow name="customer-basic-search">
    <http:listener config-ref="HTTP_Listener_Configuration" path="/basicSearch" doc:name="HTTP"/>
    <component class="CustomerBasicSearchComponent" doc:name="Create Customer Search Basic criteria"/>
    <netsuite:search config-ref="NetSuite__Login_Authentication" searchRecord="CUSTOMER_BASIC" fetchSize="5" doc:name="Customer Basic Search"/>
    <json:object-to-json-transformer doc:name="Object to JSON"/>
</flow>
</mule>

  
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

  
public class CustomerBasicSearchComponent implements Callable {
 
    @Override
    public Object onCall(MuleEventContext eventContext) throws Exception {
        CustomerSearchBasic searchCriteria = new CustomerSearchBasic();
 
        SearchStringField companyNameFilter = new SearchStringField();
        companyNameFilter.setOperator(SearchStringFieldOperator.STARTS_WITH);
        companyNameFilter.setSearchValue("A");
        searchCriteria.setCompanyName(companyNameFilter);
 
        SearchBooleanField isPersonFilter = new SearchBooleanField();
        isPersonFilter.setSearchValue(false);
        searchCriteria.setIsPerson(isPersonFilter);
 
        SearchCustomFieldList customFieldListFilter = new SearchCustomFieldList();
        List<SearchCustomField> customFieldList = new ArrayList<SearchCustomField>();
        SearchLongCustomField priority = new SearchLongCustomField();
        priority.setScriptId("custentity_cust_priority");
        priority.setOperator(SearchLongFieldOperator.EQUAL_TO);
        priority.setSearchValue(50l);
        customFieldList.add(priority);
        customFieldListFilter.setCustomField(customFieldList);
        searchCriteria.setCustomFieldList(customFieldListFilter);
 
        return searchCriteria;
    }
 
}

  
1
2
3
4
5
6

  
<flow name="item-search-pricing-join">
    <http:listener config-ref="HTTP_Listener_Configuration" path="/joinedSearch" doc:name="HTTP"/>
    <component class="ItemSearchPricingJoinComponent" doc:name="Create Item Search Pricing Join criteria"/>
    <netsuite:search config-ref="NetSuite__Login_Authentication" searchRecord="ITEM" doc:name="Item Search Pricing Join"/>
    <json:object-to-json-transformer doc:name="Object to JSON"/>
</flow>

  
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

  
public class ItemSearchPricingJoinComponent implements Callable {
 
    @Override
    public Object onCall(MuleEventContext eventContext) throws Exception {
        ItemSearch searchCriteria = new ItemSearch();
 
        ItemSearchBasic basicCriteria = new ItemSearchBasic();
        SearchEnumMultiSelectField typeFilter = new SearchEnumMultiSelectField();
        List<String> typeList = new ArrayList<String>();
        typeList.add("_inventoryItem");
        typeFilter.setOperator(SearchEnumMultiSelectFieldOperator.ANY_OF);
        typeFilter.setSearchValue(typeList);
        basicCriteria.setType(typeFilter);
        searchCriteria.setBasic(basicCriteria);
 
        PricingSearchBasic pricingJoinCriteria = new PricingSearchBasic();
        SearchDoubleField rateFilter = new SearchDoubleField();
        rateFilter.setOperator(SearchDoubleFieldOperator.EQUAL_TO);
        rateFilter.setSearchValue(10.00d);
        pricingJoinCriteria.setRate(rateFilter);
        searchCriteria.setPricingJoin(pricingJoinCriteria);
 
        return searchCriteria;
    }
 
}

  
1
2
3
4
5
6

  
<flow name="employee-search-advanced-saved-search">
    <http:listener config-ref="HTTP_Listener_Configuration" path="/advancedSearch" doc:name="HTTP"/>
    <component class="EmployeeSearchAdvancedSavedComponent" doc:name="Create Employee Search Advanced Saved Search criteria"/>
    <netsuite:search config-ref="NetSuite__Login_Authentication" searchRecord="EMPLOYEE_ADVANCED" doc:name="NetSuite"/>
    <json:object-to-json-transformer doc:name="Object to JSON"/>
</flow>

  
1
2
3
4
5
6
7
8
9
10
11
12

  
public class EmployeeSearchAdvancedSavedComponent implements Callable {
 
    @Override
    public Object onCall(MuleEventContext eventContext) throws Exception {
        EmployeeSearchAdvanced searchCriteria = new EmployeeSearchAdvanced();
 
        searchCriteria.setSavedSearchScriptId("customsearch130");
 
        return searchCriteria;
    }
 
}

  
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

  
{
   "tranId":"SampleJournal123",
   "subsidiary":{
      "internalId":"1"
   },
   "customFieldList":{
      "customField":[
         {
            "StringCustomFieldRef__custbodytestbodyfield":"Sample Transaction Body Custom Field"
         }
      ]
   },
   "lineList":{
      "line":[
         {
            "account":{
               "internalId":"1"
            },
            "debit":100.0,
            "customFieldList":{
               "customField":[
                  {
                     "SelectCustomFieldRef__custcol_far_trn_relatedasset":{
                         "internalId":"1"
                     }
                  },
                  {
                     "StringCustomFieldRef__custcoltestcolumnfield": "Sample Transaction Column Custom Field 1"
                  }
               ]
            }
         },
         {
            "account":{
               "internalId":"1"
            },
            "credit":100.0,
            "customFieldList":{
               "customField":[
                  {
                     "SelectCustomFieldRef__custcol_far_trn_relatedasset":{
                         "internalId":"2"
                     }
                  },
                  {
                     "StringCustomFieldRef__custcoltestcolumnfield": "Sample Transaction Column Custom Field 2"
                  }
               ]
            }
         }
      ]
   }
}

  
1
2
3
4
5
6
7
8
9
10

  
%dw 1.0
%output application/java
---
{
        customFieldList: payload.customFieldList,
        lineList: payload.lineList,
        subsidiary: payload.subsidiary,
        tranId: payload.tranId
}

  
1
2
3
4
5
6
7
8
9
10
11

  
{
   "companyName": {
      "operator": "STARTS_WITH",
      "searchValue": "A"
   },
   "isPerson": false,
   "priority": {
      "operator": "EQUAL_TO",
      "searchValue": 50
   }
}

  
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

  
%dw 1.0
%output application/java
---
{
        customFieldList: {
                customField: [{
                        scriptId: "custentity_cust_priority",
                        operator: payload.priority.operator,
                        searchValue: payload.priority.searchValue
                } as :object {
                        class : "com.netsuite.webservices.platform.core.SearchLongCustomField"
                }]
        } as :object {
                class : "com.netsuite.webservices.platform.core.SearchCustomFieldList"
        },
        companyName: {
                operator: payload.companyName.operator,
                searchValue: payload.companyName.searchValue
        } as :object {
                class : "com.netsuite.webservices.platform.core.SearchStringField"
        },
        isPerson: {
                searchValue: payload.isPerson
        } as :object {
                class : "com.netsuite.webservices.platform.core.SearchBooleanField"
        }
} as :object {
        class : "com.netsuite.webservices.platform.common.CustomerSearchBasic"
}

  
1
2
3
4

  
<netsuite:paged-search config-ref="NetSuite__Login_Authentication"
    searchRecord="CUSTOMER_BASIC"
    fetchSize="5"
    doc:name="Customer Basic Search"/>