价格统计去掉事务

This commit is contained in:
苏尹岚
2020-02-14 11:10:55 +08:00
parent f360072894
commit 9b53e546b9

View File

@@ -263,12 +263,8 @@ func BeginSavePriceRefer(ctx *jxcontext.Context, cityCodes, skuIDs []int, isAsyn
v := batchItemList[0].(*model.PriceReferSnapshot) v := batchItemList[0].(*model.PriceReferSnapshot)
for _, appOrg := range apimanager.CurAPIManager.GetAppOrgCodeList(model.VendorIDJD) { for _, appOrg := range apimanager.CurAPIManager.GetAppOrgCodeList(model.VendorIDJD) {
directPrice, _ := jd.GetAPI(appOrg).GetJdSkuDirectPrice(v.SkuID) directPrice, _ := jd.GetAPI(appOrg).GetJdSkuDirectPrice(v.SkuID)
if directPrice == 0 { v.JdDirectPrice = int(directPrice)
continue dao.UpdateEntity(db, v, "JdDirectPrice")
} else {
v.JdDirectPrice = int(directPrice)
dao.UpdateEntity(db, v, "JdDirectPrice")
}
} }
return retVal, err return retVal, err
} }