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-26 10:17:49 +08:00
parent d40f02701d
commit 7796df7dae
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -4345,9 +4345,19 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
for _, v := range addMatters { for _, v := range addMatters {
var ( var (
skuName *model.SkuName skuName *model.SkuName
skuNames []*model.SkuName
storeSkus []*model.StoreSkuBind storeSkus []*model.StoreSkuBind
) )
skuNames, _ := dao.GetSkuNames(db, []int{v.NameID}, nil, "", false) sql := `
SELECT *
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 = ?
AND t2.exd_sku_id <> ''
`
sqlParams := []interface{}{utils.DefaultTimeValue, v.NameID}
err = dao.GetRows(db, &skuNames, sql, sqlParams)
if len(skuNames) > 0 { if len(skuNames) > 0 {
skuName = skuNames[0] skuName = skuNames[0]
} }
@@ -4377,9 +4387,9 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool)
if err != nil { if err != nil {
return retVal, err return retVal, err
} }
sql := "SELECT * FROM jxd_dev_0.store_sku_bind WHERE store_id = ? AND sku_id = ? " sql = "SELECT * FROM jxd_dev_0.store_sku_bind WHERE store_id = ? AND sku_id = ? "
sqlParams := []interface{}{model.MatterStoreID, v.ID} sqlParams2 := []interface{}{model.MatterStoreID, v.ID}
err = dao.GetRows(db, &storeSkus, sql, sqlParams) err = dao.GetRows(db, &storeSkus, sql, sqlParams2)
if err != nil { if err != nil {
return retVal, err return retVal, err
} }