备份门店商品表时容错处理
This commit is contained in:
@@ -3882,7 +3882,9 @@ func BackUpStoreSkuBind(ctx *jxcontext.Context, isAsync, isContinueWhenError boo
|
|||||||
storeSkuBindHis.SnapshotAt = utils.Time2Date(snapshotAt)
|
storeSkuBindHis.SnapshotAt = utils.Time2Date(snapshotAt)
|
||||||
storeSkuBindHiss = append(storeSkuBindHiss, storeSkuBindHis)
|
storeSkuBindHiss = append(storeSkuBindHiss, storeSkuBindHis)
|
||||||
}
|
}
|
||||||
dao.CreateMultiEntities(db, storeSkuBindHiss)
|
if len(storeSkuBindHiss) > 0 {
|
||||||
|
dao.CreateMultiEntities(db, storeSkuBindHiss)
|
||||||
|
}
|
||||||
return retVal, err
|
return retVal, err
|
||||||
}, storeList)
|
}, storeList)
|
||||||
tasksch.HandleTask(task, nil, true).Run()
|
tasksch.HandleTask(task, nil, true).Run()
|
||||||
@@ -3931,7 +3933,9 @@ func ReturnStoreSkuBind(ctx *jxcontext.Context, snapshotAt string, storeIDs, sku
|
|||||||
storeSku.ID = v.StoreSkuBindID
|
storeSku.ID = v.StoreSkuBindID
|
||||||
storeSkus = append(storeSkus, storeSku)
|
storeSkus = append(storeSkus, storeSku)
|
||||||
}
|
}
|
||||||
dao.CreateMultiEntities(db, storeSkus)
|
if len(storeSkus) > 0 {
|
||||||
|
dao.CreateMultiEntities(db, storeSkus)
|
||||||
|
}
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user