14 Commits

Author SHA1 Message Date
3ed7d33b84 Added Verbose mode 2026-01-16 02:21:37 +03:00
3e02c6f2d5 improved error messages 2026-01-16 02:19:24 +03:00
9513c373aa some more tls magic 2026-01-16 02:17:39 +03:00
961b90626f set TLS to version 1.2 2026-01-16 02:14:31 +03:00
81fb8c7e7e changed fiscal endpoint 2026-01-14 18:00:15 +03:00
08c7556960 added device support 2026-01-10 04:47:04 +03:00
d9bfa5ff7f Added custom URL support (DM) 2026-01-08 16:37:02 +03:00
daniel
b70e95ac5c Added null cheque 2025-10-16 04:36:48 +03:00
ac4f4670bb disabled test JSON logging 2025-10-15 10:08:54 +03:00
4a8b5cf0c5 Added comment to clarify JSON request execution in executeRequest function 2025-10-14 11:40:57 +03:00
b33620f629 json mashal instead of struct in body 2025-10-14 11:37:19 +03:00
8006fd0935 added debug json req logging 2025-10-14 11:30:31 +03:00
4f9ca56157 fixed comment 2025-10-13 16:16:06 +03:00
328447f079 Added commentUP field to fiscalAPI 2025-10-13 16:08:02 +03:00
6 changed files with 123 additions and 44 deletions

View File

@@ -1,17 +1,45 @@
package api
import "resty.dev/v3"
import (
"crypto/tls"
"resty.dev/v3"
)
type Client struct {
token string
resty *resty.Client
apiBaseURL string
token string
device string
resty *resty.Client
apiBaseURL string
fiscalEndpoint string
}
func NewClient(token string) *Client {
return &Client{
token: token,
resty: resty.New(),
apiBaseURL: "https://kasa.vchasno.ua/api/v3",
token: token,
resty: resty.New(),
apiBaseURL: "https://kasa.vchasno.ua/api/v3",
fiscalEndpoint: "/fiscal/execute",
}
}
func NewDMClient(token, dmURL, device string) *Client {
restyClient := resty.New()
restyClient.SetTLSClientConfig(&tls.Config{
MinVersion: tls.VersionTLS12,
CipherSuites: []uint16{
tls.TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384,
tls.TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,
tls.TLS_RSA_WITH_AES_256_GCM_SHA384,
tls.TLS_RSA_WITH_AES_128_GCM_SHA256,
},
})
return &Client{
token: token,
device: device,
resty: restyClient,
apiBaseURL: dmURL,
fiscalEndpoint: "/dm/fiscal",
}
}

View File

