liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
苏尹岚
2021-01-28 14:32:59 +08:00
parent a236f0b14c
commit 8418420928
2 changed files with 32 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

61
business/jxstore/cms/store_sku.go
View File

@@ -1239,37 +1239,40 @@ func updateStoresSkusWithoutSync(ctx *jxcontext.Context, db *dao.DaoDB, storeIDs
} }
//下面这段很难受 //下面这段很难受
{ {
//如果是京东关注，要去建商品 //可售了的才整
list1, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, []int{storeID}, nil, model.StoreStatusAll, 1, "", "", "") if skuBind.Status == model.StoreSkuBindStatusNormal {
//表示这个门店绑定了京东 //如果是京东关注，要去建商品
if len(list1) > 0 { list1, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, []int{storeID}, nil, model.StoreStatusAll, 1, "", "", "")
//thingmap里肯定存在，再判断有没有同步上去 //表示这个门店绑定了京东
thingMaps, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, []int{v.RealSkuID}, []string{list1[0].VendorOrgCode}) if len(list1) > 0 {
if len(thingMaps) > 0 { //thingmap里肯定存在，再判断有没有同步上去
//如果平台ID为空（未创建到京东） thingMaps, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, []int{v.RealSkuID}, []string{list1[0].VendorOrgCode})
if thingMaps[0].VendorThingID == "" { if len(thingMaps) > 0 {
//并且同步标志还没有带待创建（因为addskuname现在建到thingmap上不会带待创建标志了） //如果平台ID为空（未创建到京东）
if !model.IsSyncStatusNew(thingMaps[0].SyncStatus) { if thingMaps[0].VendorThingID == "" {
isSyncSkus = true //并且同步标志还没有带待创建（因为addskuname现在建到thingmap上不会带待创建标志了）
appCodeList = append(appCodeList, list1[0].VendorOrgCode) if !model.IsSyncStatusNew(thingMaps[0].SyncStatus) {
OnCreateThing(ctx, db, []*MultiStoreVendorInfo{ isSyncSkus = true
&MultiStoreVendorInfo{ appCodeList = append(appCodeList, list1[0].VendorOrgCode)
VendorID: model.VendorIDJD, OnCreateThing(ctx, db, []*MultiStoreVendorInfo{
OrgCode: list1[0].VendorOrgCode, &MultiStoreVendorInfo{
}, VendorID: model.VendorIDJD,
}, int64(v.RealSkuID), model.ThingTypeSku, model.SyncFlagNewMask) OrgCode: list1[0].VendorOrgCode,
},
}, int64(v.RealSkuID), model.ThingTypeSku, model.SyncFlagNewMask)
}
} }
} else {
//万一不存在
isSyncSkus = true
appCodeList = append(appCodeList, list1[0].VendorOrgCode)
OnCreateThing(ctx, db, []*MultiStoreVendorInfo{
&MultiStoreVendorInfo{
VendorID: model.VendorIDJD,
OrgCode: list1[0].VendorOrgCode,
},
}, int64(v.RealSkuID), model.ThingTypeSku, model.SyncFlagNewMask)
} }
} else {
//万一不存在
isSyncSkus = true
appCodeList = append(appCodeList, list1[0].VendorOrgCode)
OnCreateThing(ctx, db, []*MultiStoreVendorInfo{
&MultiStoreVendorInfo{
VendorID: model.VendorIDJD,
OrgCode: list1[0].VendorOrgCode,
},
}, int64(v.RealSkuID), model.ThingTypeSku, model.SyncFlagNewMask)
} }
} }
} }

1
business/jxstore/cms/sync2.go
View File

@@ -139,7 +139,6 @@ func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int,
globals.SugarLogger.Debugf("SyncSkus vendorIDs:%v, appOrgCodes:%v, nameIDs:%v, skuIDs:%v", vendorIDs, appOrgCodes, nameIDs, skuIDs) globals.SugarLogger.Debugf("SyncSkus vendorIDs:%v, appOrgCodes:%v, nameIDs:%v, skuIDs:%v", vendorIDs, appOrgCodes, nameIDs, skuIDs)
db := dao.GetDB() db := dao.GetDB()
skuList, err := dao.GetSkusWithVendor(db, vendorIDs, appOrgCodes, nameIDs, skuIDs, true) skuList, err := dao.GetSkusWithVendor(db, vendorIDs, appOrgCodes, nameIDs, skuIDs, true)
fmt.Println("1111111111111111111111", utils.Format4Output(skuList, false))
if err == nil && len(skuList) > 0 { if err == nil && len(skuList) > 0 {
// todo 按vendorID orgCode合并操作 // todo 按vendorID orgCode合并操作
task := tasksch.NewParallelTask(fmt.Sprintf("同步商品:%v,%v", nameIDs, skuIDs), tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask(fmt.Sprintf("同步商品:%v,%v", nameIDs, skuIDs), tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,