144 lines
4.6 KiB
Go
144 lines
4.6 KiB
Go
package yilianyun
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
"time"
|
|
|
|
"git.rosy.net.cn/baseapi/platformapi/yilianyunapi"
|
|
"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 := `
|
|
<FS2><center>京西菜市</center></FS2>\n\n
|
|
<center>手机买菜上京西</center>
|
|
<center>极速到家送惊喜</center>\n
|
|
--------------------------------
|
|
下单时间: %s\n
|
|
预计送达: %s\n
|
|
订单编号: %s\n
|
|
\n
|
|
<FS2>%s#%d</FS2>\n\n
|
|
<QR>%s</QR>
|
|
\n
|
|
客户: %s\n
|
|
电话: %s\n
|
|
地址: %s\n
|
|
\n
|
|
客户备注: \n
|
|
<FS2>%s</FS2>\n
|
|
\n
|
|
<FB>实际支付:</FB>%s\n
|
|
\n
|
|
商品明细: \n
|
|
品名 数量 单价 小计\n
|
|
--------------------------------\n`
|
|
orderParams := []interface{}{
|
|
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\n`
|
|
orderFmt += `%10s%10s%10s\n`
|
|
orderParams = append(orderParams, sku.SkuName, "x"+utils.Int2Str(sku.Count), jxutils.IntPrice2StandardCurrencyString(sku.SalePrice), jxutils.IntPrice2StandardCurrencyString(sku.SalePrice*int64(sku.Count)))
|
|
}
|
|
orderFmt += `\n
|
|
<FB>共%d种%d件商品</FB>
|
|
\n
|
|
--------------------------------\n
|
|
<center><FB>商品质量问题请联系:</FB></center>
|
|
<center><FB>%s:%s</FB></center>\n
|
|
官方服务热线: 18011516898\n
|
|
更多信息请关注官方微信: 京西菜市\n
|
|
--------------------------------\n
|
|
--------------------------------\n
|
|
`
|
|
// <QR>http://weixin.qq.com/r/tkkDGzTERmk5rXB49xyk</QR>
|
|
orderParams = append(orderParams, order.SkuCount, order.GoodsCount, order.StoreName, storeTel)
|
|
return strings.Replace(fmt.Sprintf(strings.Replace(orderFmt, "\n", "", -1), orderParams...), "\\n", "\r\n", -1)
|
|
}
|
|
|
|
func (c *PrinterHandler) GetVendorID() int {
|
|
return model.VendorIDYiLianYun
|
|
}
|
|
|
|
func (c *PrinterHandler) PrintMsg(ctx *jxcontext.Context, machineCode, notUsed, msgTitle, msgContent string) (printerStatus *partner.PrinterStatus, err error) {
|
|
globals.SugarLogger.Debugf("PrintMsg machineCode:%s", machineCode)
|
|
if machineCode != "" {
|
|
if err = api.YilianyunAPI.PrintMsg(machineCode, msgTitle, msgContent); err == nil {
|
|
printerStatus, err = c.GetPrinterStatus(ctx, machineCode, "")
|
|
}
|
|
} else {
|
|
printerStatus = &partner.PrinterStatus{
|
|
PrintResult: partner.PrintResultNoPrinter,
|
|
}
|
|
}
|
|
return printerStatus, err
|
|
}
|
|
|
|
func (c *PrinterHandler) GetPrinterStatus(ctx *jxcontext.Context, machineCode, notUsed string) (printerStatus *partner.PrinterStatus, err error) {
|
|
status, err := api.YilianyunAPI.GetPrintStatus(machineCode)
|
|
if err == nil {
|
|
printerStatus = &partner.PrinterStatus{
|
|
PrintResult: partner.PrintResultSuccess,
|
|
}
|
|
if status == yilianyunapi.PrintStatusOffline {
|
|
printerStatus.PrinterStatus = partner.PrinterStatusOffline
|
|
} else if status == yilianyunapi.PrintStatusOnline {
|
|
printerStatus.PrinterStatus = partner.PrinterStatusOnlineOK
|
|
} else {
|
|
printerStatus.PrinterStatus = partner.PrinterStatusOnlineAbnormal
|
|
}
|
|
}
|
|
return printerStatus, err
|
|
}
|
|
|
|
func (c *PrinterHandler) PrintOrder(ctx *jxcontext.Context, store *model.Store, order *model.GoodsOrder) (printerStatus *partner.PrinterStatus, err error) {
|
|
globals.SugarLogger.Debugf("yilianyun PrintOrderByOrder orderID:%s", order.VendorOrderID)
|
|
content := c.getOrderContent(order, store.Tel1)
|
|
return c.PrintMsg(ctx, store.PrinterSN, "", order.VendorOrderID, content)
|
|
}
|
|
|
|
func (c *PrinterHandler) RegisterPrinter(ctx *jxcontext.Context, machineCode, secret, printerName string) (notUsed1, notUsed2 string, err error) {
|
|
err = api.YilianyunAPI.AddPrinter(machineCode, secret, printerName)
|
|
return "", "", err
|
|
}
|
|
|
|
func (c *PrinterHandler) UnregisterPrinter(ctx *jxcontext.Context, machineCode, notUsed string) (err error) {
|
|
err = api.YilianyunAPI.DeletePrinter(machineCode)
|
|
return err
|
|
}
|