生成门店商品备份表优化

This commit is contained in:
苏尹岚
2020-03-06 18:16:30 +08:00
parent 9b42d683bd
commit 0a400582cf
3 changed files with 35 additions and 1 deletions

View File

@@ -3863,14 +3863,16 @@ func BackUpStoreSkuBind(ctx *jxcontext.Context, isAsync, isContinueWhenError boo
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
store := batchItemList[0].(*model.Store)
storeSku, err := dao.GetStoresSkusInfo(db, []int{store.ID}, nil)
var storeSkuBindHiss []*model.StoreSkuBindHistory
for _, v := range storeSku {
storeSkuBindHis := &model.StoreSkuBindHistory{}
storeSkuBindHis.StoreSkuBind = *v
storeSkuBindHis.StoreSkuBindID = v.ID
storeSkuBindHis.StoreSkuBind.ID = 0
storeSkuBindHis.SnapshotAt = utils.Time2Date(snapshotAt)
dao.CreateEntity(db, storeSkuBindHis)
storeSkuBindHiss = append(storeSkuBindHiss, storeSkuBindHis)
}
dao.CreateMultiEntities(db, storeSkuBindHiss)
return retVal, err
}, storeList)
tasksch.HandleTask(task, nil, true).Run()
@@ -3882,3 +3884,8 @@ func BackUpStoreSkuBind(ctx *jxcontext.Context, isAsync, isContinueWhenError boo
}
return hint, err
}
func ReturnStoreSkuBind(ctx *jxcontext.Context, snapshotAt string, storeIDs, skuIDs []int)(err error) {
return err
}