- FakeMsgTypeOrderReceived, FakeMsgTypeOrderDelivering for mtwm

business/partner/purchase/mtwm/waybill.go

@@ -1,6 +1,9 @@
 package mtwm
 
 import (
+	"net/url"
+	"time"
+
 	"git.rosy.net.cn/baseapi/platformapi/mtwmapi"
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/model"
@@ -27,7 +30,21 @@ func (p *PurchaseHandler) GetWaybillStatusFromVendorStatus(vendorStatus string)
 
 func (c *PurchaseHandler) onWaybillMsg(msg *mtwmapi.CallbackMsg) (response *mtwmapi.CallbackResponse) {
 	waybill := c.callbackMsg2Waybill(msg)
-	return mtwmapi.Err2CallbackResponse(partner.CurOrderManager.OnWaybillStatusChanged(waybill), "")
+	err := partner.CurOrderManager.OnWaybillStatusChanged(waybill)
+	if err == nil && waybill.Status == model.WaybillStatusDelivering {
+		msg := &mtwmapi.CallbackMsg{
+			Cmd:  FakeMsgTypeOrderDelivering,
+			Data: url.Values{},
+		}
+		msg.Data.Set("timestamp", utils.Int64ToStr(time.Now().Unix()))
+		msg.Data.Set("utime", msg.Data.Get("timestamp"))
+		msg.Data.Set(mtwmapi.KeyOrderID, waybill.VendorOrderID)
+		msg.Data.Set("status", mtwmapi.OrderStatusDelivering)
+		go func() {
+			OnOrderCallbackMsg(msg)
+		}()
+	}
+	return mtwmapi.Err2CallbackResponse(err, "")
 }
 
 func (c *PurchaseHandler) callbackMsg2Waybill(msg *mtwmapi.CallbackMsg) (retVal *model.Waybill) {