This commit is contained in:
苏尹岚
2021-02-08 16:23:20 +08:00
parent 3afec3e583
commit 0373cebca9

View File

@@ -1869,17 +1869,17 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
}, ctx, task, vendorThingIDs, 50, true) }, ctx, task, vendorThingIDs, 50, true)
var lists []*jdapi.SkuIdEntity var lists []*jdapi.SkuIdEntity
for _, v := range resultList { for _, v := range resultList {
var thingmaps []*model.ThingMap // var thingmaps []*model.ThingMap
sql := ` // sql := `
SELECT * FROM thing_map WHERE vendor_thing_id = ? AND vendor_org_code = ? AND deleted_at = ? // SELECT * FROM thing_map WHERE vendor_thing_id = ? AND vendor_org_code = ? AND deleted_at = ?
` // `
sqlParams := []interface{}{v, 320406, utils.DefaultTimeValue} // sqlParams := []interface{}{v, 320406, utils.DefaultTimeValue}
err = dao.GetRows(db, &thingmaps, sql, sqlParams) // err = dao.GetRows(db, &thingmaps, sql, sqlParams)
for _, vv := range thingmaps { // for _, vv := range thingmaps {
lists = append(lists, &jdapi.SkuIdEntity{ lists = append(lists, &jdapi.SkuIdEntity{
OutSkuId: utils.Int64ToStr(vv.ThingID), OutSkuId: thingIDmap[v.(int64)],
}) })
} // }
} }
FreeBatchInfo2("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []*jdapi.SkuIdEntity) (result interface{}, successCount int, err error) { FreeBatchInfo2("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []*jdapi.SkuIdEntity) (result interface{}, successCount int, err error) {
err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), batchedStoreSkuList) err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), batchedStoreSkuList)