Скрипт для обмена между двумя базами УРБД на Java-Script

В начале кода нужно для каждой базы прописать:

• Путь к базе
• Имя пользователя
• Пароль

Дополнительно нужно прописать:

• Имя файла обмена из базы 1 в базу 2 и наоборот
• Название узла обмена базы 1 в базе 2 и наоборот
• Название плана обмена
• Путь к базе 1с

Внимание! Во всех путях символ бэкслеш «» нужно повторять дважды, так: «\»!

Код нужно сохранить в файл с расширением js и можно запускать.

Вот код, делюсь:

//=== Главная программа ===
//Настройки программы

//База 1 - главная
var Base1User = "Осипов";  //Имя пользователя
var Base1Password = "..."; //Пароль
var Base1Path = "R:\PIM\1s8"; //Путь к базе

//База 2 - периферийная
var Base2User = "Осипов"; //Имя пользователя
var Base2Password = "..."; //Пароль
var Base2Path = "c:\Осипов\pim1"; //Путь к базе

var FileFrom1To2 = "R:\pim\FromCentrToNode1.xml"; //Имя файла обмена из базы 1 в базу 2
var FileFrom2To1 = "R:\pim\FromNode1ToCentr.xml";//Имя файла обмена из базы 2 в базу 1

var Base1NodeCode = "У1"; //Название узла обмена базы 2 в базе 1
var Base2NodeCode = "Ц"; //Название узла обмена базы 1 в базе 2

var PlanName = "пимПолный"; //Название плана обмена

var App1sFullName = 'C:\Program Files\1cv81\bin\1cv8.exe'; //Путь к программе 1С на компьютере

//Запускаем обновление конфигурации базы 2
UpdateConfig1s(App1sFullName, Base2Path, Base2User, Base2Password);

//Создаем COM-подключения к обеим базам
var Base1COM = Connect1s(Base1Path, Base1User, Base1Password);
var Base2COM = Connect1s(Base2Path, Base2User, Base2Password);

//Создаем ссылки на узлы планы обмена
var Base1Node = Base1COM.ПланыОбмена[PlanName].НайтиПоКоду(Base1NodeCode);
var Base2Node = Base2COM.ПланыОбмена[PlanName].НайтиПоКоду(Base2NodeCode);

//Запускаем выгрузку из базы 1 в базу 2
URBDExchangeWrite(Base1COM, FileFrom1To2, Base1Node);

//Запускаем загрузку в базе 2 из базы 1
URBDExchangeRead(Base2COM, FileFrom1To2);

