a

business/jxutils/tasks/configrefresh.go

@@ -29,7 +29,7 @@ const (
 	weimobTokenExpires    = 7200 * time.Second
 	yilianyunTokenExpires = 30 * 24 * 3600 * time.Second
 	pushTokenExpires      = 7200 * time.Second
-	fnTokenExpires        = 12 * time.Hour
+	fnTokenExpires        = 6 * time.Hour
 
 	maxRefreshGap = 5 * 60 * time.Second
 	errRefreshGap = 10 * time.Second

business/model/const.go

@@ -77,6 +77,7 @@ var (
 		WaybillStatusPending:             "压单",
 		WaybillStatusAcceptCanceled:      "取消接受",
 		WaybillStatusAccepted:            "已接单",
+		WaybillStatusCourierAssigned:     "已分配骑手",
 		WaybillStatusCourierArrived:      "已到店",
 		WaybillStatusApplyFailedGetGoods: "取货失败待审核",
 		WaybillStatusAgreeFailedGetGoods: "取货失败",
@@ -306,11 +307,12 @@ const (
 	WaybillStatusRefuseFailedGetGoods = -70
 	WaybillStatusUnknown              = 0
 
-	WaybillStatusNew            = 5
-	WaybillStatusPending        = 7
-	WaybillStatusAcceptCanceled = 8
-	WaybillStatusAccepted       = 10
-	WaybillStatusCourierArrived = 15 // 此状态是可选的，明确写出来是因为还是较重要的状态，但业务逻辑不应依赖此状态
+	WaybillStatusNew             = 5
+	WaybillStatusPending         = 7
+	WaybillStatusAcceptCanceled  = 8
+	WaybillStatusAccepted        = 10
+	WaybillStatusCourierAssigned = 12 //已分配骑手
+	WaybillStatusCourierArrived  = 15 // 此状态是可选的，明确写出来是因为还是较重要的状态，但业务逻辑不应依赖此状态
 
 	WaybillStatusApplyFailedGetGoods = 17 // 取货失败待审核
 	WaybillStatusAgreeFailedGetGoods = 18 // 取货失败

business/partner/delivery/fn/waybill.go

@@ -114,3 +114,34 @@ func (c *DeliveryHandler) GetWaybillFee(order *model.GoodsOrder) (deliveryFeeInf
 
 	return deliveryFeeInfo, err
 }
+
+func OnWaybillMsg(msg *fnpsapi.WayBillInfo) {
+	order := &model.Waybill{
+		VendorWaybillID:  msg.PartnerOrderCode,
+		VendorWaybillID2: msg.PartnerOrderCode,
+		WaybillVendorID:  model.VendorIDFengNiao,
+		CourierName:      msg.CarrierDriverName,
+		CourierMobile:    msg.CarrierDriverPhone,
+		VendorStatus:     utils.Int2Str(msg.OrderStatus),
+		StatusTime:       utils.Timestamp2Time(msg.PushTime),
+		Remark:           msg.Description,
+	}
+	order.VendorOrderID, order.OrderVendorID = jxutils.SplitUniversalOrderID(msg.PartnerOrderCode)
+	switch msg.OrderStatus {
+	case fnpsapi.OrderStatusAccept:
+		order.Status = model.WaybillStatusAccepted
+	case fnpsapi.OrderStatusAssigned:
+		order.Status = model.WaybillStatusCourierAssigned
+	case fnpsapi.OrderStatusArrived:
+		order.Status = model.WaybillStatusCourierArrived
+	case fnpsapi.OrderStatusDelivering:
+		order.Status = model.WaybillStatusDelivering
+	case fnpsapi.OrderStatusDelivered:
+		order.Status = model.WaybillStatusDelivered
+	case fnpsapi.OrderStatusException:
+		order.Status = model.WaybillStatusDeliverFailed
+	default:
+		globals.SugarLogger.Warnf("onWaybillMsg unknown msg:%v", msg)
+	}
+	partner.CurOrderManager.OnWaybillStatusChanged(order)
+}

controllers/fn_callback.go

@@ -3,6 +3,8 @@ package controllers
 import (
 	"net/http"
 
+	"git.rosy.net.cn/jx-callback/globals/api"
+
 	"github.com/astaxie/beego"
 )
 
@@ -12,7 +14,10 @@ type FnController struct {
 
 func (c *FnController) Msg() {
 	if c.Ctx.Input.Method() == http.MethodPost {
-
+		msg := api.FnAPI.GetOrderCallbackMsg(c.Ctx.Request)
+		if msg != nil {
+			fn.OnWaybillMsg(msg)
+		}
 		c.Data["json"] = ""
 		c.ServeJSON()
 	} else {