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

1

Browse Source
This commit is contained in:
邹宗楠
2022-12-15 18:07:47 +08:00
parent 4f55e66ca4
commit 202e2b7cc8
3 changed files with 34 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/jxstore/cms/sync_store_sku.go
View File

@@ -489,8 +489,7 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
now := jxutils.OperationTime2HourMinuteFormat(time.Now()) now := jxutils.OperationTime2HourMinuteFormat(time.Now())
var failedList []*partner.StoreSkuInfoWithErr var failedList []*partner.StoreSkuInfoWithErr
for _, sku := range skus { for _, sku := range skus {
if !useVendorPriceDirectly && if !useVendorPriceDirectly && !isSkuLockTimeValid(sku) {
!isSkuLockTimeValid(sku) {
sku.VendorPrice = 0 sku.VendorPrice = 0
} }
sku.MergedStatus = MergeSkuSaleStatusWithStoreOpTime(sku, storeDetail, now) sku.MergedStatus = MergeSkuSaleStatusWithStoreOpTime(sku, storeDetail, now)

30
business/jxstore/misc/misc.go
View File

@@ -249,6 +249,11 @@ func Init() {
cms.RefreshTiktokShopToken(jxcontext.AdminCtx) cms.RefreshTiktokShopToken(jxcontext.AdminCtx)
}, 60*time.Second, 30*time.Minute) }, 60*time.Second, 30*time.Minute)
// 更新门店商品
ScheduleTimerFuncByInterval(func() {
syncStoreSkuTiktok()
}, 60*time.Second, 1*time.Minute)
// 定时任务刷新当前订单的物流信息 // 定时任务刷新当前订单的物流信息
ScheduleTimerFunc("RefreshMaterialLogistics", func() { ScheduleTimerFunc("RefreshMaterialLogistics", func() {
bidding.LoadingLogistics(nil) bidding.LoadingLogistics(nil)
@@ -568,6 +573,31 @@ func syncStoreSku() {
tasksch.HandleTask(task, nil, true).Run() tasksch.HandleTask(task, nil, true).Run()
} }
func syncStoreSkuTiktok() {
syncFlag := 0 | model.SyncFlagSaleMask
task := tasksch.NewParallelTask("同步京西商品到抖音平台,方案二使用", nil, jxcontext.AdminCtx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
step := batchItemList[0].(int)
errList := errlist.New()
db := dao.GetDB()
switch step {
case 0:
if beego.BConfig.RunMode != "jxgy" {
errList.AddErr(cms.DeleteSkuNameExPrefixOverdue(db))
errList.AddErr(cms.SetMultiStoreSkuSyncModifyStatus(db, partner.GetMultiStoreVendorIDs()))
_, err = cms.CurVendorSync.SyncStoresSkus2(jxcontext.AdminCtx, nil, 0, db, []int{model.VendorIDDD}, nil, false, nil, nil, syncFlag, true, true)
errList.AddErr(err)
}
case 1:
errList.AddErr(err)
SaveImportantTaskID(TaskNameSyncStoreSku, SpecialTaskID)
}
err = errList.GetErrListAsOne()
return retVal, err
}, []int{0, 1})
tasksch.HandleTask(task, nil, true).Run()
}
func doDailyWork2() { func doDailyWork2() {
if beego.BConfig.RunMode == "jxgy" { if beego.BConfig.RunMode == "jxgy" {
syncStoreSku() syncStoreSku()

6
business/partner/purchase/tiktok_store/store_sku2_utils.go
View File

@@ -759,7 +759,7 @@ func GetSpecPrices(specs, storeId string, mainSkuId int64, localSku *dao.StoreSk
} }
stock := localSku.Stock stock := localSku.Stock
if localSku.Stock == 0 { if localSku.Stock == 0 {
stock = 9999 stock = 99999
} }
sku.StockNum = stock sku.StockNum = stock
sku.SkuType = 1 sku.SkuType = 1
@@ -785,7 +785,7 @@ func GetSpecPrices(specs, storeId string, mainSkuId int64, localSku *dao.StoreSk
} }
stock := localSku.Stock stock := localSku.Stock
if localSku.Stock == 0 { if localSku.Stock == 0 {
stock = 9999 stock = 99999
} }
sku.StockNum = stock sku.StockNum = stock
sku.SkuType = 1 sku.SkuType = 1
@@ -815,7 +815,7 @@ func GetSpecPrices(specs, storeId string, mainSkuId int64, localSku *dao.StoreSk
} }
stock := localSku.Stock stock := localSku.Stock
if localSku.Stock == 0 { if localSku.Stock == 0 {
stock = 9999 stock = 99999
} }
sku.StockNum = stock sku.StockNum = stock
sku.SkuType = 1 sku.SkuType = 1