- xiaowm api

platformapi/xiaowmapi/xiaowmapi.go

@@ -0,0 +1,160 @@
+package xiaowmapi
+
+import (
+	"bytes"
+	"net/http"
+
+	"git.rosy.net.cn/baseapi"
+	"git.rosy.net.cn/baseapi/platformapi"
+	"git.rosy.net.cn/baseapi/utils"
+)
+
+const (
+	prodURL = "http://open.xiaowm.com"
+)
+
+const (
+	// ResponseCodeSuccess 操作成功
+	ResponseCodeSuccess = 0
+)
+
+const (
+	RunningStateOfflineStr = "正常运行"
+	RunningStateNormalStr  = "掉线"
+	RunningStateOffline    = 0
+	RunningStateNormal     = 1
+
+	PaperStateLackPaperStr = "缺纸"
+	PaperStateNormalStr    = "正常"
+	PaperStateLackPaper    = 0
+	PaperStateNormal       = 1
+)
+
+var (
+	exceedLimitCodes = map[int]int{}
+	canRetryCodes    = map[int]int{}
+
+	stateMap = map[string]int{
+		RunningStateOfflineStr: RunningStateOffline,
+		RunningStateNormalStr:  RunningStateNormal,
+		PaperStateLackPaperStr: PaperStateLackPaper,
+		PaperStateNormalStr:    PaperStateNormal,
+	}
+)
+
+type API struct {
+	appID  int    // 应用ID
+	appKey string // 应用编号
+	client *http.Client
+	config *platformapi.APIConfig
+}
+
+func New(appID int, appKey string, config ...*platformapi.APIConfig) *API {
+	curConfig := platformapi.DefAPIConfig
+	if len(config) > 0 {
+		curConfig = *config[0]
+	}
+	return &API{
+		appID:  appID,
+		appKey: appKey,
+		client: &http.Client{Timeout: curConfig.ClientTimeout},
+		config: &curConfig,
+	}
+}
+
+func (a *API) AccessAPI(apiName string, apiParams map[string]interface{}) (retVal map[string]interface{}, err error) {
+	params := utils.MergeMaps(map[string]interface{}{
+		"app_key": a.appKey,
+	}, apiParams)
+
+	err = platformapi.AccessPlatformAPIWithRetry(a.client,
+		func() *http.Request {
+			request, _ := http.NewRequest(http.MethodPost, utils.GenerateGetURL(prodURL, apiName, nil), bytes.NewReader(utils.MustMarshal(params)))
+			request.Header.Set("charset", "UTF-8")
+			request.Header.Set("Content-Type", "application/json")
+
+			// request.Close = true //todo 为了性能考虑还是不要关闭
+			return request
+		},
+		a.config,
+		func(jsonResult1 map[string]interface{}) (errLevel string, err error) {
+			code := int(utils.Interface2Int64WithDefault(jsonResult1["errno"], ResponseCodeSuccess))
+			if code == ResponseCodeSuccess {
+				retVal = jsonResult1
+				return platformapi.ErrLevelSuccess, nil
+			}
+			newErr := utils.NewErrorIntCode(jsonResult1["msg"].(string), code)
+			if _, ok := exceedLimitCodes[code]; ok {
+				return platformapi.ErrLevelExceedLimit, newErr
+			} else if _, ok := canRetryCodes[code]; ok {
+				return platformapi.ErrLevelRecoverableErr, newErr
+			} else {
+				baseapi.SugarLogger.Debugf("xiaowm AccessAPI failed, jsonResult1:%s", utils.Format4Output(jsonResult1, true))
+				return platformapi.ErrLevelCodeIsNotOK, newErr
+			}
+		})
+	return retVal, err
+}
+
+func (a *API) AuthPrinter(printerNumber, pwd, extends string) (printerToken string, err error) {
+	if pwd == "" {
+		pwd = "888888" // 缺省密码
+	}
+	params := map[string]interface{}{
+		"number": printerNumber,
+		"app_id": a.appID,
+		"pwd":    pwd,
+	}
+	if extends != "" {
+		params["extends"] = extends
+	}
+	result, err := a.AccessAPI("Auth_api/auth", params)
+	if err == nil {
+		return utils.Interface2String(result["data"].(map[string]interface{})["token"]), nil
+	}
+	return "", err
+}
+
+func (a *API) DelPrinter(printerNumber, printerToken string) (err error) {
+	_, err = a.AccessAPI("Auth_api/delete", map[string]interface{}{
+		"number": printerNumber,
+		"token":  printerToken,
+	})
+	return err
+}
+
+func (a *API) SendMsg(printerNumber, printerToken, msg string) (msgID string, err error) {
+	result, err := a.AccessAPI("Api/send_msg", map[string]interface{}{
+		"number": printerNumber,
+		"token":  printerToken,
+		"msg":    msg,
+	})
+	if err == nil {
+		return utils.Interface2String(result["msg_id"]), nil
+	}
+	return "", err
+}
+
+func (a *API) GetPrinterStatus(printerNumber, printerToken string) (runningState, paperState int, err error) {
+	result, err := a.AccessAPI("Api/get_printer_status", map[string]interface{}{
+		"number": printerNumber,
+		"token":  printerToken,
+	})
+	if err == nil {
+		data := result["data"].(map[string]interface{})
+		return stateMap[utils.Interface2String(data["running_state"])], stateMap[utils.Interface2String(data["paper_state"])], nil
+	}
+	return 0, 0, err
+}
+
+func (a *API) GetMsgStatus(printerNumber, printerToken, msgID string) (msgStatus string, err error) {
+	result, err := a.AccessAPI("Api/get_msg_status", map[string]interface{}{
+		"number": printerNumber,
+		"token":  printerToken,
+		"msg_id": msgID,
+	})
+	if err == nil {
+		return utils.Interface2String(result["msg"]), nil
+	}
+	return "", err
+}

