liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2024-10-11 14:20:28 +08:00
parent c5d0f41f10
commit cc34fae364
4 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
business/partner/purchase/mtwm/order.go
View File

@@ -567,6 +567,7 @@ func (c *PurchaseHandler) AcceptOrRefuseOrder(order *model.GoodsOrder, isAcceptI
order.Status = model.OrderStatusAccepted order.Status = model.OrderStatusAccepted
dao.UpdateEntity(dao.GetDB(), order, "Status") dao.UpdateEntity(dao.GetDB(), order, "Status")
} }
partner.CurOrderManager.OnOrderMsg(order, "订单确认接单成功", utils.Time2TimeStr(time.Now())) partner.CurOrderManager.OnOrderMsg(order, "订单确认接单成功", utils.Time2TimeStr(time.Now()))
} else { } else {
globals.SugarLogger.Warnf("mtwm AcceptOrRefuseOrder orderID:%s failed with err:%v", order.VendorOrderID, err) globals.SugarLogger.Warnf("mtwm AcceptOrRefuseOrder orderID:%s failed with err:%v", order.VendorOrderID, err)

2
controllers/mtwm_callback.go
View File

@@ -8,6 +8,7 @@ import (
"net/http" "net/http"
"net/url" "net/url"
"strings" "strings"
"time"
) )
type MtwmController struct { type MtwmController struct {
@@ -38,6 +39,7 @@ func (c *MtwmController) NewOrder() {
} }
func (c *MtwmController) OrderAccepted() { func (c *MtwmController) OrderAccepted() {
time.Sleep(200 * time.Millisecond) // 测试看看有的订单来不拣货,可能是这个状态推的太快了,上一个NewOrder还没处理结束导致的
c.onCallbackMsg(mtwmapi.MsgTypeOrderAccepted) c.onCallbackMsg(mtwmapi.MsgTypeOrderAccepted)
} }

2
globals/beegodb/beegodb.go
View File

@@ -10,6 +10,7 @@ import (
) )
func Init() { func Init() {
globals.SugarLogger.Debugf("---------beegodb 0")
//正式服务器 //正式服务器
orm.RegisterDataBase("default", "mysql", web.AppConfig.DefaultString("dbConnectStr", "")) 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") 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{}) orm.RegisterModel(&model.KnowledgeDepot{})
// create table // create table
orm.RunSyncdb("default", false, true) orm.RunSyncdb("default", false, true)
globals.SugarLogger.Debugf("---------beegodb 1")
} }

3
main.go
View File

@@ -142,11 +142,14 @@ func checkCmdFlags() bool {
func main() { func main() {
if !checkCmdFlags() { if !checkCmdFlags() {
globals.SugarLogger.Debugf("---------0")
Init() Init()
globals.SugarLogger.Debugf("---------0.1")
if err := tasks.RefreshWeixinToken(); err != nil { if err := tasks.RefreshWeixinToken(); err != nil {
globals.SugarLogger.Errorf("RefreshWeixinToken failed with error:%s", err) globals.SugarLogger.Errorf("RefreshWeixinToken failed with error:%s", err)
return return
} }
globals.SugarLogger.Debugf("---------0.2")
if err := tasks.RefreshWeixin2Token(); err != nil { if err := tasks.RefreshWeixin2Token(); err != nil {
globals.SugarLogger.Errorf("RefreshWeixin2Token failed with error:%s", err) globals.SugarLogger.Errorf("RefreshWeixin2Token failed with error:%s", err)
return return