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

from socketserver import TCPServer, ThreadingMixIn, BaseRequestHandler
from datetime import datetime, date
from protocol import do_command


class ThreadedTCPServer(ThreadingMixIn, TCPServer):
    pass

class K1FSocketServerHandler(BaseRequestHandler):
    def handle(self):
        self.callback(self.server, self.request, self.client_address)

class K1FSocketServer():
    handler = K1FSocketServerHandler

    def __init__(self):
        self.handler.callback = self.callback

    def callback(self, server, request, client_address):    
        print('')

        while True:
            try:
                buf = request.recv(8192)
            except:
                break

            if not buf: 
                break
            
            res = do_command(buf)

            request.sendall(res)

        print('')


TCP_IP = '0.0.0.0'
TCP_PORT = 49152

if __name__ == '__main__':
    ones_serv = K1FSocketServer()
    server = ThreadedTCPServer((TCP_IP, TCP_PORT), K1FSocketServerHandler)
    
    print('starting k1f socket server '+str(TCP_IP)+':'+str(TCP_PORT)+' (use <Ctrl-C> to stop)')

    server.serve_forever()
    

import json


OFSSET = 4


RESPONSE = {}

RESPONSE['OpenSession'] = """{"result": 0,
 "description": "Успешно завершено",
 "sessionKey": "CAC1A797-6A48-474A-A08E-72A8CD3AEFE2",
 "protocolVer": "1.0"}"""

RESPONSE['CloseSession'] = """{"result": 0,
 "description": "Успешно завершено"}"""

RESPONSE['GetCommonInfo'] = """{"result": 0,
 "description": "Успешно завершено",
 "model": "Название модели ККТ",
 "kktNum": "123456789012",
 "fnNum": "9908176526",
 "ffdFnVer": "1.0.5",
 "ffdKktVer": "1.0",
 "mac": "45:F2:0D:73:37:00",
 "programVer": "3.1",
 "programDate": "2016-09-04",
 "protocolVer": "3.0",
 "dateTime": "2016-10-01T09:15:43",
 "crc": "C5AD",
 "cpl": [21, 10],
 "dpl": 240,
 "maxGoodsSum": 999999999,
 "maxCheckSum": 999999999,
 "maxGoodsQty": 99}"""

RESPONSE['GetRegistrationInfo'] = """{"isRegistered": true,
 "registrationInfo": {
 "dateTime": "2016-10-03T12:35:27",
 "owner": {
 "inn": "3890473625"
 },
 "kkt": {
 "regNum": "123456789012",
 "mode": {
 "encryptData": true,
 "offline": false,
 "forService": true,
 "ASBSO": false
 }
 },
 "ofd": {
 "inn": "4029017981",
 "url": "ofd.astralnalog.ru",
 "port": 7779
 },
 "taxSystem": [0, 1, 3],
 "reason": 2}}"""

RESPONSE['GetDateTime'] = """{"result": 0,
 "description": "Успешно завершено",
 "dateTime": "2016-10-01T09:15:43"}"""

RESPONSE['GetStatus'] = """{"result": 0,
 "description": "Успешно завершено",
 "dateTime": "2016-10-01T09:15:43",
 "shiftInfo": {
 "isOpen": true,
 "is24Expired": false,
 "num": 17,
 "lastOpen": "2016-09-30T08:10:15",
 "cash": 500680,
 "check0": {
 "qty": 15,
 "sum": 500680
 },
 "check1": {
 "qty": 0,
 "sum": 0
 },
 "check2": {
 "qty": 0,
 "sum": 0
 },
 "check3": {
 "qty": 0,
 "sum": 0
 },
 "check4": {
 "qty": 0,
 "sum": 0
 },
 "check5": {
 "qty": 0,
 "sum": 0
 },
 "bring": {
 "qty": 0,
 "sum": 0
 },
 "withdraw": {
 "qty": 0,
 "sum": 0
 }
 },
 "checkInfo": {
 "isOpen": true,
 "num": 4,
 "goodsQty": 8,
 "sum": 12534
 },
 "fnInfo": {
 "status": 1,
 "lastDoc": {
 "num": 60,
 "dateTime": "2016-10-01T09:10:24"
 },
 "unsignedDocs": {
 "qty": 1,
 "firstNum": 61,
 "firstDateTime": "2016-10-01T09:13:37"}}}"""

