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

去掉Sku,SkuName和SkuCategory中的JdID与JdSyncStatus

Browse Source
This commit is contained in:
gazebo
2020-01-02 16:56:06 +08:00
parent c444202330
commit df927137da
6 changed files with 444 additions and 435 deletions
Download Patch File Download Diff File Expand all files Collapse all files

724
business/jxstore/tempop/tempop.go
View File

@@ -6,7 +6,6 @@ import (
"fmt"
"regexp"
"strings"
"sync"
"time"
"git.rosy.net.cn/jx-callback/business/auth2/authprovider/weixin"
@@ -40,252 +39,252 @@ func init() {
}
func Convert2JDSPU(ctx *jxcontext.Context, count int, isAsync, isContinueWhenError bool) (hint string, err error) {
sql := `
SELECT t1.*
FROM sku_name t1
LEFT JOIN sku_name t2 ON t2.link_id = t1.id AND t2.deleted_at = ?
WHERE t1.deleted_at = ? AND t1.status <> ? AND t1.is_spu = 0/* AND t1.unit = '份'*/
AND t2.id IS NULL
ORDER BY t1.id
`
if count > 0 {
sql += " LIMIT " + utils.Int2Str(count)
}
sqlParams := []interface{}{
utils.DefaultTimeValue,
utils.DefaultTimeValue,
model.SkuStatusDeleted,
}
// sql := `
// SELECT t1.*
// FROM sku_name t1
// LEFT JOIN sku_name t2 ON t2.link_id = t1.id AND t2.deleted_at = ?
// WHERE t1.deleted_at = ? AND t1.status <> ? AND t1.is_spu = 0/* AND t1.unit = '份'*/
// AND t2.id IS NULL
// ORDER BY t1.id
// `
// if count > 0 {
// sql += " LIMIT " + utils.Int2Str(count)
// }
// sqlParams := []interface{}{
// utils.DefaultTimeValue,
// utils.DefaultTimeValue,
// model.SkuStatusDeleted,
// }
db := dao.GetDB()
var skuNameList []*model.SkuName
if err = dao.GetRows(db, &skuNameList, sql, sqlParams...); err != nil {
return "", err
}
for _, skuName := range skuNameList {
sql = `
SELECT *
FROM sku
WHERE name_id = ? AND deleted_at = ? AND status = ?;
`
sqlParams := []interface{}{
skuName.ID,
utils.DefaultTimeValue,
model.SkuStatusNormal,
}
var skuList []*model.Sku
if err = dao.GetRows(db, &skuList, sql, sqlParams...); err != nil {
return "", err
}
// db := dao.GetDB()
// var skuNameList []*model.SkuName
// if err = dao.GetRows(db, &skuNameList, sql, sqlParams...); err != nil {
// return "", err
// }
// for _, skuName := range skuNameList {
// sql = `
// SELECT *
// FROM sku
// WHERE name_id = ? AND deleted_at = ? AND status = ?;
// `
// sqlParams := []interface{}{
// skuName.ID,
// utils.DefaultTimeValue,
// model.SkuStatusNormal,
// }
// var skuList []*model.Sku
// if err = dao.GetRows(db, &skuList, sql, sqlParams...); err != nil {
// return "", err
// }
sql = `
SELECT t1.*
FROM sku_name_place_bind t1
WHERE t1.name_id = ?
`
sqlParams = []interface{}{
skuName.ID,
}
var skuNamePlaceBindList []*model.SkuNamePlaceBind
if err = dao.GetRows(db, &skuNamePlaceBindList, sql, sqlParams...); err != nil {
return "", err
}
// sql = `
// SELECT t1.*
// FROM sku_name_place_bind t1
// WHERE t1.name_id = ?
// `
// sqlParams = []interface{}{
// skuName.ID,
// }
// var skuNamePlaceBindList []*model.SkuNamePlaceBind
// if err = dao.GetRows(db, &skuNamePlaceBindList, sql, sqlParams...); err != nil {
// return "", err
// }
globals.SugarLogger.Debugf("Convert2JDSPU, skuName:%s, skuCount:%d", skuName.Name, len(skuList))
dao.Begin(db)
skuNameNew2 := *skuName
skuNameNew := &skuNameNew2
dao.WrapAddIDCULEntity(skuNameNew, ctx.GetUserName())
skuNameNew.JdID = 0
skuNameNew.LinkID = skuName.ID
skuNameNew.IsSpu = 1
skuNameNew.JdSyncStatus = model.SyncFlagNewMask
// skuNameNew.Status = model.SkuStatusDontSale
if err = dao.CreateEntity(db, skuNameNew); err != nil {
dao.Rollback(db)
return "", err
}
if len(skuList) > 0 {
for _, sku := range skuList {
skuNew2 := *sku
skuNew := &skuNew2
dao.WrapAddIDCULEntity(skuNew, ctx.GetUserName())
skuNew.JdID = 0
skuNew.LinkID = sku.ID
skuNew.NameID = skuNameNew.ID
skuNew.JdSyncStatus = model.SyncFlagNewMask
if skuNameNew.Status == model.SkuStatusDontSale {
skuNew.Status = model.SkuStatusDontSale
}
globals.SugarLogger.Debugf("Convert2JDSPU, sku:%s", utils.Format4Output(skuNew, false))
if err = dao.CreateEntity(db, skuNew); err != nil {
dao.Rollback(db)
return "", err
}
}
for _, placeBind := range skuNamePlaceBindList {
dao.WrapAddIDCULEntity(placeBind, ctx.GetUserName())
placeBind.NameID = skuNameNew.ID
globals.SugarLogger.Debugf("Convert2JDSPU, placeBind:%s", utils.Format4Output(placeBind, false))
if err = dao.CreateEntity(db, placeBind); err != nil {
dao.Rollback(db)
return "", err
}
}
}
dao.Commit(db)
}
sql = `
SELECT DISTINCT t1.*
FROM sku_name t1
JOIN sku t2 ON t1.id = t2.name_id AND t2.jd_sync_status <> 0 AND t2.deleted_at = ?
WHERE t1.link_id > 0;
`
skuNameList = []*model.SkuName{}
if err = dao.GetRows(db, &skuNameList, sql, utils.DefaultTimeValue); err != nil {
return "", err
}
rootTask := tasksch.NewParallelTask("Convert2JDSPU", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
skuName := batchItemList[0].(*model.SkuName)
_, err = cms.CurVendorSync.SyncSku(ctx, db, skuName.ID, -1, false, isContinueWhenError, ctx.GetUserName())
return nil, err
}, skuNameList)
tasksch.ManageTask(rootTask).Run()
// globals.SugarLogger.Debugf("Convert2JDSPU, skuName:%s, skuCount:%d", skuName.Name, len(skuList))
// dao.Begin(db)
// skuNameNew2 := *skuName
// skuNameNew := &skuNameNew2
// dao.WrapAddIDCULEntity(skuNameNew, ctx.GetUserName())
// skuNameNew.JdID = 0
// skuNameNew.LinkID = skuName.ID
// skuNameNew.IsSpu = 1
// skuNameNew.JdSyncStatus = model.SyncFlagNewMask
// // skuNameNew.Status = model.SkuStatusDontSale
// if err = dao.CreateEntity(db, skuNameNew); err != nil {
// dao.Rollback(db)
// return "", err
// }
// if len(skuList) > 0 {
// for _, sku := range skuList {
// skuNew2 := *sku
// skuNew := &skuNew2
// dao.WrapAddIDCULEntity(skuNew, ctx.GetUserName())
// skuNew.JdID = 0
// skuNew.LinkID = sku.ID
// skuNew.NameID = skuNameNew.ID
// skuNew.JdSyncStatus = model.SyncFlagNewMask
// if skuNameNew.Status == model.SkuStatusDontSale {
// skuNew.Status = model.SkuStatusDontSale
// }
// globals.SugarLogger.Debugf("Convert2JDSPU, sku:%s", utils.Format4Output(skuNew, false))
// if err = dao.CreateEntity(db, skuNew); err != nil {
// dao.Rollback(db)
// return "", err
// }
// }
// for _, placeBind := range skuNamePlaceBindList {
// dao.WrapAddIDCULEntity(placeBind, ctx.GetUserName())
// placeBind.NameID = skuNameNew.ID
// globals.SugarLogger.Debugf("Convert2JDSPU, placeBind:%s", utils.Format4Output(placeBind, false))
// if err = dao.CreateEntity(db, placeBind); err != nil {
// dao.Rollback(db)
// return "", err
// }
// }
// }
// dao.Commit(db)
// }
// sql = `
// SELECT DISTINCT t1.*
// FROM sku_name t1
// JOIN sku t2 ON t1.id = t2.name_id AND t2.jd_sync_status <> 0 AND t2.deleted_at = ?
// WHERE t1.link_id > 0;
// `
// skuNameList = []*model.SkuName{}
// if err = dao.GetRows(db, &skuNameList, sql, utils.DefaultTimeValue); err != nil {
// return "", err
// }
// rootTask := tasksch.NewParallelTask("Convert2JDSPU", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
// func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// skuName := batchItemList[0].(*model.SkuName)
// _, err = cms.CurVendorSync.SyncSku(ctx, db, skuName.ID, -1, false, isContinueWhenError, ctx.GetUserName())
// return nil, err
// }, skuNameList)
// tasksch.ManageTask(rootTask).Run()
if !isAsync {
_, err = rootTask.GetResult(0)
} else {
hint = rootTask.ID
}
// if !isAsync {
// _, err = rootTask.GetResult(0)
// } else {
// hint = rootTask.ID
// }
return hint, err
}
func Change2JDSPU4Store(ctx *jxcontext.Context, storeIDs []int, step int, isAsync, isContinueWhenError bool) (hint string, err error) {
db := dao.GetDB()
if len(storeIDs) == 0 {
if err = dao.GetRows(db, &storeIDs, `
SELECT t1.id
FROM store t1
JOIN store_map t2 ON t2.store_id = t1.id AND t2.vendor_id = 0 AND t2.deleted_at = ? AND t2.status <> ?
WHERE t1.deleted_at = ? AND t1.status <> ? /* AND t1.city_code IN (110100, 120100, 440100, 440300, 510100)*/
`, utils.DefaultTimeValue, model.StoreStatusDisabled, utils.DefaultTimeValue, model.StoreStatusDisabled); err != nil {
return "", err
}
}
var sql string
var sqlParams []interface{}
// db := dao.GetDB()
// if len(storeIDs) == 0 {
// if err = dao.GetRows(db, &storeIDs, `
// SELECT t1.id
// FROM store t1
// JOIN store_map t2 ON t2.store_id = t1.id AND t2.vendor_id = 0 AND t2.deleted_at = ? AND t2.status <> ?
// WHERE t1.deleted_at = ? AND t1.status <> ? /* AND t1.city_code IN (110100, 120100, 440100, 440300, 510100)*/
// `, utils.DefaultTimeValue, model.StoreStatusDisabled, utils.DefaultTimeValue, model.StoreStatusDisabled); err != nil {
// return "", err
// }
// }
// var sql string
// var sqlParams []interface{}
dao.Begin(db)
defer dao.Rollback(db)
// dao.Begin(db)
// defer dao.Rollback(db)
if step == 1 {
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
}
// if step == 1 {
// 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
`
sqlParams = []interface{}{
ctx.GetUserName(),
utils.DefaultTimeValue,
// model.SkuStatusDontSale,
model.SyncFlagNewMask,
0, //model.SyncFlagNewMask,
0, //model.SyncFlagNewMask,
utils.DefaultTimeValue,
utils.DefaultTimeValue,
}
} else if step == 2 {
sql = `
SELECT COUNT(*) ct
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)
}
ct := 0
if err = dao.GetRow(db, &ct, sql, sqlParams...); err != nil {
return "", err
}
if ct == 0 {
return "", fmt.Errorf("%s看起来还没有执行《将转化的SPU在门店上架》", utils.Format4Output(storeIDs, true))
}
// 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,
// }
// } else if step == 2 {
// sql = `
// SELECT COUNT(*) ct
// 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)
// }
// ct := 0
// if err = dao.GetRow(db, &ct, sql, sqlParams...); err != nil {
// return "", err
// }
// if ct == 0 {
// return "", fmt.Errorf("%s看起来还没有执行《将转化的SPU在门店上架》", utils.Format4Output(storeIDs, true))
// }
sql = `
UPDATE store_sku_bind t1
JOIN sku t2 ON t2.link_id = t1.sku_id
SET t1.status = 0,
t1.jd_sync_status = ?
WHERE t1.deleted_at = ?
`
sqlParams = []interface{}{
model.SyncFlagSaleMask | model.SyncFlagModifiedMask,
utils.DefaultTimeValue,
}
} else {
return "", fmt.Errorf("非法的step")
}
if len(storeIDs) > 0 {
sql += " AND t1.store_id IN (" + dao.GenQuestionMarks(len(storeIDs)) + ")"
sqlParams = append(sqlParams, storeIDs)
}
globals.SugarLogger.Debug(sql)
globals.SugarLogger.Debug(utils.Format4Output(sqlParams, false))
var num int64
if num, err = dao.ExecuteSQL(db, sql, sqlParams...); err != nil {
return "", err
}
globals.SugarLogger.Debug(num)
dao.Commit(db)
// sql = `
// UPDATE store_sku_bind t1
// JOIN sku t2 ON t2.link_id = t1.sku_id
// SET t1.status = 0,
// t1.jd_sync_status = ?
// WHERE t1.deleted_at = ?
// `
// sqlParams = []interface{}{
// model.SyncFlagSaleMask | model.SyncFlagModifiedMask,
// utils.DefaultTimeValue,
// }
// } else {
// return "", fmt.Errorf("非法的step")
// }
// if len(storeIDs) > 0 {
// sql += " AND t1.store_id IN (" + dao.GenQuestionMarks(len(storeIDs)) + ")"
// sqlParams = append(sqlParams, storeIDs)
// }
// globals.SugarLogger.Debug(sql)
// globals.SugarLogger.Debug(utils.Format4Output(sqlParams, false))
// var num int64
// if num, err = dao.ExecuteSQL(db, sql, sqlParams...); err != nil {
// return "", err
// }
// globals.SugarLogger.Debug(num)
// dao.Commit(db)
var skuIDs []int
if step == 1 {
sql = `
SELECT id
FROM sku t1
WHERE t1.link_id > 0 AND t1.deleted_at = ?
`
sqlParams = []interface{}{
utils.DefaultTimeValue,
}
} else if step == 2 {
sql = `
SELECT t1.link_id
FROM sku t1
WHERE t1.link_id > 0 AND t1.deleted_at = ?
`
sqlParams = []interface{}{
utils.DefaultTimeValue,
}
}
if err = dao.GetRows(db, &skuIDs, sql, sqlParams...); err != nil {
return "", err
}
hint, err = cms.CurVendorSync.SyncStoresSkus(ctx, db, []int{model.VendorIDJD}, storeIDs, skuIDs, false, isAsync, isContinueWhenError)
// var skuIDs []int
// if step == 1 {
// sql = `
// SELECT id
// FROM sku t1
// WHERE t1.link_id > 0 AND t1.deleted_at = ?
// `
// sqlParams = []interface{}{
// utils.DefaultTimeValue,
// }
// } else if step == 2 {
// sql = `
// SELECT t1.link_id
// FROM sku t1
// WHERE t1.link_id > 0 AND t1.deleted_at = ?
// `
// sqlParams = []interface{}{
// utils.DefaultTimeValue,
// }
// }
// if err = dao.GetRows(db, &skuIDs, sql, sqlParams...); err != nil {
// return "", err
// }
// hint, err = cms.CurVendorSync.SyncStoresSkus(ctx, db, []int{model.VendorIDJD}, storeIDs, skuIDs, false, isAsync, isContinueWhenError)
return hint, err
}
@@ -600,132 +599,132 @@ type GoodsOrderOriginalEx struct {
}
func TransformJdSpu2Sku(ctx *jxcontext.Context, skuNameIDs []int, count int, isAsync, isContinueWhenError bool) (hint string, err error) {
sql := `
SELECT t1.*
FROM sku_name t1
WHERE t1.deleted_at = ? AND t1.status <> ? AND t1.is_spu = 1 AND jd_id <> 0
`
sqlParams := []interface{}{
utils.DefaultTimeValue,
model.SkuStatusDeleted,
}
if len(skuNameIDs) > 0 {
sql += " AND t1.id IN (" + dao.GenQuestionMarks(len(skuNameIDs)) + ")"
sqlParams = append(sqlParams, skuNameIDs)
}
sql += " ORDER BY t1.id"
if count > 0 {
sql += " LIMIT ?"
sqlParams = append(sqlParams, count)
}
db := dao.GetDB()
var skuNameList []*model.SkuName
if err = dao.GetRows(db, &skuNameList, sql, sqlParams...); err != nil {
return "", err
}
if len(skuNameList) == 0 {
return "", fmt.Errorf("待转换的skuName为空")
}
batchSize := 40
rootTask := tasksch.NewSeqTask2("TransformJdSpu2Sku", ctx, isContinueWhenError,
func(rootTask *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
var (
locker sync.Mutex
skuIDs []int
)
lastIndex := (step + 1) * batchSize
if lastIndex > len(skuNameList) {
lastIndex = len(skuNameList)
}
batchSkNameList := skuNameList[step*batchSize : lastIndex]
subTask := tasksch.NewParallelTask(fmt.Sprintf("TransformJdSpu2Sku:%d", step), tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
func(subTask *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
skuName := batchItemList[0].(*model.SkuName)
if !jxutils.IsEmptyID(skuName.JdID) {
sql = `
SELECT *
FROM sku
WHERE name_id = ? AND deleted_at = ? AND status <> ?;
`
sqlParams := []interface{}{
skuName.ID,
utils.DefaultTimeValue,
model.SkuStatusDeleted,
}
var skuList []*model.Sku
if err = dao.GetRows(db, &skuList, sql, sqlParams...); err != nil {
return "", err
}
globals.SugarLogger.Debugf("TransformJdSpu2Sku skuList:%s", utils.Format4Output(skuList, false))
if len(skuList) > 0 {
for _, sku := range skuList {
locker.Lock()
skuIDs = append(skuIDs, sku.ID)
locker.Unlock()
if !jxutils.IsEmptyID(sku.JdID) {
if globals.EnableJdStoreWrite {
if err = api.JdAPI.UpdateSkuBaseInfo(utils.Int2Str(skuName.ID), utils.Int2Str(sku.ID), utils.Params2Map(jdapi.KeyFixedStatus, jdapi.SkuFixedStatusDeleted)); err != nil {
if errExt, ok := err.(*utils.ErrorWithCode); ok && errExt.IntCode() == 11004 {
err = nil
} else {
break
}
}
}
}
}
}
if err == nil && globals.EnableJdStoreWrite {
if err = api.JdAPI.UpdateSpu(utils.Int2Str(skuName.ID), utils.Params2Map(jdapi.KeyFixedStatus, jdapi.SkuFixedStatusOffline)); err == nil {
err = api.JdAPI.UpdateSpu(utils.Int2Str(skuName.ID), utils.Params2Map(jdapi.KeyFixedStatus, jdapi.SkuFixedStatusDeleted))
} else if errExt, ok := err.(*utils.ErrorWithCode); ok && errExt.IntCode() == 11035 {
err = nil
}
}
if err == nil {
skuName.IsSpu = 0
skuName.JdID = 0
if _, err = dao.UpdateEntity(db, skuName, "IsSpu", "JdID"); err == nil {
sql := `
UPDATE sku t1
SET
t1.jd_sync_status = ?,
t1.jd_id = 0
WHERE t1.name_id = ? AND t1.deleted_at = ? AND t1.status <> ?
`
sqlParams := []interface{}{
model.SyncFlagNewMask,
skuName.ID,
utils.DefaultTimeValue,
model.SkuStatusDeleted,
}
if _, err = dao.ExecuteSQL(db, sql, sqlParams...); err == nil {
_, err = cms.CurVendorSync.SyncSku(ctx, db, skuName.ID, -1, false, isContinueWhenError, ctx.GetUserName())
}
}
}
} else {
globals.SugarLogger.Debugf("TransformJdSpu2Sku skuName:%d is fake", skuName.ID)
}
return nil, err
}, batchSkNameList)
rootTask.AddChild(subTask).Run()
if _, err = subTask.GetResult(0); err == nil {
if len(skuIDs) > 0 {
if _, err = dao.SetStoreSkuSyncStatus(db, model.VendorIDJD, nil, skuIDs, model.SyncFlagStoreSkuModifiedMask); err == nil {
// time.Sleep(20 * time.Second)
// _, err = cms.CurVendorSync.SyncStoresSkus(ctx, db, []int{model.VendorIDJD}, nil, skuIDs, false, isContinueWhenError)
}
}
}
return nil, err
}, (len(skuNameList)-1)/batchSize+1)
tasksch.ManageTask(rootTask).Run()
if !isAsync {
_, err = rootTask.GetResult(0)
} else {
hint = rootTask.ID
}
// sql := `
// SELECT t1.*
// FROM sku_name t1
// WHERE t1.deleted_at = ? AND t1.status <> ? AND t1.is_spu = 1 AND jd_id <> 0
// `
// sqlParams := []interface{}{
// utils.DefaultTimeValue,
// model.SkuStatusDeleted,
// }
// if len(skuNameIDs) > 0 {
// sql += " AND t1.id IN (" + dao.GenQuestionMarks(len(skuNameIDs)) + ")"
// sqlParams = append(sqlParams, skuNameIDs)
// }
// sql += " ORDER BY t1.id"
// if count > 0 {
// sql += " LIMIT ?"
// sqlParams = append(sqlParams, count)
// }
// db := dao.GetDB()
// var skuNameList []*model.SkuName
// if err = dao.GetRows(db, &skuNameList, sql, sqlParams...); err != nil {
// return "", err
// }
// if len(skuNameList) == 0 {
// return "", fmt.Errorf("待转换的skuName为空")
// }
// batchSize := 40
// rootTask := tasksch.NewSeqTask2("TransformJdSpu2Sku", ctx, isContinueWhenError,
// func(rootTask *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
// var (
// locker sync.Mutex
// skuIDs []int
// )
// lastIndex := (step + 1) * batchSize
// if lastIndex > len(skuNameList) {
// lastIndex = len(skuNameList)
// }
// batchSkNameList := skuNameList[step*batchSize : lastIndex]
// subTask := tasksch.NewParallelTask(fmt.Sprintf("TransformJdSpu2Sku:%d", step), tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
// func(subTask *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// skuName := batchItemList[0].(*model.SkuName)
// if !jxutils.IsEmptyID(skuName.JdID) {
// sql = `
// SELECT *
// FROM sku
// WHERE name_id = ? AND deleted_at = ? AND status <> ?;
// `
// sqlParams := []interface{}{
// skuName.ID,
// utils.DefaultTimeValue,
// model.SkuStatusDeleted,
// }
// var skuList []*model.Sku
// if err = dao.GetRows(db, &skuList, sql, sqlParams...); err != nil {
// return "", err
// }
// globals.SugarLogger.Debugf("TransformJdSpu2Sku skuList:%s", utils.Format4Output(skuList, false))
// if len(skuList) > 0 {
// for _, sku := range skuList {
// locker.Lock()
// skuIDs = append(skuIDs, sku.ID)
// locker.Unlock()
// if !jxutils.IsEmptyID(sku.JdID) {
// if globals.EnableJdStoreWrite {
// if err = api.JdAPI.UpdateSkuBaseInfo(utils.Int2Str(skuName.ID), utils.Int2Str(sku.ID), utils.Params2Map(jdapi.KeyFixedStatus, jdapi.SkuFixedStatusDeleted)); err != nil {
// if errExt, ok := err.(*utils.ErrorWithCode); ok && errExt.IntCode() == 11004 {
// err = nil
// } else {
// break
// }
// }
// }
// }
// }
// }
// if err == nil && globals.EnableJdStoreWrite {
// if err = api.JdAPI.UpdateSpu(utils.Int2Str(skuName.ID), utils.Params2Map(jdapi.KeyFixedStatus, jdapi.SkuFixedStatusOffline)); err == nil {
// err = api.JdAPI.UpdateSpu(utils.Int2Str(skuName.ID), utils.Params2Map(jdapi.KeyFixedStatus, jdapi.SkuFixedStatusDeleted))
// } else if errExt, ok := err.(*utils.ErrorWithCode); ok && errExt.IntCode() == 11035 {
// err = nil
// }
// }
// if err == nil {
// skuName.IsSpu = 0
// skuName.JdID = 0
// if _, err = dao.UpdateEntity(db, skuName, "IsSpu", "JdID"); err == nil {
// sql := `
// UPDATE sku t1
// SET
// t1.jd_sync_status = ?,
// t1.jd_id = 0
// WHERE t1.name_id = ? AND t1.deleted_at = ? AND t1.status <> ?
// `
// sqlParams := []interface{}{
// model.SyncFlagNewMask,
// skuName.ID,
// utils.DefaultTimeValue,
// model.SkuStatusDeleted,
// }
// if _, err = dao.ExecuteSQL(db, sql, sqlParams...); err == nil {
// _, err = cms.CurVendorSync.SyncSku(ctx, db, skuName.ID, -1, false, isContinueWhenError, ctx.GetUserName())
// }
// }
// }
// } else {
// globals.SugarLogger.Debugf("TransformJdSpu2Sku skuName:%d is fake", skuName.ID)
// }
// return nil, err
// }, batchSkNameList)
// rootTask.AddChild(subTask).Run()
// if _, err = subTask.GetResult(0); err == nil {
// if len(skuIDs) > 0 {
// if _, err = dao.SetStoreSkuSyncStatus(db, model.VendorIDJD, nil, skuIDs, model.SyncFlagStoreSkuModifiedMask); err == nil {
// // time.Sleep(20 * time.Second)
// // _, err = cms.CurVendorSync.SyncStoresSkus(ctx, db, []int{model.VendorIDJD}, nil, skuIDs, false, isContinueWhenError)
// }
// }
// }
// return nil, err
// }, (len(skuNameList)-1)/batchSize+1)
// tasksch.ManageTask(rootTask).Run()
// if !isAsync {
// _, err = rootTask.GetResult(0)
// } else {
// hint = rootTask.ID
// }
return hint, err
}
@@ -1383,7 +1382,7 @@ func BuildSkuFromEbaiStore(ctx *jxcontext.Context, baiduShopID int64, isAsync, i
Weight: int(utils.Str2Int64(utils.Interface2String(sku["weight"]))),
Status: model.SkuStatusNormal,
LinkID: int(jxutils.StandardPrice2Int(utils.MustInterface2Float64(sku["sale_price"]))), // 临时传递价格用
SkuIndex: int(jxutils.StandardPrice2Int(utils.MustInterface2Float64(sku["sale_price"]))), // 临时传递价格用
},
}
if sku["enabled"].(string) == "0" {
@@ -1449,8 +1448,7 @@ func BuildSkuFromEbaiStore(ctx *jxcontext.Context, baiduShopID int64, isAsync, i
if cat.Name == "进口水果" {
jdCatID = 20342 // 其他进口水果
}
price := sku.LinkID
sku.LinkID = 0
price := sku.SkuIndex
skuName := jxutils.ComposeSkuNameOriginal(skuNameExt.Prefix, skuNameExt.Name, sku.Comment, skuNameExt.Unit, sku.SpecQuality, sku.SpecUnit, jdapi.MaxSkuNameCharCount)
fixedStatus := 1
if sku.Status != model.SkuStatusNormal {