diff --git a/business/jxstore/initdata/temp_op.go b/business/jxstore/initdata/temp_op.go index 650026d2f..7c4c1cdd7 100644 --- a/business/jxstore/initdata/temp_op.go +++ b/business/jxstore/initdata/temp_op.go @@ -232,27 +232,50 @@ func UpdateJdOrderRealMobile(ctx *jxcontext.Context, fromTime, toTime time.Time, } func DeleteWrongSpu(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (hint string, err error) { + // sql := ` + // SELECT t1.* + // FROM sku_name t1 + // JOIN sku_name t2 ON t2.link_id = t1.id AND t2.deleted_at = ? + // WHERE t1.deleted_at = ?; + // ` + // db := dao.GetDB() + // var skuNameList []*model.SkuName + // if err = dao.GetRows(db, &skuNameList, sql, utils.DefaultTimeValue, utils.DefaultTimeValue); err != nil { + // return "", err + // } + // rootTask := tasksch.NewSeqTask("DeleteWrongSpu", ctx.GetUserName(), func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { + // _, err = cms.DeleteSkuName(ctx, skuNameList[step].ID, ctx.GetUserName()) + // if err != nil { + // globals.SugarLogger.Debugf("DeleteWrongSpu failed nameid:%d, name:%s, with error:%v", skuNameList[step].ID, skuNameList[step].Name, err) + // err = nil // 强制忽略错误 + // } + // return nil, err + // }, len(skuNameList)) + sql := ` SELECT t1.* FROM sku_name t1 - JOIN sku_name t2 ON t2.link_id = t1.id AND t2.deleted_at = ? - WHERE t1.deleted_at = ?; + WHERE t1.deleted_at = ? AND t1.is_spu = 1 AND t1.jd_id > 0 + ORDER BY t1.id ` db := dao.GetDB() var skuNameList []*model.SkuName - if err = dao.GetRows(db, &skuNameList, sql, utils.DefaultTimeValue, utils.DefaultTimeValue); err != nil { + if err = dao.GetRows(db, &skuNameList, sql, utils.DefaultTimeValue); err != nil { return "", err } rootTask := tasksch.NewSeqTask("DeleteWrongSpu", ctx.GetUserName(), func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { - _, err = cms.DeleteSkuName(ctx, skuNameList[step].ID, ctx.GetUserName()) + mapData := map[string]interface{}{ + "name": skuNameList[step].Name, + } + _, err = cms.UpdateSkuName(ctx, skuNameList[step].ID, mapData, ctx.GetUserName()) if err != nil { globals.SugarLogger.Debugf("DeleteWrongSpu failed nameid:%d, name:%s, with error:%v", skuNameList[step].ID, skuNameList[step].Name, err) err = nil // 强制忽略错误 } return nil, err }, len(skuNameList)) - tasksch.ManageTask(rootTask).Run() + tasksch.ManageTask(rootTask).Run() if !isAsync { _, err = rootTask.GetResult(0) } else {