Пример создания bridge (http api - tcp) для ККТ "Касса №1" ("К1-Ф")

Публикация № 1022617

Программирование - Практика программирования

К1-Ф python http web ККТ Касса№1 api ФР

5
Пример создания bridge (http api - tcp) для ККТ "Касса №1" ("К1-Ф"). Данная статья будет полезна интеграторам, программистам, тем кто работает (интегрирует, разрабатывает) различное ТО либо железки. Версия и релиз технологической платформы не имеет значения.

Пример создание http сервера для работы с различным торговым оборудованием.

В статье рассматривается пример для фр - ККТ "Касса №1" ("К1-Ф").

Задача:

Есть bitrix-сайт(1С Битрикс). Подключили эквайринг СБ, купили фр К1-Ф, нужно связать.

 

Отступление:

1. Да я знаю, что эквайринг СБ совместно с ГК Атол предоставляет возможность пробивать чеки.(Проектировал не я, что имеем, то имеем (bitrix-сайт, php-модуль для СБ, всё это на хостинге, с одной стороны, и с другой где-то в офисе воткнута в сеть К1-Ф)).

2. Хотя и у К1-Ф есть web админка, я не нашел доков по http методам, искал здесь:

http://www.kassa.astralnalog.ru/docs, http://v8.1c.ru/to/k1f/, на сайте производителя, итс и тд.

3. Да я знаю, как можно сделать в модуле php get/post и тд, сделано все таки разделение: php пишет в базу об оплате, python читает, при добавлении новых пробивает чек. Отслеживание происходит через запрос в бд источника с передачей в параметре последнего ид, и дальнейшего прохода по выборке для пробития. 

 

В статье рассматриваются следующие компоненты:

1. Создание эмулятора интерфейса команд ФР (нужен для теста, и вообще понять какой формат обмена)

2. Создание Web(HTTP) сервера для работы c ФР (фактически проксирование с HTTP на TCP, + некоторая инкапсуляция методов для работы, об этом ниже)

3. Разработка клиентской части (пример чтения таблиц mysql(источник на стороне хоста), пример пробития, пример записи результата в sql lite(приемник на стороне офиса))

 

Шаг 0. Протокол обмена ФР.

Обмен с ФР проходит по TCP(ФР - TCP сервер), по заданному формату. Формат - JSON(UTF-8), структура сообщения - первые 4 байта длина сообщения, с 5-го - сообщение.

Структура команд будет описана ниже.

 

Шаг 1. Эмулятор ФР.

 
 main.py

TCP сервер, описание по основным моментам делал в прошлой статье.

 
 protocol.py

 RESPONSE - соответствие имя команды - структура ответа. Формирование сообщения к отправке делается так:

message = message.encode('utf-8')

len_message = len(message)
    
len_message = len_message.to_bytes(OFSSET, byteorder='big', signed=True)

return len_message + bytes(message)

to_bytes - инт в байт с учетом оффсета(у нас 4 первых из протокола)

len_message + bytes(message) - само сообщение в байтах.

От производителя шла утилита работы.

Пример работы:

 

Шаг 2. HTTP апи сервер.

В качестве web сервера используется flask описание по основным моментам делал в прошлой статье.

 
 main.py
 
 server/__init__.py
 
 server/conf.py

SERVER = ('192.168.1.99', 49152) - адрес\порт фр

LOGIN = 'LOGIN' - по дефолту admin
PASSWORD = 'PASSWORD'  - по дефолту 12
CON_PASSWORD = 'CON_PASSWORD' - меняется в админке

OPER_LIST - массив реализованных операций фр

 
 server/view.py

Енд поинты апи.

Итак, перед тем как отправить команду на фр(например пробитие чека) нужно:

1. Установить tcp соединение ("физическое соединение")

2. Получить ключ сеанса ("логическое соединение", установить сессию)

3. Выполнить команду (пробитие чека)

4. Разорвать, закрыть сессию ("логическое соединение")

Выше было упомянуто про инкапсуляцию, имелось ввиду вот что:

Для пробития чека, этап(3) (метод в коде "make_payment") логически выглядит как:

1. Получить статус фр

2. Если смена превысила 24 час, тогда закрыть

3. Если смена не открыта, тогда открыть

4. Открыть чек

5. Добавить позиции

6. Закрыть чек

при этом все выполняется в рамках одной сессии.

make_payment - принимает в теле пост запроса структуру JSON (о ней ниже).

 
 server/fisc_reg_exchange.py

Дозаполнение полей, приведение к формату для работы с ФР, ну типа (d['paymentFormCode'] = data['payment_form_code'] и тд).

TCP клиент:

 sock = socket.socket()
 sock.connect(SERVER)

+ код для формирования сообщения.

 
 client_sample.py

Пример для тестов(клиент)

Пример работы:

 

Шаг 3. Клиент.

 
 main.py

connection = pymysql/sqlite3.connect(... - установка соединения с базой источником

res = cursor.execute(query_text, ) - выполнение запроса

cursor.executemany('INSERT INTO operations values (?,?,?,?)', rows) - вставка в базу приемник

остальное было выше

 
 operations.db.sql

Структура базы приемника

Пример работы всех компонентов вместе:

 

 
 start.sh

 

Так же возможно писать не в tcp порт, а на пример в com, в pipe, в блочное устройство(файл в терминах linux)

5

См. также

Специальные предложения

Избранное Подписка Сортировка: Древо
В этой теме еще нет сообщений.
Оставьте свое сообщение