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

生成门店商品备份表优化

Browse Source
This commit is contained in:
苏尹岚
2020-03-06 17:06:32 +08:00
parent 8f7a023d89
commit d8696cb7bc
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
business/jxstore/cms/store_sku.go
View File

@@ -3847,9 +3847,8 @@ func getSkuNamePrice(db *dao.DaoDB, skuID int, orgPrice int64) (price int64, nam
func BackUpStoreSkuBind(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (hint string, err error) {
var (
db = dao.GetDB()
storeSkuBinds []*model.StoreSkuBind
snapshotAt = time.Now()
db = dao.GetDB()
snapshotAt = time.Now()
)
storeSkuBindHis := &model.StoreSkuBindHistory{
SnapshotAt: snapshotAt.AddDate(0, 0, -3),
@@ -3860,9 +3859,6 @@ func BackUpStoreSkuBind(ctx *jxcontext.Context, isAsync, isContinueWhenError boo
dao.DeleteEntity(db, storeSkuBindHis, "SnapShotAt")
dao.DeleteEntity(db, storeSkuBindHis2, "SnapShotAt")
storeList, err := dao.GetStoreList(db, nil, nil, nil, nil, "")
sql := `SELECT * FROM store_sku_bind WHERE deleted_at = ?`
sqlParams := []interface{}{utils.DefaultTimeValue}
err = dao.GetRows(db, &storeSkuBinds, sql, sqlParams)
task := tasksch.NewParallelTask("RefreshOrdersPriceInfo", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
store := batchItemList[0].(*model.Store)