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

- 通过同步标识获取门店商品信息时，只针对已创建好，且未删除的商品

Browse Source
This commit is contained in:
gazebo
2019-06-06 15:37:47 +08:00
parent 97ca2034af
commit 8d20e7a3ef
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -222,16 +222,16 @@ func GetStoresSkus(ctx *jxcontext.Context, storeIDs []int, isFocus bool, keyword
} }
sql += " AND ( 1 = 0" sql += " AND ( 1 = 0"
if params["jdSyncStatus"] != nil && realVendorMap[model.VendorIDJD] == 1 { if params["jdSyncStatus"] != nil && realVendorMap[model.VendorIDJD] == 1 {
sql += " OR t4.jd_sync_status & ? <> 0" sql += " OR (t4.jd_sync_status & ? <> 0 AND t4.jd_sync_status & ? = 0)"
sqlParams = append(sqlParams, params["jdSyncStatus"]) sqlParams = append(sqlParams, params["jdSyncStatus"], model.SyncFlagDeletedMask|model.SyncFlagNewMask)
} }
if params["ebaiSyncStatus"] != nil && realVendorMap[model.VendorIDEBAI] == 1 { if params["ebaiSyncStatus"] != nil && realVendorMap[model.VendorIDEBAI] == 1 {
sql += " OR t4.ebai_sync_status & ? <> 0" sql += " OR (t4.ebai_sync_status & ? <> 0 AND t4.ebai_sync_status & ? = 0)"
sqlParams = append(sqlParams, params["ebaiSyncStatus"]) sqlParams = append(sqlParams, params["ebaiSyncStatus"], model.SyncFlagDeletedMask|model.SyncFlagNewMask)
} }
if params["mtwmSyncStatus"] != nil && realVendorMap[model.VendorIDMTWM] == 1 { if params["mtwmSyncStatus"] != nil && realVendorMap[model.VendorIDMTWM] == 1 {
sql += " OR t4.mtwm_sync_status & ? <> 0" sql += " OR (t4.mtwm_sync_status & ? <> 0 AND t4.mtwm_sync_status & ? = 0)"
sqlParams = append(sqlParams, params["mtwmSyncStatus"]) sqlParams = append(sqlParams, params["mtwmSyncStatus"], model.SyncFlagDeletedMask|model.SyncFlagNewMask)
} }
sql += ")" sql += ")"
} }
@@ -468,8 +468,9 @@ func GetStoreAbnormalSkuCount(ctx *jxcontext.Context, storeID, syncStatus int, i
} }
for _, vendorID := range []int{model.VendorIDJD, model.VendorIDEBAI, model.VendorIDMTWM} { for _, vendorID := range []int{model.VendorIDJD, model.VendorIDEBAI, model.VendorIDMTWM} {
if realVendorMap[vendorID] != 0 { if realVendorMap[vendorID] != 0 {
sql += fmt.Sprintf(" OR t1.%s_sync_status & ? <> 0", dao.ConvertDBFieldPrefix(model.VendorNames[vendorID])) prefix := dao.ConvertDBFieldPrefix(model.VendorNames[vendorID])
sqlParams = append(sqlParams, syncStatus) sql += fmt.Sprintf(" OR (t1.%s_sync_status & ? <> 0 AND t1.%s_sync_status & ? = 0)", prefix, prefix)
sqlParams = append(sqlParams, syncStatus, model.SyncFlagDeletedMask|model.SyncFlagNewMask)
} }
} }
sql += ")" sql += ")"