From 46c01bdac2d6a1437de5b27ad27ae4eb780fbb92 Mon Sep 17 00:00:00 2001 From: gazebo Date: Wed, 16 Jan 2019 17:30:56 +0800 Subject: [PATCH] - restrict t3.deleted_at in jd.SyncStoreSkus --- business/partner/purchase/jd/store_sku.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/business/partner/purchase/jd/store_sku.go b/business/partner/purchase/jd/store_sku.go index 504fa7b10..cf7010aab 100644 --- a/business/partner/purchase/jd/store_sku.go +++ b/business/partner/purchase/jd/store_sku.go @@ -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 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 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" var storeSkus []*tStoreSkuBindExt sqlParams := []interface{}{ model.VendorIDJD, utils.DefaultTimeValue, + utils.DefaultTimeValue, } db := dao.GetDB() if err = dao.GetRows(db, &storeSkus, sql, append(sqlParams, sqlWhereParams...)...); err != nil {