//$service = new NetSuiteService();
class CustomRecordSearchAdvancedBuilder{
private static $instance;
private $request;
private $NSService;
private $search;
private $pageIndex;
private $searchId;
private $hasMorePage;
private $fileRecordRef;
public static function getInstance(){
if (empty(static::$instance)) {
static::$instance = new static();
}
return static::$instance;
}
private function __construct() {
$this->initAdvanceSearch();
$this->buildCriteria();
$this->buildRequest();
$this->NSService = NetSuite::getInstance();
$this->fileRecordRef = new RecordRef();
$this->fileRecordRef->type = RecordType::file;
}
private function initBasicSearch(){
$this->search = new CustomRecordSearch();
}
private function initAdvanceSearch(){
$this->search = new CustomRecordSearchAdvanced();
$this->buildColumns(); //Init columns element
}
private function buildColumns(){
$this->search->columns = new CustomRecordSearchRow();
$this->search->columns->basic = new CustomRecordSearchRowBasic();
$this->search->columns->basic->internalId = [new SearchColumnSelectField()];
$field1 = new SearchColumnSelectCustomField();
$field1->scriptId = 'abcde';
$field2 = new SearchColumnSelectCustomField();
$field2->scriptId = 'abcde2';
$field3 = new SearchColumnDateCustomField();
$field3->scriptId = 'abcde3';
$field4 = new SearchColumnStringCustomField();
$field4->scriptId = 'abcde4';
$fieldList = new SearchColumnCustomFieldList();
$fieldList->customField = [$field1, $field2, $field3, $field4];
$this->search->columns->basic->customFieldList = $fieldList;
return $this;
}
private function buildCriteria(){
if ($this->search instanceof CustomRecordSearchAdvanced) {
$this->search->criteria = new CustomRecordSearch();
$this->search->criteria->basic = new CustomRecordSearchBasic();
$this->search->criteria->basic->recType = new RecordRef();
$this->search->criteria->basic->recType->type = RecordType::customRecord;
$this->search->criteria->basic->recType->internalId = 7;
} else {
$this->search->basic = new CustomRecordSearchBasic();
$this->search->basic->recType = new RecordRef();
$this->search->basic->recType->type = RecordType::customRecord;
$this->search->basic->recType->internalId = 7;
}
return $this;
}
private function buildRequest(){
$this->request = new SearchRequest();
$this->request->searchRecord = $this->search;
return $this;
}
public function setSearchCreatedValue($value){
$created = new SearchDateField();
$created->operator = SearchDateFieldOperator::on;
$created->searchValue = $value;
$this->getCriteria()->basic->created = $created;
}
public function setSearchEntityId($internalId, $operator = '='){
$long = new SearchLongField();
$long->searchValue = $internalId;
if ($operator == '>=') {
$long->operator = SearchLongFieldOperator::greaterThanOrEqualTo;
} else if ($operator == '<=') {
$long->operator = SearchLongFieldOperator::lessThanOrEqualTo;
} else {
$long->operator = SearchLongFieldOperator::equalTo;
}
$this->getCriteria()->basic->internalIdNumber = $long;
return $this;
}
public function getCriteria(){
if ($this->search instanceof CustomRecordSearchAdvanced) {
return $this->search->criteria;
} else {
return $this->search;
}
}
public function onBeforeSearch(){
$this->pageIndex = 1;
$this->searchId = '';
$this->hasMorePage = true;
return $this;
}
public function hasMorePage(){
return $this->hasMorePage;
}
private function setNoMorePage(){
$this->hasMorePage = false;
return $this;
}
public function searchByPage(){
if ($this->pageIndex <= 1) {
$response = $this->doSearch();
} else {
$response = $this->doSearchWithId($this->searchId, $this->pageIndex);
}
$this->searchId = ResponseHandler::getSearchId($response);
if (ResponseHandler::hasNextPage($response)) {
$this->pageIndex += 1;
$this->hasMorePage = true;
} else {
$this->hasMorePage = false;
}
return $response;
}
public function doSearch(){
$response = $this->NSService->getService()->search($this->request);
return $response;
}
public function doSearchWithId($searchId, $pageIdx){
$request = new SearchMoreWithIdRequest();
$request->searchId = $searchId;
$request->pageIndex = $pageIdx;
$response = $this->NSService->getService()->searchMoreWithId($request);
return $response;
}
public function getFileRecord($fileInternalId){
$this->fileRecordRef->internalId = $fileInternalId;
$file = $this->NSService->getRecord($this->fileRecordRef);
if (isset($file->url)) {
parse_str($file->url, $result);
if (isset($result['_xt'])) {
$file->name = preg_replace('/' . preg_quote($result['_xt']) . '$/i', '', $file->name) . $result['_xt'];
}
}
return $file;
}
}
function testAdvanceSearch($date){
$search = CustomRecordSearchAdvancedBuilder::getInstance();
$search->setSearchCreatedValue($date.'T00:00:00.000');
$response = $search->doSearch();
return $response;
}
function getCstmRcrdSearch($internalId){
$search = new CustomRecordSearch();
$search->basic = new CustomRecordSearchBasic();
$search->basic->recType = new RecordRef();
$search->basic->recType->type = RecordType::customRecord;
$search->basic->recType->internalId = 7;
$long = new SearchLongField();
$long->searchValue = $internalId;
$long->operator = SearchLongFieldOperator::equalTo;
$search->basic->internalIdNumber = $long;
return $search;
}
function getOneEntity($internalId){
$search = getCstmRcrdSearch($internalId);
$request = new SearchRequest();
$request->searchRecord = $search;
$response = NetSuite::getInstance()->getService()->search($request);
return $response;
}
function getOneEntityByAdvance($internalId){
$search = new CustomRecordSearchAdvanced();
$search->criteria = getCstmRcrdSearch($internalId);
$search->columns = new CustomRecordSearchRow();
$search->columns->basic = new CustomRecordSearchRowBasic();
$search->columns->basic->internalId = [new SearchColumnSelectField()];
$field1 = new SearchColumnSelectCustomField();
$field1->scriptId = 'abcde';
$field2 = new SearchColumnSelectCustomField();
$field2->scriptId = 'abcde2';
$field3 = new SearchColumnDateCustomField();
$field3->scriptId = 'abcde3';
$field4 = new SearchColumnStringCustomField();
$field4->scriptId = 'abcde4';
$fieldList = new SearchColumnCustomFieldList();
$fieldList->customField = [$field1, $field2, $field3, $field4];
$search->columns->basic->customFieldList = $fieldList;
$request = new SearchRequest();
$request->searchRecord = $search;
$response = NetSuite::getInstance()->getService()->search($request);
return $response;
}
function getOneFile($fileId,){
$file = CustomRecordSearchAdvancedBuilder::getInstance()->getFileRecord($fileId);
unset($file->content);
return $file;
}
function getFileInfo($fileId){
$file = getOneFile($fileId);
$finfo = new finfo(FILEINFO_MIME_TYPE);
return $finfo->buffer($file->content);
}
function removeFileFromFileCabinet($fileId) {
$recordRef = new RecordRef();
$recordRef->type = RecordType::file;
$recordRef->internalId = $fileId;
$request = new DeleteRequest();
$request->baseRef = $recordRef;
$response = NetSuite::getInstance()->getService()->delete($request);
return $response;
}
function testUpdateCustomFieldValueForEntity($entityInternalId){
$fieldName = 'abcde';//Hidden fields will not be updated.
$response = getOneEntity($entityInternalId);
if (ResponseHandler::isSuccess($response) && ResponseHandler::getTotalRecords($response) > 0) {
$record = $response->searchResult->recordList->record[0];
$updateRecord = new CustomRecord();
$updateRecord->internalId = (int)$record->internalId;
$updateRecord->recType = $record->recType;
$updateRecord->customFieldList = new CustomFieldList();
$stringCustomField = new StringCustomFieldRef();
$stringCustomField->scriptId = $fieldName;
$stringCustomField->value = 'hello 你好';//utf8_encode()'2021-02-23T16:00:00.000-08:00'
$updateRecord->customFieldList->customField = [$stringCustomField];
$request = new UpdateRequest();
$request->record = $updateRecord;
$updateResponse = $NetSuiteService->update($request);
if ($updateResponse->writeResponse->status->isSuccess) {
var_dump(getOneEntity($entityInternalId));
} else {
var_dump($updateResponse);
}
}
}
class ResponseHandler{
public static function hasNextPage($response){
return $response->searchResult->pageIndex < $response->searchResult->totalPages;
}
public static function getTotalRecords($response){
return $response->searchResult->totalRecords; // e.g. pageSize=1000, total Records may be 1440
}
public static function getSearchId($response){
return $response->searchResult->searchId;
}
public static function getTotalPages($response){
return $response->searchResult->totalPages;
}
public static function getRecordList($response){
return (array)$response->searchResult->searchRowList->searchRow;
}
public static function getTotalRecordsOfOnePage($response){
return count(static::getRecordList($response));
}
public static function isSuccess($response){
return $response->searchResult->status->isSuccess; //boolean
}
public static function isInvalidSearchMore($response){
return !static::isSuccess($response) && $response->searchResult->status->statusDetail[0]->code == 'INVALID_SEARCH_MORE';
}
public static function handle($response){
if (static::isSuccess($response) && static::getTotalRecords($response) > 0) {
static::forEachEntity($response);
}
}
private static function forEachEntity($response){
foreach($response->searchResult->searchRowList->searchRow as $record){//CustomRecordSearchRow
$signal = static::onEachRecord($record);
if ($signal > 0) continue;
}
}
private static function onEachRecord($record){
}
}
根据自定义字段的值进行检索：
function searchOnCustomField(){
$search = new CustomRecordSearch();
$search->basic = new CustomRecordSearchBasic();
$search->basic->recType = new RecordRef();
$search->basic->recType->type = RecordType::customRecord;
$search->basic->recType->internalId = 7;
$search->basic->customFieldList = new CustomFieldList();
$field = new SearchStringCustomField();
$fieldName = 'custrecordtmpfilename';
$field->scriptId = $fieldName;
$field->searchValue = "abcdef";
$field->operator = SearchStringFieldOperator::startsWith;
$fieldList = new SearchCustomFieldList();
$fieldList->customField = [$field];
$search->basic->customFieldList = $fieldList;
$request = new SearchRequest();
$request->searchRecord = $search;
$NetSuiteService->setSearchPreferences($bodyFieldsOnly=true,$pageSize=50,$returnSearchColumns=true);
$response = $service->search($request);
}