Обмен без правил. От простого к сложному

Введение

Обмен между конфигурациями с идентичными метаданными

• Работа с метаданными
• Кодирование

Обмен между конфигурациями с различными метаданными

• Работа с метаданными
• Кодирование

Обмен между конфигурациями с разными метаданными с использованием XDTO

• Работа с метаданными
• Кодирование

Заключение

Введение

Обмен будет работать между двумя конфигурациями на платформе 1С. Он будет иметь следующую логику: из одной базы данных будут выгружаться элементы справочников и документа. Будем называть такую базу Trade (имя только для того, чтобы в дальнейшем различать конфигурации). Далее выгруженные данные будут загружаться в базу данных Accounting. Из Accounting в Trade будет загружаться только документ. Реализация такого обмена будет выполнена за 3 итерации, на каждой будет получен работоспособный обмен данными.  Конфигурации можно использовать в других решениях в качестве шаблона.

Обмен между конфигурациями с идентичными метаданными

Работа с метаданными

На первой итерации создадим обмен с отбором между идентичными конфигурациями. В качестве транспорта данных будем использовать файлы.

Создадим новую конфигурацию с именем Trade. В ней создадим роль FullRights, в которой включим флажок Назначать права для новых объектов.  Укажем эту роль в качестве основной роли в свойствах конфигурации.

Создадим справочники Companies, Counterparties, Products, в которых все оставим по умолчанию.

Создадим документ SupplierInvoice. Добавим реквизит Company с типом CatalogRef.Companies. Добавим реквизит Counterparty с типом CatalogRef.Counterparties. Добавим табличную часть Inventory с реквизитом Product, тип которого CatalogRef.Products и Quantity с типом Number.

Создадим план обмена с именем NoRull. Изменим длину кода на 40, длину наименования на 50 символов. В состав плана обмена включим справочники Counterparties, Products с включенной авторегистрацией. Для документа SupplierInvoice и справочника Companies отключим авторегистрацию.

Реализуем возможность регистрации данных с учетом отбора. Для этого у плана обмена добавим реквизит Company с типом CatalogRef.Companies. Для каждого узла обмена (узел обмена = элемент плана обмена) данные будут фильтроваться по указанной в узле организации. Создадим подписку на событие OnWrite (ПриЗаписи) для документа и обработчик подписки разместим в общем модуле с взведенным флагом Сервер (не будем учитывать Толстый клиент). 

If Source.DataExchange.Load Then
	Return;	
EndIf; 
	
Nodes = ExchangePlans.NoRull.ExchangeNodesByCompany(Source.Company);
If Nodes.Count() > 0 Then
	ExchangePlans.RecordChanges(Nodes, Source.Ref);	
EndIf; 

Функция ExchangeNodesByCompany модуля менеджера плана обмена возвращает массив узлов, организация которых совпадает с переданной в нее организацией. Далее для таких узлов регистрируется изменение документа по ссылке.  Создадим аналогичную подписку для справочника Companies.

Для реализуемого варианта обмена создание узлов плана обмена – ручная операция, поэтому в режиме Предприятие в плане обмена зададим код и наименование для текущего узла, а также создадим еще один узел с заполненой организацией. После этого создадим пару организаций, 1 контрагента, пару товаров, несколько приходных накладных.

Проверить объекты, которые зарегистированы к выгрузке, можно с помощью любой консоли запросов. В конструкторе запросов нажимаем на кнопку Отображать таблицы изменений и выбираем данные из нужной таблицы.

Создадим общую форму ExchangeManagement, с помощью которой будем выполнять обмен данными. Добавим реквизит формы ExchangeCatalog с типом Строка и реквизит ExchangeNode с типом ExchangePlanRef.NoRull. Создадим элементы формы для созданных реквизитов. Также добавим команду, которая будет запускать выполнение обмена. Форму разместим на начальной странице приложения.

Подготовительные работы на этом закончены. Перейдем к реализации алгоритмов обмена.

Кодирование

Алгоритм обмена условно можно разделить на следующие пункты:

Импорт данных

• Чтение заголовков файла обмена
• Удаление зарегистрированных объектов для отправителя
• Чтение тела файла обмена
• Фиксация факта обработки данных

Экспорт данных

