- set id to 0 when syncStatus is new in dao.SetStoreSkuSyncStatus
This commit is contained in:
@@ -200,12 +200,17 @@ func SetStoreSkuSyncStatus(db *DaoDB, vendorID, storeID int, skuIDs []int, syncS
|
|||||||
sql := fmt.Sprintf(`
|
sql := fmt.Sprintf(`
|
||||||
UPDATE store_sku_bind
|
UPDATE store_sku_bind
|
||||||
SET %s_sync_status = IF(deleted_at = ?, %s_sync_status | ?, 0)
|
SET %s_sync_status = IF(deleted_at = ?, %s_sync_status | ?, 0)
|
||||||
WHERE 1 = 1
|
|
||||||
`, fieldPrefix, fieldPrefix)
|
`, fieldPrefix, fieldPrefix)
|
||||||
sqlParams := []interface{}{
|
sqlParams := []interface{}{
|
||||||
utils.DefaultTimeValue,
|
utils.DefaultTimeValue,
|
||||||
syncStatus,
|
syncStatus,
|
||||||
}
|
}
|
||||||
|
if (syncStatus & model.SyncFlagNewMask) != 0 {
|
||||||
|
sql += fmt.Sprintf(`,
|
||||||
|
%s_id = 0
|
||||||
|
`, fieldPrefix)
|
||||||
|
}
|
||||||
|
sql += " WHERE 1 = 1"
|
||||||
if storeID > 0 {
|
if storeID > 0 {
|
||||||
sql += " AND store_id = ?"
|
sql += " AND store_id = ?"
|
||||||
sqlParams = append(sqlParams, storeID)
|
sqlParams = append(sqlParams, storeID)
|
||||||
|
|||||||
Reference in New Issue
Block a user