platformapi/xiaowmapi/xiaowmapi_test.go

@@ -0,0 +1,61 @@
+package xiaowmapi
+
+import (
+	"testing"
+
+	"git.rosy.net.cn/baseapi"
+
+	"go.uber.org/zap"
+)
+
+var (
+	api         *API
+	sugarLogger *zap.SugaredLogger
+)
+
+func init() {
+	logger, _ := zap.NewDevelopment()
+	sugarLogger = logger.Sugar()
+	baseapi.Init(sugarLogger)
+
+	api = New(267, "94337")
+}
+
+func TestPrinterAuth(t *testing.T) {
+	result, err := api.AuthPrinter("7JizmSyiXNzkggaqU", "", "")
+	if err != nil {
+		t.Fatalf("PrinterAuth return error:%v", err)
+	}
+	t.Log(result)
+}
+
+func TestPrinterDel(t *testing.T) {
+	err := api.DelPrinter("7JizmSyiXNzkggaqU", "177f213277dd842ba2b53f6c926a48ea")
+	if err != nil {
+		t.Fatalf("PrinterDel return error:%v", err)
+	}
+}
+
+func TestSendMsg(t *testing.T) {
+	result, err := api.SendMsg("7JizmSyiXNzkggaqU", "177f213277dd842ba2b53f6c926a48ea", "hello")
+	if err != nil {
+		t.Fatalf("SendMsg return error:%v", err)
+	}
+	t.Log(result)
+}
+
+func TestGetPrinterStatus(t *testing.T) {
+	runningStae, paperState, err := api.GetPrinterStatus("7JizmSyiXNzkggaqU", "177f213277dd842ba2b53f6c926a48ea")
+	if err != nil {
+		t.Fatalf("GetPrinterStatus return error:%v", err)
+	}
+	t.Log(runningStae, paperState)
+}
+
+func TestGetMsgStatus(t *testing.T) {
+	msgStatus, err := api.GetMsgStatus("7JizmSyiXNzkggaqU", "177f213277dd842ba2b53f6c926a48ea", "29F953F9C26C4E2D7FD1279634C72ADD")
+	if err != nil {
+		t.Fatalf("GetMsgStatus return error:%v", err)
+	}
+	t.Log(msgStatus)
+}