• Формирование заголовков файла обмена
• Формирование тела файла обмена
• Фиксация факта обработки данных

Данный функционал реализуется за несколько строк кода. В общем модуле создадим экспортную процедуру ExecuteExchange с входящими параметрами Directory и Node, в которые будем передавать значения реквизитов общей формы ExchangeManagement. Процедура ExecuteExchange в свою очередь будет вызывать  процедуры ImportData и ExportData с аналогичными входящими параметрами.

NodeCodeFrom = Node.Code;
NodeCodeTo = ExchangePlans.NoRull.ThisNode().Code;
FileName = GenerateFileName(Directory, NodeCodeFrom, NodeCodeTo);

File = New File(FileName);
If Not File.Exist() Then
	Return;
EndIf;

XMLReader = New XMLReader;
XMLReader.OpenFile(FileName);
ReadingMessage = ExchangePlans.CreateMessageReader();
Try
	ReadingMessage.BeginRead(XMLReader, AllowedMessageNo.Greater);	
Except
	Message(BriefErrorDescription(ErrorInfo()));
	Return;
EndTry;
	
ExchangePlans.DeleteChangeRecords(ReadingMessage.Sender, ReadingMessage.ReceivedNo);

While CanReadXML(XMLReader) Do
	Data = ReadXML(XMLReader);
	Data.DataExchange.Sender = ReadingMessage.Sender;
	Data.DataExchange.Load = True;
	Data.Write();		
EndDo; 

ReadingMessage.EndRead();
XMLReader.Close();

Функция GenerateFileName на основнии кодов узлов обмена формирует имя файла обмена с данными для импорта (пример - D:\обмен\от 01 для 02.xml). Ситуация с отсутствующим файлом возможна при первоначальной синхронизции данных. Если же файл существует, то читаем его заголовки, которые имеют следующий вид:

<v8msg:Header>
	<v8msg:ExchangePlan>NoRull</v8msg:ExchangePlan>
	<v8msg:To>01</v8msg:To>
	<v8msg:From>02</v8msg:From>
	<v8msg:MessageNo>13</v8msg:MessageNo>
	<v8msg:ReceivedNo>33</v8msg:ReceivedNo>
</v8msg:Header>

В заголовке содержится информация об имени плана обмена, кодах узлов и номерах сообщений. Наверное, каждый встречал ошибку при обмене, которая сообщает о том, что номер сообщения меньше или равен принятому. Поэтому для упрощения разрабатываемого алгоритма в метод  BeginRead (НачатьЧтение) вторым параметром передадим, что ожидаются данные только с номером сообщения больше принятого. Если заголовки были успешно прочитаны, то это означает, что узел-отправитель успешно принял данные и теперь для него можно удалить все зарегистрированные для выгрузки данные, но номер сообщения которых меньше или равен номеру полученного сообщения (это базовые основы работы планов обмена платформы 1С, подробное описание их работы выходит за рамки данной статьи). 

После этого читаем тело сообщения пока это возможно с помощью CanReadXML (ВозможностьЧтенияXML). Так как на данном этапе алгоритм предполагает обмен между конфигурациями с идентичными метаданными, то десериализация и сериализация прикладных объектов возможна с помощью ReadXML (ПрочитатьXML) и WriteXML (ЗаписатьXML) соответственно (методы обходят метаданные сериализуемого объекта и записывают/читают документ xml в точно таком же порядке). Для того, чтобы записываемый объект при обмене не регистрировался для выгрузки, в свойстве DataExchange (ОбменДанными) укажем узел плана обмена, от которого этот объект получен.

После того, как тело сообщения будет прочитано, вызовем метод EndRead (ЗакончитьЧтение), который увеличит номер принятого сообщения в узле обмена.

NodeCodeFrom = ExchangePlans.NoRull.ThisNode().Code;
NodeCodeTo = Node.Code;
FileName = GenerateFileName(Directory, NodeCodeFrom, NodeCodeTo); 

RecordOfMessage = ExchangePlans.CreateMessageWriter();
Record = New XMLWriter;
Record.OpenFile(FileName);
RecordOfMessage.BeginWrite(Record, Node);
Selection = ExchangePlans.SelectChanges(RecordOfMessage.Recipient, RecordOfMessage.MessageNo);
While Selection.Next() Do
	Object = Selection.Get();
	WriteXML(Record, Object);