if (Base2COM .КонфигурацияИзменена()) {
Report("Конфигурация периферийной базы изменена.
 Завершите работу всех пользователей и еще раз запустите обмен!");
WScript.Quit(0);
}

//Запускаем выгрузку из базы 2 в базу 1
URBDExchangeWrite(Base2COM, FileFrom2To1, Base2Node);

//Запускаем загрузку в базе 1 из базы 2
URBDExchangeRead(Base1COM, FileFrom2To1);

Report("Обмен выполнен!");
WScript.Quit(0);

function URBDExchangeWrite(COM, FileName, Node) {
var MessageRecord = COM.ПланыОбмена.СоздатьЗаписьСообщения();
var RecordXML = COM.NewObject("ЗаписьXML");
RecordXML.ОткрытьФайл(FileName);
//Начало записи собщения
MessageRecord.НачатьЗапись(RecordXML, Node);
COM.ПланыОбмена.ЗаписатьИзменения(MessageRecord);
// Запись тела сообщения
MessageRecord.ЗакончитьЗапись();
RecordXML.Закрыть(FileName);
}

function URBDExchangeRead(COM, FileName) {
var MessageRead = COM.ПланыОбмена.СоздатьЧтениеСообщения();
var ReadXML = COM.NewObject("ЧтениеXML");
ReadXML.ОткрытьФайл(FileName);
//Начало записи собщения
MessageRead.НачатьЧтение(ReadXML);
COM.ПланыОбмена.ПрочитатьИзменения(MessageRead);
// Запись тела сообщения
MessageRead.ЗакончитьЧтение();
ReadXML.Закрыть(FileName);
}

function main() {
//Проверяем, чтобы скипт не запускался дважды
var ScriptName = WScript.ScriptName;
if (IsProcessExist(ScriptName)) {
Report('Процесс '+ScriptName+' уже запущен, эта копия будет закрыта!');
WScript.Quit(1);
}

//Проверяем переданные параметры, определяем это основной процесс или дочерний
isCheckConfig = false;
if (WScript.Arguments.Length > 0)
if (WScript.Arguments.Item(0) == "CheckConfig")
isCheckConfig = true;

//Если нужно проверять, изменилась ли конфигурация и запускать автообмен
if (isCheckConfig)
CheckConfig(); //Запускаем дочерний COM-процесс для проверки конфигурации
else
MainProcess();
}

function CheckConfig() {
//Если это проверка конфигурации, дочерний поток
//Дочерний запускается, чтобы  COM-соединение убилось, иначе оно ника не убивается

//Получаем каталог базы
//Report(WScript.ScriptFullName);

//Получаем каталог базы
Report("Запущен дочерний процесс (отчет)");

var Base1s = Connect1s();
//Base1s.ИзвещениеСистемы("Test");
Report("Создано КОМ-соединение " + Base1s);

//Нужно ли обновлять конфигурацию
var isNeedToConfigUpdate = Base1s.НужноЛиОбновлятьКонфигурацию();
Report('Нужно обновлять конфигурацию: ' + isNeedToConfigUpdate);

//Далее, запускаем автообмен силами 1С
//Функция в 1С не должна останавливать скрипт
//Т.е. должна запуски все делать асинхронно
Base1s.ЗапуститьАвтообмен();

//Возвращаем статус
if (isNeedToConfigUpdate)
WScript.Quit(200); //Нужно обновлять
else
WScript.Quit(100);//Не нужно обновлять
}

function Connect1s(Base1sPath, Base1sUser, Base1sPassword) {
//Устанавливаем быстрое COM-соединение с 1С8
var V8 = new ActiveXObject("V81.COMConnector");
//var V8 = new ActiveXObject("V81.Application");
try {
ConnectionString = 'File="' + Base1sPath + '";Usr="' + Base1sUser + '";Pwd="' + Base1sPassword + '"';
var Base1s = V8.Connect(ConnectionString);
} catch(e){
Report('Не удалось создать com-соединение!' + e.description + "
"+ConnectionString);
WScript.Quit(1);
}
return Base1s;

}

function MainProcess() {
//Запуск дочернего процесса
Shell = new ActiveXObject("WScript.Shell");
PathToRun = '"' + WScript.FullName +'" "' + WScript.ScriptFullName + '" CheckConfig';
Report("Команда для запуски дочернего процесса:" + PathToRun);
//Запускаем дочерний процесс и ждем его завершения
var result = Shell.Run(PathToRun,0,true);

//Конфигурацию нужно обновлять, если дочерний поток вернул 200
isNeedToConfigUpdate = (result == 200)

Report("COM-соединение должно умереть, т.к. дочерний поток умер");

//Если нужно обновлять конфигурацию
if (isNeedToConfigUpdate) {
//Несколько секунд ждем, чтобы наверняека
WScript.Sleep(5000);

//Выгнать пользователей
CloseUsers1s();

//Обновить конфигурацию
UpdateConfig1s(App1sFullName, Base1sPath, Base1sUser, Base1sPassword);
}
}

function CloseUsers1s() {
//Убиваем все процессы 1С
var Processing = new ActiveXObject("WbemScripting.SWbemLocator");
var Service = Processing.ConnectServer(".");
var Items  = new Enumerator(Service.ExecQuery("SELECT * FROM Win32_Process WHERE Name = '1cv8.exe'"));

for (Items.moveFirst(); !Items.atEnd(); Items.moveNext()) {
var Item = Items.item();
Item.Terminate(0);
Report('Kill process 1s8'); //удаляем процесс 1с8
}
}

function UpdateConfig1s(App1sFullName, Base1sPath, Base1sUser, Base1sPassword) {
Shell = new ActiveXObject("WScript.Shell");
PathToRun = '"' + App1sFullName + '" config /UpdateDBCfg' + ' /N"' + Base1sUser + '" /P"' + Base1sPassword + '" /F"'+ Base1sPath + '"';
//Report("Команда для обновления конфигурации базы данных :" + PathToRun);
var result = Shell.Run(PathToRun,2,true); //Запускаем команду обновления конфигурациии
//Report("Результат обновления " + result);
WScript.Sleep(5000);
}

//Возвращается путь к файлу FullName, без финального слеша
function GetPathOfFile(FullName) {
var fso = new ActiveXObject('Scripting.FileSystemObject');
return fso.GetParentFolderName(FullName);
}

//Проверяет, существует ли процесс с заданным именем файла
function IsProcessExist(ProcessName) {
var Processing = new ActiveXObject("WbemScripting.SWbemLocator");
var Service = Processing.ConnectServer(".");
//Проверяем запущенный основной процесс, без вызовов самого себя...
var Items  = new Enumerator(Service.ExecQuery("SELECT * FROM Win32_Process WHERE (CommandLine LIKE '%" + ProcessName + "%') AND NOT (CommandLine LIKE '%CheckConfig%')"));

var Count = 0;
for (Items.moveFirst(); !Items.atEnd(); Items.moveNext()) Count++;
Report("Количество процессов " + Count);
return Count > 1;
}

function Report(Msg) {
WScript.Echo(Msg);
}