RESPONSE['OpenShift'] = """{"result": 0,
 "description": "Успешно завершено",
 "shiftNum": 125,
 "fiscalDocNum": 1153,
 "fiscalSign": "1189046352"}"""

RESPONSE['CloseShift'] = """{"result": 0,
 "description": "Успешно завершено",
 "shiftNum": 125,
 "fiscalDocNum": 1153,
 "fiscalSign": "1189046352"}"""

RESPONSE['OpenCheck'] = """{"result": 0,
 "description": "Успешно завершено",
 "shiftNum": 125,
 "checkNum": 18}"""

RESPONSE['CloseCheck'] = """{"result": 0,
 "description": "Успешно завершено",
 "shiftNum": 125,
 "checkNum": 18,
 "fiscalDocNum": 1173,
 "fiscalSign": "1189046352",
 "checkUrl": "nalog.ru",
 "changeSum": 4000}"""

RESPONSE['AddGoods'] = """{"result": 0,
 "description": "Успешно завершено",
 "shiftNum": 235,
 "checkNum": 18,
 "goodsNum": 2,
 "taxSum": 0,
 "extraSum": -116,
 "goodsSum": 3134,
 "checkSum": 5392}"""

RESPONSE['PrintReport'] = """{"result": 0,
 "description": "Успешно завершено"}"""

RESPONSE['ResetCheck'] = """{"result": 0,
 "description": "Успешно завершено"}"""


def do_command(data):
    data = data[OFSSET:].decode('utf-8')
    
    data = data.rstrip('\x00')

    res = json.loads(data)

    print('->')
            
    print(res)

    if res.get('command') is None:
        return b''

    message = RESPONSE.get(res['command'])

    if message is None:
        return b''
     
    print('<-') 
    
    print(message)

    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)

from server.conf import *
from server import app

if __name__ == '__main__':
    app.run(API_SERVER, API_PORT, threaded=True) 

from flask import Flask
from flask_cors import CORS


app = Flask(__name__)

CORS(app, support_credentials=True)

import server.views

API_SERVER = '0.0.0.0'
API_PORT = 8081

OFSSET = 4

SERVER = ('192.168.1.99', 49152)

LOGIN = 'LOGIN'
PASSWORD = 'PASSWORD'
CON_PASSWORD = 'CON_PASSWORD'

BUF_SIZE = 8192

CHECK_TYPE = 0
TAX_SYSTEM = 0

OPER_LIST = []

OPER_LIST.append('OpenSession')
OPER_LIST.append('GetCommonInfo')
OPER_LIST.append('GetRegistrationInfo')
OPER_LIST.append('GetStatus')
OPER_LIST.append('CloseSession')
OPER_LIST.append('OpenShift')
OPER_LIST.append('CloseShift')
OPER_LIST.append('OpenCheck')
OPER_LIST.append('CloseCheck')
OPER_LIST.append('AddGoods')

PRINT_DOC = False

from flask import render_template, request, jsonify
import server.fisc_reg_exchange as fisc_reg
from server.conf import *
from server import app
import json


HEADERS = {"Content-type": "application/json",
           "Access-Control-Allow-Origin": "*", 
           "Access-Control-Expose-Headers": "Access-Control-Allow-Origin",
           "Access-Control-Allow-Headers": "Origin, X-Requested-With, Content-Type, Accept"}

@app.route('/')
@app.route('/index')
def index():
    return """it's k1-f server api""", 200, HEADERS


@app.errorhandler(Exception)
def handle_invalid_usage(error):
    str_error = "Exception: %s" % error

    print(str_error)

    response = jsonify(str_error)
    response.status_code = 500
    response.content_type = 'text/plain; charset=utf-8'
    
    return response

   
