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

- restrict t3.deleted_at in jd.SyncStoreSkus

Browse Source
This commit is contained in:
gazebo
2019-01-16 17:30:56 +08:00
parent d4328040f8
commit 46c01bdac2
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/partner/purchase/jd/store_sku.go
View File

@@ -40,12 +40,13 @@ func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasks
SELECT t3.jd_id, t1.*, t2.price_percentage, t2.vendor_store_id SELECT t3.jd_id, t1.*, t2.price_percentage, t2.vendor_store_id
FROM store_sku_bind t1 FROM store_sku_bind t1
JOIN store_map t2 ON t1.store_id = t2.store_id AND t2.vendor_id = ? AND t2.deleted_at = ? JOIN store_map t2 ON t1.store_id = t2.store_id AND t2.vendor_id = ? AND t2.deleted_at = ?
JOIN sku t3 ON t1.sku_id = t3.id JOIN sku t3 ON t1.sku_id = t3.id AND t3.deleted_at = ?
` + sqlWhere + " ORDER BY t1.updated_at" ` + sqlWhere + " ORDER BY t1.updated_at"
var storeSkus []*tStoreSkuBindExt var storeSkus []*tStoreSkuBindExt
sqlParams := []interface{}{ sqlParams := []interface{}{
model.VendorIDJD, model.VendorIDJD,
utils.DefaultTimeValue, utils.DefaultTimeValue,
utils.DefaultTimeValue,
} }
db := dao.GetDB() db := dao.GetDB()
if err = dao.GetRows(db, &storeSkus, sql, append(sqlParams, sqlWhereParams...)...); err != nil { if err = dao.GetRows(db, &storeSkus, sql, append(sqlParams, sqlWhereParams...)...); err != nil {