This commit is contained in:
邹宗楠
2024-07-22 17:10:05 +08:00
parent 867a50b428
commit 8223c2d050
3 changed files with 10 additions and 2 deletions

View File

@@ -83,6 +83,10 @@ func (c *OrderManager) onAfsOrderNew(afsOrder *model.AfsOrder, orderStatus *mode
} }
} }
if afsOrder.Status != existAfsOrder.Status && existAfsOrder.Status >= model.AfsOrderStatusFinished {
return nil
}
if existAfsOrder != nil { if existAfsOrder != nil {
// todo 可能导致状态回绕 // todo 可能导致状态回绕
existAfsOrder.Status = afsOrder.Status existAfsOrder.Status = afsOrder.Status

View File

@@ -2,6 +2,7 @@ package defsch
import ( import (
"fmt" "fmt"
"git.rosy.net.cn/jx-callback/business/partner/purchase/mtwm"
"math/rand" "math/rand"
"sort" "sort"
"strings" "strings"
@@ -408,6 +409,8 @@ func (s *DefScheduler) OnOrderNew(order *model.GoodsOrder, isPending bool, isAut
} }
msghub.OnNewOrder(order) msghub.OnNewOrder(order)
} }
} else if order.VendorID == model.VendorIDMTWM {
mtwm.GetAPI(order.VendorOrgCode, jxutils.GetSaleStoreIDFromOrder(order), order.VendorStoreID).PushPrintMsg(order.VendorOrderID)
} }
if order.Status >= model.OrderStatusNew { if order.Status >= model.OrderStatusNew {
if !isPending && order.Status >= model.OrderStatusAccepted { // 有订单消息错序先收到接单消息再收到新订单消息导致接单TIMER不动作这里补一下 if !isPending && order.Status >= model.OrderStatusAccepted { // 有订单消息错序先收到接单消息再收到新订单消息导致接单TIMER不动作这里补一下

View File

@@ -2,6 +2,7 @@ package netprinter
import ( import (
"fmt" "fmt"
"git.rosy.net.cn/jx-callback/business/jxutils"
"strings" "strings"
"time" "time"
@@ -10,7 +11,6 @@ import (
"git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/business/partner" "git.rosy.net.cn/jx-callback/business/partner"
"git.rosy.net.cn/jx-callback/business/jxutils"
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
"git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model"
"git.rosy.net.cn/jx-callback/business/model/dao" "git.rosy.net.cn/jx-callback/business/model/dao"
@@ -47,7 +47,8 @@ func PrintOrder(ctx *jxcontext.Context, vendorOrderID string, vendorID int) (pri
} }
func PrintOrderByOrder(ctx *jxcontext.Context, order *model.GoodsOrder, printType string, afs *model.AfsOrder) (printResult *partner.PrinterStatus, err error) { func PrintOrderByOrder(ctx *jxcontext.Context, order *model.GoodsOrder, printType string, afs *model.AfsOrder) (printResult *partner.PrinterStatus, err error) {
return PrintOrderByOrder4Store(ctx, order, jxutils.GetSaleStoreIDFromOrder(order), printType, afs) printResult, err = PrintOrderByOrder4Store(ctx, order, jxutils.GetSaleStoreIDFromOrder(order), printType, afs)
return printResult, err
} }
func getStore4Print(db *dao.DaoDB, storeID int) (store *model.Store, err error) { func getStore4Print(db *dao.DaoDB, storeID int) (store *model.Store, err error) {