@app.route('/get_common_info', methods=['GET'])
def get_common_info():
    sock = fisc_reg.init_oper()

    if sock is None:
        raise Exception('Нет связи')

    res = fisc_reg.do_oper('OpenSession', sock, session_key=None)

    if res.get('sessionKey') is None:
        raise Exception('session_key is None')
    
    session_key = res['sessionKey']

    res = fisc_reg.do_oper('GetCommonInfo', sock, session_key=session_key)

    res = json.dumps(res, default=json_serial)

    fisc_reg.do_oper('CloseSession', sock, session_key=session_key)

    return res, 200, HEADERS

@app.route('/get_registration_info', methods=['GET'])
def get_registration_info():
    sock = fisc_reg.init_oper()

    if sock is None:
        raise Exception('Нет связи')

    res = fisc_reg.do_oper('OpenSession', sock, session_key=None)

    if res.get('sessionKey') is None:
        raise Exception('session_key is None')
    
    session_key = res['sessionKey']

    res = fisc_reg.do_oper('GetRegistrationInfo', sock, session_key=session_key)

    res = json.dumps(res, default=json_serial)
        
    fisc_reg.do_oper('CloseSession', sock, session_key=session_key)

    return res, 200, HEADERS

@app.route('/get_status', methods=['GET'])
def get_status():
    sock = fisc_reg.init_oper()

    if sock is None:
        raise Exception('Нет связи')

    res = fisc_reg.do_oper('OpenSession', sock, session_key=None)

    if res.get('sessionKey') is None:
        raise Exception('session_key is None')
    
    session_key = res['sessionKey']

    res = fisc_reg.do_oper('GetStatus', sock, session_key=session_key)

    res = json.dumps(res, default=json_serial)
        
    fisc_reg.do_oper('CloseSession', sock, session_key=session_key)
    
    return res, 200, HEADERS

@app.route('/open_shift', methods=['GET'])
def open_shift():
    sock = fisc_reg.init_oper()

    if sock is None:
        raise Exception('Нет связи')

    res = fisc_reg.do_oper('OpenSession', sock, session_key=None)

    if res.get('sessionKey') is None:
        raise Exception('session_key is None')
    
    session_key = res['sessionKey']

    res = fisc_reg.do_oper('OpenShift', sock, session_key=session_key)

    res = json.dumps(res, default=json_serial)
        
    fisc_reg.do_oper('CloseSession', sock, session_key=session_key)

    return res, 200, HEADERS

@app.route('/close_shift', methods=['GET'])
def close_shift():
    sock = fisc_reg.init_oper()

    if sock is None:
        raise Exception('Нет связи')

    res = fisc_reg.do_oper('OpenSession', sock, session_key=None)

    if res.get('sessionKey') is None:
        raise Exception('session_key is None')
    
    session_key = res['sessionKey']

    res = fisc_reg.do_oper('CloseShift', sock, session_key=session_key)

    res = json.dumps(res, default=json_serial)
        
    fisc_reg.do_oper('CloseSession', sock, session_key=session_key)
    
    return res, 200, HEADERS

@app.route('/make_payment', methods=['POST'])
def make_payment():
    body = request.data.decode('utf-8-sig')
    
    data = json.loads(body)

    sock = fisc_reg.init_oper()

    if sock is None:
        raise Exception('Нет связи')

    res = fisc_reg.do_oper('OpenSession', sock, session_key=None)

    if res.get('sessionKey') is None:
        raise Exception('session_key is None')
    
    session_key = res['sessionKey']

    res_status = fisc_reg.do_oper('GetStatus', sock, session_key=session_key)

    if res_status['shiftInfo']['is24Expired'] == True:
        res = fisc_reg.do_oper('CloseShift', sock, session_key=session_key)
        if res['result'] != 0:
            raise Exception('CloseShift error: ' + str(res))
    
    if res_status['shiftInfo']['isOpen'] != True:
        res = fisc_reg.do_oper('OpenShift', sock, session_key=session_key)
        if res['result'] != 0:
            raise Exception('OpenShift error: ' + str(res))

    res = fisc_reg.do_oper('OpenCheck', sock, session_key=session_key)
    if res['result'] != 0:
        raise Exception('OpenCheck error: ' + str(res))

    for x in data['goods']: 
        code = x['code']
        id = x['id']
        name = x['name']

        qty = x['qty']
        price = x['price']

        extra_type = x['extra_type']
        extra_value = x['extra_value']

        section = x['section']
        tax_code = x['tax_code']
        payment_form_code = x['payment_form_code']

        res = fisc_reg.do_oper('AddGoods', sock, session_key=session_key, code=code, id=id, name=name, qty=qty, section=section, tax_code=tax_code, payment_form_code=payment_form_code, price=price, extra_type=extra_type, extra_value=extra_value)
        
        if res['result'] != 0:
            raise Exception('AddGoods error: ' + str(res))

    client = data['client']
    add_info = data['add_info']
    cash = data['cash']
    ecash = data['ecash']
    prepayment = data['prepayment']
    credit = data['credit']
    consideration = data['consideration']

    res = fisc_reg.do_oper('CloseCheck', sock, session_key=session_key, client=client, add_info=add_info, cash=cash, ecash=ecash, prepayment=prepayment, credit=credit, consideration=consideration)

    if res['result'] != 0:
        raise Exception('CloseCheck error: ' + str(res))

    res = json.dumps(res, default=json_serial)
        
    fisc_reg.do_oper('CloseSession', sock, session_key=session_key)

    return res, 200, HEADERS


