This commit is contained in:
richboo111
2023-07-10 14:52:05 +08:00
parent 59c452fe02
commit 49c2e851c6

View File

@@ -295,9 +295,12 @@ func createSkuAct(ctx *jxcontext.Context, parentTask tasksch.ITask, act *model.A
task := tasksch.NewParallelTask("txd createSkuAct", nil, ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
list := batchItemList[0].([]*model.ActStoreSku2)
globals.SugarLogger.Debugf("我在这里4")
failedList, err2 := createOneShopAct(act, list[0].VendorStoreID, list)
globals.SugarLogger.Debugf("我在这里6failedList=%s, err2=%v", utils.Format4Output(failedList, false), err2)
if err = err2; err2 == nil {
if len(failedList) > 0 {
globals.SugarLogger.Debugf("我在这里5")
failedMap := putils.StoreSkuInfoWithErrList2MapBySku(failedList)
list = []*model.ActStoreSku2{}
for _, v := range actStoreSku {