取消生成美团店的假商品

This commit is contained in:
gazebo
2019-11-22 17:34:00 +08:00
parent 27a573bd30
commit aaf9e9a183

View File

@@ -1,7 +1,6 @@
package mtwm package mtwm
import ( import (
"fmt"
"regexp" "regexp"
"strings" "strings"
@@ -201,34 +200,34 @@ func (p *PurchaseHandler) IsErrSkuNotExist(err error) (isNotExist bool) {
return mtwmapi.IsErrSkuNotExist(err) return mtwmapi.IsErrSkuNotExist(err)
} }
func duplicateStoreSkuList(storeSkuList []*dao.StoreSkuSyncInfo, index int) (newStoreSkuList []*dao.StoreSkuSyncInfo) { // func duplicateStoreSkuList(storeSkuList []*dao.StoreSkuSyncInfo, index int) (newStoreSkuList []*dao.StoreSkuSyncInfo) {
newStoreSkuList = make([]*dao.StoreSkuSyncInfo, len(storeSkuList)) // newStoreSkuList = make([]*dao.StoreSkuSyncInfo, len(storeSkuList))
for k, v := range storeSkuList { // for k, v := range storeSkuList {
tmp := *v // tmp := *v
tmp.SkuName = fmt.Sprintf("%s.%d", tmp.SkuName, index) // tmp.SkuName = fmt.Sprintf("%s.%d", tmp.SkuName, index)
tmp.SkuID = index*1000000 + tmp.SkuID // tmp.SkuID = index*1000000 + tmp.SkuID
newStoreSkuList[k] = &tmp // newStoreSkuList[k] = &tmp
} // }
return newStoreSkuList // return newStoreSkuList
} // }
func (p *PurchaseHandler) UpdateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (successList []*dao.StoreSkuSyncInfo, err error) { func (p *PurchaseHandler) UpdateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (successList []*dao.StoreSkuSyncInfo, err error) {
successList, err = p.createOrUpdateStoreSkus(ctx, storeID, vendorStoreID, storeSkuList, false) successList, err = p.createOrUpdateStoreSkus(ctx, storeID, vendorStoreID, storeSkuList, false)
if err == nil && vendorStoreID == specialStoreID { // if err == nil && vendorStoreID == specialStoreID {
for i := 0; i < 2; i++ { // for i := 0; i < 2; i++ {
p.createOrUpdateStoreSkus(ctx, storeID, vendorStoreID, duplicateStoreSkuList(storeSkuList, i+1), true) // p.createOrUpdateStoreSkus(ctx, storeID, vendorStoreID, duplicateStoreSkuList(storeSkuList, i+1), true)
} // }
} // }
return successList, err return successList, err
} }
func (p *PurchaseHandler) CreateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (successList []*dao.StoreSkuSyncInfo, err error) { func (p *PurchaseHandler) CreateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (successList []*dao.StoreSkuSyncInfo, err error) {
successList, err = p.createOrUpdateStoreSkus(ctx, storeID, vendorStoreID, storeSkuList, true) successList, err = p.createOrUpdateStoreSkus(ctx, storeID, vendorStoreID, storeSkuList, true)
if err == nil && vendorStoreID == specialStoreID { // if err == nil && vendorStoreID == specialStoreID {
for i := 0; i < 2; i++ { // for i := 0; i < 2; i++ {
p.createOrUpdateStoreSkus(ctx, storeID, vendorStoreID, duplicateStoreSkuList(storeSkuList, i+1), true) // p.createOrUpdateStoreSkus(ctx, storeID, vendorStoreID, duplicateStoreSkuList(storeSkuList, i+1), true)
} // }
} // }
return successList, err return successList, err
} }
@@ -263,7 +262,11 @@ func (p *PurchaseHandler) createOrUpdateStoreSkus(ctx *jxcontext.Context, storeI
} }
foodData["is_sold_out"] = skuStatusJX2Mtwm(storeSku.MergedStatus) foodData["is_sold_out"] = skuStatusJX2Mtwm(storeSku.MergedStatus)
if vendorStoreID == specialStoreID { if vendorStoreID == specialStoreID {
foodData["picture"] = strings.Join(jxutils.BatchString2Slice(storeSku.Img, storeSku.Img, storeSku.Img, storeSku.Img, storeSku.Img), ",") img2 := storeSku.Img2
if img2 == "" {
img2 = storeSku.Img
}
foodData["picture"] = strings.Join(jxutils.BatchString2Slice(storeSku.Img, img2, storeSku.Img, storeSku.Img, storeSku.Img), ",")
} else { } else {
foodData["picture"] = strings.Join(jxutils.BatchString2Slice(storeSku.Img, storeSku.Img2), ",") foodData["picture"] = strings.Join(jxutils.BatchString2Slice(storeSku.Img, storeSku.Img2), ",")
} }