From 2fa839112e1a7fe6afe4cc3b7a58b918ada6e71d Mon Sep 17 00:00:00 2001
From: gazebo <gazeboxu@gmail.com>
Date: Sat, 5 Jan 2019 17:32:39 +0800
Subject: [PATCH] - test.

---
 business/jxstore/initdata/initdata.go | 87 ++++++++++++++++-----------
 1 file changed, 53 insertions(+), 34 deletions(-)

diff --git a/business/jxstore/initdata/initdata.go b/business/jxstore/initdata/initdata.go
index 0cf0e1ec2..e2afc003b 100644
--- a/business/jxstore/initdata/initdata.go
+++ b/business/jxstore/initdata/initdata.go
@@ -332,39 +332,50 @@ func Change2JDSPU4Store(ctx *jxcontext.Context, storeIDs []int, isAsync, isConti
 	dao.Begin(db)
 	defer dao.Rollback(db)
 
-	sql := `
-	DELETE t1
-	FROM store_sku_bind t1
-	JOIN sku t2 ON t2.id = t1.sku_id AND t2.link_id <> 0
-	WHERE 1 = 1
-	`
-	sqlParams := []interface{}{}
-	if len(storeIDs) > 0 {
-		sql += " AND store_id IN (" + dao.GenQuestionMarks(len(storeIDs)) + ")"
-		sqlParams = append(sqlParams, storeIDs)
-	}
-	if _, err = dao.ExecuteSQL(db, sql, sqlParams...); err != nil {
-		return "", err
-	}
+	// sql := `
+	// DELETE t1
+	// FROM store_sku_bind t1
+	// JOIN sku t2 ON t2.id = t1.sku_id AND t2.link_id <> 0
+	// WHERE 1 = 1
+	// `
+	// sqlParams := []interface{}{}
+	// if len(storeIDs) > 0 {
+	// 	sql += " AND store_id IN (" + dao.GenQuestionMarks(len(storeIDs)) + ")"
+	// 	sqlParams = append(sqlParams, storeIDs)
+	// }
+	// if _, err = dao.ExecuteSQL(db, sql, sqlParams...); err != nil {
+	// 	return "", err
+	// }
 
-	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)
-	SELECT 						NOW(), 		NOW(),		?,				?,		t1.store_id, t2.id, t1.price, t1.unit_price, t1.status , 0, 0, ?, ?, ?
-	FROM store_sku_bind t1
-	JOIN sku t2 ON t2.link_id = t1.sku_id AND t2.deleted_at = ?
-	JOIN store t3 ON t3.id = t1.store_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
-	WHERE t1.deleted_at = ? AND (t4.is_global = 1 OR t5.id IS NOT NULL) AND t1.price > 0
+	// 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)
+	// SELECT 						NOW(), 		NOW(),		?,				?,		t1.store_id, t2.id, t1.price, t1.unit_price, t1.status , 0, 0, ?, ?, ?
+	// FROM store_sku_bind t1
+	// JOIN sku t2 ON t2.link_id = t1.sku_id AND t2.deleted_at = ?
+	// JOIN store t3 ON t3.id = t1.store_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
+	// 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{}{
-		ctx.GetUserName(),
-		utils.DefaultTimeValue,
-		// model.SkuStatusDontSale,
-		model.SyncFlagNewMask,
-		0, //model.SyncFlagNewMask,
-		0, //model.SyncFlagNewMask,
-		utils.DefaultTimeValue,
+	sqlParams := []interface{}{
+		model.SyncFlagSaleMask | model.SyncFlagModifiedMask,
 		utils.DefaultTimeValue,
 	}
 	if len(storeIDs) > 0 {
@@ -381,10 +392,18 @@ func Change2JDSPU4Store(ctx *jxcontext.Context, storeIDs []int, isAsync, isConti
 	dao.Commit(db)
 
 	var skuIDs []int
+	// sql = `
+	// SELECT id
+	// FROM sku
+	// WHERE link_id <> 0 AND deleted_at = ?
+	// `
+	// sqlParams = []interface{}{
+	// 	utils.DefaultTimeValue,
+	// }
 	sql = `
-	SELECT id
-	FROM sku
-	WHERE link_id <> 0 AND deleted_at = ?
+	SELECT t1.link_id
+	FROM sku t1
+	WHERE t1.deleted_at = ?
 	`
 	sqlParams = []interface{}{
 		utils.DefaultTimeValue,