EndDo;
RecordOfMessage.EndWrite();
Record.Close();

При выгрузке данных аналогично получим имя файла, в который будут записываться данные. Далее с помощью метода CreateMessageWriter (СоздатьЗаписьСообщения) создадим объект RecordOfMessage, с помощью которого можно будет записать сериализованные данные. Метод BeginWrite (НачатьЗапись) объекта RecordOfMessage, формирует заголовки сообщения и объявляет начало тела сообщения. Далее метод SelectChanges (ВыбратьИзменения)  вернет коллекцию ссылок на данные, которые подлежат выгрузке в узел-получатель (RecordOfMessage.Recipient). Далее обходим коллекцию, получаем выгружаемый объект и сериализуем его с помощью WriteXML (ЗаписатьXML).  Для корректного завершения процесса выгрузки вызовем метод EndWrite (ЗакончитьЗапись), который сформирует окончание тела сообщения и увеличит номер отправленного сообщения в узле обмена.

Запустим режим Предприятие, укажем каталог обмена, узел-получатель (для которого ранее заполняли организацию) и выполним обмен. Если все сделано правильно, то в каталоге обмена должен появиться документ xml (сообщение обмена), в котором будут данные из базы Trade. 

Теперь создадим новую конфигурацию и загрузим в нее ранее созданную конфигурацию Trade. Имя конфигурации зададим как Accounting (только для того, чтобы различать конфигурации). Удалим подписки на события, в плане обмена удалим реквизит Company, отключим авторегистрацию для справочников и включим для документа. Это позволит регистрировать изменения только для документа.

В режиме Предприятие для текущего узла зададим код и наименования точно такие же, как в базе Trade для узла с заполненой организацией. Добавим еще один узел обмена с кодом и наименованием такими же как и в базе Trade для узла с незаполненой организацией.

Выполним обмен данными, указав каталог обмена и выбрав узел обмена, для которого будем выгружать данные (от которого получаем). Если все сделано правильно, то в базу Accounting загрузятся данные из Trade, а в каталоге обмена появится еще один документ xml. В нем будут только заголовки (Headers), в которых будет информация о номере успешно принятого сообщения. Если в Accounting записать документ SupplierInvoice и выполнить обмен, то благодоря тому, что при импорте данных чтение сообщения происходит в попытке/исключение, мы не увидим ошибки о том, что номер сообщения меньше или равен предыдущему, а в сообщении для Trade появится тело сообщения. 

Вот так за минут 20 можно создать простейшую систему обмена данными между решениями на платформе 1С. При желании практически весть код методов импорта и экспорта данных можно найти в СП. Но реализованный алгоритм имеет один большой недостаток, который рассмотрим далее.

Обмен между конфигурациями с различными метаданными

Работа с метаданными

На второй итерации реализуем алгоритм обмена данными между конфигурациями с разными метаданными. В качестве транспорта данных будем использовать файлы.

Откроем конфигурацию Trade в режиме Конфигуратор и в документе поменяем порядок реквизитов Company и Counterparty. Затем в режиме Предприятие зарегистрируем документ к выгрузке (достаточно перезаписать документ) и попробуем выполнить обмен. На этапе загрузки файла с данными в Accounting получим ошибку преобразования xml. Вернем порядок реквизитов в Trade, а в Accounting у документа удалим реквизит Company и справочник Companies поскольку в нем нет практического смысла, ведь в Accounting всегда только одна организация. Теперь если из Trade выгрузить документ или элемент справочника Companies, то при попытке загрузки такого файла в Accounting получим уже знакомую ошибку разбора xml. Таким образом мы нашли главный недостаток разработанного ранее алгоритма обмена – метаданные объектов, которые участвуют в обмене, должны быть полностью идентичны (в том числе и порядок реквизитов).

Для решения данной задачи будем использовать постобработку xml. После выгрузки из Trade в документе xml нужно удалить все, что связано с организацией и перед загрузкой в Trade в документе xml добавить организацию для документа. Используем два способа редактирования xml – преобразование документа по шаблону (XSLT) и объектную модель (DOM).

