Add isDM flag to Client and update FiscalRequest structure for DM support

api/client.go

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

api/fiscal.go

@@ -8,9 +8,23 @@ import (
 	"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 {
 	request.Device = c.device
 
+	if c.isDM {
+		request.Ver = 6
+		request.Type = 1
+	}
+
 	reqJson, err := json.Marshal(request)
 	if err != nil {
 		return fmt.Errorf("failed to marshal request: %w", err)
@@ -46,14 +60,23 @@ func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, resp
 		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
 }
 
 func (c *Client) OpenShift(ctx context.Context, cashier string) (*SellResponse, error) {
 	request := FiscalRequest{
 		Fiscal: Fiscal{
-			Task:    TaskOpenShift,
+			Task: TaskOpenShift,
-			Cashier: cashier,
 		},
 	}
 
@@ -68,8 +91,7 @@ func (c *Client) OpenShift(ctx context.Context, cashier string) (*SellResponse,
 func (c *Client) CloseShift(ctx context.Context, cashier string) (*ZReportResponse, error) {
 	request := FiscalRequest{
 		Fiscal: Fiscal{
-			Task:    TaskZReport,
+			Task: TaskZReport,
-			Cashier: cashier,
 		},
 	}
 

api/requests.go

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

api/responses.go

@@ -15,6 +15,17 @@ type BaseResponse struct {
 	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 {
 	BaseResponse
 	Info SellInfo `json:"info"`