#!/bin/bash # Настройка ТС ПИоТ на рабочем месте: пакеты, тип кассы, Прим/Штрих, регистрация ЕСМ. # # Один запуск на самом РМ, только от суперпользователя: # sudo bash etp.sh # Скрипт сам проверяет кассу и пакеты, спрашивает про установку, # настраивает, регистрирует и в конце проверяет, что сервисы отвечают. # # Откуда пакеты, от свежего индекса репозитория, не из зашитых версий: # 1) testing # 2) если пакета там нет — current # 3) если нет и там — system11 # esm и esm-lm-controller на 2026-10-12 есть только в system11 # (тот же файл продублирован в system10). В testing и current их нет. # develop не используется. # Если в сюите несколько версий, берётся большая по dpkg --compare-versions. # Уже стоящую более новую версию скрипт не понижает. # # Штрих и Ритейл D3: TYP 2 и 12 меняются на 22. COM и SPEED кассы не трогаются. # Штрих C3 не ниже C3,63074,260602 (июнь 2026). # Ритейл D3 не ниже апреля 2026: живой эталон VER=D3,3469,260417. # Прошивка T3 для ТС ПИоТ не подходит, скрипт на ней останавливается. # Дальше D3 идёт тем же путём, что Штрих. Порт 4042 держит bukkassa. # Если смена закрыта, скрипт спрашивает и шлёт @!SHBEG;TXT=Оператор. # ГИС МТ регистрирует кассу только после этого и только если в самой ККТ # есть лицензия ТС ПИоТ. Без неё касса отвечает кодом 55. # Лицензию скрипт запрашивает у ИТС Посцентра так же, как кнопки FRS # на azs2343 14.10.2026: сведения о ККТ, параметр модели 79, заводской # номер из таблицы 18, состояние ККТ, чтение лицензий, затем # ITSLicenseIssue с allow_trial=false. Если в кассе блок версии 0 и ИТС # отвечает «новой лицензии нет», скрипт записывает триал и спрашивает, # ждать ли оплаченную. Если да — раз в минуту запрос и снова вопрос, # не дольше 8 минут. Если нет — остаётся триал, регистрация идёт дальше. # Чужой блок не подставляется. # Если console_test_fr_drv_ng нет, скрипт ставит пакет bukts-dkkt из apt. # Так для Штрих и Ритейл D3. Линейка T3 не используется. # # Прим: TYP 1 и 11 не меняются. # Образец 172.24.132.19: /etc/opt/bukts-dkkt/iskra/config.xml # физический порт из bukts-kassa.cfg и скорость 19200, # затем в bukts-kassa.cfg COM=127.0.0.1 и SPEED=65501 (это listenPort драйвера). # В STAT Прима версии нет. Драйвер Искра пишет её в /var/log/dkkt/dkkt.log. # Минимум с 172.24.132.19: 7.2LPC08 01-01-26. Ниже — установка останавливается. # # Если есть /etc/opt/bukts/conf/bukts-kassa.cfg, кассу правит веб. # Скрипт этот файл и основной bukts-kassa.cfg тогда не переписывает. # # bukts-loader перезапускает только если касса должна перечитать тип или порт. # Открытые заправки при этом не проверяет. # Не делает: закрытие смены, dpkg --purge esm # (postrm esm выполняет rm -rf /opt/esp и сносит esm-lm-controller). set -euo pipefail REPO="${REPO:-http://repo-tn.bukts.ru}" API="${API:-http://127.0.0.1:51077}" CACHE="${CACHE:-/var/cache/esm-tspiot}" BACKUP_DIR="${BACKUP_DIR:-/var/backups/esm-tspiot-setup}" GIS_WAIT="${GIS_WAIT:-180}" ONLY_ZN="" CHECK=0 ASSUME_YES=0 SKIP_REGISTER=0 ORIG_ARGS=("$@") KASSA_MAIN="/etc/opt/bukts/bukts-kassa.cfg" KASSA_CONF="/etc/opt/bukts/conf/bukts-kassa.cfg" KASSA_ENABLED="/etc/opt/bukts/conf/.enabled" CHZNAK_INI="/etc/opt/bukts-chznak/config.ini" ISKRA_XML="/etc/opt/bukts-dkkt/iskra/config.xml" ISKRA_SAMPLE="/etc/opt/bukts-dkkt/samples/iskra/config.xml" NEED_PKGS=(esm esm-lm-controller bukts-kassa bukts-chznak bukts-dkkt) MIN_FW="C3,63074,260602" MIN_FW_D="D3,0,260401" MIN_FW_PRIM="7.2LPC08 01-01-26" SHTRIH_FW_DONE=0 FW_VER="" PRIM_FW_DONE=0 LOADER_PENDING="/var/lib/esm-tspiot-setup/loader-restart-pending" INSTALL_ORDER=(esm esm-lm-controller bukts-kassa bukts-chznak bukts-dkkt) if [[ -t 1 ]]; then B=$'\033[1m'; G=$'\033[32m'; Y=$'\033[33m'; R=$'\033[31m'; Z=$'\033[0m' else B=""; G=""; Y=""; R=""; Z="" fi stamp() { date '+%H:%M:%S'; } say() { printf '%s\n' "$(stamp) $*"; } log() { say "${B}==>${Z} $*"; } ok() { say "${G} ok${Z} $*"; } warn() { say "${Y} !!${Z} $*" >&2; } die() { say "${R}ошибка:${Z} $*" >&2; exit 1; } stop() { say "${Y}стоп:${Z} $*" >&2; exit 1; } usage() { cat <<'EOF' Запуск возможен только от суперпользователя: sudo bash esm-tspiot-setup.sh Один запуск: проверка кассы, проверка пакетов, вопрос про установку или обновление, настройка, регистрация и проверка ответов сервисов. --yes ставить недостающие пакеты без вопроса --zn ЗН зарегистрировать только эту кассу --wait СЕКУНД ожидание регистрации в ГИС МТ (по умолчанию 180) -h, --help эта справка Для Штриха касса занимается на пару секунд, порт сразу закрывается. EOF } while [[ $# -gt 0 ]]; do case "$1" in --check) CHECK=1; shift ;; --yes) ASSUME_YES=1; shift ;; --skip-register) SKIP_REGISTER=1; shift ;; --zn) [[ $# -ge 2 ]] || die "--zn требует заводской номер" ONLY_ZN="$2" shift 2 ;; --wait) [[ $# -ge 2 ]] || die "--wait требует число секунд" GIS_WAIT="$2" shift 2 ;; --repo) [[ $# -ge 2 ]] || die "--repo требует URL" REPO="${2%/}" shift 2 ;; -h|--help) usage; exit 0 ;; *) die "неизвестный аргумент: $1 (см. --help)" ;; esac done [[ "$GIS_WAIT" =~ ^[0-9]+$ ]] || die "--wait должен быть целым числом секунд" if [[ "$(id -u)" -ne 0 ]]; then printf '%s\n' "Запуск возможен только от суперпользователя." >&2 exit 1 fi need() { command -v "$1" >/dev/null 2>&1 || die "нет команды $1"; } pkg_ver() { dpkg-query -W -f='${Version}' "$1" 2>/dev/null || true; } pkg_installed() { local status status="$(dpkg-query -W -f='${Status}' "$1" 2>/dev/null || true)" [[ "$status" == "install ok installed" ]] } ask_yes() { local answer if [[ "$ASSUME_YES" == 1 ]]; then log "передан --yes, пакеты ставятся без вопроса" return 0 fi [[ -r /dev/tty ]] || die "нет терминала для вопроса. Запустите в консоли или добавьте --yes" while true; do printf '%s' "Установить или обновить эти пакеты? [да/нет]: " >/dev/tty IFS= read -r answer /dev/tty ;; esac done } repo_testing_configured() { ( shopt -s nullglob local file for file in /etc/apt/sources.list /etc/apt/sources.list.d/*.list /etc/apt/sources.list.d/*.sources; do [[ -f "$file" ]] || continue if grep -Eq '^[[:space:]]*deb[[:space:]].*[[:space:]]testing[[:space:]]+bukts([[:space:]]|$)' "$file"; then exit 0 fi done exit 1 ) } enable_commented_testing() { local file changed=0 shopt -s nullglob for file in /etc/apt/sources.list /etc/apt/sources.list.d/*.list; do [[ -f "$file" ]] || continue if grep -Eq '^[[:space:]]*#[[:space:]]*deb[[:space:]].* testing bukts' "$file"; then sed -i -E '/^[[:space:]]*#[[:space:]]*deb[[:space:]].* testing bukts/ s/^[[:space:]]*#[[:space:]]*//' "$file" changed=1 log "включил закомментированный testing в ${file}" fi done shopt -u nullglob [[ "$changed" == 1 ]] } run_repo_script() { local tmp tmp="$(mktemp /tmp/update_repo_test.XXXXXX.sh)" log "в apt нет сюиты testing, скачиваю update_repo_test.sh" curl -fsS -m 40 -o "$tmp" "http://bukts.ru/files/service/update/update_repo_test.sh" \ || stop "Не скачался http://bukts.ru/files/service/update/update_repo_test.sh" chmod 755 "$tmp" log "подключаю testing, current и system. Скрипт перепишет /etc/apt/sources.list, прежний файл сохранится рядом как .bak-*" bash "$tmp" || stop "update_repo_test.sh завершился с ошибкой" } apt_refresh() { if ! repo_testing_configured; then if [[ "$CHECK" == 1 ]]; then log "[check] активного testing нет, включил бы его или запустил update_repo_test.sh" elif enable_commented_testing; then ok "testing включён в уже существующем списке, debian sources.list не трогаю" else run_repo_script fi else ok "репозиторий testing в apt уже подключён" fi if [[ "$CHECK" == 1 ]] && ! repo_testing_configured; then warn "без репозитория testing версии пакетов по apt не смотрю" return 1 fi log "apt-get update" if apt-get update -o Acquire::http::Timeout=40; then return 0 fi # Часы кассы иногда отстают на несколько секунд, и Release «ещё не действителен». warn "apt-get update не прошёл, повторяю через 20 с" sleep 20 if apt-get update -o Acquire::http::Timeout=40; then return 0 fi if [[ "$CHECK" == 1 ]]; then warn "apt-get update не прошёл" return 1 fi if repo_testing_configured; then stop "apt-get update не прошёл. testing в bukts.list уже есть, sources.list не переписываю." fi warn "в apt нет сюиты testing, подключаю репозитории" run_repo_script apt-get update -o Acquire::http::Timeout=40 || stop "apt-get update не прошёл и после update_repo_test.sh" } apt_policy_field() { local pkg="$1" label="$2" value value="$(apt-cache policy "$pkg" 2>/dev/null | awk -v label="$label" '$1 == label { print $2; exit }')" printf '%s\n' "$value" } # Версия из testing, если пакет там есть. Иначе current, иначе system. # develop не берём, даже если apt считает его кандидатом. apt_desired_version() { apt-cache madison "$1" 2>/dev/null | python3 -c ' import subprocess, sys rows = [] for line in sys.stdin: parts = [p.strip() for p in line.split("|")] if len(parts) < 3: continue ver, source = parts[1], parts[2].lower() if "develop" in source: continue if "testing" in source: rank = 0 elif "current" in source: rank = 1 elif "system" in source: rank = 2 else: rank = 3 rows.append((rank, ver)) if not rows: sys.exit(0) best_rank = min(r[0] for r in rows) cands = [ver for rank, ver in rows if rank == best_rank] def gt(a, b): return subprocess.call(["dpkg", "--compare-versions", a, "gt", b]) == 0 best = cands[0] for ver in cands[1:]: if gt(ver, best): best = ver print(best) ' } pkg_binary_ok() { case "$1" in esm) [[ -x /opt/esp/esm/bin/controlmodule ]] ;; esm-lm-controller) [[ -x /opt/esp/lmcontroller/bin/lmcontroller ]] ;; bukts-dkkt) find_fr_drv >/dev/null ;; *) return 0 ;; esac } install_planned() { local pkg have cand reason need_any=0 missing_repo=0 local -a specs=() local reinstall=0 need_any=0 say "Сверяю установленные версии с кандидатом apt после update." for pkg in "${INSTALL_ORDER[@]}"; do have="$(pkg_ver "$pkg")" cand="$(apt_desired_version "$pkg")" if [[ -z "$cand" || "$cand" == "(none)" ]]; then warn "пакета ${pkg} нет в подключённых репозиториях" missing_repo=1 continue fi if [[ -z "$have" || "$have" == "(none)" ]] || ! pkg_installed "$pkg"; then say " ${pkg}: не установлен -> ${cand}" specs+=("${pkg}=${cand}") need_any=1 continue fi if dpkg --compare-versions "$have" gt "$cand"; then warn "${pkg} ${have} новее кандидата apt ${cand}, версию не понижаю" continue fi if dpkg --compare-versions "$have" lt "$cand"; then say " ${pkg}: ${have} -> ${cand}" specs+=("${pkg}=${cand}") need_any=1 continue fi if ! pkg_binary_ok "$pkg"; then say " ${pkg}: версия ${cand} есть, но нет файлов программы" specs+=("${pkg}=${cand}") reinstall=1 need_any=1 continue fi ok "${pkg} ${have}, не старее репозитория" done if [[ "$missing_repo" == 1 ]]; then if [[ "$CHECK" == 1 ]]; then warn "apt не видит часть пакетов. В режиме --check установку не предлагаю" return 0 fi stop "Без пакетов из репозитория продолжать нечем. Проверьте apt-get update и сюиты testing, current и system." fi if [[ "$need_any" == 0 ]]; then ok "нужные пакеты уже стоят и не старее репозитория" return 0 fi say "Это установка недостающих и обновление тех, что старее репозитория." say "Пакет bukts-kassa при установке сам bukts-loader не перезапускает." say "Скрипт пакеты не удаляет: purge esm стирает /opt/esp вместе с esm-lm-controller." if [[ "$CHECK" == 1 ]]; then log "[check] пакеты не ставлю и не обновляю" return 0 fi if ! ask_yes; then say "Остановился. Пакеты не ставил и не обновлял, регистрацию не начинал." say "Когда можно будет установить или обновить их, запустите скрипт ещё раз." exit 0 fi local flag=() if [[ "$reinstall" == 1 ]]; then flag=(--reinstall) fi log "apt-get install ${specs[*]}" local preview preview="$(LANG=C LC_ALL=C apt-get install -s -y --no-install-recommends "${flag[@]}" "${specs[@]}" 2>/dev/null || true)" if printf '%s\n' "$preview" | grep -Eq '^Inst bukts-loader([[:space:]]|$)'; then stop "Это обновление затронет bukts-loader. Во время работы АЗС его не обновляю и не перезапускаю." fi if ! DEBIAN_FRONTEND=noninteractive apt-get install -y --no-install-recommends \ -o Dpkg::Options::=--force-confdef \ -o Dpkg::Options::=--force-confold \ "${flag[@]}" "${specs[@]}"; then warn "повтор установки: libabsl беру из bullseye, зеркало security отдало 404" DEBIAN_FRONTEND=noninteractive apt-get install -y --no-install-recommends \ -o Dpkg::Options::=--force-confdef \ -o Dpkg::Options::=--force-confold \ libabsl20200923/bullseye "${flag[@]}" "${specs[@]}" \ || stop "apt-get install не поставил пакеты" fi if [[ ! -x /opt/esp/lmcontroller/bin/lmcontroller ]] && pkg_installed esm-lm-controller; then stop "esm-lm-controller установлен, а /opt/esp/lmcontroller/bin/lmcontroller нет. Так бывает после purge esm: его postrm делает rm -rf /opt/esp." fi for pkg in "${INSTALL_ORDER[@]}"; do if pkg_installed "$pkg"; then ok "${pkg} $(pkg_ver "$pkg")" fi done } active_kassa_file() { if [[ -f "$KASSA_ENABLED" && -f "$KASSA_CONF" ]]; then printf '%s\n' "$KASSA_CONF" elif [[ -f "$KASSA_MAIN" ]]; then printf '%s\n' "$KASSA_MAIN" else return 1 fi } kassa_get() { local file="$1" key="$2" python3 - "$file" "$key" <<'PY' import re, sys path, key = sys.argv[1], sys.argv[2].upper() rx = re.compile(r'^\s*(?:\d+:)?(?PTYP|COM|SPEED)\s*=\s*(?P\S+)', re.I) found = [] for line in open(path, encoding="utf-8", errors="replace"): line = line.rstrip("\r\n") s = line.strip() if not s or s.startswith("#") or s.startswith(";"): continue m = rx.match(line) if m and m.group("k").upper() == key: found.append(m.group("v").strip().strip('"').strip("'")) if len(set(found)) > 1: sys.stderr.write("несколько значений " + key + ": " + ", ".join(found) + ". Беру последнее, как bukts-dkkt/start.sh\n") print(found[-1] if found else "") PY } backup_file() { local file="$1" mkdir -p "$BACKUP_DIR" cp -a "$file" "${BACKUP_DIR}/$(basename "$file").$(date +%Y%m%d%H%M%S)" } read_firmware() { local rc=0 printf '%s\n' "$(stamp) ==> на пару секунд подключаюсь к кассе 127.0.0.1:65522 и сразу закрываю порт" >&2 python3 - <<'PY' || rc=$? import socket, sys try: s = socket.create_connection(("127.0.0.1", 65522), 3) except OSError as exc: sys.stderr.write(f"connect: {exc}\n") sys.exit(2) s.settimeout(2.5) data = b"" try: s.sendall(b"@!STAT;TYP=1\n") while len(data) < 8000: try: chunk = s.recv(4096) except socket.timeout: break if not chunk: break data += chunk if b"STAT;" in data and b"$" in data.split(b"STAT;", 1)[-1]: break finally: s.close() sys.stdout.buffer.write(data) PY printf '%s\n' "$(stamp) ok порт кассы 65522 закрыт" >&2 return "$rc" } # Кнопка «Открыть смену по кассе» в «Оборудование → Кассовые аппараты» # шлёт на 65522 SHBEG;TXT=<кассир>. Без имени касса смену не открывает. kassa_cmd() { local cmd="$1" LANG=C.UTF-8 python3 - "$cmd" <<'PY' import socket, sys, time cmd = sys.argv[1] deadline = time.time() + 45 try: s = socket.create_connection(("127.0.0.1", 65522), 5) except OSError as exc: sys.stderr.write(f"connect: {exc}\n") sys.exit(2) s.settimeout(5) last = "" buf = b"" try: s.sendall(("@!" + cmd + "\n\0").encode("utf-8")) while time.time() < deadline: try: chunk = s.recv(4096) except socket.timeout: if last: break continue if not chunk: break buf += chunk while b"\n" in buf or b"$" in buf: if b"\n" in buf: raw, buf = buf.split(b"\n", 1) else: raw, _, buf = buf.partition(b"$") raw = raw + b"$" text = raw.decode("utf-8", "replace").strip("\r") if not text: continue last = text if "TCOD=WAIT" in text or "TCOD=DOING" in text: continue sys.stdout.write(text + "\n") sys.exit(0) finally: s.close() if last: sys.stdout.write(last + "\n") sys.exit(0) sys.stderr.write("касса не ответила\n") sys.exit(1) PY } ask_open_shift() { local answer if [[ "$ASSUME_YES" == 1 ]]; then log "передан --yes, открываю смену по кассе" return 0 fi [[ -r /dev/tty ]] || return 1 while true; do printf '%s' "Смена по кассе закрыта. Открыть смену? [да/нет]: " >/dev/tty IFS= read -r answer /dev/tty ;; esac done } find_fr_drv() { local dir bin="" shopt -s nullglob for dir in /opt/bukts-dkkt/poscenter/linux_*/x86_64; do if [[ -x "${dir}/console_test_fr_drv_ng" ]]; then bin="${dir}/console_test_fr_drv_ng" fi done shopt -u nullglob [[ -n "$bin" ]] || return 1 printf '%s\n' "$bin" } # Драйвер Посцентра лежит в пакете bukts-dkkt. На части РМ пакета нет. install_poscenter_driver() { local cand preview cand="$(apt_desired_version bukts-dkkt)" if [[ -z "$cand" || "$cand" == "(none)" ]]; then stop "В apt нет пакета bukts-dkkt. Драйвер Посцентра скачать неоткуда, чужой блок лицензии не подставляю." fi if [[ "$CHECK" == 1 ]]; then log "[check] поставил бы bukts-dkkt=${cand}: в нём console_test_fr_drv_ng" return 0 fi local -a flag=() if pkg_installed bukts-dkkt; then flag=(--reinstall) fi log "драйвера Посцентра нет, ставлю bukts-dkkt=${cand}" preview="$(LANG=C LC_ALL=C apt-get install -s -y --no-install-recommends "${flag[@]}" "bukts-dkkt=${cand}" 2>/dev/null || true)" if printf '%s\n' "$preview" | grep -Eq '^Inst bukts-loader([[:space:]]|$)'; then stop "Установка драйвера Посцентра затронет bukts-loader. Во время работы АЗС его не обновляю." fi if ! DEBIAN_FRONTEND=noninteractive apt-get install -y --no-install-recommends \ -o Dpkg::Options::=--force-confdef \ -o Dpkg::Options::=--force-confold \ "${flag[@]}" "bukts-dkkt=${cand}"; then warn "повтор установки драйвера: libabsl беру из bullseye" DEBIAN_FRONTEND=noninteractive apt-get install -y --no-install-recommends \ -o Dpkg::Options::=--force-confdef \ -o Dpkg::Options::=--force-confold \ libabsl20200923/bullseye "${flag[@]}" "bukts-dkkt=${cand}" \ || stop "Не поставил bukts-dkkt=${cand}. Драйвер Посцентра не скачался." fi find_fr_drv >/dev/null || stop "Пакет bukts-dkkt ${cand} встал, а console_test_fr_drv_ng в нём нет." ok "драйвер Посцентра установлен: $(find_fr_drv)" } ask_free_kassa_port() { local answer if [[ "$ASSUME_YES" == 1 ]]; then log "передан --yes, освобождаю порт кассы для лицензии ИТС" return 0 fi [[ -r /dev/tty ]] || return 1 while true; do printf '%s' "Порт кассы занят. Остановить bukts-loader, запросить лицензию и запустить снова? [да/нет]: " >/dev/tty IFS= read -r answer /dev/tty ;; esac done } # Лицензию берёт драйвер этой кассы у its.pos-center.ru. # В вызов не передаётся готовый блок: он чужой для другого юрлица. fr_drv_run() { local bin="$1" url="$2" shift 2 # Команда идёт первой: `console_test_fr_drv_ng [-a url] [-p password]`. "$bin" "$@" -a "$url" -p 30 } piot_license_missing() { local text="$1" line line="$(printf '%s\n' "$text" | grep -i 'piot' | head -n 1 || true)" [[ -n "$line" ]] || return 2 [[ "$line" == *none* || "$line" == *None* || "$line" == *NONE* ]] } stop_html_test() { if [[ -f /tmp/etp-html-test.pid ]]; then kill "$(cat /tmp/etp-html-test.pid)" 2>/dev/null || true rm -f /tmp/etp-html-test.pid fi pkill -x console_test_fr_drv_ng 2>/dev/null || true sleep 1 } restore_loader_after_its() { stop_html_test [[ "${ITS_LOADER_HELD:-0}" == 1 ]] || return 0 ITS_LOADER_HELD=0 log "запускаю bukts-loader обратно" if [[ -x /etc/init.d/bukts-loader ]]; then /etc/init.d/bukts-loader start || true else systemctl start bukts-loader || true fi } ensure_its_license() { local com="$1" speed="$2" bin url out rc=0 held=0 [[ "$com" == /dev/* ]] || stop "Лицензию ТС ПИоТ запрашиваю только на последовательном порту кассы, сейчас COM=${com}." [[ "$speed" =~ ^[0-9]+$ ]] || stop "В bukts-kassa.cfg нет скорости порта, лицензию у ИТС запросить не могу." if ! bin="$(find_fr_drv)"; then install_poscenter_driver if [[ "$CHECK" == 1 ]]; then return 0 fi bin="$(find_fr_drv)" || stop "Драйвер Посцентра так и не появился. Лицензию у ИТС запросить нечем." fi url="serial://${com}?timeout=60000&baudrate=${speed}&protocol=v1" if [[ "$CHECK" == 1 ]]; then log "[check] прошёл бы кнопки FRS и при пустом ПИоТ вызвал обычный ITSLicenseIssue, без триала" return 0 fi say " порт кассы нужен драйверу Посцентра, чтобы прочитать лицензию ТС ПИоТ" ask_free_kassa_port || stop "Порт кассы занят. Лицензию ТС ПИоТ не прочитал и чужой блок не подставлял." log "останавливаю bukts-loader, чтобы занять ${com}" ITS_LOADER_HELD=1 trap restore_loader_after_its EXIT if [[ -x /etc/init.d/bukts-loader ]]; then /etc/init.d/bukts-loader stop || stop "bukts-loader не остановился" else systemctl stop bukts-loader || stop "bukts-loader не остановился" fi local i for i in 1 2 3 4 5 6 7 8 9 10; do if ! pgrep -x bukts-loader >/dev/null 2>&1 && ! pgrep -x bukkassa >/dev/null 2>&1; then break fi sleep 1 done if pgrep -x bukts-loader >/dev/null 2>&1 || pgrep -x bukkassa >/dev/null 2>&1; then stop "bukts-loader не отпустил порт кассы. Лицензию не запрашивал." fi log "запускаю тест драйвера Посцентра" ( cd "$(dirname "$bin")" && exec "$bin" html-test ) >/tmp/etp-html-test.log 2>&1 & echo $! >/tmp/etp-html-test.pid # Не в $(...): иначе у python нет /dev/tty и вопрос про лицензию молча пропускается. set +e python3 - "$url" >/tmp/etp-license.out <<'PY' import json, socket, sys, time, urllib.request url = sys.argv[1] def fail(msg): print("FAIL " + msg) raise SystemExit(1) def note(msg): sys.stderr.write(msg + "\n") sys.stderr.flush() def rpc(method, params, timeout=300): body = json.dumps({"jsonrpc": "2.0", "method": method, "params": params}).encode() req = urllib.request.Request( "http://127.0.0.1:8080/api/execute", data=body, headers={"Content-Type": "application/json"}, ) with urllib.request.urlopen(req, timeout=timeout) as resp: data = json.load(resp) if data.get("error"): err = data["error"] raise RuntimeError(str(err.get("message") or err)) return data.get("result") or {} def bad(res): code = res.get("ResultCode") return code not in (None, 0, "0") ready = False for _ in range(30): try: sock = socket.create_connection(("127.0.0.1", 8080), 1) sock.close() ready = True break except OSError: time.sleep(0.3) if not ready: fail("тест драйвер не открыл порт 8080") def call(method, params=None, timeout=60): try: res = rpc(method, params if params is not None else {"Password": 30}, timeout=timeout) except Exception as exc: fail(method + ": " + str(exc)) if bad(res): fail(method + ": " + str(res.get("ResultCodeDescription") or res.get("ResultCode"))) return res def frs_read(): # Тот же порядок, что кнопки FRS на azs2343 14.10.2026 17:26. # ИТС v1.license.issue принимает ИНН и полный заводской номер из # таблицы 18. Короткий Get_SerialNumber и номер ФН в этот запрос не входят: # ФН нужен ЕСМ, не серверу лицензий ККТ. call("GetDeviceMetrics") call("ReadModelParamValue", {"Password": 30, "ModelParamNumber": 79}) table = call("ReadTable2", {"Password": 30, "TableNumber": 18, "FieldNumber": 1, "RowNumber": 1}) serial = str(table.get("ValueOfFieldString") or "").strip() status = call("GetECRStatus") inn = str(status.get("INN") or "").strip() if serial or inn: note("в ИТС уйдёт ИНН %s, ЗН %s" % (inn or "?", serial or "?")) return call("ReadFeatureLicenses") def no_new_license(err): text = str(err) return ("Нет лицензии" in text or "No new license" in text or "-32007" in text or "-75" in text) call("Connect", {"Password": 30, "ConnectionURI": url}) lic = frs_read() status = str(lic.get("LicensePiotStatus") or "") def issue_once(trial): try: got = rpc("ITSLicenseIssue", {"Password": 30, "ITSLicenseTrial": bool(trial)}, timeout=300) except Exception as exc: return None, str(exc) if bad(got): return None, str(got.get("ResultCodeDescription") or got.get("ResultCode")) if not (got.get("License") or "") or not (got.get("DigitalSign") or ""): return None, "ИТС не вернул блок лицензии этой кассы" return got, "" def write_block(block): res = rpc("WriteFeatureLicenses", { "Password": 30, "License": block["License"], "DigitalSign": block["DigitalSign"], }) if bad(res): fail("запись: " + str(res.get("ResultCodeDescription") or res.get("ResultCode"))) try: rpc("RebootKKT", {"Password": 30}, timeout=30) except Exception: pass time.sleep(5) back = False for _ in range(30): try: again = rpc("Connect", {"Password": 30, "ConnectionURI": url}, timeout=8) except SystemExit: raise except Exception: time.sleep(2) continue if not bad(again): back = True break time.sleep(2) if not back: fail("касса не ответила после перезагрузки с новой лицензией") def paid_attempts(): errors = [] for n in range(1, 4): note("попытка %d/3, обычная лицензия" % n) if n > 1: frs_read() got, err = issue_once(False) if got: return got, errors errors.append(err) note("попытка %d не удалась: %s" % (n, err)) if no_new_license(err): break if n < 3: time.sleep(15) return None, errors issued, errors = paid_attempts() if issued: write_block(issued) print("ISSUED") raise SystemExit(0) if status and status.lower() != "none": note("новой обычной лицензии у ИТС нет, в кассе остаётся " + status) print("PRESENT " + status) raise SystemExit(0) note("обычной лицензии нет, ТС ПИоТ в кассе пустой. Записываю триал и сразу повторяю обычный запрос") trial, err = issue_once(True) if not trial: fail("триал для пустого блока не выдан: " + err + ". Обычная лицензия: " + "; ".join(errors)) write_block(trial) lic = frs_read() status = str(lic.get("LicensePiotStatus") or "") note("после триала в кассе " + (status or "пусто")) def ask(prompt): try: tty = open("/dev/tty", "r+", encoding="utf-8", errors="replace") except OSError: note("нет терминала, оплаченную лицензию не жду") return False while True: tty.write(prompt) tty.flush() answer = tty.readline() if not answer: tty.close() return False answer = answer.strip().lower() if answer in ("да", "д", "y", "yes"): tty.close() return True if answer in ("нет", "н", "n", "no"): tty.close() return False tty.write("Нужно ответить да или нет.\n") if not ask("Оплаченная лицензия на эту кассу уже есть? Ждать её у ИТС? [да/нет]: "): note("остаёмся на триале " + (status or "")) print("ISSUED-TRIAL " + status) raise SystemExit(0) issued = None for n in range(1, 9): note("пауза 60 с, затем обычный запрос %d/8" % n) time.sleep(60) got, err = issue_once(False) if got: issued = got break note("запрос %d: %s" % (n, err)) if n < 8 and not ask("Пока нет. Ждать ещё минуту? [да/нет]: "): break if issued: write_block(issued) print("ISSUED") raise SystemExit(0) note("оплаченную не дождались, в кассе остаётся триал " + (status or "")) print("ISSUED-TRIAL " + status) PY rc=$? set -e out="$(cat /tmp/etp-license.out 2>/dev/null || true)" say " лицензия: ${out:0:300}" if [[ "$rc" -ne 0 || "$out" == FAIL* ]]; then stop "Лицензию ТС ПИоТ для этой кассы получить не удалось. Чужой блок не подставлял." fi case "$out" in PRESENT*) ok "лицензия ТС ПИоТ в этой кассе уже есть" ;; ISSUED-TRIAL*) ok "в кассе триальная лицензия ТС ПИоТ, на ней и продолжаю" ;; ISSUED*) ok "лицензия ТС ПИоТ записана в эту кассу с сервера ИТС" ;; *) stop "Не понял ответ драйвера по лицензии. Чужой блок не подставлял." ;; esac restore_loader_after_its } open_kassa_shift() { local reply log "открываю смену по кассе: @!SHBEG;TXT=Оператор на 127.0.0.1:65522" reply="$(kassa_cmd 'SHBEG;TXT=Оператор')" || stop "Касса не ответила на открытие смены. Порт 65522 уже закрыт." say " ответ кассы: ${reply}" if [[ "$reply" == *"RES=0"* || "$reply" == *"Смена уже открыта"* ]]; then ok "смена по кассе открыта" return 0 fi stop "Касса не открыла смену: ${reply}" } firmware_ok_for() { local family="$1" text="$2" minimum="${3:-$MIN_FW}" python3 - "$family" "$text" "$minimum" <<'PY' import re, sys family, text = sys.argv[1], sys.argv[2] # Пороги: C3,63074,260602 и D3 с 1 апреля 2026. Линейка T3 для ТС ПИоТ не подходит. floors = { "C": (3, 63074, 260602), "D": (3, 0, 260401), } m = re.search(r"VER=([^;$\s]+)", text) if not m: print("NOVER") sys.exit(0) ver = m.group(1).strip().strip("\r") parts = ver.split(",") if parts and parts[0][:1] == "T": print("T3 " + ver) sys.exit(0) if len(parts) < 3 or not parts[0][:1] in floors: print("BAD " + ver) sys.exit(0) try: letter = parts[0][:1] major = int(parts[0][1:]) build = int(parts[1]) day = int(parts[2]) except ValueError: print("BAD " + ver) sys.exit(0) min_major, min_build, min_day = floors[letter] below = major < min_major or day < min_day or ( major == min_major and day == min_day and build < min_build ) if below: print("LOW " + ver) sys.exit(0) above = major > min_major or day > min_day or build > min_build print(("HIGH " if above else "OK ") + ver) PY } apply_shtrih_typ() { local file="$1" python3 - "$file" <<'PY' import re, sys path = sys.argv[1] rx = re.compile(r'^(?P
\s*(?:\d+:)?)(?PTYP)(?P\s*=\s*)(?P\S+)(?P.*)$', re.I)
lines = open(path, encoding="utf-8", errors="replace").read().splitlines(keepends=True)
idx = None
for i, line in enumerate(lines):
    s = line.strip()
    if not s or s.startswith("#") or s.startswith(";"):
        continue
    m = rx.match(line.rstrip("\r\n"))
    if m:
        idx = i
