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:16:53 +08:00
parent 8f2970c504
commit de0cc168f3
2 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1248,28 +1248,31 @@ func updateStoresSkusWithoutSync(ctx *jxcontext.Context, db *dao.DaoDB, storeIDs
if thingMaps[0].VendorThingID == "" { if thingMaps[0].VendorThingID == "" {
//并且同步标志还没有带待创建（因为addskuname现在建到thingmap上不会带待创建标志了） //并且同步标志还没有带待创建（因为addskuname现在建到thingmap上不会带待创建标志了）
if !model.IsSyncStatusNew(thingMaps[0].SyncStatus) { if !model.IsSyncStatusNew(thingMaps[0].SyncStatus) {
OnCreateThing(ctx, db, []*MultiStoreVendorInfo{ if err = OnCreateThing(ctx, db, []*MultiStoreVendorInfo{
&MultiStoreVendorInfo{ &MultiStoreVendorInfo{
VendorID: model.VendorIDJD, VendorID: model.VendorIDJD,
OrgCode: list1[0].VendorOrgCode, OrgCode: list1[0].VendorOrgCode,
}, },
}, int64(v.RealSkuID), model.ThingTypeSku, model.SyncFlagNewMask) }, int64(v.RealSkuID), model.ThingTypeSku, model.SyncFlagNewMask); err == nil {
_, err = SyncSkus(ctx, nil, []int{model.VendorIDJD}, []string{list1[0].VendorOrgCode}, nil, []int{v.RealSkuID}, true)
}
} }
} }
} else { } else {
//万一不存在 //万一不存在
OnCreateThing(ctx, db, []*MultiStoreVendorInfo{ if err = OnCreateThing(ctx, db, []*MultiStoreVendorInfo{
&MultiStoreVendorInfo{ &MultiStoreVendorInfo{
VendorID: model.VendorIDJD, VendorID: model.VendorIDJD,
OrgCode: list1[0].VendorOrgCode, OrgCode: list1[0].VendorOrgCode,
}, },
}, int64(v.RealSkuID), model.ThingTypeSku, model.SyncFlagNewMask) }, int64(v.RealSkuID), model.ThingTypeSku, model.SyncFlagNewMask); err == nil {
}
_, err = SyncSkus(ctx, nil, []int{model.VendorIDJD}, []string{list1[0].VendorOrgCode}, nil, []int{v.RealSkuID}, true) _, err = SyncSkus(ctx, nil, []int{model.VendorIDJD}, []string{list1[0].VendorOrgCode}, nil, []int{v.RealSkuID}, true)
} }
} }
} }
} }
}
}
} else { } else {
beforeMsg := *v beforeMsg := *v
skuBind = &v.StoreSkuBind skuBind = &v.StoreSkuBind

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

@@ -139,6 +139,7 @@ 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,