- handle wsc_sync_status in CopyStoreSkus

This commit is contained in:
gazebo
2019-02-21 17:44:56 +08:00
parent 3d338cf441
commit 154f2b4d65

View File

@@ -764,6 +764,7 @@ func CopyStoreSkus(ctx *jxcontext.Context, fromStoreID, toStoreID int, copyMode
t1.unit_price = t1.unit_price * ? / 100, t1.unit_price = t1.unit_price * ? / 100,
t1.jd_sync_status = ?, t1.jd_sync_status = ?,
t1.elm_sync_status = ?, t1.elm_sync_status = ?,
t1.wsc_sync_status = ?,
t1.ebai_sync_status = ? t1.ebai_sync_status = ?
WHERE t1.store_id = ? AND t1.deleted_at = ? WHERE t1.store_id = ? AND t1.deleted_at = ?
` `
@@ -778,6 +779,7 @@ func CopyStoreSkus(ctx *jxcontext.Context, fromStoreID, toStoreID int, copyMode
model.SyncFlagNewMask, model.SyncFlagNewMask,
model.SyncFlagNewMask, model.SyncFlagNewMask,
model.SyncFlagNewMask, model.SyncFlagNewMask,
model.SyncFlagNewMask,
toStoreID, toStoreID,
utils.DefaultTimeValue, utils.DefaultTimeValue,
} }
@@ -805,6 +807,7 @@ func CopyStoreSkus(ctx *jxcontext.Context, fromStoreID, toStoreID int, copyMode
t1.status = ?, t1.status = ?,
t1.jd_sync_status = IF(t1.jd_sync_status = ?, 0, ?), t1.jd_sync_status = IF(t1.jd_sync_status = ?, 0, ?),
t1.elm_sync_status = IF(t1.elm_sync_status = ?, 0, ?), t1.elm_sync_status = IF(t1.elm_sync_status = ?, 0, ?),
t1.wsc_sync_status = IF(t1.wsc_sync_status = ?, 0, ?),
t1.ebai_sync_status = IF(t1.ebai_sync_status = ?, 0, ?) t1.ebai_sync_status = IF(t1.ebai_sync_status = ?, 0, ?)
WHERE t1.store_id = ? AND t1.deleted_at = ? WHERE t1.store_id = ? AND t1.deleted_at = ?
` `
@@ -822,6 +825,8 @@ func CopyStoreSkus(ctx *jxcontext.Context, fromStoreID, toStoreID int, copyMode
model.SyncFlagDeletedMask, model.SyncFlagDeletedMask,
model.SyncFlagNewMask, model.SyncFlagNewMask,
model.SyncFlagDeletedMask, model.SyncFlagDeletedMask,
model.SyncFlagNewMask,
model.SyncFlagDeletedMask,
toStoreID, toStoreID,
utils.DefaultTimeValue, utils.DefaultTimeValue,
} }
@@ -849,6 +854,7 @@ func CopyStoreSkus(ctx *jxcontext.Context, fromStoreID, toStoreID int, copyMode
t1.status = t0.status, t1.status = t0.status,
t1.jd_sync_status = ?, t1.jd_sync_status = ?,
t1.elm_sync_status = ?, t1.elm_sync_status = ?,
t1.wsc_sync_status = ?,
t1.ebai_sync_status = ? t1.ebai_sync_status = ?
WHERE t1.store_id = ? AND (t1.deleted_at = ? OR t1.deleted_at = ?) WHERE t1.store_id = ? AND (t1.deleted_at = ? OR t1.deleted_at = ?)
` `
@@ -866,6 +872,7 @@ func CopyStoreSkus(ctx *jxcontext.Context, fromStoreID, toStoreID int, copyMode
model.SyncFlagNewMask, model.SyncFlagNewMask,
model.SyncFlagNewMask, model.SyncFlagNewMask,
model.SyncFlagNewMask, model.SyncFlagNewMask,
model.SyncFlagNewMask,
toStoreID, toStoreID,
utils.DefaultTimeValue, utils.DefaultTimeValue,
now, now,
@@ -881,7 +888,7 @@ func CopyStoreSkus(ctx *jxcontext.Context, fromStoreID, toStoreID int, copyMode
} }
sql = ` sql = `
INSERT INTO store_sku_bind(created_at, updated_at, last_operator, deleted_at, store_id, sku_id, sub_store_id, price, unit_price, status, jd_sync_status, elm_sync_status, ebai_sync_status) INSERT INTO store_sku_bind(created_at, updated_at, last_operator, deleted_at, store_id, sku_id, sub_store_id, price, unit_price, status, jd_sync_status, elm_sync_status, wsc_sync_status, ebai_sync_status)
SELECT ?, ?, ?, ?, ?, SELECT ?, ?, ?, ?, ?,
t1.sku_id, 0, t1.price * ? / 100, t1.unit_price * ? / 100, t1.status, ?, ?, ? t1.sku_id, 0, t1.price * ? / 100, t1.unit_price * ? / 100, t1.status, ?, ?, ?
FROM store_sku_bind t1 FROM store_sku_bind t1
@@ -898,6 +905,7 @@ func CopyStoreSkus(ctx *jxcontext.Context, fromStoreID, toStoreID int, copyMode
model.SyncFlagNewMask, model.SyncFlagNewMask,
model.SyncFlagNewMask, model.SyncFlagNewMask,
model.SyncFlagNewMask, model.SyncFlagNewMask,
model.SyncFlagNewMask,
utils.DefaultTimeValue, utils.DefaultTimeValue,
utils.DefaultTimeValue, utils.DefaultTimeValue,
utils.DefaultTimeValue, utils.DefaultTimeValue,