ebai售后单

business/partner/purchase/ebai/order_afs.go

@@ -119,7 +119,43 @@ func (c *PurchaseHandler) onAfsOrderMsg(msg *ebaiapi.CallbackMsg) (retVal *ebaia
 				err = partner.CurOrderManager.OnAfsOrderNew(afsOrder, orderStatus)
 			}
 		} else {
-			err = partner.CurOrderManager.OnAfsOrderStatusChanged(orderStatus)
+			if afsOrder2, err := partner.CurOrderManager.LoadAfsOrder(orderStatus.VendorOrderID, orderStatus.VendorID); afsOrder2 == nil && err == nil {
+				partRefundData := msg.Data.(*ebaiapi.CBPartRefundInfo)
+				afsOrder := &model.AfsOrder{
+					VendorID:         model.VendorIDEBAI,
+					AfsOrderID:       orderStatus.VendorOrderID,
+					VendorOrderID:    orderStatus.RefVendorOrderID,
+					VendorStoreID:    "",
+					StoreID:          0,
+					AfsCreatedAt:     utils.Timestamp2Time(msg.Timestamp),
+					VendorAppealType: "",
+					AppealType:       model.AfsAppealTypeRefund,
+					VendorReasonType: partRefundData.ReasonType,
+					ReasonType:       c.convertAfsReasonType(partRefundData.ReasonType),
+					ReasonDesc:       utils.LimitUTF8StringLen(buildFullReason(partRefundData.Reason, partRefundData.AdditionReason), 1024),
+					ReasonImgList:    utils.LimitUTF8StringLen(strings.Join(partRefundData.Photos, ","), 1024),
+					RefundType:       model.AfsTypePartRefund,
+					VendorOrgCode:    msg.Source,
+				}
+				for _, sku := range partRefundData.RefundProducts {
+					orderSku := &model.OrderSkuFinancial{
+						Count:             sku.Number,
+						VendorSkuID:       sku.SkuID,
+						SkuID:             int(utils.Str2Int64WithDefault(sku.CustomSkuID, 0)),
+						Name:              sku.Name,
+						UserMoney:         sku.TotalRefund,
+						PmSkuSubsidyMoney: sku.ShopEleRefund,
+					}
+					afsOrder.SkuUserMoney += orderSku.UserMoney
+					afsOrder.PmSubsidyMoney += orderSku.PmSubsidyMoney
+					afsOrder.Skus = append(afsOrder.Skus, orderSku)
+				}
+				if afsOrder != nil {
+					err = partner.CurOrderManager.OnAfsOrderNew(afsOrder, orderStatus)
+				}
+			} else {
+				err = partner.CurOrderManager.OnAfsOrderStatusChanged(orderStatus)
+			}
 		}
 		retVal = api.EbaiAPI.Err2CallbackResponse(msg.Cmd, err, nil)
 	}