京东创建商品over?
This commit is contained in:
@@ -501,6 +501,8 @@ func GetStoreSkus2(db *DaoDB, vendorID, storeID int, skuIDs []int, mustDirty boo
|
|||||||
sql = fmt.Sprintf(sql, fmtParams...)
|
sql = fmt.Sprintf(sql, fmtParams...)
|
||||||
sql += " ORDER BY t1.price"
|
sql += " ORDER BY t1.price"
|
||||||
// globals.SugarLogger.Debug(sql)
|
// globals.SugarLogger.Debug(sql)
|
||||||
|
fmt.Println(sql)
|
||||||
|
fmt.Println(sqlParams)
|
||||||
if err = GetRows(db, &skus, sql, sqlParams...); err != nil {
|
if err = GetRows(db, &skus, sql, sqlParams...); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -26,36 +26,36 @@ var (
|
|||||||
func (p *PurchaseHandler) CreateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (failedList []*partner.StoreSkuInfoWithErr, err error) {
|
func (p *PurchaseHandler) CreateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (failedList []*partner.StoreSkuInfoWithErr, err error) {
|
||||||
if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
|
if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
|
||||||
for _, v := range storeSkuList {
|
for _, v := range storeSkuList {
|
||||||
createSkuParamWare, createSkuParamSkus, err := buildCreateWareParam(v)
|
_, _, err := buildCreateWareParam(v)
|
||||||
if err != nil {
|
// if err != nil {
|
||||||
failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "创建商品")
|
// failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "创建商品")
|
||||||
return failedList, err
|
// return failedList, err
|
||||||
}
|
// }
|
||||||
createSkuResult, err := api.JdShopAPI.CreateWare(createSkuParamWare, createSkuParamSkus)
|
// createSkuResult, err := api.JdShopAPI.CreateWare(createSkuParamWare, createSkuParamSkus)
|
||||||
if err != nil {
|
// if err != nil {
|
||||||
failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "创建商品")
|
// failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "创建商品")
|
||||||
return failedList, err
|
// return failedList, err
|
||||||
}
|
// }
|
||||||
var paramAttrs = make(map[string]*jdshopapi.CreateSkuParamSkus)
|
// var paramAttrs = make(map[string]*jdshopapi.CreateSkuParamSkus)
|
||||||
var resultAttrs = make(map[string]int64)
|
// var resultAttrs = make(map[string]int64)
|
||||||
for _, vv := range createSkuParamSkus {
|
// for _, vv := range createSkuParamSkus {
|
||||||
for _, vvv := range vv.SaleAttrs {
|
// for _, vvv := range vv.SaleAttrs {
|
||||||
paramAttrs[vvv.AttrValues[0]] = vv
|
// paramAttrs[vvv.AttrValues[0]] = vv
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
for _, vv1 := range createSkuResult.Skus {
|
// for _, vv1 := range createSkuResult.Skus {
|
||||||
for _, vvv1 := range vv1.SaleAttrs {
|
// for _, vvv1 := range vv1.SaleAttrs {
|
||||||
if paramAttrs[vvv1.AttrValues[0]] != nil {
|
// if paramAttrs[vvv1.AttrValues[0]] != nil {
|
||||||
resultAttrs[paramAttrs[vvv1.AttrValues[0]].OuterID] = vv1.SkuID
|
// resultAttrs[paramAttrs[vvv1.AttrValues[0]].OuterID] = vv1.SkuID
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
for _, vv2 := range v.StoreSkuSyncInfoJds {
|
// for _, vv2 := range v.StoreSkuSyncInfoJds {
|
||||||
vv2.JdsWareID = createSkuResult.WareID
|
// vv2.JdsWareID = createSkuResult.WareID
|
||||||
if resultAttrs[utils.Int2Str(vv2.SkuID)] != 0 {
|
// if resultAttrs[utils.Int2Str(vv2.SkuID)] != 0 {
|
||||||
vv2.VendorSkuID = utils.Int64ToStr(resultAttrs[utils.Int2Str(vv2.SkuID)])
|
// vv2.VendorSkuID = utils.Int64ToStr(resultAttrs[utils.Int2Str(vv2.SkuID)])
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return failedList, err
|
return failedList, err
|
||||||
@@ -348,7 +348,7 @@ func buildCreateWareParam(storeSku *dao.StoreSkuSyncInfo) (createSkuParamWare *j
|
|||||||
err = err2
|
err = err2
|
||||||
desc = `<p>` + jdshopapi.JdsImgDescURL + `<img src="` + jdshopapi.JdsImgURL + pic3 + `" style="width: auto; height: auto; max-width: 100%;"><br></p><p><br></p>`
|
desc = `<p>` + jdshopapi.JdsImgDescURL + `<img src="` + jdshopapi.JdsImgURL + pic3 + `" style="width: auto; height: auto; max-width: 100%;"><br></p><p><br></p>`
|
||||||
} else {
|
} else {
|
||||||
desc = `<p>` + jdshopapi.JdsImgDescURL + `" style="width: auto; height: auto; max-width: 100%;"><br></p><p><br></p>`
|
desc = `<p>` + jdshopapi.JdsImgDescURL + `<br></p><p><br></p>`
|
||||||
}
|
}
|
||||||
createSkuParamWare.MobileDesc = desc
|
createSkuParamWare.MobileDesc = desc
|
||||||
createSkuParamWare.Introduction = desc
|
createSkuParamWare.Introduction = desc
|
||||||
|
|||||||
Reference in New Issue
Block a user