" + "客户电话：17235643746" + printContent += "
" + printContent += "
" + printContent += StrRepeat("-", 32) + printContent += "
客户备注：缺货时电话与我沟通 收货人隐私号17882904902——5355，手机号 181****6752" + "
" + printContent += StrRepeat("-", 32) + printContent = printContent + "
商品列表" + StrRepeat(" ", 6) + "
" + printContent += "商品名" + StrRepeat(" ", 2) + "数量" + StrRepeat(" ", 3) + "单价" + StrRepeat(" ", 5) + "小计" + "
" + printContent += StrRepeat("-", 32) + printContent += FormatPrintOrderItem("[优]猪肉馅约250g/份", 1, 999) + printContent += FormatPrintOrderItem("鲜鸡蛋约250g/份", 1, 7.8) + printContent += FormatPrintOrderItem("豌豆米-手工剥豆约100g/份", 1, 4) + printContent += FormatPrintOrderItem("娃娃菜200g/个", 5, 2) + printContent += "
" + printContent += StrRepeat("-", 14) + "#23完" + StrRepeat("-", 14) + printContent += "
" + + request := PrintRequest{ + RestRequest: api.GenerateRestRequest(), + Sn: TestPrinterSN, + Content: printContent, + Copies: 1, + Voice: 2, + Mode: 1, + } + result, err := api.Print(&request) + //序列化 + reslutJson, _ := json.Marshal(result) + var msg = fmt.Sprintf("response result: %+v", string(reslutJson)) + fmt.Println(msg) + fmt.Println(err) +} + +////批量添加打印机 +//func TestAddPrinters(t *testing.T) { +// request := &AddPrinterRequest{ +// Items: []*AddPrinterRequestItem{{ +// Sn: TestPrinterSN, +// Name: "京西测试打印机0315", +// }}, +// RestRequest: api.GenerateRestRequest(), +// } +// err := api.AddPrinters(request) +// fmt.Println(err) +//} +// +////设置打印机语音类型 +//func TestSetVoiceType(t *testing.T) { +// request := &SetVoiceTypeRequest{ +// RestRequest: api.GenerateRestRequest(), +// Sn: TestPrinterSN, +// VoiceType: VoiceTypeV10PersonSmall, +// VolumeLevel: VolumeLevelSmall, +// } +// err := api.SetVoiceType(request) +// fmt.Println(err) +//} +// +////打印小票订单 +//func TestPrint(t *testing.T) { +// request := &PrintRequest{ +// RestRequest: api.GenerateRestRequest(), +// Sn: TestPrinterSN, +// Content: "-----测试打印小票订单---------" + +// "kljhsjkfhwiohguoiq" + +// "ojkahfohsajkohaowjgokaw", +// Copies: 1, +// Voice: VoicePlayOrder, +// Mode: ModeCheckYes, +// } +// orderID, err := api.Print(request) +// fmt.Println(orderID) +// fmt.Println(err) +//} +// +////删除打印机 +//func TestDelPrinter(t *testing.T) { +// request := &DelPrinterRequest{ +// RestRequest: api.GenerateRestRequest(), +// SnList: []string{ +// TestPrinterSN, +// }, +// } +// err := api.DelPrinters(request) +// fmt.Println(err) +//} +// +////修改打印机信息 +//func TestUpdPrinter(t *testing.T) { +// request := &UpdPrinterRequest{ +// RestRequest: api.GenerateRestRequest(), +// Sn: "234124", +// Name: "京西测试打印机3151", +// } +// err := api.UpdatePrinter(request) +// fmt.Println(err) +//} +// +////清空待打印队列 +//func TestEmptyPrinterQueue(t *testing.T) { +// request := &EmpPrinterQueueRequest{ +// RestRequest: api.GenerateRestRequest(), +// Sn: TestPrinterSN, +// } +// err := api.EmptyPrinterQueue(request) +// fmt.Println(err) +//} +// +////查询订单状态 +//func TestQueryOrderState(t *testing.T) { +// request := &QueryOrderStateRequest{ +// RestRequest: api.GenerateRestRequest(), +// OrderId: "dfhsehsteh", +// } +// state, err := api.QueryOrderState(request) +// fmt.Println(state) +// fmt.Println(err) +//} +// +////查询指定某天的订单统计数 +//func TestQueryOrderStatis(t *testing.T) { +// request := &QueryOrderStatisRequest{ +// RestRequest: api.GenerateRestRequest(), +// Sn: "72624647", +// Date: "2023-03-15", +// } +// printed, waiting, err := api.QueryOrderStatis(request) +// fmt.Println(printed) +// fmt.Println(waiting) +// fmt.Println(err) +//} +// +////查询指定打印机状态 +//func TestQueryPrinterStatus(t *testing.T) { +// request := &QueryPrinterStatusRequest{ +// RestRequest: api.GenerateRestRequest(), +// Sn: "7273737", +// } +// status, err := api.QueryPrinterStatus(request) +// fmt.Println(status) +// fmt.Println(err) +//} +// +////批量查询打印机状态 +//func TestBatchQueryPrinterStatus(t *testing.T) { +// request := &QueryPrintersStatusRequest{ +// RestRequest: api.GenerateRestRequest(), +// SnList: []string{ +// TestPrinterSN, +// "262623738", +// }, +// } +// status, err := api.QueryPrintersStatus(request) +// fmt.Println(status) +// fmt.Println(err) +//} +// +////金额播报 +//func TestPlayVoice(t *testing.T) { +// request := &PlayVoiceRequest{ +// RestRequest: api.GenerateRestRequest(), +// Sn: TestPrinterSN, +// PayType: PayTypeZFB, +// PayMode: PayModeReceipt, +// Money: 25.8, +// } +// err := api.PlayVoice(request) +// fmt.Println(err) +//} diff --git a/platformapi/xpyunapi/xputil.go b/platformapi/xpyunapi/xputil.go index 1a6a3402..cfa69d82 100644 --- a/platformapi/xpyunapi/xputil.go +++ b/platformapi/xpyunapi/xputil.go @@ -1 +1,171 @@ package xpyunapi + +import ( + "bytes" + "crypto/sha1" + "encoding/json" + "fmt" + "git.rosy.net.cn/baseapi/utils" + "golang.org/x/text/encoding/simplifiedchinese" + "golang.org/x/text/transform" + "io/ioutil" + "net/http" + "strconv" + "strings" + "time" +) + +/** + * 发送http的json请求 + * + * @param url 请求url + * @param jsonStr 发送的json字符串 + * + */ +func HttpPostJson(url string, data interface{}) *XPYunResp { + b, err := json.Marshal(&data) + if err != nil { + var msg = fmt.Sprintf("json serialize err:%+v", err) + fmt.Println(msg) + result := XPYunResp{ + HttpStatusCode: 500, + } + return &result + } + + //var reqMsg = fmt.Sprintf("response result:%+v", string(b)) + //fmt.Println(reqMsg) + + resp, err := http.Post(url, "application/json", bytes.NewBuffer(b)) + if err != nil { + fmt.Println(err) + } + defer resp.Body.Close() + body, err := ioutil.ReadAll(resp.Body) + if err != nil { + var msg = fmt.Sprintf("post json error:%+v", err) + fmt.Println(msg) + } + + result := XPYunResp{ + HttpStatusCode: resp.StatusCode, + } + + var content XPYunRespContent + err = json.Unmarshal(body, &content) + if err == nil { + result.Content = &content + } else { + var msg = fmt.Sprintf("unmarshal body failed, error:%+v", err) + fmt.Println(msg) + } + + return &result +} + +/** + * 哈稀签名 + * @param signSource - 源字符串 + * @return + */ +func Sign(signSource string) string { + h := sha1.New() + h.Write([]byte(signSource)) + result := fmt.Sprintf("%x", h.Sum(nil)) + return result +} + +//获得毫秒数 +func GetMillisecond() int64 { + return time.Now().UnixNano() / 1e6 +} + +/** + * 获得字符串重复 + * @param str - 要进行重复的字符串 + * @param repeatTimes - 重复次数 + */ +func StrRepeat(str string, repeatTimes int) string { + return strings.Repeat(str, repeatTimes) +} + +func CalcGbkLenForPrint(data string) int { + gbk, err := Utf8ToGbk(data) + if err != nil { + return 0 + } + + return len(gbk) +} + +func CalcAsciiLenForPrint(data string) int { + return len(data) +} + +func Utf8ToGbk(s string) (string, error) { + reader := transform.NewReader(bytes.NewReader([]byte(s)), simplifiedchinese.GBK.NewEncoder()) + d, e := ioutil.ReadAll(reader) + if e != nil { + return "", e + } + return string(d), nil +} + +//解析返回数据结构体 +func GetXpuResponse(data interface{}) *XPYunRespContent { + retVal := &XPYunRespContent{} + resultJson, _ := json.Marshal(data) + decoder := json.NewDecoder(bytes.NewBufferString(string(resultJson))) + if err := decoder.Decode(&retVal); err != nil { + return nil + } + return retVal +} + +const ROW_MAX_CHAR_LEN = 32 +const MAX_NAME_CHAR_LEN = 20 +const NEX_ROW_CHAR_LEN = 8 +const LAST_ROW_MAX_NAME_CHAR_LEN = 16 +const MAX_QUANTITY_CHAR_LEN = 6 +const MAX_PRICE_CHAR_LEN = 6 + +const LAST_ROW_MAX_NAME_CHAR_LEN80 = 24 //26 +const ROW_MAX_CHAR_LEN80 = 48 +const MAX_NAME_CHAR_LEN80 = 27 +const MAX_QUANTITY_CHAR_LEN80 = 7 + +//var orderNameEmpty = StrRepeat(" ", MAX_NAME_CHAR_LEN) +var orderNameEmpty = StrRepeat(" ", NEX_ROW_CHAR_LEN) + +//test函数 +func FormatPrintOrderItem(foodName string, quantity int, price float64) string { + + //foodNameLen := CalcGbkLenForPrint(foodName) + + quantityStr := strconv.Itoa(quantity) + quantityLen := CalcAsciiLenForPrint(quantityStr) + + priceStr := fmt.Sprintf("%.2f", price) + priceLen := CalcAsciiLenForPrint(priceStr) + + subtotalStr := fmt.Sprintf("%.2f", utils.Int2Float64(quantity)*price) + //subtotalLen := CalcAsciiLenForPrint(subtotalStr) + + result := foodName + "
" + //mod := foodNameLen % ROW_MAX_CHAR_LEN + //if mod <= LAST_ROW_MAX_NAME_CHAR_LEN { + // // 保证各个列的宽度固定，不足部分，利用空格填充 + // result = result + StrRepeat(" ", MAX_NAME_CHAR_LEN-mod) + // + //} else { + // // 另起新行 + // result = result + "
" + // result = result + orderNameEmpty + //} + + result += orderNameEmpty + "x" + quantityStr + StrRepeat(" ", MAX_QUANTITY_CHAR_LEN-quantityLen) + result += "￥" + priceStr + StrRepeat(" ", MAX_QUANTITY_CHAR_LEN+1-priceLen) + result += "￥" + subtotalStr + result += "
" + return result +} diff --git a/platformapi/xpyunapi/xpyunapi.go b/platformapi/xpyunapi/xpyunapi.go index 1a6a3402..66ca0ebe 100644 --- a/platformapi/xpyunapi/xpyunapi.go +++ b/platformapi/xpyunapi/xpyunapi.go @@ -1 +1,313 @@ package xpyunapi + +import ( + "errors" + "fmt" + "git.rosy.net.cn/baseapi/platformapi" + "net/http" + "strconv" + "strings" + "sync" +) + +const ( + baseURL = "https://open.xpyun.net/api/openapi/xprinter/" + signKey = "sign" + timestampKey = "timestamp" + debugTest = 1 //debug=1返回非json格式的数据，仅测试时候使用 +) + +const ( + ResponseCodeSuccess = 0 //成功 + ResponseMsgSuccess = "ok" +) + +var ( + exceedLimitCodes = map[string]int{} + canRetryCodes = map[string]int{} +) + +type API struct { + locker sync.RWMutex + accessToken string + + userName string + userKey string + client *http.Client + config *platformapi.APIConfig +} + +//初始化 +func New(userName, userKey string, config ...*platformapi.APIConfig) *API { + curConfig := platformapi.DefAPIConfig + if len(config) > 0 { + curConfig = *config[0] + } + return &API{ + userName: userName, + userKey: userKey, + client: &http.Client{Timeout: curConfig.ClientTimeout}, + config: &curConfig, + } +} + +//生成签名 +func (a *API) GenerateSign() string { + return Sign(a.userName + a.userKey + strconv.FormatInt(GetMillisecond(), 10)) +} + +//生成 RestRequest +func (a *API) GenerateRestRequest() RestRequest { + return RestRequest{ + User: a.userName, + UserKey: a.userKey, + Timestamp: GetMillisecond(), + Sign: a.GenerateSign(), + } +} + +func xpyunPostJson(url string, request interface{}) *XPYunResp { + result := HttpPostJson(url, request) + return result +} + +// 1.添加打印机到开发者账户（可批量） +func (a *API) AddPrinters(sn, printerName string) error { + url := baseURL + "addPrinters" + request := &AddPrinterRequest{ + RestRequest: a.GenerateRestRequest(), + Items: []*AddPrinterRequestItem{{ + Sn: sn, + Name: printerName, + }}, + } + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return fmt.Errorf("%v", XpuErrMsg2[resp.Content.Msg]) + } + retVal, _ := resp.Content.Data.(map[string]interface{}) + failMsg := "" + if len(retVal["failMsg"].([]interface{})) > 0 { + for _, v := range retVal["failMsg"].([]interface{}) { + t := strings.Split(v.(string), ":") + failMsg += t[0] + XpuErrMsg[t[1]] + } + return fmt.Errorf("添加打印机错误：%v", failMsg) + } + return nil +} + +//2.设置打印机语音类型 +func (a *API) SetVoiceType(sn string, soundSize int) error { + url := baseURL + "setVoiceType" + request := &SetVoiceTypeRequest{ + RestRequest: a.GenerateRestRequest(), + Sn: sn, + VoiceType: VoiceTypeOtherPerson, + VolumeLevel: soundSize, + } + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return fmt.Errorf("%v", XpuErrMsg2[resp.Content.Msg]) + } + retVal, _ := resp.Content.Data.(map[string]interface{}) + failMsg := "" + if retVal != nil && len(retVal["failMsg"].([]interface{})) > 0 { + for _, v := range retVal["failMsg"].([]interface{}) { + t := strings.Split(v.(string), ":") + failMsg += t[0] + XpuErrMsg[t[1]] + } + return fmt.Errorf("设置打印机运营类型错误：%v", failMsg) + } + return nil +} + +//3.打印小票订单 +func (a *API) Print(request *PrintRequest) (string, error) { + url := baseURL + "print" + request.RestRequest = a.GenerateRestRequest() + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return "0", errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return "0", fmt.Errorf("%v", XpuErrMsg2[resp.Content.Msg]) + } + retVal, _ := resp.Content.Data.(string) + if len(retVal) > 0 { + return retVal, nil + } else { + return "0", nil + } +} + +// 5.批量删除打印机 +func (a *API) DelPrinters(snList []string) error { + url := baseURL + "delPrinters" + request := &DelPrinterRequest{ + RestRequest: a.GenerateRestRequest(), + SnList: snList, + } + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return fmt.Errorf("%v", XpuErrMsg2[resp.Content.Msg]) + } + retVal, _ := resp.Content.Data.(map[string]interface{}) + failMsg := "" + if retVal != nil && len(retVal["failMsg"].([]interface{})) > 0 { + for _, v := range retVal["failMsg"].([]interface{}) { + t := strings.Split(v.(string), ":") + failMsg += t[0] + XpuErrMsg[t[1]] + } + return fmt.Errorf("删除打印机错误：%v", failMsg) + } + return nil +} + +//6.修改打印机信息 +func (a *API) UpdatePrinter(request *UpdPrinterRequest) error { + url := baseURL + "updPrinter" + request.RestRequest = a.GenerateRestRequest() + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return fmt.Errorf("%v", XpuErrMsg2[resp.Content.Msg]) + } + retVal, _ := resp.Content.Data.(map[string]interface{}) + failMsg := "" + if retVal != nil && len(retVal["failMsg"].([]interface{})) > 0 { + for _, v := range retVal["failMsg"].([]interface{}) { + t := strings.Split(v.(string), ":") + failMsg += t[0] + XpuErrMsg[t[1]] + } + return fmt.Errorf("修改打印机信息错误：%v", failMsg) + } + return nil +} + +//7.清空待打印队列 +func (a *API) EmptyPrinterQueue(sn string) error { + url := baseURL + "delPrinterQueue" + request := &EmpPrinterQueueRequest{ + RestRequest: a.GenerateRestRequest(), + Sn: sn, + } + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return fmt.Errorf("%v", XpuErrMsg[resp.Content.Msg]) + } + retVal, _ := resp.Content.Data.(map[string]interface{}) + failMsg := "" + if retVal != nil && len(retVal["failMsg"].([]interface{})) > 0 { + for _, v := range retVal["failMsg"].([]interface{}) { + t := strings.Split(v.(string), ":") + failMsg += t[0] + XpuErrMsg[t[1]] + } + return fmt.Errorf("清空待打印机队列错误：%v", failMsg) + } + return nil +} + +//8.查询订单状态 +func (a *API) QueryOrderState(request *QueryOrderStateRequest) (bool, error) { + url := baseURL + "queryOrderState" + request.RestRequest = a.GenerateRestRequest() + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return false, errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return false, fmt.Errorf("%v", XpuErrMsg2[resp.Content.Msg]) + } + return resp.Content.Data.(bool), nil +} + +//9.查询打印机某天的订单统计数 +func (a *API) QueryOrderStatis(request *QueryOrderStatisRequest) (printed, waiting float64, err error) { + url := baseURL + "queryOrderStatis" + request.RestRequest = a.GenerateRestRequest() + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return 0, 0, errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return 0, 0, fmt.Errorf("%v", XpuErrMsg2[resp.Content.Msg]) + } + retVal, _ := resp.Content.Data.(map[string]interface{}) + if retVal != nil { + printed = retVal["printed"].(float64) + waiting = retVal["waiting"].(float64) + return printed, waiting, nil + } + return 0, 0, nil +} + +//10.获取指定打印机状态 +//* 0、离线 1、在线正常 2、在线不正常 +// * 备注：异常一般是无纸，离线的判断是打印机与服务器失去联系超过30秒 +func (a *API) QueryPrinterStatus(sn string) (interface{}, error) { + url := baseURL + "queryPrinterStatus" + request := &QueryPrinterStatusRequest{ + RestRequest: a.GenerateRestRequest(), + Sn: sn, + } + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return PrinterStateError, errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return PrinterStateError, fmt.Errorf("%v", XpuErrMsg2[resp.Content.Msg]) + } + if resp.Content.Data != nil && resp.Content.Data.(float64) >= 0 { + return resp.Content.Data, nil + } + return PrinterStateError, nil +} + +//11.批量获取指定打印机状态 +func (a *API) QueryPrintersStatus(request *QueryPrintersStatusRequest) ([]float64, error) { + url := baseURL + "queryPrintersStatus" + request.RestRequest = a.GenerateRestRequest() + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return nil, errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return nil, fmt.Errorf("%v", XpuErrMsg2[resp.Content.Msg]) + } + retVal := []float64{} + if resp.Content.Data != nil && resp.Content.Data.(float64) >= 0 { + for _, v := range resp.Content.Data.([]interface{}) { + retVal = append(retVal, v.(float64)) + } + } + return nil, nil +} + +//12.金额播报 +func (a *API) PlayVoice(request *PlayVoiceRequest) error { + url := baseURL + "playVoice" + request.RestRequest = a.GenerateRestRequest() + resp := xpyunPostJson(url, request) + if resp.HttpStatusCode != HttpStatusSuccessCode { + return errors.New("HTTP请求错误，请检查重试") + } + if resp.Content.Code != ResponseCodeSuccess { + return fmt.Errorf("%v", XpuErrMsg2[resp.Content.Msg]) + } + return nil +}