Compare commits
6 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 23779ad6ad | |||
| f23c4ffd1c | |||
| 861a1640d4 | |||
| 28a8810ffb | |||
| 3ed7d33b84 | |||
| 3e02c6f2d5 |
@@ -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",
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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
|
||||||
@@ -49,7 +77,6 @@ func (c *Client) OpenShift(ctx context.Context, cashier string) (*SellResponse,
|
|||||||
request := FiscalRequest{
|
request := FiscalRequest{
|
||||||
Fiscal: Fiscal{
|
Fiscal: Fiscal{
|
||||||
Task: TaskOpenShift,
|
Task: TaskOpenShift,
|
||||||
Cashier: cashier,
|
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -65,7 +92,6 @@ func (c *Client) CloseShift(ctx context.Context, cashier string) (*ZReportRespon
|
|||||||
request := FiscalRequest{
|
request := FiscalRequest{
|
||||||
Fiscal: Fiscal{
|
Fiscal: Fiscal{
|
||||||
Task: TaskZReport,
|
Task: TaskZReport,
|
||||||
Cashier: cashier,
|
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -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"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -15,6 +15,17 @@ 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"`
|
||||||
@@ -25,6 +36,7 @@ type SellInfo 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"`
|
||||||
@@ -32,8 +44,11 @@ type SellInfo 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"`
|
ShiftPrevLink int `json:"shift_prev_link"`
|
||||||
|
ShiftID string `json:"shift_id"`
|
||||||
|
OpenShiftDt string `json:"open_shift_dt"`
|
||||||
Cancelid string `json:"cancelid,omitempty"`
|
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"`
|
||||||
|
|||||||
Reference in New Issue
Block a user