This commit is contained in:
邹宗楠
2023-04-10 16:41:06 +08:00
parent b86ee6373f
commit badacc25e1
2 changed files with 6 additions and 7 deletions

View File

@@ -72,14 +72,12 @@ func (c *OrderManager) onAfsOrderNew(afsOrder *model.AfsOrder, orderStatus *mode
} }
}() }()
if orderStatus.VendorID != model.VendorIDJX { isDuplicated, err := addOrderOrWaybillStatus(orderStatus, db)
isDuplicated, err := addOrderOrWaybillStatus(orderStatus, db) if err != nil || isDuplicated {
if err != nil || isDuplicated { if err == nil {
if err == nil { dao.Commit(db, txDB)
dao.Commit(db, txDB)
}
return err
} }
return err
} }
var existAfsOrder *model.AfsOrder var existAfsOrder *model.AfsOrder

View File

@@ -58,6 +58,7 @@ func buildAfsOrder(msg *CallbackMsg) (outAfsOrder *model.AfsOrder, err error) {
VendorAppealType: afsOrder.VendorAppealType, VendorAppealType: afsOrder.VendorAppealType,
AppealType: int8(utils.Str2Int64WithDefault(afsOrder.VendorAppealType, 0)), AppealType: int8(utils.Str2Int64WithDefault(afsOrder.VendorAppealType, 0)),
Flag: model.OrderFlagMaskTempJX, Flag: model.OrderFlagMaskTempJX,
RefundType: model.AfsTypeFullRefund,
} }
outAfsOrder.Status = int(utils.Str2Int64WithDefault(afsOrder.VendorStatus, 0)) outAfsOrder.Status = int(utils.Str2Int64WithDefault(afsOrder.VendorStatus, 0))