@@ -5,34 +5,45 @@ import (
"encoding/json"
"fmt"
"io"
"log"
)
func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, response interface{}) error {
request.Device = c.device
reqJson, err := json.Marshal(request)
if err != nil {
return fmt.Errorf("failed to marshal request: %w", err)
}
url := c.apiBaseURL + c.fiscalEndpoint
log.Printf("[VCHASNO] POST %s", url)
log.Printf("[VCHASNO] Request: %s", string(reqJson))
resp, err := c.resty.R().
SetContext(ctx).
SetHeader("Authorization", c.token).
SetBody(request).
Post(c.apiBaseURL + "/fiscal/execute")
SetHeader("Content-Type", "application/json").
SetBody(reqJson).
Post(url)
if err != nil {
return fmt.Errorf("request failed: %w", err)
}
if resp.IsError() {
return fmt.Errorf("api error: %v", resp.Error())
}
if resp.StatusCode() != 200 {
return fmt.Errorf("unexpected status code: %d", resp.StatusCode())
}
body, err := io.ReadAll(resp.Body)
if err != nil {
return fmt.Errorf("failed to read response: %w", err)
}
log.Printf("[VCHASNO] Response (status %d): %s", resp.StatusCode(), string(body))
if resp.StatusCode() != 200 {
return fmt.Errorf("api error (status %d): %s", resp.StatusCode(), string(body))
}
if err := json.Unmarshal(body, response); err != nil {
return fmt.Errorf("failed to unmarshal response: %w", err)
return fmt.Errorf("failed to unmarshal response: %w, body: %s", err, string(body))
}
return nil
@@ -71,15 +82,16 @@ func (c *Client) CloseShift(ctx context.Context, cashier string) (*ZReportRespon
}
type SellParams struct {
Cashier string
Source string
Rows []ReceiptRow
Pays []ReceiptPay
Userinfo *Userinfo
Cashier string
Source string
Rows []ReceiptRow
Pays []ReceiptPay
Userinfo *Userinfo
CommentUP string
}
func (c *Client) Sell(ctx context.Context, params SellParams) (*SellResponse, error) {
receipt := NewReceipt(params.Rows, params.Pays)
receipt := NewReceipt(params.Rows, params.Pays, params.CommentUP)
request := FiscalRequest{
Source: params.Source,

View File

@@ -39,13 +39,14 @@ func CalculateReceiptSum(rows []ReceiptRow) float64 {
return sum
}
func NewReceipt(rows []ReceiptRow, pays []ReceiptPay) Receipt {
func NewReceipt(rows []ReceiptRow, pays []ReceiptPay, commentUp string) Receipt {
return Receipt{
Sum: CalculateReceiptSum(rows),
Round: 0.00,
Disc: 0,
DiscType: 0,
Rows: rows,
Pays: pays,
Sum: CalculateReceiptSum(rows),
Round: 0.00,
CommentUp: commentUp,
Disc: 0,
DiscType: 0,
Rows: rows,
Pays: pays,
}
}

View File

@@ -2,6 +2,7 @@ package api
type FiscalRequest struct {
Source string `json:"source"`
Device string `json:"device,omitempty"`
Userinfo Userinfo `json:"userinfo,omitempty"`
Fiscal Fiscal `json:"fiscal"`
}

View File

@@ -7,9 +7,10 @@ import (
func ExampleBasicUsage() {
client := NewClient(Config{
Token: "your-token",
Cashier: "Иванов",
Source: "parking",
Token: "your-token",
Cashier: "Иванов",
Source: "parking",
CustomURL: "DM URL/",
})
ctx := context.Background()

View File

@@ -26,10 +26,12 @@ type Client struct {
}
type Config struct {
Token string
Cashier string
Source string
Defaults *DefaultParams
Token string
Cashier string
Source string
Defaults *DefaultParams
CustomURL string
Device string
}
type DefaultParams struct {
@@ -65,8 +67,15 @@ func NewClient(config Config) *Client {
defaults.DefaultTimeout = 30 * time.Second
}
var apicfg *api.Client
if config.CustomURL == "" {
apicfg = api.NewClient(config.Token)
} else {
apicfg = api.NewDMClient(config.Token, config.CustomURL, config.Device)
}
return &Client{
api: api.NewClient(config.Token),
api: apicfg,
cashier: config.Cashier,
source: config.Source,
defaults: defaults,
@@ -99,6 +108,7 @@ type SellParams struct {
PayType int
CardParams *CardParams
Userinfo *api.Userinfo
CommentUP string
}
type CardParams struct {
@@ -158,6 +168,11 @@ func (b *SellParamsBuilder) Comment(comment string) *SellParamsBuilder {
return b
}
func (b *SellParamsBuilder) CommentUp(commentUp string) *SellParamsBuilder {
b.params.CommentUP = commentUp
return b
}
func (b *SellParamsBuilder) PayCash() *SellParamsBuilder {
b.params.PayType = PayTypeCash
b.params.CardParams = nil
@@ -241,11 +256,12 @@ func (c *Client) Sell(ctx context.Context, params SellParams) (*api.SellResponse
}
return c.api.Sell(ctx, api.SellParams{
Cashier: c.cashier,
Source: c.source,
Rows: []api.ReceiptRow{row},
Pays: []api.ReceiptPay{pay},
Userinfo: params.Userinfo,
Cashier: c.cashier,
Source: c.source,
Rows: []api.ReceiptRow{row},
Pays: []api.ReceiptPay{pay},
Userinfo: params.Userinfo,
CommentUP: params.CommentUP,
})
}
@@ -267,3 +283,23 @@ func (c *Client) QuickSellNamed(ctx context.Context, name string, price float64)
Price: price,
})
}
func (c *Client) ZeroReceipt(ctx context.Context) (*api.SellResponse, error) {
return c.api.Sell(ctx, api.SellParams{
Cashier: c.cashier,
Source: c.source,
Rows: []api.ReceiptRow{},
Pays: []api.ReceiptPay{},
CommentUP: "Нульовий чек",
})
}
func (c *Client) ZeroReceiptWithTimeout(timeout time.Duration) (*api.SellResponse, error) {
ctx, cancel := context.WithTimeout(context.Background(), timeout)
defer cancel()
return c.ZeroReceipt(ctx)
}
func (c *Client) ZeroReceiptDefault() (*api.SellResponse, error) {
return c.ZeroReceiptWithTimeout(c.defaults.DefaultTimeout)
}