def json_serial(obj):
    from datetime import datetime, date
    import decimal
    if isinstance(obj, (datetime, date)):
       return obj.isoformat()

    if isinstance(obj, decimal.Decimal):
       return float(obj)
    pass

import json
from server.conf import *


def message_to_byte(message):
    message = json.dumps(message)
    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)

def send_data(message, sock):
    mes = message_to_byte(message)
    
    sock.send(mes)
    
    data = sock.recv(BUF_SIZE)
    data = data[OFSSET:].decode('utf-8')
    
    res = json.loads(data)
    
    print(res)
    print('')

    return res

def init_oper():
    import socket

    sock = None
    try:
        sock = socket.socket()
        sock.connect(SERVER)
    except Exception as e:
        raise Exception('Socket error ' + str(e))
        
        return None

    return sock

def do_oper(oper, sock, **data):
    res = None

    if not oper in OPER_LIST:
        raise Exception('Operation is not defined' + str(oper))

    session_key = data['session_key']

    d = {'sessionKey': session_key, 'command': oper}

    if oper == 'OpenSession':        
        d['connectionPassword'] = CON_PASSWORD
        d['login'] = LOGIN
        d['password'] = PASSWORD

    elif oper == 'OpenCheck':
        d['checkType'] = CHECK_TYPE
        d['taxSystem'] = TAX_SYSTEM
        d['printDoc'] = PRINT_DOC

    elif oper == 'CloseCheck':
        d['sendCheckTo'] = data['client']
        d['addInfo'] = data['add_info']

        payment = {'cash':data['cash'], 'ecash':data['ecash'], 'prepayment':data['prepayment'], 'credit':data['credit'], 'consideration':data['consideration']}

        d['payment'] = payment        

    elif oper == 'AddGoods':
        d['nomenclatureCode'] = data['code']
        d['productID'] = data['id']
        d['productName'] = data['name']
        d['qty'] = data['qty']
        d['section'] = data['section']
        d['taxCode'] = data['tax_code']
        d['paymentFormCode'] = data['payment_form_code']
        d['price'] = data['price']
        
        extra = {'type': data['extra_type'], 'value': data['extra_value']}

        d['extra'] = extra

    res = send_data(d, sock)

    return res

import requests
import json


server = '192.168.1.99'
port = 8081

method = 'get_common_info'
r = requests.get(f"""http://{server}:{port}/{method}""")
print(r)
print(r.text)

method = 'get_registration_info'
r = requests.get(f"""http://{server}:{port}/{method}""") 
print(r)
print(r.text)

method = 'get_status'
r = requests.get(f"""http://{server}:{port}/{method}""")
print(r)
print(r.text)

method = 'open_shift'
r = requests.get(f"""http://{server}:{port}/{method}""")  
print(r)
print(r.text)

method = 'close_shift'
r = requests.get(f"""http://{server}:{port}/{method}""")
print(r)
print(r.text)

