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

- test.

Browse Source
This commit is contained in:
gazebo
2019-01-05 17:32:39 +08:00
parent fb575d9b72
commit 2fa839112e
1 changed files with 53 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

87
business/jxstore/initdata/initdata.go
View File

@@ -332,39 +332,50 @@ func Change2JDSPU4Store(ctx *jxcontext.Context, storeIDs []int, isAsync, isConti
dao.Begin(db) dao.Begin(db)
defer dao.Rollback(db) defer dao.Rollback(db)
sql := ` // sql := `
DELETE t1 // DELETE t1
FROM store_sku_bind t1 // FROM store_sku_bind t1
JOIN sku t2 ON t2.id = t1.sku_id AND t2.link_id <> 0 // JOIN sku t2 ON t2.id = t1.sku_id AND t2.link_id <> 0
WHERE 1 = 1 // WHERE 1 = 1
` // `
sqlParams := []interface{}{} // sqlParams := []interface{}{}
if len(storeIDs) > 0 { // if len(storeIDs) > 0 {
sql += " AND store_id IN (" + dao.GenQuestionMarks(len(storeIDs)) + ")" // sql += " AND store_id IN (" + dao.GenQuestionMarks(len(storeIDs)) + ")"
sqlParams = append(sqlParams, storeIDs) // sqlParams = append(sqlParams, storeIDs)
} // }
if _, err = dao.ExecuteSQL(db, sql, sqlParams...); err != nil { // if _, err = dao.ExecuteSQL(db, sql, sqlParams...); err != nil {
return "", err // return "", err
} // }
sql = ` // sql = `
INSERT INTO store_sku_bind(created_at, updated_at, last_operator, deleted_at, store_id, sku_id, price, unit_price, status, ebai_id, mtwm_id, jd_sync_status, ebai_sync_status, mtwm_sync_status) // INSERT INTO store_sku_bind(created_at, updated_at, last_operator, deleted_at, store_id, sku_id, price, unit_price, status, ebai_id, mtwm_id, jd_sync_status, ebai_sync_status, mtwm_sync_status)
SELECT NOW(), NOW(), ?, ?, t1.store_id, t2.id, t1.price, t1.unit_price, t1.status , 0, 0, ?, ?, ? // SELECT NOW(), NOW(), ?, ?, t1.store_id, t2.id, t1.price, t1.unit_price, t1.status , 0, 0, ?, ?, ?
FROM store_sku_bind t1 // FROM store_sku_bind t1
JOIN sku t2 ON t2.link_id = t1.sku_id AND t2.deleted_at = ? // JOIN sku t2 ON t2.link_id = t1.sku_id AND t2.deleted_at = ?
JOIN store t3 ON t3.id = t1.store_id // JOIN store t3 ON t3.id = t1.store_id
JOIN sku_name t4 ON t4.id = t2.name_id // JOIN sku_name t4 ON t4.id = t2.name_id
LEFT JOIN sku_name_place_bind t5 ON t5.place_code = t3.city_code AND t5.name_id = t4.id // LEFT JOIN sku_name_place_bind t5 ON t5.place_code = t3.city_code AND t5.name_id = t4.id
WHERE t1.deleted_at = ? AND (t4.is_global = 1 OR t5.id IS NOT NULL) AND t1.price > 0 // WHERE t1.deleted_at = ? AND (t4.is_global = 1 OR t5.id IS NOT NULL) AND t1.price > 0
// `
// sqlParams = []interface{}{
// ctx.GetUserName(),
// utils.DefaultTimeValue,
// // model.SkuStatusDontSale,
// model.SyncFlagNewMask,
// 0, //model.SyncFlagNewMask,
// 0, //model.SyncFlagNewMask,
// utils.DefaultTimeValue,
// utils.DefaultTimeValue,
// }
sql := `
UPDATE store_sku_bind t1
JOIN sku t2 ON t2.link_id = t1.sku_id
SET t1.status = 0,
jd_sync_status = ?,
WHERE t1.deleted_at = ?
` `
sqlParams = []interface{}{ sqlParams := []interface{}{
ctx.GetUserName(), model.SyncFlagSaleMask | model.SyncFlagModifiedMask,
utils.DefaultTimeValue,
// model.SkuStatusDontSale,
model.SyncFlagNewMask,
0, //model.SyncFlagNewMask,
0, //model.SyncFlagNewMask,
utils.DefaultTimeValue,
utils.DefaultTimeValue, utils.DefaultTimeValue,
} }
if len(storeIDs) > 0 { if len(storeIDs) > 0 {
@@ -381,10 +392,18 @@ func Change2JDSPU4Store(ctx *jxcontext.Context, storeIDs []int, isAsync, isConti
dao.Commit(db) dao.Commit(db)
var skuIDs []int var skuIDs []int
// sql = `
// SELECT id
// FROM sku
// WHERE link_id <> 0 AND deleted_at = ?
// `
// sqlParams = []interface{}{
// utils.DefaultTimeValue,
// }
sql = ` sql = `
SELECT id SELECT t1.link_id
FROM sku FROM sku t1
WHERE link_id <> 0 AND deleted_at = ? WHERE t1.deleted_at = ?
` `
sqlParams = []interface{}{ sqlParams = []interface{}{
utils.DefaultTimeValue, utils.DefaultTimeValue,