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-04-28 09:33:08 +08:00
parent 3243ac42e1
commit c6b33eed2f
1 changed files with 44 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files

89
business/jxstore/cms/store_sku.go
View File

@@ -4223,7 +4223,6 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
var ( var (
skuName *model.SkuName skuName *model.SkuName
skuNames []*model.SkuName skuNames []*model.SkuName
storeSkus []*model.StoreSkuBind
) )
sql := ` sql := `
SELECT t1.* SELECT t1.*
@@ -4283,36 +4282,12 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
return retVal, err return retVal, err
} }
dao.Commit(db) dao.Commit(db)
sql = ` focusC4Matters(ctx, db, v)
SELECT *
FROM jxd_dev_0.store_sku_bind a, jxd_dev_0.sku b
WHERE a.sku_id = b.id
AND a.store_id = ?
AND b.eclp_id = ?
AND a.deleted_at = ?
`
sqlParams2 := []interface{}{model.MatterStoreID, v.EclpID, utils.DefaultTimeValue}
err = dao.GetRows(db, &storeSkus, sql, sqlParams2)
if err != nil {
return retVal, err
}
if len(storeSkus) > 0 {
var skuBindInfos []*StoreSkuBindInfo
skuBindInfo := &StoreSkuBindInfo{
NameID: skuName.ID,
IsFocus: 1,
IsSale: 1,
UnitPrice: skuName.Price,
}
skuBindInfos = append(skuBindInfos, skuBindInfo)
updateStoresSkusWithoutSync(ctx, db, []int{model.MatterStoreID}, skuBindInfos, false)
}
} }
} }
if len(updateMatters) > 0 { if len(updateMatters) > 0 {
for _, v := range updateMatters { for _, v := range updateMatters {
var ( var (
storeSkus []*model.StoreSkuBind
skuName *model.SkuName skuName *model.SkuName
skuNames []*model.SkuName skuNames []*model.SkuName
) )
@@ -4363,30 +4338,8 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
return retVal, err return retVal, err
} }
} }
sql = `
SELECT a.*
FROM jxd_dev_0.store_sku_bind a, jxd_dev_0.sku b
WHERE a.sku_id = b.id
AND a.store_id = ?
AND b.eclp_id = ?
AND a.deleted_at = ?
`
sqlParams2 := []interface{}{model.MatterStoreID, v.EclpID, utils.DefaultTimeValue}
err = dao.GetRows(db, &storeSkus, sql, sqlParams2)
if err != nil {
return retVal, err
}
dao.Commit(db) dao.Commit(db)
if len(storeSkus) > 0 { focusC4Matters(ctx, db, v)
var skuBindInfos []*StoreSkuBindInfo
skuBindInfo := &StoreSkuBindInfo{
NameID: skuName.ID,
IsFocus: 1,
UnitPrice: storeSkus[0].UnitPrice,
}
skuBindInfos = append(skuBindInfos, skuBindInfo)
updateStoresSkusWithoutSync(ctx, db, []int{model.MatterStoreID}, skuBindInfos, false)
}
} }
} }
} }
@@ -4401,3 +4354,41 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
} }
return hint, err return hint, err
} }
func focusC4Matters(ctx *jxcontext.Context, db *dao.DaoDB, v *model.Sku) (err error) {
var storeSkus []*model.StoreSkuBind
sql := `
SELECT *
FROM jxd_dev_0.store_sku_bind a, jxd_dev_0.sku b
WHERE a.sku_id = b.id
AND a.store_id = ?
AND b.eclp_id = ?
AND a.deleted_at = ?
`
sqlParams2 := []interface{}{model.MatterStoreID, v.EclpID, utils.DefaultTimeValue}
err = dao.GetRows(db, &storeSkus, sql, sqlParams2)
if err != nil {
return err
}
if len(storeSkus) > 0 {
var (
skuBindInfos []*StoreSkuBindInfo
skuName2 *model.SkuName
)
sql := `
SELECT * FROM sku_name a, sku b WHERE a.id = b.name_id AND b.eclp_id = ? AND a.deleted_at = ?
`
sqlParams := []interface{}{v.EclpID, utils.DefaultTimeValue}
err = dao.GetRow(db, &skuName2, sql, sqlParams)
if skuName2 != nil {
skuBindInfo := &StoreSkuBindInfo{
NameID: skuName2.ID,
IsFocus: 1,
UnitPrice: skuName2.Price,
}
skuBindInfos = append(skuBindInfos, skuBindInfo)
}
updateStoresSkusWithoutSync(ctx, db, []int{model.MatterStoreID}, skuBindInfos, false)
}
return err
}