生成门店商品备份表优化

This commit is contained in:
苏尹岚
2020-03-06 17:10:39 +08:00
parent d8696cb7bc
commit 337ea5ce69

View File

@@ -3863,13 +3863,6 @@ 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)
dao.Begin(db)
defer func() {
if r := recover(); r != nil {
dao.Rollback(db)
panic(r)
}
}()
for _, v := range storeSku {
storeSkuBindHis := &model.StoreSkuBindHistory{}
storeSkuBindHis.StoreSkuBind = *v
@@ -3877,7 +3870,6 @@ func BackUpStoreSkuBind(ctx *jxcontext.Context, isAsync, isContinueWhenError boo
storeSkuBindHis.SnapshotAt = snapshotAt
dao.CreateEntity(db, storeSkuBindHis)
}
dao.Commit(db)
return retVal, err
}, storeList)
tasksch.HandleTask(task, nil, true).Run()