From cc34fae3647e98fd85c347dc951734ad740d496f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Fri, 11 Oct 2024 14:20:28 +0800 Subject: [PATCH] 1 --- business/partner/purchase/mtwm/order.go | 1 + controllers/mtwm_callback.go | 2 ++ globals/beegodb/beegodb.go | 2 ++ main.go | 3 +++ 4 files changed, 8 insertions(+) diff --git a/business/partner/purchase/mtwm/order.go b/business/partner/purchase/mtwm/order.go index f496a58c9..0ee72b627 100644 --- a/business/partner/purchase/mtwm/order.go +++ b/business/partner/purchase/mtwm/order.go @@ -567,6 +567,7 @@ func (c *PurchaseHandler) AcceptOrRefuseOrder(order *model.GoodsOrder, isAcceptI order.Status = model.OrderStatusAccepted dao.UpdateEntity(dao.GetDB(), order, "Status") } + partner.CurOrderManager.OnOrderMsg(order, "订单确认接单成功", utils.Time2TimeStr(time.Now())) } else { globals.SugarLogger.Warnf("mtwm AcceptOrRefuseOrder orderID:%s failed with err:%v", order.VendorOrderID, err) diff --git a/controllers/mtwm_callback.go b/controllers/mtwm_callback.go index 35ac04cb3..fd136ac89 100644 --- a/controllers/mtwm_callback.go +++ b/controllers/mtwm_callback.go @@ -8,6 +8,7 @@ import ( "net/http" "net/url" "strings" + "time" ) type MtwmController struct { @@ -38,6 +39,7 @@ func (c *MtwmController) NewOrder() { } func (c *MtwmController) OrderAccepted() { + time.Sleep(200 * time.Millisecond) // 测试看看有的订单来不拣货,可能是这个状态推的太快了,上一个NewOrder还没处理结束导致的 c.onCallbackMsg(mtwmapi.MsgTypeOrderAccepted) } diff --git a/globals/beegodb/beegodb.go b/globals/beegodb/beegodb.go index 149697107..bebeb0cd0 100644 --- a/globals/beegodb/beegodb.go +++ b/globals/beegodb/beegodb.go @@ -10,6 +10,7 @@ import ( ) func Init() { + globals.SugarLogger.Debugf("---------beegodb 0") //正式服务器 orm.RegisterDataBase("default", "mysql", web.AppConfig.DefaultString("dbConnectStr", "")) orm.RegisterDataBase("c4beta", "mysql", "ubuntu:WebServer@1@tcp(111.231.218.230:3306)/jxd_dev_0?charset=utf8mb4&loc=Local&parseTime=true") @@ -137,4 +138,5 @@ func Init() { orm.RegisterModel(&model.KnowledgeDepot{}) // create table orm.RunSyncdb("default", false, true) + globals.SugarLogger.Debugf("---------beegodb 1") } diff --git a/main.go b/main.go index b82c8c921..3f0461dc6 100644 --- a/main.go +++ b/main.go @@ -142,11 +142,14 @@ func checkCmdFlags() bool { func main() { if !checkCmdFlags() { + globals.SugarLogger.Debugf("---------0") Init() + globals.SugarLogger.Debugf("---------0.1") if err := tasks.RefreshWeixinToken(); err != nil { globals.SugarLogger.Errorf("RefreshWeixinToken failed with error:%s", err) return } + globals.SugarLogger.Debugf("---------0.2") if err := tasks.RefreshWeixin2Token(); err != nil { globals.SugarLogger.Errorf("RefreshWeixin2Token failed with error:%s", err) return