1c/OpenIntegrations
1
0
Fork 0
mirror of https://github.com/Bayselonarrend/OpenIntegrations.git synced 2024-12-12 11:15:07 +02:00
Code Issues Releases Activity

Преобразование OPI -> OInt (workflow)

Browse Source
This commit is contained in:
Vitaly the Alpaca 2024-04-04 12:04:27 +00:00 committed by Vitaly the Alpaca (bot)
parent 2bccc4a6d1
commit 7e9582db84
2 changed files with 142 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

122
OInt/core/Modules/OPI_GoogleDrive.os
View File

@ -515,8 +515,7 @@
OPI_ПреобразованиеТипов.ПолучитьКоллекцию(Описание);
КонецЕсли;
СоответствиеФайла = Новый Соответствие;
MimeType = "mimeType";
MimeType = "mimeType";
Если ЗначениеЗаполнено(Идентификатор) Тогда
MIME = ПолучитьИнформациюОбОбъекте(Токен, Идентификатор)[MimeType];
@ -528,18 +527,35 @@
Описание = Новый Соответствие;
КонецЕсли;
Заголовки = OPI_GoogleWorkspace.ПолучитьЗаголовокАвторизации(Токен);
URL = "https://www.googleapis.com/upload/drive/v3/files?uploadType=multipart";
Заголовки = OPI_GoogleWorkspace.ПолучитьЗаголовокАвторизации(Токен);
СформироватьПараметрыЗагрузкиФайла(Описание);
ОписаниеJSON = OPI_Инструменты.JSONСтрокой(Описание);
Если ЗначениеЗаполнено(Файл) Тогда
СоответствиеФайла = Новый Соответствие;
OPI_ПреобразованиеТипов.ПолучитьДвоичныеДанные(Файл);
СоответствиеФайла.Вставить(Файл, MIME);
КонецЕсли;
Размер = Файл.Размер();
РазмерЧасти = 536870912;
СформироватьПараметрыЗагрузкиФайла(Описание);
Описание = OPI_Инструменты.JSONСтрокой(Описание);
Если Размер < РазмерЧасти * 2 Тогда
Ответ = ЗагрузитьМалыйФайл(ОписаниеJSON, СоответствиеФайла, Заголовки, Идентификатор);
Иначе
Ответ = ЗагрузитьБольшойФайл(Описание, СоответствиеФайла, Заголовки, Идентификатор);
КонецЕсли;
КонецЕсли;
Возврат Ответ;
КонецФункции
Функция ЗагрузитьМалыйФайл(Знач Описание, Знач СоответствиеФайла, Знач Заголовки, Знач Идентификатор = "")
URL = "https://www.googleapis.com/upload/drive/v3/files?uploadType=multipart";
Если ЗначениеЗаполнено(Идентификатор) Тогда
URL = СтрЗаменить(URL, "/files", "/files/" + Идентификатор);
@ -547,6 +563,98 @@
Иначе
Ответ = OPI_Инструменты.PostMultipartRelated(URL, Описание, СоответствиеФайла, Заголовки);
КонецЕсли;
Возврат Ответ;
КонецФункции
Функция ЗагрузитьБольшойФайл(Знач Описание, Знач СоответствиеФайла, Знач Заголовки, Знач Идентификатор = "")
Для Каждого Файл Из СоответствиеФайла Цикл
Двоичные = Файл.Ключ;
Прервать;
КонецЦикла;
РазмерЧасти = 536870912;
URL = "https://www.googleapis.com/upload/drive/v3/files?uploadType=resumable";
Ответ = OPI_Инструменты.Post(URL, Описание, Заголовки, Истина, Истина);
АдресЗагрузки = Ответ.Заголовки["Location"];
Если Не ЗначениеЗаполнено(АдресЗагрузки) Тогда
Возврат Ответ;
КонецЕсли;
Поток = Двоичные.ОткрытьПотокДляЧтения();
ЧтениеДанных = Новый ЧтениеДанных(Поток);
ТекущаяПозиция = 0;
ОбщийРазмер = Поток.Размер();
СтрОбщийРазмер = OPI_Инструменты.ЧислоВСтроку(ОбщийРазмер);
Пока Поток.ТекущаяПозиция() < ОбщийРазмер - 1 Цикл
Поток.Перейти(ТекущаяПозиция, ПозицияВПотоке.Начало);
Результат = ЧтениеДанных.Прочитать(РазмерЧасти);
ТекущиеДанные = Результат.ПолучитьДвоичныеДанные();
РазмерТекущих = ТекущиеДанные.Размер();
СледующаяПозиция = ТекущаяПозиция + РазмерТекущих - 1;
Если Не ЗначениеЗаполнено(ТекущиеДанные) Тогда
Прервать;
КонецЕсли;
ЗаголовокПотока = "bytes "
+ OPI_Инструменты.ЧислоВСтроку(ТекущаяПозиция)
+ "-"
+ OPI_Инструменты.ЧислоВСтроку(СледующаяПозиция)
+ "/"
+ СтрОбщийРазмер;
ДопЗаголовки = Новый Соответствие;
ДопЗаголовки.Вставить("Content-Length", OPI_Инструменты.ЧислоВСтроку(РазмерТекущих));
ДопЗаголовки.Вставить("Content-Range" , ЗаголовокПотока);
ДопЗаголовки.Вставить("Content-Type" , "application/octet-stream");
Ответ = OPI_Инструменты.Put(АдресЗагрузки, ТекущиеДанные, ДопЗаголовки, Ложь, Истина);
Если Ответ.КодСостояния >= 400 И Ответ.КодСостояния < 600 Тогда
ЗаголовокПотока = "bytes */" + СтрОбщийРазмер;
ДопЗаголовки.Вставить("Content-Range" , ЗаголовокПотока);
ОтветПроверки = OPI_Инструменты.Put(АдресЗагрузки, "", ДопЗаголовки, Ложь, Истина);
Если ОтветПроверки.КодСостояния >= 200 И ОтветПроверки.КодСостояния < 300 Тогда
Возврат ОтветПроверки;
ИначеЕсли ОтветПроверки.КодСостояния = 308 Тогда
ЗагруженныеДанные = Ответ.Заголовки["Range"];
Иначе
Возврат Ответ;
КонецЕсли;
Иначе
ЗагруженныеДанные = Ответ.Заголовки["Range"];
КонецЕсли;
Если Не ЗначениеЗаполнено(ЗагруженныеДанные) Тогда
Возврат Ответ;
КонецЕсли;
ЗагруженныеДанные = СтрЗаменить(ЗагруженныеДанные, "bytes=", "");
МассивИнформации = СтрРазделить(ЗагруженныеДанные, "-", Ложь);
Если Не МассивИнформации.Количество() = 2 Тогда
Возврат Ответ;
КонецЕсли;
ТекущаяПозиция = Число(МассивИнформации[1]) + 1;
СтрТекущаяПозиция = OPI_Инструменты.ЧислоВСтроку(ТекущаяПозиция);
Процент = Строка(Цел(ТекущаяПозиция / ОбщийРазмер) * 100);
Сообщить(СтрТекущаяПозиция + "/" + СтрОбщийРазмер + " (" + Процент + ")");
КонецЦикла;
Возврат Ответ;

