1
This commit is contained in:
@@ -252,11 +252,11 @@ func Init() {
|
|||||||
}, 60*time.Second, 30*time.Minute)
|
}, 60*time.Second, 30*time.Minute)
|
||||||
|
|
||||||
// 抖音更新门店商品
|
// 抖音更新门店商品
|
||||||
if beego.BConfig.RunMode != "jxgy" {
|
//if beego.BConfig.RunMode != "jxgy" {
|
||||||
ScheduleTimerFunc("RefreshSyncSkuList", func() {
|
// ScheduleTimerFunc("RefreshSyncSkuList", func() {
|
||||||
syncStoreSkuTiktok()
|
// syncStoreSkuTiktok()
|
||||||
}, []string{"01:25:00"})
|
// }, []string{"01:25:00"})
|
||||||
}
|
//}
|
||||||
|
|
||||||
// 定时任务刷新当前订单的物流信息
|
// 定时任务刷新当前订单的物流信息
|
||||||
ScheduleTimerFunc("RefreshMaterialLogistics", func() {
|
ScheduleTimerFunc("RefreshMaterialLogistics", func() {
|
||||||
@@ -590,7 +590,33 @@ func syncStoreSkuTiktok() {
|
|||||||
if beego.BConfig.RunMode != "jxgy" {
|
if beego.BConfig.RunMode != "jxgy" {
|
||||||
errList.AddErr(cms.DeleteSkuNameExPrefixOverdue(db))
|
errList.AddErr(cms.DeleteSkuNameExPrefixOverdue(db))
|
||||||
errList.AddErr(cms.SetMultiStoreSkuSyncModifyStatus(db, partner.GetMultiStoreVendorIDs()))
|
errList.AddErr(cms.SetMultiStoreSkuSyncModifyStatus(db, partner.GetMultiStoreVendorIDs()))
|
||||||
_, err = cms.CurVendorSync.SyncStoresSkus2(jxcontext.AdminCtx, nil, 0, db, []int{model.VendorIDDD}, []int{}, false, nil, nil, syncFlag, true, true)
|
var storeList2GD = []int{
|
||||||
|
102533,
|
||||||
|
668619,
|
||||||
|
100336,
|
||||||
|
102014,
|
||||||
|
103089,
|
||||||
|
667212,
|
||||||
|
667510,
|
||||||
|
100328,
|
||||||
|
100524,
|
||||||
|
102046,
|
||||||
|
103190,
|
||||||
|
667149,
|
||||||
|
100334,
|
||||||
|
101995,
|
||||||
|
102563,
|
||||||
|
102039,
|
||||||
|
100329,
|
||||||
|
102465,
|
||||||
|
102417,
|
||||||
|
100517,
|
||||||
|
102377,
|
||||||
|
666761,
|
||||||
|
102592,
|
||||||
|
102057,
|
||||||
|
}
|
||||||
|
_, err = cms.CurVendorSync.SyncStoresSkus2(jxcontext.AdminCtx, nil, 0, db, []int{model.VendorIDDD}, storeList2GD, false, nil, nil, syncFlag, true, true)
|
||||||
errList.AddErr(err)
|
errList.AddErr(err)
|
||||||
}
|
}
|
||||||
case 1:
|
case 1:
|
||||||
|
|||||||
@@ -52,7 +52,6 @@ func UpdateThingMap(thingMap *model.ThingMap) error {
|
|||||||
|
|
||||||
// GetThingToTiktokMapList 抖店获取同步类型
|
// GetThingToTiktokMapList 抖店获取同步类型
|
||||||
func GetThingToTiktokMapList(db *DaoDB, vendorId int, thingId int64, vendorOrgCode string) (cats []*model.ThingMap, err error) {
|
func GetThingToTiktokMapList(db *DaoDB, vendorId int, thingId int64, vendorOrgCode string) (cats []*model.ThingMap, err error) {
|
||||||
|
|
||||||
sql := `
|
sql := `
|
||||||
SELECT t1.*
|
SELECT t1.*
|
||||||
FROM thing_map t1
|
FROM thing_map t1
|
||||||
|
|||||||
@@ -442,28 +442,16 @@ func (p *PurchaseHandler) createOrUpdateStoreSkus(ctx *jxcontext.Context, storeI
|
|||||||
func loadMainProductId(api *tiktokShop.API, storeSku *dao.StoreSkuSyncInfo) *product_detail_response.ProductDetailData {
|
func loadMainProductId(api *tiktokShop.API, storeSku *dao.StoreSkuSyncInfo) *product_detail_response.ProductDetailData {
|
||||||
// 这有可能获取的值主商品也有可能是子商品,我们需要的是主商品id和状态
|
// 这有可能获取的值主商品也有可能是子商品,我们需要的是主商品id和状态
|
||||||
var mainOrderDetail = &product_detail_response.ProductDetailData{}
|
var mainOrderDetail = &product_detail_response.ProductDetailData{}
|
||||||
mainOrderDetailSkuId, err := api.GetSkuDetailLocalID("", utils.Int2Str(storeSku.SkuID))
|
if storeSku.VendorMainId == "" {
|
||||||
if err != nil || mainOrderDetailSkuId == nil {
|
|
||||||
mainOrderDetail.MainProductId = 0
|
mainOrderDetail.MainProductId = 0
|
||||||
return mainOrderDetail
|
return mainOrderDetail
|
||||||
}
|
}
|
||||||
if mainOrderDetailSkuId.MainProductId != 0 { // 查询出来是子商品
|
|
||||||
mainOrderDetail.MainProductId = mainOrderDetailSkuId.MainProductId
|
|
||||||
} else { // 查询出来是主商品
|
|
||||||
mainOrderDetail.MainProductId = mainOrderDetailSkuId.ProductId
|
|
||||||
return mainOrderDetail
|
|
||||||
}
|
|
||||||
|
|
||||||
if mainOrderDetail.MainProductId != 0 { // 子商品时,获取主商品id和状态
|
|
||||||
mainOrderDetailProductId, err := api.GetSkuDetail(utils.Int64ToStr(mainOrderDetail.MainProductId), "")
|
mainOrderDetailProductId, err := api.GetSkuDetail(utils.Int64ToStr(mainOrderDetail.MainProductId), "")
|
||||||
if err != nil || mainOrderDetailProductId == nil {
|
if err != nil || mainOrderDetailProductId == nil {
|
||||||
mainOrderDetail.MainProductId = 0
|
mainOrderDetail.MainProductId = 0
|
||||||
return mainOrderDetail
|
return mainOrderDetail
|
||||||
}
|
}
|
||||||
mainOrderDetail.MainProductId = mainOrderDetailProductId.ProductId
|
mainOrderDetail.MainProductId = mainOrderDetailProductId.ProductId
|
||||||
} else {
|
|
||||||
mainOrderDetail.MainProductId = mainOrderDetail.ProductId // 主商品
|
|
||||||
}
|
|
||||||
return mainOrderDetail
|
return mainOrderDetail
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user