- onAfsOrderNew都要检查是否已有同号的售后单

business/jxcallback/orderman/order_afs.go

@@ -49,18 +49,22 @@ func (c *OrderManager) onAfsOrderNew(afsOrder *model.AfsOrder, orderStatus *mode
 		}
 		return err
 	}
-	if orderStatus.Status == model.AfsOrderStatusNew {
-		if _, err = c.loadAfsOrder(db, afsOrder.AfsOrderID, afsOrder.VendorID); err != nil {
-			if !dao.IsNoRowsError(err) {
-				return err
-			}
-		} else {
-			dao.Commit(db)
-			return nil
+	var existAfsOrder *model.AfsOrder
+	if existAfsOrder, err = c.loadAfsOrder(db, afsOrder.AfsOrderID, afsOrder.VendorID); err != nil {
+		if !dao.IsNoRowsError(err) {
+			return err
 		}
 	}
-	if err = c.SaveAfsOrder(db, afsOrder, isAdjust); err != nil {
-		return err
+	if existAfsOrder != nil {
+		existAfsOrder.Status = afsOrder.Status
+		existAfsOrder.VendorStatus = afsOrder.VendorStatus
+		if _, err = dao.UpdateEntity(db, existAfsOrder, "Status", "VendorStatus"); err != nil {
+			return err
+		}
+	} else {
+		if err = c.SaveAfsOrder(db, afsOrder, isAdjust); err != nil {
+			return err
+		}
 	}
 	dao.Commit(db)
 	scheduler.CurrentScheduler.OnAfsOrderNew(afsOrder, false)

business/partner/purchase/jd/order.go

@@ -47,6 +47,7 @@ func (c *PurchaseHandler) onOrderMsg(msg *jdapi.CallbackOrderMsg) (retVal *jdapi
 	} else if msg.MsgURL == jdapi.CallbackMsgAfterSaleBillStatus {
 		retVal = c.OnAfsOrderMsg(msg)
 	} else {
+		// 新订单事件，与订单状态有点冲突
 		if jdapi.StatusIDNewOrder == msg.StatusID {
 			retVal = c.onOrderNew(msg)
 		} else if jdapi.OrderStatusAdjust == msg.StatusID {