Compare commits
11 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 28a8810ffb | |||
| 3ed7d33b84 | |||
| 3e02c6f2d5 | |||
| 9513c373aa | |||
| 961b90626f | |||
| 81fb8c7e7e | |||
| 08c7556960 | |||
| d9bfa5ff7f | |||
|
|
b70e95ac5c | ||
| ac4f4670bb | |||
| 4a8b5cf0c5 |
@@ -1,17 +1,45 @@
|
|||||||
package api
|
package api
|
||||||
|
|
||||||
import "resty.dev/v3"
|
import (
|
||||||
|
"crypto/tls"
|
||||||
|
|
||||||
|
"resty.dev/v3"
|
||||||
|
)
|
||||||
|
|
||||||
type Client struct {
|
type Client struct {
|
||||||
token string
|
token string
|
||||||
resty *resty.Client
|
device string
|
||||||
apiBaseURL string
|
resty *resty.Client
|
||||||
|
apiBaseURL string
|
||||||
|
fiscalEndpoint string
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewClient(token string) *Client {
|
func NewClient(token string) *Client {
|
||||||
return &Client{
|
return &Client{
|
||||||
token: token,
|
token: token,
|
||||||
resty: resty.New(),
|
resty: resty.New(),
|
||||||
apiBaseURL: "https://kasa.vchasno.ua/api/v3",
|
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/execute",
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -5,40 +5,45 @@ import (
|
|||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
|
"log"
|
||||||
)
|
)
|
||||||
|
|
||||||
func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, response interface{}) error {
|
func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, response interface{}) error {
|
||||||
|
request.Device = c.device
|
||||||
|
|
||||||
reqJson, err := json.Marshal(request)
|
reqJson, err := json.Marshal(request)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to marshal request: %w", err)
|
return fmt.Errorf("failed to marshal request: %w", err)
|
||||||
}
|
}
|
||||||
fmt.Println(string(reqJson))
|
|
||||||
|
url := c.apiBaseURL + c.fiscalEndpoint
|
||||||
|
log.Printf("[VCHASNO] POST %s", url)
|
||||||
|
log.Printf("[VCHASNO] Request: %s", string(reqJson))
|
||||||
|
|
||||||
resp, err := c.resty.R().
|
resp, err := c.resty.R().
|
||||||
SetContext(ctx).
|
SetContext(ctx).
|
||||||
SetHeader("Authorization", c.token).
|
SetHeader("Authorization", c.token).
|
||||||
|
SetHeader("Content-Type", "application/json").
|
||||||
SetBody(reqJson).
|
SetBody(reqJson).
|
||||||
Post(c.apiBaseURL + "/fiscal/execute")
|
Post(url)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("request failed: %w", err)
|
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)
|
body, err := io.ReadAll(resp.Body)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to read response: %w", err)
|
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 {
|
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
|
return nil
|
||||||
@@ -101,12 +106,6 @@ func (c *Client) Sell(ctx context.Context, params SellParams) (*SellResponse, er
|
|||||||
request.Userinfo = *params.Userinfo
|
request.Userinfo = *params.Userinfo
|
||||||
}
|
}
|
||||||
|
|
||||||
reqJson, err := json.Marshal(request)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
fmt.Println(string(reqJson))
|
|
||||||
|
|
||||||
var response SellResponse
|
var response SellResponse
|
||||||
if err := c.executeRequest(ctx, request, &response); err != nil {
|
if err := c.executeRequest(ctx, request, &response); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package api
|
|||||||
|
|
||||||
type FiscalRequest struct {
|
type FiscalRequest struct {
|
||||||
Source string `json:"source"`
|
Source string `json:"source"`
|
||||||
|
Device string `json:"device,omitempty"`
|
||||||
Userinfo Userinfo `json:"userinfo,omitempty"`
|
Userinfo Userinfo `json:"userinfo,omitempty"`
|
||||||
Fiscal Fiscal `json:"fiscal"`
|
Fiscal Fiscal `json:"fiscal"`
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,9 +7,10 @@ import (
|
|||||||
|
|
||||||
func ExampleBasicUsage() {
|
func ExampleBasicUsage() {
|
||||||
client := NewClient(Config{
|
client := NewClient(Config{
|
||||||
Token: "your-token",
|
Token: "your-token",
|
||||||
Cashier: "Иванов",
|
Cashier: "Иванов",
|
||||||
Source: "parking",
|
Source: "parking",
|
||||||
|
CustomURL: "DM URL/",
|
||||||
})
|
})
|
||||||
|
|
||||||
ctx := context.Background()
|
ctx := context.Background()
|
||||||
|
|||||||
39
vchasno.go
39
vchasno.go
@@ -26,10 +26,12 @@ type Client struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
type Config struct {
|
type Config struct {
|
||||||
Token string
|
Token string
|
||||||
Cashier string
|
Cashier string
|
||||||
Source string
|
Source string
|
||||||
Defaults *DefaultParams
|
Defaults *DefaultParams
|
||||||
|
CustomURL string
|
||||||
|
Device string
|
||||||
}
|
}
|
||||||
|
|
||||||
type DefaultParams struct {
|
type DefaultParams struct {
|
||||||
@@ -65,8 +67,15 @@ func NewClient(config Config) *Client {
|
|||||||
defaults.DefaultTimeout = 30 * time.Second
|
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{
|
return &Client{
|
||||||
api: api.NewClient(config.Token),
|
api: apicfg,
|
||||||
cashier: config.Cashier,
|
cashier: config.Cashier,
|
||||||
source: config.Source,
|
source: config.Source,
|
||||||
defaults: defaults,
|
defaults: defaults,
|
||||||
@@ -274,3 +283,23 @@ func (c *Client) QuickSellNamed(ctx context.Context, name string, price float64)
|
|||||||
Price: price,
|
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)
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user