6 Commits

4 changed files with 78 additions and 31 deletions

View File

@@ -9,6 +9,7 @@ import (
type Client struct { type Client struct {
token string token string
device string device string
isDM bool
resty *resty.Client resty *resty.Client
apiBaseURL string apiBaseURL string
fiscalEndpoint string fiscalEndpoint string
@@ -17,6 +18,7 @@ type Client struct {
func NewClient(token string) *Client { func NewClient(token string) *Client {
return &Client{ return &Client{
token: token, token: token,
isDM: false,
resty: resty.New(), resty: resty.New(),
apiBaseURL: "https://kasa.vchasno.ua/api/v3", apiBaseURL: "https://kasa.vchasno.ua/api/v3",
fiscalEndpoint: "/fiscal/execute", fiscalEndpoint: "/fiscal/execute",
@@ -38,8 +40,9 @@ func NewDMClient(token, dmURL, device string) *Client {
return &Client{ return &Client{
token: token, token: token,
device: device, device: device,
isDM: true,
resty: restyClient, resty: restyClient,
apiBaseURL: dmURL, apiBaseURL: dmURL,
fiscalEndpoint: "/dm/fiscal", fiscalEndpoint: "/dm/execute",
} }
} }

View File

@@ -5,41 +5,69 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"io" "io"
"log"
) )
type APIError struct {
Code int
Message string
}
func (e *APIError) Error() string {
return fmt.Sprintf("vchasno api error %d: %s", e.Code, e.Message)
}
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 request.Device = c.device
if c.isDM {
request.Ver = 6
request.Type = 1
}
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)
} }
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 + c.fiscalEndpoint) 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))
}
var baseResp BaseResponse
if err := json.Unmarshal(body, &baseResp); err == nil {
if baseResp.HasError() {
return &APIError{
Code: baseResp.Res,
Message: baseResp.Errortxt,
}
}
} }
return nil return nil
@@ -48,8 +76,7 @@ func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, resp
func (c *Client) OpenShift(ctx context.Context, cashier string) (*SellResponse, error) { func (c *Client) OpenShift(ctx context.Context, cashier string) (*SellResponse, error) {
request := FiscalRequest{ request := FiscalRequest{
Fiscal: Fiscal{ Fiscal: Fiscal{
Task: TaskOpenShift, Task: TaskOpenShift,
Cashier: cashier,
}, },
} }
@@ -64,8 +91,7 @@ func (c *Client) OpenShift(ctx context.Context, cashier string) (*SellResponse,
func (c *Client) CloseShift(ctx context.Context, cashier string) (*ZReportResponse, error) { func (c *Client) CloseShift(ctx context.Context, cashier string) (*ZReportResponse, error) {
request := FiscalRequest{ request := FiscalRequest{
Fiscal: Fiscal{ Fiscal: Fiscal{
Task: TaskZReport, Task: TaskZReport,
Cashier: cashier,
}, },
} }

View File

@@ -1,8 +1,11 @@
package api package api
type FiscalRequest struct { type FiscalRequest struct {
Source string `json:"source"` Ver int `json:"ver,omitempty"`
Source string `json:"source,omitempty"`
Device string `json:"device,omitempty"` Device string `json:"device,omitempty"`
Tag string `json:"tag,omitempty"`
Type int `json:"type,omitempty"`
Userinfo Userinfo `json:"userinfo,omitempty"` Userinfo Userinfo `json:"userinfo,omitempty"`
Fiscal Fiscal `json:"fiscal"` Fiscal Fiscal `json:"fiscal"`
} }
@@ -14,7 +17,7 @@ type Userinfo struct {
type Fiscal struct { type Fiscal struct {
Task int `json:"task"` Task int `json:"task"`
Cashier string `json:"cashier"` Cashier string `json:"cashier,omitempty"`
Receipt *Receipt `json:"receipt,omitempty"` Receipt *Receipt `json:"receipt,omitempty"`
} }

View File

@@ -15,25 +15,40 @@ type BaseResponse struct {
ErrorExtra interface{} `json:"error_extra"` ErrorExtra interface{} `json:"error_extra"`
} }
func (r *BaseResponse) HasError() bool {
return r.Res != 0
}
func (r *BaseResponse) Error() string {
if r.Errortxt != "" {
return r.Errortxt
}
return ""
}
type SellResponse struct { type SellResponse struct {
BaseResponse BaseResponse
Info SellInfo `json:"info"` Info SellInfo `json:"info"`
} }
type SellInfo struct { type SellInfo struct {
Task int `json:"task"` Task int `json:"task"`
Fisid string `json:"fisid"` Fisid string `json:"fisid"`
Dataid int `json:"dataid"` Dataid int `json:"dataid"`
Doccode string `json:"doccode"` Doccode string `json:"doccode"`
Dt string `json:"dt"` Docno interface{} `json:"docno"`
Cashier string `json:"cashier"` Dt string `json:"dt"`
Dtype int `json:"dtype"` Cashier string `json:"cashier"`
Isprint int `json:"isprint"` Dtype int `json:"dtype"`
Isoffline bool `json:"isoffline"` Isprint int `json:"isprint"`
Safe float64 `json:"safe"` Isoffline bool `json:"isoffline"`
ShiftLink int `json:"shift_link"` Safe float64 `json:"safe"`
Docno int `json:"docno"` ShiftLink int `json:"shift_link"`
Cancelid string `json:"cancelid,omitempty"` ShiftPrevLink int `json:"shift_prev_link"`
ShiftID string `json:"shift_id"`
OpenShiftDt string `json:"open_shift_dt"`
Cancelid string `json:"cancelid,omitempty"`
SafeStartShift float64 `json:"safe_start_shift"`
} }
type ZReportResponse struct { type ZReportResponse struct {
@@ -46,6 +61,7 @@ type ZReportInfo struct {
Fisid string `json:"fisid"` Fisid string `json:"fisid"`
Dataid int `json:"dataid"` Dataid int `json:"dataid"`
Doccode string `json:"doccode"` Doccode string `json:"doccode"`
Docno interface{} `json:"docno"`
Dt string `json:"dt"` Dt string `json:"dt"`
Cashier string `json:"cashier"` Cashier string `json:"cashier"`
Dtype int `json:"dtype"` Dtype int `json:"dtype"`
@@ -53,7 +69,6 @@ type ZReportInfo struct {
Isoffline bool `json:"isoffline"` Isoffline bool `json:"isoffline"`
Safe float64 `json:"safe"` Safe float64 `json:"safe"`
ShiftLink int `json:"shift_link"` ShiftLink int `json:"shift_link"`
Docno int `json:"docno"`
Receipt ZReportReceipt `json:"receipt"` Receipt ZReportReceipt `json:"receipt"`
Summary ZReportSummary `json:"summary"` Summary ZReportSummary `json:"summary"`
Taxes []ZReportTax `json:"taxes"` Taxes []ZReportTax `json:"taxes"`