wine-server/handlers/worker/worker.go

package worker

import (
	"Wine-Server/utils"
	"github.com/gorilla/websocket"
)

type openParam struct {
	Seq  string `json:"seq"`
	Kind string `json:"kind"`
}

func openGate(conn *websocket.Conn, wid string, data any) {
	var param openParam
	err := utils.AnyTrans(data, &param)
	if err != nil {
		_ = conn.WriteJSON(utils.WsError("params error"))
		return
	}
	if device, exist := utils.SellerWss[param.Seq]; exist {
		_ = device.WriteJSON(utils.WsEvent("openGate", utils.JsonType{
			"kind":   param.Kind,
			"worker": wid,
		}))
		return
	}
	_ = conn.WriteJSON(utils.WsError("no such device or device offline"))
}

func orderFinished(conn *websocket.Conn, obj any) {
	//
}