38
OInt/tools/Modules/internal/Modules/OPI_Инструменты.os
View File

@ -48,16 +48,16 @@
#Область ЗапросыСТелом
Функция Post(Знач URL, Знач Параметры = "", Знач ДопЗаголовки = "", Знач JSON = Истина) Экспорт
Возврат ВыполнитьЗапросСТелом(URL, "POST", Параметры, ДопЗаголовки, JSON);
Функция Post(Знач URL, Знач Параметры = "", Знач ДопЗаголовки = "", Знач JSON = Истина, Знач ПолныйОтвет = Ложь) Экспорт
Возврат ВыполнитьЗапросСТелом(URL, "POST", Параметры, ДопЗаголовки, JSON, ПолныйОтвет);
КонецФункции
Функция Patch(Знач URL, Знач Параметры = "", Знач ДопЗаголовки = "", Знач JSON = Истина) Экспорт
Возврат ВыполнитьЗапросСТелом(URL, "PATCH", Параметры, ДопЗаголовки, JSON);
Функция Patch(Знач URL, Знач Параметры = "", Знач ДопЗаголовки = "", Знач JSON = Истина, Знач ПолныйОтвет = Ложь) Экспорт
Возврат ВыполнитьЗапросСТелом(URL, "PATCH", Параметры, ДопЗаголовки, JSON, ПолныйОтвет);
КонецФункции
Функция Put(Знач URL, Знач Параметры = "", Знач ДопЗаголовки = "", Знач JSON = Истина) Экспорт
Возврат ВыполнитьЗапросСТелом(URL, "PUT", Параметры, ДопЗаголовки, JSON);
Функция Put(Знач URL, Знач Параметры = "", Знач ДопЗаголовки = "", Знач JSON = Истина, Знач ПолныйОтвет = Ложь) Экспорт
Возврат ВыполнитьЗапросСТелом(URL, "PUT", Параметры, ДопЗаголовки, JSON, ПолныйОтвет);
КонецФункции
#КонецОбласти
@ -300,7 +300,7 @@
#Область СлужебныеПроцедурыИФункции
Функция ВыполнитьЗапросСТелом(Знач URL, Знач Вид, Знач Параметры = "", Знач ДопЗаголовки = "", Знач JSON = Истина)
Функция ВыполнитьЗапросСТелом(Знач URL, Знач Вид, Знач Параметры = "", Знач ДопЗаголовки = "", Знач JSON = Истина, Знач ПолныйОтвет = Ложь)
Если Не ЗначениеЗаполнено(Параметры) Тогда
Параметры = Новый Структура;
@ -321,7 +321,7 @@
Если ЭтоПереадресация(Ответ) Тогда
Ответ = ВыполнитьЗапросСТелом(Ответ.Заголовки["Location"], Вид, Параметры, ДопЗаголовки, JSON);
Иначе
ОбработатьОтвет(Ответ);
ОбработатьОтвет(Ответ, ПолныйОтвет);
КонецЕсли;
Возврат Ответ;
@ -485,13 +485,19 @@
Переадресация = 300;
Ошибка = 400;
ЭтоПереадресация = Ответ.КодСостояния >= Переадресация И Ответ.КодСостояния < Ошибка;
ЭтоПереадресация = Ответ.КодСостояния >= Переадресация
И Ответ.КодСостояния < Ошибка
И ЗначениеЗаполнено(Ответ.Заголовки["Location"]);
Возврат ЭтоПереадресация;
КонецФункции
Процедура ОбработатьОтвет(Ответ)
Процедура ОбработатьОтвет(Ответ, Знач ПолныйОтвет = Ложь)
Если ПолныйОтвет Тогда
Возврат;
КонецЕсли;
GZip = "gzip";
НужнаРаспаковка =
@ -518,14 +524,24 @@
Процедура УстановитьТелоЗапроса(Запрос, Знач Параметры, Знач JSON)
Коллекция = ТипЗнч(Параметры) = Тип("Структура")
Или ТипЗнч(Параметры) = Тип("Соответствие")
Или ТипЗнч(Параметры) = Тип("Массив");
Если JSON Тогда
Данные = JSONСтрокой(Параметры);
ИначеЕсли Не Коллекция Тогда
Данные = Параметры;
Иначе
СтрокаПараметров = ПараметрыЗапросаВСтроку(Параметры);
Данные = Прав(СтрокаПараметров, СтрДлина(СтрокаПараметров) - 1);
КонецЕсли;
Запрос.УстановитьТелоИзСтроки(Данные);
Если ТипЗнч(Данные) = Тип("Строка") Тогда
Запрос.УстановитьТелоИзСтроки(Данные);
Иначе
Запрос.УстановитьТелоИзДвоичныхДанных(Данные);
КонецЕсли;
КонецПроцедуры