На общей форме управления обменом добавим возможность выбора типа обработки данных xml – DOM или XSLT.

Кодирование

Теперь выгрузим из Trade элемент справочника Companies и документ SupplierInvoice, а потом проанализируем получившийся документ xml. В документе xml нужно удалить два узла - DocumentObject.SupplierInvoice/Company и CatalogObject.Companies. Для начала используем XSLT. В качестве редактора таблицы XSL я использую онлайн инструмент. В итоге должна получиться следующая таблица XSL:

<xsl:stylesheet version="1.0" xmlns:xsl="http://www.w3.org/1999/XSL/Transform">

	<xsl:output method="xml" encoding="utf-8" indent="yes"/>

	<!-- coping of all nodes -->
	<xsl:template match="node()|@*" >
		<xsl:copy>
			<xsl:apply-templates select="node()|@*" />
		</xsl:copy>
	</xsl:template>

	<!-- deleting nodes -->
	<xsl:template match="DocumentObject.SupplierInvoice/Company">
	</xsl:template>

	<xsl:template match="CatalogObject.Companies">
	</xsl:template>

</xsl:stylesheet>

Сначала указываем, что будем использовать xsl преобразование и указываем имя пространства имен для того, чтобы преобразователь понимал что именно является инструкциями преобразования. Далее указываем, что на выходе ждем xml с определенной кодировкой и отформатированный отступами. Затем определяем "пространство", которое хотим преобразовать - в данном случае весь документ. (каждый узел со всеми его атрибутами).  И дальше копируем каждый узел. После этого также определяем "пространство" как реквизит Company документа SupplierInvoice и элемент справочника Companies, но в качестве операторов преобразования ничего не ипользуем, то есть просто удаляем такие узлы.

Сохраним полученную таблицу XSL как макет плана обмена в конфигурации Trade. После метода, который экспоритрует данные, добавим вызов метода, который преобразует сформированный документ xml.

Transform = New XSLTransform;
Transform.LoadXSLStylesheetFromString(Instructions);
Return Transform.TransformFromFile(FileName);

Используем объект платформы XSLTransform (ПреобразованиеXSL),  которому передадим XSL таблицу (переменная Instructions). Далее вызовем метод TransformFromFile (ПреобразоватьИзФайла) и в качестве параметра передадим путь к документу xml, который нужно преобразовать. На выходе получим преобразованный xml документ, который нужно записать под именем FileName. 

Реализуем такой же функционал с помощью объектной модели документа xml.

XMLReader = New XMLReader;
XMLReader.OpenFile(Path);

Builder 	= New DOMBuilder;
DomDocument = Builder.Read(XMLReader);
XMLReader.Close();

Return DomDocument;

Прежде всего получим DOM документ по имени файла (переменная Path)

DOMDocument = DomDocumentByFile(FileName);

Resolver 			 = New DOMNamespaceResolver(DOMDocument);	
SearchCatalogCompany = "//CatalogObject.Companies"; 	
XPathExpression 	 = DOMDocument.CreateXPathExpression(SearchCatalogCompany, Resolver);
CatalogCompanyNodes  = XPathExpression.Evaluate(DOMDocument);

CompanyNode = CatalogCompanyNodes.IterateNext();
If CompanyNode <> Undefined Then
	CompanyNode.ParentNode.RemoveChild(CompanyNode);
EndIf; 

SearchCompany   = "//DocumentObject.SupplierInvoice/Company"; 	
XPathExpression = DOMDocument.CreateXPathExpression(SearchCompany, Resolver);
CompanyNodes    = XPathExpression.Evaluate(DOMDocument);

CompanyNode = CompanyNodes.IterateNext();
While CompanyNode <> Undefined Do
	CompanyNode.ParentNode.RemoveChild(CompanyNode);	
	CompanyNode = CompanyNodes.IterateNext();	
EndDo; 

WriteDomDocument(FileName, DOMDocument);

Далее будем использовать XPath (язык запросов к xml). Необходимо найти узел CatalogObject.Companies, который находятся на любом уровне дерева, именно поэтому используем // в поиске. Если такой узел найден, то удаляем его как дочерний узел родительского узла. Аналогично поступим с узлами DocumentObject.SupplierInvoice/Company, которых может быть несколько в документе и именно поэтому удалять такие узлы будем в цикле. Затем обработанный DOM документ необходимо сохранить под именем исходного документа xml.

