菜市物料同步到果园优化门店商品价格
This commit is contained in:
@@ -4398,7 +4398,10 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
|
||||
}
|
||||
if len(updateMatters) > 0 {
|
||||
for _, v := range updateMatters {
|
||||
var skuName *model.SkuName
|
||||
var (
|
||||
storeSkus []*model.StoreSkuBind
|
||||
skuName *model.SkuName
|
||||
)
|
||||
skuNames, _ := dao.GetSkuNames(db, []int{v.NameID}, nil, "", false)
|
||||
if len(skuNames) > 0 {
|
||||
skuName = skuNames[0]
|
||||
@@ -4420,7 +4423,22 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
|
||||
dao.Rollback(db)
|
||||
return retVal, err
|
||||
}
|
||||
sql := "SELECT * FROM jxd_dev_0.store_sku_bind WHERE store_id = ? AND sku_id = ? "
|
||||
sqlParams := []interface{}{model.MatterStoreID, v.ID}
|
||||
err = dao.GetRows(db, &storeSkus, sql, sqlParams)
|
||||
if err != nil {
|
||||
return retVal, err
|
||||
}
|
||||
dao.Commit(db)
|
||||
if len(storeSkus) > 0 {
|
||||
var skuBindInfos []*StoreSkuBindInfo
|
||||
skuBindInfo := &StoreSkuBindInfo{
|
||||
NameID: skuName.ID,
|
||||
UnitPrice: storeSkus[0].UnitPrice,
|
||||
}
|
||||
skuBindInfos = append(skuBindInfos, skuBindInfo)
|
||||
updateStoresSkusWithoutSync(ctx, db, []int{model.MatterStoreID}, skuBindInfos, false)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user