diff --git a/business/jxcallback/orderman/waybill.go b/business/jxcallback/orderman/waybill.go
index 6a95a8c79..64bc2cc1a 100644
--- a/business/jxcallback/orderman/waybill.go
+++ b/business/jxcallback/orderman/waybill.go
@@ -92,8 +92,12 @@ func (w *OrderManager) OnWaybillStatusChanged(bill *model.Waybill) (err error) {
 			panic(r)
 		}
 	}()
+	duplicatedCount := 0
 	if bill.Status == model.WaybillStatusNew {
 		isDuplicated, err = w.onWaybillNew(bill, db)
+		if isDuplicated {
+			duplicatedCount = 1
+		}
 	} else {
 		if bill.Status == model.WaybillStatusAccepted { // 处理美团配送丢失新运单消息的情况
 			if _, err2 := w.LoadWaybill(bill.VendorWaybillID, bill.WaybillVendorID); err2 != nil {
@@ -126,11 +130,14 @@ func (w *OrderManager) OnWaybillStatusChanged(bill *model.Waybill) (err error) {
 		} else if bill.Status >= model.WaybillStatusEndBegin {
 			addParams["waybill_finished_at"] = bill.StatusTime
 		}
-		isDuplicated, err = w.addWaybillStatus(bill, db, addParams)
+		duplicatedCount, err = w.addWaybillStatus(bill, db, addParams)
+		if err != nil {
+			return err
+		}
 	}
 	if err == nil {
 		dao.Commit(db)
-		if !isDuplicated {
+		if duplicatedCount == 0 {
 			scheduler.CurrentScheduler.OnWaybillStatusChanged(bill, false)
 		}
 	} else {
@@ -155,21 +162,27 @@ func (w *OrderManager) OnWaybillStatusChanged(bill *model.Waybill) (err error) {
 	return err
 }
 
-func (w *OrderManager) addWaybillStatus(bill *model.Waybill, db *dao.DaoDB, addParams orm.Params) (isDuplicated bool, err error) {
+func (w *OrderManager) addWaybillStatus(bill *model.Waybill, db *dao.DaoDB, addParams orm.Params) (duplicatedCount int, err error) {
 	waybillStatus := model.Waybill2Status(bill)
-	isDuplicated, err = addOrderOrWaybillStatus(waybillStatus, db)
-	if err == nil && !isDuplicated && waybillStatus.Status > model.WaybillStatusUnknown { // todo 这里应该和addOrderStatus一样的改法，状态不能回绕
-		params := utils.MergeMaps(orm.Params{
-			"status":        bill.Status,
-			"vendor_status": bill.VendorStatus,
-			"status_time":   bill.StatusTime,
-		}, addParams)
-		utils.CallFuncLogError(func() error {
-			_, err = db.Db.QueryTable("waybill").Filter("vendor_waybill_id", bill.VendorWaybillID).Filter("waybill_vendor_id", bill.WaybillVendorID).Filter("status__lte", bill.Status).Update(params)
-			return err
-		}, "addWaybillStatus update waybill status, bill:%v", bill)
+	isDuplicated, err := addOrderOrWaybillStatus(waybillStatus, db)
+	if err == nil && !isDuplicated {
+		if waybillStatus.Status > model.WaybillStatusUnknown { // todo 这里应该和addOrderStatus一样的改法，状态不能回绕
+			params := utils.MergeMaps(orm.Params{
+				"status":        bill.Status,
+				"vendor_status": bill.VendorStatus,
+				"status_time":   bill.StatusTime,
+			}, addParams)
+			utils.CallFuncLogError(func() error {
+				_, err = db.Db.QueryTable("waybill").Filter("vendor_waybill_id", bill.VendorWaybillID).Filter("waybill_vendor_id", bill.WaybillVendorID).Filter("status__lte", bill.Status).Update(params)
+				return err
+			}, "addWaybillStatus update waybill status, bill:%v", bill)
+		} else {
+			duplicatedCount = -1
+		}
+	} else {
+		duplicatedCount = 1
 	}
-	return isDuplicated, err
+	return duplicatedCount, err
 }
 
 func (c *OrderManager) LoadWaybill(vendorWaybillID string, waybillVendorID int) (bill *model.Waybill, err error) {