jdapi.AdjustOrder处理重复
This commit is contained in:
@@ -437,11 +437,18 @@ func (c *PurchaseHandler) CancelOrder(ctx *jxcontext.Context, order *model.Goods
|
|||||||
func (c *PurchaseHandler) AdjustOrder(ctx *jxcontext.Context, order *model.GoodsOrder, removedSkuList []*model.OrderSku, reason string) (err error) {
|
func (c *PurchaseHandler) AdjustOrder(ctx *jxcontext.Context, order *model.GoodsOrder, removedSkuList []*model.OrderSku, reason string) (err error) {
|
||||||
order = jxutils.RemoveSkuFromOrder(order, removedSkuList)
|
order = jxutils.RemoveSkuFromOrder(order, removedSkuList)
|
||||||
var oaosAdjustDTOList []*jdapi.OAOSAdjustDTO
|
var oaosAdjustDTOList []*jdapi.OAOSAdjustDTO
|
||||||
|
dtoMap := make(map[int]*jdapi.OAOSAdjustDTO)
|
||||||
for _, sku := range order.Skus {
|
for _, sku := range order.Skus {
|
||||||
oaosAdjustDTOList = append(oaosAdjustDTOList, &jdapi.OAOSAdjustDTO{
|
skuID := jxutils.GetSkuIDFromOrderSku(sku)
|
||||||
OutSkuID: utils.Int2Str(jxutils.GetSkuIDFromOrderSku(sku)),
|
if dtoMap[skuID] == nil {
|
||||||
SkuCount: sku.Count,
|
dtoMap[skuID] = &jdapi.OAOSAdjustDTO{
|
||||||
})
|
OutSkuID: utils.Int2Str(skuID),
|
||||||
|
SkuCount: sku.Count,
|
||||||
|
}
|
||||||
|
oaosAdjustDTOList = append(oaosAdjustDTOList, dtoMap[skuID])
|
||||||
|
} else {
|
||||||
|
dtoMap[skuID].SkuCount += sku.Count
|
||||||
|
}
|
||||||
}
|
}
|
||||||
if globals.EnableJdStoreWrite {
|
if globals.EnableJdStoreWrite {
|
||||||
err = getAPI(order.VendorOrgCode).AdjustOrder(order.VendorOrderID, ctx.GetUserName(), reason, oaosAdjustDTOList)
|
err = getAPI(order.VendorOrgCode).AdjustOrder(order.VendorOrderID, ctx.GetUserName(), reason, oaosAdjustDTOList)
|
||||||
|
|||||||
Reference in New Issue
Block a user