Compare commits
8 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 961b90626f | |||
| 81fb8c7e7e | |||
| 08c7556960 | |||
| d9bfa5ff7f | |||
|
|
b70e95ac5c | ||
| ac4f4670bb | |||
| 4a8b5cf0c5 | |||
| b33620f629 |
@@ -1,11 +1,17 @@
|
||||
package api
|
||||
|
||||
import "resty.dev/v3"
|
||||
import (
|
||||
"crypto/tls"
|
||||
|
||||
"resty.dev/v3"
|
||||
)
|
||||
|
||||
type Client struct {
|
||||
token string
|
||||
device string
|
||||
resty *resty.Client
|
||||
apiBaseURL string
|
||||
fiscalEndpoint string
|
||||
}
|
||||
|
||||
func NewClient(token string) *Client {
|
||||
@@ -13,5 +19,22 @@ func NewClient(token string) *Client {
|
||||
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,
|
||||
MaxVersion: tls.VersionTLS12,
|
||||
})
|
||||
|
||||
return &Client{
|
||||
token: token,
|
||||
device: device,
|
||||
resty: restyClient,
|
||||
apiBaseURL: dmURL,
|
||||
fiscalEndpoint: "/dm/fiscal",
|
||||
}
|
||||
}
|
||||
|
||||
@@ -8,11 +8,18 @@ import (
|
||||
)
|
||||
|
||||
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)
|
||||
}
|
||||
|
||||
resp, err := c.resty.R().
|
||||
SetContext(ctx).
|
||||
SetHeader("Authorization", c.token).
|
||||
SetBody(request).
|
||||
Post(c.apiBaseURL + "/fiscal/execute")
|
||||
SetBody(reqJson).
|
||||
Post(c.apiBaseURL + c.fiscalEndpoint)
|
||||
|
||||
if err != nil {
|
||||
return fmt.Errorf("request failed: %w", err)
|
||||
@@ -95,12 +102,6 @@ func (c *Client) Sell(ctx context.Context, params SellParams) (*SellResponse, er
|
||||
request.Userinfo = *params.Userinfo
|
||||
}
|
||||
|
||||
reqJson, err := json.Marshal(request)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
fmt.Println(string(reqJson))
|
||||
|
||||
var response SellResponse
|
||||
if err := c.executeRequest(ctx, request, &response); err != nil {
|
||||
return nil, err
|
||||
|
||||
@@ -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"`
|
||||
}
|
||||
|
||||
@@ -10,6 +10,7 @@ func ExampleBasicUsage() {
|
||||
Token: "your-token",
|
||||
Cashier: "Иванов",
|
||||
Source: "parking",
|
||||
CustomURL: "DM URL/",
|
||||
})
|
||||
|
||||
ctx := context.Background()
|
||||
|
||||
31
vchasno.go
31
vchasno.go
@@ -30,6 +30,8 @@ type Config struct {
|
||||
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,
|
||||
@@ -274,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)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user