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

同步菜市物料到果园,更新list修改

Browse Source
This commit is contained in:
苏尹岚
2020-04-26 11:55:00 +08:00
parent f02fd61da7
commit b11d35cc47
1 changed files with 27 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -4351,7 +4351,6 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
sql := `
SELECT t1.*
FROM jxd_dev_0.sku_name t1
LEFT JOIN jxd_dev_0.sku t2 ON t2.name_id = t1.id
WHERE t1.deleted_at = ?
AND t1.id = ?
`
@@ -4407,8 +4406,14 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
return retVal, err
}
dao.Commit(db)
sql = "SELECT * FROM jxd_dev_0.store_sku_bind WHERE store_id = ? AND sku_id = ? "
sqlParams2 := []interface{}{model.MatterStoreID, v.ID}
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 = ?
`
sqlParams2 := []interface{}{model.MatterStoreID, v.EclpID}
err = dao.GetRows(db, &storeSkus, sql, sqlParams2)
if err != nil {
return retVal, err
@@ -4431,8 +4436,16 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
var (
storeSkus []*model.StoreSkuBind
skuName *model.SkuName
skuNames []*model.SkuName
)
skuNames, _ := dao.GetSkuNames(db, []int{v.NameID}, nil, "", false)
sql := `
SELECT t1.*
FROM jxd_dev_0.sku_name t1
WHERE t1.deleted_at = ?
AND t1.id = ?
`
sqlParams := []interface{}{utils.DefaultTimeValue, v.NameID}
err = dao.GetRows(db, &skuNames, sql, sqlParams)
if len(skuNames) > 0 {
skuName = skuNames[0]
}
@@ -4457,9 +4470,15 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
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)
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 = ?
`
sqlParams2 := []interface{}{model.MatterStoreID, v.EclpID}
err = dao.GetRows(db, &storeSkus, sql, sqlParams2)
if err != nil {
return retVal, err
}
@@ -4468,6 +4487,7 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
var skuBindInfos []*StoreSkuBindInfo
skuBindInfo := &StoreSkuBindInfo{
NameID: skuName.ID,
IsFocus: 1,
UnitPrice: storeSkus[0].UnitPrice,
}
skuBindInfos = append(skuBindInfos, skuBindInfo)