if idx is None:
    sys.exit(3)
m = rx.match(lines[idx].rstrip("\r\n"))
old = m.group("v").strip().strip('"').strip("'")
if old in ("22",):
    print("keep")
    sys.exit(0)
if old not in ("2", "12"):
    print(old)
    sys.exit(4)
nl = "\n" if lines[idx].endswith("\n") else ""
lines[idx] = f"{m.group('pre')}{m.group('k')}{m.group('eq')}22{m.group('rest')}{nl}"
open(path, "w", encoding="utf-8").write("".join(lines))
print("changed")
PY
}

apply_prim() {
    local file="$1" device_com="$2"
    python3 - "$file" "$ISKRA_XML" "$ISKRA_SAMPLE" "$device_com" <<'PY'
import os, re, shutil, sys
kassa, xml, sample, device = sys.argv[1:]
rx = re.compile(r'^(?P
\s*(?:\d+:)?)(?PCOM|SPEED)(?P\s*=\s*)(?P\S+)(?P.*)$', re.I)

def load(path):
    return open(path, encoding="utf-8", errors="replace").read().splitlines(keepends=True)

def last_idx(lines, key):
    idx = None
    for i, line in enumerate(lines):
        s = line.strip()
        if not s or s.startswith("#") or s.startswith(";"):
            continue
        m = rx.match(line.rstrip("\r\n"))
        if m and m.group("k").upper() == key:
            idx = i
    return idx

def set_key(lines, key, new):
    i = last_idx(lines, key)
    if i is None:
        lines.append(f"{key}={new}\n")
        return True
    raw = lines[i].rstrip("\r\n")
    m = rx.match(raw)
    if m.group("v").strip().strip('"').strip("'") == new:
        return False
    lines[i] = f"{m.group('pre')}{m.group('k')}{m.group('eq')}{new}{m.group('rest')}\n"
    return True

cfg_changed = False
lines = load(kassa)
if set_key(lines, "COM", "127.0.0.1"):
    cfg_changed = True
if set_key(lines, "SPEED", "65501"):
    cfg_changed = True
if cfg_changed:
    open(kassa, "w", encoding="utf-8").write("".join(lines))

xml_created = False
if not os.path.isfile(xml):
    os.makedirs(os.path.dirname(xml), exist_ok=True)
    if not os.path.isfile(sample):
        sys.stderr.write(f"нет {sample}\n")
        sys.exit(2)
    shutil.copy(sample, xml)
    xml_created = True
text = open(xml, encoding="utf-8", errors="replace").read()
# Первый Device в файле — рабочий. Дальше в комментарии есть другой .
head, sep, tail = text.partition("