Обработанный любым из двух способов, документ xml будет успешно загружен в Accounting. Если Вы впервые сталкивваетесь с XSLT и XPath, то рекомендую этот ресурс для изучения.

Остается добавить организацию в документ xml перед загрузкой в Trade. Поскольку в Accounting данные всегда по одной организации, то ИД организации для подстановки в документы можно брать как ИД организации, которая указана в узле отправителе. Для этого разработаем новую таблицу XSL.

<xsl:stylesheet version="1.0" xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:v8msg="http://v8.1c.ru/messages">

	<xsl:output method="xml" encoding="utf-8" indent="yes"/>


	<!-- coping of all nodes -->
	<xsl:template match="node()|@*" >
		<xsl:copy>
			<xsl:apply-templates select="node()|@*" />
		</xsl:copy>
	</xsl:template>

	<!-- adding Company nodes -->
	<xsl:template match="v8msg:Body/DocumentObject.SupplierInvoice/Posted">
		<xsl:for-each select="."> 
			<xsl:element name="Posted"><xsl:value-of select="."/></xsl:element>
			<xsl:element name="Company">$CompanyId</xsl:element>
		</xsl:for-each>
	</xsl:template>

</xsl:stylesheet>

Идея преобразования документа xml в следующем - определяем область, в которой будем что-либо менять - v8msg:Body/DocumentObject.SupplierInvoice/Posted (так как у узла Body есть префикс, то определим в заголовке документа пространство имен как xmlns:v8msg="http://v8.1c.ru/messages). Далее перебираем все узлы в этой области и к узлу Posted добавляем его текущее значение, а также узел  Company со значением $CompanyId ($CompanyId заменим через СтрЗаменить на Гуид организации узла обмена). Полученную таблицу используем по аналогии с экспортом данных и преобразованный документ xml сохраним.

Реализуем такой же функционал, но с помощью объектной модели документа xml.

DOMDocument = DomDocumentByFile(FileName);

Resolver = New DOMNamespaceResolver(DOMDocument);	

SearchCounterparties = "//DocumentObject.SupplierInvoice/Counterparty"; 	
XPathExpression = DOMDocument.CreateXPathExpression(SearchCounterparties, Resolver);
CounterpartiesNodes    = XPathExpression.Evaluate(DOMDocument);

CounterpartyNode = CounterpartiesNodes.IterateNext();
While CounterpartyNode <> Undefined Do
	
	DOMElement = DOMDocument.CreateElement("Company");
	DOMElement.TextContent = CompanyUUID(Node.Company);
	CounterpartyNode.ParentNode.InsertBefore(DOMElement, CounterpartyNode);
	
	CounterpartyNode = CounterpartiesNodes.IterateNext();
	
EndDo;

Выбираем все узлы DocumentObject.SupplierInvoice/Counterparty, которые находятся на любом уровне дерева. Обходим коллекцию таких узлов и добавляем новый узел DocumentObject.SupplierInvoice/Company для узла DocumentObject.SupplierInvoice, но перед DocumentObject.SupplierInvoice/Counterparty. Сохраняем обработанный DOM документ.

После этого будет работоспособный двухсторонний обмен. Данный способ сложен в разработке (количество объектов, которые участвуют в обмене, может быть большим) и его довольно тяжело поддерживать.

Обмен между конфигурациями с разными метаданными с использованием XDTO

Работа с метаданными

На третьей итерации переработаем созданный ранее алгоритм. Откажемся от пост обработки документов xml, а в качестве транспорта данных будем использовать http. Инциатором обмена будет всегда выступать один из его участников, то есть можно сказать, что будет Клиент (инициатор) и Сервер (обработчик запросов клиента). Поэтому в качестве Клиента будет выступать Accounting (зададим новое имя конфигурации Client), в роли Сервера будет Trade (новое имя конфигурации Server). При инициации обмена клиентом подготавливается сообщение обмена и вызывается метод веб сервиса сервера, который отвечает за импорт данных. Сообщение обмена обрабатывается сервером и клиент получает результат обработки. Если он успешен, то вызывается метод веб сервиса сервера, который отвечает за экспорт данных. На сервере подготавливается сообщение обмена и отправляется в качестве ответа клиенту. В свою очередь клиент обрабатывает полученное сообщение.

Тело сообщения (узел Body в документе xml) можно использовать как "контейнер" для передачи любой сериализуемой информации. В качестве "шаблона", по которому будем формировать тело, используем XDTO пакет.

В конфигурации Server создадим XDTO пакет с именем пространств имен http://norull.com (имя может быть любым, главное чтобы оно было уникально в рамках проекта). Структура пакета следующая:

• Типы значений - все возможные типы значений, которые будут встречаться в рамках разрабатываемого пакета. Базовые типы всех значений из пространства имен http://www.w3.org/2001/XMLSchema (необязательно).
• Тип Objects - "родительский контейнер", в который будут помещаться все сериализованные объекты.  
• Object - список XDTO с типом Object
• Тип Object - базовый тип для всех остальных сущностей (Counterparty, Product, SupplierInvoice)
  • Id - тип IdType
  • DeletinoMark - тип FlagType
• Тип Counterparty - базовый тип Object
  • Description - тип DescriptionType
• Тип Product - базовый тип Object 
  • Description - тип DescriptionType
  • SKU - тип DescriptionType
• Тип SupplierInvoice - базовый тип Object
  • Number - тип NumberType
  • Date - тип DateTimeType   
  • Counterparty - тип IdType
  • Inventory - "родительский контейнер", в который будем помещать строки табличной части документа
    • InventoryItem - список XDTO
      • Product - тип IdType
      • Quantity - тип QuantityType 

Создадим веб сервис с именем пространств имен http://norull.com и созданным ранее XDTO пакетом. Имя файла публикации зададим как server.ws. Вэб сервис будет обслуживать две операции - импорт и экспорт данных. Обе операции не могут возвращать пустое значение и будут выполняться в транзацкии (соответствующие флажки в свойствах операции). Операция импорта будет иметь 3 входящих параметра - идентификатор узла инициаотора обмена (NodeId, тип IdType), наименование узла отправителя (NodeDescription, тип DescriptionType) и данные для загрузки (Data, тип String). Операция экспорта будет иметь 1 входящий параметр - идентификатор узла инициатора обмена. 

Кодирование

Из модуля веб сервиса вызовем функцию общего модуля, в которую передадим в качестве параметров - параметры метода вэб-сервиса.

Nodes = ExchangePlans.NoRull.FindCreateExchangeNodes(SenderNodeId, SenderNodeDescription); 

If Nodes.NeedFullExchange Then
	ExchangePlans.NoRull.ObjectsRegistrationForFullExchange(Nodes.Sender);
EndIf; 

Response = New Structure("Status, Message, Data", 1, "", "");

ExchangeData = CommonUse.Base64ValueToString(Data);

XMLReader = New XMLReader;
XMLReader.SetString(ExchangeData);
ReadingMessage = ExchangePlans.CreateMessageReader();
Try
	ReadingMessage.BeginRead(XMLReader, AllowedMessageNo.Greater);	
Except
	Response.Status  = 0;
	Response.Message = BriefErrorDescription(ErrorInfo());
	Return CommonUse.DataToJSON(Response);
EndTry;

ExchangePlans.DeleteChangeRecords(ReadingMessage.Sender, ReadingMessage.ReceivedNo);

NewObjects = XDTOFactory.ReadXML(XMLReader);
XDTOObjects = New Array;
If NewObjects .Properties().Get("Object") <> Undefined Then
	If TypeOf(Objects.Object) = Type("XDTOList") Then
		For Each Object In Objects.Object Do
			XDTOObjects.Add(Object);		
		EndDo; 
	Else
		XDTOObjects.Add(Objects.Object);	
	EndIf;	
EndIf; 
	
For Each XDTOObject In XDTOObjects Do
	
	If XDTOObject.Type().Name = "SupplierInvoice" Then
		FindCreateSupplierInvoice(XDTOObject, ReadingMessage.Sender); 	
	Else
		// unknown type
		Continue;
	EndIf;
	
EndDo; 

ReadingMessage.EndRead(); 

Return CommonUse.DataToJSON(Response);

Функция FindCreateExchangeNodes модуля менеджера плана обмена проверяет наличие узла обмена с переданным ИД. Если такого нет, то создает его, а также инициализирует текущий узел обмена и устанавливает флаг NeedFullExchange в true. Таким образом в текущем варианте обмена нет необходимости вручную создавать узлы планов обмена. Далее если это новый обмен, то вызывается процедура ObjectsRegistrationForFullExchange, которая по определенной логике регистриует объекты для выгрузки. Затем из параметра Data получаем документ XML (сообщение обмена) и пробуем прочитать заголовки сообщения. Если их прочитать удалось, то удаляем зарегистрированные изменения для узла-отправителя. Далее читаем тело сообщения с помощью метода глобального контекста XDTOFactory.ReadXML (ФабрикаXDTO). Согласно созданному ранее XDTO пакету, все объекты XDTO будут находиться в "контейнере" Objects.Object, который может быть как списоком XDTO (если объектов больше 1) так и объектом XDTO (если объект в списке 1). Поэтому поместим все объекты XDTO в массив, с которым будем работать в дальнейшем. Так как в данном примере известно, что от клиента может прийти только документ, то при переборе массива объектов XDTO по имени объекта определяем тип текущего объекта и если это документ, то  вызываем метод FindCreateSupplierInvoice (сниппет метода далее). После перебора всех элементов массива заканчиваем чтение сообщения обмена и возвращаем ответ инициатору обмена.

SupplierInvoice = Documents.SupplierInvoice.GetRef(New UUID(XDTOSupplierInvoice.Id));
If Not CommonUse.IsRefExist(SupplierInvoice) Then
	SupplierInvoiceObject = Documents.SupplierInvoice.CreateDocument();
	SupplierInvoiceObject.SetNewObjectRef(SupplierInvoice);
	SupplierInvoiceObject.Company = SenderNode.Company;
Else
	SupplierInvoiceObject = SupplierInvoice.GetObject();
	SupplierInvoiceObject.Inventory.Clear();
EndIf; 

FillPropertyValues(SupplierInvoiceObject, XDTOSupplierInvoice, "Date,Number");

SupplierInvoiceObject.Counterparty = Catalogs.Counterparties.GetRef(New UUID(XDTOSupplierInvoice.Counterparty));

XDTOInventory = XDTOObjectsToArray(XDTOSupplierInvoice.Inventory, "InventoryItem");
For Each XDTOInventoryItem In XDTOInventory Do
	
	Item = SupplierInvoiceObject.Inventory.Add();
	Item.Product = Catalogs.Products.GetRef(New UUID(XDTOInventoryItem.Product));
	Item.Quantity = XDTOInventoryItem.Quantity;
	
EndDo; 

SupplierInvoiceObject.DataExchange.Sender = SenderNode;
SupplierInvoiceObject.DataExchange.Load = True;

SupplierInvoiceObject.Write();
If SupplierInvoiceObject.DeletionMark <> XDTOSupplierInvoice.DeletionMark Then
	SupplierInvoiceObject.SetDeletionMark(XDTOSupplierInvoice.DeletionMark);	
EndIf; 

Рассмотрим сниппет, который преобразует данные XDTO объекта в прикладной объект конфигурации (документ). Сначала пробуем получить ссылку на документ по ИД. Если ссылка существует, то получим объект от этой ссылки, в противном случае создадим новый документ и присвоим ему ссылку, которая пришла по обмену. Далее заполним атрибуты шапки и табличную часть документа, установим свойство Загрузка в истину и запишем документ с учетом пометки удаления. На этом алгоритм импорта данных готов. 

Реализуем алгоритм экспорта данных. Из модуля веб сервиса вызовем функцию общего модуля, в которую передадим в качестве параметра - параметр метода веб сервиса.

Response = New Structure("Status, Message, Data", 1, "", "");

NodeRecipient = ExchangePlans.NoRull.FindByCode(NodeId);

XDTOTypeObjects = XDTOFactory.Type(URI(), "Objects");
XDTOTypeObject  = XDTOTypeObjects.Properties.Get("Object").Type;
XDTOTypeSupplierInvoice = XDTOFactory.Type(URI(), "SupplierInvoice");

XDTOObjects = XDTOFactory.Create(XDTOTypeObjects);	

RecordOfMessage = ExchangePlans.CreateMessageWriter();
Record = New XMLWriter;
Record.SetString("UTF-8");
RecordOfMessage.BeginWrite(Record, NodeRecipient);

Selection = ExchangePlans.SelectChanges(RecordOfMessage.Recipient, RecordOfMessage.MessageNo);
While Selection.Next() Do
	
	Object = Selection.Get();
	
	If TypeOf(Object) = Type("CatalogObject.Counterparties") Then
		XDTOObject = XDTOCounterparty(Object);		
	ElsIf TypeOf(Object) = Type("CatalogObject.Products") Then
		XDTOObject = XDTOProduct(Object);	
	ElsIf TypeOf(Object) = Type("DocumentObject.SupplierInvoice") Then
		XDTOObject = XDTOSupplierInvoice(Object);	
	Else
		// unknown type
		Continue;		   
	EndIf; 
	
	XDTOObjects.Object.Add(XDTOObject);
	
EndDo;

XDTOFactory.WriteXML(Record, XDTOObjects);

RecordOfMessage.EndWrite();
ExchangeData = Record.Close();

Data = CommonUse.StringToBase64String(ExchangeData);	

Response.Data = Data;

Return CommonUse.DataToJSON(Response);

Данный метод подготавливает список XDTO Objects.Object согласно зарегистрированным изменениям для узла обмена, ссылку на который находим по переданному коду узла. Затем с помощью XDTOFactory.WriteXML (ФабрикаXDTO.ЗаписатьXML) сериализуем подготовленный список и записываем его как тело сообщения. После завершаем запись сообщения обмена и упаковываем сообщение в строку Base64 формата. Отправляем ответ в формате json инициатору.

Реализуем алгоритм вызова веб сервиса со стороны клиента. Для этого в общей форме ExchangeManagement добавим команду, которая будет вызывать метод ExecuteExchange общего модуля, и реквизит формы, в котором будем указывать адрес опубликованной на веб сервере базы сервера.

ExchangeResult = New Structure("Status, Message, Data", 1, "", "");

Proxy = CommonUse.WebServiceProxy(DataBaseAddress, ExchangeResult);
If Proxy = Undefined Then
	Return ExchangeResult;	
EndIf; 

Result = ExportData(Proxy);
If Result.Status = 0 Then
	ExchangeResult.Status = 0;
	ExchangeResult.Message = Result.Message;
	Return ExchangeResult;
EndIf; 

Result = ImportData(Proxy);
If Result.Status = 0 Then
	ExchangeResult.Status = 0;
	ExchangeResult.Message = Result.Message;
	Return ExchangeResult;
EndIf; 

ExchangeResult.Message = NStr("en = 'The exchange was successful.'; ru = 'Обмен выполнен успешно.'");
Return ExchangeResult

Сначала получаем WSPorxy веб сервиса. Далее процедуры экспорта и импорта данных практически такие же как и в Trade, с той разницей, что при экспорте данных вызывается метод веб сервиса ImportData (то есть клиент данные экспортирует, а сервер их импортирует), а при импорте данных вызывается метод веб сервиса ExportData (сервер данные экспоритрует, а клиент импортирует), а также фабрика xdto используется от объекта WSPorxy.

Заключение

Каждый из рассмотренных трех вариантов реализации синхронизации данных хорош для конктертной задачи. Но на практике, как правило, используется 3 вариант (обмен с мобильным устройством или сайтом). Приведенный алгоритм реализации вполне работоспособный, но есть ряд фич, которые могут быть добавлены:

• Обработка сбоев
• Асинхронный обмен
• Кэширование
• Коды доступа приложений (мобильные устройства)
• Перенос данных регистров
• Удаление объектов
• Отложенное проведение документов
• Коллизии при обмене
• Передача и сжатие больших объемов данных

Если материал вызовет достаточный интерес в комьюнити, то сделаю продолжение по вышеозвученным фичам.

В архивах данной публикации можно найти конфигурации всех трех вариантов обмена со всеми формами и методами, код которых не был добавлен в данный материал по причине его объемности.

Третий вариант обмена доступен на github.