241 lines
7.3 KiB
Go
241 lines
7.3 KiB
Go
package xiaowm
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
"time"
|
|
|
|
"git.rosy.net.cn/baseapi/platformapi/xiaowmapi"
|
|
|
|
"git.rosy.net.cn/baseapi/utils"
|
|
"git.rosy.net.cn/jx-callback/business/jxutils"
|
|
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
|
|
"git.rosy.net.cn/jx-callback/business/model"
|
|
"git.rosy.net.cn/jx-callback/business/partner"
|
|
"git.rosy.net.cn/jx-callback/globals"
|
|
"git.rosy.net.cn/jx-callback/globals/api"
|
|
)
|
|
|
|
var (
|
|
CurPrinterHandler *PrinterHandler
|
|
)
|
|
|
|
type PrinterHandler struct {
|
|
}
|
|
|
|
func init() {
|
|
CurPrinterHandler = new(PrinterHandler)
|
|
partner.RegisterPrinterPlatform(CurPrinterHandler)
|
|
}
|
|
|
|
func (c *PrinterHandler) getOrderContent(order *model.GoodsOrder, storeTel string) (content string) {
|
|
expectedDeliveryTime := order.ExpectedDeliveredTime
|
|
if utils.IsTimeZero(expectedDeliveryTime) {
|
|
expectedDeliveryTime = order.OrderCreatedAt.Add(1 * time.Hour)
|
|
}
|
|
orderFmt := `
|
|
<big> %s**
|
|
手机买菜上京西*
|
|
极速到家送惊喜*
|
|
------------------------------*
|
|
下单时间: %s*
|
|
预计送达: %s*
|
|
订单编号: %s*
|
|
*
|
|
<big>%s\#%d**
|
|
<qrcA4>%s*
|
|
客户: %s*
|
|
电话: %s*
|
|
地址: %s*
|
|
*
|
|
客户备注: *
|
|
<big>%s*
|
|
*
|
|
<S011>实际支付: %s*
|
|
*
|
|
商品明细: *
|
|
品名 数量 单价 小计
|
|
--------------------------------*
|
|
`
|
|
orderParams := []interface{}{
|
|
globals.StoreName,
|
|
utils.Time2Str(order.OrderCreatedAt),
|
|
utils.Time2Str(expectedDeliveryTime),
|
|
order.VendorOrderID,
|
|
jxutils.GetVendorName(order.VendorID),
|
|
order.OrderSeq,
|
|
order.VendorOrderID,
|
|
order.ConsigneeName,
|
|
order.ConsigneeMobile,
|
|
order.ConsigneeAddress,
|
|
order.BuyerComment,
|
|
jxutils.IntPrice2StandardCurrencyString(order.ActualPayPrice),
|
|
}
|
|
for _, sku := range order.Skus {
|
|
orderFmt += `%s*`
|
|
orderFmt += `%8s%10s%10s*`
|
|
orderParams = append(orderParams, sku.SkuName, "x"+utils.Int2Str(sku.Count), jxutils.IntPrice2StandardCurrencyString(sku.SalePrice), jxutils.IntPrice2StandardCurrencyString(sku.SalePrice*int64(sku.Count)))
|
|
}
|
|
orderFmt += `
|
|
*
|
|
<S011>共%d种%d件商品*
|
|
--------------------------------*
|
|
<S020>商品质量问题请联系:*
|
|
<S020>%s:%s*
|
|
*
|
|
更多信息请关注官方微信: %s*
|
|
--------------------------------
|
|
--------------------------------
|
|
*<BEEP13500,3,2,1>*
|
|
`
|
|
// <QR>http://weixin.qq.com/r/tkkDGzTERmk5rXB49xyk</QR>
|
|
orderParams = append(orderParams, order.SkuCount, order.GoodsCount, order.StoreName, storeTel, globals.StoreName)
|
|
return fmt.Sprintf(strings.Replace(orderFmt, "\n", "", -1), escapeString4Printer(orderParams)...)
|
|
}
|
|
|
|
func (c *PrinterHandler) getOrderContent2(order *model.GoodsOrder, storeTel string) (content string) {
|
|
expectedDeliveryTime := order.ExpectedDeliveredTime
|
|
if utils.IsTimeZero(expectedDeliveryTime) {
|
|
expectedDeliveryTime = order.OrderCreatedAt.Add(1 * time.Hour)
|
|
}
|
|
orderFmt := `
|
|
|7 %s
|
|
|5 手机买菜上京西
|
|
|5 极速到家送惊喜
|
|
|5--------------------------------
|
|
|5下单时间: %s
|
|
|5预计送达: %s
|
|
|5订单编号: %s
|
|
|5
|
|
|7%s\#%d
|
|
|5
|
|
|2%s
|
|
|5客户: %s
|
|
|5电话: %s
|
|
|5地址: %s
|
|
|5
|
|
|5客户备注:
|
|
|7%s
|
|
|5
|
|
|6实际支付: %s
|
|
|5
|
|
|5商品明细:
|
|
|5品名 数量 单价 小计
|
|
|5--------------------------------
|
|
`
|
|
orderParams := []interface{}{
|
|
globals.StoreName,
|
|
utils.Time2Str(order.OrderCreatedAt),
|
|
utils.Time2Str(expectedDeliveryTime),
|
|
order.VendorOrderID,
|
|
jxutils.GetVendorName(order.VendorID),
|
|
order.OrderSeq,
|
|
order.VendorOrderID,
|
|
order.ConsigneeName,
|
|
order.ConsigneeMobile,
|
|
order.ConsigneeAddress,
|
|
order.BuyerComment,
|
|
jxutils.IntPrice2StandardCurrencyString(order.ActualPayPrice),
|
|
}
|
|
for _, sku := range order.Skus {
|
|
orderFmt += `|5%s`
|
|
orderFmt += `|5%8s%10s%10s`
|
|
orderParams = append(orderParams, sku.SkuName, "x"+utils.Int2Str(sku.Count), jxutils.IntPrice2StandardCurrencyString(sku.SalePrice), jxutils.IntPrice2StandardCurrencyString(sku.SalePrice*int64(sku.Count)))
|
|
}
|
|
orderFmt += `
|
|
|5
|
|
|6共%d种%d件商品
|
|
|5--------------------------------
|
|
|5商品质量问题请联系:
|
|
|5%s:%s
|
|
|5
|
|
|5更多信息请关注官方微信: %s
|
|
|5--------------------------------
|
|
|5--------------------------------
|
|
`
|
|
orderParams = append(orderParams, order.SkuCount, order.GoodsCount, order.StoreName, storeTel, globals.StoreName)
|
|
return fmt.Sprintf(orderFmt, escapeString4Printer(orderParams)...)
|
|
}
|
|
|
|
func (c *PrinterHandler) GetVendorID() int {
|
|
return model.VendorIDXiaoWM
|
|
}
|
|
|
|
func (c *PrinterHandler) PrintMsg(ctx *jxcontext.Context, printerNumber, printerToken, msgTitle, msgContent string) (printerStatus *partner.PrinterStatus, err error) {
|
|
globals.SugarLogger.Debugf("PrintMsg printerNumber:%s", printerNumber)
|
|
if printerNumber != "" {
|
|
if _, err = api.XiaoWMAPI.SendMsg(printerNumber, printerToken, msgContent); err == nil {
|
|
printerStatus, err = c.GetPrinterStatus(ctx, printerNumber, printerToken)
|
|
}
|
|
} else {
|
|
printerStatus = &partner.PrinterStatus{
|
|
PrintResult: partner.PrintResultNoPrinter,
|
|
}
|
|
}
|
|
return printerStatus, err
|
|
}
|
|
|
|
func (c *PrinterHandler) GetPrinterStatus(ctx *jxcontext.Context, printerNumber, printerToken string) (printerStatus *partner.PrinterStatus, err error) {
|
|
runningState, paperState, err := api.XiaoWMAPI.GetPrinterStatus(printerNumber, printerToken)
|
|
if err == nil {
|
|
printerStatus = &partner.PrinterStatus{
|
|
PrintResult: partner.PrintResultSuccess,
|
|
}
|
|
if runningState == xiaowmapi.RunningStateOffline {
|
|
printerStatus.PrinterStatus = partner.PrinterStatusOffline
|
|
} else {
|
|
if paperState == xiaowmapi.PaperStateLackPaper {
|
|
printerStatus.PrinterStatus = partner.PrinterStatusOnlineAbnormal
|
|
} else {
|
|
printerStatus.PrinterStatus = partner.PrinterStatusOnlineOK
|
|
}
|
|
}
|
|
}
|
|
return printerStatus, err
|
|
}
|
|
|
|
func (c *PrinterHandler) PrintOrder(ctx *jxcontext.Context, store *model.Store, order *model.GoodsOrder) (printerStatus *partner.PrinterStatus, err error) {
|
|
globals.SugarLogger.Debugf("xiaowm PrintOrderByOrder orderID:%s", order.VendorOrderID)
|
|
var content string
|
|
if isV500(store.PrinterSN) {
|
|
content = c.getOrderContent2(order, store.Tel1)
|
|
} else {
|
|
content = c.getOrderContent(order, store.Tel1)
|
|
}
|
|
return c.PrintMsg(ctx, store.PrinterSN, store.PrinterKey, order.VendorOrderID, content)
|
|
}
|
|
|
|
func isV500(printerNo string) bool {
|
|
printerNoNum := utils.Str2Int64WithDefault("1"+printerNo, 0)
|
|
return printerNoNum > 1000000000
|
|
}
|
|
|
|
func (c *PrinterHandler) RegisterPrinter(ctx *jxcontext.Context, printerNumber, notUsed, printerName string) (newID1, printerToken string, err error) {
|
|
globals.SugarLogger.Debugf("xiaowm RegisterPrinter printerNumber:%s", printerNumber)
|
|
if printerNumber == "" { //len(printerNumber) != len("7JizmSyiXNzkggaqU") {
|
|
err = fmt.Errorf("外卖管家打印机设备编号:%s长度不合法", printerNumber)
|
|
} else {
|
|
if printerToken, err = api.XiaoWMAPI.AuthPrinter(printerNumber, "", ""); err == nil {
|
|
if _, err = c.GetPrinterStatus(ctx, printerNumber, printerToken); err != nil {
|
|
c.UnregisterPrinter(ctx, printerNumber, printerToken)
|
|
}
|
|
}
|
|
}
|
|
globals.SugarLogger.Debugf("xiaowm RegisterPrinter printerNumber:%s, error:%v", printerNumber, err)
|
|
return "", printerToken, err
|
|
}
|
|
|
|
func (c *PrinterHandler) UnregisterPrinter(ctx *jxcontext.Context, printerNumber, printerToken string) (err error) {
|
|
err = api.XiaoWMAPI.DelPrinter(printerNumber, printerToken)
|
|
return err
|
|
}
|
|
|
|
func escapeString4Printer(params []interface{}) []interface{} {
|
|
for k, v := range params {
|
|
if vStr, ok := v.(string); ok {
|
|
params[k] = strings.Replace(vStr, "*", "\\*", -1)
|
|
}
|
|
}
|
|
return params
|
|
}
|