data = {}

data['client'] = 'test@mail.ru'
data['add_info'] = 'оплата по заказу номер 100'
data['cash'] = 0
data['ecash'] = 100
data['prepayment'] = 0
data['credit'] = 0
data['consideration'] = 0

data['goods'] = []

row_goods = {}

row_goods['code'] = '001'
row_goods['id'] = '001'
row_goods['name'] = 'услуги'
row_goods['qty'] = 1
row_goods['price'] = 100

row_goods['extra_type'] = 0
row_goods['extra_value'] = 0

row_goods['section'] = 1
row_goods['tax_code'] = 1
row_goods['payment_form_code'] = 0

data['goods'].append(row_goods)

data = json.dumps(data)
method = 'make_payment'
r = requests.post(f"""http://{server}:{port}/{method}""", data=data)
print(r)
print(r.text)

p = input()

import pymysql.cursors
import time
import requests
import json
import sqlite3
from sqlite3 import Error
from datetime import datetime, date

from secret import *


T_SLEEP = 60

API_SERVER = '192.168.1.99'
API_PORT = 8081
API_MAKE_PAYMENT = 'make_payment'

DB_LOCAL = 'operations.db'


def get_data_source(last_id):
    try:
        connection = pymysql.connect(host=DB_HOST, user=DB_USER, password=DB_PASS, db=DB, charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor)
    except Exception as e:
        print(e)
        return None

    cursor = connection.cursor()
    
    query_text = f"SELECT b_tszh_payment.*, b_user.* FROM b_tszh_payment LEFT JOIN b_user ON b_tszh_payment.USER_ID = b_user.ID WHERE b_tszh_payment.ID > {last_id}"
    
    try:
        res = cursor.execute(query_text, )
    except Exception as e:
        print(e)
        return None

    result = cursor.fetchall()

    cursor = None

    connection.close()

    return result

def get_last_id():
    try:
        connection = sqlite3.connect(DB_LOCAL)
    except Error as e:
        print(e)
        return None

    cursor = connection.cursor()
    
    query_text = f"SELECT last_id FROM operations ORDER BY last_id DESC LIMIT 1"
    
    try:
        res = cursor.execute(query_text, )
    except Exception as e:
        print(e)
        return None

    result = cursor.fetchall()

    cursor = None

    connection.close()

    if len(result) == 0:
        return 0
    
    return result[0][0]

def set_result(res, x):
    try:
        connection = sqlite3.connect(DB_LOCAL)
    except Error as e:
        print(e)
        return None

    source_data = json.dumps(res, default=json_serial)
    fisc_reg_data = json.dumps(x, default=json_serial)
    last_id = x['ID']
    fisc_reg_doc = res['fiscalDocNum']

    cursor = connection.cursor()
    
    rows = [(source_data, fisc_reg_data, last_id, fisc_reg_doc)]

    cursor.executemany('INSERT INTO operations values (?,?,?,?)', rows)
   
    connection.commit()

    cursor = None

    connection.close()

    return None

def make_payment(client, summ, add_info):
    data = {}
    
    data['client'] = client
    data['add_info'] = add_info
    data['cash'] = 0
    data['ecash'] = summ
    data['prepayment'] = 0
    data['credit'] = 0
    data['consideration'] = 0
    
    data['goods'] = []
    
    row_goods = {}
    
    row_goods['code'] = '001'
    row_goods['id'] = '001'
    row_goods['name'] = add_info
    row_goods['qty'] = 1
    row_goods['price'] = summ
    row_goods['extra_type'] = 0
    row_goods['extra_value'] = 0
    row_goods['section'] = 1
    row_goods['tax_code'] = 1
    row_goods['payment_form_code'] = 0
    
    data['goods'].append(row_goods)
    
    data = json.dumps(data, default=json_serial)
    
    r = requests.post(f"""http://{API_SERVER}:{API_PORT}/{API_MAKE_PAYMENT}""", data=data)
    
    print('API_SERVER response:')
    print(r)
    print(r.text)

    if r.status_code == 200:
        res = json.loads(r.text)
        return res

    return None

