liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复价格

Browse Source
This commit is contained in:
苏尹岚
2020-06-10 15:02:36 +08:00
parent cd1f0a23f2
commit 05ae5497e9
2 changed files with 18 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
business/jxcallback/orderman/order_afs.go
View File

@@ -295,6 +295,7 @@ func (c *OrderManager) updateAfsOrderSkuOtherInfo(db *dao.DaoDB, order *model.Af
globals.SugarLogger.Infof("updateAfsOrderSkuOtherInfo [运营%s]%s订单sku找不到门店价格（或商品映射），orderID:%s, StoreID:%d, VendorSkuID:%s, sku:%v", opNumStr, model.VendorChineseNames[order.VendorID], order.VendorOrderID, jxStoreID, v.VendorSkuID, v) globals.SugarLogger.Infof("updateAfsOrderSkuOtherInfo [运营%s]%s订单sku找不到门店价格（或商品映射），orderID:%s, StoreID:%d, VendorSkuID:%s, sku:%v", opNumStr, model.VendorChineseNames[order.VendorID], order.VendorOrderID, jxStoreID, v.VendorSkuID, v)
} else { } else {
v.JxSkuID = skuBindInfo.SkuID v.JxSkuID = skuBindInfo.SkuID
v.ShopPrice = int64(skuBindInfo.Price)
} }
} }
if actStoreSkuMap != nil { if actStoreSkuMap != nil {

36
business/jxstore/tempop/tempop.go
View File

@@ -1609,29 +1609,27 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// continue // continue
// } // }
// } // }
storeSkus, err := dao.GetStoresSkusInfo(dao.GetDB(), nil, nil) var orders []*model.GoodsOrder
sql := `
SELECT * FROM goods_order
WHERE order_created_at > '2020-06-10 12:20:00' AND vendor_id <> 5
AND vendor_order_id = '88033321555614726'
`
dao.GetRows(dao.GetDB(), &orders, sql, nil)
task := tasksch.NewParallelTask("刷新门店价格", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask("刷新门店价格", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(*model.StoreSkuBind) v := batchItemList[0].(*model.GoodsOrder)
skus, _ := dao.GetSkus(dao.GetDB(), []int{v.SkuID}, nil, nil, nil, nil) var sumPrice int64
if len(skus) > 0 { skus, _ := dao.GetSimpleOrderSkus(dao.GetDB(), v.VendorOrderID)
sku := skus[0] for _, vv := range skus {
if v.Price == v.UnitPrice { sumPrice += vv.ShopPrice
if sku.Unit == model.UnitNames[0] { }
if sku.SpecUnit == model.SpecUnitNames[1] || sku.SpecUnit == model.SpecUnitNames[2] { if sumPrice != v.ShopPrice {
v.Price = utils.Float64TwoInt(utils.Int2Float64(v.UnitPrice) * float64(sku.SpecQuality) * 2) v.ShopPrice = sumPrice
} else { dao.UpdateEntity(dao.GetDB(), v, "ShopPrice")
v.Price = utils.Float64TwoInt(utils.Int2Float64(v.UnitPrice) * float64(sku.SpecQuality/500))
}
v.JdsSyncStatus = v.JdsSyncStatus | 16
v.MtwmSyncStatus = v.MtwmSyncStatus | 16
v.EbaiSyncStatus = v.EbaiSyncStatus | 16
dao.UpdateEntity(dao.GetDB(), v, "Price", "JdsSyncStatus", "MtwmSyncStatus", "EbaiSyncStatus")
}
}
} }
return retVal, err return retVal, err
}, storeSkus) }, orders)
tasksch.HandleTask(task, nil, true).Run() tasksch.HandleTask(task, nil, true).Run()
task.GetID() task.GetID()
return err return err