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-07-13 13:48:00 +08:00
parent ad58b41a34
commit 2b61c19346
1 changed files with 57 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

104
business/jxstore/cms/sku.go
View File

@@ -2542,6 +2542,7 @@ func UpdateSkuExinfoMap(ctx *jxcontext.Context, nameIDs []int, imgWaterMark stri
fromTimeP time.Time fromTimeP time.Time
toTimeP time.Time toTimeP time.Time
db = dao.GetDB() db = dao.GetDB()
skuIDs []int
) )
if fromTime != "" { if fromTime != "" {
fromTimeP = utils.Time2Date(utils.Str2Time(fromTime)) fromTimeP = utils.Time2Date(utils.Str2Time(fromTime))
@@ -2552,66 +2553,75 @@ func UpdateSkuExinfoMap(ctx *jxcontext.Context, nameIDs []int, imgWaterMark stri
if toTimeP.Before(fromTimeP) { if toTimeP.Before(fromTimeP) {
return "", fmt.Errorf("结束时间不可以小于开始时间！开始时间：[%v]，结束时间：[%v]", fromTimeP, toTimeP) return "", fmt.Errorf("结束时间不可以小于开始时间！开始时间：[%v]，结束时间：[%v]", fromTimeP, toTimeP)
} }
task := tasksch.NewParallelTask("UpdateSkuExinfoMap", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { switch step {
nameID := batchItemList[0].(int) case 0:
skuEx := &model.SkuExinfoMap{ taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
NameID: nameID, nameID := batchItemList[0].(int)
ImgWatermark: imgWaterMark, skuEx := &model.SkuExinfoMap{
ExPrefix: exPrefix, NameID: nameID,
VendorID: vendorID, ImgWatermark: imgWaterMark,
BeginAt: fromTimeP, ExPrefix: exPrefix,
EndAt: toTimeP, VendorID: vendorID,
} BeginAt: fromTimeP,
dao.WrapAddIDCULDEntity(skuEx, ctx.GetUserName()) EndAt: toTimeP,
skuExs, _ := dao.GetSkuExinfos(db, []int{nameID}, []int{vendorID}, "", utils.ZeroTimeValue, utils.ZeroTimeValue) }
if len(skuExs) > 0 { dao.WrapAddIDCULDEntity(skuEx, ctx.GetUserName())
skuEx2 := skuExs[0] skuExs, _ := dao.GetSkuExinfos(db, []int{nameID}, []int{vendorID}, "", utils.ZeroTimeValue, utils.ZeroTimeValue)
skuEx2.DeletedAt = time.Now() if len(skuExs) > 0 {
skuEx2.LastOperator = ctx.GetUserName() skuEx2 := skuExs[0]
dao.UpdateEntity(db, skuEx2, "DeletedAt", "LastOperator") skuEx2.DeletedAt = time.Now()
dao.CreateEntity(db, skuEx) skuEx2.LastOperator = ctx.GetUserName()
} else { dao.UpdateEntity(db, skuEx2, "DeletedAt", "LastOperator")
dao.CreateEntity(db, skuEx) dao.CreateEntity(db, skuEx)
} } else {
now := utils.Time2Date(time.Now()) dao.CreateEntity(db, skuEx)
if now.Sub(fromTimeP) >= 0 && now.Sub(toTimeP) <= 0 { }
var skuIDs []int now := utils.Time2Date(time.Now())
skuList, err2 := dao.GetSkus(db, nil, []int{nameID}, nil, nil, nil) if now.Sub(fromTimeP) >= 0 && now.Sub(toTimeP) <= 0 {
if err = err2; err == nil { var skuIDs []int
if len(skuList) > 0 { skuList, err2 := dao.GetSkus(db, nil, []int{nameID}, nil, nil, nil)
for _, v := range skuList { if err = err2; err == nil {
skuIDs = append(skuIDs, v.ID) if len(skuList) > 0 {
retVal = []int{v.ID} for _, v := range skuList {
} skuIDs = append(skuIDs, v.ID)
if partner.IsMultiStore(vendorID) { retVal = []int{v.ID}
for _, v := range skuIDs { }
OnUpdateThing(ctx, db, nil, int64(v), model.ThingTypeSku) if partner.IsMultiStore(vendorID) {
for _, v := range skuIDs {
OnUpdateThing(ctx, db, nil, int64(v), model.ThingTypeSku)
}
} }
} }
} }
} }
return retVal, err
} }
return retVal, err taskParallel := tasksch.NewParallelTask("UpdateSkuExinfoMap", tasksch.NewParallelConfig().SetParallelCount(parallelCount), ctx, taskFunc, nameIDs)
}, nameIDs) tasksch.HandleTask(taskParallel, task, true).Run()
tasksch.HandleTask(task, nil, true).Run() result, err2 := task.GetResult(0)
if isAsync { err = err2
hint = task.GetID() if len(result) > 0 {
} else { for _, v := range result {
var skuIDs []int skuIDs = append(skuIDs, int(utils.Interface2Int64WithDefault(v, 0)))
result, err2 := task.GetResult(0) }
err = err2
if len(result) > 0 {
for _, v := range result {
skuIDs = append(skuIDs, int(utils.Interface2Int64WithDefault(v, 0)))
} }
case 1:
if partner.IsMultiStore(vendorID) { if partner.IsMultiStore(vendorID) {
CurVendorSync.SyncSkus(ctx, db, nil, skuIDs, isAsync, isContinueWhenError, ctx.GetUserName()) CurVendorSync.SyncSkus(ctx, db, nil, skuIDs, isAsync, isContinueWhenError, ctx.GetUserName())
} else { } else {
CurVendorSync.SyncStoresSkus2(ctx, nil, 0, db, []int{vendorID}, nil, false, skuIDs, nil, model.SyncFlagModifiedMask, isAsync, isContinueWhenError) CurVendorSync.SyncStoresSkus2(ctx, nil, 0, db, []int{vendorID}, nil, false, skuIDs, nil, model.SyncFlagModifiedMask, isAsync, isContinueWhenError)
} }
} }
return result, err
}
taskSeq := tasksch.NewSeqTask2("更新商品前缀", ctx, isContinueWhenError, taskSeqFunc, 2)
tasksch.HandleTask(taskSeq, nil, true).Run()
if !isAsync {
_, err = taskSeq.GetResult(0)
hint = "1" hint = "1"
} else {
hint = taskSeq.GetID()
} }
return hint, err return hint, err
} }