def do_loop():
    print('')
    print(datetime.now())
    
    last_id = get_last_id()

    if last_id is None:
        return None

    result = get_data_source(last_id)

    if result is None:
        return None
        
    print('new records ' + str(len(result)))
    
    if len(result) == 0:
        return None

    for x in result:
        print(x)
        res = make_payment(x['EMAIL'], x['SUMM_PAYED'], x['C_ADDRESS'])
        
        if not res is None:
            set_result(res, x)

    pass

def json_serial(obj):
    from datetime import datetime, date
    import decimal
    if isinstance(obj, (datetime, date)):
       return obj.isoformat()

    if isinstance(obj, decimal.Decimal):
       return float(obj)
    pass 


while True:
    do_loop()

    time.sleep(T_SLEEP)

BEGIN TRANSACTION;
CREATE TABLE "operations" (
	`source_data`	TEXT NOT NULL,
	`fisc_reg_data`	TEXT,
	`last_id`	INTEGER,
	`fisc_reg_doc`	INTEGER
);
INSERT INTO `operations` VALUES ('',NULL,1235,NULL);
INSERT INTO `operations` VALUES ('{"result": 0, "description": "\u0423\u0441\u043f\u0435\u0448\u043d\u043e \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u043e", "shiftNum": 125, "checkNum": 18, "fiscalDocNum": 1173, "fiscalSign": "1189046352", "checkUrl": "nalog.ru", "changeSum": 4000}','{"ID": 1236, "LID": "s1", "PAYED": "N", "DATE_PAYED": null, "EMP_PAYED_ID": null, "SUMM": 12848.03, "SUMM_PAYED": 0.0, "CURRENCY": "RUB", "USER_ID": 128, "PAY_SYSTEM_ID": 2, "DATE_INSERT": "2018-06-30T09:26:37", ...88", "LANGUAGE_ID": null}',1236,1173);
INSERT INTO `operations` VALUES ('{"result": 0, "description": "\u0423\u0441\u043f\u0435\u0448\u043d\u043e \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u043e", "shiftNum": 125, "checkNum": 18, "fiscalDocNum": 1173, "fiscalSign": "1189046352", "checkUrl": "nalog.ru", "changeSum": 4000}','{"ID": 1237, "LID": "s1", "PAYED": "N", "DATE_PAYED": null, "EMP_PAYED_ID": null, "SUMM": 12848.03, "SUMM_PAYED": 0.0, "CURRENCY": "RUB", "USER_ID": 128, "PAY_SYSTEM_ID": 2, "DATE_INSERT": "2018-06-30T09:26:46", "DATE_UPDATE": "2018-06-30T09:26:...4c\u0435\u0432\u0438\u0447", "CONFIRM_CODE": null, "LOGIN_ATTEMPTS": 0, "LAST_ACTIVITY_DATE": null, "AUTO_TIME_ZONE": null, "TIME_ZONE": null, "TIME_ZONE_OFFSET": 0, "TITLE": null, "BX_USER_ID": "aa51cf01e427ee3481364316b2f89088", "LANGUAGE_ID": null}',1237,1173);
INSERT INTO `operations` VALUES ('{"result": 0, "description": "\u0423\u0441\u043f\u0435\u0448\u043d\u043e \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u043e", "shiftNum": 125, "checkNum": 18, "fiscalDocNum": 1173, "fiscalSign": "1189046352", "checkUrl": "nalog.ru", "changeSum": 4000}','{"ID": 1238, "LID": "s1", "PAYED": "N", "DATE_PAYED": null, "EMP_PAYED_ID": null, "SUMM": 12848.03, "SUMM_PAYED": 0.0, "CURRENCY": "RUB", "USER_ID": 128, "PAY_SYSTEM_ID": 2, "DATE_INSERT": "2018-06-30T09:34:38", "DATE_U...LANGUAGE_ID": null}',1238,1173);
CREATE INDEX `idx_last_id` ON `operations` (`last_id` DESC)

;
COMMIT;

для сервера
#!/bin/sh
screen -dmUS k1f_fisc_reg_api_server python3.5 main.py

для клиента
#!/bin/sh
screen -dmUS b_tszh python3.5 main.py