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

- setStoreSkuSyncStatus

Browse Source
This commit is contained in:
gazebo
2018-11-14 15:34:43 +08:00
parent a84286df4f
commit 0f8cb39ac3
1 changed files with 25 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
business/partner/purchase/ebai/store_sku.go
View File

@@ -142,22 +142,24 @@ func (p *PurchaseHandler) FullSyncStoreSkus(ctx *jxcontext.Context, parentTask t
userName := ctx.GetUserName() userName := ctx.GetUserName()
globals.SugarLogger.Debugf("FullSyncStoreSkus storeID:%d, isContinueWhenError:%t, userName:%s", storeID, isContinueWhenError, userName) globals.SugarLogger.Debugf("FullSyncStoreSkus storeID:%d, isContinueWhenError:%t, userName:%s", storeID, isContinueWhenError, userName)
db := dao.GetDB()
rootTask := tasksch.NewSeqTask("FullSyncStoreSkus", userName, func(rootTask *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { rootTask := tasksch.NewSeqTask("FullSyncStoreSkus", userName, func(rootTask *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
switch step { switch step {
case 0: case 0:
err = p.DeleteRemoteSkus(storeID, nil) err = p.DeleteRemoteSkus(storeID, nil)
case 1: case 1:
err = p.DeleteRemoteCategories(storeID, nil) _, err = p.setStoreSkuSyncStatus(ctx, db, storeID, nil, model.SyncFlagNewMask)
case 2: case 2:
db := dao.GetDB() err = p.DeleteRemoteCategories(storeID, nil)
err = p.SyncLocalStoreCategory(db, storeID, userName)
case 3: case 3:
_, err = p.SyncStoreCategory(ctx, rootTask, storeID, false) err = p.SyncLocalStoreCategory(db, storeID, userName)
case 4: case 4:
_, err = p.SyncStoreCategory(ctx, rootTask, storeID, false)
case 5:
_, err = p.SyncStoreSkus(ctx, rootTask, storeID, nil, true, isContinueWhenError) _, err = p.SyncStoreSkus(ctx, rootTask, storeID, nil, true, isContinueWhenError)
} }
return nil, err return nil, err
}, 5) }, 6)
tasksch.AddChild(parentTask, rootTask).Run() tasksch.AddChild(parentTask, rootTask).Run()
if !isAsync { if !isAsync {
_, err = rootTask.GetResult(0) _, err = rootTask.GetResult(0)
@@ -534,6 +536,24 @@ func (p *PurchaseHandler) updateLocalCatAsNew(db *dao.DaoDB, localCatMap map[str
return nil return nil
} }
func (p *PurchaseHandler) setStoreSkuSyncStatus(ctx *jxcontext.Context, db *dao.DaoDB, storeID int, skuIDs []int, syncStatus int) (num int64, err error) {
sql := `
UPDATE store_sku_bind
SET ebai_sync_status = ebai_sync_status | ?
WHERE deleted_at = ? AND store_id = ?
`
sqlParams := []interface{}{
syncStatus,
utils.DefaultTimeValue,
storeID,
}
if len(skuIDs) > 0 {
sql += " AND sku_id IN (" + dao.GenQuestionMarks(len(skuIDs)) + ")"
sqlParams = append(sqlParams, skuIDs)
}
return dao.ExecuteSQL(db, sql, sqlParams...)
}
func formatName(name string) string { func formatName(name string) string {
return utils.TrimBlankChar(utils.FilterMb4(name)) return utils.TrimBlankChar(utils.FilterMb4(name))
} }